proxy

type Identifier uint64

type Metadata struct {
	Time       time.Time
	Identifier Identifier
	User       radio.User
	MountName  string
	Addr       string

	Value string
}

type MetadataWriter interface {
	io.Writer
	SendMetadata(ctx context.Context, metadata *Metadata)
}

type Mount struct {

	// ContentType of this mount, this can only be set during creation and all
	// future clients afterwards will use the same content type
	ContentType string
	// Name of the mountpoint
	Name string

	// Conn is the conn to the icecast server
	Conn *util.TypedValue[net.Conn]

	// Sources is the different sources of audio data, the mount
	// broadcasts the data of the first entry and voids the others
	SourcesMu *sync.RWMutex
	Sources   []*MountSourceClient
	// contains filtered or unexported fields
}

type MountMetadataWriter struct {

	// metadata is the last metadata we send (or tried to send)
	Metadata string

	// live indicates if we are the live writer, actually writing to the master
	Live bool
	// out is the writer we write into
	Out io.Writer
	// contains filtered or unexported fields
}

type MountSourceClient struct {
	// Source is the SourceClient we're handling, should not be mutated by
	// anything once the MountSourceClient is made
	Source *SourceClient
	// Priority is the Priority for live-ness determination
	// lower is higher Priority
	Priority uint
	// MW is the writer this source is writing to
	MW *MountMetadataWriter
	// contains filtered or unexported fields
}

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

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

type SourceClient struct {
	ID SourceID
	// UserAgent is the User-Agent HTTP header passed by the client
	UserAgent string
	// ContentType is the Content-Type HTTP header passed by the client
	ContentType string

	// MountName is the mount this client is trying to stream to
	MountName string
	// User is the user that is trying to stream
	User radio.User
	// Identifier is an identifier that should be the same between two
	// different requests, but same mountpoint and user. This is to match-up
	// metadata information
	Identifier Identifier
	// Metadata is a pointer to the last Metadata received for this client
	Metadata *atomic.Pointer[Metadata]
	// contains filtered or unexported fields
}

type SourceID struct {
	xid.ID
}