api/rocketmq/Credentials.h

#pragma once

#include <chrono>
#include <string>
#include <utility>

#include "rocketmq/RocketMQ.h"

ROCKETMQ_NAMESPACE_BEGIN

class Credentials {
public:
  Credentials() : expiration_instant_(std::chrono::system_clock::time_point::max()) {
  }

  Credentials(std::string access_key, std::string access_secret)
      : access_key_(std::move(access_key)), access_secret_(std::move(access_secret)),
        expiration_instant_(std::chrono::system_clock::time_point::max()) {
  }

  Credentials(std::string access_key, std::string access_secret, std::string session_token,
              std::chrono::system_clock::time_point expiration)
      : access_key_(std::move(access_key)), access_secret_(std::move(access_secret)),
        session_token_(std::move(session_token)), expiration_instant_(expiration) {
  }

  bool operator==(const Credentials& rhs) const {
    return access_key_ == rhs.access_key_ && access_secret_ == rhs.access_secret_ &&
           session_token_ == rhs.session_token_ && expiration_instant_ == rhs.expiration_instant_;
  }

  bool operator!=(const Credentials& rhs) const {
    return !(*this == rhs);
  }

  bool empty() const {
    return access_key_.empty() || access_secret_.empty();
  }

  bool expired() const {
    return std::chrono::system_clock::now() > expiration_instant_;
  }

  const std::string& accessKey() const {
    return access_key_;
  }

  const std::string& accessSecret() const {
    return access_secret_;
  }

  const std::string& sessionToken() const {
    return session_token_;
  }

  std::chrono::system_clock::time_point expirationInstant() const {
    return expiration_instant_;
  }

private:
  std::string access_key_;
  std::string access_secret_;
  std::string session_token_;
  std::chrono::system_clock::time_point expiration_instant_;
};

ROCKETMQ_NAMESPACE_END