feat: return job after start/stop

Author: shadowgate15

app/controllers/api/v1/control.js

@@ -9,37 +9,53 @@ async function checkJobName(ctx, next) {
   return next();
 }
 
-async function start(ctx) {
+async function addJobNameToQuery(ctx, next) {
+  const { jobName } = ctx.params;
+
+  ctx.query = { name: jobName };
+
+  return next();
+}
+
+async function start(ctx, next) {
   const { jobName } = ctx.params;
 
   await ctx.bree.start(jobName);
 
   ctx.body = {};
+
+  return next();
 }
 
-async function stop(ctx) {
+async function stop(ctx, next) {
   const { jobName } = ctx.params;
 
   await ctx.bree.stop(jobName);
 
   ctx.body = {};
+
+  return next();
 }
 
-async function run(ctx) {
+async function run(ctx, next) {
   const { jobName } = ctx.params;
 
   await ctx.bree.run(jobName);
 
   ctx.body = {};
+
+  return next();
 }
 
-async function restart(ctx) {
+async function restart(ctx, next) {
   const { jobName } = ctx.params;
 
   await ctx.bree.stop(jobName);
   await ctx.bree.start(jobName);
 
   ctx.body = {};
+
+  return next();
 }
 
-module.exports = { checkJobName, start, stop, run, restart };
+module.exports = { checkJobName, addJobNameToQuery, start, stop, run, restart };

app/controllers/api/v1/sse.js

@@ -3,7 +3,7 @@ async function connect(ctx) {
     // send bree events over sse
     for (const event of ['worker created', 'worker deleted']) {
       ctx.bree.on(event, (name) => {
-        ctx.sse.send({ event, data: { name } });
+        ctx.sse.send({ event, data: name });
       });
     }
 

routes/api/v1/index.js

@@ -19,16 +19,42 @@ router.post('/jobs', api.v1.jobs.add);
 router.use(api.v1.control.checkJobName);
 
 router.post('/start', api.v1.control.start);
-router.post('/start/:jobName', api.v1.control.start);
+router.post(
+  '/start/:jobName',
+  api.v1.control.start,
+  api.v1.control.addJobNameToQuery,
+  api.v1.jobs.get
+);
 
 router.post('/stop', api.v1.control.stop);
-router.post('/stop/:jobName', api.v1.control.stop);
-
-router.post('/run/:jobName', api.v1.control.run);
+router.post(
+  '/stop/:jobName',
+  api.v1.control.stop,
+  api.v1.control.addJobNameToQuery,
+  api.v1.jobs.get
+);
+
+router.post(
+  '/run/:jobName',
+  api.v1.control.run,
+  api.v1.control.addJobNameToQuery,
+  api.v1.jobs.get
+);
 
 router.post('/restart', api.v1.control.restart);
-router.post('/restart/:jobName', api.v1.control.restart);
-
-router.get('/sse/:token', api.v1.sse.connect);
+router.post(
+  '/restart/:jobName',
+  api.v1.control.restart,
+  api.v1.control.addJobNameToQuery,
+  api.v1.jobs.get
+);
+
+router.get('/sse', api.v1.sse.connect);
+router.get(
+  '/sse/:token',
+  api.v1.sse.connect,
+  api.v1.control.addJobNameToQuery,
+  api.v1.jobs.get
+);
 
 module.exports = router;

test/api/v1/restart.js

@@ -54,6 +54,8 @@ test.serial('successfully restart active job', async (t) => {
   const res = await api.post(`${rootUrl}/active`).send({});
 
   t.is(res.status, 200);
+  t.is(res.body.length, 1);
+  t.like(res.body[0], { name: 'active' });
 
   await delay(200);
 

test/api/v1/sse.js

@@ -12,20 +12,10 @@ const rootUrl = '/v1/sse';
 test.before(async (t) => {
   await utils.setupApiServer(t, {
     jobs: [
-      { name: 'done', path: path.join(utils.root, 'basic.js') },
       {
         name: 'delayed',
         path: path.join(utils.root, 'basic.js'),
-        timeout: 100
-      },
-      {
-        name: 'waiting',
-        path: path.join(utils.root, 'basic.js'),
-        interval: 100
-      },
-      {
-        name: 'active',
-        path: path.join(utils.root, 'long.js')
+        interval: 1000
       }
     ]
   });
@@ -48,9 +38,10 @@ const eventsMacro = test.macro({
   async exec(t, event) {
     const es = utils.setupEventSource(t, rootUrl);
 
-    await once(es, event);
+    const [res] = await once(es, event);
 
-    t.pass();
+    t.is(res.type, event);
+    t.is(res.data, 'delayed');
   },
   title(_, event) {
     return `successfully listen to "${event}" messages`;

test/api/v1/start.js

@@ -70,6 +70,8 @@ test.serial('successfully start named job', async (t) => {
   const res = await api.post(`${rootUrl}/timeout`).send({});
 
   t.is(res.status, 200);
+  t.is(res.body.length, 1);
+  t.like(res.body[0], { name: 'timeout' });
 
   await delay(200);
 

test/api/v1/stop.js

@@ -46,6 +46,8 @@ test.serial('successfully stop named job', async (t) => {
   const res = await api.post(`${rootUrl}/active`).send({});
 
   t.is(res.status, 200);
+  t.is(res.body.length, 1);
+  t.like(res.body[0], { name: 'active' });
 
   t.falsy(bree.workers.has('active'));
 });