Method handleStop

server.go:221–272

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

}

func (s *Server) handleStop(w http.ResponseWriter, r *http.Request) {
	var req StopRequest
	if err := json.NewDecoder(r.Body).Decode(&req); err != nil {
		writeJSONError(w, http.StatusBadRequest, "invalid request body", err.Error())
		return
	}

	if req.Path == "" {
		writeJSONError(w, http.StatusBadRequest, "path required", nil)
		return
	}

	expandedPath, err := s.expandPath(req.Path)
	if err != nil {
		writeJSONError(w, http.StatusBadRequest, fmt.Sprintf("invalid path: %v", err), nil)
		return
	}

	timeout := req.Timeout
	if timeout == 0 {
		timeout = 30
	}
	ctx, cancel := context.WithTimeout(s.ctx, time.Duration(timeout)*time.Second)
	defer cancel()

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

	status := "stopped"
	if !db.IsOpen() {
		status = "already_stopped"
	} else {
		if err := s.store.DisableDB(ctx, expandedPath); err != nil {
			writeJSONError(w, http.StatusInternalServerError, err.Error(), nil)
			return
		}
	}
	txID, err := s.storeTXID(expandedPath)
	if err != nil {
		writeJSONError(w, http.StatusInternalServerError, err.Error(), nil)
		return
	}

	writeJSON(w, http.StatusOK, StopResponse{
		Status: status,
		Path:   expandedPath,
		TXID:   txID,
	})
}

func (s *Server) storeTXID(path string) (uint64, error) {
	db := s.store.FindDB(path)