blog-real-time-word-cloud

server.js

const tmi = require('tmi.js');
const redis = require('redis');
const bluebird = require('bluebird');

bluebird.promisifyAll(redis);

const options = {
  identity: {
    username: process.env.BOT_USERNAME,
    password: process.env.OAUTH_TOKEN,
  },
  channels: [
    process.env.CHANNEL_NAME,
  ],
};

const tmiClient = new tmi.client(options);
const redisClient = redis.createClient(process.env.REDIS_URL);

tmiClient.on('connected', onConnectedHandler);
tmiClient.on('message', onMessageHandler);

tmiClient.connect();

async function onConnectedHandler (address, port) {
  console.log(`* Connected to ${address}:${port}`);
}

async function onMessageHandler (target, context, message, self) {
  const words = message.replace(/,/g, '').split(' ');

  for (let i = 0; i < words.length; i++) {
    await redisClient.zincrbyAsync(target, 1, words[i]);
  }
}