import { useState, useRef, useEffect } from 'react'; import { useParams, useNavigate } from 'react-router-dom'; import Layout from '../components/layout/Layout'; import { useAuth } from '../contexts/AuthContext'; import { mockEvents } from '../mocks/events'; import { Send, UserPlus } from 'lucide-react'; import { connectSocket, disconnectSocket, getSocket } from '../services/socket'; const EventChatPage = () => { const { eventId } = useParams(); const { user } = useAuth(); const navigate = useNavigate(); const [messages, setMessages] = useState([]); const [newMessage, setNewMessage] = useState(''); const [activeUsers, setActiveUsers] = useState([]); const [isConnected, setIsConnected] = useState(false); const messagesEndRef = useRef(null); const event = mockEvents.find(e => e.id === parseInt(eventId)); const scrollToBottom = () => { messagesEndRef.current?.scrollIntoView({ behavior: 'smooth' }); }; useEffect(() => { scrollToBottom(); }, [messages]); useEffect(() => { // Connect to Socket.IO const socket = connectSocket(); if (!socket) { console.error('Failed to connect to socket'); return; } // Socket event listeners socket.on('connect', () => { setIsConnected(true); // Join event room socket.emit('join_event_room', { eventId: parseInt(eventId) }); }); socket.on('disconnect', () => { setIsConnected(false); }); // Receive messages socket.on('event_message', (message) => { setMessages((prev) => [...prev, message]); }); // Receive active users list socket.on('active_users', (users) => { // Filter out duplicates and current user const uniqueUsers = users .filter((u, index, self) => index === self.findIndex((t) => t.userId === u.userId) ) .filter((u) => u.userId !== user.id); setActiveUsers(uniqueUsers); }); // User joined notification socket.on('user_joined', (userData) => { console.log(`${userData.username} joined the room`); }); // User left notification socket.on('user_left', (userData) => { console.log(`${userData.username} left the room`); }); // Cleanup return () => { socket.emit('leave_event_room', { eventId: parseInt(eventId) }); socket.off('connect'); socket.off('disconnect'); socket.off('event_message'); socket.off('active_users'); socket.off('user_joined'); socket.off('user_left'); }; }, [eventId, user.id]); const handleSendMessage = (e) => { e.preventDefault(); if (!newMessage.trim()) return; const socket = getSocket(); if (!socket || !socket.connected) { alert('Not connected to chat server'); return; } // Send message via Socket.IO socket.emit('send_event_message', { eventId: parseInt(eventId), content: newMessage, }); setNewMessage(''); }; const handleMatchWith = (userId) => { // TODO: Implement match request alert(`Match request sent to user!`); setTimeout(() => { navigate(`/matches/1/chat`); }, 1000); }; if (!event) { return ( Event not found ); } return ( {/* Header */} {event.name} {event.location} {isConnected ? '● Connected' : '● Disconnected'} {/* Active Users Sidebar */} Active users ({activeUsers.length}) {activeUsers.length === 0 && ( No other users online )} {activeUsers.map((activeUser) => ( {activeUser.username} handleMatchWith(activeUser.userId)} className="p-1 text-primary-600 hover:bg-primary-50 rounded" title="Connect" > ))} {/* Chat Area */} {/* Messages */} {messages.length === 0 && ( No messages yet. Start the conversation! )} {messages.map((message) => { const isOwnMessage = message.userId === user.id; return ( {message.username} {new Date(message.createdAt).toLocaleTimeString('en-US', { hour: '2-digit', minute: '2-digit' })} {message.content} ); })} {/* Message Input */} setNewMessage(e.target.value)} placeholder="Write a message..." disabled={!isConnected} className="flex-1 px-4 py-2 border border-gray-300 rounded-lg focus:ring-primary-500 focus:border-primary-500 disabled:opacity-50" /> ); }; export default EventChatPage;
{event.location}
No other users online
{activeUser.username}