Sign upLogin

streamdal/go-sdk

View on GitHub
Star

Showing 33 of 36 total issues

Function WriteResponseToMemory has 8 return statements (exceeds 4 allowed).
Open

func WriteResponseToMemory(module api.Module, msg proto.Message) (uint64, error) {
    if module == nil {
        return 0, errors.New("module cannot be nil")
    }
Severity: Major
Found in helper/helper.go - About 50 mins to fix

    Method Tail.startWorker has 7 return statements (exceeds 4 allowed).
    Open

    func (t *Tail) startWorker(looper director.Looper, stream protos.Internal_SendTailClient) {
    if stream == nil {
        t.log.Error("stream is nil, unable to start tail worker")
        return
    }
    Severity: Major
    Found in tail.go - About 45 mins to fix

      Method Streamdal.Process has 7 return statements (exceeds 4 allowed).
      Open

      func (s *Streamdal) Process(ctx context.Context, req *ProcessRequest) *ProcessResponse {
    resp := &ProcessResponse{
        PipelineStatus: make([]*protos.PipelineStatus, 0),
        Metadata:       make(map[string]string),
    }
      Severity: Major
      Found in go_sdk.go - About 45 mins to fix

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

        func Audience(aud *protos.Audience) error {
    if aud == nil {
        return ErrNilInput
    }
        Severity: Major
        Found in validate/validate.go - About 40 mins to fix

          Method HostFunc.HTTPRequest has 6 return statements (exceeds 4 allowed).
          Open

          func (h *HostFunc) HTTPRequest(_ context.Context, module api.Module, ptr, length int32) uint64 {
    request := &steps.HttpRequest{}

    if err := helper.ReadRequestFromMemory(module, request, ptr, length); err != nil {
        return httpRequestResponse(module, http.StatusInternalServerError, "unable to read HTTP request params: "+err.Error(), nil)
          Severity: Major
          Found in hostfunc/httprequest.go - About 40 mins to fix

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

            func TailRequestStartCommand(cmd *protos.Command) error {
    if cmd == nil {
        return ErrNilInput
    }
            Severity: Major
            Found in validate/validate.go - About 40 mins to fix

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

              func ReadRequestFromMemory(module api.Module, msg proto.Message, ptr, length int32) error {
    if length <= 0 {
        return errors.New("length must be greater than 0")
    }
              Severity: Major
              Found in helper/helper.go - About 40 mins to fix

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

                func TailRequestStopCommand(cmd *protos.Command) error {
    if cmd == nil {
        return ErrNilInput
    }
                Severity: Major
                Found in validate/validate.go - About 40 mins to fix

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

                  func TailRequestPauseCommand(cmd *protos.Command) error {
    if cmd == nil {
        return ErrNilInput
    }
                  Severity: Major
                  Found in validate/validate.go - About 40 mins to fix

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

                    func TailRequestResumeCommand(cmd *protos.Command) error {
    if cmd == nil {
        return ErrNilInput
    }
                    Severity: Major
                    Found in validate/validate.go - About 40 mins to fix

                      Method Streamdal.runStep has 5 arguments (exceeds 4 allowed). Consider refactoring.
                      Open

                      func (s *Streamdal) runStep(ctx context.Context, aud *protos.Audience, step *protos.PipelineStep, data []byte, isr *protos.InterStepResult) (*protos.WASMResponse, error) {
                      Severity: Minor
                      Found in go_sdk.go - About 35 mins to fix

                        Method Streamdal.createFunction has 5 return statements (exceeds 4 allowed).
                        Open

                        func (s *Streamdal) createFunction(step *protos.PipelineStep) (*function, error) {
    inst, err := s.createWASMInstance(step.GetXWasmBytes())
    if err != nil {
        return nil, errors.Wrap(err, "unable to create WASM instance")
    }
                        Severity: Major
                        Found in function.go - About 35 mins to fix

                          Method Streamdal.runStep has 5 return statements (exceeds 4 allowed).
                          Open

                          func (s *Streamdal) runStep(ctx context.Context, aud *protos.Audience, step *protos.PipelineStep, data []byte, isr *protos.InterStepResult) (*protos.WASMResponse, error) {
    s.config.Logger.Debugf("Running step '%s'", step.Name)

    // Get WASM module
    f, err := s.getFunction(ctx, step)
                          Severity: Major
                          Found in go_sdk.go - About 35 mins to fix
                            Severity
                            Category
                            Status
                            Source
                            Language