Merge pull request #156 from openmove/master

upgrande modules strucutere

.dockerignore

@@ -3,6 +3,7 @@
 **/*.zip
 **/*.tif
 **/.env
+**/.token*
 **/node_modules
 journey/dist
 journey/src/config.yml

base/config.yml

@@ -0,0 +1,25 @@
+environments:
+  default: prod
+#   #default environment if NODE_ENV is not defined
+
+## override in each module
+# prod:
+#   listen_port: 8080
+# dev:
+#   listen_port: 9090
+#   polling_interval: 2
+
+# polling_interval: 120
+cors:
+  origin: '*'
+  optionsSuccessStatus: 200
+  #some legacy browsers (IE11, various SmartTVs) choke on 2
+
+endpoints:
+  default:
+    hostname: mobility.api.opendatahub.bz.it
+    method: GET
+    port: 443
+    #path: /v2
+    headers:
+      User-Agent: OpenMove-Api-Client

base/index.js

@@ -0,0 +1,111 @@
+
+const https = require('https');
+//TODO replace with something else or undici
+
+const _ = require('lodash')
+    , yaml = require('js-yaml')
+    , express = require('express')
+    , cors = require('cors')
+    , dotenv = require('dotenv').config()
+    , configyml = require('@stefcud/configyml');
+
+const basepath = process.cwd() //path of module that includes this
+    , {name, version} = require(`${basepath}/package.json`)
+    , serviceName = `service ${name} v${version}`
+    , configDefault = configyml({basepath: __dirname})
+    , config = configyml({basepath});
+
+config.endpoints = _.mapValues(config.endpoints, conf => {
+    return _.defaults(conf, config.endpoints.default, configDefault.endpoints.default);
+});
+delete config.endpoints.default;
+
+config.cors = _.defaults(config.cors, configDefault.cors);
+
+var last_updated = Math.trunc((new Date()).getTime() / 1000 );
+
+function polling(getData) {
+
+    function poll() {
+        last_updated = Math.trunc((new Date()).getTime() / 1000 );
+        getData(last_updated);
+    }
+    poll(last_updated);
+    let intervalObj = setInterval(poll, config.polling_interval * 1000);
+
+    return last_updated;
+}
+
+function fetchData(endpoint) {
+    return new Promise((resolve, reject) => {
+        const req = https.request(endpoint, res => {
+            if (res.statusCode===401) {
+                console.error(`Error to retrieve data, ${res.statusCode} try to run ./token.sh or ./token_refresh.sh`)
+                //reject(new Error(`http reponse code ${res.statusCode}`))
+                return
+            }
+            var str = "";
+            res.on('data', chunk => {
+                str += chunk;
+            });
+            res.on('end', () => {
+                try {
+                    const {data} = JSON.parse(str);
+                    resolve(data);
+                }
+                catch(err) {
+                    console.error(`Error "${err}" to connect endpoint ${endpoint.hostname}${endpoint.path}`);
+                    //reject(err)
+                }
+            });
+        })
+        .on('error', err => {
+            console.error(`Error "${err.code}" to connect endpoint ${endpoint.hostname}${endpoint.path}`);
+            //reject(err)
+        })
+        .end();
+    });
+}
+
+
+function listenLog() {
+    console.log('listen paths', app._router.stack.filter(r => r.route).map(r => `${Object.keys(r.route.methods)[0]} ${r.route.path}`) );
+    console.log(`${serviceName} listening at http://localhost:${this.address().port}`);
+    /*
+    //TODO manage sigterm
+    process.on('SIGTERM', () => {
+        console.error('[geocoder-pelias-services] closing...')
+        serverParser.close();
+    });*/
+}
+
+const app = express();
+
+app.use(cors(config.cors));
+
+if (config.envId == 'dev') {
+   app.set('json spaces', 2);
+}
+
+/*TODO in all modules
+app.get(['/','/carsharing'], async (req, res) => {
+  res.send({
+    status: 'OK',
+    //TODO status error if polling failed
+    version
+  });
+});*/
+
+console.log(`Starting ${serviceName}... ${version}\nConfig:\n`, config);
+
+module.exports = {
+    app,
+    config,
+    serviceName,
+    version,
+    polling,
+    fetchData,
+    listenLog,
+    //libs
+    express, yaml, _
+};