package pointer

import (
	"github.com/github/git-media/gitmedia"
	"github.com/github/git-media/gitmediaclient"
	"io"
	"os"
)

func Smudge(writer io.Writer, ptr *Pointer, cb gitmedia.CopyCallback) error {
	mediafile, err := gitmedia.LocalMediaPath(ptr.Oid)
	if err != nil {
		return err
	}

	var wErr *gitmedia.WrappedError
	if stat, statErr := os.Stat(mediafile); statErr != nil || stat == nil {
		wErr = downloadFile(writer, ptr, mediafile, cb)
	} else {
		wErr = readLocalFile(writer, ptr, mediafile, cb)
	}

	if wErr != nil {
		return &SmudgeError{ptr.Oid, mediafile, wErr}
	} else {
		return nil
	}
}

func downloadFile(writer io.Writer, ptr *Pointer, mediafile string, cb gitmedia.CopyCallback) *gitmedia.WrappedError {
	reader, size, wErr := gitmediaclient.Get(mediafile)
	if wErr != nil {
		wErr.Errorf("Error downloading %s.", mediafile)
		return wErr
	}
	defer reader.Close()

	if ptr.Size == 0 {
		ptr.Size = size
	}

	mediaWriter, err := newFile(mediafile, ptr.Oid)
	if err != nil {
		return gitmedia.Errorf(err, "Error opening media file buffer.")
	}

	_, copyErr := io.Copy(mediaWriter, reader)
	closeErr := mediaWriter.Close()

	if copyErr != nil {
		return gitmedia.Errorf(copyErr, "Error buffering media file.")
	}

	if closeErr != nil {
		return gitmedia.Errorf(closeErr, "Error closing saved media file bubfer.")
	}

	return readLocalFile(writer, ptr, mediaWriter.Path, cb)
}

func readLocalFile(writer io.Writer, ptr *Pointer, mediafile string, cb gitmedia.CopyCallback) *gitmedia.WrappedError {
	reader, err := os.Open(mediafile)
	if err != nil {
		return gitmedia.Errorf(err, "Error opening media file.")
	}
	defer reader.Close()

	if ptr.Size == 0 {
		if stat, _ := os.Stat(mediafile); stat != nil {
			ptr.Size = stat.Size()
		}
	}

	_, err = gitmedia.CopyWithCallback(writer, reader, ptr.Size, cb)
	return gitmedia.Errorf(err, "Error reading from media file.")
}

type SmudgeError struct {
	Oid      string
	Filename string
	*gitmedia.WrappedError
}