export hls lib.

Author: m1k1o

internal/hls/manager.go hls/manager.gointernal/hls/manager.go renamed to hls/manager.go

@@ -11,16 +11,17 @@ import (
 	"syscall"
 	"time"
 
-	"github.com/m1k1o/go-transcode/internal/utils"
 	"github.com/rs/zerolog"
 	"github.com/rs/zerolog/log"
+
+	"github.com/m1k1o/go-transcode/internal/utils"
 )
 
 const cleanupPeriod = 2 * time.Second
 const hlsMinimumSegments = 2
 const hlsSegmentDuration = 6
 
-type HlsManagerCtx struct {
+type ManagerCtx struct {
 	logger     zerolog.Logger
 	mu         sync.Mutex
 	cmdFactory func() *exec.Cmd
@@ -37,8 +38,8 @@ type HlsManagerCtx struct {
 	shutdown     chan interface{}
 }
 
-func New(cmdFactory func() *exec.Cmd) *HlsManagerCtx {
-	return &HlsManagerCtx{
+func New(cmdFactory func() *exec.Cmd) *ManagerCtx {
+	return &ManagerCtx{
 		logger:     log.With().Str("module", "hls").Str("submodule", "manager").Logger(),
 		cmdFactory: cmdFactory,
 
@@ -47,7 +48,7 @@ func New(cmdFactory func() *exec.Cmd) *HlsManagerCtx {
 	}
 }
 
-func (m *HlsManagerCtx) Start() error {
+func (m *ManagerCtx) Start() error {
 	m.mu.Lock()
 	defer m.mu.Unlock()
 
@@ -129,7 +130,7 @@ func (m *HlsManagerCtx) Start() error {
 	return m.cmd.Start()
 }
 
-func (m *HlsManagerCtx) Stop() {
+func (m *ManagerCtx) Stop() {
 	m.mu.Lock()
 	defer m.mu.Unlock()
 
@@ -152,7 +153,7 @@ func (m *HlsManagerCtx) Stop() {
 	})
 }
 
-func (m *HlsManagerCtx) Cleanup() {
+func (m *ManagerCtx) Cleanup() {
 	diff := time.Now().Unix() - m.lastRequest
 	stop := m.active && diff > 2*hlsSegmentDuration || !m.active && diff > 4*hlsSegmentDuration
 
@@ -168,7 +169,7 @@ func (m *HlsManagerCtx) Cleanup() {
 	}
 }
 
-func (m *HlsManagerCtx) ServePlaylist(w http.ResponseWriter, r *http.Request) {
+func (m *ManagerCtx) ServePlaylist(w http.ResponseWriter, r *http.Request) {
 	m.lastRequest = time.Now().Unix()
 	playlist := m.playlist
 
@@ -198,7 +199,7 @@ func (m *HlsManagerCtx) ServePlaylist(w http.ResponseWriter, r *http.Request) {
 	w.Write([]byte(playlist))
 }
 
-func (m *HlsManagerCtx) ServeMedia(w http.ResponseWriter, r *http.Request) {
+func (m *ManagerCtx) ServeMedia(w http.ResponseWriter, r *http.Request) {
 	fileName := path.Base(r.URL.RequestURI())
 	path := path.Join(m.tempdir, fileName)
 

internal/types/hls.go hls/types.gointernal/types/hls.go renamed to hls/types.go

@@ -1,8 +1,8 @@
-package types
+package hls
 
 import "net/http"
 
-type HlsManager interface {
+type Manager interface {
 	Start() error
 	Stop()
 	Cleanup()

internal/api/hls.go

@@ -9,11 +9,10 @@ import (
 	"github.com/go-chi/chi"
 	"github.com/rs/zerolog/log"
 
-	"github.com/m1k1o/go-transcode/internal/hls"
-	"github.com/m1k1o/go-transcode/internal/types"
+	"github.com/m1k1o/go-transcode/hls"
 )
 
-var hlsManagers map[string]types.HlsManager = make(map[string]types.HlsManager)
+var hlsManagers map[string]hls.Manager = make(map[string]hls.Manager)
 
 func (a *ApiManagerCtx) HLS(r chi.Router) {
 	r.Get("/{profile}/{input}/index.m3u8", func(w http.ResponseWriter, r *http.Request) {