Function callbackHandler

packages/yjs-websocket/src/server/callback.ts:12–32

(doc: WSSharedDoc, options: CallbackOptions)

}

const callbackHandler = (doc: WSSharedDoc, options: CallbackOptions) => {
  const { action, timeout = 5000, objects = {} } = options
  const room = doc.name
  const dataToSend: Record<string, any> = {
    room,
    data: {},
  }
  const sharedObjectList = Object.keys(objects)
  sharedObjectList.forEach(sharedObjectName => {
    const sharedObjectType = objects[sharedObjectName]
    dataToSend.data[sharedObjectName] = {
      type: sharedObjectType,
      content: getContent(sharedObjectName, sharedObjectType, doc)?.toJSON() || {},
    }
  })
  if (typeof action === 'function') {
    action(dataToSend)
  } else {
    callbackRequest(action, timeout, dataToSend)
  }
}

const callbackRequest = (url: URL, timeout: number, data: any) => {
  data = JSON.stringify(data)