Method OAuthTokenAuth

be/src/util/webserver.cc:1187–1218

}

bool Webserver::OAuthTokenAuth(const std::string& oauth_token,
    struct sq_connection* connection, struct sq_request_info* request_info) {
  JWTHelper::UniqueJWTDecodedToken decoded_token;
  Status status = JWTHelper::Decode(oauth_token, decoded_token);
  if (!status.ok()) {
    LOG(ERROR) << "Error decoding OAuth token in Authorization header, "
               << "Error: " << status;
    return false;
  }
  if (FLAGS_oauth_jwt_validate_signature) {
    status = ExecEnv::GetInstance()->GetOAuthHelperInstance()->Verify(
        decoded_token.get());
    if (!status.ok()) {
      LOG(ERROR) << "Error verifying OAuth token in Authorization header, "
                 << "Error: " << status;
      return false;
    }
  }

  DCHECK(!FLAGS_oauth_jwt_custom_claim_username.empty());
  string username;
  status = JWTHelper::GetCustomClaimUsername(
      decoded_token.get(), FLAGS_oauth_jwt_custom_claim_username, username);
  if (!status.ok()) {
    LOG(ERROR) << "Cannot retrieve username from OAUTh token in Authorization header, "
               << "Error: " << status;
    return false;
  }
  request_info->remote_user = strdup(username.c_str());

  return true;
}

Status Webserver::HandleBasic(struct sq_connection* connection,
    struct sq_request_info* request_info, vector<string>* response_headers) {