Mirrors/iptv-proxy
1
0
Fork 0
mirror of https://github.com/pierre-emmanuelJ/iptv-proxy.git synced 2026-03-17 23:42:57 +01:00
Code Issues Packages Projects Releases Wiki Activity

Add an new hls xtream protocol

Browse Source 
Signed-off-by: Pierre-Emmanuel Jacquier <15922119+pierre-emmanuelJ@users.noreply.github.com>
This commit is contained in:
Pierre-Emmanuel Jacquier
2021-03-19 00:12:52 +01:00
parent 08bbf139c5
commit d3d0f998e2
2 changed files with 16 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
pkg/server/routes.go
View File

@@ -57,7 +57,8 @@ func (c *Config) xtreamRoutes(r *gin.RouterGroup) {
r.GET(fmt.Sprintf("/live/%s/%s/:id", c.User, c.Password), c.xtreamStreamLive)
r.GET(fmt.Sprintf("/movie/%s/%s/:id", c.User, c.Password), c.xtreamStreamMovie)
r.GET(fmt.Sprintf("/series/%s/%s/:id", c.User, c.Password), c.xtreamStreamSeries)
r.GET(fmt.Sprintf("/hlsr/:token/%s/%s/:channel/:hash/:chunk", c.User, c.Password), c.hlsrStream)
r.GET(fmt.Sprintf("/hlsr/:token/%s/%s/:channel/:hash/:chunk", c.User, c.Password), c.xtreamHlsrStream)
r.GET("/hls/:token/:id", c.xtreamHlsStream)
}
func (c *Config) m3uRoutes(r *gin.RouterGroup) {

15
pkg/server/xtreamHandles.go
View File

@@ -242,7 +242,7 @@ func (c *Config) xtreamStreamSeries(ctx *gin.Context) {
c.xtreamStream(ctx, rpURL)
}
func (c *Config) hlsrStream(ctx *gin.Context) {
func (c *Config) xtreamHlsrStream(ctx *gin.Context) {
hlsChannelsRedirectURLLock.RLock()
url, ok := hlsChannelsRedirectURL[ctx.Param("channel")+".m3u8"]
if !ok {
@@ -339,3 +339,16 @@ func (c *Config) hlsXtreamStream(ctx *gin.Context, oriURL *url.URL) {
ctx.Status(resp.StatusCode)
}
func (c *Config) xtreamHlsStream(ctx *gin.Context) {
id := ctx.Param("id")
token := ctx.Param("token")
rpURL, err := url.Parse(fmt.Sprintf("%s/hls/%s/%s", c.XtreamBaseURL, token, id))
if err != nil {
ctx.AbortWithError(http.StatusInternalServerError, err) // nolint: errcheck
return
}
c.stream(ctx, rpURL)
}