package src import ( "fmt" "path/filepath" "strconv" "strings" "github.com/zoriya/go-mediainfo" ) type MediaInfo struct { // closed if the mediainfo is ready for read. open otherwise ready <-chan struct{} // The sha1 of the video file. Sha string `json:"sha"` /// The internal path of the video file. Path string `json:"path"` /// The extension currently used to store this video file Extension string `json:"extension"` /// The file size of the video file. Size uint64 `json:"size"` /// The length of the media in seconds. Duration float32 `json:"duration"` /// The container of the video file of this episode. Container *string `json:"container"` /// The video codec and infromations. Video *Video `json:"video"` /// The list of videos if there are multiples. Videos []Video `json:"videos"` /// The list of audio tracks. Audios []Audio `json:"audios"` /// The list of subtitles tracks. Subtitles []Subtitle `json:"subtitles"` /// The list of fonts that can be used to display subtitles. Fonts []string `json:"fonts"` /// The list of chapters. See Chapter for more information. Chapters []Chapter `json:"chapters"` } type Video struct { /// The codec of this stream (defined as the RFC 6381). Codec string `json:"codec"` /// The language of this stream (as a ISO-639-2 language code) Language *string `json:"language"` /// The max quality of this video track. Quality Quality `json:"quality"` /// The width of the video stream Width uint32 `json:"width"` /// The height of the video stream Height uint32 `json:"height"` /// The average bitrate of the video in bytes/s Bitrate uint32 `json:"bitrate"` } type Audio struct { /// The index of this track on the media. Index uint32 `json:"index"` /// The title of the stream. Title *string `json:"title"` /// The language of this stream (as a ISO-639-2 language code) Language *string `json:"language"` /// The codec of this stream. Codec string `json:"codec"` /// Is this stream the default one of it's type? IsDefault bool `json:"isDefault"` /// Is this stream tagged as forced? (useful only for subtitles) IsForced bool `json:"isForced"` } type Subtitle struct { /// The index of this track on the media. Index uint32 `json:"index"` /// The title of the stream. Title *string `json:"title"` /// The language of this stream (as a ISO-639-2 language code) Language *string `json:"language"` /// The codec of this stream. Codec string `json:"codec"` /// The extension for the codec. Extension *string `json:"extension"` /// Is this stream the default one of it's type? IsDefault bool `json:"isDefault"` /// Is this stream tagged as forced? (useful only for subtitles) IsForced bool `json:"isForced"` /// The link to access this subtitle. Link *string `json:"link"` } type Chapter struct { /// The start time of the chapter (in second from the start of the episode). StartTime float32 `json:"startTime"` /// The end time of the chapter (in second from the start of the episode). EndTime float32 `json:"endTime"` /// The name of this chapter. This should be a human-readable name that could be presented to the user. Name string `json:"name"` // TODO: add a type field for Opening, Credits... } func ParseFloat(str string) float32 { f, err := strconv.ParseFloat(str, 32) if err != nil { return 0 } return float32(f) } func ParseUint(str string) uint32 { i, err := strconv.ParseUint(str, 10, 32) if err != nil { println(str) return 0 } return uint32(i) } func ParseUint64(str string) uint64 { i, err := strconv.ParseUint(str, 10, 64) if err != nil { println(str) return 0 } return i } func ParseTime(str string) float32 { x := strings.Split(str, ":") hours, minutes, sms := ParseFloat(x[0]), ParseFloat(x[1]), x[2] y := strings.Split(sms, ".") seconds, ms := ParseFloat(y[0]), ParseFloat(y[1]) return (hours*60.+minutes)*60. + seconds + ms/1000. } // Stolen from the cmp.Or code that is not yet released // Or returns the first of its arguments that is not equal to the zero value. // If no argument is non-zero, it returns the zero value. func Or[T comparable](vals ...T) T { var zero T for _, val := range vals { if val != zero { return val } } return zero } func Map[T, U any](ts []T, f func(T, int) U) []U { us := make([]U, len(ts)) for i := range ts { us[i] = f(ts[i], i) } return us } func OrNull(str string) *string { if str == "" { return nil } return &str } func Max(x, y uint32) uint32 { if x < y { return y } return x } var SubtitleExtensions = map[string]string{ "subrip": "srt", "ass": "ass", "vtt": "vtt", } var infos = NewCMap[string, *MediaInfo]() func GetInfo(path string, sha string, route string) (*MediaInfo, error) { var err error ret, _ := infos.GetOrCreate(sha, func() *MediaInfo { readyChan := make(chan struct{}) mi := &MediaInfo{ Sha: sha, ready: readyChan, } go func() { var val *MediaInfo val, err = getInfo(path, route) *mi = *val mi.ready = readyChan mi.Sha = sha close(readyChan) }() return mi }) <-ret.ready return ret, err } func getInfo(path string, route string) (*MediaInfo, error) { defer printExecTime("mediainfo for %s", path)() mi, err := mediainfo.Open(path) if err != nil { return nil, err } defer mi.Close() chapters_begin := ParseUint(mi.Parameter(mediainfo.StreamMenu, 0, "Chapters_Pos_Begin")) chapters_end := ParseUint(mi.Parameter(mediainfo.StreamMenu, 0, "Chapters_Pos_End")) attachments := strings.Split(mi.Parameter(mediainfo.StreamGeneral, 0, "Attachments"), " / ") if len(attachments) == 1 && attachments[0] == "" { attachments = make([]string, 0) } // fmt.Printf("%s", mi.Option("info_parameters", "")) ret := MediaInfo{ Path: path, // Remove leading . Extension: filepath.Ext(path)[1:], Size: ParseUint64(mi.Parameter(mediainfo.StreamGeneral, 0, "FileSize")), // convert ms to seconds Duration: ParseFloat(mi.Parameter(mediainfo.StreamGeneral, 0, "Duration")) / 1000, Container: OrNull(mi.Parameter(mediainfo.StreamGeneral, 0, "Format")), Videos: Map(make([]Video, ParseUint(mi.Parameter(mediainfo.StreamVideo, 0, "StreamCount"))), func(_ Video, i int) Video { return Video{ // This codec is not in the right format (does not include bitdepth...). Codec: mi.Parameter(mediainfo.StreamVideo, 0, "Format"), Language: OrNull(mi.Parameter(mediainfo.StreamVideo, 0, "Language")), Quality: QualityFromHeight(ParseUint(mi.Parameter(mediainfo.StreamVideo, 0, "Height"))), Width: ParseUint(mi.Parameter(mediainfo.StreamVideo, 0, "Width")), Height: ParseUint(mi.Parameter(mediainfo.StreamVideo, 0, "Height")), Bitrate: ParseUint( Or( mi.Parameter(mediainfo.StreamVideo, 0, "BitRate"), mi.Parameter(mediainfo.StreamVideo, 0, "OverallBitRate"), mi.Parameter(mediainfo.StreamVideo, 0, "BitRate_Nominal"), ), ), } }), Audios: Map(make([]Audio, ParseUint(mi.Parameter(mediainfo.StreamAudio, 0, "StreamCount"))), func(_ Audio, i int) Audio { return Audio{ Index: uint32(i), Title: OrNull(mi.Parameter(mediainfo.StreamAudio, i, "Title")), Language: OrNull(mi.Parameter(mediainfo.StreamAudio, i, "Language")), // TODO: format is invalid. Channels count missing... Codec: mi.Parameter(mediainfo.StreamAudio, i, "Format"), IsDefault: mi.Parameter(mediainfo.StreamAudio, i, "Default") == "Yes", IsForced: mi.Parameter(mediainfo.StreamAudio, i, "Forced") == "Yes", } }), Subtitles: Map(make([]Subtitle, ParseUint(mi.Parameter(mediainfo.StreamText, 0, "StreamCount"))), func(_ Subtitle, i int) Subtitle { format := strings.ToLower(mi.Parameter(mediainfo.StreamText, i, "Format")) if format == "utf-8" { format = "subrip" } extension := OrNull(SubtitleExtensions[format]) var link *string if extension != nil { x := fmt.Sprintf("%s/subtitle/%d.%s", route, i, *extension) link = &x } return Subtitle{ Index: uint32(i), Title: OrNull(mi.Parameter(mediainfo.StreamText, i, "Title")), Language: OrNull(mi.Parameter(mediainfo.StreamText, i, "Language")), Codec: format, Extension: extension, IsDefault: mi.Parameter(mediainfo.StreamText, i, "Default") == "Yes", IsForced: mi.Parameter(mediainfo.StreamText, i, "Forced") == "Yes", Link: link, } }), Chapters: Map(make([]Chapter, Max(chapters_end-chapters_begin, 1)-1), func(_ Chapter, i int) Chapter { return Chapter{ StartTime: ParseTime(mi.GetI(mediainfo.StreamMenu, 0, int(chapters_begin)+i, mediainfo.InfoName)), // +1 is safe, the value at chapters_end contains the right duration EndTime: ParseTime(mi.GetI(mediainfo.StreamMenu, 0, int(chapters_begin)+i+1, mediainfo.InfoName)), Name: mi.GetI(mediainfo.StreamMenu, 0, int(chapters_begin)+i, mediainfo.InfoText), } }), Fonts: Map( attachments, func(font string, _ int) string { return fmt.Sprintf("%s/attachment/%s", route, font) }), } if len(ret.Videos) > 0 { ret.Video = &ret.Videos[0] } return &ret, nil }