Spaces:
Sleeping
Sleeping
Update app.py
Browse files
app.py
CHANGED
|
@@ -1,65 +1,79 @@
|
|
| 1 |
-
import gradio as gr
|
| 2 |
-
import cv2
|
| 3 |
import os
|
| 4 |
import random
|
| 5 |
-
import
|
|
|
|
| 6 |
from services.video_service import get_random_video_frame
|
| 7 |
-
from services.metrics_service import update_metrics
|
| 8 |
from services.overlay_service import overlay_boxes
|
|
|
|
|
|
|
| 9 |
|
| 10 |
-
#
|
| 11 |
TEMP_IMAGE_PATH = "temp_frame.jpg"
|
| 12 |
-
VIDEO_FOLDER = "data/sample_videos"
|
| 13 |
-
|
| 14 |
-
# State Variables
|
| 15 |
paused = False
|
| 16 |
-
frame_rate = 1 # Default
|
|
|
|
|
|
|
|
|
|
| 17 |
|
| 18 |
-
# Helper Functions
|
| 19 |
def monitor_feed():
|
| 20 |
global paused
|
|
|
|
|
|
|
|
|
|
|
|
|
| 21 |
frame = get_random_video_frame()
|
|
|
|
| 22 |
if frame is None:
|
| 23 |
-
return
|
| 24 |
-
if not paused:
|
| 25 |
-
frame = overlay_boxes(frame)
|
| 26 |
-
cv2.imwrite(TEMP_IMAGE_PATH, frame)
|
| 27 |
-
return TEMP_IMAGE_PATH, update_metrics()
|
| 28 |
|
| 29 |
-
|
| 30 |
-
|
| 31 |
-
|
|
|
|
| 32 |
|
| 33 |
-
|
| 34 |
-
|
| 35 |
-
|
| 36 |
|
| 37 |
def loop_monitor():
|
| 38 |
while True:
|
| 39 |
-
time.sleep(1 / frame_rate if frame_rate > 0 else 1)
|
| 40 |
yield monitor_feed()
|
| 41 |
|
| 42 |
-
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 43 |
def build_interface():
|
| 44 |
-
with gr.Blocks() as app:
|
|
|
|
|
|
|
| 45 |
with gr.Row():
|
| 46 |
-
|
| 47 |
-
|
| 48 |
-
with gr.Column():
|
| 49 |
-
metrics_output = gr.Label(label="Live Metrics")
|
| 50 |
|
| 51 |
with gr.Row():
|
| 52 |
-
|
| 53 |
-
|
|
|
|
|
|
|
|
|
|
| 54 |
|
| 55 |
-
pause_button.click(
|
| 56 |
-
|
|
|
|
| 57 |
|
| 58 |
-
app.load(
|
| 59 |
|
| 60 |
return app
|
| 61 |
|
| 62 |
-
# Launch
|
| 63 |
if __name__ == "__main__":
|
| 64 |
demo = build_interface()
|
| 65 |
-
demo.
|
|
|
|
|
|
|
|
|
|
| 1 |
import os
|
| 2 |
import random
|
| 3 |
+
import cv2
|
| 4 |
+
import gradio as gr
|
| 5 |
from services.video_service import get_random_video_frame
|
|
|
|
| 6 |
from services.overlay_service import overlay_boxes
|
| 7 |
+
from services.thermal_service import detect_thermal_anomalies
|
| 8 |
+
from services.metrics_service import update_metrics, get_metrics_text
|
| 9 |
|
| 10 |
+
# Global Configurations
|
| 11 |
TEMP_IMAGE_PATH = "temp_frame.jpg"
|
|
|
|
|
|
|
|
|
|
| 12 |
paused = False
|
| 13 |
+
frame_rate = 1 # Default frames per second
|
| 14 |
+
|
| 15 |
+
# Gradio state variables
|
| 16 |
+
global_frame_rate = frame_rate
|
| 17 |
|
|
|
|
| 18 |
def monitor_feed():
|
| 19 |
global paused
|
| 20 |
+
|
| 21 |
+
if paused:
|
| 22 |
+
return TEMP_IMAGE_PATH, get_metrics_text()
|
| 23 |
+
|
| 24 |
frame = get_random_video_frame()
|
| 25 |
+
|
| 26 |
if frame is None:
|
| 27 |
+
return TEMP_IMAGE_PATH, get_metrics_text()
|
|
|
|
|
|
|
|
|
|
|
|
|
| 28 |
|
| 29 |
+
detected_boxes = detect_thermal_anomalies(frame)
|
| 30 |
+
frame = overlay_boxes(frame, detected_boxes)
|
| 31 |
+
|
| 32 |
+
update_metrics(detected=bool(detected_boxes), anomaly_name="Anomaly")
|
| 33 |
|
| 34 |
+
cv2.imwrite(TEMP_IMAGE_PATH, frame)
|
| 35 |
+
|
| 36 |
+
return TEMP_IMAGE_PATH, get_metrics_text()
|
| 37 |
|
| 38 |
def loop_monitor():
|
| 39 |
while True:
|
|
|
|
| 40 |
yield monitor_feed()
|
| 41 |
|
| 42 |
+
def pause_stream():
|
| 43 |
+
global paused
|
| 44 |
+
paused = True
|
| 45 |
+
|
| 46 |
+
def resume_stream():
|
| 47 |
+
global paused
|
| 48 |
+
paused = False
|
| 49 |
+
|
| 50 |
+
def update_frame_rate(new_rate):
|
| 51 |
+
global global_frame_rate
|
| 52 |
+
global_frame_rate = int(new_rate)
|
| 53 |
+
|
| 54 |
def build_interface():
|
| 55 |
+
with gr.Blocks(title="Solar Surveillance Thermal Detection") as app:
|
| 56 |
+
gr.Markdown("# ✨ Solar Surveillance Thermal Anomaly Detection")
|
| 57 |
+
|
| 58 |
with gr.Row():
|
| 59 |
+
video_output = gr.Image(label="Video Feed", elem_id="video-feed")
|
| 60 |
+
metrics_output = gr.Textbox(label="Live Metrics", elem_id="metrics-box")
|
|
|
|
|
|
|
| 61 |
|
| 62 |
with gr.Row():
|
| 63 |
+
with gr.Column():
|
| 64 |
+
pause_button = gr.Button("Pause")
|
| 65 |
+
resume_button = gr.Button("Resume")
|
| 66 |
+
with gr.Column():
|
| 67 |
+
frame_rate_slider = gr.Slider(1, 10, step=1, value=global_frame_rate, label="Frame Rate (fps)")
|
| 68 |
|
| 69 |
+
pause_button.click(pause_stream)
|
| 70 |
+
resume_button.click(resume_stream)
|
| 71 |
+
frame_rate_slider.change(update_frame_rate, inputs=[frame_rate_slider])
|
| 72 |
|
| 73 |
+
app.load(loop_monitor, outputs=[video_output, metrics_output])
|
| 74 |
|
| 75 |
return app
|
| 76 |
|
|
|
|
| 77 |
if __name__ == "__main__":
|
| 78 |
demo = build_interface()
|
| 79 |
+
demo.launch(server_name="0.0.0.0", server_port=7860)
|