sshego

Aug 23, 2017

Changes in this version

type SshegoConfig

+ Halt *ssh.Halter

+ SkipCommandRecv bool

+ SshClient *ssh.Client

+ Underlying net.Conn

+ func (cfg *SshegoConfig) NewSSHClient(ctx context.Context, c ssh.Conn, chans <-chan ssh.NewChannel, ...) *ssh.Client

Aug 12, 2017

Changes in this version

+ func Base64ofPublicKey(key ssh.PublicKey) string

type Filedb

+ func NewFiledb(filepath string) (*Filedb, error)

type HostDb

+ HostSshSigner ssh.Signer

+ Persist HostDbPersist

+ UserHomePrefix string

+ func (h *HostDb) Rsapath(username string) string

+ type HostDbPersist struct

+ HostPrivateKeyPath string

+ Users *AtomicUserMap

+ func (z *HostDbPersist) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *HostDbPersist) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *HostDbPersist) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *HostDbPersist) Msgsize() (s int)

+ func (z *HostDbPersist) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z *HostDbPersist) UnmarshalMsgWithCfg(bts []byte, cfg *msgp.RuntimeConfig) (o []byte, err error)

type KnownHosts

+ Mut sync.Mutex

type ServerPubKey

+ Mut sync.Mutex

type SshegoConfig

+ Nickname string

+ func (cfg *SshegoConfig) ChannelHandlerSummary() (s string)

type User

+ PublicKey ssh.PublicKey

Aug 11, 2017

Changes in this version

+ type Filedb struct

+ HostDb *HostDb

+ func (b *Filedb) Close()

+ func (b *Filedb) SaveToDisk() error

+ func (z *Filedb) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *Filedb) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *Filedb) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *Filedb) Msgsize() (s int)

+ func (z *Filedb) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z *Filedb) UnmarshalMsgWithCfg(bts []byte, cfg *msgp.RuntimeConfig) (o []byte, err error)

Aug 11, 2017

Changes in this version

type AtomicUserMap

+ func (z *AtomicUserMap) UnmarshalMsgWithCfg(bts []byte, cfg *msgp.RuntimeConfig) (o []byte, err error)

+ type CustomChannelHandlerCB func(nc ssh.NewChannel, ca *ConnectionAlert)

type HostDb

+ func (z *HostDb) UnmarshalMsgWithCfg(bts []byte, cfg *msgp.RuntimeConfig) (o []byte, err error)

type LoginRecord

+ func (z *LoginRecord) UnmarshalMsgWithCfg(bts []byte, cfg *msgp.RuntimeConfig) (o []byte, err error)

type SshegoConfig

+ CustomChannelHandlers map[string]CustomChannelHandlerCB

type User

+ func (z *User) UnmarshalMsgWithCfg(bts []byte, cfg *msgp.RuntimeConfig) (o []byte, err error)

Aug 6, 2017

Changes in this version

+ func StartKeepalives(sshClientConn *ssh.Client) (error, chan struct{})

type DialConfig

+ CancelKeepAlive chan struct{}

+ SkipKeepAlive bool

Mar 28, 2017

Changes in this version

type AtomicUserMap

+ func (m *AtomicUserMap) String() string

type HostDb

+ func (h *HostDb) String() string

type User

+ func (u *User) String() string

Mar 27, 2017

Changes in this version

+ func AddUserAndExit(cfg *SshegoConfig)

+ func DelUserAndExit(cfg *SshegoConfig)

+ func GetAvailPort() (net.Listener, int)

+ func IsAlreadyBound(addr string) bool

+ func MakeAndMoveToTempDir() (origdir string, tmpdir string)

+ func StartBackgroundTestTcpServer(serverDone chan bool, payloadByteCount int, confirmationPayload string, ...)

+ func TempDirCleanup(origdir string, tmpdir string)

+ func TestCreateNewAccount(srvCfg *SshegoConfig) (mylogin, toptPath, rsaPath, pw string, err error)

+ func UnencPingPong(dest, confirmationPayload, confirmationReply string, payloadByteCount int)

+ func VerifyClientServerExchangeAcrossSshd(channelToTcpServer net.Conn, confirmationPayload, confirmationReply string, ...)

+ func WaitUntilAddrAvailable(addr string, dur time.Duration, tries int) int

type DialConfig

+ TestAllowOneshotConnect bool

type SshegoConfig

+ Mut sync.Mutex

+ Origdir string

+ Tempdir string

+ TestAllowOneshotConnect bool

+ TestingModeNoWait bool

+ func GenTestConfig() (c *SshegoConfig, releasePorts func())

+ type TestSetup struct

+ CliCfg *SshegoConfig

+ Mylogin string

+ Pw string

+ RsaPath string

+ SrvCfg *SshegoConfig

+ Totp string

+ func MakeTestSshClientAndServer(startEsshd bool) *TestSetup

Jan 22, 2017

Changes in this version

+ type BasicAddress struct

+ func (a *BasicAddress) Network() string

+ func (a *BasicAddress) String() string

+ type BasicListener struct

+ func (b *BasicListener) Accept() (net.Conn, error)

+ func (b *BasicListener) Addr() net.Addr

+ func (b *BasicListener) Close() error

+ type BasicServer struct

+ func NewBasicServer(cfg *SshegoConfig) *BasicServer

+ func (b *BasicServer) Close() error

+ func (bs *BasicServer) Listen(laddr string) (*BasicListener, error)

+ type ConnectionAlert struct

+ PortOne chan ssh.Channel

+ ShutDown chan bool

type Esshd

+ Halt idem.Halter

+ func (e *Esshd) Listen(bs *BasicServer) (*BasicListener, error)

Jan 17, 2017

Changes in this version

+ const ProgramName

+ var GIT_BRANCH string

+ var GO_VERSION string

+ var LAST_GIT_COMMIT_HASH string

+ var NEAREST_GIT_TAG string

+ func SourceVersion() string

type SshegoConfig

+ ShowVersion bool

Jan 17, 2017

Changes in this version

type DialConfig

+ Verbose bool

Jan 17, 2017

Changes in this version

+ const MUX_C_OPEN_FWD

+ func DialRemoteUnixDomain(c *ssh.Client, udpath string) (net.Conn, error)

+ func RandomString(n int) string

type AddrHostPort

+ UnixDomainPath string

Jan 15, 2017

Changes in this version

+ var DelUserCmd = []byte("01DELUSER___")

+ var DelUserCmdStr = string(DelUserCmd)

+ var DelUserReplyFailed = []byte("01REPLY_FAIL")

+ var DelUserReplyOK = []byte("01REPLY_OK__")

+ var ErrCouldNotAquirePort = fmt.Errorf(...)

+ var NewUserCmd = []byte("00NEWUSER___")

+ var NewUserCmdStr = string(NewUserCmd)

+ var NewUserReply = []byte("00REPLY_____")

+ var Verbose bool

+ func CryptoRandBytes(n int) []byte

+ func CryptoRandInt64() int64

+ func CryptoRandNonNegInt(n int64) int64

+ func Fingerprint(k ssh.PublicKey) string

+ func GenRSAKeyPair(rsaFile string, bits int, email string) (priv *rsa.PrivateKey, sshPriv ssh.Signer, err error)

+ func GenRSAKeyPairCrypt(rsaFile string, bits int, password string) (priv *rsa.PrivateKey, sshPriv ssh.Signer, err error)

+ func GetExternalIP() string

+ func IsRoutableIPv4(ip string) bool

+ func KnownHostsEqual(a, b *KnownHosts) (bool, error)

+ func LoadRSAPrivateKey(path string) (privkey ssh.Signer, err error)

+ func LoadRSAPrivateKeyCrypt(path string, password string) (privkey ssh.Signer, err error)

+ func LoadRSAPublicKey(path string) (pubkey ssh.PublicKey, err error)

+ func PromptForPassword(username string) (pw string, err error)

+ func RSAToSSHPublicKey(pubkey *rsa.PublicKey) []byte

+ func ScryptHash(password string) []byte

+ func SetWinsize(fd uintptr, w, h uint32)

+ type AddrHostPort struct

+ Addr string

+ Host string

+ Port uint64

+ Required bool

+ Title string

+ func (a *AddrHostPort) ParseAddr() error

+ type AtomicUserMap struct

+ U map[string]*User

+ func NewAtomicUserMap() *AtomicUserMap

+ func (m *AtomicUserMap) Del(key string)

+ func (m *AtomicUserMap) Get(key string) *User

+ func (m *AtomicUserMap) Get2(key string) (*User, bool)

+ func (m *AtomicUserMap) Set(key string, val *User)

+ func (z *AtomicUserMap) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *AtomicUserMap) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *AtomicUserMap) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *AtomicUserMap) Msgsize() (s int)

+ func (z *AtomicUserMap) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type AuthState struct

+ AuthorizedKeysMap map[string]bool

+ Cert *ssh.Certificate

+ HostKey ssh.Signer

+ OneTime *TOTP

+ PrivateKeys map[string]interface{}

+ PublicKeys map[string]ssh.PublicKey

+ Signers map[string]ssh.Signer

+ func NewAuthState(w *TOTP) *AuthState

+ func (a *AuthState) LoadHostKey(path string) error

+ func (a *AuthState) LoadPublicKeys(authorizedKeysPath string) error

+ type CommandRecv struct

+ Done chan bool

+ func (cr *CommandRecv) Start() error

+ type DialConfig struct

+ ClientKnownHostsPath string

+ DoNotUpdateSshKnownHosts bool

+ DownstreamHostPort string

+ KnownHosts *KnownHosts

+ Mylogin string

+ Pw string

+ RsaPath string

+ Sshdhost string

+ Sshdport uint64

+ TofuAddIfNotKnown bool

+ TotpUrl string

+ func (dc *DialConfig) Dial() (net.Conn, *ssh.Client, error)

+ type Esshd struct

+ Done chan bool

+ func (e *Esshd) NewCommandRecv() *CommandRecv

+ func (e *Esshd) Start()

+ func (e *Esshd) Stop()

+ type Forwarder struct

+ func NewForward(cfg *SshegoConfig, sshClientConn *ssh.Client, fromBrowser net.Conn) *Forwarder

+ type HostDb struct

+ HostPrivateKeyPath string

+ Users *AtomicUserMap

+ func (h *HostDb) AddUser(mylogin, myemail, pw, issuer, fullname string) (toptPath, qrPath, rsaPath string, err error)

+ func (h *HostDb) DelUser(mylogin string) error

+ func (h *HostDb) UserExists(mylogin string) bool

+ func (h *HostDb) ValidEmail(myemail string) (bool, error)

+ func (h *HostDb) ValidLogin(login string) (bool, error)

+ func (z *HostDb) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *HostDb) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *HostDb) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *HostDb) Msgsize() (s int)

+ func (z *HostDb) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type HostState int

+ const AddedNew

+ const Banned

+ const KnownOK

+ const KnownRecordMismatch

+ const Unknown

+ func (s HostState) String() string

+ type KnownHosts struct

+ FilepathPrefix string

+ Hosts map[string]*ServerPubKey

+ NoSave bool

+ PersistFormat KnownHostsPersistFormat

+ PersistFormatSuffix string

+ func LoadSshKnownHosts(path string) (*KnownHosts, error)

+ func NewKnownHosts(filepath string, format KnownHostsPersistFormat) (*KnownHosts, error)

+ func (h *KnownHosts) AddNeeded(addIfNotKnown, allowOneshotConnect bool, hostname string, remote net.Addr, ...) (HostState, *ServerPubKey, error)

+ func (h *KnownHosts) Close()

+ func (h *KnownHosts) HostAlreadyKnown(hostname string, remote net.Addr, key ssh.PublicKey, pubBytes []byte, ...) (HostState, *ServerPubKey, error)

+ func (h *KnownHosts) Sync() (err error)

+ type KnownHostsPersistFormat int

+ const KHGob

+ const KHJson

+ const KHSsh

+ type LoginRecord struct

+ AcceptedCount int64

+ FirstTm time.Time

+ LastTm time.Time

+ PubFinger string

+ SeenCount int64

+ func (r LoginRecord) String() string

+ func (z *LoginRecord) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *LoginRecord) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *LoginRecord) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *LoginRecord) Msgsize() (s int)

+ func (z *LoginRecord) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type MailgunConfig struct

+ Domain string

+ PublicApiKey string

+ SecretApiKey string

+ func (c *MailgunConfig) DefineFlags(fs *flag.FlagSet)

+ func (c *MailgunConfig) LoadConfig(path string) error

+ func (c *MailgunConfig) SaveConfig(fd io.Writer) error

+ func (c *MailgunConfig) SendEmail(senderEmail, subject, plain, html, recipEmail string) (string, error)

+ func (c *MailgunConfig) ValidateConfig() error

+ type PerAttempt struct

+ Config *ssh.ServerConfig

+ OneTimeOK bool

+ PublicKeyOK bool

+ State *AuthState

+ User *User

+ func NewPerAttempt(s *AuthState, cfg *SshegoConfig) *PerAttempt

+ func (a *PerAttempt) AuthLogCallback(conn ssh.ConnMetadata, method string, err error)

+ func (a *PerAttempt) KeyboardInteractiveCallback(conn ssh.ConnMetadata, challenge ssh.KeyboardInteractiveChallenge) (*ssh.Permissions, error)

+ func (a *PerAttempt) NoteLogin(user *User, now time.Time, conn ssh.ConnMetadata)

+ func (a *PerAttempt) PerConnection(nConn net.Conn)

+ func (a *PerAttempt) PublicKeyCallback(c ssh.ConnMetadata, providedPubKey ssh.PublicKey) (perm *ssh.Permissions, rerr error)

+ func (a *PerAttempt) SetTripleConfig()

+ func (a *PerAttempt) SetupAuthRequirements()

+ type Reverse struct

+ type ServerPubKey struct

+ AlreadySaved bool

+ Base64EncodededPublicKey string

+ Comment string

+ Hostname string

+ Hostnames string

+ HumanKey string

+ Keytype string

+ LineInFileOneBased int

+ Markers string

+ Port string

+ ServerBanned bool

+ SplitHostnames map[string]bool

+ func (prior *ServerPubKey) AddHostPort(hp string)

+ type SshegoConfig struct

+ AddIfNotKnown bool

+ AddUser string

+ BitLenRSAkeys int

+ ClientKnownHostsPath string

+ ConfigPath string

+ Debug bool

+ DelUser string

+ DirectTcp bool

+ EmbeddedSSHd AddrHostPort

+ EmbeddedSSHdHostDbPath string

+ Esshd *Esshd

+ HostDb *HostDb

+ KnownHosts *KnownHosts

+ LocalToRemote TunnelSpec

+ MailCfg MailgunConfig

+ PrivateKeyPath string

+ Quiet bool

+ RemoteToLocal TunnelSpec

+ SSHdServer AddrHostPort

+ SkipPassphrase bool

+ SkipRSA bool

+ SkipTOTP bool

+ SshegoSystemMutexPort int

+ SshegoSystemMutexPortString string

+ Username string

+ WriteConfigOnly bool

+ WriteConfigOut string

+ func NewSshegoConfig() *SshegoConfig

+ func (c *SshegoConfig) DefineFlags(fs *flag.FlagSet)

+ func (c *SshegoConfig) LoadConfig(path string) error

+ func (c *SshegoConfig) SaveConfig(fd io.Writer) error

+ func (c *SshegoConfig) ValidateConfig() error

+ func (cfg *SshegoConfig) GenAuthString() string

+ func (cfg *SshegoConfig) NewEsshd() *Esshd

+ func (cfg *SshegoConfig) NewHostDb() error

+ func (cfg *SshegoConfig) SSHConnect(h *KnownHosts, username string, keypath string, sshdHost string, ...) (*ssh.Client, error)

+ func (cfg *SshegoConfig) StartNewReverse(sshClientConn *ssh.Client, fromRemote net.Conn) (*Reverse, error)

+ func (cfg *SshegoConfig) StartupForwardListener(sshClientConn *ssh.Client) error

+ func (cfg *SshegoConfig) StartupReverseListener(sshClientConn *ssh.Client) error

+ func (cfg *SshegoConfig) TcpClientUserAdd(user *User) (toptPath, qrPath, rsaPath string, err error)

+ func (cfg *SshegoConfig) TcpClientUserDel(user *User) error

+ type TOTP struct

+ Issuer string

+ Key *otp.Key

+ QRcodePng []byte

+ UserEmail string

+ func NewTOTP(userEmail, issuer string) (w *TOTP, err error)

+ func (w *TOTP) IsValid(passcode string, mylogin string) bool

+ func (w *TOTP) LoadFromFile(path string) error

+ func (w *TOTP) SaveToFile(path string) (secretPath, qrPath string, err error)

+ func (w *TOTP) String() string

+ type TcpPort struct

+ Lsn net.Listener

+ Port int

+ func (t *TcpPort) Lock(limitMsec int) error

+ func (t *TcpPort) Unlock()

+ type TunnelSpec struct

+ Listen AddrHostPort

+ Remote AddrHostPort

+ type User struct

+ ClearPw string

+ DisabledAcct bool

+ FirstLoginTime time.Time

+ IPwhitelist []string

+ Issuer string

+ LastLoginAddr string

+ LastLoginTime time.Time

+ MyEmail string

+ MyFullname string

+ MyLogin string

+ PrivateKeyPath string

+ PublicKeyPath string

+ QrPath string

+ ScryptedPassword []byte

+ SeenPubKey map[string]LoginRecord

+ TOTPorig string

+ TOTPpath string

+ func NewUser() *User

+ func (user *User) MatchingHashAndPw(password string) bool

+ func (user *User) RestoreTotp()

+ func (z *User) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *User) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *User) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *User) Msgsize() (s int)

+ func (z *User) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type Winsize struct

+ Height uint16

+ Width uint16