vorteil/direktiv

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

Open

  await expect(
    page.getByTestId("sync-row").first().getByRole("cell", { name: "failed" }),
    "The sync has failed"
  ).toBeVisible();

• Read up
  Read up

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

Open

  <div className="flex grow flex-col">
    <Header syncId={syncId} />
    <Logs syncId={syncId} />
  </div>

• Read up
  Read up

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

Open

          <h3 className="flex items-center gap-x-2 font-bold text-primary-500">
            <Box className="h-5" /> {instance.id.slice(0, 8)}
          </h3>

• Read up
  Read up

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

Open

    <Dialog
      open={dialogOpen}
      onOpenChange={(isOpen) => {
        if (isOpen === false) setEditIndex(undefined);
        setDialogOpen(isOpen);

• Read up
  Read up

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

Open

        <div className="flex grow justify-end gap-4">
          <EditDialog mirror={mirror} />
          <SyncDialog loading={loading} />
        </div>

• Read up
  Read up

Method events.deleteWorkflowEventListeners has 5 return statements (exceeds 4 allowed).

Open

func (events *events) deleteWorkflowEventListeners(ctx context.Context, nsID uuid.UUID, fileID uuid.UUID) error {
    err := events.runSQLTx(ctx, func(tx *database.SQLStore) error {
        ids, err := tx.DataStore().EventListener().DeleteAllForWorkflow(ctx, fileID)
        if err != nil {
            return err

Method events.deleteInstanceEventListeners has 5 return statements (exceeds 4 allowed).

Open

func (events *events) deleteInstanceEventListeners(ctx context.Context, im *instanceMemory) error {
    err := events.runSQLTx(ctx, func(tx *database.SQLStore) error {
        ids, err := tx.DataStore().EventListener().DeleteAllForWorkflow(ctx, im.instance.Instance.ID)
        if err != nil {
            return err

Method delayLogic.Run has 5 return statements (exceeds 4 allowed).

Open

func (logic *delayLogic) Run(ctx context.Context, wakedata []byte) (*Transition, error) {
    first, err := scheduleTwiceConst(logic, wakedata, `""`)
    if err != nil {
        return nil, err
    }

Method FlowVarPlugin.Execute has 5 return statements (exceeds 4 allowed).

Open

func (tnv *FlowVarPlugin) Execute(w http.ResponseWriter, r *http.Request) *http.Request {
    currentNS := gateway.ExtractContextEndpoint(r).Namespace
    if tnv.Namespace == "" {
        tnv.Namespace = currentNS
    }

Method errorLogic.Run has 5 return statements (exceeds 4 allowed).

Open

func (logic *errorLogic) Run(ctx context.Context, wakedata []byte) (*Transition, error) {
    err := scheduleOnce(logic, wakedata)
    if err != nil {
        return nil, err
    }

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

Open

func findProjectRoot(path string) (string, error) {
    fi, err := os.Stat(path)
    if err != nil {
        return "", err
    }

Method Manager.Execute has 5 return statements (exceeds 4 allowed).

Open

func (d *Manager) Execute(ctx context.Context, p *datastore.MirrorProcess, m *datastore.MirrorConfig, applyer Applyer) {
    ctx, cancel := context.WithCancel(ctx)
    defer func() {
        cancel()
        // TODO: find a way to store a separate status 'cancelled' instead of 'error'?

Method KeyAuthPlugin.Execute has 5 return statements (exceeds 4 allowed).

Open

func (ka *KeyAuthPlugin) Execute(w http.ResponseWriter, r *http.Request) *http.Request {
    // check request is already authenticated
    if gateway.ExtractContextActiveConsumer(r) != nil {
        return r
    }

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

Open

func getVariables(ctx context.Context, flowToken, addr string) (*variablesResponse, int, error) {
    resp, err := doRequest(ctx, http.MethodGet, flowToken, addr, nil)
    if err != nil {
        return nil, resp.StatusCode, err
    }

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

Open

func getVariableDataViaID(ctx context.Context, flowToken string, flowAddr string, namespace string, id string) (variable, error) {
    addr := fmt.Sprintf("http://%v/api/v2/namespaces/%v/variables/%v", flowAddr, namespace, id)
    client := &http.Client{}
    req, err := http.NewRequestWithContext(ctx, http.MethodGet, addr, nil)
    if err != nil {

Method BasicAuthPlugin.Execute has 5 return statements (exceeds 4 allowed).

Open

func (ba *BasicAuthPlugin) Execute(w http.ResponseWriter, r *http.Request) *http.Request {
    // check request is already authenticated
    if gateway.ExtractContextActiveConsumer(r) != nil {
        return r
    }

Method FlowPlugin.Execute has 5 return statements (exceeds 4 allowed).

Open

func (tf *FlowPlugin) Execute(w http.ResponseWriter, r *http.Request) *http.Request {
    currentNS := gateway.ExtractContextEndpoint(r).Namespace
    if tf.Namespace == "" {
        tf.Namespace = currentNS
    }

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

Open

func parseFetchSecretExpressionTwoArgs(callExpression string) (*fetchSecretArgs, error) {
    // parse fetchSecret( g1 ) pattern
    pattern := `^[ ]{0,}fetchSecret[ ]{0,}\((.*)\)[ ]{0,}$`
    regex := regexp.MustCompile(pattern)
    matches := regex.FindStringSubmatch(callExpression)

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

Open

func handleResponse(resp *http.Response, next func(resp *http.Response) (int, error)) (int, error) {
    defer resp.Body.Close()

    if resp.StatusCode != http.StatusOK {
        var apiErrorResp apiError

Method events.addInstanceEventListener has 5 return statements (exceeds 4 allowed).

Open

func (events *events) addInstanceEventListener(ctx context.Context, namespace uuid.UUID, nsName string, instance uuid.UUID, sevents []*model.ConsumeEventDefinition, all bool) error {
    // var ev []map[string]interface{}

    fEv := &datastore.EventListener{
        ID:                     uuid.New(),