Implemented API for chat

Author: impruthvi

components/chat/chat-input.tsx

@@ -8,6 +8,9 @@ import { Form, FormField, FormControl, FormItem } from "@/components/ui/form";
 import { Input } from "@/components/ui/input";
 import { Plus, Smile } from "lucide-react";
 
+import axios from "axios";
+import qs from "query-string";
+
 interface ChatInputProps {
   apiUrl: string;
   query: Record<string, any>;
@@ -34,8 +37,19 @@ export const ChatInput: React.FC<ChatInputProps> = ({
 
   const isLoading = form.formState.isSubmitting;
 
-  const onSubmit = async (value: z.infer<typeof formSchema>) => {
-    console.log(value);
+  const onSubmit = async (values: z.infer<typeof formSchema>) => {
+    try {
+      const url = qs.stringifyUrl({
+        url: apiUrl,
+        query,
+      });
+
+      await axios.post(url, values);
+
+      form.reset();
+    } catch (error) {
+      console.log(error);
+    }
   };
 
   return (
@@ -58,7 +72,9 @@ export const ChatInput: React.FC<ChatInputProps> = ({
                   <Input
                     disabled={isLoading}
                     className="px-14 py-6 bg-zinc-200/90 dark:bg-zinc-700/75 border-none border-0 focus-visible:ring-0 focus-visible:ring-offset-0 text-zinc-600 dark:text-zinc-200"
-                    placeholder={`Message ${type === "conversation" ? name : "#"}${name}`}
+                    placeholder={`Message ${
+                      type === "conversation" ? name : "#"
+                    }${name}`}
                     {...field}
                   />
                   <div className="absolute top-8 right-8">

lib/current-profile-pages.ts

@@ -0,0 +1,16 @@
+import { getAuth } from "@clerk/nextjs/server";
+
+import { db } from "@/lib/db";
+import { NextApiRequest } from "next";
+
+export const currentProfilePages = async (req: NextApiRequest) => {
+  const { userId } = getAuth(req);
+
+  if (!userId) return null;
+
+  const profile = await db.profile.findFirst({
+    where: { userId },
+  });
+
+  return profile;
+};

pages/api/socket/messages.ts

@@ -0,0 +1,83 @@
+import { currentProfilePages } from "@/lib/current-profile-pages";
+import { db } from "@/lib/db";
+import { NextApiResponseServerIo } from "@/types";
+import { NextApiRequest } from "next";
+
+export default async function handler(
+  req: NextApiRequest,
+  res: NextApiResponseServerIo
+) {
+  if (req.method !== "POST")
+    return res.status(405).json({ message: "Method not allowed" });
+
+  try {
+    const profile = await currentProfilePages(req);
+    const { content, fileUrl } = req.body;
+
+    const { serverId, channelId } = req.query;
+
+    if (!profile) return res.status(401).json({ message: "Unauthorized" });
+    if (!serverId)
+      return res.status(400).json({ message: "Server id is required" });
+    if (!channelId)
+      return res.status(400).json({ message: "Channel id is required" });
+    if (!content)
+      return res.status(400).json({ message: "Content is required" });
+
+    const server = await db.server.findFirst({
+      where: {
+        id: serverId as string,
+        members: {
+          some: {
+            profileId: profile.id,
+          },
+        },
+      },
+      include: {
+        members: true,
+      },
+    });
+
+    if (!server) return res.status(404).json({ message: "Server not found" });
+
+    const channel = await db.channel.findFirst({
+      where: {
+        id: channelId as string,
+        serverId: server.id,
+      },
+    });
+
+    if (!channel) return res.status(404).json({ message: "Channel not found" });
+
+    const member = server.members.find(
+      (member) => member.profileId === profile.id
+    );
+
+    if (!member) return res.status(401).json({ message: "Unauthorized" });
+
+    const message = await db.message.create({
+      data: {
+        content,
+        fileUrl,
+        memberId: member.id,
+        channelId: channel.id as string,
+      },
+      include: {
+        member: {
+          include: {
+            profile: true,
+          },
+        },
+      },
+    });
+
+    const channelKey = `chat:${channelId}:messages`;
+
+    res?.socket?.server?.io.emit(channelKey, message);
+
+    return res.status(200).json({ message });
+  } catch (error) {
+    console.log("[MESSAGES_POST_ERROR]", error);
+    return res.status(500).json({ message: "Internal server error" });
+  }
+}