packages/pass/lib/b2b/b2b.dispatcher.ts

   1 import { sendB2BEventsBundle } from '@proton/pass/lib/b2b/b2b.requests';
   2 import type { AnyStorage } from '@proton/pass/types';
   3 import type { B2BEvent } from '@proton/pass/types/data/b2b';
   4 import type { EventDispatcher, EventDispatcherAlarm } from '@proton/pass/utils/event/dispatcher';
   5 import { createEventDispatcher } from '@proton/pass/utils/event/dispatcher';
   6 import { UNIX_HOUR, UNIX_MINUTE } from '@proton/pass/utils/time/constants';
   7 import { getEpoch } from '@proton/pass/utils/time/epoch';
   8
   9 type B2BDispatcherOptions<StorageKey extends string> = {
  10     alarm: EventDispatcherAlarm;
  11     storage: AnyStorage<Record<StorageKey, string>>;
  12     getEnabled: () => boolean;
  13     getStorageKey: () => StorageKey;
  14 };
  15
  16 export const createB2BEventDispatcher = <StorageKey extends string>({
  17     alarm,
  18     storage,
  19     getEnabled,
  20     getStorageKey,
  21 }: B2BDispatcherOptions<StorageKey>) =>
  22     createEventDispatcher<B2BEvent, StorageKey>({
  23         id: 'B2BEvents',
  24         alarm,
  25         maxRetries: 3,
  26         storage,
  27         dispatch: sendB2BEventsBundle,
  28         getEnabled,
  29         getSendTime: () => getEpoch() + (ENV === 'production' ? UNIX_HOUR : UNIX_MINUTE),
  30         getStorageKey,
  31     });
  32
  33 export type B2BEventDispatcher = EventDispatcher<B2BEvent>;