fixed error handling in worker and added search by request id

Author: n0nag0n

dashboard/js/script.js

@@ -687,6 +687,7 @@ function setupFilterHandlers() {
         const url = document.getElementById('filter-url').value.trim();
         const responseCode = filterResponseCode.value;
         const exactCode = filterExactCode.value.trim();
+        const requestId = document.getElementById('filter-request-id').value.trim();
         const bot = document.getElementById('filter-bot').value;
         const customEvent = document.getElementById('filter-custom-event').value.trim();
         const minTime = document.getElementById('filter-min-time').value.trim();
@@ -696,6 +697,7 @@ function setupFilterHandlers() {
 
         // Add non-empty filters to the activeFilters object
         if (url) activeFilters.url = url;
+        if (requestId) activeFilters.request_id = requestId;
 
         if (responseCode === 'exact' && exactCode) {
             activeFilters.response_code = exactCode;
@@ -723,6 +725,7 @@ function setupFilterHandlers() {
         document.getElementById('filter-url').value = '';
         filterResponseCode.value = '';
         filterExactCode.value = '';
+        document.getElementById('filter-request-id').value = '';
         document.getElementById('filter-bot').value = '';
         document.getElementById('filter-custom-event').value = '';
         document.getElementById('filter-min-time').value = '';
@@ -761,6 +764,9 @@ function setupFilterHandlers() {
                 case 'url':
                     filterLabel = `URL: ${value}`;
                     break;
+                case 'request_id':
+                    filterLabel = `Request ID: ${value}`;
+                    break;
                 case 'response_code':
                     filterLabel = `Code: ${value}`;
                     break;

dashboard/views/dashboard.php

@@ -146,6 +146,10 @@
 											<label for="filter-exact-code" class="form-label">Exact Code</label>
 											<input type="number" class="form-control" id="filter-exact-code" placeholder="e.g. 404">
 										</div>
+										<div class="col-md-3">
+											<label for="filter-request-id" class="form-label">Request ID</label>
+											<input type="text" class="form-control" id="filter-request-id" placeholder="e.g. req_1234abcd">
+										</div>
 										<div class="col-md-3">
 											<label for="filter-bot" class="form-label">Bot Requests</label>
 											<select class="form-select" id="filter-bot">

src/apm/presenter/SqlitePresenter.php

@@ -182,11 +182,18 @@ public function getRequestsData(string $threshold, int $page, int $perPage, stri
         $isBot = $_GET['is_bot'] ?? '';
         $customEventType = $_GET['custom_event_type'] ?? '';
         $minTime = $_GET['min_time'] ?? '';
+        $requestId = $_GET['request_id'] ?? '';
 
         // Build main query with conditions for URL and response code
         $conditions = ['timestamp >= ?'];
         $params = [$threshold];
 
+        // Add request ID filter (exact match)
+        if (!empty($requestId)) {
+            $conditions[] = 'request_id = ?';
+            $params[] = $requestId;
+        }
+
         // Add URL filter
         if (!empty($url)) {
             $conditions[] = 'request_url LIKE ?';

src/commands/WorkerCommand.php

@@ -213,7 +213,9 @@ public function execute()
                                 break;
                             }
                         } catch (\Exception $e) {
-                            $io->red("Failed! {$e->getMessage()}", true);
+                            $io->red("Failed to process metric ID {$metric['id']}: {$e->getMessage()}", true);
+                            // Add to processed IDs to delete the erroneous metric
+                            $processedIds[] = $metric['id'];
                             // Continue with other messages
                         }
                     }