finnal changes

backend/src/services/chatService.ts

@@ -453,7 +453,6 @@ export class ChatService {
         };
       }
 
-      // Check if target user is an admin
       const targetMembership = await prisma.chatRoomMember.findUnique({
         where: {
           userId_roomId: {
@@ -479,7 +478,6 @@ export class ChatService {
         };
       }
 
-      // Remove user from chat room
       await prisma.chatRoomMember.delete({
         where: {
           userId_roomId: {
@@ -489,7 +487,6 @@ export class ChatService {
         },
       });
 
-      // Get updated chat room
       const updatedRoom = await prisma.chatRoom.findUnique({
         where: { id: roomId },
         include: {

backend/src/socket/socketHandlers.ts

@@ -2,12 +2,14 @@ import { prisma } from "@/config/database.js";
 import { checkMessageRateLimit } from "@/middleware/rateLimiter.js";
 import { ChatService } from "@/services/chatService.js";
 import { MessageService } from "@/services/messageService.js";
-import { AuthenticatedSocket, ReactToMessageRequest, SendMessageRequest } from "@/types/index.js";
+import { AuthenticatedSocket, CreateChatRoomRequest, ReactToMessageRequest, SendMessageRequest } from "@/types/index.js";
 import { Server } from "socket.io";
 
 export const handleConnection = async (io: Server, socket: AuthenticatedSocket) => {
   console.log(`User connected: ${socket.user.username} (${socket.user.id})`);
 
+  socket.join(socket.userId);
+
   await updateUserOnlineStatus(socket.userId, true);
 
   const onlineUsers = await prisma.user.findMany({
@@ -33,6 +35,8 @@ export const handleConnection = async (io: Server, socket: AuthenticatedSocket)
 
   socket.on("messages_seen", (data: { roomId: string; messageIds: string[] }) => handleMessagesSeen(io, socket, data));
 
+  socket.on("create_chat_room", (data: CreateChatRoomRequest) => handleCreateChatRoom(io, socket, data));
+
   socket.on("disconnect", () => handleDisconnect(socket));
 };
 
@@ -220,6 +224,27 @@ const handleJoinRoom = async (socket: AuthenticatedSocket, roomId: string) => {
   await socket.join(roomId);
 };
 
+const handleCreateChatRoom = async (io: Server, socket: AuthenticatedSocket, data: CreateChatRoomRequest) => {
+  try {
+    const result = await ChatService.createChatRoom(socket.userId, data);
+
+    if (result.success) {
+      const room = result.data;
+
+      room.members.forEach((member: { userId: string | string[] }) => {
+        io.to(member.userId).emit("chat_room_created", room);
+      });
+
+      socket.emit("chat_room_created", room);
+    } else {
+      socket.emit("error", { message: result.error });
+    }
+  } catch (error) {
+    console.error(`Error creating chat room: ${error}`);
+    socket.emit("error", { message: "Failed to create chat room" });
+  }
+};
+
 const handleLeaveRoom = async (socket: AuthenticatedSocket, roomId: string) => {
   await socket.leave(roomId);
 };

frontend/src/components/ChatSidebar.tsx

@@ -1,8 +1,9 @@
 import { chatAPI } from '@/lib/api';
 import { useAuthStore } from '@/stores/authStore';
 import { useChatStore } from '@/stores/chatStore';
+import { useSocketStore } from '@/stores/socketStore';
 import type { ChatRoom, CreateChatRoomRequest } from '@/types';
-import { useMutation, useQuery } from '@tanstack/react-query';
+import { useQuery } from '@tanstack/react-query';
 import {
   Laptop,
   LogOut,
@@ -52,8 +53,9 @@ export const ChatSidebar: FC<ChatSidebarProps> = ({
     memberUsernames: [],
   });
 
-  const { chatRooms, onlineUsers, setChatRooms, addChatRoom } = useChatStore();
+  const { chatRooms, onlineUsers, setChatRooms } = useChatStore();
   const { user, logout } = useAuthStore();
+  const { socket } = useSocketStore();
   const navigate = useNavigate();
   const { theme, setTheme } = useTheme();
 
@@ -69,29 +71,18 @@ export const ChatSidebar: FC<ChatSidebarProps> = ({
     },
   });
 
-  const createRoomMutation = useMutation({
-    mutationKey: ['createChatRoom'],
-    mutationFn: chatAPI.createChatRoom,
-    onSuccess: (response) => {
-      if (response.data.success) {
-        const newRoom = response.data.data;
-        addChatRoom(newRoom);
-        setIsCreateDialogOpen(false);
-        setNewRoomData({ name: '', description: '', memberUsernames: [] });
-        toast.success('Chat room created successfully');
-
-        navigate(`/room/${newRoom.id}`);
-      }
-    },
-    // eslint-disable-next-line @typescript-eslint/no-explicit-any
-    onError: (error: any) => {
-      toast.error(error.response?.data?.error ?? 'Failed to create chat room');
-    },
-  });
-
   const handleCreateRoom = (e: FormEvent) => {
     e.preventDefault();
-    createRoomMutation.mutate(newRoomData);
+
+    if (!socket) {
+      toast.error('Socket connection is not established');
+      return;
+    }
+
+    socket.emit('create_chat_room', newRoomData);
+
+    setNewRoomData({ name: '', description: '', memberUsernames: [] });
+    setIsCreateDialogOpen(false);
   };
 
   const getOnlineMembersCount = (room: ChatRoom) => {
@@ -193,12 +184,8 @@ export const ChatSidebar: FC<ChatSidebarProps> = ({
                     placeholder="user1, user2, user3"
                   />
                 </div>
-                <Button
-                  type="submit"
-                  className="w-full"
-                  disabled={createRoomMutation.isPending}
-                >
-                  {createRoomMutation.isPending ? 'Creating...' : 'Create Room'}
+                <Button type="submit" className="w-full">
+                  Create Room
                 </Button>
               </form>
             </DialogContent>

frontend/src/components/MessageCard.tsx

@@ -198,11 +198,11 @@ export const MessageCard: FC<{ message: Message }> = ({ message }) => {
                 'flex items-center gap-1 text-xs px-2 py-1 rounded-full',
                 hasUserReacted(message.reactions, type)
                   ? type === 'like'
-                    ? 'bg-red-100'
+                    ? 'bg-red-100 dark:bg-red-900/20'
                     : type === 'thumbs_up'
-                      ? 'bg-blue-100'
-                      : 'bg-yellow-100'
-                  : 'bg-gray-100'
+                      ? 'bg-blue-100 dark:bg-blue-900/20'
+                      : 'bg-yellow-100 dark:bg-yellow-900/20'
+                  : 'bg-gray-100 dark:bg-gray-700'
               )}
               onClick={() => handleReaction(message.id, type)}
             >
@@ -210,8 +210,9 @@ export const MessageCard: FC<{ message: Message }> = ({ message }) => {
                 <Heart
                   className={cn(
                     'h-3 w-3',
-                    hasUserReacted(message.reactions, type) &&
-                      'fill-red-500 text-red-500'
+                    hasUserReacted(message.reactions, type)
+                      ? 'fill-red-500 text-red-500'
+                      : 'text-gray-600 dark:text-gray-300'
                   )}
                 />
               )}
@@ -219,8 +220,9 @@ export const MessageCard: FC<{ message: Message }> = ({ message }) => {
                 <ThumbsUp
                   className={cn(
                     'h-3 w-3',
-                    hasUserReacted(message.reactions, type) &&
-                      'fill-blue-500 text-blue-500'
+                    hasUserReacted(message.reactions, type)
+                      ? 'fill-blue-500 text-blue-500'
+                      : 'text-gray-600 dark:text-gray-300'
                   )}
                 />
               )}
@@ -228,12 +230,13 @@ export const MessageCard: FC<{ message: Message }> = ({ message }) => {
                 <Smile
                   className={cn(
                     'h-3 w-3',
-                    hasUserReacted(message.reactions, type) &&
-                      'fill-yellow-500 text-yellow-500'
+                    hasUserReacted(message.reactions, type)
+                      ? 'text-yellow-500'
+                      : 'text-gray-600 dark:text-gray-300'
                   )}
                 />
               )}
-              <span className="text-gray-600 dark:text-black">{count}</span>
+              <span className="text-gray-600 dark:text-gray-300">{count}</span>
             </div>
           ))}
         </div>

frontend/src/components/Navbar.tsx

@@ -1,3 +1,4 @@
+import { useAuthStore } from '@/stores/authStore';
 import { useChatStore } from '@/stores/chatStore';
 import { Settings, Users } from 'lucide-react';
 import { useState, type FC } from 'react';
@@ -10,7 +11,7 @@ export const NavBar: FC = () => {
   const { chatRooms, onlineUsers } = useChatStore();
   const { roomId } = useParams<{ roomId: string }>();
   const [isSettingsOpen, setIsSettingsOpen] = useState(false);
-
+  const { user } = useAuthStore();
   const currentRoom = chatRooms.find((room) => room.id === roomId);
 
   const getOnlineMembersCount = () => {
@@ -45,7 +46,10 @@ export const NavBar: FC = () => {
         )}
       </div>
       <div>
-        {currentRoom && (
+        {currentRoom &&
+          currentRoom.members.some(
+            (member) => member.userId === user?.id && member.role === 'admin'
+          ) && (
             <Button
               size="sm"
               variant="ghost"

frontend/src/lib/api.ts

@@ -55,7 +55,6 @@ export const chatAPI = {
     limit = 50
   ): Promise<AxiosResponse<ApiResponse>> =>
     api.get(`/messages/${roomId}?page=${page}&limit=${limit}`),
-  // Add these new endpoints
   updateChatRoom: (
     roomId: string,
     data: UpdateChatRoomRequest

frontend/src/lib/socket.ts

@@ -1,6 +1,6 @@
 import { useChatStore } from '@/stores/chatStore';
 import { useSocketStore } from '@/stores/socketStore';
-import type { Message, MessageReaction } from '@/types';
+import type { ChatRoom, Message, MessageReaction } from '@/types';
 import { io, type Socket } from 'socket.io-client';
 import { toast } from 'sonner';
 
@@ -116,13 +116,23 @@ class SocketService {
       }
     );
 
+    this.socket.on('chat_room_created', (room: ChatRoom) => {
+      const { chatRooms, addChatRoom } = useChatStore.getState();
+
+      if (!chatRooms.some((r) => r.id === room.id)) {
+        addChatRoom(room);
+        toast.success('Chat room created successfully', {
+          id: 'creating-room',
+        });
+      }
+    });
+
     this.socket.on(
       'rate_limit_exceeded',
       (data: { message: string; remainingTime?: number }) => {
         console.warn('Rate limit exceeded:', data.message);
         toast.error(`Rate limit exceeded: ${data.message}`, {
           duration: data.remainingTime ? data.remainingTime * 1000 : 5000,
-          position: 'top-right',
           style: {
             background: '#f8d7da',
             color: '#721c24',