mirror of https://github.com/1Panel-dev/1Panel
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
114 lines
2.9 KiB
114 lines
2.9 KiB
package terminal
|
|
|
|
import (
|
|
"encoding/base64"
|
|
"encoding/json"
|
|
"sync"
|
|
|
|
"github.com/1Panel-dev/1Panel/backend/global"
|
|
"github.com/gorilla/websocket"
|
|
"github.com/pkg/errors"
|
|
)
|
|
|
|
type LocalWsSession struct {
|
|
slave *LocalCommand
|
|
wsConn *websocket.Conn
|
|
|
|
writeMutex sync.Mutex
|
|
}
|
|
|
|
func NewLocalWsSession(cols, rows int, wsConn *websocket.Conn, slave *LocalCommand) (*LocalWsSession, error) {
|
|
if err := slave.ResizeTerminal(cols, rows); err != nil {
|
|
global.LOG.Errorf("ssh pty change windows size failed, err: %v", err)
|
|
}
|
|
|
|
return &LocalWsSession{
|
|
slave: slave,
|
|
wsConn: wsConn,
|
|
}, nil
|
|
}
|
|
|
|
func (sws *LocalWsSession) Start(quitChan chan bool) {
|
|
go sws.handleSlaveEvent(quitChan)
|
|
go sws.receiveWsMsg(quitChan)
|
|
}
|
|
|
|
func (sws *LocalWsSession) handleSlaveEvent(exitCh chan bool) {
|
|
defer setQuit(exitCh)
|
|
defer global.LOG.Debug("thread of handle slave event has exited now")
|
|
|
|
buffer := make([]byte, 1024)
|
|
for {
|
|
select {
|
|
case <-exitCh:
|
|
return
|
|
default:
|
|
n, _ := sws.slave.Read(buffer)
|
|
_ = sws.masterWrite(buffer[:n])
|
|
}
|
|
}
|
|
}
|
|
|
|
func (sws *LocalWsSession) masterWrite(data []byte) error {
|
|
sws.writeMutex.Lock()
|
|
defer sws.writeMutex.Unlock()
|
|
wsData, err := json.Marshal(WsMsg{
|
|
Type: WsMsgCmd,
|
|
Data: base64.StdEncoding.EncodeToString(data),
|
|
})
|
|
if err != nil {
|
|
return errors.Wrapf(err, "failed to encoding to json")
|
|
}
|
|
err = sws.wsConn.WriteMessage(websocket.TextMessage, wsData)
|
|
if err != nil {
|
|
return errors.Wrapf(err, "failed to write to master")
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (sws *LocalWsSession) receiveWsMsg(exitCh chan bool) {
|
|
wsConn := sws.wsConn
|
|
defer setQuit(exitCh)
|
|
defer global.LOG.Debug("thread of receive ws msg has exited now")
|
|
for {
|
|
select {
|
|
case <-exitCh:
|
|
return
|
|
default:
|
|
_, wsData, err := wsConn.ReadMessage()
|
|
if err != nil {
|
|
global.LOG.Errorf("reading webSocket message failed, err: %v", err)
|
|
return
|
|
}
|
|
msgObj := WsMsg{}
|
|
_ = json.Unmarshal(wsData, &msgObj)
|
|
switch msgObj.Type {
|
|
case WsMsgResize:
|
|
if msgObj.Cols > 0 && msgObj.Rows > 0 {
|
|
if err := sws.slave.ResizeTerminal(msgObj.Cols, msgObj.Rows); err != nil {
|
|
global.LOG.Errorf("ssh pty change windows size failed, err: %v", err)
|
|
}
|
|
}
|
|
case WsMsgCmd:
|
|
decodeBytes, err := base64.StdEncoding.DecodeString(msgObj.Data)
|
|
if err != nil {
|
|
global.LOG.Errorf("websock cmd string base64 decoding failed, err: %v", err)
|
|
}
|
|
sws.sendWebsocketInputCommandToSshSessionStdinPipe(decodeBytes)
|
|
case WsMsgHeartbeat:
|
|
// 接收到心跳包后将心跳包原样返回，可以用于网络延迟检测等情况
|
|
err = wsConn.WriteMessage(websocket.TextMessage, wsData)
|
|
if err != nil {
|
|
global.LOG.Errorf("ssh sending heartbeat to webSocket failed, err: %v", err)
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
func (sws *LocalWsSession) sendWebsocketInputCommandToSshSessionStdinPipe(cmdBytes []byte) {
|
|
if _, err := sws.slave.Write(cmdBytes); err != nil {
|
|
global.LOG.Errorf("ws cmd bytes write to ssh.stdin pipe failed, err: %v", err)
|
|
}
|
|
}
|