Method wait_auth

tee/cocoon/FwdProxy.cpp:88–112

  }

  td::Status wait_auth() {
    auto buf = pipe_.input_buffer().clone();
    TRY_RESULT(header, read(buf, 2));
    td::uint8 version = header[0];
    if (version != 0x1) {
      return td::Status::Error(PSLICE() << "Invalid socks5 auth version " << version << ", expected 0x1");
    }
    td::uint8 user_length = header[1];
    TRY_RESULT(user, read(buf, user_length));

    TRY_RESULT(header2, read(buf, 1));
    td::uint8 password_length = header2[0];
    TRY_RESULT(password, read(buf, password_length));

    TRY_STATUS(set_policy_name(user));

    pipe_.input_buffer() = std::move(buf);

    unsigned char ans[2];
    ans[0] = 0x1;  // version
    ans[1] = 0x0;  // status
    pipe_.output_buffer().append(td::Slice(ans, 2));
    state_ = State::WaitRequest;
    return td::Status::OK();
  }

  td::Status set_policy_name(const std::string &policy_name) {
    LOG(ERROR) << "set policy name = " << policy_name;