Skip to content

Commit

Permalink
fix: apply new linters rules
Browse files Browse the repository at this point in the history
Signed-off-by: gfanton <8671905+gfanton@users.noreply.github.com>
  • Loading branch information
gfanton committed Dec 9, 2021
1 parent a43c19f commit 89fc4a1
Show file tree
Hide file tree
Showing 9 changed files with 22 additions and 22 deletions.
2 changes: 1 addition & 1 deletion go/cmd/berty/peers.go
Expand Up @@ -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)")
Expand Down
12 changes: 6 additions & 6 deletions go/cmd/rdvp/main.go
Expand Up @@ -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)
}
Expand Down Expand Up @@ -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)
}
Expand Down Expand Up @@ -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
},
}
Expand Down
4 changes: 2 additions & 2 deletions go/internal/grpcutil/lazy_client.go
Expand Up @@ -9,8 +9,8 @@ import (
)

var (
lazyCodec = NewLazyCodec()
streamids uint64 = 0
lazyCodec = NewLazyCodec()
streamids uint64
)

type LazyClient struct {
Expand Down
8 changes: 4 additions & 4 deletions go/internal/grpcutil/server.go
Expand Up @@ -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{
Expand Down
2 changes: 1 addition & 1 deletion go/internal/initutil/ipfs.go
Expand Up @@ -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
Expand Down
4 changes: 2 additions & 2 deletions go/internal/omnisearch/config.go
Expand Up @@ -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()
Expand Down
2 changes: 1 addition & 1 deletion go/pkg/bertymessenger/service.go
Expand Up @@ -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{
Expand Down
8 changes: 4 additions & 4 deletions go/pkg/bertyprotocol/api_event.go
Expand Up @@ -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
Expand Down Expand Up @@ -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
Expand Down
2 changes: 1 addition & 1 deletion go/pkg/tyber/format.go
Expand Up @@ -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 {
Expand Down

0 comments on commit 89fc4a1

Please sign in to comment.