fix(runtime): remove reconnection of mongo stream since bug in it

labring · Aug 19, 2023 · f6d8aed · f6d8aed
1 parent ed6061d
commit f6d8aed
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 15 deletions.
diff --git a/runtimes/nodejs/src/support/db-change-stream.ts b/runtimes/nodejs/src/support/db-change-stream.ts
@@ -23,14 +23,13 @@ export class DatabaseChangeStream {
       this.updateEnvironments()
     })
 
-    stream.on('close', () => { 
-      logger.info('Conf collection change stream closed.')
-      setTimeout(() => { 
-        logger.info('Reconnecting conf collection change stream...')
-        this.watchConf()
-      }, 3000)
-    })
-
+    // stream.on('close', () => { 
+    //   logger.info('Conf collection change stream closed.')
+    //   setTimeout(() => { 
+    //     logger.info('Reconnecting conf collection change stream...')
+    //     DatabaseChangeStream.watchConf()
+    //   }, 3000)
+    // })
   }
 
   private static async updateEnvironments() {

diff --git a/runtimes/nodejs/src/support/function-engine/cache.ts b/runtimes/nodejs/src/support/function-engine/cache.ts
@@ -72,13 +72,13 @@ export class FunctionCache {
       }
     })
 
-    stream.on('close', () => {
-      logger.error('Cloud function change stream closed')
-      setTimeout(() => {
-        logger.info('Reconnecting cloud function change stream...')
-        this.streamChange()
-       }, 3000)
-    })
+    // stream.on('close', () => {
+    //   logger.error('Cloud function change stream closed')
+    //   setTimeout(() => {
+    //     logger.info('Reconnecting cloud function change stream...')
+    //     FunctionCache.streamChange()
+    //    }, 3000)
+    // })
   }
 
   /**