forked from nodeshift-starters/nodejs-configmap
-
Notifications
You must be signed in to change notification settings - Fork 0
/
app.js
111 lines (93 loc) · 3.15 KB
/
app.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
'use strict';
/*
*
* Copyright 2016-2017 Red Hat, Inc, and individual contributors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*
*/
const express = require('express');
const path = require('path');
const bodyParser = require('body-parser');
// Setup logging
const winston = require('winston');
const logger = new (winston.Logger)({
transports: [
new (winston.transports.Console)({level: 'info'})
]
});
const app = express();
// Health Check Middleware
const probe = require('kube-probe');
app.use(bodyParser.json());
app.use(bodyParser.urlencoded({ extended: false }));
app.use(express.static(path.join(__dirname, 'public')));
// expose the license.html at http[s]://[host]:[port]/licences/licenses.html
app.use('/licenses', express.static(path.join(__dirname, 'licenses')));
let configMap;
let message;
app.use('/api/greeting', (request, response) => {
const name = (request.query && request.query.name) ? request.query.name : 'World';
if (!message) {
response.status(500);
return response.send({content: 'no config map'});
}
logger.debug('Replying to request, parameter={}', name);
return response.send({content: message.replace(/%s/g, name)});
});
// set health check
probe(app);
// Periodic check for config map update
// If new configMap is found, then set new log level
setInterval(() => {
retrieveConfigfMap().then((config) => {
if (!config) {
message = null;
return;
}
if (JSON.stringify(config) !== JSON.stringify(configMap)) {
configMap = config;
message = config.message;
// Set New log level
if (logger.transports.console.level !== config.level.toLowerCase()) {
logger.info('New configuration retrieved: {}', config.message);
logger.info('New log level: {}', config.level.toLowerCase());
logger.transports.console.level = config.level.toLowerCase();
}
}
}).catch((err) => {
logger.error('Error getting config', err);
});
}, 2000);
// Get ConfigMap Stuff
const openshiftConfigLoader = require('openshift-config-loader');
const openshiftRestClient = require('openshift-rest-client');
const jsyaml = require('js-yaml');
// Find the Config Map
function retrieveConfigfMap () {
return openshiftConfigLoader().then((config) => {
const settings = {
request: {
strictSSL: false
}
};
return openshiftRestClient(config, settings).then((client) => {
const configMapName = 'app-config';
return client.configmaps.find(configMapName).then((configMap) => {
const configMapParsed = jsyaml.safeLoad(configMap.data['app-config.yml']);
return configMapParsed;
});
});
});
}
module.exports = app;