gateway

type ACMERequest struct {
	FQDN  string `json:"fqdn"`  // e.g., "_acme-challenge.example.com."
	Value string `json:"value"` // The challenge token
}

type CircuitBreaker struct {
	// contains filtered or unexported fields
}

type CircuitBreakerRegistry struct {
	// contains filtered or unexported fields
}

type CircuitState int

type Config struct {
	ListenAddr      string
	ClientNamespace string
	BootstrapPeers  []string
	NodePeerID      string // The node's actual peer ID from its identity file

	// Optional DSN for rqlite database/sql driver, e.g. "http://localhost:4001"
	// If empty, defaults to "http://localhost:4001".
	RQLiteDSN string

	// Global RQLite DSN for API key validation (for namespace gateways)
	// If empty, uses RQLiteDSN (for main/global gateways)
	GlobalRQLiteDSN string

	// HTTPS configuration
	EnableHTTPS bool   // Enable HTTPS with ACME (Let's Encrypt)
	DomainName  string // Domain name for HTTPS certificate
	TLSCacheDir string // Directory to cache TLS certificates (default: ~/.orama/tls-cache)

	// Domain routing configuration
	BaseDomain string // Base domain for deployment routing. Set via node config http_gateway.base_domain. Defaults to "dbrs.space"

	// Data directory configuration
	DataDir string // Base directory for node-local data (SQLite databases, deployments). Defaults to ~/.orama

	// Olric cache configuration
	OlricServers []string      // List of Olric server addresses (e.g., ["localhost:3320"]). If empty, defaults to ["localhost:3320"]
	OlricTimeout time.Duration // Timeout for Olric operations (default: 10s)

	// IPFS Cluster configuration
	IPFSClusterAPIURL     string        // IPFS Cluster HTTP API URL (e.g., "http://localhost:9094"). If empty, gateway will discover from node configs
	IPFSAPIURL            string        // IPFS HTTP API URL for content retrieval (e.g., "http://localhost:4501"). If empty, gateway will discover from node configs
	IPFSTimeout           time.Duration // Timeout for IPFS operations (default: 60s)
	IPFSReplicationFactor int           // Replication factor for pins (default: 3)
	IPFSEnableEncryption  bool          // Enable client-side encryption before upload (default: true, discovered from node configs)

	// WireGuard mesh configuration
	ClusterSecret string // Cluster secret for authenticating internal WireGuard peer exchange

	// WebRTC configuration (set when namespace has WebRTC enabled)
	WebRTCEnabled bool   // Whether WebRTC endpoints are active on this gateway
	SFUPort       int    // Local SFU signaling port to proxy WebSocket connections to
	TURNDomain    string // TURN server domain for credential generation
	TURNSecret    string // HMAC-SHA1 shared secret for TURN credential generation
}

type Dependencies struct {
	// Client is the network client for P2P communication
	Client client.NetworkClient

	// RQLite database dependencies
	SQLDB     *sql.DB
	ORMClient rqlite.Client
	ORMHTTP   *rqlite.HTTPGateway

	// Olric distributed cache client
	OlricClient *olric.Client

	// IPFS storage client
	IPFSClient ipfs.IPFSClient

	// Serverless function engine components
	ServerlessEngine   *serverless.Engine
	ServerlessRegistry *serverless.Registry
	ServerlessInvoker  *serverless.Invoker
	ServerlessWSMgr    *serverless.WSManager
	ServerlessHandlers *serverlesshandlers.ServerlessHandlers

	// PubSub trigger dispatcher (used to wire into PubSubHandlers)
	PubSubDispatcher *triggers.PubSubDispatcher

	// Authentication service
	AuthService *auth.Service
}

type ExpoPushMessage struct {
	To       string                 `json:"to"`
	Title    string                 `json:"title"`
	Body     string                 `json:"body"`
	Data     map[string]interface{} `json:"data,omitempty"`
	Sound    string                 `json:"sound,omitempty"`
	Badge    int                    `json:"badge,omitempty"`
	Priority string                 `json:"priority,omitempty"`
	// iOS specific
	MutableContent bool   `json:"mutableContent,omitempty"`
	IosIcon        string `json:"iosIcon,omitempty"`
	// Android specific
	AndroidBigLargeIcon string `json:"androidBigLargeIcon,omitempty"`
	ChannelID           string `json:"channelId,omitempty"`
}

type ExpoTicket struct {
	ID    string `json:"id"`
	Error string `json:"error,omitempty"`
}

type Gateway struct {
	// contains filtered or unexported fields
}

type GatewayInstance struct {
	Namespace    string
	NodeID       string
	HTTPPort     int
	BaseDomain   string
	RQLiteDSN    string   // Connection to namespace RQLite
	OlricServers []string // Connection to namespace Olric
	ConfigPath   string
	PID          int
	StartedAt    time.Time

	Status          InstanceNodeStatus
	LastHealthCheck time.Time
	// contains filtered or unexported fields
}

type GatewayYAMLConfig struct {
	ListenAddr            string            `yaml:"listen_addr"`
	ClientNamespace       string            `yaml:"client_namespace"`
	RQLiteDSN             string            `yaml:"rqlite_dsn"`
	GlobalRQLiteDSN       string            `yaml:"global_rqlite_dsn,omitempty"`
	BootstrapPeers        []string          `yaml:"bootstrap_peers,omitempty"`
	EnableHTTPS           bool              `yaml:"enable_https,omitempty"`
	DomainName            string            `yaml:"domain_name,omitempty"`
	TLSCacheDir           string            `yaml:"tls_cache_dir,omitempty"`
	OlricServers          []string          `yaml:"olric_servers"`
	OlricTimeout          string            `yaml:"olric_timeout,omitempty"`
	IPFSClusterAPIURL     string            `yaml:"ipfs_cluster_api_url,omitempty"`
	IPFSAPIURL            string            `yaml:"ipfs_api_url,omitempty"`
	IPFSTimeout           string            `yaml:"ipfs_timeout,omitempty"`
	IPFSReplicationFactor int               `yaml:"ipfs_replication_factor,omitempty"`
	WebRTC                GatewayYAMLWebRTC `yaml:"webrtc,omitempty"`
}

type GatewayYAMLWebRTC struct {
	Enabled    bool   `yaml:"enabled"`
	SFUPort    int    `yaml:"sfu_port,omitempty"`
	TURNDomain string `yaml:"turn_domain,omitempty"`
	TURNSecret string `yaml:"turn_secret,omitempty"`
}

type HTTPGateway struct {
	// contains filtered or unexported fields
}

type HTTPSGateway struct {
	*HTTPGateway
	// contains filtered or unexported fields
}

type InstanceConfig struct {
	Namespace       string        // Namespace name (e.g., "alice")
	NodeID          string        // Physical node ID
	HTTPPort        int           // HTTP API port
	BaseDomain      string        // Base domain (e.g., "orama-devnet.network")
	RQLiteDSN       string        // RQLite connection DSN (e.g., "http://localhost:10000")
	GlobalRQLiteDSN string        // Global RQLite DSN for API key validation (empty = use RQLiteDSN)
	OlricServers    []string      // Olric server addresses
	OlricTimeout    time.Duration // Timeout for Olric operations
	NodePeerID      string        // Physical node's peer ID for home node management
	DataDir         string        // Data directory for deployments, SQLite, etc.
	// IPFS configuration for storage endpoints
	IPFSClusterAPIURL     string        // IPFS Cluster API URL (e.g., "http://localhost:9094")
	IPFSAPIURL            string        // IPFS API URL (e.g., "http://localhost:5001")
	IPFSTimeout           time.Duration // Timeout for IPFS operations
	IPFSReplicationFactor int           // IPFS replication factor
	// WebRTC configuration (populated when WebRTC is enabled for the namespace)
	WebRTCEnabled bool   // Enable WebRTC (SFU/TURN) routes on this gateway
	SFUPort       int    // SFU signaling port on this node
	TURNDomain    string // TURN server domain (e.g., "turn.ns-alice.orama-devnet.network")
	TURNSecret    string // TURN shared secret for credential generation
}

type InstanceError struct {
	Message string
	Cause   error
}

type InstanceNodeStatus string

type InstanceSpawner struct {
	// contains filtered or unexported fields
}

type NamespaceHealth struct {
	Status   string                            `json:"status"` // "healthy", "degraded", "unhealthy"
	Services map[string]NamespaceServiceHealth `json:"services"`
}

type NamespaceRateLimiter struct {
	// contains filtered or unexported fields
}

type NamespaceServiceHealth struct {
	Status  string `json:"status"`
	Port    int    `json:"port"`
	Latency string `json:"latency,omitempty"`
	Error   string `json:"error,omitempty"`
}

type PeerDiscovery struct {
	// contains filtered or unexported fields
}

type PresenceMember struct {
	MemberID string                 `json:"member_id"`
	JoinedAt int64                  `json:"joined_at"` // Unix timestamp
	Meta     map[string]interface{} `json:"meta,omitempty"`
	ConnID   string                 `json:"-"` // Internal: for tracking which connection
}

type PushNotificationService struct {
	// contains filtered or unexported fields
}

type RateLimiter struct {
	// contains filtered or unexported fields
}

type TCPSNIGateway struct {
	// contains filtered or unexported fields
}