moleculer-go/moleculer

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

Open

func chainStarted(service moleculer.ServiceSchema, mixin *moleculer.Mixin) moleculer.ServiceSchema {
    if mixin.Started != nil {
        svcHook := service.Started
        mixinHook := mixin.Started
        service.Started = func(ctx moleculer.BrokerContext, svc moleculer.ServiceSchema) {

• Read up
  Read up

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

Open

func chainStopped(service moleculer.ServiceSchema, mixin *moleculer.Mixin) moleculer.ServiceSchema {
    if mixin.Stopped != nil {
        svcHook := service.Stopped
        mixinHook := mixin.Stopped
        service.Stopped = func(ctx moleculer.BrokerContext, svc moleculer.ServiceSchema) {

• Read up
  Read up

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

Open

    mapTransformer{
        "map[string]string",
        func(source *interface{}) map[string]interface{} {
            result := make(map[string]interface{}, len((*source).(map[string]string)))
            for key, value := range (*source).(map[string]string) {

• Read up
  Read up

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

Open

    mapTransformer{
        "map[string]float64",
        func(source *interface{}) map[string]interface{} {
            result := make(map[string]interface{}, len((*source).(map[string]float64)))
            for key, value := range (*source).(map[string]float64) {

• Read up
  Read up

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

Open

    mapTransformer{
        "map[string]int64",
        func(source *interface{}) map[string]interface{} {
            result := make(map[string]interface{}, len((*source).(map[string]int64)))
            for key, value := range (*source).(map[string]int64) {

• Read up
  Read up

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

Open

    mapTransformer{
        "map[string]uint64",
        func(source *interface{}) map[string]interface{} {
            result := make(map[string]interface{}, len((*source).(map[string]uint64)))
            for key, value := range (*source).(map[string]uint64) {

• Read up
  Read up

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

Open

func (broker *ServiceBroker) Emit(event string, params interface{}, groups ...string) {
    broker.logger.Trace("Broker - Emit() event: ", event, " params: ", params, " groups: ", groups)
    if !broker.IsStarted() {
        panic(errors.New("Broker must be started before emiting events :("))
    }

• Read up
  Read up

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

Open

func (broker *ServiceBroker) Broadcast(event string, params interface{}, groups ...string) {
    broker.logger.Trace("Broker - Broadcast() event: ", event, " params: ", params, " groups: ", groups)
    if !broker.IsStarted() {
        panic(errors.New("Broker must be started before broadcasting events :("))
    }

• Read up
  Read up

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

Open

        if item.Kind() == reflect.Map {
            mt := MapTransformer(&value)
            result[key] = mt.AsMap(&value)
        } else if item.Kind() == reflect.Array || item.Kind() == reflect.Slice {
            at := ArrayTransformer(&value)

• Read up
  Read up

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

Open

        if item.Kind() == reflect.Map {
            mt := MapTransformer(&value)
            result[i] = mt.AsMap(&value)
        } else if item.Kind() == reflect.Array || item.Kind() == reflect.Slice {
            at := ArrayTransformer(&value)

• Read up
  Read up

Avoid deeply nested control flow statements.

Open

    } else if strings.ToUpper(broker.config.LogLevel) == "FATAL" {
        log.SetLevel(log.FatalLevel)
    } else {
        log.SetLevel(log.InfoLevel)
    }

Avoid deeply nested control flow statements.

Open

                if selected := stg.Select(nodes); selected != nil {
                    entry := (*selected).(*EventEntry)
                    result = append(result, entry)
                }

Avoid deeply nested control flow statements.

Open

    } else if isKafka(pubsub.broker.Config.Transporter) {
        pubsub.logger.Info("Transporter: KafkaTransporter")
        transport = pubsub.createKafkaTransporter()
    } else {
        pubsub.logger.Info("Transporter: Memory")

Method TCPTransporter.onGossipResponse has 7 return statements (exceeds 4 allowed).

Open

func (transporter *TCPTransporter) onGossipResponse(msgBytes *[]byte) {
    payload := transporter.serializer.BytesToPayload(msgBytes)
    sender := payload.Get("sender").String()

    transporter.logger.Trace("Received gossip response from " + sender)

Method RawPayload.Get has 7 return statements (exceeds 4 allowed).

Open

func (p *RawPayload) Get(s string, defaultValue ...interface{}) moleculer.Payload {
    if _, ok := p.mapGet(s); ok {
        if defaultValue != nil {
            return p.getKey(s, defaultValue...)
        }

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

Open

var mathService = moleculer.ServiceSchema{
    Name: "math",
    Actions: []moleculer.Action{
        {
            Name: "add",

• Read up
  Read up

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

Open

var mathService = moleculer.ServiceSchema{
    Name: "math",
    Actions: []moleculer.Action{
        {
            Name: "add",

• Read up
  Read up

Method TCPTransporter.Publish has 6 return statements (exceeds 4 allowed).

Open

func (transporter *TCPTransporter) Publish(command, nodeID string, message moleculer.Payload) {
    transporter.logger.Debug("TCPTransporter.Publish() command: " + command + " to nodeID: " + nodeID)
    if command == "DISCOVER" {
        if transporter.udpServer != nil {
            transporter.udpServer.BroadcastDiscoveryMessage()

Method TCPTransporter.onGossipRequest has 6 return statements (exceeds 4 allowed).

Open

func (transporter *TCPTransporter) onGossipRequest(msgBytes *[]byte) {
    payload := transporter.serializer.BytesToPayload(msgBytes)
    sender := payload.Get("sender").String()

    transporter.logger.Trace("Received gossip request from " + sender)

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

Open

func (actionCatalog *ActionCatalog) listByName() map[string][]ActionEntry {
    result := make(map[string][]ActionEntry)
    actionCatalog.actions.Range(func(key, value interface{}) bool {
        result[key.(string)] = value.([]ActionEntry)
        return true

• Read up
  Read up