Skip to content

Commit 6706826

Browse files
Mani BrarMani Brar
authored andcommitted
chore: add catch for rejected heartbeat
1 parent 8ac426b commit 6706826

File tree

2 files changed

+7
-7
lines changed

2 files changed

+7
-7
lines changed

relayer-cli/src/relayer.ts

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ const sendHeartbeat = async (): Promise<void> => {
3838
path: url.pathname,
3939
method: "GET",
4040
headers: {
41-
"User-Agent": "Vea-Validator-CLI/1.0",
41+
"User-Agent": "Vea-Relayer-CLI/1.0",
4242
},
4343
};
4444

@@ -79,7 +79,7 @@ export async function start({ networkConfigs, shutdownManager, emitter }: Relaye
7979
initializeEmitter(emitter);
8080

8181
// Send startup heartbeat
82-
await sendHeartbeat();
82+
await sendHeartbeat().catch(() => {});
8383

8484
let delayAmount = 7200 * 1000; // 2 hours in ms
8585
while (!shutdownManager.getIsShuttingDown()) {
@@ -89,13 +89,13 @@ export async function start({ networkConfigs, shutdownManager, emitter }: Relaye
8989
emitter.emit(BotEvents.WAITING, delayAmount);
9090

9191
// Send heartbeat before waiting
92-
await sendHeartbeat();
92+
await sendHeartbeat().catch(() => {});
9393

9494
await delay(delayAmount);
9595
}
9696

9797
// Send shutdown heartbeat
98-
await sendHeartbeat();
98+
await sendHeartbeat().catch(() => {});
9999
}
100100

101101
/**

validator-cli/src/watcher.ts

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -86,20 +86,20 @@ export const watch = async (
8686
emitter.emit(BotEvents.STARTED, path, networkConfigs[0].networks);
8787

8888
// Send startup heartbeat
89-
await sendHeartbeat();
89+
await sendHeartbeat().catch(() => {});
9090

9191
const transactionHandlers: { [key: string]: any } = {};
9292
const toWatch: { [key: string]: { count: number; epochs: number[] } } = {};
9393
while (!shutDownSignal.getIsShutdownSignal()) {
94-
await sendHeartbeat();
94+
await sendHeartbeat().catch(() => {});
9595
for (const networkConfig of networkConfigs) {
9696
await processNetwork(path, toSaveSnapshot, networkConfig, transactionHandlers, toWatch, emitter);
9797
}
9898
await wait(1000 * 10);
9999
}
100100

101101
// Send shutdown heartbeat
102-
await sendHeartbeat();
102+
await sendHeartbeat().catch(() => {});
103103
};
104104

105105
async function processNetwork(

0 commit comments

Comments
 (0)