You've been invited to join a group chat!

${user.email} has invited you to join the conversation \"${conversation.title}\".

Join Conversation

This invitation will expire in 7 days.

If the button doesn't work, copy and paste this link: ${inviteUrl}

\n `,\n text: `You've been invited by ${user.email} to join the conversation \"${conversation.title}\". Click here to join: ${inviteUrl}`\n });\n } catch (error) {\n console.error('Failed to send invitation email:', error);\n // Don't fail the request if email fails\n }\n\n return c.json({ success: true, invite_token: invite.invite_token });\n});\n\n// Remove participant from conversation\napi.delete('/conversations/:id/participants/:userId', async (c) => {\n const user = c.get('user');\n const conversationId = parseInt(c.req.param('id'));\n const targetUserId = parseInt(c.req.param('userId'));\n \n if (isNaN(conversationId) || isNaN(targetUserId)) {\n return c.json({ error: 'Invalid IDs' }, 400);\n }\n\n // Check if user is admin\n const isAdmin = await isUserAdmin(conversationId, user.id);\n if (!isAdmin) {\n return c.json({ error: 'Only admins can remove participants' }, 403);\n }\n\n // Can't remove yourself if you're the only admin\n if (user.id === targetUserId) {\n return c.json({ error: 'Cannot remove yourself as admin' }, 400);\n }\n\n const removed = await removeParticipant(conversationId, targetUserId);\n \n if (!removed) {\n return c.json({ error: 'Participant not found' }, 404);\n }\n\n return c.json({ success: true });\n});\n\n// Send chat message\napi.post('/chat', async (c) => {\n const user = c.get('user');\n const { message, conversationId }: ChatRequest = await c.req.json();\n \n if (!message || typeof message !== 'string') {\n return c.json({ error: 'Message is required' }, 400);\n }\n\n let currentConversationId = conversationId;\n let conversationTitle: string | undefined;\n\n // If conversation ID provided, check if user is participant\n if (currentConversationId) {\n const isParticipant = await isUserParticipant(currentConversationId, user.id);\n if (!isParticipant) {\n return c.json({ error: 'Access denied' }, 403);\n }\n }\n\n // If no conversation ID, create a new conversation\n if (!currentConversationId) {\n conversationTitle = generateConversationTitle(message);\n const newConversation = await createConversation(user.id, conversationTitle);\n currentConversationId = newConversation.id;\n }\n\n // Add user message to database\n const userMessage = await addMessage(currentConversationId, 'user', message);\n\n // Get conversation history for context\n const messages = await getConversationMessages(currentConversationId);\n \n // Prepare messages for OpenAI (exclude the current user message since we'll add it)\n const chatMessages = messages\n .filter(m => m.id !== userMessage.id) // Exclude the message we just added\n .map(m => ({\n role: m.role as 'user' | 'assistant',\n content: m.content\n }));\n\n // Add the current user message\n chatMessages.push({ role: 'user', content: message });\n\n try {\n // Get response from ChatGPT\n const completion = await openai.chat.completions.create({\n messages: chatMessages,\n model: \"gpt-4o-mini\",\n max_tokens: 1000,\n });\n\n const assistantResponse = completion.choices[0]?.message?.content;\n \n if (!assistantResponse) {\n throw new Error('No response from ChatGPT');\n }\n\n // Add assistant message to database\n const assistantMessage = await addMessage(currentConversationId, 'assistant', assistantResponse);\n\n // Update conversation timestamp\n await updateConversationTimestamp(currentConversationId);\n\n const response: ChatResponse = {\n message: assistantMessage,\n conversationId: currentConversationId,\n conversationTitle\n };\n\n return c.json(response);\n\n } catch (error) {\n console.error('Error getting ChatGPT response:', error);\n return c.json({ error: 'Failed to get response from ChatGPT' }, 500);\n }\n});\n\n// Get invite details (public endpoint)\napi.get('/invites/:token', async (c) => {\n const token = c.req.param('token');\n \n const invite = await getInviteByToken(token);\n \n if (!invite) {\n return c.json({ error: 'Invitation not found' }, 404);\n }\n\n const isExpired = new Date(invite.expires_at) < new Date();\n\n const inviteDetails: InviteDetails = {\n conversation_title: invite.conversation_title,\n invited_by_email: invite.invited_by_email,\n expires_at: invite.expires_at,\n is_expired: isExpired\n };\n\n return c.json(inviteDetails);\n});\n\n// Accept invitation\napi.post('/invites/:token/accept', async (c) => {\n const user = c.get('user');\n const token = c.req.param('token');\n \n const invite = await getInviteByToken(token);\n \n if (!invite) {\n return c.json({ error: 'Invitation not found' }, 404);\n }\n\n const isExpired = new Date(invite.expires_at) < new Date();\n if (isExpired) {\n return c.json({ error: 'Invitation has expired' }, 400);\n }\n\n // Check if user is already a participant\n const isAlreadyParticipant = await isUserParticipant(invite.conversation_id, user.id);\n if (isAlreadyParticipant) {\n // Delete the invite and return success\n await deleteInvite(token);\n return c.json({ success: true, conversation_id: invite.conversation_id });\n }\n\n // Add user as participant\n await addParticipant(invite.conversation_id, user.id, 'participant');\n\n // Delete the invite\n await deleteInvite(token);\n\n return c.json({ success: true, conversation_id: invite.conversation_id });\n});\n\n// Server-Sent Events for real-time updates\napi.get('/conversations/:id/stream', async (c) => {\n const user = c.get('user');\n const conversationId = parseInt(c.req.param('id'));\n \n if (isNaN(conversationId)) {\n return c.json({ error: 'Invalid conversation ID' }, 400);\n }\n\n // Check if user is participant\n const isParticipant = await isUserParticipant(conversationId, user.id);\n if (!isParticipant) {\n return c.json({ error: 'Access denied' }, 403);\n }\n\n // Set up SSE headers\n c.header('Content-Type', 'text/event-stream');\n c.header('Cache-Control', 'no-cache');\n c.header('Connection', 'keep-alive');\n\n // Create a readable stream for SSE\n const stream = new ReadableStream({\n start(controller) {\n // Send initial connection message\n controller.enqueue(`data: ${JSON.stringify({ type: 'connected' })}\\n\\n`);\n\n // Keep connection alive with periodic pings\n const pingInterval = setInterval(() => {\n try {\n controller.enqueue(`data: ${JSON.stringify({ type: 'ping' })}\\n\\n`);\n } catch (error) {\n clearInterval(pingInterval);\n }\n }, 30000); // Ping every 30 seconds\n\n // Store cleanup function\n (controller as any).cleanup = () => {\n clearInterval(pingInterval);\n };\n },\n cancel() {\n // Cleanup when connection is closed\n if ((this as any).cleanup) {\n (this as any).cleanup();\n }\n }\n });\n\n return new Response(stream, {\n headers: {\n 'Content-Type': 'text/event-stream',\n 'Cache-Control': 'no-cache',\n 'Connection': 'keep-alive'\n }\n });\n});\n\nexport default api;","deleted","label",[168,169,149],"backend","routes","permalink","https://www.val.town/x/jessicaocean/untitled-1522/code/backend/routes/api.ts","extension","actionData","errors"]