@frontmcp/storage-sqlite
Advanced tools
+7
-1
@@ -505,2 +505,8 @@ var __require = /* @__PURE__ */ ((x) => typeof require !== "undefined" ? require : typeof Proxy !== "undefined" ? new Proxy(x, { | ||
| /** | ||
| * Get the underlying database instance. | ||
| */ | ||
| getDatabase() { | ||
| return this.db; | ||
| } | ||
| /** | ||
| * Get the current number of stored events. | ||
@@ -522,3 +528,3 @@ */ | ||
| }).optional(), | ||
| ttlCleanupIntervalMs: z.number().int().positive().optional().default(6e4), | ||
| ttlCleanupIntervalMs: z.number().int().nonnegative().optional().default(6e4), | ||
| walMode: z.boolean().optional().default(true) | ||
@@ -525,0 +531,0 @@ }); |
+2
-2
| { | ||
| "name": "@frontmcp/storage-sqlite", | ||
| "version": "0.12.2", | ||
| "version": "1.0.0-beta.1", | ||
| "description": "SQLite storage backend for FrontMCP - local session, elicitation, and event persistence without Redis", | ||
@@ -47,3 +47,3 @@ "author": "AgentFront <info@agentfront.dev>", | ||
| "dependencies": { | ||
| "@frontmcp/utils": "0.12.2", | ||
| "@frontmcp/utils": "1.0.0-beta.1", | ||
| "better-sqlite3": "^12.6.2" | ||
@@ -50,0 +50,0 @@ }, |
+7
-1
@@ -524,2 +524,8 @@ "use strict"; | ||
| /** | ||
| * Get the underlying database instance. | ||
| */ | ||
| getDatabase() { | ||
| return this.db; | ||
| } | ||
| /** | ||
| * Get the current number of stored events. | ||
@@ -541,3 +547,3 @@ */ | ||
| }).optional(), | ||
| ttlCleanupIntervalMs: import_zod.z.number().int().positive().optional().default(6e4), | ||
| ttlCleanupIntervalMs: import_zod.z.number().int().nonnegative().optional().default(6e4), | ||
| walMode: import_zod.z.boolean().optional().default(true) | ||
@@ -544,0 +550,0 @@ }); |
+2
-2
| { | ||
| "name": "@frontmcp/storage-sqlite", | ||
| "version": "0.12.2", | ||
| "version": "1.0.0-beta.1", | ||
| "description": "SQLite storage backend for FrontMCP - local session, elicitation, and event persistence without Redis", | ||
@@ -47,3 +47,3 @@ "author": "AgentFront <info@agentfront.dev>", | ||
| "dependencies": { | ||
| "@frontmcp/utils": "0.12.2", | ||
| "@frontmcp/utils": "1.0.0-beta.1", | ||
| "better-sqlite3": "^12.6.2" | ||
@@ -50,0 +50,0 @@ }, |
| /** | ||
| * SQLite Event Store | ||
| * | ||
| * Implements the EventStore interface from @modelcontextprotocol/sdk for SSE resumability. | ||
| * Implements the EventStore interface from @frontmcp/protocol for SSE resumability. | ||
| * Stores events in SQLite with TTL-based expiration and max event limits. | ||
| */ | ||
| import type Database from 'better-sqlite3'; | ||
| import type { SqliteStorageOptions } from './sqlite.options'; | ||
| /** | ||
| * Event store interface matching @modelcontextprotocol/sdk EventStore. | ||
| * Redeclared here to avoid hard dependency on @modelcontextprotocol/sdk. | ||
| * Event store interface matching @frontmcp/protocol EventStore. | ||
| * Redeclared here to avoid hard dependency on @frontmcp/protocol. | ||
| */ | ||
@@ -65,2 +66,6 @@ export interface EventStoreInterface { | ||
| /** | ||
| * Get the underlying database instance. | ||
| */ | ||
| getDatabase(): Database.Database; | ||
| /** | ||
| * Get the current number of stored events. | ||
@@ -67,0 +72,0 @@ */ |
@@ -1,1 +0,1 @@ | ||
| {"version":3,"file":"sqlite-event.store.d.ts","sourceRoot":"","sources":["../src/sqlite-event.store.ts"],"names":[],"mappings":"AAAA;;;;;GAKG;AAGH,OAAO,KAAK,EAAE,oBAAoB,EAAE,MAAM,kBAAkB,CAAC;AAE7D;;;GAGG;AACH,MAAM,WAAW,mBAAmB;IAClC,UAAU,CAAC,QAAQ,EAAE,MAAM,EAAE,OAAO,EAAE,OAAO,GAAG,OAAO,CAAC,MAAM,CAAC,CAAC;IAChE,iBAAiB,CACf,WAAW,EAAE,MAAM,EACnB,SAAS,EAAE;QAAE,IAAI,EAAE,CAAC,OAAO,EAAE,MAAM,EAAE,OAAO,EAAE,OAAO,KAAK,OAAO,CAAC,IAAI,CAAC,CAAA;KAAE,GACxE,OAAO,CAAC,MAAM,CAAC,CAAC;CACpB;AAED,MAAM,WAAW,uBAAwB,SAAQ,oBAAoB;IACnE,wEAAwE;IACxE,SAAS,CAAC,EAAE,MAAM,CAAC;IACnB,yEAAyE;IACzE,KAAK,CAAC,EAAE,MAAM,CAAC;CAChB;AAaD;;;;;;;;;;;;GAYG;AACH,qBAAa,gBAAiB,YAAW,mBAAmB;IAC1D,OAAO,CAAC,EAAE,CAAoB;IAC9B,OAAO,CAAC,SAAS,CAAS;IAC1B,OAAO,CAAC,KAAK,CAAS;IACtB,OAAO,CAAC,QAAQ,CAA6B;IAC7C,OAAO,CAAC,YAAY,CAA+C;IACnE,OAAO,CAAC,KAAK,CAAmC;gBAEpC,OAAO,EAAE,uBAAuB;IA+B5C,OAAO,CAAC,UAAU;IAalB,OAAO,CAAC,iBAAiB;IAgBzB;;OAEG;IACH,OAAO,CAAC,QAAQ;IAOhB;;OAEG;IACH,OAAO,CAAC,cAAc;IAmBhB,UAAU,CAAC,QAAQ,EAAE,MAAM,EAAE,OAAO,EAAE,OAAO,GAAG,OAAO,CAAC,MAAM,CAAC;IAoB/D,iBAAiB,CACrB,WAAW,EAAE,MAAM,EACnB,EAAE,IAAI,EAAE,EAAE;QAAE,IAAI,EAAE,CAAC,OAAO,EAAE,MAAM,EAAE,OAAO,EAAE,OAAO,KAAK,OAAO,CAAC,IAAI,CAAC,CAAA;KAAE,GACvE,OAAO,CAAC,MAAM,CAAC;IAyBlB,OAAO,CAAC,YAAY;IAMpB;;OAEG;IACH,KAAK,IAAI,IAAI;IAQb;;OAEG;IACH,IAAI,IAAI,IAAI,MAAM,CAIjB;CACF"} | ||
| {"version":3,"file":"sqlite-event.store.d.ts","sourceRoot":"","sources":["../src/sqlite-event.store.ts"],"names":[],"mappings":"AAAA;;;;;GAKG;AAEH,OAAO,KAAK,QAAQ,MAAM,gBAAgB,CAAC;AAC3C,OAAO,KAAK,EAAE,oBAAoB,EAAE,MAAM,kBAAkB,CAAC;AAE7D;;;GAGG;AACH,MAAM,WAAW,mBAAmB;IAClC,UAAU,CAAC,QAAQ,EAAE,MAAM,EAAE,OAAO,EAAE,OAAO,GAAG,OAAO,CAAC,MAAM,CAAC,CAAC;IAChE,iBAAiB,CACf,WAAW,EAAE,MAAM,EACnB,SAAS,EAAE;QAAE,IAAI,EAAE,CAAC,OAAO,EAAE,MAAM,EAAE,OAAO,EAAE,OAAO,KAAK,OAAO,CAAC,IAAI,CAAC,CAAA;KAAE,GACxE,OAAO,CAAC,MAAM,CAAC,CAAC;CACpB;AAED,MAAM,WAAW,uBAAwB,SAAQ,oBAAoB;IACnE,wEAAwE;IACxE,SAAS,CAAC,EAAE,MAAM,CAAC;IACnB,yEAAyE;IACzE,KAAK,CAAC,EAAE,MAAM,CAAC;CAChB;AAaD;;;;;;;;;;;;GAYG;AACH,qBAAa,gBAAiB,YAAW,mBAAmB;IAC1D,OAAO,CAAC,EAAE,CAAoB;IAC9B,OAAO,CAAC,SAAS,CAAS;IAC1B,OAAO,CAAC,KAAK,CAAS;IACtB,OAAO,CAAC,QAAQ,CAA6B;IAC7C,OAAO,CAAC,YAAY,CAA+C;IACnE,OAAO,CAAC,KAAK,CAAmC;gBAEpC,OAAO,EAAE,uBAAuB;IA+B5C,OAAO,CAAC,UAAU;IAalB,OAAO,CAAC,iBAAiB;IAgBzB;;OAEG;IACH,OAAO,CAAC,QAAQ;IAOhB;;OAEG;IACH,OAAO,CAAC,cAAc;IAmBhB,UAAU,CAAC,QAAQ,EAAE,MAAM,EAAE,OAAO,EAAE,OAAO,GAAG,OAAO,CAAC,MAAM,CAAC;IAoB/D,iBAAiB,CACrB,WAAW,EAAE,MAAM,EACnB,EAAE,IAAI,EAAE,EAAE;QAAE,IAAI,EAAE,CAAC,OAAO,EAAE,MAAM,EAAE,OAAO,EAAE,OAAO,KAAK,OAAO,CAAC,IAAI,CAAC,CAAA;KAAE,GACvE,OAAO,CAAC,MAAM,CAAC;IAyBlB,OAAO,CAAC,YAAY;IAMpB;;OAEG;IACH,KAAK,IAAI,IAAI;IAQb;;OAEG;IACH,WAAW,IAAI,QAAQ,CAAC,QAAQ;IAIhC;;OAEG;IACH,IAAI,IAAI,IAAI,MAAM,CAIjB;CACF"} |
74171
0.58%1516
1.13%+ Added
- Removed
Updated