fetch.test.ts

import { Helpers } from '@secret-agent/testing';
import { ITestKoaServer } from '@secret-agent/testing/helpers';
import { Handler } from '../index';

let koaServer: ITestKoaServer;
let handler: Handler;
beforeAll(async () => {
  handler = new Handler();
  Helpers.onClose(() => handler.close(), true);
  koaServer = await Helpers.runKoaServer();
});
afterAll(Helpers.afterAll);
afterEach(Helpers.afterEach);

describe('Fetch tests', () => {
  it('should be able to fetch from top level', async () => {
    const agent = await handler.createAgent();
    Helpers.needsClosing.push(agent);

    await expect(agent.fetch('https://dataliberationfoundation.org')).rejects.toThrowError(
      'need to use a "goto"',
    );
  });

  it('should be able to run a fetch from the browser', async () => {
    koaServer.get('/fetch', ctx => {
      ctx.body = { got: 'it' };
    });
    const agent = await handler.createAgent();
    Helpers.needsClosing.push(agent);

    await agent.goto(`${koaServer.baseUrl}/`);
    await agent.waitForPaintingStable();
    const result = await agent.fetch('/fetch');
    const json = await result.json();
    expect(json).toStrictEqual({ got: 'it' });
  });

  it('should be able to do an http post', async () => {
    let posted: string;
    koaServer.post('/post', async ctx => {
      let body = '';
      for await (const chunk of ctx.req) {
        body += chunk.toString();
      }
      posted = body;

      ctx.body = { got: '2' };
    });
    const agent = await handler.createAgent();

    await agent.goto(`${koaServer.baseUrl}/`);
    await agent.waitForPaintingStable();

    const response = await agent.fetch(`${koaServer.baseUrl}/post`, {
      method: 'post',
      headers: {
        Accept: 'application/json',
        'Content-Type': 'application/json',
      },
      body: JSON.stringify({ sent: 'it' }),
    });

    expect(await response.json()).toStrictEqual({ got: '2' });
    expect(posted).toStrictEqual(JSON.stringify({ sent: 'it' }));
  });

  it('should be able to create a request object', async () => {
    let header1: string;
    koaServer.get('/request', ctx => {
      header1 = ctx.headers.header1 as string;

      ctx.body = { got: 'request' };
    });
    const agent = await handler.createAgent();

    await agent.goto(`${koaServer.baseUrl}/`);
    await agent.waitForPaintingStable();

    const { Request, fetch } = agent;
    const request = new Request(`${koaServer.baseUrl}/request`, {
      headers: {
        header1: 'sent',
      },
    });

    const response = await fetch(request);

    expect(await response.json()).toStrictEqual({ got: 'request' });
    expect(header1).toBe('sent');
  });

  it('should be able to get a byte array back', async () => {
    koaServer.get('/buffer', ctx => {
      ctx.body = Buffer.from('This is a test');
    });
    const agent = await handler.createAgent();

    await agent.goto(`${koaServer.baseUrl}/`);
    await agent.waitForPaintingStable();

    const response = await agent.fetch(`${koaServer.baseUrl}/buffer`);

    const buff = await response.arrayBuffer();

    expect(Buffer.from(buff)).toStrictEqual(Buffer.from('This is a test'));
  });

  it.todo('should be able to get a blob back');
});