${post.title}

${post.content}

`,\n published: formatActivityPubDate(new Date(post.published_at)),\n to: [\"https://www.w3.org/ns/activitystreams#Public\"],\n cc: [`${baseUrl}/followers`],\n url: postUrl,\n name: post.title,\n summary: truncateHTML(post.content, 150),\n };\n\n // Create Create activity\n const activity = {\n \"@context\": [\n \"https://www.w3.org/ns/activitystreams\",\n \"https://w3id.org/security/v1\",\n ],\n type: \"Create\",\n id: `${postUrl}#create`,\n actor: actorId,\n object: note,\n published: note.published,\n to: note.to,\n cc: note.cc,\n };\n\n console.log(\"✅ ActivityPub activity created:\", {\n activity,\n });\n\n // Get followers to send the activity to\n console.log(\"👥 Fetching followers...\");\n const followers = await getActiveFollowers();\n console.log(\"📊 Followers found:\", {\n totalFollowers: followers.length,\n followersWithInbox: followers.filter(f => f.actor_inbox).length,\n followersWithSharedInbox: followers.filter(f => f.actor_shared_inbox).length,\n });\n\n if (followers.length === 0) {\n console.log(\"⚠️ No followers found - activity created but not delivered\");\n return;\n }\n\n // Group followers by inbox to avoid duplicate deliveries\n const inboxMap = new Map();\n\n for (const follower of followers) {\n // Prefer shared inbox over individual inbox for efficiency\n const inbox = follower.actor_shared_inbox || follower.actor_inbox;\n if (!inbox) {\n console.warn(\"⚠️ Follower has no inbox:\", {\n actorId: follower.actor_id,\n username: follower.actor_username,\n domain: follower.actor_domain,\n });\n continue;\n }\n\n if (!inboxMap.has(inbox)) {\n inboxMap.set(inbox, []);\n }\n inboxMap.get(inbox)!.push(follower);\n }\n\n console.log(\"📮 Delivery plan:\", {\n uniqueInboxes: inboxMap.size,\n totalDeliveries: followers.length,\n });\n\n // Send activity to each unique inbox\n const deliveryPromises: Promise[] = [];\n let successCount = 0;\n let failureCount = 0;\n\n for (const [inbox, inboxFollowers] of inboxMap.entries()) {\n const deliveryPromise = deliverActivityToInbox(activity, inbox, inboxFollowers, baseUrl)\n .then(() => {\n successCount++;\n console.log(\"✅ Delivery successful:\", {\n inbox: inbox,\n followerCount: inboxFollowers.length,\n followers: inboxFollowers.map(f => f.actor_username || f.actor_id).join(\", \"),\n });\n })\n .catch((error) => {\n failureCount++;\n console.error(\"❌ Delivery failed:\", {\n inbox: inbox,\n followerCount: inboxFollowers.length,\n error: error.message,\n followers: inboxFollowers.map(f => f.actor_username || f.actor_id).join(\", \"),\n });\n });\n\n deliveryPromises.push(deliveryPromise);\n }\n\n // Wait for all deliveries to complete (with timeout)\n console.log(\"⏳ Waiting for deliveries to complete...\");\n await Promise.allSettled(deliveryPromises);\n\n const processingTime = Date.now() - startTime;\n console.log(\"🎉 ACTIVITYPUB PUBLISH COMPLETED:\", {\n processingTimeMs: processingTime,\n totalInboxes: inboxMap.size,\n successfulDeliveries: successCount,\n failedDeliveries: failureCount,\n deliveryRate: `${Math.round((successCount / inboxMap.size) * 100)}%`,\n });\n } catch (error) {\n const processingTime = Date.now() - startTime;\n console.error(\"💥 ACTIVITYPUB PUBLISH FAILED:\", {\n error: error.message,\n stack: error.stack,\n processingTimeMs: processingTime,\n postTitle: post.title,\n postSlug: post.slug,\n });\n throw error;\n } finally {\n console.log(\"🐘 === ACTIVITYPUB PUBLISH END ===\");\n }\n}\n\n/**\n * Deliver an activity to a specific inbox\n */\nasync function deliverActivityToInbox(\n activity: any,\n inboxUrl: string,\n followers: any[],\n actorBaseUrl: string,\n): Promise {\n try {\n console.log(\"📤 Delivering to inbox:\", {\n inbox: inboxUrl,\n activityType: activity.type,\n activityId: activity.id,\n followerCount: followers.length,\n actorBaseUrl: actorBaseUrl,\n });\n\n const body = JSON.stringify(activity);\n const headers = await createActivityPubHeaders(\"POST\", inboxUrl, body, actorBaseUrl);\n\n console.log(\"📋 Request headers prepared:\", {\n inbox: inboxUrl,\n hasSignature: !!headers[\"Signature\"],\n hasDigest: !!headers[\"Digest\"],\n contentType: headers[\"Content-Type\"],\n });\n\n const response = await fetch(inboxUrl, {\n method: \"POST\",\n headers: headers,\n body: body,\n });\n\n if (!response.ok) {\n const errorText = await response.text().catch(() => \"Unknown error\");\n throw new Error(`HTTP ${response.status}: ${errorText}`);\n }\n\n console.log(\"✅ Inbox delivery successful:\", {\n inbox: inboxUrl,\n status: response.status,\n statusText: response.statusText,\n });\n } catch (error) {\n console.error(\"❌ Inbox delivery failed:\", {\n inbox: inboxUrl,\n error: error.message,\n followers: followers.map(f => f.actor_username || f.actor_id),\n });\n throw error;\n }\n}\n\n/**\n * Generate ActivityPub actor document\n */\nexport async function generateActorDocument(domain?: string): Promise {\n console.log(\"🎭 Generating ActivityPub actor document:\", { providedDomain: domain });\n\n // Use the provided domain, or get base URL from environment\n let baseUrl: string;\n if (domain) {\n baseUrl = `https://${domain}`;\n } else {\n baseUrl = getBaseUrl();\n }\n\n console.log(\"🌐 Base URL determined:\", { baseUrl, domain });\n\n // Get the real public key\n console.log(\"🔑 Fetching public key...\");\n const publicKeyPem = await getPublicKeyPem();\n console.log(\"✅ Public key retrieved:\", {\n keyLength: publicKeyPem.length,\n keyPreview: publicKeyPem.substring(0, 50) + \"...\",\n });\n\n const actor = {\n \"@context\": [\n \"https://www.w3.org/ns/activitystreams\",\n \"https://w3id.org/security/v1\",\n ],\n type: \"Person\",\n id: `${baseUrl}/actor`,\n preferredUsername: \"blog\",\n name: \"Email Blog\",\n summary: \"A blog powered by email publishing. Follow for updates on new posts!\",\n inbox: `${baseUrl}/inbox`,\n outbox: `${baseUrl}/outbox`,\n followers: `${baseUrl}/followers`,\n following: `${baseUrl}/following`,\n // Add avatar/icon for better visual representation\n icon: {\n type: \"Image\",\n mediaType: \"image/png\",\n url: `https://posthero.us/images/1752442753496-q8omo6-logo-small.png`,\n },\n // Add header image\n image: {\n type: \"Image\",\n mediaType: \"image/jpeg\",\n url: `https://posthero.us/images/1752443393121-bb51qa-logo-header.jpg`,\n },\n // Add some additional fields that Mastodon likes\n discoverable: true,\n indexable: true,\n memorial: false,\n // Add attachment/fields for profile metadata\n attachment: [\n {\n type: \"PropertyValue\",\n name: \"Blog Type\",\n value: \"Email-to-Publish\",\n },\n {\n type: \"PropertyValue\",\n name: \"Platform\",\n value: \"Val Town\",\n },\n {\n type: \"PropertyValue\",\n name: \"RSS Feed\",\n value: `RSS`,\n },\n ],\n publicKey: {\n id: `${baseUrl}/actor#main-key`,\n owner: `${baseUrl}/actor`,\n publicKeyPem: publicKeyPem,\n },\n };\n\n console.log(\"✅ Actor document generated:\", {\n id: actor.id,\n type: actor.type,\n preferredUsername: actor.preferredUsername,\n name: actor.name,\n inbox: actor.inbox,\n outbox: actor.outbox,\n followers: actor.followers,\n following: actor.following,\n publicKeyId: actor.publicKey.id,\n attachmentCount: actor.attachment.length,\n });\n\n return actor;\n}\n\n/**\n * Get the base URL for the application\n */\nfunction getBaseUrl(): string {\n // Prioritize BASE_URL environment variable for custom domains\n const baseUrl = Deno.env.get(\"BASE_URL\");\n if (baseUrl) {\n // Ensure the BASE_URL has a protocol\n if (baseUrl.startsWith(\"http://\") || baseUrl.startsWith(\"https://\")) {\n return baseUrl.replace(/\\/$/, \"\"); // Remove trailing slash if present\n } else {\n // Assume https if no protocol is specified\n return `https://${baseUrl}`;\n }\n }\n\n // Fall back to ACTIVITYPUB_DOMAIN if set\n const domain = Deno.env.get(\"ACTIVITYPUB_DOMAIN\");\n if (domain) {\n return `https://${domain}`;\n }\n\n // Default fallback\n return \"https://your-val-name.web.val.run\";\n}","deleted","label",[170,171,153],"backend","services","permalink","https://www.val.town/x/humble/postherous/code/backend/services/activitypub.ts","extension","actionData","errors"]