diff --git a/src/app.ts b/src/app.ts index 18b0fb96..6929757f 100644 --- a/src/app.ts +++ b/src/app.ts @@ -109,7 +109,11 @@ import { zappedByController, } from '@/controllers/api/statuses.ts'; import { streamingController } from '@/controllers/api/streaming.ts'; -import { suggestionsV1Controller, suggestionsV2Controller } from '@/controllers/api/suggestions.ts'; +import { + localSuggestionsController, + suggestionsV1Controller, + suggestionsV2Controller, +} from '@/controllers/api/suggestions.ts'; import { hashtagTimelineController, homeTimelineController, @@ -348,6 +352,7 @@ app.get( app.get('/api/v1/suggestions', suggestionsV1Controller); app.get('/api/v2/suggestions', suggestionsV2Controller); +app.get('/api/v2/ditto/suggestions/local', localSuggestionsController); app.get('/api/v1/notifications', rateLimitMiddleware(8, Time.seconds(30)), requireSigner, notificationsController); app.get('/api/v1/notifications/:id', requireSigner, notificationController); diff --git a/src/controllers/api/suggestions.ts b/src/controllers/api/suggestions.ts index c047c415..e2357c1a 100644 --- a/src/controllers/api/suggestions.ts +++ b/src/controllers/api/suggestions.ts @@ -4,7 +4,7 @@ import { matchFilter } from 'nostr-tools'; import { AppContext, AppController } from '@/app.ts'; import { Conf } from '@/config.ts'; import { hydrateEvents } from '@/storages/hydrate.ts'; -import { paginatedList } from '@/utils/api.ts'; +import { paginated, paginatedList } from '@/utils/api.ts'; import { getTagSet } from '@/utils/tags.ts'; import { accountFromPubkey, renderAccount } from '@/views/mastodon/accounts.ts'; @@ -87,3 +87,24 @@ async function renderV2Suggestions(c: AppContext, params: { offset: number; limi }; })); } + +export const localSuggestionsController: AppController = async (c) => { + const signal = c.req.raw.signal; + const params = c.get('pagination'); + const store = c.get('store'); + + const events = await store.query( + [{ kinds: [0], search: `domain:${Conf.url.host}`, ...params }], + { signal }, + ) + .then((events) => hydrateEvents({ store, events, signal })); + + const suggestions = await Promise.all(events.map(async (event) => { + return { + source: 'global', + account: await renderAccount(event), + }; + })); + + return paginated(c, events, suggestions); +}; diff --git a/src/utils/api.ts b/src/utils/api.ts index 89cb608b..29304cbd 100644 --- a/src/utils/api.ts +++ b/src/utils/api.ts @@ -207,7 +207,8 @@ function buildLinkHeader(url: string, events: NostrEvent[]): string | undefined return `<${next}>; rel="next", <${prev}>; rel="prev"`; } -type Entity = { id: string }; +// deno-lint-ignore ban-types +type Entity = {}; type HeaderRecord = Record; /** Return results with pagination headers. Assumes chronological sorting of events. */