Package maitenance

.github/workflows/test.yml

@@ -1,7 +1,5 @@
 name: Testing CI
-
 on: pull_request
-
 jobs:
   build:
     runs-on: ubuntu-latest
@@ -12,13 +10,13 @@ jobs:
           - 18
           - 20
           - 21
+          - 22
     services:
       postgres:
         image: postgres
         env:
           POSTGRES_PASSWORD: postgres
         options: --health-cmd pg_isready --health-interval 10s --health-timeout 5s --health-retries 5
-
     steps:
       - uses: actions/checkout@v2
       - uses: actions/cache@v2

eslint.config.js

@@ -0,0 +1,15 @@
+'use strict';
+
+const init = require('eslint-config-metarhia');
+
+module.exports = [
+  ...init,
+  {
+    files: ['lib/plugins/*.js'],
+    languageOptions: {
+      globals: {
+        db: true,
+      },
+    },
+  },
+];

lib/plugins/crud.js

@@ -7,31 +7,36 @@ module.exports = (init) => () => {
   for (const [entity, methods] of Object.entries(entities)) {
     if (methods.includes('create')) {
       unit['create' + entity] = (context) => async (record) => {
+        if (!context) throw new Error('Cant execute CREATE');
         const result = await database.insert(entity, record);
         return { result };
       };
     }
     if (methods.includes('get')) {
       unit['get' + entity] = (context) => async (conditions) => {
+        if (!context) throw new Error('Cant execute GET');
         const result = await database.row(entity, conditions);
         return { result };
       };
     }
     if (methods.includes('select')) {
       unit['select' + entity] = (context) => async (conditions) => {
+        if (!context) throw new Error('Cant execute SELECT');
         const result = await database.select(entity, conditions);
         return { result };
       };
     }
     if (methods.includes('update')) {
       unit['update' + entity] = (context) => async (args) => {
+        if (!context) throw new Error('Cant execute UPDATE');
         const { delta, conditions } = args;
         const result = await database.update(entity, delta, conditions);
         return { result };
       };
     }
     if (methods.includes('delete')) {
       unit['delete' + entity] = (context) => async (conditions) => {
+        if (!context) throw new Error('Cant execute DELETE');
         const result = await database.delete(entity, conditions);
         return { result };
       };