feat: add event utilities

Author: juniorode

src/events.utils.ts

@@ -0,0 +1,23 @@
+import http, { RefinedResponse, ResponseType } from "k6/http";
+import { getHeaders } from "./user.utils";
+import { fail } from "k6";
+//@ts-ignore
+import { FormData } from "https://jslib.k6.io/formdata/0.0.2/index.js";
+import {
+  EventDTO,
+} from "./models";
+
+const rootUrl = __ENV.ROOT_URL;
+
+export function getLastEvents(since: number, type: 'events' | 'traces' = 'events'): RefinedResponse<ResponseType | undefined> {
+  let headers = getHeaders();
+  return http.get(`${rootUrl}/infra/v2/event/list/${type}/${since}`, { headers });
+}
+
+export function getLastEventsOrFail(since: number, type: 'events' | 'traces' = 'events'): EventDTO[] {
+  const res = getLastEvents(since, type);
+  if (res.status !== 200) {
+    fail(`Failed to get last events since ${since} of type ${type}`);
+  }
+  return JSON.parse(res.body as string) as EventDTO[];
+}

src/index.ts

@@ -19,3 +19,4 @@ export * from "./userbook.utils";
 export * from "./ws.utils";
 export * from "./archive.utils";
 export * from "./explorer.utils";
+export * from "./events.utils";

src/models.ts

@@ -301,3 +301,19 @@ export type AppImportResult = {
   resourcesIdsMap: Record<string, Record<string, string>>;
   duplicatesNumberMap: Record<string, number>;
 };
+
+
+export type EventDTO = {
+  _id: string;
+  resource: string;
+  "event-type": string;
+  module: string;
+  date: number;
+  userId: string;
+  profil: string;
+  structures: string[];
+  classes: string[];
+  groups: string[];
+  referer: string;
+  sessionId: string;
+};