From b173e70ae7f54e81cb84a9d3f4ef106789abd98d Mon Sep 17 00:00:00 2001
From: Yutang Li <yt.li2@siat.ac.cn>
Date: Mon, 24 Feb 2025 15:28:57 +0800
Subject: [PATCH] 123

---
 .gitignore      |  2 +-
 _backend/api.py | 41 -----------------------------------------
 2 files changed, 1 insertion(+), 42 deletions(-)

diff --git a/.gitignore b/.gitignore
index 6a99ccf..d92d709 100755
--- a/.gitignore
+++ b/.gitignore
@@ -1,7 +1,7 @@
 # ---> Python
 
 _backend/evaluate/eval_rag_dataset/*
-
+_backend/history/*
 # Byte-compiled / optimized / DLL files
 __pycache__/
 *.py[cod]
diff --git a/_backend/api.py b/_backend/api.py
index 6ed987d..138b318 100644
--- a/_backend/api.py
+++ b/_backend/api.py
@@ -266,52 +266,11 @@ async def chat(websocket: WebSocket):
 
 
 
-# 设置缓冲区大小
-BUFFER_SIZE = 10
-frame_buffer = deque(maxlen=BUFFER_SIZE)
 RTSP_STREAMS = {
     "camera1": "rtsp://admin:@192.168.1.13:554/live",
     "camera2": "rtsp://admin:@192.168.1.10:554/live",
 }
 
-# @app.websocket("/video_stream/{camera_id}")
-# async def websocket_endpoint(websocket: WebSocket, camera_id: str):
-#     await websocket.accept()
-#     cap = cv2.VideoCapture(RTSP_STREAMS[camera_id])
-#     fps = 15
-#     cap.set(cv2.CAP_PROP_FPS, 15) 
-#     frame_interval = 1 / fps if fps > 0 else 0.1  # 计算帧间隔时间
-
-#     async def capture_frames():
-#         while True:
-#             ret, frame = cap.read()
-#             if not ret:
-#                 break
-#             _, buffer = cv2.imencode('.jpg', frame)
-#             jpeg_frame = base64.b64encode(buffer).decode('utf-8')
-#             frame_buffer.append(jpeg_frame)
-#             await asyncio.sleep(frame_interval)
-
-#     async def send_frames():
-#         while True:
-#             if frame_buffer:
-#                 frame = frame_buffer.popleft()
-#                 await websocket.send_text(frame)
-#             await asyncio.sleep(frame_interval)
-
-#     # 启动帧捕获和发送任务
-#     capture_task = asyncio.create_task(capture_frames())
-#     send_task = asyncio.create_task(send_frames())
-
-#     try:
-#         await asyncio.gather(capture_task, send_task)
-#     except asyncio.CancelledError:
-#         pass
-#     finally:
-#         cap.release()
-
-frame_buffer = deque()
-
 @app.websocket("/video_stream/{camera_id}")
 async def websocket_endpoint(websocket: WebSocket, camera_id: str):
     await websocket.accept()