Method authenticateRequest

src/brpc/couchbase.cpp:560–602

}

bool CouchbaseOperations::CouchbaseRequest::authenticateRequest(
    const butil::StringPiece& username, const butil::StringPiece& password) {
  if (username.empty() || password.empty()) {
    DEBUG_PRINT("Empty username or password");
    return false;
  }
  // insert the features to get enabled, calling function helloRequest() will do
  // this.
  if (!helloRequest()) {
    DEBUG_PRINT("Failed to send helloRequest for authentication");
    return false;
  }
  // Construct the request header
  constexpr char kPlainAuthCommand[] = "PLAIN";
  constexpr char kPadding[1] = {'\0'};
  const brpc::policy::CouchbaseRequestHeader header = {
      brpc::policy::CB_MAGIC_REQUEST,
      brpc::policy::CB_BINARY_SASL_AUTH,
      butil::HostToNet16(sizeof(kPlainAuthCommand) - 1),
      0,
      0,
      0,
      butil::HostToNet32(sizeof(kPlainAuthCommand) + 1 + username.length() * 2 +
                         password.length()),
      0,
      0};
  std::string auth_str;
  auth_str.reserve(sizeof(header) + sizeof(kPlainAuthCommand) - 1 +
                   username.size() * 2 + password.size() + 2);
  auth_str.append(reinterpret_cast<const char*>(&header), sizeof(header));
  auth_str.append(kPlainAuthCommand, sizeof(kPlainAuthCommand) - 1);
  auth_str.append(username.data(), username.size());
  auth_str.append(kPadding, sizeof(kPadding));
  auth_str.append(username.data(), username.size());
  auth_str.append(kPadding, sizeof(kPadding));
  auth_str.append(password.data(), password.size());
  if (_buf.append(auth_str.data(), auth_str.size())) {
    DEBUG_PRINT("Failed to append auth std::string to buffer");
    return false;
  }
  ++_pipelined_count;
  return true;
}

void CouchbaseOperations::CouchbaseRequest::MergeFrom(
    const CouchbaseRequest& from) {