mirror/ditto
mirror/ditto
1
0
Fork 0
mirror of https://gitlab.com/soapbox-pub/ditto.git synced 2025-12-06 11:29:46 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Fix streaming API hydration ( ͡° ͜ʖ ͡°)

Browse source
This commit is contained in:
Alex Gleason 2025-02-23 11:56:29 -06:00
parent a52fe9fbc6
commit decb3ac618
No known key found for this signature in database
GPG key ID: 7211D1F99744FBB7
1 changed files with 3 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
packages/ditto/controllers/api/streaming.ts
View file

@ -99,8 +99,9 @@ const streamingController: AppController = async (c) => {
filter: NostrFilter & { limit: 0 }, filter: NostrFilter & { limit: 0 },
render: (event: NostrEvent) => Promise<StreamingEvent | undefined>, render: (event: NostrEvent) => Promise<StreamingEvent | undefined>,
) { ) {
const { signal } = controller;
try { try {
for await (const msg of relay.req([filter], { signal: controller.signal })) { for await (const msg of relay.req([filter], { signal })) {
if (msg[0] === 'EVENT') { if (msg[0] === 'EVENT') {
const event = msg[2]; const event = msg[2];
@ -111,7 +112,7 @@ const streamingController: AppController = async (c) => {
} }
} }
await hydrateEvents({ ...c.var, events: [event] }); await hydrateEvents({ ...c.var, events: [event], signal });
const result = await render(event); const result = await render(event);