[Shim] Add Support for Context.tags

src/shared/util/attributeLogRecordProcessor.ts

@@ -0,0 +1,14 @@
+import { BatchLogRecordProcessor, LogRecord, LogRecordExporter } from "@opentelemetry/sdk-logs";
+
+export class AttributeLogProcessor extends BatchLogRecordProcessor {
+    private _attributes: { [key: string]: string };
+    constructor(exporter: LogRecordExporter, attributes: { [key: string]: string }) {
+        super(exporter);
+        this._attributes = attributes;
+    }
+    // Override onEmit to apply log record attributes before exporting
+    onEmit(record: LogRecord) {
+        record.setAttributes(this._attributes);
+        super.onEmit(record);
+    }
+}

src/shared/util/attributeSpanProcessor.ts

@@ -0,0 +1,16 @@
+import { BatchSpanProcessor, Span } from "@opentelemetry/sdk-trace-base";
+import { SpanExporter } from "@opentelemetry/sdk-trace-node";
+import { context } from "@opentelemetry/api";
+
+export class AttributeSpanProcessor extends BatchSpanProcessor {
+    private _attributes: { [key: string]: string };
+    constructor(exporter: SpanExporter, attributes: { [key: string]: string }) {
+        super(exporter);
+        this._attributes = attributes;
+    }
+    // Override onStart to apply span attributes before exporting
+    onStart(span: Span) {
+        span.setAttributes(this._attributes);
+        super.onStart(span, context.active());
+    }
+}

src/shared/util/configHelper.ts

@@ -26,7 +26,7 @@ export function setAutoCollectRequests(options: ApplicationInsightsOptions, valu
                     ...options.instrumentationOptions?.http,
                     enabled: true,
                     // eslint-disable-next-line @typescript-eslint/no-unused-vars
-                    ignoreIncomingRequestHook: (request: http.RequestOptions) => true,
+                    ignoreIncomingRequestHook: (request: http.IncomingMessage) => true,
                 } as HttpInstrumentationConfig
             };
         } else {
@@ -35,7 +35,7 @@ export function setAutoCollectRequests(options: ApplicationInsightsOptions, valu
                     ...options.instrumentationOptions?.http,
                     enabled: true,
                     // eslint-disable-next-line @typescript-eslint/no-unused-vars
-                    ignoreIncomingRequestHook: (request: http.RequestOptions) => false,
+                    ignoreIncomingRequestHook: (request: http.IncomingMessage) => false,
                 } as HttpInstrumentationConfig
             };
         }

src/shim/config.ts

@@ -290,7 +290,7 @@ class Config implements IConfig {
 
         // NOT SUPPORTED CONFIGURATION OPTIONS
         if (this.disableAppInsights) {
-            Logger.getInstance().warn("disableAppInsights cohnfiguration no longer supported.");
+            Logger.getInstance().warn("disableAppInsights configuration no longer supported.");
         }
         if (this.enableAutoCollectHeartbeat) {
             Logger.getInstance().warn("Heartbeat metris are no longer supported.");

src/shim/telemetryClient.ts

@@ -1,25 +1,30 @@
 // Copyright (c) Microsoft Corporation.
 // Licensed under the MIT license.
 
-import { Attributes, context, DiagLogLevel, SpanKind, SpanOptions, SpanStatusCode, trace } from "@opentelemetry/api";
+import { Attributes, context, ProxyTracerProvider, SpanKind, SpanOptions, SpanStatusCode, trace } from "@opentelemetry/api";
 import { logs } from "@opentelemetry/api-logs";
+import { LoggerProvider } from "@opentelemetry/sdk-logs";
 import { SemanticAttributes } from "@opentelemetry/semantic-conventions";
-
 import * as Contracts from "../declarations/contracts";
 import { TelemetryItem as Envelope } from "../declarations/generated";
 import { Context } from "./context";
 import { Logger } from "../shared/logging";
 import { Util } from "../shared/util";
 import Config = require("./config");
+import { AzureMonitorTraceExporter, AzureMonitorLogExporter } from "@azure/monitor-opentelemetry-exporter";
+import { AttributeSpanProcessor } from "../shared/util/attributeSpanProcessor";
+import { NodeTracerProvider } from "@opentelemetry/sdk-trace-node";
+import { AttributeLogProcessor } from "../shared/util/attributeLogRecordProcessor";
 import { ApplicationInsightsClient } from "../applicationInsightsClient";
 import { LogApi } from "../logs/api";
 
-
 /**
  * Application Insights telemetry client provides interface to track telemetry items, register telemetry initializers and
  * and manually trigger immediate sending (flushing)
  */
 export class TelemetryClient {
+    private _attributeSpanProcessor: AttributeSpanProcessor;
+    private _attributeLogProcessor: AttributeLogProcessor;
     private _client: ApplicationInsightsClient;
     private _logApi: LogApi;
     public context: Context;
@@ -44,6 +49,11 @@ export class TelemetryClient {
         // LoggerProvider would be initialized when client is instantiated
         // Get Logger from global provider
         this._logApi = new LogApi(logs.getLogger("ApplicationInsightsLogger"));
+        this._attributeSpanProcessor = new AttributeSpanProcessor(new AzureMonitorTraceExporter(this.config.parseConfig().azureMonitorExporterConfig), this.context.tags);
+        ((trace.getTracerProvider() as ProxyTracerProvider).getDelegate() as NodeTracerProvider).addSpanProcessor(this._attributeSpanProcessor);
+
+        this._attributeLogProcessor = new AttributeLogProcessor(new AzureMonitorLogExporter(options.azureMonitorExporterConfig), this.context.tags);
+        (logs.getLoggerProvider() as LoggerProvider).addLogRecordProcessor(this._attributeLogProcessor);
     }
 
     /**