Prepare and modify sending of (all) notifications

controllers/notifications.js

@@ -0,0 +1,50 @@
+const axios = require('axios');
+const asyncHandler = require('@evnotify/utils').asyncHandler;
+const mailController = require('./mail');
+
+const retrieveData = async(req) => {
+    return Promise.all([
+        axios.get(`${process.env.SETTINGS_SERVICE}/${req.params.akey}`, {
+            headers: {
+                'Authorization': req.headers.authorization,
+                'Authentication': req.headers.authentication,
+                'AKey': req.params.akey
+            }
+        }).then((response) => {
+            return response.data;
+        }),
+        axios.get(`${process.env.SYNC_SERVICE}/${akey}`, {
+            headers: {
+                'Authorization': req.headers.authorization,
+                'Authentication': req.headers.authentication,
+                'AKey': req.params.akey
+            }
+        }).then((response) => {
+            return response.data;
+        })
+    ]);
+};
+
+
+const getNotificationsQuota = asyncHandler(async (req, res, next) => {
+
+});
+
+const sendNotification = asyncHandler(async (req, res, next) =>  {
+    const [settings, sync] = await retrieveData(req);
+    const notificationChannel = req.baseUrl.replace('/') || 'broadcast';
+    const notificationType = req.body.type;
+
+    // TODO: implement the notifications
+    if (notificationChannel === 'mail' || notificationChannel === 'broadcast') mailController.sendMessage();
+    if (notificationChannel === 'telegram' || notificationChannel === 'broadcast') telegramController.sendMessage();
+    if (notificationChannel === 'push' || notificationChannel === 'broadcast') pushController.sendMessage();
+    if (notificationChannel === 'sms' || notificationChannel === 'broadcast') smsController.sendMessage();
+
+    res.sendStatus(200);
+});
+
+module.exports = {
+    getNotificationsQuota,
+    sendNotification
+};

routes/notifications.js

@@ -7,10 +7,10 @@ const notificationsController = require('../controllers/notifications');
 
 router.get('/', authorizationMiddleware, authenticationMiddleware, notificationsController.getNotificationsQuota);
 
-router.post('/', authorizationMiddleware, authenticationMiddleware, notificationsController.sendNotifications);
-router.post('/mail', authorizationMiddleware, authenticationMiddleware, notificationsController.sendMailNotification);
-router.post('/push', authorizationMiddleware, authenticationMiddleware, notificationsController.sendPushNotification);
-router.post('/telegram', authorizationMiddleware, authenticationMiddleware, notificationsController.sendTelegramNotification);
-router.post('/sms', authorizationMiddleware, authenticationMiddleware, notificationsController.sendSMSNotification);
+router.post('/', authorizationMiddleware, authenticationMiddleware, notificationsController.sendNotification);
+router.post('/mail', authorizationMiddleware, authenticationMiddleware, notificationsController.sendNotification);
+router.post('/push', authorizationMiddleware, authenticationMiddleware, notificationsController.sendNotification);
+router.post('/telegram', authorizationMiddleware, authenticationMiddleware, notificationsController.sendNotification);
+router.post('/sms', authorizationMiddleware, authenticationMiddleware, notificationsController.sendNotification);
 
 module.exports = router;