feat: retrieve post actions and save it in appInstance

Author: pyphilia

public/app/config/channels.js

@@ -41,4 +41,5 @@ module.exports = {
   CLEARED_USER_INPUT_CHANNEL: 'space:cleared',
   SHOW_CLEAR_USER_INPUT_PROMPT_CHANNEL: 'prompt:space:clear:show',
   RESPOND_CLEAR_USER_INPUT_PROMPT_CHANNEL: 'prompt:space:clear:respond',
+  POST_ACTION_CHANNEL: 'action:post',
 };

public/app/listeners/index.js

@@ -18,6 +18,7 @@ const getDeveloperMode = require('./getDeveloperMode');
 const setDeveloperMode = require('./setDeveloperMode');
 const clearUserInput = require('./clearUserInput');
 const showClearUserInputPrompt = require('./showClearUserInputPrompt');
+const postAction = require('./postAction');
 
 module.exports = {
   loadSpace,
@@ -40,4 +41,5 @@ module.exports = {
   setDeveloperMode,
   clearUserInput,
   showClearUserInputPrompt,
+  postAction,
 };

public/app/listeners/postAction.js

@@ -0,0 +1,63 @@
+const ObjectId = require('bson-objectid');
+const { POST_ACTION_CHANNEL } = require('../config/channels');
+
+const postAction = (mainWindow, db) => (event, payload = {}) => {
+  try {
+    const {
+      userId,
+      appInstanceId,
+      spaceId,
+      subSpaceId,
+      format,
+      verb,
+      data,
+      visibility = 'private',
+    } = payload;
+
+    // prepare the timestamp
+    const now = new Date();
+
+    // prepare the resource that we will create
+    const actionToWrite = {
+      appInstance: appInstanceId,
+      createdAt: now,
+      updatedAt: now,
+      data,
+      format,
+      verb,
+      visibility,
+      user: userId,
+      id: ObjectId().str,
+    };
+
+    // write the resource to the database
+    const appInstanceElement = db
+      .get('spaces')
+      .find({ id: spaceId })
+      .get('phases')
+      .find({ id: subSpaceId })
+      .get('items')
+      .filter(item => item.appInstance)
+      .map(item => item.appInstance)
+      .find({ id: appInstanceId });
+
+    // add the actions key if it does not exist
+    const hasActions = appInstanceElement.has('actions').value();
+    if (!hasActions) {
+      appInstanceElement.set('actions', [actionToWrite]).write();
+    } else {
+      appInstanceElement
+        .get('actions')
+        .push(actionToWrite)
+        .write();
+    }
+
+    // send back the resource
+    mainWindow.webContents.send(POST_ACTION_CHANNEL, actionToWrite);
+  } catch (e) {
+    console.error(e);
+    mainWindow.webContents.send(POST_ACTION_CHANNEL, null);
+  }
+};
+
+module.exports = postAction;

public/electron.js

@@ -49,6 +49,7 @@ const {
   SYNC_SPACE_CHANNEL,
   CLEAR_USER_INPUT_CHANNEL,
   SHOW_CLEAR_USER_INPUT_PROMPT_CHANNEL,
+  POST_ACTION_CHANNEL,
 } = require('./app/config/channels');
 const env = require('./env.json');
 const {
@@ -72,6 +73,7 @@ const {
   setDeveloperMode,
   clearUserInput,
   showClearUserInputPrompt,
+  postAction,
 } = require('./app/listeners');
 const isMac = require('./app/utils/isMac');
 
@@ -368,6 +370,9 @@ app.on('ready', async () => {
     setGeolocationEnabled(mainWindow, db)
   );
 
+  // called when creating an action
+  ipcMain.on(POST_ACTION_CHANNEL, postAction(mainWindow, db));
+
   // called when getting AppInstanceResources
   ipcMain.on(GET_APP_INSTANCE_RESOURCES_CHANNEL, (event, data = {}) => {
     const defaultResponse = [];

src/actions/action.js

@@ -0,0 +1,41 @@
+import { POST_ACTION_SUCCEEDED } from '../types';
+import { POST_ACTION_CHANNEL } from '../config/channels';
+
+const postAction = async (ddd = {}, callback) => () => {
+  const {
+    userId,
+    id: appInstanceId,
+    spaceId,
+    subSpaceId,
+    format,
+    data,
+    verb,
+    visibility,
+  } = ddd;
+  try {
+    window.ipcRenderer.send(POST_ACTION_CHANNEL, {
+      userId,
+      appInstanceId,
+      spaceId,
+      subSpaceId,
+      format,
+      data,
+      verb,
+      visibility,
+    });
+
+    window.ipcRenderer.once(POST_ACTION_CHANNEL, async (event, response) => {
+      callback({
+        // have to include the appInstanceId to avoid broadcasting
+        appInstanceId,
+        type: POST_ACTION_SUCCEEDED,
+        payload: response,
+      });
+    });
+  } catch (err) {
+    console.error(err);
+  }
+};
+
+// eslint-disable-next-line import/prefer-default-export
+export { postAction };

src/actions/index.js

@@ -5,3 +5,4 @@ export * from './appInstanceResource';
 export * from './appInstance';
 export * from './developer';
 export * from './layout';
+export * from './action';

src/components/phase/PhaseApp.js

@@ -12,12 +12,14 @@ import {
   GET_APP_INSTANCE,
   POST_APP_INSTANCE_RESOURCE,
   APP_INSTANCE_RESOURCE_TYPES,
+  POST_ACTION,
 } from '../../types';
 import {
   getAppInstanceResources,
   patchAppInstanceResource,
   postAppInstanceResource,
   getAppInstance,
+  postAction,
 } from '../../actions';
 import {
   DEFAULT_LANGUAGE,
@@ -45,6 +47,7 @@ class PhaseApp extends Component {
     name: PropTypes.string,
     folder: PropTypes.string.isRequired,
     dispatchGetAppInstance: PropTypes.func.isRequired,
+    dispatchPostAction: PropTypes.func.isRequired,
     id: PropTypes.string.isRequired,
     phaseId: PropTypes.string.isRequired,
     spaceId: PropTypes.string.isRequired,
@@ -101,7 +104,11 @@ class PhaseApp extends Component {
 
   handleReceiveMessage = event => {
     try {
-      const { dispatchGetAppInstance, appInstance } = this.props;
+      const {
+        dispatchGetAppInstance,
+        appInstance,
+        dispatchPostAction,
+      } = this.props;
 
       // get app instance id in message
       const { id: componentAppInstanceId } = appInstance || {};
@@ -122,6 +129,8 @@ class PhaseApp extends Component {
             return patchAppInstanceResource(payload, this.postMessage);
           case GET_APP_INSTANCE:
             return dispatchGetAppInstance(payload, this.postMessage);
+          case POST_ACTION:
+            return dispatchPostAction(payload, this.postMessage);
           default:
             return false;
         }
@@ -280,6 +289,7 @@ const mapStateToProps = ({ User, Space }) => ({
 
 const mapDispatchToProps = {
   dispatchGetAppInstance: getAppInstance,
+  dispatchPostAction: postAction,
 };
 
 const ConnectedComponent = connect(

src/config/channels.js

@@ -41,4 +41,5 @@ module.exports = {
   CLEARED_USER_INPUT_CHANNEL: 'space:cleared',
   SHOW_CLEAR_USER_INPUT_PROMPT_CHANNEL: 'prompt:space:clear:show',
   RESPOND_CLEAR_USER_INPUT_PROMPT_CHANNEL: 'prompt:space:clear:respond',
+  POST_ACTION_CHANNEL: 'action:post',
 };

src/types/action.js

@@ -0,0 +1,2 @@
+export const POST_ACTION = 'POST_ACTION';
+export const POST_ACTION_SUCCEEDED = 'POST_ACTION_SUCCEEDED';

src/types/index.js

@@ -5,3 +5,4 @@ export * from './appInstance';
 export * from './appInstanceResource';
 export * from './developer';
 export * from './layout';
+export * from './action';