import nock from 'nock';
import { vi } from 'vitest';
import {InternalConfig} from '../config/configure';
import {ApiV3} from '../lib/ApiV3';
import {ReachabilityUpdate} from '../Types';
import {getReachability, updateReachability} from './reachability';
import deepFreeze from 'deep-freeze';

const mockConfiguration: InternalConfig = {
  apiBasePath: 'https://api.zaius.com/v3/',
  apiKey: 'api-key',
};

let apiV3: ApiV3.API;

describe('reachability', () => {
  describe('updateReachability', () => {
    beforeAll(() => {
      apiV3 = new ApiV3.API(mockConfiguration);
    });

    it('sends a post to /reachability', async () => {
      const update: ReachabilityUpdate = Object.freeze({
        identifier_field_name: 'email',
        identifier_value: 'foo@optimizely.com',
        reachable: false,
        reachable_update_reason: 'hard_bounce',
      });
      nock('https://api.zaius.com')
        .post('/v3/reachability', [update] as any)
        .reply(200, '{}');
      await updateReachability(apiV3, update);
      expect(nock.isDone()).toBeTruthy();
    });

    it('handles multiple updates', async () => {
      const update = deepFreeze([
        {
          identifier_field_name: 'email',
          identifier_value: 'foo@optimizely.com',
          reachable: false,
          reachable_update_reason: 'hard_bounce',
        },
        {
          identifier_field_name: 'email',
          identifier_value: 'bar@optimizely.com',
          reachable: true,
          reachable_update_reason: 'hard_bounce',
        },
      ]) as ReachabilityUpdate[];
      nock('https://api.zaius.com')
        .post('/v3/reachability', update as any)
        .reply(200, '{}');
      await updateReachability(apiV3, update);
      expect(nock.isDone()).toBeTruthy();
    });

    it('throws an error if the api returns an error', async () => {
      const update: ReachabilityUpdate = {
        identifier_field_name: 'email',
        identifier_value: 'foo@optimizely.com',
        reachable: false,
      };
      nock('https://api.zaius.com')
        .post('/v3/reachability', [update] as any)
        .reply(400, '{}');
      await expect(updateReachability(apiV3, update)).rejects.toThrowError('Bad Request');
      expect(nock.isDone()).toBeTruthy();
    });

    it('throws an error if the batch is too large', async () => {
      const updates = Array(101).fill({
        identifier_field_name: 'email',
        identifier_value: 'foo@optimizely.com',
        reachable: true,
      });
      await expect(updateReachability(apiV3, updates)).rejects.toThrowError('maximum batch size');
    });

    it('converts date if provided as a Date object', async () => {
      vi.spyOn(Date.prototype, 'getTime').mockReturnValueOnce(1579648074373);
      const update: ReachabilityUpdate = Object.freeze({
        identifier_field_name: 'email',
        identifier_value: 'foo@optimizely.com',
        reachable: false,
        reachable_update_reason: 'preference center update',
        reachable_update_ts: new Date(),
      });
      const expectedUpdate: ReachabilityUpdate = {
        ...update,
        reachable_update_ts: 1579648074,
      };
      nock('https://api.zaius.com')
        .post('/v3/reachability', [expectedUpdate] as any)
        .reply(200, '{}');
      await updateReachability(apiV3, update);
      expect(nock.isDone()).toBeTruthy();
    });

    it('converts date if provided as an string', async () => {
      vi.spyOn(Date.prototype, 'getTime').mockReturnValueOnce(1579648074373);
      const update: ReachabilityUpdate = Object.freeze({
        identifier_field_name: 'email',
        identifier_value: 'foo@optimizely.com',
        reachable: false,
        reachable_update_reason: 'preference center update',
        reachable_update_ts: '2020-01-21T23:07:54.373Z',
      });
      const expectedUpdate: ReachabilityUpdate = {
        ...update,
        reachable_update_ts: 1579648074,
      };
      nock('https://api.zaius.com')
        .post('/v3/reachability', [expectedUpdate] as any)
        .reply(200, '{}');
      await updateReachability(apiV3, update);
      expect(nock.isDone()).toBeTruthy();
    });
  });

  describe('getReachability', () => {
    it('sends a get to /reachability/{identifier}', async () => {
      nock('https://api.zaius.com').get('/v3/reachability/email?id=foo%40optimizely.com').reply(200, '{}');
      await getReachability(apiV3, 'email', 'foo@optimizely.com');
      expect(nock.isDone()).toBeTruthy();
    });

    it('safely encodes url values', async () => {
      nock('https://api.zaius.com').get('/v3/reachability/em%20ail?id=%22foo%22%40optimizely.com').reply(200, '{}');
      await getReachability(apiV3, 'em ail', '"foo"@optimizely.com');
      expect(nock.isDone()).toBeTruthy();
    });
  });
});