INNER CODE UNIT · TypeScript

handleMessage

rotki/rotki · frontend/app/src/modules/core/messaging/index.ts:61

  const handleMessage = async (data: string): Promise<void> => {
    const message = parseMessage(camelCaseTransformer(JSON.parse(data)));
    if (message)
      await route(message);
  };

  const consume = async (): Promise<void> => {
    if (isRunning)
      return;

    isRunning = true;
    const title = t('actions.notifications.consume.message_title');

    try {
      const { dropped, messages } = await backoff(3, async () => consumeMessages(), 10000, sessionWorkSignal());

      for (const { count, lastSent, ...raw } of messages) {
        const message = parseMessage(raw);

View source record →