A self-hosted orchestration system crafted for power users. composia.xyz
Something went wrong. Try again.
1.0 kB · 42 lines
Go
12345678910111213141516171819202122232425262728293031323334353637383940414243package controller
import ( "context" "os" "path/filepath" "testing"
"forgejo.alexma.top/alexma233/composia/internal/platform/store")
const testAccessToken = "access-token"
func syncDeclaredServicesForTests(ctx context.Context, db *store.DB, serviceNames ...string) error { declared := make(map[string][]string, len(serviceNames)) for _, serviceName := range serviceNames { declared[serviceName] = []string{"main"} } return db.SyncDeclaredServices(ctx, declared)}
func openControllerTestDB(t *testing.T) *store.DB { t.Helper() stateDir := filepath.Join(t.TempDir(), "state") if err := os.MkdirAll(stateDir, 0o750); err != nil { t.Fatalf("create state dir: %v", err) } db, err := store.Open(stateDir) if err != nil { t.Fatalf("open sqlite db: %v", err) } return db}
func mustTaskParams(t *testing.T, paramsJSON string) serviceTaskParams { t.Helper() params, err := taskParams(paramsJSON) if err != nil { t.Fatalf("decode task params: %v", err) } return params}