Function getPageFileQueue

src/renderer/src/stores/persistenceQueue.ts:301–329

(scope: WorkspaceScope)

}

function getPageFileQueue(scope: WorkspaceScope): PersistenceQueue<string, PageFileMutation> {
  return getOrCreateQueue(workspaceQueueId(scope, 'page-file'), () =>
    createPersistenceQueue<string, PageFileMutation>(
      async (pageId, mutation) => {
        if (mutation.deletePage) {
          await persistence.workspace(scope).pages.deleteWithMessages(pageId)
          return
        }

        if (mutation.page) {
          await flushQueue(getFoldersQueue(scope))
          await persistence.workspace(scope).pages.put(mutation.page)
        }

        if (mutation.messages !== undefined) {
          if (mutation.messages === null) {
            await persistence.workspace(scope).messages.delete(pageId)
          } else {
            await persistence.workspace(scope).messages.put(pageId, mutation.messages)
          }
        }
      },
      {
        ...DEFAULT_QUEUE_OPTIONS,
        mergePending: mergePageFileMutation
      }
    )
  )
}

export function queueFoldersSnapshot(scope: WorkspaceScope, folders: PageFolder[]): void {
  getFoldersQueue(scope).enqueue('folders', folders)