ffmpeg.go

package radikocast

import (
	"context"
	"fmt"
	"io"
	"io/ioutil"
	"os"
	"os/exec"
	"path/filepath"
)

type ffmpeg struct {
	*exec.Cmd
}

func newFfmpeg(ctx context.Context) (*ffmpeg, error) {
	cmdPath, err := exec.LookPath("ffmpeg")
	if err != nil {
		return nil, err
	}

	return &ffmpeg{exec.CommandContext(
		ctx,
		cmdPath,
	)}, nil
}

func (f *ffmpeg) setDir(dir string) {
	f.Dir = dir
}

func (f *ffmpeg) setArgs(args ...string) {
	f.Args = append(f.Args, args...)
}

func (f *ffmpeg) setInput(input string) {
	f.setArgs("-i", input)
}

func (f *ffmpeg) run(output string) error {
	f.setArgs(output)
	return f.Run()
}

func (f *ffmpeg) start(output string) error {
	f.setArgs(output)
	return f.Start()
}

func (f *ffmpeg) wait() error {
	return f.Wait()
}

func (f *ffmpeg) stdinPipe() (io.WriteCloser, error) {
	return f.StdinPipe()
}

func (f *ffmpeg) stderrPipe() (io.ReadCloser, error) {
	return f.StderrPipe()
}

// ConcatAACFilesFromList concatenates files from the list of resources.
func ConcatAACFilesFromList(ctx context.Context, resourcesDir string) (string, error) {
	files, err := ioutil.ReadDir(resourcesDir)
	if err != nil {
		return "", err
	}

	allFilePaths := []string{}
	for _, f := range files {
		p := filepath.Join(resourcesDir, f.Name())
		allFilePaths = append(allFilePaths, p)
	}
	concatedFile := filepath.Join(resourcesDir, "concated.aac")
	if err := ConcatAACFilesAll(ctx, allFilePaths, resourcesDir, concatedFile); err != nil {
		return "", err
	}

	return concatedFile, nil
}

// ConcatAACFiles concatenate files of the same type.
func ConcatAACFilesAll(ctx context.Context, files []string, resourcesDir string, output string) error {
	// input is a path to a file which lists all the aac files.
	// it may include a lot of aac file and exceed max number of file descriptor.
	oneConcatNum := 100
	if len(files) > oneConcatNum {
		reducedFiles := files[:oneConcatNum]
		restFiles := files[oneConcatNum:]
		// reducedFiles -> reducedFiles[0]
		tmpOutputFile, err := ioutil.TempFile(resourcesDir, "tmp-concatenated-*.aac")
		if err != nil {
			fmt.Println("Failed to call ioutil.TempFile")
			return err
		}
		err = ConcatAACFiles(ctx, reducedFiles, resourcesDir, tmpOutputFile.Name())
		if err != nil {
			fmt.Println("Failed to ConcatAACFiles")
			return err
		}
		err = ConcatAACFilesAll(ctx, append([]string{tmpOutputFile.Name()}, restFiles...), resourcesDir, output)
		defer os.Remove(tmpOutputFile.Name())
		return err
	} else {
		return ConcatAACFiles(ctx, files, resourcesDir, output)
	}
}

func ConcatAACFiles(ctx context.Context, input []string, resourcesDir string, output string) error {
	listFile, err0 := ioutil.TempFile(resourcesDir, "aac_resources")
	if err0 != nil {
		return err0
	}
	defer os.Remove(listFile.Name())

	for _, f := range input {
		p := fmt.Sprintf("file '%s'\n", f)
		if _, err := listFile.WriteString(p); err != nil {
			return err
		}
	}

	f, err := newFfmpeg(ctx)
	if err != nil {
		return err
	}

	f.setArgs(
		"-f", "concat",
		"-safe", "0",
		"-y",
	)
	f.setInput(listFile.Name())
	f.setArgs("-c", "copy")
	// TODO: Collect log
	err = f.run(output)
	// Remove the intermediate files right after they are concatenated into one file
	for _, f := range input {
		defer os.Remove(f)
	}
	return err
}