Function stopActiveWork

src/renderer/src/services/switchTransactionService.ts:33–50

()

}

async function stopActiveWork(): Promise<void> {
  const stopped = await streamingManager.stopAll()
  const currentContext = persistence.database.getActiveContext()
  if (currentContext.accountId && currentContext.workspacePath) {
    for (const item of stopped) {
      if (item.content) {
        await messagesService.updateMessage(item.pageId, item.messageId, {
          content: item.content,
          reasoning_content: item.reasoning
        })
      } else {
        await messagesService.deleteMessage(item.pageId, item.messageId)
      }
    }
  }
  streamingManager.reset()
  await flushAllPersistenceQueues()
}

async function waitForScopedWrites(scope: WorkspaceScope | null): Promise<void> {
  const context = persistence.database.getActiveContext()