summaryrefslogtreecommitdiffhomepage
path: root/packages/conversation-store/src/extension.ts
diff options
context:
space:
mode:
Diffstat (limited to 'packages/conversation-store/src/extension.ts')
-rw-r--r--packages/conversation-store/src/extension.ts42
1 files changed, 21 insertions, 21 deletions
diff --git a/packages/conversation-store/src/extension.ts b/packages/conversation-store/src/extension.ts
index cd03077..b86ffa7 100644
--- a/packages/conversation-store/src/extension.ts
+++ b/packages/conversation-store/src/extension.ts
@@ -2,30 +2,30 @@ import type { Extension, HostAPI, Manifest } from "@dispatch/kernel";
import { conversationStoreHandle, createConversationStore } from "./store.js";
export const manifest: Manifest = {
- id: "conversation-store",
- name: "Conversation Store",
- version: "0.0.0",
- apiVersion: "^0.1.0",
- trust: "bundled",
- capabilities: { db: true },
- contributes: { services: ["conversation-store/store"] },
- activation: "eager",
+ id: "conversation-store",
+ name: "Conversation Store",
+ version: "0.0.0",
+ apiVersion: "^0.1.0",
+ trust: "bundled",
+ capabilities: { db: true },
+ contributes: { services: ["conversation-store/store"] },
+ activation: "eager",
};
export const extension: Extension = {
- manifest,
- activate: async (host: HostAPI) => {
- const storage = host.storage("conversation-store");
- const store = createConversationStore(storage, host.logger, undefined, process.cwd());
+ manifest,
+ activate: async (host: HostAPI) => {
+ const storage = host.storage("conversation-store");
+ const store = createConversationStore(storage, host.logger, undefined, process.cwd());
- const stale = await store.listConversations({ status: ["active"] });
- for (const m of stale) {
- await store.setConversationStatus(m.id, "idle");
- }
- if (stale.length > 0) {
- host.logger.info("conversation-store: boot-sweep", { resetCount: stale.length });
- }
+ const stale = await store.listConversations({ status: ["active"] });
+ for (const m of stale) {
+ await store.setConversationStatus(m.id, "idle");
+ }
+ if (stale.length > 0) {
+ host.logger.info("conversation-store: boot-sweep", { resetCount: stale.length });
+ }
- host.provideService(conversationStoreHandle, store);
- },
+ host.provideService(conversationStoreHandle, store);
+ },
};