root
/
sftp
mirror of https://github.com/pkg/sftp.git
1
0
Fork 0
Code Issues Actions Packages Projects Releases Wiki Activity

gofmt hook having issues

This commit is contained in:
John Eikenberry 2016-07-24 20:36:42 -07:00
parent 7fe33ffe26
commit 15d5c4cfef
1 changed files with 21 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
examples/request-server/main.go
View File

@ -28,7 +28,9 @@ func main() {
flag.Parse() flag.Parse()
debugStream := ioutil.Discard debugStream := ioutil.Discard
if debugStderr { debugStream = os.Stderr } if debugStderr {
debugStream = os.Stderr
}
// An SSH server is represented by a ServerConfig, which holds // An SSH server is represented by a ServerConfig, which holds
// certificate details and handles authentication of ServerConns. // certificate details and handles authentication of ServerConns.
@ -45,17 +47,23 @@ func main() {
} }
privateBytes, err := ioutil.ReadFile("id_rsa") privateBytes, err := ioutil.ReadFile("id_rsa")
if err != nil { log.Fatal("Failed to load private key", err) } if err != nil {
log.Fatal("Failed to load private key", err)
}
private, err := ssh.ParsePrivateKey(privateBytes) private, err := ssh.ParsePrivateKey(privateBytes)
if err != nil { log.Fatal("Failed to parse private key", err) } if err != nil {
log.Fatal("Failed to parse private key", err)
}
config.AddHostKey(private) config.AddHostKey(private)
// Once a ServerConfig has been configured, connections can be // Once a ServerConfig has been configured, connections can be
// accepted. // accepted.
listener, err := net.Listen("tcp", "0.0.0.0:2022") listener, err := net.Listen("tcp", "0.0.0.0:2022")
if err != nil { log.Fatal("failed to listen for connection", err) } if err != nil {
log.Fatal("failed to listen for connection", err)
}
fmt.Printf("Listening on %v\n", listener.Addr()) fmt.Printf("Listening on %v\n", listener.Addr())
nConn, err := listener.Accept() nConn, err := listener.Accept()
@ -66,7 +74,9 @@ func main() {
// Before use, a handshake must be performed on the incoming // Before use, a handshake must be performed on the incoming
// net.Conn. // net.Conn.
_, chans, reqs, err := ssh.NewServerConn(nConn, config) _, chans, reqs, err := ssh.NewServerConn(nConn, config)
if err != nil { log.Fatal("failed to handshake", err) } if err != nil {
log.Fatal("failed to handshake", err)
}
fmt.Fprintf(debugStream, "SSH server established\n") fmt.Fprintf(debugStream, "SSH server established\n")
// The incoming Request channel must be serviced. // The incoming Request channel must be serviced.
@ -84,7 +94,9 @@ func main() {
continue continue
} }
channel, requests, err := newChannel.Accept() channel, requests, err := newChannel.Accept()
if err != nil { log.Fatal("could not accept channel.", err) } if err != nil {
log.Fatal("could not accept channel.", err)
}
fmt.Fprintf(debugStream, "Channel accepted\n") fmt.Fprintf(debugStream, "Channel accepted\n")
// Sessions have out-of-band requests such as "shell", // Sessions have out-of-band requests such as "shell",
@ -108,7 +120,9 @@ func main() {
root := sftp.InMemHandler() root := sftp.InMemHandler()
server, err := sftp.NewRequestServer(channel, root) server, err := sftp.NewRequestServer(channel, root)
if err != nil { log.Fatal(err) } if err != nil {
log.Fatal(err)
}
if err := server.Serve(); err != nil { if err := server.Serve(); err != nil {
log.Fatal("sftp server completed with error:", err) log.Fatal("sftp server completed with error:", err)
} }