diff --git a/src/data_providers/sqlite/index.ts b/src/data_providers/sqlite/index.ts index dd6bf04..9368efa 100644 --- a/src/data_providers/sqlite/index.ts +++ b/src/data_providers/sqlite/index.ts @@ -25,14 +25,14 @@ const provider: DataProvider = { }, "events": { "get": async (id: string): Promise => { - const event: Event | undefined = convertFromSqlite(await db.get("SELECT (id, pubkey, created_at, kind, tags, content, sig) FROM Event WHERE id = ?", id)); + const event: Event | undefined = convertFromSqlite(await db.get("SELECT id, pubkey, created_at, kind, tags, content, sig FROM Event WHERE id = ?", id)); if (event && isEventExpired(event) === false) { return event; } return undefined; }, "getAll": async (): Promise => { - const events: Event[] = (await db.all("SELECT (id, pubkey, created_at, kind, tags, content, sig) FROM Event")).map((event) => convertFromSqlite(event)); + const events: Event[] = (await db.all("SELECT id, pubkey, created_at, kind, tags, content, sig FROM Event")).map((event) => convertFromSqlite(event)); return events.filter((event) => isEventExpired(event) === false); }, "delete": async (id: string): Promise => { @@ -47,7 +47,7 @@ const provider: DataProvider = { return parseInt(count.count) > 0; }, "purgeExpired": async (): Promise => { - const events: Event[] = (await db.all("SELECT (id, pubkey, created_at, kind, tags, content, sig) FROM Event")).map((event) => convertFromSqlite(event)); + const events: Event[] = (await db.all("SELECT id, pubkey, created_at, kind, tags, content, sig FROM Event")).map((event) => convertFromSqlite(event)); const expiredEvents: Event[] = events.filter((event) => isEventExpired(event)); console.log(`Purging ${expiredEvents.length} expired events`); await Promise.all(expiredEvents.map((event) => db.run("DELETE FROM Event WHERE id = ?", event.id)));