Merge pull request #45 from Layr-Labs/sm-numericFix

All numeric columns need to be text to avoid potential truncation

.dockerignore

@@ -0,0 +1 @@
+/sqlite*

Dockerfile

@@ -13,9 +13,6 @@ RUN make deps-linux
 
 RUN make build
 
-# FROM golang:1.22-bullseye as run
-#
-# RUN apt-get update
-# RUN apt-get install -y vim postgresql-client
-#
-# COPY --from=build /build/bin/cmd /bin
+FROM debian:stable-slim as run
+
+COPY --from=build /build/bin/cmd/* /bin

README.md

@@ -36,7 +36,7 @@ docker run -it --rm \
   -e SIDECAR_SQLITE_DB_FILE_PATH="/sqlite/sidecar.db" \
   -v "$(pwd)/sqlite:/sqlite" \
   --tty -i \
-  public.ecr.aws/z6g0f8n7/go-sidecar:latest /build/bin/cmd/sidecar
+  public.ecr.aws/z6g0f8n7/go-sidecar:latest /bin/sidecar
 ```
 
 ### Build and run a container locally
@@ -56,7 +56,7 @@ docker run \
   -e "SIDECAR_SQLITE_DB_FILE_PATH=/sqlite/sidecar.db" \
   -v "$(pwd)/sqlite:/sqlite" \
   --tty -i \
-  go-sidecar:latest /build/bin/cmd/sidecar
+  go-sidecar:latest /bin/sidecar
 ```
 
 ## RPC Routes

internal/eigenState/operatorShares/operatorShares.go

@@ -30,7 +30,7 @@ import (
 type OperatorShares struct {
 	Operator    string
 	Strategy    string
-	Shares      string `gorm:"type:numeric"`
+	Shares      string
 	BlockNumber uint64
 	CreatedAt   time.Time
 }
@@ -290,6 +290,7 @@ func (osm *OperatorSharesModel) prepareState(blockNumber uint64) ([]OperatorShar
 	// Map the existing records to a map for easier lookup
 	mappedRecords := make(map[SlotId]OperatorShares)
 	for _, record := range existingRecords {
+		fmt.Printf("Existing OperatorShares %+v\n", record)
 		slotId := NewSlotId(record.Operator, record.Strategy)
 		mappedRecords[slotId] = record
 	}
@@ -308,7 +309,12 @@ func (osm *OperatorSharesModel) prepareState(blockNumber uint64) ([]OperatorShar
 		if existingRecord, ok := mappedRecords[slotId]; ok {
 			existingShares, success := numbers.NewBig257().SetString(existingRecord.Shares, 10)
 			if !success {
-				osm.logger.Sugar().Errorw("Failed to convert existing shares to big.Int")
+				osm.logger.Sugar().Errorw("Failed to convert existing shares to big.Int",
+					zap.String("shares", existingRecord.Shares),
+					zap.String("operator", existingRecord.Operator),
+					zap.String("strategy", existingRecord.Strategy),
+					zap.Uint64("blockNumber", blockNumber),
+				)
 				continue
 			}
 			prepared.Shares = existingShares.Add(existingShares, newState.Shares)

internal/eigenState/rewardSubmissions/rewardSubmissions.go

@@ -32,7 +32,7 @@ type RewardSubmission struct {
 	Amount         string
 	Strategy       string
 	StrategyIndex  uint64
-	Multiplier     string     `gorm:"type:numeric"`
+	Multiplier     string
 	StartTimestamp *time.Time `gorm:"type:DATETIME"`
 	EndTimestamp   *time.Time `gorm:"type:DATETIME"`
 	Duration       uint64

internal/eigenState/stakerShares/stakerShares.go

@@ -30,7 +30,7 @@ import (
 type StakerShares struct {
 	Staker      string
 	Strategy    string
-	Shares      string `gorm:"type:numeric"`
+	Shares      string
 	BlockNumber uint64
 	CreatedAt   time.Time
 }
@@ -579,7 +579,12 @@ func (ss *StakerSharesModel) prepareState(blockNumber uint64) ([]StakerSharesDif
 		if existingRecord, ok := mappedRecords[slotId]; ok {
 			existingShares, success := numbers.NewBig257().SetString(existingRecord.Shares, 10)
 			if !success {
-				ss.logger.Sugar().Errorw("Failed to convert existing shares to big.Int")
+				ss.logger.Sugar().Errorw("Failed to convert existing shares to big.Int",
+					zap.String("shares", existingRecord.Shares),
+					zap.String("staker", existingRecord.Staker),
+					zap.String("strategy", existingRecord.Strategy),
+					zap.Uint64("blockNumber", blockNumber),
+				)
 				continue
 			}
 			prepared.Shares = existingShares.Add(existingShares, newState.Shares)

internal/sqlite/migrations/202409061720_operatorShareChanges/up.go

@@ -12,7 +12,7 @@ func (m *SqliteMigration) Up(grm *gorm.DB) error {
 		`create table if not exists operator_shares (
 			operator TEXT NOT NULL,
 			strategy TEXT NOT NULL,
-			shares NUMERIC NOT NULL,
+			shares TEXT NOT NULL,
 			block_number INTEGER NOT NULL,
 			created_at DATETIME default current_timestamp,
 			unique (operator, strategy, block_number)

internal/sqlite/migrations/202409082234_stakerShare/up.go

@@ -12,7 +12,7 @@ func (m *SqliteMigration) Up(grm *gorm.DB) error {
 		`create table if not exists staker_shares (
 			staker TEXT NOT NULL,
 			strategy TEXT NOT NULL,
-			shares NUMERIC NOT NULL,
+			shares TEXT NOT NULL,
 			block_number INTEGER NOT NULL,
 			created_at DATETIME default current_timestamp,
 			unique (staker, strategy, block_number)

internal/sqlite/migrations/202409101540_rewardSubmissions/up.go

@@ -13,10 +13,10 @@ func (m *SqliteMigration) Up(grm *gorm.DB) error {
 			avs TEXT NOT NULL,
 			reward_hash TEST NOT NULL,
 			token TEXT NOT NULL,
-			amount NUMERIC NOT NULL,
+			amount TEXT NOT NULL,
 			strategy TEXT NOT NULL,
 			strategy_index INTEGER NOT NULL,
-			multiplier NUMERIC NOT NULL,
+			multiplier TEXT NOT NULL,
 			start_timestamp DATETIME NOT NULL,
 			end_timestamp DATETIME NOT NULL,
 			duration INTEGER NOT NULL,