2019-05-09 02:04:40 +00:00
|
|
|
package websocket
|
|
|
|
|
|
|
|
import (
|
|
|
|
"net"
|
|
|
|
"net/http"
|
|
|
|
"net/http/httputil"
|
|
|
|
"time"
|
|
|
|
|
|
|
|
"github.com/asaskevich/govalidator"
|
|
|
|
"github.com/gorilla/websocket"
|
|
|
|
httperror "github.com/portainer/libhttp/error"
|
|
|
|
"github.com/portainer/libhttp/request"
|
2021-02-23 03:21:39 +00:00
|
|
|
portainer "github.com/portainer/portainer/api"
|
2020-07-07 21:57:52 +00:00
|
|
|
"github.com/portainer/portainer/api/bolt/errors"
|
2019-05-09 02:04:40 +00:00
|
|
|
)
|
|
|
|
|
2021-02-23 03:21:39 +00:00
|
|
|
// @summary Attach a websocket
|
|
|
|
// @description If the nodeName query parameter is present, the request will be proxied to the underlying agent endpoint.
|
|
|
|
// @description If the nodeName query parameter is not specified, the request will be upgraded to the websocket protocol and
|
|
|
|
// @description an AttachStart operation HTTP request will be created and hijacked.
|
|
|
|
// @description Authentication and access is controlled via the mandatory token query parameter.
|
|
|
|
// @security jwt
|
|
|
|
// @tags websocket
|
|
|
|
// @accept json
|
|
|
|
// @produce json
|
|
|
|
// @param endpointId query int true "endpoint ID of the endpoint where the resource is located"
|
|
|
|
// @param nodeName query string false "node name"
|
|
|
|
// @param token query string true "JWT token used for authentication against this endpoint"
|
|
|
|
// @success 200
|
|
|
|
// @failure 400
|
|
|
|
// @failure 403
|
|
|
|
// @failure 404
|
|
|
|
// @failure 500
|
|
|
|
// @router /websocket/attach [get]
|
2019-05-09 02:04:40 +00:00
|
|
|
func (handler *Handler) websocketAttach(w http.ResponseWriter, r *http.Request) *httperror.HandlerError {
|
|
|
|
attachID, err := request.RetrieveQueryParameter(r, "id", false)
|
|
|
|
if err != nil {
|
|
|
|
return &httperror.HandlerError{http.StatusBadRequest, "Invalid query parameter: id", err}
|
|
|
|
}
|
|
|
|
if !govalidator.IsHexadecimal(attachID) {
|
|
|
|
return &httperror.HandlerError{http.StatusBadRequest, "Invalid query parameter: id (must be hexadecimal identifier)", err}
|
|
|
|
}
|
|
|
|
|
|
|
|
endpointID, err := request.RetrieveNumericQueryParameter(r, "endpointId", false)
|
|
|
|
if err != nil {
|
|
|
|
return &httperror.HandlerError{http.StatusBadRequest, "Invalid query parameter: endpointId", err}
|
|
|
|
}
|
|
|
|
|
2020-05-20 05:23:15 +00:00
|
|
|
endpoint, err := handler.DataStore.Endpoint().Endpoint(portainer.EndpointID(endpointID))
|
2020-07-07 21:57:52 +00:00
|
|
|
if err == errors.ErrObjectNotFound {
|
2019-05-09 02:04:40 +00:00
|
|
|
return &httperror.HandlerError{http.StatusNotFound, "Unable to find the endpoint associated to the stack inside the database", err}
|
|
|
|
} else if err != nil {
|
|
|
|
return &httperror.HandlerError{http.StatusInternalServerError, "Unable to find the endpoint associated to the stack inside the database", err}
|
|
|
|
}
|
|
|
|
|
2020-08-11 05:41:37 +00:00
|
|
|
err = handler.requestBouncer.AuthorizedEndpointOperation(r, endpoint)
|
2019-05-09 02:04:40 +00:00
|
|
|
if err != nil {
|
2019-05-24 06:04:58 +00:00
|
|
|
return &httperror.HandlerError{http.StatusForbidden, "Permission denied to access endpoint", err}
|
2019-05-09 02:04:40 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
params := &webSocketRequestParams{
|
|
|
|
endpoint: endpoint,
|
|
|
|
ID: attachID,
|
|
|
|
nodeName: r.FormValue("nodeName"),
|
|
|
|
}
|
|
|
|
|
|
|
|
err = handler.handleAttachRequest(w, r, params)
|
|
|
|
if err != nil {
|
|
|
|
return &httperror.HandlerError{http.StatusInternalServerError, "An error occured during websocket attach operation", err}
|
|
|
|
}
|
|
|
|
|
|
|
|
return nil
|
|
|
|
}
|
|
|
|
|
|
|
|
func (handler *Handler) handleAttachRequest(w http.ResponseWriter, r *http.Request, params *webSocketRequestParams) error {
|
|
|
|
|
|
|
|
r.Header.Del("Origin")
|
|
|
|
|
2019-07-25 22:38:07 +00:00
|
|
|
if params.endpoint.Type == portainer.AgentOnDockerEnvironment {
|
|
|
|
return handler.proxyAgentWebsocketRequest(w, r, params)
|
2020-07-05 23:21:03 +00:00
|
|
|
} else if params.endpoint.Type == portainer.EdgeAgentOnDockerEnvironment {
|
2019-07-25 22:38:07 +00:00
|
|
|
return handler.proxyEdgeAgentWebsocketRequest(w, r, params)
|
2019-05-09 02:04:40 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
websocketConn, err := handler.connectionUpgrader.Upgrade(w, r, nil)
|
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
defer websocketConn.Close()
|
|
|
|
|
|
|
|
return hijackAttachStartOperation(websocketConn, params.endpoint, params.ID)
|
|
|
|
}
|
|
|
|
|
|
|
|
func hijackAttachStartOperation(websocketConn *websocket.Conn, endpoint *portainer.Endpoint, attachID string) error {
|
|
|
|
dial, err := initDial(endpoint)
|
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
|
|
|
|
// When we set up a TCP connection for hijack, there could be long periods
|
|
|
|
// of inactivity (a long running command with no output) that in certain
|
|
|
|
// network setups may cause ECONNTIMEOUT, leaving the client in an unknown
|
|
|
|
// state. Setting TCP KeepAlive on the socket connection will prohibit
|
|
|
|
// ECONNTIMEOUT unless the socket connection truly is broken
|
|
|
|
if tcpConn, ok := dial.(*net.TCPConn); ok {
|
|
|
|
tcpConn.SetKeepAlive(true)
|
|
|
|
tcpConn.SetKeepAlivePeriod(30 * time.Second)
|
|
|
|
}
|
|
|
|
|
|
|
|
httpConn := httputil.NewClientConn(dial, nil)
|
|
|
|
defer httpConn.Close()
|
|
|
|
|
|
|
|
attachStartRequest, err := createAttachStartRequest(attachID)
|
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
|
|
|
|
err = hijackRequest(websocketConn, httpConn, attachStartRequest)
|
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
|
|
|
|
return nil
|
|
|
|
}
|
|
|
|
|
|
|
|
func createAttachStartRequest(attachID string) (*http.Request, error) {
|
|
|
|
|
|
|
|
request, err := http.NewRequest("POST", "/containers/"+attachID+"/attach?stdin=1&stdout=1&stderr=1&stream=1", nil)
|
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
|
|
|
|
request.Header.Set("Content-Type", "application/json")
|
|
|
|
request.Header.Set("Connection", "Upgrade")
|
|
|
|
request.Header.Set("Upgrade", "tcp")
|
|
|
|
|
|
|
|
return request, nil
|
|
|
|
}
|