[Shim] Add Support for Context.tags

src/shared/util/attributeLogRecordProcessor.ts

@@ -0,0 +1,21 @@
+import { LogRecord, LogRecordProcessor } from "@opentelemetry/sdk-logs";
+
+export class AttributeLogProcessor implements LogRecordProcessor {
+    private _attributes: { [key: string]: string };
+    constructor(attributes: { [key: string]: string }) {
+        this._attributes = attributes;
+    }
+
+    // Override onEmit to apply log record attributes before exporting
+    onEmit(record: LogRecord) {
+        record.setAttributes(this._attributes);
+    }
+
+    shutdown(): Promise<void> {
+        return Promise.resolve();
+    }
+
+    forceFlush(): Promise<void> {
+        return Promise.resolve();
+    }
+}

src/shared/util/attributeSpanProcessor.ts

@@ -0,0 +1,25 @@
+import { SpanProcessor, Span } from "@opentelemetry/sdk-trace-base";
+
+export class AttributeSpanProcessor implements SpanProcessor {
+    private _attributes: { [key: string]: string };
+    constructor(attributes: { [key: string]: string }) {
+        this._attributes = attributes;
+    }
+
+    // Implement onStart to apply span attributes before exporting
+    onStart(span: Span): void {
+        span.setAttributes(this._attributes);
+    }
+
+    onEnd(): void {
+        return;
+    }
+
+    shutdown(): Promise<void> {
+        return Promise.resolve();
+    }
+
+    forceFlush(): Promise<void> {
+        return Promise.resolve();
+    }
+}

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,29 @@
 // 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 { 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 +48,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(this.context.tags);
+        ((trace.getTracerProvider() as ProxyTracerProvider).getDelegate() as NodeTracerProvider).addSpanProcessor(this._attributeSpanProcessor);
+
+        this._attributeLogProcessor = new AttributeLogProcessor(this.context.tags);
+        (logs.getLoggerProvider() as LoggerProvider).addLogRecordProcessor(this._attributeLogProcessor);
     }
 
     /**