Merge pull request #44 from oslabs-beta/dev

Dev

Author: matthewxing1

.github/workflows/integration-tests.yml

@@ -0,0 +1,52 @@
+# This is a basic workflow to help you get started with Actions
+
+name: Integration-Tests
+
+# Controls when the workflow will run
+on:
+  # Triggers the workflow on push or pull request events but only for the "master" branch
+  push:
+    branches: 
+    - ms/**
+    - gb/**
+    - jl/**
+    - mx/**
+    - ja/**
+  pull_request:
+    branches: 
+    - dev
+
+# A workflow run is made up of one or more jobs that can run sequentially or in parallel
+jobs:
+  # This workflow contains a single job called "build"
+  build:
+    # The type of runner that the job will run on
+    runs-on: ubuntu-latest
+    timeout-minutes: 3
+
+    # Steps represent a sequence of tasks that will be executed as part of the job
+    steps:
+      # Checks-out your repository under $GITHUB_WORKSPACE, so your job can access it
+      - uses: actions/checkout@v3
+
+      - name: Start Containers
+        run: docker-compose -f "docker-compose.yml" up -d --build
+      
+      - name: Install node
+        uses: actions/setup-node@v1
+        with:
+          node-version: 16.x
+
+      - name: Install dependencies
+        run: npm install
+
+      - name: Sleep for 30 seconds
+        run: sleep 30s
+        shell: bash
+
+      - name: Run tests
+        run: npm run test
+
+      - name: Stop containers
+        if: always()
+        run: docker-compose -f "docker-compose.yml" down

.gitignore

@@ -103,5 +103,10 @@ dist
 # TernJS port file
 .tern-port
 
+# Local
+ksqljsTest.js
+package-lock.json
+local_ignore/
+.gitignore
 
 

__tests__/integrationtests.js

@@ -1,4 +1,3 @@
-const { default: waitForExpect } = require('wait-for-expect');
 const ksqldb = require('../ksqldb/ksqldb');
 // Pre-requisite: start a docker container
 /* To add to README: Prior to running test with 'npm test', please start the ksqlDB

ksqldb/customErrors.js

@@ -10,12 +10,13 @@ class ksqlDBError extends Error {
 
     // Ensure the name of this error is the same as the class name
     this.name = this.constructor.name
-
+    
     // capturing the stack trace keeps the reference to your error class
     Error.captureStackTrace(this, this.constructor);
-
+    
     // you may also assign additional properties to your error
     //this.status = 404
+    Object.keys(error).forEach(property => {this[property] = error[property]});
   }
 }
 
@@ -46,10 +47,22 @@ class InappropriateStringParamError extends QueryBuilderError {
   }
 }
 
+class invalidArgumentTypes extends Error {
+  constructor(message) {
+    super(message);
+
+    this.name = this.constructor.name;
+    // necessary?
+    Error.captureStackTrace(this, this.constructor);
+
+  }
+}
+
 module.exports = {
   ksqlDBError,
   QueryBuilderError,
   EmptyQueryError,
   NumParamsError,
-  InappropriateStringParamError
+  InappropriateStringParamError,
+  invalidArgumentTypes
 };