Select an addon from the navigation bar.
+${callerName || 'Unknown peer'}
+ + +Select an addon from the navigation bar.
+backone service';
+ return;
+ }
+ const netPart = net ? networkLabel(net) : 'no network joined';
+ const addr = core.address ? ` · ${escapeHtml(core.address)}` : '';
+ const authNote = core.authenticated
+ ? ' · auth token OK'
+ : ' · paste ~/.backOneOneAuthToken below';
+ statusEl.innerHTML =
+ ` BackOne online${addr} · ` +
+ `${escapeHtml(netPart)} · ${core.leafPeerCount} peer(s)${authNote}`;
+}
+
+async function initAuthTokenBar(statusEl, onSaved) {
+ const bar = document.getElementById('auth-token-bar');
+ const input = document.getElementById('auth-token-input');
+ const saveBtn = document.getElementById('auth-token-save');
+ if (!bar || !input || !saveBtn) return;
+
+ async function refreshAuthUi() {
+ const ok = await BackOneAuth.validateCurrentToken();
+ bar.classList.toggle('auth-token-hidden', ok);
+ if (!ok && !input.value) {
+ input.placeholder = 'Paste from ~/.backOneOneAuthToken';
+ }
+ return ok;
+ }
+
+ saveBtn.addEventListener('click', async () => {
+ const token = input.value.trim();
+ if (!token) {
+ if (statusEl) statusEl.textContent = 'Paste the token from ~/.backOneOneAuthToken';
+ return;
+ }
+ saveBtn.disabled = true;
+ await BackOneAuth.setUserToken(token);
+ BackOneAuth.invalidate();
+ const ok = await BackOneAuth.validateCurrentToken();
+ if (!ok) {
+ if (statusEl) statusEl.textContent = 'Token rejected — check ~/.backOneOneAuthToken matches the running backone service';
+ saveBtn.disabled = false;
+ return;
+ }
+ input.value = '';
+ bar.classList.add('auth-token-hidden');
+ if (typeof onSaved === 'function') await onSaved();
+ saveBtn.disabled = false;
+ });
+
+ await refreshAuthUi();
+ return refreshAuthUi;
+}
+
+async function initNetworkBar() {
+ const bar = document.getElementById('network-bar');
+ if (!bar) return;
+
+ const netSel = bar.querySelector('#global-network');
+ const joinInput = bar.querySelector('#global-join-id');
+ const joinBtn = bar.querySelector('#global-join-btn');
+ const leaveBtn = bar.querySelector('#global-leave-btn');
+ const statusEl = bar.querySelector('#global-network-status');
+
+ async function reloadNetworkList(selectId) {
+ await BackOneNetworkSession.syncFromCore();
+ const networks = await BackOneNetworkSession.loadNetworks();
+ netSel.innerHTML = networks.map(n =>
+ ``
+ ).join('') || '';
+
+ const want = (selectId || BackOneNetworkSession.getNetworkId() || '').toLowerCase();
+ if (want && networks.some(n => (n.id || '').toLowerCase() === want)) {
+ netSel.value = networks.find(n => (n.id || '').toLowerCase() === want).id;
+ await BackOneNetworkSession.selectNetwork(netSel.value);
+ } else if (networks.length === 1) {
+ netSel.value = networks[0].id;
+ await BackOneNetworkSession.selectNetwork(networks[0].id);
+ } else if (networks.length > 0 && BackOneNetworkSession.getNetworkId()) {
+ netSel.value = BackOneNetworkSession.getNetworkId();
+ }
+ renderCoreStatus(statusEl);
+ }
+
+ netSel.addEventListener('change', async () => {
+ if (!netSel.value) return;
+ statusEl.textContent = 'Switching network…';
+ await BackOneNetworkSession.selectNetwork(netSel.value);
+ await BackOneNetworkSession.syncFromCore();
+ renderCoreStatus(statusEl);
+ });
+
+ joinBtn.addEventListener('click', async () => {
+ const id = BackOnePeerDirectory.normalizeNetworkId(joinInput.value);
+ if (!id) {
+ statusEl.textContent = 'Enter a 16-digit hexadecimal network ID';
+ return;
+ }
+ joinBtn.disabled = true;
+ leaveBtn.disabled = true;
+ statusEl.textContent = `Joining ${id}…`;
+ try {
+ await BackOneNetworkSession.joinNetwork(id);
+ joinInput.value = '';
+ await reloadNetworkList(id);
+ } catch (err) {
+ statusEl.textContent = err.message || 'Join failed';
+ } finally {
+ joinBtn.disabled = false;
+ leaveBtn.disabled = false;
+ }
+ });
+
+ leaveBtn.addEventListener('click', async () => {
+ const id = netSel.value || BackOneNetworkSession.getNetworkId();
+ if (!id) {
+ statusEl.textContent = 'Select a network to leave';
+ return;
+ }
+ if (!confirm(`Leave network ${networkLabel(BackOneNetworkSession.getActiveNetwork() || { id })}?`)) return;
+ joinBtn.disabled = true;
+ leaveBtn.disabled = true;
+ statusEl.textContent = `Leaving ${id}…`;
+ try {
+ await BackOneNetworkSession.leaveNetwork(id);
+ await reloadNetworkList();
+ } catch (err) {
+ statusEl.textContent = err.message || 'Leave failed';
+ } finally {
+ joinBtn.disabled = false;
+ leaveBtn.disabled = false;
+ }
+ });
+
+ BackOneNetworkSession.subscribe(() => renderCoreStatus(statusEl));
+
+ const refreshAuthUi = await initAuthTokenBar(statusEl, () => reloadNetworkList());
+
+ await reloadNetworkList();
+ if (refreshAuthUi) await refreshAuthUi();
+
+ coreRefreshTimer = setInterval(() => {
+ BackOneNetworkSession.syncFromCore().then(() => renderCoreStatus(statusEl));
+ }, 45000);
+}
+
+async function initAppShell() {
+ await BackOneAuth.init();
+ await initNetworkBar();
+
+ const nav = document.getElementById('addon-nav');
+ const panel = document.getElementById('addon-panel');
+ const addons = await BackOneAddonLoader.loadAddonManifest();
+ if (!addons.length) {
+ panel.innerHTML = 'No UI addons found. Install backone-addon-voice, backone-addon-video, or backone-addon-chat, then run: sudo backone-updater rebuild-manifest and restart backone.
Addon "${entry.id}" loaded.
`; + } + }; + addonButtons[entry.id] = btn; + nav.appendChild(btn); + } + + const fromHash = hashAddonId(); + if (fromHash && addonButtons[fromHash]) { + activateAddon(fromHash); + } else { + nav.querySelector('button')?.click(); + } +} + +window.addEventListener('hashchange', () => { + const id = hashAddonId(); + if (id) activateAddon(id); +}); + +document.addEventListener('visibilitychange', () => { + if (document.visibilityState === 'visible') { + BackOneNetworkSession.syncFromCore(); + } +}); + +document.addEventListener('DOMContentLoaded', initAppShell); diff --git a/Support/BackOne/app/network-session.js b/Support/BackOne/app/network-session.js new file mode 100644 index 0000000..4a394a6 --- /dev/null +++ b/Support/BackOne/app/network-session.js @@ -0,0 +1,178 @@ +/** + * Single BackOne core network for all addons (same as backone-cli listnetworks/join). + */ +window.BackOneNetworkSession = (function () { + const NETWORK_KEY = 'backone.lastNetworkId'; + const PEER_KEY = 'backone.lastPeerId'; + + let activeNetwork = null; + let selectedPeer = null; + let coreStatus = { online: false, address: '', networkCount: 0, leafPeerCount: 0, authenticated: false }; + const listeners = new Set(); + + function emit() { + const snap = { + network: activeNetwork, + networkId: getNetworkId(), + peer: selectedPeer, + core: { ...coreStatus } + }; + listeners.forEach(fn => { + try { fn(snap); } catch (_) { /* ignore */ } + }); + } + + function getNetworkId() { + return (localStorage.getItem(NETWORK_KEY) || '').toLowerCase(); + } + + function setNetworkId(id) { + const nwid = BackOnePeerDirectory.normalizeNetworkId(id); + if (nwid) { + localStorage.setItem(NETWORK_KEY, nwid); + } else { + localStorage.removeItem(NETWORK_KEY); + } + BackOnePeerDirectory.setLastNetworkId(nwid); + return nwid; + } + + function getSelectedPeerId() { + return (localStorage.getItem(PEER_KEY) || '').toLowerCase(); + } + + function setSelectedPeer(peer) { + selectedPeer = peer || null; + if (peer && peer.peerId) { + localStorage.setItem(PEER_KEY, peer.peerId); + } else { + localStorage.removeItem(PEER_KEY); + } + emit(); + } + + function pickDefaultNetworkId(networks) { + if (!networks.length) return ''; + const stored = getNetworkId(); + if (stored && networks.some(n => (n.id || '').toLowerCase() === stored)) { + return stored; + } + const preferred = networks.find(n => n.status === 'OK') + || networks.find(n => n.status === 'REQUESTING_CONFIGURATION') + || networks[0]; + return preferred ? (preferred.id || '').toLowerCase() : ''; + } + + /** + * On app start: read BackOne core state (same as backone-cli info / listnetworks / peers). + */ + async function syncFromCore() { + const token = await BackOneAuth.getToken(); + const [status, networks, cliPeers] = await Promise.all([ + BackOnePeerDirectory.loadCoreStatus(), + BackOnePeerDirectory.loadNetworks(), + BackOnePeerDirectory.loadCliPeers() + ]); + + coreStatus = { + online: !!(status && status.online), + address: (status && status.address) || '', + version: (status && status.version) || '', + networkCount: networks.length, + leafPeerCount: BackOnePeerDirectory.countLeafPeers(cliPeers), + authenticated: !!token + }; + + const pick = pickDefaultNetworkId(networks); + if (pick) { + setNetworkId(pick); + activeNetwork = networks.find(n => (n.id || '').toLowerCase() === pick) + || await BackOnePeerDirectory.loadNetwork(pick); + } else { + setNetworkId(''); + activeNetwork = null; + } + + emit(); + return { coreStatus, activeNetwork, networks }; + } + + async function refresh() { + const id = getNetworkId(); + if (!id) { + activeNetwork = null; + emit(); + return null; + } + activeNetwork = await BackOnePeerDirectory.loadNetwork(id); + if (!activeNetwork) { + activeNetwork = { id, name: id, status: 'UNKNOWN' }; + } + emit(); + return activeNetwork; + } + + async function loadNetworks() { + return BackOnePeerDirectory.loadNetworks(); + } + + async function selectNetwork(nwid) { + const id = setNetworkId(nwid); + if (!id) { + await refresh(); + return null; + } + return refresh(); + } + + async function joinNetwork(nwid) { + const id = BackOnePeerDirectory.normalizeNetworkId(nwid); + if (!id) throw new Error('Network ID must be 16 hexadecimal characters'); + await BackOnePeerDirectory.joinNetwork(id); + return syncFromCore(); + } + + async function leaveNetwork(nwid) { + const id = BackOnePeerDirectory.normalizeNetworkId(nwid || getNetworkId()); + if (!id) throw new Error('No network selected'); + await BackOnePeerDirectory.leaveNetwork(id); + if (getNetworkId() === id) { + setNetworkId(''); + selectedPeer = null; + localStorage.removeItem(PEER_KEY); + } + return syncFromCore(); + } + + function subscribe(fn) { + listeners.add(fn); + return () => listeners.delete(fn); + } + + function requireNetworkId() { + const id = getNetworkId(); + if (!id) throw new Error('Join a BackOne network first (same as backone-cli join)'); + return id; + } + + function getCoreStatus() { + return { ...coreStatus }; + } + + return { + getNetworkId, + getActiveNetwork: () => activeNetwork, + getCoreStatus, + getSelectedPeer: () => selectedPeer, + getSelectedPeerId, + setSelectedPeer, + selectNetwork, + joinNetwork, + leaveNetwork, + loadNetworks, + syncFromCore, + refresh, + subscribe, + requireNetworkId + }; +})(); diff --git a/Support/BackOne/app/peer-directory.js b/Support/BackOne/app/peer-directory.js new file mode 100644 index 0000000..cff0511 --- /dev/null +++ b/Support/BackOne/app/peer-directory.js @@ -0,0 +1,266 @@ +window.BackOnePeerDirectory = (function () { + const NETWORK_KEY = 'backone.lastNetworkId'; + const API = { + peers: ['/api/backone/peers', '/app/api/peers', '/peer'], + networks: ['/api/backone/networks', '/app/api/networks', '/network'], + status: ['/api/backone/status', '/app/api/status', '/status'], + network: (id) => [ + `/api/backone/network/${id}`, + `/app/api/network/${id}`, + `/network/${id}` + ], + members: (id) => [ + `/api/backone/network/${id}/members`, + `/app/api/network/${id}/members`, + `/unstable/controller/network/${id}/member` + ], + join: (id) => [ + `/api/backone/network/${id}`, + `/app/api/network/${id}`, + `/network/${id}` + ], + leave: (id) => [ + `/api/backone/network/${id}`, + `/app/api/network/${id}`, + `/network/${id}` + ] + }; + + function apiGet(path) { + return BackOneAuth.apiGet(path); + } + + /** Same data as `backone-cli -j peers` (GET /peer). */ + async function loadCliPeers() { + try { + const peers = await BackOneAuth.apiGetFirst(API.peers); + return Array.isArray(peers) ? peers : []; + } catch (_) { + return []; + } + } + + /** Same data as `backone-cli -j listnetworks` (GET /network). */ + async function loadNetworks() { + try { + const nets = await BackOneAuth.apiGetFirst(API.networks); + return Array.isArray(nets) ? nets : []; + } catch (_) { + return []; + } + } + + /** Same data as `backone-cli -j info` (GET /status). */ + async function loadCoreStatus() { + try { + return await BackOneAuth.apiGetFirst(API.status); + } catch (_) { + try { + const res = await fetch('/health', { cache: 'no-store' }); + return { online: res.ok }; + } catch (_2) { + return { online: false }; + } + } + } + + function countLeafPeers(cliPeers) { + if (!Array.isArray(cliPeers)) return 0; + return cliPeers.filter(p => !p.role || p.role === 'LEAF').length; + } + + async function loadNetwork(nwid) { + if (!nwid) return null; + const networks = await loadNetworks(); + const found = networks.find(n => n.id === nwid); + if (found) return found; + try { + return await BackOneAuth.apiGetFirst(API.network(nwid)); + } catch (_) { + return null; + } + } + + function getLastNetworkId() { + return localStorage.getItem(NETWORK_KEY) || ''; + } + + function setLastNetworkId(nwid) { + if (nwid) localStorage.setItem(NETWORK_KEY, nwid); + } + + function peerIsOnline(p) { + if (!p) return false; + const paths = p.paths || []; + return paths.some(x => x.active && !x.expired); + } + + function peerLinkLabel(p) { + if (!p) return ''; + if (p.tunneled) return 'RELAY'; + const paths = p.paths || []; + for (const path of paths) { + if (path.preferred && path.active && !path.expired) { + return 'DIRECT'; + } + } + for (const path of paths) { + if (path.active && !path.expired) { + return 'DIRECT'; + } + } + return 'RELAY'; + } + + function peerPreferredPath(p) { + if (!p) return ''; + const paths = p.paths || []; + for (const path of paths) { + if (path.preferred && path.address) return path.address; + } + for (const path of paths) { + if (path.active && path.address) return path.address; + } + return ''; + } + + function cliPeerMap(cliPeers) { + const map = {}; + for (const p of cliPeers) { + const id = (p.address || '').toLowerCase(); + if (id) map[id] = p; + } + return map; + } + + async function loadMemberMap(nwid) { + if (!nwid) return {}; + try { + const data = await BackOneAuth.apiGetFirst(API.members(nwid)); + const map = {}; + if (data && Array.isArray(data.data)) { + for (const m of data.data) { + const id = (m.id || '').toLowerCase(); + if (id) map[id] = m; + } + } + return map; + } catch (_) { + return {}; + } + } + + function buildPeerEntry(peerId, member, cliPeer, networkId, networkName) { + const controllerName = member ? (member.name || '') : ''; + const ips = member && member.ipAssignments ? member.ipAssignments : []; + return { + peerId, + networkId: networkId || '', + networkName: networkName || '', + displayName: BackOneContacts.getDisplayName(peerId, controllerName), + controllerName, + nickname: BackOneContacts.getNickname(peerId), + online: peerIsOnline(cliPeer), + latency: cliPeer && typeof cliPeer.latency === 'number' ? cliPeer.latency : null, + role: (cliPeer && cliPeer.role) || (member ? 'LEAF' : ''), + version: (cliPeer && cliPeer.version) || '', + link: cliPeer ? peerLinkLabel(cliPeer) : '', + path: cliPeer ? peerPreferredPath(cliPeer) : '', + ip: ips.length ? ips[0] : '', + onNetwork: !!member + }; + } + + async function loadPeersForNetwork(nwid) { + if (!nwid) return []; + + const [cliPeers, members, selfStatus, network] = await Promise.all([ + loadCliPeers(), + loadMemberMap(nwid), + loadCoreStatus().catch(() => ({})), + loadNetwork(nwid) + ]); + await BackOneContacts.load(); + + const selfId = ((selfStatus && selfStatus.address) || '').toLowerCase(); + const networkId = nwid; + const networkName = network ? (network.name || network.id || nwid) : nwid; + const cliById = cliPeerMap(cliPeers); + const out = []; + + if (Object.keys(members).length > 0) { + for (const peerId of Object.keys(members)) { + const member = members[peerId]; + if (!member || member.authorized === false) continue; + if (peerId === selfId) continue; + out.push(buildPeerEntry(peerId, member, cliById[peerId], networkId, networkName)); + } + } else { + for (const peerId of Object.keys(cliById)) { + const p = cliById[peerId]; + if (!peerId || peerId.length !== 10 || peerId === selfId) continue; + if (p.role && p.role !== 'LEAF') continue; + out.push(buildPeerEntry(peerId, null, p, networkId, networkName)); + } + } + + out.sort((a, b) => { + if (a.online !== b.online) return a.online ? -1 : 1; + return a.displayName.localeCompare(b.displayName); + }); + return out; + } + + function searchPeers(query, list) { + const q = (query || '').trim().toLowerCase(); + if (!q) return list; + return list.filter(p => + p.displayName.toLowerCase().includes(q) || + p.peerId.includes(q) || + (p.networkName || '').toLowerCase().includes(q) || + (p.networkId || '').includes(q) || + (p.controllerName || '').toLowerCase().includes(q) || + (p.role || '').toLowerCase().includes(q) || + (p.path || '').toLowerCase().includes(q) || + (p.ip || '').toLowerCase().includes(q) + ); + } + + function normalizeNetworkId(input) { + const id = String(input || '').replace(/[^0-9a-fA-F]/g, '').toLowerCase(); + return id.length === 16 ? id : ''; + } + + async function joinNetwork(nwid) { + const id = normalizeNetworkId(nwid); + if (!id) { + throw new Error('Network ID must be 16 hexadecimal characters'); + } + return BackOneAuth.apiSendFirst(API.join(id), 'POST', {}); + } + + async function leaveNetwork(nwid) { + const id = normalizeNetworkId(nwid); + if (!id) { + throw new Error('Network ID must be 16 hexadecimal characters'); + } + return BackOneAuth.apiSendFirst(API.leave(id), 'DELETE'); + } + + return { + loadCliPeers, + loadNetworks, + loadNetwork, + loadCoreStatus, + countLeafPeers, + loadPeersForNetwork, + getLastNetworkId, + setLastNetworkId, + joinNetwork, + leaveNetwork, + normalizeNetworkId, + searchPeers, + peerIsOnline, + peerLinkLabel + }; +})(); diff --git a/Support/BackOne/app/peer-picker.js b/Support/BackOne/app/peer-picker.js new file mode 100644 index 0000000..9eb830f --- /dev/null +++ b/Support/BackOne/app/peer-picker.js @@ -0,0 +1,151 @@ +window.BackOnePeerPicker = function PeerPicker(container, options) { + options = options || {}; + const onSelect = options.onSelect || (() => {}); + const onNetworkChange = options.onNetworkChange || (() => {}); + const onAction = options.onAction || null; + const actionLabel = options.actionLabel || 'Select'; + const showActionButton = options.showActionButton !== false; + const useSharedNetwork = options.useSharedNetwork !== false; + + let selectedPeer = null; + let peers = []; + let currentNetwork = null; + let unsub = null; + + container.innerHTML = ` +backone-clibackone-cli unavailable';
+ return;
+ }
+ if (!currentNetwork || !id) {
+ netBanner.innerHTML = 'No network — core reports ' + core.networkCount + ' joined (use header bar or backone-cli listnetworks)';
+ return;
+ }
+ netBanner.textContent = `Network: ${networkLabel(currentNetwork)} · ${peers.length} contact(s) · ${core.leafPeerCount} VL1 peer(s) from core`;
+ }
+
+ function renderList() {
+ const q = searchInput.value;
+ const filtered = BackOnePeerDirectory.searchPeers(q, peers);
+ const netTag = currentNetwork ? escapeHtml(currentNetwork.name || currentNetwork.id) : '';
+ listEl.innerHTML = filtered.map(p => {
+ const lat = p.latency != null ? `${p.latency}ms` : '—';
+ const meta = [p.role || 'LEAF', lat, p.link || ''].filter(Boolean).join(' · ');
+ const ip = p.ip ? ` · ${escapeHtml(p.ip)}` : '';
+ return `
+ backone-cli peers and controller membersChoose a contact from the list
'; + return; + } + const messages = getThread(selectedPeer.peerId); + if (!messages.length) { + thread.innerHTML = 'No messages yet — start the conversation
'; + return; + } + thread.innerHTML = messages.map(m => ` + `).join(''); + thread.scrollTop = thread.scrollHeight; + }; + + function updateInputs() { + const networkId = BackOneNetworkSession.getNetworkId(); + const ok = !!networkId && !!selectedPeer; + input.disabled = !ok; + sendBtn.disabled = !ok; + renderHeader(); + } + + if (unsubChat) unsubChat(); + unsubChat = BackOneWebHubClient.subscribe('chat_message', (msg) => { + const networkId = BackOneNetworkSession.getNetworkId(); + if (!networkId || (msg.networkId && msg.networkId.toLowerCase() !== networkId)) return; + const senderId = (msg.senderId || '').toLowerCase(); + const peerId = selectedPeer?.peerId?.toLowerCase(); + if (!peerId || senderId !== peerId) { + if (senderId) { + getThread(senderId).push({ + sender: senderId, + senderName: msg.senderName || senderId, + body: msg.body || '', + at: msg.at || Date.now() + }); + } + return; + } + getThread(peerId).push({ + sender: senderId, + senderName: msg.senderName || senderId, + body: msg.body || '', + at: msg.at || Date.now() + }); + render(); + }); + + BackOnePeerPicker(container.querySelector('#chat-peer-picker'), { + layout: 'sidebar', + showActionButton: false, + onSelect(peer) { + selectedPeer = peer; + updateInputs(); + render(); + }, + onNetworkChange() { + selectedPeer = null; + clearSessionMessages(); + updateInputs(); + render(); + } + }); + + BackOneNetworkSession.subscribe(() => { + updateInputs(); + render(); + }); + + sendBtn.onclick = () => { + const networkId = BackOneNetworkSession.getNetworkId(); + if (!selectedPeer || !networkId) return; + const body = input.value.trim(); + if (!body) return; + const now = Date.now(); + const name = selfName(); + BackOneWebHubClient.send({ + type: 'chat_message', + networkId, + targetId: selectedPeer.peerId, + senderName: name, + body + }); + getThread(selectedPeer.peerId).push({ + sender: 'me', + senderName: name, + body, + at: now + }); + input.value = ''; + render(); + }; + + updateInputs(); + render(); + } + }; +}; diff --git a/addons/comms-core/addon.json b/addons/comms-core/addon.json new file mode 100644 index 0000000..dae6899 --- /dev/null +++ b/addons/comms-core/addon.json @@ -0,0 +1,10 @@ +{ + "id": "comms-core", + "name": "Comms Core", + "version": "1.17.1", + "requires": [], + "backend": { + "routes": ["/controller/comms"], + "websocketEvents": ["presence", "incoming_call", "call_state", "chat_message"] + } +} diff --git a/addons/comms-core/schema.sql b/addons/comms-core/schema.sql new file mode 100644 index 0000000..a7d5a83 --- /dev/null +++ b/addons/comms-core/schema.sql @@ -0,0 +1,32 @@ +-- BackOne comms-core addon schema (PostgreSQL) +CREATE TABLE IF NOT EXISTS backone_calls ( + id TEXT PRIMARY KEY, + network_id TEXT NOT NULL, + caller_id TEXT NOT NULL, + callee_id TEXT NOT NULL, + call_type TEXT NOT NULL CHECK (call_type IN ('voice', 'video')), + state TEXT NOT NULL, + sdp_offer TEXT, + sdp_answer TEXT, + created_at BIGINT NOT NULL +); + +CREATE TABLE IF NOT EXISTS backone_chat_messages ( + id TEXT PRIMARY KEY, + network_id TEXT NOT NULL, + sender_id TEXT NOT NULL, + body TEXT, + attachment_id TEXT, + created_at BIGINT NOT NULL +); + +CREATE TABLE IF NOT EXISTS backone_attachments ( + id TEXT PRIMARY KEY, + network_id TEXT NOT NULL, + sender_id TEXT NOT NULL, + filename TEXT NOT NULL, + mime_type TEXT NOT NULL, + size_bytes BIGINT NOT NULL, + storage_path TEXT NOT NULL, + created_at BIGINT NOT NULL +); diff --git a/addons/secure-chat/addon.json b/addons/secure-chat/addon.json new file mode 100644 index 0000000..42dba0d --- /dev/null +++ b/addons/secure-chat/addon.json @@ -0,0 +1,27 @@ +{ + "id": "secure-chat", + "name": "Secure Chat", + "version": "1.17.1", + "requires": ["comms-core", "webhub"], + "backoneCore": { + "apis": [ + "/app/api/peers", + "/app/api/networks", + "POST /app/api/network/{nwid}", + "DELETE /app/api/network/{nwid}", + "/app/api/network/{nwid}", + "/app/api/network/{nwid}/members", + "/app/api/authtoken", + "/app/api/contacts" + ] + }, + "backend": { + "routes": ["/controller/comms/network"], + "websocketEvents": ["secure_chat_message"] + }, + "frontend": { + "entry": "/app/addons/secure-chat/index.js", + "navLabel": "Secure Chat", + "icon": "chat" + } +} diff --git a/addons/secure-chat/frontend/index.js b/addons/secure-chat/frontend/index.js new file mode 100644 index 0000000..c4110f6 --- /dev/null +++ b/addons/secure-chat/frontend/index.js @@ -0,0 +1,186 @@ +window.BackOneAddons = window.BackOneAddons || {}; + +window.BackOneAddons['secure-chat'] = function secureChatAddon() { + const messagesByPeer = {}; + let selectedPeer = null; + let root = null; + let unsubChat = null; + + function escapeHtml(s) { + return String(s).replace(/&/g, '&').replace(//g, '>'); + } + + function clearSessionMessages() { + Object.keys(messagesByPeer).forEach(k => delete messagesByPeer[k]); + } + + function getThread(peerId) { + if (!messagesByPeer[peerId]) messagesByPeer[peerId] = []; + return messagesByPeer[peerId]; + } + + function formatTime(ts) { + if (!ts) return ''; + const d = new Date(ts); + return d.toLocaleString(undefined, { hour: '2-digit', minute: '2-digit', month: 'short', day: 'numeric' }); + } + + function networkLabel() { + const n = BackOneNetworkSession.getActiveNetwork(); + return n ? (n.name || n.id) : BackOneNetworkSession.getNetworkId(); + } + + function renderHeader() { + const header = root?.querySelector('#secure-chat-header'); + if (!header) return; + const net = networkLabel(); + if (!selectedPeer) { + header.textContent = net ? `Select a contact on ${net}` : 'Join a network in the header bar'; + return; + } + header.innerHTML = `${escapeHtml(selectedPeer.displayName || selectedPeer.peerId)} ${escapeHtml(selectedPeer.peerId)}${net ? ' · ' + escapeHtml(net) : ''}`; + } + + function selfName() { + const addr = (BackOneNetworkSession.getCoreStatus().address || '').toLowerCase(); + return addr ? addr.slice(0, 10) + '…' : 'me'; + } + + return { + mount(container) { + root = container; + clearSessionMessages(); + container.innerHTML = ` +Choose a contact from the list
'; + return; + } + const messages = getThread(selectedPeer.peerId); + if (!messages.length) { + thread.innerHTML = 'No messages yet — start the conversation
'; + return; + } + thread.innerHTML = messages.map(m => ` + `).join(''); + thread.scrollTop = thread.scrollHeight; + }; + + function updateInputs() { + const networkId = BackOneNetworkSession.getNetworkId(); + const ok = !!networkId && !!selectedPeer; + input.disabled = !ok; + sendBtn.disabled = !ok; + renderHeader(); + } + + if (unsubChat) unsubChat(); + unsubChat = BackOneWebHubClient.subscribe('chat_message', (msg) => { + const networkId = BackOneNetworkSession.getNetworkId(); + if (!networkId || (msg.networkId && msg.networkId.toLowerCase() !== networkId)) return; + const senderId = (msg.senderId || '').toLowerCase(); + const peerId = selectedPeer?.peerId?.toLowerCase(); + if (!peerId || senderId !== peerId) { + if (senderId) { + getThread(senderId).push({ + sender: senderId, + senderName: msg.senderName || senderId, + body: msg.body || '', + at: msg.at || Date.now() + }); + } + return; + } + getThread(peerId).push({ + sender: senderId, + senderName: msg.senderName || senderId, + body: msg.body || '', + at: msg.at || Date.now() + }); + render(); + }); + + BackOnePeerPicker(container.querySelector('#secure-chat-peer-picker'), { + layout: 'sidebar', + showActionButton: false, + onSelect(peer) { + selectedPeer = peer; + updateInputs(); + render(); + }, + onNetworkChange() { + selectedPeer = null; + clearSessionMessages(); + updateInputs(); + render(); + } + }); + + BackOneNetworkSession.subscribe(() => { + updateInputs(); + render(); + }); + + sendBtn.onclick = () => { + const networkId = BackOneNetworkSession.getNetworkId(); + if (!selectedPeer || !networkId) return; + const body = input.value.trim(); + if (!body) return; + const now = Date.now(); + const name = selfName(); + BackOneWebHubClient.send({ + type: 'chat_message', + networkId, + targetId: selectedPeer.peerId, + senderName: name, + body + }); + getThread(selectedPeer.peerId).push({ + sender: 'me', + senderName: name, + body, + at: now + }); + input.value = ''; + render(); + }; + + updateInputs(); + render(); + } + }; +}; diff --git a/addons/updater/addon.json b/addons/updater/addon.json new file mode 100644 index 0000000..e68031d --- /dev/null +++ b/addons/updater/addon.json @@ -0,0 +1,10 @@ +{ + "id": "updater", + "name": "BackOne Updater", + "version": "1.17.1", + "requires": [], + "backend": { + "routes": [], + "websocketEvents": [] + } +} diff --git a/addons/updater/backone-updater b/addons/updater/backone-updater new file mode 100755 index 0000000..2b17b41 --- /dev/null +++ b/addons/updater/backone-updater @@ -0,0 +1,132 @@ +#!/bin/bash +set -euo pipefail + +SCRIPT_DIR="$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)" +if [ -f "${SCRIPT_DIR}/platform-paths.sh" ]; then + # shellcheck source=platform-paths.sh + . "${SCRIPT_DIR}/platform-paths.sh" +else + # shellcheck source=../../pkg/common/platform-paths.sh + . "${SCRIPT_DIR}/../../pkg/common/platform-paths.sh" +fi +backone_resolve_paths + +HOME_DIR="${BACKONE_HOME}" +STAMP="${HOME_DIR}/.installed-version" +LOG_DIR="${BACKONE_LOG_DIR:-/var/log/backone}" +LOG_FILE="${LOG_DIR}/updater.log" +MIGRATIONS="${BACKONE_ADDONS_DIR}/updater/migrations" +LEGACY_HOME="/var/lib/zerotier-one" + +log() { + mkdir -p "$LOG_DIR" + echo "$(date -Iseconds) $*" | tee -a "$LOG_FILE" +} + +read_version() { + if [ -f "$STAMP" ]; then + cat "$STAMP" + else + echo '{"package":"backone","version":"0.0.0","schemaVersion":0}' + fi +} + +write_version() { + local version="${1:-$(cat debian/version 2>/dev/null || echo 1.15.0)}" + mkdir -p "$HOME_DIR" + cat > "$STAMP" <Live calls only — no call history is stored.
+ +${callerName || 'Unknown peer'}
+ + +No UI addons found. Install backone-addon-secure-chat, backone-addon-voice, backone-addon-video, or backone-addon-chat, then run: sudo backone-updater rebuild-manifest and restart backone.
Addon "${entry.id}" loaded.
`; + } + }; + addonButtons[entry.id] = btn; + nav.appendChild(btn); + } + + const fromHash = hashAddonId(); + if (fromHash && addonButtons[fromHash]) { + activateAddon(fromHash); + } else { + nav.querySelector('button')?.click(); + } +} + +window.addEventListener('hashchange', () => { + const id = hashAddonId(); + if (id) activateAddon(id); +}); + +document.addEventListener('visibilitychange', () => { + if (document.visibilityState === 'visible') { + BackOneNetworkSession.syncFromCore(); + } +}); + +document.addEventListener('DOMContentLoaded', initAppShell); diff --git a/app-shell/dist/network-session.js b/app-shell/dist/network-session.js new file mode 100644 index 0000000..4a394a6 --- /dev/null +++ b/app-shell/dist/network-session.js @@ -0,0 +1,178 @@ +/** + * Single BackOne core network for all addons (same as backone-cli listnetworks/join). + */ +window.BackOneNetworkSession = (function () { + const NETWORK_KEY = 'backone.lastNetworkId'; + const PEER_KEY = 'backone.lastPeerId'; + + let activeNetwork = null; + let selectedPeer = null; + let coreStatus = { online: false, address: '', networkCount: 0, leafPeerCount: 0, authenticated: false }; + const listeners = new Set(); + + function emit() { + const snap = { + network: activeNetwork, + networkId: getNetworkId(), + peer: selectedPeer, + core: { ...coreStatus } + }; + listeners.forEach(fn => { + try { fn(snap); } catch (_) { /* ignore */ } + }); + } + + function getNetworkId() { + return (localStorage.getItem(NETWORK_KEY) || '').toLowerCase(); + } + + function setNetworkId(id) { + const nwid = BackOnePeerDirectory.normalizeNetworkId(id); + if (nwid) { + localStorage.setItem(NETWORK_KEY, nwid); + } else { + localStorage.removeItem(NETWORK_KEY); + } + BackOnePeerDirectory.setLastNetworkId(nwid); + return nwid; + } + + function getSelectedPeerId() { + return (localStorage.getItem(PEER_KEY) || '').toLowerCase(); + } + + function setSelectedPeer(peer) { + selectedPeer = peer || null; + if (peer && peer.peerId) { + localStorage.setItem(PEER_KEY, peer.peerId); + } else { + localStorage.removeItem(PEER_KEY); + } + emit(); + } + + function pickDefaultNetworkId(networks) { + if (!networks.length) return ''; + const stored = getNetworkId(); + if (stored && networks.some(n => (n.id || '').toLowerCase() === stored)) { + return stored; + } + const preferred = networks.find(n => n.status === 'OK') + || networks.find(n => n.status === 'REQUESTING_CONFIGURATION') + || networks[0]; + return preferred ? (preferred.id || '').toLowerCase() : ''; + } + + /** + * On app start: read BackOne core state (same as backone-cli info / listnetworks / peers). + */ + async function syncFromCore() { + const token = await BackOneAuth.getToken(); + const [status, networks, cliPeers] = await Promise.all([ + BackOnePeerDirectory.loadCoreStatus(), + BackOnePeerDirectory.loadNetworks(), + BackOnePeerDirectory.loadCliPeers() + ]); + + coreStatus = { + online: !!(status && status.online), + address: (status && status.address) || '', + version: (status && status.version) || '', + networkCount: networks.length, + leafPeerCount: BackOnePeerDirectory.countLeafPeers(cliPeers), + authenticated: !!token + }; + + const pick = pickDefaultNetworkId(networks); + if (pick) { + setNetworkId(pick); + activeNetwork = networks.find(n => (n.id || '').toLowerCase() === pick) + || await BackOnePeerDirectory.loadNetwork(pick); + } else { + setNetworkId(''); + activeNetwork = null; + } + + emit(); + return { coreStatus, activeNetwork, networks }; + } + + async function refresh() { + const id = getNetworkId(); + if (!id) { + activeNetwork = null; + emit(); + return null; + } + activeNetwork = await BackOnePeerDirectory.loadNetwork(id); + if (!activeNetwork) { + activeNetwork = { id, name: id, status: 'UNKNOWN' }; + } + emit(); + return activeNetwork; + } + + async function loadNetworks() { + return BackOnePeerDirectory.loadNetworks(); + } + + async function selectNetwork(nwid) { + const id = setNetworkId(nwid); + if (!id) { + await refresh(); + return null; + } + return refresh(); + } + + async function joinNetwork(nwid) { + const id = BackOnePeerDirectory.normalizeNetworkId(nwid); + if (!id) throw new Error('Network ID must be 16 hexadecimal characters'); + await BackOnePeerDirectory.joinNetwork(id); + return syncFromCore(); + } + + async function leaveNetwork(nwid) { + const id = BackOnePeerDirectory.normalizeNetworkId(nwid || getNetworkId()); + if (!id) throw new Error('No network selected'); + await BackOnePeerDirectory.leaveNetwork(id); + if (getNetworkId() === id) { + setNetworkId(''); + selectedPeer = null; + localStorage.removeItem(PEER_KEY); + } + return syncFromCore(); + } + + function subscribe(fn) { + listeners.add(fn); + return () => listeners.delete(fn); + } + + function requireNetworkId() { + const id = getNetworkId(); + if (!id) throw new Error('Join a BackOne network first (same as backone-cli join)'); + return id; + } + + function getCoreStatus() { + return { ...coreStatus }; + } + + return { + getNetworkId, + getActiveNetwork: () => activeNetwork, + getCoreStatus, + getSelectedPeer: () => selectedPeer, + getSelectedPeerId, + setSelectedPeer, + selectNetwork, + joinNetwork, + leaveNetwork, + loadNetworks, + syncFromCore, + refresh, + subscribe, + requireNetworkId + }; +})(); diff --git a/app-shell/dist/peer-directory.js b/app-shell/dist/peer-directory.js new file mode 100644 index 0000000..cff0511 --- /dev/null +++ b/app-shell/dist/peer-directory.js @@ -0,0 +1,266 @@ +window.BackOnePeerDirectory = (function () { + const NETWORK_KEY = 'backone.lastNetworkId'; + const API = { + peers: ['/api/backone/peers', '/app/api/peers', '/peer'], + networks: ['/api/backone/networks', '/app/api/networks', '/network'], + status: ['/api/backone/status', '/app/api/status', '/status'], + network: (id) => [ + `/api/backone/network/${id}`, + `/app/api/network/${id}`, + `/network/${id}` + ], + members: (id) => [ + `/api/backone/network/${id}/members`, + `/app/api/network/${id}/members`, + `/unstable/controller/network/${id}/member` + ], + join: (id) => [ + `/api/backone/network/${id}`, + `/app/api/network/${id}`, + `/network/${id}` + ], + leave: (id) => [ + `/api/backone/network/${id}`, + `/app/api/network/${id}`, + `/network/${id}` + ] + }; + + function apiGet(path) { + return BackOneAuth.apiGet(path); + } + + /** Same data as `backone-cli -j peers` (GET /peer). */ + async function loadCliPeers() { + try { + const peers = await BackOneAuth.apiGetFirst(API.peers); + return Array.isArray(peers) ? peers : []; + } catch (_) { + return []; + } + } + + /** Same data as `backone-cli -j listnetworks` (GET /network). */ + async function loadNetworks() { + try { + const nets = await BackOneAuth.apiGetFirst(API.networks); + return Array.isArray(nets) ? nets : []; + } catch (_) { + return []; + } + } + + /** Same data as `backone-cli -j info` (GET /status). */ + async function loadCoreStatus() { + try { + return await BackOneAuth.apiGetFirst(API.status); + } catch (_) { + try { + const res = await fetch('/health', { cache: 'no-store' }); + return { online: res.ok }; + } catch (_2) { + return { online: false }; + } + } + } + + function countLeafPeers(cliPeers) { + if (!Array.isArray(cliPeers)) return 0; + return cliPeers.filter(p => !p.role || p.role === 'LEAF').length; + } + + async function loadNetwork(nwid) { + if (!nwid) return null; + const networks = await loadNetworks(); + const found = networks.find(n => n.id === nwid); + if (found) return found; + try { + return await BackOneAuth.apiGetFirst(API.network(nwid)); + } catch (_) { + return null; + } + } + + function getLastNetworkId() { + return localStorage.getItem(NETWORK_KEY) || ''; + } + + function setLastNetworkId(nwid) { + if (nwid) localStorage.setItem(NETWORK_KEY, nwid); + } + + function peerIsOnline(p) { + if (!p) return false; + const paths = p.paths || []; + return paths.some(x => x.active && !x.expired); + } + + function peerLinkLabel(p) { + if (!p) return ''; + if (p.tunneled) return 'RELAY'; + const paths = p.paths || []; + for (const path of paths) { + if (path.preferred && path.active && !path.expired) { + return 'DIRECT'; + } + } + for (const path of paths) { + if (path.active && !path.expired) { + return 'DIRECT'; + } + } + return 'RELAY'; + } + + function peerPreferredPath(p) { + if (!p) return ''; + const paths = p.paths || []; + for (const path of paths) { + if (path.preferred && path.address) return path.address; + } + for (const path of paths) { + if (path.active && path.address) return path.address; + } + return ''; + } + + function cliPeerMap(cliPeers) { + const map = {}; + for (const p of cliPeers) { + const id = (p.address || '').toLowerCase(); + if (id) map[id] = p; + } + return map; + } + + async function loadMemberMap(nwid) { + if (!nwid) return {}; + try { + const data = await BackOneAuth.apiGetFirst(API.members(nwid)); + const map = {}; + if (data && Array.isArray(data.data)) { + for (const m of data.data) { + const id = (m.id || '').toLowerCase(); + if (id) map[id] = m; + } + } + return map; + } catch (_) { + return {}; + } + } + + function buildPeerEntry(peerId, member, cliPeer, networkId, networkName) { + const controllerName = member ? (member.name || '') : ''; + const ips = member && member.ipAssignments ? member.ipAssignments : []; + return { + peerId, + networkId: networkId || '', + networkName: networkName || '', + displayName: BackOneContacts.getDisplayName(peerId, controllerName), + controllerName, + nickname: BackOneContacts.getNickname(peerId), + online: peerIsOnline(cliPeer), + latency: cliPeer && typeof cliPeer.latency === 'number' ? cliPeer.latency : null, + role: (cliPeer && cliPeer.role) || (member ? 'LEAF' : ''), + version: (cliPeer && cliPeer.version) || '', + link: cliPeer ? peerLinkLabel(cliPeer) : '', + path: cliPeer ? peerPreferredPath(cliPeer) : '', + ip: ips.length ? ips[0] : '', + onNetwork: !!member + }; + } + + async function loadPeersForNetwork(nwid) { + if (!nwid) return []; + + const [cliPeers, members, selfStatus, network] = await Promise.all([ + loadCliPeers(), + loadMemberMap(nwid), + loadCoreStatus().catch(() => ({})), + loadNetwork(nwid) + ]); + await BackOneContacts.load(); + + const selfId = ((selfStatus && selfStatus.address) || '').toLowerCase(); + const networkId = nwid; + const networkName = network ? (network.name || network.id || nwid) : nwid; + const cliById = cliPeerMap(cliPeers); + const out = []; + + if (Object.keys(members).length > 0) { + for (const peerId of Object.keys(members)) { + const member = members[peerId]; + if (!member || member.authorized === false) continue; + if (peerId === selfId) continue; + out.push(buildPeerEntry(peerId, member, cliById[peerId], networkId, networkName)); + } + } else { + for (const peerId of Object.keys(cliById)) { + const p = cliById[peerId]; + if (!peerId || peerId.length !== 10 || peerId === selfId) continue; + if (p.role && p.role !== 'LEAF') continue; + out.push(buildPeerEntry(peerId, null, p, networkId, networkName)); + } + } + + out.sort((a, b) => { + if (a.online !== b.online) return a.online ? -1 : 1; + return a.displayName.localeCompare(b.displayName); + }); + return out; + } + + function searchPeers(query, list) { + const q = (query || '').trim().toLowerCase(); + if (!q) return list; + return list.filter(p => + p.displayName.toLowerCase().includes(q) || + p.peerId.includes(q) || + (p.networkName || '').toLowerCase().includes(q) || + (p.networkId || '').includes(q) || + (p.controllerName || '').toLowerCase().includes(q) || + (p.role || '').toLowerCase().includes(q) || + (p.path || '').toLowerCase().includes(q) || + (p.ip || '').toLowerCase().includes(q) + ); + } + + function normalizeNetworkId(input) { + const id = String(input || '').replace(/[^0-9a-fA-F]/g, '').toLowerCase(); + return id.length === 16 ? id : ''; + } + + async function joinNetwork(nwid) { + const id = normalizeNetworkId(nwid); + if (!id) { + throw new Error('Network ID must be 16 hexadecimal characters'); + } + return BackOneAuth.apiSendFirst(API.join(id), 'POST', {}); + } + + async function leaveNetwork(nwid) { + const id = normalizeNetworkId(nwid); + if (!id) { + throw new Error('Network ID must be 16 hexadecimal characters'); + } + return BackOneAuth.apiSendFirst(API.leave(id), 'DELETE'); + } + + return { + loadCliPeers, + loadNetworks, + loadNetwork, + loadCoreStatus, + countLeafPeers, + loadPeersForNetwork, + getLastNetworkId, + setLastNetworkId, + joinNetwork, + leaveNetwork, + normalizeNetworkId, + searchPeers, + peerIsOnline, + peerLinkLabel + }; +})(); diff --git a/app-shell/dist/peer-picker.js b/app-shell/dist/peer-picker.js new file mode 100644 index 0000000..dec84bc --- /dev/null +++ b/app-shell/dist/peer-picker.js @@ -0,0 +1,193 @@ +window.BackOnePeerPicker = function PeerPicker(container, options) { + options = options || {}; + const onSelect = options.onSelect || (() => {}); + const onNetworkChange = options.onNetworkChange || (() => {}); + const onAction = options.onAction || null; + const actionLabel = options.actionLabel || 'Select'; + const showActionButton = options.showActionButton !== false; + const useSharedNetwork = options.useSharedNetwork !== false; + const layout = options.layout || 'default'; + + let selectedPeer = null; + let peers = []; + let currentNetwork = null; + let unsub = null; + + if (layout === 'sidebar') { + container.innerHTML = ` +backone-cli