Initial commit (user sessions)

Author: j3k0

Diff for: app.js

@@ -0,0 +1,25 @@
+const bodyParser = require('body-parser');
+const express    = require('express');
+const users = require('./users');
+ 
+const router = express.Router();
+router.get('/', (req, res, next) => {
+    res.json({ok: true});
+});
+
+router.post('/login', (req, res, next) => {
+    const token = users.userLogin(req.query['username']);
+    res.json({token});
+});
+
+router.get('/me/:token', (req, res, next) => {
+    users.userSession(req.params.token, (err, user) => {
+        res.json(err ? {error: err.message} : user);
+    })
+});
+
+const app = express();
+app.use(bodyParser.json());
+app.use(bodyParser.urlencoded({ extended: false }));
+app.use('/', router);
+module.exports = app;

Diff for: index.js

@@ -0,0 +1,46 @@
+#!/usr/bin/env node
+
+const http = require('http');
+const app = require('./app');
+
+const port = parseInt(process.env.PORT || '8000');
+// app.set('port', port);
+const server = http.createServer(app);
+server.on('error', onError);
+server.on('listening', onListening);
+server.listen(port);
+
+// Event listener for HTTP server "error" event.
+function onError(error) {
+  if (error.syscall !== 'listen') {
+    throw error;
+  }
+
+  const bind = typeof port === 'string'
+    ? 'Pipe ' + port
+    : 'Port ' + port;
+
+  // Handle specific listen errors with friendly messages.
+  switch (error.code) {
+    case 'EACCES':
+      console.error(bind + ' requires elevated privileges');
+      process.exit(1);
+      break;
+    case 'EADDRINUSE':
+      console.error(bind + ' is already in use');
+      process.exit(1);
+      break;
+    default:
+      throw error;
+  }
+}
+
+// Event listener for HTTP server "listening" event.
+function onListening() {
+  const addr = server.address();
+  const bind = typeof addr === 'string'
+    ? 'pipe ' + addr
+    : 'port ' + addr.port;
+  console.log('Listening on ' + bind);
+}
+

Diff for: package.json

@@ -0,0 +1,15 @@
+{
+  "name": "demo-iaptic-server",
+  "version": "1.0.0",
+  "description": "",
+  "main": "index.js",
+  "scripts": {
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "author": "",
+  "license": "ISC",
+  "dependencies": {
+    "express": "^4.18.2",
+    "sqlite3": "^5.1.6"
+  }
+}

Diff for: users.js

@@ -0,0 +1,34 @@
+const sqlite3 = require('sqlite3');
+const db = new sqlite3.Database('sessions.db');
+
+db.run('CREATE TABLE IF NOT EXISTS sessions (token TEXT PRIMARY KEY, username TEXT)');
+
+function userLogin(username) {
+    const token = generateToken();
+    db.run('INSERT INTO sessions VALUES (?, ?)', token, username);
+    return token;
+}
+
+function userSession(token, callback) {
+
+    db.each('SELECT * FROM sessions WHERE token = (?)', token, (err, row) => {
+        if (!callback) return;
+        if (err) {
+            callback(err);
+            callback = null;
+        }
+        else {
+            callback(null, row);
+            callback = null;
+        }
+    }, () => {
+        if (!callback) return;
+        callback(new Error('UserNotFound'));
+    });
+}
+
+function generateToken() {
+    return '' + Math.round(9999999 * Math.random());
+}
+
+module.exports = {userLogin, userSession}