hlsdl

README

HLS downloader

This is a library to support downloading a m3u8 file. All TS segments will be downloaded into a folder and then joined into a single TS file. The default file name is video.ts

Features:

• Concurrent download segments with multiple http connections
• Decrypt HLS-encoded segments
• Auto-retry download
• Display downloading progress bar
• Record a live stream video

Todo:

• Allow adding http headers

How to integrate this library into your code

Get the library

go get github.com/kuuy/hlsdl

then import it to your code.

import "github.com/kuuy/hlsdl"

Sample:

package main

import (
	"fmt"

	"github.com/kuuy/hlsdl"
)

func main() {
	hlsDL := hlsdl.New("https://bitdash-a.akamaihd.net/content/sintel/hls/video/1500kbit.m3u8", nil, "download", 64, true, "")
	
	filepath, err := hlsDL.Download()
	if err != nil {
		panic(err)
	}

	fmt.Println(filepath)
}

How to build a console application

Build for linux

make build-linux

Build for windows

make build-windows

Run the application

./bin/hlsdl --help

./bin/hlsdl -u https://bitdash-a.akamaihd.net/content/sintel/hls/video/1500kbit.m3u8 -d download -w 10

Record a live stream video

./bin/hlsdl --url "http://cdn1.live-tv.od.ua:8081/bbb/bbbtv-abr/bbb/bbbtv-720p/chunks.m3u8?nimblesessionid=62115268" --record true

Get prebuild here https://github.com/kuuy/hlsdl/releases *

Documentation

Index

• type AESDecrypt
• type DownloadResult
• type DownloadSegmentReport
• type HlsDl
  • func New(hlsURL string, headers map[string]string, dir, filename string, workers int, ...) *HlsDl
  • func (hlsDl *HlsDl) AES128Decrypt(aesDecrypt AESDecrypt)
  • func (hlsDl *HlsDl) Context(context func(ctx context.Context, network, addr string) (net.Conn, error)) (err error)
  • func (hlsDl *HlsDl) Download() (string, error)
  • func (hlsDl *HlsDl) DownloadSegments() error
  • func (hlsDl *HlsDl) GetProgress() float64
  • func (hlsDl *HlsDl) Proxy(proxyUrl string)
• type Recorder
  • func NewRecorder(url string, headers map[string]string, dir, filename string) *Recorder
  • func (r *Recorder) Start() (string, error)
• type Segment
• type SegmentPuller

Types

type AESDecrypt

type AESDecrypt func(ciphertext []byte, key []byte, iv []byte) ([]byte, error)

type DownloadResult

type DownloadResult struct {
	Err   error
	SeqId uint64
}

type DownloadSegmentReport

type DownloadSegmentReport struct {
	Data []byte
	Err  error
}

type HlsDl

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

HlsDl present a HLS downloader

func New

func New(hlsURL string, headers map[string]string, dir, filename string, workers int, enableBar bool) *HlsDl

func (*HlsDl) AES128Decrypt

func (hlsDl *HlsDl) AES128Decrypt(aesDecrypt AESDecrypt)

func (*HlsDl) Context

func (hlsDl *HlsDl) Context(context func(ctx context.Context, network, addr string) (net.Conn, error)) (err error)

func (*HlsDl) Download

func (hlsDl *HlsDl) Download() (string, error)

func (*HlsDl) DownloadSegments

func (hlsDl *HlsDl) DownloadSegments() error

func (*HlsDl) GetProgress

func (hlsDl *HlsDl) GetProgress() float64

func (*HlsDl) Proxy

func (hlsDl *HlsDl) Proxy(proxyUrl string)

type Recorder

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

func NewRecorder

func NewRecorder(url string, headers map[string]string, dir, filename string) *Recorder

func (*Recorder) Start

func (r *Recorder) Start() (string, error)

Start starts a record a live streaming

type Segment

type Segment struct {
	*m3u8.MediaSegment
	Path string
}

type SegmentPuller

type SegmentPuller struct {
	Segment *Segment
	Err     error
}