Hackathon

README.md

@@ -1,5 +1,5 @@
 # Crowd Microservices
-Demo of Crowd Microservices environment
+Demo of Crowd Microservices environment.
 
 
 

app.js

@@ -6,8 +6,9 @@ const favicon = require('serve-favicon');
 const logger = require('morgan');
 const cookieParser = require('cookie-parser');
 const bodyParser = require('body-parser');
+const firebaseConstant = require('firebase');
 const cors = require('cors')({
- origin: true
+origin: true
 });
 const status = require('http-status');
 const wagner = require('wagner-core');
@@ -22,89 +23,101 @@ app.set('views', path.join(__dirname, 'public'));
 app.use(logger('dev'));
 app.use(cookieParser());
 app.use(session({
- name: 'server-session-cookie-id',
- secret: 'my express secret',
- saveUninitialized: true,
- resave: true,
- store: new FileStore({
- retries: 10,
- minTimeout: 100,
- maxTimeout: 200,
- path: path.join(__dirname,'sessions')
- })
+name: 'server-session-cookie-id',
+secret: 'my express secret',
+saveUninitialized: true,
+resave: true,
+store: new FileStore({
+retries: 10,
+minTimeout: 100,
+maxTimeout: 200,
+path: path.join(__dirname,'sessions')
+})
 }));
-const isAuth = wagner.invoke(function() {
- return (req, res, next) => {
-if(req.session.user || req.path==='/login' || req.path === '/loggedin.html') {
- req.user = req.session.user;
- next();
- } else {
- res.redirect('/login');
- }
- };
+const isAuth = wagner.invoke(function() {
+return (req, res, next) => {
+ if (req.session.user || req.path==='/login' || req.path === '/loggedin.html') {
+req.user = req.session.user;
+next();
+} else {
+res.redirect('/login');
+}
+};
 });
 app.use(bodyParser.json());
 app.use(bodyParser.urlencoded({
- extended: false
+extended: false
 }));
-app.post('/authenticate', wagner.invoke(function(UserService, AdminFirebase, FirebaseService) {
- return function(req, res) {
- //var idToken = req.body.idToken;
- var idToken = req.headers['authorization'].split(' ').pop();
- AdminFirebase.auth().verifyIdToken(idToken)
- .then(function(decodedToken) {
- var uid = decodedToken.uid;
- req.session.user = decodedToken;
- UserService.getUserById(uid)
- .then(function(userRecord) {
- // See the UserRecord reference doc for the contents of userRecord.
- console.log("Successfully fetched user data:", userRecord.toJSON());
- var worker_id = userRecord.uid;
- var worker_name = userRecord.displayName;
- var avatar_url = userRecord.photoURL;
- var firebase = FirebaseService;
- var workers_list_promise = firebase.retrieveWorkersList();
- workers_list_promise.then(function(workers_list) {
- if (workers_list.indexOf(worker_id) < 0) {
- firebase.createWorker(worker_id, worker_name, avatar_url);
- }
- }).catch(function(err) {
- console.trace(err);
- });
- })
- .catch(function(err) {
- console.log("Error fetching user data:", err);
- });
- res.json({
- 'Success': 200
- })
- }).catch(function(err) {
- // Handle error
- console.trace(err);
- });
- };
+app.post('/authenticate', wagner.invoke(function (UserService, AdminFirebase, FirebaseService) {
+ return function (req, res) {
+ //var idToken = req.body.idToken;
+ var idToken = req.headers['authorization'].split(' ').pop();
+ AdminFirebase.auth().verifyIdToken(idToken)
+ .then(function (decodedToken) {
+ var uid = decodedToken.uid;
+ req.session.user = decodedToken;
+ UserService.getUserById(uid)
+ .then(function (userRecord) {
+ // See the UserRecord reference doc for the contents of userRecord.
+ console.log("Successfully fetched user data:", userRecord.toJSON());
+ var worker_id = userRecord.uid;
+ var worker_name = userRecord.displayName;
+ var avatar_url = userRecord.photoURL;
+ var firebase = FirebaseService;
+ // logs worker authentication
+ var ref = AdminFirebase.database().ref().child('Workers').child('logs');
+ ref.push({
+ eventType: "LoggedIn",
+ eventDescription: "Logged in successfully",
+ timestamp: firebaseConstant.database.ServerValue.TIMESTAMP,
+ workerId: userRecord.uid,
+ workerName: userRecord.displayName
+ }).catch(e => {
+ console.log(e)
+ });
+
+ var workers_list_promise = firebase.retrieveWorkersList();
+ workers_list_promise.then(function (workers_list) {
+ if (workers_list.indexOf(worker_id) < 0) {
+ firebase.createWorker(worker_id, worker_name, avatar_url);
+ }
+ }).catch(function (err) {
+ console.trace(err);
+ });
+ })
+ .catch(function (err) {
+ console.log("Error fetching user data:", err);
+ });
+ res.json({
+ 'Success': 200
+ })
+ }).catch(function (err) {
+ // Handle error
+ console.trace(err);
+ });
+ };
 }));
 app.use(cookieParser());
 app.use(isAuth);
 app.use('/api/v1', require('./routes/api')(wagner));
 app.use(express.static(path.join(__dirname, 'public')));
 app.use(require('./routes/app-routing')(wagner));
 // catch 404 and forward to error handler
-app.use(function(req, res, next) {
- var err = new Error('Not Found');
- err.status = 404;
- next(err);
+app.use(function(req, res, next) {
+var err = new Error('Not Found');
+err.status = 404;
+next(err);
 });
 
 // error handler
-app.use(function(err, req, res, next) {
- // set locals, only providing error in development
- res.locals.message = err.message;
- res.locals.error = req.app.get('env') === 'development' ? err : {};
+app.use(function(err, req, res, next) {
+// set locals, only providing error in development
+res.locals.message = err.message;
+res.locals.error = req.app.get('env') === 'development' ? err : {};
 
- // render the error page
- res.status(err.status || 500);
- res.sendFile(path.join(__dirname, '/public/404.html'));
+// render the error page
+res.status(err.status || 500);
+res.sendFile(path.join(__dirname, '/public/404.html'));
 });
 
 module.exports = app;

config/config.json

@@ -2,14 +2,15 @@
  "serviceAccount": {
  "type": "service_account",
  "project_id": "crowdcode2",
- "private_key_id": "4ef77e02829e6ff9ba96a35d264f092025aaef1d",
- "private_key": "-----BEGIN PRIVATE KEY-----\nMIIEvwIBADANBgkqhkiG9w0BAQEFAASCBKkwggSlAgEAAoIBAQDHZvikJdmZv5zI\nbM6ECnfp77QiFQidH93goS0438aGk5YR1La8tuOD62khNa3qbCNA2qMtj5c/WM8L\nONuzBnLYXcRtgbjiTftok3O37aeV1yW/Hty3jkKcFf2OsYO5oQRv73joP+ADcSu0\nz9LYx4uXrAx7x9wBNLSi5GP/ecWpvLMxRJUltzUg5p2Fn1/RHfQaa+GNd3oKWABe\na0sn88V2E5EM/Ie7xkApj5ozayW9F22Fct814pk1en7ZvE1+6JuQ63+3eEpNaLaj\neeLkKCkUzSLVX6UAUpnlf3gS15jdAjoWf+jPIrlpsY0T44jRUQb4ok0Pwn6orbRO\nHoVrBsArAgMBAAECggEAB+hefev+WCmQJyahff0ISl+2Lg/Vep2z59+ccn/1WIrr\nzaM45/z8wtOIJMgDMKO/Nig1hm4GWn3EIDbOB6h+z3PQgWM+mMLs8HXAhg/HsJqK\npaysph7fJ1974bfKeIcZLPM7QUKfOKO5Tv9a5jvrnkU1bYc8g1O6wib6jDwhCZ0f\nG+oZR6ka+SPi3Z6xNoBkw/JEJC+f0WDZV4VLy+rFlgQpC2FYiFWJHxh7D0MNIVbC\n7jowXvQ7jyqaNPBysfnkoGomeFrCxV+Zc1KuuHx3PL7Z+XdJsHxfPISANU9LzrW0\nVcsZ6GOihL1YE/1blk2lyA5cYJT3Bb3ybAkIKwgm6QKBgQD7oL4CI827mGtzzTv/\nKTeWOqRARAPLggo8dS79tgfP6BKEudeJGlxLA3l+1eWFrjjEpG85nrLkcIXz4Cm9\nwZmg/esP1pts8v7rc/nJ1cL/UySznUkiGH1fLbIc8vkfTkbLx9pedjr0UAlNO+zX\nSmCE+lrHDXKn2wmTfBniewSgPwKBgQDK3ez+l7ESFaUGTyLHRe6EDvU6A9X72q6e\nJj4LVLW8JoGVezIBUk/orPij6S7oOEAMj72OCP4DCX6zZ6FfVaERZVHoSx7yBltU\n5Tf988guqR9zB4B7PrQP+uf6UXaL4LtT9XYxDvoyyqyZ8A2WRrHaks1wo+psc+lC\nNqPKoGOlFQKBgQCIC1NPwt3TpEfMN1VN0pIMNi5h1KQcnnU8VLsQTx+QJ9ADVJsU\ntFzb7cf9bFYI3bYxkxnTlFryKWgy/6pxvr96DG7PhF9KG2L6GB0gI+OmueQo/Evz\nFDyMfh9DiZZpd5/NQ4Nr+Q5M0w0EZfbaO4tNujHkVv/7gvB9feZczdglbwKBgQC6\npY6r+tK+ic2ITXz5DN1TARQcaXUSQHQSK6s/75M5ZdApwOwUDTBaKfKllCBFJaPA\nKuvC54EVOEIrO/hb50PG5oqCh8MT+EdFh5OJgia2z4GQ6uEKA3nVjgqq4xKHxZ90\nss0oe9g0rQY6p4NItQhjyldcAGPpnoeJFQ6DmieztQKBgQDToHOxSPDwfnXC+pei\nf8wbL2OReWNwnmu0kM/UUjcN6owBExaMghanUAXR8jpl229/MIUJyhGjqKpp+c3N\naVBlatxHl7niJXfV6JXu9WyfvAOC7SssAWrnDqMlWfNoPECTBZ3uItWy1FcWuFmh\n92d5t5RxFMFAG4FPws4fFKgyMg==\n-----END PRIVATE KEY-----\n",
- "client_email": "firebase-adminsdk-8ri07@crowdcode2.iam.gserviceaccount.com",
- "client_id": "116287562601899349887",
+ "private_key_id": "ee2194e5cd3aa1461e2442e81c05766eab6cfa00",
+ "private_key": "-----BEGIN PRIVATE KEY-----\nMIIEvwIBADANBgkqhkiG9w0BAQEFAASCBKkwggSlAgEAAoIBAQDazdoyIYSXq6hd\nuYVpcdYId+UzruabySi3LbURwjSLf9pSVprAdTro4c7zxBBhHz6Z35d2l/Reao6Q\nsyuIydPXz6yDM9m9ayALMYnQssTu7hwvdC2tMyBsoiG/qCRwahZmw6EatmNAN6yY\nhUi41m+dGybu/cbq/RCmtKe0BcwWhjEVcipnueD0ax0uZcmzdkwl2jT9zezFQx2t\n6MjpVYAzWxNp1voTACc/dF3Ks8pvPqHst+nXGhVWVrMDPSHum1AEwbd+9qxCjEZ0\nQGTqTeYoHULnx7IVXp1nBwy7HahrmAhiEE9g5bGBKJo9HG3seY2QhcIvN+utqAvL\ndfMdpDPfAgMBAAECggEAYgEDQyINPEw4gSaIUccZ2bguMvybsVqkQIwaBubIV1WA\nihHdhefcZ5RA+KGwvnfat9xVANsmKyYqTjjafo38M7WC7U+Lr1Ksyya4toBkQirn\n9/9fOC1m0BG88RYUoD98YjIs1oSsJwbo6XYFsTjnTGTthu2nq/iG/Ux8s19HXyyO\n2BXk/LR15cMhcCqKWs2h3zmekU83XPxPMG6/3LVdWx1SdNouHjvM2L9WzDKQnG2O\n5pTTe0J/wLAERQ7grRMen4mFrdV5FJBYnq8rLVqHMCJ6/+D7mp51hq+dJ/Kyy2nI\nZJYReWGmj1hgMQxRhpB0cBLw+bTMagt/2/DD+Jg8AQKBgQD3DcxlZuJnApl4a53L\n6lPSbvu48q+DLB2VoWM5N8jn2VvCC4RTDceF2lSFaXvF6vGdMmMbpM5UkXu0Xkof\nOvIsFQLwCNU+vsPSv3s5Rqwza3plKTb9ndRJtIBLNo9hamA7qldr2u45O3srHPIe\nQFcOBXXgvt2Rmw6VN/eJS1R0AQKBgQDiui1PdOn+lH25Zp0dTf6awmX2YKouoA1X\nn6HRrmPl6odRCRiMlWAXmUhvx67Mjwaz5FIgqC10ykgrLWe3jtIZ4T2wdyml54Dy\ncqdoLzRrak8Fgkk3AYyeiiAPHdUmkOvtyM6U6JHA0DX3DkzeEdAVvpCY9SChiKJi\ntdTh9Wcn3wKBgQDHdD5mR0/VdkXM8KUusfoGVE+pm1SThBRGb0saMK1kcRkhagbk\nvqUsrX27T9P7j5iNHtbgxIdHw0Sp883HtOE7MaNzgs4WoBCcnravIR15TfY8oa+h\nxcBT2QQStPPA5A7ZXMbDbrcRQbJItk/KmIsv6LyoO6/KE/MMCWkxUL3YAQKBgQCR\nYwN1JSp7ZmrsfYGYbhAq2yeZAsl+VoHXw3R3ydUjdO3KqAOG+q6A03kgvLI5WCnb\nJzkG2fE0KBZ5IYeVrE7L66SsSO17BmWokp8I7uQ1URlVFgOu8x5h936xUtcBAQNZ\nGmBmGnCEbL9+KjxeVpvRpb6BZwbCrqQ6mhDlyICajwKBgQCGbD3YL0AtZD0iMUdh\nvUGhHlmtN+TUcInYPiWfk9VwjUS4087AxVOrUDp8aBGUtKBVdC9g9EhmWX26vuCd\nv6yDCSF0enYPVJLI/6CU8yDK2wZCV5CE9JcCuVyu+2BZ9sgM4MfGQVcdWkbxDRfy\nIAu9OY6uEkcdJc4pB6sTZ6nA3g==\n-----END PRIVATE KEY-----\n",
+ "client_email": "firebase-adminsdk-roovx@crowdcode2.iam.gserviceaccount.com",
+ "client_id": "105510340470187039060",
  "auth_uri": "https://accounts.google.com/o/oauth2/auth",
- "token_uri": "https://accounts.google.com/o/oauth2/token",
+ "token_uri": "https://oauth2.googleapis.com/token",
  "auth_provider_x509_cert_url": "https://www.googleapis.com/oauth2/v1/certs",
- "client_x509_cert_url": "https://www.googleapis.com/robot/v1/metadata/x509/firebase-adminsdk-8ri07%40crowdcode2.iam.gserviceaccount.com"
+ "client_x509_cert_url": "https://www.googleapis.com/robot/v1/metadata/x509/firebase-adminsdk-roovx%40crowdcode2.iam.gserviceaccount.com",
+ "universe_domain": "googleapis.com"
  },
  "firebaseConfig": {
  "apiKey": "AIzaSyCmhzDIbe7pp8dl0gveS2TtOH4n8mvMzsU",

README.md

@@ -1,5 +1,5 @@
 # Crowd Microservices
-Demo of Crowd Microservices environment
+Demo of Crowd Microservices environment.
 
 
 

app.js

@@ -6,8 +6,9 @@ const favicon = require('serve-favicon');
 const logger = require('morgan');
 const cookieParser = require('cookie-parser');
 const bodyParser = require('body-parser');
+const firebaseConstant = require('firebase');
 const cors = require('cors')({
- origin: true
+origin: true
 });
 const status = require('http-status');
 const wagner = require('wagner-core');
@@ -22,89 +23,101 @@ app.set('views', path.join(__dirname, 'public'));
 app.use(logger('dev'));
 app.use(cookieParser());
 app.use(session({
- name: 'server-session-cookie-id',
- secret: 'my express secret',
- saveUninitialized: true,
- resave: true,
- store: new FileStore({
- retries: 10,
- minTimeout: 100,
- maxTimeout: 200,
- path: path.join(__dirname,'sessions')
- })
+name: 'server-session-cookie-id',
+secret: 'my express secret',
+saveUninitialized: true,
+resave: true,
+store: new FileStore({
+retries: 10,
+minTimeout: 100,
+maxTimeout: 200,
+path: path.join(__dirname,'sessions')
+})
 }));
-const isAuth = wagner.invoke(function() {
- return (req, res, next) => {
-if(req.session.user || req.path==='/login' || req.path === '/loggedin.html') {
- req.user = req.session.user;
- next();
- } else {
- res.redirect('/login');
- }
- };
+const isAuth = wagner.invoke(function() {
+return (req, res, next) => {
+ if (req.session.user || req.path==='/login' || req.path === '/loggedin.html') {
+req.user = req.session.user;
+next();
+} else {
+res.redirect('/login');
+}
+};
 });
 app.use(bodyParser.json());
 app.use(bodyParser.urlencoded({
- extended: false
+extended: false
 }));
-app.post('/authenticate', wagner.invoke(function(UserService, AdminFirebase, FirebaseService) {
- return function(req, res) {
- //var idToken = req.body.idToken;
- var idToken = req.headers['authorization'].split(' ').pop();
- AdminFirebase.auth().verifyIdToken(idToken)
- .then(function(decodedToken) {
- var uid = decodedToken.uid;
- req.session.user = decodedToken;
- UserService.getUserById(uid)
- .then(function(userRecord) {
- // See the UserRecord reference doc for the contents of userRecord.
- console.log("Successfully fetched user data:", userRecord.toJSON());
- var worker_id = userRecord.uid;
- var worker_name = userRecord.displayName;
- var avatar_url = userRecord.photoURL;
- var firebase = FirebaseService;
- var workers_list_promise = firebase.retrieveWorkersList();
- workers_list_promise.then(function(workers_list) {
- if (workers_list.indexOf(worker_id) < 0) {
- firebase.createWorker(worker_id, worker_name, avatar_url);
- }
- }).catch(function(err) {
- console.trace(err);
- });
- })
- .catch(function(err) {
- console.log("Error fetching user data:", err);
- });
- res.json({
- 'Success': 200
- })
- }).catch(function(err) {
- // Handle error
- console.trace(err);
- });
- };
+app.post('/authenticate', wagner.invoke(function (UserService, AdminFirebase, FirebaseService) {
+ return function (req, res) {
+ //var idToken = req.body.idToken;
+ var idToken = req.headers['authorization'].split(' ').pop();
+ AdminFirebase.auth().verifyIdToken(idToken)
+ .then(function (decodedToken) {
+ var uid = decodedToken.uid;
+ req.session.user = decodedToken;
+ UserService.getUserById(uid)
+ .then(function (userRecord) {
+ // See the UserRecord reference doc for the contents of userRecord.
+ console.log("Successfully fetched user data:", userRecord.toJSON());
+ var worker_id = userRecord.uid;
+ var worker_name = userRecord.displayName;
+ var avatar_url = userRecord.photoURL;
+ var firebase = FirebaseService;
+ // logs worker authentication
+ var ref = AdminFirebase.database().ref().child('Workers').child('logs');
+ ref.push({
+ eventType: "LoggedIn",
+ eventDescription: "Logged in successfully",
+ timestamp: firebaseConstant.database.ServerValue.TIMESTAMP,
+ workerId: userRecord.uid,
+ workerName: userRecord.displayName
+ }).catch(e => {
+ console.log(e)
+ });
+
+ var workers_list_promise = firebase.retrieveWorkersList();
+ workers_list_promise.then(function (workers_list) {
+ if (workers_list.indexOf(worker_id) < 0) {
+ firebase.createWorker(worker_id, worker_name, avatar_url);
+ }
+ }).catch(function (err) {
+ console.trace(err);
+ });
+ })
+ .catch(function (err) {
+ console.log("Error fetching user data:", err);
+ });
+ res.json({
+ 'Success': 200
+ })
+ }).catch(function (err) {
+ // Handle error
+ console.trace(err);
+ });
+ };
 }));
 app.use(cookieParser());
 app.use(isAuth);
 app.use('/api/v1', require('./routes/api')(wagner));
 app.use(express.static(path.join(__dirname, 'public')));
 app.use(require('./routes/app-routing')(wagner));
 // catch 404 and forward to error handler
-app.use(function(req, res, next) {
- var err = new Error('Not Found');
- err.status = 404;
- next(err);
+app.use(function(req, res, next) {
+var err = new Error('Not Found');
+err.status = 404;
+next(err);
 });
 
 // error handler
-app.use(function(err, req, res, next) {
- // set locals, only providing error in development
- res.locals.message = err.message;
- res.locals.error = req.app.get('env') === 'development' ? err : {};
+app.use(function(err, req, res, next) {
+// set locals, only providing error in development
+res.locals.message = err.message;
+res.locals.error = req.app.get('env') === 'development' ? err : {};
 
- // render the error page
- res.status(err.status || 500);
- res.sendFile(path.join(__dirname, '/public/404.html'));
+// render the error page
+res.status(err.status || 500);
+res.sendFile(path.join(__dirname, '/public/404.html'));
 });
 
 module.exports = app;

config/config.json

@@ -2,14 +2,15 @@
  "serviceAccount": {
  "type": "service_account",
  "project_id": "crowdcode2",
- "private_key_id": "4ef77e02829e6ff9ba96a35d264f092025aaef1d",
- "private_key": "-----BEGIN PRIVATE KEY-----\nMIIEvwIBADANBgkqhkiG9w0BAQEFAASCBKkwggSlAgEAAoIBAQDHZvikJdmZv5zI\nbM6ECnfp77QiFQidH93goS0438aGk5YR1La8tuOD62khNa3qbCNA2qMtj5c/WM8L\nONuzBnLYXcRtgbjiTftok3O37aeV1yW/Hty3jkKcFf2OsYO5oQRv73joP+ADcSu0\nz9LYx4uXrAx7x9wBNLSi5GP/ecWpvLMxRJUltzUg5p2Fn1/RHfQaa+GNd3oKWABe\na0sn88V2E5EM/Ie7xkApj5ozayW9F22Fct814pk1en7ZvE1+6JuQ63+3eEpNaLaj\neeLkKCkUzSLVX6UAUpnlf3gS15jdAjoWf+jPIrlpsY0T44jRUQb4ok0Pwn6orbRO\nHoVrBsArAgMBAAECggEAB+hefev+WCmQJyahff0ISl+2Lg/Vep2z59+ccn/1WIrr\nzaM45/z8wtOIJMgDMKO/Nig1hm4GWn3EIDbOB6h+z3PQgWM+mMLs8HXAhg/HsJqK\npaysph7fJ1974bfKeIcZLPM7QUKfOKO5Tv9a5jvrnkU1bYc8g1O6wib6jDwhCZ0f\nG+oZR6ka+SPi3Z6xNoBkw/JEJC+f0WDZV4VLy+rFlgQpC2FYiFWJHxh7D0MNIVbC\n7jowXvQ7jyqaNPBysfnkoGomeFrCxV+Zc1KuuHx3PL7Z+XdJsHxfPISANU9LzrW0\nVcsZ6GOihL1YE/1blk2lyA5cYJT3Bb3ybAkIKwgm6QKBgQD7oL4CI827mGtzzTv/\nKTeWOqRARAPLggo8dS79tgfP6BKEudeJGlxLA3l+1eWFrjjEpG85nrLkcIXz4Cm9\nwZmg/esP1pts8v7rc/nJ1cL/UySznUkiGH1fLbIc8vkfTkbLx9pedjr0UAlNO+zX\nSmCE+lrHDXKn2wmTfBniewSgPwKBgQDK3ez+l7ESFaUGTyLHRe6EDvU6A9X72q6e\nJj4LVLW8JoGVezIBUk/orPij6S7oOEAMj72OCP4DCX6zZ6FfVaERZVHoSx7yBltU\n5Tf988guqR9zB4B7PrQP+uf6UXaL4LtT9XYxDvoyyqyZ8A2WRrHaks1wo+psc+lC\nNqPKoGOlFQKBgQCIC1NPwt3TpEfMN1VN0pIMNi5h1KQcnnU8VLsQTx+QJ9ADVJsU\ntFzb7cf9bFYI3bYxkxnTlFryKWgy/6pxvr96DG7PhF9KG2L6GB0gI+OmueQo/Evz\nFDyMfh9DiZZpd5/NQ4Nr+Q5M0w0EZfbaO4tNujHkVv/7gvB9feZczdglbwKBgQC6\npY6r+tK+ic2ITXz5DN1TARQcaXUSQHQSK6s/75M5ZdApwOwUDTBaKfKllCBFJaPA\nKuvC54EVOEIrO/hb50PG5oqCh8MT+EdFh5OJgia2z4GQ6uEKA3nVjgqq4xKHxZ90\nss0oe9g0rQY6p4NItQhjyldcAGPpnoeJFQ6DmieztQKBgQDToHOxSPDwfnXC+pei\nf8wbL2OReWNwnmu0kM/UUjcN6owBExaMghanUAXR8jpl229/MIUJyhGjqKpp+c3N\naVBlatxHl7niJXfV6JXu9WyfvAOC7SssAWrnDqMlWfNoPECTBZ3uItWy1FcWuFmh\n92d5t5RxFMFAG4FPws4fFKgyMg==\n-----END PRIVATE KEY-----\n",
- "client_email": "firebase-adminsdk-8ri07@crowdcode2.iam.gserviceaccount.com",
- "client_id": "116287562601899349887",
+ "private_key_id": "ee2194e5cd3aa1461e2442e81c05766eab6cfa00",
+ "private_key": "-----BEGIN PRIVATE KEY-----\nMIIEvwIBADANBgkqhkiG9w0BAQEFAASCBKkwggSlAgEAAoIBAQDazdoyIYSXq6hd\nuYVpcdYId+UzruabySi3LbURwjSLf9pSVprAdTro4c7zxBBhHz6Z35d2l/Reao6Q\nsyuIydPXz6yDM9m9ayALMYnQssTu7hwvdC2tMyBsoiG/qCRwahZmw6EatmNAN6yY\nhUi41m+dGybu/cbq/RCmtKe0BcwWhjEVcipnueD0ax0uZcmzdkwl2jT9zezFQx2t\n6MjpVYAzWxNp1voTACc/dF3Ks8pvPqHst+nXGhVWVrMDPSHum1AEwbd+9qxCjEZ0\nQGTqTeYoHULnx7IVXp1nBwy7HahrmAhiEE9g5bGBKJo9HG3seY2QhcIvN+utqAvL\ndfMdpDPfAgMBAAECggEAYgEDQyINPEw4gSaIUccZ2bguMvybsVqkQIwaBubIV1WA\nihHdhefcZ5RA+KGwvnfat9xVANsmKyYqTjjafo38M7WC7U+Lr1Ksyya4toBkQirn\n9/9fOC1m0BG88RYUoD98YjIs1oSsJwbo6XYFsTjnTGTthu2nq/iG/Ux8s19HXyyO\n2BXk/LR15cMhcCqKWs2h3zmekU83XPxPMG6/3LVdWx1SdNouHjvM2L9WzDKQnG2O\n5pTTe0J/wLAERQ7grRMen4mFrdV5FJBYnq8rLVqHMCJ6/+D7mp51hq+dJ/Kyy2nI\nZJYReWGmj1hgMQxRhpB0cBLw+bTMagt/2/DD+Jg8AQKBgQD3DcxlZuJnApl4a53L\n6lPSbvu48q+DLB2VoWM5N8jn2VvCC4RTDceF2lSFaXvF6vGdMmMbpM5UkXu0Xkof\nOvIsFQLwCNU+vsPSv3s5Rqwza3plKTb9ndRJtIBLNo9hamA7qldr2u45O3srHPIe\nQFcOBXXgvt2Rmw6VN/eJS1R0AQKBgQDiui1PdOn+lH25Zp0dTf6awmX2YKouoA1X\nn6HRrmPl6odRCRiMlWAXmUhvx67Mjwaz5FIgqC10ykgrLWe3jtIZ4T2wdyml54Dy\ncqdoLzRrak8Fgkk3AYyeiiAPHdUmkOvtyM6U6JHA0DX3DkzeEdAVvpCY9SChiKJi\ntdTh9Wcn3wKBgQDHdD5mR0/VdkXM8KUusfoGVE+pm1SThBRGb0saMK1kcRkhagbk\nvqUsrX27T9P7j5iNHtbgxIdHw0Sp883HtOE7MaNzgs4WoBCcnravIR15TfY8oa+h\nxcBT2QQStPPA5A7ZXMbDbrcRQbJItk/KmIsv6LyoO6/KE/MMCWkxUL3YAQKBgQCR\nYwN1JSp7ZmrsfYGYbhAq2yeZAsl+VoHXw3R3ydUjdO3KqAOG+q6A03kgvLI5WCnb\nJzkG2fE0KBZ5IYeVrE7L66SsSO17BmWokp8I7uQ1URlVFgOu8x5h936xUtcBAQNZ\nGmBmGnCEbL9+KjxeVpvRpb6BZwbCrqQ6mhDlyICajwKBgQCGbD3YL0AtZD0iMUdh\nvUGhHlmtN+TUcInYPiWfk9VwjUS4087AxVOrUDp8aBGUtKBVdC9g9EhmWX26vuCd\nv6yDCSF0enYPVJLI/6CU8yDK2wZCV5CE9JcCuVyu+2BZ9sgM4MfGQVcdWkbxDRfy\nIAu9OY6uEkcdJc4pB6sTZ6nA3g==\n-----END PRIVATE KEY-----\n",
+ "client_email": "firebase-adminsdk-roovx@crowdcode2.iam.gserviceaccount.com",
+ "client_id": "105510340470187039060",
  "auth_uri": "https://accounts.google.com/o/oauth2/auth",
- "token_uri": "https://accounts.google.com/o/oauth2/token",
+ "token_uri": "https://oauth2.googleapis.com/token",
  "auth_provider_x509_cert_url": "https://www.googleapis.com/oauth2/v1/certs",
- "client_x509_cert_url": "https://www.googleapis.com/robot/v1/metadata/x509/firebase-adminsdk-8ri07%40crowdcode2.iam.gserviceaccount.com"
+ "client_x509_cert_url": "https://www.googleapis.com/robot/v1/metadata/x509/firebase-adminsdk-roovx%40crowdcode2.iam.gserviceaccount.com",
+ "universe_domain": "googleapis.com"
  },
  "firebaseConfig": {
  "apiKey": "AIzaSyCmhzDIbe7pp8dl0gveS2TtOH4n8mvMzsU",

README.md

@@ -1,5 +1,5 @@
 # Crowd Microservices
-Demo of Crowd Microservices environment
+Demo of Crowd Microservices environment.
 
 
 

app.js

@@ -6,8 +6,9 @@ const favicon = require('serve-favicon');
 const logger = require('morgan');
 const cookieParser = require('cookie-parser');
 const bodyParser = require('body-parser');
+const firebaseConstant = require('firebase');
 const cors = require('cors')({
- origin: true
+origin: true
 });
 const status = require('http-status');
 const wagner = require('wagner-core');
@@ -22,89 +23,101 @@ app.set('views', path.join(__dirname, 'public'));
 app.use(logger('dev'));
 app.use(cookieParser());
 app.use(session({
- name: 'server-session-cookie-id',
- secret: 'my express secret',
- saveUninitialized: true,
- resave: true,
- store: new FileStore({
- retries: 10,
- minTimeout: 100,
- maxTimeout: 200,
- path: path.join(__dirname,'sessions')
- })
+name: 'server-session-cookie-id',
+secret: 'my express secret',
+saveUninitialized: true,
+resave: true,
+store: new FileStore({
+retries: 10,
+minTimeout: 100,
+maxTimeout: 200,
+path: path.join(__dirname,'sessions')
+})
 }));
-const isAuth = wagner.invoke(function() {
- return (req, res, next) => {
-if(req.session.user || req.path==='/login' || req.path === '/loggedin.html') {
- req.user = req.session.user;
- next();
- } else {
- res.redirect('/login');
- }
- };
+const isAuth = wagner.invoke(function() {
+return (req, res, next) => {
+ if (req.session.user || req.path==='/login' || req.path === '/loggedin.html') {
+req.user = req.session.user;
+next();
+} else {
+res.redirect('/login');
+}
+};
 });
 app.use(bodyParser.json());
 app.use(bodyParser.urlencoded({
- extended: false
+extended: false
 }));
-app.post('/authenticate', wagner.invoke(function(UserService, AdminFirebase, FirebaseService) {
- return function(req, res) {
- //var idToken = req.body.idToken;
- var idToken = req.headers['authorization'].split(' ').pop();
- AdminFirebase.auth().verifyIdToken(idToken)
- .then(function(decodedToken) {
- var uid = decodedToken.uid;
- req.session.user = decodedToken;
- UserService.getUserById(uid)
- .then(function(userRecord) {
- // See the UserRecord reference doc for the contents of userRecord.
- console.log("Successfully fetched user data:", userRecord.toJSON());
- var worker_id = userRecord.uid;
- var worker_name = userRecord.displayName;
- var avatar_url = userRecord.photoURL;
- var firebase = FirebaseService;
- var workers_list_promise = firebase.retrieveWorkersList();
- workers_list_promise.then(function(workers_list) {
- if (workers_list.indexOf(worker_id) < 0) {
- firebase.createWorker(worker_id, worker_name, avatar_url);
- }
- }).catch(function(err) {
- console.trace(err);
- });
- })
- .catch(function(err) {
- console.log("Error fetching user data:", err);
- });
- res.json({
- 'Success': 200
- })
- }).catch(function(err) {
- // Handle error
- console.trace(err);
- });
- };
+app.post('/authenticate', wagner.invoke(function (UserService, AdminFirebase, FirebaseService) {
+ return function (req, res) {
+ //var idToken = req.body.idToken;
+ var idToken = req.headers['authorization'].split(' ').pop();
+ AdminFirebase.auth().verifyIdToken(idToken)
+ .then(function (decodedToken) {
+ var uid = decodedToken.uid;
+ req.session.user = decodedToken;
+ UserService.getUserById(uid)
+ .then(function (userRecord) {
+ // See the UserRecord reference doc for the contents of userRecord.
+ console.log("Successfully fetched user data:", userRecord.toJSON());
+ var worker_id = userRecord.uid;
+ var worker_name = userRecord.displayName;
+ var avatar_url = userRecord.photoURL;
+ var firebase = FirebaseService;
+ // logs worker authentication
+ var ref = AdminFirebase.database().ref().child('Workers').child('logs');
+ ref.push({
+ eventType: "LoggedIn",
+ eventDescription: "Logged in successfully",
+ timestamp: firebaseConstant.database.ServerValue.TIMESTAMP,
+ workerId: userRecord.uid,
+ workerName: userRecord.displayName
+ }).catch(e => {
+ console.log(e)
+ });
+
+ var workers_list_promise = firebase.retrieveWorkersList();
+ workers_list_promise.then(function (workers_list) {
+ if (workers_list.indexOf(worker_id) < 0) {
+ firebase.createWorker(worker_id, worker_name, avatar_url);
+ }
+ }).catch(function (err) {
+ console.trace(err);
+ });
+ })
+ .catch(function (err) {
+ console.log("Error fetching user data:", err);
+ });
+ res.json({
+ 'Success': 200
+ })
+ }).catch(function (err) {
+ // Handle error
+ console.trace(err);
+ });
+ };
 }));
 app.use(cookieParser());
 app.use(isAuth);
 app.use('/api/v1', require('./routes/api')(wagner));
 app.use(express.static(path.join(__dirname, 'public')));
 app.use(require('./routes/app-routing')(wagner));
 // catch 404 and forward to error handler
-app.use(function(req, res, next) {
- var err = new Error('Not Found');
- err.status = 404;
- next(err);
+app.use(function(req, res, next) {
+var err = new Error('Not Found');
+err.status = 404;
+next(err);
 });
 
 // error handler
-app.use(function(err, req, res, next) {
- // set locals, only providing error in development
- res.locals.message = err.message;
- res.locals.error = req.app.get('env') === 'development' ? err : {};
+app.use(function(err, req, res, next) {
+// set locals, only providing error in development
+res.locals.message = err.message;
+res.locals.error = req.app.get('env') === 'development' ? err : {};
 
- // render the error page
- res.status(err.status || 500);
- res.sendFile(path.join(__dirname, '/public/404.html'));
+// render the error page
+res.status(err.status || 500);
+res.sendFile(path.join(__dirname, '/public/404.html'));
 });
 
 module.exports = app;

config/config.json

@@ -2,14 +2,15 @@
  "serviceAccount": {
  "type": "service_account",
  "project_id": "crowdcode2",
- "private_key_id": "4ef77e02829e6ff9ba96a35d264f092025aaef1d",
- "private_key": "-----BEGIN PRIVATE KEY-----\nMIIEvwIBADANBgkqhkiG9w0BAQEFAASCBKkwggSlAgEAAoIBAQDHZvikJdmZv5zI\nbM6ECnfp77QiFQidH93goS0438aGk5YR1La8tuOD62khNa3qbCNA2qMtj5c/WM8L\nONuzBnLYXcRtgbjiTftok3O37aeV1yW/Hty3jkKcFf2OsYO5oQRv73joP+ADcSu0\nz9LYx4uXrAx7x9wBNLSi5GP/ecWpvLMxRJUltzUg5p2Fn1/RHfQaa+GNd3oKWABe\na0sn88V2E5EM/Ie7xkApj5ozayW9F22Fct814pk1en7ZvE1+6JuQ63+3eEpNaLaj\neeLkKCkUzSLVX6UAUpnlf3gS15jdAjoWf+jPIrlpsY0T44jRUQb4ok0Pwn6orbRO\nHoVrBsArAgMBAAECggEAB+hefev+WCmQJyahff0ISl+2Lg/Vep2z59+ccn/1WIrr\nzaM45/z8wtOIJMgDMKO/Nig1hm4GWn3EIDbOB6h+z3PQgWM+mMLs8HXAhg/HsJqK\npaysph7fJ1974bfKeIcZLPM7QUKfOKO5Tv9a5jvrnkU1bYc8g1O6wib6jDwhCZ0f\nG+oZR6ka+SPi3Z6xNoBkw/JEJC+f0WDZV4VLy+rFlgQpC2FYiFWJHxh7D0MNIVbC\n7jowXvQ7jyqaNPBysfnkoGomeFrCxV+Zc1KuuHx3PL7Z+XdJsHxfPISANU9LzrW0\nVcsZ6GOihL1YE/1blk2lyA5cYJT3Bb3ybAkIKwgm6QKBgQD7oL4CI827mGtzzTv/\nKTeWOqRARAPLggo8dS79tgfP6BKEudeJGlxLA3l+1eWFrjjEpG85nrLkcIXz4Cm9\nwZmg/esP1pts8v7rc/nJ1cL/UySznUkiGH1fLbIc8vkfTkbLx9pedjr0UAlNO+zX\nSmCE+lrHDXKn2wmTfBniewSgPwKBgQDK3ez+l7ESFaUGTyLHRe6EDvU6A9X72q6e\nJj4LVLW8JoGVezIBUk/orPij6S7oOEAMj72OCP4DCX6zZ6FfVaERZVHoSx7yBltU\n5Tf988guqR9zB4B7PrQP+uf6UXaL4LtT9XYxDvoyyqyZ8A2WRrHaks1wo+psc+lC\nNqPKoGOlFQKBgQCIC1NPwt3TpEfMN1VN0pIMNi5h1KQcnnU8VLsQTx+QJ9ADVJsU\ntFzb7cf9bFYI3bYxkxnTlFryKWgy/6pxvr96DG7PhF9KG2L6GB0gI+OmueQo/Evz\nFDyMfh9DiZZpd5/NQ4Nr+Q5M0w0EZfbaO4tNujHkVv/7gvB9feZczdglbwKBgQC6\npY6r+tK+ic2ITXz5DN1TARQcaXUSQHQSK6s/75M5ZdApwOwUDTBaKfKllCBFJaPA\nKuvC54EVOEIrO/hb50PG5oqCh8MT+EdFh5OJgia2z4GQ6uEKA3nVjgqq4xKHxZ90\nss0oe9g0rQY6p4NItQhjyldcAGPpnoeJFQ6DmieztQKBgQDToHOxSPDwfnXC+pei\nf8wbL2OReWNwnmu0kM/UUjcN6owBExaMghanUAXR8jpl229/MIUJyhGjqKpp+c3N\naVBlatxHl7niJXfV6JXu9WyfvAOC7SssAWrnDqMlWfNoPECTBZ3uItWy1FcWuFmh\n92d5t5RxFMFAG4FPws4fFKgyMg==\n-----END PRIVATE KEY-----\n",
- "client_email": "firebase-adminsdk-8ri07@crowdcode2.iam.gserviceaccount.com",
- "client_id": "116287562601899349887",
+ "private_key_id": "ee2194e5cd3aa1461e2442e81c05766eab6cfa00",
+ "private_key": "-----BEGIN PRIVATE KEY-----\nMIIEvwIBADANBgkqhkiG9w0BAQEFAASCBKkwggSlAgEAAoIBAQDazdoyIYSXq6hd\nuYVpcdYId+UzruabySi3LbURwjSLf9pSVprAdTro4c7zxBBhHz6Z35d2l/Reao6Q\nsyuIydPXz6yDM9m9ayALMYnQssTu7hwvdC2tMyBsoiG/qCRwahZmw6EatmNAN6yY\nhUi41m+dGybu/cbq/RCmtKe0BcwWhjEVcipnueD0ax0uZcmzdkwl2jT9zezFQx2t\n6MjpVYAzWxNp1voTACc/dF3Ks8pvPqHst+nXGhVWVrMDPSHum1AEwbd+9qxCjEZ0\nQGTqTeYoHULnx7IVXp1nBwy7HahrmAhiEE9g5bGBKJo9HG3seY2QhcIvN+utqAvL\ndfMdpDPfAgMBAAECggEAYgEDQyINPEw4gSaIUccZ2bguMvybsVqkQIwaBubIV1WA\nihHdhefcZ5RA+KGwvnfat9xVANsmKyYqTjjafo38M7WC7U+Lr1Ksyya4toBkQirn\n9/9fOC1m0BG88RYUoD98YjIs1oSsJwbo6XYFsTjnTGTthu2nq/iG/Ux8s19HXyyO\n2BXk/LR15cMhcCqKWs2h3zmekU83XPxPMG6/3LVdWx1SdNouHjvM2L9WzDKQnG2O\n5pTTe0J/wLAERQ7grRMen4mFrdV5FJBYnq8rLVqHMCJ6/+D7mp51hq+dJ/Kyy2nI\nZJYReWGmj1hgMQxRhpB0cBLw+bTMagt/2/DD+Jg8AQKBgQD3DcxlZuJnApl4a53L\n6lPSbvu48q+DLB2VoWM5N8jn2VvCC4RTDceF2lSFaXvF6vGdMmMbpM5UkXu0Xkof\nOvIsFQLwCNU+vsPSv3s5Rqwza3plKTb9ndRJtIBLNo9hamA7qldr2u45O3srHPIe\nQFcOBXXgvt2Rmw6VN/eJS1R0AQKBgQDiui1PdOn+lH25Zp0dTf6awmX2YKouoA1X\nn6HRrmPl6odRCRiMlWAXmUhvx67Mjwaz5FIgqC10ykgrLWe3jtIZ4T2wdyml54Dy\ncqdoLzRrak8Fgkk3AYyeiiAPHdUmkOvtyM6U6JHA0DX3DkzeEdAVvpCY9SChiKJi\ntdTh9Wcn3wKBgQDHdD5mR0/VdkXM8KUusfoGVE+pm1SThBRGb0saMK1kcRkhagbk\nvqUsrX27T9P7j5iNHtbgxIdHw0Sp883HtOE7MaNzgs4WoBCcnravIR15TfY8oa+h\nxcBT2QQStPPA5A7ZXMbDbrcRQbJItk/KmIsv6LyoO6/KE/MMCWkxUL3YAQKBgQCR\nYwN1JSp7ZmrsfYGYbhAq2yeZAsl+VoHXw3R3ydUjdO3KqAOG+q6A03kgvLI5WCnb\nJzkG2fE0KBZ5IYeVrE7L66SsSO17BmWokp8I7uQ1URlVFgOu8x5h936xUtcBAQNZ\nGmBmGnCEbL9+KjxeVpvRpb6BZwbCrqQ6mhDlyICajwKBgQCGbD3YL0AtZD0iMUdh\nvUGhHlmtN+TUcInYPiWfk9VwjUS4087AxVOrUDp8aBGUtKBVdC9g9EhmWX26vuCd\nv6yDCSF0enYPVJLI/6CU8yDK2wZCV5CE9JcCuVyu+2BZ9sgM4MfGQVcdWkbxDRfy\nIAu9OY6uEkcdJc4pB6sTZ6nA3g==\n-----END PRIVATE KEY-----\n",
+ "client_email": "firebase-adminsdk-roovx@crowdcode2.iam.gserviceaccount.com",
+ "client_id": "105510340470187039060",
  "auth_uri": "https://accounts.google.com/o/oauth2/auth",
- "token_uri": "https://accounts.google.com/o/oauth2/token",
+ "token_uri": "https://oauth2.googleapis.com/token",
  "auth_provider_x509_cert_url": "https://www.googleapis.com/oauth2/v1/certs",
- "client_x509_cert_url": "https://www.googleapis.com/robot/v1/metadata/x509/firebase-adminsdk-8ri07%40crowdcode2.iam.gserviceaccount.com"
+ "client_x509_cert_url": "https://www.googleapis.com/robot/v1/metadata/x509/firebase-adminsdk-roovx%40crowdcode2.iam.gserviceaccount.com",
+ "universe_domain": "googleapis.com"
  },
  "firebaseConfig": {
  "apiKey": "AIzaSyCmhzDIbe7pp8dl0gveS2TtOH4n8mvMzsU",

README.md

@@ -1,5 +1,5 @@
 # Crowd Microservices
-Demo of Crowd Microservices environment
+Demo of Crowd Microservices environment.
 
 
 

app.js

@@ -6,8 +6,9 @@ const favicon = require('serve-favicon');
 const logger = require('morgan');
 const cookieParser = require('cookie-parser');
 const bodyParser = require('body-parser');
+const firebaseConstant = require('firebase');
 const cors = require('cors')({
- origin: true
+origin: true
 });
 const status = require('http-status');
 const wagner = require('wagner-core');
@@ -22,89 +23,101 @@ app.set('views', path.join(__dirname, 'public'));
 app.use(logger('dev'));
 app.use(cookieParser());
 app.use(session({
- name: 'server-session-cookie-id',
- secret: 'my express secret',
- saveUninitialized: true,
- resave: true,
- store: new FileStore({
- retries: 10,
- minTimeout: 100,
- maxTimeout: 200,
- path: path.join(__dirname,'sessions')
- })
+name: 'server-session-cookie-id',
+secret: 'my express secret',
+saveUninitialized: true,
+resave: true,
+store: new FileStore({
+retries: 10,
+minTimeout: 100,
+maxTimeout: 200,
+path: path.join(__dirname,'sessions')
+})
 }));
-const isAuth = wagner.invoke(function() {
- return (req, res, next) => {
-if(req.session.user || req.path==='/login' || req.path === '/loggedin.html') {
- req.user = req.session.user;
- next();
- } else {
- res.redirect('/login');
- }
- };
+const isAuth = wagner.invoke(function() {
+return (req, res, next) => {
+ if (req.session.user || req.path==='/login' || req.path === '/loggedin.html') {
+req.user = req.session.user;
+next();
+} else {
+res.redirect('/login');
+}
+};
 });
 app.use(bodyParser.json());
 app.use(bodyParser.urlencoded({
- extended: false
+extended: false
 }));
-app.post('/authenticate', wagner.invoke(function(UserService, AdminFirebase, FirebaseService) {
- return function(req, res) {
- //var idToken = req.body.idToken;
- var idToken = req.headers['authorization'].split(' ').pop();
- AdminFirebase.auth().verifyIdToken(idToken)
- .then(function(decodedToken) {
- var uid = decodedToken.uid;
- req.session.user = decodedToken;
- UserService.getUserById(uid)
- .then(function(userRecord) {
- // See the UserRecord reference doc for the contents of userRecord.
- console.log("Successfully fetched user data:", userRecord.toJSON());
- var worker_id = userRecord.uid;
- var worker_name = userRecord.displayName;
- var avatar_url = userRecord.photoURL;
- var firebase = FirebaseService;
- var workers_list_promise = firebase.retrieveWorkersList();
- workers_list_promise.then(function(workers_list) {
- if (workers_list.indexOf(worker_id) < 0) {
- firebase.createWorker(worker_id, worker_name, avatar_url);
- }
- }).catch(function(err) {
- console.trace(err);
- });
- })
- .catch(function(err) {
- console.log("Error fetching user data:", err);
- });
- res.json({
- 'Success': 200
- })
- }).catch(function(err) {
- // Handle error
- console.trace(err);
- });
- };
+app.post('/authenticate', wagner.invoke(function (UserService, AdminFirebase, FirebaseService) {
+ return function (req, res) {
+ //var idToken = req.body.idToken;
+ var idToken = req.headers['authorization'].split(' ').pop();
+ AdminFirebase.auth().verifyIdToken(idToken)
+ .then(function (decodedToken) {
+ var uid = decodedToken.uid;
+ req.session.user = decodedToken;
+ UserService.getUserById(uid)
+ .then(function (userRecord) {
+ // See the UserRecord reference doc for the contents of userRecord.
+ console.log("Successfully fetched user data:", userRecord.toJSON());
+ var worker_id = userRecord.uid;
+ var worker_name = userRecord.displayName;
+ var avatar_url = userRecord.photoURL;
+ var firebase = FirebaseService;
+ // logs worker authentication
+ var ref = AdminFirebase.database().ref().child('Workers').child('logs');
+ ref.push({
+ eventType: "LoggedIn",
+ eventDescription: "Logged in successfully",
+ timestamp: firebaseConstant.database.ServerValue.TIMESTAMP,
+ workerId: userRecord.uid,
+ workerName: userRecord.displayName
+ }).catch(e => {
+ console.log(e)
+ });
+
+ var workers_list_promise = firebase.retrieveWorkersList();
+ workers_list_promise.then(function (workers_list) {
+ if (workers_list.indexOf(worker_id) < 0) {
+ firebase.createWorker(worker_id, worker_name, avatar_url);
+ }
+ }).catch(function (err) {
+ console.trace(err);
+ });
+ })
+ .catch(function (err) {
+ console.log("Error fetching user data:", err);
+ });
+ res.json({
+ 'Success': 200
+ })
+ }).catch(function (err) {
+ // Handle error
+ console.trace(err);
+ });
+ };
 }));
 app.use(cookieParser());
 app.use(isAuth);
 app.use('/api/v1', require('./routes/api')(wagner));
 app.use(express.static(path.join(__dirname, 'public')));
 app.use(require('./routes/app-routing')(wagner));
 // catch 404 and forward to error handler
-app.use(function(req, res, next) {
- var err = new Error('Not Found');
- err.status = 404;
- next(err);
+app.use(function(req, res, next) {
+var err = new Error('Not Found');
+err.status = 404;
+next(err);
 });
 
 // error handler
-app.use(function(err, req, res, next) {
- // set locals, only providing error in development
- res.locals.message = err.message;
- res.locals.error = req.app.get('env') === 'development' ? err : {};
+app.use(function(err, req, res, next) {
+// set locals, only providing error in development
+res.locals.message = err.message;
+res.locals.error = req.app.get('env') === 'development' ? err : {};
 
- // render the error page
- res.status(err.status || 500);
- res.sendFile(path.join(__dirname, '/public/404.html'));
+// render the error page
+res.status(err.status || 500);
+res.sendFile(path.join(__dirname, '/public/404.html'));
 });
 
 module.exports = app;

config/config.json

@@ -2,14 +2,15 @@
  "serviceAccount": {
  "type": "service_account",
  "project_id": "crowdcode2",
- "private_key_id": "4ef77e02829e6ff9ba96a35d264f092025aaef1d",
- "private_key": "-----BEGIN PRIVATE KEY-----\nMIIEvwIBADANBgkqhkiG9w0BAQEFAASCBKkwggSlAgEAAoIBAQDHZvikJdmZv5zI\nbM6ECnfp77QiFQidH93goS0438aGk5YR1La8tuOD62khNa3qbCNA2qMtj5c/WM8L\nONuzBnLYXcRtgbjiTftok3O37aeV1yW/Hty3jkKcFf2OsYO5oQRv73joP+ADcSu0\nz9LYx4uXrAx7x9wBNLSi5GP/ecWpvLMxRJUltzUg5p2Fn1/RHfQaa+GNd3oKWABe\na0sn88V2E5EM/Ie7xkApj5ozayW9F22Fct814pk1en7ZvE1+6JuQ63+3eEpNaLaj\neeLkKCkUzSLVX6UAUpnlf3gS15jdAjoWf+jPIrlpsY0T44jRUQb4ok0Pwn6orbRO\nHoVrBsArAgMBAAECggEAB+hefev+WCmQJyahff0ISl+2Lg/Vep2z59+ccn/1WIrr\nzaM45/z8wtOIJMgDMKO/Nig1hm4GWn3EIDbOB6h+z3PQgWM+mMLs8HXAhg/HsJqK\npaysph7fJ1974bfKeIcZLPM7QUKfOKO5Tv9a5jvrnkU1bYc8g1O6wib6jDwhCZ0f\nG+oZR6ka+SPi3Z6xNoBkw/JEJC+f0WDZV4VLy+rFlgQpC2FYiFWJHxh7D0MNIVbC\n7jowXvQ7jyqaNPBysfnkoGomeFrCxV+Zc1KuuHx3PL7Z+XdJsHxfPISANU9LzrW0\nVcsZ6GOihL1YE/1blk2lyA5cYJT3Bb3ybAkIKwgm6QKBgQD7oL4CI827mGtzzTv/\nKTeWOqRARAPLggo8dS79tgfP6BKEudeJGlxLA3l+1eWFrjjEpG85nrLkcIXz4Cm9\nwZmg/esP1pts8v7rc/nJ1cL/UySznUkiGH1fLbIc8vkfTkbLx9pedjr0UAlNO+zX\nSmCE+lrHDXKn2wmTfBniewSgPwKBgQDK3ez+l7ESFaUGTyLHRe6EDvU6A9X72q6e\nJj4LVLW8JoGVezIBUk/orPij6S7oOEAMj72OCP4DCX6zZ6FfVaERZVHoSx7yBltU\n5Tf988guqR9zB4B7PrQP+uf6UXaL4LtT9XYxDvoyyqyZ8A2WRrHaks1wo+psc+lC\nNqPKoGOlFQKBgQCIC1NPwt3TpEfMN1VN0pIMNi5h1KQcnnU8VLsQTx+QJ9ADVJsU\ntFzb7cf9bFYI3bYxkxnTlFryKWgy/6pxvr96DG7PhF9KG2L6GB0gI+OmueQo/Evz\nFDyMfh9DiZZpd5/NQ4Nr+Q5M0w0EZfbaO4tNujHkVv/7gvB9feZczdglbwKBgQC6\npY6r+tK+ic2ITXz5DN1TARQcaXUSQHQSK6s/75M5ZdApwOwUDTBaKfKllCBFJaPA\nKuvC54EVOEIrO/hb50PG5oqCh8MT+EdFh5OJgia2z4GQ6uEKA3nVjgqq4xKHxZ90\nss0oe9g0rQY6p4NItQhjyldcAGPpnoeJFQ6DmieztQKBgQDToHOxSPDwfnXC+pei\nf8wbL2OReWNwnmu0kM/UUjcN6owBExaMghanUAXR8jpl229/MIUJyhGjqKpp+c3N\naVBlatxHl7niJXfV6JXu9WyfvAOC7SssAWrnDqMlWfNoPECTBZ3uItWy1FcWuFmh\n92d5t5RxFMFAG4FPws4fFKgyMg==\n-----END PRIVATE KEY-----\n",
- "client_email": "firebase-adminsdk-8ri07@crowdcode2.iam.gserviceaccount.com",
- "client_id": "116287562601899349887",
+ "private_key_id": "ee2194e5cd3aa1461e2442e81c05766eab6cfa00",
+ "private_key": "-----BEGIN PRIVATE KEY-----\nMIIEvwIBADANBgkqhkiG9w0BAQEFAASCBKkwggSlAgEAAoIBAQDazdoyIYSXq6hd\nuYVpcdYId+UzruabySi3LbURwjSLf9pSVprAdTro4c7zxBBhHz6Z35d2l/Reao6Q\nsyuIydPXz6yDM9m9ayALMYnQssTu7hwvdC2tMyBsoiG/qCRwahZmw6EatmNAN6yY\nhUi41m+dGybu/cbq/RCmtKe0BcwWhjEVcipnueD0ax0uZcmzdkwl2jT9zezFQx2t\n6MjpVYAzWxNp1voTACc/dF3Ks8pvPqHst+nXGhVWVrMDPSHum1AEwbd+9qxCjEZ0\nQGTqTeYoHULnx7IVXp1nBwy7HahrmAhiEE9g5bGBKJo9HG3seY2QhcIvN+utqAvL\ndfMdpDPfAgMBAAECggEAYgEDQyINPEw4gSaIUccZ2bguMvybsVqkQIwaBubIV1WA\nihHdhefcZ5RA+KGwvnfat9xVANsmKyYqTjjafo38M7WC7U+Lr1Ksyya4toBkQirn\n9/9fOC1m0BG88RYUoD98YjIs1oSsJwbo6XYFsTjnTGTthu2nq/iG/Ux8s19HXyyO\n2BXk/LR15cMhcCqKWs2h3zmekU83XPxPMG6/3LVdWx1SdNouHjvM2L9WzDKQnG2O\n5pTTe0J/wLAERQ7grRMen4mFrdV5FJBYnq8rLVqHMCJ6/+D7mp51hq+dJ/Kyy2nI\nZJYReWGmj1hgMQxRhpB0cBLw+bTMagt/2/DD+Jg8AQKBgQD3DcxlZuJnApl4a53L\n6lPSbvu48q+DLB2VoWM5N8jn2VvCC4RTDceF2lSFaXvF6vGdMmMbpM5UkXu0Xkof\nOvIsFQLwCNU+vsPSv3s5Rqwza3plKTb9ndRJtIBLNo9hamA7qldr2u45O3srHPIe\nQFcOBXXgvt2Rmw6VN/eJS1R0AQKBgQDiui1PdOn+lH25Zp0dTf6awmX2YKouoA1X\nn6HRrmPl6odRCRiMlWAXmUhvx67Mjwaz5FIgqC10ykgrLWe3jtIZ4T2wdyml54Dy\ncqdoLzRrak8Fgkk3AYyeiiAPHdUmkOvtyM6U6JHA0DX3DkzeEdAVvpCY9SChiKJi\ntdTh9Wcn3wKBgQDHdD5mR0/VdkXM8KUusfoGVE+pm1SThBRGb0saMK1kcRkhagbk\nvqUsrX27T9P7j5iNHtbgxIdHw0Sp883HtOE7MaNzgs4WoBCcnravIR15TfY8oa+h\nxcBT2QQStPPA5A7ZXMbDbrcRQbJItk/KmIsv6LyoO6/KE/MMCWkxUL3YAQKBgQCR\nYwN1JSp7ZmrsfYGYbhAq2yeZAsl+VoHXw3R3ydUjdO3KqAOG+q6A03kgvLI5WCnb\nJzkG2fE0KBZ5IYeVrE7L66SsSO17BmWokp8I7uQ1URlVFgOu8x5h936xUtcBAQNZ\nGmBmGnCEbL9+KjxeVpvRpb6BZwbCrqQ6mhDlyICajwKBgQCGbD3YL0AtZD0iMUdh\nvUGhHlmtN+TUcInYPiWfk9VwjUS4087AxVOrUDp8aBGUtKBVdC9g9EhmWX26vuCd\nv6yDCSF0enYPVJLI/6CU8yDK2wZCV5CE9JcCuVyu+2BZ9sgM4MfGQVcdWkbxDRfy\nIAu9OY6uEkcdJc4pB6sTZ6nA3g==\n-----END PRIVATE KEY-----\n",
+ "client_email": "firebase-adminsdk-roovx@crowdcode2.iam.gserviceaccount.com",
+ "client_id": "105510340470187039060",
  "auth_uri": "https://accounts.google.com/o/oauth2/auth",
- "token_uri": "https://accounts.google.com/o/oauth2/token",
+ "token_uri": "https://oauth2.googleapis.com/token",
  "auth_provider_x509_cert_url": "https://www.googleapis.com/oauth2/v1/certs",
- "client_x509_cert_url": "https://www.googleapis.com/robot/v1/metadata/x509/firebase-adminsdk-8ri07%40crowdcode2.iam.gserviceaccount.com"
+ "client_x509_cert_url": "https://www.googleapis.com/robot/v1/metadata/x509/firebase-adminsdk-roovx%40crowdcode2.iam.gserviceaccount.com",
+ "universe_domain": "googleapis.com"
  },
  "firebaseConfig": {
  "apiKey": "AIzaSyCmhzDIbe7pp8dl0gveS2TtOH4n8mvMzsU",

README.md

@@ -1,5 +1,5 @@
 # Crowd Microservices
-Demo of Crowd Microservices environment
+Demo of Crowd Microservices environment.
 
 
 

app.js

@@ -6,8 +6,9 @@ const favicon = require('serve-favicon');
 const logger = require('morgan');
 const cookieParser = require('cookie-parser');
 const bodyParser = require('body-parser');
+const firebaseConstant = require('firebase');
 const cors = require('cors')({
- origin: true
+origin: true
 });
 const status = require('http-status');
 const wagner = require('wagner-core');
@@ -22,89 +23,101 @@ app.set('views', path.join(__dirname, 'public'));
 app.use(logger('dev'));
 app.use(cookieParser());
 app.use(session({
- name: 'server-session-cookie-id',
- secret: 'my express secret',
- saveUninitialized: true,
- resave: true,
- store: new FileStore({
- retries: 10,
- minTimeout: 100,
- maxTimeout: 200,
- path: path.join(__dirname,'sessions')
- })
+name: 'server-session-cookie-id',
+secret: 'my express secret',
+saveUninitialized: true,
+resave: true,
+store: new FileStore({
+retries: 10,
+minTimeout: 100,
+maxTimeout: 200,
+path: path.join(__dirname,'sessions')
+})
 }));
-const isAuth = wagner.invoke(function() {
- return (req, res, next) => {
-if(req.session.user || req.path==='/login' || req.path === '/loggedin.html') {
- req.user = req.session.user;
- next();
- } else {
- res.redirect('/login');
- }
- };
+const isAuth = wagner.invoke(function() {
+return (req, res, next) => {
+ if (req.session.user || req.path==='/login' || req.path === '/loggedin.html') {
+req.user = req.session.user;
+next();
+} else {
+res.redirect('/login');
+}
+};
 });
 app.use(bodyParser.json());
 app.use(bodyParser.urlencoded({
- extended: false
+extended: false
 }));
-app.post('/authenticate', wagner.invoke(function(UserService, AdminFirebase, FirebaseService) {
- return function(req, res) {
- //var idToken = req.body.idToken;
- var idToken = req.headers['authorization'].split(' ').pop();
- AdminFirebase.auth().verifyIdToken(idToken)
- .then(function(decodedToken) {
- var uid = decodedToken.uid;
- req.session.user = decodedToken;
- UserService.getUserById(uid)
- .then(function(userRecord) {
- // See the UserRecord reference doc for the contents of userRecord.
- console.log("Successfully fetched user data:", userRecord.toJSON());
- var worker_id = userRecord.uid;
- var worker_name = userRecord.displayName;
- var avatar_url = userRecord.photoURL;
- var firebase = FirebaseService;
- var workers_list_promise = firebase.retrieveWorkersList();
- workers_list_promise.then(function(workers_list) {
- if (workers_list.indexOf(worker_id) < 0) {
- firebase.createWorker(worker_id, worker_name, avatar_url);
- }
- }).catch(function(err) {
- console.trace(err);
- });
- })
- .catch(function(err) {
- console.log("Error fetching user data:", err);
- });
- res.json({
- 'Success': 200
- })
- }).catch(function(err) {
- // Handle error
- console.trace(err);
- });
- };
+app.post('/authenticate', wagner.invoke(function (UserService, AdminFirebase, FirebaseService) {
+ return function (req, res) {
+ //var idToken = req.body.idToken;
+ var idToken = req.headers['authorization'].split(' ').pop();
+ AdminFirebase.auth().verifyIdToken(idToken)
+ .then(function (decodedToken) {
+ var uid = decodedToken.uid;
+ req.session.user = decodedToken;
+ UserService.getUserById(uid)
+ .then(function (userRecord) {
+ // See the UserRecord reference doc for the contents of userRecord.
+ console.log("Successfully fetched user data:", userRecord.toJSON());
+ var worker_id = userRecord.uid;
+ var worker_name = userRecord.displayName;
+ var avatar_url = userRecord.photoURL;
+ var firebase = FirebaseService;
+ // logs worker authentication
+ var ref = AdminFirebase.database().ref().child('Workers').child('logs');
+ ref.push({
+ eventType: "LoggedIn",
+ eventDescription: "Logged in successfully",
+ timestamp: firebaseConstant.database.ServerValue.TIMESTAMP,
+ workerId: userRecord.uid,
+ workerName: userRecord.displayName
+ }).catch(e => {
+ console.log(e)
+ });
+
+ var workers_list_promise = firebase.retrieveWorkersList();
+ workers_list_promise.then(function (workers_list) {
+ if (workers_list.indexOf(worker_id) < 0) {
+ firebase.createWorker(worker_id, worker_name, avatar_url);
+ }
+ }).catch(function (err) {
+ console.trace(err);
+ });
+ })
+ .catch(function (err) {
+ console.log("Error fetching user data:", err);
+ });
+ res.json({
+ 'Success': 200
+ })
+ }).catch(function (err) {
+ // Handle error
+ console.trace(err);
+ });
+ };
 }));
 app.use(cookieParser());
 app.use(isAuth);
 app.use('/api/v1', require('./routes/api')(wagner));
 app.use(express.static(path.join(__dirname, 'public')));
 app.use(require('./routes/app-routing')(wagner));
 // catch 404 and forward to error handler
-app.use(function(req, res, next) {
- var err = new Error('Not Found');
- err.status = 404;
- next(err);
+app.use(function(req, res, next) {
+var err = new Error('Not Found');
+err.status = 404;
+next(err);
 });
 
 // error handler
-app.use(function(err, req, res, next) {
- // set locals, only providing error in development
- res.locals.message = err.message;
- res.locals.error = req.app.get('env') === 'development' ? err : {};
+app.use(function(err, req, res, next) {
+// set locals, only providing error in development
+res.locals.message = err.message;
+res.locals.error = req.app.get('env') === 'development' ? err : {};
 
- // render the error page
- res.status(err.status || 500);
- res.sendFile(path.join(__dirname, '/public/404.html'));
+// render the error page
+res.status(err.status || 500);
+res.sendFile(path.join(__dirname, '/public/404.html'));
 });
 
 module.exports = app;

config/config.json

@@ -2,14 +2,15 @@
  "serviceAccount": {
  "type": "service_account",
  "project_id": "crowdcode2",
- "private_key_id": "4ef77e02829e6ff9ba96a35d264f092025aaef1d",
- "private_key": "-----BEGIN PRIVATE KEY-----\nMIIEvwIBADANBgkqhkiG9w0BAQEFAASCBKkwggSlAgEAAoIBAQDHZvikJdmZv5zI\nbM6ECnfp77QiFQidH93goS0438aGk5YR1La8tuOD62khNa3qbCNA2qMtj5c/WM8L\nONuzBnLYXcRtgbjiTftok3O37aeV1yW/Hty3jkKcFf2OsYO5oQRv73joP+ADcSu0\nz9LYx4uXrAx7x9wBNLSi5GP/ecWpvLMxRJUltzUg5p2Fn1/RHfQaa+GNd3oKWABe\na0sn88V2E5EM/Ie7xkApj5ozayW9F22Fct814pk1en7ZvE1+6JuQ63+3eEpNaLaj\neeLkKCkUzSLVX6UAUpnlf3gS15jdAjoWf+jPIrlpsY0T44jRUQb4ok0Pwn6orbRO\nHoVrBsArAgMBAAECggEAB+hefev+WCmQJyahff0ISl+2Lg/Vep2z59+ccn/1WIrr\nzaM45/z8wtOIJMgDMKO/Nig1hm4GWn3EIDbOB6h+z3PQgWM+mMLs8HXAhg/HsJqK\npaysph7fJ1974bfKeIcZLPM7QUKfOKO5Tv9a5jvrnkU1bYc8g1O6wib6jDwhCZ0f\nG+oZR6ka+SPi3Z6xNoBkw/JEJC+f0WDZV4VLy+rFlgQpC2FYiFWJHxh7D0MNIVbC\n7jowXvQ7jyqaNPBysfnkoGomeFrCxV+Zc1KuuHx3PL7Z+XdJsHxfPISANU9LzrW0\nVcsZ6GOihL1YE/1blk2lyA5cYJT3Bb3ybAkIKwgm6QKBgQD7oL4CI827mGtzzTv/\nKTeWOqRARAPLggo8dS79tgfP6BKEudeJGlxLA3l+1eWFrjjEpG85nrLkcIXz4Cm9\nwZmg/esP1pts8v7rc/nJ1cL/UySznUkiGH1fLbIc8vkfTkbLx9pedjr0UAlNO+zX\nSmCE+lrHDXKn2wmTfBniewSgPwKBgQDK3ez+l7ESFaUGTyLHRe6EDvU6A9X72q6e\nJj4LVLW8JoGVezIBUk/orPij6S7oOEAMj72OCP4DCX6zZ6FfVaERZVHoSx7yBltU\n5Tf988guqR9zB4B7PrQP+uf6UXaL4LtT9XYxDvoyyqyZ8A2WRrHaks1wo+psc+lC\nNqPKoGOlFQKBgQCIC1NPwt3TpEfMN1VN0pIMNi5h1KQcnnU8VLsQTx+QJ9ADVJsU\ntFzb7cf9bFYI3bYxkxnTlFryKWgy/6pxvr96DG7PhF9KG2L6GB0gI+OmueQo/Evz\nFDyMfh9DiZZpd5/NQ4Nr+Q5M0w0EZfbaO4tNujHkVv/7gvB9feZczdglbwKBgQC6\npY6r+tK+ic2ITXz5DN1TARQcaXUSQHQSK6s/75M5ZdApwOwUDTBaKfKllCBFJaPA\nKuvC54EVOEIrO/hb50PG5oqCh8MT+EdFh5OJgia2z4GQ6uEKA3nVjgqq4xKHxZ90\nss0oe9g0rQY6p4NItQhjyldcAGPpnoeJFQ6DmieztQKBgQDToHOxSPDwfnXC+pei\nf8wbL2OReWNwnmu0kM/UUjcN6owBExaMghanUAXR8jpl229/MIUJyhGjqKpp+c3N\naVBlatxHl7niJXfV6JXu9WyfvAOC7SssAWrnDqMlWfNoPECTBZ3uItWy1FcWuFmh\n92d5t5RxFMFAG4FPws4fFKgyMg==\n-----END PRIVATE KEY-----\n",
- "client_email": "firebase-adminsdk-8ri07@crowdcode2.iam.gserviceaccount.com",
- "client_id": "116287562601899349887",
+ "private_key_id": "ee2194e5cd3aa1461e2442e81c05766eab6cfa00",
+ "private_key": "-----BEGIN PRIVATE KEY-----\nMIIEvwIBADANBgkqhkiG9w0BAQEFAASCBKkwggSlAgEAAoIBAQDazdoyIYSXq6hd\nuYVpcdYId+UzruabySi3LbURwjSLf9pSVprAdTro4c7zxBBhHz6Z35d2l/Reao6Q\nsyuIydPXz6yDM9m9ayALMYnQssTu7hwvdC2tMyBsoiG/qCRwahZmw6EatmNAN6yY\nhUi41m+dGybu/cbq/RCmtKe0BcwWhjEVcipnueD0ax0uZcmzdkwl2jT9zezFQx2t\n6MjpVYAzWxNp1voTACc/dF3Ks8pvPqHst+nXGhVWVrMDPSHum1AEwbd+9qxCjEZ0\nQGTqTeYoHULnx7IVXp1nBwy7HahrmAhiEE9g5bGBKJo9HG3seY2QhcIvN+utqAvL\ndfMdpDPfAgMBAAECggEAYgEDQyINPEw4gSaIUccZ2bguMvybsVqkQIwaBubIV1WA\nihHdhefcZ5RA+KGwvnfat9xVANsmKyYqTjjafo38M7WC7U+Lr1Ksyya4toBkQirn\n9/9fOC1m0BG88RYUoD98YjIs1oSsJwbo6XYFsTjnTGTthu2nq/iG/Ux8s19HXyyO\n2BXk/LR15cMhcCqKWs2h3zmekU83XPxPMG6/3LVdWx1SdNouHjvM2L9WzDKQnG2O\n5pTTe0J/wLAERQ7grRMen4mFrdV5FJBYnq8rLVqHMCJ6/+D7mp51hq+dJ/Kyy2nI\nZJYReWGmj1hgMQxRhpB0cBLw+bTMagt/2/DD+Jg8AQKBgQD3DcxlZuJnApl4a53L\n6lPSbvu48q+DLB2VoWM5N8jn2VvCC4RTDceF2lSFaXvF6vGdMmMbpM5UkXu0Xkof\nOvIsFQLwCNU+vsPSv3s5Rqwza3plKTb9ndRJtIBLNo9hamA7qldr2u45O3srHPIe\nQFcOBXXgvt2Rmw6VN/eJS1R0AQKBgQDiui1PdOn+lH25Zp0dTf6awmX2YKouoA1X\nn6HRrmPl6odRCRiMlWAXmUhvx67Mjwaz5FIgqC10ykgrLWe3jtIZ4T2wdyml54Dy\ncqdoLzRrak8Fgkk3AYyeiiAPHdUmkOvtyM6U6JHA0DX3DkzeEdAVvpCY9SChiKJi\ntdTh9Wcn3wKBgQDHdD5mR0/VdkXM8KUusfoGVE+pm1SThBRGb0saMK1kcRkhagbk\nvqUsrX27T9P7j5iNHtbgxIdHw0Sp883HtOE7MaNzgs4WoBCcnravIR15TfY8oa+h\nxcBT2QQStPPA5A7ZXMbDbrcRQbJItk/KmIsv6LyoO6/KE/MMCWkxUL3YAQKBgQCR\nYwN1JSp7ZmrsfYGYbhAq2yeZAsl+VoHXw3R3ydUjdO3KqAOG+q6A03kgvLI5WCnb\nJzkG2fE0KBZ5IYeVrE7L66SsSO17BmWokp8I7uQ1URlVFgOu8x5h936xUtcBAQNZ\nGmBmGnCEbL9+KjxeVpvRpb6BZwbCrqQ6mhDlyICajwKBgQCGbD3YL0AtZD0iMUdh\nvUGhHlmtN+TUcInYPiWfk9VwjUS4087AxVOrUDp8aBGUtKBVdC9g9EhmWX26vuCd\nv6yDCSF0enYPVJLI/6CU8yDK2wZCV5CE9JcCuVyu+2BZ9sgM4MfGQVcdWkbxDRfy\nIAu9OY6uEkcdJc4pB6sTZ6nA3g==\n-----END PRIVATE KEY-----\n",
+ "client_email": "firebase-adminsdk-roovx@crowdcode2.iam.gserviceaccount.com",
+ "client_id": "105510340470187039060",
  "auth_uri": "https://accounts.google.com/o/oauth2/auth",
- "token_uri": "https://accounts.google.com/o/oauth2/token",
+ "token_uri": "https://oauth2.googleapis.com/token",
  "auth_provider_x509_cert_url": "https://www.googleapis.com/oauth2/v1/certs",
- "client_x509_cert_url": "https://www.googleapis.com/robot/v1/metadata/x509/firebase-adminsdk-8ri07%40crowdcode2.iam.gserviceaccount.com"
+ "client_x509_cert_url": "https://www.googleapis.com/robot/v1/metadata/x509/firebase-adminsdk-roovx%40crowdcode2.iam.gserviceaccount.com",
+ "universe_domain": "googleapis.com"
  },
  "firebaseConfig": {
  "apiKey": "AIzaSyCmhzDIbe7pp8dl0gveS2TtOH4n8mvMzsU",

README.md

@@ -1,5 +1,5 @@
 # Crowd Microservices
-Demo of Crowd Microservices environment
+Demo of Crowd Microservices environment.
 
 
 

app.js

@@ -6,8 +6,9 @@ const favicon = require('serve-favicon');
 const logger = require('morgan');
 const cookieParser = require('cookie-parser');
 const bodyParser = require('body-parser');
+const firebaseConstant = require('firebase');
 const cors = require('cors')({
- origin: true
+origin: true
 });
 const status = require('http-status');
 const wagner = require('wagner-core');
@@ -22,89 +23,101 @@ app.set('views', path.join(__dirname, 'public'));
 app.use(logger('dev'));
 app.use(cookieParser());
 app.use(session({
- name: 'server-session-cookie-id',
- secret: 'my express secret',
- saveUninitialized: true,
- resave: true,
- store: new FileStore({
- retries: 10,
- minTimeout: 100,
- maxTimeout: 200,
- path: path.join(__dirname,'sessions')
- })
+name: 'server-session-cookie-id',
+secret: 'my express secret',
+saveUninitialized: true,
+resave: true,
+store: new FileStore({
+retries: 10,
+minTimeout: 100,
+maxTimeout: 200,
+path: path.join(__dirname,'sessions')
+})
 }));
-const isAuth = wagner.invoke(function() {
- return (req, res, next) => {
-if(req.session.user || req.path==='/login' || req.path === '/loggedin.html') {
- req.user = req.session.user;
- next();
- } else {
- res.redirect('/login');
- }
- };
+const isAuth = wagner.invoke(function() {
+return (req, res, next) => {
+ if (req.session.user || req.path==='/login' || req.path === '/loggedin.html') {
+req.user = req.session.user;
+next();
+} else {
+res.redirect('/login');
+}
+};
 });
 app.use(bodyParser.json());
 app.use(bodyParser.urlencoded({
- extended: false
+extended: false
 }));
-app.post('/authenticate', wagner.invoke(function(UserService, AdminFirebase, FirebaseService) {
- return function(req, res) {
- //var idToken = req.body.idToken;
- var idToken = req.headers['authorization'].split(' ').pop();
- AdminFirebase.auth().verifyIdToken(idToken)
- .then(function(decodedToken) {
- var uid = decodedToken.uid;
- req.session.user = decodedToken;
- UserService.getUserById(uid)
- .then(function(userRecord) {
- // See the UserRecord reference doc for the contents of userRecord.
- console.log("Successfully fetched user data:", userRecord.toJSON());
- var worker_id = userRecord.uid;
- var worker_name = userRecord.displayName;
- var avatar_url = userRecord.photoURL;
- var firebase = FirebaseService;
- var workers_list_promise = firebase.retrieveWorkersList();
- workers_list_promise.then(function(workers_list) {
- if (workers_list.indexOf(worker_id) < 0) {
- firebase.createWorker(worker_id, worker_name, avatar_url);
- }
- }).catch(function(err) {
- console.trace(err);
- });
- })
- .catch(function(err) {
- console.log("Error fetching user data:", err);
- });
- res.json({
- 'Success': 200
- })
- }).catch(function(err) {
- // Handle error
- console.trace(err);
- });
- };
+app.post('/authenticate', wagner.invoke(function (UserService, AdminFirebase, FirebaseService) {
+ return function (req, res) {
+ //var idToken = req.body.idToken;
+ var idToken = req.headers['authorization'].split(' ').pop();
+ AdminFirebase.auth().verifyIdToken(idToken)
+ .then(function (decodedToken) {
+ var uid = decodedToken.uid;
+ req.session.user = decodedToken;
+ UserService.getUserById(uid)
+ .then(function (userRecord) {
+ // See the UserRecord reference doc for the contents of userRecord.
+ console.log("Successfully fetched user data:", userRecord.toJSON());
+ var worker_id = userRecord.uid;
+ var worker_name = userRecord.displayName;
+ var avatar_url = userRecord.photoURL;
+ var firebase = FirebaseService;
+ // logs worker authentication
+ var ref = AdminFirebase.database().ref().child('Workers').child('logs');
+ ref.push({
+ eventType: "LoggedIn",
+ eventDescription: "Logged in successfully",
+ timestamp: firebaseConstant.database.ServerValue.TIMESTAMP,
+ workerId: userRecord.uid,
+ workerName: userRecord.displayName
+ }).catch(e => {
+ console.log(e)
+ });
+
+ var workers_list_promise = firebase.retrieveWorkersList();
+ workers_list_promise.then(function (workers_list) {
+ if (workers_list.indexOf(worker_id) < 0) {
+ firebase.createWorker(worker_id, worker_name, avatar_url);
+ }
+ }).catch(function (err) {
+ console.trace(err);
+ });
+ })
+ .catch(function (err) {
+ console.log("Error fetching user data:", err);
+ });
+ res.json({
+ 'Success': 200
+ })
+ }).catch(function (err) {
+ // Handle error
+ console.trace(err);
+ });
+ };
 }));
 app.use(cookieParser());
 app.use(isAuth);
 app.use('/api/v1', require('./routes/api')(wagner));
 app.use(express.static(path.join(__dirname, 'public')));
 app.use(require('./routes/app-routing')(wagner));
 // catch 404 and forward to error handler
-app.use(function(req, res, next) {
- var err = new Error('Not Found');
- err.status = 404;
- next(err);
+app.use(function(req, res, next) {
+var err = new Error('Not Found');
+err.status = 404;
+next(err);
 });
 
 // error handler
-app.use(function(err, req, res, next) {
- // set locals, only providing error in development
- res.locals.message = err.message;
- res.locals.error = req.app.get('env') === 'development' ? err : {};
+app.use(function(err, req, res, next) {
+// set locals, only providing error in development
+res.locals.message = err.message;
+res.locals.error = req.app.get('env') === 'development' ? err : {};
 
- // render the error page
- res.status(err.status || 500);
- res.sendFile(path.join(__dirname, '/public/404.html'));
+// render the error page
+res.status(err.status || 500);
+res.sendFile(path.join(__dirname, '/public/404.html'));
 });
 
 module.exports = app;

config/config.json

@@ -2,14 +2,15 @@
  "serviceAccount": {
  "type": "service_account",
  "project_id": "crowdcode2",
- "private_key_id": "4ef77e02829e6ff9ba96a35d264f092025aaef1d",
- "private_key": "-----BEGIN PRIVATE KEY-----\nMIIEvwIBADANBgkqhkiG9w0BAQEFAASCBKkwggSlAgEAAoIBAQDHZvikJdmZv5zI\nbM6ECnfp77QiFQidH93goS0438aGk5YR1La8tuOD62khNa3qbCNA2qMtj5c/WM8L\nONuzBnLYXcRtgbjiTftok3O37aeV1yW/Hty3jkKcFf2OsYO5oQRv73joP+ADcSu0\nz9LYx4uXrAx7x9wBNLSi5GP/ecWpvLMxRJUltzUg5p2Fn1/RHfQaa+GNd3oKWABe\na0sn88V2E5EM/Ie7xkApj5ozayW9F22Fct814pk1en7ZvE1+6JuQ63+3eEpNaLaj\neeLkKCkUzSLVX6UAUpnlf3gS15jdAjoWf+jPIrlpsY0T44jRUQb4ok0Pwn6orbRO\nHoVrBsArAgMBAAECggEAB+hefev+WCmQJyahff0ISl+2Lg/Vep2z59+ccn/1WIrr\nzaM45/z8wtOIJMgDMKO/Nig1hm4GWn3EIDbOB6h+z3PQgWM+mMLs8HXAhg/HsJqK\npaysph7fJ1974bfKeIcZLPM7QUKfOKO5Tv9a5jvrnkU1bYc8g1O6wib6jDwhCZ0f\nG+oZR6ka+SPi3Z6xNoBkw/JEJC+f0WDZV4VLy+rFlgQpC2FYiFWJHxh7D0MNIVbC\n7jowXvQ7jyqaNPBysfnkoGomeFrCxV+Zc1KuuHx3PL7Z+XdJsHxfPISANU9LzrW0\nVcsZ6GOihL1YE/1blk2lyA5cYJT3Bb3ybAkIKwgm6QKBgQD7oL4CI827mGtzzTv/\nKTeWOqRARAPLggo8dS79tgfP6BKEudeJGlxLA3l+1eWFrjjEpG85nrLkcIXz4Cm9\nwZmg/esP1pts8v7rc/nJ1cL/UySznUkiGH1fLbIc8vkfTkbLx9pedjr0UAlNO+zX\nSmCE+lrHDXKn2wmTfBniewSgPwKBgQDK3ez+l7ESFaUGTyLHRe6EDvU6A9X72q6e\nJj4LVLW8JoGVezIBUk/orPij6S7oOEAMj72OCP4DCX6zZ6FfVaERZVHoSx7yBltU\n5Tf988guqR9zB4B7PrQP+uf6UXaL4LtT9XYxDvoyyqyZ8A2WRrHaks1wo+psc+lC\nNqPKoGOlFQKBgQCIC1NPwt3TpEfMN1VN0pIMNi5h1KQcnnU8VLsQTx+QJ9ADVJsU\ntFzb7cf9bFYI3bYxkxnTlFryKWgy/6pxvr96DG7PhF9KG2L6GB0gI+OmueQo/Evz\nFDyMfh9DiZZpd5/NQ4Nr+Q5M0w0EZfbaO4tNujHkVv/7gvB9feZczdglbwKBgQC6\npY6r+tK+ic2ITXz5DN1TARQcaXUSQHQSK6s/75M5ZdApwOwUDTBaKfKllCBFJaPA\nKuvC54EVOEIrO/hb50PG5oqCh8MT+EdFh5OJgia2z4GQ6uEKA3nVjgqq4xKHxZ90\nss0oe9g0rQY6p4NItQhjyldcAGPpnoeJFQ6DmieztQKBgQDToHOxSPDwfnXC+pei\nf8wbL2OReWNwnmu0kM/UUjcN6owBExaMghanUAXR8jpl229/MIUJyhGjqKpp+c3N\naVBlatxHl7niJXfV6JXu9WyfvAOC7SssAWrnDqMlWfNoPECTBZ3uItWy1FcWuFmh\n92d5t5RxFMFAG4FPws4fFKgyMg==\n-----END PRIVATE KEY-----\n",
- "client_email": "firebase-adminsdk-8ri07@crowdcode2.iam.gserviceaccount.com",
- "client_id": "116287562601899349887",
+ "private_key_id": "ee2194e5cd3aa1461e2442e81c05766eab6cfa00",
+ "private_key": "-----BEGIN PRIVATE KEY-----\nMIIEvwIBADANBgkqhkiG9w0BAQEFAASCBKkwggSlAgEAAoIBAQDazdoyIYSXq6hd\nuYVpcdYId+UzruabySi3LbURwjSLf9pSVprAdTro4c7zxBBhHz6Z35d2l/Reao6Q\nsyuIydPXz6yDM9m9ayALMYnQssTu7hwvdC2tMyBsoiG/qCRwahZmw6EatmNAN6yY\nhUi41m+dGybu/cbq/RCmtKe0BcwWhjEVcipnueD0ax0uZcmzdkwl2jT9zezFQx2t\n6MjpVYAzWxNp1voTACc/dF3Ks8pvPqHst+nXGhVWVrMDPSHum1AEwbd+9qxCjEZ0\nQGTqTeYoHULnx7IVXp1nBwy7HahrmAhiEE9g5bGBKJo9HG3seY2QhcIvN+utqAvL\ndfMdpDPfAgMBAAECggEAYgEDQyINPEw4gSaIUccZ2bguMvybsVqkQIwaBubIV1WA\nihHdhefcZ5RA+KGwvnfat9xVANsmKyYqTjjafo38M7WC7U+Lr1Ksyya4toBkQirn\n9/9fOC1m0BG88RYUoD98YjIs1oSsJwbo6XYFsTjnTGTthu2nq/iG/Ux8s19HXyyO\n2BXk/LR15cMhcCqKWs2h3zmekU83XPxPMG6/3LVdWx1SdNouHjvM2L9WzDKQnG2O\n5pTTe0J/wLAERQ7grRMen4mFrdV5FJBYnq8rLVqHMCJ6/+D7mp51hq+dJ/Kyy2nI\nZJYReWGmj1hgMQxRhpB0cBLw+bTMagt/2/DD+Jg8AQKBgQD3DcxlZuJnApl4a53L\n6lPSbvu48q+DLB2VoWM5N8jn2VvCC4RTDceF2lSFaXvF6vGdMmMbpM5UkXu0Xkof\nOvIsFQLwCNU+vsPSv3s5Rqwza3plKTb9ndRJtIBLNo9hamA7qldr2u45O3srHPIe\nQFcOBXXgvt2Rmw6VN/eJS1R0AQKBgQDiui1PdOn+lH25Zp0dTf6awmX2YKouoA1X\nn6HRrmPl6odRCRiMlWAXmUhvx67Mjwaz5FIgqC10ykgrLWe3jtIZ4T2wdyml54Dy\ncqdoLzRrak8Fgkk3AYyeiiAPHdUmkOvtyM6U6JHA0DX3DkzeEdAVvpCY9SChiKJi\ntdTh9Wcn3wKBgQDHdD5mR0/VdkXM8KUusfoGVE+pm1SThBRGb0saMK1kcRkhagbk\nvqUsrX27T9P7j5iNHtbgxIdHw0Sp883HtOE7MaNzgs4WoBCcnravIR15TfY8oa+h\nxcBT2QQStPPA5A7ZXMbDbrcRQbJItk/KmIsv6LyoO6/KE/MMCWkxUL3YAQKBgQCR\nYwN1JSp7ZmrsfYGYbhAq2yeZAsl+VoHXw3R3ydUjdO3KqAOG+q6A03kgvLI5WCnb\nJzkG2fE0KBZ5IYeVrE7L66SsSO17BmWokp8I7uQ1URlVFgOu8x5h936xUtcBAQNZ\nGmBmGnCEbL9+KjxeVpvRpb6BZwbCrqQ6mhDlyICajwKBgQCGbD3YL0AtZD0iMUdh\nvUGhHlmtN+TUcInYPiWfk9VwjUS4087AxVOrUDp8aBGUtKBVdC9g9EhmWX26vuCd\nv6yDCSF0enYPVJLI/6CU8yDK2wZCV5CE9JcCuVyu+2BZ9sgM4MfGQVcdWkbxDRfy\nIAu9OY6uEkcdJc4pB6sTZ6nA3g==\n-----END PRIVATE KEY-----\n",
+ "client_email": "firebase-adminsdk-roovx@crowdcode2.iam.gserviceaccount.com",
+ "client_id": "105510340470187039060",
  "auth_uri": "https://accounts.google.com/o/oauth2/auth",
- "token_uri": "https://accounts.google.com/o/oauth2/token",
+ "token_uri": "https://oauth2.googleapis.com/token",
  "auth_provider_x509_cert_url": "https://www.googleapis.com/oauth2/v1/certs",
- "client_x509_cert_url": "https://www.googleapis.com/robot/v1/metadata/x509/firebase-adminsdk-8ri07%40crowdcode2.iam.gserviceaccount.com"
+ "client_x509_cert_url": "https://www.googleapis.com/robot/v1/metadata/x509/firebase-adminsdk-roovx%40crowdcode2.iam.gserviceaccount.com",
+ "universe_domain": "googleapis.com"
  },
  "firebaseConfig": {
  "apiKey": "AIzaSyCmhzDIbe7pp8dl0gveS2TtOH4n8mvMzsU",

README.md

@@ -1,5 +1,5 @@
 # Crowd Microservices
-Demo of Crowd Microservices environment
+Demo of Crowd Microservices environment.
 
 
 

app.js

@@ -6,8 +6,9 @@ const favicon = require('serve-favicon');
 const logger = require('morgan');
 const cookieParser = require('cookie-parser');
 const bodyParser = require('body-parser');
+const firebaseConstant = require('firebase');
 const cors = require('cors')({
- origin: true
+origin: true
 });
 const status = require('http-status');
 const wagner = require('wagner-core');
@@ -22,89 +23,101 @@ app.set('views', path.join(__dirname, 'public'));
 app.use(logger('dev'));
 app.use(cookieParser());
 app.use(session({
- name: 'server-session-cookie-id',
- secret: 'my express secret',
- saveUninitialized: true,
- resave: true,
- store: new FileStore({
- retries: 10,
- minTimeout: 100,
- maxTimeout: 200,
- path: path.join(__dirname,'sessions')
- })
+name: 'server-session-cookie-id',
+secret: 'my express secret',
+saveUninitialized: true,
+resave: true,
+store: new FileStore({
+retries: 10,
+minTimeout: 100,
+maxTimeout: 200,
+path: path.join(__dirname,'sessions')
+})
 }));
-const isAuth = wagner.invoke(function() {
- return (req, res, next) => {
-if(req.session.user || req.path==='/login' || req.path === '/loggedin.html') {
- req.user = req.session.user;
- next();
- } else {
- res.redirect('/login');
- }
- };
+const isAuth = wagner.invoke(function() {
+return (req, res, next) => {
+ if (req.session.user || req.path==='/login' || req.path === '/loggedin.html') {
+req.user = req.session.user;
+next();
+} else {
+res.redirect('/login');
+}
+};
 });
 app.use(bodyParser.json());
 app.use(bodyParser.urlencoded({
- extended: false
+extended: false
 }));
-app.post('/authenticate', wagner.invoke(function(UserService, AdminFirebase, FirebaseService) {
- return function(req, res) {
- //var idToken = req.body.idToken;
- var idToken = req.headers['authorization'].split(' ').pop();
- AdminFirebase.auth().verifyIdToken(idToken)
- .then(function(decodedToken) {
- var uid = decodedToken.uid;
- req.session.user = decodedToken;
- UserService.getUserById(uid)
- .then(function(userRecord) {
- // See the UserRecord reference doc for the contents of userRecord.
- console.log("Successfully fetched user data:", userRecord.toJSON());
- var worker_id = userRecord.uid;
- var worker_name = userRecord.displayName;
- var avatar_url = userRecord.photoURL;
- var firebase = FirebaseService;
- var workers_list_promise = firebase.retrieveWorkersList();
- workers_list_promise.then(function(workers_list) {
- if (workers_list.indexOf(worker_id) < 0) {
- firebase.createWorker(worker_id, worker_name, avatar_url);
- }
- }).catch(function(err) {
- console.trace(err);
- });
- })
- .catch(function(err) {
- console.log("Error fetching user data:", err);
- });
- res.json({
- 'Success': 200
- })
- }).catch(function(err) {
- // Handle error
- console.trace(err);
- });
- };
+app.post('/authenticate', wagner.invoke(function (UserService, AdminFirebase, FirebaseService) {
+ return function (req, res) {
+ //var idToken = req.body.idToken;
+ var idToken = req.headers['authorization'].split(' ').pop();
+ AdminFirebase.auth().verifyIdToken(idToken)
+ .then(function (decodedToken) {
+ var uid = decodedToken.uid;
+ req.session.user = decodedToken;
+ UserService.getUserById(uid)
+ .then(function (userRecord) {
+ // See the UserRecord reference doc for the contents of userRecord.
+ console.log("Successfully fetched user data:", userRecord.toJSON());
+ var worker_id = userRecord.uid;
+ var worker_name = userRecord.displayName;
+ var avatar_url = userRecord.photoURL;
+ var firebase = FirebaseService;
+ // logs worker authentication
+ var ref = AdminFirebase.database().ref().child('Workers').child('logs');
+ ref.push({
+ eventType: "LoggedIn",
+ eventDescription: "Logged in successfully",
+ timestamp: firebaseConstant.database.ServerValue.TIMESTAMP,
+ workerId: userRecord.uid,
+ workerName: userRecord.displayName
+ }).catch(e => {
+ console.log(e)
+ });
+
+ var workers_list_promise = firebase.retrieveWorkersList();
+ workers_list_promise.then(function (workers_list) {
+ if (workers_list.indexOf(worker_id) < 0) {
+ firebase.createWorker(worker_id, worker_name, avatar_url);
+ }
+ }).catch(function (err) {
+ console.trace(err);
+ });
+ })
+ .catch(function (err) {
+ console.log("Error fetching user data:", err);
+ });
+ res.json({
+ 'Success': 200
+ })
+ }).catch(function (err) {
+ // Handle error
+ console.trace(err);
+ });
+ };
 }));
 app.use(cookieParser());
 app.use(isAuth);
 app.use('/api/v1', require('./routes/api')(wagner));
 app.use(express.static(path.join(__dirname, 'public')));
 app.use(require('./routes/app-routing')(wagner));
 // catch 404 and forward to error handler
-app.use(function(req, res, next) {
- var err = new Error('Not Found');
- err.status = 404;
- next(err);
+app.use(function(req, res, next) {
+var err = new Error('Not Found');
+err.status = 404;
+next(err);
 });
 
 // error handler
-app.use(function(err, req, res, next) {
- // set locals, only providing error in development
- res.locals.message = err.message;
- res.locals.error = req.app.get('env') === 'development' ? err : {};
+app.use(function(err, req, res, next) {
+// set locals, only providing error in development
+res.locals.message = err.message;
+res.locals.error = req.app.get('env') === 'development' ? err : {};
 
- // render the error page
- res.status(err.status || 500);
- res.sendFile(path.join(__dirname, '/public/404.html'));
+// render the error page
+res.status(err.status || 500);
+res.sendFile(path.join(__dirname, '/public/404.html'));
 });
 
 module.exports = app;

config/config.json

@@ -2,14 +2,15 @@
  "serviceAccount": {
  "type": "service_account",
  "project_id": "crowdcode2",
- "private_key_id": "4ef77e02829e6ff9ba96a35d264f092025aaef1d",
- "private_key": "-----BEGIN PRIVATE KEY-----\nMIIEvwIBADANBgkqhkiG9w0BAQEFAASCBKkwggSlAgEAAoIBAQDHZvikJdmZv5zI\nbM6ECnfp77QiFQidH93goS0438aGk5YR1La8tuOD62khNa3qbCNA2qMtj5c/WM8L\nONuzBnLYXcRtgbjiTftok3O37aeV1yW/Hty3jkKcFf2OsYO5oQRv73joP+ADcSu0\nz9LYx4uXrAx7x9wBNLSi5GP/ecWpvLMxRJUltzUg5p2Fn1/RHfQaa+GNd3oKWABe\na0sn88V2E5EM/Ie7xkApj5ozayW9F22Fct814pk1en7ZvE1+6JuQ63+3eEpNaLaj\neeLkKCkUzSLVX6UAUpnlf3gS15jdAjoWf+jPIrlpsY0T44jRUQb4ok0Pwn6orbRO\nHoVrBsArAgMBAAECggEAB+hefev+WCmQJyahff0ISl+2Lg/Vep2z59+ccn/1WIrr\nzaM45/z8wtOIJMgDMKO/Nig1hm4GWn3EIDbOB6h+z3PQgWM+mMLs8HXAhg/HsJqK\npaysph7fJ1974bfKeIcZLPM7QUKfOKO5Tv9a5jvrnkU1bYc8g1O6wib6jDwhCZ0f\nG+oZR6ka+SPi3Z6xNoBkw/JEJC+f0WDZV4VLy+rFlgQpC2FYiFWJHxh7D0MNIVbC\n7jowXvQ7jyqaNPBysfnkoGomeFrCxV+Zc1KuuHx3PL7Z+XdJsHxfPISANU9LzrW0\nVcsZ6GOihL1YE/1blk2lyA5cYJT3Bb3ybAkIKwgm6QKBgQD7oL4CI827mGtzzTv/\nKTeWOqRARAPLggo8dS79tgfP6BKEudeJGlxLA3l+1eWFrjjEpG85nrLkcIXz4Cm9\nwZmg/esP1pts8v7rc/nJ1cL/UySznUkiGH1fLbIc8vkfTkbLx9pedjr0UAlNO+zX\nSmCE+lrHDXKn2wmTfBniewSgPwKBgQDK3ez+l7ESFaUGTyLHRe6EDvU6A9X72q6e\nJj4LVLW8JoGVezIBUk/orPij6S7oOEAMj72OCP4DCX6zZ6FfVaERZVHoSx7yBltU\n5Tf988guqR9zB4B7PrQP+uf6UXaL4LtT9XYxDvoyyqyZ8A2WRrHaks1wo+psc+lC\nNqPKoGOlFQKBgQCIC1NPwt3TpEfMN1VN0pIMNi5h1KQcnnU8VLsQTx+QJ9ADVJsU\ntFzb7cf9bFYI3bYxkxnTlFryKWgy/6pxvr96DG7PhF9KG2L6GB0gI+OmueQo/Evz\nFDyMfh9DiZZpd5/NQ4Nr+Q5M0w0EZfbaO4tNujHkVv/7gvB9feZczdglbwKBgQC6\npY6r+tK+ic2ITXz5DN1TARQcaXUSQHQSK6s/75M5ZdApwOwUDTBaKfKllCBFJaPA\nKuvC54EVOEIrO/hb50PG5oqCh8MT+EdFh5OJgia2z4GQ6uEKA3nVjgqq4xKHxZ90\nss0oe9g0rQY6p4NItQhjyldcAGPpnoeJFQ6DmieztQKBgQDToHOxSPDwfnXC+pei\nf8wbL2OReWNwnmu0kM/UUjcN6owBExaMghanUAXR8jpl229/MIUJyhGjqKpp+c3N\naVBlatxHl7niJXfV6JXu9WyfvAOC7SssAWrnDqMlWfNoPECTBZ3uItWy1FcWuFmh\n92d5t5RxFMFAG4FPws4fFKgyMg==\n-----END PRIVATE KEY-----\n",
- "client_email": "firebase-adminsdk-8ri07@crowdcode2.iam.gserviceaccount.com",
- "client_id": "116287562601899349887",
+ "private_key_id": "ee2194e5cd3aa1461e2442e81c05766eab6cfa00",
+ "private_key": "-----BEGIN PRIVATE KEY-----\nMIIEvwIBADANBgkqhkiG9w0BAQEFAASCBKkwggSlAgEAAoIBAQDazdoyIYSXq6hd\nuYVpcdYId+UzruabySi3LbURwjSLf9pSVprAdTro4c7zxBBhHz6Z35d2l/Reao6Q\nsyuIydPXz6yDM9m9ayALMYnQssTu7hwvdC2tMyBsoiG/qCRwahZmw6EatmNAN6yY\nhUi41m+dGybu/cbq/RCmtKe0BcwWhjEVcipnueD0ax0uZcmzdkwl2jT9zezFQx2t\n6MjpVYAzWxNp1voTACc/dF3Ks8pvPqHst+nXGhVWVrMDPSHum1AEwbd+9qxCjEZ0\nQGTqTeYoHULnx7IVXp1nBwy7HahrmAhiEE9g5bGBKJo9HG3seY2QhcIvN+utqAvL\ndfMdpDPfAgMBAAECggEAYgEDQyINPEw4gSaIUccZ2bguMvybsVqkQIwaBubIV1WA\nihHdhefcZ5RA+KGwvnfat9xVANsmKyYqTjjafo38M7WC7U+Lr1Ksyya4toBkQirn\n9/9fOC1m0BG88RYUoD98YjIs1oSsJwbo6XYFsTjnTGTthu2nq/iG/Ux8s19HXyyO\n2BXk/LR15cMhcCqKWs2h3zmekU83XPxPMG6/3LVdWx1SdNouHjvM2L9WzDKQnG2O\n5pTTe0J/wLAERQ7grRMen4mFrdV5FJBYnq8rLVqHMCJ6/+D7mp51hq+dJ/Kyy2nI\nZJYReWGmj1hgMQxRhpB0cBLw+bTMagt/2/DD+Jg8AQKBgQD3DcxlZuJnApl4a53L\n6lPSbvu48q+DLB2VoWM5N8jn2VvCC4RTDceF2lSFaXvF6vGdMmMbpM5UkXu0Xkof\nOvIsFQLwCNU+vsPSv3s5Rqwza3plKTb9ndRJtIBLNo9hamA7qldr2u45O3srHPIe\nQFcOBXXgvt2Rmw6VN/eJS1R0AQKBgQDiui1PdOn+lH25Zp0dTf6awmX2YKouoA1X\nn6HRrmPl6odRCRiMlWAXmUhvx67Mjwaz5FIgqC10ykgrLWe3jtIZ4T2wdyml54Dy\ncqdoLzRrak8Fgkk3AYyeiiAPHdUmkOvtyM6U6JHA0DX3DkzeEdAVvpCY9SChiKJi\ntdTh9Wcn3wKBgQDHdD5mR0/VdkXM8KUusfoGVE+pm1SThBRGb0saMK1kcRkhagbk\nvqUsrX27T9P7j5iNHtbgxIdHw0Sp883HtOE7MaNzgs4WoBCcnravIR15TfY8oa+h\nxcBT2QQStPPA5A7ZXMbDbrcRQbJItk/KmIsv6LyoO6/KE/MMCWkxUL3YAQKBgQCR\nYwN1JSp7ZmrsfYGYbhAq2yeZAsl+VoHXw3R3ydUjdO3KqAOG+q6A03kgvLI5WCnb\nJzkG2fE0KBZ5IYeVrE7L66SsSO17BmWokp8I7uQ1URlVFgOu8x5h936xUtcBAQNZ\nGmBmGnCEbL9+KjxeVpvRpb6BZwbCrqQ6mhDlyICajwKBgQCGbD3YL0AtZD0iMUdh\nvUGhHlmtN+TUcInYPiWfk9VwjUS4087AxVOrUDp8aBGUtKBVdC9g9EhmWX26vuCd\nv6yDCSF0enYPVJLI/6CU8yDK2wZCV5CE9JcCuVyu+2BZ9sgM4MfGQVcdWkbxDRfy\nIAu9OY6uEkcdJc4pB6sTZ6nA3g==\n-----END PRIVATE KEY-----\n",
+ "client_email": "firebase-adminsdk-roovx@crowdcode2.iam.gserviceaccount.com",
+ "client_id": "105510340470187039060",
  "auth_uri": "https://accounts.google.com/o/oauth2/auth",
- "token_uri": "https://accounts.google.com/o/oauth2/token",
+ "token_uri": "https://oauth2.googleapis.com/token",
  "auth_provider_x509_cert_url": "https://www.googleapis.com/oauth2/v1/certs",
- "client_x509_cert_url": "https://www.googleapis.com/robot/v1/metadata/x509/firebase-adminsdk-8ri07%40crowdcode2.iam.gserviceaccount.com"
+ "client_x509_cert_url": "https://www.googleapis.com/robot/v1/metadata/x509/firebase-adminsdk-roovx%40crowdcode2.iam.gserviceaccount.com",
+ "universe_domain": "googleapis.com"
  },
  "firebaseConfig": {
  "apiKey": "AIzaSyCmhzDIbe7pp8dl0gveS2TtOH4n8mvMzsU",

README.md

@@ -1,5 +1,5 @@
 # Crowd Microservices
-Demo of Crowd Microservices environment
+Demo of Crowd Microservices environment.
 
 
 

app.js

@@ -6,8 +6,9 @@ const favicon = require('serve-favicon');
 const logger = require('morgan');
 const cookieParser = require('cookie-parser');
 const bodyParser = require('body-parser');
+const firebaseConstant = require('firebase');
 const cors = require('cors')({
- origin: true
+origin: true
 });
 const status = require('http-status');
 const wagner = require('wagner-core');
@@ -22,89 +23,101 @@ app.set('views', path.join(__dirname, 'public'));
 app.use(logger('dev'));
 app.use(cookieParser());
 app.use(session({
- name: 'server-session-cookie-id',
- secret: 'my express secret',
- saveUninitialized: true,
- resave: true,
- store: new FileStore({
- retries: 10,
- minTimeout: 100,
- maxTimeout: 200,
- path: path.join(__dirname,'sessions')
- })
+name: 'server-session-cookie-id',
+secret: 'my express secret',
+saveUninitialized: true,
+resave: true,
+store: new FileStore({
+retries: 10,
+minTimeout: 100,
+maxTimeout: 200,
+path: path.join(__dirname,'sessions')
+})
 }));
-const isAuth = wagner.invoke(function() {
- return (req, res, next) => {
-if(req.session.user || req.path==='/login' || req.path === '/loggedin.html') {
- req.user = req.session.user;
- next();
- } else {
- res.redirect('/login');
- }
- };
+const isAuth = wagner.invoke(function() {
+return (req, res, next) => {
+ if (req.session.user || req.path==='/login' || req.path === '/loggedin.html') {
+req.user = req.session.user;
+next();
+} else {
+res.redirect('/login');
+}
+};
 });
 app.use(bodyParser.json());
 app.use(bodyParser.urlencoded({
- extended: false
+extended: false
 }));
-app.post('/authenticate', wagner.invoke(function(UserService, AdminFirebase, FirebaseService) {
- return function(req, res) {
- //var idToken = req.body.idToken;
- var idToken = req.headers['authorization'].split(' ').pop();
- AdminFirebase.auth().verifyIdToken(idToken)
- .then(function(decodedToken) {
- var uid = decodedToken.uid;
- req.session.user = decodedToken;
- UserService.getUserById(uid)
- .then(function(userRecord) {
- // See the UserRecord reference doc for the contents of userRecord.
- console.log("Successfully fetched user data:", userRecord.toJSON());
- var worker_id = userRecord.uid;
- var worker_name = userRecord.displayName;
- var avatar_url = userRecord.photoURL;
- var firebase = FirebaseService;
- var workers_list_promise = firebase.retrieveWorkersList();
- workers_list_promise.then(function(workers_list) {
- if (workers_list.indexOf(worker_id) < 0) {
- firebase.createWorker(worker_id, worker_name, avatar_url);
- }
- }).catch(function(err) {
- console.trace(err);
- });
- })
- .catch(function(err) {
- console.log("Error fetching user data:", err);
- });
- res.json({
- 'Success': 200
- })
- }).catch(function(err) {
- // Handle error
- console.trace(err);
- });
- };
+app.post('/authenticate', wagner.invoke(function (UserService, AdminFirebase, FirebaseService) {
+ return function (req, res) {
+ //var idToken = req.body.idToken;
+ var idToken = req.headers['authorization'].split(' ').pop();
+ AdminFirebase.auth().verifyIdToken(idToken)
+ .then(function (decodedToken) {
+ var uid = decodedToken.uid;
+ req.session.user = decodedToken;
+ UserService.getUserById(uid)
+ .then(function (userRecord) {
+ // See the UserRecord reference doc for the contents of userRecord.
+ console.log("Successfully fetched user data:", userRecord.toJSON());
+ var worker_id = userRecord.uid;
+ var worker_name = userRecord.displayName;
+ var avatar_url = userRecord.photoURL;
+ var firebase = FirebaseService;
+ // logs worker authentication
+ var ref = AdminFirebase.database().ref().child('Workers').child('logs');
+ ref.push({
+ eventType: "LoggedIn",
+ eventDescription: "Logged in successfully",
+ timestamp: firebaseConstant.database.ServerValue.TIMESTAMP,
+ workerId: userRecord.uid,
+ workerName: userRecord.displayName
+ }).catch(e => {
+ console.log(e)
+ });
+
+ var workers_list_promise = firebase.retrieveWorkersList();
+ workers_list_promise.then(function (workers_list) {
+ if (workers_list.indexOf(worker_id) < 0) {
+ firebase.createWorker(worker_id, worker_name, avatar_url);
+ }
+ }).catch(function (err) {
+ console.trace(err);
+ });
+ })
+ .catch(function (err) {
+ console.log("Error fetching user data:", err);
+ });
+ res.json({
+ 'Success': 200
+ })
+ }).catch(function (err) {
+ // Handle error
+ console.trace(err);
+ });
+ };
 }));
 app.use(cookieParser());
 app.use(isAuth);
 app.use('/api/v1', require('./routes/api')(wagner));
 app.use(express.static(path.join(__dirname, 'public')));
 app.use(require('./routes/app-routing')(wagner));
 // catch 404 and forward to error handler
-app.use(function(req, res, next) {
- var err = new Error('Not Found');
- err.status = 404;
- next(err);
+app.use(function(req, res, next) {
+var err = new Error('Not Found');
+err.status = 404;
+next(err);
 });
 
 // error handler
-app.use(function(err, req, res, next) {
- // set locals, only providing error in development
- res.locals.message = err.message;
- res.locals.error = req.app.get('env') === 'development' ? err : {};
+app.use(function(err, req, res, next) {
+// set locals, only providing error in development
+res.locals.message = err.message;
+res.locals.error = req.app.get('env') === 'development' ? err : {};
 
- // render the error page
- res.status(err.status || 500);
- res.sendFile(path.join(__dirname, '/public/404.html'));
+// render the error page
+res.status(err.status || 500);
+res.sendFile(path.join(__dirname, '/public/404.html'));
 });
 
 module.exports = app;

config/config.json

@@ -2,14 +2,15 @@
  "serviceAccount": {
  "type": "service_account",
  "project_id": "crowdcode2",
- "private_key_id": "4ef77e02829e6ff9ba96a35d264f092025aaef1d",
- "private_key": "-----BEGIN PRIVATE KEY-----\nMIIEvwIBADANBgkqhkiG9w0BAQEFAASCBKkwggSlAgEAAoIBAQDHZvikJdmZv5zI\nbM6ECnfp77QiFQidH93goS0438aGk5YR1La8tuOD62khNa3qbCNA2qMtj5c/WM8L\nONuzBnLYXcRtgbjiTftok3O37aeV1yW/Hty3jkKcFf2OsYO5oQRv73joP+ADcSu0\nz9LYx4uXrAx7x9wBNLSi5GP/ecWpvLMxRJUltzUg5p2Fn1/RHfQaa+GNd3oKWABe\na0sn88V2E5EM/Ie7xkApj5ozayW9F22Fct814pk1en7ZvE1+6JuQ63+3eEpNaLaj\neeLkKCkUzSLVX6UAUpnlf3gS15jdAjoWf+jPIrlpsY0T44jRUQb4ok0Pwn6orbRO\nHoVrBsArAgMBAAECggEAB+hefev+WCmQJyahff0ISl+2Lg/Vep2z59+ccn/1WIrr\nzaM45/z8wtOIJMgDMKO/Nig1hm4GWn3EIDbOB6h+z3PQgWM+mMLs8HXAhg/HsJqK\npaysph7fJ1974bfKeIcZLPM7QUKfOKO5Tv9a5jvrnkU1bYc8g1O6wib6jDwhCZ0f\nG+oZR6ka+SPi3Z6xNoBkw/JEJC+f0WDZV4VLy+rFlgQpC2FYiFWJHxh7D0MNIVbC\n7jowXvQ7jyqaNPBysfnkoGomeFrCxV+Zc1KuuHx3PL7Z+XdJsHxfPISANU9LzrW0\nVcsZ6GOihL1YE/1blk2lyA5cYJT3Bb3ybAkIKwgm6QKBgQD7oL4CI827mGtzzTv/\nKTeWOqRARAPLggo8dS79tgfP6BKEudeJGlxLA3l+1eWFrjjEpG85nrLkcIXz4Cm9\nwZmg/esP1pts8v7rc/nJ1cL/UySznUkiGH1fLbIc8vkfTkbLx9pedjr0UAlNO+zX\nSmCE+lrHDXKn2wmTfBniewSgPwKBgQDK3ez+l7ESFaUGTyLHRe6EDvU6A9X72q6e\nJj4LVLW8JoGVezIBUk/orPij6S7oOEAMj72OCP4DCX6zZ6FfVaERZVHoSx7yBltU\n5Tf988guqR9zB4B7PrQP+uf6UXaL4LtT9XYxDvoyyqyZ8A2WRrHaks1wo+psc+lC\nNqPKoGOlFQKBgQCIC1NPwt3TpEfMN1VN0pIMNi5h1KQcnnU8VLsQTx+QJ9ADVJsU\ntFzb7cf9bFYI3bYxkxnTlFryKWgy/6pxvr96DG7PhF9KG2L6GB0gI+OmueQo/Evz\nFDyMfh9DiZZpd5/NQ4Nr+Q5M0w0EZfbaO4tNujHkVv/7gvB9feZczdglbwKBgQC6\npY6r+tK+ic2ITXz5DN1TARQcaXUSQHQSK6s/75M5ZdApwOwUDTBaKfKllCBFJaPA\nKuvC54EVOEIrO/hb50PG5oqCh8MT+EdFh5OJgia2z4GQ6uEKA3nVjgqq4xKHxZ90\nss0oe9g0rQY6p4NItQhjyldcAGPpnoeJFQ6DmieztQKBgQDToHOxSPDwfnXC+pei\nf8wbL2OReWNwnmu0kM/UUjcN6owBExaMghanUAXR8jpl229/MIUJyhGjqKpp+c3N\naVBlatxHl7niJXfV6JXu9WyfvAOC7SssAWrnDqMlWfNoPECTBZ3uItWy1FcWuFmh\n92d5t5RxFMFAG4FPws4fFKgyMg==\n-----END PRIVATE KEY-----\n",
- "client_email": "firebase-adminsdk-8ri07@crowdcode2.iam.gserviceaccount.com",
- "client_id": "116287562601899349887",
+ "private_key_id": "ee2194e5cd3aa1461e2442e81c05766eab6cfa00",
+ "private_key": "-----BEGIN PRIVATE KEY-----\nMIIEvwIBADANBgkqhkiG9w0BAQEFAASCBKkwggSlAgEAAoIBAQDazdoyIYSXq6hd\nuYVpcdYId+UzruabySi3LbURwjSLf9pSVprAdTro4c7zxBBhHz6Z35d2l/Reao6Q\nsyuIydPXz6yDM9m9ayALMYnQssTu7hwvdC2tMyBsoiG/qCRwahZmw6EatmNAN6yY\nhUi41m+dGybu/cbq/RCmtKe0BcwWhjEVcipnueD0ax0uZcmzdkwl2jT9zezFQx2t\n6MjpVYAzWxNp1voTACc/dF3Ks8pvPqHst+nXGhVWVrMDPSHum1AEwbd+9qxCjEZ0\nQGTqTeYoHULnx7IVXp1nBwy7HahrmAhiEE9g5bGBKJo9HG3seY2QhcIvN+utqAvL\ndfMdpDPfAgMBAAECggEAYgEDQyINPEw4gSaIUccZ2bguMvybsVqkQIwaBubIV1WA\nihHdhefcZ5RA+KGwvnfat9xVANsmKyYqTjjafo38M7WC7U+Lr1Ksyya4toBkQirn\n9/9fOC1m0BG88RYUoD98YjIs1oSsJwbo6XYFsTjnTGTthu2nq/iG/Ux8s19HXyyO\n2BXk/LR15cMhcCqKWs2h3zmekU83XPxPMG6/3LVdWx1SdNouHjvM2L9WzDKQnG2O\n5pTTe0J/wLAERQ7grRMen4mFrdV5FJBYnq8rLVqHMCJ6/+D7mp51hq+dJ/Kyy2nI\nZJYReWGmj1hgMQxRhpB0cBLw+bTMagt/2/DD+Jg8AQKBgQD3DcxlZuJnApl4a53L\n6lPSbvu48q+DLB2VoWM5N8jn2VvCC4RTDceF2lSFaXvF6vGdMmMbpM5UkXu0Xkof\nOvIsFQLwCNU+vsPSv3s5Rqwza3plKTb9ndRJtIBLNo9hamA7qldr2u45O3srHPIe\nQFcOBXXgvt2Rmw6VN/eJS1R0AQKBgQDiui1PdOn+lH25Zp0dTf6awmX2YKouoA1X\nn6HRrmPl6odRCRiMlWAXmUhvx67Mjwaz5FIgqC10ykgrLWe3jtIZ4T2wdyml54Dy\ncqdoLzRrak8Fgkk3AYyeiiAPHdUmkOvtyM6U6JHA0DX3DkzeEdAVvpCY9SChiKJi\ntdTh9Wcn3wKBgQDHdD5mR0/VdkXM8KUusfoGVE+pm1SThBRGb0saMK1kcRkhagbk\nvqUsrX27T9P7j5iNHtbgxIdHw0Sp883HtOE7MaNzgs4WoBCcnravIR15TfY8oa+h\nxcBT2QQStPPA5A7ZXMbDbrcRQbJItk/KmIsv6LyoO6/KE/MMCWkxUL3YAQKBgQCR\nYwN1JSp7ZmrsfYGYbhAq2yeZAsl+VoHXw3R3ydUjdO3KqAOG+q6A03kgvLI5WCnb\nJzkG2fE0KBZ5IYeVrE7L66SsSO17BmWokp8I7uQ1URlVFgOu8x5h936xUtcBAQNZ\nGmBmGnCEbL9+KjxeVpvRpb6BZwbCrqQ6mhDlyICajwKBgQCGbD3YL0AtZD0iMUdh\nvUGhHlmtN+TUcInYPiWfk9VwjUS4087AxVOrUDp8aBGUtKBVdC9g9EhmWX26vuCd\nv6yDCSF0enYPVJLI/6CU8yDK2wZCV5CE9JcCuVyu+2BZ9sgM4MfGQVcdWkbxDRfy\nIAu9OY6uEkcdJc4pB6sTZ6nA3g==\n-----END PRIVATE KEY-----\n",
+ "client_email": "firebase-adminsdk-roovx@crowdcode2.iam.gserviceaccount.com",
+ "client_id": "105510340470187039060",
  "auth_uri": "https://accounts.google.com/o/oauth2/auth",
- "token_uri": "https://accounts.google.com/o/oauth2/token",
+ "token_uri": "https://oauth2.googleapis.com/token",
  "auth_provider_x509_cert_url": "https://www.googleapis.com/oauth2/v1/certs",
- "client_x509_cert_url": "https://www.googleapis.com/robot/v1/metadata/x509/firebase-adminsdk-8ri07%40crowdcode2.iam.gserviceaccount.com"
+ "client_x509_cert_url": "https://www.googleapis.com/robot/v1/metadata/x509/firebase-adminsdk-roovx%40crowdcode2.iam.gserviceaccount.com",
+ "universe_domain": "googleapis.com"
  },
  "firebaseConfig": {
  "apiKey": "AIzaSyCmhzDIbe7pp8dl0gveS2TtOH4n8mvMzsU",