memories/main.go

package main

import (
	"fmt"
	"log"
	"net/http"
	"os"
	"strings"
	"sync"
)

type Handler struct {
	c        *Config
	managers map[string]*Manager
	mutex    sync.RWMutex
	close    chan string
}

func NewHandler(c *Config) *Handler {
	h := &Handler{
		c:        c,
		managers: make(map[string]*Manager),
		close:    make(chan string),
	}

	// Recreate tempdir
	os.RemoveAll(c.tempdir)
	os.MkdirAll(c.tempdir, 0755)

	go h.watchClose()
	return h
}

func (h *Handler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
	url := r.URL.Path
	parts := make([]string, 0)

	for _, part := range strings.Split(url, "/") {
		if part != "" {
			parts = append(parts, part)
		}
	}

	if len(parts) < 3 {
		log.Println("Invalid URL", url)
		w.WriteHeader(http.StatusBadRequest)
		return
	}

	streamid := parts[0]
	path := "/" + strings.Join(parts[1:len(parts)-1], "/")
	chunk := parts[len(parts)-1]

	// log.Println("Serving", path, streamid, chunk)

	if streamid == "" || chunk == "" || path == "" {
		w.WriteHeader(http.StatusBadRequest)
		return
	}

	manager := h.getManager(path, streamid)
	if manager == nil {
		manager = h.createManager(path, streamid)
	}

	if manager == nil {
		w.WriteHeader(http.StatusInternalServerError)
		return
	}
	manager.ServeHTTP(w, r, chunk)
}

func (h *Handler) getManager(path string, streamid string) *Manager {
	h.mutex.RLock()
	defer h.mutex.RUnlock()

	m := h.managers[streamid]
	if m == nil || m.path != path {
		return nil
	}
	return m
}

func (h *Handler) createManager(path string, streamid string) *Manager {
	manager, err := NewManager(h.c, path, streamid, h.close)
	if err != nil {
		log.Println("Error creating manager", err)
		return nil
	}

	h.mutex.Lock()
	defer h.mutex.Unlock()

	old := h.managers[streamid]
	if old != nil {
		old.Destroy()
	}

	h.managers[streamid] = manager
	return manager
}

func (h *Handler) removeManager(streamid string) {
	h.mutex.Lock()
	defer h.mutex.Unlock()
	delete(h.managers, streamid)
}

func (h *Handler) watchClose() {
	for {
		id := <-h.close
		if id == "" {
			return
		}
		h.removeManager(id)
	}
}

func (h *Handler) Close() {
	h.close <- ""
}

func main() {
	if len(os.Args) >= 2 && os.Args[1] == "test" {
		fmt.Println("test successful")
		return
	}

	log.Println("Starting VOD server")

	// get executable paths
	ffmpeg := os.Getenv("FFMPEG")
	if ffmpeg == "" {
		ffmpeg = "ffmpeg"
	}

	ffprobe := os.Getenv("FFPROBE")
	if ffprobe == "" {
		ffprobe = "ffprobe"
	}

	// get tempdir
	tempdir := os.Getenv("GOVOD_TEMPDIR")
	if tempdir == "" {
		tempdir = "/tmp/go-vod"
	}

	// get port
	bind := os.Getenv("GOVOD_BIND")
	if bind == "" {
		bind = ":47788"
	}

	h := NewHandler(&Config{
		ffmpeg:          ffmpeg,
		ffprobe:         ffprobe,
		tempdir:         tempdir,
		chunkSize:       3,
		lookBehind:      5,
		goalBufferMin:   1,
		goalBufferMax:   4,
		streamIdleTime:  60,
		managerIdleTime: 60,
	})

	http.Handle("/", h)
	http.ListenAndServe(bind, nil)

	log.Println("Exiting VOD server")
	h.Close()
}