Skip to content

Commit

Permalink
remove useless logs
Browse files Browse the repository at this point in the history
  • Loading branch information
colinlyguo committed Dec 13, 2023
1 parent cd883a3 commit ebf7a46
Show file tree
Hide file tree
Showing 2 changed files with 10 additions and 10 deletions.
8 changes: 4 additions & 4 deletions bridge-history-api/internal/orm/batch_event.go
Original file line number Diff line number Diff line change
Expand Up @@ -100,25 +100,25 @@ func (c *BatchEvent) InsertOrUpdateBatchEvents(ctx context.Context, l1BatchEvent
switch BatchStatusType(l1BatchEvent.BatchStatus) {
case BatchStatusTypeCommitted:
if err := db.Create(l1BatchEvent).Error; err != nil {
return fmt.Errorf("failed to insert batch event, batch: %+v, error: %w", l1BatchEvent, err)
return fmt.Errorf("failed to insert batch event, error: %w", err)
}
case BatchStatusTypeFinalized:
db = db.Where("batch_index = ?", l1BatchEvent.BatchIndex)
db = db.Where("batch_hash = ?", l1BatchEvent.BatchHash)
updateFields["batch_status"] = BatchStatusTypeFinalized
if err := db.Updates(updateFields).Error; err != nil {
return fmt.Errorf("failed to update batch event, batch: %+v, error: %w", l1BatchEvent, err)
return fmt.Errorf("failed to update batch event, error: %w", err)
}
case BatchStatusTypeReverted:
db = db.Where("batch_index = ?", l1BatchEvent.BatchIndex)
db = db.Where("batch_hash = ?", l1BatchEvent.BatchHash)
updateFields["batch_status"] = BatchStatusTypeReverted
if err := db.Updates(updateFields).Error; err != nil {
return fmt.Errorf("failed to update batch event, batch: %+v, error: %w", l1BatchEvent, err)
return fmt.Errorf("failed to update batch event, error: %w", err)
}
// Soft delete the batch event.
if err := db.Delete(l1BatchEvent).Error; err != nil {
return fmt.Errorf("failed to soft delete batch event, batch: %+v, error: %w", l1BatchEvent, err)
return fmt.Errorf("failed to soft delete batch event, error: %w", err)
}
}
}
Expand Down
12 changes: 6 additions & 6 deletions bridge-history-api/internal/orm/cross_message.go
Original file line number Diff line number Diff line change
Expand Up @@ -241,7 +241,7 @@ func (c *CrossMessage) UpdateL1MessageQueueEventsInfo(ctx context.Context, l1Mes
updateFields["tx_status"] = TxStatusTypeDropped
}
if err := db.Updates(updateFields).Error; err != nil {
return fmt.Errorf("failed to update L1 message queue events info, event: %+v, error: %w", l1MessageQueueEvent, err)
return fmt.Errorf("failed to update L1 message queue events info, error: %w", err)
}
}
return nil
Expand Down Expand Up @@ -279,7 +279,7 @@ func (c *CrossMessage) InsertOrUpdateL1Messages(ctx context.Context, messages []
DoUpdates: clause.AssignmentColumns([]string{"sender", "receiver", "token_type", "l1_block_number", "l1_tx_hash", "l1_token_address", "l2_token_address", "token_ids", "token_amounts", "message_type", "tx_status", "block_timestamp", "message_nonce"}),
})
if err := db.Create(messages).Error; err != nil {
return fmt.Errorf("failed to insert message, message: %+v, error: %w", messages, err)
return fmt.Errorf("failed to insert message, error: %w", err)
}
return nil
}
Expand All @@ -300,7 +300,7 @@ func (c *CrossMessage) InsertOrUpdateL2Messages(ctx context.Context, messages []
DoUpdates: clause.AssignmentColumns([]string{"sender", "receiver", "token_type", "l2_block_number", "l2_tx_hash", "l1_token_address", "l2_token_address", "token_ids", "token_amounts", "message_type", "tx_status", "block_timestamp", "message_from", "message_to", "message_value", "message_data", "merkle_proof", "message_nonce"}),
})
if err := db.Create(messages).Error; err != nil {
return fmt.Errorf("failed to insert message, message: %+v, error: %w", messages, err)
return fmt.Errorf("failed to insert message, error: %w", err)
}
return nil
}
Expand All @@ -323,7 +323,7 @@ func (c *CrossMessage) InsertFailedGatewayRouterTxs(ctx context.Context, message
message.MessageHash = uuid.New().String()
}
if err := db.Create(messages).Error; err != nil {
return fmt.Errorf("failed to insert failed gateway router txs, message: %+v, error: %w", messages, err)
return fmt.Errorf("failed to insert failed gateway router txs, error: %w", err)
}
return nil
}
Expand All @@ -340,7 +340,7 @@ func (c *CrossMessage) InsertOrUpdateL2RelayedMessagesOfL1Deposits(ctx context.C
DoUpdates: clause.AssignmentColumns([]string{"l2_block_number", "l2_tx_hash", "tx_status"}),
})
if err := db.Create(l2RelayedMessages).Error; err != nil {
return fmt.Errorf("failed to update L2 relayed message of L1 deposit, L2 relayed message: %+v, error: %w", l2RelayedMessages, err)
return fmt.Errorf("failed to update L2 relayed message of L1 deposit, error: %w", err)
}
return nil
}
Expand All @@ -361,7 +361,7 @@ func (c *CrossMessage) InsertOrUpdateL1RelayedMessagesOfL2Withdrawals(ctx contex
DoUpdates: clause.AssignmentColumns([]string{"l1_block_number", "l1_tx_hash", "tx_status"}),
})
if err := db.Create(l1RelayedMessages).Error; err != nil {
return fmt.Errorf("failed to update L1 relayed message of L2 withdrawal, L1 relayed messages: %+v, error: %w", l1RelayedMessages, err)
return fmt.Errorf("failed to update L1 relayed message of L2 withdrawal, error: %w", err)
}
return nil
}

0 comments on commit ebf7a46

Please sign in to comment.