diagox

type AudioMediaStack interface {
	AudioStereoRecordingCreate(*os.File) (diago.AudioStereoRecordingWav, error)
	SetAudioReader(io.Reader)
	SetAudioWriter(io.Writer)
}

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

type BridgeData struct {
	ID      string
	NodeID  string
	Dialogs []string
}

type CDR struct {
	Direction        string           `json:"direction"`
	CallID           string           `json:"callId"`
	OriginatorCallID string           `json:"originatorCallId"`
	StartTime        time.Time        `json:"startTime"`
	Duration         time.Duration    `json:"duration"`
	CallerID         string           `json:"callerId"`
	CalleeID         string           `json:"calleeId"`
	Bill             float64          `json:"bill"`
	Disposition      string           `json:"disposition"`
	MediaStats       DialogMediaStats `json:"mediaStats"`
	MES              float64          `json:"mes"` // Media Experience Score
	RecordingID      string           `json:"recordingId"`
	Bridged          bool             `json:"bridged"`

	StartTimeFormated string `json:"startTimeFormatted"`
}

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

type CDRPiper struct {
	CDRStorage
	Pipe chan CDR
}

type CDRReadOptions struct {
	Offset           int
	FromTime         time.Time
	ToTime           time.Time
	From             string
	To               string
	CallID           string
	OriginatorCallID string
	Mes              float64
}

type CDRStorage interface {
	CDRWrite(ctx context.Context, cdr CDR) error
	CDRRead(ctx context.Context, buf []CDR, opts CDRReadOptions) (n int, err error)
}

type CallContext struct {
	*PBX
	// contains filtered or unexported fields
}

type Config struct {
	Version    string                     `yaml:"version"`
	Transports map[string]ConfigTransport `yaml:"transports"`
	Endpoints  map[string]ConfigEndpoint  `yaml:"endpoints"`
	Routes     map[string][]ConfigRoute   `yaml:"routes"`
	// contains filtered or unexported fields
}

type ConfigAOR struct {
	URI      string     `yaml:"uri"`
	Protocol string     `yaml:"protocol"`
	Auth     ConfigAuth `yaml:"auth"`
}

type ConfigAuth struct {
	Type     string `yaml:"type"`
	Username string `yaml:"username"`
	Password string `yaml:"password"`
}

type ConfigEndpoint struct {
	Name  string      `yaml:"name"`
	Match ConfigMatch `yaml:"match"`
	Auth  ConfigAuth  `yaml:"auth,omitempty"`
	URI   string      `yaml:"uri"`
	Route string      `yaml:"route"`

	// AOR         ConfigAOR   `yaml:"aor,omitempty"`
	// MatchNext   string `yaml:"match_next,omitempty"`
	TransportID string              `yaml:"transport,omitempty"`
	Media       ConfigEndpointMedia `yaml:"media"`
	ContactHDR  string              `yaml:"contact_header"`
	// contains filtered or unexported fields
}

type ConfigEndpointMedia struct {
	Type string `yaml:"type"`
}

type ConfigMatch struct {
	Type      string   `yaml:"type"`
	Values    []string `yaml:"values,omitempty"`
	Transport string   `yaml:"transport,omitempty"`
}

type ConfigRecordings struct {
	Path string `yaml:"path,omitempty"`
}

type ConfigRoute struct {
	ID             string              `yaml:"id"`
	EndpointName   string              `yaml:"endpoint"`
	Fallback       ConfigRouteFallback `yaml:"fallback"`
	Match          string              `yaml:"match"`
	StripPrefix    string              `yaml:"strip_prefix"`
	UseRegistry    bool                `yaml:"use_registry"`
	Recording      bool                `yaml:"recording"`
	Hangup         ConfigRouteHangup   `yaml:"hangup"`
	SipHeaders     map[string]string   `yaml:"sip_headers"`
	SipHeadersPass []string            `yaml:"sip_headers_pass"`
}

type ConfigRouteFallback struct {
	Enabled          bool     `yaml:"enabled"`
	Endpoints        []string `yaml:"endpoints"`
	FallbacksCodes   []int    `yaml:"codes"`
	FallbacksTimeout bool     `yaml:"timeout"`
}

type ConfigRouteHangup struct {
	Code   int    `yaml:"code"`
	Reason string `yaml:"reason"`
}

type ConfigTransport struct {
	Transport       string `yaml:"transport"`
	Bind            string `yaml:"bind"`
	Port            int    `yaml:"port"`
	ExternalHost    string `yaml:"external_host"`
	ExternalPort    int    `yaml:"external_port"`
	ExternalMediaIP string `yaml:"external_media_ip"`
	RewriteContact  bool   `yaml:"rewrite_contact"`
}

type DialogCacheFile struct {
	NodeID string
	// contains filtered or unexported fields
}

type DialogData struct {
	ID                string
	NodeID            string
	Direction         uint8 // 0: Server, 1:Client
	InviteRequestData string
	Dialplan          string
}

type DialogExternalCache interface {
	StoreDialog(ctx context.Context, data DialogData) error
	LoadDialog(ctx context.Context, id string) (DialogData, error)
	DeleteDialog(ctx context.Context, id string) error
	DeleteDialogNode(ctx context.Context, id string, nodeId string) error
	LoadDialogs(ctx context.Context, nodeID string) ([]DialogData, error)
}

type DialogMediaStats struct {
	RTTMax            time.Duration `json:"rttMax"`
	RTTMin            time.Duration `json:"rttMin"`
	PacketsReadCount  uint64        `json:"packetsReadCount"`
	PacketsWriteCount uint64        `json:"packetsWriteCount"`
	PacketsReadLost   uint32        `json:"packetsReadLost"`
	PacketsWriteLost  uint32        `json:"packetsWriteLost"`
	MaxJitter         time.Duration `json:"maxJitter"`
}

type DialogRateLimiterIncoming struct {
	DialogMax int64
	DialogRPS int64

	RateLimiterIn
}

type DialogRateLimiterOutgoing struct {
	DialogRPS int64

	RateLimiterOut
}

type EnvConfig struct {
	// Internal
	Cluster     bool `env:"GOPBX_CLUSTER"`
	TestMode    bool `env:"TEST_MODE"`
	SIPDebug    bool `env:"SIP_DEBUG" envDefault:"false"`
	SIPCDRTrace bool `env:"SIP_CDR_TRACE" envDefault:"true"`
	RTPDebug    bool `env:"RTP_DEBUG" envDefault:"false"`
	RTCPDebug   bool `env:"RTCP_DEBUG" envDefault:"false"`

	OutboundDialUri  string `env:"OUTBOUND_DIAL_URI" envDefault:""`
	ConfFile         string `env:"CONF_FILE" envDefault:"diagox.yaml"`
	CDREnable        bool   `env:"CDR_ENABLE" envDefault:"true"`
	RecordingsPath   string `env:"RECORDINGS_PATH" envDefault:"recordings"`
	FrontendEnable   bool   `env:"FRONTEND_ENABLE" envDefault:"false"`
	FrontendDevMode  bool   `env:"FRONTEND_DEV_MODE" envDefault:"false"`
	HTTPAddr         string `env:"HTTP_ADDR" envDefault:":6060"`
	HTTPDebug        bool   `env:"HTTP_DEBUG" envDefault:"false"`
	MediaCodecs      string `env:"MEDIA_CODECS" envDefault:""`
	WebrtcICEServers string `env:"WEBRTC_ICE_SERVERS" envDefault:""`
	WebrtcSTUN       WebrtcSTUNConfig
	Redis            RedisConfig
	Mysql            MysqlConfig
	Postgres         PostgresConfig
	// SIP global transport overrides
	// if you have dedicated interface like POD ip, set SIP_BIND_IP
	SIPBindIP          string `env:"SIP_BIND_IP" envDefault:""`
	SIPExternalHost    string `env:"SIP_EXTERNAL_HOST" envDefault:""`
	SIPExternalMediaIP string `env:"SIP_EXTERNAL_MEDIA_IP" envDefault:""`
	// SIP_HOSTNAME identifies that message are matching this hostname like REGISTER
	SIPHostname           string `env:"SIP_HOSTNAME" envDefault:""`
	RateLimiterIn         RateLimiterIncomingConfig
	RateLimiterOut        RateLimiterOutgoingConfig
	SIPRegisterBearerAuth SIPRegisterBearerAuthConfig

	// TLS
	ServerTLSKeyPath string `env:"SERVER_TLS_KEY_PATH" envDefault:""`
	ServerTLSCrtPath string `env:"SERVER_TLS_CRT_PATH" envDefault:""`
	ServerTLSKey     string `env:"SERVER_TLS_KEY" envDefault:""` // Base64 encoded key
	ServerTLSCrt     string `env:"SERVER_TLS_CRT" envDefault:""` // Base64 encoded CRT

	// Flow RPC
	FlowRPCAddr string `env:"FLOW_RPC_HTTP_ADDR" envDefault:":6000"`
}

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

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

type FlowRPC struct {
	Config Config
	// contains filtered or unexported fields
}

type FlowRequest struct {
	ID   string          `json:"id"`
	DID  string          `json:"did"`
	OP   string          `json:"op"`
	Data json.RawMessage `json:"data"`
	// contains filtered or unexported fields
}

type FlowResponse struct {
	ID     string          `json:"id"`
	DID    string          `json:"did"` // dialog ID
	Code   int             `json:"code"`
	Reason string          `json:"reason"`
	Data   json.RawMessage `json:"data"`
}

type Handler struct {
	CdrStore CDRStorage

	D *diago.Diago

	SIPtracer SIPTracer
	// contains filtered or unexported fields
}

type MysqlConfig struct {
	User     string `env:"MYSQL_USER" envDefault:"diagox"`
	Password string `env:"MYSQL_PASSWORD"`
	Database string `env:"MYSQL_DATABASE" envDefault:"diagox"`
	Host     string `env:"MYSQL_HOST" envDefault:""`
}

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

type PostgresConfig struct {
	User     string `env:"POSTGRES_USER" envDefault:"diagox"`
	Password string `env:"POSTGRES_PASSWORD"`
	Database string `env:"POSTGRES_DATABASE" envDefault:"diagox"`
	Host     string `env:"POSTGRES_HOST" envDefault:""`
}

type Providers struct {
	CDRStore  CDRStorage
	Registry  RegistryStore
	SIPTracer SIPTracer
	Cache     DialogExternalCache
	RateIn    *DialogRateLimiterIncoming
	RateOut   *DialogRateLimiterOutgoing
	Cleanup   []func()
}

type RateLimiterAtomic struct {
	Max int64
	RPS int64
	// contains filtered or unexported fields
}

type RateLimiterIn interface {
	DialogActiveLimit() bool
	DialogActiveDec()
	DialogRPSLimit() bool
}

type RateLimiterIncomingConfig struct {
	Enabled   bool  `env:"RATE_LIMITER_IN_ENABLED" envDefault:"false"`
	DialogRPS int64 `env:"RATE_LIMITER_IN_DIALOG_RPS"`
	DialogMax int64 `env:"RATE_LIMITER_IN_DIALOG_MAX"`
}

type RateLimiterOut interface {
	Block(log *slog.Logger, ctx context.Context) error
	DialogRPSLimit() bool
}

type RateLimiterOutgoingConfig struct {
	Enabled   bool  `env:"RATE_LIMITER_OUT_ENABLED" envDefault:"false"`
	DialogRPS int64 `env:"RATE_LIMITER_OUT_DIALOG_RPS"`
}

type RedisConfig struct {
	Addr              string `env:"REDIS_ADDR" envDefault:""` // Addr holds the address to connect with Redis. If multiple addresses are provided seperated by comma, then redis cluster is being used
	Username          string `env:"REDIS_USERNAME" envDefault:""`
	Password          string `env:"REDIS_PASSWORD" envDefault:""`
	CacheEnabled      bool   `env:"REDIS_CACHE" envDefault:"true"`
	SentinelMasterSet string `env:"REDIS_SENTINEL_MASTER_SET" envDefault:""`
	CacheConnSizeMB   int    `env:"REDIS_CACHE_CONN_SIZE_MB" envDefault:"32"`
}

type RegisterBinding struct {
	Aor        sip.Uri
	CallID     string
	Contacts   []sip.Uri
	Expiry     time.Duration
	TenantID   string // TODO should be mapped from tenant_host to id
	SourceAddr string
	Transport  string
}

type Registrar struct {
	Hostname    string
	Registry    RegistryStore
	DigestStore UserDigestAuthStore
	BearerStore UserBearerAuthStore
	// contains filtered or unexported fields
}

type RegistryMemory struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type RegistryStore interface {
	// TODO add context
	RegisterBindingSet(id string, r RegisterBinding) error
	RegisterBindingDelete(id string) error
	RegisterBindingContactDelete(id string, contactAddress sip.Uri) error
	RegisterBindingGet(id string) (RegisterBinding, error)
}

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

type SIPRegisterBearerAuthConfig struct {
	URL           string        `env:"SIP_REGISTER_BEARER_AUTH_URL" envDefault:""`
	Timeout       time.Duration `env:"SIP_REGISTER_BEARER_AUTH_TIMEOUT"`
	IdentityField string        `env:"SIP_REGISTER_BEARER_AUTH_IDENTITY_FIELD"`
	ActiveField   string        `env:"SIP_REGISTER_BEARER_AUTH_ACTIVE_FIELD"`
	Header        string        `env:"SIP_REGISTER_BEARER_AUTH_HEADER" envDefault:""`
}

type SIPTrace struct {
	Created          time.Time
	RW               int // 0 read 1 write
	Transport        string
	Laddr            string
	Raddr            string
	CallID           string
	OriginatorCallID string
	Msg              string
}

type SIPTracer interface {
	sip.SIPTracer
	SIPTraceFind(callID string, f func(m SIPTrace))
}

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

type UserAuthStoreBearerHTTP struct {
	HTTPClient *http.Client
	Config     SIPRegisterBearerAuthConfig
}

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

type UserBearerAuth struct {
	User   string
	Token  string
	Method string
}

type UserBearerAuthStore interface {
	UserAuthenticateBearer(ctx context.Context, auth UserBearerAuth) error
}

type UserDigestAuthStore interface {
	// TODO extend with tenant domain
	UserReadDigestAuth(user string, auth *diago.DigestAuth) error
}

type WebrtcSTUNConfig struct {
	Enabled  bool   `env:"WEBRTC_STUN_ENABLED" envDefault:"false"`
	BindIP   string `env:"WEBRTC_STUN_BIND_IP" envDefault:"0.0.0.0"`
	Port     int    `env:"WEBRTC_STUN_PORT" envDefault:"3478"`
	PublicIP string `env:"WEBRTC_STUN_PUBLIC_IP" envDefault:""`
	Realm    string `env:"WEBRTC_STUN_REALM" envDefault:"diagox"`
	Username string `env:"WEBRTC_STUN_USERNAME" envDefault:""`
	Password string `env:"WEBRTC_STUN_PASSWORD" envDefault:""`
}