ci: add github actions workflow

.eslintrc.json

@@ -1,3 +1,15 @@
 {
-    "extends": "airbnb-base"
+    "env": {
+        "es2022": true,
+        "node": true
+    },
+    "extends": "airbnb-base",
+    "overrides": [
+    ],
+    "parserOptions": {
+        "ecmaVersion": "latest",
+        "sourceType": "module"
+    },
+    "rules": {
+    }
 }

.github/workflows/test.yml

@@ -0,0 +1,76 @@
+name: Node.js CI
+
+on:
+  push:
+    branches: [ "master" ]
+  pull_request:
+    branches: [ "master" ]
+
+jobs:
+  build:
+
+    runs-on: ubuntu-latest
+
+    strategy:
+      matrix:
+        node-version: [18.x, 19.x, 20.x]
+        # See supported Node.js release schedule at https://nodejs.org/en/about/releases/
+
+    services:
+      mssql:
+        image: mcr.microsoft.com/mssql/server
+        env:
+          ACCEPT_EULA: Y
+          SA_PASSWORD: integrator!23
+        ports:
+          - 1433:1433
+        options: >-
+          --name=mssql
+          --health-cmd="/opt/mssql-tools/bin/sqlcmd -S localhost -U SA -P 'integrator!23' -Q 'SELECT 1'"
+          --health-interval=10s
+          --health-timeout=5s
+          --health-retries=3
+
+      postgres:
+        image: postgres
+        env:
+          POSTGRES_USER: integrator
+          POSTGRES_DB: integrator
+          POSTGRES_PASSWORD: integrator!23
+        ports:
+          - 5432:5432
+        options: >-
+          --health-cmd pg_isready
+          --health-interval 10s
+          --health-timeout 5s
+          --health-retries 5
+      mysql:
+        image: bitnami/mysql:8.0.33
+        env:
+          MYSQL_ROOT_PASSWORD: integrator!23
+          MYSQL_USER: integrator
+          MYSQL_PASSWORD: integrator!23
+          MYSQL_DATABASE: integrator
+          MYSQL_AUTHENTICATION_PLUGIN: mysql_native_password
+        ports:
+          - 3306:3306
+        options: >-
+          --health-cmd "mysqladmin ping"
+          --health-interval 10s
+          --health-timeout 5s
+          --health-retries 10
+
+    steps:
+    - name: Checkout
+      uses: actions/checkout@v3
+    - name: Use Node.js ${{ matrix.node-version }}
+      uses: actions/setup-node@v3
+      with:
+        node-version: ${{ matrix.node-version }}
+        cache: 'npm'
+    - name: Install dependencies
+      run: npm ci
+    # - name: Lint code
+    #   run: npm run lint
+    - name: Run tests
+      run: npm test

__tests__/AdapterFactory.test.js

@@ -0,0 +1,41 @@
+import { describe, it } from 'node:test';
+import assert from 'node:assert';
+import CsvAdapter from '../src/Adapters/Csv.js';
+import HttpAdapter from '../src/Adapters/Http.js';
+import AdapterFactory from '../src/AdapterFactory.js';
+import DatabaseAdapter from '../src/Adapters/Database.js';
+
+describe('Adapter Factory', () => {
+  it('It creates database adapter', async () => {
+    const adapter = AdapterFactory({
+      type: 'database',
+      options: {
+        client: 'sqlite',
+      },
+    });
+
+    assert.equal(adapter instanceof DatabaseAdapter, true);
+  });
+
+  it('It creates csv adapter', async () => {
+    const adapter = AdapterFactory({
+      type: 'csv',
+      options: {
+        path: 'my-fake-file',
+      },
+    });
+
+    assert.equal(adapter instanceof CsvAdapter, true);
+  });
+
+  it('It creates http adapter', async () => {
+    const adapter = AdapterFactory({
+      type: 'http',
+      options: {
+        url: 'http://api.com/users',
+      },
+    });
+
+    assert.equal(adapter instanceof HttpAdapter, true);
+  });
+});

__tests__/Adapters/Csv.test.js

@@ -0,0 +1,84 @@
+import fs from 'node:fs';
+import {
+  describe, it, beforeEach, afterEach,
+} from 'node:test';
+import assert from 'node:assert';
+import path from 'path';
+import Csv from '../../src/Adapters/Csv.js';
+
+function deleteDir(pathName) {
+  fs.rmSync(path.resolve(pathName), { recursive: true, force: true });
+}
+
+describe('Csv Adapter', () => {
+  beforeEach(() => {
+    deleteDir('./__tests__/fixtures/tmp');
+    fs.mkdirSync(path.resolve('./__tests__/fixtures/tmp'));
+  });
+  afterEach(() => deleteDir('./__tests__/fixtures/tmp'));
+
+  it('Requires argument for Csv Adapter', () => {
+    assert.throws(() => {
+      const adapter = new Csv();
+      assert.ok(adapter);
+    }, new Error('It\'s required to provide options for the integration'));
+  });
+
+  it('Requires path on options for Csv Adapter', async () => {
+    assert.throws(() => {
+      const adapter = new Csv({
+        //
+      });
+      assert.ok(adapter);
+    }, new Error('It\'s required to provide a file for the csv file'));
+  });
+
+  it('It fetches the records', async () => {
+    const adapter = new Csv({
+      path: path.resolve('./__tests__/fixtures/users.csv'),
+    });
+
+    const result = await adapter.fetch();
+
+    assert.deepEqual(result, [
+      {
+        name: 'John',
+        email: 'johndoe@example.com',
+      },
+    ]);
+  });
+
+  it('It fetches specified columns for the records', async () => {
+    const adapter = new Csv({
+      path: path.resolve('./__tests__/fixtures/users.csv'),
+      columns: [
+        'email',
+      ],
+    });
+
+    const result = await adapter.fetch();
+
+    assert.deepEqual(result, [
+      {
+        email: 'johndoe@example.com',
+      },
+    ]);
+  });
+
+  it('It writes the records', async () => {
+    const adapter = new Csv({
+      path: path.resolve('./__tests__/fixtures/tmp/users.csv'),
+    });
+
+    await adapter.write([
+      {
+        name: 'John',
+        email: 'johndoe@example.com',
+      },
+    ]);
+
+    const result = fs.readFileSync(path.resolve('./__tests__/fixtures/tmp/users.csv'), 'utf-8');
+
+    assert.deepEqual(result, 'name;email\nJohn;johndoe@example.com\n');
+  });
+});