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 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 ## Features
- 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.
Notes - **Add options** — type an option and press Enter or click "Add Option". Duplicate options (case-insensitive) are rejected with an inline error message.
- This scaffold uses GUNs browser-based peer-to-peer data replication. - **Vote on options** — click the vote button next to any option. You can vote on multiple options, but only once per option.
- You can extend with: - **Toggle votes** — click your vote again to remove it (the button turns green with a checkmark when you've voted).
- Persistent storage on each peer - **Live vote counts** — options are sorted by vote count in descending order and update in real time as votes come in from other users.
- Better conflict resolution UI - **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.
- Optional signaling server for explicit peer discovery - **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() { const REPO = new Repo({
// Initialize GUN (no server needed; can optionally connect to a relay server) network: [
// If you want a local-only node for prototyping: Gun() new BroadcastChannelNetworkAdapter(),
// If you want to use a signaling server for discovery, pass a list of peers to Gun().opt({peers: [...]}) new WebSocketClientAdapter("wss://sync.automerge.org"),
const gun = Gun(); ],
storage: new IndexedDBStorageAdapter(),
});
// DOM helpers let HANDLE;
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 currentPollId = null; function getVotedKey(docUrl) {
let pollsRef = null; // Gun node for /polls/{pollId} return `p2p-poll-voted:${docUrl}`;
let pollData = null; // local cache }
// Helpers function getVotedOptions() {
function renderOptionList(options) { const key = getVotedKey(document.location.hash);
optionsDiv.innerHTML = ''; return new Set(JSON.parse(localStorage.getItem(key) || "[]"));
const keys = Object.keys(options || {}); }
if (keys.length === 0) {
optionsDiv.innerHTML = '<p>No options yet. Add one below.</p>'; function markVoted(opt) {
return; const key = getVotedKey(document.location.hash);
} const voted = getVotedOptions();
keys.forEach((optId) => { voted.add(opt);
const opt = options[optId]; localStorage.setItem(key, JSON.stringify([...voted]));
const el = document.createElement('div'); }
el.className = 'option';
el.innerHTML = ` function unmarkVoted(opt) {
<span class="text">${opt.text}</span> const key = getVotedKey(document.location.hash);
<button data-optid="${optId}" class="voteBtn">Vote (${opt.votes || 0})</button> const voted = getVotedOptions();
`; voted.delete(opt);
optionsDiv.appendChild(el); localStorage.setItem(key, JSON.stringify([...voted]));
}); }
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");
if (isValidAutomergeUrl(locationHash)) {
statusEl.textContent = "Loading document…";
try {
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;
}
function updateTotalVotes() { HANDLE.on("change", ({ doc }) => render(doc));
const opts = pollData && pollData.options ? pollData.options : {};
const total = Object.values(opts).reduce((sum, o) => sum + (o.votes || 0), 0);
totalVotesSpan.textContent = total;
}
// Load existing poll and subscribe to changes const initialDoc = HANDLE.doc();
function loadPoll(pollId) { if (initialDoc) render(initialDoc);
if (!pollId) return;
currentPollId = pollId; let timerInterval = null;
pollIdDisplay.textContent = pollId;
pollsRef = gun.get('polls').get(pollId);
// Initialize structure if new poll function render(doc) {
pollsRef.get('title').put('Untitled Poll'); renderOptions(doc);
pollsRef.get('options').put({}); // ensure map exists renderTimer(doc);
}
// Real-time updates: listen to changes function renderOptions(doc) {
pollsRef.get('title').on((title) => { const votes = doc.votes || {};
pollTitleInput.value = title || ''; 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;
});
}
}); });
pollsRef.on((data) => { item.appendChild(label);
// data is the entire poll node if subscribed; but we explore explicit fields item.appendChild(voteBtn);
}); optionsList.appendChild(item);
// 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
try {
const copy = JSON.parse(JSON.stringify(obj));
return copy;
} catch (e) {
// Fallback: return as-is if cannot stringify
return obj;
}
}
// Event bindings
loadPollBtn.addEventListener('click', () => {
const id = pollIdInput.value.trim();
if (!id) {
alert('Enter a Poll ID to load.');
return;
}
loadPoll(id);
}); });
}
createPollBtn.addEventListener('click', () => { function renderTimer(doc) {
createPoll(); const deadline = doc?.deadline ?? null;
}); const now = Date.now();
addOptionBtn.addEventListener('click', addOption); if (deadline === null) {
newOptionInput.addEventListener('keydown', (ev) => { timerEl.textContent = "";
if (ev.key === 'Enter') addOption(); startVotingBtn.hidden = false;
}); return;
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);
} }
})(); startVotingBtn.hidden = true;
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> <!doctype html>
<html lang="en"> <html lang="en">
<head> <head>
<meta charset="UTF-8" /> <meta charset="UTF-8" />
<meta name="viewport" content="width=device-width, initial-scale=1.0"/> <meta name="viewport" content="width=device-width, initial-scale=1.0" />
<title>P2P Poll</title> <title>P2P Polling App</title>
<link rel="stylesheet" href="styles.css" /> <link rel="stylesheet" href="./styles.css" />
<!-- Gun.js via CDN for quick start --> </head>
<script src="https://unpkg.com/gun/gun.js"></script> <body>
</head> <div id="app">
<body> <h1>P2P Polling App</h1>
<div class="container"> <div id="status"></div>
<h1>P2P Poll</h1> <div id="add-option">
<input
<section id="setup" class="card"> type="text"
<h2>Start or Join Poll</h2> id="option-input"
<div class="field"> placeholder="Enter an option..."
<label for="pollId">Poll ID (share with peer):</label> />
<input id="pollId" type="text" placeholder="e.g. my-poll-123" /> <button id="add-btn">Add Option</button>
</div> </div>
<button id="loadPollBtn">Load Poll</button> <div id="duplicate-msg" hidden></div>
<button id="createPollBtn">Create New Poll</button> <div id="timer-section">
<p class="note">Tip: You can run two instances and connect by using the same Poll ID.</p> <div id="timer"></div>
</section> <button id="start-voting-btn">Start 2-min Vote</button>
</div>
<section id="poll" class="card" style="display:none;"> <div id="options-list"></div>
<h2>Poll</h2> <button id="copy-btn">Copy URL</button>
<div class="field"> </div>
<label for="pollTitle">Poll Title</label> <script type="module" src="./app.js"></script>
<input id="pollTitle" type="text" placeholder="Poll Title" /> </body>
<button id="setTitleBtn">Set Title</button> </html>
</div>
<div id="options" class="options">
<!-- dynamic options will render here -->
</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>
</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 { body {
margin: 0;
padding: 0;
font-family: sans-serif; font-family: sans-serif;
background: #0b0a14; max-width: 480px;
color: #fff;
height: 100%;
}
.container {
max-width: 700px;
margin: 40px auto; margin: 40px auto;
padding: 0 16px; padding: 0 16px;
} }
.card { #add-option {
background: #1f1740;
border-radius: 12px;
padding: 16px;
margin-bottom: 14px;
border: 1px solid #2a1950;
}
.field {
margin-bottom: 12px;
display: flex; display: flex;
gap: 8px; gap: 8px;
align-items: center; margin-bottom: 8px;
} }
label { #option-input {
min-width: 180px;
}
input[type="text"] {
flex: 1; flex: 1;
padding: 8px; padding: 8px;
border-radius: 6px; font-size: 1rem;
border: 1px solid #5a2d8a; border: 1px solid #ccc;
background: #2a174f; border-radius: 4px;
color: #fff; }
#duplicate-msg {
color: #c00;
font-size: 0.9rem;
margin-bottom: 12px;
} }
button { button {
padding: 8px 12px; padding: 8px 16px;
border-radius: 6px; font-size: 1rem;
border: none;
background: #6bd3ff;
color: #04152a;
font-weight: bold;
cursor: pointer; cursor: pointer;
border: 1px solid #ccc;
border-radius: 4px;
background: #fff;
} }
button:hover { button:hover:not(:disabled) {
opacity: 0.95; background: #f0f0f0;
} }
.options { button:disabled {
opacity: 0.5;
cursor: default;
}
#timer-section {
display: flex; display: flex;
flex-direction: column;
gap: 8px;
margin-top: 6px;
}
.option {
display: flex;
justify-content: space-between;
align-items: center; align-items: center;
padding: 8px; gap: 12px;
background: #2a174f; margin-bottom: 16px;
border: 1px solid #40217a;
border-radius: 6px;
} }
.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; flex: 1;
} }
.share { .vote-btn {
font-size: 0.9em; padding: 4px 12px;
color: var(--muted); font-size: 0.9rem;
white-space: nowrap;
} }
.note { .vote-btn.voted {
color: #c8b5ff; background: #e6f4e6;
font-size: 0.9em; 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()]
})