ccldevelopers
diff --git a/‎javascript/rest-api/part-3-handling-get-requests/hr_app/config/database.js
Lines changed: 10 additions & 0 deletions b/‎javascript/rest-api/part-3-handling-get-requests/hr_app/config/database.js
Lines changed: 10 additions & 0 deletions
diff --git a/‎javascript/rest-api/part-3-handling-get-requests/hr_app/config/web-server.js
Lines changed: 3 additions & 0 deletions b/‎javascript/rest-api/part-3-handling-get-requests/hr_app/config/web-server.js
Lines changed: 3 additions & 0 deletions
diff --git a/‎javascript/rest-api/part-3-handling-get-requests/hr_app/controllers/employees.js
Lines changed: 25 additions & 0 deletions b/‎javascript/rest-api/part-3-handling-get-requests/hr_app/controllers/employees.js
Lines changed: 25 additions & 0 deletions
diff --git a/‎javascript/rest-api/part-3-handling-get-requests/hr_app/db_apis/employees.js
Lines changed: 32 additions & 0 deletions b/‎javascript/rest-api/part-3-handling-get-requests/hr_app/db_apis/employees.js
Lines changed: 32 additions & 0 deletions
diff --git a/‎javascript/rest-api/part-3-handling-get-requests/hr_app/index.js
Lines changed: 86 additions & 0 deletions b/‎javascript/rest-api/part-3-handling-get-requests/hr_app/index.js
Lines changed: 86 additions & 0 deletions
@@ -0,0 +1,10 @@
+module.exports = {
+  hrPool: {
+    user: process.env.HR_USER,
+    password: process.env.HR_PASSWORD,
+    connectString: process.env.HR_CONNECTIONSTRING,
+    poolMin: 10,
+    poolMax: 10,
+    poolIncrement: 0
+  }
+};
@@ -0,0 +1,3 @@
+module.exports = {
+  port: process.env.HTTP_PORT || 3000
+};
@@ -0,0 +1,25 @@
+const employees = require('../db_apis/employees.js');
+
+async function get(req, res, next) {
+  try {
+    const context = {};
+
+    context.id = Number(req.params.id);
+
+    const rows = await employees.find(context);
+
+    if (req.params.id) {
+      if (rows.length === 1) {
+        res.status(200).json(rows[0]);
+      } else {
+        res.status(404).end();
+      }
+    } else {
+      res.status(200).json(rows);
+    }
+  } catch (err) {
+    next(err);
+  }
+}
+
+module.exports.get = get;
@@ -0,0 +1,32 @@
+const database = require('../services/database.js');
+
+const baseQuery =
+ `select employee_id "id",
+    first_name "first_name",
+    last_name "last_name",
+    email "email",
+    phone_number "phone_number",
+    hire_date "hire_date",
+    job_id "job_id",
+    salary "salary",
+    commission_pct "commission_pct",
+    manager_id "manager_id",
+    department_id "department_id"
+  from employees`;
+
+async function find(context) {
+  let query = baseQuery;
+  const binds = {};
+
+  if (context.id) {
+    binds.employee_id = context.id;
+
+    query += `\nwhere employee_id = :employee_id`;
+  }
+
+  const result = await database.simpleExecute(query, binds);
+
+  return result.rows;
+}
+
+module.exports.find = find;
@@ -0,0 +1,86 @@
+const webServer = require('./services/web-server.js');
+const database = require('./services/database.js');
+const dbConfig = require('./config/database.js');
+const defaultThreadPoolSize = 4;
+
+// Increase thread pool size by poolMax
+process.env.UV_THREADPOOL_SIZE = dbConfig.hrPool.poolMax + defaultThreadPoolSize;
+
+async function startup() {
+  console.log('Starting application');
+
+  try {
+    console.log('Initializing database module');
+
+    await database.initialize();
+  } catch (err) {
+    console.error(err);
+
+    process.exit(1); // Non-zero failure code
+  }
+
+  try {
+    console.log('Initializing web server module');
+
+    await webServer.initialize();
+  } catch (err) {
+    console.error(err);
+
+    process.exit(1); // Non-zero failure code
+  }
+}
+
+startup();
+
+async function shutdown(e) {
+  let err = e;
+
+  console.log('Shutting down application');
+
+  try {
+    console.log('Closing web server module');
+
+    await webServer.close();
+  } catch (e) {
+    console.error(e);
+
+    err = err || e;
+  }
+
+  try {
+    console.log('Closing database module');
+
+    await database.close();
+  } catch (e) {
+    console.error(e);
+
+    err = err || e;
+  }
+
+  console.log('Exiting process');
+
+  if (err) {
+    process.exit(1); // Non-zero failure code
+  } else {
+    process.exit(0);
+  }
+}
+
+process.on('SIGTERM', () => {
+  console.log('Received SIGTERM');
+
+  shutdown();
+});
+
+process.on('SIGINT', () => {
+  console.log('Received SIGINT');
+
+  shutdown();
+});
+
+process.on('uncaughtException', err => {
+  console.log('Uncaught exception');
+  console.error(err);
+
+  shutdown(err);
+});
Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,3 @@`
	`1`	`+module.exports = {`
	`2`	`+ port: process.env.HTTP_PORT \|\| 3000`
	`3`	`+};`