vorteil/direktiv

package mirror

import (
    "context"
    "errors"
    "fmt"

    "github.com/direktiv/direktiv/pkg/datastore"
    "github.com/google/uuid"
)

func (d *Manager) NewProcess(ctx context.Context, ns *datastore.Namespace, processType string) (*datastore.MirrorProcess, error) {
    // TODO: make this check 100% threadsafe in HA

    procs, err := d.callbacks.Store().GetProcessesByNamespace(ctx, ns.Name)
    if err != nil {
        return nil, fmt.Errorf("querying existing a mirroring processes, err: %w", err)
    }

    for _, proc := range procs {
        if status := proc.Status; status == datastore.ProcessStatusExecuting || status == datastore.ProcessStatusPending {
            return nil, errors.New("a mirroring process is already being executed on this namespace")
        }
    }

    process, err := d.callbacks.Store().CreateProcess(ctx, &datastore.MirrorProcess{
        ID:        uuid.New(),
        Namespace: ns.Name,
        Typ:       processType,
        Status:    datastore.ProcessStatusPending,
    })
    if err != nil {
        return nil, fmt.Errorf("creating a new mirroring process, err: %w", err)
    }

    return process, nil
}