From b6b96184ef6a61d7381a87a9b9b464c12bf25b42 Mon Sep 17 00:00:00 2001
From: Suyesh Shankar <suyesh@gmail.com>
Date: Thu, 18 Apr 2024 11:06:00 +0530
Subject: [PATCH] removed ztsd

---
 src/app/lib/mongoBreeze.ts | 41 ++++++++++++++++++++++++++++++++++++++
 src/hooks/useSocketMobx.ts |  2 ++
 2 files changed, 43 insertions(+)
 create mode 100644 src/app/lib/mongoBreeze.ts

diff --git a/src/app/lib/mongoBreeze.ts b/src/app/lib/mongoBreeze.ts
new file mode 100644
index 0000000..fc2db6c
--- /dev/null
+++ b/src/app/lib/mongoBreeze.ts
@@ -0,0 +1,41 @@
+import { MongoClient } from 'mongodb';
+import {  ChartData } from '../utils/dataAggregation';
+
+export async function fetchHistoricalData(specificStrikePrice: number, startDate: Date, endDate: Date) {
+    const uri = "mongodb://127.0.0.1:27017/";
+
+    //const uri = "mongodb://ns3151328.ip-151-106-34.eu:27017/";
+    const client = new MongoClient(uri);
+    
+    try {
+        console.log("Connecting to MongoDB");
+        await client.connect();
+        console.log("Connected correctly to server");
+        const db = client.db('tradepod');
+
+        // Define the query object with your criteria
+        const query = {
+            strikePrice: specificStrikePrice,
+            date: {
+                $gte: startDate,
+                $lte: endDate
+            }
+        };
+        
+        console.log("Query object:", query);
+
+        // Use the query object in the find method
+        const chartRecords: ChartData[] = (await db.collection('historicalDataBreeze').find(query).toArray()).map(doc => ({
+            date: doc.datetime,
+            openInterest: doc.open_interest,
+            strikePrice: doc.strike_price,
+            ltp: doc.close,
+            optionType: doc.right,
+            
+        }));
+        console.log("Chart Records",chartRecords)
+        return chartRecords;
+    } finally {
+        client.close();
+    }
+}
\ No newline at end of file
diff --git a/src/hooks/useSocketMobx.ts b/src/hooks/useSocketMobx.ts
index 928074e..00206fc 100644
--- a/src/hooks/useSocketMobx.ts
+++ b/src/hooks/useSocketMobx.ts
@@ -11,6 +11,8 @@ export const useWebSocketMobX = () => {
   const socket = useRef<WebSocket | null>(null);
   const accumulatedData = useRef<OptionData[]>([]);
   const url = 'ws://tradepodsocket-vzpocpxkaa-uc.a.run.app/tradepod';
+  //const url = 'ws://127.0.0.1:8888/tradepod';
+
 
   const connectWebSocket = useCallback(() => {
     // Close existing socket connection if any