chore: bump bree version

Author: shadowgate15

app/controllers/api/v1/control.js

@@ -12,7 +12,7 @@ async function checkJobName(ctx, next) {
 async function start(ctx) {
   const { jobName } = ctx.params;
 
-  ctx.bree.start(jobName);
+  await ctx.bree.start(jobName);
 
   ctx.body = {};
 }
@@ -28,7 +28,7 @@ async function stop(ctx) {
 async function run(ctx) {
   const { jobName } = ctx.params;
 
-  ctx.bree.run(jobName);
+  await ctx.bree.run(jobName);
 
   ctx.body = {};
 }
@@ -37,7 +37,7 @@ async function restart(ctx) {
   const { jobName } = ctx.params;
 
   await ctx.bree.stop(jobName);
-  ctx.bree.start(jobName);
+  await ctx.bree.start(jobName);
 
   ctx.body = {};
 }

app/controllers/api/v1/jobs.js

@@ -56,15 +56,13 @@ async function add(ctx) {
   let jobs;
 
   try {
-    jobs = bree.add(body.jobs);
+    jobs = await bree.add(body.jobs);
   } catch (err) {
     return ctx.throw(Boom.badData(err));
   }
 
   if (body.start) {
-    for (const job of jobs) {
-      bree.start(job.name);
-    }
+    await Promise.all(jobs.map((j) => bree.start(j.name)));
   }
 
   ctx.body = { jobs };

index.js

@@ -17,8 +17,8 @@ function plugin(opts, Bree) {
 
   const oldInit = Bree.prototype.init;
 
-  Bree.prototype.init = function () {
-    oldInit.bind(this)();
+  Bree.prototype.init = async function () {
+    await oldInit.bind(this)();
 
     // assign bree to the context
     api.app.context.bree = this;

package.json

@@ -48,7 +48,7 @@
     "@commitlint/cli": "^17.0.2",
     "@commitlint/config-conventional": "^17.0.2",
     "ava": "^4.3.0",
-    "bree": "^8.0.0",
+    "bree": "^9.0.0",
     "codecov": "^3.8.1",
     "delay": "^5.0.0",
     "eslint": "^8.17.0",
@@ -107,7 +107,7 @@
     ]
   },
   "peerDependencies": {
-    "bree": "~8.0"
+    "bree": "~9.0"
   },
   "prettier": {
     "singleQuote": true,

test/api/v1/jobs/get.js

@@ -34,7 +34,7 @@ test.before(async (t) => {
 
   t.context.api = t.context.api.auth(t.context.token, { type: 'bearer' });
 
-  t.context.bree.start();
+  await t.context.bree.start();
 });
 
 test.serial('successfully', async (t) => {

test/api/v1/jobs/post.js

@@ -16,7 +16,7 @@ test.before(async (t) => {
 
   t.context.api = t.context.api.auth(t.context.token, { type: 'bearer' });
 
-  t.context.bree.start();
+  await t.context.bree.start();
 });
 
 test('successfully add one job', async (t) => {

test/api/v1/sse.js

@@ -33,7 +33,7 @@ test.before(async (t) => {
 
   t.context.api = t.context.api.auth(t.context.token, { type: 'bearer' });
 
-  t.context.bree.start();
+  await t.context.bree.start();
 });
 
 test('successfully connect to sse', async (t) => {

test/api/v1/stop.js

@@ -33,7 +33,7 @@ test.before(async (t) => {
 
   t.context.api = t.context.api.auth(t.context.token, { type: 'bearer' });
 
-  t.context.bree.start();
+  await t.context.bree.start();
 
   await delay(200);
 });

test/plugin/index.js

@@ -15,10 +15,11 @@ test('api does not exist on bree constructor', (t) => {
   t.is(typeof Bree.api, 'undefined');
 });
 
-test('api does exist on bree instance', (t) => {
+test('api does exist on bree instance', async (t) => {
   const { Bree } = t.context;
 
   const bree = new Bree(baseConfig);
+  await bree.init();
 
   t.log(bree);
   // just to make sure this works correctly

test/plugin/options.js

@@ -4,7 +4,7 @@ const Bree = require('bree');
 const { plugin } = require('../..');
 const { baseConfig } = require('../utils');
 
-test('can modify options', (t) => {
+test('can modify options', async (t) => {
   t.not(plugin.$i, true);
 
   Bree.extend(plugin, {
@@ -14,6 +14,7 @@ test('can modify options', (t) => {
   });
 
   const bree = new Bree(baseConfig);
+  await bree.init();
 
   t.is(bree.api.config.port, 3000);
   t.is(bree.api.config.jwt.secret, 'thisisasecret');