package 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
}