wait for reset before config api resolve (#45)

Resolves #44

---------

Co-authored-by: Arthur Buldauskas <[email protected]>

CHANGELOG.md

@@ -1,3 +1,7 @@
+## 0.1.2 - Fix config api route
+
+- fix: wait on `reset` event during config api calls
+
 ## 0.1.1 - `--reset` cli arg, better messages
 
 - feat: custom responses for cache misses while network access is disabled

package.json

@@ -1,6 +1,6 @@
 {
   "name": "jambox",
-  "version": "0.1.1",
+  "version": "0.1.2",
   "description": "Tool for recording and playing back HTTP requests.",
   "bin": {
     "jam": "./jam.mjs",

src/Jambox.mjs

@@ -55,6 +55,7 @@ export default class Jambox extends Emitter {
 
   async reset() {
     debug('Reset');
+
     await this.proxy.reset();
     await this.cache.reset({ ...this.config.cache });
 
@@ -93,21 +94,21 @@ export default class Jambox extends Emitter {
         .thenPassThrough();
     }
 
-    if (this.config.paused) {
-      return;
-    }
+    if (!this.config.paused) {
+      if (this.config.cache) {
+        await this.record(this.config.cache);
+      }
 
-    if (this.config.cache) {
-      await this.record(this.config.cache);
-    }
+      if (this.config.forward) {
+        await this.forward(this.config.forward);
+      }
 
-    if (this.config.forward) {
-      await this.forward(this.config.forward);
+      if (this.config.stub) {
+        await this.stub(this.config.stub);
+      }
     }
 
-    if (this.config.stub) {
-      await this.stub(this.config.stub);
-    }
+    this.dispatch('reset');
   }
 
   record(setting) {

src/server/routes/__tests__/config.route.test.mjs

@@ -16,7 +16,12 @@ test('get & post api', async (t) => {
 
   const app = express();
   app.use(bodyParser.json());
-  app.use((req, res, next) => enter({ jambox: { config, reset() {} } }, next));
+  app.use((req, res, next) =>
+    enter(
+      { jambox: { config, reset() {}, once: () => Promise.resolve() } },
+      next
+    )
+  );
   app.use('/api', router);
 
   await supertest(app)

src/server/routes/config.route.mjs

@@ -9,6 +9,7 @@ router.get('/config', async (_, res) => res.send(jambox().config.serialize()));
 router.post('/config', async (req, res, next) => {
   try {
     jambox().config.update(req.body);
+    await jambox().once('jambox.reset');
     res.sendStatus(200);
   } catch (error) {
     next(error);
@@ -21,6 +22,7 @@ router.post('/pause', async (req, res, next) => {
   try {
     const { paused } = req.body;
     jambox().config.update({ paused });
+    await jambox().once('jambox.reset');
     res.sendStatus(200);
   } catch (error) {
     next(error);