diff --git a/src/events/gateway-integration.ts b/src/events/gateway-integration.ts index aa8115c41..2aec6ac30 100644 --- a/src/events/gateway-integration.ts +++ b/src/events/gateway-integration.ts @@ -12,13 +12,8 @@ import type { MoltbotConfig } from "../config/config.js"; import { onAgentEvent, type AgentEventPayload } from "../infra/agent-events.js"; import { onDiagnosticEvent, type DiagnosticEventPayload } from "../infra/diagnostic-events.js"; -import { - createEventBus, - setEventBus, - getEventBus, - type EventBus, - type EventBusConfig, -} from "./bus.js"; +import { createEventBus, setEventBus, getEventBus } from "./bus.js"; +import type { EventBus, EventBusConfig } from "./types.js"; import { createEventStore, getDefaultEventStorePath } from "./store.js"; import { createEvent, type EventTopicMap } from "./catalog.js"; diff --git a/src/events/store.ts b/src/events/store.ts index 545f5594e..c8bff401e 100644 --- a/src/events/store.ts +++ b/src/events/store.ts @@ -249,7 +249,7 @@ export function createEventStore(config: EventStoreConfig): EventStore & { const prune = async (olderThan: number): Promise => { const result = pruneByTimeStmt.run(olderThan); - return result.changes; + return Number(result.changes); }; const close = (): void => {