diff --git a/go/cmd/berty/peers.go b/go/cmd/berty/peers.go index ddf9f21f11..17230d14c0 100644 --- a/go/cmd/berty/peers.go +++ b/go/cmd/berty/peers.go @@ -14,7 +14,7 @@ import ( ) func peersCommand() *ffcli.Command { - var refreshEveryFlag time.Duration = time.Second + refreshEveryFlag := time.Second fsBuilder := func() (*flag.FlagSet, error) { fs := flag.NewFlagSet("peers", flag.ExitOnError) fs.String("config", "", "config file (optional)") diff --git a/go/cmd/rdvp/main.go b/go/cmd/rdvp/main.go index 0846860ba4..e50e60468e 100644 --- a/go/cmd/rdvp/main.go +++ b/go/cmd/rdvp/main.go @@ -124,11 +124,11 @@ func main() { // load existing or generate new identity var priv libp2p_ci.PrivKey if servePK != "" { - kBytes, err := base64.StdEncoding.DecodeString(servePK) + kbytes, err := base64.StdEncoding.DecodeString(servePK) if err != nil { return errcode.TODO.Wrap(err) } - priv, err = libp2p_ci.UnmarshalPrivateKey(kBytes) + priv, err = libp2p_ci.UnmarshalPrivateKey(kbytes) if err != nil { return errcode.TODO.Wrap(err) } @@ -243,11 +243,11 @@ func main() { return flag.ErrHelp } - kBytes, err := base64.StdEncoding.DecodeString(sharekeyPK) + kbytes, err := base64.StdEncoding.DecodeString(sharekeyPK) if err != nil { return errcode.TODO.Wrap(err) } - priv, err := libp2p_ci.UnmarshalPrivateKey(kBytes) + priv, err := libp2p_ci.UnmarshalPrivateKey(kbytes) if err != nil { return errcode.TODO.Wrap(err) } @@ -278,12 +278,12 @@ func main() { return errcode.TODO.Wrap(err) } - kBytes, err := libp2p_ci.MarshalPrivateKey(priv) + kbytes, err := libp2p_ci.MarshalPrivateKey(priv) if err != nil { return errcode.TODO.Wrap(err) } - fmt.Println(base64.StdEncoding.EncodeToString(kBytes)) + fmt.Println(base64.StdEncoding.EncodeToString(kbytes)) return nil }, } diff --git a/go/internal/grpcutil/lazy_client.go b/go/internal/grpcutil/lazy_client.go index c77fc53c20..d0308852c9 100644 --- a/go/internal/grpcutil/lazy_client.go +++ b/go/internal/grpcutil/lazy_client.go @@ -9,8 +9,8 @@ import ( ) var ( - lazyCodec = NewLazyCodec() - streamids uint64 = 0 + lazyCodec = NewLazyCodec() + streamids uint64 ) type LazyClient struct { diff --git a/go/internal/grpcutil/server.go b/go/internal/grpcutil/server.go index 7feb8e40ca..c9ae110896 100644 --- a/go/internal/grpcutil/server.go +++ b/go/internal/grpcutil/server.go @@ -16,10 +16,10 @@ import ( const BertyCustomPrefix = 0xbe00 const ( - P_GRPC = BertyCustomPrefix + 0x0002 //nolint:golint - P_GRPC_WEB = BertyCustomPrefix + 0x0004 //nolint:golint - P_GRPC_WEBSOCKET = BertyCustomPrefix + 0x0008 //nolint:golint - P_GRPC_GATEWAY = BertyCustomPrefix + 0x0016 //nolint:golint + P_GRPC = BertyCustomPrefix + 0x0002 //nolint:revive + P_GRPC_WEB = BertyCustomPrefix + 0x0004 //nolint:revive + P_GRPC_WEBSOCKET = BertyCustomPrefix + 0x0008 //nolint:revive + P_GRPC_GATEWAY = BertyCustomPrefix + 0x0016 //nolint:revive ) var protos = []ma.Protocol{ diff --git a/go/internal/initutil/ipfs.go b/go/internal/initutil/ipfs.go index 42d0a93872..c9ea50cf56 100644 --- a/go/internal/initutil/ipfs.go +++ b/go/internal/initutil/ipfs.go @@ -167,7 +167,7 @@ func (m *Manager) getLocalIPFS() (ipfsutil.ExtendedCoreAPI, *ipfs_core.IpfsNode, return nil, nil, errcode.ErrIPFSInit.Wrap(err) } - var dhtmode p2p_dht.ModeOpt = 0 + var dhtmode p2p_dht.ModeOpt switch m.Node.Protocol.DHT { case FlagValueP2PDHTClient: dhtmode = p2p_dht.ModeClient diff --git a/go/internal/omnisearch/config.go b/go/internal/omnisearch/config.go index ef80ade190..9d632b1b17 100644 --- a/go/internal/omnisearch/config.go +++ b/go/internal/omnisearch/config.go @@ -17,8 +17,8 @@ func (c *coordinatorConfig) usingConstructorMake(constructor interface{}, target if typ.Kind() != reflect.Func { return nil, fmt.Errorf("got a %s", typ.Name()) } - var iTgt int = -1 - var iError int = -1 + iTgt := -1 + iError := -1 // Finding the index of the returns we want. { i := typ.NumOut() diff --git a/go/pkg/bertymessenger/service.go b/go/pkg/bertymessenger/service.go index 0b6b334d8e..a54cd31830 100644 --- a/go/pkg/bertymessenger/service.go +++ b/go/pkg/bertymessenger/service.go @@ -457,7 +457,7 @@ func (svc *service) subscribeToMessages(tctx context.Context, gpkb []byte) error return nil } -var monitorCounter uint64 = 0 +var monitorCounter uint64 func (svc *service) subscribeToGroupMonitor(groupPK []byte) error { cl, err := svc.protocolClient.MonitorGroup(svc.ctx, &protocoltypes.MonitorGroup_Request{ diff --git a/go/pkg/bertyprotocol/api_event.go b/go/pkg/bertyprotocol/api_event.go index debdb4052f..ea6bcdc486 100644 --- a/go/pkg/bertyprotocol/api_event.go +++ b/go/pkg/bertyprotocol/api_event.go @@ -36,8 +36,8 @@ func checkParametersConsistency(sinceID, untilID []byte, sinceNow, untilNow, rev func (s *service) GroupMetadataList(req *protocoltypes.GroupMetadataList_Request, sub protocoltypes.ProtocolService_GroupMetadataListServer) error { var ( newEvents <-chan events.Event - sentEvents = map[string]bool{} - firstReplicatedFound bool = true + sentEvents = map[string]bool{} + firstReplicatedFound = true ) // Get group context / check if the group is opened @@ -131,8 +131,8 @@ func (s *service) GroupMetadataList(req *protocoltypes.GroupMetadataList_Request func (s *service) GroupMessageList(req *protocoltypes.GroupMessageList_Request, sub protocoltypes.ProtocolService_GroupMessageListServer) error { var ( newEvents <-chan events.Event - sentEvents = map[string]bool{} - firstReplicatedFound bool = true + sentEvents = map[string]bool{} + firstReplicatedFound = true ) // Get group context / check if the group is opened diff --git a/go/pkg/tyber/format.go b/go/pkg/tyber/format.go index 21c097be3e..cba42952cc 100644 --- a/go/pkg/tyber/format.go +++ b/go/pkg/tyber/format.go @@ -49,7 +49,7 @@ const ( SubscribeType LogType = "subcribe" ) -var KnownLogTypes []LogType = []LogType{TraceType, StepType, EventType, SubscribeType} +var KnownLogTypes = []LogType{TraceType, StepType, EventType, SubscribeType} func (lt LogType) IsKnown() bool { for _, vlt := range KnownLogTypes {