feat: Sleep on failure or no messages

runner/src/stream-handler.ts

@@ -35,6 +35,8 @@ export default class StreamHandler {
 }
 
 if (!isMainThread) {
+  const sleep = async (ms: number): Promise<void> => { await new Promise((resolve) => setTimeout(resolve, ms)); };
+
   void (async function main () {
     const indexer = new Indexer('mainnet');
     const redisClient = new RedisClient();
@@ -47,7 +49,6 @@ if (!isMainThread) {
 
     while (true) {
       try {
-        const startTime = performance.now();
         const streamType = redisClient.getStreamType(streamKey);
 
         const messages = await redisClient.getNextStreamMessage(streamKey);
@@ -56,11 +57,14 @@ if (!isMainThread) {
         indexerName = `${indexerConfig.account_id}/${indexerConfig.function_name}`;
 
         if (messages == null) {
+          await sleep(1000);
           continue;
         }
 
         const [{ id, message }] = messages;
 
+        const startTime = performance.now();
+
         const functions = {
           [indexerName]: {
             account_id: indexerConfig.account_id,
@@ -92,6 +96,7 @@ if (!isMainThread) {
 
         console.log(`Success: ${indexerName}`);
       } catch (err) {
+        await sleep(10000);
         console.log(`Failed: ${indexerName}`, err);
       }
     }