All numeric columns need to be text to avoid potential truncation

In some cases, sqlite is turning numbers into scientific notation
which results in lost precision.

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
 }
@@ -167,6 +167,7 @@ func (osm *OperatorSharesModel) GetStateTransitions() (types.StateTransitions[Ac
 		} else {
 			record.Shares = record.Shares.Add(record.Shares, shares)
 		}
+		fmt.Printf("OperatorShares %+v\n", record)
 
 		return record, nil
 	}
@@ -268,7 +269,7 @@ func (osm *OperatorSharesModel) prepareState(blockNumber uint64) ([]OperatorShar
 		select
 			operator,
 			strategy,
-			shares
+			cast(shares as text) as shares
 		from operator_shares
 		where
 			block_number = @previousBlock
@@ -290,6 +291,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 +310,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,