p2p poll logic added

resolved conflict
first commit
2026-03-19 10:52:12 +01:00 · 2026-03-19 01:07:34 +01:00 · 2026-03-19 00:41:15 +01:00
28 changed files with 7085 additions and 659 deletions
--- a/.gitignore
+++ b/.gitignore
@@ -1 +1,41 @@
-node_modules/
+# See https://help.github.com/articles/ignoring-files/ for more about ignoring files.
+
+# dependencies
+/node_modules
+/.pnp
+.pnp.*
+.yarn/*
+!.yarn/patches
+!.yarn/plugins
+!.yarn/releases
+!.yarn/versions
+
+# testing
+/coverage
+
+# next.js
+/.next/
+/out/
+
+# production
+/build
+
+# misc
+.DS_Store
+*.pem
+
+# debug
+npm-debug.log*
+yarn-debug.log*
+yarn-error.log*
+.pnpm-debug.log*
+
+# env files (can opt-in for committing if needed)
+.env*
+
+# vercel
+.vercel
+
+# typescript
+*.tsbuildinfo
+next-env.d.ts
--- a/README.md
+++ b/README.md
@@ -1,28 +1,2 @@
-# P2P Poll App
-
-## Install npm packages
-```
-npm init -y
-npm install
-```
-
-Note: the frontend obtains the packages `yjs` and `y-websocket` dynamically.
-
-## Run backend
-```
-node backend.js
-```
-
-### Note on Yjs suggestion
-Note that the following server setup is suggested in the Yjs docs (https://docs.yjs.dev/ecosystem/connection-provider/y-websocket):
-```
-npm install y-websocket-server
-HOST=localhost PORT=1000 npx y-websocket
-```
-
-However, across a range of npm versions, this does not work.
-Nevertheless, the essential code from the `y-websocket-server` package is used here as provided in `utils.js`.
-
-## Run frontend
-Open "frontend.html" in browser.
-
+# P2P Poll App
+Remove-Item -Recurse -Force node_modules, .next
--- a/app/favicon.ico
+++ b/app/favicon.ico
--- a/app/globals.css
+++ b/app/globals.css
@@ -0,0 +1,26 @@
+@import "tailwindcss";
+
+:root {
+  --background: #ffffff;
+  --foreground: #171717;
+}
+
+@theme inline {
+  --color-background: var(--background);
+  --color-foreground: var(--foreground);
+  --font-sans: var(--font-geist-sans);
+  --font-mono: var(--font-geist-mono);
+}
+
+@media (prefers-color-scheme: dark) {
+  :root {
+    --background: #0a0a0a;
+    --foreground: #ededed;
+  }
+}
+
+body {
+  background: var(--background);
+  color: var(--foreground);
+  font-family: Arial, Helvetica, sans-serif;
+}
--- a/app/layout.tsx
+++ b/app/layout.tsx
@@ -0,0 +1,25 @@
+import type { Metadata } from "next";
+
+import "./globals.css";
+
+
+
+export const metadata: Metadata = {
+  title: "p2p polling",
+  description: "creating a p2p-polling app",
+};
+
+export default function RootLayout({
+  children,
+}: Readonly<{
+  children: React.ReactNode;
+}>) {
+  return (
+    <html
+      lang="en"
+      className={` h-full antialiased`}
+    >
+      <body className="min-h-full flex flex-col">{children}</body>
+    </html>
+  );
+}
--- a/app/page.tsx
+++ b/app/page.tsx
@@ -0,0 +1,47 @@
+"use client";
+
+import { useState } from "react";
+import usePeerManager from "../hooks/usePeerManager";
+import usePollManager from "../hooks/usePollManager";
+import PollCreation from "../components/PollCreation";
+import PollActive from "../components/PollActive";
+import PeersList from "../components/PeersList";
+
+export default function Page() {
+  const peerManager = usePeerManager();
+  const pollManager = usePollManager(peerManager);
+
+  const [connectId, setConnectId] = useState("");
+
+  return (
+    <div className="p-6 space-y-4">
+      <h1 className="text-2xl font-bold">P2P Poll App</h1>
+
+      {/* Connect */}
+      <div className="flex gap-2">
+        <input
+          className="border p-2"
+          placeholder="Peer ID"
+          value={connectId}
+          onChange={(e) => setConnectId(e.target.value)}
+        />
+        <button
+          className="bg-blue-500 text-white px-4"
+          onClick={() => peerManager.connectToPeer(connectId)}
+        >
+          Connect
+        </button>
+      </div>
+
+      <p>Your ID: {peerManager.peerId}</p>
+
+      {pollManager.poll ? (
+        <PollActive pollManager={pollManager} peerId={peerManager.peerId} />
+      ) : (
+        <PollCreation pollManager={pollManager} />
+      )}
+
+      <PeersList peers={peerManager.peers} />
+    </div>
+  );
+}
--- a/backend.js
+++ b/backend.js
@@ -1,31 +0,0 @@
-import { WebSocketServer } from 'ws';
-import { setupWSConnection } from './utils.js'
-
-// Create a WebSocket server
-const WS_PORT = 8080;
-const wss = new WebSocketServer({ port: WS_PORT });
-
-console.log('WebSocket server is running on ws://localhost:' + String(WS_PORT));
-
-// Connection event handler
-wss.on('connection', setupWSConnection);
-/*
-wss.on('connection', (ws) => {
-  console.log('Client connected');
-
-  // Message event handler
-  ws.on('message', (message) => {
-    let msg_str = String(message);
-    console.log("Received: " + msg_str);
-    
-    // If this is a text or state message (no Yjs logic) - echo the message back to the client
-    if (msg_str.startsWith("TEXT_MESSAGE") | msg_str.startsWith("STATE_MESSAGE")) {
-      ws.send(msg_str);
-    }
-  });
-
-  // Close event handler
-  ws.on('close', () => {
-    console.log('Client disconnected');
-  });
-});*/
--- a/components/Modal.tsx
+++ b/components/Modal.tsx
--- a/components/Notification.tsx
+++ b/components/Notification.tsx
@@ -0,0 +1,22 @@
+"use client";
+
+type NotificationType = "info" | "success" | "error";
+
+interface NotificationProps {
+  message: string;
+  type?: NotificationType;
+}
+
+export default function Notification({ message, type = "info" }: NotificationProps) {
+  const colors: Record<NotificationType, string> = {
+    info: "bg-blue-100 text-blue-700",
+    success: "bg-green-100 text-green-700",
+    error: "bg-red-100 text-red-700",
+  };
+
+  return (
+    <div className={`px-4 py-2 rounded shadow ${colors[type]}`}>
+      {message}
+    </div>
+  );
+}
--- a/components/PeersList.tsx
+++ b/components/PeersList.tsx
@@ -0,0 +1,14 @@
+"use client";
+
+export default function PeersList({ peers }: { peers: string[] }) {
+  return (
+    <div>
+      <h3>Peers</h3>
+      {peers.length === 0 ? (
+        <p>No peers</p>
+      ) : (
+        peers.map((p) => <div key={p}>{p}</div>)
+      )}
+    </div>
+  );
+}
--- a/components/PollActive.tsx
+++ b/components/PollActive.tsx
@@ -0,0 +1,22 @@
+"use client";
+
+import PollOption from "./PollOption";
+
+export default function PollActive({ pollManager, peerId }: any) {
+  const poll = pollManager.poll;
+
+  return (
+    <div>
+      <h2 className="text-xl font-bold">{poll.question}</h2>
+
+      {poll.options.map((opt: any) => (
+        <PollOption
+          key={opt.id}
+          option={opt}
+          pollManager={pollManager}
+          peerId={peerId}
+        />
+      ))}
+    </div>
+  );
+}
--- a/components/PollCreation.tsx
+++ b/components/PollCreation.tsx
@@ -0,0 +1,40 @@
+"use client";
+
+import { useState } from "react";
+
+export default function PollCreation({ pollManager }: any) {
+  const [question, setQuestion] = useState("");
+  const [options, setOptions] = useState<string[]>(["", ""]);
+
+  return (
+    <div>
+      <input
+        className="border p-2 w-full"
+        placeholder="Question"
+        value={question}
+        onChange={(e) => setQuestion(e.target.value)}
+      />
+
+      {options.map((opt, i) => (
+        <input
+          key={i}
+          className="border p-2 w-full mt-2"
+          placeholder={`Option ${i + 1}`}
+          value={opt}
+          onChange={(e) => {
+            const newOpts = [...options];
+            newOpts[i] = e.target.value;
+            setOptions(newOpts);
+          }}
+        />
+      ))}
+
+      <button
+        className="bg-green-500 text-white px-4 mt-2"
+        onClick={() => pollManager.createPoll(question, options)}
+      >
+        Create Poll
+      </button>
+    </div>
+  );
+}
--- a/components/PollOption.tsx
+++ b/components/PollOption.tsx
@@ -0,0 +1,12 @@
+"use client";
+
+export default function PollOption({ option, pollManager, peerId }: any) {
+  return (
+    <div
+      className="border p-2 mt-2 cursor-pointer"
+      onClick={() => pollManager.vote(option.id, peerId)}
+    >
+      {option.text} - {option.votes} votes
+    </div>
+  );
+}
--- a/eslint.config.mjs
+++ b/eslint.config.mjs
@@ -0,0 +1,18 @@
+import { defineConfig, globalIgnores } from "eslint/config";
+import nextVitals from "eslint-config-next/core-web-vitals";
+import nextTs from "eslint-config-next/typescript";
+
+const eslintConfig = defineConfig([
+  ...nextVitals,
+  ...nextTs,
+  // Override default ignores of eslint-config-next.
+  globalIgnores([
+    // Default ignores of eslint-config-next:
+    ".next/**",
+    "out/**",
+    "build/**",
+    "next-env.d.ts",
+  ]),
+]);
+
+export default eslintConfig;
--- a/frontend.html
+++ b/frontend.html
@@ -1,196 +0,0 @@
-<!DOCTYPE html>
-<html>
-<head>
-  <title>Poll Client</title>
-  <style>
-    body {
-      font-family: Arial, sans-serif;
-      max-width: 600px;
-      margin: 0 auto;
-      padding: 20px;
-    }
-    #messages {
-      height: 300px;
-      border: 1px solid #ccc;
-      overflow-y: auto;
-      padding: 10px;
-      margin-bottom: 10px;
-    }
-    .message { margin: 5px 0; }
-  </style>
-</head>
-<body>
-  <h1>Poll Client</h1>
-  <div id="status">Connecting to server...</div>
-  <div id="status2">Connecting to server...</div>
-  <div id="messages"></div>
-  <div>
-    <input type="text" id="messageInput" placeholder="Type your message">
-    <!--button onclick="sendMessage()">Send</button-->
-    <button id="sendBtn">Send</button>
-    <input id="optionInput" placeholder="Add option">
-    <button id="addBtn">Add</button>
-    <ul id="options"></ul>
-  </div>
-
-  <script type="module">
-    import * as Y from "https://esm.sh/yjs"
-    import { WebsocketProvider } from "https://esm.sh/y-websocket"
-
-    const WS_PORT = 8080;
-    const ydoc = new Y.Doc();
-    const status = document.getElementById('status');
-    const status2 = document.getElementById('status2');
-    const messages = document.getElementById('messages');
-    const messageInput = document.getElementById('messageInput');
-
-    // Connect to the backend (WebSocket server) via Yjs WebsocketProvider
-    const wsp = new WebsocketProvider(
-      'ws://localhost:' + String(WS_PORT), 'poll-room',
-      ydoc
-    )
-    wsp.on('status', event => {
-      //console.log("event.status =", event.status)
-      if (event.status == "connected") {
-        status.textContent = 'Yjs connected to WebSocket server';
-        status.style.color = 'green';
-      }
-      else {
-        status.textContent = 'Yjs disonnected from WebSocket server';
-        status.style.color = 'red';
-      }
-    })
-    wsp.onopen = () => {
-      console.log('connected to y-websocket server');
-    };
-    ydoc.on('update', () => {
-      console.log('Yjs document updated locally');
-    });
-    wsp.on('sync', isSynced => {
-      console.log("isSynced =", isSynced)
-    })
-
-    // Connect to the backend (WebSocket server) via common WebSocket (only for informative messages)
-    const ws = new WebSocket('ws://localhost:' + String(WS_PORT));
-    ws.onopen = () => {
-      status2.textContent = 'WebSocket client connected to WebSocket server';
-      status2.style.color = 'green';
-    };
-    ws.onmessage = (event) => {
-      const message = document.createElement('div');
-      message.className = 'message';
-      message.textContent = event.data;
-      messages.appendChild(message);
-      messages.scrollTop = messages.scrollHeight;
-    };
-    ws.onerror = (error) => {
-      status2.textContent = 'Error: ' + error.message;
-      status2.style.color = 'red';
-    };
-    ws.onclose = () => {
-      status2.textContent = 'WebSocket client disconnected from WebSocket server';
-      status2.style.color = 'red';
-    };
-
-    // Function to send a message
-    function sendMessage(command, payload) {
-        let message = "";
-        if (command === "TEXT_MESSAGE") {
-            message = command + ":" + messageInput.value.trim();
-            messageInput.value = "";
-        }
-        else if (command.startsWith("STATE_MESSAGE--")) {
-            message = command + ":" + payload;
-        }
-        else {
-            console.log("Error: unknown command '" + command + "'")
-        }
-
-        if (message) {
-            /* To make compatible with y-websocket-server API:
-            const encoder = encoding.createEncoder()
-            encoding.writeVarUint(encoder, messageTextMessage)
-            syncProtocol.writeUpdate(encoder, update)
-            enc_message = encoding.toUint8Array(encoder)*/
-            ws.send(message);
-        }
-    }
-
-     // Send message on button click
-    document.getElementById("sendBtn").onclick = () => {
-        sendMessage("TEXT_MESSAGE", "");
-    };
-
-    // Send message on Enter key
-    messageInput.addEventListener('keypress', (e) => {
-      if (e.key === 'Enter') {
-        sendMessage("TEXT_MESSAGE", "");
-      }
-    });
-    
-    // Actual poll logic
-    const optionsMap = ydoc.getMap("options");
-
-    const optionsList = document.getElementById("options");
-    const input = document.getElementById("optionInput");
-
-    function render() {
-        optionsList.innerHTML = ""
-
-        optionsMap.forEach((vote, name) => {
-            // List element for this option
-            const li = document.createElement("li")
-
-            // Label for this option
-            const label = document.createElement("span")
-            label.textContent = name + " — " + vote + " "
-
-            // "Vote"/"Unvote" button
-            const voteBtn = document.createElement("button")
-            if (vote == false) {
-                voteBtn.textContent = "Vote"
-            }
-            else {
-                voteBtn.textContent = "Unvote"
-            }
-            voteBtn.onclick = () => {
-                vote = !vote;
-                optionsMap.set(name, vote);
-                sendMessage("STATE_MESSAGE--" + (vote ? "VOTE" : "UNVOTE"), name);
-            }
-
-            // "Remove" button
-            const removeBtn = document.createElement("button")
-            removeBtn.textContent = "Remove"
-            removeBtn.onclick = () => {
-                optionsMap.delete(name);
-                sendMessage("STATE_MESSAGE--REMOVE", name);
-            }
-
-            li.appendChild(label)
-            li.appendChild(voteBtn)
-            li.appendChild(removeBtn)
-
-            optionsList.appendChild(li)
-        })
-    };
-
-    document.getElementById("addBtn").onclick = () => {
-        const name = input.value.trim()
-
-        if (!name) return
-
-        if (!optionsMap.has(name)) {
-            optionsMap.set(name, false);
-            sendMessage("STATE_MESSAGE--ADD_OPTION", name);
-        }
-
-        input.value = ""
-    };
-
-    optionsMap.observe(render);
-
-    render();
-  </script>
-</body>
-</html>
--- a/hooks/usePeerManager.ts
+++ b/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 };
+}
--- a/hooks/usePollManager.ts
+++ b/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 };
+}
--- a/next.config.ts
+++ b/next.config.ts
@@ -0,0 +1,9 @@
+import type { NextConfig } from "next";
+
+const nextConfig: NextConfig = {
+  experimental: {
+    turbopackFileSystemCacheForDev: true,
+  }
+};
+
+export default nextConfig;
--- a/package-lock.json
+++ b/package-lock.json
--- a/package.json
+++ b/package.json
@@ -1,20 +1,27 @@
 {
-  "name": "yjs-poll",
-  "version": "1.0.0",
-  "main": "index.js",
-  "type": "module",
+  "name": "p2p-polling",
+  "version": "0.1.0",
+  "private": true,
  "scripts": {
-    "test": "echo \"Error: no test specified\" && exit 1",
-    "y-websocket": "y-websocket"
+    "dev": "next dev",
+    "build": "next build",
+    "start": "next start",
+    "lint": "eslint"
  },
-  "keywords": [],
-  "author": "",
-  "license": "ISC",
-  "description": "",
  "dependencies": {
-    "ws": "^8.19.0",
-    "@y/protocols": "^1.0.6-1",
-    "lib0": "^0.2.102",
-    "yjs": "^14.0.0-7"
+    "next": "16.2.0",
+    "peerjs": "^1.5.5",
+    "react": "19.2.4",
+    "react-dom": "19.2.4"
+  },
+  "devDependencies": {
+    "@tailwindcss/postcss": "^4",
+    "@types/node": "^20",
+    "@types/react": "^19",
+    "@types/react-dom": "^19",
+    "eslint": "^9",
+    "eslint-config-next": "16.2.0",
+    "tailwindcss": "^4",
+    "typescript": "^5"
  }
 }
--- a/postcss.config.mjs
+++ b/postcss.config.mjs
@@ -0,0 +1,7 @@
+const config = {
+  plugins: {
+    "@tailwindcss/postcss": {},
+  },
+};
+
+export default config;
--- a/public/file.svg
+++ b/public/file.svg
@@ -0,0 +1 @@
+<svg fill="none" viewBox="0 0 16 16" xmlns="http://www.w3.org/2000/svg"><path d="M14.5 13.5V5.41a1 1 0 0 0-.3-.7L9.8.29A1 1 0 0 0 9.08 0H1.5v13.5A2.5 2.5 0 0 0 4 16h8a2.5 2.5 0 0 0 2.5-2.5m-1.5 0v-7H8v-5H3v12a1 1 0 0 0 1 1h8a1 1 0 0 0 1-1M9.5 5V2.12L12.38 5zM5.13 5h-.62v1.25h2.12V5zm-.62 3h7.12v1.25H4.5zm.62 3h-.62v1.25h7.12V11z" clip-rule="evenodd" fill="#666" fill-rule="evenodd"/></svg>
--- a/public/globe.svg
+++ b/public/globe.svg
@@ -0,0 +1 @@
+<svg fill="none" xmlns="http://www.w3.org/2000/svg" viewBox="0 0 16 16"><g clip-path="url(#a)"><path fill-rule="evenodd" clip-rule="evenodd" d="M10.27 14.1a6.5 6.5 0 0 0 3.67-3.45q-1.24.21-2.7.34-.31 1.83-.97 3.1M8 16A8 8 0 1 0 8 0a8 8 0 0 0 0 16m.48-1.52a7 7 0 0 1-.96 0H7.5a4 4 0 0 1-.84-1.32q-.38-.89-.63-2.08a40 40 0 0 0 3.92 0q-.25 1.2-.63 2.08a4 4 0 0 1-.84 1.31zm2.94-4.76q1.66-.15 2.95-.43a7 7 0 0 0 0-2.58q-1.3-.27-2.95-.43a18 18 0 0 1 0 3.44m-1.27-3.54a17 17 0 0 1 0 3.64 39 39 0 0 1-4.3 0 17 17 0 0 1 0-3.64 39 39 0 0 1 4.3 0m1.1-1.17q1.45.13 2.69.34a6.5 6.5 0 0 0-3.67-3.44q.65 1.26.98 3.1M8.48 1.5l.01.02q.41.37.84 1.31.38.89.63 2.08a40 40 0 0 0-3.92 0q.25-1.2.63-2.08a4 4 0 0 1 .85-1.32 7 7 0 0 1 .96 0m-2.75.4a6.5 6.5 0 0 0-3.67 3.44 29 29 0 0 1 2.7-.34q.31-1.83.97-3.1M4.58 6.28q-1.66.16-2.95.43a7 7 0 0 0 0 2.58q1.3.27 2.95.43a18 18 0 0 1 0-3.44m.17 4.71q-1.45-.12-2.69-.34a6.5 6.5 0 0 0 3.67 3.44q-.65-1.27-.98-3.1" fill="#666"/></g><defs><clipPath id="a"><path fill="#fff" d="M0 0h16v16H0z"/></clipPath></defs></svg>
--- a/public/next.svg
+++ b/public/next.svg
@@ -0,0 +1 @@
+<svg xmlns="http://www.w3.org/2000/svg" fill="none" viewBox="0 0 394 80"><path fill="#000" d="M262 0h68.5v12.7h-27.2v66.6h-13.6V12.7H262V0ZM149 0v12.7H94v20.4h44.3v12.6H94v21h55v12.6H80.5V0h68.7zm34.3 0h-17.8l63.8 79.4h17.9l-32-39.7 32-39.6h-17.9l-23 28.6-23-28.6zm18.3 56.7-9-11-27.1 33.7h17.8l18.3-22.7z"/><path fill="#000" d="M81 79.3 17 0H0v79.3h13.6V17l50.2 62.3H81Zm252.6-.4c-1 0-1.8-.4-2.5-1s-1.1-1.6-1.1-2.6.3-1.8 1-2.5 1.6-1 2.6-1 1.8.3 2.5 1a3.4 3.4 0 0 1 .6 4.3 3.7 3.7 0 0 1-3 1.8zm23.2-33.5h6v23.3c0 2.1-.4 4-1.3 5.5a9.1 9.1 0 0 1-3.8 3.5c-1.6.8-3.5 1.3-5.7 1.3-2 0-3.7-.4-5.3-1s-2.8-1.8-3.7-3.2c-.9-1.3-1.4-3-1.4-5h6c.1.8.3 1.6.7 2.2s1 1.2 1.6 1.5c.7.4 1.5.5 2.4.5 1 0 1.8-.2 2.4-.6a4 4 0 0 0 1.6-1.8c.3-.8.5-1.8.5-3V45.5zm30.9 9.1a4.4 4.4 0 0 0-2-3.3 7.5 7.5 0 0 0-4.3-1.1c-1.3 0-2.4.2-3.3.5-.9.4-1.6 1-2 1.6a3.5 3.5 0 0 0-.3 4c.3.5.7.9 1.3 1.2l1.8 1 2 .5 3.2.8c1.3.3 2.5.7 3.7 1.2a13 13 0 0 1 3.2 1.8 8.1 8.1 0 0 1 3 6.5c0 2-.5 3.7-1.5 5.1a10 10 0 0 1-4.4 3.5c-1.8.8-4.1 1.2-6.8 1.2-2.6 0-4.9-.4-6.8-1.2-2-.8-3.4-2-4.5-3.5a10 10 0 0 1-1.7-5.6h6a5 5 0 0 0 3.5 4.6c1 .4 2.2.6 3.4.6 1.3 0 2.5-.2 3.5-.6 1-.4 1.8-1 2.4-1.7a4 4 0 0 0 .8-2.4c0-.9-.2-1.6-.7-2.2a11 11 0 0 0-2.1-1.4l-3.2-1-3.8-1c-2.8-.7-5-1.7-6.6-3.2a7.2 7.2 0 0 1-2.4-5.7 8 8 0 0 1 1.7-5 10 10 0 0 1 4.3-3.5c2-.8 4-1.2 6.4-1.2 2.3 0 4.4.4 6.2 1.2 1.8.8 3.2 2 4.3 3.4 1 1.4 1.5 3 1.5 5h-5.8z"/></svg>
--- a/public/vercel.svg
+++ b/public/vercel.svg
@@ -0,0 +1 @@
+<svg fill="none" xmlns="http://www.w3.org/2000/svg" viewBox="0 0 1155 1000"><path d="m577.3 0 577.4 1000H0z" fill="#fff"/></svg>
--- a/public/window.svg
+++ b/public/window.svg
@@ -0,0 +1 @@
+<svg fill="none" xmlns="http://www.w3.org/2000/svg" viewBox="0 0 16 16"><path fill-rule="evenodd" clip-rule="evenodd" d="M1.5 2.5h13v10a1 1 0 0 1-1 1h-11a1 1 0 0 1-1-1zM0 1h16v11.5a2.5 2.5 0 0 1-2.5 2.5h-11A2.5 2.5 0 0 1 0 12.5zm3.75 4.5a.75.75 0 1 0 0-1.5.75.75 0 0 0 0 1.5M7 4.75a.75.75 0 1 1-1.5 0 .75.75 0 0 1 1.5 0m1.75.75a.75.75 0 1 0 0-1.5.75.75 0 0 0 0 1.5" fill="#666"/></svg>
--- a/tsconfig.json
+++ b/tsconfig.json
@@ -0,0 +1,34 @@
+{
+  "compilerOptions": {
+    "target": "ES2017",
+    "lib": ["dom", "dom.iterable", "esnext"],
+    "allowJs": true,
+    "skipLibCheck": true,
+    "strict": true,
+    "noEmit": true,
+    "esModuleInterop": true,
+    "module": "esnext",
+    "moduleResolution": "bundler",
+    "resolveJsonModule": true,
+    "isolatedModules": true,
+    "jsx": "react-jsx",
+    "incremental": true,
+    "plugins": [
+      {
+        "name": "next"
+      }
+    ],
+    "paths": {
+      "@/*": ["./*"]
+    }
+  },
+  "include": [
+    "next-env.d.ts",
+    "**/*.ts",
+    "**/*.tsx",
+    ".next/types/**/*.ts",
+    ".next/dev/types/**/*.ts",
+    "**/*.mts"
+  ],
+  "exclude": ["node_modules"]
+}
--- a/utils.js
+++ b/utils.js
@@ -1,291 +0,0 @@
-/* Adapted from https://github.com/yjs/y-websocket-server/blob/main/src/server.js, version of 2025-04-02
-   (author: dmonad/Kevin Jahns, MIT license) */
-
-import * as Y from 'yjs'
-import * as syncProtocol from '@y/protocols/sync'
-import * as awarenessProtocol from '@y/protocols/awareness'
-
-import * as encoding from 'lib0/encoding'
-import * as decoding from 'lib0/decoding'
-import * as map from 'lib0/map'
-
-import * as eventloop from 'lib0/eventloop'
-
-/*import { callbackHandler, isCallbackSet } from './callback.js'
-
-const CALLBACK_DEBOUNCE_WAIT = parseInt(process.env.CALLBACK_DEBOUNCE_WAIT || '2000')
-const CALLBACK_DEBOUNCE_MAXWAIT = parseInt(process.env.CALLBACK_DEBOUNCE_MAXWAIT || '10000')
-
-const debouncer = eventloop.createDebouncer(CALLBACK_DEBOUNCE_WAIT, CALLBACK_DEBOUNCE_MAXWAIT)*/
-
-const wsReadyStateConnecting = 0
-const wsReadyStateOpen = 1
-const wsReadyStateClosing = 2 // eslint-disable-line
-const wsReadyStateClosed = 3 // eslint-disable-line
-
-// disable gc when using snapshots!
-const gcEnabled = process.env.GC !== 'false' && process.env.GC !== '0'
-// const persistenceDir = process.env.YPERSISTENCE
-/**
- * @type {{bindState: function(string,WSSharedDoc):void, writeState:function(string,WSSharedDoc):Promise<any>, provider: any}|null}
- */
-let persistence = null
-
-/**
- * @param {{bindState: function(string,WSSharedDoc):void,
- * writeState:function(string,WSSharedDoc):Promise<any>,provider:any}|null} persistence_
- */
-export const setPersistence = persistence_ => {
-  persistence = persistence_
-}
-
-/**
- * @return {null|{bindState: function(string,WSSharedDoc):void,
-  * writeState:function(string,WSSharedDoc):Promise<any>}|null} used persistence layer
-  */
-export const getPersistence = () => persistence
-
-/**
- * @type {Map<string,WSSharedDoc>}
- */
-export const docs = new Map()
-
-const messageSync = 0
-const messageAwareness = 1
-// const messageAuth = 2
-//const messageTextMessage = 3
-//const messageStateMessage = 4
-
-/**
- * @param {Uint8Array} update
- * @param {any} _origin
- * @param {WSSharedDoc} doc
- * @param {any} _tr
- */
-const updateHandler = (update, _origin, doc, _tr) => {
-  const encoder = encoding.createEncoder()
-  encoding.writeVarUint(encoder, messageSync)
-  syncProtocol.writeUpdate(encoder, update)
-  const message = encoding.toUint8Array(encoder)
-  doc.conns.forEach((_, conn) => send(doc, conn, message))
-}
-
-/**
- * @type {(ydoc: Y.Doc) => Promise<void>}
- */
-let contentInitializor = _ydoc => Promise.resolve()
-
-/**
- * This function is called once every time a Yjs document is created. You can
- * use it to pull data from an external source or initialize content.
- *
- * @param {(ydoc: Y.Doc) => Promise<void>} f
- */
-export const setContentInitializor = (f) => {
-  contentInitializor = f
-}
-
-export class WSSharedDoc extends Y.Doc {
-  /**
-   * @param {string} name
-   */
-  constructor (name) {
-    super({ gc: gcEnabled })
-    this.name = name
-    /**
-     * Maps from conn to set of controlled user ids. Delete all user ids from awareness when this conn is closed
-     * @type {Map<Object, Set<number>>}
-     */
-    this.conns = new Map()
-    /**
-     * @type {awarenessProtocol.Awareness}
-     */
-    this.awareness = new awarenessProtocol.Awareness(this)
-    this.awareness.setLocalState(null)
-    /**
-     * @param {{ added: Array<number>, updated: Array<number>, removed: Array<number> }} changes
-     * @param {Object | null} conn Origin is the connection that made the change
-     */
-    const awarenessChangeHandler = ({ added, updated, removed }, conn) => {
-      const changedClients = added.concat(updated, removed)
-      if (conn !== null) {
-        const connControlledIDs = /** @type {Set<number>} */ (this.conns.get(conn))
-        if (connControlledIDs !== undefined) {
-          added.forEach(clientID => { connControlledIDs.add(clientID) })
-          removed.forEach(clientID => { connControlledIDs.delete(clientID) })
-        }
-      }
-      // broadcast awareness update
-      const encoder = encoding.createEncoder()
-      encoding.writeVarUint(encoder, messageAwareness)
-      encoding.writeVarUint8Array(encoder, awarenessProtocol.encodeAwarenessUpdate(this.awareness, changedClients))
-      const buff = encoding.toUint8Array(encoder)
-      this.conns.forEach((_, c) => {
-        send(this, c, buff)
-      })
-    }
-    this.awareness.on('update', awarenessChangeHandler)
-    this.on('update', /** @type {any} */ (updateHandler))
-    //if (isCallbackSet) {
-    //  this.on('update', (_update, _origin, doc) => {
-    //    debouncer(() => callbackHandler(/** @type {WSSharedDoc} */ (doc)))
-    //  })
-    //}
-    this.whenInitialized = contentInitializor(this)
-  }
-}
-
-/**
- * Gets a Y.Doc by name, whether in memory or on disk
- *
- * @param {string} docname - the name of the Y.Doc to find or create
- * @param {boolean} gc - whether to allow gc on the doc (applies only when created)
- * @return {WSSharedDoc}
- */
-export const getYDoc = (docname, gc = true) => map.setIfUndefined(docs, docname, () => {
-  const doc = new WSSharedDoc(docname)
-  doc.gc = gc
-  if (persistence !== null) {
-    persistence.bindState(docname, doc)
-  }
-  docs.set(docname, doc)
-  return doc
-})
-
-/**
- * @param {any} conn
- * @param {WSSharedDoc} doc
- * @param {Uint8Array} message
- */
-const messageListener = (conn, doc, message) => {
-  try {
-    const encoder = encoding.createEncoder()
-    const decoder = decoding.createDecoder(new Uint8Array(message))
-    const messageType = decoding.readVarUint(decoder)
-    switch (messageType) {
-      case messageSync:
-        encoding.writeVarUint(encoder, messageSync)
-        syncProtocol.readSyncMessage(decoder, encoder, doc, conn)
-
-        // If the `encoder` only contains the type of reply message and no
-        // message, there is no need to send the message. When `encoder` only
-        // contains the type of reply, its length is 1.
-        if (encoding.length(encoder) > 1) {
-          send(doc, conn, encoding.toUint8Array(encoder))
-        }
-        break
-      case messageAwareness: {
-        awarenessProtocol.applyAwarenessUpdate(doc.awareness, decoding.readVarUint8Array(decoder), conn)
-        break
-      }
-      // If this is a text or a message (no Yjs logic) - echo the message back to the client
-      default: {
-        conn.send(String(message))
-        console.log(String(message))
-        break
-      }
-    }
-  } catch (err) {
-    console.error(err)
-    // @ts-ignore
-    doc.emit('error', [err])
-  }
-}
-
-/**
- * @param {WSSharedDoc} doc
- * @param {any} conn
- */
-const closeConn = (doc, conn) => {
-  if (doc.conns.has(conn)) {
-    /**
-     * @type {Set<number>}
-     */
-    // @ts-ignore
-    const controlledIds = doc.conns.get(conn)
-    doc.conns.delete(conn)
-    awarenessProtocol.removeAwarenessStates(doc.awareness, Array.from(controlledIds), null)
-    if (doc.conns.size === 0 && persistence !== null) {
-      // if persisted, we store state and destroy ydocument
-      persistence.writeState(doc.name, doc).then(() => {
-        doc.destroy()
-      })
-      docs.delete(doc.name)
-    }
-  }
-  conn.close()
-}
-
-/**
- * @param {WSSharedDoc} doc
- * @param {import('ws').WebSocket} conn
- * @param {Uint8Array} m
- */
-const send = (doc, conn, m) => {
-  if (conn.readyState !== wsReadyStateConnecting && conn.readyState !== wsReadyStateOpen) {
-    closeConn(doc, conn)
-  }
-  try {
-    conn.send(m, {}, err => { err != null && closeConn(doc, conn) })
-  } catch (e) {
-    closeConn(doc, conn)
-  }
-}
-
-const pingTimeout = 30000
-
-/**
- * @param {import('ws').WebSocket} conn
- * @param {import('http').IncomingMessage} req
- * @param {any} opts
- */
-export const setupWSConnection = (conn, req, { docName = (req.url || '').slice(1).split('?')[0], gc = true } = {}) => {
-  conn.binaryType = 'arraybuffer'
-  // get doc, initialize if it does not exist yet
-  const doc = getYDoc(docName, gc)
-  doc.conns.set(conn, new Set())
-  // listen and reply to events
-  conn.on('message', /** @param {ArrayBuffer} message */ message => messageListener(conn, doc, message))
-
-  // Check if connection is still alive
-  let pongReceived = true
-  const pingInterval = setInterval(() => {
-    if (!pongReceived) {
-      if (doc.conns.has(conn)) {
-        closeConn(doc, conn)
-      }
-      clearInterval(pingInterval)
-    } else if (doc.conns.has(conn)) {
-      pongReceived = false
-      try {
-        conn.ping()
-      } catch (e) {
-        closeConn(doc, conn)
-        clearInterval(pingInterval)
-      }
-    }
-  }, pingTimeout)
-  conn.on('close', () => {
-    closeConn(doc, conn)
-    clearInterval(pingInterval)
-  })
-  conn.on('pong', () => {
-    pongReceived = true
-  })
-  // put the following in a variables in a block so the interval handlers don't keep in in
-  // scope
-  {
-    // send sync step 1
-    const encoder = encoding.createEncoder()
-    encoding.writeVarUint(encoder, messageSync)
-    syncProtocol.writeSyncStep1(encoder, doc)
-    send(doc, conn, encoding.toUint8Array(encoder))
-    const awarenessStates = doc.awareness.getStates()
-    if (awarenessStates.size > 0) {
-      const encoder = encoding.createEncoder()
-      encoding.writeVarUint(encoder, messageAwareness)
-      encoding.writeVarUint8Array(encoder, awarenessProtocol.encodeAwarenessUpdate(doc.awareness, Array.from(awarenessStates.keys())))
-      send(doc, conn, encoding.toUint8Array(encoder))
-    }
-  }
-}
Author	SHA1	Message	Date
Hollajay	5415741940	p2p poll logic added	2026-03-19 10:52:12 +01:00
Hollajay	68797053ac	resolved conflict	2026-03-19 01:07:34 +01:00
Hollajay	c0e53ad652	first commit	2026-03-19 00:41:15 +01:00
				`@@ -0,0 +1 @@`
				`<svg fill="none" viewBox="0 0 16 16" xmlns="http://www.w3.org/2000/svg"><path d="M14.5 13.5V5.41a1 1 0 0 0-.3-.7L9.8.29A1 1 0 0 0 9.08 0H1.5v13.5A2.5 2.5 0 0 0 4 16h8a2.5 2.5 0 0 0 2.5-2.5m-1.5 0v-7H8v-5H3v12a1 1 0 0 0 1 1h8a1 1 0 0 0 1-1M9.5 5V2.12L12.38 5zM5.13 5h-.62v1.25h2.12V5zm-.62 3h7.12v1.25H4.5zm.62 3h-.62v1.25h7.12V11z" clip-rule="evenodd" fill="#666" fill-rule="evenodd"/></svg>`
				`@@ -0,0 +1 @@`
				<svg fill="none" xmlns="http://www.w3.org/2000/svg" viewBox="0 0 16 16"><g clip-path="url(#a)"><path fill-rule="evenodd" clip-rule="evenodd" d="M10.27 14.1a6.5 6.5 0 0 0 3.67-3.45q-1.24.21-2.7.34-.31 1.83-.97 3.1M8 16A8 8 0 1 0 8 0a8 8 0 0 0 0 16m.48-1.52a7 7 0 0 1-.96 0H7.5a4 4 0 0 1-.84-1.32q-.38-.89-.63-2.08a40 40 0 0 0 3.92 0q-.25 1.2-.63 2.08a4 4 0 0 1-.84 1.31zm2.94-4.76q1.66-.15 2.95-.43a7 7 0 0 0 0-2.58q-1.3-.27-2.95-.43a18 18 0 0 1 0 3.44m-1.27-3.54a17 17 0 0 1 0 3.64 39 39 0 0 1-4.3 0 17 17 0 0 1 0-3.64 39 39 0 0 1 4.3 0m1.1-1.17q1.45.13 2.69.34a6.5 6.5 0 0 0-3.67-3.44q.65 1.26.98 3.1M8.48 1.5l.01.02q.41.37.84 1.31.38.89.63 2.08a40 40 0 0 0-3.92 0q.25-1.2.63-2.08a4 4 0 0 1 .85-1.32 7 7 0 0 1 .96 0m-2.75.4a6.5 6.5 0 0 0-3.67 3.44 29 29 0 0 1 2.7-.34q.31-1.83.97-3.1M4.58 6.28q-1.66.16-2.95.43a7 7 0 0 0 0 2.58q1.3.27 2.95.43a18 18 0 0 1 0-3.44m.17 4.71q-1.45-.12-2.69-.34a6.5 6.5 0 0 0 3.67 3.44q-.65-1.27-.98-3.1" fill="#666"/></g><defs><clipPath id="a"><path fill="#fff" d="M0 0h16v16H0z"/></clipPath></defs></svg>
				`@@ -0,0 +1 @@`
				<svg xmlns="http://www.w3.org/2000/svg" fill="none" viewBox="0 0 394 80"><path fill="#000" d="M262 0h68.5v12.7h-27.2v66.6h-13.6V12.7H262V0ZM149 0v12.7H94v20.4h44.3v12.6H94v21h55v12.6H80.5V0h68.7zm34.3 0h-17.8l63.8 79.4h17.9l-32-39.7 32-39.6h-17.9l-23 28.6-23-28.6zm18.3 56.7-9-11-27.1 33.7h17.8l18.3-22.7z"/><path fill="#000" d="M81 79.3 17 0H0v79.3h13.6V17l50.2 62.3H81Zm252.6-.4c-1 0-1.8-.4-2.5-1s-1.1-1.6-1.1-2.6.3-1.8 1-2.5 1.6-1 2.6-1 1.8.3 2.5 1a3.4 3.4 0 0 1 .6 4.3 3.7 3.7 0 0 1-3 1.8zm23.2-33.5h6v23.3c0 2.1-.4 4-1.3 5.5a9.1 9.1 0 0 1-3.8 3.5c-1.6.8-3.5 1.3-5.7 1.3-2 0-3.7-.4-5.3-1s-2.8-1.8-3.7-3.2c-.9-1.3-1.4-3-1.4-5h6c.1.8.3 1.6.7 2.2s1 1.2 1.6 1.5c.7.4 1.5.5 2.4.5 1 0 1.8-.2 2.4-.6a4 4 0 0 0 1.6-1.8c.3-.8.5-1.8.5-3V45.5zm30.9 9.1a4.4 4.4 0 0 0-2-3.3 7.5 7.5 0 0 0-4.3-1.1c-1.3 0-2.4.2-3.3.5-.9.4-1.6 1-2 1.6a3.5 3.5 0 0 0-.3 4c.3.5.7.9 1.3 1.2l1.8 1 2 .5 3.2.8c1.3.3 2.5.7 3.7 1.2a13 13 0 0 1 3.2 1.8 8.1 8.1 0 0 1 3 6.5c0 2-.5 3.7-1.5 5.1a10 10 0 0 1-4.4 3.5c-1.8.8-4.1 1.2-6.8 1.2-2.6 0-4.9-.4-6.8-1.2-2-.8-3.4-2-4.5-3.5a10 10 0 0 1-1.7-5.6h6a5 5 0 0 0 3.5 4.6c1 .4 2.2.6 3.4.6 1.3 0 2.5-.2 3.5-.6 1-.4 1.8-1 2.4-1.7a4 4 0 0 0 .8-2.4c0-.9-.2-1.6-.7-2.2a11 11 0 0 0-2.1-1.4l-3.2-1-3.8-1c-2.8-.7-5-1.7-6.6-3.2a7.2 7.2 0 0 1-2.4-5.7 8 8 0 0 1 1.7-5 10 10 0 0 1 4.3-3.5c2-.8 4-1.2 6.4-1.2 2.3 0 4.4.4 6.2 1.2 1.8.8 3.2 2 4.3 3.4 1 1.4 1.5 3 1.5 5h-5.8z"/></svg>
				`@@ -0,0 +1 @@`
				`<svg fill="none" xmlns="http://www.w3.org/2000/svg" viewBox="0 0 1155 1000"><path d="m577.3 0 577.4 1000H0z" fill="#fff"/></svg>`