tests: remove e2e

test/core.int.test.ts

@@ -1,19 +1,21 @@
-import Supergood from '../src';
-import { postEvents, postError } from '../src/api';
-import { initialize } from './json-server-config';
-import { errors } from '../src/constants';
-import { request } from 'undici';
-import { ErrorPayloadType, EventRequestType } from '../src/types';
-import initialDB from './initial-db';
 import http from 'http';
 import fs from 'fs';
 import path from 'path';
 import get from 'lodash.get';
 
 // HTTP libraries
+import { request } from 'undici';
 import superagent from 'superagent';
 import axios from 'axios';
 import fetch from 'node-fetch';
+
+import Supergood from '../src';
+import { postEvents, postError } from '../src/api';
+import { initialize } from './json-server-config';
+import { errors } from '../src/constants';
+import { ErrorPayloadType, EventRequestType } from '../src/types';
+import initialDB from './initial-db';
+
 import { sleep } from '../src/utils';
 
 const base64Regex =
@@ -40,7 +42,19 @@ const defaultConfig = {
 
 let server: http.Server;
 
-beforeAll(async () => {
+const getEvents = (mockedPostEvents: jest.Mock): Array<EventRequestType> => {
+  return Object.values(
+    mockedPostEvents.mock.calls.flat()[1] as EventRequestType
+  );
+};
+
+const getErrors = (mockedPostError: jest.Mock): ErrorPayloadType => {
+  return Object.values(
+    mockedPostError.mock.calls.flat()
+  )[1] as ErrorPayloadType;
+};
+
+const resetDatabase = () => {
   fs.writeFileSync(
     path.join(__dirname, 'db.json'),
     JSON.stringify(initialDB, null, 2),
@@ -49,33 +63,21 @@ beforeAll(async () => {
       flag: 'w'
     }
   );
+};
+
+beforeAll(async () => {
+  resetDatabase();
   server = await initialize();
 });
 
 afterAll(async () => {
   server.close();
-  fs.writeFileSync(
-    path.join(__dirname, 'db.json'),
-    JSON.stringify(initialDB, null, 2),
-    {
-      encoding: 'utf8',
-      flag: 'w'
-    }
-  );
+  resetDatabase();
 });
 
-const getEvents = (mockedPostEvents: jest.Mock): Array<EventRequestType> =>
-  Object.values(mockedPostEvents.mock.calls.flat()[1] as EventRequestType);
-
-const getErrors = (mockedPostError: jest.Mock): ErrorPayloadType => {
-  return Object.values(
-    mockedPostError.mock.calls.flat()
-  )[1] as ErrorPayloadType;
-};
-
 jest.mock('../src/api', () => ({
-  postEvents: jest.fn(async (eventSinkUrl, data) => ({ data })),
-  postError: jest.fn(async (errorSinkUrl, payload) => ({
+  postEvents: jest.fn(async (_, data) => ({ data })),
+  postError: jest.fn(async (_, payload) => ({
     payload
   }))
 }));
@@ -171,7 +173,7 @@ describe('testing failure states', () => {
     await axios.get(`${HTTP_OUTBOUND_TEST_SERVER}/posts`);
     await Supergood.close();
     const postedErrors = getErrors(postError as jest.Mock);
-    expect(postError as jest.Mock).toBeCalled();
+    expect(postError as jest.Mock).toHaveBeenCalled();
     expect(postedErrors.message).toEqual(errors.POSTING_EVENTS);
   });
 });
@@ -498,7 +500,9 @@ describe('local client id and secret', () => {
   });
 });
 
-xdescribe('testing openAI', () => {
+// node 14 fails due to AbortController not being supported
+// need to figure out why it is not get caught by the agent
+describe.skip('testing openAI', () => {
   test('simple chat completion call being logged', async () => {
     /* eslint-disable-next-line @typescript-eslint/no-var-requires */
     const OpenAI = require('openai');