Package containing tracking logic reused between multiple Schibsted niche sites. 

Package containing tracking logic reused between multiple Schibsted niche sites

gustavkj

joawan

pakerstrand

schibstedbot

filipgolonka

spp-owner

mike-dvtka

rodbiffi

@schibsted/niche-tracking

import { eventTarget } from '@schibsted/niche-utils';

        this.eventTarget.dispatchEvent(new CustomEvent('initialized'));

    constructor({ enabled, trackers, trackersConfig, pageViewTrackerMappers, eventTrackerMappers, pageLeaveTrackerMappers, }) {

        this._eventTarget = getEventTarget();

        this.pageView = (type, payload) => {

            this._lastPageViewEventData = {};

                .filter((tracker) => { var _a, _b; return (_b = (_a = this._pageViewTrackerMappers) === null || _a === void 0 ? void 0 : _a[type]) === null || _b === void 0 ? void 0 : _b[tracker.name]; })

                    const getTrackerOptions = (_b = (_a = this._pageViewTrackerMappers) === null || _a === void 0 ? void 0 : _a[type]) === null || _b === void 0 ? void 0 : _b[tracker.name];

                    trackerOptions = getTrackerOptions === null || getTrackerOptions === void 0 ? void 0 : getTrackerOptions(payload);

                    console.error(`[${tracker.name}] Page view mapper for ${type} failed`, err);

                if (this._enabled && !skip) {

                    this._lastPageViewEventData[tracker.name] = trackerOptions;

                    if (this._initialized) {

                            tracker.pageView(trackerOptions);

                            // updates page leave tracking

                            if (this._pageLeaveTrackingActive) {

                                const { type: leaveType, activeElement, options } = this._pageLeaveTrackingActive;

                                (_c = tracker.updatePageLeaveTracking) === null || _c === void 0 ? void 0 : _c.call(tracker, activeElement, () => {

                                    var _a, _b, _c;

                                    const getTrackerOptions = (_b = (_a = this._pageLeaveTrackerMappers) === null || _a === void 0 ? void 0 : _a[leaveType]) === null || _b === void 0 ? void 0 : _b[tracker.name];

                                    return getTrackerOptions === null || getTrackerOptions === void 0 ? void 0 : getTrackerOptions(options, (_c = this._lastPageViewEventData) === null || _c === void 0 ? void 0 : _c[tracker.name]);

                        this._queue.push(() => tracker.pageView(trackerOptions));

        this.event = (type, payload) => {

                .filter((tracker) => { var _a, _b; return (_b = (_a = this._eventTrackerMappers) === null || _a === void 0 ? void 0 : _a[type]) === null || _b === void 0 ? void 0 : _b[tracker.name]; })

                    const getTrackerOptions = (_b = (_a = this._eventTrackerMappers) === null || _a === void 0 ? void 0 : _a[type]) === null || _b === void 0 ? void 0 : _b[tracker.name];

                    trackerOptions = getTrackerOptions === null || getTrackerOptions === void 0 ? void 0 : getTrackerOptions(payload, (_c = this._lastPageViewEventData) === null || _c === void 0 ? void 0 : _c[tracker.name]);

                    console.error(`[${tracker.name}] Event mapper for ${type} failed`, err);

                    const hasOptions = Array.isArray(trackerOptions) && trackerOptions.length === 2;

                    const eventArgs = hasOptions ? trackerOptions : [trackerOptions];

                            // eslint-disable-next-line @typescript-eslint/ban-ts-comment

                            // @ts-ignore

                            (_d = tracker.event) === null || _d === void 0 ? void 0 : _d.call(tracker, ...eventArgs);

                        // eslint-disable-next-line @typescript-eslint/ban-ts-comment

                        this._queue.push(() => { var _a; return (_a = tracker.event) === null || _a === void 0 ? void 0 : _a.call(tracker, ...eventArgs); });

        /** Creates event but waits with sending it until next pageView invocation. */

                this._initialized = true;

                return Promise.resolve();

            return Promise.all(this._trackers.map((tracker) => tracker

                .initialize(Object.assign(Object.assign({}, this._trackersConfig[tracker.name]), { userId,

                console.error(`[${tracker.name}] Initialization failed`, err);

                this.eventTarget.dispatchEvent(new Event('initialized'));

                while (this._queue.length) {

                    const queuedJob = this._queue.shift();

                        const result = queuedJob === null || queuedJob === void 0 ? void 0 : queuedJob();

                        if (isPromise(result)) {

                            result === null || result === void 0 ? void 0 : result.catch(() => {

                                // ignore

                if (this._pageLeaveQueue) {

                    this._pageLeaveQueue();

                    this._pageLeaveQueue = null;

        this.addPageLeaveTracking = (type, activeElement, payload) => {

                this._pageLeaveTrackingActive = {

                    .filter((tracker) => tracker.addPageLeaveTracking)

                    .filter((tracker) => { var _a, _b; return (_b = (_a = this._pageLeaveTrackerMappers) === null || _a === void 0 ? void 0 : _a[type]) === null || _b === void 0 ? void 0 : _b[tracker.name]; })

                    .forEach((tracker) => {

                        (_a = tracker.addPageLeaveTracking) === null || _a === void 0 ? void 0 : _a.call(tracker, activeElement, () => {

                            var _a, _b, _c;

                                const getTrackerOptions = (_b = (_a = this._pageLeaveTrackerMappers) === null || _a === void 0 ? void 0 : _a[type]) === null || _b === void 0 ? void 0 : _b[tracker.name];

                                return getTrackerOptions === null || getTrackerOptions === void 0 ? void 0 : getTrackerOptions(payload, (_c = this._lastPageViewEventData) === null || _c === void 0 ? void 0 : _c[tracker.name]);

                            catch (err) {

                                console.error(`[${tracker.name}] Article leave mapper failed`, err);

                                return {};

                this._pageLeaveQueue = () => this.addPageLeaveTracking(type, activeElement, payload);

        this.trackActivePageLeave = (type, eventName) => {

                    .filter((tracker) => tracker.trackActivePageLeave)

                        (_a = tracker.trackActivePageLeave) === null || _a === void 0 ? void 0 : _a.call(tracker, eventName);

            this._pageLeaveTrackingActive = undefined;

        this.waitForInitialization = () => new Promise((resolve) => {

                this.eventTarget.addEventListener('initialized', () => {

        this._trackersConfig = trackersConfig;

        this._pageViewTrackerMappers = pageViewTrackerMappers;

        this._eventTrackerMappers = eventTrackerMappers;

        this._pageLeaveTrackerMappers = pageLeaveTrackerMappers;

        this._trackers.forEach((tracker) => {

    "description": "Package containing tracking logic reused between multiple Schibsted niche sites",

        "dev": "rimraf lib && tsc --watch",

        "lint": "eslint --ext .js,.ts,.tsx ./src",

        "@schibsted/niche-utils": "^0.4.2"

    "gitHead": "ae51183e8bb79ff2bd5bcbf30510a8e0fe8ed643"

    "gitHead": "14eeb683631c309d243151af24e55eda749a54ad"

import type { Mappers, Experiment, SingleTracker, EventMappers, TrackersConfig } from './types';

    // eslint-disable-next-line @typescript-eslint/no-explicit-any

    PageViewEventMapper extends Record<PageViewEventType, any>,

    EventTypesMapper extends Record<EventType, any>,

    PageLeaveEventTypeMapper extends Record<PageLeaveEventType, any>

    private set initialized(newState: boolean) {

    private _eventTarget: EventTarget = getEventTarget();

    private _pageViewTrackerMappers: Mappers<PageViewEventMapper[PageViewEventType]>;

    private _eventTrackerMappers: EventMappers<EventTypesMapper[EventType]>;

    private _pageLeaveTrackerMappers: EventMappers<PageLeaveEventTypeMapper[PageLeaveEventType]>;

    private _pageLeaveTrackingActive: any;

    private _queue: (() => void | Promise<void>)[] = [];

    private _pageLeaveQueue: (() => void) | null = null;

        pageViewTrackerMappers: Mappers<PageViewEventMapper[PageViewEventType]>;

        eventTrackerMappers: EventMappers<EventTypesMapper[EventType]>;

        pageLeaveTrackerMappers: EventMappers<PageLeaveEventTypeMapper[PageLeaveEventType]>;

    pageView = <T extends PageViewEventType>(type: T, payload?: PageViewEventMapper[T]) => {

        this._lastPageViewEventData = {};

            .filter((tracker) => this._pageViewTrackerMappers?.[type]?.[tracker.name])

                    const getTrackerOptions = this._pageViewTrackerMappers?.[type]?.[tracker.name];

                    trackerOptions = getTrackerOptions?.(payload);

            this._trackers.map((tracker) =>

                        ...this._trackersConfig[tracker.name],

                    .catch((err: Error) => {

                        console.error(`[${tracker.name}] Initialization failed`, err);

            this.eventTarget.dispatchEvent(new Event('initialized'));

                const queuedJob = this._queue.shift();

                    const result = queuedJob?.();

                    if (isPromise(result)) {

                        result?.catch(() => {

                this._pageLeaveQueue = null;

                    tracker.setUserId?.(userId);

                this._queue.push(() => tracker.setUserId?.(userId));

    addPageLeaveTracking = <T extends PageLeaveEventType>(

        payload: PageLeaveEventTypeMapper[T]

            this._pageLeaveTrackingActive = {

                .filter((tracker) => tracker.addPageLeaveTracking)

                .filter((tracker) => this._pageLeaveTrackerMappers?.[type]?.[tracker.name])

                        tracker.addPageLeaveTracking?.(activeElement, () => {

                                const getTrackerOptions = this._pageLeaveTrackerMappers?.[type]?.[tracker.name];

                                return getTrackerOptions?.(payload, this._lastPageViewEventData?.[tracker.name]);

                            } catch (err) {

            this._pageLeaveQueue = () => this.addPageLeaveTracking(type, activeElement, payload);

    trackActivePageLeave = (type: string, eventName: string) => {

                .filter((tracker) => tracker.trackActivePageLeave)

                        tracker.trackActivePageLeave?.(eventName);

        this._pageLeaveTrackingActive = undefined;

		@@ -143,2 +143,3 @@ import { eventTarget } from '@schibsted/niche-utils';
		if (!this._enabled) {
		this._initialized = true;
		return Promise.resolve();
		@@ -153,3 +154,2 @@ }
		this.initialized = true;
		this.eventTarget.dispatchEvent(new Event('initialized'));
		while (this._queue.length) {
		@@ -156,0 +156,0 @@ const queuedJob = this._queue.shift();

		@@ -204,2 +204,4 @@ import { eventTarget } from '@schibsted/niche-utils';
		if (!this._enabled) {
		this._initialized = true;

		return Promise.resolve();
		@@ -222,3 +224,2 @@ }
		this.initialized = true;
		this.eventTarget.dispatchEvent(new Event('initialized'));

		@@ -225,0 +226,0 @@ while (this._queue.length) {

		{
		"name": "@schibsted/niche-tracking",
		"version": "4.6.7",
		"version": "4.6.8",
		"description": "Package containing tracking logic reused between multiple Schibsted niche sites",
		@@ -26,3 +26,3 @@ "main": "lib/index.js",
		},
		"gitHead": "ae51183e8bb79ff2bd5bcbf30510a8e0fe8ed643"
		"gitHead": "14eeb683631c309d243151af24e55eda749a54ad"
		}

Worsened metrics