media.go

package oreka

import (
	"fmt"
	"io"
	"os/exec"

	"github.com/LasTshaMAN/Go-Execute/executor"
)

type MediaInfo struct {
	Length      int64
	ContentType string
	Data        io.ReadCloser
}

type MediaProcessor struct {
	FileName string
	ID       *string
	Size     *int
	Duration *int
}

var tmpFilePath = `/tmp/%s.mp3`

func (mp *MediaProcessor) ToMP3() (*deleteCloser, error) {
	mp3FileName := fmt.Sprintf(tmpFilePath, mp.ID)
	ffmpegResult, err := exec.Command("ffmpeg", "-y", "-i", mp.FileName, mp3FileName).CombinedOutput()
	if err != nil {
		fmt.Println("FFMPEG Error", string(ffmpegResult))
		return nil, err
	}
	return DeleteOnCloseReader(mp3FileName)
}

var threadPoolExecutor = executor.New(32)

// OrkaudioTranscode trigger orkadudio trancode <filename>
func OrkaudioTranscode(filename string) error {
	ch := make(chan error)
	threadPoolExecutor.Enqueue(func() {
		transcodeError, err := exec.Command("orkaudio", "transcode", filename).CombinedOutput()
		if err != nil {
			fmt.Println("OrkaudioTranscode Error", string(transcodeError))
			ch <- err
		} else {
			ch <- nil
		}
	})
	result := <-ch
	return result
}