feat: support sequences creation through web sockets (NoMercy235/cyoa…

…-frontend#56)

src/sockets/constants.js

@@ -4,6 +4,27 @@ const SocketEvents = {
     UserOnline: 'USER_ONLINE',
     UserOffline: 'USER_OFFLINE',
     UsersOnline: 'USERS_ONLINE',
+
+    NewSequenceRequest: 'NEW_SEQUENCE_REQUEST',
+    UpdateSequenceRequest: 'UPDATE_SEQUENCE_REQUEST',
+    DeleteSequenceRequest: 'DELETE_SEQUENCE_REQUEST',
+    NewOptionRequest: 'NEW_OPTION_REQUEST',
+    UpdateOptionRequest: 'UPDATE_OPTION_REQUEST',
+    DeleteOptionRequest: 'DELETE_OPTION_REQUEST',
+
+    NewSequenceResponse: 'NEW_SEQUENCE_RESPONSE',
+    UpdateSequenceResponse: 'UPDATE_SEQUENCE_RESPONSE',
+    DeleteSequenceResponse: 'DELETE_SEQUENCE_RESPONSE',
+    NewOptionResponse: 'NEW_OPTION_RESPONSE',
+    UpdateOptionResponse: 'UPDATE_OPTION_RESPONSE',
+    DeleteOptionResponse: 'DELETE_OPTION_RESPONSE',
+
+    NewSequenceError: 'NEW_SEQUENCE_ERROR',
+    UpdateSequenceError: 'UPDATE_SEQUENCE_ERROR',
+    DeleteSequenceError: 'DELETE_SEQUENCE_ERROR',
+    NewOptionError: 'NEW_OPTION_ERROR',
+    UpdateOptionError: 'UPDATE_OPTION_ERROR',
+    DeleteOptionError: 'DELETE_OPTION_ERROR',
 };
 
 module.exports = {

src/sockets/setup.js

@@ -1,7 +1,9 @@
 const registerUserConnectionSocket = require('./user-connections');
+const registerWriteStorySocket = require('./write-story');
 
 const handleSocket = socket => {
     registerUserConnectionSocket(socket);
+    registerWriteStorySocket(socket);
 };
 
 module.exports = {

src/sockets/write-story.js

@@ -0,0 +1,34 @@
+const Sequence = require('../models/sequence').model;
+const { SocketEvents } = require('./constants');
+
+const handleNewSequence = socket => async (data) => {
+    console.log(data);
+    const sequence = new Sequence(data);
+    sequence.hasScenePic = !!sequence.scenePic;
+    const lastSeqInOrder = await Sequence.findLastInOrder();
+    sequence.order = lastSeqInOrder ? lastSeqInOrder.order + 1 : 0;
+    try {
+        await sequence.save();
+    } catch (e) {
+        socket.emit(
+            SocketEvents.NewSequenceResponse,
+            e,
+        );
+    }
+    socket.emit(
+        SocketEvents.NewSequenceResponse,
+        sequence,
+    );
+};
+
+function registerWriteStorySocket (socket) {
+    socket.on(SocketEvents.NewSequenceRequest, handleNewSequence(socket));
+    socket.on(SocketEvents.UpdateSequenceRequest, () => {
+        console.log('Update Sequence')
+    });
+    socket.on(SocketEvents.DeleteSequenceRequest, () => {
+        console.log('Delete Sequence')
+    });
+}
+
+module.exports = registerWriteStorySocket;