apply gofumpt formatter

api/gateway/bindings_test.go

@@ -109,7 +109,6 @@ func hasEndpointRegistered(router *mux.Router, path string, method string) bool
 		}
 		return nil
 	})
-
 	if err != nil {
 		fmt.Println("Error walking through routes:", err)
 		return false

api/gateway/header.go

@@ -15,9 +15,7 @@ const (
 	headerByHeightEndpoint = "/header"
 )
 
-var (
-	heightKey = "height"
-)
+var heightKey = "height"
 
 func (h *Handler) handleHeadRequest(w http.ResponseWriter, r *http.Request) {
 	head, err := h.header.LocalHead(r.Context())

api/rpc_test.go

@@ -139,7 +139,7 @@ func TestAuthedRPC(t *testing.T) {
 	adminToken, err := perms.NewTokenWithPerms(signer, perms.AllPerms)
 	require.NoError(t, err)
 
-	var tests = []struct {
+	tests := []struct {
 		perm  int
 		token string
 	}{
@@ -280,7 +280,6 @@ func implementsMarshaler(t *testing.T, typ reflect.Type) {
 	default:
 		return
 	}
-
 }
 
 // setupNodeWithAuthedRPC sets up a node and overrides its JWT

blob/blob_test.go

@@ -19,7 +19,7 @@ func TestBlob(t *testing.T) {
 	blob, err := convertBlobs(appBlobs...)
 	require.NoError(t, err)
 
-	var test = []struct {
+	test := []struct {
 		name        string
 		expectedRes func(t *testing.T)
 	}{

blob/parser.go

@@ -20,7 +20,8 @@ type parser struct {
 	verifyFn func(blob *Blob) bool
 }
 
-// NOTE: passing shares here needed to detect padding shares(as we do not need this check in addShares)
+// NOTE: passing shares here needed to detect padding shares(as we do not need this check in
+// addShares)
 func (p *parser) set(index int, shrs []shares.Share) ([]shares.Share, error) {
 	if len(shrs) == 0 {
 		return nil, errEmptyShares

blob/service_test.go

@@ -49,7 +49,7 @@ func TestBlobService_Get(t *testing.T) {
 	require.NoError(t, err)
 
 	service := createService(ctx, t, append(blobs0, blobs1...))
-	var test = []struct {
+	test := []struct {
 		name           string
 		doFn           func() (interface{}, error)
 		expectedResult func(interface{}, error)
@@ -305,7 +305,6 @@ func TestBlobService_Get(t *testing.T) {
 				assert.Empty(t, blobs)
 				require.Error(t, err)
 				require.ErrorIs(t, err, ErrBlobNotFound)
-
 			},
 		},
 		{

cmd/auth.go

@@ -20,7 +20,7 @@ import (
 )
 
 func AuthCmd(fsets ...*flag.FlagSet) *cobra.Command {
-	var cmd = &cobra.Command{
+	cmd := &cobra.Command{
 		Use:   "auth [permission-level (e.g. read || write || admin)]",
 		Short: "Signs and outputs a hex-encoded JWT token with the given permissions.",
 		Long: "Signs and outputs a hex-encoded JWT token with the given permissions. NOTE: only use this command when " +
@@ -37,7 +37,6 @@ func AuthCmd(fsets ...*flag.FlagSet) *cobra.Command {
 			ks, err := newKeystore(StorePath(cmd.Context()))
 			if err != nil {
 				return err
-
 			}
 
 			key, err := ks.Get(nodemod.SecretName)

core/fetcher.go

@@ -103,7 +103,7 @@ func (f *BlockFetcher) Commit(ctx context.Context, height *int64) (*types.Commit
 // ValidatorSet queries Core for the ValidatorSet from the
 // block at the given height.
 func (f *BlockFetcher) ValidatorSet(ctx context.Context, height *int64) (*types.ValidatorSet, error) {
-	var perPage = 100
+	perPage := 100
 
 	vals, total := make([]*types.Validator, 0), -1
 	for page := 1; len(vals) != total; page++ {

core/listener.go

@@ -248,7 +248,7 @@ func (cl *Listener) handleNewSignedBlock(ctx context.Context, b types.EventDataS
 		if err != nil && !errors.Is(err, context.Canceled) {
 			log.Errorw("listener: broadcasting data hash",
 				"height", b.Header.Height,
-				"hash", b.Header.Hash(), "err", err) //TODO: hash or datahash?
+				"hash", b.Header.Hash(), "err", err) // TODO: hash or datahash?
 		}
 	}
 

core/listener_test.go

@@ -128,7 +128,6 @@ func TestListener_DoesNotStoreHistoric(t *testing.T) {
 		require.NoError(t, err)
 		assert.False(t, has)
 	}
-
 }
 
 func createMocknetWithTwoPubsubEndpoints(ctx context.Context, t *testing.T) (*pubsub.PubSub, *pubsub.PubSub) {

das/backoff_test.go

@@ -30,7 +30,8 @@ func Test_exponentialBackoff(t *testing.T) {
 				4 * time.Minute,
 				16 * time.Minute,
 				64 * time.Minute,
-			}},
+			},
+		},
 	}
 	for _, tt := range tests {
 		t.Run(tt.name, func(t *testing.T) {

das/daser.go

@@ -39,8 +39,10 @@ type DASer struct {
 	running        int32
 }
 
-type listenFn func(context.Context, *header.ExtendedHeader)
-type sampleFn func(context.Context, *header.ExtendedHeader) error
+type (
+	listenFn func(context.Context, *header.ExtendedHeader)
+	sampleFn func(context.Context, *header.ExtendedHeader) error
+)
 
 // NewDASer creates a new DASer.
 func NewDASer(

das/daser_test.go

@@ -263,7 +263,7 @@ func TestDASer_SamplingWindow(t *testing.T) {
 		WithSamplingWindow(time.Second))
 	require.NoError(t, err)
 
-	var tests = []struct {
+	tests := []struct {
 		timestamp    time.Time
 		withinWindow bool
 	}{
@@ -282,7 +282,6 @@ func TestDASer_SamplingWindow(t *testing.T) {
 			assert.Equal(t, tt.withinWindow, daser.isWithinSamplingWindow(eh))
 		})
 	}
-
 }
 
 // createDASerSubcomponents takes numGetter (number of headers
@@ -403,7 +402,8 @@ type benchGetterStub struct {
 
 func newBenchGetter() benchGetterStub {
 	return benchGetterStub{header: &header.ExtendedHeader{
-		DAH: &share.Root{RowRoots: make([][]byte, 0)}}}
+		DAH: &share.Root{RowRoots: make([][]byte, 0)},
+	}}
 }
 
 func (m benchGetterStub) GetByHeight(context.Context, uint64) (*header.ExtendedHeader, error) {
@@ -423,7 +423,8 @@ func (m getterStub) GetByHeight(_ context.Context, height uint64) (*header.Exten
 	return &header.ExtendedHeader{
 		Commit:    &types.Commit{},
 		RawHeader: header.RawHeader{Height: int64(height)},
-		DAH:       &share.Root{RowRoots: make([][]byte, 0)}}, nil
+		DAH:       &share.Root{RowRoots: make([][]byte, 0)},
+	}, nil
 }
 
 func (m getterStub) GetRangeByHeight(

das/store.go

@@ -27,7 +27,8 @@ type checkpointStore struct {
 func newCheckpointStore(ds datastore.Datastore) checkpointStore {
 	return checkpointStore{
 		namespace.Wrap(ds, storePrefix),
-		newDone("checkpoint store")}
+		newDone("checkpoint store"),
+	}
 }
 
 // load loads the DAS checkpoint from disk and returns it.
@@ -65,7 +66,8 @@ func (s *checkpointStore) store(ctx context.Context, cp checkpoint) error {
 func (s *checkpointStore) runBackgroundStore(
 	ctx context.Context,
 	storeInterval time.Duration,
-	getCheckpoint func(ctx context.Context) (checkpoint, error)) {
+	getCheckpoint func(ctx context.Context) (checkpoint, error),
+) {
 	defer s.indicateDone()
 
 	// runBackgroundStore could be disabled by setting storeInterval = 0

header/headertest/fraud/testing.go

@@ -85,6 +85,7 @@ func (f *FraudMaker) MakeExtendedHeader(odsSize int, edsStore *eds.Store) header
 		return header.MakeExtendedHeader(h, comm, vals, eds)
 	}
 }
+
 func CreateFraudExtHeader(
 	t *testing.T,
 	eh *header.ExtendedHeader,

header/headertest/testing.go

@@ -94,7 +94,6 @@ func MakeCommit(
 	blockID types.BlockID, height int64, round int32,
 	voteSet *types.VoteSet, validators []types.PrivValidator, now time.Time,
 ) (*types.Commit, error) {
-
 	// all sign
 	for i := 0; i < len(validators); i++ {
 		pubKey, err := validators[i].GetPubKey()

libs/keystore/fs_keystore.go

@@ -24,7 +24,7 @@ type fsKeystore struct {
 // NewFSKeystore creates a new Keystore over OS filesystem.
 // The path must point to a directory. It is created automatically if necessary.
 func NewFSKeystore(path string, ring keyring.Keyring) (Keystore, error) {
-	err := os.Mkdir(path, 0755)
+	err := os.Mkdir(path, 0o755)
 	if err != nil && !os.IsExist(err) {
 		return nil, fmt.Errorf("keystore: failed to make a dir: %w", err)
 	}
@@ -49,7 +49,7 @@ func (f *fsKeystore) Put(n KeyName, pk PrivKey) error {
 		return fmt.Errorf("keystore: failed to marshal key '%s': %w", n, err)
 	}
 
-	err = os.WriteFile(path, data, 0600)
+	err = os.WriteFile(path, data, 0o600)
 	if err != nil {
 		return fmt.Errorf("keystore: failed to write key '%s': %w", n, err)
 	}
@@ -138,7 +138,7 @@ func (f *fsKeystore) pathTo(file string) string {
 }
 
 func checkPerms(perms os.FileMode) error {
-	if perms&0077 != 0 {
+	if perms&0o077 != 0 {
 		return fmt.Errorf("required: 0600, got: %#o", perms)
 	}
 	return nil

libs/utils/address_test.go

@@ -8,7 +8,7 @@ import (
 )
 
 func TestSanitizeAddr(t *testing.T) {
-	var tests = []struct {
+	tests := []struct {
 		addr string
 		want string
 		err  error
@@ -39,7 +39,7 @@ func TestValidateAddr(t *testing.T) {
 		addr       string
 		unresolved bool
 	}
-	var tests = []struct {
+	tests := []struct {
 		addr string
 		want want
 	}{

nodebuilder/init.go

@@ -146,7 +146,7 @@ func IsInit(path string) bool {
 	return false
 }
 
-const perms = 0755
+const perms = 0o755
 
 // initRoot initializes(creates) directory if not created and check if it is writable
 func initRoot(path string) error {

nodebuilder/node_test.go

@@ -21,7 +21,7 @@ import (
 )
 
 func TestLifecycle(t *testing.T) {
-	var test = []struct {
+	test := []struct {
 		tp node.Type
 	}{
 		{tp: node.Bridge},
@@ -58,7 +58,7 @@ func TestLifecycle_WithMetrics(t *testing.T) {
 
 	otelCollectorURL := strings.ReplaceAll(url, "http://", "")
 
-	var test = []struct {
+	test := []struct {
 		tp           node.Type
 		coreExpected bool
 	}{
@@ -130,7 +130,7 @@ func TestEmptyBlockExists(t *testing.T) {
 	ctx, cancel := context.WithCancel(context.Background())
 	defer cancel()
 
-	var test = []struct {
+	test := []struct {
 		tp node.Type
 	}{
 		{tp: node.Bridge},
@@ -155,5 +155,4 @@ func TestEmptyBlockExists(t *testing.T) {
 			require.NoError(t, err)
 		})
 	}
-
 }

nodebuilder/p2p/flags_test.go

@@ -79,12 +79,10 @@ func TestParseNetwork_emptyFlag(t *testing.T) {
 
 	_, err = ParseNetwork(cmd)
 	assert.Error(t, err)
-
 }
 
 // Set empty network flag and ensure error returned
 func TestParseNetwork_emptyEnvEmptyFlag(t *testing.T) {
-
 	t.Setenv(EnvCustomNetwork, "")
 
 	cmd := createCmdWithNetworkFlag()
@@ -93,12 +91,10 @@ func TestParseNetwork_emptyEnvEmptyFlag(t *testing.T) {
 
 	_, err = ParseNetwork(cmd)
 	require.Error(t, err)
-
 }
 
 // Env overrides empty flag to take precedence
 func TestParseNetwork_envOverridesEmptyFlag(t *testing.T) {
-
 	t.Setenv(EnvCustomNetwork, "custom-network")
 
 	cmd := createCmdWithNetworkFlag()
@@ -108,12 +104,10 @@ func TestParseNetwork_envOverridesEmptyFlag(t *testing.T) {
 	network, err := ParseNetwork(cmd)
 	require.NoError(t, err)
 	assert.Equal(t, Network("custom-network"), network)
-
 }
 
 // Explicitly set flag but env should still override
 func TestParseNetwork_envOverridesFlag(t *testing.T) {
-
 	t.Setenv(EnvCustomNetwork, "custom-network")
 
 	cmd := createCmdWithNetworkFlag()
@@ -123,5 +117,4 @@ func TestParseNetwork_envOverridesFlag(t *testing.T) {
 	network, err := ParseNetwork(cmd)
 	require.NoError(t, err)
 	assert.Equal(t, Network("custom-network"), network)
-
 }

nodebuilder/p2p/module_test.go

@@ -31,7 +31,7 @@ func testModule(tp node.Type) fx.Option {
 }
 
 func TestModuleBuild(t *testing.T) {
-	var test = []struct {
+	test := []struct {
 		tp node.Type
 	}{
 		{tp: node.Bridge},
@@ -49,7 +49,7 @@ func TestModuleBuild(t *testing.T) {
 }
 
 func TestModuleBuild_WithMetrics(t *testing.T) {
-	var test = []struct {
+	test := []struct {
 		tp node.Type
 	}{
 		{tp: node.Full},

nodebuilder/share/cmd/share.go

@@ -42,7 +42,6 @@ var sharesAvailableCmd = &cobra.Command{
 		defer client.Close()
 
 		eh, err := getExtendedHeaderFromCmdArg(cmd.Context(), client, args[0])
-
 		if err != nil {
 			return err
 		}
@@ -80,7 +79,6 @@ var getSharesByNamespaceCmd = &cobra.Command{
 		defer client.Close()
 
 		eh, err := getExtendedHeaderFromCmdArg(cmd.Context(), client, args[0])
-
 		if err != nil {
 			return err
 		}
@@ -107,7 +105,6 @@ var getShare = &cobra.Command{
 		defer client.Close()
 
 		eh, err := getExtendedHeaderFromCmdArg(cmd.Context(), client, args[0])
-
 		if err != nil {
 			return err
 		}
@@ -156,7 +153,6 @@ var getEDS = &cobra.Command{
 		defer client.Close()
 
 		eh, err := getExtendedHeaderFromCmdArg(cmd.Context(), client, args[0])
-
 		if err != nil {
 			return err
 		}