/** * RawStore — per-connector SQLite evidence storage. * Creates basePath//raw.db for each connector. * Uses the project's existing Database wrapper (sqlite.ts). */ import type { NormalizedItem } from './types.js'; interface ConnectorEventIndexInput { source_connector: string; source_type: string; source_id: string; source_locator: string; channel: string; author: string; content: string; event_datetime: number; source_timestamp_ms: number; source_cursor: string | null; tenant_id: string | null; project_id: string | null; memory_scope_kind: string | null; memory_scope_id: string | null; metadata: Record | null; content_hash: Buffer; } export interface RawStoreBackfillOptions { sourceCursor?: string; tenantId?: string; projectId?: string; memoryScopeKind?: string; memoryScopeId?: string; } export type RawIndexSink = (connectorName: string, items: NormalizedItem[]) => void | Promise; export declare function mapNormalizedItemsToConnectorEventIndexInputs(connectorName: string, items: NormalizedItem[]): ConnectorEventIndexInput[]; export declare class RawStore { private dbs; private readonly basePath; constructor(basePath: string); private getDb; private getDbPath; private mapRawRowToNormalizedItem; save(connectorName: string, items: NormalizedItem[]): void; query(connectorName: string, since: Date): NormalizedItem[]; hasConnector(connectorName: string): boolean; getRecent(connectorName: string, count: number): NormalizedItem[]; backfillProvenance(connectorName: string, options?: RawStoreBackfillOptions): number; close(): void; } export {}; //# sourceMappingURL=raw-store.d.ts.map