From a50f35aac306bbbb164878e3530b8f1669c676de Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?P=C5=99emysl=20Janouch?= Date: Tue, 25 Oct 2016 00:21:26 +0200 Subject: Little improvements --- LICENSE | 3 +- bbc-on-ice.go | 257 ---------------------------------------------------------- main.go | 257 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ 3 files changed, 258 insertions(+), 259 deletions(-) delete mode 100644 bbc-on-ice.go create mode 100644 main.go diff --git a/LICENSE b/LICENSE index 3bc6282..7678a10 100644 --- a/LICENSE +++ b/LICENSE @@ -1,5 +1,4 @@ -Copyright (c) 2016, Přemysl Janouch -All rights reserved. +Copyright (c) 2016 - 2017, Přemysl Janouch Permission to use, copy, modify, and/or distribute this software for any purpose with or without fee is hereby granted, provided that the above diff --git a/bbc-on-ice.go b/bbc-on-ice.go deleted file mode 100644 index 57f5539..0000000 --- a/bbc-on-ice.go +++ /dev/null @@ -1,257 +0,0 @@ -package main - -import ( - "context" - "encoding/json" - "errors" - "fmt" - "io" - "io/ioutil" - "log" - "net/http" - "os" - "path" - "regexp" - "strings" - "time" - "unicode/utf8" -) - -type meta struct { - title string // What's playing right now - timeout uint // Timeout for the next poll in ms -} - -// Retrieve and decode metadata information from an independent webservice -func getMeta(name string) (*meta, error) { - const metaBaseURI = "http://polling.bbc.co.uk/radio/nhppolling/" - resp, err := http.Get(metaBaseURI + name) - if err != nil { - return nil, err - } - b, err := ioutil.ReadAll(resp.Body) - resp.Body.Close() - if len(b) < 2 { - // There needs to be an enclosing () pair - return nil, errors.New("invalid metadata response") - } - - // TODO: also retrieve richtracks/is_now_playing, see example file - type broadcast struct { - Title string `json:"title"` // Title of the broadcast - Percentage int `json:"percentage"` // How far we're in - } - var v struct { - Packages struct { - OnAir struct { - Broadcasts []broadcast `json:"broadcasts"` - BroadcastNowIndex uint `json:"broadcastNowIndex"` - } `json:"on-air"` - } `json:"packages"` - Timeouts struct { - PollingTimeout uint `json:"polling_timeout"` - } `json:"timeouts"` - } - err = json.Unmarshal(b[1:len(b)-1], &v) - if err != nil { - return nil, errors.New("invalid metadata response") - } - onAir := v.Packages.OnAir - if onAir.BroadcastNowIndex >= uint(len(onAir.Broadcasts)) { - return nil, errors.New("no active broadcast") - } - return &meta{ - timeout: v.Timeouts.PollingTimeout, - title: onAir.Broadcasts[onAir.BroadcastNowIndex].Title, - }, nil -} - -// Resolve an M3U8 playlist to the first link that seems to be playable -func resolveM3U8(target string) (out []string, err error) { - resp, err := http.Get(target) - if err != nil { - return nil, err - } - b, err := ioutil.ReadAll(resp.Body) - resp.Body.Close() - if !utf8.Valid(b) { - return nil, errors.New("invalid UTF-8") - } - lines := strings.Split(string(b), "\n") - for _, line := range lines { - if strings.HasPrefix(line, "#") { - continue - } - if !strings.Contains(line, "/") { - // Seems to be a relative link, let's make it absolute - dir, _ := path.Split(target) - line = dir + line - } - if strings.HasSuffix(line, "m3u8") { - // The playlist seems to recurse, and so do we - return resolveM3U8(line) - } - out = append(out, line) - } - return out, nil -} - -func metaProc(ctx context.Context, name string, out chan<- string) { - var current, last string - var interval time.Duration - for { - meta, err := getMeta(name) - if err != nil { - current = "Error: " + err.Error() - interval = 30 * time.Second - } else { - current = meta.title - interval = time.Duration(meta.timeout) - } - // TODO: select on the send? Can't close it in the main proc. - // Also see https://blog.golang.org/pipelines - if current != last { - out <- current - last = current - } - - select { - case <-time.After(time.Duration(interval) * time.Millisecond): - case <-ctx.Done(): - return - } - } -} - -var pathRE = regexp.MustCompile(`^/(.*?)/(.*?)/(.*?)$`) - -func proxy(w http.ResponseWriter, req *http.Request) { - const targetURI = "http://a.files.bbci.co.uk/media/live/manifesto/" + - "audio/simulcast/hls/%s/%s/ak/%s.m3u8" - const metaint = 1 << 16 - m := pathRE.FindStringSubmatch(req.URL.Path) - if m == nil { - http.NotFound(w, req) - return - } - hijacker, ok := w.(http.Hijacker) - if !ok { - // We're not using TLS where HTTP/2 could have caused this - panic("cannot hijack connection") - } - - // E.g. `nonuk`, `sbr_low` `bbc_radio_one`, or `uk`, `sbr_high`, `bbc_1xtra` - region, quality, name := m[1], m[2], m[3] - // This validates the params as a side-effect - target, err := resolveM3U8(fmt.Sprintf(targetURI, region, quality, name)) - if err == nil && len(target) == 0 { - err = errors.New("cannot resolve playlist") - } - if err != nil { - http.Error(w, err.Error(), http.StatusInternalServerError) - return - } - - wantMeta := false - if icyMeta, ok := req.Header["Icy-MetaData"]; ok { - wantMeta = len(icyMeta) == 1 && icyMeta[0] == "1" - } - resp, err := http.Get(target[0]) - if err != nil { - http.Error(w, err.Error(), http.StatusInternalServerError) - return - } - - conn, bufrw, err := hijacker.Hijack() - if err != nil { - http.Error(w, err.Error(), http.StatusInternalServerError) - return - } - defer conn.Close() - - // TODO: retrieve some general information from somewhere? - // There's nothing interesting in the playlist files. - fmt.Fprintf(bufrw, "ICY 200 OK\r\n") - fmt.Fprintf(bufrw, "icy-name:%s\r\n", name) - // BBC marks this as a video type, maybe just force audio/mpeg - fmt.Fprintf(bufrw, "content-type:%s\r\n", resp.Header["Content-Type"][0]) - fmt.Fprintf(bufrw, "icy-pub:%d\r\n", 0) - if wantMeta { - fmt.Fprintf(bufrw, "icy-metaint: %d\r\n", metaint) - } - fmt.Fprintf(bufrw, "\r\n") - - metaChan := make(chan string) - go metaProc(req.Context(), name, metaChan) - - // TODO: move to a normal function - // FIXME: this will load a few seconds (one URL) and die - // - we can either try to implement this and hope for the best - // https://tools.ietf.org/html/draft-pantos-http-live-streaming-20 - // then like https://github.com/kz26/gohls/blob/master/main.go - // - or we can become more of a proxy, which complicates ICY - chunkChan := make(chan []byte) - go func() { - defer resp.Body.Close() - defer close(chunkChan) - for { - chunk := make([]byte, metaint) - n, err := io.ReadFull(resp.Body, chunk) - chunkChan <- chunk[:n] - if err != nil { - return - } - - select { - default: - case <-req.Context().Done(): - return - } - } - }() - - var queuedMeta []byte - makeMetaChunk := func() []byte { - meta := queuedMeta - queuedMeta = nil - for len(meta)%16 != 0 { - meta = append(meta, 0) - } - if len(meta) > 16*255 { - meta = meta[:16*255] - } - chunk := []byte{byte(len(meta) / 16)} - return append(chunk, meta...) - } - - for { - select { - case title := <-metaChan: - queuedMeta = []byte(fmt.Sprintf("StreamTitle='%s'", title)) - case chunk, connected := <-chunkChan: - if !connected { - return - } - if wantMeta { - chunk = append(chunk, makeMetaChunk()...) - } - if _, err := bufrw.Write(chunk); err != nil { - return - } - if err := bufrw.Flush(); err != nil { - return - } - } - } -} - -func main() { - // TODO: also try to support systemd socket activation - address := ":8000" - if len(os.Args) == 2 { - address = os.Args[1] - } - - http.HandleFunc("/", proxy) - log.Fatal(http.ListenAndServe(address, nil)) -} diff --git a/main.go b/main.go new file mode 100644 index 0000000..efd0978 --- /dev/null +++ b/main.go @@ -0,0 +1,257 @@ +package main + +import ( + "context" + "encoding/json" + "errors" + "fmt" + "io" + "io/ioutil" + "log" + "net/http" + "os" + "path" + "regexp" + "strings" + "time" + "unicode/utf8" +) + +type meta struct { + title string // What's playing right now + timeout uint // Timeout for the next poll in ms +} + +// Retrieve and decode metadata information from an independent webservice +func getMeta(name string) (*meta, error) { + const metaBaseURI = "http://polling.bbc.co.uk/radio/nhppolling/" + resp, err := http.Get(metaBaseURI + name) + if resp != nil { + defer resp.Body.Close() + } + if err != nil { + return nil, err + } + b, err := ioutil.ReadAll(resp.Body) + if len(b) < 2 { + // There needs to be an enclosing () pair + return nil, errors.New("invalid metadata response") + } + + // TODO: also retrieve richtracks/is_now_playing, see example file + type broadcast struct { + Title string // Title of the broadcast + Percentage int // How far we're in + } + var v struct { + Packages struct { + OnAir struct { + Broadcasts []broadcast + BroadcastNowIndex uint + } `json:"on-air"` + } + Timeouts struct { + PollingTimeout uint `json:"polling_timeout"` + } + } + err = json.Unmarshal(b[1:len(b)-1], &v) + if err != nil { + return nil, errors.New("invalid metadata response") + } + onAir := v.Packages.OnAir + if onAir.BroadcastNowIndex >= uint(len(onAir.Broadcasts)) { + return nil, errors.New("no active broadcast") + } + return &meta{ + timeout: v.Timeouts.PollingTimeout, + title: onAir.Broadcasts[onAir.BroadcastNowIndex].Title, + }, nil +} + +// Resolve an M3U8 playlist to the first link that seems to be playable +func resolveM3U8(target string) (out []string, err error) { + resp, err := http.Get(target) + if resp != nil { + defer resp.Body.Close() + } + if err != nil { + return nil, err + } + b, err := ioutil.ReadAll(resp.Body) + if !utf8.Valid(b) { + return nil, errors.New("invalid UTF-8") + } + lines := strings.Split(string(b), "\n") + for _, line := range lines { + if strings.HasPrefix(line, "#") { + continue + } + if !strings.Contains(line, "/") { + // Seems to be a relative link, let's make it absolute + dir, _ := path.Split(target) + line = dir + line + } + if strings.HasSuffix(line, "m3u8") { + // The playlist seems to recurse, and so do we + return resolveM3U8(line) + } + out = append(out, line) + } + return out, nil +} + +func metaProc(ctx context.Context, name string, out chan<- string) { + defer close(out) + + var current, last string + var interval time.Duration + for { + meta, err := getMeta(name) + if err != nil { + current = "Error: " + err.Error() + interval = 30 * time.Second + } else { + current = meta.title + interval = time.Duration(meta.timeout) + } + if current != last { + // TODO: see https://blog.golang.org/pipelines + // find out if we can do this better + select { + case out <- current: + case <-ctx.Done(): + return + } + last = current + } + + select { + case <-time.After(time.Duration(interval) * time.Millisecond): + case <-ctx.Done(): + return + } + } +} + +var pathRE = regexp.MustCompile(`^/(.*?)/(.*?)/(.*?)$`) + +func proxy(w http.ResponseWriter, req *http.Request) { + const targetURI = "http://a.files.bbci.co.uk/media/live/manifesto/" + + "audio/simulcast/hls/%s/%s/ak/%s.m3u8" + const metaint = 1 << 16 + m := pathRE.FindStringSubmatch(req.URL.Path) + if m == nil { + http.NotFound(w, req) + return + } + hijacker, ok := w.(http.Hijacker) + if !ok { + // We're not using TLS where HTTP/2 could have caused this + panic("cannot hijack connection") + } + + // E.g. `nonuk`, `sbr_low` `bbc_radio_one`, or `uk`, `sbr_high`, `bbc_1xtra` + region, quality, name := m[1], m[2], m[3] + // This validates the params as a side-effect + target, err := resolveM3U8(fmt.Sprintf(targetURI, region, quality, name)) + if err == nil && len(target) == 0 { + err = errors.New("cannot resolve playlist") + } + if err != nil { + http.Error(w, err.Error(), http.StatusInternalServerError) + return + } + + wantMeta := false + if icyMeta, ok := req.Header["Icy-MetaData"]; ok { + wantMeta = len(icyMeta) == 1 && icyMeta[0] == "1" + } + resp, err := http.Get(target[0]) + if err != nil { + http.Error(w, err.Error(), http.StatusInternalServerError) + return + } + + conn, bufrw, err := hijacker.Hijack() + if err != nil { + http.Error(w, err.Error(), http.StatusInternalServerError) + return + } + defer conn.Close() + + // TODO: retrieve some general information from somewhere? + // There's nothing interesting in the playlist files. + fmt.Fprintf(bufrw, "ICY 200 OK\r\n") + fmt.Fprintf(bufrw, "icy-name:%s\r\n", name) + // BBC marks this as a video type, maybe just force audio/mpeg + fmt.Fprintf(bufrw, "content-type:%s\r\n", resp.Header["Content-Type"][0]) + fmt.Fprintf(bufrw, "icy-pub:%d\r\n", 0) + if wantMeta { + fmt.Fprintf(bufrw, "icy-metaint: %d\r\n", metaint) + } + fmt.Fprintf(bufrw, "\r\n") + + metaChan := make(chan string) + go metaProc(req.Context(), name, metaChan) + + // TODO: move to a normal function + // FIXME: this will load a few seconds (one URL) and die + // - we can either try to implement this and hope for the best + // https://tools.ietf.org/html/draft-pantos-http-live-streaming-20 + // then like https://github.com/kz26/gohls/blob/master/main.go + // - or we can become more of a proxy, which complicates ICY + chunkChan := make(chan []byte) + go func() { + defer resp.Body.Close() + defer close(chunkChan) + for { + chunk := make([]byte, metaint) + n, err := io.ReadFull(resp.Body, chunk) + chunkChan <- chunk[:n] + if err != nil { + return + } + + select { + default: + case <-req.Context().Done(): + return + } + } + }() + + var queuedMeta []byte + for { + select { + case title := <-metaChan: + queuedMeta = []byte(fmt.Sprintf("StreamTitle='%s'", title)) + case chunk, ok := <-chunkChan: + if !ok { + return + } + if wantMeta { + var meta [1 + 16*255]byte + meta[0] = byte((copy(meta[1:], queuedMeta) + 15) / 16) + chunk = append(chunk, meta[:1+int(meta[0])*16]...) + queuedMeta = nil + } + if _, err := bufrw.Write(chunk); err != nil { + return + } + if err := bufrw.Flush(); err != nil { + return + } + } + } +} + +func main() { + // TODO: also try to support systemd socket activation + address := ":8000" + if len(os.Args) == 2 { + address = os.Args[1] + } + + http.HandleFunc("/", proxy) + log.Fatal(http.ListenAndServe(address, nil)) +} -- cgit v1.2.3