Files
hermes-web-ui/tests/server/sessions-controller.test.ts
牧濑红莉栖(BOT) 0bfa9d2ed4 fix(coding-agent): 持久化会话 API 模式 (#1944)
* fix(coding-agent): persist API mode per session

* docs(chat-chain): document coding agent API mode persistence

---------

Co-authored-by: x1051445024 <你的GitHub注册邮箱>
2026-07-06 08:17:49 +08:00

1603 lines
60 KiB
TypeScript

import { beforeEach, describe, expect, it, vi } from 'vitest'
import { mkdir, mkdtemp, rm, symlink } from 'fs/promises'
import { tmpdir } from 'os'
import { join } from 'path'
const listConversationSummariesFromDbMock = vi.fn()
const getConversationDetailFromDbMock = vi.fn()
const listConversationSummariesMock = vi.fn()
const getConversationDetailMock = vi.fn()
const listSessionSummariesMock = vi.fn()
const getSessionDetailFromDbMock = vi.fn()
const getSessionDetailFromDbWithProfileMock = vi.fn()
const getExactSessionDetailFromDbWithProfileMock = vi.fn()
const getUsageStatsFromDbMock = vi.fn()
const getSessionMock = vi.fn()
const deleteHermesSessionForProfileMock = vi.fn()
const localListSessionsMock = vi.fn()
const localGetSessionDetailMock = vi.fn()
const localSearchSessionsMock = vi.fn()
const localDeleteSessionMock = vi.fn()
const localRenameSessionMock = vi.fn()
const localSetSessionArchivedMock = vi.fn()
const localCreateSessionMock = vi.fn()
const localUpdateSessionMock = vi.fn()
const localAddMessagesMock = vi.fn()
const localUpdateSessionStatsMock = vi.fn()
const getGroupChatServerMock = vi.fn()
const getLocalUsageStatsMock = vi.fn()
const getActiveProfileNameMock = vi.fn()
const loggerWarnMock = vi.fn()
const getCompressionSnapshotMock = vi.fn()
const listUserProfilesMock = vi.fn()
const readConfigYamlForProfileMock = vi.fn()
const bridgeSwitchSessionModelMock = vi.fn()
const bridgeGetRuntimeStateMock = vi.fn()
const codingAgentRunManagerMock = vi.hoisted(() => ({
stop: vi.fn(),
}))
vi.mock('../../packages/server/src/db/hermes/conversations-db', () => ({
listConversationSummariesFromDb: listConversationSummariesFromDbMock,
getConversationDetailFromDb: getConversationDetailFromDbMock,
}))
vi.mock('../../packages/server/src/services/hermes/conversations', () => ({
listConversationSummaries: listConversationSummariesMock,
getConversationDetail: getConversationDetailMock,
}))
vi.mock('../../packages/server/src/services/logger', () => ({
logger: {
warn: loggerWarnMock,
error: vi.fn(),
},
}))
vi.mock('../../packages/server/src/services/hermes/hermes-cli', () => ({
listSessions: vi.fn(),
getSession: getSessionMock,
deleteSession: vi.fn(),
deleteSessionForProfile: deleteHermesSessionForProfileMock,
renameSession: vi.fn(),
}))
vi.mock('../../packages/server/src/db/hermes/sessions-db', () => ({
listSessionSummaries: listSessionSummariesMock,
searchSessionSummaries: vi.fn(),
getSessionDetailFromDb: getSessionDetailFromDbMock,
getSessionDetailFromDbWithProfile: getSessionDetailFromDbWithProfileMock,
getExactSessionDetailFromDbWithProfile: getExactSessionDetailFromDbWithProfileMock,
getUsageStatsFromDb: getUsageStatsFromDbMock,
}))
vi.mock('../../packages/server/src/db/hermes/session-store', () => ({
listSessions: localListSessionsMock,
searchSessions: localSearchSessionsMock,
getSessionDetail: localGetSessionDetailMock,
deleteSession: localDeleteSessionMock,
renameSession: localRenameSessionMock,
setSessionArchived: localSetSessionArchivedMock,
createSession: localCreateSessionMock,
addMessages: localAddMessagesMock,
getSession: getSessionMock,
updateSession: localUpdateSessionMock,
updateSessionStats: localUpdateSessionStatsMock,
}))
vi.mock('../../packages/server/src/db/hermes/users-store', () => ({
listUserProfiles: listUserProfilesMock,
}))
vi.mock('../../packages/server/src/db/hermes/usage-store', () => ({
deleteUsage: vi.fn(),
getUsage: vi.fn(),
getUsageBatch: vi.fn(),
getLocalUsageStats: getLocalUsageStatsMock,
}))
vi.mock('../../packages/server/src/routes/hermes/group-chat', () => ({
getGroupChatServer: getGroupChatServerMock,
}))
vi.mock('../../packages/server/src/services/hermes/model-context', () => ({
getModelContextLength: vi.fn(),
}))
vi.mock('../../packages/server/src/services/hermes/hermes-profile', () => ({
getActiveProfileName: getActiveProfileNameMock,
getActiveProfileDir: () => '/tmp/hermes-test/default',
getProfileDir: (name: string) => `/tmp/hermes-test/${name || 'default'}`,
listProfileNamesFromDisk: () => ['default', 'travel'],
}))
vi.mock('../../packages/server/src/services/hermes/agent-bridge', () => ({
AgentBridgeClient: vi.fn().mockImplementation(() => ({
switchSessionModel: bridgeSwitchSessionModelMock,
})),
getAgentBridgeManager: vi.fn(() => ({
getRuntimeState: bridgeGetRuntimeStateMock,
})),
}))
vi.mock('../../packages/server/src/services/config-helpers', () => ({
readConfigYamlForProfile: readConfigYamlForProfileMock,
}))
vi.mock('../../packages/server/src/services/agent-runner/coding-agent-run-manager', () => ({
codingAgentRunManager: codingAgentRunManagerMock,
}))
vi.mock('../../packages/server/src/db/hermes/compression-snapshot', () => ({
getCompressionSnapshot: getCompressionSnapshotMock,
}))
vi.mock('../../packages/server/src/lib/context-compressor/export-compressor', () => ({
ExportCompressor: class {
async compress(messages: any[]) {
return {
messages,
meta: { totalMessages: messages.length, compressed: true, llmCompressed: true, summaryTokenEstimate: 100, verbatimCount: 0, compressedStartIndex: -1 },
}
}
},
}))
describe('session conversations controller', () => {
beforeEach(() => {
vi.resetModules()
listConversationSummariesFromDbMock.mockReset()
getConversationDetailFromDbMock.mockReset()
listConversationSummariesMock.mockReset()
getConversationDetailMock.mockReset()
listSessionSummariesMock.mockReset()
getSessionDetailFromDbMock.mockReset()
getSessionDetailFromDbWithProfileMock.mockReset()
getExactSessionDetailFromDbWithProfileMock.mockReset()
getUsageStatsFromDbMock.mockReset()
getSessionMock.mockReset()
deleteHermesSessionForProfileMock.mockReset()
localListSessionsMock.mockReset()
localGetSessionDetailMock.mockReset()
localSearchSessionsMock.mockReset()
localDeleteSessionMock.mockReset()
localRenameSessionMock.mockReset()
localSetSessionArchivedMock.mockReset()
localCreateSessionMock.mockReset()
localUpdateSessionMock.mockReset()
localAddMessagesMock.mockReset()
localUpdateSessionStatsMock.mockReset()
getGroupChatServerMock.mockReset()
getGroupChatServerMock.mockReturnValue(null)
getLocalUsageStatsMock.mockReset()
getActiveProfileNameMock.mockReset()
getActiveProfileNameMock.mockReturnValue('default')
loggerWarnMock.mockReset()
getCompressionSnapshotMock.mockReset()
listUserProfilesMock.mockReset()
listUserProfilesMock.mockReturnValue([])
readConfigYamlForProfileMock.mockReset()
readConfigYamlForProfileMock.mockResolvedValue({ model: { default: 'gpt-default', provider: 'openai' } })
bridgeSwitchSessionModelMock.mockReset()
bridgeGetRuntimeStateMock.mockReset()
bridgeGetRuntimeStateMock.mockReturnValue({ ready: false, running: false, endpoint: 'ipc:///tmp/hermes-agent-bridge.sock' })
codingAgentRunManagerMock.stop.mockReset()
})
it('lists conversations from the local session store', async () => {
localListSessionsMock.mockReturnValue([{
id: 'local-conversation',
source: 'cli',
model: 'gpt-5',
title: 'Local',
started_at: 1,
ended_at: null,
last_active: Math.floor(Date.now() / 1000),
message_count: 2,
tool_call_count: 0,
input_tokens: 1,
output_tokens: 2,
cache_read_tokens: 0,
cache_write_tokens: 0,
reasoning_tokens: 0,
billing_provider: null,
estimated_cost_usd: 0,
actual_cost_usd: null,
cost_status: '',
preview: 'preview',
workspace: null,
}])
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const ctx: any = { query: { humanOnly: 'true', limit: '5' }, body: null }
await mod.listConversations(ctx)
expect(localListSessionsMock).toHaveBeenCalledWith(undefined, undefined, 5)
expect(listConversationSummariesMock).not.toHaveBeenCalled()
expect(ctx.body.sessions[0]).toMatchObject({ id: 'local-conversation', source: 'cli', title: 'Local' })
})
it('lists Windows drive roots for the workspace folder picker', async () => {
const originalPlatform = process.platform
const originalWorkspaceBase = process.env.WORKSPACE_BASE
const readdirMock = vi.fn(async (path: string) => {
if (path === 'D:\\') {
return [
{ name: 'Projects', isDirectory: () => true },
{ name: 'notes.txt', isDirectory: () => false },
]
}
return []
})
Object.defineProperty(process, 'platform', { value: 'win32' })
delete process.env.WORKSPACE_BASE
vi.doMock('fs', () => ({
existsSync: (path: string) => path === 'C:\\' || path === 'D:\\',
}))
vi.doMock('fs/promises', () => ({
readdir: readdirMock,
stat: vi.fn(async () => ({ isDirectory: () => true })),
realpath: vi.fn(async (path: string) => path),
}))
try {
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const rootCtx: any = { query: {}, body: null }
await mod.listWorkspaceFolders(rootCtx)
expect(rootCtx.body.folders).toEqual([
{ name: 'C:\\', path: 'C:\\', fullPath: 'C:\\', readonly: true },
{ name: 'D:\\', path: 'D:\\', fullPath: 'D:\\', readonly: true },
])
const driveCtx: any = { query: { path: 'D:\\' }, body: null }
await mod.listWorkspaceFolders(driveCtx)
expect(readdirMock).toHaveBeenCalledWith('D:\\', { withFileTypes: true })
expect(driveCtx.body).toMatchObject({
base: 'D:\\',
current: 'D:\\',
folders: [{ name: 'Projects', path: 'D:\\Projects', fullPath: 'D:\\Projects' }],
})
} finally {
Object.defineProperty(process, 'platform', { value: originalPlatform })
if (originalWorkspaceBase === undefined) delete process.env.WORKSPACE_BASE
else process.env.WORKSPACE_BASE = originalWorkspaceBase
vi.doUnmock('fs')
vi.doUnmock('fs/promises')
}
})
it('lists Windows junction-like workspace folders even when their target realpath leaves WORKSPACE_BASE', async () => {
const originalPlatform = process.platform
const originalWorkspaceBase = process.env.WORKSPACE_BASE
const workspaceBase = await mkdtemp(join(tmpdir(), 'hermes-workspace-win-picker-'))
const outsideRoot = await mkdtemp(join(tmpdir(), 'hermes-workspace-win-picker-outside-'))
try {
const outsideTarget = join(outsideRoot, 'drive-target')
const outsideChild = join(outsideTarget, 'project')
const outsideLink = join(workspaceBase, 'DrivesD')
await mkdir(outsideChild, { recursive: true })
await symlink(outsideTarget, outsideLink)
Object.defineProperty(process, 'platform', { value: 'win32' })
process.env.WORKSPACE_BASE = workspaceBase
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const rootCtx: any = { query: {}, body: null }
await mod.listWorkspaceFolders(rootCtx)
expect(rootCtx.status).toBeUndefined()
expect(rootCtx.body.folders).toContainEqual({
name: 'DrivesD',
path: 'DrivesD',
fullPath: outsideLink,
})
const nestedCtx: any = { query: { path: 'DrivesD' }, body: null }
await mod.listWorkspaceFolders(nestedCtx)
expect(nestedCtx.status).toBeUndefined()
expect(nestedCtx.body.folders).toEqual([
{ name: 'project', path: 'DrivesD/project', fullPath: join(outsideLink, 'project') },
])
} finally {
Object.defineProperty(process, 'platform', { value: originalPlatform })
if (originalWorkspaceBase === undefined) delete process.env.WORKSPACE_BASE
else process.env.WORKSPACE_BASE = originalWorkspaceBase
await rm(workspaceBase, { recursive: true, force: true })
await rm(outsideRoot, { recursive: true, force: true })
}
})
it('lists symlinked workspace folders that resolve within WORKSPACE_BASE and blocks escaped links', async () => {
const originalWorkspaceBase = process.env.WORKSPACE_BASE
const workspaceBase = await mkdtemp(join(tmpdir(), 'hermes-workspace-picker-'))
const outsideRoot = await mkdtemp(join(tmpdir(), 'hermes-workspace-picker-outside-'))
try {
const safeTarget = join(workspaceBase, 'workspace-target')
const safeChild = join(safeTarget, 'nested-child')
const safeLink = join(workspaceBase, 'linked-workspace')
const outsideTarget = join(outsideRoot, 'external-target')
const outsideLink = join(workspaceBase, 'linked-external')
await mkdir(safeChild, { recursive: true })
await mkdir(outsideTarget, { recursive: true })
await symlink(safeTarget, safeLink)
await symlink(outsideTarget, outsideLink)
process.env.WORKSPACE_BASE = workspaceBase
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const rootCtx: any = { query: {}, body: null }
await mod.listWorkspaceFolders(rootCtx)
expect(rootCtx.status).toBeUndefined()
expect(rootCtx.body).toEqual({
base: workspaceBase,
current: '',
folders: [
{ name: 'linked-workspace', path: 'linked-workspace', fullPath: safeLink },
{ name: 'workspace-target', path: 'workspace-target', fullPath: safeTarget },
],
})
const nestedCtx: any = { query: { path: 'linked-workspace' }, body: null }
await mod.listWorkspaceFolders(nestedCtx)
expect(nestedCtx.status).toBeUndefined()
expect(nestedCtx.body).toEqual({
base: workspaceBase,
current: 'linked-workspace',
folders: [
{ name: 'nested-child', path: 'linked-workspace/nested-child', fullPath: join(safeLink, 'nested-child') },
],
})
const escapedCtx: any = { query: { path: 'linked-external' }, body: null }
await mod.listWorkspaceFolders(escapedCtx)
expect(escapedCtx.status).toBe(403)
expect(escapedCtx.body).toEqual({ error: 'Access denied' })
} finally {
if (originalWorkspaceBase === undefined) delete process.env.WORKSPACE_BASE
else process.env.WORKSPACE_BASE = originalWorkspaceBase
await rm(workspaceBase, { recursive: true, force: true })
await rm(outsideRoot, { recursive: true, force: true })
}
})
it('lists dot-prefixed workspace folders under WORKSPACE_BASE', async () => {
const originalWorkspaceBase = process.env.WORKSPACE_BASE
const workspaceBase = await mkdtemp(join(tmpdir(), 'hermes-workspace-dot-picker-'))
try {
const hermesDir = join(workspaceBase, '.hermes')
const codexDir = join(workspaceBase, '.codex')
const hiddenChildDir = join(hermesDir, '.plugins')
const visibleChildDir = join(hermesDir, 'workspace')
await mkdir(hiddenChildDir, { recursive: true })
await mkdir(visibleChildDir, { recursive: true })
await mkdir(codexDir, { recursive: true })
process.env.WORKSPACE_BASE = workspaceBase
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const rootCtx: any = { query: {}, body: null }
await mod.listWorkspaceFolders(rootCtx)
expect(rootCtx.status).toBeUndefined()
expect(rootCtx.body).toEqual({
base: workspaceBase,
current: '',
folders: [
{ name: '.codex', path: '.codex', fullPath: codexDir },
{ name: '.hermes', path: '.hermes', fullPath: hermesDir },
],
})
const nestedCtx: any = { query: { path: '.hermes' }, body: null }
await mod.listWorkspaceFolders(nestedCtx)
expect(nestedCtx.status).toBeUndefined()
expect(nestedCtx.body).toEqual({
base: workspaceBase,
current: '.hermes',
folders: [
{ name: '.plugins', path: '.hermes/.plugins', fullPath: hiddenChildDir },
{ name: 'workspace', path: '.hermes/workspace', fullPath: visibleChildDir },
],
})
} finally {
if (originalWorkspaceBase === undefined) delete process.env.WORKSPACE_BASE
else process.env.WORKSPACE_BASE = originalWorkspaceBase
await rm(workspaceBase, { recursive: true, force: true })
}
})
it('blocks workspace folder mutations through symlinked ancestors that escape WORKSPACE_BASE', async () => {
const originalWorkspaceBase = process.env.WORKSPACE_BASE
const workspaceBase = await mkdtemp(join(tmpdir(), 'hermes-workspace-mutation-'))
const outsideRoot = await mkdtemp(join(tmpdir(), 'hermes-workspace-mutation-outside-'))
try {
const outsideTarget = join(outsideRoot, 'external-target')
const escapeLink = join(workspaceBase, 'escape-link')
await mkdir(outsideTarget, { recursive: true })
await symlink(outsideTarget, escapeLink)
process.env.WORKSPACE_BASE = workspaceBase
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const createCtx: any = { request: { body: { parentPath: 'escape-link', name: 'created' } }, body: null }
await mod.createWorkspaceFolder(createCtx)
expect(createCtx.status).toBe(403)
expect(createCtx.body).toEqual({ error: 'Access denied' })
const renameCtx: any = { request: { body: { path: 'escape-link', name: 'renamed-link' } }, body: null }
await mod.renameWorkspaceFolder(renameCtx)
expect(renameCtx.status).toBe(403)
expect(renameCtx.body).toEqual({ error: 'Access denied' })
const deleteCtx: any = { request: { body: { path: 'escape-link' } }, body: null }
await mod.deleteWorkspaceFolder(deleteCtx)
expect(deleteCtx.status).toBe(403)
expect(deleteCtx.body).toEqual({ error: 'Access denied' })
const { access } = await import('fs/promises')
await expect(access(escapeLink)).resolves.toBeUndefined()
await expect(access(join(outsideTarget, 'created'))).rejects.toMatchObject({ code: 'ENOENT' })
await expect(access(join(workspaceBase, 'renamed-link'))).rejects.toMatchObject({ code: 'ENOENT' })
} finally {
if (originalWorkspaceBase === undefined) delete process.env.WORKSPACE_BASE
else process.env.WORKSPACE_BASE = originalWorkspaceBase
await rm(workspaceBase, { recursive: true, force: true })
await rm(outsideRoot, { recursive: true, force: true })
}
})
it('returns clean session context without tool calls or tool results', async () => {
localGetSessionDetailMock.mockReturnValue({
id: 'session-context-1',
profile: 'default',
source: 'cli',
title: 'Context Session',
messages: [
{ id: 1, role: 'user', content: 'Please inspect the repo', timestamp: 101 },
{
id: 2,
role: 'assistant',
content: 'I will inspect it.',
timestamp: 102,
tool_calls: [{ id: 'call-1', type: 'function', function: { name: 'read_file', arguments: '{}' } }],
},
{ id: 3, role: 'tool', content: '{"file":"secret tool result"}', timestamp: 103, tool_call_id: 'call-1', tool_name: 'read_file' },
{
id: 4,
role: 'assistant',
content: '',
timestamp: 104,
tool_calls: [{ id: 'call-2', type: 'function', function: { name: 'list_files', arguments: '{}' } }],
},
{ id: 5, role: 'assistant', content: 'The repo has a README.', timestamp: 105, reasoning_content: 'Checked files.' },
{ id: 6, role: 'command', content: '/usage', timestamp: 106 },
],
})
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const ctx: any = { params: { id: 'session-context-1' }, query: {}, body: null }
await mod.getContext(ctx)
expect(localGetSessionDetailMock).toHaveBeenCalledWith('session-context-1')
expect(ctx.body).toEqual({
session_id: 'session-context-1',
profile: 'default',
source: 'cli',
title: 'Context Session',
message_count: 3,
messages: [
{ id: 1, role: 'user', content: 'Please inspect the repo', timestamp: 101 },
{ id: 2, role: 'assistant', content: 'I will inspect it.', timestamp: 102 },
{ id: 5, role: 'assistant', content: 'The repo has a README.', timestamp: 105, reasoning_content: 'Checked files.' },
],
})
expect(JSON.stringify(ctx.body)).not.toContain('tool_calls')
expect(JSON.stringify(ctx.body)).not.toContain('secret tool result')
})
it('returns 404 for missing session context', async () => {
localGetSessionDetailMock.mockReturnValue(null)
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const ctx: any = { params: { id: 'missing-session' }, query: {}, body: null }
await mod.getContext(ctx)
expect(ctx.status).toBe(404)
expect(ctx.body).toEqual({ error: 'Session not found' })
})
it('lists all account-accessible single-chat sessions when only the active profile header is present', async () => {
listUserProfilesMock.mockReturnValue([{ profile_name: 'default' }, { profile_name: 'travel' }])
localListSessionsMock.mockReturnValue([
{
id: 'default-session',
profile: 'default',
source: 'cli',
model: 'gpt-5',
title: 'Default',
started_at: 1,
ended_at: null,
last_active: 3,
message_count: 1,
tool_call_count: 0,
input_tokens: 0,
output_tokens: 0,
cache_read_tokens: 0,
cache_write_tokens: 0,
reasoning_tokens: 0,
billing_provider: null,
estimated_cost_usd: 0,
actual_cost_usd: null,
cost_status: '',
preview: '',
},
{
id: 'travel-session',
profile: 'travel',
source: 'cli',
model: 'gpt-5',
title: 'Travel',
started_at: 2,
ended_at: null,
last_active: 4,
message_count: 1,
tool_call_count: 0,
input_tokens: 0,
output_tokens: 0,
cache_read_tokens: 0,
cache_write_tokens: 0,
reasoning_tokens: 0,
billing_provider: null,
estimated_cost_usd: 0,
actual_cost_usd: null,
cost_status: '',
preview: '',
},
{
id: 'secret-session',
profile: 'secret',
source: 'cli',
model: 'gpt-5',
title: 'Secret',
started_at: 3,
ended_at: null,
last_active: 5,
message_count: 1,
tool_call_count: 0,
input_tokens: 0,
output_tokens: 0,
cache_read_tokens: 0,
cache_write_tokens: 0,
reasoning_tokens: 0,
billing_provider: null,
estimated_cost_usd: 0,
actual_cost_usd: null,
cost_status: '',
preview: '',
},
])
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const ctx: any = {
query: {},
state: {
user: { id: 1, role: 'admin' },
profile: { name: 'travel' },
},
body: null,
}
await mod.list(ctx)
expect(localListSessionsMock).toHaveBeenCalledWith(undefined, undefined, 2000)
expect(ctx.body.sessions.map((session: any) => session.id)).toEqual(['default-session', 'travel-session'])
})
it('filters the single-chat session list when profile is explicitly provided', async () => {
localListSessionsMock.mockReturnValue([])
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const ctx: any = {
query: { profile: 'travel' },
state: { profile: { name: 'default' } },
body: null,
}
await mod.list(ctx)
expect(localListSessionsMock).toHaveBeenCalledWith('travel', undefined, 2000)
})
it('lists only global-agent sessions when requested by source', async () => {
localListSessionsMock.mockReturnValue([
{ id: 'global-1', profile: 'default', source: 'global_agent' },
{ id: 'chat-1', profile: 'default', source: 'cli' },
])
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const ctx: any = {
query: { source: 'global_agent' },
state: {},
body: null,
}
await mod.list(ctx)
expect(localListSessionsMock).toHaveBeenCalledWith(undefined, 'global_agent', 2000)
expect(ctx.body.sessions).toEqual([expect.objectContaining({ id: 'global-1', source: 'global_agent' })])
})
it('filters archived sessions from the single-chat session list', async () => {
localListSessionsMock.mockReturnValue([
{ id: 'visible-session', profile: 'default', source: 'cli', is_archived: 0 },
{ id: 'archived-session', profile: 'default', source: 'cli', is_archived: 1 },
])
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const ctx: any = { query: {}, state: {}, body: null }
await mod.list(ctx)
expect(ctx.body.sessions.map((session: any) => session.id)).toEqual(['visible-session'])
})
it('hides workflow sessions from the default list but allows explicit workflow filtering', async () => {
localListSessionsMock.mockReturnValue([
{ id: 'workflow-1', profile: 'default', source: 'workflow' },
{ id: 'chat-1', profile: 'default', source: 'cli' },
])
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const defaultCtx: any = {
query: {},
state: {},
body: null,
}
await mod.list(defaultCtx)
expect(defaultCtx.body.sessions).toEqual([expect.objectContaining({ id: 'chat-1', source: 'cli' })])
const workflowCtx: any = {
query: { source: 'workflow' },
state: {},
body: null,
}
await mod.list(workflowCtx)
expect(localListSessionsMock).toHaveBeenLastCalledWith(undefined, 'workflow', 2000)
expect(workflowCtx.body.sessions).toEqual([expect.objectContaining({ id: 'workflow-1', source: 'workflow' })])
})
it('counts visible single-chat sessions with the same filters as the list endpoint', async () => {
listUserProfilesMock.mockReturnValue([{ profile_name: 'default' }, { profile_name: 'travel' }])
localListSessionsMock.mockReturnValue([
{ id: 'default-session', profile: 'default', source: 'cli' },
{ id: 'travel-session', profile: 'travel', source: 'coding_agent' },
{ id: 'archived-session', profile: 'default', source: 'cli', is_archived: 1 },
{ id: 'secret-session', profile: 'secret', source: 'cli' },
{ id: 'unknown-profile-session', profile: 'missing', source: 'cli' },
{ id: 'api-session', profile: 'default', source: 'api_server' },
{ id: 'workflow-session', profile: 'default', source: 'workflow' },
])
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const ctx: any = {
query: {},
state: {
user: { id: 1, role: 'admin' },
},
body: null,
}
await mod.count(ctx)
expect(localListSessionsMock).toHaveBeenCalledWith(undefined, undefined, 2147483647)
expect(ctx.body).toEqual({ count: 3 })
})
it('counts sessions for an explicit profile and source', async () => {
localListSessionsMock.mockReturnValue([
{ id: 'travel-global', profile: 'travel', source: 'global_agent' },
])
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const ctx: any = {
query: { profile: 'travel', source: 'global_agent' },
state: {},
body: null,
}
await mod.count(ctx)
expect(localListSessionsMock).toHaveBeenCalledWith('travel', 'global_agent', 2147483647)
expect(ctx.body).toEqual({ count: 1 })
})
it('marks Hermes history sessions that already exist in the Web UI store', async () => {
localListSessionsMock.mockReturnValue([{ id: 'cli-1', profile: 'travel' }])
listSessionSummariesMock.mockResolvedValue([
{
id: 'cli-1',
source: 'cli',
model: 'gpt-5',
title: 'Imported',
started_at: 1,
ended_at: null,
last_active: 2,
message_count: 1,
tool_call_count: 0,
input_tokens: 0,
output_tokens: 0,
cache_read_tokens: 0,
cache_write_tokens: 0,
reasoning_tokens: 0,
billing_provider: null,
estimated_cost_usd: 0,
actual_cost_usd: null,
cost_status: '',
preview: '',
},
{
id: 'cli-2',
source: 'cli',
model: 'gpt-5',
title: 'History only',
started_at: 1,
ended_at: null,
last_active: 2,
message_count: 1,
tool_call_count: 0,
input_tokens: 0,
output_tokens: 0,
cache_read_tokens: 0,
cache_write_tokens: 0,
reasoning_tokens: 0,
billing_provider: null,
estimated_cost_usd: 0,
actual_cost_usd: null,
cost_status: '',
preview: '',
},
])
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const ctx: any = { query: { profile: 'travel' }, state: {}, body: null }
await mod.listHermesSessions(ctx)
expect(localListSessionsMock).toHaveBeenCalledWith('travel', undefined, 2000)
expect(listSessionSummariesMock).toHaveBeenCalledWith(undefined, 2000, 'travel')
expect(ctx.body.sessions).toEqual([
expect.objectContaining({ id: 'cli-1', profile: 'travel', webui_imported: true }),
expect.objectContaining({ id: 'cli-2', profile: 'travel', webui_imported: false }),
])
})
it.each(['cli', 'api_server'])('keeps archived %s sessions visible in Hermes history', async (source) => {
localListSessionsMock.mockReturnValue([{ id: `${source}-archived`, profile: 'travel', source, is_archived: 1 }])
listSessionSummariesMock.mockResolvedValue([
{
id: `${source}-archived`,
source,
model: 'gpt-5',
title: 'Archived imported history',
started_at: 1,
ended_at: null,
last_active: 2,
message_count: 1,
tool_call_count: 0,
input_tokens: 0,
output_tokens: 0,
cache_read_tokens: 0,
cache_write_tokens: 0,
reasoning_tokens: 0,
billing_provider: null,
estimated_cost_usd: 0,
actual_cost_usd: null,
cost_status: '',
preview: '',
},
])
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const ctx: any = { query: { profile: 'travel' }, state: {}, body: null }
await mod.listHermesSessions(ctx)
expect(ctx.body.sessions).toEqual([
expect.objectContaining({
id: `${source}-archived`,
source,
profile: 'travel',
webui_imported: true,
is_archived: 1,
}),
])
})
it('keeps archived coding-agent sessions visible in Hermes history', async () => {
localListSessionsMock.mockReturnValue([{
id: 'codex-archived',
profile: 'travel',
source: 'coding_agent',
agent: 'codex',
model: 'gpt-5',
title: 'Archived Codex',
started_at: 1,
ended_at: null,
last_active: 2,
message_count: 1,
tool_call_count: 0,
input_tokens: 0,
output_tokens: 0,
cache_read_tokens: 0,
cache_write_tokens: 0,
reasoning_tokens: 0,
billing_provider: null,
estimated_cost_usd: 0,
actual_cost_usd: null,
cost_status: '',
preview: '',
is_archived: 1,
}])
listSessionSummariesMock.mockResolvedValue([])
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const ctx: any = { query: { profile: 'travel' }, state: {}, body: null }
await mod.listHermesSessions(ctx)
expect(ctx.body.sessions).toEqual([
expect.objectContaining({ id: 'codex-archived', source: 'coding_agent', agent: 'codex', webui_imported: true }),
])
})
it('archives an existing accessible session', async () => {
getSessionMock.mockReturnValue({ id: 'session-1', profile: 'default', source: 'cli' })
localSetSessionArchivedMock.mockReturnValue(true)
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const ctx: any = { params: { id: 'session-1' }, state: {}, body: null }
await mod.archive(ctx)
expect(localSetSessionArchivedMock).toHaveBeenCalledWith('session-1', true)
expect(ctx.body).toEqual({ ok: true })
})
it('rejects archiving global-agent sessions', async () => {
getSessionMock.mockReturnValue({ id: 'global-1', profile: 'default', source: 'global_agent' })
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const ctx: any = { params: { id: 'global-1' }, state: {}, body: null }
await mod.archive(ctx)
expect(localSetSessionArchivedMock).not.toHaveBeenCalled()
expect(ctx.status).toBe(400)
expect(ctx.body).toEqual({ error: 'Global agent sessions cannot be archived' })
})
it('returns 404 when archiving a missing session', async () => {
getSessionMock.mockReturnValue(null)
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const ctx: any = { params: { id: 'missing' }, state: {}, body: null }
await mod.archive(ctx)
expect(localSetSessionArchivedMock).not.toHaveBeenCalled()
expect(ctx.status).toBe(404)
expect(ctx.body).toEqual({ error: 'Session not found' })
})
it('unarchives an existing accessible session', async () => {
getSessionMock.mockReturnValue({ id: 'session-1', profile: 'default', source: 'coding_agent', is_archived: 1 })
localSetSessionArchivedMock.mockReturnValue(true)
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const ctx: any = { params: { id: 'session-1' }, state: {}, body: null }
await mod.unarchive(ctx)
expect(localSetSessionArchivedMock).toHaveBeenCalledWith('session-1', false)
expect(ctx.body).toEqual({ ok: true })
})
it('returns 404 when unarchiving a missing session', async () => {
getSessionMock.mockReturnValue(null)
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const ctx: any = { params: { id: 'missing' }, state: {}, body: null }
await mod.unarchive(ctx)
expect(localSetSessionArchivedMock).not.toHaveBeenCalled()
expect(ctx.status).toBe(404)
expect(ctx.body).toEqual({ error: 'Session not found' })
})
it('searches all account-accessible single-chat sessions unless profile is explicit', async () => {
localSearchSessionsMock.mockReturnValue([
{ id: 'global-1', profile: 'default', source: 'global_agent' },
{ id: 'chat-1', profile: 'default', source: 'cli' },
])
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const ctx: any = {
query: { q: 'docker', limit: '10' },
state: { profile: { name: 'travel' } },
body: null,
}
await mod.search(ctx)
expect(localSearchSessionsMock).toHaveBeenCalledWith(undefined, 'docker', 10)
expect(ctx.body.results).toEqual([
expect.objectContaining({ id: 'global-1', source: 'global_agent' }),
expect.objectContaining({ id: 'chat-1', source: 'cli' }),
])
})
it('searches only global-agent sessions when requested by source', async () => {
localSearchSessionsMock.mockReturnValue([
{ id: 'global-1', profile: 'default', source: 'global_agent' },
{ id: 'chat-1', profile: 'default', source: 'cli' },
])
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const ctx: any = {
query: { q: 'docker', source: 'global_agent', limit: '10' },
state: {},
body: null,
}
await mod.search(ctx)
expect(localSearchSessionsMock).toHaveBeenCalledWith(undefined, 'docker', 10)
expect(ctx.body.results).toEqual([expect.objectContaining({ id: 'global-1', source: 'global_agent' })])
})
it('propagates local session store errors for conversation summaries', async () => {
localListSessionsMock.mockImplementation(() => {
throw new Error('db unavailable')
})
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const ctx: any = { query: { humanOnly: 'false' }, body: null }
await expect(mod.listConversations(ctx)).rejects.toThrow('db unavailable')
})
it('gets conversation messages from the local session store', async () => {
localGetSessionDetailMock.mockReturnValue({
id: 'root',
messages: [
{ id: 1, session_id: 'root', role: 'user', content: 'hello', timestamp: 1 },
{ id: 2, session_id: 'root', role: 'command', content: '/usage', timestamp: 2 },
],
})
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const ctx: any = { params: { id: 'root' }, query: { humanOnly: 'true' }, body: null }
await mod.getConversationMessages(ctx)
expect(localGetSessionDetailMock).toHaveBeenCalledWith('root')
expect(getConversationDetailMock).not.toHaveBeenCalled()
expect(ctx.body).toEqual({
session_id: 'root',
messages: [{ id: 1, session_id: 'root', role: 'user', content: 'hello', timestamp: 1 }],
visible_count: 1,
thread_session_count: 1,
})
})
it('treats missing conversation message arrays as empty', async () => {
localGetSessionDetailMock.mockReturnValue({
id: 'root',
})
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const ctx: any = { params: { id: 'root' }, query: { humanOnly: 'false' }, body: null }
await mod.getConversationMessages(ctx)
expect(localGetSessionDetailMock).toHaveBeenCalledWith('root')
expect(ctx.body).toEqual({
session_id: 'root',
messages: [],
visible_count: 0,
thread_session_count: 1,
})
})
it('returns 404 when local conversation detail is missing', async () => {
localGetSessionDetailMock.mockReturnValue(null)
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const ctx: any = { params: { id: 'root' }, query: { humanOnly: 'false' }, body: null }
await mod.getConversationMessages(ctx)
expect(ctx.status).toBe(404)
expect(ctx.body).toEqual({ error: 'Conversation not found' })
})
it('prefers local session detail for Hermes history detail when available', async () => {
localGetSessionDetailMock.mockReturnValue({
id: 'cli-1',
source: 'cli',
title: 'Local complete',
messages: [
{ id: 1, session_id: 'cli-1', role: 'user', content: 'local full message', timestamp: 1 },
],
})
getSessionDetailFromDbMock.mockResolvedValue({
id: 'cli-1',
source: 'cli',
title: 'Hermes incomplete',
messages: [],
})
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const ctx: any = { params: { id: 'cli-1' }, body: null }
await mod.getHermesSession(ctx)
expect(localGetSessionDetailMock).toHaveBeenCalledWith('cli-1')
expect(getSessionDetailFromDbMock).not.toHaveBeenCalled()
expect(getSessionMock).not.toHaveBeenCalled()
expect(ctx.body.session).toMatchObject({
id: 'cli-1',
title: 'Local complete',
messages: [{ content: 'local full message' }],
})
})
it('falls back to Hermes state.db when local history detail is missing', async () => {
localGetSessionDetailMock.mockReturnValue(null)
getSessionDetailFromDbMock.mockResolvedValue({
id: 'hermes-1',
source: 'cli',
title: 'Hermes detail',
messages: [
{ id: 1, session_id: 'hermes-1', role: 'user', content: 'from hermes', timestamp: 1 },
],
})
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const ctx: any = { params: { id: 'hermes-1' }, body: null }
await mod.getHermesSession(ctx)
expect(localGetSessionDetailMock).toHaveBeenCalledWith('hermes-1')
expect(getSessionDetailFromDbMock).toHaveBeenCalledWith('hermes-1')
expect(getSessionMock).not.toHaveBeenCalled()
expect(ctx.body.session).toMatchObject({
id: 'hermes-1',
title: 'Hermes detail',
messages: [{ content: 'from hermes' }],
})
})
it('reads Hermes history detail from the requested profile database', async () => {
localGetSessionDetailMock.mockReturnValue(null)
getSessionDetailFromDbWithProfileMock.mockResolvedValue({
id: 'travel-session',
source: 'cli',
title: 'Travel detail',
messages: [
{ id: 1, session_id: 'travel-session', role: 'user', content: 'from travel', timestamp: 1 },
],
})
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const ctx: any = { params: { id: 'travel-session' }, query: { profile: 'travel' }, body: null }
await mod.getHermesSession(ctx)
expect(localGetSessionDetailMock).toHaveBeenCalledWith('travel-session')
expect(getSessionDetailFromDbWithProfileMock).toHaveBeenCalledWith('travel-session', 'travel')
expect(getSessionDetailFromDbMock).not.toHaveBeenCalled()
expect(getSessionMock).not.toHaveBeenCalled()
expect(ctx.body.session).toMatchObject({
id: 'travel-session',
profile: 'travel',
title: 'Travel detail',
messages: [{ content: 'from travel' }],
})
})
it('does not return api_server sessions from the Hermes history detail endpoint', async () => {
localGetSessionDetailMock.mockReturnValue({
id: 'api-1',
source: 'api_server',
title: 'API Server',
messages: [{ id: 1, session_id: 'api-1', role: 'user', content: 'local api', timestamp: 1 }],
})
getSessionDetailFromDbMock.mockResolvedValue(null)
getSessionMock.mockResolvedValue(null)
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const ctx: any = { params: { id: 'api-1' }, body: null }
await mod.getHermesSession(ctx)
expect(localGetSessionDetailMock).toHaveBeenCalledWith('api-1')
expect(getSessionDetailFromDbMock).toHaveBeenCalledWith('api-1')
expect(ctx.status).toBe(404)
expect(ctx.body).toEqual({ error: 'Session not found' })
})
it('returns native state.db usage analytics for the requested period', async () => {
const today = new Date().toISOString().slice(0, 10)
getLocalUsageStatsMock.mockReturnValue({
input_tokens: 10,
output_tokens: 5,
cache_read_tokens: 2,
cache_write_tokens: 1,
reasoning_tokens: 3,
sessions: 1,
by_model: [
{ model: 'local-model', input_tokens: 10, output_tokens: 5, cache_read_tokens: 2, cache_write_tokens: 1, reasoning_tokens: 3, sessions: 1 },
],
by_day: [
{ date: today, input_tokens: 10, output_tokens: 5, cache_read_tokens: 2, cache_write_tokens: 1, sessions: 1, errors: 0, cost: 0 },
],
})
getUsageStatsFromDbMock.mockResolvedValue({
input_tokens: 20,
output_tokens: 10,
cache_read_tokens: 4,
cache_write_tokens: 2,
reasoning_tokens: 6,
sessions: 2,
cost: 0.02,
total_api_calls: 7,
by_model: [
{ model: 'hermes-model', input_tokens: 20, output_tokens: 10, cache_read_tokens: 4, cache_write_tokens: 2, reasoning_tokens: 6, sessions: 2 },
],
by_day: [
{ date: today, input_tokens: 20, output_tokens: 10, cache_read_tokens: 4, cache_write_tokens: 2, sessions: 2, errors: 0, cost: 0.02 },
],
})
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const ctx: any = { query: { days: '2' }, body: null }
await mod.usageStats(ctx)
expect(getLocalUsageStatsMock).not.toHaveBeenCalled()
expect(getUsageStatsFromDbMock).toHaveBeenCalledWith(2)
expect(ctx.body).toMatchObject({
total_input_tokens: 20,
total_output_tokens: 10,
total_cache_read_tokens: 4,
total_cache_write_tokens: 2,
total_reasoning_tokens: 6,
total_sessions: 2,
total_cost: 0.02,
total_api_calls: 7,
period_days: 2,
})
expect(ctx.body.model_usage).toEqual([
{ model: 'hermes-model', input_tokens: 20, output_tokens: 10, cache_read_tokens: 4, cache_write_tokens: 2, reasoning_tokens: 6, sessions: 2 },
])
expect(ctx.body.daily_usage.find((row: any) => row.date === today)).toMatchObject({
input_tokens: 20,
output_tokens: 10,
cache_read_tokens: 4,
cache_write_tokens: 2,
sessions: 2,
cost: 0.02,
})
})
it('loads usage analytics from the request-scoped profile state database', async () => {
getUsageStatsFromDbMock.mockResolvedValue({
input_tokens: 12,
output_tokens: 6,
cache_read_tokens: 3,
cache_write_tokens: 1,
reasoning_tokens: 2,
sessions: 1,
cost: 0.01,
total_api_calls: 4,
by_model: [
{ model: 'research-model', input_tokens: 12, output_tokens: 6, cache_read_tokens: 3, cache_write_tokens: 1, reasoning_tokens: 2, sessions: 1 },
],
by_day: [],
})
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const ctx: any = { query: { days: '2' }, state: { profile: { name: 'research' } }, body: null }
await mod.usageStats(ctx)
expect(getUsageStatsFromDbMock).toHaveBeenCalledWith(2, undefined, 'research')
expect(ctx.body).toMatchObject({
total_input_tokens: 12,
total_output_tokens: 6,
total_sessions: 1,
total_cost: 0.01,
total_api_calls: 4,
})
expect(ctx.body.model_usage).toEqual([
{ model: 'research-model', input_tokens: 12, output_tokens: 6, cache_read_tokens: 3, cache_write_tokens: 1, reasoning_tokens: 2, sessions: 1 },
])
})
it('keeps blank model usage as returned by state.db analytics', async () => {
getLocalUsageStatsMock.mockReturnValue({
input_tokens: 3,
output_tokens: 1,
cache_read_tokens: 2,
cache_write_tokens: 0,
reasoning_tokens: 0,
sessions: 1,
by_model: [
{ model: '', input_tokens: 3, output_tokens: 1, cache_read_tokens: 2, cache_write_tokens: 0, reasoning_tokens: 0, sessions: 1 },
],
by_day: [],
})
getUsageStatsFromDbMock.mockResolvedValue({
input_tokens: 2,
output_tokens: 1,
cache_read_tokens: 1,
cache_write_tokens: 1,
reasoning_tokens: 0,
sessions: 1,
cost: 0,
total_api_calls: 0,
by_model: [
{ model: ' ', input_tokens: 2, output_tokens: 1, cache_read_tokens: 1, cache_write_tokens: 1, reasoning_tokens: 0, sessions: 1 },
],
by_day: [],
})
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const ctx: any = { query: { days: '2' }, body: null }
await mod.usageStats(ctx)
expect(ctx.body.model_usage).toEqual([
{ model: ' ', input_tokens: 2, output_tokens: 1, cache_read_tokens: 1, cache_write_tokens: 1, reasoning_tokens: 0, sessions: 1 },
])
})
it('sets a session model and provider in the local session store', async () => {
getSessionMock.mockReturnValue({ id: 'session-1' })
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const ctx: any = {
params: { id: 'session-1' },
request: { body: { model: 'grok-4', provider: 'xai' } },
body: null,
}
await mod.setModel(ctx)
expect(localCreateSessionMock).not.toHaveBeenCalled()
expect(localUpdateSessionMock).toHaveBeenCalledWith('session-1', {
model: 'grok-4',
provider: 'xai',
workspace: '/tmp/hermes-test/default/workspace',
})
expect(bridgeSwitchSessionModelMock).not.toHaveBeenCalled()
expect(ctx.body).toEqual({ ok: true })
})
it('notifies a loaded agent bridge session after storing the session model', async () => {
bridgeGetRuntimeStateMock.mockReturnValue({ ready: true, running: true, endpoint: 'ipc:///tmp/hermes-agent-bridge.sock' })
bridgeSwitchSessionModelMock.mockResolvedValue({
ok: true,
session_id: 'session-1',
model: 'claude-sonnet-4-6',
provider: 'anthropic',
loaded: true,
switched: true,
})
getSessionMock.mockReturnValue({ id: 'session-1', profile: 'travel' })
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const ctx: any = {
params: { id: 'session-1' },
request: { body: { model: 'claude-sonnet-4-6', provider: 'claude-oauth' } },
body: null,
}
await mod.setModel(ctx)
expect(localUpdateSessionMock).toHaveBeenCalledWith('session-1', {
model: 'claude-sonnet-4-6',
provider: 'claude-oauth',
workspace: '/tmp/hermes-test/travel/workspace',
})
expect(bridgeSwitchSessionModelMock).toHaveBeenCalledWith(
'session-1',
'claude-sonnet-4-6',
'anthropic',
'travel',
)
expect(ctx.body).toEqual({ ok: true })
})
it('stores a coding agent session model and API mode without stopping the runner or notifying the Hermes bridge', async () => {
bridgeGetRuntimeStateMock.mockReturnValue({ ready: true, running: true, endpoint: 'ipc:///tmp/hermes-agent-bridge.sock' })
getSessionMock.mockReturnValue({
id: 'codex-session',
profile: 'default',
source: 'coding_agent',
agent: 'codex',
model: 'old-model',
provider: 'openrouter',
api_mode: 'codex_responses',
agent_native_session_id: 'old-native-thread',
workspace: '/tmp/original-workspace',
})
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const ctx: any = {
params: { id: 'codex-session' },
request: { body: { model: 'gpt-5.5', provider: 'openai-codex', apiMode: 'chat_completions' } },
body: null,
}
await mod.setModel(ctx)
expect(localUpdateSessionMock).toHaveBeenCalledWith('codex-session', {
model: 'gpt-5.5',
provider: 'openai-codex',
api_mode: 'chat_completions',
agent_native_session_id: '',
})
expect(codingAgentRunManagerMock.stop).not.toHaveBeenCalled()
expect(bridgeSwitchSessionModelMock).not.toHaveBeenCalled()
expect(ctx.body).toEqual({ ok: true })
})
it('deletes a current-profile Hermes history session even when no local Web UI session exists', async () => {
getActiveProfileNameMock.mockReturnValue('travel')
getSessionMock.mockReturnValue(null)
getExactSessionDetailFromDbWithProfileMock.mockResolvedValue({ id: 'history-only', messages: [] })
deleteHermesSessionForProfileMock.mockResolvedValue(true)
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const ctx: any = { params: { id: 'history-only' }, body: null }
await mod.remove(ctx)
expect(getExactSessionDetailFromDbWithProfileMock).toHaveBeenCalledWith('history-only', 'travel')
expect(deleteHermesSessionForProfileMock).toHaveBeenCalledWith('history-only', 'travel')
expect(localDeleteSessionMock).not.toHaveBeenCalled()
expect(ctx.body).toEqual({
ok: true,
deleted: false,
hermes: { attempted: true, deleted: true, profile: 'travel', error: undefined },
})
})
it('deletes a local coding-agent session without invoking Hermes CLI deletion', async () => {
getSessionMock.mockReturnValue({
id: 'codex-session',
profile: 'default',
source: 'coding_agent',
})
localDeleteSessionMock.mockReturnValue(true)
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const ctx: any = { params: { id: 'codex-session' }, body: null }
await mod.remove(ctx)
expect(codingAgentRunManagerMock.stop).toHaveBeenCalledWith('codex-session', { reportClosed: false })
expect(getExactSessionDetailFromDbWithProfileMock).not.toHaveBeenCalled()
expect(deleteHermesSessionForProfileMock).not.toHaveBeenCalled()
expect(localDeleteSessionMock).toHaveBeenCalledWith('codex-session')
expect(ctx.body).toEqual({
ok: true,
deleted: true,
hermes: { attempted: false, deleted: false, profile: 'default' },
})
})
it('batch deletes sessions from their requested profiles', async () => {
listUserProfilesMock.mockReturnValue([{ profile_name: 'default' }, { profile_name: 'travel' }])
getSessionMock.mockImplementation((id: string) => ({
id,
profile: id === 'travel-session' ? 'travel' : 'default',
}))
getExactSessionDetailFromDbWithProfileMock.mockResolvedValue({ id: 'matched', messages: [] })
deleteHermesSessionForProfileMock.mockResolvedValue(true)
localDeleteSessionMock.mockReturnValue(true)
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const ctx: any = {
request: {
body: {
sessions: [
{ id: 'default-session', profile: 'default' },
{ id: 'travel-session', profile: 'travel' },
],
},
},
state: {
user: { id: 1, role: 'admin' },
},
body: null,
}
await mod.batchRemove(ctx)
expect(getExactSessionDetailFromDbWithProfileMock).toHaveBeenCalledWith('default-session', 'default')
expect(getExactSessionDetailFromDbWithProfileMock).toHaveBeenCalledWith('travel-session', 'travel')
expect(deleteHermesSessionForProfileMock).toHaveBeenCalledWith('default-session', 'default')
expect(deleteHermesSessionForProfileMock).toHaveBeenCalledWith('travel-session', 'travel')
expect(localDeleteSessionMock).toHaveBeenCalledWith('default-session')
expect(localDeleteSessionMock).toHaveBeenCalledWith('travel-session')
expect(ctx.body).toMatchObject({ ok: true, deleted: 2, failed: 0, hermesDeleted: 2 })
})
it('batch deletes local coding-agent sessions without invoking Hermes CLI deletion', async () => {
getSessionMock.mockReturnValue({
id: 'codex-session',
profile: 'default',
source: 'coding_agent',
})
localDeleteSessionMock.mockReturnValue(true)
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const ctx: any = {
request: {
body: {
sessions: [{ id: 'codex-session', profile: 'default' }],
},
},
body: null,
}
await mod.batchRemove(ctx)
expect(codingAgentRunManagerMock.stop).toHaveBeenCalledWith('codex-session', { reportClosed: false })
expect(getExactSessionDetailFromDbWithProfileMock).not.toHaveBeenCalled()
expect(deleteHermesSessionForProfileMock).not.toHaveBeenCalled()
expect(localDeleteSessionMock).toHaveBeenCalledWith('codex-session')
expect(ctx.body).toMatchObject({ ok: true, deleted: 1, failed: 0, hermesDeleted: 0 })
})
it('imports a Hermes session into the local Web UI store', async () => {
const hermesDetail = {
id: 'cli-1',
source: 'cli',
user_id: null,
model: 'gpt-5',
title: 'CLI run',
started_at: 100,
ended_at: 200,
end_reason: null,
message_count: 2,
tool_call_count: 0,
input_tokens: 10,
output_tokens: 20,
cache_read_tokens: 0,
cache_write_tokens: 0,
reasoning_tokens: 0,
billing_provider: null,
estimated_cost_usd: 0,
actual_cost_usd: null,
cost_status: '',
preview: 'hello',
last_active: 200,
thread_session_count: 1,
messages: [
{ id: 1, session_id: 'cli-1', role: 'user', content: 'hello', tool_call_id: null, tool_calls: null, tool_name: null, timestamp: 100, token_count: null, finish_reason: null, reasoning: null },
{ id: 2, session_id: 'cli-1', role: 'assistant', content: 'hi', tool_call_id: null, tool_calls: null, tool_name: null, timestamp: 101, token_count: null, finish_reason: null, reasoning: null, reasoning_details: { text: 'ok' } },
{ id: 3, session_id: 'cli-1', role: 'assistant', content: '', tool_call_id: null, tool_calls: [{ id: 'call-1', function: { name: 'read_file', arguments: { path: 'README.md' } } }], tool_name: null, timestamp: 102, token_count: null, finish_reason: 'tool_calls', reasoning: null },
{ id: 4, session_id: 'cli-1', role: 'tool', content: { ok: true }, tool_call_id: 'call-1', tool_calls: null, tool_name: 'read_file', timestamp: 103, token_count: null, finish_reason: null, reasoning: null },
{ id: 5, session_id: 'cli-1', role: 'tool', content: 'orphan', tool_call_id: null, tool_calls: null, tool_name: 'bad_tool', timestamp: 104, token_count: null, finish_reason: null, reasoning: null },
{ id: 6, session_id: 'cli-1', role: 'system', content: 'drop me', tool_call_id: null, tool_calls: null, tool_name: null, timestamp: 105, token_count: null, finish_reason: null, reasoning: null },
],
}
localGetSessionDetailMock.mockReturnValueOnce(null).mockReturnValueOnce({ ...hermesDetail, profile: 'travel' })
getSessionDetailFromDbWithProfileMock.mockResolvedValue(hermesDetail)
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const ctx: any = { params: { id: 'cli-1' }, query: { profile: 'travel' }, state: {}, body: null }
await mod.importHermesSession(ctx)
expect(getSessionDetailFromDbWithProfileMock).toHaveBeenCalledWith('cli-1', 'travel')
expect(localCreateSessionMock).toHaveBeenCalledWith(expect.objectContaining({
id: 'cli-1',
profile: 'travel',
source: 'cli',
model: 'gpt-default',
provider: 'openai',
title: 'CLI run',
}))
expect(localUpdateSessionMock).toHaveBeenCalledWith('cli-1', expect.objectContaining({
source: 'cli',
model: 'gpt-default',
provider: 'openai',
}))
expect(localAddMessagesMock).toHaveBeenCalledWith([
expect.objectContaining({ session_id: 'cli-1', role: 'user', content: 'hello', tool_calls: null }),
expect.objectContaining({ session_id: 'cli-1', role: 'assistant', content: 'hi', reasoning_details: '{"text":"ok"}' }),
expect.objectContaining({
session_id: 'cli-1',
role: 'assistant',
content: '',
tool_calls: [{ id: 'call-1', type: 'function', function: { name: 'read_file', arguments: '{"path":"README.md"}' } }],
}),
expect.objectContaining({ session_id: 'cli-1', role: 'tool', content: '{"ok":true}', tool_call_id: 'call-1', tool_name: 'read_file' }),
])
expect(localUpdateSessionStatsMock).toHaveBeenCalledWith('cli-1')
expect(localUpdateSessionMock.mock.calls.at(-1)?.[1]).toEqual(expect.objectContaining({
last_active: expect.any(Number),
}))
expect(localUpdateSessionMock.mock.calls.at(-1)?.[1].last_active).toBeGreaterThan(200)
expect(ctx.body).toMatchObject({ ok: true, imported: true })
})
describe('exportSession', () => {
it('returns session as JSON download with correct headers (full mode)', async () => {
const sessionData = { id: 'abc-123', title: 'Test Session', messages: [{ id: 1, role: 'user', content: 'hello' }] }
localGetSessionDetailMock.mockReturnValue(sessionData)
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const setMock = vi.fn()
const ctx: any = { params: { id: 'abc-123' }, query: {}, set: setMock, body: null }
await mod.exportSession(ctx)
expect(localGetSessionDetailMock).toHaveBeenCalledWith('abc-123')
expect(setMock).toHaveBeenCalledWith('Content-Disposition', expect.stringContaining('abc-123'))
expect(setMock).toHaveBeenCalledWith('Content-Type', 'application/json')
expect(ctx.status).toBeUndefined()
expect(JSON.parse(ctx.body)).toMatchObject({ id: 'abc-123', title: 'Test Session' })
})
it('returns full TXT export', async () => {
const sessionData = {
id: 'txt-123',
title: 'Text Export',
messages: [
{ id: 1, role: 'user', content: 'hello', timestamp: 1700000000 },
{ id: 2, role: 'assistant', content: 'hi', timestamp: 1700000001 },
],
}
localGetSessionDetailMock.mockReturnValue(sessionData)
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const setMock = vi.fn()
const ctx: any = { params: { id: 'txt-123' }, query: { mode: 'full', ext: 'txt' }, set: setMock, body: null }
await mod.exportSession(ctx)
expect(setMock).toHaveBeenCalledWith('Content-Type', 'text/plain; charset=utf-8')
expect(ctx.body).toContain('# Text Export')
expect(ctx.body).toContain('[user]')
expect(ctx.body).toContain('hello')
expect(ctx.body).toContain('[assistant]')
expect(ctx.body).toContain('hi')
})
it('returns 404 when session not found', async () => {
localGetSessionDetailMock.mockReturnValue(null)
getSessionMock.mockResolvedValue(null)
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const ctx: any = { params: { id: 'not-found' }, query: {}, set: vi.fn(), body: null }
await mod.exportSession(ctx)
expect(ctx.status).toBe(404)
expect(ctx.body).toEqual({ error: 'Session not found' })
})
it('falls back to CLI when DB query fails', async () => {
const sessionData = { id: 'cli-123', title: 'CLI Session', messages: [] }
localGetSessionDetailMock.mockReturnValue(sessionData)
const mod = await import('../../packages/server/src/controllers/hermes/sessions')
const setMock = vi.fn()
const ctx: any = { params: { id: 'cli-123' }, query: {}, set: setMock, body: null }
await mod.exportSession(ctx)
expect(localGetSessionDetailMock).toHaveBeenCalledWith('cli-123')
expect(JSON.parse(ctx.body)).toMatchObject({ id: 'cli-123' })
})
})
})