mirror of
				https://github.com/containers/podman.git
				synced 2025-11-04 17:07:20 +08:00 
			
		
		
		
	This commit is courtesy of ``` for f in $(git ls-files *.go | grep -v ^vendor/); do \ sed -i 's/\(errors\..*\)"Error /\1"error /' $f; done for f in $(git ls-files *.go | grep -v ^vendor/); do \ sed -i 's/\(errors\..*\)"Failed to /\1"failed to /' $f; done ``` etc. Self-reviewed using `git diff --word-diff`, found no issues. Signed-off-by: Kir Kolyshkin <kolyshkin@gmail.com>
		
			
				
	
	
		
			101 lines
		
	
	
		
			3.1 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
			
		
		
	
	
			101 lines
		
	
	
		
			3.1 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
package utils
 | 
						|
 | 
						|
import (
 | 
						|
	"fmt"
 | 
						|
	"net/http"
 | 
						|
 | 
						|
	"github.com/containers/podman/v2/libpod/define"
 | 
						|
	"github.com/containers/podman/v2/pkg/domain/entities"
 | 
						|
	"github.com/pkg/errors"
 | 
						|
	log "github.com/sirupsen/logrus"
 | 
						|
)
 | 
						|
 | 
						|
var (
 | 
						|
	ErrLinkNotSupport = errors.New("Link is not supported")
 | 
						|
)
 | 
						|
 | 
						|
// TODO: document the exported functions in this file and make them more
 | 
						|
// generic (e.g., not tied to one ctr/pod).
 | 
						|
 | 
						|
// Error formats an API response to an error
 | 
						|
//
 | 
						|
// apiMessage and code must match the container API, and are sent to client
 | 
						|
// err is logged on the system running the podman service
 | 
						|
func Error(w http.ResponseWriter, apiMessage string, code int, err error) {
 | 
						|
	// Log detailed message of what happened to machine running podman service
 | 
						|
	log.Infof("Request Failed(%s): %s", http.StatusText(code), err.Error())
 | 
						|
	em := entities.ErrorModel{
 | 
						|
		Because:      (errors.Cause(err)).Error(),
 | 
						|
		Message:      err.Error(),
 | 
						|
		ResponseCode: code,
 | 
						|
	}
 | 
						|
	WriteJSON(w, code, em)
 | 
						|
}
 | 
						|
 | 
						|
func VolumeNotFound(w http.ResponseWriter, name string, err error) {
 | 
						|
	if errors.Cause(err) != define.ErrNoSuchVolume {
 | 
						|
		InternalServerError(w, err)
 | 
						|
	}
 | 
						|
	msg := fmt.Sprintf("No such volume: %s", name)
 | 
						|
	Error(w, msg, http.StatusNotFound, err)
 | 
						|
}
 | 
						|
 | 
						|
func ContainerNotFound(w http.ResponseWriter, name string, err error) {
 | 
						|
	if errors.Cause(err) != define.ErrNoSuchCtr {
 | 
						|
		InternalServerError(w, err)
 | 
						|
	}
 | 
						|
	msg := fmt.Sprintf("No such container: %s", name)
 | 
						|
	Error(w, msg, http.StatusNotFound, err)
 | 
						|
}
 | 
						|
 | 
						|
func ImageNotFound(w http.ResponseWriter, name string, err error) {
 | 
						|
	if errors.Cause(err) != define.ErrNoSuchImage {
 | 
						|
		InternalServerError(w, err)
 | 
						|
	}
 | 
						|
	msg := fmt.Sprintf("No such image: %s", name)
 | 
						|
	Error(w, msg, http.StatusNotFound, err)
 | 
						|
}
 | 
						|
 | 
						|
func NetworkNotFound(w http.ResponseWriter, name string, err error) {
 | 
						|
	if errors.Cause(err) != define.ErrNoSuchNetwork {
 | 
						|
		InternalServerError(w, err)
 | 
						|
	}
 | 
						|
	msg := fmt.Sprintf("No such network: %s", name)
 | 
						|
	Error(w, msg, http.StatusNotFound, err)
 | 
						|
}
 | 
						|
 | 
						|
func PodNotFound(w http.ResponseWriter, name string, err error) {
 | 
						|
	if errors.Cause(err) != define.ErrNoSuchPod {
 | 
						|
		InternalServerError(w, err)
 | 
						|
	}
 | 
						|
	msg := fmt.Sprintf("No such pod: %s", name)
 | 
						|
	Error(w, msg, http.StatusNotFound, err)
 | 
						|
}
 | 
						|
 | 
						|
func SessionNotFound(w http.ResponseWriter, name string, err error) {
 | 
						|
	if errors.Cause(err) != define.ErrNoSuchExecSession {
 | 
						|
		InternalServerError(w, err)
 | 
						|
	}
 | 
						|
	msg := fmt.Sprintf("No such exec session: %s", name)
 | 
						|
	Error(w, msg, http.StatusNotFound, err)
 | 
						|
}
 | 
						|
 | 
						|
func ContainerNotRunning(w http.ResponseWriter, containerID string, err error) {
 | 
						|
	msg := fmt.Sprintf("Container %s is not running", containerID)
 | 
						|
	Error(w, msg, http.StatusConflict, err)
 | 
						|
}
 | 
						|
 | 
						|
func InternalServerError(w http.ResponseWriter, err error) {
 | 
						|
	Error(w, http.StatusText(http.StatusInternalServerError), http.StatusInternalServerError, err)
 | 
						|
}
 | 
						|
 | 
						|
func BadRequest(w http.ResponseWriter, key string, value string, err error) {
 | 
						|
	e := errors.Wrapf(err, "failed to parse query parameter '%s': %q", key, value)
 | 
						|
	Error(w, http.StatusText(http.StatusBadRequest), http.StatusBadRequest, e)
 | 
						|
}
 | 
						|
 | 
						|
// UnsupportedParameter logs a given param by its string name as not supported.
 | 
						|
func UnSupportedParameter(param string) {
 | 
						|
	log.Infof("API parameter %q: not supported", param)
 | 
						|
}
 |