ssh tcp bridge

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
use "lori"

actor SshClientTcpBridge is (TCPConnectionActor & ClientLifecycleEventReceiver)
  var _tcp_connection: TCPConnection = TCPConnection.none()
  let _session: SshSession tag

  new create(auth: TCPConnectAuth, host: String, port: String,
    session: SshSession tag)
  =>
    _session = session
    _tcp_connection = TCPConnection.client(auth, host, port, "", this, this)

  fun ref _connection(): TCPConnection => _tcp_connection

  fun ref _on_connected() =>
    _session._tcp_connected()

  fun ref _on_connection_failure(reason: ConnectionFailureReason) =>
    _session._tcp_connection_failed()

  fun ref _on_received(data: Array[U8] iso) =>
    _session._tcp_received(consume data)

  fun ref _on_closed() =>
    _session._tcp_closed()

  be write(data: ByteSeq) =>
    _connection().send(data)

  be close() =>
    _connection().close()

actor SshServerTcpBridge is (TCPConnectionActor & ServerLifecycleEventReceiver)
  var _tcp_connection: TCPConnection = TCPConnection.none()
  let _session: SshSession tag

  new create(auth: TCPServerAuth, fd: U32, session: SshSession tag) =>
    _session = session
    _tcp_connection = TCPConnection.server(auth, fd, this, this)

  fun ref _connection(): TCPConnection => _tcp_connection

  fun ref _on_started() =>
    _session._tcp_connected()

  fun ref _on_received(data: Array[U8] iso) =>
    _session._tcp_received(consume data)

  fun ref _on_closed() =>
    _session._tcp_closed()

  be write(data: ByteSeq) =>
    _connection().send(data)

  be close() =>
    _connection().close()