chatRoomsInternal.ts RawHistoryFolder

1import { internalQuery, internalMutation } from './_generated/server';
2import { v } from 'convex/values';
3
4// Get chat room by ID (internal)
5export const getById = internalQuery({
6	args: { id: v.id('chatRooms') },
7	handler: async (ctx, args) => {
8		return await ctx.db.get(args.id);
9	}
10});
11
12// List all chat rooms (internal)
13export const list = internalQuery({
14	args: {},
15	handler: async (ctx) => {
16		return await ctx.db.query('chatRooms').collect();
17	}
18});
19
20// Create a chat room (internal)
21export const create = internalMutation({
22	args: {
23		name: v.optional(v.string()),
24		type: v.string()
25	},
26	handler: async (ctx, args) => {
27		const roomId = await ctx.db.insert('chatRooms', {
28			name: args.name,
29			type: args.type,
30			createdAt: Date.now()
31		});
32
33		return await ctx.db.get(roomId);
34	}
35});
36
37// Get or create the default "General" room (internal)
38export const getOrCreateDefault = internalMutation({
39	args: {},
40	handler: async (ctx) => {
41		// Look for existing General room
42		const rooms = await ctx.db.query('chatRooms').collect();
43		const generalRoom = rooms.find((r) => r.name === 'General' && r.type === 'group');
44
45		if (generalRoom) {
46			return generalRoom;
47		}
48
49		// Create default room
50		const roomId = await ctx.db.insert('chatRooms', {
51			name: 'General',
52			type: 'group',
53			createdAt: Date.now()
54		});
55
56		return await ctx.db.get(roomId);
57	}
58});