70 lines
1.5 KiB
Go
70 lines
1.5 KiB
Go
package ssh
|
|
|
|
import (
|
|
"bytes"
|
|
"net"
|
|
|
|
"github.com/genofire/golang-lib/log"
|
|
"golang.org/x/crypto/ssh"
|
|
)
|
|
|
|
type SSHResultHandler func(string, string, error)
|
|
|
|
func SSHResultToString(result string) string {
|
|
if len(result) > 0 {
|
|
result = result[:len(result)-1]
|
|
}
|
|
return result
|
|
}
|
|
|
|
func SSHResultToStringHandler(handler SSHResultHandler) SSHResultHandler {
|
|
return func(addr string, result string, err error) {
|
|
handler(addr, SSHResultToString(result), err)
|
|
}
|
|
}
|
|
|
|
func (m *Manager) RunEverywhere(cmd string, handler SSHResultHandler) {
|
|
m.clientsMUX.Lock()
|
|
defer m.clientsMUX.Unlock()
|
|
for host, client := range m.clients {
|
|
go func() {
|
|
result, err := m.run(host, client, cmd)
|
|
handler(host, result, err)
|
|
}()
|
|
}
|
|
}
|
|
|
|
func (m *Manager) RunOn(addr net.TCPAddr, cmd string) (string, error) {
|
|
client, err := m.ConnectTo(addr)
|
|
if err != nil {
|
|
return "", err
|
|
}
|
|
return m.run(addr.IP.String(), client, cmd)
|
|
}
|
|
|
|
func (m *Manager) run(host string, client *ssh.Client, cmd string) (string, error) {
|
|
session, err := client.NewSession()
|
|
defer session.Close()
|
|
|
|
if err != nil {
|
|
log.Log.Warnf("can not create session on %s: %s", host, err)
|
|
m.clientsMUX.Lock()
|
|
delete(m.clients, host)
|
|
m.clientsMUX.Unlock()
|
|
return "", err
|
|
}
|
|
buffer := &bytes.Buffer{}
|
|
session.Stdout = buffer
|
|
if err != nil {
|
|
log.Log.Warnf("can not create pipe for run on %s: %s", host, err)
|
|
delete(m.clients, host)
|
|
return "", err
|
|
}
|
|
err = session.Run(cmd)
|
|
if err != nil {
|
|
log.Log.Debugf("could not run %s on %s: %s", cmd, host, err)
|
|
return "", err
|
|
}
|
|
return buffer.String(), nil
|
|
}
|