feat(api): change report API

qri-io · Dec 8, 2020 · ca16f3c · ca16f3c
1 parent 63c3d44
commit ca16f3c
Show file tree

Hide file tree

Showing 9 changed files with 1,334 additions and 2 deletions.
diff --git a/api/api.go b/api/api.go
@@ -167,6 +167,7 @@ func NewServerRoutes(s Server) *http.ServeMux {
 	m.Handle("/get/", s.middleware(dsh.GetHandler))
 	m.Handle("/rename", s.middleware(dsh.RenameHandler))
 	m.Handle("/diff", s.middleware(dsh.DiffHandler))
+	m.Handle("/changes", s.middleware(dsh.ChangesHandler))
 	// Deprecated, use /get/username/name?component=body or /get/username/name/body.csv
 	m.Handle("/body/", s.middleware(dsh.BodyHandler))
 	m.Handle("/stats/", s.middleware(dsh.StatsHandler))

diff --git a/api/datasets.go b/api/datasets.go
@@ -97,6 +97,20 @@ func (h *DatasetHandlers) DiffHandler(w http.ResponseWriter, r *http.Request) {
 	}
 }
 
+// ChangesHandler is a dataset single endpoint
+func (h *DatasetHandlers) ChangesHandler(w http.ResponseWriter, r *http.Request) {
+	switch r.Method {
+	case http.MethodPost, http.MethodGet:
+		if h.ReadOnly {
+			readOnlyResponse(w, "/changereport")
+			return
+		}
+		h.changesHandler(w, r)
+	default:
+		util.NotFoundHandler(w, r)
+	}
+}
+
 // PeerListHandler is a dataset list endpoint
 func (h *DatasetHandlers) PeerListHandler(w http.ResponseWriter, r *http.Request) {
 	switch r.Method {
@@ -340,6 +354,30 @@ func (h *DatasetHandlers) diffHandler(w http.ResponseWriter, r *http.Request) {
 	util.WritePageResponse(w, res, r, util.Page{})
 }
 
+func (h *DatasetHandlers) changesHandler(w http.ResponseWriter, r *http.Request) {
+	req := &lib.ChangeReportParams{}
+	switch r.Header.Get("Content-Type") {
+	case "application/json":
+		if err := json.NewDecoder(r.Body).Decode(req); err != nil {
+			util.WriteErrResponse(w, http.StatusBadRequest, fmt.Errorf("error decoding body into params: %s", err.Error()))
+			return
+		}
+	default:
+		req = &lib.ChangeReportParams{
+			LeftRefstr:  r.FormValue("left_path"),
+			RightRefstr: r.FormValue("right_path"),
+		}
+	}
+
+	res := &lib.ChangeReport{}
+	if err := h.ChangeReport(req, res); err != nil {
+		util.WriteErrResponse(w, http.StatusInternalServerError, fmt.Errorf("error generating change report: %s", err.Error()))
+		return
+	}
+
+	util.WritePageResponse(w, res, r, util.Page{})
+}
+
 func (h *DatasetHandlers) peerListHandler(w http.ResponseWriter, r *http.Request) {
 	log.Info(r.URL.Path)
 	p := lib.ListParamsFromRequest(r)