mirror of
https://github.com/appleboy/drone-ssh.git
synced 2025-07-02 21:52:51 +08:00
fix: undefined variable.
This commit is contained in:
parent
c3155dea41
commit
ebe1d829fb
10
plugin.go
10
plugin.go
@ -1,12 +1,14 @@
|
|||||||
package main
|
package main
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"log"
|
||||||
"net"
|
"net"
|
||||||
"os"
|
"os"
|
||||||
"strconv"
|
"strconv"
|
||||||
"strings"
|
"strings"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
|
"fmt"
|
||||||
"golang.org/x/crypto/ssh"
|
"golang.org/x/crypto/ssh"
|
||||||
)
|
)
|
||||||
|
|
||||||
@ -32,7 +34,7 @@ type (
|
|||||||
// Exec executes the plugin.
|
// Exec executes the plugin.
|
||||||
func (p Plugin) Exec() error {
|
func (p Plugin) Exec() error {
|
||||||
if p.Config.Key == "" && p.Config.Password == "" {
|
if p.Config.Key == "" && p.Config.Password == "" {
|
||||||
return errors.New("Error: can't connect without a private SSH key or password")
|
return fmt.Errorf("Error: can't connect without a private SSH key or password")
|
||||||
}
|
}
|
||||||
|
|
||||||
for i, host := range p.Config.Host {
|
for i, host := range p.Config.Host {
|
||||||
@ -48,7 +50,7 @@ func (p Plugin) Exec() error {
|
|||||||
signer, err := ssh.ParsePrivateKey([]byte(p.Config.Key))
|
signer, err := ssh.ParsePrivateKey([]byte(p.Config.Key))
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return errors.New("Error: Failed to parse private key. %s", err)
|
return fmt.Errorf("Error: Failed to parse private key. %s", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
auths = append(auths, ssh.PublicKeys(signer))
|
auths = append(auths, ssh.PublicKeys(signer))
|
||||||
@ -69,13 +71,13 @@ func (p Plugin) Exec() error {
|
|||||||
client, err := ssh.Dial("tcp", addr, config)
|
client, err := ssh.Dial("tcp", addr, config)
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return errors.New("Error: Failed to dial to server. %s", err)
|
return fmt.Errorf("Error: Failed to dial to server. %s", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
session, err := client.NewSession()
|
session, err := client.NewSession()
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return errors.New("Error: Failed to start a SSH session. %s", err)
|
return fmt.Errorf("Error: Failed to start a SSH session. %s", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
defer session.Close()
|
defer session.Close()
|
||||||
|
Loading…
Reference in New Issue
Block a user