krikkert/habitica
1
0
Fork 0
mirror of https://github.com/HabitRPG/habitica.git synced 2025-12-18 23:27:26 +01:00
Code Issues Packages Projects Releases Wiki Activity

Merge remote-tracking branch 'origin/greenkeeper/update-to-node-10' into release

Browse Source 
also remove Kafka
This commit is contained in:
Sabe Jones
2018-11-29 14:51:40 +00:00
parent 37d9f76fea 1815d2b6d3
commit b218eb2c00
7 changed files with 16 additions and 86 deletions
Download Patch File Download Diff File Expand all files Collapse all files

54
website/server/libs/queue/index.js
View File

@@ -1,59 +1,7 @@
import nconf from 'nconf';
import logger from '../logger';
const GROUP_ID = nconf.get('KAFKA:GROUP_ID');
const CLOUDKARAFKA_BROKERS = nconf.get('KAFKA:CLOUDKARAFKA_BROKERS');
const CLOUDKARAFKA_USERNAME = nconf.get('KAFKA:CLOUDKARAFKA_USERNAME');
const CLOUDKARAFKA_PASSWORD = nconf.get('KAFKA:CLOUDKARAFKA_PASSWORD');
const CLOUDKARAFKA_TOPIC_PREFIX = nconf.get('KAFKA:CLOUDKARAFKA_TOPIC_PREFIX');
const prefix = CLOUDKARAFKA_TOPIC_PREFIX;
const topic = `${prefix}-default`;
let Kafka;
let producer;
try {
Kafka = require('node-rdkafka'); // eslint-disable-line global-require
} catch (er) {
Kafka = null;
}
function createProducer () {
const kafkaConf = {
'group.id': GROUP_ID,
'metadata.broker.list': CLOUDKARAFKA_BROKERS ? CLOUDKARAFKA_BROKERS.split(',') : '',
'socket.keepalive.enable': true,
'security.protocol': 'SASL_SSL',
'sasl.mechanisms': 'SCRAM-SHA-256',
'sasl.username': CLOUDKARAFKA_USERNAME,
'sasl.password': CLOUDKARAFKA_PASSWORD,
debug: 'generic,broker,security',
};
producer = new Kafka.Producer(kafkaConf);
producer.connect();
}
if (Kafka && GROUP_ID && CLOUDKARAFKA_BROKERS && CLOUDKARAFKA_USERNAME && CLOUDKARAFKA_PASSWORD && CLOUDKARAFKA_TOPIC_PREFIX) {
createProducer();
}
process.on('exit', () => {
if (producer && producer.isConnected()) producer.disconnect();
});
const api = {};
api.sendMessage = function sendMessage (message, key) {
if (!producer || !producer.isConnected()) return;
try {
producer.produce(topic, -1, new Buffer(JSON.stringify(message)), key);
} catch (err) {
logger.error(err);
}
return;
};
module.exports = api;