feat(api): Unpack endpoint gets a zip and sends back its contents

api/api.go

@@ -240,6 +240,7 @@ func NewServerRoutes(s *Server) *http.ServeMux {
 	m.Handle("/export/", s.middleware(dsh.ZipDatasetHandler))
 	m.Handle("/diff", s.middleware(dsh.DiffHandler))
 	m.Handle("/body/", s.middleware(dsh.BodyHandler))
+	m.Handle("/unpack/", s.middleware(dsh.UnpackHandler))
 
 	renderh := NewRenderHandlers(s.qriNode.Repo)
 	m.Handle("/render/", s.middleware(renderh.RenderHandler))

api/datasets.go

@@ -1,6 +1,7 @@
 package api
 
 import (
+	"archive/zip"
 	"bytes"
 	"encoding/json"
 	"errors"
@@ -176,6 +177,23 @@ func (h *DatasetHandlers) BodyHandler(w http.ResponseWriter, r *http.Request) {
 	}
 }
 
+// UnpackHandler unpacks a zip file and sends it back as json
+func (h *DatasetHandlers) UnpackHandler(w http.ResponseWriter, r *http.Request) {
+	switch r.Method {
+	case "OPTIONS":
+		util.EmptyOkHandler(w, r)
+	case "POST":
+		postData, err := ioutil.ReadAll(r.Body)
+		if err != nil {
+			util.WriteErrResponse(w, http.StatusBadRequest, err)
+			return
+		}
+		h.unpackHandler(w, r, postData)
+	default:
+		util.NotFoundHandler(w, r)
+	}
+}
+
 // ZipDatasetHandler is the endpoint for getting a zip archive of a dataset
 func (h *DatasetHandlers) ZipDatasetHandler(w http.ResponseWriter, r *http.Request) {
 	switch r.Method {
@@ -765,3 +783,35 @@ func (h DatasetHandlers) bodyHandler(w http.ResponseWriter, r *http.Request) {
 		log.Infof("error writing response: %s", err.Error())
 	}
 }
+
+func (h DatasetHandlers) unpackHandler(w http.ResponseWriter, r *http.Request, postData []byte) {
+	zr, err := zip.NewReader(bytes.NewReader(postData), int64(len(postData)))
+	if err != nil {
+		util.WriteErrResponse(w, http.StatusInternalServerError, err)
+		return
+	}
+	// Create a map from filenames in the zip to their json encoded contents.
+	contents := make(map[string]string)
+	for _, f := range zr.File {
+		rc, err := f.Open()
+		if err != nil {
+			util.WriteErrResponse(w, http.StatusInternalServerError, err)
+			return
+		}
+		data, err := ioutil.ReadAll(rc)
+		if err != nil {
+			util.WriteErrResponse(w, http.StatusInternalServerError, err)
+			return
+		}
+		contents[f.Name] = string(data)
+	}
+	data, err := json.Marshal(contents)
+	if err != nil {
+		util.WriteErrResponse(w, http.StatusInternalServerError, err)
+		return
+	}
+	// Send response.
+	w.Header().Set("Content-Type", "application/json")
+	w.WriteHeader(http.StatusOK)
+	w.Write(data)
+}