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
    }

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

Open

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

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

Open

func (e *varController) list(w http.ResponseWriter, r *http.Request) {
    // handle raw var read.
    if r.URL.Query().Get("raw") == "true" {
        e.listRaw(w, r)
        return

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

Open

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

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

Open

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

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

Open

func (e *varController) get(w http.ResponseWriter, r *http.Request) {
    // handle raw var read.
    if r.URL.Query().Get("raw") == "true" {
        e.getRaw(w, r)
        return

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

Open

const ServicePage: FC = () => {
  const pages = usePages();
  const { path } = pages.explorer.useParams();
  const namespace = useNamespace();
  const { segments } = analyzePath(path);

• Read up
  Read up

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

Open

const FileViewer = ({ file }: { file: BaseFileSchemaType }) => {
  const { t } = useTranslation();
  const theme = useTheme();
  const { data } = useFile({ path: file.path });

• Read up
  Read up

Avoid too many return statements within this function.

Open

  return [...startSegment, ...activeSegment, ...endSegment];

Avoid too many return statements within this function.

Open

    return (
      <Card className="m-5 flex grow">
        <NoPermissions>{noPermissionMessage}</NoPermissions>
      </Card>
    );

Avoid too many return statements within this function.

Open

  if (!servicesList) return null;