diff options
author | Eric Bailey <git@esb.lol> | 2025-06-20 11:30:52 -0500 |
---|---|---|
committer | GitHub <noreply@github.com> | 2025-06-20 09:30:52 -0700 |
commit | aeafb14fb41ad15f4093e9c3d7fed23702e56f4f (patch) | |
tree | 56fad6e59f65bca7a535a43f125490af5a18c0e5 /src/state/messages/events/agent.ts | |
parent | 4c75b568dfad4f44d4df76f44236bb1c9acd89a4 (diff) | |
download | voidsky-aeafb14fb41ad15f4093e9c3d7fed23702e56f4f.tar.zst |
Couple of Sentry cleanups (#8532)
* Temp ignore a couple logs * Add debug for unknown notifications * Nvm let's do this in Sentry * Downgrade two DMs network related issues * Check for network errors before sending in Convo * Do the same for event bus * Fix mistake
Diffstat (limited to 'src/state/messages/events/agent.ts')
-rw-r--r-- | src/state/messages/events/agent.ts | 36 |
1 files changed, 18 insertions, 18 deletions
diff --git a/src/state/messages/events/agent.ts b/src/state/messages/events/agent.ts index 589c5b6d3..fb3047bf6 100644 --- a/src/state/messages/events/agent.ts +++ b/src/state/messages/events/agent.ts @@ -3,6 +3,7 @@ import EventEmitter from 'eventemitter3' import {nanoid} from 'nanoid/non-secure' import {networkRetry} from '#/lib/async/retry' +import {isNetworkError} from '#/lib/strings/errors' import {Logger} from '#/logger' import { BACKGROUND_POLL_INTERVAL, @@ -18,7 +19,6 @@ import { } from '#/state/messages/events/types' import {DM_SERVICE_HEADERS} from '#/state/queries/messages/const' -const LOGGER_CONTEXT = 'MessagesEventBus' const logger = Logger.create(Logger.Context.DMsAgent) export class MessagesEventBus { @@ -91,17 +91,17 @@ export class MessagesEventBus { } background() { - logger.debug(`${LOGGER_CONTEXT}: background`, {}) + logger.debug(`background`, {}) this.dispatch({event: MessagesEventBusDispatchEvent.Background}) } suspend() { - logger.debug(`${LOGGER_CONTEXT}: suspend`, {}) + logger.debug(`suspend`, {}) this.dispatch({event: MessagesEventBusDispatchEvent.Suspend}) } resume() { - logger.debug(`${LOGGER_CONTEXT}: resume`, {}) + logger.debug(`resume`, {}) this.dispatch({event: MessagesEventBusDispatchEvent.Resume}) } @@ -228,7 +228,7 @@ export class MessagesEventBus { break } - logger.debug(`${LOGGER_CONTEXT}: dispatch '${action.event}'`, { + logger.debug(`dispatch '${action.event}'`, { id: this.id, prev: prevStatus, next: this.status, @@ -236,7 +236,7 @@ export class MessagesEventBus { } private async init() { - logger.debug(`${LOGGER_CONTEXT}: init`, {}) + logger.debug(`init`, {}) try { const response = await networkRetry(2, () => { @@ -260,9 +260,11 @@ export class MessagesEventBus { this.dispatch({event: MessagesEventBusDispatchEvent.Ready}) } catch (e: any) { - logger.error(e, { - message: `${LOGGER_CONTEXT}: init failed`, - }) + if (!isNetworkError(e)) { + logger.error(`init failed`, { + safeMessage: e.message, + }) + } this.dispatch({ event: MessagesEventBusDispatchEvent.Error, @@ -324,7 +326,7 @@ export class MessagesEventBus { this.isPolling = true // logger.debug( - // `${LOGGER_CONTEXT}: poll`, + // `poll`, // { // requestedPollIntervals: Array.from( // this.requestedPollIntervals.values(), @@ -370,16 +372,14 @@ export class MessagesEventBus { } if (needsEmit) { - try { - this.emitter.emit('event', {type: 'logs', logs: batch}) - } catch (e: any) { - logger.error(e, { - message: `${LOGGER_CONTEXT}: process latest events`, - }) - } + this.emitter.emit('event', {type: 'logs', logs: batch}) } } catch (e: any) { - logger.error(e, {message: `${LOGGER_CONTEXT}: poll events failed`}) + if (!isNetworkError(e)) { + logger.error(`poll events failed`, { + safeMessage: e.message, + }) + } this.dispatch({ event: MessagesEventBusDispatchEvent.Error, |