socket.on(events.MESSAGES, async function(messages, callback) {
          try {
            // Проверка что пользователь пишите от себя
            const userId = socket.decoded_token.id;
            const groupByConvId = _(messages)
              .groupBy("convId")
              .value();

            for (const convId of Object.keys(groupByConvId)) {
              const companion = await db_helper.getCompanion(userId, convId);
              const savedMessages = groupByConvId[convId];
              await db_helper.saveMessages(convId, userId, savedMessages);
              const totalCount = await db_helper.getMessageTotalCount(convId);
              // Отправляем сообщение назад, что мы его получили.
              callback(requester.createBody(savedMessages));
              // Отправляем сообщения участнику чата
              savedMessages.forEach(msg => {
                msg.totalCount = totalCount;
              });
              self.sendData(
                userId,
                companion.user_id,
                events.MESSAGES,
                savedMessages
              );
            }
          } catch (error) {
            callback(requester.createError(error));
            console.error("Не могу сохранить сообщения пользователя", error);
          }
        });