Slashing amount in prometheus metrics

Author: hakaiLuganodes

pkg/metrics/metrics.go

@@ -29,6 +29,14 @@ var (
 		},
 		[]string{"vault", "slasher"},
 	)
+
+	AmountSlashedEventCounter = prometheus.NewCounterVec(
+		prometheus.CounterOpts{
+			Name: "amount_slashed_by_operator",
+			Help: "Amount of tokens slashed due to operator misbehavior",
+		},
+		[]string{"vault", "operator", "subnetwork"}, // ← this is correct
+	)
 )
 
 func Init() {

pkg/observer/observer.go

@@ -99,7 +99,7 @@ func StartVetoSlasherObserver(ctx context.Context, address string, vault string)
 					continue
 				}
 
-				decoded := make(map[string]interface{})
+				decoded := make(map[string]interface{}) //<-- here to change
 				if err := parsedABI.UnpackIntoMap(decoded, event.Name, vLog.Data); err != nil {
 					log.Printf("❌ [%s] Failed to unpack data: %v", address, err)
 					continue
@@ -124,6 +124,23 @@ func StartVetoSlasherObserver(ctx context.Context, address string, vault string)
 				alertmanager.SendStructuredData(alertData)
 				metrics.SlashingEventCounter.WithLabelValues(vault, address).Inc()
 
+				if event.Name == "RequestSlash" {
+					operatorAddr, ok1 := decoded["operator"].(common.Address)
+					subnetworkRaw, ok2 := decoded["subnetwork"].(string)
+					slashAmount, ok3 := decoded["slashAmount"].(*big.Int)
+
+					if !ok1 || !ok2 || !ok3 {
+						log.Printf("⚠️ [%s] Failed to cast RequestSlash fields properly", address)
+						continue
+					}
+
+					amountFloat, _ := new(big.Float).SetInt(slashAmount).Float64()
+
+					metrics.AmountSlashedEventCounter.
+						WithLabelValues(vault, operatorAddr.Hex(), subnetworkRaw).
+						Add(amountFloat)
+				}
+
 			case <-ctx.Done():
 				log.Printf("🛑 [%s] Stopping observer...", address)
 				return