Secure Chat Rooms

;\n }\n\n return (\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 \n \n )}\n {currentRoom && (\n <>\n \n \n \n )}\n \n ⚙️\n \n

\n \n {roomError && (\n

\n {roomError}\n

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

Your Chat Rooms

\n {chatRooms.length === 0 ? (\n

No rooms yet. Create or join a room!

\n ) : (\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 {messages.map((msg, index) => (\n

\n {msg.text}\n

\n {new Date(msg.timestamp).toLocaleTimeString()}\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

\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 = \"selfassuredCoralPig\";\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-${Math.floor(Math.random() * 100)}`;\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 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 `, [userId]);\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 INSERT INTO ${KEY}_rooms_${SCHEMA_VERSION} \n (id, code, created_by, access_token) VALUES (?, ?, ?, ?)\n `, [roomId, roomCode, userId, accessToken]);\n\n // Automatically add creator to the room\n await sqlite.execute(`\n INSERT OR IGNORE INTO ${KEY}_room_users_${SCHEMA_VERSION} \n (room_id, user_id) VALUES (?, ?)\n `, [roomId, userId]);\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 SELECT * FROM ${KEY}_rooms_${SCHEMA_VERSION} \n WHERE code = ?\n `, [roomCode]);\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 INSERT OR IGNORE INTO ${KEY}_room_users_${SCHEMA_VERSION} \n (room_id, user_id) VALUES (?, ?)\n `, [roomId, userId]);\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 SELECT * FROM ${KEY}_messages_${SCHEMA_VERSION}\n WHERE room_id = ?\n ORDER BY timestamp\n `, [roomId]);\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 SELECT * FROM ${KEY}_room_users_${SCHEMA_VERSION}\n WHERE room_id = ? AND user_id = ?\n `, [message.roomId, message.sender]);\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: 150\n });\n\n const aiResponse = aiCompletion.choices[0].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/selfassuredCoralPig/code/main.tsx","extension","actionData","errors"]