fix(runtime): add mongodb stream reconnect (#1276)

* feat: fix runtime

* feat: add  stream reconnect

* fix: fix work case

Author: skyoct

runtimes/nodejs/src/support/db-change-stream.ts

@@ -22,6 +22,15 @@ export class DatabaseChangeStream {
     stream.on('change', async (_change) => {
       this.updateEnvironments()
     })
+
+    stream.on('close', () => { 
+      logger.info('Conf collection change stream closed.')
+      setTimeout(() => { 
+        logger.info('Reconnecting conf collection change stream...')
+        this.watchConf()
+      }, 3000)
+    })
+
   }
 
   private static async updateEnvironments() {

runtimes/nodejs/src/support/function-engine/cache.ts

@@ -71,6 +71,14 @@ export class FunctionCache {
         }
       }
     })
+
+    stream.on('close', () => {
+      logger.error('Cloud function change stream closed')
+      setTimeout(() => {
+        logger.info('Reconnecting cloud function change stream...')
+        this.streamChange()
+       }, 3000)
+    })
   }
 
   /**