Function dequeueComposerPrompt

desktop/runtime/composer-service.ts:488–547

(
  request: ComposerStateRequest & {
    queueId: string
    queueSnapshotKey: string
    queueMode: Exclude<ComposerStreamingBehavior, 'stop'>
  },
)

}

export async function dequeueComposerPrompt(
  request: ComposerStateRequest & {
    queueId: string
    queueSnapshotKey: string
    queueMode: Exclude<ComposerStreamingBehavior, 'stop'>
  },
): Promise<string | null> {
  const persistedSessionPath = getPersistedSessionPath(request.sessionPath)
  if (!persistedSessionPath) {
    return null
  }

  return await withRuntimeMutationLock(persistedSessionPath, async () => {
    const runtime = await getOrCreateRuntimeForSessionPath(persistedSessionPath, {
      suspendDisposal: true,
      settingsCwd: request.composerSessionDir ?? null,
      chatGroupId: request.chatGroupId ?? null,
    })

    try {
      const currentQueueSnapshot = {
        steering: [...runtime.session.getSteeringMessages()],
        followUp: [...runtime.session.getFollowUpMessages()],
      }

      if (buildComposerQueueSnapshotKey(currentQueueSnapshot) !== request.queueSnapshotKey) {
        await emitComposerUpdate({ ...request, sessionPath: persistedSessionPath })
        return null
      }

      const currentQueue =
        request.queueMode === 'steer'
          ? currentQueueSnapshot.steering
          : currentQueueSnapshot.followUp
      if (findQueuedPromptIndexById(request.queueMode, currentQueue, request.queueId) === null) {
        await emitComposerUpdate({ ...request, sessionPath: persistedSessionPath })
        return null
      }

      const clearedQueue = runtime.session.clearQueue()
      const dequeueResult = removeQueuedPromptById(clearedQueue, request.queueMode, request.queueId)

      if (!dequeueResult) {
        await replayComposerQueue(runtime.session, clearedQueue)
        await emitComposerUpdate({ ...request, sessionPath: persistedSessionPath })
        return null
      }

      return await replayDequeuedComposerQueue({
        clearedQueue,
        dequeueResult,
        request,
        runtime,
        sessionPath: persistedSessionPath,
      })
    } finally {
      scheduleRuntimeDisposalForRuntime(runtime)
    }