Initial session API implentation

src/app.js

@@ -7,16 +7,14 @@ whatsapp = require('./whatsapp'),
 { listen } = require('./socket'),
 chats = require('./routes/chatsRouter'),
 groups = require('./routes/groupsRouter')
+sessions = require('./routes/sessionRouter')
 
 app.use(bodyParser.urlencoded({ extended: true }))
 app.use(bodyParser.json())
 
 app.use('/chats', chats)
 app.use('/groups', groups)
-
-app.get('/', (req, res) => {
-    res.sendFile('./index.html', {root: __dirname})
-})
+app.use('/sessions', sessions)
 
 app.all('*', (req, res) => {
     response(res, 404, {success: false, message: 'The requested url cannot be found.'})

src/controllers/sessionController.js

@@ -0,0 +1,42 @@
+const { response } = require('../response'),
+{ validationResult } = require('express-validator'),
+whatsapp = require('../whatsapp')
+
+const createSession = (req, res) => {
+    const errors = validationResult(req)
+    if(!errors.isEmpty()) return response(res, 400, {success: false, message: 'Please fill out all required inputs.'})
+
+    const session = req.body.session;
+
+    if(whatsapp.checkSession(session)) return response(res, 422, {
+        error: 'Session already exists.'
+    })
+
+    whatsapp.createSession(null, session)
+        .then(() => {
+            response(res, 200, {
+                success: true,
+                message: "New session created."
+            })
+        })
+        .catch(err => {
+            response(res, 422, {
+                error: 'Error creating session.',
+                message: err
+            })
+        })
+}
+
+const getActiveSessions = (req, res) => {
+
+    response(res, 200, {
+        success: true, 
+        data: whatsapp.getActiveSessions()
+    })
+
+}
+
+module.exports = {
+    createSession: createSession,
+    getActiveSessions: getActiveSessions
+}

src/routes/sessionRouter.js

@@ -0,0 +1,16 @@
+const router = require('express').Router(),
+{ query, body } = require('express-validator'),
+controller = require('./../controllers/sessionController')
+
+router.get(
+    '/',
+    controller.getActiveSessions
+)
+
+router.post(
+    '/',
+    body('session').notEmpty(),
+    controller.createSession
+)
+
+module.exports = router

src/whatsapp.js

@@ -40,7 +40,7 @@ const createExistedSession = async session => {
     .catch(err => console.log('Unexpected error: ' + err))
 }
 
-const createSession = async (socket, session) => {
+const createSession = async (session) => {
     let wa = new WAConnection()
 
     wa.browserDescription = ['Windows', 'Chrome', '10']
@@ -51,9 +51,8 @@ const createSession = async (socket, session) => {
 
     wa.on('qr', qr => {
         qrcode.toDataURL(qr, (err, url) => {
-            if(err) socket.emit('message', 'An error occured during creating QR image.')
-
-            socket.emit('qr', {id: session, qr: url})
+            //save session
+            console.log(qr)
         })
     })
 
@@ -65,14 +64,10 @@ const createSession = async (socket, session) => {
         connections[session] = wa
 
         clearTimeout(timeout)
-
-        socket.emit('added', session)
     })
 
     wa.on('close', () => {
         deleteSession(session)
-
-        socket.emit('deleted', session)
     })
 
     return await wa.connect()