feat(api.FSI): initial FSI api methods

api/api.go

@@ -289,6 +289,9 @@ func NewServerRoutes(s Server) *http.ServeMux {
 	m.Handle("/update/logs/file", s.middleware(uh.LogFileHandler))
 	m.Handle("/update/service", s.middleware(uh.ServiceHandler))
 
+	fsih := NewFSIHandlers(s.Instance, cfg.API.ReadOnly)
+	m.Handle("/dsstatus", s.middleware(fsih.StatusHandler))
+
 	renderh := NewRenderHandlers(node.Repo)
 	m.Handle("/render/", s.middleware(renderh.RenderHandler))
 

api/fsi.go

@@ -0,0 +1,59 @@
+package api
+
+import (
+	"fmt"
+	"net/http"
+
+	util "github.com/qri-io/apiutil"
+	"github.com/qri-io/qri/lib"
+)
+
+
+// FSIHandlers connects HTTP requests to the FSI subsystem
+type FSIHandlers struct {
+	lib.FSIMethods
+	ReadOnly bool
+}
+
+// NewFSIHandlers creates handlers that talk to qri's filesystem integration
+func NewFSIHandlers(inst *lib.Instance, readOnly bool) FSIHandlers {
+	return FSIHandlers{
+		FSIMethods: *lib.NewFSIMethods(inst),
+		ReadOnly: readOnly,
+	}
+}
+
+
+// StatusHandler is the endpoint for getting the status of a linked dataset
+func (h *FSIHandlers) StatusHandler(w http.ResponseWriter, r *http.Request) {
+	switch r.Method {
+	case "OPTIONS":
+		util.EmptyOkHandler(w, r)
+	case "GET":
+		if h.ReadOnly {
+			readOnlyResponse(w, "/status")
+			return
+		}
+		h.statusHandler(w, r)
+	case "POST":
+		h.statusHandler(w, r)
+	default:
+		util.NotFoundHandler(w, r)
+	}
+}
+
+func (h *FSIHandlers) statusHandler(w http.ResponseWriter, r *http.Request) {
+	ref, err := DatasetRefFromPath(r.URL.Path[len("/dsstatus"):])
+	if err != nil {
+		util.WriteErrResponse(w, http.StatusBadRequest, fmt.Errorf("bad reference: %s", err.Error()))
+		return
+	}
+
+	alias := ref.AliasString()
+	res := []lib.StatusItem{}
+	if err = h.AliasStatus(&alias, &res); err != nil {
+		util.WriteErrResponse(w, http.StatusInternalServerError, fmt.Errorf("error getting status: %s", err.Error()))
+		return
+	}
+	util.WriteResponse(w, res)
+}

fsi/fsi.go

@@ -169,6 +169,9 @@ func (fsi *FSI) load() (links, error) {
 
 	data, err := ioutil.ReadFile(fsi.linksPath)
 	if err != nil {
+		if os.IsNotExist(err) {
+			return links{}, nil
+		}
 		return nil, err
 	}
 

fsi/status.go

@@ -30,6 +30,22 @@ type StatusItem struct {
 	Message    string
 }
 
+// AliasStatus returns the status for a given dataset alias
+func (fsi *FSI) AliasStatus(alias string) (changes []StatusItem, err error) {
+	links, err := fsi.load()
+	if err != nil {
+		return nil, err
+	}
+
+	for _, l := range links {
+		if l.Alias == alias {
+			return fsi.Status(l.Path)
+		}
+	}
+
+	return nil, fmt.Errorf("alias not found: %s", alias)
+}
+
 // Status reads the diff status from the current working directory
 func (fsi *FSI) Status(dir string) (changes []StatusItem, err error) {
 	refStr, ok := GetLinkedFilesysRef(dir)

go.sum

@@ -394,6 +394,7 @@ github.com/libp2p/go-libp2p-net v0.0.0-20190226201932-e71fff5ba6e9/go.mod h1:8W6
 github.com/libp2p/go-libp2p-net v0.0.1/go.mod h1:Yt3zgmlsHOgUWSXmt5V/Jpz9upuJBE8EgNU9DrCcR8c=
 github.com/libp2p/go-libp2p-net v0.0.2 h1:qP06u4TYXfl7uW/hzqPhlVVTSA2nw1B/bHBJaUnbh6M=
 github.com/libp2p/go-libp2p-net v0.0.2/go.mod h1:Yt3zgmlsHOgUWSXmt5V/Jpz9upuJBE8EgNU9DrCcR8c=
+github.com/libp2p/go-libp2p-netutil v0.0.1 h1:LgD6+skofkOx8z6odD9+MZHKjupv3ng1u6KRhaADTnA=
 github.com/libp2p/go-libp2p-netutil v0.0.1/go.mod h1:GdusFvujWZI9Vt0X5BKqwWWmZFxecf9Gt03cKxm2f/Q=
 github.com/libp2p/go-libp2p-peer v0.0.1/go.mod h1:nXQvOBbwVqoP+T5Y5nCjeH4sP9IX/J0AMzcDUVruVoo=
 github.com/libp2p/go-libp2p-peer v0.1.1 h1:qGCWD1a+PyZcna6htMPo26jAtqirVnJ5NvBQIKV7rRY=
@@ -468,6 +469,7 @@ github.com/libp2p/go-tcp-transport v0.0.1/go.mod h1:mnjg0o0O5TmXUaUIanYPUqkW4+u6
 github.com/libp2p/go-tcp-transport v0.0.3/go.mod h1:f11C2zvCaGDkE8aFPUKmuYZwd3pP6HI24LeLMWhJnkQ=
 github.com/libp2p/go-tcp-transport v0.0.4 h1:2iRu994wCT/iEz62F+c60FUoSkijNEQ0q2Itc+79XlQ=
 github.com/libp2p/go-tcp-transport v0.0.4/go.mod h1:+E8HvC8ezEVOxIo3V5vCK9l1y/19K427vCzQ+xHKH/o=
+github.com/libp2p/go-testutil v0.0.1 h1:Xg+O0G2HIMfHqBOBDcMS1iSZJ3GEcId4qOxCQvsGZHk=
 github.com/libp2p/go-testutil v0.0.1/go.mod h1:iAcJc/DKJQanJ5ws2V+u5ywdL2n12X1WbbEG+Jjy69I=
 github.com/libp2p/go-ws-transport v0.0.1/go.mod h1:p3bKjDWHEgtuKKj+2OdPYs5dAPIjtpQGHF2tJfGz7Ww=
 github.com/libp2p/go-ws-transport v0.0.3/go.mod h1:iU0kzfMcO4tBVIk3z+7srp1YG/RFLWTSuO4enpivw8g=

lib/fsi.go

@@ -72,3 +72,16 @@ func (m *FSIMethods) Status(dir *string, res *[]StatusItem) (err error) {
 	*res, err = fsint.Status(*dir)
 	return err
 }
+
+
+// AlisStatus checks for any modifications or errors in a dataset alias
+func (m *FSIMethods) AliasStatus(alias *string, res *[]StatusItem) (err error) {
+	if m.inst.rpc != nil {
+		return m.inst.rpc.Call("FSIMethods.AliasStatus", alias, res)
+	}
+
+	// TODO (b5) - inst should have an fsi instance
+	fsint := fsi.NewFSI(m.inst.repo, fsi.RepoPath(m.inst.repoPath))
+	*res, err = fsint.AliasStatus(*alias)
+	return err
+}