VILLASweb-backend-go/routes/file/file_methods.go

package file

import (
	"fmt"
	"github.com/gin-gonic/gin"
	"io/ioutil"
	"mime/multipart"
	"os"
	"path/filepath"
	"time"

	"git.rwth-aachen.de/acs/public/villas/villasweb-backend-go/common"
	"git.rwth-aachen.de/acs/public/villas/villasweb-backend-go/routes/simulationmodel"
	"git.rwth-aachen.de/acs/public/villas/villasweb-backend-go/routes/widget"
)

type File struct {
	common.File
}

func (f *File) byPath(path string) error {
	db := common.GetDB()
	err := db.Where("Path = ?", path).Find(f).Error
	if err != nil {
		return fmt.Errorf("File with path=%s does not exist", path)
	}
	return err
}

func (f *File) byID(id uint) error {
	db := common.GetDB()
	err := db.Find(f, id).Error
	if err != nil {
		return fmt.Errorf("File with id=%v does not exist", id)
	}
	return nil
}

func (f *File) save() error {
	db := common.GetDB()
	err := db.Create(f).Error

	return err
}

func (f *File) download(c *gin.Context) error {

	err := ioutil.WriteFile(f.Name, f.FileData, 0644)
	if err != nil {
		return fmt.Errorf("file could not be temporarily created on server disk: %s", err.Error())
	}
	defer os.Remove(f.Name)
	//Seems this headers needed for some browsers (for example without this headers Chrome will download files as txt)
	c.Header("Content-Description", "File Transfer")
	c.Header("Content-Transfer-Encoding", "binary")
	c.Header("Content-Disposition", "attachment; filename="+f.Name)
	//c.Header("Content-Type", contentType)
	c.File(f.Name)

	return nil

}

func (f *File) register(fileHeader *multipart.FileHeader, objectType string, objectID uint) error {

	// Obtain properties of file
	f.Type = fileHeader.Header.Get("Content-Type")
	f.Name = filepath.Base(fileHeader.Filename)
	//f.Path = filepath.Join(getFolderName(objectType, objectID), f.Name)
	f.Size = uint(fileHeader.Size)
	f.Date = time.Now().String()
	f.ImageWidth = 0  // TODO: do we need this?
	f.ImageHeight = 0 // TODO: do we need this?

	var m simulationmodel.SimulationModel
	var w widget.Widget
	var err error
	if objectType == "model" {
		// check if model exists
		err = m.ByID(objectID)
		f.WidgetID = 0
		f.SimulationModelID = objectID
		if err != nil {
			return err
		}

	} else {
		// check if widget exists
		f.WidgetID = objectID
		f.SimulationModelID = 0
		err = w.ByID(uint(objectID))
		if err != nil {
			return err
		}

	}

	// set file data
	fileContent, err := fileHeader.Open()
	if err != nil {
		return err
	}

	f.FileData, err = ioutil.ReadAll(fileContent)
	defer fileContent.Close()

	// Add File object with parameters to DB
	err = f.save()
	if err != nil {
		return err
	}

	// Create association to model or widget
	if objectType == "model" {
		db := common.GetDB()
		err := db.Model(&m).Association("Files").Append(f).Error
		if err != nil {
			return err
		}
	} else {
		db := common.GetDB()
		err := db.Model(&w).Association("Files").Append(f).Error
		if err != nil {
			return err
		}
	}

	return nil
}

func (f *File) update(fileHeader *multipart.FileHeader) error {

	// set file data
	fileContent, err := fileHeader.Open()
	if err != nil {
		return err
	}

	fileData, err := ioutil.ReadAll(fileContent)
	fmt.Println("File content: ", string(fileData))
	defer fileContent.Close()

	db := common.GetDB()
	err = db.Model(f).Updates(map[string]interface{}{"Size": fileHeader.Size,
		"FileData": fileData,
		"Date":     time.Now().String()}).Error
	return err
}

func (f *File) delete() error {

	db := common.GetDB()

	if f.WidgetID > 0 {
		// remove association between file and widget
		var w widget.Widget
		err := w.ByID(f.WidgetID)
		if err != nil {
			return err
		}
		err = db.Model(&w).Association("Files").Delete(f).Error
		if err != nil {
			return err
		}
	} else {
		// remove association between file and simulation model
		var m simulationmodel.SimulationModel
		err := m.ByID(f.SimulationModelID)
		if err != nil {
			return err
		}
		err = db.Model(&m).Association("Files").Delete(f).Error
		if err != nil {
			return err
		}
	}

	// delete file from DB
	err := db.Delete(f).Error

	return err
}