refactor: remove observability & perf code added for experimental use

Author: malwarebo

analytics/reporter.go

@@ -3,10 +3,7 @@ package api
 import (
 	"encoding/json"
 	"net/http"
-	"runtime"
 	"time"
-
-	"github.com/malwarebo/conductor/utils"
 )
 
 type HealthResponse struct {
@@ -15,21 +12,6 @@ type HealthResponse struct {
 	Uptime    string    `json:"uptime"`
 }
 
-type MetricsResponse struct {
-	GoRoutines int                    `json:"goroutines"`
-	Memory     Memory                 `json:"memory"`
-	Uptime     string                 `json:"uptime"`
-	Providers  map[string]interface{} `json:"providers,omitempty"`
-	Business   map[string]interface{} `json:"business_metrics,omitempty"`
-}
-
-type Memory struct {
-	Alloc      uint64 `json:"alloc"`
-	TotalAlloc uint64 `json:"total_alloc"`
-	Sys        uint64 `json:"sys"`
-	NumGC      uint32 `json:"num_gc"`
-}
-
 var startTime = time.Now()
 
 func CreateHealthCheckHandler(w http.ResponseWriter, r *http.Request) {
@@ -48,54 +30,3 @@ func CreateHealthCheckHandler(w http.ResponseWriter, r *http.Request) {
 		return
 	}
 }
-
-func CreateMetricsHandler(w http.ResponseWriter, r *http.Request) {
-	var m runtime.MemStats
-	runtime.ReadMemStats(&m)
-
-	uptime := time.Since(startTime)
-
-	businessMetrics := make(map[string]interface{})
-	allMetrics := utils.CreateGetAllMetrics()
-
-	paymentCounts := make(map[string]int)
-	fraudCounts := make(map[string]int)
-	providerCounts := make(map[string]int)
-
-	for _, metric := range allMetrics {
-		switch metric.Name {
-		case "payments_total":
-			key := metric.Labels["status"] + "_" + metric.Labels["currency"]
-			paymentCounts[key] = int(metric.Value)
-		case "fraud_analysis_total":
-			key := metric.Labels["status"]
-			fraudCounts[key] = int(metric.Value)
-		case "provider_operations_total":
-			key := metric.Labels["provider"] + "_" + metric.Labels["status"]
-			providerCounts[key] = int(metric.Value)
-		}
-	}
-
-	businessMetrics["payments"] = paymentCounts
-	businessMetrics["fraud_analysis"] = fraudCounts
-	businessMetrics["provider_operations"] = providerCounts
-
-	response := MetricsResponse{
-		GoRoutines: runtime.NumGoroutine(),
-		Memory: Memory{
-			Alloc:      m.Alloc,
-			TotalAlloc: m.TotalAlloc,
-			Sys:        m.Sys,
-			NumGC:      m.NumGC,
-		},
-		Uptime:   uptime.String(),
-		Business: businessMetrics,
-	}
-
-	w.Header().Set("Content-Type", "application/json")
-	w.WriteHeader(http.StatusOK)
-	if err := json.NewEncoder(w).Encode(response); err != nil {
-		http.Error(w, "Failed to encode response", http.StatusInternalServerError)
-		return
-	}
-}

api/health.go

@@ -51,8 +51,6 @@ func (h *RoutingHandler) HandleRouting(w http.ResponseWriter, r *http.Request) {
 
 	response.RoutingTime = time.Since(startTime).Milliseconds()
 
-	utils.CreateRecordRoutingMetrics(r.Context(), response.RecommendedProvider, response.ConfidenceScore, response.EstimatedSuccessRate)
-
 	w.Header().Set("Content-Type", "application/json")
 	w.WriteHeader(http.StatusOK)
 
@@ -83,51 +81,6 @@ func (h *RoutingHandler) HandleProviderStats(w http.ResponseWriter, r *http.Requ
 	}
 }
 
-func (h *RoutingHandler) HandleRoutingMetrics(w http.ResponseWriter, r *http.Request) {
-	startDateStr := r.URL.Query().Get("start_date")
-	endDateStr := r.URL.Query().Get("end_date")
-
-	var err error
-
-	if startDateStr != "" {
-		_, err = time.Parse(time.RFC3339, startDateStr)
-		if err != nil {
-			http.Error(w, "Invalid start_date format. Use RFC3339 (e.g., 2024-01-01T00:00:00Z)", http.StatusBadRequest)
-			return
-		}
-	}
-
-	if endDateStr != "" {
-		_, err = time.Parse(time.RFC3339, endDateStr)
-		if err != nil {
-			http.Error(w, "Invalid end_date format. Use RFC3339 (e.g., 2024-01-01T00:00:00Z)", http.StatusBadRequest)
-			return
-		}
-	}
-
-	metrics := &models.RoutingMetrics{
-		TotalDecisions:     1000,
-		CacheHitRate:       0.75,
-		AvgConfidenceScore: 85.5,
-		SuccessRate:        0.96,
-		AvgResponseTime:    150,
-		CostSavings:        1250.50,
-		ProviderDistribution: map[string]int64{
-			"stripe": 650,
-			"xendit": 350,
-		},
-	}
-
-	w.Header().Set("Content-Type", "application/json")
-	w.WriteHeader(http.StatusOK)
-
-	if err := json.NewEncoder(w).Encode(metrics); err != nil {
-		utils.CreateLogger("conductor").Error(r.Context(), "Failed to encode routing metrics", map[string]interface{}{
-			"error": err.Error(),
-		})
-	}
-}
-
 func (h *RoutingHandler) HandleRoutingConfig(w http.ResponseWriter, r *http.Request) {
 	switch r.Method {
 	case "GET":

api/routing_handler.go

@@ -42,30 +42,6 @@ services:
       - redis_data:/data
     restart: unless-stopped
 
-  prometheus:
-    image: prom/prometheus:latest
-    ports:
-      - "9090:9090"
-    volumes:
-      - ./prometheus.yml:/etc/prometheus/prometheus.yml
-    command:
-      - '--config.file=/etc/prometheus/prometheus.yml'
-      - '--storage.tsdb.path=/prometheus'
-      - '--web.console.libraries=/etc/prometheus/console_libraries'
-      - '--web.console.templates=/etc/prometheus/consoles'
-    restart: unless-stopped
-
-  grafana:
-    image: grafana/grafana:latest
-    ports:
-      - "3000:3000"
-    environment:
-      - GF_SECURITY_ADMIN_PASSWORD=admin
-    volumes:
-      - grafana_data:/var/lib/grafana
-    restart: unless-stopped
-
 volumes:
   postgres_data:
   redis_data:
-  grafana_data: