package service

import (
	"encoding/json"
	"reflect"
	"testing"

	"github.com/alicebob/miniredis/v2"
	"github.com/ez-api/ez-api/internal/model"
	"github.com/ez-api/foundation/contract"
	"github.com/redis/go-redis/v9"
)

func TestSyncProvider_WritesSnapshotAndRouting(t *testing.T) {
	goldenRaw := contract.ProviderSnapshotJSON()
	var golden map[string]any
	if err := json.Unmarshal(goldenRaw, &golden); err != nil {
		t.Fatalf("parse golden json: %v", err)
	}

	mr := miniredis.RunT(t)
	rdb := redis.NewClient(&redis.Options{Addr: mr.Addr()})

	svc := NewSyncService(rdb)

	p := &model.Provider{
		Name:           "p1",
		Type:           "vertex-express",
		Group:          "default",
		Models:         "gemini-3-pro-preview",
		Status:         "active",
		AutoBan:        true,
		GoogleProject:  "",
		GoogleLocation: "global",
	}
	p.ID = 42

	if err := svc.SyncProvider(p); err != nil {
		t.Fatalf("SyncProvider: %v", err)
	}

	raw := mr.HGet("config:providers", "42")
	if raw == "" {
		t.Fatalf("expected config:providers hash entry")
	}

	var snap map[string]any
	if err := json.Unmarshal([]byte(raw), &snap); err != nil {
		t.Fatalf("invalid snapshot json: %v", err)
	}
	for k, v := range golden {
		if !reflect.DeepEqual(snap[k], v) {
			t.Fatalf("snapshot mismatch for %q: got=%#v want=%#v", k, snap[k], v)
		}
	}

	routeKey := "route:group:default:gemini-3-pro-preview"
	if !mr.Exists(routeKey) {
		t.Fatalf("expected routing key %q to exist", routeKey)
	}
	ok, err := mr.SIsMember(routeKey, "42")
	if err != nil {
		t.Fatalf("SIsMember: %v", err)
	}
	if !ok {
		t.Fatalf("expected provider id 42 in routing set %q", routeKey)
	}
}