snowplow-javascript-tracker/libraries/tracker-core/test/event_store.test.ts at plugin-element-tracking · jethron/snowplow-javascript-tracker · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
import test from 'ava';

import { newInMemoryEventStore } from '../src/event_store';
import { newEventStorePayload } from '../src/event_store_payload';

test('count returns the number of events', async (t) => {
  const eventStore = newInMemoryEventStore({});

  t.is(await eventStore.add(newEventStorePayload({ payload: { e: 'pv' } })), 1);
  t.is(await eventStore.add(newEventStorePayload({ payload: { e: 'pv' } })), 2);
  t.is(await eventStore.count(), 2);
});

test('iterator returns all events', async (t) => {
  const eventStore = newInMemoryEventStore({});
  await eventStore.add(newEventStorePayload({ payload: { e: 'pv' } }));
  await eventStore.add(newEventStorePayload({ payload: { e: 'pv' } }));

  const iterator = eventStore.iterator();
  const { value: first } = await iterator.next();
  const { value: second } = await iterator.next();
  const { done } = await iterator.next();

  t.deepEqual(first?.payload, { e: 'pv' });
  t.deepEqual(second?.payload, { e: 'pv' });
  t.true(done);
});

test('removeHead removes the first n events', async (t) => {
  const eventStore = newInMemoryEventStore({});
  await eventStore.add(newEventStorePayload({ payload: { e: 'pv' } }));
  await eventStore.add(newEventStorePayload({ payload: { e: 'pv' } }));

  await eventStore.removeHead(1);

  t.is(await eventStore.count(), 1);
});

test('removeHead does nothing when there are no events', async (t) => {
  const eventStore = newInMemoryEventStore({});
  await eventStore.removeHead(1);

  t.is(await eventStore.count(), 0);
});

test('does not exceed maxSize', async (t) => {
  const eventStore = newInMemoryEventStore({ maxSize: 1 });
  await eventStore.add(newEventStorePayload({ payload: { e: 'pv1' } }));
  await eventStore.add(newEventStorePayload({ payload: { e: 'pv2' } }));

  t.is(await eventStore.count(), 1);
  t.is((await eventStore.iterator().next()).value?.payload.e, 'pv2');
});

test('iterator does not consider mutations', async (t) => {
  const eventStore = newInMemoryEventStore({});
  await eventStore.add(newEventStorePayload({ payload: { e: 'pv' } }));

  const iterator = eventStore.iterator();
  await iterator.next();

  await eventStore.add(newEventStorePayload({ payload: { e: 'pv' } }));

  const { value } = await iterator.next();

  t.is(value, undefined);
});

test('stores server anonymization setting', async (t) => {
  const eventStore = newInMemoryEventStore({});
  await eventStore.add(newEventStorePayload({ payload: { e: 'pv' }, svrAnon: true }));
  await eventStore.add(newEventStorePayload({ payload: { e: 'pv' }, svrAnon: false }));
  await eventStore.add(newEventStorePayload({ payload: { e: 'pv' } }));

  t.is(await eventStore.count(), 3);
  const iterator = eventStore.iterator();
  const first = await iterator.next();
  const second = await iterator.next();
  const third = await iterator.next();

  t.true(first?.value?.svrAnon);
  t.false(second?.value?.svrAnon);
  t.false(third?.value?.svrAnon);
});

test('getAllPayloads returns all payloads', async (t) => {
  const eventStore = newInMemoryEventStore({});
  await eventStore.add(newEventStorePayload({ payload: { e: 'pv' } }));
  await eventStore.add(newEventStorePayload({ payload: { e: 'pv' } }));

  t.deepEqual(await eventStore.getAllPayloads(), [{ e: 'pv' }, { e: 'pv' }]);
});