refactor: readability attempted noise reduction

README.md

@@ -51,7 +51,7 @@ run.setOptions({
 
 test("Iterations Executor Test @iterations-executor", async ({ request }) => {
   await run.go(async () => {
-    const response = await request.get("/public/crocodiles/");
+    const response = await request.get("https://yesno.wtf/api");
     expect(response.ok()).toBeTruthy();
   });
 });
@@ -71,7 +71,7 @@ run.setOptions({
 
 test("Duration Executor Test @duration-executor", async ({ request }) => {
   await run.go(async () => {
-    const response = await request.get("/public/crocodiles/");
+    const response = await request.get("https://yesno.wtf/api");
     expect(response.ok()).toBeTruthy();
   });
 });
@@ -94,7 +94,7 @@ test("Iterations per Second Executor Test @iterations-per-second-executor", asyn
   request,
 }) => {
   await run.go(async () => {
-    const response = await request.get("/public/crocodiles/");
+    const response = await request.get("https://yesno.wtf/api");
     expect(response.ok()).toBeTruthy();
   });
 });

src/runner.ts

@@ -1,5 +1,13 @@
 import { Options } from "./types";
 
+const write = process.stdout.write;
+
+const timeout = setTimeout;
+
+const sleep = async (duration: number) => {
+  await new Promise((resolve) => setTimeout(resolve, duration));
+};
+
 export default class Runner {
   private options: Options;
   private resolved: any[] = [];
@@ -19,46 +27,48 @@ export default class Runner {
     this.resolved.push(await func());
   }
 
-  private async makeSequentialRequests(func: Function) {
-    await this.makeSyncronousRequests(func);
-  }
-
   private async makeConcurrentRequests(func: Function) {
     this.promises.push(
       new Promise((resolve) => {
         return resolve(func());
-      }),
+      })
     );
   }
 
   private async iterationsExecutor(func: Function) {
     for (let i = 0; i < this.options.iterations!; i++) {
-      await this.makeSequentialRequests(func);
-      process.stdout.write("|");
+      await this.makeSyncronousRequests(func);
+      write("|");
     }
   }
 
   private async durationExecutor(func: Function) {
-    let end = performance.now() + this.options.duration! * 1000;
-    while (performance.now() < end) {
-      await this.makeSequentialRequests(func);
-      process.stdout.write("|");
+    let go = true;
+    timeout(() => {
+      go = false;
+    }, this.options.duration! * 1000);
+    while (go) {
+      await this.makeSyncronousRequests(func);
+      write("|");
     }
   }
 
   private async iterationsPerSecondExecutor(func: Function) {
-    let end = performance.now() + this.options.duration! * 1000;
-    while (performance.now() < end) {
+    let go = true;
+    timeout(() => {
+      go = false;
+    }, this.options.duration! * 1000);
+    while (go) {
       for (let i = 0; i < this.options.ips!; i++) {
         this.makeConcurrentRequests(func);
       }
-      await new Promise((resolve) => setTimeout(resolve, 1000));
-      process.stdout.write("|");
+      await sleep(1000);
+      write("|");
     }
   }
 
   async go(func: Function) {
-    process.stdout.write("\nRUNNING:");
+    write("\nRUNNING:");
     switch (this.options.executor !== null) {
       case this.options.executor === "iterations": {
         await this.iterationsExecutor(func);
@@ -74,6 +84,6 @@ export default class Runner {
       }
     }
     await this.resolvePromises();
-    process.stdout.write("...COMPLETE!");
+    write("...COMPLETE!");
   }
 }

tests/duration.spec.ts

@@ -8,7 +8,7 @@ run.setOptions({
 
 test("Duration Executor Test @duration-executor", async ({ request }) => {
   await run.go(async () => {
-    const response = await request.get("/public/crocodiles/");
+    const response = await request.get("/api");
     expect(response.ok()).toBeTruthy();
   });
 });

tests/iterations.spec.ts

@@ -8,7 +8,7 @@ run.setOptions({
 
 test("Iterations Executor Test @iterations-executor", async ({ request }) => {
   await run.go(async () => {
-    const response = await request.get("/public/crocodiles/");
+    const response = await request.get("/api");
     expect(response.ok()).toBeTruthy();
   });
 });

tests/iterationsPerSecond.spec.ts

@@ -11,7 +11,7 @@ test("Iterations per Second Executor Test @iterations-per-second-executor", asyn
   request,
 }) => {
   await run.go(async () => {
-    const response = await request.get("/public/crocodiles/");
+    const response = await request.get("/api");
     expect(response.ok()).toBeTruthy();
   });
 });

tests/playwright.config.ts

@@ -3,6 +3,6 @@ import { defineConfig } from "@playwright/test";
 export default defineConfig({
   use: {
     // All requests we send go to this API endpoint.
-    baseURL: "https://test-api.k6.io",
+    baseURL: "https://yesno.wtf",
   },
 });