nuts-foundation/nuts-event-octopus

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

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

Open

type EventOctopus struct {
    Name       string
    Config     EventOctopusConfig
    configOnce sync.Once
    stanServer *natsServer.StanServer

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

Open

func (w *ServerInterfaceWrapper) GetEventByExternalId(ctx echo.Context) error {
    var err error
    // ------------- Path parameter "external_id" -------------
    var externalId string

• Read up
  Read up

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

Open

func (w *ServerInterfaceWrapper) GetEvent(ctx echo.Context) error {
    var err error
    // ------------- Path parameter "uuid" -------------
    var uuid string

• Read up
  Read up

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 {

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

Open

func (w Wrapper) GetEvent(ctx echo.Context, uuid string) error {
    event, err := w.Eo.GetEvent(uuid)

    if err != nil {
        return fmt.Errorf("Error while fetching event from DB: %v", err)

• Read up
  Read up

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

Open

func (w Wrapper) GetEventByExternalId(ctx echo.Context, externalId string) error {
    event, err := w.Eo.GetEventByExternalID(externalId)

    if err != nil {
        return fmt.Errorf("Error while fetching event from DB: %v", err)

• Read up
  Read up

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

Open

func (octopus *EventOctopus) GetEvent(uuid string) (*Event, error) {
    event := &Event{}

    err := octopus.Db.Debug().Where("uuid = ?", uuid).First(&event).Error

• Read up
  Read up

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

Open

func (octopus *EventOctopus) GetEventByExternalID(externalID string) (*Event, error) {
    event := &Event{}

    err := octopus.Db.Debug().Where("external_id = ?", externalID).First(&event).Error

• Read up
  Read up

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 {

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 {

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

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

Open

func _1_create_table_eventUpSql() (*asset, error) {
    bytes, err := _1_create_table_eventUpSqlBytes()
    if err != nil {
        return nil, err
    }

• Read up
  Read up

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

Open

func _1_create_table_eventDownSql() (*asset, error) {
    bytes, err := _1_create_table_eventDownSqlBytes()
    if err != nil {
        return nil, err
    }

• Read up
  Read up

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

Open

func bindataGo() (*asset, error) {
    bytes, err := bindataGoBytes()
    if err != nil {
        return nil, err
    }

• Read up
  Read up

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
    }

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

Open

func (octopus *EventOctopus) configure() error {
    var (
        err error
    )

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(),