From b61a3edb583b5e3291f66724ea9499d812ad6f65 Mon Sep 17 00:00:00 2001 From: Evgeny Shurakov Date: Mon, 2 Mar 2026 16:17:35 +0100 Subject: [PATCH] feat(cli): publish Session.Event.Created on import to trigger session ingestion --- packages/opencode/src/cli/cmd/import.ts | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/packages/opencode/src/cli/cmd/import.ts b/packages/opencode/src/cli/cmd/import.ts index 26869826589..9696d17add9 100644 --- a/packages/opencode/src/cli/cmd/import.ts +++ b/packages/opencode/src/cli/cmd/import.ts @@ -1,6 +1,7 @@ import type { Argv } from "yargs" import type { Session as SDKSession, Message, Part } from "@kilocode/sdk/v2" import { Session } from "../../session" +import { Bus } from "../../bus" import { cmd } from "./cmd" import { bootstrap } from "../bootstrap" import { Database } from "../../storage/db" @@ -131,7 +132,10 @@ export const ImportCommand = cmd({ return } - Database.use((db) => db.insert(SessionTable).values(Session.toRow(exportData.info)).onConflictDoNothing().run()) + Database.use((db) => { + db.insert(SessionTable).values(Session.toRow(exportData.info)).onConflictDoNothing().run() + Database.effect(() => Bus.publish(Session.Event.Created, { info: exportData.info })) + }) for (const msg of exportData.messages) { Database.use((db) =>