Method handleSyncStatus

server.go:317–344

(w http.ResponseWriter, r *http.Request)

}

func (s *Server) handleSyncStatus(w http.ResponseWriter, r *http.Request) {
	path := r.URL.Query().Get("path")
	if path != "" {
		expandedPath, err := s.expandPath(path)
		if err != nil {
			writeJSONError(w, http.StatusBadRequest, fmt.Sprintf("invalid path: %v", err), nil)
			return
		}

		db := s.store.FindDB(expandedPath)
		if db == nil {
			writeJSONError(w, http.StatusNotFound, "database not found", nil)
			return
		}

		writeJSON(w, http.StatusOK, SyncDiagnosticsResponse{
			Databases: []SyncDiagnostic{db.SyncDiagnostic()},
		})
		return
	}

	dbs := s.store.DBs()
	diagnostics := make([]SyncDiagnostic, 0, len(dbs))
	for _, db := range dbs {
		diagnostics = append(diagnostics, db.SyncDiagnostic())
	}
	writeJSON(w, http.StatusOK, SyncDiagnosticsResponse{Databases: diagnostics})
}

func writeJSON(w http.ResponseWriter, status int, v interface{}) {
	w.Header().Set("Content-Type", "application/json")