//
//  rhimportd
//
//  The Radio Helsinki Rivendell Import Daemon
//
//
//  Copyright (C) 2015-2016 Christian Pointner <equinox@helsinki.at>
//
//  This file is part of rhimportd.
//
//  rhimportd is free software: you can redistribute it and/or modify
//  it under the terms of the GNU General Public License as published by
//  the Free Software Foundation, either version 3 of the License, or
//  any later version.
//
//  rhimportd is distributed in the hope that it will be useful,
//  but WITHOUT ANY WARRANTY; without even the implied warranty of
//  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
//  GNU General Public License for more details.
//
//  You should have received a copy of the GNU General Public License
//  along with rhimportd. If not, see <http://www.gnu.org/licenses/>.
//

package rhimport

import (
	"io"
	"os"
	"os/exec"
	"path/filepath"
	"strings"
)

type Converter interface {
	io.WriteCloser
	GetResult() (result string, err error)
}

type ConverterResult struct {
	output string
	err    error
}

//
// NUll Converter aka File Writer
//

type NullConverter struct {
	file *os.File
}

func NewNullConverter(filename string) (n *NullConverter, newFilename string, err error) {
	n = &NullConverter{}
	rhl.Printf("null-converter: opening file '%s'", filename)
	newFilename = filename
	n.file, err = os.OpenFile(filename, os.O_WRONLY|os.O_CREATE|os.O_EXCL, 0600)
	return
}

func (c *NullConverter) Write(p []byte) (n int, err error) {
	return c.file.Write(p)
}

func (c *NullConverter) Close() (err error) {
	return c.file.Close()
}

func (c *NullConverter) GetResult() (result string, err error) {
	return "", nil
}

//
// FFMpeg Converter: converts all files into flac
//

type FFMpegConverter struct {
	cmd    *exec.Cmd
	pipe   io.WriteCloser
	result chan ConverterResult
}

func NewFFMpegConverter(filename string) (ff *FFMpegConverter, filenameFlac string, err error) {
	ff = &FFMpegConverter{}
	ext := filepath.Ext(filename)
	filenameFlac = strings.TrimSuffix(filename, ext) + ".flac"
	rhl.Printf("ffmpeg-converter: starting ffmpeg for file '%s' (had extension: '%s')", filenameFlac, ext)
	ff.cmd = exec.Command("ffmpeg", "-loglevel", "warning", "-i", "-", "-map_metadata", "0", "-f", "flac", filenameFlac)
	if ff.pipe, err = ff.cmd.StdinPipe(); err != nil {
		return nil, "", err
	}

	ff.result = make(chan ConverterResult, 1)
	go func() {
		output, err := ff.cmd.CombinedOutput()
		ff.result <- ConverterResult{strings.TrimSpace(string(output)), err}
	}()
	return
}

func (ff *FFMpegConverter) Write(p []byte) (n int, err error) {
	return ff.pipe.Write(p)
}

func (ff *FFMpegConverter) Close() (err error) {
	return ff.pipe.Close()
}

func (ff *FFMpegConverter) GetResult() (result string, err error) {
	if ff.result != nil {
		r := <-ff.result
		return r.output, r.err
	}
	return "", nil
}