feature: wait InfluxDB to become available

On server/plugin start wait for Influx connection to become
available.

Previously plugin startup would fail if InfluxDB is not available
when plugin starts and never retry. If SK server would start more
quickly than Influx on server bootup the plugin would never start
writing data.

Fixes #52.

src/influx.ts

@@ -201,17 +201,28 @@ export class SKInflux {
     })
   }
 
-  async init() {
-    const bucketId = await ensureBucketExists(this.influx, this.org, this.bucket)
-    try {
-      await this.ensureV1MappingExists(bucketId)
-      // eslint-disable-next-line @typescript-eslint/no-explicit-any
-    } catch (err: any) {
-      this.logging.error('Could not verify or create v1 database mapping, history api will not work')
-      this.logging.error(err)
-    }
+  init() {
+    let retryCount = 0
+    return new Promise((resolve) => {
+      const retryInit = () => {
+        // eslint-disable-next-line @typescript-eslint/no-explicit-any
+        this._init(resolve).catch((e: any) => {
+          this.logging.debug(e.message)
+          this.logging.debug(`${e.message} retry ${retryCount++}`)
+          setTimeout(() => {
+            retryInit()
+          }, 10 * 1000)
+        })
+      }
+      retryInit()
+    })
   }
 
+  async _init(onSuccess: (v: unknown) => void) {
+    const bucketId = await ensureBucketExists(this.influx, this.org, this.bucket)
+    await this.ensureV1MappingExists(bucketId)
+    onSuccess(undefined)
+  }
   async ensureV1MappingExists(bucketId: string | undefined) {
     if (!bucketId) {
       throw new Error('No bucketid')

src/plugin.ts

@@ -143,7 +143,9 @@ export default function InfluxPluginFactory(app: App): Plugin & InfluxPlugin {
         onStop.push(() => clearInterval(interval))
       }
 
+      app.setPluginStatus(`Connecting ${skInfluxes.map((sk) => sk.url)}`)
       return Promise.all(skInfluxes.map((skInflux) => skInflux.init())).then(() => {
+        app.setPluginStatus('Connected')
         const onDelta = (_delta: Delta) => {
           const delta = _delta as ValuesDelta
           const now = Date.now()