${o.name}
`) : '', - atts, - url: pagina ? pagina.href : null, - }; - } - - // Een ARTIKEL heeft een titel, en die is het eerste wat je wilt zien. Zonder - // dit kwam een WordPress-post binnen als kale body: de titel zit in `name` en - // die gooiden we weg, terwijl de excerpt in `summary` ten onrechte als - // waarschuwing dienstdeed. Nu allebei goed -- en dit is dezelfde greep die - // resolveRemoteNote al doet voor niet-Note-objecten, dus de tijdlijn en het - // antwoordpad zeggen eindelijk hetzelfde. - if (o.type && o.type !== 'Note' && typeof o.name === 'string' && o.name.trim()) { - const kop = `${HtmlSanitizerService.escape ? HtmlSanitizerService.escape(o.name) : o.name}
`; - const atts = mediaFromNote(o); - const pagina = pickLink(o.url, (mt) => !mt || /html/i.test(mt)); - return { - html: HtmlSanitizerService.sanitize(kop + (o.content || '')), - atts, - url: pagina ? pagina.href : null, - }; - } - - // Note / Question -- ongewijzigd gedrag. - const atts = (Array.isArray(o.attachment) ? o.attachment : []) - .map((a) => ({ url: safeUrl(a && a.url), type: (a && a.mediaType) || '' })) - .filter((m) => m.url); - if (!atts.some((m) => !m.type || /image/i.test(m.type))) { - const h = hoes(); if (h) atts.push(h); - } - const pagina = pickLink(o.url, () => true); - return { html: HtmlSanitizerService.sanitize(o.content || ''), atts, url: pagina ? pagina.href : null }; -} - -/** - * De site achter een library-uri, of null. Zelfde strengheid als localSlugOf: - * de uri moet met ONZE basis beginnen en de site moet bestaan -- anders levert - * andermans /library met dezelfde padstaart hier een volger op onze naam op. - */ -function libraryOwnerSlug(uri) { - const u = String(uri || ''); - if (!u.endsWith('/library')) return null; - return localSlugOf(u.slice(0, -'/library'.length)); -} - -export function buildActor(base, site) { - const id = actorId(base, site.slug); - const keys = getOrCreateKeys(site.slug); - // FEP-633c §5.3: a ward's follows are gated (guardians approve), so the actor - // MUST advertise manuallyApprovesFollowers:true — otherwise a follower's server - // (Mastodon) assumes auto-accept and shows "Following" while we hold it pending. - const isWard = (() => { try { return Guardianship.listGuardians(site.slug).length > 0; } catch { return false; } })(); - const actor = { - '@context': AP_CONTEXT, - id, - type: 'Person', - preferredUsername: site.slug, - name: site.title || site.slug, - summary: site.tagline || site.description || '', - // Een Link-ARRAY in plaats van een kale string (shaer-0nh): zo adverteert - // een kanaal zichzelf, en zo vindt een podcast-app de feed. De text/html - // staat VOORAAN, want een lezer die maar één url verwacht pakt de eerste -- - // dezelfde vorm die Funkwhale in productie met Mastodon uitwisselt. - url: channelUrls(base, site), - ...(channelCategory(site) ? { category: channelCategory(site) } : {}), - // …and the same honesty for the OWNER gate (Robins wens, 18-8): a site - // with approve_followers on holds follows pending until the owner decides. - manuallyApprovesFollowers: isWard || !!site.approve_followers, - discoverable: true, - inbox: `${id}/inbox`, - outbox: `${id}/outbox`, - followers: `${id}/followers`, - following: `${id}/following`, - featured: `${id}/featured`, - // AS2-kern `streams`: "supplementary Collections which may be of - // interest" -- precies wat de playlist-lijst is (shaer-ayc, stap 2). - // Geen eigen vocabulaire nodig, en wie het niet kent negeert het. - streams: [`${id}/tracks`, `${id}/playlists`], - // AP §5.6: the private blocked collection (owner-only GET). The server - // list is the source of truth for Shaer's "in Orbit"; clients keep no - // separate state. - blocked: `${id}/blocked`, - // FEP-1580: de vertaaltabel van een verhuizing plus de Moves die hem - // rechtvaardigen. Deze twee staan er ALTIJD, ook leeg, en dat is met opzet: - // de FEP wijst er apart op dat "een verhuizing zonder objecten" en "een - // server die dit niet kent" anders niet uit elkaar te houden zijn. - migration: `${id}/migration`, - moves: `${id}/moves`, - // FEP-633c §2: shaer:guardians / shaer:isGuardian / shaer:queues - // (guardianship module owns these). - ...Guardianship.guardianshipActorProps(id, site.slug), - // C2S clients (Shaer apps) discover auth + upload here — no hardcoded paths. - // All four are ActivityPub-spec `endpoints` terms. Dynamic client registration - // (RFC 7591) is discovered via /.well-known/oauth-authorization-server, not here. - endpoints: { - sharedInbox: `${base}/ap/inbox`, - oauthAuthorizationEndpoint: `${base}/oauth/authorize`, - oauthTokenEndpoint: `${base}/oauth/token`, - uploadMedia: `${id}/uploadMedia`, - }, - publicKey: { - id: `${id}#main-key`, - owner: id, - publicKeyPem: keys.public_pem, - }, - }; - if (site.profile_photo) { - const u = /^https?:/.test(site.profile_photo) ? site.profile_photo : `${base}${site.profile_photo.startsWith('/') ? '' : '/'}${site.profile_photo}`; - actor.icon = { type: 'Image', url: u }; - } - // Account creation date — shown by Mastodon + read by indexers (additive, standard AS2). - if (site.created_at) { try { actor.published = new Date(site.created_at).toISOString(); } catch { /* skip bad date */ } } - // FEP-7628: former identities this account claims. The OLD server checks for - // exactly this back-reference before it will move followers here, so the - // list must be on the public actor, not tucked away in settings. - try { - const aka = JSON.parse(site.ap_aliases || '[]'); - if (Array.isArray(aka)) { - const clean = aka.filter((u) => typeof u === 'string' && /^https?:\/\//i.test(u) && u !== id); - if (clean.length) actor.alsoKnownAs = clean; - } - } catch { /* skip malformed ap_aliases */ } - // FEP-7628 slice 3: this account moved. The old actor stays online AS A - // SIGNPOST — that is the whole point of keeping it: whoever missed the Move - // activity (offline server, later visitor) still learns where we went by - // fetching us. Per the FEP the moved actor "should be considered inactive", - // and publishers should stop delivering here. - if (site.moved_to && /^https?:\/\//i.test(String(site.moved_to))) actor.movedTo = String(site.moved_to); - // Zie movedLock() verderop: het serveren van movedTo is de ENE helft, het - // stilzetten van de uitgaande kant de andere. - // De MusicBrainz-koppeling van de artiest (shaer-mbz). Alleen als hij ZELF - // gekozen heeft -- er staat niets als er niets gekoppeld is, want een lege - // of geraden verwijzing is erger dan geen. - // - // schema:sameAs en niet alsoKnownAs: dat laatste is in AS2 voor vroegere - // identiteiten van dezelfde actor, en FEP-7628 leunt erop bij een verhuizing. - // Een MBID hier neerzetten zou een verhuizing kunnen laten mislukken. - const mbUrl = artiestUrl(site.mb_artist_id); - if (mbUrl) actor.sameAs = mbUrl; - // Profile links → PropertyValue rows: Mastodon/PeerTube/WordPress-ActivityPub render these as - // profile metadata (rel=me enables link-back verification). Additive; ignored by simpler receivers. - try { - const links = JSON.parse(site.profile_links || '[]'); - if (Array.isArray(links) && links.length) { - const esc = (s) => String(s).replace(/[<>&]/g, (c) => ({ '<': '<', '>': '>', '&': '&' }[c])); - const rows = links - .filter((l) => l && l.url && /^https?:/i.test(l.url)) - .map((l) => ({ - type: 'PropertyValue', - name: esc(l.platform || 'Link'), - value: `${esc(String(l.url).replace(/^https?:\/\//, ''))}`, - })); - if (rows.length) actor.attachment = rows; - } - } catch { /* skip malformed profile_links */ } - return actor; -} - -// Does a post's audio shortcodes reference at least one PLAYABLE (file-backed) -// track? Link-only tracks (external Spotify/YouTube, media_id NULL) don't count — -// they have no Klonkt-hosted audio to embed, so no player card / cover-suppression. -export function hasPlayableAudio(content, siteId) { - if (!content || !/\[\[(track|album|playlist):/i.test(content)) return false; - try { - for (const m of content.matchAll(/\[\[track:([A-Za-z0-9_-]+)\]\]/g)) { const r = db.prepare('SELECT media_id FROM audio_tracks WHERE id = ?').get(m[1]); if (r && r.media_id) return true; } - for (const m of content.matchAll(/\[\[album:([^\]]+)\]\]/g)) { if (db.prepare('SELECT 1 FROM audio_tracks WHERE site_id = ? AND album = ? AND media_id IS NOT NULL LIMIT 1').get(siteId, m[1].trim())) return true; } - for (const m of content.matchAll(/\[\[playlist:([A-Za-z0-9_-]+)\]\]/g)) { if (db.prepare('SELECT 1 FROM playlist_tracks pt JOIN audio_tracks t ON t.id = pt.track_id WHERE pt.playlist_id = ? AND t.media_id IS NOT NULL LIMIT 1').get(m[1])) return true; } - } catch { /* non-fatal */ } - return false; -} - -// fedi_open tracks → real AS2 Audio attachments (the actual file URL, served ungated) so -// EVERY client incl. the Mastodon apps plays them inline natively. Gated tracks (default) -// stay link/card-only — the file is never exposed for them. Resolve from post.content so a -// later body mutation can't affect it. -// -// Staat apart en niet meer midden in buildNote, omdat een BETAALDE post hem ook -// nodig heeft: daar staat de muur om de TEKST en niet om de muziek. -function openAudioAttachments(base, site, post) { - const openAudio = []; - if (!/\[\[(track|album|playlist):/i.test(post.content || '')) return openAudio; - const abs = (u) => !u ? null : (/^https?:/i.test(u) ? u : `${base}${u.startsWith('/') ? '' : '/'}${u}`); - const seenA = new Set(); - const addRow = (r) => { - const fn = r.filename || (r.storage_path || '').split('/').pop(); - if (!fn || seenA.has(fn)) return; seenA.add(fn); - const a = { type: 'Audio', mediaType: r.mime_type || 'audio/mpeg', url: `${base}/audio/stream/${encodeURIComponent(fn)}`, name: r.title || 'Audio' }; - // Cover art on the Audio attachment (AS2 `icon`): track cover, else the post cover. - // Mastodon renders it as the artwork thumbnail on its native audio player. - const art = abs(r.cover_url || post.cover_image_url || null); - if (art) a.icon = { type: 'Image', mediaType: guessMediaType(art), url: art }; - openAudio.push(a); - }; - const SEL = 'SELECT t.title, t.cover_url, m.filename, m.storage_path, m.mime_type FROM audio_tracks t JOIN media m ON m.id = t.media_id WHERE t.fedi_open = 1 AND '; - try { - for (const mm of (post.content || '').matchAll(/\[\[track:([A-Za-z0-9_-]+)\]\]/g)) { const r = db.prepare(SEL + 't.id = ?').get(mm[1]); if (r) addRow(r); } - for (const mm of (post.content || '').matchAll(/\[\[album:([^\]]+)\]\]/g)) for (const r of db.prepare(SEL + 't.site_id = ? AND t.album = ? ORDER BY t.rowid').all(site.id, mm[1].trim())) addRow(r); - for (const mm of (post.content || '').matchAll(/\[\[playlist:([A-Za-z0-9_-]+)\]\]/g)) for (const r of db.prepare('SELECT t.title, t.cover_url, m.filename, m.storage_path, m.mime_type FROM playlist_tracks pt JOIN audio_tracks t ON t.id = pt.track_id JOIN media m ON m.id = t.media_id WHERE t.fedi_open = 1 AND pt.playlist_id = ? ORDER BY pt.position').all(mm[1])) addRow(r); - } catch { /* non-fatal */ } - return openAudio; -} - -// HET BANDJE OP DE DRAAD. Zonder dit stuk bestaat `Mixtape` alleen in onze -// eigen code: de playlist-collectie blijft namelijk een OrderedCollection -// (dat moet, anders verliest een lezer die `type` als tekst uitpakt het hele -// object), en dan zegt niets naar buiten toe ooit dat dit een cassette is. -// Gemeten op 21-8: in de Note van een mixtape-post kwam het woord Mixtape -// niet voor, en de hub gooide zo'n bandje daarom stil weg. -// -// Als bijlage en niet als het object zelf: de post blijft een Note, zodat -// Mastodon en alles wat `Mixtape` niet kent gewoon een bericht met audio -// ziet. Wie het type wel kent, vindt het bandje als geheel. -// -// Het bandje draagt alleen wat al open staat: playlistOpenTracks filtert op -// fedi_open. Daarom is het veilig om hem ook aan een betaalde teaser te hangen. -function mixtapeAttachment(base, site, post) { - try { - const soort = postMusicType(post.content || '', site.id); - if (!soort || soort.type !== 'mixtape' || !soort.collectie || !soort.collectie.id) return null; - const pl = db.prepare('SELECT * FROM playlists WHERE id = ? AND site_id = ?') - .get(soort.collectie.id, site.id); - if (!pl) return null; - return buildMixtapeObject(base, site, { ...pl, _post: post }, playlistOpenTracks(pl.id)) || null; - } catch { return null; /* een bandje minder is geen kapotte post */ } -} - -// A single post as an AS2 Note (the object), and as a Create activity (for outbox/delivery). -export function buildNote(base, site, post, opts = {}) { - // Replies are Notes too. buildNote is the single entry point for ALL Notes; a reply is - // (for now) the simple flavor: pre-baked content, no title/cover/image/audio/embed - // machinery, addressed to the parent actor + thread. This early branch keeps that output - // byte-identical to the old buildReplyNote. When rich replies land (images/audio/embeds), - // this branch collapses and replies flow through the full post pipeline below. `post` here - // is the ap_outbox reply row (id, in_reply_to, content, post_slug, created_at, to_actor). - if (opts.isReply) { - const meR = actorId(base, site.slug); - // Rich replies: attachments column (JSON [{url, mediaType, name}]) → AS2 - // attachment array with absolute URLs and the matching object type. - let replyAtt; - try { - const list = post.attachments ? JSON.parse(post.attachments) : []; - if (Array.isArray(list) && list.length) { - replyAtt = list.map((a) => ({ - type: a.mediaType.startsWith('image/') ? 'Image' : a.mediaType.startsWith('audio/') ? 'Audio' : 'Video', - mediaType: a.mediaType, - url: /^https?:/i.test(a.url) ? a.url : `${base}${a.url}`, - name: a.name || undefined, - })); - } - } catch { /* malformed attachments never block the Note */ } - return { - id: noteId(base, post.id), - type: 'Note', - attributedTo: meR, - inReplyTo: post.in_reply_to || undefined, - content: post.content, - // Reply language (rich replies): the AS2 language map next to `content`. - contentMap: post.language ? { [post.language]: post.content } : undefined, - attachment: replyAtt, - url: post.post_slug ? `${base}/${encodeURIComponent(post.post_slug)}` : undefined, - published: toISO(post.created_at), - // A direct note (private mention, shaer-tqc) addresses ONLY its - // recipients: no Public anywhere, so it cannot be boosted and never - // shows in public timelines (the Mastodon DM model). - to: post.visibility === 'direct' - ? (JSON.parse(post.to_actors || '[]')) - : (post.to_actor ? [post.to_actor] : [PUBLIC]), - // Followers-only reply ('friends', shaer detail-view Reply): the parent - // author (in `to`) + our followers, but NO Public — it does not federate - // into open discovery. Default reply stays quiet-public (Public in cc). - cc: post.visibility === 'direct' ? [] - : post.visibility === 'friends' ? [`${meR}/followers`] - : [PUBLIC, `${meR}/followers`], - // FEP-633c 5.2.1: a ward's call for help. Only ever on direct notes. - ...Guardianship.helpRequestProps(post), - ...Guardianship.waveProps(post), - ...Guardianship.awayProps(post), - // FEP-633c §2.2: object hint that the author is a ward. - ...Guardianship.hasGuardiansProps(site.slug), - tag: [ - ...mentionTags(post.content), - ...hashtagTags(base, post.content), - ], - }; - } - const id = noteId(base, post.id); - const aId = actorId(base, site.slug); - const human = `${base}/${encodeURIComponent(post.slug)}`; - // Mastodon ignores a Note's `name`, so put the title INTO the content (bold - // first line) — the standard blog→fediverse convention. post.content is - // already sanitized HTML; the title is plain text, so escape it. - const escTitle = String(post.title || '').replace(/[<>&]/g, (c) => ({ '<': '<', '>': '>', '&': '&' }[c])); - const titleHtml = post.title ? `${escTitle}
` : ''; - - // Paid post (klonkt-demo-aki): federate a PUBLIC teaser + link, never the full - // content, so nothing leaks past the paywall. Images stay home too. - // - // MAAR DE OPENGEZETTE AUDIO REIST WEL MEE (Robin, 24-8, naar aanleiding van - // boiert.eu/introducing-this-machine). De muur staat om de TEKST. `fedi_open` - // is een aparte, eenrichtings, per nummer bewust gezette vlag van de eigenaar, - // en die nummers federeren toch al los als eigen Audio-objecten met hun - // `context` naar deze post. Hield deze tak het bandje tegen, dan hield hij - // niets geheim -- alleen de VOLGORDE en het feit dat het een cassette is. In - // de hub viel het bandje daardoor uiteen in vier losse nummers onder een kale - // teaserkaart. Een cassette die terugwijst naar "lees verder (supporters)" - // dient de betaalde post beter dan vier weesnummers. - if (post.paid) { - const esc = (x) => String(x || '').replace(/[<>&]/g, (c) => ({ '<': '<', '>': '>', '&': '&' }[c])); - const _firstP = (String(post.content || '').match(/${esc(rawTeaser)}${rawTeaser ? '…' : ''}
Lees de volledige post (supporters)
`, - url: human, - published: toISO(post.published_at || post.created_at || Date.now()), - ...(openBijlagen.length ? { attachment: openBijlagen } : {}), - to: [PUBLIC], - cc: [`${aId}/followers`], - tag: [...hashtagTags(base, post.content)], - replies: `${id}/replies`, - // DE WAARSCHUWING REIST MEE (Barts melding, 15-8). Deze vroege return liet - // `sensitive` en `summary` vallen, want die worden pas na de gewone tak - // gezet. Gevolg: een betaalde post met een waarschuwing ging ZONDER die - // waarschuwing de deur uit -- en de teaser is publiek, dus juist die had - // hem nodig. Een gevoelige teaser zonder vlag is erger dan geen teaser. - sensitive: !!post.nsfw, - ...(post.nsfw ? { summary: post.content_warning || 'Gevoelige inhoud' } : {}), - ...Guardianship.hasGuardiansProps(site.slug), - }; - } - - // Images travel as AP `attachment` (Mastodon strips🎵 ${lbl ? `${lbl}` : ''}
`; - for (const u of trackEmbedLinks) { const eu = esc(u); body += ``; } - } else { - // For playable posts, append a version param to the listen-link so Mastodon - // sees a NEW card URL and re-crawls it (fresh SQUARE player card) instead of - // reusing the cached landscape one. Invisible: the link TEXT stays clean, the - // page ignores the param. Bump FEDI_CARD_VER when the card dimensions change. - const listenHref = playable ? `${human}?fc=${FEDI_CARD_VER}` : human; - body += `🎵 ${lbl ? `${lbl} — ` : ''}listen on ${esc(site.title || 'the site')}
`; - } - } - // Klonkt renders post content with white-space:pre-wrap, so raw newlines ARE line - // breaks on the site. Mastodon (plain HTML) collapses whitespace and would drop them, - // so convert newlines tofor the federated copy (content already made with - // shift+enter uses
and has no \n → this is a no-op there). - body = body.replace(/\r?\n/g, '
'); - body = linkHashtags(base, body); // link inline #hashtags in the post body too - body = linkUrls(body); // bare URLs → clickable links on the federated copy - // Append the tags-field hashtags to the content so Mastodon renders them as clickable - // hashtags (a Hashtag that's only in the `tag` array isn't shown inline). CamelCase - // multi-word tags; skip any already present inline in the body. - { - const inlineTags = new Set(hashtagTags(base, body).map((h) => h.name.slice(1).toLowerCase())); - const addSeen = new Set(); - const tagLinks = normalizeTags(post.tags).map(tagParts).filter(Boolean) - .filter((p) => !inlineTags.has(p.slug) && !addSeen.has(p.slug) && addSeen.add(p.slug)) - .map((p) => `#${p.label}`); - if (tagLinks.length) body += `
${tagLinks.join(' ')}
`; - } - const seen = new Set(); - const attachment = urls.filter((x) => x && x.url) - .filter((x) => { if (seen.has(x.url)) return false; seen.add(x.url); return true; }) - .map((x) => { const mt = x.mt || guessMediaType(x.url); // the stored type wins; the extension map is the fallback - const ty = /^image\//i.test(mt) ? 'Image' : /^video\//i.test(mt) ? 'Video' : /^audio\//i.test(mt) ? 'Audio' : 'Document'; - const a = { type: ty, mediaType: mt, url: x.url }; - if (x.name) a.name = String(x.name).slice(0, 1500); // alt text / description (AS2 `name`) - if (x.poster) a.icon = { type: 'Image', url: x.poster }; // the video's still (shaer-zowq) - return a; }); - for (const a of openAudio) attachment.push(a); // fedi_open tracks → native Audio players - - // Het bandje als bijlage — zie mixtapeAttachment() voor het waarom. - const tape = mixtapeAttachment(base, site, post); - if (tape) attachment.push(tape); - - // Inline @user@host mentions: the Mention tag objects + the mentioned actor URIs. Only - // present when the content was already mention-linked (deliverCreate/Update resolve them - // at send time); a plain buildNote (outbox/notes) yields none. - const _mentionTags = mentionTags(body); - const _mentionCc = _mentionTags.map((t) => t.href); - - const note = { - id, - type: 'Note', - attributedTo: aId, - content: titleHtml + body, - url: human, - published: new Date(post.published_at || post.created_at || Date.now()).toISOString(), - // fan_only = "fans only" → followers-only visibility (delivered to your followers - // but not addressed to Public, so Mastodon shows it only to them and can't boost it). - to: (post.fan_only || post.ap_visibility === 'quiet') ? [`${aId}/followers`] : [PUBLIC], - // Mentioned actors (from inline @user@host links the caller resolved) are addressed in cc - // so Mastodon notifies them; empty unless the content was mention-linked (delivery time). - cc: [...new Set([ - ...(post.ap_visibility === 'quiet' ? [PUBLIC] : []), // quiet public: Public in cc, not to - ...((post.fan_only || post.ap_visibility === 'quiet') ? [] : [`${aId}/followers`]), - ..._mentionCc])], - tag: [...buildHashtagList(base, post.tags, body), ..._mentionTags, ...playlistLinkTags(base, site, post.content, post)], - replies: `${id}/replies`, - // NSFW → Mastodon-style content warning: sensitive (blurs media) + a summary/spoiler - // (hides the whole post behind a "Gevoelige inhoud" button until the reader opens it). - sensitive: !!post.nsfw, - }; - // FEP-633c §2.2: object hint that the author is a ward (safely ignorable). - Object.assign(note, Guardianship.hasGuardiansProps(site.slug)); - // FEP-044f: this post quotes a fediverse object. Emit it the way the network - // actually reads it, and address the quoted author so they get told. - applyQuoteProps(note, post.quote_uri, post.quote_actor); - if (post.nsfw) note.summary = post.content_warning || 'Gevoelige inhoud'; - if (attachment.length) note.attachment = attachment; - // When the cover attachment is suppressed (hosted audio OR an external embed/link-only track → - // so Mastodon shows the player/link card, not media), still expose the cover via AS2 `image` so - // card/grid consumers (the Klonkt Cirkel/News feed) can show it. Mastodon ignores a Note's - // `image`, so its card is unaffected — but a Klonkt receiver reads it (handleInbox o.image). - if (post.cover_image_url && noImages) { - const cov = abs(post.cover_image_url); - if (cov) { note.image = { type: 'Image', mediaType: guessMediaType(cov), url: cov }; if (post.cover_alt) note.image.name = String(post.cover_alt).slice(0, 1500); } - } - // Experiment (mirrors PeerTube / schema.org `embedUrl`): point at the GATED player page - // (/embed) so a client that honours embedUrl can show an inline player WITHOUT ever - // getting the audio file — the anti-steal posture is untouched. `embedUrl` is a real - // standard field name (not a Klonkt invention); if Mastodon's apps honour it on a Note we - // make it JSON-LD-clean with a context term, otherwise it degrades to the player card. - if (playable) note.embedUrl = `${base}/embed?post=${encodeURIComponent(post.slug)}`; - // Content language → AS2 contentMap (a BCP-47-keyed copy of the content). Mastodon reads the - // language from its key for the timeline language filter + the translate button. Emitted - // alongside `content` (Mastodon sends both); a plain receiver just uses `content`. - if (post.language && /^[a-z]{2,3}(-[A-Za-z]{2,4})?$/.test(post.language)) note.contentMap = { [post.language]: note.content }; - // A hosted poll → federate as an AS2 Question (options + live tally). Do this last so it - // reuses the note's content/addressing/tags, then swaps the type and strips media. - const ownPoll = parseOwnPoll(post.poll_json); - if (ownPoll) applyPollToNote(note, post.id, ownPoll); - return note; -} - -// All reply note URIs on a local post (inbound fediverse replies + our own -// outbound replies) — backs the Note's `replies` Collection so remote servers -// can fetch the whole thread. -export function getReplyUris(base, postId) { - const out = []; - try { - for (const r of db.prepare("SELECT object_uri FROM ap_interactions WHERE kind = 'reply' AND post_id = ? AND object_uri != '' ORDER BY created_at").all(postId)) out.push(r.object_uri); - for (const r of db.prepare('SELECT id FROM ap_outbox WHERE post_id = ? ORDER BY rowid').all(postId)) out.push(`${base}/ap/notes/${r.id}`); - } catch { /* non-fatal */ } - return out; -} - -// Notifications "seen" tracking → a real bell badge. Stored per site in app_settings. -export function markNotificationsSeen(slug) { - try { - db.prepare("INSERT INTO app_settings (key, value, updated_at) VALUES (?, ?, CURRENT_TIMESTAMP) ON CONFLICT(key) DO UPDATE SET value = excluded.value, updated_at = CURRENT_TIMESTAMP") - .run(`fedi_notif_seen:${slug}`, new Date().toISOString()); - } catch { /* non-fatal */ } -} -export function countUnseenNotifications(slug) { - try { - const row = db.prepare('SELECT value FROM app_settings WHERE key = ?').get(`fedi_notif_seen:${slug}`); - const seen = row ? Date.parse(row.value) : 0; - let n = 0; - for (const it of getNotifications(slug, 50)) { if (Date.parse(it.created_at) > seen) n++; } - return n; - } catch { return 0; } -} -// The seen-watermark itself (ms epoch, 0 = never marked) — the Messages page reads it -// BEFORE marking seen, so it can render unread dots on the items newer than last visit. -export function notificationsSeenAt(slug) { - try { - const row = db.prepare('SELECT value FROM app_settings WHERE key = ?').get(`fedi_notif_seen:${slug}`); - return row ? (Date.parse(row.value) || 0) : 0; - } catch { return 0; } -} - -// Messages = the unified inbox (Reacties + Meldingen merged, decision Robin+Bart 2026-07-16): -// every notification PLUS your own outbound replies ('sent', with edit/delete via their -// outboxId), sorted as one stream. Consecutive likes/boosts on the same post collapse into -// one grouped item (actors list + count) so activity doesn't drown out conversations. -/** ap_outbox.attachments ([{url, mediaType, name}]) naar de vorm die note-body - * leest (media_json: [{url, type, name}]). Geeft null bij niets of rommel, - * zodat een kapotte kolom hooguit media kost en niet de hele regel. */ -function outboxMediaJson(attachments) { - if (!attachments) return null; - try { - const list = JSON.parse(attachments); - if (!Array.isArray(list) || !list.length) return null; - const media = list - .filter((a) => a && a.url) - .map((a) => ({ url: a.url, type: a.mediaType || a.type || '', name: a.name || undefined })); - return media.length ? JSON.stringify(media) : null; - } catch { return null; } -} - -export function getMessages(slug, limit, offset) { - const off = Math.max(0, offset || 0); - const lim = limit || 60; - // The stream is grouped (consecutive likes/boosts collapse), so paging is done by - // recomputing the whole stream top-down and slicing [off, off+lim] — stable across - // pages. Fetch a buffer past off+lim so grouping-shrinkage can't hide a full page. - const need = off + lim + 100; - const items = getNotifications(slug, need); - try { - for (const m of listOutbox(slug).slice(0, need)) { - items.push({ - type: 'sent', outboxId: m.id, to_handle: m.to_handle, to_actor: m.to_actor, to_actors: m.to_actors, - in_reply_to: m.in_reply_to, post_slug: m.post_slug, content: m.content, - editable: m.editable, language: m.language, created_at: m.created_at, - // Je eigen bericht hoort er hetzelfde uit te zien als dat van een ander: - // note-body rendert Berichten, de Krant en de Guardian-PWA, maar leest - // media uit media_json met een `type`, terwijl ap_outbox ze als - // `attachments` met een `mediaType` bewaart. Zonder deze vertaling kwam - // een foto die JIJ meestuurde als kale tekst binnen. - media_json: outboxMediaJson(m.attachments), - }); - } - } catch { /* ignore */ } - // Een verzonden antwoord kent zijn post_slug maar niet de titel (ap_outbox - // bewaart die niet). Zonder titel toont een draad waarin JIJ als enige iets - // zei alleen een slug, dus vullen we ze in één query aan. - try { - const missing = [...new Set(items.filter((i) => i.post_slug && !i.post_title).map((i) => i.post_slug))]; - if (missing.length) { - const rows = db.prepare( - `SELECT slug, title FROM posts WHERE slug IN (${missing.map(() => '?').join(',')}) - AND site_id = (SELECT id FROM sites WHERE slug = ?)`, - ).all(...missing, slug); - const byslug = new Map(rows.map((r) => [r.slug, r.title])); - for (const i of items) if (i.post_slug && !i.post_title) i.post_title = byslug.get(i.post_slug) || null; - } - } catch { /* zonder titel valt de draad terug op de slug */ } - items.sort((a, b) => _msgTs(b) - _msgTs(a)); // NaN-safe (zie getNotifications) - const out = []; - for (const it of items) { - const prev = out[out.length - 1]; - if ((it.type === 'like' || it.type === 'announce') && prev && prev.type === it.type - && prev.post_slug === it.post_slug) { - prev.actors = prev.actors || [prev.name || prev.handle || '?']; - prev.actors.push(it.name || it.handle || '?'); - prev.count = (prev.count || 1) + 1; - continue; - } - out.push(it); - } - // Antwoorden, mentions en je eigen verzonden berichten vouwen samen tot - // draden; likes/boosts/follows/reports blijven losse regels. Na deze stap - // telt een draad als één item voor de paginering, wat klopt: je scrolt door - // gesprekken, niet door losse zinnen. - return groupConversations(out).slice(off, off + lim); -} - -// De drie soorten die samen een gesprek vormen. Vroeger zaten ze in drie -// aparte chips: 'reply' en 'mention' onder Berichten/Gesprekken (afhankelijk van -// de zichtbaarheid) en 'sent' onder Verzonden. Wie een uitwisseling wilde volgen -// moest dus tussen chips heen en weer, terwijl het één draad is. -const CONV_TYPES = new Set(['reply', 'mention', 'sent']); - -/** Waar hangt dit bericht aan? Twee soorten draden, en de volgorde telt: - * - * 1. Aan een post van jou. Een ontvangen antwoord kent zijn post via de join - * op `posts`, een verzonden antwoord via ap_outbox.post_slug. Dat is - * dezelfde sleutel, en daarom staan ze nu in dezelfde draad. - * 2. Aan een persoon. Een mention hangt aan niets van jou (het is iemands - * eigen post waarin je genoemd wordt) en heeft geen post_slug; die draad - * loopt per tegenpartij. - * - * De post wint van de persoon: twee mensen die onder dezelfde post reageren - * voeren één gesprek, geen twee. Geeft null terug voor alles wat geen gesprek - * is (likes, boosts, follows, reports, poll-uitslagen); die stromen ongemoeid - * door. - */ -export function threadKey(it) { - if (!it || !CONV_TYPES.has(it.type)) return null; - if (it.post_slug) return `post:${it.post_slug}`; - let who = it.handle || it.to_handle || ''; - // Een direct bericht kan zonder to_handle in de tabel staan (de handle van de - // ontvanger was niet af te leiden). De eerste uit to_actors is dan alsnog de - // tegenpartij, en zonder deze terugval kreeg een gesprek dat JIJ begon geen - // draad -- precies het geval waarin het meest onlogisch is dat het los blijft. - if (!who && it.to_actors) { - try { - const first = JSON.parse(it.to_actors)[0]; - if (first) who = deriveHandle(first); - } catch { /* geen bruikbare lijst → geen sleutel, het blijft een losse regel */ } - } - const norm = String(who || '').trim().toLowerCase().replace(/^@/, ''); - return norm ? `actor:${norm}` : null; -} - -/** Vouw losse berichten samen tot draden, met alles wat geen gesprek is - * ongemoeid ertussen. Verwacht [items] al gesorteerd op created_at aflopend - * (zoals getMessages ze aanlevert); de draad komt daardoor op de plek van zijn - * nieuwste bericht te staan en `created_at` van de draad IS dat bericht. Binnen - * de draad draait het om: een gesprek leest naar beneden, oud naar nieuw. - */ -export function groupConversations(items) { - const threads = new Map(); - const out = []; - for (const it of items || []) { - const key = threadKey(it); - if (!key) { out.push(it); continue; } - let t = threads.get(key); - if (!t) { - // Eerste keer dat we deze draad zien = het nieuwste bericht erin, want de - // invoer is aflopend gesorteerd. Vandaar created_at hier en niet later. - t = { type: 'thread', key, post: null, people: [], messages: [], created_at: it.created_at }; - threads.set(key, t); - out.push(t); - } - t.messages.push(it); - // De context bij de draad: gaat het over een post, dan hoort de link - // erbij, anders is een los antwoord in een lijst niet te plaatsen. - // De titel blijft LEEG zolang hij onbekend is, in plaats van terug te - // vallen op de slug: het nieuwste bericht in een draad is vaak je eigen - // verzonden antwoord, en dat kent alleen de slug. Zou die de titel worden, - // dan kan het ontvangen antwoord eronder de echte titel niet meer - // invullen. De terugval op de slug hoort in de weergave, niet in de data. - if (it.post_slug) { - if (!t.post) t.post = { slug: it.post_slug, title: it.post_title || null }; - else if (!t.post.title && it.post_title) t.post.title = it.post_title; - } - } - for (const t of threads.values()) { - t.messages.sort((a, b) => _msgTs(a) - _msgTs(b)); - t.count = t.messages.length; - // Wie zit er in dit gesprek, jij niet meegerekend: 'sent' ben jij. - const seen = new Set(); - for (const m of t.messages) { - if (m.type === 'sent') continue; - const h = m.handle || m.name; - if (!h || seen.has(h)) continue; - seen.add(h); - t.people.push({ name: m.name, handle: m.handle, icon: m.icon, url: m.url }); - } - // Heb JIJ in deze draad iets gezegd? Bepaalt of hij als uitwisseling of als - // onbeantwoord bericht leest. - t.mine = t.messages.some((m) => m.type === 'sent'); - // Waar gaat een antwoord uit deze draad heen? Twee paden, en ze sluiten - // elkaar uit: hangt de draad aan een post, dan antwoord je op het NIEUWSTE - // ontvangen bericht erin (dat is de parent van de thread) -- anders is het - // een direct bericht aan de tegenpartij. - const inkomend = t.messages.filter((m) => m.type !== 'sent'); - const laatste = inkomend[inkomend.length - 1]; - t.replyTo = { - interactionId: (laatste && laatste.interactionId) || null, - postSlug: (t.post && t.post.slug) || null, - actorUri: (laatste && (laatste.actorUri || laatste.url)) - || (t.messages.find((m) => m.to_actor) || {}).to_actor - || (() => { try { return JSON.parse((t.messages.find((m) => m.to_actors) || {}).to_actors || '[]')[0] || null; } catch { return null; } })(), - }; - } - return out; -} - -export function buildCreate(base, site, post, opts = {}) { - const note = buildNote(base, site, post, opts); - return { - '@context': AP_CONTEXT, - id: note.id + '#create', - type: 'Create', - actor: actorId(base, site.slug), - published: note.published, - to: note.to, - cc: note.cc, - object: note, - }; -} - - -/** - * De outbox: wat deze actor heeft uitgebracht. Posts EN tracks (shaer-0nh, - * stap 4). - * - * WAAROM HIER EN NIET IN EEN BEZORGING. Een kanaal-lezer HAALT de outbox op -- - * zo heb ik zelf Funkwhales kanaal uitgelezen. Een Create(Audio) ook naar de - * inboxen van volgers duwen zou schade doen: Mastodon neemt Audio aan als - * statustype, dus bij een album-post zou dezelfde muziek twee keer in hun - * tijdlijn komen -- een keer als bijlage bij de Note, en dan nog N keer los. - * De post is het bericht, de outbox is de discografie. - * - * Door elkaar op datum, nieuwste eerst, zodat de outbox één verhaal vertelt in - * plaats van twee lijstjes achter elkaar. - * - * De tracks komen als ARGUMENT binnen, net als de posts, en worden hier - * uitdrukkelijk NIET zelf opgehaald. De route beslist wie wat mag zien -- een - * geblokkeerde bezoeker krijgt daar een lege outbox, en een bouwer die stiekem - * zijn eigen database bevraagt zou dwars door die deur heen leveren. - */ -/** - * Een PAGINA van de outbox, in SQL (shaer-sk4). - * - * De outbox mengt twee bronnen: posts en open tracks, gevlochten op datum. Een - * offset over die twee kan niet met twee losse queries -- je weet niet hoeveel - * van elk er in pagina drie horen. Vandaar een UNION met de datum als sleutel, - * daar de LIMIT/OFFSET overheen, en pas dan de rijen zelf ophalen. - * - * Wat er stond was geen paginering maar een KAP: de route haalde twintig posts - * en hield daarvan twintig items over. Alles daarvoor was niet op een volgende - * pagina maar helemaal onbereikbaar. - * - * @param {boolean} fanOnly mag de lezer ook de fans-only posts zien? - */ -export function outboxSlice(siteId, { fanOnly = false, offset = 0, limit = MAX_OUTBOX } = {}) { - const fanClause = fanOnly ? '' : 'AND (p.fan_only IS NULL OR p.fan_only = 0)'; - const unie = ` - SELECT 'post' AS soort, p.id AS id, ${isoSql('COALESCE(p.published_at, p.created_at)')} AS wanneer - FROM posts p WHERE p.site_id = ? AND p.status = 'published' ${fanClause} - UNION ALL - SELECT 'track', t.id, t.created_at - FROM audio_tracks t WHERE t.site_id = ? AND t.fedi_open = 1`; - let rijen = [], totaal = 0; - try { - totaal = db.prepare(`SELECT COUNT(*) n FROM (${unie})`).get(siteId, siteId).n; - rijen = db.prepare(`SELECT soort, id FROM (${unie}) ORDER BY wanneer DESC LIMIT ? OFFSET ?`) - .all(siteId, siteId, limit, Math.max(0, offset)); - } catch { return { posts: [], tracks: [], totaal: 0 }; } - - const postIds = rijen.filter((r) => r.soort === 'post').map((r) => r.id); - const trackIds = rijen.filter((r) => r.soort === 'track').map((r) => r.id); - const gaten = (n) => Array.from({ length: n }, () => '?').join(','); - const posts = postIds.length ? db.prepare( - // fan_only en ap_visibility MOETEN mee. buildNote adresseert hierop, en - // zonder deze twee kolommen is post.fan_only altijd undefined: elke - // fan-only post ging dan de outbox uit met to: as:Public, terwijl hij - // alleen aan vrienden geserveerd wordt. Een volger kreeg dus een - // vrienden-post met een publiek etiket erop, en die mag hij dan publiek - // boosten. Gevonden tijdens de FEP-1580 end-to-end test (shaer-fuyo). - // EN paid + excerpt, om exact dezelfde reden (Barts melding, 15-8). Zonder - // `paid` is post.paid hier `undefined`, dan slaat buildNote zijn redactie - // over en gaat de VOLLEDIGE tekst van een betaalde post de outbox uit. Zo - // kwam een post via een hub-actor gewoon te lezen. `excerpt` moet mee omdat - // de teaser daaruit komt; zonder dat veld valt hij terug op de eerste - // alinea van precies de tekst die verborgen hoort te blijven. - // - // Dit is een KOLOMMENLIJST, en die faalt stil: een vergeten kolom is - // `undefined` en niet een fout. Wie hier een veld toevoegt waar buildNote - // op beslist, moet het HIER ook toevoegen. - `SELECT id, slug, title, excerpt, content, cover_image_url, cover_video_url, nsfw, content_warning, - c2s_attachments, quote_json, embed_json, published_at, created_at, - fan_only, ap_visibility, paid, paid_min_cents - FROM posts WHERE id IN (${gaten(postIds.length)})`).all(...postIds) : []; - const tracks = trackIds.length ? db.prepare( - `SELECT ${TRACK_KOLOMMEN} - FROM audio_tracks t JOIN media m ON m.id = t.media_id - WHERE t.id IN (${gaten(trackIds.length)})`).all(...trackIds) : []; - return { posts, tracks, totaal }; -} - -export function buildOutbox(base, site, posts, tracks = [], { page = false, totalItems, alGesneden = false, rauweInhoud = false } = {}) { - const id = `${actorId(base, site.slug)}/outbox`; - const wanneer = (x) => Date.parse(x && x.published ? x.published : 0) || 0; - const items = [ - ...(posts || []).map((p) => buildCreate(base, site, p, { rauweInhoud })), - // Eén zoekopdracht voor alle tracks samen, niet per stuk. - ...(() => { - const posts = (tracks || []).length && site.id ? trackHostPosts(site.id) : null; - return (tracks || []).map((r) => buildTrackCreate(base, site, r, { hostPosts: posts })); - })(), - ] - .sort((a, b) => wanneer(b) - wanneer(a)) - .slice(0, alGesneden ? Infinity : MAX_OUTBOX); - // WAT HIER NOG NIET GEPAGINEERD IS, en dat hoort genoemd (shaer-sk4): deze - // lijst is al door de route op twintig rijen afgekapt, dus pagina 2 is leeg. - // Echt doorbladeren vraagt een LIMIT/OFFSET in SQL -- en dat is hier lastiger - // dan bij volgers, want posts en tracks worden op DATUM door elkaar gevlochten - // en komen uit twee tabellen. Dat vraagt een UNION met een offset erover, geen - // tweede slice. De vorm klopt nu wel: pagina 2 zegt eerlijk dat hij leeg is en - // biedt geen `next` aan, in plaats van pagina 1 nog eens te geven. - // GEPAGINEERD, ook al past alles op een pagina (Funkwhale, 11-8). - // - // Hun serializer weigerde onze outbox met "first: This field is required" en - // "last: This field is required". AS2 EIST ze niet -- een collectie mag zijn - // items inline dragen -- maar bijna iedereen pagineert, en een lezer die de - // paginaweg volgt liep hier dood. Dit is de eerste concrete reden die we - // hoorden waarom er niets van ons binnenkwam. - // - // De items blijven WEL inline op de wortel. Shaer bouwt zijn feed daaruit, en - // wie hem vandaag leest hoort er morgen niet voor te hoeven pagineren. Er is - // precies een pagina, dus first en last wijzen naar dezelfde. - return pagedCollection(id, items, { page, totalItems, alGesneden }); -} - -// Public callers get a count-only collection (privacy). The authenticated -// account owner (a C2S bearer scoped to this site) gets the real actor URIs via -// `items`, so their own client can build a friends list. -export function buildFollowers(base, site, count, items = null, { page = false } = {}) { - const id = `${actorId(base, site.slug)}/followers`; - // count-only for the public; full for the owner - return pagedCollection(id, items || [], { totalItems: items ? items.length : (count || 0), page }); -} - -// The accounts this site follows — count only, mirroring buildFollowers. The spec lists -// `following` as a standard actor property; Hubzilla/Friendica + crawlers expect it. -export function buildFollowing(base, site, count, items = null, { page = false } = {}) { - const id = `${actorId(base, site.slug)}/following`; - // count-only for the public; full for the owner - return pagedCollection(id, items || [], { totalItems: items ? items.length : (count || 0), page }); -} - -// Pinned posts → the actor's `featured` collection. Mastodon reads this and shows -// these as the "Featured" tab (pinned to the profile). Posts come ordered by pin -// rank; embedded as full Notes so a remote server doesn't need extra fetches. -export function buildFeatured(base, site, posts, { page = false } = {}) { - const id = `${actorId(base, site.slug)}/featured`; - const items = (posts || []).map((p) => buildNote(base, site, p)); - return pagedCollection(id, items, { page }); -} - -// ── Playlist als AP-collectie (shaer-ayc, stap 1 van het Funkwhale-spoor) ── -// Een playlist heeft, anders dan een album-als-tekstveld, een id — dus kan hij -// een stabiele URI dragen en federeren. De vorm is bewust kaal AS2: een -// OrderedCollection van Audio-objecten, dezelfde rijvorm die een post als -// attachment meestuurt, zodat elke client die post-audio al speelt dit ook -// speelt. -// -// De poortregel verandert hier NIET: alleen fedi_open-tracks staan erin, met -// echte bestands-URL. Een gated track is niet "een rij zonder url" maar -// afwezig — wie de collectie leest ziet het open deel en kan niet aftellen -// hoeveel er achter de poort staat. totalItems telt daarom ook alleen het -// open deel: een eerlijke telling over wat er werkelijk in de collectie staat, -// niet over wat wij thuis in de kast hebben. - -// ── followers store (lazy stmts) ────────────────────────────────── -let _insF, _updFDisp, _delF, _listF, _cntF; -function fStmts() { - if (!_insF) { - _insF = db.prepare('INSERT OR IGNORE INTO ap_followers (slug, actor_uri, inbox, shared_inbox, name, handle, icon, created_at) VALUES (?,?,?,?,?,?,?,CURRENT_TIMESTAMP)'); - _updFDisp = db.prepare('UPDATE ap_followers SET name = COALESCE(?, name), handle = COALESCE(?, handle), icon = COALESCE(?, icon) WHERE slug = ? AND actor_uri = ?'); - _delF = db.prepare('DELETE FROM ap_followers WHERE slug = ? AND actor_uri = ?'); - _listF = db.prepare('SELECT inbox, shared_inbox FROM ap_followers WHERE slug = ?'); - _cntF = db.prepare('SELECT COUNT(*) n FROM ap_followers WHERE slug = ?'); - } - return { ins: _insF, del: _delF, list: _listF, cnt: _cntF }; -} -export function followerCount(slug) { return fStmts().cnt.get(slug).n; } - -// Followers with delivery health, for the management list. Never-delivered accounts -// first, then oldest successful delivery first — i.e. the cleanup candidates on top. -export function listFollowers(slug) { - return db.prepare( - `SELECT id, actor_uri, inbox, shared_inbox, created_at, last_delivery_at, last_error_at - FROM ap_followers WHERE slug = ? - ORDER BY (last_delivery_at IS NULL) DESC, last_delivery_at ASC, created_at ASC` - ).all(slug); -} -// Manually drop a follower after a check (a still-live account would have to re-follow). -/** - * Een volger verwijderen, en het hem ook LATEN WETEN (Robin, 21-8). - * - * Reject(Follow) is het standaardsignaal voor "je volgt me niet meer": de - * andere kant ruimt de relatie dan op in plaats van te blijven denken dat hij - * volgt. Zonder dit merkte de hub niets -- die bleef als volger in zijn eigen - * boeken staan terwijl er nooit meer iets werd bezorgd. - * - * Verwijderen gaat altijd door; de melding is een gunst en mag mislukken. - */ -export function removeFollower(slug, id) { - const rij = db.prepare('SELECT actor_uri FROM ap_followers WHERE slug = ? AND id = ?').get(slug, id); - const info = db.prepare('DELETE FROM ap_followers WHERE slug = ? AND id = ?').run(slug, id); - if (info.changes > 0 && rij && rij.actor_uri) meldNietLangerVolger(slug, rij.actor_uri); - return info.changes > 0; -} - -/** Reject(Follow) naar een ex-volger; faalt stil, want de relatie is al weg. */ -export function meldNietLangerVolger(slug, actorUri) { - try { - const base = (process.env.PUBLIC_BASE_URL || '').replace(/\/+$/, ''); - const me = actorId(base, slug); - const site = db.prepare('SELECT * FROM sites WHERE slug = ?').get(slug); - if (!site) return; - const reject = { - '@context': AP_CONTEXT, - id: `${me}#reject-follow-${Date.now()}-${rid()}`, - type: 'Reject', - actor: me, - to: [actorUri], - object: { type: 'Follow', actor: actorUri, object: me }, - }; - deliverToActor(site, actorUri, reject) - .then((r) => console.log('[AP] Reject(Follow)', slug, '→', actorUri, r && r.delivered ? 'bezorgd' : 'niet bezorgd')) - .catch(() => {}); - } catch { /* nooit blokkerend */ } -} - -// Best cached display for an actor URI, across the caches Klonkt already fills: -// followers (now with name/icon), following, interactions, timeline, mentions. -// Falls back to a handle derived from the URI. Display info is not sensitive. -export function actorDisplay(slug, uri) { - const ok = (r) => r && (r.name || r.icon); - try { - let r = db.prepare('SELECT name, handle, icon FROM ap_followers WHERE slug = ? AND actor_uri = ?').get(slug, uri); - if (ok(r)) return { name: r.name, handle: r.handle || deriveHandle(uri), icon: r.icon }; - r = db.prepare('SELECT name, handle, icon FROM ap_following WHERE slug = ? AND actor_uri = ?').get(slug, uri); - if (ok(r)) return { name: r.name, handle: r.handle || deriveHandle(uri), icon: r.icon }; - r = db.prepare('SELECT actor_name AS name, actor_handle AS handle, actor_icon AS icon FROM ap_interactions WHERE actor_uri = ? AND (actor_name IS NOT NULL OR actor_icon IS NOT NULL) ORDER BY created_at DESC LIMIT 1').get(uri); - if (ok(r)) return { name: r.name, handle: r.handle || deriveHandle(uri), icon: r.icon }; - r = db.prepare('SELECT author_name AS name, author_handle AS handle, author_icon AS icon FROM ap_timeline WHERE author_uri = ? AND (author_name IS NOT NULL OR author_icon IS NOT NULL) LIMIT 1').get(uri); - if (ok(r)) return { name: r.name, handle: r.handle || deriveHandle(uri), icon: r.icon }; - r = db.prepare('SELECT actor_name AS name, actor_handle AS handle, actor_icon AS icon FROM ap_mentions WHERE actor_uri = ? AND (actor_name IS NOT NULL OR actor_icon IS NOT NULL) ORDER BY created_at DESC LIMIT 1').get(uri); - if (ok(r)) return { name: r.name, handle: r.handle || deriveHandle(uri), icon: r.icon }; - } catch { /* ignore */ } - return { name: null, handle: deriveHandle(uri), icon: null }; -} - -// FEP-9876: does this `Prefer` header ask for enriched (embedded) members? -// Pure and testable; the route sets the response headers around it. -export function prefersEnriched(preferHeader) { - return /(^|[,;\s])return=representation($|[,;\s])/i.test(String(preferHeader || '')); -} - -// AS2 actor reference with display, for the owner C2S followers/following view. -// preferredUsername = the local part of the handle; name = the set display name. -export function buildActorRef(slug, uri) { - const d = actorDisplay(slug, uri); - const user = d.handle && d.handle[0] === '@' ? d.handle.slice(1).split('@')[0] : null; - const out = { id: uri, type: 'Person' }; - if (d.name) out.name = d.name; - if (user) out.preferredUsername = user; - if (d.icon) out.icon = { type: 'Image', url: d.icon }; - return out; -} - -// The site's OWN display info in the same shape as `shaer:author` on timeline -// entries. The owner's app reads its own posts from the outbox, which carried -// no author info, so every card but your own had a byline (Robins melding, -// 30-7: geen header van self op eigen posts). -export function selfAuthor(base, site) { - const out = { - name: site.title || site.slug, - handle: `@${site.slug}@${String(base).replace(/^https?:\/\//, '')}`, - url: `${base}/${site.slug === site.primary_slug ? '' : 'user/' + encodeURIComponent(site.slug)}`, - }; - if (site.profile_photo) { - out.icon = /^https?:/.test(site.profile_photo) ? site.profile_photo : `${base}${site.profile_photo.startsWith('/') ? '' : '/'}${site.profile_photo}`; - } - return out; -} - -// Merge who-you-follow (ap_following, rich display) with who-follows-you (ap_followers, -// delivery health) into ONE connections list, keyed by actor_uri. Each entry gets a -// direction (following →, follower ←, mutual ↔) and, for accounts we deliver to, an -// `unreachable` flag (never delivered, or last attempt failed after the last success) so -// the view can split dead connections into their own section. Powers the Connect page. -export function listConnections(slug) { - const byUri = new Map(); - for (const f of listFollowing(slug)) { - byUri.set(f.actor_uri, { - actor_uri: f.actor_uri, name: f.name || null, handle: f.handle || null, - icon: f.icon || null, url: f.url || null, auto_boost: f.auto_boost ? 1 : 0, - status: f.status || null, following: true, follower: false, - last_delivery_at: null, last_error_at: null, follower_id: null, - }); - } - for (const fo of listFollowers(slug)) { - const e = byUri.get(fo.actor_uri); - if (e) { e.follower = true; e.last_delivery_at = fo.last_delivery_at; e.last_error_at = fo.last_error_at; e.follower_id = fo.id; } - else byUri.set(fo.actor_uri, { - actor_uri: fo.actor_uri, name: null, handle: null, icon: null, url: null, - auto_boost: 0, status: null, following: false, follower: true, - last_delivery_at: fo.last_delivery_at, last_error_at: fo.last_error_at, follower_id: fo.id, - }); - } - return [...byUri.values()].map((e) => { - e.direction = (e.following && e.follower) ? 'mutual' : (e.following ? 'following' : 'follower'); - e.unreachable = e.follower && (!e.last_delivery_at || (!!e.last_error_at && (!e.last_delivery_at || e.last_error_at > e.last_delivery_at))); - return e; - }); -} - -// ── inbound interactions store (replies / likes / boosts) + our outbound replies ── -let _insI, _delLA, _delReply, _listI, _getI, _insO, _listO, _getO; -// ── moderation tombstones (ap_rejected_objects) ─────────────────── -// A reply the owner removed stays removed: its object URI is tombstoned and -// checked at ingest AND by the thread-crawler (else thread-filling would -// re-fetch it). Owner moderation acts on the LOCAL copy, so it also works for -// private notes that authorize_interaction can't fetch (401/404). -let _insRj, _hasRj; -function rjStmts() { - if (!_insRj) { - _insRj = db.prepare('INSERT OR IGNORE INTO ap_rejected_objects (object_uri, post_id, reason) VALUES (?,?,?)'); - _hasRj = db.prepare('SELECT 1 FROM ap_rejected_objects WHERE object_uri = ?'); - } - return { ins: _insRj, has: _hasRj }; -} -export function isRejectedObject(uri) { - if (!uri) return false; - try { return !!rjStmts().has.get(String(uri)); } catch { return false; } -} -// Owner removes an incoming reply: tombstone + delete. Tenancy-scoped: the -// interaction's post must belong to the caller's site. -export function rejectInteraction(site, interactionId, reason) { - if (!site || !site.slug) return { error: 'forbidden' }; - const row = iStmts().getI.get(interactionId); - if (!row) return { error: 'not_found' }; - const owns = db.prepare('SELECT 1 FROM posts WHERE id = ? AND site_id = (SELECT id FROM sites WHERE slug = ?)') - .get(row.post_id, site.slug); - if (!owns) return { error: 'forbidden' }; - if (row.object_uri) { try { rjStmts().ins.run(row.object_uri, row.post_id, reason || 'removed by site owner'); } catch { /* non-fatal */ } } - db.prepare('DELETE FROM ap_interactions WHERE id = ?').run(interactionId); - console.log('[AP] interaction removed by owner', site.slug, row.object_uri || row.actor_uri); - return { ok: true, object_uri: row.object_uri || null, actor_uri: row.actor_uri || null }; -} -// Stored URIs of an interaction (tenancy-scoped) → feed sendReport for flagging -// from the local copy (works for private notes; no remote fetch needed to target). -export function interactionReportTarget(site, interactionId) { - if (!site || !site.slug) return null; - const row = iStmts().getI.get(interactionId); - if (!row) return null; - const owns = db.prepare('SELECT 1 FROM posts WHERE id = ? AND site_id = (SELECT id FROM sites WHERE slug = ?)') - .get(row.post_id, site.slug); - if (!owns) return null; - return { objectUri: row.object_uri || null, actorUri: row.actor_uri || null }; -} - -// AP addressing → visibility: 'public' | 'unlisted' | 'followers' | 'direct'. -// Mastodon-conventie: Public in `to` = public, Public in `cc` = unlisted, een -// followers-collectie zonder Public = followers-only, anders direct (DM). Public -// kan als volledige URI, 'as:Public' of 'Public' voorkomen (JSON-LD shorthands). -export function noteVisibility(o) { - const arr = (v) => (Array.isArray(v) ? v : (v ? [v] : [])); - const isPub = (u) => u === PUBLIC || u === 'as:Public' || u === 'Public'; - const to = arr(o && o.to).map(String); - const cc = arr(o && o.cc).map(String); - if (to.some(isPub)) return 'public'; - if (cc.some(isPub)) return 'unlisted'; - if ([...to, ...cc].some((u) => /\/followers\/?$/.test(u))) return 'followers'; - return 'direct'; -} - -/** - * Does this note belong in the home timeline (de Krant)? - * - * Only if it is a POST. A direct note is addressed to named people, so it is a - * message: a plain DM, a ward's 🛟 help request (FEP-633c 5.2.1) or a - * guardian's wave. Those are stored as mentions instead and surface in - * Berichten and the Guardian PWA. A reply belongs to its thread, not the feed. - */ -export function belongsInTimeline(o) { - if (!o || !o.id || o.inReplyTo) return false; - return noteVisibility(o) !== 'direct'; -} - -function iStmts() { - if (!_insI) { - _insI = db.prepare(`INSERT OR IGNORE INTO ap_interactions (kind, post_id, object_uri, actor_uri, actor_name, actor_handle, actor_url, actor_icon, content, published, parent_uri, visibility, emoji_json, actor_emoji_json, created_at) VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,${NU_ISO})`); - _delLA = db.prepare('DELETE FROM ap_interactions WHERE kind = ? AND post_id = ? AND actor_uri = ?'); - _delReply = db.prepare("DELETE FROM ap_interactions WHERE kind = 'reply' AND object_uri = ?"); - _listI = db.prepare('SELECT id, kind, object_uri, parent_uri, actor_uri, actor_name, actor_handle, actor_url, actor_icon, content, published, created_at, acted_boost, acted_like, visibility, emoji_json, actor_emoji_json FROM ap_interactions WHERE post_id = ? ORDER BY created_at ASC'); - _getI = db.prepare('SELECT * FROM ap_interactions WHERE id = ?'); - _insO = db.prepare(`INSERT INTO ap_outbox (id, site_slug, post_id, post_slug, in_reply_to, to_actor, to_handle, content, language, attachments, created_at) VALUES (?,?,?,?,?,?,?,?,?,?,${NU_ISO})`); - _listO = db.prepare('SELECT * FROM ap_outbox WHERE post_id = ? ORDER BY created_at ASC'); - _getO = db.prepare('SELECT * FROM ap_outbox WHERE id = ?'); - } - return { ins: _insI, delLA: _delLA, delReply: _delReply, list: _listI, getI: _getI, insO: _insO, listO: _listO, getO: _getO }; -} - -export function getInteractionById(id) { return iStmts().getI.get(id); } -export function setInteractionBoosted(id, on) { - db.prepare('UPDATE ap_interactions SET acted_boost = ? WHERE id = ?').run(on ? 1 : 0, id); -} -export function setInteractionLiked(id, on) { - db.prepare('UPDATE ap_interactions SET acted_like = ? WHERE id = ?').run(on ? 1 : 0, id); -} - -const localPostExists = (id) => { try { return !!db.prepare('SELECT 1 FROM posts WHERE id = ?').get(id); } catch { return false; } }; -// Extract our local post id from a note URL, but only if it's ours (base match). -// One host, two spellings (Barts WebFinger-les, 2-8): a URL the client hands -// back may carry the punycoded host (every URL parser silently punycodes) -// while PUBLIC_BASE_URL carries the typed one. WHATWG URL does the IDNA, so -// compare origins in ASCII and never the bytes the client happened to send. -function asciiOrigin(u) { - try { const x = new URL(String(u)); return `${x.protocol}//${x.host}`.toLowerCase(); } catch { return null; } -} -function isOwnUrl(u) { - const base = (process.env.PUBLIC_BASE_URL || '').replace(/\/+$/, ''); - if (!base) return false; - const a = asciiOrigin(u); - return !!a && a === asciiOrigin(base); -} -function postIdFromNoteUrl(url, base) { - const s = String(url || ''); - // ASCII origins, not startsWith: xn--zz9h.example IS 🩵.example, and a - // byte comparison read our own note as a stranger's. - if (base) { const a = asciiOrigin(s); if (!a || a !== asciiOrigin(base)) return null; } - const m = s.match(/\/ap\/notes\/([^/?#]+)/); - return m ? decodeURIComponent(m[1]) : null; -} -export function deriveHandle(actorUri) { - try { const u = new URL(actorUri); const seg = u.pathname.split('/').filter(Boolean).pop() || ''; return `@${seg}@${u.host}`; } catch { return String(actorUri || ''); } -} -function actorInfo(doc, actorUri) { - let host = ''; try { host = new URL(actorUri).host; } catch { /* keep empty */ } - const handle = doc && doc.preferredUsername ? `@${doc.preferredUsername}@${host}` : deriveHandle(actorUri); - const icon = doc && doc.icon ? (doc.icon.url || (Array.isArray(doc.icon) && doc.icon[0] && doc.icon[0].url)) : null; - const name = (doc && (doc.name || doc.preferredUsername)) || handle; - // Een AS2 `url` mag een ARRAY van Links zijn -- onze eigen buildActor doet - // dat (profiel + RSS), en een oudere consument stringde die array tot - // "[object Object],[object Object]" in de mention-hrefs van een hulpvraag - // (Barts vondst, 8-8). pickLink kiest de html-Link; de kale string blijft - // de gewone weg, en de actor-id de terugval. - const profiel = (doc && Array.isArray(doc.url)) - ? ((pickLink(doc.url, (mt) => !mt || /html/i.test(mt)) || {}).href || safeUrl(doc.id || actorUri)) - : safeUrl((doc && (doc.url || doc.id)) || actorUri); - return { - name, - handle, - url: profiel || null, - icon: safeUrl(icon) || null, - // FEP-9098 custom emojis in the display name (":shortcode:"), so the byline - // renders them. Only computed when the name actually has a shortcode. - emojis: /:[A-Za-z0-9_+-]+:/.test(name) ? actorNameEmojis(doc) : undefined, - }; -} - -// Map ":shortcode:" → image url from an actor doc's Emoji tags (for a custom- -// emoji display name). Undefined when there are none. -function actorNameEmojis(doc) { - const arr = doc && Array.isArray(doc.tag) ? doc.tag : (doc && doc.tag ? [doc.tag] : []); - const out = {}; - for (const t of arr) { - if (!t || (Array.isArray(t.type) ? t.type[0] : t.type) !== 'Emoji' || typeof t.name !== 'string' || !t.icon) continue; - const u = t.icon.url || (Array.isArray(t.icon) && t.icon[0] && t.icon[0].url); - if (u) out[t.name] = u; - } - return Object.keys(out).length ? out : undefined; -} - -// Given an inReplyTo note URL, find which local post the thread belongs to + the -// note being replied to (parent), so a reply-to-a-comment can be nested. -function findThreadTarget(inReplyTo, base) { - if (!inReplyTo) return null; - const seg = postIdFromNoteUrl(inReplyTo, base); // our /ap/notes/ wrapper; handles mention links and plain-text @user@domain.
-export function stripLeadingMentions(html) {
- if (!html) return html;
- let s = String(html);
- s = s.replace(/^(\s* ')) {
- content = processed.replace(' ', ` ${mention}`); // inline in the first paragraph
- } else if (/^<(blockquote|ul|ol|pre|h[1-6]|div|hr)\b/i.test(processed)) {
- content = ` ${mention} ${mention}${processed} ${mention}${linkUrls(linkHashtags(base, mres.html))} ${note.name} ')) content = processed.replace(' ', ` ${mention}`);
- else if (/^<(blockquote|ul|ol|pre|h[1-6]|div|hr)\b/i.test(processed)) content = ` ${mention} ${mention}${processed} ${mention}${linkUrls(linkHashtags(base, mres.html))} You have been observed dormant as a guardian. Nothing is wrong and nothing is held against you: one answer restores everything (FEP-633c 3.6.2). ...`
- * -- omdat Mastodon `name` negeert. In de cache staat dus de gefedereerde vorm,
- * en zonder deze stap komt elke post titelloos terug met zijn titel als vetgedrukte
- * eerste regel in de body.
- *
- * Er is GEEN sluitend signaal. De slug is niet van de titel afgeleid (op echte
- * data: titel "Back to 1987!", slug "waiting-on-you"), dus we moeten op de vorm
- * afgaan: een openende alinea die niets anders bevat dan vetgedrukte platte
- * tekst. Een post die echt zo begint verliest die regel naar zijn titel. Vandaar
- * dat de beller een lijst terugkrijgt van alles wat is losgetrokken -- dat hoort
- * een mens na te lopen, niet een script.
- */
-export function splitsTitel(html) {
- const m = String(html || '').match(/^\s* \s*([^<>]+)<\/strong>\s*<\/p>/i);
- if (!m) return { titel: null, rest: html || '' };
- const titel = m[1].replace(/</g, '<').replace(/>/g, '>').replace(/&/g, '&').trim();
- if (!titel) return { titel: null, rest: html || '' };
- return { titel, rest: String(html).slice(m[0].length) };
-}
-
-/**
- * Van een URL naar een bestand op de geredde schijf.
- *
- * Twee routes, en de tweede was bijna vergeten: gewone media gaan via /media/ op
- * MEDIA_ROOT, maar GEHOSTE AUDIO gaat via /audio/stream/
');
- mres = await resolveMentionsInText(base, body); // link inline @mentions + collect their inboxes
- content = `
→ newline)
-// so the manage view can prefill an edit box; the mention is re-added on save.
-function outboxEditableText(content) {
- return String(content || '')
- .replace(/
'));
- content = `