wip: setup announcement actor, add endpoint for actor

src/server/api/announcements.ts

@@ -0,0 +1,53 @@
+import { APActor } from 'activitypub-types'
+
+import type { APIConfig, FastifyTypebox } from '.'
+import Store from '../store'
+import type ActivityPubSystem from '../apsystem'
+
+type APActorNonStandard = APActor & {
+  publicKey: {
+    id: string
+    owner: string
+    publicKeyPem: string
+  }
+}
+
+export const announcementsRoutes = (cfg: APIConfig, store: Store, apsystem: ActivityPubSystem) => async (server: FastifyTypebox): Promise<void> => {
+  server.get<{
+    Reply: APActorNonStandard
+  }>('/announcements', {
+    schema: {
+      params: {},
+      // XXX: even with Type.Any(), the endpoint returns `{}` :/
+      // response: {
+      //   // TODO: typebox APActor
+      //   200: Type.Any()
+      // },
+      description: 'Announcements ActivityPub actor',
+      tags: ['ActivityPub']
+    }
+  }, async (request, reply) => {
+    // return await reply.send({ prueba: 'asdfasd' })
+    const actor = await store.announcements.getInfo()
+
+    return await reply.send({
+      '@context': [
+        // TODO: I copied this from Mastodon, is this correct?
+        'https://www.w3.org/ns/activitystreams',
+        'https://w3id.org/security/v1'
+      ],
+      // https://www.w3.org/TR/activitystreams-vocabulary/#actor-types
+      type: 'Service',
+      name: 'Announcements',
+      inbox: `${actor.actorUrl}/inbox`,
+      outbox: `${actor.actorUrl}/outbox`,
+      publicKey: {
+        // TODO: copied from Mastodon
+        id: `${actor.actorUrl}#main-key`,
+
+        owner: actor.actorUrl,
+        publicKeyPem: actor.keypair.publicKeyPem
+      }
+    })
+  })
+}

src/server/api/index.ts

@@ -27,6 +27,8 @@ import { blockAllowListRoutes } from './blockallowlist.js'
 import { adminRoutes } from './admins.js'
 import { followerRoutes } from './followers.js'
 import { hookRoutes } from './hooks.js'
+import { generateKeypair } from 'http-signed-fetch'
+import { announcementsRoutes } from './announcements.js'
 
 export const paths = envPaths('distributed-press')
 
@@ -94,6 +96,23 @@ async function apiBuilder (cfg: APIConfig): Promise<FastifyTypebox> {
     return 'ok\n'
   })
 
+  // Setup announcements actor
+  let keys
+  try {
+    const prev = await store.announcements.getInfo()
+    keys = { ...prev.keypair, publicKeyId: prev.publicKeyId }
+  } catch {
+    keys = generateKeypair()
+  }
+  await store.announcements.setInfo({
+    actorUrl: `${cfg.publicURL}/v1/announcements`,
+    publicKeyId: keys.publicKeyId,
+    keypair: {
+      privateKeyPem: keys.privateKeyPem,
+      publicKeyPem: keys.publicKeyPem
+    }
+  })
+
   await server.register(v1Routes(cfg, store, apsystem, hookSystem), { prefix: '/v1' })
 
   await server.ready()
@@ -123,6 +142,7 @@ const v1Routes = (cfg: APIConfig, store: Store, apsystem: ActivityPubSystem, hoo
     })
   }
 
+  await server.register(announcementsRoutes(cfg, store, apsystem))
   await server.register(creationRoutes(cfg, store, apsystem))
   await server.register(inboxRoutes(cfg, store, apsystem))
   await server.register(outboxRoutes(cfg, store, apsystem))

src/server/store/index.ts

@@ -10,6 +10,7 @@ export default class Store {
   db: AbstractLevel<any, string, any>
   actorCache: Map<string, ActorStore>
   actorsDb: AbstractLevel<any, string, any>
+  announcements: ActorStore
   blocklist: AccountListStore
   allowlist: AccountListStore
   admins: AccountListStore
@@ -19,6 +20,8 @@ export default class Store {
     this.db = db
     this.actorCache = new Map()
     this.actorsDb = this.db.sublevel('actorCache', { valueEncoding: 'json' })
+    const announcementsDb = this.db.sublevel('announcements', { valueEncoding: 'json' })
+    this.announcements = new ActorStore(announcementsDb)
     const blocklistDb = this.db.sublevel('blocklist', {
       valueEncoding: 'json'
     })