p2p poll logic added

hooks/usePeerManager.ts

@@ -0,0 +1,58 @@
+"use client";
+
+import { useEffect, useRef, useState } from "react";
+import Peer from "peerjs";
+
+export default function usePeerManager() {
+  const [peerId, setPeerId] = useState<string | null>(null);
+  const [peers, setPeers] = useState<string[]>([]);
+  const peerRef = useRef<Peer | null>(null);
+  const connectionsRef = useRef<Map<string, any>>(new Map());
+
+  useEffect(() => {
+    const peer = new Peer();
+    peerRef.current = peer;
+
+    peer.on("open", (id) => {
+      setPeerId(id);
+    });
+
+    peer.on("connection", (conn) => {
+      conn.on("open", () => {
+        connectionsRef.current.set(conn.peer, conn);
+        setPeers(Array.from(connectionsRef.current.keys()));
+      });
+
+      conn.on("data", (data) => {
+        console.log("Received:", data);
+      });
+
+      conn.on("close", () => {
+        connectionsRef.current.delete(conn.peer);
+        setPeers(Array.from(connectionsRef.current.keys()));
+      });
+    });
+
+    return () => {
+      peer.destroy();
+    };
+  }, []);
+
+  const connectToPeer = (id: string) => {
+    if (!peerRef.current) return;
+    const conn = peerRef.current.connect(id);
+
+    conn.on("open", () => {
+      connectionsRef.current.set(conn.peer, conn);
+      setPeers(Array.from(connectionsRef.current.keys()));
+    });
+  };
+
+  const broadcast = (data: any) => {
+    connectionsRef.current.forEach((conn) => {
+      if (conn.open) conn.send(data);
+    });
+  };
+
+  return { peerId, peers, connectToPeer, broadcast };
+}

hooks/usePollManager.ts

@@ -0,0 +1,68 @@
+"use client";
+
+import { useState } from "react";
+
+type Option = {
+  id: string;
+  text: string;
+  votes: number;
+  voters: string[];
+};
+
+type Poll = {
+  id: string;
+  question: string;
+  options: Option[];
+};
+
+export default function usePollManager(peerManager: any) {
+  const [poll, setPoll] = useState<Poll | null>(null);
+  const [myVote, setMyVote] = useState<string | null>(null);
+
+  const createPoll = (question: string, options: string[]) => {
+    const newPoll: Poll = {
+      id: Date.now().toString(),
+      question,
+      options: options.map((opt, i) => ({
+        id: `opt-${i}`,
+        text: opt,
+        votes: 0,
+        voters: [],
+      })),
+    };
+
+    setPoll(newPoll);
+    peerManager.broadcast({ type: "poll", poll: newPoll });
+  };
+
+  const vote = (optionId: string, peerId: string) => {
+    if (!poll) return;
+
+    const updated = { ...poll };
+
+    updated.options.forEach((opt) => {
+      const index = opt.voters.indexOf(peerId);
+      if (index !== -1) {
+        opt.voters.splice(index, 1);
+        opt.votes--;
+      }
+    });
+
+    const option = updated.options.find((o) => o.id === optionId);
+    if (!option) return;
+
+    option.votes++;
+    option.voters.push(peerId);
+
+    setPoll(updated);
+    setMyVote(optionId);
+
+    peerManager.broadcast({
+      type: "vote",
+      optionId,
+      voterId: peerId,
+    });
+  };
+
+  return { poll, createPoll, vote, myVote };
+}