Improve LogPoller logs (#1440)

* Improved LogPoller logs

* Lint

Author: amit-momin

pkg/solana/logpoller/job_get_block.go

@@ -129,7 +129,7 @@ func (j *getBlockJob) Run(ctx context.Context) error {
 		events = append(events, txEvents...)
 	}
 
-	j.lggr.Debugf("found %d events at slot %d", len(events), j.slotNumber)
+	j.lggr.Debugw("found events", "count", len(events), "slot", j.slotNumber)
 
 	result := types.Block{
 		SlotNumber: j.slotNumber,

pkg/solana/logpoller/log_poller.go

@@ -230,7 +230,7 @@ func (lp *Service) Process(ctx context.Context, programEvent types.ProgramEvent)
 			log.ExpiresAt = &expiresAt
 		}
 
-		lp.lggr.Infof("found matching event %+v", log)
+		lp.lggr.Infow("found matching event", "log", log, "eventName", filter.EventName)
 
 		logs = append(logs, log)
 	}
@@ -409,7 +409,7 @@ consumedAllBlocks:
 
 			batch := []types.Block{block}
 			batch = appendBuffered(blocks, blocksChBuffer, batch)
-			lp.lggr.Infof("processing batch of %d blocks: [slots %d-%d]", len(batch), batch[0].SlotNumber, batch[len(batch)-1].SlotNumber)
+			lp.lggr.Infow("processing batch of blocks", "count", len(batch), "start", batch[0].SlotNumber, "end", batch[len(batch)-1].SlotNumber)
 			err = lp.processBlocks(ctx, batch)
 			if err != nil {
 				return fmt.Errorf("error processing blocks: %w", err)

pkg/solana/logpoller/types/types.go

@@ -67,6 +67,10 @@ func (h Hash) ToSolana() solana.Hash {
 	return solana.Hash(h)
 }
 
+func (h Hash) String() string {
+	return h.ToSolana().String()
+}
+
 type Signature solana.Signature
 
 // Scan implements Scanner for database/sql.
@@ -83,6 +87,10 @@ func (s Signature) ToSolana() solana.Signature {
 	return solana.Signature(s)
 }
 
+func (s Signature) String() string {
+	return s.ToSolana().String()
+}
+
 func scanFixedLengthArray(name string, maxLength int, src interface{}, dest []byte) error {
 	srcB, ok := src.([]byte)
 	if !ok {