chore: add queue reservation test

src/performanceTest/scripts/lib/helpers.js

@@ -3,14 +3,18 @@ import exec from 'k6/execution';
 
 const getRandomByRange = (max) => Math.floor(Math.random() * max);
 
+export const sleep = (ms) => new Promise((resolve) => setTimeout(resolve, ms));
+
 export const getOneFromList = (list) => list[getRandomByRange(list.length)];
 
 export const isSuccess = (r) => r.status >= 200 && r.status < 300;
 export const isFail = (r) => !isSuccess(r);
 
 
 export const isAlreadReservedAll = (r) => r.status == 409 && r.json().errorCode == 50001;
+export const isRunningQueueTicket = (r) => r.status == 200 && r.json().data.isWaiting == false;
 
 export const randomInt = (start, end) => randomIntBetween(start, end);
 
-export const getUserIDFromExec = (VU_COUNT) => exec.vu.idInTest + (VU_COUNT * exec.vu.iterationInScenario)
+export const getUserIDFromExec = (VU_COUNT) => exec.vu.idInTest + (VU_COUNT * exec.vu.iterationInScenario)
+

src/performanceTest/scripts/lib/request.js

@@ -110,4 +110,21 @@ export default class Request {
         this.afterHook()
         return res
     }
+
+
+    createQueueTicket(eventId, userId) {
+        this.beforeHook()
+        const res =  http.post(`${this.baseURL}/ticket`, JSON.stringify({eventId, userId}), this.getParams());
+        this.afterHook()
+        return res
+    }
+
+    getQueueTicket(eventId, userId) {
+        this.beforeHook()
+        const res =  http.get(`${this.baseURL}/ticket/${eventId}/${userId}`, this.getParams());
+        this.afterHook()
+        this.afterHook()
+        this.afterHook()
+        return res
+    }
 }

src/performanceTest/scripts/smokeTest/queue_reservationCheck.js

@@ -0,0 +1,28 @@
+import { check } from "k6";
+import Request from "../lib/request.js";
+import generator from "../lib/generator.js";
+import hooks from "../lib/hooks.js";
+import { getOneFromList, isRunningQueueTicket } from "../lib/helpers.js";
+
+export const setup = hooks.setup
+export const handleSummary = hooks.handleSummary
+
+export default function () {
+   const req = new Request()
+
+   const USERID = 1
+   const user = generator.User(USERID)
+   req.signup(user)
+   req.signin(user)
+   const event = getOneFromList(req.getEvents().json().data)
+   const res1 = req.createQueueTicket(event.id, USERID)
+
+   check(res1, { "createQueueTicket status == 201": (r) => r.status == 201 });
+
+   while (!isRunningQueueTicket(req.getQueueTicket(event.id, USERID))) {}
+
+   const res2 = req.createReservation(generator.Reservation(event.id))
+   console.log(res2)
+   check(res2, { "createReservation status == 201": (r) => r.status == 201 });
+   check(res2, { "createReservation.eventId == event.id": (r) => r.json().data.eventId == event.id });
+}

src/performanceTest/scripts/spikeTest/queue_spikeTest.js

@@ -0,0 +1,68 @@
+import { check } from "k6";
+import Request from "../lib/request.js";
+import { encode } from "../lib/jwt.js";
+import hooks from "../lib/hooks.js";
+import generator from "../lib/generator.js";
+import { isSuccess, randomInt, isAlreadReservedAll, isRunningQueueTicket } from "../lib/helpers.js";
+
+export const setup = hooks.setup
+export const handleSummary = hooks.handleSummary
+
+export const options = {
+  tags: {
+    testid: `${__ENV.ENTRYPOINT}`
+  },
+  ext: {
+    loadimpact: {
+      apm: [
+        {
+          includeTestRunId: true,
+        }
+      ]
+    }
+  },
+  scenarios: {
+    contacts: {
+      executor: 'per-vu-iterations',
+      vus: 200,
+      iterations: 1,
+      maxDuration: '1m', 
+    },
+  },
+
+  thresholds: {
+    http_req_failed: ['rate<0.01'], // http errors should be less than 1%
+    http_req_duration: ['p(95)<300'], // 95% of requests should be below 300ms
+  },
+};
+
+
+export default function () {
+  const req = new Request()
+
+  const ID = randomInt(1, 1000000)
+  req.setToken(encode(ID))
+
+  const query = {
+    size: 20,
+    page: 0,
+    sort: "id,asc"
+  }
+  for (let i = 0; i < 13; i++) {
+    check(req.getEvents(query), {"Success Get Events": isSuccess});
+    query.page = query.page + randomInt(1, 10)
+  }
+
+  const eventId = 98 // maxAttendees = 191
+  check(req.getEvent(eventId), {"EVENT 98 maxAttendees = 191": (r) => r.json().data.maxAttendees === 191})
+
+  const res1 = req.createQueueTicket(eventId, ID)
+  check(res1, { "createQueueTicket status == 201": (r) => r.status == 201 });
+
+  while (!isRunningQueueTicket(req.getQueueTicket(eventId, ID))) {}
+
+
+  const res = req.createReservation(generator.Reservation(eventId))
+  check(res, {"Success Reservation": isSuccess});
+  check(res, {"Already reserved": isAlreadReservedAll});
+}

src/performanceTest/scripts/spikeTest/spikeTest.js

@@ -24,7 +24,7 @@ export const options = {
   scenarios: {
     contacts: {
       executor: 'per-vu-iterations',
-      vus: 500,
+      vus: 200,
       iterations: 1,
       maxDuration: '1m', 
     },