hostexec

type Dialer interface {
	DialHost(user, hostAlias string, overridePort int, identityFile string) (HostClient, error)
}

type DialerFunc func(user, hostAlias string, overridePort int, identityFile string) (HostClient, error)

type Executor interface {
	Dial(user string, r hosts.Record) (HostClient, error)
	RunInteractive(user string, r hosts.Record) error
	RunTunnel(ctx context.Context, user string, r hosts.Record, localFwd string, out io.Writer) error
	DialUpstream(ctx context.Context, user string, r hosts.Record, address string) (net.Conn, error)
}

type ExecutorResolver interface {
	ResolveExecutor(rec hosts.Record, reg Registry) Executor
}

type ExecutorResolverFunc func(rec hosts.Record, reg Registry) Executor

type HostClient interface {
	Run(cmd string) ([]byte, error)
	// RunWithStreams runs a remote command with stdin/stdout/stderr wired through.
	// stderr may be nil to discard remote stderr.
	RunWithStreams(cmd string, stdin io.Reader, stdout, stderr io.Writer) error
	Upload(localPath, remotePath string) error
	Download(remotePath, localPath string) error
	ListRemoteDir(path string) ([]RemoteFileEntry, error)
	StatRemote(path string) (RemoteFileEntry, error)
	MkdirAllRemote(path string) error
	RemoveRemote(path string, recursive bool) error
	Close() error
}

type InteractiveRunner interface {
	RunInteractive(user string, r hosts.Record, recorder any) error
}

type InteractiveRunnerFunc func(user string, r hosts.Record, recorder any) error

type Reconfigurer interface {
	ReconfigureFromConfig(cfg *config.File)
}

type ReconfigurerFunc func(cfg *config.File)

type Registry interface {
	ForRecord(r hosts.Record) Executor
	Reconfigure(cfg *config.File)
	RunSSHTunnel(ctx context.Context, user, host string, sshPort int, localFwd string, out io.Writer) error
	BorrowSSH(user string, hop hosts.Record) (any, bool)
}

type RemoteFileEntry struct {
	Name       string    `json:"name"`
	Path       string    `json:"path"`
	IsDir      bool      `json:"is_dir"`
	Size       int64     `json:"size"`
	Mode       string    `json:"mode"`
	ModifiedAt time.Time `json:"modified_at"`
}

type SSHBorrower interface {
	BorrowSSH(user string, hop hosts.Record) (any, bool)
}

type SSHBorrowerFunc func(user string, hop hosts.Record) (any, bool)

type StandardRegistry struct {
	Resolver     ExecutorResolver
	Reconfigurer Reconfigurer
	Dialer       Dialer
	Interactive  InteractiveRunner
	Tunnel       TunnelRunner
	SSHBorrower  SSHBorrower
}

type TunnelRunner interface {
	RunTunnel(ctx context.Context, user, host string, sshPort int, localFwd string, out io.Writer) error
}

type TunnelRunnerFunc func(ctx context.Context, user, host string, sshPort int, localFwd string, out io.Writer) error