fc2

package
v0.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 1, 2023 License: MIT Imports: 25 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrWebSocketServerDisconnection = errors.New("server disconnected")
	ErrWebSocketPaidProgram         = errors.New("paid program")
	ErrWebSocketLoginRequired       = errors.New("login required")
	ErrWebSocketMultipleConnection  = errors.New("multiple connection error")
	ErrWebSocketStreamEnded         = errors.New("stream ended")
	ErrWebSocketEmptyPlaylist       = errors.New("server did not return a valid playlist")
)
View Source 
var ErrLiveStreamNotOnline = errors.New("live stream is not online")
View Source 
var ErrUnknownLatency = errors.New("unknown latency")
View Source 
var ErrUnknownQuality = errors.New("unknown quality")

Functions

This section is empty.

Types

type ChannelData 

type ChannelData struct {
	ChannelID           string                `json:"channelid"`
	UserID              string                `json:"userid"`
	Adult               int                   `json:"adult"`
	Twoshot             int                   `json:"twoshot"`
	Title               string                `json:"title"`
	Info                string                `json:"info"`
	Image               string                `json:"image"`
	LoginOnly           int                   `json:"login_only"`
	GiftLimit           int                   `json:"gift_limit"`
	GiftList            []ChannelDataGiftList `json:"gift_list"`
	CommentLimit        string                `json:"comment_limit"`
	Tfollow             int                   `json:"tfollow"`
	Tname               string                `json:"tname"`
	Fee                 int                   `json:"fee"`
	Amount              int                   `json:"amount"`
	Interval            int                   `json:"interval"`
	Category            string                `json:"category"`
	CategoryName        string                `json:"category_name"`
	IsOfficial          int                   `json:"is_official"`
	IsPremiumPublisher  int                   `json:"is_premium_publisher"`
	IsLinkShare         int                   `json:"is_link_share"`
	Ticketid            int                   `json:"ticketid"`
	IsPremium           int                   `json:"is_premium"`
	TicketPrice         int                   `json:"ticket_price"`
	TicketOnly          int                   `json:"ticket_only"`
	IsApp               int                   `json:"is_app"`
	IsVideo             int                   `json:"is_video"`
	IsREST              int                   `json:"is_rest"`
	Count               int                   `json:"count"`
	IsPublish           int                   `json:"is_publish"`
	IsLimited           int                   `json:"is_limited"`
	Start               int                   `json:"start"`
	Version             string                `json:"version"`
	Fc2Channel          Fc2Channel            `json:"fc2_channel"`
	ControlTag          string                `json:"control_tag"`
	PublishMethod       string                `json:"publish_method"`
	VideoStereo3D       interface{}           `json:"video_stereo3d"`
	VideoMapping        interface{}           `json:"video_mapping"`
	VideoHorizontalView interface{}           `json:"video_horizontal_view"`
}

type ChannelDataGiftList 

type ChannelDataGiftList struct {
	ID   int      `json:"id"`
	Type int      `json:"type"`
	URL  []string `json:"url"`
	Name string   `json:"name"`
}

type Comment 

type Comment struct {
	UserName        string `json:"user_name"`
	Comment         string `json:"comment"`
	Timestamp       int    `json:"timestamp"`
	EncryptedUserID string `json:"encrypted_user_id"`
	OrzToken        string `json:"orz_token"`
	Hash            string `json:"hash"`
	Color           string `json:"color"`
	Size            string `json:"size"`
	Lang            string `json:"lang"`
	Anonymous       int    `json:"anonymous"`
	History         int    `json:"history"`
}

type CommentArguments 

type CommentArguments struct {
	Comments []Comment `json:"comments"`
}

type ControlDisconnectionArguments 

type ControlDisconnectionArguments struct {
	Code int `json:"code"`
}

type ControlToken 

type ControlToken struct {
	ChannelID      string `json:"channel_id"`
	UserID         string `json:"user_id"`
	Fc2ID          string `json:"fc2_id"`
	OrzToken       string `json:"orz_token"`
	SessionToken   string `json:"session_token"`
	Premium        int    `json:"premium"`
	Mode           string `json:"mode"`
	Language       string `json:"language"`
	ClientType     string `json:"client_type"`
	ClientApp      string `json:"client_app"`
	ClientVersion  string `json:"client_version"`
	AppInstallKey  string `json:"app_install_key"`
	ChannelVersion string `json:"channel_version"`
	ControlTag     string `json:"control_tag"`
	Ipv6           string `json:"ipv6"`
	Commentable    bool   `json:"commentable"`
	jwt.RegisteredClaims
}

type FC2 

type FC2 struct {
	*http.Client
	// contains filtered or unexported fields
}

func NewDownloader 

func NewDownloader(client *http.Client, params *Params) *FC2

func (*FC2) Download 

func (f *FC2) Download(ctx context.Context, channelID string) error

func (*FC2) FetchPlaylist 

func (f *FC2) FetchPlaylist(
	ctx context.Context,
	ws *WebSocket,
	conn *websocket.Conn,
	msgChan chan *WSResponse,
) (*Playlist, error)

func (*FC2) HandleWS 

func (f *FC2) HandleWS(
	ctx context.Context,
	wsURL string,
	fnameStream string,
	fnameChat string,
) error

type Fc2Channel 

type Fc2Channel struct {
	Result      int           `json:"result"`
	UserID      int           `json:"userid"`
	Fc2ID       int           `json:"fc2id"`
	Adult       int           `json:"adult"`
	Title       string        `json:"title"`
	Description string        `json:"description"`
	URL         string        `json:"url"`
	Images      []interface{} `json:"images"`
}

type GetControlServerResponse 

type GetControlServerResponse struct {
	URL          string `json:"url"`
	Orz          string `json:"orz"`
	OrzRaw       string `json:"orz_raw"`
	ControlToken string `json:"control_token"`
	Status       int    `json:"status"`
}

type GetMetaData 

type GetMetaData struct {
	ChannelData ChannelData `json:"channel_data"`
	ProfileData ProfileData `json:"profile_data"`
	UserData    UserData    `json:"user_data"`
}

type GetMetaOptions 

type GetMetaOptions struct {
	Refetch bool
}

type GetMetaResponse 

type GetMetaResponse struct {
	Status int         `json:"status"`
	Data   GetMetaData `json:"data"`
}

type HLSInformation 

type HLSInformation struct {
	Status                 int        `json:"status"`
	Playlists              []Playlist `json:"playlists"`
	PlaylistsHighLatency   []Playlist `json:"playlists_high_latency"`
	PlaylistsMiddleLatency []Playlist `json:"playlists_middle_latency"`
}

type Latency 

type Latency int
const (
	LatencyUnknown Latency = 0
	LatencyLow     Latency = 1
	LatencyHigh    Latency = 2
	LatencyMid     Latency = 3
)

func LatencyFromMode 

func LatencyFromMode(mode int) Latency

func LatencyParseString 

func LatencyParseString(value string) Latency

func (Latency) String 

func (l Latency) String() string

func (*Latency) UnmarshalText 

func (l *Latency) UnmarshalText(text []byte) error

type LiveStream 

type LiveStream struct {
	*http.Client
	ChannelID string
	// contains filtered or unexported fields
}

func NewLiveStream 

func NewLiveStream(client *http.Client, channelID string) *LiveStream

func (*LiveStream) GetMeta 

func (ls *LiveStream) GetMeta(ctx context.Context, options ...GetMetaOptions) (*GetMetaData, error)

func (*LiveStream) GetWebSocketURL 

func (ls *LiveStream) GetWebSocketURL(ctx context.Context) (string, error)

func (*LiveStream) IsOnline 

func (ls *LiveStream) IsOnline(ctx context.Context, options ...GetMetaOptions) (bool, error)

func (*LiveStream) WaitForOnline 

func (ls *LiveStream) WaitForOnline(ctx context.Context, interval time.Duration) error

type OptionalParams 

type OptionalParams struct {
	Quality                *Quality          `yaml:"quality"`
	Latency                *Latency          `yaml:"latency"`
	PacketLossMax          *int              `yaml:"packetLossMax"`
	OutFormat              *string           `yaml:"outFormat"`
	WriteChat              *bool             `yaml:"writeChat"`
	WriteInfoJSON          *bool             `yaml:"writeInfoJson"`
	WriteThumbnail         *bool             `yaml:"writeThumbnail"`
	WaitForLive            *bool             `yaml:"waitForLive"`
	WaitForQualityMaxTries *int              `yaml:"waitForQualityMaxTries"`
	WaitPollInterval       *time.Duration    `yaml:"waitPollInterval"`
	CookiesFile            *string           `yaml:"cookiesFile"`
	Remux                  *bool             `yaml:"remux"`
	KeepIntermediates      *bool             `yaml:"keepIntermediates"`
	ExtractAudio           *bool             `yaml:"extractAudio"`
	Labels                 map[string]string `yaml:"labels"`
}

func (*OptionalParams) Override 

func (override *OptionalParams) Override(params *Params)

type Params 

type Params struct {
	Quality                Quality           `yaml:"quality"`
	Latency                Latency           `yaml:"latency"`
	PacketLossMax          int               `yaml:"packetLossMax"`
	OutFormat              string            `yaml:"outFormat"`
	WriteChat              bool              `yaml:"writeChat"`
	WriteInfoJSON          bool              `yaml:"writeInfoJson"`
	WriteThumbnail         bool              `yaml:"writeThumbnail"`
	WaitForLive            bool              `yaml:"waitForLive"`
	WaitForQualityMaxTries int               `yaml:"waitForQualityMaxTries"`
	WaitPollInterval       time.Duration     `yaml:"waitPollInterval"`
	CookiesFile            string            `yaml:"cookiesFile"`
	Remux                  bool              `yaml:"remux"`
	KeepIntermediates      bool              `yaml:"keepIntermediates"`
	ExtractAudio           bool              `yaml:"extractAudio"`
	Labels                 map[string]string `yaml:"labels"`
}
var DefaultParams Params = Params{
	Quality:                Quality1_2MBps,
	Latency:                LatencyMid,
	PacketLossMax:          200,
	OutFormat:              "{{ .Date }} {{ .Title }} ({{ .ChannelName }}).{{ .Ext }}",
	WriteChat:              false,
	WriteInfoJSON:          false,
	WriteThumbnail:         false,
	WaitForLive:            true,
	WaitForQualityMaxTries: 10,
	WaitPollInterval:       5 * time.Second,
	CookiesFile:            "",
	Remux:                  true,
	KeepIntermediates:      false,
	ExtractAudio:           false,
	Labels:                 nil,
}

func (*Params) Clone 

func (p *Params) Clone() *Params

type Playlist 

type Playlist struct {
	Mode   int    `json:"mode"`
	Status int    `json:"status"`
	URL    string `json:"url"`
}

func ExtractAndMergePlaylists 

func ExtractAndMergePlaylists(hlsInfo *HLSInformation) []Playlist

func GetPlaylistOrBest 

func GetPlaylistOrBest(sortedPlaylists []Playlist, expectMode int) (*Playlist, error)

func SortPlaylists 

func SortPlaylists(playlists []Playlist) []Playlist

type ProfileData 

type ProfileData struct {
	UserID string `json:"userid"`
	Fc2ID  string `json:"fc2id"`
	Name   string `json:"name"`
	Info   string `json:"info"`
	Icon   string `json:"icon"`
	Image  string `json:"image"`
	Sex    string `json:"sex"`
	Age    string `json:"age"`
}

type Quality 

type Quality int
const (
	QualityUnknown Quality = 0
	Quality150KBps Quality = 10
	Quality400KBps Quality = 20
	Quality1_2MBps Quality = 30
	Quality2MBps   Quality = 40
	Quality3MBps   Quality = 50
	QualitySound   Quality = 90
)

func QualityFromMode 

func QualityFromMode(mode int) Quality

func QualityParseString 

func QualityParseString(value string) Quality

func (Quality) String 

func (q Quality) String() string

func (*Quality) UnmarshalText 

func (q *Quality) UnmarshalText(text []byte) error

type Stamina 

type Stamina struct {
	Timestamp int             `json:"timestamp"`
	Stamina   [][]interface{} `json:"stamina"`
}

type UserData 

type UserData struct {
	IsLogin       int                `json:"is_login"`
	UserID        int                `json:"userid"`
	Fc2ID         int                `json:"fc2id"`
	Icon          string             `json:"icon"`
	Name          string             `json:"name"`
	Point         int                `json:"point"`
	AdultAccess   int                `json:"adult_access"`
	Recauth       int                `json:"recauth"`
	IsPremiumUser int                `json:"is_premium_user"`
	GiftList      []UserDataGiftList `json:"gift_list"`
	Stamina       Stamina            `json:"stamina"`
}

type UserDataGiftList 

type UserDataGiftList struct {
	ID       int `json:"id"`
	Category int `json:"category"`
	Amount   int `json:"amount"`
}

type WSResponse 

type WSResponse struct {
	ID        int             `json:"id,omitempty"`
	Name      string          `json:"name"`
	Arguments json.RawMessage `json:"arguments"`
}

type WebSocket 

type WebSocket struct {
	*http.Client
	// contains filtered or unexported fields
}

func NewWebSocket 

func NewWebSocket(
	client *http.Client,
	url string,
	healthCheckInterval time.Duration,
) *WebSocket

func (*WebSocket) Dial 

func (w *WebSocket) Dial(ctx context.Context) (*websocket.Conn, error)

func (*WebSocket) GetHLSInformation 

func (w *WebSocket) GetHLSInformation(
	ctx context.Context,
	conn *websocket.Conn,
	msgChan <-chan *WSResponse,
) (*HLSInformation, error)

func (*WebSocket) HeartbeatLoop added in v0.3.0 

func (w *WebSocket) HeartbeatLoop(ctx context.Context, conn *websocket.Conn) error

HeartbeatLoop sends a heartbeat to keep the ws alive.

The only way to exit the heartbeat loop is to have the WS socket closed or to cancel the context.

func (*WebSocket) Listen 

func (w *WebSocket) Listen(
	ctx context.Context,
	conn *websocket.Conn,
	msgChan chan<- *WSResponse,
	commentChan chan<- *Comment,
) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.