feat(api): init fsi endpoint

qri-io · Jul 26, 2019 · 7613302 · 7613302
1 parent 56fae3b
commit 7613302
Show file tree

Hide file tree

Showing 2 changed files with 34 additions and 0 deletions.
diff --git a/api/api.go b/api/api.go
@@ -295,6 +295,7 @@ func NewServerRoutes(s Server) *http.ServeMux {
  m.Handle("/fsi/", s.middleware(fsih.DatasetHandler))
  m.Handle("/fsi/body/", s.middleware(fsih.BodyHandler))
  m.Handle("/fsi/save/", s.middleware(fsih.SaveHandler))
+ m.Handle("/fsi/init/", s.middleware(fsih.InitHandler))
 
  renderh := NewRenderHandlers(node.Repo)
  m.Handle("/render/", s.middleware(renderh.RenderHandler))

diff --git a/api/fsi.go b/api/fsi.go
@@ -232,3 +232,36 @@ func (h *FSIHandlers) saveHandler(w http.ResponseWriter, r *http.Request) {
 
  util.WriteResponse(w, res)
 }
+
+// InitHandler creates a new FSI-linked dataset
+func (h *FSIHandlers) InitHandler(w http.ResponseWriter, r *http.Request) {
+ if h.ReadOnly {
+ readOnlyResponse(w, "/fsi/init")
+ return
+ }
+
+ switch r.Method {
+ case "OPTIONS":
+ util.EmptyOkHandler(w, r)
+ case "POST":
+ h.initHandler(w, r)
+ default:
+ util.NotFoundHandler(w, r)
+ }
+}
+
+func (h *FSIHandlers) initHandler(w http.ResponseWriter, r *http.Request) {
+ p := &lib.InitFSIDatasetParams{
+ Filepath: r.FormValue("filepath"),
+ Name: r.FormValue("name"),
+ Format: r.FormValue("format"),
+ }
+
+ var name string
+ if err := h.InitDataset(p, &name); err != nil {
+ util.WriteErrResponse(w, http.StatusBadRequest, err)
+ return
+ }
+
+ util.WriteResponse(w, map[string]string{"ref": name})
+}