notifying worker of job done

src/api/general-services/pipeline-manage/constants.js

@@ -13,7 +13,6 @@ const SUCCEEDED = 'SUCCEEDED';
 
 // Custom defined statuses defined in the API
 const NOT_CREATED = 'NOT_CREATED';
-
 // Additional custom statuses
 
 module.exports = {

src/api/route-services/work-response.js

@@ -4,6 +4,12 @@ const validateRequest = require('../../utils/schema-validator');
 const logger = require('../../utils/logging');
 const { cacheSetResponse } = require('../../utils/cache-request');
 const { handlePagination } = require('../../utils/handlePagination');
+const ExperimentService = require('./experiment');
+
+const experimentService = new ExperimentService();
+
+const NEW = 'NEW';
+const DATA_UPDATE = 'data_update';
 
 class WorkResponseService {
   constructor(io, workResponse) {
@@ -15,6 +21,29 @@ class WorkResponseService {
     })();
   }
 
+  async notifyDataUpdate(responseForClient) {
+    const { experimentId } = responseForClient.request;
+
+    // this should resend the request so the UI can replay it
+    // instead of sending the data to everyone
+    const response = {
+      // response: responseForClient,
+      request: responseForClient.request,
+      status: NEW,
+      type: DATA_UPDATE,
+    };
+
+    console.log('RESPONSE FOR CLIENT');
+    console.log(responseForClient);
+    // const cellsets = responseForClient.results[0].body;
+
+    // await experimentService.updateCellSets(experimentId, cellsets);
+
+
+    logger.log('Sending to all clients subscribed to experiment', experimentId);
+    this.io.sockets.emit(`ExperimentUpdates-${experimentId}`, response);
+  }
+
   // eslint-disable-next-line class-methods-use-this
   async processS3PathType(workResponse) {
     const s3Promises = [];
@@ -102,11 +131,16 @@ class WorkResponseService {
       throw e;
     }
 
+    // const { experimentId } = responseForClient.request;
+
+    await this.notifyDataUpdate(responseForClient);
+
     if (socketId === 'no-socket') {
       logger.log('Socket is not provided, no response sent out.');
       return;
     }
 
+
     if (Date.parse(timeout) > Date.now()) {
       this.io.to(socketId).emit(`WorkResponse-${uuid}`, responseForClient);
       logger.log('Work response sent out.');

src/api/routes/experiment.js

@@ -40,6 +40,8 @@ module.exports = {
   'experiment#updateCellSets': [
     expressAuthorizationMiddleware,
     (req, res, next) => {
+      console.log('REQUEST UPDATE FOR CELLSETS MORTY');
+      console.log(req);
       experimentService.updateCellSets(req.params.experimentId, req.body)
         .then((data) => res.json(data))
         .catch(next);