Refactor the codebase

1 files changed, 66 insertions, 0 deletions

diff --git a/s3_fs.go b/s3_fs.go
new file mode 100644
index 0000000..ecade9f
--- /dev/null
+++ b/s3_fs.go
@@ -0,0 +1,66 @@
+package main
+
+import (
+	"context"
+	"errors"
+	"os"
+	"time"
+
+	"github.com/minio/minio-go/v7"
+	"golang.org/x/net/webdav"
+)
+
+/*
+ * S3FS lifetime is limited to a single request
+ * Conversely, Golang's abstraction has been thought to be shared between users
+ * Sharing an instance between users would be very dangerous (as we would need many checks between shared values)
+ */
+type S3FS struct {
+	cache map[string]*S3Stat
+	mc    *minio.Client
+	ctx   context.Context
+}
+
+func NewS3FS(mc *minio.Client) S3FS {
+	return S3FS{
+		cache: make(map[string]*S3Stat),
+		mc:    mc,
+	}
+}
+
+func (s S3FS) Mkdir(ctx context.Context, name string, perm os.FileMode) error {
+	s.ctx = ctx
+	return errors.New("Not implemented Mkdir")
+}
+
+func (s S3FS) OpenFile(ctx context.Context, name string, flag int, perm os.FileMode) (webdav.File, error) {
+	s.ctx = ctx
+
+	// If the file does not exist when opening it, we create a stub
+	if _, ok := s.cache[name]; !ok {
+		st := new(S3Stat)
+		st.fs = &s
+		st.path = NewS3Path(name)
+		st.path.class = OBJECT
+		st.obj.Key = st.path.key
+		st.obj.LastModified = time.Now()
+		s.cache[name] = st
+	}
+
+	return NewS3File(&s, name)
+}
+
+func (s S3FS) RemoveAll(ctx context.Context, name string) error {
+	s.ctx = ctx
+	return errors.New("Not implemented RemoveAll")
+}
+
+func (s S3FS) Rename(ctx context.Context, oldName, newName string) error {
+	s.ctx = ctx
+	return errors.New("Not implemented Rename")
+}
+
+func (s S3FS) Stat(ctx context.Context, name string) (os.FileInfo, error) {
+	s.ctx = ctx
+	return NewS3Stat(&s, name)
+}