SSH Remote Port Fowarding

client.go

package main

import (
	"log"

	"dev.justinjudd.org/justin/easyssh"
	"golang.org/x/crypto/ssh"
)

func main() {
	config := &ssh.ClientConfig{
		User: "test",
		Auth: []ssh.AuthMethod{
			ssh.Password("test"),
		},
	}

  hostString := "ip:port"
  conn, err := easyssh.Dial("tcp", hostString, config)
  if err != nil {
  	log.Fatalf("unable to connect: %s", err)
  }
  defer conn.Close()

  err = conn.RemoteForward("0.0.0.0:8000", "localhost:80")
  if err != nil {
  	log.Fatalf("unable to forward local port: %s", err)
  }

}

server.go

package main

import (
	"fmt"
	"net"
	"dev.justinjudd.org/justin/easyssh"

	"golang.org/x/crypto/ssh"
)

var sshListener net.Listener
func main() {

  host_string := "0.0.0.0:6667"

  privateBytes := []byte(`-----BEGIN RSA PRIVATE KEY-----
MIIEpAIBAAKCAQEA3iFZY9GjMkGznXCGIutlgFJxfaq2qmx5vW7Hld7mT8Bxn5GP
TX1oe/AZbfGovYTxD8i0hew2j3qmG2ZkgWPOWVZd+Ky7gZe5pJylTL79YpYs/3Xq
xtuNpwtcdqd4QHuon01WODFq4RQhFwq/s3tLjNBuWgQm/6uiDrgw3aUJPqwXX8cr
lBQRPX5CdtkbGEHp1cUWz9EF35Hwu9FQ+Ki3snspf8Dz3Nmsr+8COlMp3CWrGCt8
gG7IQH1YP6CNz4xp5OUEm6VYhtVoY90N4My6ZFR1KFL/vgHlFx8dp/OugQZEqZTU
g8ExDmuNtE8nGUMExHgASz7UIR+90kOBx7rnpQIDAQABAoIBAQCV5+OvnZaJIBXb
NkkP39SMGRdGO6MyuCogUVaYKek8AR+tFEqlfPC6U3qV2/SIkeMtR8Gsb5ESmy7m
Zt+FApoLaGHapJeWCZLbKGvVsz7E/Zw4epeKxDiAdwZbfQGGYu2VNFfvbEo4w6Dh
L/vXYGnIChGu5gZ7nJStYlh3/ByVEcQXGT3rjEKA5R5zjqXTwNhqOaxC9QRpTSUT
KTBQaDry8LRwcISI06F/sYAyTpNPytX3Xc80xpV/r6Qh0PkgzAW7Ui+N8MXUUfDt
gb4f+nddBVmvq1F09A7Uo5W9+ZOznqhlElZ8rmblBsTImAOG2n7dyO1vT7DU4ATq
WGZFbEaxAoGBAPtARoov6KlSPjAAmO5/X2FAXcBqQ2SZ9GxSVRC1zrnx8NES5FhQ
2ohtJnAK5Xri9cjlr+gqzgroWWLSvEw/UFaRFwQ3Hc3qfRwK7W/8DwU4CgnnAyla
t6o89xu/YkhnTpS4wXceSU+J2OWqt80YK4LvyEkyWEb8/NS3Z8w90exDAoGBAOJU
KtIH2M7lTV2WtFjCPk9g538qQGtQBmialElfxCOE4LVyRiHZJAKxe4rev4rRd7dl
7fBr0i5FMeXP3P4EPxgH+trcgVCPeSr8y7V/1oIT7gwFnkXAQz0vwtzJG3je05An
T7iIAc3pKXaEdVD7MwacN8/G1zkvnX55CTlQSpH3AoGAUa9s/6Jh1yLY+wxGrEuW
++xMTrF9pah0Ef+Wjm89fbDOJXsp6BipY+9wrr6sKw688ArU7Pt1r5Ao93siIvv2
p55WSFWPCBJziHl5Bo6BZ6X3hY6otXo7+koF4OyRDI8hujJzG8Ip/YUIkmq1hSWV
h+VjTYDjuHipzpKuWXXD2TcCgYA/lqA1RGkgsAINkmL3MRPqn3JLIybYP7KdPxj8
iICF7jZoJEQaDHT2oMDyImU0bmexSl0QmGqD/4Lma4FOiQjlCpDrXtqiNL05W68s
Pk+ZWloeXJG8TSlXDo00FPi3+/r63GCkmunO3Xx9xPdlGj6a09dGdDpR4dPhDcaO
qMVavwKBgQCNJmgkx6uS7PoaDCBI9xY7hZVUbJ4svTsM768dEs/idYl8JjbKMqt9
8GCd1jZxIcpEidY+X8h5GFtFVvWF67ncF+70wBfNOpGL3/mK51KLveMuSx+moKIj
raongFrv2IAutz8WM/0bOVsLFtqOOBYJgUlm+tzbiIFaXzY26j8Q7A==
-----END RSA PRIVATE KEY-----\n`)

      private, err := ssh.ParsePrivateKey(privateBytes)
      if err != nil {
       fmt.Println("Error with Key")
      }

      config := &ssh.ServerConfig{
        PasswordCallback: func(c ssh.ConnMetadata, pass []byte) (*ssh.Permissions, error) {
          if c.User() == "test" && string(pass) == "test" {
            return nil, nil
          }
          return nil, fmt.Errorf("password rejected for %s", c.User())
        },
      }
      config.AddHostKey(private)
      easyssh.HandleChannel(easyssh.SessionRequest, easyssh.SessionHandler())
      easyssh.HandleChannel(easyssh.DirectForwardRequest, easyssh.DirectPortForwardHandler())
      easyssh.HandleRequestFunc(easyssh.RemoteForwardRequest, easyssh.TCPIPForwardRequest)
      //easyssh.ListenAndServe(":2022", config, nil)


      sshListener, err := net.Listen("tcp", host_string)
      if err != nil {
		fmt.Println("SSH Error")
        return
      }
      easyssh.Serve(sshListener,config, nil)
}