tpviz

type AppState struct {
	Name           string   `json:"name"`
	Status         int      `json:"status"`          // 0=stopped, 1=running, 2=errored, 3=starting
	DetailedStatus string   `json:"detailed_status"` // Human-readable status
	AutoStart      bool     `json:"auto_start"`
	Port           uint16   `json:"port"`
	Args           []string `json:"args,omitempty"`
}

type CXOSubMgr interface {
	AcquireForTab(tab int)
	ReleaseForTab(tab int)
	Walk(feed int, prefix string, fn func(path string, body []byte) bool) bool
}

type Config struct {
	// Addr is the address to bind to (default: 127.0.0.1)
	Addr string
	// Port is the port to listen on (default: 8080)
	Port int
	// CacheDirTPD is the cache directory for TPD data (default: /tmp/{tpd-host})
	// Set to "" to disable caching
	CacheDirTPD string
	// CacheDirUT is the cache directory for uptime tracker data (default: /tmp/{ut-host})
	// Set to "" to disable caching
	CacheDirUT string
	// CacheDirSD is the cache directory for service discovery data (default: /tmp/{sd-host})
	// Set to "" to disable caching
	CacheDirSD string
	// CacheDirDMSG is the cache directory for DMSG discovery data (default: /tmp/{dmsg-host})
	// Set to "" to disable caching
	CacheDirDMSG string
	// CacheMaxAge is the cache max age in minutes (default: 5)
	CacheMaxAge int
	// TPDURL is the transport discovery URL
	TPDURL string
	// SDURL is the service discovery URL
	SDURL string
	// DMSGURL is the DMSG discovery URL
	DMSGURL string
	// TPDURLDmsg / SDURLDmsg / DMSGURLDmsg are the dmsg:// forms of the
	// deployment-discovery URLs (default from deployment.Prod.*Dmsg). When a
	// dmsg HTTP client is set (SetDmsgHTTPClient), deployment discovery is
	// fetched over dmsg using these instead of the clearnet URLs above —
	// required on a dmsg-only deployment.
	TPDURLDmsg  string
	SDURLDmsg   string
	DMSGURLDmsg string
	// AllowClearnetDisc forces the legacy clearnet deployment-discovery fetches
	// even with no dmsg client / visor API. Default false: on a dmsg-only
	// deployment the clearnet HTTP frontends are dead (404), so the fetches are
	// gated to avoid spamming them.
	AllowClearnetDisc bool
	// NoCache disables caching when true
	NoCache bool
	// AutoRefresh enables auto-refresh of cache at specified interval
	AutoRefresh bool
	// SurveyDir is the directory containing visor surveys (node-info.json files)
	// Used for IP-based grouping without exposing actual IP addresses
	SurveyDir string
	// GeoIPURL is the URL of the geoip service (default from deployment.Prod.GeoIP)
	GeoIPURL string
}

type DMSGData struct {
	Servers      []DMSGServer `json:"servers"`
	EntriesCount int          `json:"entries_count"`
	Entries      []string     `json:"entries"` // list of all entry PKs
	LastUpdated  time.Time    `json:"last_updated"`
}

type DMSGHealthResponse struct {
	Status    string `json:"status"`
	BuildInfo string `json:"build_info,omitempty"`
	Message   string `json:"message,omitempty"`
	Error     string `json:"error,omitempty"`
}

type DMSGServer struct {
	PK                string   `json:"pk"`
	Address           string   `json:"address"`
	AvailableSessions int      `json:"available_sessions"`
	ServerType        string   `json:"server_type"`
	IP                string   `json:"ip,omitempty"`
	Country           string   `json:"country,omitempty"`
	Clients           []string `json:"clients,omitempty"` // PKs of clients connected to this server
}

type LatencyEdge struct {
	A string `json:"a"`
	B string `json:"b"`
	// MS is the round-trip time in milliseconds.
	MS float64 `json:"ms"`
	// N is how many transports between this pair were sampled.
	N int `json:"n"`
	// Type is the transport type that produced MS (the fastest one).
	Type string `json:"type"`
}

type LatencyGraph struct {
	Edges []LatencyEdge `json:"edges"`
	// Visors is every public key that appears in Edges, sorted, so the
	// client can index points without a second pass.
	Visors []string `json:"visors"`
	Days   int      `json:"days"`
}

type LocalRoute struct {
	RouteID     uint32 `json:"route_id"`
	Type        string `json:"type"` // "forward", "consume", "intermediary"
	SrcPK       string `json:"src_pk,omitempty"`
	DstPK       string `json:"dst_pk,omitempty"`
	NextHopPK   string `json:"next_hop_pk,omitempty"` // For forward/intermediary routes
	TransportID string `json:"transport_id,omitempty"`
}

type LocalTransport struct {
	ID        string `json:"id"`
	RemotePK  string `json:"remote_pk"`
	Type      string `json:"type"`
	Label     string `json:"label,omitempty"`
	IsSetup   bool   `json:"is_setup"`
	SentBytes uint64 `json:"sent_bytes"`
	RecvBytes uint64 `json:"recv_bytes"`
	// Bandwidth deltas for animation
	SentDelta uint64 `json:"sent_delta"`
	RecvDelta uint64 `json:"recv_delta"`
}

type LocalVisorData struct {
	Connected   bool             `json:"connected"`
	PubKey      string           `json:"pub_key,omitempty"`
	Country     string           `json:"country,omitempty"`
	IP          string           `json:"ip,omitempty"`
	Transports  []LocalTransport `json:"transports,omitempty"`
	Routes      []LocalRoute     `json:"routes,omitempty"`
	RoutesCount int              `json:"routes_count"`
	LastUpdated time.Time        `json:"last_updated"`
	// Bandwidth deltas for animation (bytes since last update)
	TotalSentDelta uint64 `json:"total_sent_delta"`
	TotalRecvDelta uint64 `json:"total_recv_delta"`
}

type NavLink struct {
	URL   string
	Label string
}

type PingResponse struct {
	Status     string  `json:"status"`
	LatencyMs  float64 `json:"latency_ms,omitempty"`
	Latencies  []int64 `json:"latencies,omitempty"` // Individual latencies in ms
	MinMs      float64 `json:"min_ms,omitempty"`
	MaxMs      float64 `json:"max_ms,omitempty"`
	AvgMs      float64 `json:"avg_ms,omitempty"`
	PacketLoss float64 `json:"packet_loss,omitempty"`
	Error      string  `json:"error,omitempty"`
	Mode       string  `json:"mode"` // "route" or "dmsg"
}

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

type ServiceInfo struct {
	PK       string   `json:"pk"`
	Services []string `json:"services"`
	Country  string   `json:"country,omitempty"`
}

type TPSAPI interface {
	AddTransport(ctx context.Context, targetPK, remotePK, tpType string) (*TPSTransportResponse, error)
	RemoveTransport(ctx context.Context, targetPK, tpID string) error
	GetTransports(ctx context.Context, targetPK string) ([]TPSTransportResponse, error)
	PK() string
}

type TPSTransportResponse struct {
	ID     string `json:"id"`
	Local  string `json:"local_pk"`
	Remote string `json:"remote_pk"`
	Type   string `json:"type"`
}

type TransportSummary struct {
	ID      uuid.UUID           `json:"id"`
	Local   cipher.PubKey       `json:"local_pk"`
	Remote  cipher.PubKey       `json:"remote_pk"`
	Type    tptypes.Type        `json:"type"`
	Log     *transport.LogEntry `json:"log,omitempty"`
	IsSetup bool                `json:"is_setup"`
	Label   transport.Label     `json:"label"`
}

type VisorAPI interface {
	Overview() (*VisorOverview, error)
	RoutingRules() ([]routing.Rule, error)
	// AllTransports returns the network-wide all-transports JSON snapshot the
	// visor holds via its dmsg/CXO-backed transport-discovery feed — the same
	// payload TPD's HTTP /all-transports serves, but obtained over dmsg with no
	// clearnet request. Returns an error on a CXO cache miss (feed not yet
	// populated); the caller surfaces that rather than falling back to clearnet.
	AllTransports(ctx context.Context) ([]byte, error)
	AddTransport(ctx context.Context, remotePK, tpType string) (*TransportSummary, error)
	RemoveTransport(ctx context.Context, tpID string) error
	DMSGHealth(ctx context.Context, pk string) (*DMSGHealthResponse, error)
	Ping(ctx context.Context, pk string, useDMSG, localRoute bool, tries, sizeKB int) (*PingResponse, error)
	// App management
	Apps() ([]*AppState, error)
	StartApp(appName string) error
	StopApp(appName string) error
	SetAutoStart(appName string, autoStart bool) error
	SetAppPK(appName, pk string) error
	Close() error
}

type VisorOverview struct {
	PubKey      cipher.PubKey       `json:"local_pk"`
	Transports  []*TransportSummary `json:"transports"`
	RoutesCount int                 `json:"routes_count"`
}