Method Chat.parseInput has a Cognitive Complexity of 94 (exceeds 20 allowed). Consider refactoring.

Open

func (c *Chat) parseInput() {
    defer c.wg.Done()
 
    var disconnectedPeers []peer.ID
 
 

• Read up
  Read up

Function Execute has a Cognitive Complexity of 91 (exceeds 20 allowed). Consider refactoring.

Open

func Execute(options NodeOptions) error {
    // Set encoding for logs (console, json, ...)
    // Note that libp2p reads the encoding from GOLOG_LOG_FMT env var.
    lvl, err := zapcore.ParseLevel(options.LogLevel)
    if err != nil {

• Read up
  Read up

Function Execute has 285 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func Execute(options NodeOptions) error {
    // Set encoding for logs (console, json, ...)
    // Note that libp2p reads the encoding from GOLOG_LOG_FMT env var.
    lvl, err := zapcore.ParseLevel(options.LogLevel)
    if err != nil {

Method Chat.parseInput has a Cognitive Complexity of 80 (exceeds 20 allowed). Consider refactoring.

Open

func (c *Chat) parseInput() {
    defer c.wg.Done()
    for {
        select {
        case <-c.ctx.Done():

• Read up
  Read up

Method WakuNode.startKeepAlive has a Cognitive Complexity of 79 (exceeds 20 allowed). Consider refactoring.

Open

func (w *WakuNode) startKeepAlive(ctx context.Context, randomPeersPingDuration time.Duration, allPeersPingDuration time.Duration) {
    defer utils.LogOnPanic()
    defer w.wg.Done()
 
    if !w.opts.enableRelay {

• Read up
  Read up

File wakunode2.go has 781 lines of code (exceeds 500 allowed). Consider refactoring.

Open

package node
 
import (
    "context"
    "math/rand"

Method MissingMessageVerifier.fetchMessagesBatch has a Cognitive Complexity of 63 (exceeds 20 allowed). Consider refactoring.

Open

func (m *MissingMessageVerifier) fetchMessagesBatch(c chan<- *protocol.Envelope, interest criteriaInterest, batchFrom int, batchTo int, now time.Time) error {
    contentTopics := interest.contentFilter.ContentTopics.ToList()
 
    logger := m.logger.With(
        zap.Stringer("peerID", interest.peerInfo.ID),

• Read up
  Read up

Function getFlags has 193 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func getFlags() []cli.Flag {
    // Defaults
    options.Fleet = fleetProd
 
    testCT, err := protocol.NewContentTopic("toy-chat", "3", "mingde", "proto")

Function getFlags has 193 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func getFlags() []cli.Flag {
    // Defaults
    options.Fleet = fleetProd
 
    testCT, err := protocol.NewContentTopic("toy-chat", "3", "mingde", "proto")

File client.go has 649 lines of code (exceeds 500 allowed). Consider refactoring.

Open

package filter
 
import (
    "context"
    "encoding/hex"

Function New has a Cognitive Complexity of 51 (exceeds 20 allowed). Consider refactoring.

Open

func New(opts ...WakuNodeOption) (*WakuNode, error) {
    var err error
    params := new(WakuNodeParameters)
    params.libP2POpts = DefaultLibP2POptions
 
 

• Read up
  Read up

WakuNode has 40 methods (exceeds 20 allowed). Consider refactoring.

Open

type WakuNode struct {
    host       host.Host
    opts       *WakuNodeParameters
    log        *zap.Logger
    timesource timesource.Timesource

Method HistoryRetriever.Query has a Cognitive Complexity of 48 (exceeds 20 allowed). Consider refactoring.

Open

func (hr *HistoryRetriever) Query(
    ctx context.Context,
    criteria store.FilterCriteria,
    storenode peer.AddrInfo,
    pageLimit uint64,

• Read up
  Read up

Function getStoreParams has a Cognitive Complexity of 47 (exceeds 20 allowed). Consider refactoring.

Open

func getStoreParams(r *http.Request) (store.Criteria, []store.RequestOption, error) {
    var options []store.RequestOption
    var err error
    peerAddrStr := r.URL.Query().Get("peerAddr")
    var m multiaddr.Multiaddr

• Read up
  Read up

Function New has 141 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func New(opts ...WakuNodeOption) (*WakuNode, error) {
    var err error
    params := new(WakuNodeParameters)
    params.libP2POpts = DefaultLibP2POptions
 
 

File peer_manager.go has 604 lines of code (exceeds 500 allowed). Consider refactoring.

Open

package peermanager
 
import (
    "context"
    "errors"

Method HistoryRetriever.Query has 134 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (hr *HistoryRetriever) Query(
    ctx context.Context,
    criteria store.FilterCriteria,
    storenode peer.AddrInfo,
    pageLimit uint64,

Function TestStoreClient has 134 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func TestStoreClient(t *testing.T) {
    ctx, cancel := context.WithTimeout(context.Background(), 60*time.Second)
    defer cancel()
 
    port, err := tests.FindFreePort(t, "", 5)

Method MessageSentCheck.Start has a Cognitive Complexity of 44 (exceeds 20 allowed). Consider refactoring.

Open

func (m *MessageSentCheck) Start() {
    defer utils.LogOnPanic()
    ticker := time.NewTicker(m.hashQueryInterval)
    defer ticker.Stop()
    for {

• Read up
  Read up

Function getLegacyStoreParams has a Cognitive Complexity of 43 (exceeds 20 allowed). Consider refactoring.

Open

func getLegacyStoreParams(r *http.Request) (*legacy_store.Query, []legacy_store.HistoryRequestOption, error) {
    query := &legacy_store.Query{}
    var options []legacy_store.HistoryRequestOption
    var err error
    peerAddrStr := r.URL.Query().Get("peerAddr")

• Read up
  Read up