130 lines
3.1 KiB
Go
130 lines
3.1 KiB
Go
/*
|
|
* Copyright 2026 Oleg Borodin <onborodin@gmail.com>
|
|
*
|
|
* This work is published and licensed under a Creative Commons
|
|
* Attribution-NonCommercial-NoDerivatives 4.0 International License.
|
|
*
|
|
* Distribution of this work is permitted, but commercial use and
|
|
* modifications are strictly prohibited.
|
|
*/
|
|
package handler
|
|
|
|
import (
|
|
"io"
|
|
|
|
"mstore/app/operator"
|
|
"mstore/app/router"
|
|
)
|
|
|
|
const zeroContentLength = "0"
|
|
|
|
func (hand *Handler) FileInfo(rctx *router.Context) {
|
|
|
|
filepath, _ := rctx.GetSubpath("filepath")
|
|
params := &operator.FileInfoParams{
|
|
Filepath: filepath,
|
|
}
|
|
ctx := rctx.GetContext()
|
|
code, res, err := hand.oper.FileInfo(ctx, params)
|
|
if err != nil {
|
|
hand.logg.Errorf("FileInfo error: %v", err)
|
|
rctx.SetStatus(code)
|
|
return
|
|
}
|
|
rctx.SetHeader("Content-Collection", res.ContentCollection)
|
|
rctx.SetHeader("Content-Name", res.ContentName)
|
|
rctx.SetHeader("Content-Type", res.ContentType)
|
|
rctx.SetHeader("Content-Size", res.ContentSize)
|
|
rctx.SetHeader("Content-Digest", res.ContentDigest)
|
|
|
|
rctx.SetHeader("Content-Length", zeroContentLength)
|
|
rctx.SetStatus(code)
|
|
}
|
|
|
|
func (hand *Handler) PutFile(rctx *router.Context) {
|
|
contentSize := rctx.GetHeader("Content-Size")
|
|
contentType := rctx.GetHeader("Content-Type")
|
|
filepath, _ := rctx.GetSubpath("filepath")
|
|
|
|
params := &operator.PutFileParams{
|
|
Filepath: filepath,
|
|
ContentType: contentType,
|
|
ContentSize: contentSize,
|
|
Source: rctx.Request.Body,
|
|
}
|
|
ctx := rctx.GetContext()
|
|
|
|
code, _, err := hand.oper.PutFile(ctx, params)
|
|
if err != nil {
|
|
hand.logg.Errorf("PutFile error: %v", err)
|
|
rctx.SetStatus(code)
|
|
return
|
|
}
|
|
rctx.SetStatus(code)
|
|
}
|
|
|
|
func (hand *Handler) GetFile(rctx *router.Context) {
|
|
|
|
filepath, _ := rctx.GetSubpath("filepath")
|
|
params := &operator.GetFileParams{
|
|
Filepath: filepath,
|
|
}
|
|
ctx := rctx.GetContext()
|
|
code, res, err := hand.oper.GetFile(ctx, params)
|
|
if err != nil {
|
|
hand.logg.Errorf("PutFile error: %v", err)
|
|
rctx.SetStatus(code)
|
|
return
|
|
}
|
|
|
|
rctx.SetHeader("Content-Type", res.ContentType)
|
|
rctx.SetHeader("Content-Size", res.ContentSize)
|
|
rctx.SetHeader("Content-Digest", res.ContentDigest)
|
|
rctx.SetHeader("Content-Length", res.ContentSize)
|
|
rctx.SetStatus(code)
|
|
|
|
if res.Source != nil {
|
|
defer res.Source.Close()
|
|
_, err = io.Copy(rctx.Writer, res.Source)
|
|
if err != nil {
|
|
hand.logg.Errorf("GetFile error: %v", err)
|
|
return
|
|
}
|
|
}
|
|
}
|
|
|
|
func (hand *Handler) DeleteFile(rctx *router.Context) {
|
|
|
|
filepath, _ := rctx.GetSubpath("filepath")
|
|
params := &operator.DeleteFileParams{
|
|
Filepath: filepath,
|
|
}
|
|
ctx := rctx.GetContext()
|
|
code, _, err := hand.oper.DeleteFile(ctx, params)
|
|
if err != nil {
|
|
hand.logg.Errorf("GetFile error: %v", err)
|
|
}
|
|
|
|
rctx.SetStatus(code)
|
|
}
|
|
|
|
func (hand *Handler) ListFiles(rctx *router.Context) {
|
|
|
|
filepath, _ := rctx.GetSubpath("filepath")
|
|
if filepath == "" {
|
|
filepath = "/"
|
|
}
|
|
params := &operator.ListFilesParams{
|
|
Filepath: filepath,
|
|
}
|
|
ctx := rctx.GetContext()
|
|
|
|
code, res, err := hand.oper.ListFiles(ctx, params)
|
|
if err != nil {
|
|
hand.logg.Errorf("ListFiles error: %v", err)
|
|
rctx.SetStatus(code)
|
|
return
|
|
}
|
|
rctx.SendJSON(code, res.Files)
|
|
}
|