tldraw/apps/www/pages/api/create.ts

73 lines
1.9 KiB
TypeScript
Raw Normal View History

2022-05-19 10:45:59 +00:00
import { Utils } from '@tldraw/core'
import { TDDocument } from '@tldraw/tldraw'
import { NextApiRequest, NextApiResponse } from 'next'
2022-05-19 10:45:59 +00:00
type RequestBody = {
pageId: string
document: TDDocument
}
2022-05-19 10:45:59 +00:00
export default async function CreateMultiplayerRoom(req: NextApiRequest, res: NextApiResponse) {
try {
2022-05-19 10:45:59 +00:00
// 1. Get an authentication token from Liveblocks
const { token } = await fetch('https://liveblocks.io/api/authorize', {
headers: {
Authorization: `Bearer ${process.env.LIVEBLOCKS_SECRET_KEY}`,
'Content-Type': 'application/json',
},
}).then((d) => d.json())
2022-05-19 10:45:59 +00:00
// 2. Create the Liveblocks storage JSON
2022-05-19 10:45:59 +00:00
const { pageId, document } = JSON.parse(req.body) as RequestBody
const storageJson = {
liveblocksType: 'LiveObject',
data: {
version: 2.1,
shapes: {
liveblocksType: 'LiveMap',
data: {},
},
bindings: {
liveblocksType: 'LiveMap',
data: {},
},
assets: {
liveblocksType: 'LiveMap',
data: {},
},
},
}
2022-05-19 10:45:59 +00:00
const page = document.pages[pageId]
2022-05-19 10:45:59 +00:00
storageJson.data.shapes.data = page.shapes ?? {}
storageJson.data.bindings.data = page.bindings ?? {}
storageJson.data.assets.data = document.assets ?? {}
// 3. Post the JSON and token to Liveblocks
2022-05-19 10:45:59 +00:00
const roomId = Utils.uniqueId()
const result = await fetch(`https://liveblocks.net/api/v1/room/${roomId}/storage`, {
method: 'POST',
2022-05-19 10:45:59 +00:00
body: JSON.stringify(storageJson),
headers: {
2022-05-19 10:45:59 +00:00
Authorization: `Bearer ${token}`,
'Content-Type': 'application/json',
},
})
if (result.status === 200) {
2022-05-19 11:03:06 +00:00
// If success, send back the url for the new multiplayer project
2022-05-19 10:45:59 +00:00
res.send({ status: 'success', message: result.statusText, url: '/r/' + roomId })
} else {
2022-05-19 10:45:59 +00:00
throw Error(result.statusText)
}
} catch (e) {
res.send({ status: 'error', message: e.message })
}
}