import { Accept, Application, createFederation, Endpoints, exportJwk, Follow, generateCryptoKeyPair, Image, importJwk, LanguageString, MemoryKvStore, Note, PropertyValue, PUBLIC_COLLECTION, } from "jsr:@fedify/fedify@1.2.2"; import { configure, getConsoleSink } from "jsr:@logtape/logtape@0.7.1"; import { AsyncLocalStorage } from "node:async_hooks"; import { sqlite } from "https://esm.town/v/std/sqlite"; await configure({ contextLocalStorage: new AsyncLocalStorage(), sinks: { console: getConsoleSink(), }, loggers: [ { category: ["logtape", "meta"], sinks: [], level: "warning" }, { category: ["fedify"], sinks: ["console"], level: "info" }, ], }); await sqlite.execute(` CREATE TABLE IF NOT EXISTS key_pairs ( identifier TEXT NOT NULL PRIMARY KEY, private_key TEXT NOT NULL, public_key TEXT NOT NULL, created DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP ); `); const federation = createFederation({ kv: new MemoryKvStore(), }); federation .setActorDispatcher("/users/{identifier}", async (ctx, identifier) => { if (identifier !== "demo") return null; const keyPairs = await ctx.getActorKeyPairs(identifier); return new Application({ id: ctx.getActorUri(identifier), name: "Fedify on Val Town", summary: "This is a demo of Fedify on Val Town", preferredUsername: identifier, publicKeys: keyPairs.map(pair => pair.cryptographicKey), assertionMethods: keyPairs.map(pair => pair.multikey), url: new URL("/", ctx.url), icon: new Image({ mediaType: "image/png", url: new URL("https://fedify.dev/logo.png"), }), attachments: [ new PropertyValue({ name: "Val (code)", value: "https://www.val.town/v/minhee/FedifyOnValTown", }), ], inbox: ctx.getInboxUri(identifier), endpoints: new Endpoints({ sharedInbox: ctx.getInboxUri(), }), featured: ctx.getFeaturedUri(identifier), }); }) .setKeyPairsDispatcher(async (ctx, identifier) => { const keyPairs = await sqlite.execute({ sql: "SELECT * FROM key_pairs WHERE identifier = :identifier", args: { identifier }, }); if (keyPairs.rows.length > 0) { const [_, privateKey, publicKey] = keyPairs.rows[0]; return [ { privateKey: await importJwk(JSON.parse(privateKey), "private"), publicKey: await importJwk(JSON.parse(publicKey), "public"), }, ]; } const { privateKey, publicKey } = await generateCryptoKeyPair("RSASSA-PKCS1-v1_5"); await sqlite.execute({ sql: ` INSERT INTO key_pairs (identifier, private_key, public_key) VALUES (:identifier, :privateKey, :publicKey) `, args: { identifier, privateKey: JSON.stringify(await exportJwk(privateKey)), publicKey: JSON.stringify(await exportJwk(publicKey)), }, }); return [{ privateKey, publicKey }]; }); federation.setFeaturedDispatcher("/users/{identifier}/featured", async (ctx, identifier) => { return { items: [ await ctx.getObject(Note, { identifier }), ], } }); federation.setObjectDispatcher(Note, "/users/{identifier}/note", (ctx, values) => { if (values.identifier !== "demo") return null; const content = `

Hi there!

This account is a demo of Fedify on Val Town.

If you follow this account, it will follow you back.

Thanks to Fedify & Val Town, it only consists of a single TypeScript file (about 170 lines).

Interested? See the source code.

`.trim(); return new Note({ id: ctx.getObjectUri(Note, values), attribution: ctx.getActorUri(values.identifier), to: PUBLIC_COLLECTION, contents: [content, new LanguageString(content, "en")], sensitive: false, published: Temporal.Instant.from("2024-10-03T01:00:00+09:00"), }); }); federation .setInboxListeners("/users/{identifier}/inbox", "/inbox") .on(Follow, async (ctx, follow) => { const following = ctx.parseUri(follow.objectId); if (following?.type !== "actor" || following.identifier !== "demo") return; const follower = await follow.getActor(); if (follower == null) return; await ctx.sendActivity( following, follower, new Accept({ id: new URL(`#accept/${follower.id.href}`, follow.objectId), actor: follow.objectId, to: follower.id, object: follow, }) ); await ctx.sendActivity( following, follower, new Follow({ id: new URL(`#follow/${follower.id.href}`, follow.objectId), actor: follow.objectId, to: follower.id, object: follower.id, }), ); }); export default async function (req: Request): Promise { const url = new URL(req.url); if (url.pathname === "/") { return new Response( `Follow @demo@${url.host} on your Mastodon/Akkoma/Misskey/etc.`, { headers: { "Content-Type": "text/plain; charset=utf-8" } } ); } return federation.fetch(req, { contextData: undefined }); }