nuts-foundation/nuts-event-octopus

View on GitHub

Showing 9 of 18 total issues

File events.go has 538 lines of code (exceeds 500 allowed). Consider refactoring.
Open

/*
 * Nuts event octopus
 * Copyright (C) 2019. Nuts community
 *
 * This program is free software: you can redistribute it and/or modify
Severity: Minor
Found in pkg/events.go - About 2 hrs to fix

    EventOctopus has 23 methods (exceeds 20 allowed). Consider refactoring.
    Open

    type EventOctopus struct {
        Name       string
        Config     EventOctopusConfig
        configOnce sync.Once
        stanServer *natsServer.StanServer
    Severity: Minor
    Found in pkg/events.go - About 2 hrs to fix

      Method EventOctopus.startSubscribers has 56 lines of code (exceeds 50 allowed). Consider refactoring.
      Open

      func (octopus *EventOctopus) startSubscribers() error {
          logrus.Tracef("Connecting to Stan-Streaming server @ nats://localhost:%d", octopus.Config.NatsPort)
      
          sc, err := octopus.client(ClientID)
          if err != nil {
      Severity: Minor
      Found in pkg/events.go - About 1 hr to fix

        Method EventOctopus.startSubscribers has 8 return statements (exceeds 4 allowed).
        Open

        func (octopus *EventOctopus) startSubscribers() error {
            logrus.Tracef("Connecting to Stan-Streaming server @ nats://localhost:%d", octopus.Config.NatsPort)
        
            sc, err := octopus.client(ClientID)
            if err != nil {
        Severity: Major
        Found in pkg/events.go - About 50 mins to fix

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

          func NewDelayedConsumerSet(consumeSubject string, publishSubject string, count int, interval time.Duration, exponent int, conn stan.Conn) []*DelayedConsumer {
          Severity: Minor
          Found in pkg/retry.go - About 45 mins to fix

            Method EventOctopus.Start has 7 return statements (exceeds 4 allowed).
            Open

            func (octopus *EventOctopus) Start() error {
                var err error
            
                if octopus.Config.GetMode() != core.ServerEngineMode {
                    return nil
            Severity: Major
            Found in pkg/events.go - About 45 mins to fix

              Function RestoreAsset has 6 return statements (exceeds 4 allowed).
              Open

              func RestoreAsset(dir, name string) error {
                  data, err := Asset(name)
                  if err != nil {
                      return err
                  }
              Severity: Major
              Found in migrations/bindata.go - About 40 mins to fix

                Method EventOctopus.configure has 5 return statements (exceeds 4 allowed).
                Open

                func (octopus *EventOctopus) configure() error {
                    var (
                        err error
                    )
                
                
                Severity: Major
                Found in pkg/events.go - About 35 mins to fix

                  Method EventOctopus.RunMigrations has 5 return statements (exceeds 4 allowed).
                  Open

                  func (octopus *EventOctopus) RunMigrations(db *sql.DB) error {
                      driver, err := sqlite3.WithInstance(db, &sqlite3.Config{})
                  
                      // wrap assets into Resource
                      s := bindata.Resource(migrations.AssetNames(),
                  Severity: Major
                  Found in pkg/events.go - About 35 mins to fix
                    Severity
                    Category
                    Status
                    Source
                    Language