Как применить паттерн observer правильно?

Question

[Михаил]

Здравствуйте. Столкнулся с проблемой при использовании паттерна observer. Ситуация такая: мне приходит от пользователя сообщение, и мне надо сделать следующее:
1) Получить часовой пояс с помощью экземпляра класса googleMapsAPI
const zone = await geoTime.getTimeZone(msg.text)
2) Получить все раннее записанные данные в Redis

const user = await redisApi.getUserForSave(msg.from.id)

3) Записать это всё в MySQL. И в зависимости от кода ответа и наличия ошибки ответить пользователю

const code = await sql.saveUser(user);
code === 'good' ? bot.sendMessage(msg.from.id, 'Good') : bot.sendMessage(msg.from.id, 'Good');

В итоге код получается громоздкий. И нарушается связность между модулями:

observer.on('end', (msg) => {
   const zone = await geoTime.getTimeZone(msg.text);
   const user = await redisApi.getUserForSave(msg.from.id);
   const code = await sql.saveUser(user);
   code === 'good' ? bot.sendMessage(msg.from.id, 'Good') : bot.sendMessage(msg.from.id, 'Good');
})

Это я немного упростил код и логику. В реальной жизни всё чуть сложнее. Как правильно быть в такой ситуации?

Comments

[napa3um]

> код получается громоздкий

Вроде, норм.

> нарушается связность между модулями

О какой связности и нарушении идёт речь?

[Михаил]

napa3um:

Вроде норм

Хорошо. А как понять, когда не норм? Мне казалось (не знаю, почему), что в идеале на каждое событие должна передаваться одна функция. То есть как-то так:

observer.on('msg', msg => {
   someFunc(msg);
});

Весь код в проекте у меня так и записан. Всё лаконично и компактно. Если же я пытаюсь выделить отдельную функцию для вышеописанного события, то получается громоздкая функция, принимающая на вход 6-7 аргументов и работающая с 3-4 модулями. Как-то это некрасиво

З. Ы. Паттерны проектирования стал изучать совсем недавно. Может, я не понимаю что-то

[napa3um]

Михаил: проблемы у вас в голове от "опережающих знаний". Сначала столкнитесь с реальными проблемами, тогда и решайте их, а пока "решения заранее" превращаются в гадание на кофейной гуще.

Answer 1

[Philipp]

Поскольку обработчик сообщения получается громоздким, его можно легко вынести в отдельный модуль и импортировать примерно так.

const messageProcessor = require('path/to/message/processor');
// ваш код идет здесь ...
// далее навешиваем наш обработчик на шину сообщений
messageBus.on('end', messageProcessor);

Так же вы можете автоматическую регистрацию внутри обработчика.

// в вашем основном файле
messageProcessor.register(messageBus);

Внутри процессора сообщений

function messageProcessor() {
 // ...
}

module.exports.register = function(messageBus) {
   messageBus.on('end', messageProcessor);
};