vorteil/direktiv

Method fsController.createFile has 6 return statements (exceeds 4 allowed).

Open

func (e *fsController) createFile(w http.ResponseWriter, r *http.Request) {
    ns := extractContextNamespace(r)

    db, err := e.db.BeginTx(r.Context())
    if err != nil {

Method ActionState.Validate has 6 return statements (exceeds 4 allowed).

Open

func (o *ActionState) Validate() error {
    if err := o.commonValidate(); err != nil {
        return err
    }

Method eventsController.registerCoudEvent has 6 return statements (exceeds 4 allowed).

Open

func (c *eventsController) registerCoudEvent(w http.ResponseWriter, r *http.Request) {
    ns := extractContextNamespace(r)
    cType := r.Header.Get("Content-type")
    limit := int64(1024 * 1024 * 32)

Method sqlRuntimeVariablesStore.Patch has 6 return statements (exceeds 4 allowed).

Open

func (s *sqlRuntimeVariablesStore) Patch(ctx context.Context, id uuid.UUID, patch *datastore.RuntimeVariablePatch) (*datastore.RuntimeVariable, error) {
    if patch.Name != nil {
        if *patch.Name == "" {
            return nil, datastore.ErrInvalidRuntimeVariableName
        }

Method RootQuery.GetFile has 6 return statements (exceeds 4 allowed).

Open

func (q *RootQuery) GetFile(ctx context.Context, path string) (*filestore.File, error) {
    path, err := filestore.SanitizePath(path)
    if err != nil {
        return nil, fmt.Errorf("%w: %w", filestore.ErrInvalidPathParameter, err)
    }

Method RootQuery.ReadDirectory has 6 return statements (exceeds 4 allowed).

Open

func (q *RootQuery) ReadDirectory(ctx context.Context, path string) ([]*filestore.File, error) {
    var list []*filestore.File
    path, err := filestore.SanitizePath(path)
    if err != nil {
        return nil, fmt.Errorf("%w: %w", filestore.ErrInvalidPathParameter, err)

Method varController.update has 6 return statements (exceeds 4 allowed).

Open

func (e *varController) update(w http.ResponseWriter, r *http.Request) {
    id, err := uuid.Parse(chi.URLParam(r, "variableID"))
    if err != nil {
        writeError(w, &Error{
            Code:    "request_data_invalid",

Method sqlRuntimeVariablesStore.Create has 6 return statements (exceeds 4 allowed).

Open

func (s *sqlRuntimeVariablesStore) Create(ctx context.Context, variable *datastore.RuntimeVariable) (*datastore.RuntimeVariable, error) {
    if variable.Name == "" {
        return nil, datastore.ErrInvalidRuntimeVariableName
    }
    if matched, _ := regexp.MatchString(datastore.RuntimeVariableNameRegexPattern, variable.Name); !matched {

Method EventsAndState.Validate has 6 return statements (exceeds 4 allowed).

Open

func (o *EventsAndState) Validate() error {
    if err := o.commonValidate(); err != nil {
        return err
    }

Method varController.create has 6 return statements (exceeds 4 allowed).

Open

func (e *varController) create(w http.ResponseWriter, r *http.Request) {
    ns := extractContextNamespace(r)

    db, err := e.db.BeginTx(r.Context())
    if err != nil {

Method sqlMirrorStore.UpdateConfig has 6 return statements (exceeds 4 allowed).

Open

func (s sqlMirrorStore) UpdateConfig(ctx context.Context, config *datastore.MirrorConfig) (*datastore.MirrorConfig, error) {
    config, err := cryptDecryptConfig(config, s.configEncryptionKey, true)
    if err != nil {
        return nil, err
    }

Method EventsXorState.Validate has 6 return statements (exceeds 4 allowed).

Open

func (o *EventsXorState) Validate() error {
    if err := o.commonValidate(); err != nil {
        return err
    }

Method RootQuery.checkRootExists has 6 return statements (exceeds 4 allowed).

Open

func (q *RootQuery) checkRootExists(ctx context.Context) error {
    zeroUUID := (uuid.UUID{}).String()

    if zeroUUID == q.rootID.String() {
        n := &filestore.Root{}

Method ParallelState.Validate has 6 return statements (exceeds 4 allowed).

Open

func (o *ParallelState) Validate() error {
    if err := o.commonValidate(); err != nil {
        return err
    }

Method nsController.create has 6 return statements (exceeds 4 allowed).

Open

func (e *nsController) create(w http.ResponseWriter, r *http.Request) {
    // Parse request.

    req := struct {
        Name   string `json:"name"`

Method logController.stream has 6 return statements (exceeds 4 allowed).

Open

func (m logController) stream(w http.ResponseWriter, r *http.Request) {
    // cursor is set to multiple seconds before the current time to mitigate data loss
    // that may occur due to delays between submitting and processing the request, or when a sequence of client requests is necessary.
    cursor := time.Now().UTC().Add(-time.Second * 3)

Function determineTrack has 6 return statements (exceeds 4 allowed).

Open

func determineTrack(params map[string]string) (string, error) {
    if p, ok := params["instance"]; ok {
        return "flow.instance." + "%" + p + "%", nil
    } else if p, ok := params["route"]; ok {
        return "flow.route." + params["namespace"] + "." + p, nil

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

Open

func (e *secretsController) mountRouter(r chi.Router) {
    r.Get("/{secretName}", e.get)
    r.Delete("/{secretName}", e.delete)
    r.Patch("/{secretName}", e.update)

• Read up
  Read up

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

Open

func (e *varController) mountRouter(r chi.Router) {
    r.Get("/{variableID}", e.get)
    r.Delete("/{variableID}", e.delete)
    r.Patch("/{variableID}", e.update)

• Read up
  Read up

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

Open

func (e *nsController) mountRouter(r chi.Router) {
    r.Get("/{name}", e.get)
    r.Delete("/{name}", e.delete)
    r.Patch("/{name}", e.update)

• Read up
  Read up