Initial commit

Author: William

Dockerfile

@@ -0,0 +1,9 @@
+FROM node:16-alpine as template-private-api-nodejs
+RUN mkdir /home/app
+WORKDIR /home/app
+COPY . /home/app
+RUN apk add git
+RUN npm install --quiet
+VOLUME /tmp
+EXPOSE 80
+ENTRYPOINT node server.js

cluster.js

@@ -0,0 +1,83 @@
+const dotenv = require('dotenv');
+const cluster =require('cluster');
+const http = require('http');
+const getPort = require('get-port'); // TODO: Replace with "port-finder"?
+const os = require('os');
+const createApp = require('./src/app.js');
+
+dotenv.config(); // Load environment vars
+
+// Load app config.ini
+const DEFAULT_PORT = process.env.APP_PORT || process.env.PORT || 4000; // Configure server default PORT
+const MAX_TIMEOUT = 30 * 60 *1000; // Configure server max hard timeout 30m
+const NUM_CPUS =  os.cpus().length || 1; // Configure number of threads
+
+var server, app, port = null;
+
+const events = {
+  onInit: () => {
+    console.log(`Node.js template Private API ${process.pid} - listening on port %s`, port);
+  
+    if (process.emit) {
+      process.emit('ready');
+    }
+  },
+  onShutdown: () => {
+    if (!app || !app.locals) {
+      return;
+    }
+    
+    app.locals.discovery.unregister()
+      .then(() => {
+        console.log('Service unregistred!');
+        process.exit(0);
+      })
+      .catch(console.error);
+  }
+};
+
+if (cluster.isMaster) {
+  console.log(`Node.js template Private API ${process.pid} - master`);
+
+  for (let i = 0; i < NUM_CPUS; i++) {
+    cluster.fork();
+  }
+
+  cluster.on('exit', (worker, code, signal) => {
+    console.log(`worker ${worker.process.pid} died`);
+  });
+
+  cluster.on('disconnect', () => {
+    console.log('worker disconnected');
+  });
+}
+
+/**
+ * Bootstrap app
+ */
+const main = async () => {
+  const getPortOptions = {
+    port: parseInt(DEFAULT_PORT)
+  };
+
+  port = 4000;
+
+  /*
+  if (!port) {
+    port = await getPort(getPortOptions);
+  }
+  */
+
+  app = createApp(port);
+  server = http.createServer(app);
+  server.setTimeout(MAX_TIMEOUT);
+  server.listen(port, events.onInit);
+};
+
+process.on('SIGHUP', events.onShutdown);
+process.on('SIGINT', events.onShutdown);
+process.on('SIGTERM', events.onShutdown);
+
+if (!cluster.isMaster) {
+  main();
+}

config.ini

@@ -0,0 +1,23 @@
+[app]
+port=4000
+
+[database]
+driver=postgres
+
+[database.connection]
+host=localhost
+port=5432
+user=postgres
+password=postgres
+database=postgres
+
+[database.options]
+test_connection=true
+
+[aws]
+aws_access_key_id=AKIAXI6...
+aws_secret_access_key=EiBTeA0...
+
+[aws.s3]
+bucket=BUCKET_NAME
+region=sa-east-1

db/migrations/20200408164235_extensions.js

@@ -0,0 +1,8 @@
+
+exports.up = function(knex) {
+  return knex.raw('CREATE EXTENSION IF NOT EXISTS "uuid-ossp"');
+};
+
+exports.down = function(knex) {
+  Promise.resolve('ok');
+};

db/migrations/20200408164236_project.js

@@ -0,0 +1,15 @@
+exports.up = function (knex) {
+  return knex.schema.createTable('project', function (table) {
+    // Columns
+    table.uuid('id').unique().primary().notNullable().defaultTo(knex.raw('uuid_generate_v4()'));
+    table.uuid('ownerId').notNullable();
+    table.string('name', 60).notNullable();
+    table.specificType('tags', 'varchar[]').nullable();
+    table.timestamp('createdAt').notNullable().defaultTo(knex.fn.now());
+    table.timestamp('deletedAt');
+  });
+};
+
+exports.down = function (knex) {
+  return knex.schema.dropTable('project');
+};

db/migrations/20200408164237_project_tag.js

@@ -0,0 +1,13 @@
+exports.up = function (knex) {
+  return knex.schema.createTable('project_tag', function (table) {
+    // Columns
+    table.uuid('id').unique().primary().notNullable().defaultTo(knex.raw('uuid_generate_v4()'));
+    table.uuid('projectId').notNullable();
+    table.string('name', 60).notNullable();
+    table.string('value', 60).notNullable();
+  });
+};
+
+exports.down = function (knex) {
+  return knex.schema.dropTable('project_tag');
+};

db/migrations/20200408172830_team.js

@@ -0,0 +1,14 @@
+exports.up = function (knex) {
+  return knex.schema.createTable('team', function (table) {
+    // Columns
+    table.uuid('id').unique().primary().notNullable().defaultTo(knex.raw('uuid_generate_v4()'));
+    table.uuid('projectId').notNullable();
+    table.string('name');
+    table.timestamp('createdAt').notNullable().defaultTo(knex.fn.now());
+    table.timestamp('deletedAt');
+  });
+};
+
+exports.down = function (knex) {
+  return knex.schema.dropTable('team');
+};

db/migrations/20200408172831_team_tag.js

@@ -0,0 +1,14 @@
+exports.up = function (knex) {
+  return knex.schema.createTable('team_tag', function (table) {
+    // Columns
+    table.uuid('id').unique().primary().notNullable().defaultTo(knex.raw('uuid_generate_v4()'));
+    table.uuid('projectId').notNullable();
+    table.uuid('teamId').notNullable();
+    table.string('name', 60).notNullable();
+    table.string('value', 60).notNullable();
+  });
+};
+
+exports.down = function (knex) {
+  return knex.schema.dropTable('team_tag');
+};

db/migrations/20200408172832_member.js

@@ -0,0 +1,15 @@
+exports.up = function (knex) {
+  return knex.schema.createTable('member', function (table) {
+    // Columns
+    table.uuid('id').unique().primary().notNullable().defaultTo(knex.raw('uuid_generate_v4()'));
+    table.uuid('projectId').notNullable();
+    table.uuid('userId').notNullable();
+    table.uuid('teamId').notNullable();
+    table.timestamp('createdAt').notNullable().defaultTo(knex.fn.now());
+    table.timestamp('deletedAt');
+  });
+};
+
+exports.down = function (knex) {
+  return knex.schema.dropTable('member');
+};

db/migrations/20200408172833_user_permission.js

@@ -0,0 +1,13 @@
+exports.up = function (knex) {
+  return knex.schema.createTable('user_permission', function (table) {
+    // Columns
+    table.uuid('id').unique().primary().notNullable().defaultTo(knex.raw('uuid_generate_v4()'));
+    table.uuid('projectId').notNullable();
+    table.uuid('userId').notNullable();
+    table.string('permission', 30).notNullable();
+  });
+};
+
+exports.down = function (knex) {
+  return knex.schema.dropTable('user_permission');
+};