Function dequeueComposerPrompt

desktop/runtime-host/live-runtime-service.ts:566–617

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

}

export async function dequeueComposerPrompt(
  request: ComposerStateRequest & {
    queueId: string
    queueSnapshotKey: string
    queueMode: Exclude<ComposerStreamingBehavior, 'stop'>
  },
) {
  const persistedSessionPath = getPersistedSessionPath(request.sessionPath)
  if (!persistedSessionPath) return null
  return await withRuntimeMutationLock(persistedSessionPath, async () => {
    await reloadRuntimeSettingsIfSafe(persistedSessionPath, { useMutationLock: false })
    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 {
      scheduleRuntimeDisposal(persistedSessionPath)
    }
  })
}

export async function answerNativeAskQuestions(
  request: ComposerStateRequest & { requestId: string; answers: string[][] | null },