report-listener: speed up by-brand search path and skip n=1 heavy counts

Author: borisolver

report-listener/.version

@@ -1 +1 @@
-BUILD_VERSION=1.0.114
+BUILD_VERSION=1.0.115

report-listener/database/database.go

@@ -1472,14 +1472,15 @@ func (d *Database) GetReportsByLatLngLite(ctx context.Context, latitude, longitu
 // PERFORMANCE: Skip report_status and reports_owners checks for speed
 // These tables are sparsely populated and add 40+ seconds to large brand queries
 func (d *Database) GetReportsByBrandName(ctx context.Context, brandName string, limit int) ([]models.ReportWithAnalysis, error) {
-	// FAST PATH: Query directly on report_analysis index, skip rarely-used status/owner tables
+	// FAST PATH: Drive from report_analysis with the brand+valid+seq index and
+	// order by ra.seq to avoid slow join/order plans on reports for high-volume brands.
 	reportsQuery := `
-		SELECT r.seq, r.ts, r.id, r.latitude, r.longitude
-		FROM reports r
-		INNER JOIN report_analysis ra ON r.seq = ra.seq
+		SELECT ra.seq, r.ts, r.id, r.latitude, r.longitude
+		FROM report_analysis ra FORCE INDEX (idx_ra_brand_valid_seq)
+		INNER JOIN reports r ON r.seq = ra.seq
 		WHERE ra.brand_name = ? 
 		AND ra.is_valid = TRUE
-		ORDER BY r.seq DESC
+		ORDER BY ra.seq DESC
 		LIMIT ?
 	`
 

report-listener/handlers/handlers.go

@@ -981,18 +981,21 @@ func (h *Handlers) GetReportsByBrand(c *gin.Context) {
 	}
 
 	// Get counts with a bounded timeout to avoid slow/full-table scans blocking UI.
+	// For n=1 (digital search flow), skip aggregate counts entirely.
 	totalCount := len(reports)
 	highPriorityCount := 0
 	mediumPriorityCount := 0
-	countCtx, cancelCounts := context.WithTimeout(c.Request.Context(), 4*time.Second)
-	defer cancelCounts()
-	t, hpc, mpc, err := h.db.GetBrandPriorityCountsByBrandName(countCtx, brandName)
-	if err != nil {
-		log.Printf("Failed to get aggregated counts for brand '%s' (fallbacking to partial): %v", brandName, err)
-	} else {
-		totalCount = t
-		highPriorityCount = hpc
-		mediumPriorityCount = mpc
+	if limit > 1 {
+		countCtx, cancelCounts := context.WithTimeout(c.Request.Context(), 1200*time.Millisecond)
+		defer cancelCounts()
+		t, hpc, mpc, err := h.db.GetBrandPriorityCountsByBrandName(countCtx, brandName)
+		if err != nil {
+			log.Printf("Failed to get aggregated counts for brand '%s' (fallbacking to partial): %v", brandName, err)
+		} else {
+			totalCount = t
+			highPriorityCount = hpc
+			mediumPriorityCount = mpc
+		}
 	}
 
 	// Create the response in the same format as other endpoints