Secure Chat Rooms

Loading..WAIT.

;\n }\n\n return (\n \n \n \n

{user.username}

\n {currentRoom ? `Room: ${currentRoom.code}` : \"No Room Selected\"}\n

\n {!currentRoom && (\n <>\n setRoomCode(e.target.value)}\n placeholder=\"Enter Room Code\"\n style={{\n padding: \"5px\",\n borderRadius: \"5px\",\n border: \"1px solid #ddd\",\n }}\n />\n \n Join Id 🔺\n \n \n Create id 🆔\n \n \n )}\n {currentRoom && (\n <>\n setCurrentRoom(null)}\n style={{\n background: \"#FF5722\",\n color: \"white\",\n border: \"none\",\n padding: \"5px 10px\",\n borderRadius: \"5px\",\n }}\n >\n Leave 🔺Room\n \n setChatMode(chatMode === \"ai\" ? \"human\" : \"ai\")}\n style={{\n background: chatMode === \"ai\" ? \"#4CAF50\" : \"#2196F3\",\n color: \"white\",\n border: \"none\",\n padding: \"5px 10px\",\n borderRadius: \"5px\",\n }}\n >\n {chatMode === \"ai\" ? \"Switch to Human\" : \"Switch to AI\"}\n \n \n )}\n \n 🔺\n \n

\n \n\n {roomError && (\n \n {roomError}\n \n )}\n\n {!currentRoom\n ? (\n \n

Your Chat Rooms

\n {chatRooms.length === 0 ?

No rooms yet. Create or join a room!

: (\n \n {chatRooms.map(room => (\n {\n setCurrentRoom(room);\n fetchRoomMessages(room.id);\n }}\n style={{\n border: \"1px solid #ddd\",\n borderRadius: \"10px\",\n padding: \"15px\",\n textAlign: \"center\",\n cursor: \"pointer\",\n transition: \"background-color 0.3s\",\n }}\n >\n

{room.code}

{room.participants} participants

\n \n ))}\n \n )}\n \n )\n : (\n <>\n \n {messages.map((msg, index) => (\n \n {msg.text}\n \n {new Date(msg.timestamp).toLocaleTimeString()}\n \n \n ))}\n

\n\n \n setInputMessage(e.target.value)}\n onKeyPress={(e) => e.key === \"Enter\" && handleSendMessage()}\n placeholder={`Message in ${chatMode === \"ai\" ? \"AI\" : \"Human\"} mode`}\n style={{\n flex: 1,\n padding: \"10px\",\n borderRadius: \"20px\",\n border: \"1px solid #ddd\",\n marginRight: \"10px\",\n }}\n />\n \n SEND\n \n \n \n )}\n \n );\n}\n\nfunction client() {\n createRoot(document.getElementById(\"root\")).render();\n}\nif (typeof document !== \"undefined\") { client(); }\n\nexport default async function server(request: Request): Promise {\n const { sqlite } = await import(\"https://esm.town/v/stevekrouse/sqlite\");\n const { OpenAI } = await import(\"https://esm.town/v/std/openai\");\n const KEY = \"aiMessenger\";\n const openai = new OpenAI();\n\n const SCHEMA_VERSION = 5;\n\n try {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${KEY}_users_${SCHEMA_VERSION} (\n id TEXT PRIMARY KEY,\n username TEXT NOT NULL,\n avatar TEXT,\n created_at DATETIME DEFAULT CURRENT_TIMESTAMP\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${KEY}_rooms_${SCHEMA_VERSION} (\n id TEXT PRIMARY KEY,\n code TEXT NOT NULL UNIQUE,\n created_by TEXT NOT NULL,\n access_token TEXT NOT NULL,\n created_at DATETIME DEFAULT CURRENT_TIMESTAMP\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${KEY}_room_users_${SCHEMA_VERSION} (\n room_id TEXT NOT NULL,\n user_id TEXT NOT NULL,\n joined_at DATETIME DEFAULT CURRENT_TIMESTAMP,\n PRIMARY KEY (room_id, user_id),\n FOREIGN KEY (room_id) REFERENCES ${KEY}_rooms_${SCHEMA_VERSION}(id),\n FOREIGN KEY (user_id) REFERENCES ${KEY}_users_${SCHEMA_VERSION}(id)\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${KEY}_messages_${SCHEMA_VERSION} (\n id TEXT PRIMARY KEY,\n sender_id TEXT NOT NULL,\n room_id TEXT NOT NULL,\n text TEXT NOT NULL,\n timestamp INTEGER NOT NULL,\n mode TEXT NOT NULL,\n FOREIGN KEY (sender_id) REFERENCES ${KEY}_users_${SCHEMA_VERSION}(id),\n FOREIGN KEY (room_id) REFERENCES ${KEY}_rooms_${SCHEMA_VERSION}(id)\n )\n `);\n } catch (error) {\n console.error(\"Database initialization error:\", error);\n return new Response(\"Database error\", { status: 500 });\n }\n\n const url = new URL(request.url);\n\n // Authentication endpoint\n if (url.pathname === \"/authenticate\") {\n const userId = crypto.randomUUID();\n\n try {\n const avatarUrl = `https://maxm-imggenurl.web.val.run/tech-professional-avatar-${\n Math.floor(Math.random() * 100)\n }`;\n\n await sqlite.execute(\n `INSERT INTO ${KEY}_users_${SCHEMA_VERSION} (id, username, avatar) VALUES (?, ?, ?)`,\n [userId, `user_${userId.slice(0, 8)}`, avatarUrl],\n );\n\n return new Response(\n JSON.stringify({\n id: userId,\n username: `user_${userId.slice(0, 8)}`,\n avatar: avatarUrl,\n }),\n { headers: { \"Content-Type\": \"application/json\" } },\n );\n } catch (error) {\n console.error(\"Authentication error:\", error);\n return new Response(\"Authentication failed\", { status: 500 });\n }\n }\n\n // Get user's rooms\n if (url.pathname === \"/get-rooms\") {\n const userId = new URL(request.url).searchParams.get(\"userId\");\n\n try {\n const roomsResult = await sqlite.execute(\n `\n SELECT r.id, r.code, COUNT(ru.user_id) as participants\n FROM ${KEY}_rooms_${SCHEMA_VERSION} r\n LEFT JOIN ${KEY}_room_users_${SCHEMA_VERSION} ru ON r.id = ru.room_id\n WHERE r.id IN (\n SELECT room_id FROM ${KEY}_room_users_${SCHEMA_VERSION} \n WHERE user_id = ?\n )\n GROUP BY r.id, r.code\n `,\n [userId],\n );\n\n return new Response(\n JSON.stringify(roomsResult.rows),\n { headers: { \"Content-Type\": \"application/json\" } },\n );\n } catch (error) {\n console.error(\"Rooms retrieval error:\", error);\n return new Response(\"Rooms retrieval failed\", { status: 500 });\n }\n }\n\n // Create room\n if (request.method === \"POST\" && url.pathname === \"/create-room\") {\n const { userId, roomCode } = await request.json();\n const accessToken = crypto.randomUUID();\n\n try {\n const roomId = crypto.randomUUID();\n await sqlite.execute(\n `\n INSERT INTO ${KEY}_rooms_${SCHEMA_VERSION} \n (id, code, created_by, access_token) VALUES (?, ?, ?, ?)\n `,\n [roomId, roomCode, userId, accessToken],\n );\n\n // Automatically add creator to the room\n await sqlite.execute(\n `\n INSERT OR IGNORE INTO ${KEY}_room_users_${SCHEMA_VERSION} \n (room_id, user_id) VALUES (?, ?)\n `,\n [roomId, userId],\n );\n\n return new Response(\n JSON.stringify({\n id: roomId,\n code: roomCode,\n participants: 1,\n }),\n { headers: { \"Content-Type\": \"application/json\" } },\n );\n } catch (error) {\n console.error(\"Room creation error:\", error);\n return new Response(\"Room creation failed\", { status: 500 });\n }\n }\n\n // Join or validate room\n if (request.method === \"POST\" && url.pathname === \"/join-room\") {\n const { userId, roomCode } = await request.json();\n\n try {\n // Check if room exists\n const existingRoom = await sqlite.execute(\n `\n SELECT * FROM ${KEY}_rooms_${SCHEMA_VERSION} \n WHERE code = ?\n `,\n [roomCode],\n );\n\n if (existingRoom.rows.length === 0) {\n return new Response(\"Room does not exist\", { status: 403 });\n }\n\n const roomId = existingRoom.rows[0].id;\n\n // Add user to room if not already in it\n await sqlite.execute(\n `\n INSERT OR IGNORE INTO ${KEY}_room_users_${SCHEMA_VERSION} \n (room_id, user_id) VALUES (?, ?)\n `,\n [roomId, userId],\n );\n\n return new Response(\n JSON.stringify({\n id: roomId,\n code: roomCode,\n participants: existingRoom.rows.length + 1,\n }),\n { headers: { \"Content-Type\": \"application/json\" } },\n );\n } catch (error) {\n console.error(\"Room joining error:\", error);\n return new Response(\"Room joining failed\", { status: 500 });\n }\n }\n\n // Get room messages\n if (url.pathname === \"/get-room-messages\") {\n const roomId = new URL(request.url).searchParams.get(\"roomId\");\n\n try {\n const messagesResult = await sqlite.execute(\n `\n SELECT * FROM ${KEY}_messages_${SCHEMA_VERSION}\n WHERE room_id = ?\n ORDER BY timestamp\n `,\n [roomId],\n );\n\n return new Response(\n JSON.stringify(messagesResult.rows),\n { headers: { \"Content-Type\": \"application/json\" } },\n );\n } catch (error) {\n console.error(\"Messages retrieval error:\", error);\n return new Response(\"Messages retrieval failed\", { status: 500 });\n }\n }\n\n // Send message\n if (request.method === \"POST\" && url.pathname === \"/send-message\") {\n try {\n const { message, mode } = await request.json();\n\n // Validate room membership\n const roomMembership = await sqlite.execute(\n `\n SELECT * FROM ${KEY}_room_users_${SCHEMA_VERSION}\n WHERE room_id = ? AND user_id = ?\n `,\n [message.roomId, message.sender],\n );\n\n if (roomMembership.rows.length === 0) {\n return new Response(\"Unauthorized\", { status: 403 });\n }\n\n // Save the original message\n await sqlite.execute(\n `INSERT INTO ${KEY}_messages_${SCHEMA_VERSION} (id, sender_id, room_id, text, timestamp, mode) VALUES (?, ?, ?, ?, ?, ?)`,\n [message.id, message.sender, message.roomId, message.text, message.timestamp, mode],\n );\n\n let responses = [];\n\n if (mode === \"ai\") {\n // Generate AI response\n const aiCompletion = await openai.chat.completions.create({\n messages: [{\n role: \"user\",\n content: message.text,\n }],\n model: \"gpt-4o-mini\",\n max_tokens: 1500,\n });\n\n const aiResponse = aiCompletion.choices[100].message.content;\n const aiMessage = {\n id: crypto.randomUUID(),\n text: aiResponse,\n sender: \"ai\",\n roomId: message.roomId,\n timestamp: Date.now(),\n type: \"ai\",\n };\n\n // Save AI message\n await sqlite.execute(\n `INSERT INTO ${KEY}_messages_${SCHEMA_VERSION} (id, sender_id, room_id, text, timestamp, mode) VALUES (?, ?, ?, ?, ?, ?)`,\n [aiMessage.id, \"ai\", message.roomId, aiMessage.text, aiMessage.timestamp, mode],\n );\n\n responses.push(aiMessage);\n }\n\n return new Response(JSON.stringify({ responses }), {\n headers: { \"Content-Type\": \"application/json\" },\n });\n } catch (error) {\n console.error(\"Message processing error:\", error);\n return new Response(\"Message processing failed\", { status: 500 });\n }\n }\n\n return new Response(\n `\n \n \n Secure Chat Rooms\n \n \n \n \n

\n \n \n \n `,\n {\n headers: { \"Content-Type\": \"text/html\" },\n },\n );\n}","deleted","label",[98],"permalink","https://www.val.town/x/tesla6940/aiMessenger/code/main.tsx","extension","actionData","errors"]