Backport app from metarhia/Example

tshemsedinov · tshemsedinov · commit f7ee20b04f37 · 2020-09-27T12:14:23.000+03:00
PR-URL: #184
diff --git a/application/api/auth.1/register.js b/application/api/auth.1/register.js
diff --git a/application/api/auth.1/signIn.js b/application/api/auth.1/signIn.js
diff --git a/application/api/auth.1/status.js b/application/api/auth.1/status.js
diff --git a/application/api/cms.1/.eslintrc.json b/application/api/cms.1/.eslintrc.json
@@ -0,0 +1,13 @@
+{
+  "rules": {
+    "strict": [
+      "error",
+      "never"
+    ]
+  },
+  "globals": {
+    "application": "readonly",
+    "context": "readonly",
+    "api": "readonly"
+  }
+}
diff --git a/application/api/cms.1/about.js b/application/api/cms.1/about.js
diff --git a/application/api/example.1/citiesByCountry.js b/application/api/example.1/citiesByCountry.js
@@ -1,6 +1,6 @@
 async ({ countryId }) => {
   const fields = ['Id', 'Name'];
   const where = { countryId };
-  const data = await application.db.select('City', fields, where);
+  const data = await domain.database.example.select('City', fields, where);
   return { result: 'success', data };
 };
diff --git a/application/api/example.1/counter.js b/application/api/example.1/counter.js
diff --git a/application/api/example.1/countries.js b/application/api/example.1/countries.js
@@ -1,5 +1,5 @@
 async () => {
   const fields = ['Id', 'Name'];
-  const data = await application.db.select('Country', fields);
+  const data = await domain.database.example.select('Country', fields);
   return { result: 'success', data };
 };
diff --git a/application/api/example.1/error.js b/application/api/example.1/error.js
@@ -0,0 +1 @@
+async () => new Error('Hello!', 54321);
diff --git a/application/api/example.1/exception.js b/application/api/example.1/exception.js
@@ -0,0 +1,3 @@
+async () => {
+  throw new Error('Hello', 12345);
+};
diff --git a/application/api/example.1/getUndefined.js b/application/api/example.1/getUndefined.js
@@ -0,0 +1 @@
+async () => undefined;
diff --git a/application/api/example.1/remoteMethod.js b/application/api/example.1/remoteMethod.js
@@ -0,0 +1,7 @@
+({
+  access: 'public',
+  method: async ({ ...args }) => {
+    console.debug({ remoteMethod: args });
+    return { result: 'success' };
+  }
+});
diff --git a/application/api/example.1/resources.js b/application/api/example.1/resources.js
@@ -0,0 +1,9 @@
+async () => {
+  const loadavg = node.os.loadavg();
+  const stats = lib.resmon.getStatistics();
+  const { heapTotal, heapUsed, external, contexts } = stats;
+  const total = lib.utils.bytesToSize(heapTotal);
+  const used = lib.utils.bytesToSize(heapUsed);
+  const ext = lib.utils.bytesToSize(external);
+  return { total, used, ext, contexts, loadavg };
+};
diff --git a/application/api/example.1/subscribe.js b/application/api/example.1/subscribe.js
@@ -0,0 +1,7 @@
+async () => {
+  setInterval(() => {
+    const stats = lib.resmon.getStatistics();
+    context.client.emit('example/resmon', stats);
+  }, config.resmon.interval);
+  return { subscribed: 'resmon' };
+};
diff --git a/application/api/example.1/uploadFile.js b/application/api/example.1/uploadFile.js
@@ -0,0 +1,9 @@
+async ({ name, data }) => {
+  const buffer = Buffer.from(data, 'base64');
+  const tmpPath = 'application/tmp';
+  const filePath = node.path.join(tmpPath, name);
+  if (filePath.startsWith(tmpPath)) {
+    await node.fsp.writeFile(filePath, buffer);
+  }
+  return { uploaded: data.length };
+};
diff --git a/application/api/example.1/wait.js b/application/api/example.1/wait.js
@@ -0,0 +1,3 @@
+async ({ delay }) => new Promise(resolve => {
+  setTimeout(resolve, delay, 'done');
+});
diff --git a/application/api/example.1/webHook.js b/application/api/example.1/webHook.js
@@ -0,0 +1,7 @@
+({
+  access: 'public',
+  method: async ({ ...args }) => {
+    console.debug({ webHook: args });
+    return { result: 'success' };
+  }
+});
diff --git a/application/api/introspection.js b/application/api/introspection.js
diff --git a/application/api/resmon.js b/application/api/resmon.js
diff --git a/application/api/system.1/introspect.js b/application/api/system.1/introspect.js
@@ -0,0 +1,4 @@
+({
+  access: 'public',
+  method: application.introspect
+});
diff --git a/application/cert/generate.sh b/application/cert/generate.sh
@@ -1,29 +1,5 @@
-#!/bin/sh
-
 cd "$(dirname "$0")"
-
-KEY_FILE=key.pem
-if [ -f "$KEY_FILE" ]; then
-  read -e -p "Are you sure you want to replace existing key? [y/N] " YES_NO
-  if [ "$YES_NO" != "y" ] && [ "$YES_NO" != "Y" ]; then
-    exit 0
-  fi
-fi
-
-if [ "$1" == "secure" ]; then
-  echo "Generating private ed25519 key"
-  openssl genpkey -algorithm ed25519 -out $KEY_FILE
-else
-  echo "Generating private RSA3072 key"
-  openssl genrsa -out key.pem 3072
-fi
-
-set -e
-
-echo "Generating certificate signing request"
-openssl req -new -out self.pem -key $KEY_FILE -subj '/CN=localhost'
-
+openssl genrsa -out key.pem 3072
+openssl req -new -out self.pem -key key.pem -subj '/CN=localhost'
 openssl req -text -noout -in self.pem
-
-echo "Generating certificate"
-openssl x509 -req -days 1024 -in self.pem -signkey $KEY_FILE -out cert.pem -extfile generate.ext
+openssl x509 -req -days 1024 -in self.pem -signkey key.pem -out cert.pem -extfile generate.ext
diff --git a/application/domain/database/start.js b/application/domain/database/start.js
@@ -0,0 +1,4 @@
+(async () => {
+  console.debug('Connect to pg');
+  domain.database.example = new lib.pg.Database(config.database);
+});
diff --git a/application/domain/resmon.js b/application/domain/resmon.js
diff --git a/application/domain/utils.js b/application/domain/utils.js
diff --git a/application/lib/example/add.js b/application/lib/example/add.js
@@ -0,0 +1,13 @@
+({
+  parameters: {
+    a: 'number',
+    b: 'number',
+  },
+
+  method({ a, b }) {
+    console.log({ a, b });
+    return a + b;
+  },
+
+  returns: 'number',
+});
diff --git a/application/lib/example/cache.js b/application/lib/example/cache.js
@@ -0,0 +1,15 @@
+({
+  values: new Map(),
+
+  set({ key, val }) {
+    console.log({ set: { key, val } });
+    return this.values.set(key, val);
+  },
+
+  get({ key }) {
+    console.log({ get: key });
+    const res = this.values.get(key);
+    console.log({ return: res });
+    return res;
+  }
+});
diff --git a/application/lib/example/doSomething.js b/application/lib/example/doSomething.js
@@ -0,0 +1,3 @@
+(() => {
+  console.debug('Call method: example.doSomething');
+});
diff --git a/application/lib/example/start.js b/application/lib/example/start.js
@@ -0,0 +1,10 @@
+({
+  privateField: 100,
+
+  async method() {
+    console.log('Start example plugin');
+    this.parent.cache.set({ key: 'keyName', val: this.privateField });
+    const res = lib.example.cache.get({ key: 'keyName' });
+    console.log({ res, cache: this.parent.cache.values });
+  }
+});
diff --git a/application/lib/example/stop.js b/application/lib/example/stop.js
@@ -0,0 +1,3 @@
+(async () => {
+  console.debug('Stop example plugin');
+});
diff --git a/application/lib/example/storage/set.js b/application/lib/example/storage/set.js
@@ -0,0 +1,13 @@
+({
+  values: new Map(),
+
+  method({ key, val }) {
+    console.log({ key, val });
+    if (val) {
+      return this.values.set(key, val);
+    }
+    const res = this.values.get(key);
+    console.log({ return: { res } });
+    return res;
+  }
+});
diff --git a/application/lib/example/submodule1/method1.js b/application/lib/example/submodule1/method1.js
@@ -0,0 +1,3 @@
+(() => {
+  console.debug('Call method: example.submodule1.method1');
+});
diff --git a/application/lib/example/submodule1/method2.js b/application/lib/example/submodule1/method2.js
@@ -0,0 +1,3 @@
+(() => {
+  console.debug('Call method: example.submodule1.method2');
+});
diff --git a/application/lib/example/submodule2/method1.js b/application/lib/example/submodule2/method1.js
@@ -0,0 +1,3 @@
+(() => {
+  console.debug('Call method: example.submodule2.method1');
+});
diff --git a/application/lib/example/submodule2/method2.js b/application/lib/example/submodule2/method2.js
@@ -0,0 +1,3 @@
+(() => {
+  console.debug('Call method: example.submodule2.method2');
+});
diff --git a/application/lib/example/submodule2/nested1/method1.js b/application/lib/example/submodule2/nested1/method1.js
@@ -0,0 +1,3 @@
+(() => {
+  console.debug('Call method: example.submodule2.nested1.method1');
+});
diff --git a/application/lib/example/submodule3/nested2/method1.js b/application/lib/example/submodule3/nested2/method1.js
@@ -0,0 +1,3 @@
+(() => {
+  console.debug('Call method: example.submodule3.nested2.method1');
+});
diff --git a/application/lib/pg/Database.js b/application/lib/pg/Database.js
@@ -0,0 +1,58 @@
+(class Database {
+  constructor(options) {
+    this.pool = new npm.pg.Pool(options);
+  }
+
+  query(sql, values) {
+    const data = values ? values.join(',') : '';
+    console.debug(`${sql}\t[${data}]`);
+    return this.pool.query(sql, values);
+  }
+
+  insert(table, record) {
+    const keys = Object.keys(record);
+    const nums = new Array(keys.length);
+    const data = new Array(keys.length);
+    let i = 0;
+    for (const key of keys) {
+      data[i] = record[key];
+      nums[i] = `$${++i}`;
+    }
+    const fields = keys.join(', ');
+    const params = nums.join(', ');
+    const sql = `INSERT INTO ${table} (${fields}) VALUES (${params})`;
+    return this.query(sql, data);
+  }
+
+  async select(table, fields = ['*'], conditions = null) {
+    const keys = fields.join(', ');
+    const sql = `SELECT ${keys} FROM ${table}`;
+    let whereClause = '';
+    let args = [];
+    if (conditions) {
+      const whereData = lib.pg.utils.where(conditions);
+      whereClause = ' WHERE ' + whereData.clause;
+      args = whereData.args;
+    }
+    const res = await this.query(sql + whereClause, args);
+    return res.rows;
+  }
+
+  delete(table, conditions = null) {
+    const { clause, args } = lib.pg.utils.where(conditions);
+    const sql = `DELETE FROM ${table} WHERE ${clause}`;
+    return this.query(sql, args);
+  }
+
+  update(table, delta = null, conditions = null) {
+    const upd = lib.pg.utils.updates(delta);
+    const cond = lib.pg.utils.where(conditions, upd.args.length + 1);
+    const sql = `UPDATE ${table} SET ${upd.clause} WHERE ${cond.clause}`;
+    const args = [...upd.args, ...cond.args];
+    return this.query(sql, args);
+  }
+
+  close() {
+    this.pool.end();
+  }
+});
diff --git a/application/lib/pg/constants.js b/application/lib/pg/constants.js
@@ -0,0 +1,3 @@
+({
+  OPERATORS: ['>=', '<=', '<>', '>', '<']
+});
diff --git a/application/lib/pg/updates.js b/application/lib/pg/updates.js
@@ -0,0 +1,12 @@
+((delta, firstArgIndex = 1) => {
+  const clause = [];
+  const args = [];
+  let i = firstArgIndex;
+  const keys = Object.keys(delta);
+  for (const key of keys) {
+    const value = delta[key].toString();
+    clause.push(`${key} = $${i++}`);
+    args.push(value);
+  }
+  return { clause: clause.join(', '), args };
+});
diff --git a/application/lib/pg/where.js b/application/lib/pg/where.js
@@ -0,0 +1,26 @@
+((conditions, firstArgIndex = 1) => {
+  const clause = [];
+  const args = [];
+  let i = firstArgIndex;
+  const keys = Object.keys(conditions);
+  for (const key of keys) {
+    let operator = '=';
+    let value = conditions[key];
+    if (typeof value === 'string') {
+      for (const op of lib.pg.constants.OPERATORS) {
+        const len = op.length;
+        if (value.startsWith(op)) {
+          operator = op;
+          value = value.substring(len);
+        }
+      }
+      if (value.includes('*') || value.includes('?')) {
+        operator = 'LIKE';
+        value = value.replace(/\*/g, '%').replace(/\?/g, '_');
+      }
+    }
+    clause.push(`${key} ${operator} $${i++}`);
+    args.push(value);
+  }
+  return { clause: clause.join(' AND '), args };
+});
diff --git a/application/lib/resmon/getStatistics.js b/application/lib/resmon/getStatistics.js
@@ -0,0 +1,7 @@
+(() => {
+  const { heapTotal, heapUsed, external } = node.process.memoryUsage();
+  const hs = node.v8.getHeapStatistics();
+  const contexts = hs.number_of_native_contexts;
+  const detached = hs.number_of_detached_contexts;
+  return { heapTotal, heapUsed, external, contexts, detached };
+});
diff --git a/application/lib/resmon/start.js b/application/lib/resmon/start.js
@@ -0,0 +1,13 @@
+(async () => {
+  if (config.resmon.active) {
+    setInterval(() => {
+      const stats = lib.resmon.getStatistics();
+      const { heapTotal, heapUsed, external, contexts, detached } = stats;
+      const total = lib.utils.bytesToSize(heapTotal);
+      const used = lib.utils.bytesToSize(heapUsed);
+      const ext = lib.utils.bytesToSize(external);
+      console.debug(`Heap: ${used} of ${total}, ext: ${ext}`);
+      console.debug(`Contexts: ${contexts}, detached: ${detached}`);
+    }, config.resmon.interval);
+  }
+});
diff --git a/application/lib/utils/bytesToSize.js b/application/lib/utils/bytesToSize.js
@@ -0,0 +1,9 @@
+(bytes => {
+  const UNITS = ['', ' Kb', ' Mb', ' Gb', ' Tb', ' Pb', ' Eb', ' Zb', ' Yb'];
+  if (bytes === 0) return '0';
+  const exp = Math.floor(Math.log(bytes) / Math.log(1000));
+  const size = bytes / 1000 ** exp;
+  const short = Math.round(size, 2);
+  const unit = UNITS[exp];
+  return short + unit;
+});
diff --git a/application/static/console.js b/application/static/console.js
diff --git a/application/static/metacom.js b/application/static/metacom.js
diff --git a/lib/application.js b/lib/application.js

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1 @@`
	`1`	`+async () => new Error('Hello!', 54321);`
Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,3 @@`
	`1`	`+async () => {`
	`2`	`+ throw new Error('Hello', 12345);`
	`3`	`+};`