testing engine

Praashh · Oct 22, 2024 · c8fa5a0 · c8fa5a0
1 parent 65b0ca9
commit c8fa5a0
Show file tree

Hide file tree

Showing 5 changed files with 29 additions and 9 deletions.
diff --git a/apps/server/src/controllers/order/index.ts b/apps/server/src/controllers/order/index.ts
@@ -15,10 +15,11 @@ type TPlaceOrder = {
 };
 export const placeHandler = AsyncWrapper(
   async (req: Request<{}, {}, TPlaceOrder>, res) => {
-    const { event_id, l1_expected_price, l1_order_quantity, offer_type } =
-      req.body;
-    let orderId = generateOrderId();
+    const { event_id, l1_expected_price, l1_order_quantity, offer_type } = req.body;
 
+    const orderId = generateOrderId();
+    console.log(orderId);
+
     const order = {
       [orderId]: {
         event_id: event_id,
@@ -28,7 +29,7 @@ export const placeHandler = AsyncWrapper(
       },
     };
     await addToOrderQueue(order);
-    redisClient.publishMessage("123", order);
+    redisClient.publishMessage(orderId, order);
     let response = new SuccessResponse("Order placed successfully", 201);
     return res.status(201).json(response);
   }

diff --git a/packages/order-queue/src/classes/RedisManager.ts b/packages/order-queue/src/classes/RedisManager.ts
@@ -7,6 +7,7 @@ export class RedisManager {
 
   constructor() {
     this.client = createClient();
+    console.log("Redis connected log inside Redis Manager")
     this.client.connect();
   }
 

diff --git a/packages/zod/src/index.ts b/packages/zod/src/index.ts
@@ -9,7 +9,7 @@ export const userZodSchema = z.object({
 export const intiateOrderZodSchema = z.object({
   event_id: z.number(),
   l1_expected_price: z.number().min(0.1, {
-    message: "Order quantity must be a positive integer",
+    message: "Order price must be a positive integer",
   }),
   l1_order_quantity: z.number().min(0.1, {
     message: "Order quantity must be a positive integer",

diff --git a/services/engine/logs/server.log b/services/engine/logs/server.log
@@ -21,3 +21,21 @@
 [ 2024-10-20 22:50:18 ] -  [32minfo[39m -  WORKER | Starting order worker
 [ 2024-10-20 23:47:55 ] -  [32minfo[39m -  WORKER | Starting order worker
 [ 2024-10-20 23:52:25 ] -  [32minfo[39m -  WORKER | Starting order worker
+[ 2024-10-22 11:00:20 ] -  [32minfo[39m -  WORKER | Starting order worker
+[ 2024-10-22 11:00:53 ] -  [32minfo[39m -  WORKER | Starting order worker
+[ 2024-10-22 11:02:50 ] -  [32minfo[39m -  WORKER | Starting order worker
+[ 2024-10-22 13:10:53 ] -  [32minfo[39m -  WORKER | Starting order worker
+[ 2024-10-22 13:11:49 ] -  [32minfo[39m -  WORKER | Starting order worker
+[ 2024-10-22 13:13:59 ] -  [32minfo[39m -  WORKER | Starting order worker
+[ 2024-10-22 13:14:16 ] -  [32minfo[39m -  WORKER | Starting order worker
+[ 2024-10-22 13:30:29 ] -  [32minfo[39m -  WORKER | Starting order worker
+[ 2024-10-22 13:38:17 ] -  [32minfo[39m -  WORKER | Starting order worker
+[ 2024-10-22 13:39:42 ] -  [32minfo[39m -  WORKER | Starting order worker
+[ 2024-10-22 13:40:03 ] -  [32minfo[39m -  WORKER | Starting order worker
+[ 2024-10-22 13:40:17 ] -  [32minfo[39m -  WORKER | Starting order worker
+[ 2024-10-22 13:40:30 ] -  [32minfo[39m -  WORKER | Starting order worker
+[ 2024-10-22 16:06:21 ] -  [32minfo[39m -  WORKER | Starting order worker
+[ 2024-10-22 23:26:09 ] -  [32minfo[39m -  WORKER | Starting order worker
+[ 2024-10-22 23:28:24 ] -  [32minfo[39m -  WORKER | Starting order worker
+[ 2024-10-22 23:28:41 ] -  [32minfo[39m -  WORKER | Starting order worker
+[ 2024-10-22 23:39:45 ] -  [32minfo[39m -  WORKER | Starting order worker
diff --git a/services/engine/src/index.ts b/services/engine/src/index.ts
@@ -8,19 +8,19 @@
  6. Test Cases
 */
 
-import { createClient } from "@repo/order-queue";
+import { RedisManager } from "@repo/order-queue";
 import { Engine } from "./trade/Engine";
 import {Orderbook} from "./trade/Orderbook"
 
 
 async function main() {
     const engine = new Engine(); 
-    const redisClient = createClient();
-    await redisClient.connect();
+    const redis = new RedisManager();
+    const redisClient = redis.getClient();
     console.log("connected to redis");
 
     while (true) {
-        const response = await redisClient.rPop("messages" as string)
+        const response = await redisClient.lPop("ORDER_QUEUE")
         if (!response) {
 
         }  else {