You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
97 lines
2.0 KiB
Go
97 lines
2.0 KiB
Go
package dataswamp
|
|
|
|
import (
|
|
"caj-larsson/bog/dataswamp/namespace"
|
|
"caj-larsson/bog/dataswamp/swampfile"
|
|
"io"
|
|
"path"
|
|
"path/filepath"
|
|
"strconv"
|
|
"strings"
|
|
"time"
|
|
)
|
|
|
|
type SwampFileService struct {
|
|
namespace_repo namespace.Repository
|
|
swamp_file_repo swampfile.Repository
|
|
default_allowance_bytes int64
|
|
default_allowance_duration time.Duration
|
|
}
|
|
|
|
func NewSwampFileService(
|
|
namespace_repo namespace.Repository,
|
|
swamp_file_repo swampfile.Repository,
|
|
da_bytes int64,
|
|
da_duration time.Duration,
|
|
) SwampFileService {
|
|
return SwampFileService{namespace_repo, swamp_file_repo, da_bytes, da_duration}
|
|
}
|
|
|
|
func (s SwampFileService) getOrCreateNs(namespace_in string) *namespace.Namespace {
|
|
ns, err := s.namespace_repo.GetByName(namespace_in)
|
|
|
|
if err == namespace.ErrNotExists {
|
|
new_ns := namespace.Namespace{
|
|
0,
|
|
namespace_in,
|
|
time.Now(),
|
|
s.default_allowance_duration,
|
|
namespace.FileSizeQuota{s.default_allowance_bytes, 0},
|
|
}
|
|
created_ns, err := s.namespace_repo.Create(new_ns)
|
|
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
|
|
return created_ns
|
|
}
|
|
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
|
|
return ns
|
|
}
|
|
|
|
func (s SwampFileService) SaveFile(ref swampfile.FileReference, src io.Reader, size int64) error {
|
|
ns := s.getOrCreateNs(ref.UserAgent)
|
|
|
|
if !ns.FileQuota.Allows(size) {
|
|
return namespace.ErrExceedQuota
|
|
}
|
|
|
|
f, err := s.swamp_file_repo.Create(ref.Path, strconv.FormatInt(ns.ID, 10))
|
|
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
io.Copy(f, src)
|
|
f.Close()
|
|
ns.FileQuota.Add(size)
|
|
s.namespace_repo.Update(ns.ID, *ns)
|
|
|
|
return nil
|
|
}
|
|
|
|
func (s SwampFileService) OpenOutFile(ref swampfile.FileReference) (swampfile.SwampOutFile, error) {
|
|
ns := s.getOrCreateNs(ref.UserAgent)
|
|
|
|
// if err == namespace.ErrNotExists {
|
|
// return nil, err
|
|
// }
|
|
|
|
f, err := s.swamp_file_repo.Open(ref.Path, strconv.FormatInt(ns.ID, 10))
|
|
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return f, nil
|
|
}
|
|
|
|
func CleanPath(inpath string) string {
|
|
return filepath.FromSlash(path.Clean("/" + strings.Trim(inpath, "/")))
|
|
}
|