chore: better support for event sender analytics paths

packages/shared/common/src/internal/events/LDInternalOptions.ts

@@ -0,0 +1,5 @@
+export type LDInternalOptions = {
+  analyticsEventPath?: string;
+  diagnosticEventPath?: string;
+  includeAuthorizationHeader?: boolean;
+};

packages/shared/common/src/internal/events/index.ts

@@ -3,5 +3,13 @@ import InputCustomEvent from './InputCustomEvent';
 import InputEvalEvent from './InputEvalEvent';
 import InputEvent from './InputEvent';
 import InputIdentifyEvent from './InputIdentifyEvent';
+import type { LDInternalOptions } from './LDInternalOptions';
 
-export { InputCustomEvent, InputEvalEvent, InputEvent, InputIdentifyEvent, EventProcessor };
+export {
+  EventProcessor,
+  InputCustomEvent,
+  InputEvalEvent,
+  InputEvent,
+  InputIdentifyEvent,
+  LDInternalOptions,
+};

packages/shared/common/src/options/ServiceEndpoints.ts

@@ -12,9 +12,36 @@ export default class ServiceEndpoints {
 
   public readonly events: string;
 
-  public constructor(streaming: string, polling: string, events: string) {
+  /** Valid paths are:
+   * /bulk
+   * /events/bulk/envId
+   * /mobile
+   */
+  public readonly analyticsEventPath: string;
+
+  /** Valid paths are:
+   * /diagnostic
+   * /events/diagnostic/envId
+   * /mobile/events/diagnostic
+   */
+  public readonly diagnosticEventPath: string;
+
+  // if true the sdk key will be included as authorization header
+  public readonly includeAuthorizationHeader: boolean;
+
+  public constructor(
+    streaming: string,
+    polling: string,
+    events: string,
+    analyticsEventPath: string = '/bulk',
+    diagnosticEventPath: string = '/diagnostic',
+    includeAuthorizationHeader: boolean = true,
+  ) {
     this.streaming = canonicalizeUri(streaming);
     this.polling = canonicalizeUri(polling);
     this.events = canonicalizeUri(events);
+    this.analyticsEventPath = analyticsEventPath;
+    this.diagnosticEventPath = diagnosticEventPath;
+    this.includeAuthorizationHeader = includeAuthorizationHeader;
   }
 }

packages/shared/sdk-server-edge/src/api/LDClient.ts

@@ -1,5 +1,6 @@
 import { EventEmitter } from 'node:events';
 
+import { internal } from '@launchdarkly/js-sdk-common';
 import { Info, LDClientImpl, LDOptions } from '@launchdarkly/js-server-sdk-common';
 
 import EdgePlatform from '../platform';
@@ -16,7 +17,12 @@ export class LDClient extends LDClientImpl {
   constructor(clientSideID: string, platformInfo: Info, options: LDOptions) {
     const em = new EventEmitter();
     const platform = new EdgePlatform(platformInfo);
-    super(clientSideID, platform, createOptions(options), createCallbacks(em));
+    const internalOptions: internal.LDInternalOptions = {
+      analyticsEventPath: `/events/bulk/${clientSideID}`,
+      diagnosticEventPath: `/events/diagnostic/${clientSideID}`,
+      includeAuthorizationHeader: false,
+    };
+    super(clientSideID, platform, createOptions(options), createCallbacks(em), internalOptions);
     this.emitter = em;
   }
 }

packages/shared/sdk-server/src/LDClientImpl.ts

@@ -120,13 +120,14 @@ export default class LDClientImpl implements LDClient {
     private platform: Platform,
     options: LDOptions,
     callbacks: LDClientCallbacks,
+    internalOptions?: internal.LDInternalOptions,
   ) {
     this.onError = callbacks.onError;
     this.onFailed = callbacks.onFailed;
     this.onReady = callbacks.onReady;
 
     const { onUpdate, hasEventListeners } = callbacks;
-    const config = new Configuration(options);
+    const config = new Configuration(options, internalOptions);
     if (!sdkKey && !config.offline) {
       throw new Error('You must configure the client with an SDK key');
     }

packages/shared/sdk-server/src/data_sources/defaultHeaders.ts

@@ -8,6 +8,7 @@ export default function defaultHeaders(
   sdkKey: string,
   config: DefaultHeaderOptions,
   info: Info,
+  includeAuthorizationHeader: boolean = true,
 ): { [key: string]: string } {
   const sdkData = info.sdkData();
   const headers: { [key: string]: string } = {
@@ -16,8 +17,9 @@ export default function defaultHeaders(
     }`,
   };
 
-  // edge sdks use clientSideID and don't need the authorization header
-  if (sdkKey.startsWith('sdk-')) {
+  // edge sdks sets this to false because they use the clientSideID
+  // and they don't need the authorization header
+  if (includeAuthorizationHeader) {
     headers.authorization = sdkKey;
   }
 

packages/shared/sdk-server/src/events/EventSender.ts

@@ -31,22 +31,22 @@ export default class EventSender implements subsystem.LDEventSender {
     const {
       basicConfiguration: {
         sdkKey,
-        serviceEndpoints: { events },
+        serviceEndpoints: {
+          events,
+          analyticsEventPath,
+          diagnosticEventPath,
+          includeAuthorizationHeader,
+        },
       },
       platform: { info, requests, crypto },
     } = clientContext;
 
     this.defaultHeaders = {
-      ...defaultHeaders(sdkKey, config, info),
+      ...defaultHeaders(sdkKey, config, info, includeAuthorizationHeader),
     };
 
-    // edge sdks use clientSideID to send events
-    const isClientSideID = !sdkKey.startsWith('sdk-');
-    this.eventsUri = isClientSideID ? `${events}/events/bulk/${sdkKey}` : `${events}/bulk`;
-    this.diagnosticEventsUri = isClientSideID
-      ? `${events}/events/diagnostic/${sdkKey}`
-      : `${events}/diagnostic`;
-
+    this.eventsUri = `${events}${analyticsEventPath}`;
+    this.diagnosticEventsUri = `${events}${diagnosticEventPath}`;
     this.requests = requests;
     this.crypto = crypto;
   }

packages/shared/sdk-server/src/options/Configuration.ts

@@ -1,5 +1,6 @@
 import {
   ApplicationTags,
+  internal,
   LDClientContext,
   LDLogger,
   NumberWithMinimum,
@@ -209,7 +210,7 @@ export default class Configuration {
 
   public readonly bigSegments?: LDBigSegmentsOptions;
 
-  constructor(options: LDOptions = {}) {
+  constructor(options: LDOptions = {}, internalOptions: internal.LDInternalOptions = {}) {
     // The default will handle undefined, but not null.
     // Because we can be called from JS we need to be extra defensive.
     // eslint-disable-next-line no-param-reassign
@@ -228,6 +229,8 @@ export default class Configuration {
       validatedOptions.streamUri,
       validatedOptions.baseUri,
       validatedOptions.eventsUri,
+      internalOptions.analyticsEventPath,
+      internalOptions.diagnosticEventPath,
     );
     this.eventsCapacity = validatedOptions.capacity;
     this.timeout = validatedOptions.timeout;