diff --git a/README.md b/README.md
index 7d5bdce..4ede8f4 100644
--- a/README.md
+++ b/README.md
@@ -70,6 +70,10 @@ The SDK exposes the following methods through the `useContentpassSdk` hook:
Initiates the OAuth 2.0 authentication process via a modal interface. It validates the user’s active Contentpass subscriptions
upon successful authentication.
+### countImpression
+Tracks and increments the impression count for the current user. This method should be invoked whenever a user views a
+piece of content. It applies to all users, whether authenticated or unauthenticated.
+
### registerObserver
Registers a callback function to listen for changes in the user’s authentication and subscription status. The observer function
receives a state object describing the current status (see the exported [ContentpassState](./src/types/ContentpassState.ts) type).
@@ -94,6 +98,7 @@ import { Button, View } from 'react-native';
const YourApp = () => {
const {
authenticate,
+ countImpression,
registerObserver,
unregisterObserver,
logout,
@@ -115,6 +120,7 @@ const YourApp = () => {
return (
+
);
};
diff --git a/package.json b/package.json
index 463e184..b6e4e32 100644
--- a/package.json
+++ b/package.json
@@ -150,6 +150,7 @@
"version": "0.44.1"
},
"dependencies": {
- "@sentry/react-native": "^6.3.0"
+ "@sentry/react-native": "^6.3.0",
+ "react-native-uuid": "^2.0.3"
}
}
diff --git a/sharedExample/src/ContentpassUsage.tsx b/sharedExample/src/ContentpassUsage.tsx
index 1168a34..6a49cdf 100644
--- a/sharedExample/src/ContentpassUsage.tsx
+++ b/sharedExample/src/ContentpassUsage.tsx
@@ -93,6 +93,10 @@ export default function ContentpassUsage() {
spConsentManager.current?.loadMessage();
};
+ const countImpression = async () => {
+ await contentpassSdk.countImpression();
+ };
+
return (
<>
@@ -100,6 +104,7 @@ export default function ContentpassUsage() {
title={'Clear sourcepoint data'}
onPress={clearSourcepointData}
/>
+
diff --git a/sharedExample/src/contentpassConfig.ts b/sharedExample/src/contentpassConfig.ts
index 606d83c..68bb9f2 100644
--- a/sharedExample/src/contentpassConfig.ts
+++ b/sharedExample/src/contentpassConfig.ts
@@ -4,9 +4,12 @@ export const contentpassConfig: ContentpassConfig = {
// Testing app
propertyId: 'cc3fc4ad-cbe5-4d09-bf85-a49796603b19',
issuer: 'https://my.contentpass.dev',
+ apiUrl: 'https://cp.cmp-sourcepoint.contenttimes.dev',
// Staging app
// propertyId: '78da2fd3-8b25-4642-b7b7-4a0193d00f89',
// issuer: 'https://my.contentpass.io',
+ // apiUrl: 'cp.cmp-sourcepoint.contenttimes.io',
+ samplingRate: 1,
redirectUrl: 'de.contentpass.demo://oauth',
};
diff --git a/src/Contentpass.test.ts b/src/Contentpass.test.ts
index c2e63e3..7f50dc8 100644
--- a/src/Contentpass.test.ts
+++ b/src/Contentpass.test.ts
@@ -5,14 +5,18 @@ import * as AppAuthModule from 'react-native-app-auth';
import * as OidcAuthStateStorageModule from './OidcAuthStateStorage';
import type { ContentpassState } from './types/ContentpassState';
import OidcAuthStateStorage from './OidcAuthStateStorage';
-import * as FetchContentpassTokenModule from './utils/fetchContentpassToken';
+import * as FetchContentpassTokenModule from './contentpassTokenUtils/fetchContentpassToken';
import { SCOPES } from './consts/oidcConsts';
import * as SentryIntegrationModule from './sentryIntegration';
+import * as SendStatsModule from './countImpressionUtils/sendStats';
+import * as SendPageViewEventModule from './countImpressionUtils/sendPageViewEvent';
const config: ContentpassConfig = {
- propertyId: 'propertyId-1',
+ propertyId: '5803179c-5b9f-40be-9a91-e67e8ea20593',
redirectUrl: 'de.test.net://oauth',
issuer: 'https://issuer.net',
+ apiUrl: 'https://cp.property.com',
+ samplingRate: 1,
};
const NOW = new Date('2024-12-02T11:53:56.272Z').getTime();
@@ -36,6 +40,12 @@ const EXAMPLE_REFRESH_RESULT = {
accessTokenExpirationDate: '2024-12-03T10:00:50Z',
};
+const CONTENTPASS_TOKEN_WITH_PLANS =
+ 'eyJhbGciOiJSUzI1NiIsImtpZCI6IjY5NzUwYTZjLTNmYjctNDUyNi05NWY4LTVhZmYxMmIyZjFjOSJ9.eyJhdXRoIjp0cnVlLCJ0eXBlIjoiY3AiLCJwbGFucyI6WyIwYWNhZTkxNy1iZTk5LTQ4ZWEtYjhmMS0yMGZhNjhhNDdkM2EiLCI0NDIxNjI4Yy05NjA2LTRjMDEtOGU1ZC1jMmE5YmNhNjhhYjQiLCI3ZThkZTBjYy0zZTk3LTQ5YTItODgxZC05ZmZiNWI4NDE1MTUiLCJhNDcyMWRiNS02N2RmLTQxNDUtYmJiZi1jYmQwOWY3ZTAzOTciLCJjNGQzYjBmNS05ODlhLTRmN2ItOGFjNy0zZDhmZmE5NTcxN2YiLCI2NGRkOTkwNS05NmUxLTRmYjItOTgwZC01MDdmMTYzNzVmZTkiXSwiYXVkIjoiY2MzZmM0YWQiLCJpYXQiOjE3MzMxMzU2ODEsImV4cCI6MTczMzMxMjA4MX0.CMtH7HRLf2HVgw3_cZRN0en8tml_SQKM73iLGJAp72-vJuRJaq85xBp6Jgy9WD3L7x4itRlBAYZxX8tLxZGogU0WP4_dMGFQ2QlcwKshwJygwRM1YqvxGWX2Az_KxEMc2QGHvpE1qe2MAr_xOU7VFfc0-vWxFc3hRzpAM5j7YHctj2t1v6h9-M7V2Hkcn37569QmtgU8gJkUxXsgUTufbb1ikjjjAvnjvTluHJo51_utbimpUbCk3EFxXVCVEI_pAqiZQXNninUQ6dbSujLb3L2UlEdQzLeUiBdYroeFzSyruLrR841ledLQ5ZP2OqzF5oUMuAGVOOhmgGdwGMCDRQ';
+
+export const CONTENTPASS_TOKEN_WITHOUT_PLANS =
+ 'eyJhbGciOiJSUzI1NiIsImtpZCI6IjY5NzUwYTZjLTNmYjctNDUyNi05NWY4LTVhZmYxMmIyZjFjOSJ9.eyJhdXRoIjp0cnVlLCJ0eXBlIjoiY3AiLCJwbGFucyI6W10sImF1ZCI6ImNjM2ZjNGFkIiwiaWF0IjoxNzMzMTM1NjgxLCJleHAiOjE3MzMzMTIwODF9.CMtH7HRLf2HVgw3_cZRN0en8tml_SQKM73iLGJAp72-vJuRJaq85xBp6Jgy9WD3L7x4itRlBAYZxX8tLxZGogU0WP4_dMGFQ2QlcwKshwJygwRM1YqvxGWX2Az_KxEMc2QGHvpE1qe2MAr_xOU7VFfc0-vWxFc3hRzpAM5j7YHctj2t1v6h9-M7V2Hkcn37569QmtgU8gJkUxXsgUTufbb1ikjjjAvnjvTluHJo51_utbimpUbCk3EFxXVCVEI_pAqiZQXNninUQ6dbSujLb3L2UlEdQzLeUiBdYroeFzSyruLrR841ledLQ5ZP2OqzF5oUMuAGVOOhmgGdwGMCDRQ';
+
describe('Contentpass', () => {
let contentpass: Contentpass;
let authorizeSpy: jest.SpyInstance;
@@ -43,6 +53,8 @@ describe('Contentpass', () => {
let reportErrorSpy: jest.SpyInstance;
let fetchContentpassTokenSpy: jest.SpyInstance;
let oidcAuthStorageMock: OidcAuthStateStorage;
+ let sendStatsSpy: jest.SpyInstance;
+ let sendPageViewEventSpy: jest.SpyInstance;
beforeEach(() => {
jest.useFakeTimers({ now: NOW });
@@ -68,9 +80,15 @@ describe('Contentpass', () => {
fetchContentpassTokenSpy = jest
.spyOn(FetchContentpassTokenModule, 'default')
- .mockResolvedValue(
- 'eyJhbGciOiJSUzI1NiIsImtpZCI6IjY5NzUwYTZjLTNmYjctNDUyNi05NWY4LTVhZmYxMmIyZjFjOSJ9.eyJhdXRoIjp0cnVlLCJ0eXBlIjoiY3AiLCJwbGFucyI6WyIwYWNhZTkxNy1iZTk5LTQ4ZWEtYjhmMS0yMGZhNjhhNDdkM2EiLCI0NDIxNjI4Yy05NjA2LTRjMDEtOGU1ZC1jMmE5YmNhNjhhYjQiLCI3ZThkZTBjYy0zZTk3LTQ5YTItODgxZC05ZmZiNWI4NDE1MTUiLCJhNDcyMWRiNS02N2RmLTQxNDUtYmJiZi1jYmQwOWY3ZTAzOTciLCJjNGQzYjBmNS05ODlhLTRmN2ItOGFjNy0zZDhmZmE5NTcxN2YiLCI2NGRkOTkwNS05NmUxLTRmYjItOTgwZC01MDdmMTYzNzVmZTkiXSwiYXVkIjoiY2MzZmM0YWQiLCJpYXQiOjE3MzMxMzU2ODEsImV4cCI6MTczMzMxMjA4MX0.CMtH7HRLf2HVgw3_cZRN0en8tml_SQKM73iLGJAp72-vJuRJaq85xBp6Jgy9WD3L7x4itRlBAYZxX8tLxZGogU0WP4_dMGFQ2QlcwKshwJygwRM1YqvxGWX2Az_KxEMc2QGHvpE1qe2MAr_xOU7VFfc0-vWxFc3hRzpAM5j7YHctj2t1v6h9-M7V2Hkcn37569QmtgU8gJkUxXsgUTufbb1ikjjjAvnjvTluHJo51_utbimpUbCk3EFxXVCVEI_pAqiZQXNninUQ6dbSujLb3L2UlEdQzLeUiBdYroeFzSyruLrR841ledLQ5ZP2OqzF5oUMuAGVOOhmgGdwGMCDRQ'
- );
+ .mockResolvedValue(CONTENTPASS_TOKEN_WITH_PLANS);
+
+ sendStatsSpy = jest
+ .spyOn(SendStatsModule, 'default')
+ .mockResolvedValue({ ok: true } as any);
+
+ sendPageViewEventSpy = jest
+ .spyOn(SendPageViewEventModule, 'default')
+ .mockResolvedValue({ ok: true } as any);
contentpass = new Contentpass(config);
});
@@ -82,6 +100,24 @@ describe('Contentpass', () => {
});
describe('constructor', () => {
+ it('should throw an error if sampling rate is not between 0 and 1', () => {
+ expect(
+ () =>
+ new Contentpass({
+ ...config,
+ samplingRate: -1,
+ })
+ ).toThrow('Sampling rate must be between 0 and 1');
+
+ expect(
+ () =>
+ new Contentpass({
+ ...config,
+ samplingRate: 2,
+ })
+ ).toThrow('Sampling rate must be between 0 and 1');
+ });
+
it('should initialise contentpass state', () => {
const contentpassStates: ContentpassState[] = [];
contentpass.registerObserver((state) => {
@@ -137,9 +173,9 @@ describe('Contentpass', () => {
expect(refreshSpy).toHaveBeenCalledTimes(1);
expect(refreshSpy).toHaveBeenCalledWith(
{
- clientId: 'propertyId-1',
- redirectUrl: 'de.test.net://oauth',
- issuer: 'https://issuer.net',
+ clientId: config.propertyId,
+ redirectUrl: config.redirectUrl,
+ issuer: config.issuer,
scopes: SCOPES,
},
{ refreshToken: EXAMPLE_AUTH_RESULT.refreshToken }
@@ -158,13 +194,13 @@ describe('Contentpass', () => {
expect(authorizeSpy).toHaveBeenCalledWith({
additionalParameters: {
- cp_property: 'propertyId-1',
+ cp_property: config.propertyId,
cp_route: 'login',
prompt: 'consent',
},
- clientId: 'propertyId-1',
- issuer: 'https://issuer.net',
- redirectUrl: 'de.test.net://oauth',
+ clientId: config.propertyId,
+ issuer: config.issuer,
+ redirectUrl: config.redirectUrl,
scopes: ['openid', 'offline_access', 'contentpass'],
});
});
@@ -248,9 +284,9 @@ describe('Contentpass', () => {
expect(refreshSpy).toHaveBeenCalledTimes(1);
expect(refreshSpy).toHaveBeenCalledWith(
{
- clientId: 'propertyId-1',
- redirectUrl: 'de.test.net://oauth',
- issuer: 'https://issuer.net',
+ clientId: config.propertyId,
+ redirectUrl: config.redirectUrl,
+ issuer: config.issuer,
scopes: SCOPES,
},
{ refreshToken: EXAMPLE_AUTH_RESULT.refreshToken }
@@ -436,4 +472,78 @@ describe('Contentpass', () => {
});
});
});
+
+ describe('countImpression', () => {
+ it('should count paid impression if user has valid subscription and access token', async () => {
+ await contentpass.authenticate();
+
+ await contentpass.countImpression();
+
+ expect(sendPageViewEventSpy).toHaveBeenCalledWith(config.apiUrl, {
+ propertyId: config.propertyId,
+ impressionId: expect.any(String),
+ accessToken: EXAMPLE_AUTH_RESULT.accessToken,
+ });
+ expect(sendStatsSpy).toHaveBeenCalled();
+ });
+
+ it('should not count paid impression if user is authenticated, but does not have valid subscription', async () => {
+ fetchContentpassTokenSpy.mockResolvedValue(
+ CONTENTPASS_TOKEN_WITHOUT_PLANS
+ );
+ await contentpass.authenticate();
+
+ await contentpass.countImpression();
+
+ expect(sendPageViewEventSpy).not.toHaveBeenCalled();
+ expect(sendStatsSpy).toHaveBeenCalled();
+ });
+
+ it('should report error if counting paid impression fails', async () => {
+ await contentpass.authenticate();
+
+ const error = new Error('Send page view event error');
+ sendPageViewEventSpy.mockRejectedValue(error);
+
+ await contentpass.countImpression();
+
+ expect(reportErrorSpy).toHaveBeenCalledWith(error, {
+ msg: 'Failed to count paid impression',
+ });
+ expect(sendStatsSpy).toHaveBeenCalled();
+ });
+
+ it('should count sampled impression even if user does not have valid subscription', async () => {
+ await contentpass.countImpression();
+
+ expect(sendPageViewEventSpy).not.toHaveBeenCalled();
+ expect(sendStatsSpy).toHaveBeenCalledWith(config.apiUrl, {
+ cpabid: expect.any(String),
+ cppid: '5803179c',
+ cpsr: config.samplingRate,
+ ea: 'load',
+ ec: 'tcf-sampled',
+ });
+ });
+
+ it('should report error if counting sampled impression fails', async () => {
+ const error = new Error('Send stats error');
+ sendStatsSpy.mockRejectedValue(error);
+
+ await contentpass.countImpression();
+
+ expect(reportErrorSpy).toHaveBeenCalledWith(error, {
+ msg: 'Failed to count sampled impression',
+ });
+ });
+
+ it('should not send sampled impression when generatedSample is higher than samplingRate', async () => {
+ jest.spyOn(Math, 'random').mockReturnValue(0.5);
+ contentpass = new Contentpass({ ...config, samplingRate: 0.4 });
+
+ await contentpass.countImpression();
+ expect(sendStatsSpy).not.toHaveBeenCalled();
+ expect(sendPageViewEventSpy).not.toHaveBeenCalled();
+ });
+ });
});
diff --git a/src/Contentpass.ts b/src/Contentpass.ts
index 413e1d0..d1a613e 100644
--- a/src/Contentpass.ts
+++ b/src/Contentpass.ts
@@ -1,3 +1,4 @@
+import uuid from 'react-native-uuid';
import OidcAuthStateStorage, {
type OidcAuthState,
} from './OidcAuthStateStorage';
@@ -12,16 +13,31 @@ import {
} from 'react-native-app-auth';
import { REFRESH_TOKEN_RETRIES, SCOPES } from './consts/oidcConsts';
import { RefreshTokenStrategy } from './types/RefreshTokenStrategy';
-import fetchContentpassToken from './utils/fetchContentpassToken';
-import validateSubscription from './utils/validateSubscription';
+import fetchContentpassToken from './contentpassTokenUtils/fetchContentpassToken';
+import validateSubscription from './contentpassTokenUtils/validateSubscription';
import type { ContentpassConfig } from './types/ContentpassConfig';
import { reportError, setSentryExtraAttribute } from './sentryIntegration';
+import sendStats from './countImpressionUtils/sendStats';
+import sendPageViewEvent from './countImpressionUtils/sendPageViewEvent';
+
+const DEFAULT_SAMPLING_RATE = 0.05;
export type ContentpassObserver = (state: ContentpassState) => void;
-export default class Contentpass {
+interface ContentpassInterface {
+ authenticate: () => Promise;
+ registerObserver: (observer: ContentpassObserver) => void;
+ unregisterObserver: (observer: ContentpassObserver) => void;
+ logout: () => Promise;
+ recoverFromError: () => Promise;
+ countImpression: () => Promise;
+}
+
+export default class Contentpass implements ContentpassInterface {
private authStateStorage: OidcAuthStateStorage;
private readonly config: ContentpassConfig;
+ private readonly samplingRate: number;
+ private readonly instanceId: string;
private contentpassState: ContentpassState = {
state: ContentpassStateType.INITIALISING,
@@ -31,6 +47,14 @@ export default class Contentpass {
private refreshTimer: NodeJS.Timeout | null = null;
constructor(config: ContentpassConfig) {
+ if (
+ config.samplingRate &&
+ (config.samplingRate < 0 || config.samplingRate > 1)
+ ) {
+ throw new Error('Sampling rate must be between 0 and 1');
+ }
+ this.samplingRate = config.samplingRate || DEFAULT_SAMPLING_RATE;
+ this.instanceId = uuid.v4();
this.authStateStorage = new OidcAuthStateStorage(config.propertyId);
this.config = config;
setSentryExtraAttribute('propertyId', config.propertyId);
@@ -96,6 +120,49 @@ export default class Contentpass {
await this.initialiseAuthState();
};
+ public countImpression = async () => {
+ if (this.hasValidSubscriptionAndAccessToken()) {
+ try {
+ await this.countPaidImpression();
+ } catch (err: any) {
+ reportError(err, { msg: 'Failed to count paid impression' });
+ }
+ }
+
+ try {
+ await this.countSampledImpression();
+ } catch (err: any) {
+ reportError(err, { msg: 'Failed to count sampled impression' });
+ }
+ };
+
+ private countPaidImpression = async () => {
+ const impressionId = uuid.v4();
+
+ await sendPageViewEvent(this.config.apiUrl, {
+ propertyId: this.config.propertyId,
+ impressionId,
+ accessToken: this.oidcAuthState!.accessToken,
+ });
+ };
+
+ private countSampledImpression = async () => {
+ const generatedSample = Math.random();
+ const publicId = this.config.propertyId.slice(0, 8);
+
+ if (generatedSample >= this.samplingRate) {
+ return;
+ }
+
+ await sendStats(this.config.apiUrl, {
+ ea: 'load',
+ ec: 'tcf-sampled',
+ cpabid: this.instanceId,
+ cppid: publicId,
+ cpsr: this.samplingRate,
+ });
+ };
+
private initialiseAuthState = async () => {
const authState = await this.authStateStorage.getOidcAuthState();
if (authState) {
@@ -208,4 +275,12 @@ export default class Contentpass {
this.contentpassState = state;
this.contentpassStateObservers.forEach((observer) => observer(state));
};
+
+ private hasValidSubscriptionAndAccessToken = () => {
+ return (
+ this.contentpassState.state === ContentpassStateType.AUTHENTICATED &&
+ this.contentpassState.hasValidSubscription &&
+ this.oidcAuthState?.accessToken
+ );
+ };
}
diff --git a/src/utils/fetchContentpassToken.test.ts b/src/contentpassTokenUtils/fetchContentpassToken.test.ts
similarity index 67%
rename from src/utils/fetchContentpassToken.test.ts
rename to src/contentpassTokenUtils/fetchContentpassToken.test.ts
index 2430f61..069b412 100644
--- a/src/utils/fetchContentpassToken.test.ts
+++ b/src/contentpassTokenUtils/fetchContentpassToken.test.ts
@@ -8,6 +8,7 @@ describe('fetchContentpassToken', () => {
it('should return the contentpass token', async () => {
jest.spyOn(global, 'fetch').mockResolvedValue({
+ ok: true,
json: jest
.fn()
.mockResolvedValue({ contentpass_token: 'example_contentpass_token' }),
@@ -31,4 +32,19 @@ describe('fetchContentpassToken', () => {
}
);
});
+
+ it('should throw an error if the fetch fails', async () => {
+ jest.spyOn(global, 'fetch').mockResolvedValue({
+ ok: false,
+ statusText: 'Not Found',
+ } as any);
+
+ await expect(async () => {
+ await fetchContentpassToken({
+ idToken: '123456',
+ propertyId: '987654321',
+ issuer: 'https://issuer.com',
+ });
+ }).rejects.toThrow('Failed to fetch Contentpass token, status: Not Found');
+ });
});
diff --git a/src/utils/fetchContentpassToken.ts b/src/contentpassTokenUtils/fetchContentpassToken.ts
similarity index 80%
rename from src/utils/fetchContentpassToken.ts
rename to src/contentpassTokenUtils/fetchContentpassToken.ts
index 1bc23ba..7c68f96 100644
--- a/src/utils/fetchContentpassToken.ts
+++ b/src/contentpassTokenUtils/fetchContentpassToken.ts
@@ -21,6 +21,12 @@ export default async function fetchContentpassToken({
}).toString(),
});
+ if (!tokenEndpointResponse.ok) {
+ throw new Error(
+ `Failed to fetch Contentpass token, status: ${tokenEndpointResponse.statusText}`
+ );
+ }
+
const { contentpass_token } = await tokenEndpointResponse.json();
return contentpass_token;
diff --git a/src/utils/parseContentpassToken.test.ts b/src/contentpassTokenUtils/parseContentpassToken.test.ts
similarity index 100%
rename from src/utils/parseContentpassToken.test.ts
rename to src/contentpassTokenUtils/parseContentpassToken.test.ts
diff --git a/src/utils/parseContentpassToken.ts b/src/contentpassTokenUtils/parseContentpassToken.ts
similarity index 100%
rename from src/utils/parseContentpassToken.ts
rename to src/contentpassTokenUtils/parseContentpassToken.ts
diff --git a/src/utils/validateSubscription.test.ts b/src/contentpassTokenUtils/validateSubscription.test.ts
similarity index 100%
rename from src/utils/validateSubscription.test.ts
rename to src/contentpassTokenUtils/validateSubscription.test.ts
diff --git a/src/utils/validateSubscription.ts b/src/contentpassTokenUtils/validateSubscription.ts
similarity index 100%
rename from src/utils/validateSubscription.ts
rename to src/contentpassTokenUtils/validateSubscription.ts
diff --git a/src/countImpressionUtils/sendPageViewEvent.test.ts b/src/countImpressionUtils/sendPageViewEvent.test.ts
new file mode 100644
index 0000000..bd81d0c
--- /dev/null
+++ b/src/countImpressionUtils/sendPageViewEvent.test.ts
@@ -0,0 +1,43 @@
+import sendPageViewEvent from './sendPageViewEvent';
+
+describe('sendPageViewEvent', () => {
+ const apiUrl = 'https://api.example.com';
+ const payload = {
+ propertyId: 'property123',
+ impressionId: 'impression456',
+ accessToken: 'token789',
+ };
+
+ afterEach(() => {
+ jest.resetAllMocks();
+ jest.restoreAllMocks();
+ });
+
+ it('should send a page view event successfully', async () => {
+ jest.spyOn(global, 'fetch').mockResolvedValue({
+ ok: true,
+ } as any);
+
+ const response = await sendPageViewEvent(apiUrl, payload);
+
+ expect(response.ok).toBe(true);
+ expect(global.fetch).toHaveBeenCalledWith(
+ `${apiUrl}/pass/hit?pid=${payload.propertyId}&iid=${payload.impressionId}&t=pageview`,
+ {
+ headers: {
+ Authorization: `Bearer ${payload.accessToken}`,
+ },
+ }
+ );
+ });
+
+ it('should throw an error if the fetch fails', async () => {
+ jest.spyOn(global, 'fetch').mockResolvedValue({
+ ok: false,
+ } as any);
+
+ await expect(sendPageViewEvent(apiUrl, payload)).rejects.toThrow(
+ 'Failed send page view event'
+ );
+ });
+});
diff --git a/src/countImpressionUtils/sendPageViewEvent.ts b/src/countImpressionUtils/sendPageViewEvent.ts
new file mode 100644
index 0000000..40cae54
--- /dev/null
+++ b/src/countImpressionUtils/sendPageViewEvent.ts
@@ -0,0 +1,27 @@
+type HitEndpointArgs = {
+ propertyId: string;
+ impressionId: string;
+ accessToken: string;
+};
+
+export default async function sendPageViewEvent(
+ apiUrl: string,
+ payload: HitEndpointArgs
+) {
+ const { propertyId, impressionId, accessToken } = payload;
+ const path = `pass/hit?pid=${propertyId}&iid=${impressionId}&t=pageview`;
+
+ const response = await fetch(`${apiUrl}/${path}`, {
+ headers: {
+ Authorization: `Bearer ${accessToken}`,
+ },
+ });
+
+ if (!response.ok) {
+ throw new Error(
+ `Failed send page view event, status: ${response.statusText}`
+ );
+ }
+
+ return response;
+}
diff --git a/src/countImpressionUtils/sendStats.test.ts b/src/countImpressionUtils/sendStats.test.ts
new file mode 100644
index 0000000..a847635
--- /dev/null
+++ b/src/countImpressionUtils/sendStats.test.ts
@@ -0,0 +1,44 @@
+import sendStats from './sendStats';
+
+describe('sendStats', () => {
+ const apiUrl = 'https://api.example.com';
+ const payload = {
+ ea: 'eventAction',
+ ec: 'eventCategory',
+ cpabid: 'cpabid123',
+ cppid: 'cppid456',
+ cpsr: 1,
+ };
+
+ afterEach(() => {
+ jest.resetAllMocks();
+ jest.restoreAllMocks();
+ });
+
+ it('should send stats successfully', async () => {
+ jest.spyOn(global, 'fetch').mockResolvedValue({
+ ok: true,
+ } as any);
+
+ const response = await sendStats(apiUrl, payload);
+
+ expect(response.ok).toBe(true);
+ expect(global.fetch).toHaveBeenCalledWith(`${apiUrl}/stats`, {
+ method: 'POST',
+ headers: {
+ 'Content-Type': 'application/json; charset=UTF-8',
+ },
+ body: JSON.stringify(payload),
+ });
+ });
+
+ it('should throw an error if the fetch fails', async () => {
+ jest.spyOn(global, 'fetch').mockResolvedValue({
+ ok: false,
+ } as any);
+
+ await expect(sendStats(apiUrl, payload)).rejects.toThrow(
+ 'Failed to send stats'
+ );
+ });
+});
diff --git a/src/countImpressionUtils/sendStats.ts b/src/countImpressionUtils/sendStats.ts
new file mode 100644
index 0000000..2932b15
--- /dev/null
+++ b/src/countImpressionUtils/sendStats.ts
@@ -0,0 +1,23 @@
+type StatsPayload = {
+ ea: string;
+ ec: string;
+ cpabid: string;
+ cppid: string;
+ cpsr: number;
+};
+
+export default async function sendStats(apiUrl: string, payload: StatsPayload) {
+ const response = await fetch(`${apiUrl}/stats`, {
+ method: 'POST',
+ headers: {
+ 'Content-Type': 'application/json; charset=UTF-8',
+ },
+ body: JSON.stringify(payload),
+ });
+
+ if (!response.ok) {
+ throw new Error(`Failed to send stats, status: ${response.statusText}`);
+ }
+
+ return response;
+}
diff --git a/src/sdkContext/ContentpassSdkProvder.test.tsx b/src/sdkContext/ContentpassSdkProvder.test.tsx
index f80f8b9..c502b8f 100644
--- a/src/sdkContext/ContentpassSdkProvder.test.tsx
+++ b/src/sdkContext/ContentpassSdkProvder.test.tsx
@@ -11,6 +11,7 @@ describe('ContentpassSdkProvider', () => {
issuer: 'https://my.contentpass.me',
propertyId: 'my-property-id',
redirectUrl: 'de.contentpass.test://oauth',
+ apiUrl: 'https://cp.propert.com',
};
afterEach(() => {
diff --git a/src/types/ContentpassConfig.ts b/src/types/ContentpassConfig.ts
index 03dacd6..b44f7ce 100644
--- a/src/types/ContentpassConfig.ts
+++ b/src/types/ContentpassConfig.ts
@@ -4,4 +4,6 @@ export type ContentpassConfig = {
propertyId: string;
redirectUrl: string;
issuer: string;
+ apiUrl: string;
+ samplingRate?: number;
};
diff --git a/yarn.lock b/yarn.lock
index d4a03c9..39ce116 100644
--- a/yarn.lock
+++ b/yarn.lock
@@ -1844,6 +1844,7 @@ __metadata:
react-native-app-auth: ^8.0.0
react-native-builder-bob: ^0.32.1
react-native-encrypted-storage: ^4.0.3
+ react-native-uuid: ^2.0.3
react-test-renderer: 18.3.1
release-it: ^17.10.0
turbo: ^1.10.7
@@ -12587,6 +12588,13 @@ __metadata:
languageName: node
linkType: hard
+"react-native-uuid@npm:^2.0.3":
+ version: 2.0.3
+ resolution: "react-native-uuid@npm:2.0.3"
+ checksum: e47774481feaed5d38f75fb4b03f5189c03e7452038f1b0fa56677add8a8bdef64ec7ad5e83f9fa761d8788cac5c8e554ade07e82a2818145337df7c883e2124
+ languageName: node
+ linkType: hard
+
"react-native@npm:0.76.2":
version: 0.76.2
resolution: "react-native@npm:0.76.2"