From d44cb584169928bb370353bd35285ff8da1ec2b6 Mon Sep 17 00:00:00 2001 From: dsutanto Date: Wed, 29 Jul 2026 16:22:58 +0700 Subject: [PATCH] Reset delete live stream jpg as well --- .oc/session.json | 232 +++++++++++++++++++++++++++++++++++++++++++++-- src/main.cpp | 1 + 2 files changed, 227 insertions(+), 6 deletions(-) diff --git a/.oc/session.json b/.oc/session.json index e049c63..ee821e2 100644 --- a/.oc/session.json +++ b/.oc/session.json @@ -17,19 +17,19 @@ "deletions": 0, "files": 0 }, - "cost": 0.21404607100000003, + "cost": 0.21538775600000004, "tokens": { - "input": 229295, - "output": 36279, - "reasoning": 29904, + "input": 229544, + "output": 36551, + "reasoning": 29935, "cache": { - "read": 15647872, + "read": 15915392, "write": 0 } }, "time": { "created": 1783419130384, - "updated": 1785316263302 + "updated": 1785316898896 } }, "messages": [ @@ -21722,6 +21722,226 @@ "messageID": "msg_fad2435550018wohdUwDYyc0GF" } ] + }, + { + "info": { + "role": "user", + "time": { + "created": 1785316887324 + }, + "agent": "build", + "model": { + "providerID": "deepseek", + "modelID": "deepseek-v4-pro" + }, + "summary": { + "diffs": [ + { + "file": "src/main.cpp", + "patch": "Index: src/main.cpp\n===================================================================\n--- src/main.cpp\t\n+++ src/main.cpp\t\n@@ -1,582 +1,583 @@\n #include \"config.hpp\"\n #include \"bytetrack.hpp\"\n #include \"batch_store.hpp\"\n #include \"csv_logger.hpp\"\n #include \"rknn_yolo.hpp\"\n #include \"drawing.hpp\"\n #include \"nms.hpp\"\n #include \"version.hpp\"\n #include \"video_writer.hpp\"\n \n #include \n #include \n #include \n #include \n #include \n #include \n #include \n #include \n #include \n #include \n #include \n \n static std::atomic shutdown_requested{false};\n \n static void signal_handler(int) {\n shutdown_requested = true;\n std::cout << \"\\nShutdown requested — finishing current frame...\" << std::endl;\n }\n \n static std::string now_str() {\n auto now = std::chrono::system_clock::now();\n auto t = std::chrono::system_clock::to_time_t(now);\n std::ostringstream ss;\n ss << std::put_time(std::localtime(&t), \"%Y-%m-%d %H:%M:%S\");\n return ss.str();\n }\n \n static cv::VideoCapture open_capture(const std::string& source) {\n bool is_live = source.substr(0, 7) == \"rtsp://\" || source.substr(0, 7) == \"http://\";\n if (is_live) {\n setenv(\"OPENCV_FFMPEG_CAPTURE_OPTIONS\", g_config.rtsp_ffmpeg_options.c_str(), 1);\n }\n cv::VideoCapture cap(source, cv::CAP_FFMPEG);\n cap.set(cv::CAP_PROP_BUFFERSIZE, 1);\n return cap;\n }\n \n static void warmup_stream(cv::VideoCapture& cap, int n) {\n std::cout << \"Warming up stream...\" << std::endl;\n cv::Mat frame;\n for (int i = 0; i < n; ++i) cap.read(frame);\n std::cout << \"Stream ready!\" << std::endl;\n }\n \n static bool connect_stream(cv::VideoCapture& cap, int& w, int& h, double& fps) {\n bool is_live = g_config.source.substr(0, 7) == \"rtsp://\" ||\n g_config.source.substr(0, 7) == \"http://\";\n int attempts = 0;\n while (!shutdown_requested) {\n cap = open_capture(g_config.source);\n if (cap.isOpened()) break;\n attempts++;\n if (g_config.max_reconnect_attempts > 0 && attempts >= g_config.max_reconnect_attempts) {\n std::cerr << \"Cannot open source after \" << attempts\n << \" attempts: \" << g_config.source << std::endl;\n return false;\n }\n std::cout << \"Cannot open source, retry in \" << g_config.reconnect_delay_sec\n << \"s...\" << std::endl;\n std::this_thread::sleep_for(std::chrono::seconds(g_config.reconnect_delay_sec));\n }\n if (shutdown_requested) return false;\n \n if (is_live && g_config.warmup_frames > 0)\n warmup_stream(cap, g_config.warmup_frames);\n \n w = static_cast(cap.get(cv::CAP_PROP_FRAME_WIDTH));\n h = static_cast(cap.get(cv::CAP_PROP_FRAME_HEIGHT));\n fps = cap.get(cv::CAP_PROP_FPS);\n if (fps <= 1) fps = g_config.output_fps;\n return true;\n }\n \n struct TrackedInfo {\n float cx;\n std::chrono::steady_clock::time_point ts;\n };\n \n static void prune_stale_tracks(std::unordered_map& tracked, double prune_sec) {\n auto now = std::chrono::steady_clock::now();\n std::vector stale;\n for (auto& [tid, info] : tracked) {\n auto age = std::chrono::duration_cast(now - info.ts).count();\n if (age > prune_sec) stale.push_back(tid);\n }\n for (int tid : stale) tracked.erase(tid);\n }\n \n int main(int argc, char* argv[]) {\n signal(SIGINT, signal_handler);\n signal(SIGTERM, signal_handler);\n \n if (argc < 2) {\n std::cout << \"ByteTrack Counter (C++)\" << std::endl;\n std::cout << \"Version: \" << version::GIT_COMMIT\n << \" | branch: \" << version::GIT_BRANCH\n << \" | built: \" << version::BUILD_DATE << \" \" << version::BUILD_TIME\n << \" | rknn: \" << (version::BUILD_RKNN ? \"ON\" : \"OFF\");\n if (!version::GIT_TAG.empty())\n std::cout << \" | tag: \" << version::GIT_TAG;\n std::cout << std::endl;\n std::cout << \"Usage: bytetrack-counter \" << std::endl;\n std::cout << \" config.env path to environment configuration file (required)\" << std::endl;\n return 1;\n }\n \n g_config.load_from_env(argv[1]);\n \n std::cout << \"Starting ByteTrack Counter (C++)\" << std::endl;\n std::cout << \"Version: \" << version::GIT_COMMIT\n << \" | branch: \" << version::GIT_BRANCH\n << \" | built: \" << version::BUILD_DATE << \" \" << version::BUILD_TIME\n << \" | rknn: \" << (version::BUILD_RKNN ? \"ON\" : \"OFF\");\n if (!version::GIT_TAG.empty())\n std::cout << \" | tag: \" << version::GIT_TAG;\n std::cout << std::endl;\n std::cout << \"Camera: \" << g_config.camera_name << std::endl;\n std::cout << \"Source: \" << g_config.source << std::endl;\n std::cout << \"Model: \" << g_config.model_path << \" | imgsz=\" << g_config.imgsz\n << \" | core_mask=\" << g_config.core_mask << std::endl;\n std::cout << \"DB: \" << g_config.db_path << std::endl;\n std::cout << \"State: \" << g_config.state_file << std::endl;\n std::cout << \"ByteTrack Index 0: high_thresh=\" << g_config.track_high_thresh_0\n << \" low_thresh=\" << g_config.track_low_thresh_0\n << \" match_thresh=\" << g_config.track_match_thresh_0\n << \" buffer=\" << g_config.track_buffer_0\n << \" min_hits=\" << g_config.track_min_hits_0 << std::endl;\n std::cout << \"ByteTrack Index 1: high_thresh=\" << g_config.track_high_thresh_1\n << \" low_thresh=\" << g_config.track_low_thresh_1\n << \" match_thresh=\" << g_config.track_match_thresh_1\n << \" buffer=\" << g_config.track_buffer_1\n << \" min_hits=\" << g_config.track_min_hits_1 << std::endl;\n \n {\n std::string reset_file = g_config.shm_dir + \"/.reset\";\n if (std::filesystem::exists(reset_file)) {\n std::cout << \"[RESET] .reset detected — clearing state\" << std::endl;\n std::error_code ec;\n std::filesystem::remove(g_config.state_file, ec);\n+ std::filesystem::remove(g_config.live_stream_frame_path, ec);\n std::filesystem::remove(reset_file, ec);\n }\n }\n \n if (g_config.live_stream_enabled) {\n std::filesystem::path live_p(g_config.live_stream_frame_path);\n if (live_p.has_parent_path())\n std::filesystem::create_directories(live_p.parent_path());\n }\n \n int class_ayam = g_config.ayam_class_id;\n int class_talenan = g_config.talenan_class_id;\n \n auto logger = [](const std::string& msg) {\n std::cout << \"[\" << now_str() << \"] \" << msg << std::endl;\n };\n \n BatchStore store(g_config.db_path, g_config.state_file,\n g_config.camera_name, g_config.object_label,\n g_config.daily_cutoff_time,\n g_config.batch_timeout_seconds,\n g_config.ignore_batch_label_timeout,\n g_config.min_object_per_batch,\n g_config.min_duration_per_batch,\n logger);\n store.start_cutoff_watcher();\n \n std::unique_ptr cross_logger;\n if (g_config.export_csv) {\n cross_logger = std::make_unique(g_config.cross_csv,\n std::vector{\"batch\", \"frame\", \"timestamp\", \"chicken_id\"});\n }\n \n RKNNYOLO model(g_config.model_path, g_config.core_mask,\n g_config.imgsz, g_config.conf, 0.45f,\n g_config.num_classes, 0, g_config.score_sigmoid);\n if (!model.is_loaded()) {\n std::cerr << \"ERROR: Failed to load model: \" << g_config.model_path\n << std::endl;\n return 1;\n }\n \n ByteTracker ayam_tracker(g_config.track_high_thresh_0, g_config.track_low_thresh_0,\n g_config.track_match_thresh_0, g_config.track_buffer_0,\n g_config.track_min_hits_0);\n ByteTracker talenan_tracker(g_config.track_high_thresh_1, g_config.track_low_thresh_1,\n g_config.track_match_thresh_1, g_config.track_buffer_1,\n g_config.track_min_hits_1);\n \n std::unordered_set ayam_line_crossed;\n std::unordered_set talenan_line_crossed;\n \n std::unordered_map ayam_cross_flash;\n std::unordered_map talenan_cross_flash;\n int line_pulse = 0, count_pulse = 0, batch_pulse = 0;\n std::vector popups;\n std::deque crossing_times;\n \n auto session_start = std::chrono::steady_clock::now();\n int frame_idx = 0;\n float inf_ema = 0.0f;\n \n std::string model_name = g_config.model_path;\n auto slash = model_name.find_last_of(\"/\\\\\");\n if (slash != std::string::npos) model_name = model_name.substr(slash + 1);\n \n cv::VideoCapture cap;\n int w, h;\n double fps_prop;\n \n if (!connect_stream(cap, w, h, fps_prop)) {\n store.shutdown();\n return shutdown_requested ? 0 : 1;\n }\n bool is_live = g_config.source.substr(0, 7) == \"rtsp://\" ||\n g_config.source.substr(0, 7) == \"http://\";\n \n int line_x = resolve_line_x(w, g_config.line_x, g_config.line_x_frac);\n \n std::cout << \"RKNN+ByteTrack counter | \" << w << \"x\" << h << \" @ \"\n << fps_prop << \"fps | line x=\" << line_x\n << \" | cross=\" << g_config.cross_direction << std::endl;\n \n std::unique_ptr video_writer;\n if (g_config.record_video) {\n video_writer = std::make_unique(\n g_config.shm_dir, g_config.output_dir,\n w, h, static_cast(fps_prop),\n g_config.record_delay_seconds,\n g_config.record_end_delay_seconds,\n g_config.record_retention_days);\n auto* vw = video_writer.get();\n store.set_batch_closed_callback([vw](int bn) { vw->on_batch_closed(bn); });\n }\n \n int reconnect_count = 0;\n \n std::unordered_map ayam_tracked;\n std::unordered_map talenan_tracked;\n cv::Mat prev_gray;\n \n while (!shutdown_requested) {\n cv::Mat frame;\n cap >> frame;\n if (frame.empty()) {\n if (!is_live) break;\n reconnect_count++;\n std::cout << \"Stream dropped (attempt \" << reconnect_count\n << \"), reconnecting...\" << std::endl;\n cap.release();\n std::this_thread::sleep_for(std::chrono::seconds(g_config.reconnect_delay_sec));\n if (!connect_stream(cap, w, h, fps_prop)) break;\n line_x = resolve_line_x(w, g_config.line_x, g_config.line_x_frac);\n continue;\n }\n \n auto elapsed_sec = std::chrono::duration(\n std::chrono::steady_clock::now() - session_start).count();\n auto mono = std::chrono::steady_clock::now();\n \n if (store.check_cutoff_reset()) {\n if (g_config.reset_counters_at_cutoff) {\n std::cout << \"[\" << now_str() << \"] Cutoff reset — resetting frame + tracker counters\" << std::endl;\n frame_idx = 0;\n KalmanBoxTracker::count = 0;\n ayam_tracker.reset();\n talenan_tracker.reset();\n ayam_tracked.clear();\n talenan_tracked.clear();\n ayam_line_crossed.clear();\n talenan_line_crossed.clear();\n ayam_cross_flash.clear();\n talenan_cross_flash.clear();\n crossing_times.clear();\n line_pulse = 0;\n count_pulse = 0;\n batch_pulse = 0;\n }\n if (video_writer) video_writer->cleanup_retention();\n }\n \n bool ayam_crossed_frame = false, batch_closed_frame = false, batch_started_frame = false;\n \n bool skip_inference = false;\n if (g_config.motion_detection_enabled) {\n cv::Mat gray;\n cv::cvtColor(frame, gray, cv::COLOR_BGR2GRAY);\n if (!prev_gray.empty()) {\n cv::Mat diff;\n cv::absdiff(gray, prev_gray, diff);\n double mean_diff = cv::mean(diff)[0];\n skip_inference = (mean_diff < g_config.motion_threshold);\n }\n prev_gray = gray;\n if (!skip_inference && video_writer) video_writer->note_motion();\n } else {\n if (video_writer) video_writer->note_motion();\n }\n \n std::vector detections;\n float inf_ms = 0.0f;\n if (!skip_inference) {\n auto inf_start = std::chrono::steady_clock::now();\n detections = model(frame);\n inf_ms = std::chrono::duration(\n std::chrono::steady_clock::now() - inf_start).count();\n }\n inf_ema = inf_ema * 0.9f + inf_ms * 0.1f;\n \n if (!detections.empty()) {\n std::vector ayam_boxes, talenan_boxes;\n std::vector ayam_scores, talenan_scores;\n std::vector ayam_cx_list, talenan_cx_list;\n std::vector>> ayam_kpts_list;\n \n for (const auto& det : detections) {\n const auto& bbox = det.bbox;\n float cx = (bbox(0) + bbox(2)) / 2.0f;\n \n if (det.cls == class_talenan) {\n talenan_boxes.push_back(bbox);\n talenan_scores.push_back(det.score);\n talenan_cx_list.push_back(cx);\n } else if (det.cls == class_ayam) {\n ayam_boxes.push_back(bbox);\n ayam_scores.push_back(det.score);\n ayam_cx_list.push_back(cx);\n ayam_kpts_list.push_back(det.keypoints);\n }\n }\n \n int na = static_cast(ayam_boxes.size());\n int nt = static_cast(talenan_boxes.size());\n \n if (na > 0) store.ping_activity();\n \n Eigen::MatrixXf ayam_mat(na, 4), talenan_mat(nt, 4);\n Eigen::VectorXf ayam_scores_vec(na), talenan_scores_vec(nt);\n \n for (int i = 0; i < na; ++i) {\n ayam_mat.row(i) = ayam_boxes[i];\n ayam_scores_vec(i) = ayam_scores[i];\n }\n for (int i = 0; i < nt; ++i) {\n talenan_mat.row(i) = talenan_boxes[i];\n talenan_scores_vec(i) = talenan_scores[i];\n }\n \n // Apply NMS per-class to suppress duplicate boxes\n if (na > 0) {\n if (video_writer) video_writer->note_ayam_detection();\n auto keep = nms(ayam_mat, ayam_scores_vec);\n int nk = static_cast(keep.size());\n Eigen::MatrixXf fm(nk, 4);\n Eigen::VectorXf fs(nk);\n std::vector fb;\n std::vector fcx;\n std::vector>> fkpts;\n for (int ki = 0; ki < nk; ++ki) {\n int idx = keep[ki];\n fm.row(ki) = ayam_mat.row(idx);\n fs(ki) = ayam_scores_vec(idx);\n fb.push_back(ayam_boxes[idx]);\n fcx.push_back(ayam_cx_list[idx]);\n if (idx < (int)ayam_kpts_list.size())\n fkpts.push_back(ayam_kpts_list[idx]);\n }\n na = nk;\n ayam_mat = std::move(fm);\n ayam_scores_vec = std::move(fs);\n ayam_boxes = std::move(fb);\n ayam_cx_list = std::move(fcx);\n ayam_kpts_list = std::move(fkpts);\n }\n if (nt > 0) {\n auto keep = nms(talenan_mat, talenan_scores_vec);\n int nk = static_cast(keep.size());\n Eigen::MatrixXf fm(nk, 4);\n Eigen::VectorXf fs(nk);\n std::vector fb;\n std::vector fcx;\n for (int ki = 0; ki < nk; ++ki) {\n int idx = keep[ki];\n fm.row(ki) = talenan_mat.row(idx);\n fs(ki) = talenan_scores_vec(idx);\n fb.push_back(talenan_boxes[idx]);\n fcx.push_back(talenan_cx_list[idx]);\n }\n nt = nk;\n talenan_mat = std::move(fm);\n talenan_scores_vec = std::move(fs);\n talenan_boxes = std::move(fb);\n talenan_cx_list = std::move(fcx);\n }\n \n TrackResult ayam_tr = ayam_tracker.update(ayam_mat, ayam_scores_vec);\n TrackResult talenan_tr = talenan_tracker.update(talenan_mat, talenan_scores_vec);\n \n // Process talenan crossings\n for (int di = 0; di < nt; ++di) {\n auto it = talenan_tr.det_to_track.find(di);\n if (it == talenan_tr.det_to_track.end()) continue;\n int tid = it->second;\n float cx = talenan_cx_list[di];\n \n auto tit = talenan_tracked.find(tid);\n if (tit != talenan_tracked.end()) {\n float prev_cx = tit->second.cx;\n if (crossed_line(prev_cx, cx, line_x, g_config.cross_direction) &&\n talenan_line_crossed.find(tid) == talenan_line_crossed.end()) {\n talenan_line_crossed.insert(tid);\n if (store.record_talenan_crossing(tid, talenan_scores_vec(di))) {\n batch_closed_frame = true;\n talenan_cross_flash[tid] = g_config.cross_flash_frames;\n popups.push_back({\n static_cast(cx) - 20,\n static_cast((talenan_boxes[di](1) + talenan_boxes[di](3)) / 2),\n frame_idx, \"BATCH CLOSED\"\n });\n }\n }\n }\n talenan_tracked[tid] = {cx, mono};\n }\n \n // Process ayam crossings\n for (int di = 0; di < na; ++di) {\n auto it = ayam_tr.det_to_track.find(di);\n if (it == ayam_tr.det_to_track.end()) continue;\n int tid = it->second;\n float cx = ayam_cx_list[di];\n \n auto tit = ayam_tracked.find(tid);\n if (tit != ayam_tracked.end()) {\n float prev_cx = tit->second.cx;\n if (crossed_line(prev_cx, cx, line_x, g_config.cross_direction) &&\n ayam_line_crossed.find(tid) == ayam_line_crossed.end()) {\n ayam_line_crossed.insert(tid);\n auto [count, started_new] = store.record_ayam_crossing(tid);\n std::cout << \"[\" << now_str() << \"] Batch #\" << store.current_batch_number() << \" | count: \" << count << \" | conf: \" << ayam_scores_vec(di) << std::endl;\n if (cross_logger) {\n std::ostringstream frame_str, tid_str;\n frame_str << frame_idx;\n tid_str << tid;\n cross_logger->write_row({\n std::to_string(store.current_batch_number()),\n frame_str.str(),\n now_str(),\n tid_str.str()\n });\n }\n ayam_crossed_frame = true;\n if (started_new) batch_started_frame = true;\n crossing_times.push_back(mono);\n ayam_cross_flash[tid] = g_config.cross_flash_frames;\n popups.push_back({\n static_cast(cx) - 12,\n static_cast((ayam_boxes[di](1) + ayam_boxes[di](3)) / 2),\n frame_idx, \"+1\"\n });\n }\n }\n ayam_tracked[tid] = {cx, mono};\n }\n \n // Track lost tracks for continuity\n for (auto& [tid, cx] : ayam_tr.lost_map) {\n if (ayam_tracked.find(tid) == ayam_tracked.end())\n ayam_tracked[tid] = {cx, mono};\n }\n \n if (video_writer) video_writer->feed_frame(frame);\n \n // Draw talenan\n for (int di = 0; di < nt; ++di) {\n auto it = talenan_tr.det_to_track.find(di);\n if (it == talenan_tr.det_to_track.end()) continue;\n int tid = it->second;\n const auto& bbox = talenan_boxes[di];\n int x1 = static_cast(bbox(0)), y1 = static_cast(bbox(1));\n int x2 = static_cast(bbox(2)), y2 = static_cast(bbox(3));\n int flash = talenan_cross_flash.count(tid) ? talenan_cross_flash[tid] : 0;\n cv::Scalar color = flash > 0 ? C_GREEN : C_TALENAN_BOX;\n cv::rectangle(frame, cv::Point(x1, y1), cv::Point(x2, y2), color, flash > 0 ? 3 : 2);\n draw_pill(frame, \"TALENAN \" + std::to_string(tid), x1, y1 - 4, color);\n }\n \n // Draw ayam\n for (int di = 0; di < na; ++di) {\n auto it = ayam_tr.det_to_track.find(di);\n if (it == ayam_tr.det_to_track.end()) continue;\n int tid = it->second;\n const auto& bbox = ayam_boxes[di];\n int x1 = static_cast(bbox(0)), y1 = static_cast(bbox(1));\n int x2 = static_cast(bbox(2)), y2 = static_cast(bbox(3));\n int flash = ayam_cross_flash.count(tid) ? ayam_cross_flash[tid] : 0;\n cv::Scalar color = flash > 0 ? C_GREEN : C_AYAM_BOX;\n cv::rectangle(frame, cv::Point(x1, y1), cv::Point(x2, y2), color, flash > 0 ? 3 : 2);\n draw_pill(frame, \"ID \" + std::to_string(tid), x1, y1 - 4, color);\n if (di < (int)ayam_kpts_list.size() && !ayam_kpts_list[di].empty())\n draw_skeleton_bold(frame, ayam_kpts_list[di]);\n }\n }\n \n if (ayam_crossed_frame) {\n line_pulse = g_config.line_pulse_frames;\n count_pulse = g_config.count_pulse_frames;\n }\n if (batch_closed_frame) {\n line_pulse = g_config.line_pulse_frames;\n }\n if (batch_started_frame) {\n batch_pulse = g_config.batch_pulse_frames;\n }\n \n int batch_num = store.current_batch_number();\n int batch_count = store.current_batch_count();\n int display_total = store.display_total();\n \n while (!crossing_times.empty() &&\n std::chrono::duration(mono - crossing_times.front()).count() > g_config.rate_window_sec)\n crossing_times.pop_front();\n double rate = crossing_times.empty() ? 0.0 :\n (crossing_times.size() / static_cast(g_config.rate_window_sec) * 60.0);\n \n draw_elegant_counting_line(frame, line_x, h, line_pulse);\n draw_hero_count(frame, line_x, h, batch_count, count_pulse);\n draw_hud(frame, w, batch_num, batch_count, display_total,\n elapsed_sec, rate);\n draw_batch_banner(frame, w, batch_num, batch_pulse);\n draw_footer(frame, w, h, frame_idx, is_live ? \"LIVE\" : \"FILE\", inf_ema, model_name);\n popups = draw_popups(frame, popups, frame_idx);\n \n // Flash decay\n for (auto& flash_map : {&ayam_cross_flash, &talenan_cross_flash}) {\n for (auto it = flash_map->begin(); it != flash_map->end(); ) {\n it->second--;\n if (it->second <= 0) it = flash_map->erase(it);\n else ++it;\n }\n }\n line_pulse = std::max(0, line_pulse - 1);\n count_pulse = std::max(0, count_pulse - 1);\n batch_pulse = std::max(0, batch_pulse - 1);\n \n if (g_config.live_stream_enabled && frame_idx % g_config.live_stream_every_n == 0) {\n try {\n std::filesystem::path p(g_config.live_stream_frame_path);\n if (p.has_parent_path())\n std::filesystem::create_directories(p.parent_path());\n std::vector jpeg;\n cv::imencode(\".jpg\", frame, jpeg,\n {cv::IMWRITE_JPEG_QUALITY, g_config.live_stream_quality});\n std::ofstream f(g_config.live_stream_frame_path, std::ios::binary);\n f.write(reinterpret_cast(jpeg.data()), jpeg.size());\n } catch (...) {}\n }\n \n frame_idx++;\n \n prune_stale_tracks(ayam_tracked, g_config.tracked_prune_sec);\n prune_stale_tracks(talenan_tracked, g_config.tracked_prune_sec);\n }\n \n cap.release();\n if (video_writer) video_writer->shutdown();\n store.shutdown();\n \n std::cout << \"\\n=== Batch Summary (SQLite) ===\" << std::endl;\n std::cout << \"Database: \" << g_config.db_path << std::endl;\n \n return 0;\n }\n", + "additions": 1, + "deletions": 0, + "status": "modified" + } + ] + }, + "id": "msg_fad2dcb1c001pZ0fDpTdXPLYJX", + "sessionID": "ses_0c3efadf0ffeP4HreoRuvKX5h3" + }, + "parts": [ + { + "type": "text", + "text": "when reset detected also delete LIVE STREAM jpg frame", + "id": "prt_fad2dcb270013RKlE5Xbn89VR8", + "sessionID": "ses_0c3efadf0ffeP4HreoRuvKX5h3", + "messageID": "msg_fad2dcb1c001pZ0fDpTdXPLYJX" + } + ] + }, + { + "info": { + "parentID": "msg_fad2dcb1c001pZ0fDpTdXPLYJX", + "role": "assistant", + "mode": "build", + "agent": "build", + "path": { + "cwd": "/opt/bytetrack-counter-cpp", + "root": "/opt/bytetrack-counter-cpp" + }, + "cost": 0.000771081, + "tokens": { + "total": 134015, + "input": 107, + "output": 245, + "reasoning": 31, + "cache": { + "write": 0, + "read": 133632 + } + }, + "modelID": "deepseek-v4-pro", + "providerID": "deepseek", + "time": { + "created": 1785316887429, + "completed": 1785316895612 + }, + "finish": "tool-calls", + "id": "msg_fad2dcb85001X90c0q6YWT7252", + "sessionID": "ses_0c3efadf0ffeP4HreoRuvKX5h3" + }, + "parts": [ + { + "snapshot": "4606fb94c80d7184f2f3037d6623e6ff31c17ba8", + "type": "step-start", + "id": "prt_fad2ddc86001LrOha94a5rXMee", + "sessionID": "ses_0c3efadf0ffeP4HreoRuvKX5h3", + "messageID": "msg_fad2dcb85001X90c0q6YWT7252" + }, + { + "type": "reasoning", + "text": "The user wants the `.reset` file detection to also delete the live stream JPEG frame (from `LIVE_STREAM_FRAME_PATH` config).", + "time": { + "start": 1785316892475, + "end": 1785316893365 + }, + "id": "prt_fad2ddf3b001yCtS1XeRL5DQPQ", + "sessionID": "ses_0c3efadf0ffeP4HreoRuvKX5h3", + "messageID": "msg_fad2dcb85001X90c0q6YWT7252" + }, + { + "type": "tool", + "tool": "edit", + "callID": "call_00_qMffgVDwCzE9vJywHlrc9262", + "state": { + "status": "completed", + "input": { + "filePath": "/opt/bytetrack-counter-cpp/src/main.cpp", + "newString": " if (std::filesystem::exists(reset_file)) {\n std::cout << \"[RESET] .reset detected — clearing state\" << std::endl;\n std::error_code ec;\n std::filesystem::remove(g_config.state_file, ec);\n std::filesystem::remove(g_config.live_stream_frame_path, ec);\n std::filesystem::remove(reset_file, ec);\n }", + "oldString": " if (std::filesystem::exists(reset_file)) {\n std::cout << \"[RESET] .reset detected — clearing state\" << std::endl;\n std::error_code ec;\n std::filesystem::remove(g_config.state_file, ec);\n std::filesystem::remove(reset_file, ec);\n }" + }, + "output": "Edit applied successfully.", + "metadata": { + "diagnostics": {}, + "diff": "Index: /opt/bytetrack-counter-cpp/src/main.cpp\n===================================================================\n--- /opt/bytetrack-counter-cpp/src/main.cpp\n+++ /opt/bytetrack-counter-cpp/src/main.cpp\n@@ -146,8 +146,9 @@\n if (std::filesystem::exists(reset_file)) {\n std::cout << \"[RESET] .reset detected — clearing state\" << std::endl;\n std::error_code ec;\n std::filesystem::remove(g_config.state_file, ec);\n+ std::filesystem::remove(g_config.live_stream_frame_path, ec);\n std::filesystem::remove(reset_file, ec);\n }\n }\n \n", + "filediff": { + "file": "/opt/bytetrack-counter-cpp/src/main.cpp", + "patch": "Index: /opt/bytetrack-counter-cpp/src/main.cpp\n===================================================================\n--- /opt/bytetrack-counter-cpp/src/main.cpp\n+++ /opt/bytetrack-counter-cpp/src/main.cpp\n@@ -146,8 +146,9 @@\n if (std::filesystem::exists(reset_file)) {\n std::cout << \"[RESET] .reset detected — clearing state\" << std::endl;\n std::error_code ec;\n std::filesystem::remove(g_config.state_file, ec);\n+ std::filesystem::remove(g_config.live_stream_frame_path, ec);\n std::filesystem::remove(reset_file, ec);\n }\n }\n \n", + "additions": 1, + "deletions": 0 + }, + "truncated": false + }, + "title": "src/main.cpp", + "time": { + "start": 1785316895193, + "end": 1785316895204 + } + }, + "id": "prt_fad2de2bc001oXtGSVn0eNp0Mr", + "sessionID": "ses_0c3efadf0ffeP4HreoRuvKX5h3", + "messageID": "msg_fad2dcb85001X90c0q6YWT7252" + }, + { + "reason": "tool-calls", + "snapshot": "7a603081d1ecf645fefa416e0364e0f3face7d8d", + "type": "step-finish", + "tokens": { + "total": 134015, + "input": 107, + "output": 245, + "reasoning": 31, + "cache": { + "write": 0, + "read": 133632 + } + }, + "cost": 0.000771081, + "id": "prt_fad2dead4001gaGahwPPiMfD5g", + "sessionID": "ses_0c3efadf0ffeP4HreoRuvKX5h3", + "messageID": "msg_fad2dcb85001X90c0q6YWT7252" + }, + { + "type": "patch", + "hash": "4606fb94c80d7184f2f3037d6623e6ff31c17ba8", + "files": [ + "/opt/bytetrack-counter-cpp/src/main.cpp" + ], + "id": "prt_fad2deb5c001FWOgzdx5vP1JJb", + "sessionID": "ses_0c3efadf0ffeP4HreoRuvKX5h3", + "messageID": "msg_fad2dcb85001X90c0q6YWT7252" + } + ] + }, + { + "info": { + "parentID": "msg_fad2dcb1c001pZ0fDpTdXPLYJX", + "role": "assistant", + "mode": "build", + "agent": "build", + "path": { + "cwd": "/opt/bytetrack-counter-cpp", + "root": "/opt/bytetrack-counter-cpp" + }, + "cost": 0.000570604, + "tokens": { + "total": 134057, + "input": 142, + "output": 27, + "reasoning": 0, + "cache": { + "write": 0, + "read": 133888 + } + }, + "modelID": "deepseek-v4-pro", + "providerID": "deepseek", + "time": { + "created": 1785316895654, + "completed": 1785316898843 + }, + "finish": "stop", + "id": "msg_fad2deba6001GGfVEXi3CANMeM", + "sessionID": "ses_0c3efadf0ffeP4HreoRuvKX5h3" + }, + "parts": [ + { + "snapshot": "7a603081d1ecf645fefa416e0364e0f3face7d8d", + "type": "step-start", + "id": "prt_fad2df2c5001RZt5Mqz1NypEm3", + "sessionID": "ses_0c3efadf0ffeP4HreoRuvKX5h3", + "messageID": "msg_fad2deba6001GGfVEXi3CANMeM" + }, + { + "type": "text", + "text": "Done. `.reset` now clears `STATE_FILE`, `LIVE_STREAM_FRAME_PATH`, then deletes itself.", + "time": { + "start": 1785316898131, + "end": 1785316898578 + }, + "id": "prt_fad2df553001A23rMdhe6fERXF", + "sessionID": "ses_0c3efadf0ffeP4HreoRuvKX5h3", + "messageID": "msg_fad2deba6001GGfVEXi3CANMeM" + }, + { + "reason": "stop", + "snapshot": "7a603081d1ecf645fefa416e0364e0f3face7d8d", + "type": "step-finish", + "tokens": { + "total": 134057, + "input": 142, + "output": 27, + "reasoning": 0, + "cache": { + "write": 0, + "read": 133888 + } + }, + "cost": 0.000570604, + "id": "prt_fad2df79b001d41u61nK2WXcR2", + "sessionID": "ses_0c3efadf0ffeP4HreoRuvKX5h3", + "messageID": "msg_fad2deba6001GGfVEXi3CANMeM" + } + ] } ] } diff --git a/src/main.cpp b/src/main.cpp index 6e5c640..0ad1758 100644 --- a/src/main.cpp +++ b/src/main.cpp @@ -147,6 +147,7 @@ int main(int argc, char* argv[]) { std::cout << "[RESET] .reset detected — clearing state" << std::endl; std::error_code ec; std::filesystem::remove(g_config.state_file, ec); + std::filesystem::remove(g_config.live_stream_frame_path, ec); std::filesystem::remove(reset_file, ec); } }