convert to async/await (#141)

hms-dbmi-cellenics · Jun 2, 2021 · 6c72660 · 6c72660
1 parent b132269
commit 6c72660
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 20 deletions.
diff --git a/src/api/routes/gem2s.js b/src/api/routes/gem2s.js
@@ -10,14 +10,12 @@ const { expressAuthorizationMiddleware } = require('../../utils/authMiddlewares'
 module.exports = {
   'gem2s#create': [
     expressAuthorizationMiddleware,
-    (req, res, next) => {
-      createGem2SPipeline(req.params.experimentId)
-        .then((data) => {
-          const experimentService = new ExperimentService();
-          experimentService.saveGem2sHandle(req.params.experimentId, data)
-            .then(() => res.json(data));
-        })
-        .catch(next);
+    async (req, res) => {
+      const data = await createGem2SPipeline(req.params.experimentId);
+
+      const experimentService = new ExperimentService();
+      await experimentService.saveGem2sHandle(req.params.experimentId, data);
+      res.json(data);
     },
   ],
 

diff --git a/src/api/routes/pipelines.js b/src/api/routes/pipelines.js
@@ -10,24 +10,20 @@ const { expressAuthorizationMiddleware } = require('../../utils/authMiddlewares'
 module.exports = {
   'pipelines#get': [
     expressAuthorizationMiddleware,
-    (req, res, next) => {
+    async (req, res) => {
       // The changes to add gem2s status will be obsoleted once agi's PR is merged in
-      getBackendStatus(req.params.experimentId)
-        .then((data) => res.json(data))
-        .catch(next);
+      const data = await getBackendStatus(req.params.experimentId);
+      res.json(data);
     },
   ],
   'pipelines#create': [
-    (req, res, next) => {
+    async (req, res) => {
       const { processingConfig } = req.body;
 
-      createQCPipeline(req.params.experimentId, processingConfig || [])
-        .then((data) => {
-          const experimentService = new ExperimentService();
-          experimentService.saveQCHandle(req.params.experimentId, data)
-            .then(() => res.json(data));
-        })
-        .catch(next);
+      const data = await createQCPipeline(req.params.experimentId, processingConfig || []);
+      const experimentService = new ExperimentService();
+      await experimentService.saveQCHandle(req.params.experimentId, data);
+      res.json(data);
     },
   ],
   'pipelines#response': async (req, res) => {