optional app insights

Author: pelikhan

devicescript

@@ -1,12 +1,19 @@
+import * as mq from "./mq"
 import * as appInsights from "applicationinsights"
 import { ContextTagKeys } from "applicationinsights/out/Declarations/Contracts"
 import { registerMessageSink } from "./messages"
 
 // telemetry from devices
 let _devsTelemetry: appInsights.TelemetryClient
 export async function setup() {
+    const connString = process.env.APPLICATIONINSIGHTS_CONNECTION_STRING
+    if (!connString) {
+        console.log(`no application insights connection string, skipping`)
+        return
+    }
+
     appInsights
-        .setup()
+        .setup(connString)
         .setAutoDependencyCorrelation(true)
         .setAutoCollectRequests(true)
         .setAutoCollectPerformance(true, true)
@@ -81,7 +88,7 @@ export async function setup() {
 }
 
 export function serverTelemetry(): appInsights.TelemetryClient {
-    return appInsights.defaultClient
+    return _devsTelemetry ? appInsights.defaultClient : undefined
 }
 
 export function devsTelemetry(): appInsights.TelemetryClient {

src/appinsights.ts

@@ -36,7 +36,7 @@ export async function setup() {
                     correlationId,
                 })
             ) {
-                serverTelemetry().trackEvent({
+                serverTelemetry()?.trackEvent({
                     name: "messages.eventhub.push.fail",
                 })
             } else await producer.sendBatch(batch)

src/eventhub.ts

@@ -152,7 +152,7 @@ async function main() {
     const host = "0.0.0.0"
     server.listen({ port, host }, err => {
         if (err) {
-            appinsights.serverTelemetry().trackException({ exception: err })
+            appinsights.serverTelemetry()?.trackException({ exception: err })
             console.error(err)
             process.exit(1)
         }

src/index.ts

@@ -371,7 +371,7 @@ export class ConnectedDevice {
                     } else this.setDeploy(tmp)
                 }
             } catch (e: any) {
-                serverTelemetry().trackException({ exception: e })
+                serverTelemetry()?.trackException({ exception: e })
             }
         }
 
@@ -586,6 +586,8 @@ export class ConnectedDevice {
 
     private track(telemetry: Telemetry, telemetryType: TelemetryType) {
         const dt = devsTelemetry()
+        if (!dt) return
+
         const { tagOverrides = {}, ...rest } = telemetry
         const {
             productId,
@@ -807,7 +809,7 @@ export async function wsskInit(server: FastifyInstance) {
                     }
                 } catch (e: any) {
                     log.error(`message handler: ${e.stack}`)
-                    serverTelemetry().trackException({ exception: e })
+                    serverTelemetry()?.trackException({ exception: e })
                 }
             })