2020-05-30 03:08:33 +02:00
|
|
|
package main
|
|
|
|
|
|
|
|
import (
|
|
|
|
"fmt"
|
|
|
|
"os"
|
|
|
|
"os/exec"
|
|
|
|
"strings"
|
|
|
|
)
|
|
|
|
|
|
|
|
func pipeTest() {
|
2020-06-01 21:15:07 +02:00
|
|
|
ffmpegCmd := "cat streampipe.flv | ffmpeg -hide_banner -i pipe: -preset ultrafast -f hls -hls_list_size 30 -hls_time 10 -strftime 1 -use_localtime 1 -hls_segment_filename 'hls/stream-%Y%m%d-%s.ts' -hls_flags delete_segments -segment_wrap 100 hls/temp.m3u8"
|
2020-05-30 03:08:33 +02:00
|
|
|
|
|
|
|
out, err := exec.Command("bash", "-c", ffmpegCmd).Output()
|
|
|
|
verifyError(err)
|
|
|
|
fmt.Println(string(out))
|
|
|
|
}
|
|
|
|
|
|
|
|
func verifyError(e error) {
|
|
|
|
if e != nil {
|
|
|
|
panic(e)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
func generateRemotePlaylist(playlist string, segments map[string]string) string {
|
|
|
|
for local, remote := range segments {
|
|
|
|
playlist = strings.ReplaceAll(playlist, local, "https://gateway.temporal.cloud"+remote)
|
|
|
|
}
|
|
|
|
return playlist
|
|
|
|
}
|
|
|
|
|
|
|
|
func writePlaylist(data string, filePath string) {
|
|
|
|
f, err := os.Create(filePath)
|
2020-06-01 21:15:07 +02:00
|
|
|
defer f.Close()
|
|
|
|
|
2020-05-30 03:08:33 +02:00
|
|
|
if err != nil {
|
|
|
|
fmt.Println(err)
|
|
|
|
return
|
|
|
|
}
|
|
|
|
_, err = f.WriteString(data)
|
|
|
|
if err != nil {
|
|
|
|
fmt.Println(err)
|
|
|
|
return
|
|
|
|
}
|
|
|
|
}
|