Compare commits

..

5 Commits

Author SHA1 Message Date
ako
a78626e0a2 update readme 2026-03-11 14:51:06 +01:00
ako
343a55a673 feat: add styles for polling app UI
Responsive single-column layout (max 480px) with styles for:
- Option items with label/vote-button rows
- Voted state highlighting (green tint)
- Active/closed timer color states
- Disabled button opacity
- Full-width copy URL button

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
2026-03-11 14:49:17 +01:00
ako
a76f00a08a feat: implement P2P polling app with Automerge sync
Core functionality using Automerge CRDT for real-time P2P sync:
- Creates or loads a shared document via URL hash
- Syncs over BroadcastChannel (local tabs) and WebSocket (wss://sync.automerge.org)
- Persists state to IndexedDB
- Add poll options with case-insensitive duplicate detection
- Toggle-vote per option, tracked per-document in localStorage
- Options sorted by vote count descending
- 2-minute countdown timer that disables voting on expiry
- Copy-to-clipboard for shareable URL

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
2026-03-11 14:49:12 +01:00
ako
1d773dcb07 feat: add HTML shell for P2P polling app
Defines the app layout with sections for:
- Status indicator for document load state
- Option input and add button
- Duplicate warning message area
- Timer section with start-voting button
- Options list for rendered poll items
- Copy URL button for sharing

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
2026-03-11 14:49:02 +01:00
ako
812098a6bb chore: initialize Vite project with Automerge dependencies
Set up project scaffold for a P2P polling app:
- package.json with @automerge/vanillajs, automerge-repo, vite deps
- vite.config.js with wasm and top-level-await plugins required by Automerge
- pnpm-lock.yaml lockfile
- .gitignore excluding node_modules

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
2026-03-11 14:48:56 +01:00
8 changed files with 1453 additions and 319 deletions

1
.gitignore vendored Normal file
View File

@@ -0,0 +1 @@
node_modules/

View File

@@ -1,14 +1,55 @@
# P2P Poll App
P2P Poll - Minimal GUN-based Scaffolding
A peer-to-peer polling app built with [Automerge](https://automerge.org/) and Vanilla JS. No backend required — polls sync in real time across browsers using CRDTs and a WebSocket relay.
What this is
- A tiny peer-to-peer polling app implemented with vanilla JS and GUN (a decentralized, CRDT-friendly database).
- No central server for poll data. Peers connect and synchronize the poll in real-time.
## Features
Notes
- This scaffold uses GUNs browser-based peer-to-peer data replication.
- You can extend with:
- Persistent storage on each peer
- Better conflict resolution UI
- Optional signaling server for explicit peer discovery
- **Add options** — type an option and press Enter or click "Add Option". Duplicate options (case-insensitive) are rejected with an inline error message.
- **Vote on options** — click the vote button next to any option. You can vote on multiple options, but only once per option.
- **Toggle votes** — click your vote again to remove it (the button turns green with a checkmark when you've voted).
- **Live vote counts** — options are sorted by vote count in descending order and update in real time as votes come in from other users.
- **2-minute countdown timer** — click "Start 2-min Vote" to begin a shared countdown. Voting is open before and during the countdown. Once the timer expires, all vote buttons are disabled.
- **Shared timer** — the deadline is stored in the Automerge document, so all peers see the same countdown and voting closes simultaneously for everyone.
- **Copy URL** — click "Copy URL" to copy the poll link to your clipboard. Share it with others to join the same poll.
- **P2P sync** — all state (options, votes, timer) syncs across browsers in real time with no central server handling your data.
## How it works
### Tech stack
- **[Automerge](https://automerge.org/)** via `@automerge/vanillajs` — a CRDT library that lets multiple clients concurrently edit shared documents and merge changes without conflicts.
- **BroadcastChannelNetworkAdapter** — syncs between tabs in the same browser instantly via the browser's BroadcastChannel API.
- **WebSocketClientAdapter** — syncs across different browsers/devices via a WebSocket relay (`wss://sync.automerge.org`). The relay only forwards CRDT messages; it does not store or interpret your data.
- **IndexedDBStorageAdapter** — persists the document locally so it survives page refreshes.
- **Vite** — bundles the app with WebAssembly support (required by Automerge).
### Data model
The poll is a single Automerge document with three fields:
```js
{
options: string[], // list of poll options in insertion order
votes: { [option]: number }, // vote count per option
deadline: number | null // Unix timestamp (ms) when voting closes, or null
}
```
### URL-based sharing
Each document gets a unique Automerge URL (e.g. `automerge:abc123...`) stored in the page's URL hash. Opening the same URL in any browser loads and syncs the same document. Creating a new poll generates a new document and updates the hash automatically.
### Voting rules
- Voted options are tracked in `localStorage` (keyed by document URL), so they persist across page refreshes but are isolated per browser.
- One vote per option per user. Votes can be toggled off and back on until the timer expires.
- The timer (`doc.deadline`) is set once by whoever clicks "Start 2-min Vote" and is shared via the Automerge document, so all peers use the same deadline.
## Running locally
```bash
pnpm install
pnpm dev
```
Open the printed localhost URL. To test cross-browser sync, copy the URL (including the `#automerge:...` hash) and open it in a different browser.

380
app.js
View File

@@ -1,200 +1,214 @@
// Minimal GUN-based P2P Poll scaffold (vanilla JS)
import {
Repo,
BroadcastChannelNetworkAdapter,
WebSocketClientAdapter,
IndexedDBStorageAdapter,
isValidAutomergeUrl,
} from "@automerge/vanillajs";
(function() {
// Initialize GUN (no server needed; can optionally connect to a relay server)
// If you want a local-only node for prototyping: Gun()
// If you want to use a signaling server for discovery, pass a list of peers to Gun().opt({peers: [...]})
const gun = Gun();
const REPO = new Repo({
network: [
new BroadcastChannelNetworkAdapter(),
new WebSocketClientAdapter("wss://sync.automerge.org"),
],
storage: new IndexedDBStorageAdapter(),
});
// DOM helpers
const pollSection = document.getElementById('poll');
const pollIdInput = document.getElementById('pollId');
const loadPollBtn = document.getElementById('loadPollBtn');
const createPollBtn = document.getElementById('createPollBtn');
const pollTitleInput = document.getElementById('pollTitle');
const setTitleBtn = document.getElementById('setTitleBtn');
const optionsDiv = document.getElementById('options');
const newOptionInput = document.getElementById('newOption');
const addOptionBtn = document.getElementById('addOptionBtn');
const totalVotesSpan = document.getElementById('totalVotes');
const pollIdDisplay = document.getElementById('pollIdDisplay');
let HANDLE;
let currentPollId = null;
let pollsRef = null; // Gun node for /polls/{pollId}
let pollData = null; // local cache
function getVotedKey(docUrl) {
return `p2p-poll-voted:${docUrl}`;
}
// Helpers
function renderOptionList(options) {
optionsDiv.innerHTML = '';
const keys = Object.keys(options || {});
if (keys.length === 0) {
optionsDiv.innerHTML = '<p>No options yet. Add one below.</p>';
return;
}
keys.forEach((optId) => {
const opt = options[optId];
const el = document.createElement('div');
el.className = 'option';
el.innerHTML = `
<span class="text">${opt.text}</span>
<button data-optid="${optId}" class="voteBtn">Vote (${opt.votes || 0})</button>
`;
optionsDiv.appendChild(el);
});
}
function getVotedOptions() {
const key = getVotedKey(document.location.hash);
return new Set(JSON.parse(localStorage.getItem(key) || "[]"));
}
function updateTotalVotes() {
const opts = pollData && pollData.options ? pollData.options : {};
const total = Object.values(opts).reduce((sum, o) => sum + (o.votes || 0), 0);
totalVotesSpan.textContent = total;
}
function markVoted(opt) {
const key = getVotedKey(document.location.hash);
const voted = getVotedOptions();
voted.add(opt);
localStorage.setItem(key, JSON.stringify([...voted]));
}
// Load existing poll and subscribe to changes
function loadPoll(pollId) {
if (!pollId) return;
function unmarkVoted(opt) {
const key = getVotedKey(document.location.hash);
const voted = getVotedOptions();
voted.delete(opt);
localStorage.setItem(key, JSON.stringify([...voted]));
}
currentPollId = pollId;
pollIdDisplay.textContent = pollId;
pollsRef = gun.get('polls').get(pollId);
const locationHash = document.location.hash.substring(1);
const statusEl = document.getElementById("status");
const optionsList = document.getElementById("options-list");
const optionInput = document.getElementById("option-input");
const addBtn = document.getElementById("add-btn");
const duplicateMsg = document.getElementById("duplicate-msg");
const copyBtn = document.getElementById("copy-btn");
const timerEl = document.getElementById("timer");
const startVotingBtn = document.getElementById("start-voting-btn");
// Initialize structure if new poll
pollsRef.get('title').put('Untitled Poll');
pollsRef.get('options').put({}); // ensure map exists
// Real-time updates: listen to changes
pollsRef.get('title').on((title) => {
pollTitleInput.value = title || '';
});
pollsRef.on((data) => {
// data is the entire poll node if subscribed; but we explore explicit fields
});
// For options map
pollsRef.get('options').on((opts) => {
// opts is the entire options map; convert to plain object
const optionsObj = toPlainObject(opts);
pollData = {
title: null,
options: optionsObj
};
renderOptionList(optionsObj);
updateTotalVotes();
});
// Also listen for title changes separately (in case some clients push via title path)
pollsRef.get('title').on((title) => {
pollTitleInput.value = title || '';
});
// Show UI
document.getElementById('setup').style.display = 'none';
pollSection.style.display = 'block';
}
// Create a new poll
function createPoll() {
const pollId = pollIdInput.value.trim();
if (!pollId) {
alert('Please enter a poll ID to create.');
return;
}
currentPollId = pollId;
// Initialize poll
pollsRef = gun.get('polls').get(pollId);
pollsRef.put({
title: 'New Poll',
});
pollsRef.get('options').put({}); // ensure map exists
// reflect in UI
pollIdDisplay.textContent = pollId;
pollTitleInput.value = 'New Poll';
pollSection.style.display = 'block';
document.getElementById('setup').style.display = 'none';
}
// Add option
function addOption() {
if (!pollsRef) {
alert('Load or create a poll first.');
return;
}
const text = newOptionInput.value.trim();
if (!text) return;
const optionId = 'opt_' + Date.now();
pollsRef.get('options').get(optionId).put({ text, votes: 0 });
newOptionInput.value = '';
}
// Set title
function setTitle() {
if (!pollsRef) return;
const title = pollTitleInput.value.trim() || 'Untitled';
pollsRef.get('title').put(title);
}
// Vote handler (delegated)
function handleVoteClick(e) {
if (e.target.classList.contains('voteBtn')) {
const optId = e.target.getAttribute('data-optid');
if (!optId || !pollsRef) return;
const optRef = pollsRef.get('options').get(optId);
// Increment votes locally
optRef.get('votes').once((v) => {
const current = v || 0;
optRef.put({ votes: current + 1 });
});
// UI will update via the on() listener on options map
}
}
// Utilities
function toPlainObject(obj) {
// Gun emits special proxy-like objects; convert to plain object
if (!obj) return {};
// If it's already a plain object, return
if (typeof obj !== 'object') return {};
// Gun events deliver object-like; attempt shallow copy
if (isValidAutomergeUrl(locationHash)) {
statusEl.textContent = "Loading document…";
try {
const copy = JSON.parse(JSON.stringify(obj));
return copy;
} catch (e) {
// Fallback: return as-is if cannot stringify
return obj;
}
HANDLE = await REPO.find(locationHash);
statusEl.textContent = "";
} catch (err) {
statusEl.textContent = "Could not load document. Starting a new one.";
HANDLE = REPO.create({ options: [], votes: {}, deadline: null });
document.location.hash = HANDLE.url;
}
} else {
HANDLE = REPO.create({ options: [], votes: {}, deadline: null });
document.location.hash = HANDLE.url;
}
// Event bindings
loadPollBtn.addEventListener('click', () => {
const id = pollIdInput.value.trim();
if (!id) {
alert('Enter a Poll ID to load.');
HANDLE.on("change", ({ doc }) => render(doc));
const initialDoc = HANDLE.doc();
if (initialDoc) render(initialDoc);
let timerInterval = null;
function render(doc) {
renderOptions(doc);
renderTimer(doc);
}
function renderOptions(doc) {
const votes = doc.votes || {};
const deadline = doc.deadline ?? null;
const now = Date.now();
const votingClosed = deadline !== null && now >= deadline;
const votedOptions = getVotedOptions();
const sorted = [...(doc.options || [])].sort(
(a, b) => (votes[b] || 0) - (votes[a] || 0),
);
optionsList.innerHTML = "";
sorted.forEach((opt) => {
const count = votes[opt] || 0;
const alreadyVoted = votedOptions.has(opt);
const item = document.createElement("div");
item.className = "option-item";
const label = document.createElement("span");
label.className = "option-label";
label.textContent = opt;
const voteBtn = document.createElement("button");
voteBtn.className = alreadyVoted ? "vote-btn voted" : "vote-btn";
voteBtn.textContent = alreadyVoted ? `${count}` : `${count}`;
voteBtn.disabled = votingClosed;
if (votingClosed) voteBtn.title = "Voting is closed";
else if (alreadyVoted) voteBtn.title = "Click to remove your vote";
voteBtn.addEventListener("click", () => {
if (alreadyVoted) {
unmarkVoted(opt);
HANDLE.change((d) => {
if (!d.votes) d.votes = {};
d.votes[opt] = Math.max(0, (d.votes[opt] || 0) - 1);
});
} else {
markVoted(opt);
HANDLE.change((d) => {
if (!d.votes) d.votes = {};
d.votes[opt] = (d.votes[opt] || 0) + 1;
});
}
});
item.appendChild(label);
item.appendChild(voteBtn);
optionsList.appendChild(item);
});
}
function renderTimer(doc) {
const deadline = doc?.deadline ?? null;
const now = Date.now();
if (deadline === null) {
timerEl.textContent = "";
startVotingBtn.hidden = false;
return;
}
loadPoll(id);
});
createPollBtn.addEventListener('click', () => {
createPoll();
});
startVotingBtn.hidden = true;
addOptionBtn.addEventListener('click', addOption);
newOptionInput.addEventListener('keydown', (ev) => {
if (ev.key === 'Enter') addOption();
});
setTitleBtn.addEventListener('click', setTitle);
// Delegate vote clicks
optionsDiv.addEventListener('click', handleVoteClick);
// Initialize: optionally auto-create a poll if URL param present
// Example: ?pollId=my-poll-123
const urlParams = new URLSearchParams(window.location.search);
const autoPoll = urlParams.get('pollId');
if (autoPoll) {
pollIdInput.value = autoPoll;
loadPoll(autoPoll);
if (now >= deadline) {
timerEl.textContent = "Voting closed.";
timerEl.className = "timer closed";
clearInterval(timerInterval);
timerInterval = null;
return;
}
})();
const remaining = Math.ceil((deadline - now) / 1000);
const mins = Math.floor(remaining / 60);
const secs = remaining % 60;
timerEl.textContent = `Voting closes in ${mins}:${secs.toString().padStart(2, "0")}`;
timerEl.className = "timer active";
if (!timerInterval) {
timerInterval = setInterval(() => {
const d = HANDLE.doc();
if (!d) return;
renderTimer(d);
renderOptions(d);
if (Date.now() >= d.deadline) {
clearInterval(timerInterval);
timerInterval = null;
}
}, 1000);
}
}
startVotingBtn.addEventListener("click", () => {
HANDLE.change((d) => {
d.deadline = Date.now() + 2 * 60 * 1000;
});
});
addBtn.addEventListener("click", () => {
const value = optionInput.value.trim();
if (!value) return;
const doc = HANDLE.doc();
const valueLower = value.toLowerCase();
const isDuplicate = (doc?.options || []).some(
(opt) => opt.toLowerCase() === valueLower,
);
if (isDuplicate) {
duplicateMsg.textContent = `"${value}" is already in the list.`;
duplicateMsg.hidden = false;
return;
}
duplicateMsg.hidden = true;
HANDLE.change((d) => {
if (!d.options) d.options = [];
d.options.push(value);
});
optionInput.value = "";
});
optionInput.addEventListener("keydown", (e) => {
if (e.key === "Enter") addBtn.click();
});
optionInput.addEventListener("input", () => {
duplicateMsg.hidden = true;
});
copyBtn.addEventListener("click", () => {
navigator.clipboard.writeText(window.location.href).then(() => {
copyBtn.textContent = "Copied!";
setTimeout(() => (copyBtn.textContent = "Copy URL"), 1500);
});
});

View File

@@ -1,55 +1,31 @@
<!doctype html>
<html lang="en">
<head>
<head>
<meta charset="UTF-8" />
<meta name="viewport" content="width=device-width, initial-scale=1.0"/>
<title>P2P Poll</title>
<link rel="stylesheet" href="styles.css" />
<!-- Gun.js via CDN for quick start -->
<script src="https://unpkg.com/gun/gun.js"></script>
</head>
<body>
<div class="container">
<h1>P2P Poll</h1>
<section id="setup" class="card">
<h2>Start or Join Poll</h2>
<div class="field">
<label for="pollId">Poll ID (share with peer):</label>
<input id="pollId" type="text" placeholder="e.g. my-poll-123" />
<meta name="viewport" content="width=device-width, initial-scale=1.0" />
<title>P2P Polling App</title>
<link rel="stylesheet" href="./styles.css" />
</head>
<body>
<div id="app">
<h1>P2P Polling App</h1>
<div id="status"></div>
<div id="add-option">
<input
type="text"
id="option-input"
placeholder="Enter an option..."
/>
<button id="add-btn">Add Option</button>
</div>
<button id="loadPollBtn">Load Poll</button>
<button id="createPollBtn">Create New Poll</button>
<p class="note">Tip: You can run two instances and connect by using the same Poll ID.</p>
</section>
<section id="poll" class="card" style="display:none;">
<h2>Poll</h2>
<div class="field">
<label for="pollTitle">Poll Title</label>
<input id="pollTitle" type="text" placeholder="Poll Title" />
<button id="setTitleBtn">Set Title</button>
<div id="duplicate-msg" hidden></div>
<div id="timer-section">
<div id="timer"></div>
<button id="start-voting-btn">Start 2-min Vote</button>
</div>
<div id="options" class="options">
<!-- dynamic options will render here -->
<div id="options-list"></div>
<button id="copy-btn">Copy URL</button>
</div>
<div class="field">
<input id="newOption" type="text" placeholder="Add a new option" />
<button id="addOptionBtn">Add Option</button>
</div>
<div class="summary">
<p>Total votes: <span id="totalVotes">0</span></p>
</div>
<div class="share">
<p>Share Poll ID with peer: <code id="pollIdDisplay"></code></p>
</div>
</section>
</div>
<script src="app.js"></script>
</body>
<script type="module" src="./app.js"></script>
</body>
</html>

23
package.json Normal file
View File

@@ -0,0 +1,23 @@
{
"name": "p2p-poll-app",
"type": "module",
"engines": {
"node": ">=24"
},
"scripts": {
"dev": "vite",
"build": "vite build",
"preview": "vite preview"
},
"dependencies": {
"@automerge/automerge-repo": "^2.0.0",
"@automerge/automerge-repo-network-websocket": "^2.0.0",
"@automerge/automerge-repo-storage-indexeddb": "^2.0.0",
"@automerge/vanillajs": "^2.5.3"
},
"devDependencies": {
"vite": "^6.0.0",
"vite-plugin-top-level-await": "^1.4.0",
"vite-plugin-wasm": "^3.3.0"
}
}

1083
pnpm-lock.yaml generated Normal file

File diff suppressed because it is too large Load Diff

View File

@@ -1,104 +1,93 @@
:root {
--bg: #0f1220;
--card: #1a1740;
--text: #e8e3ff;
--muted: #b8a7d2;
--accent: #6bd3ff;
}
* {
box-sizing: border-box;
}
html,
body {
margin: 0;
padding: 0;
font-family: sans-serif;
background: #0b0a14;
color: #fff;
height: 100%;
}
.container {
max-width: 700px;
max-width: 480px;
margin: 40px auto;
padding: 0 16px;
}
.card {
background: #1f1740;
border-radius: 12px;
padding: 16px;
margin-bottom: 14px;
border: 1px solid #2a1950;
}
.field {
margin-bottom: 12px;
#add-option {
display: flex;
gap: 8px;
align-items: center;
margin-bottom: 8px;
}
label {
min-width: 180px;
}
input[type="text"] {
#option-input {
flex: 1;
padding: 8px;
border-radius: 6px;
border: 1px solid #5a2d8a;
background: #2a174f;
color: #fff;
font-size: 1rem;
border: 1px solid #ccc;
border-radius: 4px;
}
#duplicate-msg {
color: #c00;
font-size: 0.9rem;
margin-bottom: 12px;
}
button {
padding: 8px 12px;
border-radius: 6px;
border: none;
background: #6bd3ff;
color: #04152a;
font-weight: bold;
padding: 8px 16px;
font-size: 1rem;
cursor: pointer;
border: 1px solid #ccc;
border-radius: 4px;
background: #fff;
}
button:hover {
opacity: 0.95;
button:hover:not(:disabled) {
background: #f0f0f0;
}
.options {
button:disabled {
opacity: 0.5;
cursor: default;
}
#timer-section {
display: flex;
flex-direction: column;
gap: 8px;
margin-top: 6px;
}
.option {
display: flex;
justify-content: space-between;
align-items: center;
padding: 8px;
background: #2a174f;
border: 1px solid #40217a;
border-radius: 6px;
gap: 12px;
margin-bottom: 16px;
}
.option .text {
.timer.active {
font-weight: bold;
color: #1a6e1a;
}
.timer.closed {
font-weight: bold;
color: #c00;
}
.option-item {
display: flex;
align-items: center;
justify-content: space-between;
padding: 10px 12px;
border: 1px solid #ddd;
border-radius: 4px;
margin-bottom: 8px;
}
.option-label {
flex: 1;
}
.share {
font-size: 0.9em;
color: var(--muted);
.vote-btn {
padding: 4px 12px;
font-size: 0.9rem;
white-space: nowrap;
}
.note {
color: #c8b5ff;
font-size: 0.9em;
.vote-btn.voted {
background: #e6f4e6;
border-color: #4a9e4a;
color: #2a6e2a;
}
.total {
font-weight: bold;
#copy-btn {
margin-top: 16px;
width: 100%;
}

7
vite.config.js Normal file
View File

@@ -0,0 +1,7 @@
import { defineConfig } from 'vite'
import wasm from 'vite-plugin-wasm'
import topLevelAwait from 'vite-plugin-top-level-await'
export default defineConfig({
plugins: [wasm(), topLevelAwait()]
})