diff --git a/src/app.ts b/src/app.ts index 38ca4dc9..80e260eb 100644 --- a/src/app.ts +++ b/src/app.ts @@ -62,6 +62,7 @@ import { favouriteController, favouritedByController, pinController, + quotesController, rebloggedByController, reblogStatusController, statusController, @@ -189,6 +190,8 @@ app.post('/api/v1/statuses/:id{[0-9a-f]{64}}/unreblog', requireSigner, unreblogS app.post('/api/v1/statuses', requireSigner, createStatusController); app.delete('/api/v1/statuses/:id{[0-9a-f]{64}}', requireSigner, deleteStatusController); +app.get('/api/v1/pleroma/statuses/:id{[0-9a-f]{64}}/quotes', quotesController); + app.post('/api/v1/media', mediaController); app.post('/api/v2/media', mediaController); diff --git a/src/controllers/api/statuses.ts b/src/controllers/api/statuses.ts index ad21381c..4666c341 100644 --- a/src/controllers/api/statuses.ts +++ b/src/controllers/api/statuses.ts @@ -14,7 +14,7 @@ import { renderEventAccounts } from '@/views.ts'; import { renderReblog, renderStatus } from '@/views/mastodon/statuses.ts'; import { Storages } from '@/storages.ts'; import { hydrateEvents, purifyEvent } from '@/storages/hydrate.ts'; -import { createEvent, paginationSchema, parseBody, updateListEvent } from '@/utils/api.ts'; +import { createEvent, paginated, paginationSchema, parseBody, updateListEvent } from '@/utils/api.ts'; import { getInvoice, getLnurl } from '@/utils/lnurl.ts'; import { lookupPubkey } from '@/utils/lookup.ts'; import { addTag, deleteTag } from '@/utils/tags.ts'; @@ -322,6 +322,33 @@ const rebloggedByController: AppController = (c) => { return renderEventAccounts(c, [{ kinds: [6], '#e': [id], ...params }]); }; +const quotesController: AppController = async (c) => { + const id = c.req.param('id'); + const params = paginationSchema.parse(c.req.query()); + const store = await Storages.db(); + + const [event] = await store.query([{ ids: [id], kinds: [1] }]); + if (!event) { + return c.json({ error: 'Event not found.' }, 404); + } + + const quotes = await store + .query([{ kinds: [1], '#q': [event.id], ...params }]) + .then((events) => hydrateEvents({ events, store })); + + const viewerPubkey = await c.get('signer')?.getPublicKey(); + + const statuses = await Promise.all( + quotes.map((event) => renderStatus(event, { viewerPubkey })), + ); + + if (!statuses.length) { + return c.json([]); + } + + return paginated(c, quotes, statuses); +}; + /** https://docs.joinmastodon.org/methods/statuses/#bookmark */ const bookmarkController: AppController = async (c) => { const pubkey = await c.get('signer')?.getPublicKey()!; @@ -487,6 +514,7 @@ export { favouriteController, favouritedByController, pinController, + quotesController, rebloggedByController, reblogStatusController, statusController,