Method start_up

net/TcpConnection.cpp:36–92

namespace cocoon {

void TcpConnection::start_up() {
  self_ = actor_id(this);
  update_timer();

  if (!type_) {
    CHECK(socket_pipe_);
    start();
    return;
  }

  type_->type.visit(td::overloaded(
      [&](const TcpConnectionSimple &t) {
        auto R = td::SocketFd::open(connect_to_);
        if (R.is_error()) {
          fail(R.move_as_error_prefix(PSTRING() << "tcp: failed to connect to " << connect_to_ << ": "));
          return;
        }
        socket_pipe_ = td::make_socket_pipe(R.move_as_ok());
        start();
      },
      [&](const TcpConnectionSocks5 &t) {
        auto R = td::SocketFd::open(t.connect_via);
        if (R.is_error()) {
          fail(R.move_as_error_prefix(PSTRING() << "tcp: failed to connect to " << t.connect_via << ": "));
          return;
        }
        td::connect(
            [self = actor_id(this), connect_to = connect_to_](td::Result<td::BufferedFd<td::SocketFd>> R) {
              if (R.is_ok()) {
                td::actor::send_closure(self, &TcpConnection::socks5_connected, R.move_as_ok());
              } else {
                td::actor::send_closure(
                    self, &TcpConnection::fail,
                    R.move_as_error_prefix(PSTRING() << "tcp: failed to connect to " << connect_to << " via socks5: "));
              }
            },
            socks5(R.move_as_ok(), connect_to_, "", ""));
      },
      [&](const TcpConnectionTls &t) {
        auto R = td::SocketFd::open(connect_to_);
        if (R.is_error()) {
          fail(R.move_as_error_prefix(PSTRING() << "tcp: failed to connect to " << connect_to_ << ": "));
          return;
        }
        auto pipe = td::make_socket_pipe(R.move_as_ok());
        td::connect(
            [self = actor_id(this)](td::Result<td::SocketPipe> R) {
              if (R.is_ok()) {
                td::actor::send_closure(self, &TcpConnection::tls_solved_pow, R.move_as_ok());
              } else {
                td::actor::send_closure(self, &TcpConnection::fail,
                                        R.move_as_error_prefix("tcp: failed to solve pow: "));
              }
            },
            pow::solve_pow_client(std::move(pipe), 28));
      }));
}