Merge remote-tracking branch 'origin/main' into ph/txWorkerRedis

Author: arcoraven

src/server/routes/system/queue.ts

@@ -2,6 +2,7 @@ import { Static, Type } from "@sinclair/typebox";
 import { FastifyInstance } from "fastify";
 import { StatusCodes } from "http-status-codes";
 import { TransactionDB } from "../../../db/transactions/db";
+import { getPercentile } from "../../../utils/math";
 import { MinedTransaction } from "../../../utils/transaction/types";
 import { MineTransactionQueue } from "../../../worker/queues/mineTransactionQueue";
 import { SendTransactionQueue } from "../../../worker/queues/sendTransactionQueue";

src/server/routes/transaction/syncRetry.ts

@@ -117,7 +117,6 @@ export async function syncRetryTransaction(fastify: FastifyInstance) {
       await TransactionDB.set(sentTransaction);
       await MineTransactionQueue.add({ queueId: sentTransaction.queueId });
       await enqueueTransactionWebhook(sentTransaction);
-      await _reportUsageSuccess(sentTransaction);
 
       reply.status(StatusCodes.OK).send({
         result: {

src/tests/math.test.ts

@@ -0,0 +1,29 @@
+import { describe, expect, it } from "vitest";
+import { getPercentile } from "../utils/math";
+
+describe("getPercentile", () => {
+  it("should correctly calculate the p50 (median) of a sorted array", () => {
+    const numbers = [1, 2, 3, 4, 5, 6, 7, 8, 9, 10];
+    expect(getPercentile(numbers, 50)).toBe(5);
+  });
+
+  it("should correctly calculate the p90 of a sorted array", () => {
+    const numbers = [1, 2, 3, 4, 5, 6, 7, 8, 9, 10];
+    expect(getPercentile(numbers, 90)).toBe(9);
+  });
+
+  it("should handle arrays with even number of elements", () => {
+    const numbers = [10, 20, 30, 40, 50, 60, 70, 80];
+    expect(getPercentile(numbers, 50)).toBe(40);
+  });
+
+  it("should handle single element array", () => {
+    const numbers = [1];
+    expect(getPercentile(numbers, 50)).toBe(1);
+  });
+
+  it("should handle empty array", () => {
+    const numbers: number[] = [];
+    expect(getPercentile(numbers, 50)).toBe(0);
+  });
+});

src/utils/math.ts

@@ -0,0 +1,9 @@
+export const getPercentile = (arr: number[], percentile: number): number => {
+  if (arr.length === 0) {
+    return 0;
+  }
+
+  arr.sort((a, b) => a - b);
+  const index = Math.floor((percentile / 100) * (arr.length - 1));
+  return arr[index];
+};