import {relayPool, generatePrivateKey, getPublicKey, signEvent} from 'nostr-tools'; import {elem, parseTextContent} from './domutil.js'; import {dateTime, formatTime} from './timeutil.js'; // curl -H 'accept: application/nostr+json' https://relay.nostr.ch/ const pool = relayPool(); pool.addRelay('wss://relay.nostr.info', {read: true, write: true}); pool.addRelay('wss://relay.damus.io', {read: true, write: true}); pool.addRelay('wss://nostr.x1ddos.ch', {read: true, write: true}); pool.addRelay('wss://relay.nostr.ch', {read: true, write: true}); // pool.addRelay('wss://nostr.openchain.fr', {read: true, write: true}); // pool.addRelay('wss://nostr.bitcoiner.social/', {read: true, write: true}); // read only // pool.addRelay('wss://nostr.rocks', {read: true, write: false}); function onEvent(evt, relay) { switch (evt.kind) { case 0: handleMetadata(evt, relay); break; case 1: handleTextNote(evt, relay); break; case 2: handleRecommendServer(evt, relay); break; case 3: // handleContactList(evt, relay); break; case 7: handleReaction(evt, relay); default: // console.log(`TODO: add support for event kind ${evt.kind}`/*, evt*/) } } let pubkey = localStorage.getItem('pub_key') || (() => { const privatekey = generatePrivateKey(); const pubkey = getPublicKey(privatekey); localStorage.setItem('private_key', privatekey); localStorage.setItem('pub_key', pubkey); return pubkey; })(); const subscription = pool.sub({ cb: onEvent, filter: { // authors: [ // '52155da703585f25053830ac39863c80ea6adc57b360472c16c566a412d2bc38', // quark // 'a6057742e73ff93b89587c27a74edf2cdab86904291416e90dc98af1c5f70cfa', // mosc // '3bf0c63fcb93463407af97a5e5ee64fa883d107ef9e558472c4eb9aaaefa459d', // fiatjaf // '52155da703585f25053830ac39863c80ea6adc57b360472c16c566a412d2bc38', // x1ddos // // pubkey, // me // '32e1827635450ebb3c5a7d12c1f8e7b2b514439ac10a67eef3d9fd9c5c68e245', // jb55 // ], // since: new Date(Date.now() - (24 * 60 * 60 * 1000)), limit: 250, } }); const textNoteList = []; // could use indexDB const eventRelayMap = {}; // eventId: [relay1, relay2] const hasEventTag = tag => tag[0] === 'e'; function handleTextNote(evt, relay) { if (eventRelayMap[evt.id]) { eventRelayMap[evt.id] = [relay, ...(eventRelayMap[evt.id])]; } else { eventRelayMap[evt.id] = [relay]; if (evt.tags.some(hasEventTag)) { handleReply(evt, relay); } else { textNoteList.push(evt); } renderFeed(); } } const replyList = []; const reactionMap = {}; const getReactionList = (id) => { return reactionMap[id]?.map(({content}) => content) || []; }; function handleReaction(evt, relay) { if (!evt.content.length) { // console.log('reaction with no content', evt) return; } const eventTags = evt.tags.filter(hasEventTag); let replies = eventTags.filter(([tag, eventId, relayUrl, marker]) => marker === 'reply'); if (replies.length === 0) { // deprecated https://github.com/nostr-protocol/nips/blob/master/10.md#positional-e-tags-deprecated replies = eventTags.filter((tags) => tags[3] === undefined); } if (replies.length !== 1) { console.log('call me', evt); return; } const [tag, eventId/*, relayUrl, marker*/] = replies[0]; if (reactionMap[eventId]) { if (reactionMap[eventId].find(reaction => reaction.id === evt.id)) { // already received this reaction from a different relay return; } reactionMap[eventId] = [evt, ...(reactionMap[eventId])]; } else { reactionMap[eventId] = [evt]; } const article = feedDomMap[eventId] || replyDomMap[eventId]; if (article) { const button = article.querySelector('button[name="star"]'); const reactions = button.querySelector('[data-reactions]'); reactions.textContent = reactionMap[eventId].length; if (evt.pubkey === pubkey) { const star = button.querySelector('img[src*="star"]'); star?.setAttribute('src', 'assets/star-fill.svg'); star?.setAttribute('title', getReactionList(eventId).join(' ')); } } } // feed const feedContainer = document.querySelector('#homefeed'); const feedDomMap = {}; const replyDomMap = {}; const restoredReplyTo = localStorage.getItem('reply_to'); const sortByCreatedAt = (evt1, evt2) => { if (evt1.created_at === evt2.created_at) { // console.log('TODO: OMG exactly at the same time, figure out how to sort then', evt1, evt2); } return evt1.created_at > evt2.created_at ? -1 : 1; }; function renderFeed() { const sortedFeeds = textNoteList.sort(sortByCreatedAt).reverse(); sortedFeeds.forEach((evt, i) => { if (feedDomMap[evt.id]) { // TODO check eventRelayMap if event was published to different relays return; } const article = createTextNote(evt, eventRelayMap[evt.id]); if (i === 0) { feedContainer.append(article); } else { feedDomMap[sortedFeeds[i - 1].id].before(article); } feedDomMap[evt.id] = article; }); } setInterval(() => { document.querySelectorAll('time[datetime]').forEach(timeElem => { timeElem.textContent = formatTime(new Date(timeElem.dateTime)); }); }, 10000); const getNoxyUrl = (type, url, id, relay) => { if (!isHttpUrl(url)) { return false; } const link = new URL(`https://noxy.nostr.ch/${type}`); link.searchParams.set('id', id); link.searchParams.set('relay', relay); link.searchParams.set('url', url); return link; } const fetchQue = []; let fetchPending; const fetchNext = (href, id, relay) => { const noxy = getNoxyUrl('meta', href, id, relay); const previewId = noxy.searchParams.toString(); if (fetchPending) { fetchQue.push({href, id, relay}); return previewId; } fetchPending = fetch(noxy.href) .then(data => { if (data.status === 200) { return data.json(); } // fetchQue.push({href, id, relay}); // could try one more time return Promise.reject(data); }) .then(meta => { const container = document.getElementById(previewId); const content = []; if (meta.images[0]) { content.push(elem('img', {className: 'preview-image', loading: 'lazy', src: getNoxyUrl('data', meta.images[0], id, relay).href})); } if (meta.title) { content.push(elem('h2', {className: 'preview-title'}, meta.title)); } if (meta.descr) { content.push(elem('p', {className: 'preview-descr'}, meta.descr)) } if (content.length) { container.append(elem('a', {href, rel: 'noopener noreferrer', target: '_blank'}, content)); container.classList.add('preview-loaded'); } }) .finally(() => { fetchPending = false; if (fetchQue.length) { const {href, id, relay} = fetchQue.shift(); return fetchNext(href, id, relay); } }) .catch(err => err.text && err.text()) .then(errMsg => errMsg && console.warn(errMsg)); return previewId; }; function linkPreview(href, id, relay) { if ((/\.(gif|jpe?g|png)$/i).test(href)) { return elem('div', {}, [elem('img', {className: 'preview-image-only', loading: 'lazy', src: getNoxyUrl('data', href, id, relay).href})] ); } const previewId = fetchNext(href, id, relay); return elem('div', { className: 'preview', id: previewId }); } function createTextNote(evt, relay) { const {host, img, isReply, name, replies, time, userName} = getMetadata(evt, relay); // const isLongContent = evt.content.trimRight().length > 280; // const content = isLongContent ? evt.content.slice(0, 280) : evt.content; const hasReactions = reactionMap[evt.id]?.length > 0; const didReact = hasReactions && !!reactionMap[evt.id].find(reaction => reaction.pubkey === pubkey); const replyFeed = replies[0] ? replies.map(e => replyDomMap[e.id] = createTextNote(e, relay)) : []; const [content, {firstLink}] = parseTextContent(evt.content); const body = elem('div', {className: 'mbox-body'}, [ elem('header', { className: 'mbox-header', title: `User: ${userName}\n${time}\n\nUser pubkey: ${evt.pubkey}\n\nRelay: ${host}\n\nEvent-id: ${evt.id} ${evt.tags.length ? `\nTags ${JSON.stringify(evt.tags)}\n` : ''} ${isReply ? `\nReply to ${evt.tags[0][1]}\n` : ''} ${evt.content}` }, [ elem('small', {}, [ elem('strong', {className: `mbox-username${name ? ' mbox-kind0-name' : ''}`, data: {pubkey: evt.pubkey.slice(0, 12)}}, name || userName), ' ', elem('time', {dateTime: time.toISOString()}, formatTime(time)), ]), ]), elem('div', {/* data: isLongContent ? {append: evt.content.slice(280)} : null*/}, [ ...content, firstLink ? linkPreview(firstLink, evt.id, relay) : '' ]), elem('button', { className: 'btn-inline', name: 'star', type: 'button', data: {'eventId': evt.id, relay}, }, [ elem('img', { alt: didReact ? '✭' : '✩', // ♥ height: 24, width: 24, src: `assets/${didReact ? 'star-fill' : 'star'}.svg`, title: getReactionList(evt.id).join(' '), }), elem('small', {data: {reactions: evt.id}}, hasReactions ? reactionMap[evt.id].length : ''), ]), elem('button', { className: 'btn-inline', name: 'reply', type: 'button', data: {'eventId': evt.id, relay}, }, [elem('img', {height: 24, width: 24, src: 'assets/comment.svg'})]), // replies[0] ? elem('div', {className: 'mobx-replies'}, replyFeed.reverse()) : '', ]); if (restoredReplyTo === evt.id) { appendReplyForm(body.querySelector('button[name="reply"]')); requestAnimationFrame(() => updateElemHeight(writeInput)); } return rendernArticle([ elem('div', {className: 'mbox-img'}, [img]), body, replies[0] ? elem('div', {className: 'mobx-replies'}, replyFeed.reverse()) : '', ]); } function handleReply(evt, relay) { if (replyDomMap[evt.id]) { console.log('CALL ME already have reply in replyDomMap', evt, relay); return; } replyList.push(evt); renderReply(evt, relay); } function renderReply(evt, relay) { const eventId = evt.tags[0][1]; // TODO: double check const article = feedDomMap[eventId] || replyDomMap[eventId]; if (!article) { // root article has not been rendered return; } let replyContainer = article.querySelector('.mobx-replies'); if (!replyContainer) { replyContainer = elem('div', {className: 'mobx-replies'}); article.append(replyContainer); } const reply = createTextNote(evt, relay); replyContainer.append(reply); replyDomMap[evt.id] = reply; } const sortEventCreatedAt = (created_at) => ( {created_at: a}, {created_at: b}, ) => ( Math.abs(a - created_at) < Math.abs(b - created_at) ? -1 : 1 ); function handleRecommendServer(evt, relay) { if (feedDomMap[evt.id]) { return; } const art = renderRecommendServer(evt, relay); if (textNoteList.length < 2) { feedContainer.append(art); return; } const closestTextNotes = textNoteList.sort(sortEventCreatedAt(evt.created_at)); feedDomMap[closestTextNotes[0].id].after(art); feedDomMap[evt.id] = art; } function handleContactList(evt, relay) { if (feedDomMap[evt.id]) { return; } const art = renderUpdateContact(evt, relay); if (textNoteList.length < 2) { feedContainer.append(art); return; } const closestTextNotes = textNoteList.sort(sortEventCreatedAt(evt.created_at)); feedDomMap[closestTextNotes[0].id].after(art); feedDomMap[evt.id] = art; // const user = userList.find(u => u.pupkey === evt.pubkey); // if (user) { // console.log(`TODO: add contact list for ${evt.pubkey.slice(0, 8)} on ${relay}`, evt.tags); // } else { // tempContactList[relay] = tempContactList[relay] // ? [...tempContactList[relay], evt] // : [evt]; // } } function renderUpdateContact(evt, relay) { const {img, time, userName} = getMetadata(evt, relay); const body = elem('div', {className: 'mbox-body', title: dateTime.format(time)}, [ elem('header', {className: 'mbox-header'}, [ elem('small', {}, [ ]), ]), elem('pre', {title: JSON.stringify(evt.content)}, [ elem('strong', {}, userName), ' updated contacts: ', JSON.stringify(evt.tags), ]), ]); return rendernArticle([img, body], {className: 'mbox-updated-contact'}); } function renderRecommendServer(evt, relay) { const {img, name, time, userName} = getMetadata(evt, relay); const body = elem('div', {className: 'mbox-body', title: dateTime.format(time)}, [ elem('header', {className: 'mbox-header'}, [ elem('small', {}, [ elem('strong', {}, userName) ]), ]), ` recommends server: ${evt.content}`, ]); return rendernArticle([ elem('div', {className: 'mbox-img'}, [img]), body ], {className: 'mbox-recommend-server', data: {relay: evt.content}}); } function rendernArticle(content, props = {}) { const className = props.className ? ['mbox', props?.className].join(' ') : 'mbox'; return elem('article', {...props, className}, content); } const userList = []; // const tempContactList = {}; function handleMetadata(evt, relay) { try { const content = JSON.parse(evt.content); setMetadata(evt, relay, content); } catch(err) { console.log(evt); console.error(err); } } function setMetadata(evt, relay, content) { let user = userList.find(u => u.pubkey === evt.pubkey); const picture = getNoxyUrl('data', content.picture, evt.id, relay).href; if (!user) { user = { metadata: {[relay]: content}, ...(content.picture && {picture}), pubkey: evt.pubkey, }; userList.push(user); } else { user.metadata[relay] = { ...user.metadata[relay], timestamp: evt.created_at, ...content, }; // use only the first profile pic (for now), different pics on each releay are not supported yet if (!user.picture) { user.picture = picture; } } // update profile images if (user.picture) { feedContainer .querySelectorAll(`canvas[data-pubkey="${evt.pubkey.slice(0, 12)}"]`) .forEach(canvas => (canvas.parentNode.replaceChild(elem('img', {src: user.picture}), canvas))); } if (user.metadata[relay].name) { feedContainer .querySelectorAll(`.mbox-username[data-pubkey="${evt.pubkey.slice(0, 12)}"]`) .forEach(username => { username.textContent = user.metadata[relay].name; username.classList.add('mbox-kind0-name'); username.removeAttribute('data-pubkey'); }); } // if (tempContactList[relay]) { // const updates = tempContactList[relay].filter(update => update.pubkey === evt.pubkey); // if (updates) { // console.log('TODO: add contact list (kind 3)', updates); // } // } } function isHttpUrl(string) { try { return ['http:', 'https:'].includes(new URL(string).protocol); } catch (err) { return false; } } const getHost = (url) => { try { return new URL(url).host; } catch(err) { return err; } } const elemCanvas = (text) => { const canvas = elem('canvas', {height: 80, width: 80, data: {pubkey: text.slice(0, 12)}}); const context = canvas.getContext('2d'); const color = `#${text.slice(0, 6)}`; context.fillStyle = color; context.fillRect(0, 0, 80, 80); context.fillStyle = '#111'; context.fillRect(0, 50, 80, 32); context.font = 'bold 18px monospace'; if (color === '#000000') { context.fillStyle = '#fff'; } context.fillText(text, 2, 46); return canvas; } function getMetadata(evt, relay) { const host = getHost(relay); const user = userList.find(user => user.pubkey === evt.pubkey); const userImg = user?.picture; const name = user?.metadata[relay]?.name; const userName = name || evt.pubkey.slice(0, 8); const userAbout = user?.metadata[relay]?.about || ''; const img = userImg ? elem('img', { alt: `${userName} ${host}`, loading: 'lazy', src: userImg, title: `${userName} on ${host} ${userAbout}`, }) : elemCanvas(evt.pubkey); const isReply = evt.tags.some(hasEventTag); const replies = replyList.filter((reply) => reply.tags[0][1] === evt.id); const time = new Date(evt.created_at * 1000); return {host, img, isReply, name, replies, time, userName}; } feedContainer.addEventListener('click', (e) => { const button = e.target.closest('button'); if (button && button.name === 'reply') { if (localStorage.getItem('reply_to') === button.dataset.eventId) { writeInput.blur(); return; } appendReplyForm(button); localStorage.setItem('reply_to', button.dataset.eventId); return; } if (button && button.name === 'star') { upvote(button.dataset.eventId, button.dataset.relay) return; } }); const writeForm = document.querySelector('#writeForm'); const writeInput = document.querySelector('textarea[name="message"]'); const elemShrink = () => { const height = writeInput.style.height || writeInput.getBoundingClientRect().height; const shrink = elem('div', {className: 'shrink-out'}); shrink.style.height = `${height}px`; shrink.addEventListener('animationend', () => shrink.remove(), {once: true}); return shrink; } writeInput.addEventListener('focusout', () => { const reply_to = localStorage.getItem('reply_to'); if (reply_to && writeInput.value === '') { writeInput.addEventListener('transitionend', (event) => { if (!reply_to || reply_to === localStorage.getItem('reply_to') && !writeInput.style.height) { // should prob use some class or data-attr instead of relying on height writeForm.after(elemShrink()); writeForm.remove(); localStorage.removeItem('reply_to'); } }, {once: true}); } }); function appendReplyForm(el) { writeForm.before(elemShrink()); writeInput.blur(); writeInput.style.removeProperty('height'); el.after(writeForm); if (writeInput.value && !writeInput.value.trimRight()) { writeInput.value = ''; } else { requestAnimationFrame(() => updateElemHeight(writeInput)); } requestAnimationFrame(() => writeInput.focus()); } const newMessageDiv = document.querySelector('#newMessage'); document.querySelector('#bubble').addEventListener('click', (e) => { localStorage.removeItem('reply_to'); // should it forget old replyto context? newMessageDiv.prepend(writeForm); hideNewMessage(false); writeInput.focus(); if (writeInput.value.trimRight()) { writeInput.style.removeProperty('height'); } document.body.style.overflow = 'hidden'; requestAnimationFrame(() => updateElemHeight(writeInput)); }); document.body.addEventListener('keyup', (e) => { if (e.key === 'Escape') { hideNewMessage(true); } }); function hideNewMessage(hide) { document.body.style.removeProperty('overflow'); newMessageDiv.hidden = hide; } async function upvote(eventId, relay) { const privatekey = localStorage.getItem('private_key'); const newReaction = { kind: 7, pubkey, // TODO: lib could check that this is the pubkey of the key to sign with content: '+', tags: [['e', eventId, relay, 'reply']], created_at: Math.floor(Date.now() * 0.001), }; const sig = await signEvent(newReaction, privatekey).catch(console.error); if (sig) { const ev = await pool.publish({...newReaction, sig}, (status, url) => { if (status === 0) { console.info(`publish request sent to ${url}`); } if (status === 1) { console.info(`event published by ${url}`); } }).catch(console.error); } } // send const sendStatus = document.querySelector('#sendstatus'); const onSendError = err => sendStatus.textContent = err.message; const publish = document.querySelector('#publish'); writeForm.addEventListener('submit', async (e) => { e.preventDefault(); // const pubkey = localStorage.getItem('pub_key'); const privatekey = localStorage.getItem('private_key'); if (!pubkey || !privatekey) { return onSendError(new Error('no pubkey/privatekey')); } const content = writeInput.value.trimRight(); if (!content) { return onSendError(new Error('message is empty')); } const replyTo = localStorage.getItem('reply_to'); const tags = replyTo ? [['e', replyTo, eventRelayMap[replyTo][0]]] : []; const newEvent = { kind: 1, pubkey, content, tags, created_at: Math.floor(Date.now() * 0.001), }; const sig = await signEvent(newEvent, privatekey).catch(onSendError); if (sig) { const ev = await pool.publish({...newEvent, sig}, (status, url) => { if (status === 0) { console.info(`publish request sent to ${url}`); } if (status === 1) { sendStatus.textContent = ''; writeInput.value = ''; writeInput.style.removeProperty('height'); publish.disabled = true; if (replyTo) { localStorage.removeItem('reply_to'); newMessageDiv.append(writeForm); } hideNewMessage(true); // console.info(`event published by ${url}`, ev); } }); } }); writeInput.addEventListener('input', () => { publish.disabled = !writeInput.value.trimRight(); updateElemHeight(writeInput); }); writeInput.addEventListener('blur', () => sendStatus.textContent = ''); function updateElemHeight(el) { el.style.removeProperty('height'); if (el.value) { el.style.paddingBottom = 0; el.style.paddingTop = 0; el.style.height = el.scrollHeight + 'px'; el.style.removeProperty('padding-bottom'); el.style.removeProperty('padding-top'); } } // settings const settingsForm = document.querySelector('form[name="settings"]'); const privateKeyInput = settingsForm.querySelector('#privatekey'); const pubKeyInput = settingsForm.querySelector('#pubkey'); const statusMessage = settingsForm.querySelector('#keystatus'); const generateBtn = settingsForm.querySelector('button[name="generate"]'); const importBtn = settingsForm.querySelector('button[name="import"]'); const privateTgl = settingsForm.querySelector('button[name="privatekey-toggle"]'); generateBtn.addEventListener('click', () => { const privatekey = generatePrivateKey(); const pubkey = getPublicKey(privatekey); if (validKeys(privatekey, pubkey)) { privateKeyInput.value = privatekey; pubKeyInput.value = pubkey; statusMessage.textContent = 'private-key created!'; statusMessage.hidden = false; } }); importBtn.addEventListener('click', () => { const privatekey = privateKeyInput.value; const pubkeyInput = pubKeyInput.value; if (validKeys(privatekey, pubkeyInput)) { localStorage.setItem('private_key', privatekey); localStorage.setItem('pub_key', pubkeyInput); statusMessage.textContent = 'stored private and public key locally!'; statusMessage.hidden = false; pubkey = pubkeyInput; } }); settingsForm.addEventListener('input', () => validKeys(privateKeyInput.value, pubKeyInput.value)); privateKeyInput.addEventListener('paste', (event) => { if (pubKeyInput.value || !event.clipboardData) { return; } if (privateKeyInput.value === '' || ( // either privatekey field is empty privateKeyInput.selectionStart === 0 // or the whole text is selected and replaced with the clipboard && privateKeyInput.selectionEnd === privateKeyInput.value.length )) { // only generate the pubkey if no data other than the text from clipboard will be used try { pubKeyInput.value = getPublicKey(event.clipboardData.getData('text')); } catch(err) {} // settings form will call validKeys on input and display the error } }); function validKeys(privatekey, pubkey) { try { if (getPublicKey(privatekey) === pubkey) { statusMessage.hidden = true; statusMessage.textContent = 'public-key corresponds to private-key'; importBtn.removeAttribute('disabled'); return true; } else { statusMessage.textContent = 'private-key does not correspond to public-key!' } } catch (e) { statusMessage.textContent = `not a valid private-key: ${e.message || e}`; } statusMessage.hidden = false; importBtn.setAttribute('disabled', true); return false; } privateTgl.addEventListener('click', () => { privateKeyInput.type = privateKeyInput.type === 'text' ? 'password' : 'text'; }); privateKeyInput.value = localStorage.getItem('private_key'); pubKeyInput.value = localStorage.getItem('pub_key'); document.body.addEventListener('click', (e) => { // const container = e.target.closest('[data-append]'); // if (container) { // container.append(...parseTextContent(container.dataset.append)); // delete container.dataset.append; // return; // } const back = e.target.closest('[name="back"]') if (back) { hideNewMessage(true); } }); // profile const profileForm = document.querySelector('form[name="profile"]'); const profileSubmit = profileForm.querySelector('button[type="submit"]'); const profileStatus = document.querySelector('#profilestatus'); const onProfileError = err => { profileStatus.hidden = false; profileStatus.textContent = err.message }; profileForm.addEventListener('input', (e) => { if (e.target.nodeName === 'TEXTAREA') { updateElemHeight(e.target); } const form = new FormData(profileForm); const name = form.get('name'); const about = form.get('about'); const picture = form.get('picture'); profileSubmit.disabled = !(name || about || picture); }); profileForm.addEventListener('submit', async (e) => { e.preventDefault(); const form = new FormData(profileForm); const privatekey = localStorage.getItem('private_key'); const newProfile = { kind: 0, pubkey, content: JSON.stringify(Object.fromEntries(form)), created_at: Math.floor(Date.now() * 0.001), tags: [], }; const sig = await signEvent(newProfile, privatekey).catch(console.error); if (sig) { const ev = await pool.publish({...newProfile, sig}, (status, url) => { if (status === 0) { console.info(`publish request sent to ${url}`); } if (status === 1) { profileStatus.textContent = 'profile metadata successfully published'; profileStatus.hidden = false; profileSubmit.disabled = true; } }).catch(console.error); } });