Something went wrong. Try again.
a tool for shared writing and social publishing
Something went wrong. Try again.
TypeScript
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458"use server";
import * as Y from "yjs";import * as base64 from "base64-js";import { createOauthClient } from "src/atproto-oauth";import { getIdentityData } from "actions/getIdentityData";import { AtpBaseClient, PubLeafletBlocksHeader, PubLeafletBlocksImage, PubLeafletBlocksText, PubLeafletBlocksUnorderedList, PubLeafletDocument, PubLeafletPagesLinearDocument, PubLeafletRichtextFacet, PubLeafletBlocksWebsite, PubLeafletBlocksCode, PubLeafletBlocksMath, PubLeafletBlocksHorizontalRule, PubLeafletBlocksBskyPost, PubLeafletBlocksBlockquote, PubLeafletBlocksIframe,} from "lexicons/api";import { Block } from "components/Blocks/Block";import { TID } from "@atproto/common";import { supabaseServerClient } from "supabase/serverClient";import { scanIndexLocal } from "src/replicache/utils";import type { Fact } from "src/replicache";import type { Attribute } from "src/replicache/attributes";import { Delta, YJSFragmentToString,} from "components/Blocks/TextBlock/RenderYJSFragment";import { ids } from "lexicons/api/lexicons";import { BlobRef } from "@atproto/lexicon";import { AtUri } from "@atproto/syntax";import { Json } from "supabase/database.types";import { $Typed, UnicodeString } from "@atproto/api";import { List, parseBlocksToList } from "src/utils/parseBlocksToList";import { getBlocksWithTypeLocal } from "src/hooks/queries/useBlocks";
export async function publishToPublication({ root_entity, publication_uri, leaflet_id, title, description,}: { root_entity: string; publication_uri: string; leaflet_id: string; title?: string; description?: string;}) { const oauthClient = await createOauthClient(); let identity = await getIdentityData(); if (!identity || !identity.atp_did) throw new Error("No Identity");
let credentialSession = await oauthClient.restore(identity.atp_did); let agent = new AtpBaseClient( credentialSession.fetchHandler.bind(credentialSession), ); let { data: draft } = await supabaseServerClient .from("leaflets_in_publications") .select("*, publications(*), documents(*)") .eq("publication", publication_uri) .eq("leaflet", leaflet_id) .single(); if (!draft || identity.atp_did !== draft?.publications?.identity_did) throw new Error("No draft or not publisher"); let { data } = await supabaseServerClient.rpc("get_facts", { root: root_entity, }); let facts = (data as unknown as Fact<Attribute>[]) || []; let scan = scanIndexLocal(facts); let firstEntity = scan.eav(root_entity, "root/page")?.[0]; if (!firstEntity) throw new Error("No root page"); let blocks = getBlocksWithTypeLocal(facts, firstEntity?.data.value);
let images = blocks .filter((b) => b.type === "image") .map((b) => scan.eav(b.value, "block/image")[0]); let links = blocks .filter((b) => b.type == "link") .map((b) => scan.eav(b.value, "link/preview")[0]); let imageMap = new Map<string, BlobRef>(); for (const b of [...links, ...images]) { if (!b) continue; let data = await fetch(b.data.src); if (data.status !== 200) continue; let binary = await data.blob(); try { let blob = await agent.com.atproto.repo.uploadBlob(binary, { headers: { "Content-Type": binary.type }, }); if (!blob.success) { console.log(blob); console.log("Error uploading image: " + b.data.src); throw new Error("Failed to upload image"); } imageMap.set(b.data.src, blob.data.blob); } catch (e) { console.error(e); console.log("Error uploading image: " + b.data.src); throw new Error("Failed to upload image"); } }
let b: PubLeafletPagesLinearDocument.Block[] = blocksToRecord( blocks, imageMap, scan, root_entity, );
let existingRecord = (draft?.documents?.data as PubLeafletDocument.Record | undefined) || {}; let record: PubLeafletDocument.Record = { $type: "pub.leaflet.document", author: credentialSession.did!, publication: publication_uri, publishedAt: new Date().toISOString(), ...existingRecord, title: title || "Untitled", description: description || "", pages: [ { $type: "pub.leaflet.pages.linearDocument", blocks: b, }, ], }; let rkey = draft?.doc ? new AtUri(draft.doc).rkey : TID.nextStr(); let { data: result } = await agent.com.atproto.repo.putRecord({ rkey, repo: credentialSession.did!, collection: record.$type, record, validate: false, //TODO publish the lexicon so we can validate! });
await supabaseServerClient.from("documents").upsert({ uri: result.uri, data: record as Json, }); await Promise.all([ //Optimistically put these in! supabaseServerClient.from("documents_in_publications").upsert({ publication: record.publication, document: result.uri, }), supabaseServerClient .from("leaflets_in_publications") .update({ doc: result.uri, }) .eq("leaflet", leaflet_id) .eq("publication", publication_uri), ]);
return { rkey, record: JSON.parse(JSON.stringify(record)) };}
function blocksToRecord( blocks: Block[], imageMap: Map<string, BlobRef>, scan: ReturnType<typeof scanIndexLocal>, root_entity: string,): PubLeafletPagesLinearDocument.Block[] { let parsedBlocks = parseBlocksToList(blocks); return parsedBlocks.flatMap((blockOrList) => { if (blockOrList.type === "block") { let alignmentValue = scan.eav(blockOrList.block.value, "block/text-alignment")[0]?.data .value || "left"; let alignment = alignmentValue === "center" ? "lex:pub.leaflet.pages.linearDocument#textAlignCenter" : alignmentValue === "right" ? "lex:pub.leaflet.pages.linearDocument#textAlignRight" : undefined; let b = blockToRecord(blockOrList.block, imageMap, scan, root_entity); if (!b) return []; let block: PubLeafletPagesLinearDocument.Block = { $type: "pub.leaflet.pages.linearDocument#block", alignment, block: b, }; return [block]; } else { let block: PubLeafletPagesLinearDocument.Block = { $type: "pub.leaflet.pages.linearDocument#block", block: { $type: "pub.leaflet.blocks.unorderedList", children: childrenToRecord( blockOrList.children, imageMap, scan, root_entity, ), }, }; return [block]; } });}
function childrenToRecord( children: List[], imageMap: Map<string, BlobRef>, scan: ReturnType<typeof scanIndexLocal>, root_entity: string,) { return children.flatMap((child) => { let content = blockToRecord(child.block, imageMap, scan, root_entity); if (!content) return []; let record: PubLeafletBlocksUnorderedList.ListItem = { $type: "pub.leaflet.blocks.unorderedList#listItem", content, children: childrenToRecord(child.children, imageMap, scan, root_entity), }; return record; });}function blockToRecord( b: Block, imageMap: Map<string, BlobRef>, scan: ReturnType<typeof scanIndexLocal>, root_entity: string,) { const getBlockContent = (b: string) => { let [content] = scan.eav(b, "block/text"); if (!content) return ["", [] as PubLeafletRichtextFacet.Main[]] as const; let doc = new Y.Doc(); const update = base64.toByteArray(content.data.value); Y.applyUpdate(doc, update); let nodes = doc.getXmlElement("prosemirror").toArray(); let stringValue = YJSFragmentToString(nodes[0]); let facets = YJSFragmentToFacets(nodes[0]); return [stringValue, facets] as const; };
if (b.type === "bluesky-post") { let [post] = scan.eav(b.value, "block/bluesky-post"); if (!post || !post.data.value.post) return; let block: $Typed<PubLeafletBlocksBskyPost.Main> = { $type: ids.PubLeafletBlocksBskyPost, postRef: { uri: post.data.value.post.uri, cid: post.data.value.post.cid, }, }; return block; } if (b.type === "horizontal-rule") { let block: $Typed<PubLeafletBlocksHorizontalRule.Main> = { $type: ids.PubLeafletBlocksHorizontalRule, }; return block; }
if (b.type === "heading") { let [headingLevel] = scan.eav(b.value, "block/heading-level");
let [stringValue, facets] = getBlockContent(b.value); let block: $Typed<PubLeafletBlocksHeader.Main> = { $type: "pub.leaflet.blocks.header", level: headingLevel?.data.value || 1, plaintext: stringValue, facets, }; return block; }
if (b.type === "blockquote") { let [stringValue, facets] = getBlockContent(b.value); let block: $Typed<PubLeafletBlocksBlockquote.Main> = { $type: ids.PubLeafletBlocksBlockquote, plaintext: stringValue, facets, }; return block; }
if (b.type == "text") { let [stringValue, facets] = getBlockContent(b.value); let block: $Typed<PubLeafletBlocksText.Main> = { $type: ids.PubLeafletBlocksText, plaintext: stringValue, facets, }; return block; } if (b.type === "embed") { let [url] = scan.eav(b.value, "embed/url"); let [height] = scan.eav(b.value, "embed/height"); if (!url) return; let block: $Typed<PubLeafletBlocksIframe.Main> = { $type: "pub.leaflet.blocks.iframe", url: url.data.value, height: Math.floor(height?.data.value || 600), }; return block; } if (b.type == "image") { let [image] = scan.eav(b.value, "block/image"); if (!image) return; let [altText] = scan.eav(b.value, "image/alt"); let blobref = imageMap.get(image.data.src); if (!blobref) return; let block: $Typed<PubLeafletBlocksImage.Main> = { $type: "pub.leaflet.blocks.image", image: blobref, aspectRatio: { height: image.data.height, width: image.data.width, }, alt: altText ? altText.data.value : undefined, }; return block; } if (b.type === "link") { let [previewImage] = scan.eav(b.value, "link/preview"); let [description] = scan.eav(b.value, "link/description"); let [src] = scan.eav(b.value, "link/url"); if (!src) return; let blobref = previewImage ? imageMap.get(previewImage?.data.src) : undefined; let [title] = scan.eav(b.value, "link/title"); let block: $Typed<PubLeafletBlocksWebsite.Main> = { $type: "pub.leaflet.blocks.website", previewImage: blobref, src: src.data.value, description: description?.data.value, title: title?.data.value, }; return block; } if (b.type === "code") { let [language] = scan.eav(b.value, "block/code-language"); let [code] = scan.eav(b.value, "block/code"); let [theme] = scan.eav(root_entity, "theme/code-theme"); let block: $Typed<PubLeafletBlocksCode.Main> = { $type: "pub.leaflet.blocks.code", language: language?.data.value, plaintext: code?.data.value || "", syntaxHighlightingTheme: theme?.data.value, }; return block; } if (b.type === "math") { let [math] = scan.eav(b.value, "block/math"); let block: $Typed<PubLeafletBlocksMath.Main> = { $type: "pub.leaflet.blocks.math", tex: math?.data.value || "", }; return block; } return;}
async function sendPostToEmailSubscribers( publication_uri: string, post: { content: string; title: string },) { let { data: publication } = await supabaseServerClient .from("publications") .select("*, subscribers_to_publications(*)") .eq("uri", publication_uri) .single();
let res = await fetch("https://api.postmarkapp.com/email/batch", { method: "POST", headers: { "Content-Type": "application/json", "X-Postmark-Server-Token": process.env.POSTMARK_API_KEY!, }, body: JSON.stringify( publication?.subscribers_to_publications.map((sub) => ({ Headers: [ { Name: "List-Unsubscribe-Post", Value: "List-Unsubscribe=One-Click", }, { Name: "List-Unsubscribe", Value: `<${"TODO"}/mail/unsubscribe?sub_id=${sub.identity}>`, }, ], MessageStream: "broadcast", From: `${publication.name} <mailbox@leaflet.pub>`, Subject: post.title, To: sub.identity, HtmlBody: ` <h1>${publication.name}</h1> <hr style="margin-top: 1em; margin-bottom: 1em;"> ${post.content} <hr style="margin-top: 1em; margin-bottom: 1em;"> This is a super alpha release! Ask Jared if you want to unsubscribe (sorry) `, TextBody: post.content, })), ), });}
function YJSFragmentToFacets( node: Y.XmlElement | Y.XmlText | Y.XmlHook,): PubLeafletRichtextFacet.Main[] { if (node.constructor === Y.XmlElement) { return node .toArray() .map((f) => YJSFragmentToFacets(f)) .flat(); } if (node.constructor === Y.XmlText) { let facets: PubLeafletRichtextFacet.Main[] = []; let delta = node.toDelta() as Delta[]; let byteStart = 0; for (let d of delta) { let unicodestring = new UnicodeString(d.insert); let facet: PubLeafletRichtextFacet.Main = { index: { byteStart, byteEnd: byteStart + unicodestring.length, }, features: [], };
if (d.attributes?.strikethrough) facet.features.push({ $type: "pub.leaflet.richtext.facet#strikethrough", });
if (d.attributes?.code) facet.features.push({ $type: "pub.leaflet.richtext.facet#code" }); if (d.attributes?.highlight) facet.features.push({ $type: "pub.leaflet.richtext.facet#highlight" }); if (d.attributes?.underline) facet.features.push({ $type: "pub.leaflet.richtext.facet#underline" }); if (d.attributes?.strong) facet.features.push({ $type: "pub.leaflet.richtext.facet#bold" }); if (d.attributes?.em) facet.features.push({ $type: "pub.leaflet.richtext.facet#italic" }); if (d.attributes?.link) facet.features.push({ $type: "pub.leaflet.richtext.facet#link", uri: d.attributes.link.href, }); if (facet.features.length > 0) facets.push(facet); byteStart += unicodestring.length; } return facets; } return [];}