moon
/
ditto
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

db/events: add comments

This commit is contained in:
Alex Gleason 2023-08-12 15:45:58 -05:00
parent 4c8a685528
commit 9da4fb2bba
No known key found for this signature in database
GPG Key ID: 7211D1F99744FBB7
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/db/events.ts
View File

@ -15,6 +15,7 @@ const tagConditions: Record<string, TagCondition> = {
't': ({ count }) => count < 5, 't': ({ count }) => count < 5,
}; };
/** Insert an event (and its tags) into the database. */
function insertEvent(event: SignedEvent): Promise<void> { function insertEvent(event: SignedEvent): Promise<void> {
return db.transaction().execute(async (trx) => { return db.transaction().execute(async (trx) => {
await trx.insertInto('events') await trx.insertInto('events')
@ -50,10 +51,12 @@ function insertEvent(event: SignedEvent): Promise<void> {
}); });
} }
/** Custom filter interface that extends Nostr filters with extra options for Ditto. */
interface DittoFilter<K extends number = number> extends Filter<K> { interface DittoFilter<K extends number = number> extends Filter<K> {
local?: boolean; local?: boolean;
} }
/** Build the query for a filter. */
function getFilterQuery(filter: DittoFilter) { function getFilterQuery(filter: DittoFilter) {
let query = db let query = db
.selectFrom('events') .selectFrom('events')
@ -107,6 +110,7 @@ function getFilterQuery(filter: DittoFilter) {
return query; return query;
} }
/** Get events for filters from the database. */
async function getFilters<K extends number>(filters: [DittoFilter<K>]): Promise<SignedEvent<K>[]>; async function getFilters<K extends number>(filters: [DittoFilter<K>]): Promise<SignedEvent<K>[]>;
async function getFilters(filters: DittoFilter[]): Promise<SignedEvent[]>; async function getFilters(filters: DittoFilter[]): Promise<SignedEvent[]>;
async function getFilters(filters: DittoFilter[]) { async function getFilters(filters: DittoFilter[]) {
@ -121,6 +125,7 @@ async function getFilters(filters: DittoFilter[]) {
)); ));
} }
/** Get events for a filter from the database. */
function getFilter<K extends number = number>(filter: DittoFilter<K>): Promise<SignedEvent<K>[]> { function getFilter<K extends number = number>(filter: DittoFilter<K>): Promise<SignedEvent<K>[]> {
return getFilters<K>([filter]); return getFilters<K>([filter]);
} }