api

type App struct {
	Router  *mux.Router
	Handler http.Handler
	DB      common.DBInterface
	// contains filtered or unexported fields
}

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

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

type DynamicConfigsResponse struct {
	ListResponse
	Items []*models.DynamicConfig `json:"data"`
}

type FailoverMapping struct {
	FailedServer   string    // Primary server that failed (e.g., "gxy1")
	FailoverServer string    // Failover server replacing it (e.g., "gxy12")
	FailedAt       time.Time // When failover happened
}

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

type GatewayDTO struct {
	ID          int64       `json:"id"`
	Name        string      `json:"name"`
	Description null.String `json:"description,omitempty"`
	URL         string      `json:"url"`
	Disabled    bool        `json:"disabled"`
	CreatedAt   time.Time   `json:"created_at"`
	UpdatedAt   null.Time   `json:"updated_at,omitempty"`
	RemovedAt   null.Time   `json:"removed_at,omitempty"`
	Type        string      `json:"type"`
}

type GatewayStatus struct {
	Name         string
	Online       bool
	Sessions     int
	LastSeen     time.Time
	OfflineAt    time.Time   // When server went offline
	OfflineTimer *time.Timer // Timer for failover trigger
	// contains filtered or unexported fields
}

type GatewaysResponse struct {
	ListResponse
	Gateways []*GatewayDTO `json:"data"`
}

type JanusAdminResponse struct {
	Janus       string  `json:"janus"`
	Transaction string  `json:"transaction"`
	Sessions    []int64 `json:"sessions"`
}

type JanusStatusMessage struct {
	Online bool `json:"online"`
}

type ListParams struct {
	PageNumber int    `json:"page_no"`
	PageSize   int    `json:"page_size"`
	OrderBy    string `json:"order_by"`
	GroupBy    string `json:"-"`
}

type ListResponse struct {
	Total int64 `json:"total"`
}

type MQTTListener struct {
	SessionManager SessionManager
	// contains filtered or unexported fields
}

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

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

type ProtocolError struct {
	errs.WithMessage
}

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

type RoomsRequest struct {
	Gateways []int64
	Disabled null.Bool
	Removed  null.Bool
	Term     string
}

type RoomsResponse struct {
	ListResponse
	Rooms []*models.Room `json:"data"`
}

type ServiceProtocolHandler interface {
	HandleMessage(ctx context.Context, payload string) error
}

type SessionManager interface {
	HandleEvent(context.Context, interface{}) error
	HandleProtocol(context.Context, *janus.TextroomPostMsg) error
	UpsertSession(context.Context, *V1User) error
	Start()
	Close()
}

type SessionsResponse struct {
	ListResponse
	Sessions []*V1User `json:"data"`
}

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

type V1Composite struct {
	VQuad []*V1CompositeRoom `json:"vquad"`
}

type V1CompositeRoom struct {
	V1Room
	Position int `json:"queue"`
}

type V1ProtocolMessageText struct {
	Type   string
	Status bool
	Room   string // Changed from int to string for Janus string ID support
	User   V1User
}

type V1Room struct {
	V1RoomInfo
	Questions bool                   `json:"questions"`
	NumUsers  int                    `json:"num_users"`
	Users     []*V1User              `json:"users"`
	Region    string                 `json:"region"`
	Extra     map[string]interface{} `json:"extra"`
	// contains filtered or unexported fields
}

type V1RoomInfo struct {
	Room        string `json:"room"` // Changed from int to string for Janus string ID support
	Janus       string `json:"janus"`
	Description string `json:"description"`
}

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

type V1ServiceProtocolMessageText struct {
	Type        string
	Status      bool
	Room        *string // Changed from *int to *string for Janus string ID support
	Column      *int    `json:"col"`
	Index       *int    `json:"i"`
	Transaction *string
}

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

type V1User struct {
	ID             string                 `json:"id"`
	Display        string                 `json:"display"`
	Email          string                 `json:"email"`
	Group          string                 `json:"group"`
	IP             string                 `json:"ip"`
	Janus          string                 `json:"janus"`
	Name           string                 `json:"name"`
	Role           string                 `json:"role"`
	System         string                 `json:"system"`
	Username       string                 `json:"username"`
	Room           string                 `json:"room"` // Changed from int to string for Janus string ID support
	Timestamp      int64                  `json:"timestamp"`
	Session        int64                  `json:"session"`
	Handle         int64                  `json:"handle"`
	RFID           string                 `json:"rfid"`
	TextroomHandle int64                  `json:"textroom_handle"`
	Camera         bool                   `json:"camera"`
	Question       bool                   `json:"question"`
	SelfTest       bool                   `json:"self_test"`
	SoundTest      bool                   `json:"sound_test"`
	Extra          map[string]interface{} `json:"extra"`
}

type V2Config struct {
	Gateways      map[string]map[string]*V2Gateway `json:"gateways"`
	IceServers    map[string][]string              `json:"ice_servers"`
	DynamicConfig map[string]string                `json:"dynamic_config"`
	LastModified  time.Time                        `json:"last_modified"`
}

type V2Gateway struct {
	Name string `json:"name"`
	URL  string `json:"url"`
	Type string `json:"type"`
}

type V2RoomServerRequest struct {
	Room string                  `json:"room"` // Changed from int to string for Janus string ID support
	Geo  *V2RoomServerRequestGeo `json:"geo,omitempty"`
}

type V2RoomServerRequestGeo struct {
	CountryCode string `json:"country_code,omitempty"` // e.g., "US", "RU", "IL"
}

type V2RoomServerResponse struct {
	Janus string `json:"janus"`
}

type V2RoomStatistics struct {
	OnAir int `json:"on_air"`
}

type VHInfo struct {
	UserID    string    `json:"id"`
	FirstName string    `json:"first_name"`
	LastName  string    `json:"last_name"`
	Email     string    `json:"email"`
	Active    bool      `json:"active"`
	CreatedAt time.Time `json:"created_at"`
}