package oss_repository

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

type LocalOssRepository struct {
	dir string
}

func NewLocalOssRepository() OssInterface {
	return &LocalOssRepository{dir: os.TempDir()}
}

func (l *LocalOssRepository) UploadFile(objectName string, data io.Reader) error {
	objectName = filepath.Clean(objectName)
	objectName = filepath.Join(l.dir,objectName)

	out, err := os.Create(objectName)
	if err != nil {
		return err
	}
	defer out.Close()

	_, err = io.Copy(out, data)
	return err
}

func (l *LocalOssRepository) DownloadFile(objectName, downloadedFileName string) error  {
	objectName = filepath.Clean(objectName)
	objectName = filepath.Join(l.dir,objectName)
	if _,err := os.Stat(objectName);err != nil{
		return err
	}
	return os.Rename(objectName,downloadedFileName)
}

func (l *LocalOssRepository) ListFile() ([]string, error)  {
	return nil, nil
}

func (l *LocalOssRepository) DeleteFile(objectName string) error  {
	objectName = filepath.Clean(objectName)
	objectName = filepath.Join(l.dir,objectName)
	if _,err := os.Stat(objectName);err != nil{
		return err
	}
	return os.Remove(objectName)
}

func (l *LocalOssRepository) Location() string  {
	return "disk"
}