autonomous.contact/public/api/rooms/index.ts

import lurid from '@andyburke/lurid';
import parse_body from '../../../utils/bodyparser.ts';
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 '@andyburke/fsdb';

export const PRECHECKS: PRECHECK_TABLE = {};

// GET /api/rooms - get rooms
PRECHECKS.GET = [get_session, get_user, require_user, (_req: Request, meta: Record<string, any>): Response | undefined => {
	const can_read_rooms = meta.user.permissions.includes('rooms.read');

	if (!can_read_rooms) {
		return CANNED_RESPONSES.permission_denied();
	}
}];
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,
		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((room_entry) => room_entry.load());

	return Response.json(rooms, {
		status: 200
	});
}

// POST /api/rooms - Create a room
PRECHECKS.POST = [get_session, get_user, require_user, (_req: Request, meta: Record<string, any>): Response | undefined => {
	const can_create_rooms = meta.user.permissions.includes('rooms.create');

	if (!can_create_rooms) {
		return CANNED_RESPONSES.permission_denied();
	}
}];
export async function POST(req: Request, meta: Record<string, any>): Promise<Response> {
	try {
		const now = new Date().toISOString();

		const body = await parse_body(req);

		if (typeof body.name !== 'string' || body.name.length === 0) {
			return Response.json({
				error: {
					cause: 'missing_room_name',
					message: 'You must specify a unique name for a room.'
				}
			}, {
				status: 400
			});
		}

		if (body.name.length > 64) {
			return Response.json({
				error: {
					cause: 'invalid_room_name',
					message: 'Room names must be 64 characters or fewer.'
				}
			}, {
				status: 400
			});
		}

		const normalized_name = body.name.toLowerCase();

		const existing_room = (await ROOMS.find({
			name: normalized_name
		})).shift();
		if (existing_room) {
			return Response.json({
				error: {
					cause: 'room_name_conflict',
					message: 'There is already a room with this name.'
				}
			}, {
				status: 400
			});
		}

		const room: ROOM = {
			...body,
			id: lurid(),
			creator_id: meta.user.id,
			permissions: {
				read: (body.permissions?.read ?? []),
				write: (body.permissions?.write ?? [meta.user.id]),
				read_events: (body.permissions?.read_events ?? []),
				write_events: (body.permissions?.write_events ?? [])
			},
			timestamps: {
				created: now,
				updated: now,
				archived: undefined
			}
		};

		await ROOMS.create(room);

		return Response.json(room, {
			status: 201
		});
	} catch (error) {
		return Response.json({
			error: {
				message: (error as Error).message ?? 'Unknown Error!',
				cause: (error as Error).cause ?? 'unknown'
			}
		}, { status: 500 });
	}
}