andyburke/autonomous.contact
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

feature: events polling

Browse source
This commit is contained in:
Andy Burke 2025-07-02 21:28:07 -07:00
parent 61a51017a3
commit b700251278
19 changed files with 353 additions and 77 deletions
Download patch file Download diff file Expand all files Collapse all files

16
public/api/rooms/:room_id/events/:event_id/index.ts
View file

@ -1,4 +1,5 @@
import { EVENT, EVENTS } from '../../../../../../models/event.ts';
import { FSDB_COLLECTION } from '@andyburke/fsdb';
import { EVENT, get_events_collection_for_room } from '../../../../../../models/event.ts';
import { ROOM, ROOMS } from '../../../../../../models/room.ts';
import parse_body from '../../../../../../utils/bodyparser.ts';
import * as CANNED_RESPONSES from '../../../../../../utils/canned_responses.ts';
@ -29,7 +30,8 @@ PRECHECKS.GET = [get_session, get_user, require_user, async (_req: Request, meta
}
}];
export async function GET(_req: Request, meta: Record<string, any>): Promise<Response> {
const event: EVENT | null = await EVENTS.get(meta.params.event_id);
const events: FSDB_COLLECTION<EVENT> = get_events_collection_for_room(meta.room.id);
const event: EVENT | null = await events.get(meta.params.event_id);
if (!event) {
return CANNED_RESPONSES.not_found();
@ -76,7 +78,8 @@ export async function PUT(req: Request, meta: Record<string, any>): Promise<Resp
const now = new Date().toISOString();
try {
const event: EVENT | null = await EVENTS.get(meta.params.event_id);
const events: FSDB_COLLECTION<EVENT> = get_events_collection_for_room(meta.room.id);
const event: EVENT | null = await events.get(meta.params.event_id);
if (!event) {
return CANNED_RESPONSES.not_found();
@ -98,7 +101,7 @@ export async function PUT(req: Request, meta: Record<string, any>): Promise<Resp
}
};
await EVENTS.update(updated);
await events.update(updated);
return Response.json(updated, {
status: 200
});
@ -147,12 +150,13 @@ PRECHECKS.DELETE = [
}
];
export async function DELETE(_req: Request, meta: Record<string, any>): Promise<Response> {
const event: EVENT | null = await EVENTS.get(meta.params.event_id);
const events: FSDB_COLLECTION<EVENT> = get_events_collection_for_room(meta.room.id);
const event: EVENT | null = await events.get(meta.params.event_id);
if (!event) {
return CANNED_RESPONSES.not_found();
}
await EVENTS.delete(event);
await events.delete(event);
return Response.json({
deleted: true

93
public/api/rooms/:room_id/events/index.ts
View file

@ -2,8 +2,10 @@ import lurid from 'jsr:@andyburke/lurid';
import { get_session, get_user, PRECHECK_TABLE, require_user } from '../../../../../utils/prechecks.ts';
import { ROOM, ROOMS } from '../../../../../models/room.ts';
import * as CANNED_RESPONSES from '../../../../../utils/canned_responses.ts';
import { EVENT, EVENTS } from '../../../../../models/event.ts';
import { EVENT, get_events_collection_for_room } from '../../../../../models/event.ts';
import parse_body from '../../../../../utils/bodyparser.ts';
import { FSDB_COLLECTION, FSDB_SEARCH_OPTIONS, WALK_ENTRY } from 'jsr:@andyburke/fsdb';
import * as path from 'jsr:@std/path';
export const PRECHECKS: PRECHECK_TABLE = {};
@ -31,30 +33,80 @@ PRECHECKS.GET = [get_session, get_user, require_user, async (_req: Request, meta
return CANNED_RESPONSES.permission_denied();
}
}];
export async function GET(_req: Request, meta: Record<string, any>): Promise<Response> {
const query: URLSearchParams = meta.query;
const partial_id: string | undefined = query.get('partial_id')?.toLowerCase().trim();
export async function GET(request: Request, meta: Record<string, any>): Promise<Response> {
const events: FSDB_COLLECTION<EVENT> = get_events_collection_for_room(meta.room.id);
const has_partial_id = typeof partial_id === 'string' && partial_id.length >= 2;
if (!has_partial_id) {
const sorts = events.sorts;
const sort_name: string = meta.query.sort ?? 'newest';
const key = sort_name as keyof typeof sorts;
const sort: any = sorts[key];
if (!sort) {
return Response.json({
error: {
message: 'You must specify a `partial_id` query parameter.',
cause: 'missing_query_parameter'
message: 'You must specify a sort: newest, oldest, latest, stalest',
cause: 'invalid_sort'
}
}, {
status: 400
});
}
const limit = Math.min(parseInt(query.get('limit') ?? '10'), 100);
const events = await EVENTS.all({
id_after: partial_id,
limit
});
const options: FSDB_SEARCH_OPTIONS<EVENT> = {
...(meta.query ?? {}),
limit: Math.min(parseInt(meta.query?.limit ?? '10'), 1_000),
sort,
filter: (entry: WALK_ENTRY<EVENT>) => {
const event_id = path.basename(entry.path).replace(/\.json$/i, '');
return Response.json(events, {
status: 200
if (meta.query.after_id && event_id <= meta.query.after_id) {
return false;
}
if (meta.query.before_id && event_id >= meta.query.before_id) {
return false;
}
return true;
}
};
const headers = {
'Cache-Control': 'no-cache, must-revalidate'
};
const results = (await events.all(options)).map((entry) => entry.load());
// long-polling support
if (results.length === 0 && meta.query.wait) {
return new Promise((resolve) => {
function on_create(create_event: any) {
results.push(create_event.item);
clearTimeout(timeout);
events.off('create', on_create);
return resolve(Response.json(results, {
status: 200,
headers
}));
}
const timeout = setTimeout(() => {
events.off('create', on_create);
return resolve(Response.json(results, {
status: 200,
headers
}));
}, 60_000); // 60 seconds
events.on('create', on_create);
request.signal.addEventListener('abort', () => {
events.off('create', on_create);
});
});
}
return Response.json(results, {
status: 200,
headers
});
}
@ -82,12 +134,15 @@ PRECHECKS.POST = [get_session, get_user, require_user, async (_req: Request, met
}];
export async function POST(req: Request, meta: Record<string, any>): Promise<Response> {
try {
const events: FSDB_COLLECTION<EVENT> = get_events_collection_for_room(meta.room.id);
const now = new Date().toISOString();
const body = await parse_body(req);
const new_event: EVENT = {
const event: EVENT = {
type: 'unknown',
...body,
id: `${meta.params.room_id}:${lurid()}`,
id: lurid(),
creator_id: meta.user.id,
timestamps: {
created: now,
@ -95,9 +150,9 @@ export async function POST(req: Request, meta: Record<string, any>): Promise<Res
}
};
await EVENTS.create(new_event);
await events.create(event);
return Response.json(new_event, {
return Response.json(event, {
status: 201
});
} catch (error) {