sessions

type Closer interface {
	Close(reason domain.SessionCloseReason, addBytes int64)
	Touch()
}

type ConnHit struct {
	StreamCode domain.StreamCode
	Protocol   domain.SessionProto // SessionProtoRTMP / SessionProtoSRT / SessionProtoRTSP
	RemoteAddr string              // ip:port from net.Conn.RemoteAddr().String()
	UserAgent  string              // RTMP flashVer / RTSP User-Agent / "" for SRT
	Token      string              // optional, e.g. SRT streamid query
	Secure     bool                // true for RTMPS / SRTS / RTSPS
}

type Filter struct {
	StreamCode domain.StreamCode // exact match; "" = any
	Protocol   domain.SessionProto
	Status     FilterStatus
	Limit      int // <=0 = unlimited
}

type FilterStatus string

type GeoIPResolver interface {
	Country(ip net.IP) string
}

type HTTPHit struct {
	StreamCode domain.StreamCode
	Protocol   domain.SessionProto // SessionProtoHLS or SessionProtoDASH
	IP         string              // already extracted; no port
	UserAgent  string
	Referer    string
	Query      string // raw r.URL.RawQuery — stored only on session open
	Token      string // ?token=… value if present
	Secure     bool
	BytesDelta int64 // bytes the most recent response wrote to the client
}

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

type NullGeoIP struct{}

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

type Stats struct {
	Active          int   `json:"active"`
	OpenedTotal     int64 `json:"opened_total"`
	ClosedTotal     int64 `json:"closed_total"`
	IdleClosedTotal int64 `json:"idle_closed_total"`
	KickedTotal     int64 `json:"kicked_total"`
}

type Tracker interface {
	// TrackHTTP records activity for an HTTP-based pull protocol (HLS / DASH).
	// Called once per segment / manifest GET. Idempotent on the (stream, fp)
	// pair within the idle window — repeated calls extend UpdatedAt and
	// accumulate Bytes onto an existing session instead of opening a new one.
	//
	// The returned session is a snapshot copy safe to retain by the caller;
	// further mutations happen on the live record held inside the tracker.
	TrackHTTP(ctx context.Context, h HTTPHit) *domain.PlaySession

	// OpenConn opens a session for a connection-bound protocol (RTMP / SRT /
	// RTSP). Returns the session record and a Closer the caller must invoke
	// when the underlying transport ends. The Closer is idempotent.
	OpenConn(ctx context.Context, h ConnHit) (*domain.PlaySession, Closer)

	// List returns a snapshot of every session matching the filter. Active
	// (ClosedAt == nil) and idle entries are included; filter by Status.
	List(filter Filter) []*domain.PlaySession

	// Get returns the session with the given ID, or false when missing.
	Get(id string) (*domain.PlaySession, bool)

	// Kick force-closes an active session and emits a closed event with
	// reason="kicked". Returns false when the id is unknown or already closed.
	Kick(id string) bool

	// Stats returns aggregate counters useful for /metrics or readiness
	// probes. Does not allocate per-session storage.
	Stats() Stats
}