add worker logs

internal/server/tradelogs/server.go

@@ -90,6 +90,7 @@ func (s *Server) getTradeLogs(c *gin.Context) {
 		responseErr(c, http.StatusBadRequest, errors.New("max time range"))
 		return
 	}
+	s.l.Infow("get trade log query", "query", query)
 	data, err := s.s.Get(query)
 	if err != nil {
 		responseErr(c, http.StatusBadRequest, err)

internal/worker/worker.go

@@ -83,6 +83,7 @@ func (w *Worker) Run(ctx context.Context) error {
 }
 func (w *Worker) processMessages(m []evmlistenerclient.Message) error {
 	for _, message := range m {
+		w.l.Infow("about to process new message", "msg", message)
 		var (
 			insertOrders []storage.TradeLog
 			deleteBlocks []uint64
@@ -91,6 +92,7 @@ func (w *Worker) processMessages(m []evmlistenerclient.Message) error {
 		for _, block := range message.RevertedBlocks {
 			deleteBlocks = append(deleteBlocks, block.Number.Uint64())
 			if err := w.s.DeleteErrorLogsWithBlock(block.Hash); err != nil {
+				w.l.Infow("error when revert block", "blocks", deleteBlocks, "err", err)
 				return err
 			}
 		}

v2/internal/server/tradelogs.go

@@ -74,6 +74,8 @@ func (s *TradeLogs) getTradeLogs(c *gin.Context) {
 		return
 	}
 
+	s.l.Infow("get trade log query", "query", query)
+
 	var data []storageTypes.TradeLog
 	for _, storage := range s.storage {
 		tradeLogs, err := storage.Get(query)

v2/internal/worker/log_parser.go

@@ -40,6 +40,8 @@ func (w *LogParser) Publish(ctx context.Context, topic string, data interface{})
 func (w *LogParser) processMessage(msg types.Message) error {
 	var deleteBlocks []uint64
 
+	w.l.Infow("process message", "msg", msg)
+
 	for _, block := range msg.RevertedBlocks {
 		deleteBlocks = append(deleteBlocks, block.Number.Uint64())
 	}