package main

import (
	"encoding/json"
	"os"
	"strings"
	"time"

	"go-simpler.org/env"
	"next.orly.dev/pkg/lol/chk"
	"next.orly.dev/pkg/lol/log"

	"next.orly.dev/pkg/nostr/encoders/filter"
)

// Config holds the negentropy sync service configuration.
type Config struct {
	// Listen is the gRPC server listen address
	Listen string `env:"ORLY_SYNC_NEGENTROPY_LISTEN" default:"127.0.0.1:50064" usage:"gRPC server listen address"`

	// LogLevel is the logging level
	LogLevel string `env:"ORLY_SYNC_NEGENTROPY_LOG_LEVEL" default:"info" usage:"log level (trace, debug, info, warn, error)"`

	// Database configuration
	DBType       string `env:"ORLY_SYNC_NEGENTROPY_DB_TYPE" default:"grpc" usage:"database type: grpc or badger"`
	GRPCDBServer string `env:"ORLY_SYNC_NEGENTROPY_DB_SERVER" default:"127.0.0.1:50051" usage:"gRPC database server address"`
	DataDir      string `env:"ORLY_DATA_DIR" usage:"database data directory (for badger mode)"`

	// Negentropy configuration
	PeersRaw     string        `env:"ORLY_SYNC_NEGENTROPY_PEERS" usage:"comma-separated peer relay WebSocket URLs"`
	SyncInterval time.Duration `env:"ORLY_SYNC_NEGENTROPY_INTERVAL" default:"60s" usage:"background sync interval"`
	FrameSize    int           `env:"ORLY_SYNC_NEGENTROPY_FRAME_SIZE" default:"4096" usage:"negentropy frame size"`
	IDSize       int           `env:"ORLY_SYNC_NEGENTROPY_ID_SIZE" default:"16" usage:"negentropy ID truncation size"`

	// Filter configuration - JSON encoded nostr filter
	// Example: {"kinds":[1,6,7],"authors":["abc123..."]}
	FilterJSON string `env:"ORLY_SYNC_NEGENTROPY_FILTER" usage:"JSON-encoded nostr filter for selective sync"`

	// Client session configuration
	ClientSessionTimeout time.Duration `env:"ORLY_SYNC_NEGENTROPY_SESSION_TIMEOUT" default:"5m" usage:"client session timeout"`

	// Parsed peers
	Peers []string

	// Parsed filter
	Filter *filter.F
}

// loadConfig loads configuration from environment variables.
func loadConfig() *Config {
	cfg := &Config{}
	if err := env.Load(cfg, nil); chk.E(err) {
		log.E.F("failed to load config: %v", err)
		os.Exit(1)
	}

	// Parse peers from comma-separated string
	if cfg.PeersRaw != "" {
		cfg.Peers = strings.Split(cfg.PeersRaw, ",")
		for i, p := range cfg.Peers {
			cfg.Peers[i] = strings.TrimSpace(p)
		}
	}

	// Parse filter from JSON if provided
	if cfg.FilterJSON != "" {
		cfg.Filter = &filter.F{}
		if err := json.Unmarshal([]byte(cfg.FilterJSON), cfg.Filter); err != nil {
			log.E.F("failed to parse filter JSON: %v", err)
			os.Exit(1)
		}
		log.I.F("using sync filter: %s", cfg.FilterJSON)
	}

	return cfg
}