initial commit

Author: mrjoshuak

LICENSE

@@ -0,0 +1,21 @@
+The MIT License
+
+Copyright (c) 2018 The AbsFs Contributors
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in
+all copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
+THE SOFTWARE.

Readme.md

@@ -0,0 +1,5 @@
+# httpfs
+The `httpfs` package implements a `net/http` FileSystem interface compatible
+object that includes both file reading and file writing operations.
+
+Work in progress

httpfs.go

@@ -0,0 +1,123 @@
+package httpfs
+
+import (
+	"net/http"
+	"os"
+	"path/filepath"
+	"strings"
+	"time"
+
+	"github.com/pkg/errors"
+
+	"github.com/absfs/absfs"
+)
+
+var ErrNotImplemented = errors.New("not implemented")
+
+type Httpfs struct {
+	fs absfs.Filer
+}
+
+func New(fs absfs.Filer) *Httpfs {
+	return &Httpfs{fs}
+}
+
+func (filer *Httpfs) Open(name string) (http.File, error) {
+	f, err := filer.OpenFile(name, os.O_RDONLY, 0400)
+
+	return http.File(f), err
+}
+
+// OpenFile opens a file using the given flags and the given mode.
+func (filer *Httpfs) OpenFile(name string, flag int, perm os.FileMode) (absfs.File, error) {
+	return filer.fs.OpenFile(name, flag, perm)
+}
+
+// Mkdir creates a directory in the filesystem, return an error if any
+// happens.
+func (filer *Httpfs) Mkdir(name string, perm os.FileMode) error {
+	return filer.fs.Mkdir(name, perm)
+}
+
+// MkdirAll creates all missing directories in `name` without returning an error
+// for directories that already exist
+func (filer *Httpfs) MkdirAll(name string, perm os.FileMode) error {
+	p := string(filepath.Separator)
+	for _, name := range strings.Split(name, p) {
+		if name == "" {
+			continue
+		}
+		p = filepath.Join(p, name)
+		err := filer.Mkdir(p, perm)
+		if err != nil && !os.IsExist(err) {
+			return err
+		}
+	}
+	return nil
+}
+
+// Remove removes a file identified by name, returning an error, if any
+// happens.
+func (filer *Httpfs) Remove(name string) error {
+	return filer.fs.Remove(name)
+}
+
+// RemoveAll removes a directory after removing all children of that directory.
+func (filer *Httpfs) RemoveAll(path string) (err error) {
+	info, err := filer.Stat(path)
+	if err != nil {
+		if os.IsNotExist(err) {
+			return nil
+		}
+		return err
+	}
+
+	// if it's not a directory remove it and return
+	if !info.IsDir() {
+		return filer.Remove(path)
+	}
+
+	f, err := filer.OpenFile(path, os.O_RDWR, 0700)
+	if err != nil {
+		if os.IsNotExist(err) {
+			return nil
+		}
+		return err
+	}
+
+	// get and loop through each directory entry calling remove all recursively
+	infos, err := f.Readdir(0)
+	if err != nil {
+		return err
+	}
+	f.Close()
+
+	for _, info := range infos {
+		err = filer.RemoveAll(filepath.Join(path, info.Name()))
+		if err != nil {
+			return err
+		}
+	}
+
+	return filer.Remove(path)
+}
+
+// Stat returns the FileInfo structure describing file. If there is an error, it will be of type *PathError.
+func (filer *Httpfs) Stat(name string) (os.FileInfo, error) {
+	return filer.fs.Stat(name)
+}
+
+//Chmod changes the mode of the named file to mode.
+func (filer *Httpfs) Chmod(name string, mode os.FileMode) error {
+	return filer.fs.Chmod(name, mode)
+}
+
+//Chtimes changes the access and modification times of the named file
+func (filer *Httpfs) Chtimes(name string, atime time.Time, mtime time.Time) error {
+	return filer.fs.Chtimes(name, atime, mtime)
+}
+
+//Chown changes the owner and group ids of the named file
+func (filer *Httpfs) Chown(name string, uid, gid int) error {
+	return filer.fs.Chown(name, uid, gid)
+}

httpfs_test.go

@@ -0,0 +1,47 @@
+package httpfs_test
+
+import (
+	"io/ioutil"
+	"log"
+	"net/http"
+	"net/http/httptest"
+	"os"
+
+	"github.com/absfs/httpfs"
+	"github.com/absfs/memfs"
+
+	"testing"
+)
+
+func TestFileServer(t *testing.T) {
+	mfs, err := memfs.NewFS()
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	fs := httpfs.New(mfs)
+
+	f, err := fs.OpenFile("/foo.txt", os.O_CREATE|os.O_RDWR|os.O_TRUNC, 0600)
+	if err != nil {
+		t.Fatal(err)
+	}
+	_, err = f.Write([]byte("foo bar bat."))
+	if err != nil {
+		t.Fatal(err)
+	}
+	f.Close()
+
+	server := httptest.NewServer(http.FileServer(fs))
+	defer server.Close()
+
+	res, err := http.Get(server.URL + "/foo.txt")
+	if err != nil {
+		log.Fatal(err)
+	}
+	data, err := ioutil.ReadAll(res.Body)
+	res.Body.Close()
+	if string(data) != "foo bar bat." {
+		t.Fatal("wrong response")
+	}
+	t.Logf("received: %q", string(data))
+}