feat(reportingLogger): Add 'rokt-account-id' header and update constructor to accept accountId, with corresponding test adjustments

Author: gtamanaha

src/logging/reportingLogger.ts

@@ -19,6 +19,7 @@ export class ReportingLogger implements IReportingLogger {
     constructor(
         mpInstance: IMParticleWebSDKInstance,
         private readonly sdkVersion: string,
+        private readonly accountId: string,
         rateLimiter?: IRateLimiter,
     ) {
         this.mpInstance = mpInstance;
@@ -121,6 +122,7 @@ export class ReportingLogger implements IReportingLogger {
             headers: {
                 Accept: 'text/plain;charset=UTF-8',
                 'Content-Type': 'text/plain;charset=UTF-8',
+                'rokt-account-id': this.accountId
             },
             body: JSON.stringify(logRequest),
         });

src/uploaders.ts

@@ -5,6 +5,7 @@ export interface IFetchPayload {
     headers: {
         Accept: string;
         'Content-Type'?: string;
+        'rokt-account-id'?: string;
     };
     body?: string;
 }

test/jest/reportingLogger.spec.ts

@@ -7,7 +7,7 @@ describe('ReportingLogger', () => {
     let logger: ReportingLogger;
     const sdkVersion = '1.2.3';
     let mockFetch: jest.Mock;
-
+    const accountId = '1234567890';
     beforeEach(() => {
         mockFetch = jest.fn().mockResolvedValue({ ok: true });
         global.fetch = mockFetch;
@@ -36,7 +36,7 @@ describe('ReportingLogger', () => {
             ROKT_DOMAIN: 'set',
             fetch: mockFetch
         });
-        logger = new ReportingLogger(mpInstance, sdkVersion);
+        logger = new ReportingLogger(mpInstance, sdkVersion, accountId);
     });
 
     afterEach(() => {
@@ -67,27 +67,28 @@ describe('ReportingLogger', () => {
         expect(body).toMatchObject({
             severity: LogRequestSeverity.Warning
         });
+        expect(fetchCall[1].headers['rokt-account-id']).toBe(accountId);
     });
 
     it('does not log if ROKT_DOMAIN missing', () => {
         delete (globalThis as any).ROKT_DOMAIN;
-        logger = new ReportingLogger(mpInstance, sdkVersion);
+        logger = new ReportingLogger(mpInstance, sdkVersion, accountId);
         logger.error('x');
         expect(mockFetch).not.toHaveBeenCalled();
     });
 
     it('does not log if feature flag and debug mode off', () => {
         window.mParticle.config.isWebSdkLoggingEnabled = false;
         window.location.search = '';
-        logger = new ReportingLogger(mpInstance, sdkVersion);
+        logger = new ReportingLogger(mpInstance, sdkVersion, accountId);
         logger.error('x');
         expect(mockFetch).not.toHaveBeenCalled();
     });
 
     it('logs if debug mode on even if feature flag off', () => {
         window.mParticle.config.isWebSdkLoggingEnabled = false;
         window.location.search = '?mp_enable_logging=true';
-        logger = new ReportingLogger(mpInstance, sdkVersion);
+        logger = new ReportingLogger(mpInstance, sdkVersion, accountId);
         logger.error('x');
         expect(mockFetch).toHaveBeenCalled();
     });
@@ -99,7 +100,7 @@ describe('ReportingLogger', () => {
                 return ++count > 3;
             }),
         };
-        logger = new ReportingLogger(mpInstance, sdkVersion, mockRateLimiter);
+        logger = new ReportingLogger(mpInstance, sdkVersion, accountId, mockRateLimiter);
 
         for (let i = 0; i < 5; i++) logger.error('err');
         expect(mockFetch).toHaveBeenCalledTimes(3);