Function execute has 89 lines of code (exceeds 50 allowed). Consider refactoring.

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 {

Method Chat.parseInput has 88 lines of code (exceeds 50 allowed). Consider refactoring.

Open

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

WakuRelay has 23 methods (exceeds 20 allowed). Consider refactoring.

Open

type WakuRelay struct {
    host                host.Host
    relayParams         *relayParameters
    pubsub              *pubsub.PubSub
    params              pubsub.GossipSubParams

Function Test500 has 86 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func Test500(t *testing.T) {
    maxMsgs := 500
    maxMsgBytes := int2Bytes(maxMsgs)
 
    ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)

Function getGossipSubParams has 86 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func getGossipSubParams(cfg *GossipSubParams) pubsub.GossipSubParams {
    params := pubsub.DefaultGossipSubParams()
 
    if cfg.D != nil {
        params.D = *cfg.D

Function getLegacyStoreParams has 85 lines of code (exceeds 50 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")

Function NewNode has a Cognitive Complexity of 32 (exceeds 20 allowed). Consider refactoring.

Open

func NewNode(instance *WakuInstance, configJSON string) error {
    if err := validateInstance(instance, NotConfigured); err != nil {
        return err
    }
 
 

• Read up
  Read up

Function main has 81 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func main() {
    hostAddr1, _ := net.ResolveTCPAddr("tcp", "0.0.0.0:60000")
    hostAddr2, _ := net.ResolveTCPAddr("tcp", "0.0.0.0:60001")
 
    key1, err := randomHex(32)

Function TestPairingObj1Success has 80 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func TestPairingObj1Success(t *testing.T) {
    host1, relay1 := createRelayNode(t)
    host2, relay2 := createRelayNode(t)
 
    defer host1.Close()

Method WakuFilterLightNode.Unsubscribe has 80 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (wf *WakuFilterLightNode) Unsubscribe(ctx context.Context, contentFilter protocol.ContentFilter, opts ...FilterSubscribeOption) (*WakuFilterPushResult, error) {
    wf.RLock()
    defer wf.RUnlock()
    if err := wf.ErrOnNotRunning(); err != nil {
        return nil, err

Chat has 21 methods (exceeds 20 allowed). Consider refactoring.

Open

func (c *Chat) initReliabilityProtocol() {
    c.wg.Add(4)
    c.setupMessageRequestHandler()
 
    go c.periodicBufferSweep()

WakuFilterLightNode has 21 methods (exceeds 20 allowed). Consider refactoring.

Open

type WakuFilterLightNode struct {
    *service.CommonService
    h                host.Host
    broadcaster      relay.Broadcaster //TODO: Move the broadcast functionality outside of relay client to a higher SDK layer.
    onlineChecker    onlinechecker.OnlineChecker

Method Pairing.initiatorHandshake has 79 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (p *Pairing) initiatorHandshake(ctx context.Context, msgCh <-chan *pb.WakuMessage) (doneCh chan error) {
    doneCh = make(chan error, 1)
 
    go func() {
        defer utils.LogOnPanic()

Method WakuFilterLightNode.Subscribe has 79 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (wf *WakuFilterLightNode) Subscribe(ctx context.Context, contentFilter protocol.ContentFilter, opts ...FilterSubscribeOption) ([]*subscription.SubscriptionDetails, error) {
    wf.RLock()
    defer wf.RUnlock()
    if err := wf.ErrOnNotRunning(); err != nil {
        return nil, err

Method UI.Update has 78 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (m UI) Update(msg tea.Msg) (tea.Model, tea.Cmd) {
    var (
        tiCmd tea.Cmd
        vpCmd tea.Cmd
    )

Method UI.Update has 78 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (m UI) Update(msg tea.Msg) (tea.Model, tea.Cmd) {
    var (
        tiCmd tea.Cmd
        vpCmd tea.Cmd
    )

Method onCreate has 53 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)
        setContentView(R.layout.activity_main)
 
        val lbl = findViewById<TextView>(R.id.lbl)

Function Test500 has a Cognitive Complexity of 31 (exceeds 20 allowed). Consider refactoring.

Open

func Test500(t *testing.T) {
    maxMsgs := 500
    maxMsgBytes := int2Bytes(maxMsgs)
 
    ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)

• Read up
  Read up

Function Execute has 23 return statements (exceeds 4 allowed).

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 {

Function execute has 77 lines of code (exceeds 50 allowed). Consider refactoring.

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 {