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

refactor(streaming): use better Sticky

Browse source
This commit is contained in:
P. Reis 2024-10-28 20:39:46 -03:00
parent 8ff4a0bdbd
commit fef787faad
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
src/controllers/api/streaming.ts
View file

@ -1,6 +1,6 @@
import TTLCache from '@isaacs/ttlcache'; import TTLCache from '@isaacs/ttlcache';
import { NostrEvent, NostrFilter } from '@nostrify/nostrify'; import { NostrEvent, NostrFilter } from '@nostrify/nostrify';
import Debug from '@soapbox/stickynotes/debug'; import { Stickynotes } from '@soapbox/stickynotes';
import { z } from 'zod'; import { z } from 'zod';
import { type AppController } from '@/app.ts'; import { type AppController } from '@/app.ts';
@ -19,7 +19,7 @@ import { bech32ToPubkey, Time } from '@/utils.ts';
import { renderReblog, renderStatus } from '@/views/mastodon/statuses.ts'; import { renderReblog, renderStatus } from '@/views/mastodon/statuses.ts';
import { renderNotification } from '@/views/mastodon/notifications.ts'; import { renderNotification } from '@/views/mastodon/notifications.ts';
const debug = Debug('ditto:streaming'); const console = new Stickynotes('ditto:streaming');
/** /**
* Streaming timelines/categories. * Streaming timelines/categories.
@ -100,7 +100,7 @@ const streamingController: AppController = async (c) => {
function send(e: StreamingEvent) { function send(e: StreamingEvent) {
if (socket.readyState === WebSocket.OPEN) { if (socket.readyState === WebSocket.OPEN) {
debug('send', e.event, e.payload); console.debug('send', e.event, e.payload);
streamingServerMessagesCounter.inc(); streamingServerMessagesCounter.inc();
socket.send(JSON.stringify(e)); socket.send(JSON.stringify(e));
} }
@ -129,7 +129,7 @@ const streamingController: AppController = async (c) => {
} }
} }
} catch (e) { } catch (e) {
debug('streaming error:', e); console.debug('streaming error:', e);
} }
} }