MCPcopy Create free account
hub / github.com/cameri/nostream / clearOldEventsSafely

Method clearOldEventsSafely

src/app/maintenance-worker.ts:92–103  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

90 }
91
92 private async clearOldEventsSafely(): Promise<void> {
93 try {
94 await Promise.race([
95 this.maintenanceService.clearOldEvents(),
96 delayMs(CLEAR_OLD_EVENTS_TIMEOUT_MS).then(() => {
97 throw new Error(`clearOldEvents timed out after ${CLEAR_OLD_EVENTS_TIMEOUT_MS}ms`)
98 }),
99 ])
100 } catch (error) {
101 logger('unable to clear old events: %o', error)
102 }
103 }
104
105 public run(): void {
106 this.interval = setInterval(async () => {

Callers 1

onScheduleMethod · 0.95

Calls 2

delayMsFunction · 0.90
clearOldEventsMethod · 0.65

Tested by

no test coverage detected