Method deleteRawWithExecutor

internal/resources/kernel.go:612–655

(
	ctx context.Context,
	exec sqlExecutor,
	actor MutationActor,
	kind ResourceKind,
	id string,
	expectedVersion int64,
)

}

func (k *Kernel) deleteRawWithExecutor(
	ctx context.Context,
	exec sqlExecutor,
	actor MutationActor,
	kind ResourceKind,
	id string,
	expectedVersion int64,
) error {
	if expectedVersion < 0 {
		return fmt.Errorf("%w: expected_version cannot be negative: %d", ErrValidation, expectedVersion)
	}

	existing, found, err := lookupRecordWithExecutor(ctx, exec, kind, id)
	if err != nil {
		return err
	}
	if !found {
		return ErrNotFound
	}
	if err := validateActorWriteAccess(actor, existing.Kind, existing.Scope); err != nil {
		return err
	}
	if existing.Source != actor.Source {
		return fmt.Errorf(
			"%w: actor cannot mutate source %q/%q",
			ErrPermissionDenied,
			existing.Source.Kind,
			existing.Source.ID,
		)
	}

	result, err := exec.ExecContext(ctx, deleteRecordByVersionQuery, kind, id, expectedVersion)
	if err != nil {
		return fmt.Errorf("resources: delete record %q/%q: %w", kind, id, err)
	}
	rowsAffected, err := result.RowsAffected()
	if err != nil {
		return fmt.Errorf("resources: rows affected for delete %q/%q: %w", kind, id, err)
	}
	if rowsAffected == 0 {
		return fmt.Errorf("%w: expected version %d", ErrConflict, expectedVersion)
	}
	return nil
}

func (k *Kernel) prepareListRaw(
	actor MutationActor,