Method fsController.readRaw has 5 return statements (exceeds 4 allowed).

Open

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

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

Method fsController.read has 5 return statements (exceeds 4 allowed).

Open

func (e *fsController) read(w http.ResponseWriter, r *http.Request) {
    // handle raw file read.
    if r.URL.Query().Get("raw") == "true" {
        e.readRaw(w, r)
        return

Method varController.getRaw has 5 return statements (exceeds 4 allowed).

Open

func (e *varController) getRaw(w http.ResponseWriter, r *http.Request) {
    id, err := uuid.Parse(chi.URLParam(r, "variableID"))
    if err != nil {
        w.WriteHeader(http.StatusBadRequest)
        return

Function Authdialog has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

export const Authdialog = () => {
  const { t } = useTranslation();
  const [showKey, setShowKey] = useState(false);
  const { setApiKey: storeApiKey } = useApiActions();
  const apiKeyFromLocalStorage = useApiKey();

• Read up
  Read up

Method FileQuery.SetData has 5 return statements (exceeds 4 allowed).

Open

func (q *FileQuery) SetData(ctx context.Context, data []byte) (string, error) {
    if q.file.Typ == filestore.FileTypeDirectory {
        return "", filestore.ErrFileTypeIsDirectory
    }

Method fsController.delete has 5 return statements (exceeds 4 allowed).

Open

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

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

Function extractEventFilterParams has 5 return statements (exceeds 4 allowed).

Open

func extractEventFilterParams(r *http.Request) ([]string, error) {
    params := make([]string, 0)
    if v := chi.URLParam(r, "namespace"); v != "" {
        params = append(params, "namespace")
        params = append(params, v)

Method secretsController.update has 5 return statements (exceeds 4 allowed).

Open

func (e *secretsController) update(w http.ResponseWriter, r *http.Request) {
    ns := extractContextNamespace(r)
    secretName := chi.URLParam(r, "secretName")

    db, err := e.db.BeginTx(r.Context())

Method sqlNamespacesStore.Create has 5 return statements (exceeds 4 allowed).

Open

func (s *sqlNamespacesStore) Create(ctx context.Context, namespace *datastore.Namespace) (*datastore.Namespace, error) {
    const nameRegex = `^(([a-z][a-z0-9_\-\.]*[a-z0-9])|([a-z]))$`
    matched, _ := regexp.MatchString(nameRegex, namespace.Name)
    if !matched {
        return nil, datastore.ErrInvalidNamespaceName

Function ParseStateType has 5 return statements (exceeds 4 allowed).

Open

func ParseStateType(s string) (StateType, error) {
    if s == "" {
        return 0, fmt.Errorf("type must be one of %v", stateTypeStrings)
    }

Method logController.stream has a Cognitive Complexity of 22 (exceeds 20 allowed). Consider refactoring.

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)

• Read up
  Read up

Function writeFileStoreError has 5 return statements (exceeds 4 allowed).

Open

func writeFileStoreError(w http.ResponseWriter, err error) {
    if errors.Is(err, filestore.ErrNotFound) {
        writeError(w, &Error{
            Code:    "resource_not_found",
            Message: "filesystem path is not found",

Method logController.mountRouter has a Cognitive Complexity of 22 (exceeds 20 allowed). Consider refactoring.

Open

func (m *logController) mountRouter(r chi.Router) {
    r.Get("/subscribe", m.stream)

    r.Get("/", func(w http.ResponseWriter, r *http.Request) {
        params := extractLogRequestParams(r)

• Read up
  Read up

Method ActionDefinition.Validate has 5 return statements (exceeds 4 allowed).

Open

func (o *ActionDefinition) Validate() error {
    if o == nil {
        return nil
    }

Method SystemFunctionDefinition.Validate has 5 return statements (exceeds 4 allowed).

Open

func (o *SystemFunctionDefinition) Validate() error {
    if o == nil {
        return nil
    }

Method ReusableFunctionDefinition.Validate has 5 return statements (exceeds 4 allowed).

Open

func (o *ReusableFunctionDefinition) Validate() error {
    if o == nil {
        return nil
    }

Method seeWorker.start has a Cognitive Complexity of 22 (exceeds 20 allowed). Consider refactoring.

Open

func (lw *seeWorker) start(ctx context.Context) {
    go func() {
        ticker := time.NewTicker(lw.Interval)
        defer ticker.Stop()
        defer close(lw.Ch)

• Read up
  Read up

Function LoadInstanceTelemetryInfo has 5 return statements (exceeds 4 allowed).

Open

func LoadInstanceTelemetryInfo(data []byte) (*InstanceTelemetryInfo, error) {
    m := make(map[string]interface{})

    err := json.Unmarshal(data, &m)
    if err != nil {

Method sqlEventListenerStore.Get has 5 return statements (exceeds 4 allowed).

Open

func (s *sqlEventListenerStore) Get(ctx context.Context, namespace uuid.UUID, limit int, offset int) ([]*datastore.EventListener, int, error) {
    q := `SELECT 
    id, namespace_id, namespace, created_at, updated_at, deleted, received_events, trigger_type, events_lifespan, event_types, trigger_info, metadata, event_context_filters
    FROM event_listeners WHERE namespace_id = $1 `
    q += " ORDER BY created_at DESC "

Method RetryDefinition.Validate has 5 return statements (exceeds 4 allowed).

Open

func (o *RetryDefinition) Validate() error {
    if o == nil {
        return nil
    }