Ужесточил проверку интерфейса пользовательского модуля взаимодействия с БД - все его функции должны быть асинхронными (мы де их await)

This commit is contained in:
Mikhail Chechnev 2018-11-28 18:14:43 +03:00
parent 6f955b1ed2
commit 57eff9cda9

View File

@ -13,9 +13,9 @@ const Schema = require("validate"); //Схемы валидации
// Тело модуля // Тело модуля
//------------ //------------
const validateFunctionType = val => { const validateAsyncFunctionType = val => {
let sFn = {}.toString.call(val); let sFn = {}.toString.call(val);
return sFn === "[object Function]" || sFn === "[object AsyncFunction]"; return sFn === "[object AsyncFunction]";
}; };
//------------------ //------------------
@ -26,80 +26,80 @@ const validateFunctionType = val => {
exports.dbConnectorModule = new Schema({ exports.dbConnectorModule = new Schema({
//Подключение к БД //Подключение к БД
connect: { connect: {
use: { validateFunctionType }, use: { validateAsyncFunctionType },
required: true, required: true,
message: { message: {
validateFunctionType: validateAsyncFunctionType:
"Функция подключения к БД (connect) имеет неверный формат (ожидалось - Function или AsyncFunction)", "Функция подключения к БД (connect) имеет неверный формат (ожидалось - Function или AsyncFunction)",
required: "Не реализована функция подключения к БД (connect)" required: "Не реализована функция подключения к БД (connect)"
} }
}, },
//Отключение от БД //Отключение от БД
disconnect: { disconnect: {
use: { validateFunctionType }, use: { validateAsyncFunctionType },
required: true, required: true,
message: { message: {
validateFunctionType: validateAsyncFunctionType:
"Функция отключения от БД (disconnect) имеет неверный формат (ожидалось - Function или AsyncFunction)", "Функция отключения от БД (disconnect) имеет неверный формат (ожидалось - Function или AsyncFunction)",
required: "Не реализована функция отключения от БД (disconnect)" required: "Не реализована функция отключения от БД (disconnect)"
} }
}, },
//Получение списка сервисов //Получение списка сервисов
getServices: { getServices: {
use: { validateFunctionType }, use: { validateAsyncFunctionType },
required: true, required: true,
message: { message: {
validateFunctionType: validateAsyncFunctionType:
"Функция получения списка сервисов (getServices) имеет неверный формат (ожидалось - Function или AsyncFunction)", "Функция получения списка сервисов (getServices) имеет неверный формат (ожидалось - Function или AsyncFunction)",
required: "Не реализована функция получения списка сервисов (getServices)" required: "Не реализована функция получения списка сервисов (getServices)"
} }
}, },
//Получения списка функций сервиса //Получения списка функций сервиса
getServiceFunctions: { getServiceFunctions: {
use: { validateFunctionType }, use: { validateAsyncFunctionType },
required: true, required: true,
message: { message: {
validateFunctionType: validateAsyncFunctionType:
"Функция получения списка функций сервиса (getServiceFunctions) имеет неверный формат (ожидалось - Function или AsyncFunction)", "Функция получения списка функций сервиса (getServiceFunctions) имеет неверный формат (ожидалось - Function или AsyncFunction)",
required: "Не реализована функция получения списка функций сервиса (getServiceFunctions)" required: "Не реализована функция получения списка функций сервиса (getServiceFunctions)"
} }
}, },
//Протоколирование работы сервиса //Протоколирование работы сервиса
log: { log: {
use: { validateFunctionType }, use: { validateAsyncFunctionType },
required: true, required: true,
message: { message: {
validateFunctionType: validateAsyncFunctionType:
"Функция протоколирования работы сервиса (log) имеет неверный формат (ожидалось - Function или AsyncFunction)", "Функция протоколирования работы сервиса (log) имеет неверный формат (ожидалось - Function или AsyncFunction)",
required: "Не реализована функция протоколирования работы сервиса (log)" required: "Не реализована функция протоколирования работы сервиса (log)"
} }
}, },
//Считывание записей исходящих сообщений очереди //Считывание записей исходящих сообщений очереди
getQueueOutgoing: { getQueueOutgoing: {
use: { validateFunctionType }, use: { validateAsyncFunctionType },
required: true, required: true,
message: { message: {
validateFunctionType: validateAsyncFunctionType:
"Функция считывания записей исходящих сообщений очереди (getQueueOutgoing) имеет неверный формат (ожидалось - Function или AsyncFunction)", "Функция считывания записей исходящих сообщений очереди (getQueueOutgoing) имеет неверный формат (ожидалось - Function или AsyncFunction)",
required: "Не реализована функция считывания записей исходящих сообщений очереди (getQueueOutgoing)" required: "Не реализована функция считывания записей исходящих сообщений очереди (getQueueOutgoing)"
} }
}, },
//Добавление входящего сообщения очереди //Добавление входящего сообщения очереди
putQueueIncoming: { putQueueIncoming: {
use: { validateFunctionType }, use: { validateAsyncFunctionType },
required: true, required: true,
message: { message: {
validateFunctionType: validateAsyncFunctionType:
"Функция добавления входящего сообщения очереди (putQueueIncoming) имеет неверный формат (ожидалось - Function или AsyncFunction)", "Функция добавления входящего сообщения очереди (putQueueIncoming) имеет неверный формат (ожидалось - Function или AsyncFunction)",
required: "Не реализована функция добавления входящего сообщения очереди (putQueueIncoming)" required: "Не реализована функция добавления входящего сообщения очереди (putQueueIncoming)"
} }
}, },
//Уствновка состояния записи очереди //Уствновка состояния записи очереди
setQueueState: { setQueueState: {
use: { validateFunctionType }, use: { validateAsyncFunctionType },
required: true, required: true,
message: { message: {
validateFunctionType: validateAsyncFunctionType:
"Функция уствновки состояния записи очереди (setQueueState) имеет неверный формат (ожидалось - Function или AsyncFunction)", "Функция уствновки состояния записи очереди (setQueueState) имеет неверный формат (ожидалось - Function или AsyncFunction)",
required: "Не реализована функция уствновки состояния записи очереди (setQueueState)" required: "Не реализована функция уствновки состояния записи очереди (setQueueState)"
} }