video-utils

video-utils

Содержит общие вспомогательные модули модули для сервисов "Видеосвязь" и "Вебинары"

logger

Нужен для логирования работы приложения. Логи пишутся в консоль и отправляются в админку облака.

Инициализация

var
    cfg = {
        appName: 'my-super-app',  // имя приложения
        extra: {
            cloudLogger: true,    // если false или не указан, то в админку логи не полетят
            port: 82              // порт, который слушает приложение (отображается в логах)
        },
        log: {
            address: 'http://dev-private.sbis.ru/log' // адрес центра логирования
        }
    },
    logger = require('video-utils-rabbit/logger)(
        cfg,                      // конфигурация
        function(log4js){         // функция расширяющая возможности логгера
            var myLogger = log4js.getLogger('myLog')
            log4js.addAppender(function (e) {
               //do something
            }, 'myLog');

            return {
                myLog: function(tag, msg){
                    myLogger.info(tag, msg);
                }
            }
        }
    );

sender

Нужен для отправки данных через RabbitMQ

Инициализация

var 
    cfg = {
        address: 'amqp://cloud_service:[e-mail]',
        exchanges: ['test-online.sbis.ru', 'test-inside.tensor.ru']    
    },
    logger = require('log4js').getLogger(),
    sender = require('video-utils-rabbit/sender)(cfg, logger);

Параметр logger является опциональным, по-умолчанию будет require('log4js').getLogger()

Использование

sender.send(userId, exchange, channel, data, cb);

где:

• userId - идентификатор пользователя, которому отправляется сообщение
• exchange - имя обменника
• channel - имя канала
• [data] - передаваемые данные(опциональный)
• [cb] - callback(опциональный)

subscriber

Нужен для подписки на события в RabbitMQ

Инициализация

var 
    cfg = {
        address: 'amqp://cloud_service:[e-mail]'    
    },
    logger = require('log4js').getLogger(),
    subscriber = require('video-utils-rabbit/subscriber)(cfg, logger);

Параметр logger является опциональным, по-умолчанию будет require('log4js').getLogger()

Использование

subscriber.subscribe(exchange, userId); // необходимо для подписки на сообщения в обменнике для конкретного пользователя

subscriber.on('message', function (channel, data) { // подписка на сообщения
   // 
});

где:

• exchange - имя обменника
• userId - идентификатор пользователя, для которого мы хотим получать сообщения
• channel - имя канала, в который пришло сообщение
• data - переданные данные