Method handleUnregister

server.go:630–680

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

}

func (s *Server) handleUnregister(w http.ResponseWriter, r *http.Request) {
	var req UnregisterDatabaseRequest
	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
	}

	// Set up timeout context. Treat non-positive values as default.
	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)

	// Remove database from store (this also closes it).
	if err := s.store.UnregisterDB(ctx, expandedPath); err != nil {
		writeJSONError(w, http.StatusInternalServerError, fmt.Sprintf("failed to unregister database: %v", err), nil)
		return
	}
	var txID uint64
	status := "already_unregistered"
	if db != nil {
		_, maxTXID, err := db.MaxLTX()
		if err != nil {
			writeJSONError(w, http.StatusInternalServerError, fmt.Sprintf("failed to read final txid: %v", err), nil)
			return
		}
		txID = uint64(maxTXID)
		status = "unregistered"
	}

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