chat.server.ts RawHistoryFolder

1import type { LibSQLDatabase } from "drizzle-orm/libsql";
2import { createLogger } from "$lib/utils/logger.server";
3import schema, { chatRooms } from "$lib/db/schema";
4import { eq } from "drizzle-orm";
5import { env } from "$env/dynamic/public";
6
7const log = createLogger('chat-utils');
8
9// Default chat room ID from environment variable
10export const DEFAULT_CHAT_ROOM_ID = env.PUBLIC_DEFAULT_CHAT_ROOM_ID || '00000000-0000-0000-0000-000000000001';
11
12// Type guard for LibSQL errors
13interface LibSQLError {
14    code: string;
15    message: string;
16}
17
18function isLibSQLError(error: unknown): error is LibSQLError {
19    return typeof error === 'object' && error !== null && 'code' in error;
20}
21
22// Function to ensure default chat room exists
23export async function ensureDefaultChatRoom(db: LibSQLDatabase<typeof schema>) {
24    log.debug('Ensuring default chat room exists...');
25    try {
26        // Use a transaction to handle concurrent creation attempts
27        await db.transaction(async (tx) => {
28            const defaultRoom = await tx.select()
29                .from(chatRooms)
30                .where(eq(chatRooms.id, DEFAULT_CHAT_ROOM_ID))
31                .get();
32
33            if (!defaultRoom) {
34                log.debug('Creating default chat room...');
35                await tx.insert(chatRooms).values({
36                    id: DEFAULT_CHAT_ROOM_ID,
37                    name: 'General',
38                    type: 'group',
39                    createdAt: Date.now()
40                });
41                log.debug('Default chat room created successfully');
42            } else {
43                log.debug('Default chat room already exists');
44            }
45        });
46    } catch (error: unknown) {
47        // If the error is a unique constraint violation, another process probably created the room
48        if (isLibSQLError(error) && error.code === 'SQLITE_CONSTRAINT') {
49            log.debug('Default chat room was created by another process');
50            return;
51        }
52        log.error('Error ensuring default chat room:', { error: error instanceof Error ? error.message : 'Unknown error' });
53        throw error;
54    }
55}