fix(eventindexer): add address to Slashed event in db, + add logs (#1…

…4103)
taikoxyz · Jul 4, 2023 · 4ef8d0c · 4ef8d0c
1 parent 7f41353
commit 4ef8d0c
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 3 deletions.
diff --git a/packages/eventindexer/http/get_pos_stats.go b/packages/eventindexer/http/get_pos_stats.go
@@ -7,6 +7,7 @@ import (
 	"github.com/cyberhorsey/webutils"
 	"github.com/labstack/echo/v4"
 	"github.com/patrickmn/go-cache"
+	log "github.com/sirupsen/logrus"
 )
 
 type posStatsResponse struct {
@@ -47,6 +48,12 @@ func (srv *Server) getPosStats(ctx context.Context) (*posStatsResponse, error) {
 		return nil, err
 	}
 
+	log.Infof(
+		"pos stats, slashedTokens: %v, capacity: %v",
+		totalSlashedTokens.String(),
+		capacity.String(),
+	)
+
 	resp := &posStatsResponse{
 		TotalSlashedTokens:      totalSlashedTokens.String(),
 		CurrentProtocolCapacity: capacity.String(),

diff --git a/packages/eventindexer/indexer/save_slashed_event.go b/packages/eventindexer/indexer/save_slashed_event.go
@@ -24,12 +24,12 @@ func (svc *Service) saveSlashedEvents(
 	for {
 		event := events.Event
 
-		log.Infof("new slashed event, addr: %v", event.Addr.Hex())
+		log.Infof("new slashed event, addr: %v, amt: %v", event.Addr.Hex(), event.Amount)
 
 		if err := svc.saveSlashedEvent(ctx, chainID, event); err != nil {
 			eventindexer.SlashedEventsProcessedError.Inc()
 
-			return errors.Wrap(err, "svc.saveBlockVerifiedEvent")
+			return errors.Wrap(err, "svc.saveSlashedEvent")
 		}
 
 		if !events.Next() {
@@ -53,7 +53,8 @@ func (svc *Service) saveSlashedEvent(
 		Data:    string(marshaled),
 		ChainID: chainID,
 		Event:   eventindexer.EventNameSlashed,
-		Address: "",
+		Address: event.Addr.Hex(),
+		Amount:  new(big.Int).SetUint64(event.Amount),
 	})
 	if err != nil {
 		return errors.Wrap(err, "svc.eventRepo.Save")