go 1.24 (#4869)

* go 1.24

* Fixed params to Fatal and Msg

* feat(go version) - update the golang version to the 1.24.2

Author: Frozen

.travis.yml

@@ -2,7 +2,7 @@ os: linux
 dist: jammy
 language: go
 go:
-  - 1.22.5
+  - 1.24.2
 go_import_path: github.com/harmony-one/harmony
 cache:
   directories:

Dockerfile

@@ -1,7 +1,7 @@
 FROM ubuntu:22.04
 
 ARG TARGETARCH
-ARG GOLANG_VERSION="1.22.5"
+ARG GOLANG_VERSION="1.24.2"
 
 SHELL ["/bin/bash", "-c"]
 

Makefile

@@ -256,3 +256,4 @@ debug-delete-log:
 	docker volume rm logs_aggregator_loki_data
 	@echo "[WARN] - it needs sudo to remove folder created with loki docker image user"
 	sudo rm -rf test/logs_aggregator/loki
+

README.md

@@ -16,7 +16,7 @@ http://api.hmny.io/
 
 ## Requirements
 
-### **Go 1.22.5**
+### **Go 1.24.2**
 ### **GMP and OpenSSL**
 
 On macOS:

accounts/abi/unpack_test.go

@@ -909,7 +909,7 @@ func TestOOMMaliciousInput(t *testing.T) {
 		}
 		encb, err := hex.DecodeString(test.enc)
 		if err != nil {
-			t.Fatalf("invalid hex: %s" + test.enc)
+			t.Fatalf("invalid hex: %s", test.enc)
 		}
 		_, err = abi.Methods["method"].Outputs.UnpackValues(encb)
 		if err == nil {

api/service/legacysync/downloader/Proto.Dockerfile

@@ -1,4 +1,4 @@
-FROM golang:1.22.5-bullseye
+FROM golang:1.24.2-bullseye
 
 RUN apt update
 RUN apt install -y protobuf-compiler

api/service/stagedstreamsync/stage_heads.go

@@ -83,7 +83,7 @@ func (heads *StageHeads) Exec(ctx context.Context, firstCycle bool, invalidBlock
 			Uint64("currentHeight", currentHeight).
 			Uint64("maxPeersHeight", maxHeight).
 			Uint64("targetHeight", targetHeight).
-			Msgf(WrapStagedSyncMsg("current height is ahead of target height, target height is readjusted to max peers height"))
+			Msg(WrapStagedSyncMsg("current height is ahead of target height, target height is readjusted to max peers height"))
 		targetHeight = maxHeight
 	}
 
@@ -108,7 +108,7 @@ func (heads *StageHeads) Exec(ctx context.Context, firstCycle bool, invalidBlock
 	if err := s.Update(tx, targetHeight); err != nil {
 		heads.configs.logger.Error().
 			Err(err).
-			Msgf(WrapStagedSyncMsg("saving progress for headers stage failed"))
+			Msg(WrapStagedSyncMsg("saving progress for headers stage failed"))
 		return err
 	}
 

api/service/stagedstreamsync/staged_stream_sync.go

@@ -225,7 +225,7 @@ func (sss *StagedStreamSync) RevertTo(revertPoint uint64, invalidBlockNumber uin
 		Interface("invalidBlockHash", invalidBlockHash).
 		Interface("invalidBlockStreamID", invalidBlockStreamID).
 		Uint64("revertPoint", revertPoint).
-		Msgf(WrapStagedSyncMsg("Reverting blocks"))
+		Msg(WrapStagedSyncMsg("Reverting blocks"))
 	sss.revertPoint = &revertPoint
 	if invalidBlockNumber > 0 || invalidBlockHash != (common.Hash{}) {
 		resetBadStreams := !sss.invalidBlock.Active
@@ -286,7 +286,7 @@ func (sss *StagedStreamSync) cleanUp(ctx context.Context, fromStage int, db kv.R
 		if err := sss.pruneStage(ctx, firstCycle, sss.pruningOrder[i], db, tx); err != nil {
 			sss.logger.Error().Err(err).
 				Interface("stage id", sss.pruningOrder[i].ID).
-				Msgf(WrapStagedSyncMsg("stage cleanup failed"))
+				Msg(WrapStagedSyncMsg("stage cleanup failed"))
 			panic(err)
 		}
 	}
@@ -431,7 +431,7 @@ func (sss *StagedStreamSync) Run(ctx context.Context, db kv.RwDB, tx kv.RwTx, fi
 						sss.logger.Error().
 							Err(err).
 							Interface("stage id", sss.revertOrder[j].ID).
-							Msgf(WrapStagedSyncMsg("revert stage failed"))
+							Msg(WrapStagedSyncMsg("revert stage failed"))
 						return err
 					}
 				}
@@ -446,7 +446,7 @@ func (sss *StagedStreamSync) Run(ctx context.Context, db kv.RwDB, tx kv.RwTx, fi
 
 		if stage.Disabled {
 			sss.logger.Trace().
-				Msgf(WrapStagedSyncMsg(fmt.Sprintf("%s disabled. %s", stage.ID, stage.DisabledDescription)))
+				Msg(WrapStagedSyncMsg(fmt.Sprintf("%s disabled. %s", stage.ID, stage.DisabledDescription)))
 
 			sss.NextStage()
 			continue
@@ -461,7 +461,7 @@ func (sss *StagedStreamSync) Run(ctx context.Context, db kv.RwDB, tx kv.RwTx, fi
 			sss.logger.Error().
 				Err(err).
 				Interface("stage id", stage.ID).
-				Msgf(WrapStagedSyncMsg("stage failed"))
+				Msg(WrapStagedSyncMsg("stage failed"))
 			return err
 		}
 		sss.NextStage()
@@ -470,7 +470,7 @@ func (sss *StagedStreamSync) Run(ctx context.Context, db kv.RwDB, tx kv.RwTx, fi
 	if err := sss.cleanUp(ctx, 0, db, tx, firstCycle); err != nil {
 		sss.logger.Error().
 			Err(err).
-			Msgf(WrapStagedSyncMsg("stages cleanup failed"))
+			Msg(WrapStagedSyncMsg("stages cleanup failed"))
 		return err
 	}
 	if err := sss.SetCurrentStage(sss.stages[0].ID); err != nil {
@@ -564,7 +564,7 @@ func printLogs(tx kv.RwTx, timings []Timing) error {
 	}
 	if len(logCtx) > 0 {
 		timingLog := fmt.Sprintf("Timings (slower than 50ms) %v", logCtx)
-		utils.Logger().Info().Msgf(WrapStagedSyncMsg(timingLog))
+		utils.Logger().Info().Msg(WrapStagedSyncMsg(timingLog))
 	}
 
 	if tx == nil {
@@ -582,7 +582,7 @@ func printLogs(tx kv.RwTx, timings []Timing) error {
 			bucketSizes = append(bucketSizes, bucket, ByteCount(sz))
 		}
 		utils.Logger().Info().
-			Msgf(WrapStagedSyncMsg(fmt.Sprintf("Tables %v", bucketSizes...)))
+			Msg(WrapStagedSyncMsg(fmt.Sprintf("Tables %v", bucketSizes...)))
 	}
 	tx.CollectMetrics()
 	return nil
@@ -599,15 +599,15 @@ func (sss *StagedStreamSync) runStage(ctx context.Context, stage *Stage, db kv.R
 		sss.logger.Error().
 			Err(err).
 			Interface("stage id", stage.ID).
-			Msgf(WrapStagedSyncMsg("stage failed"))
+			Msg(WrapStagedSyncMsg("stage failed"))
 		return fmt.Errorf("[%s] %w", sss.LogPrefix(), err)
 	}
 
 	took := time.Since(start)
 	if took > 60*time.Second {
 		logPrefix := sss.LogPrefix()
 		sss.logger.Info().
-			Msgf(WrapStagedSyncMsg(fmt.Sprintf("%s:  DONE in %d", logPrefix, took)))
+			Msg(WrapStagedSyncMsg(fmt.Sprintf("%s:  DONE in %d", logPrefix, took)))
 
 	}
 	sss.timings = append(sss.timings, Timing{stage: stage.ID, took: took})
@@ -641,7 +641,7 @@ func (sss *StagedStreamSync) revertStage(ctx context.Context, firstCycle bool, s
 	if took > 60*time.Second {
 		logPrefix := sss.LogPrefix()
 		sss.logger.Info().
-			Msgf(WrapStagedSyncMsg(fmt.Sprintf("%s: Revert done in %d", logPrefix, took)))
+			Msg(WrapStagedSyncMsg(fmt.Sprintf("%s: Revert done in %d", logPrefix, took)))
 	}
 	sss.timings = append(sss.timings, Timing{isRevert: true, stage: stage.ID, took: took})
 	return nil
@@ -673,7 +673,7 @@ func (sss *StagedStreamSync) pruneStage(ctx context.Context, firstCycle bool, st
 	if took > 60*time.Second {
 		logPrefix := sss.LogPrefix()
 		sss.logger.Info().
-			Msgf(WrapStagedSyncMsg(fmt.Sprintf("%s: CleanUp done in %d", logPrefix, took)))
+			Msg(WrapStagedSyncMsg(fmt.Sprintf("%s: CleanUp done in %d", logPrefix, took)))
 	}
 	sss.timings = append(sss.timings, Timing{isCleanUp: true, stage: stage.ID, took: took})
 	return nil

api/service/stagedstreamsync/syncing.go

@@ -450,7 +450,7 @@ func (s *StagedStreamSync) doSyncCycle(ctx context.Context) (int, error) {
 			Bool("isBeaconShard", s.isBeaconShard).
 			Uint32("shard", s.bc.ShardID()).
 			Uint64("currentHeight", startHead).
-			Msgf(WrapStagedSyncMsg("sync cycle failed"))
+			Msg(WrapStagedSyncMsg("sync cycle failed"))
 		return totalInserted, err
 	}
 

consensus/consensus.go

@@ -256,7 +256,7 @@ func (consensus *Consensus) getLeaderPrivateKey(leaderKey *bls_core.PublicKey) (
 			return &consensus.priKey[i], nil
 		}
 	}
-	return nil, errors.Wrapf(errLeaderPriKeyNotFound, leaderKey.SerializeToHexStr())
+	return nil, errors.Wrap(errLeaderPriKeyNotFound, leaderKey.SerializeToHexStr())
 }
 
 // getConsensusLeaderPrivateKey returns consensus leader private key if node is the leader