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' }]);
});