Add Prisma and new folder structure

.prettierrc

@@ -1,5 +1,5 @@
 {
-  "semi": false,
+  "semi": true,
   "trailingComma": "es5",
   "singleQuote": true
 }

api/.eslintrc.json

@@ -2,11 +2,19 @@
   "parserOptions": {
     "sourceType": "module"
   },
-  "rules": {
-    "strict": ["error", "never"]
-  },
   "globals": {
+    "api": "readonly",
     "db": "readonly",
-    "common": "readonly"
+    "crud": "readonly",
+    "common": "readonly",
+    "domain": "readonly",
+    "lib": "readonly",
+    "context": "readonly",
+    "config": "readonly",
+    "metarhia": "readonly"
+  },
+  "rules": {
+    "strict": ["error", "never"],
+    "id-denylist": [2, "api", "db", "common", "console"]
   }
 }

api/user.js

@@ -1,28 +1,7 @@
-module.exports = ({ db, common }) => {
-  const user = db('users')
-
-  return {
-    async read(id) {
-      return await user.read(id, ['id', 'login'])
-    },
-
-    async create({ login, password }) {
-      const passwordHash = await common.hash(password)
-      return await user.create({ login, password: passwordHash })
-    },
-
-    async update(id, { login, password }) {
-      const passwordHash = await common.hash(password)
-      return await user.update(id, { login, password: passwordHash })
-    },
-
-    async delete(id) {
-      return await user.delete(id)
-    },
-
-    async find(mask) {
-      const sql = 'SELECT login from users where login like $1'
-      return await user.query(sql, [mask])
-    },
-  }
-}
+({
+  ...crud('user'),
+  read: async () => {
+    console.warn('🚨 This is a warning');
+    return await await db.user.findMany();
+  },
+});

config/index.js

@@ -0,0 +1,22 @@
+module.exports = {
+  db: {
+    url: 'postgresql://marcus:marcus@localhost:5432/example',
+  },
+  api: {
+    path: './api',
+    port: 8001,
+    transport: 'ws',
+  },
+  static: {
+    port: 8000,
+  },
+  load: {
+    timeout: 5000,
+    displayErrors: false,
+  },
+  logger: { name: 'winston', fsPath: './logs', console: true },
+  sandbox: {
+    timeout: 5000,
+    displayErrors: false,
+  },
+};

lib/db/crud.js

@@ -0,0 +1,35 @@
+const { PrismaClient } = require('@prisma/client');
+
+const prisma = new PrismaClient();
+
+const crud = (model) => ({
+  async read(id) {
+    if (!id) {
+      return await prisma[model].findMany();
+    }
+    return prisma[model].findUnique({
+      where: { id },
+    });
+  },
+
+  async create(record) {
+    return prisma[model].create({
+      data: record,
+    });
+  },
+
+  async update(id, record) {
+    return prisma[model].update({
+      where: { id },
+      data: record,
+    });
+  },
+
+  async delete(id) {
+    return prisma[model].delete({
+      where: { id },
+    });
+  },
+});
+
+module.exports = crud;

lib/db/start.js

@@ -0,0 +1,14 @@
+'use strict';
+
+/**
+ * @typedef { import("@prisma/client").User} User
+ */
+const { PrismaClient } = require('@prisma/client');
+
+const start = async (config) => {
+  const prisma = new PrismaClient({ datasourceUrl: config.url });
+  await prisma.$connect();
+  return prisma;
+};
+
+module.exports = start;

logger/pino.js → lib/logger/pino.js

@@ -1,12 +1,12 @@
-const pino = require('pino')
+const pino = require('pino');
 
 module.exports = (config) => {
-  const targets = []
+  const targets = [];
   if (config.console) {
     targets.push({
       level: 'trace',
       target: 'pino-pretty',
-    })
+    });
   }
   if (config.fsPath) {
     targets.push({
@@ -15,26 +15,26 @@ module.exports = (config) => {
       options: {
         destination: `${config.fsPath}/${config.name}/combined.log`,
       },
-    })
+    });
   }
   const transport = pino.transport({
     targets,
-  })
-  const logger = pino(transport)
+  });
+  const logger = pino(transport);
 
   return {
     log(...args) {
       // TODO: issue https://github.com/pinojs/pino-pretty/issues/455
-      logger.info(...args)
+      logger.info(...args);
     },
     info(...args) {
-      logger.info(...args)
+      logger.info(...args);
     },
     warn(...args) {
-      logger.warn(...args)
+      logger.warn(...args);
     },
     error(...args) {
-      logger.error(...args)
+      logger.error(...args);
     },
-  }
-}
+  };
+};