feat: restart watcher if no events seen for specified period

lib/external-secret.js

@@ -42,20 +42,39 @@ async function startWatcher ({
       const jsonStream = new JSONStream()
       stream.pipe(jsonStream)
 
-      jsonStream.on('data', eventQueue.put)
+      let timeout
+      const startTimeout = () => {
+        if (timeout) {
+          clearTimeout(timeout)
+        }
+
+        const timeMs = 60000
+        timeout = setTimeout(() => {
+          logger.info(`No watch event for ${timeMs} ms, restarting watcher`)
+          deathQueue.put('RESTART')
+        }, timeMs)
+        timeout.unref()
+      }
+
+      jsonStream.on('data', (evt) => {
+        eventQueue.put(evt)
+        startTimeout()
+      })
 
       jsonStream.on('error', (err) => {
         logger.warn(err, 'Got error on stream')
         deathQueue.put('ERROR')
+        clearTimeout(timeout)
       })
 
       jsonStream.on('end', () => {
         deathQueue.put('END')
+        clearTimeout(timeout)
       })
 
-      await deathQueue.take()
+      const deathEvent = await deathQueue.take()
 
-      logger.debug('Stopping watch stream')
+      logger.info('Stopping watch stream due to event: %s', deathEvent)
       eventQueue.put({ type: 'DELETED_ALL' })
 
       stream.abort()