-
Notifications
You must be signed in to change notification settings - Fork 3
/
db-factory.js
54 lines (49 loc) · 2.11 KB
/
db-factory.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
const mongoose = require('mongoose');
const log4js = require('log4js');
const config = require('./config');
const httpClient = require('./http-client');
const LOGGER_NAME = config.isK8sEnv() ? `[${config.hostname}] [INTEGRATION-FLOW v${config.imageTag}]` : `[INTEGRATION-FLOW v${config.imageTag}]`;
const logger = log4js.getLogger(LOGGER_NAME);
// For threads to pick txnId and user headers
global.userHeader = 'user';
global.txnIdHeader = 'txnid';
global.loggerName = LOGGER_NAME;
global.trueBooleanValues = ['y', 'yes', 'true', '1'];
global.falseBooleanValues = ['n', 'no', 'false', '0'];
(async () => {
try {
mongoose.connection.on('connected', () => logger.info('MongoDB Connected to ', config.appDB));
mongoose.connection.on('disconnected', () => logger.error('MongoDB Connection Lost !'));
mongoose.connection.on('reconnected', () => logger.warn('MongoDB ReConnected to ', config.appDB));
mongoose.connection.on('error', (err) => logger.error('MongoDB Error', err));
await mongoose.connect(config.mongoUrl, { dbName: config.appDB });
// logger.trace(config.mongoUrl, config.mongoAppCenterOptions, config.appDB);
// const client = await MongoClient.connect(config.mongoUrl, config.mongoAppCenterOptions);
// logger.info('Connected to ', config.appDB);
// const appcenterDB = client.db(config.appDB);
global.appcenterDB = mongoose.connection.db;
} catch (err) {
logger.error(err);
process.exit(0);
}
// if (process.env.NODE_ENV !== 'production') {
// logger.info(`NODE_ENV is ${process.env.NODE_ENV}. Won't call BM API.`);
// } else {
try {
let b2bBaseURL = config.baseUrlBM + '/' + config.app + '/flow/utils/' + config.flowId + '/init';
logger.debug(`BM API Call :: ${config.baseUrlBM + '/' + config.app + '/flow/utils/' + config.flowId + '/init'}`);
const resp = await httpClient.request({
method: 'PUT',
url: b2bBaseURL,
headers: {
'Content-Type': 'application/json'
}
});
logger.debug(`BM API Call status :: ${resp.statusCode}`);
logger.trace('BM API Call response body :: ', resp.body);
} catch (err) {
logger.error('Unable to inform B2B Manager');
logger.error(err);
}
// }
})();