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

feature: chat is working?

Browse source
This commit is contained in:
Andy Burke 2025-07-04 12:15:06 -07:00
parent b700251278
commit 200b89954b
9 changed files with 189 additions and 71 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -56,7 +56,7 @@ export async function GET(request: Request, meta: Record<string, any>): Promise<
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, '');
const [event_id, event_type] = path.basename(entry.path).replace(/\.json$/i, '').split(':');
if (meta.query.after_id && event_id <= meta.query.after_id) {
return false;
@ -66,6 +66,10 @@ export async function GET(request: Request, meta: Record<string, any>): Promise<
return false;
}
if (meta.query.type && event_type !== meta.query.type) {
return false;
}
return true;
}
};
@ -78,7 +82,7 @@ export async function GET(request: Request, meta: Record<string, any>): Promise<
// long-polling support
if (results.length === 0 && meta.query.wait) {
return new Promise((resolve) => {
return new Promise((resolve, reject) => {
function on_create(create_event: any) {
results.push(create_event.item);
clearTimeout(timeout);
@ -101,6 +105,13 @@ export async function GET(request: Request, meta: Record<string, any>): Promise<
request.signal.addEventListener('abort', () => {
events.off('create', on_create);
});
Deno.addSignalListener('SIGINT', () => {
events.off('create', on_create);
return resolve(Response.json(results, {
status: 200,
headers
}));
});
});
}
@ -142,7 +153,6 @@ export async function POST(req: Request, meta: Record<string, any>): Promise<Res
const event: EVENT = {
type: 'unknown',
...body,
id: lurid(),
creator_id: meta.user.id,
timestamps: {
created: now,
@ -150,6 +160,8 @@ export async function POST(req: Request, meta: Record<string, any>): Promise<Res
}
};
event.id = `${lurid()}:${event.type}`;
await events.create(event);
return Response.json(event, {

12
public/api/rooms/index.ts
View file

@ -4,6 +4,7 @@ import { get_session, get_user, require_user } from '../../../utils/prechecks.ts
import * as CANNED_RESPONSES from '../../../utils/canned_responses.ts';
import { PRECHECK_TABLE } from '../../../utils/prechecks.ts';
import { ROOM, ROOMS } from '../../../models/room.ts';
import { WALK_ENTRY } from 'jsr:@andyburke/fsdb';
export const PRECHECKS: PRECHECK_TABLE = {};
@ -17,9 +18,14 @@ PRECHECKS.GET = [get_session, get_user, require_user, (_req: Request, meta: Reco
}];
export async function GET(_req: Request, meta: Record<string, any>): Promise<Response> {
const limit = Math.min(parseInt(meta.query.limit ?? '100'), 100);
const rooms = await ROOMS.all({
limit
});
const rooms = (await ROOMS.all({
limit,
filter: (entry: WALK_ENTRY<ROOM>) => {
// we push our event collections into the rooms, and fsdb
// doesn't yet filter that out in its all() logic
return entry.path.indexOf('/events/') === -1;
}
})).map((item) => item.load());
return Response.json(rooms, {
status: 200