Merge pull request #171 from cloudflare/sven/serve-objects

serve Object

backend/test/activitypub.spec.ts

@@ -2,10 +2,11 @@ import { makeDB, isUrlValid } from './utils'
 import { MessageType } from 'wildebeest/backend/src/types/queue'
 import type { JWK } from 'wildebeest/backend/src/webpush/jwk'
 import { createPerson } from 'wildebeest/backend/src/activitypub/actors'
-import { createPrivateNote } from 'wildebeest/backend/src/activitypub/objects/note'
+import { createPrivateNote, createPublicNote } from 'wildebeest/backend/src/activitypub/objects/note'
 import { addObjectInOutbox } from 'wildebeest/backend/src/activitypub/actors/outbox'
 import { strict as assert } from 'node:assert/strict'
 import { cacheObject } from 'wildebeest/backend/src/activitypub/objects/'
+import * as ap_objects from 'wildebeest/functions/ap/o/[id]'
 import * as ap_users from 'wildebeest/functions/ap/users/[id]'
 import * as ap_outbox from 'wildebeest/functions/ap/users/[id]/outbox'
 import * as ap_inbox from 'wildebeest/functions/ap/users/[id]/inbox'
@@ -156,6 +157,24 @@ describe('ActivityPub', () => {
 			result = await db.prepare('SELECT count(*) as count from objects').first()
 			assert.equal(result.count, 1)
 		})
+
+		test('serve unknown object', async () => {
+			const db = await makeDB()
+			const res = await ap_objects.handleRequest(domain, db, 'unknown id')
+			assert.equal(res.status, 404)
+		})
+
+		test('serve object', async () => {
+			const db = await makeDB()
+			const actor = await createPerson(domain, db, userKEK, 'a@cloudflare.com')
+			const note = await createPublicNote(domain, db, 'content', actor)
+
+			const res = await ap_objects.handleRequest(domain, db, note.mastodonId!)
+			assert.equal(res.status, 200)
+
+			const data = await res.json<any>()
+			assert.equal(data.content, 'content')
+		})
 	})
 
 	describe('Inbox', () => {

functions/ap/o/[id].ts

@@ -0,0 +1,40 @@
+import { cors } from 'wildebeest/backend/src/utils/cors'
+import type { Env } from 'wildebeest/backend/src/types/env'
+import * as objects from 'wildebeest/backend/src/activitypub/objects'
+
+export const onRequest: PagesFunction<Env, any> = async ({ params, request, env }) => {
+	const domain = new URL(request.url).hostname
+	return handleRequest(domain, env.DATABASE, params.id as string)
+}
+
+const headers = {
+	...cors(),
+	'content-type': 'application/json; charset=utf-8',
+}
+
+export async function handleRequest(domain: string, db: D1Database, id: string): Promise<Response> {
+	const obj = await objects.getObjectById(db, objects.uri(domain, id))
+	if (obj === null) {
+		return new Response('', { status: 404 })
+	}
+
+	const res = {
+		// TODO: should this be part of the object?
+		'@context': [
+			'https://www.w3.org/ns/activitystreams',
+			{
+				ostatus: 'http://ostatus.org#',
+				atomUri: 'ostatus:atomUri',
+				inReplyToAtomUri: 'ostatus:inReplyToAtomUri',
+				conversation: 'ostatus:conversation',
+				sensitive: 'as:sensitive',
+				toot: 'http://joinmastodon.org/ns#',
+				votersCount: 'toot:votersCount',
+			},
+		],
+
+		...obj,
+	}
+
+	return new Response(JSON.stringify(res), { status: 200, headers })
+}