waku-org/go-waku

Identical blocks of code found in 2 locations. Consider refactoring.

Open

func (m UI) View() string {
    spinnerStr := ""
    inputStr := ""
    if m.isSending {
        spinnerStr = m.spinner.View() + " Sending message..."

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

                lbl.text =
                    (lbl.text.toString() + ">>> Protocols: " + it.protocols.joinToString(",") + "\n")

• Read up
  Read up

Function NewDiscoveryV5 has 6 arguments (exceeds 4 allowed). Consider refactoring.

Open

func NewDiscoveryV5(priv *ecdsa.PrivateKey, localnode *enode.LocalNode, peerConnector PeerConnector, reg prometheus.Registerer, log *zap.Logger, opts ...DiscoveryV5Option) (*DiscoveryV5, error) {

Method HistoryRetriever.Query has 7 return statements (exceeds 4 allowed).

Open

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

Avoid deeply nested control flow statements.

Open

                            if err != nil {
                                c.ui.ErrorMessage(err)
                                return
                            }

Avoid deeply nested control flow statements.

Open

                            if err != nil {
                                c.ui.ErrorMessage(err)
                                return
                            }

Avoid deeply nested control flow statements.

Open

                if err := pm.metadata.DisconnectPeerOnShardMismatch(ctx, peerEvt.PeerID); err != nil {
                    return
                }

Function NewPeerManager has 6 arguments (exceeds 4 allowed). Consider refactoring.

Open

func NewPeerManager(maxConnections int, maxPeers int, metadata *metadata.WakuMetadata, relay *relay.WakuRelay, relayEnabled bool, logger *zap.Logger) *PeerManager {

Function computeOffset has 7 return statements (exceeds 4 allowed).

Open

func computeOffset(timeQuery ntpQuery, servers []string, allowedFailures int) (time.Duration, error) {
    if len(servers) == 0 {
        return 0, nil
    }
    responses := make(chan queryResponse, len(servers))

Function execute has 7 return statements (exceeds 4 allowed).

Open

func execute(options Options) {
    var err error
    hostAddr, _ := net.ResolveTCPAddr("tcp", fmt.Sprintf("0.0.0.0:%d", options.Port))

    if options.NodeKey == nil {

Function NewLocalnode has 6 arguments (exceeds 4 allowed). Consider refactoring.

Open

func NewLocalnode(priv *ecdsa.PrivateKey, ipAddr *net.TCPAddr, udpPort int, wakuFlags wenr.WakuEnrBitfield, advertiseAddr *net.IP, log *zap.Logger) (*enode.LocalNode, error) {

Avoid deeply nested control flow statements.

Open

                    if prevNodeVal == "" {
                        w.log.Info("local node enr record", logging.ENode("enr", w.localNode.Node()))
                    } else {
                        w.log.Info("local node new enr record", logging.ENode("enr", w.localNode.Node()))
                    }

Method StaticShardingPubsubTopic.Parse has 7 return statements (exceeds 4 allowed).

Open

func (s *StaticShardingPubsubTopic) Parse(topic string) error {
    if !strings.HasPrefix(topic, StaticShardingPubsubTopicPrefix) {
        return ErrInvalidShardedTopicPrefix
    }

Method HistoryRetriever.Query has 6 arguments (exceeds 4 allowed). Consider refactoring.

Open

    ctx context.Context,
    criteria store.FilterCriteria,
    storenodeID peer.ID,
    pageLimit uint64,
    shouldProcessNextPage func(int) (bool, uint64),

Avoid deeply nested control flow statements.

Open

                    if peerLen > len(relayPeers) {
                        peerLen = len(relayPeers)
                    }

Method HistoryRetriever.requestStoreMessages has 6 arguments (exceeds 4 allowed). Consider refactoring.

Open

func (hr *HistoryRetriever) requestStoreMessages(ctx context.Context, peerID peer.ID, criteria store.FilterCriteria, cursor []byte, limit uint64, processEnvelopes bool) ([]byte, int, error) {

Method WakuNode.AddDiscoveredPeer has 6 arguments (exceeds 4 allowed). Consider refactoring.

Open

func (w *WakuNode) AddDiscoveredPeer(ID peer.ID, addrs []ma.Multiaddr, origin wps.Origin, pubsubTopics []string, enr *enode.Node, connectNow bool) {

Function NewFilterManager has 6 arguments (exceeds 4 allowed). Consider refactoring.

Open

func NewFilterManager(ctx context.Context, logger *zap.Logger, minPeersPerFilter int, envProcessor EnevelopeProcessor, node *filter.WakuFilterLightNode, opts ...SubscribeOptions) *FilterManager {

Avoid deeply nested control flow statements.

Open

                            if _, ok := meshPeersSet[p]; !ok {
                                relayPeersSet[p] = struct{}{}
                            }

Function Subscribe has 6 arguments (exceeds 4 allowed). Consider refactoring.

Open

func Subscribe(ctx context.Context, wf *filter.WakuFilterLightNode, contentFilter protocol.ContentFilter, config FilterConfig, log *zap.Logger, params *subscribeParameters) (*Sub, error) {