Server Side Events + Edit / delete activities tests study groups + limesurvey owners

bin/www

@@ -6,8 +6,7 @@
 const app = require('../routes');
 const http = require('http');
 const config = require('../config');
-
-
+const logger = require('../logger');
 //XXX
 //require('https').globalAgent.options.ca = require('ssl-root-cas/latest').create();
 
@@ -58,17 +57,17 @@ function onError (error) {
 
   const bind = typeof port === 'string' ? `Pipe ${port}` : `Port ${port}`;
 
-  console.log(error.code);
-  console.log(error);
+  logger.info(error.code);
+  logger.info(error);
 
   // handle specific listen errors with friendly messages
   switch (error.code) {
   case 'EACCES':
-    console.log(`${bind} requires elevated privileges`);
+    logger.info(`${bind} requires elevated privileges`);
     process.exit(1);
     break;
   case 'EADDRINUSE':
-    console.log(`${bind} is already in use`);
+    logger.info(`${bind} is already in use`);
     process.exit(1);
     break;
   default:
@@ -82,5 +81,5 @@ function onError (error) {
 function onListening () {
   const addr = server.address();
   const bind = typeof addr === 'string' ? `pipe ${addr}` : `port ${addr.port}`;
-  console.log(`Listening on ${bind}`);
+  logger.info(`Listening on ${bind}`);
 }

config.js

@@ -56,7 +56,27 @@ config.limesurvey.url =  `${config.limesurvey.protocol}://${config.limesurvey.ho
 config.limesurvey.adminUser =  process.env.LIMESURVEY_ADMIN_USER || 'admin'
 config.limesurvey.adminPassword = process.env.LIMESURVEY_ADMIN_PASSWORD || 'password'
 
+config.hmac = {}
+config.hmac.password = process.env.HMAC_PASSWORD || 'mypassword'
+config.hmac.salt = process.env.HMAC_SALT || 'mysalt'
+config.hmac.key = process.env.HMAC_KEY || 'mykey'
+config.hmac.hmacKey = null
+
 config.lti = {}
 config.lti.enabled = process.env.LTI_ENABLED || 'false'
 
+config.kafka = {}
+config.kafka.clientId= process.env.SIMVA_KAFKA_CLIENTID || 'my-client-id'
+config.kafka.brokers= [ process.env.SIMVA_KAFKA_BROKER ] || ['localhost:9092']
+config.kafka.groupId= process.env.SIMVA_KAFKA_GROUPID || 'my-group-id'
+config.kafka.topic= process.env.SIMVA_KAFKA_SIMVA_EVENTS_TOPIC || 'minio-events'
+
+config.shlink = {}
+config.shlink.apihost = process.env.SHLINK_SERVER_HOST || 'shlink.external.test'
+config.shlink.protocol = process.env.SHLINK_PROTOCOL || 'https'
+config.shlink.port = process.env.SHLINK_PORT || '443'
+config.shlink.apiurl =  `${config.shlink.protocol}://${config.shlink.apihost}:${config.shlink.port}`
+config.shlink.apikey = process.env.SHLINK_SERVER_API_KEY || 'myapikey'
+
+
 module.exports = config;

logger.js

@@ -0,0 +1,73 @@
+const pino = require('pino');
+const config = require('./config.js');
+const path = require('path');
+const logsFolder = path.join(__dirname, '../logs');
+var now = new Date();
+const logFile = `${logsFolder.pathname}/${now.toISOString()}.log`;
+
+/** @type {{targets:import('pino').TransportTargetOptions[]}} */
+let transport = {
+    targets: [
+        {
+            target: 'pino/file',
+            level: (process.env.LOG_LEVEL || 'info').toLowerCase(),
+            options: {
+                destination: logFile,
+                mkdir: true
+            }
+        }
+    ]
+};
+if (process.env.NODE_ENV !== 'production') {
+    transport.targets.push(
+            {
+                target: 'pino-pretty',
+                level: (process.env.LOG_LEVEL || 'info').toLowerCase(),
+                options: {
+                    ignore: 'pid,hostname'
+                }
+            }
+    );
+} else {
+    transport.targets.push(
+        {
+            target: 'pino/file',
+            level: (process.env.LOG_LEVEL || 'info').toLowerCase(),
+            options: {
+                singleLine: true,
+                ignore: 'pid,hostname'
+            }
+        }
+);   
+}
+
+/** @type {import('pino').LoggerOptions} */
+const options = {
+    level: (process.env.LOG_LEVEL || 'info').toLowerCase(),
+    redact: {
+        paths: ['config.password', 'config.api.adminPassword', 'config.JWT.secret', 'config.limesurvey.adminPassword', 'config.sso.clientSecret', 'config.sso.adminPassword', 'config.a2.adminPassword', 'config.LTI.platform.mongo.password', 'config.LTI.platform.key'],
+        censor: '**REDACTED**'
+    },
+    customLevels: { log: 30 },
+    serializers: {
+        err: pino.stdSerializers.err,
+        req: pino.stdSerializers.req,
+        res: pino.stdSerializers.res
+    },
+    transport
+}
+
+
+const logger = pino.pino(options);
+
+
+process.on('uncaughtException', err => {
+    logger.fatal(err, 'uncaughtException')
+    process.exitCode = 1
+});
+
+process.on('unhandledRejection', reason =>
+    logger.fatal(reason, 'unhandledRejection')
+);
+
+module.exports = logger;