src/main/cpp/client/include/ClientConfigImpl.h

#pragma once

#include "ClientConfig.h"
#include "absl/strings/string_view.h"
#include "absl/time/time.h"
#include "rocketmq/RocketMQ.h"
#include <atomic>
#include <chrono>
#include <memory>
#include <string>
#include <vector>

ROCKETMQ_NAMESPACE_BEGIN

class ClientConfigImpl : virtual public ClientConfig {
public:
  ClientConfigImpl();

  explicit ClientConfigImpl(std::string group_name);

  ~ClientConfigImpl() override = default;

  const std::string& resourceNamespace() const override { return resource_namespace_; }

  void resourceNamespace(absl::string_view resource_namespace) {
    resource_namespace_ = std::string(resource_namespace.data(), resource_namespace.length());
  }

  std::string clientId() const override;

  const std::string& getInstanceName() const;

  void setInstanceName(std::string instance_name);

  const std::string& getGroupName() const override;
  void setGroupName(std::string group_name);

  const std::string& getUnitName() const { return unit_name_; }
  void setUnitName(std::string unit_name) { unit_name_ = std::move(unit_name); }

  absl::Duration getIoTimeout() const override;
  void setIoTimeout(absl::Duration timeout);

  absl::Duration getLongPollingTimeout() const override { return long_polling_timeout_; }

  void setLongPollingTimeout(absl::Duration timeout) { long_polling_timeout_ = timeout; }

  bool isTracingEnabled() { return enable_tracing_.load(); }
  void enableTracing(bool enabled) { enable_tracing_.store(enabled); }

  CredentialsProviderPtr credentialsProvider() override;
  void setCredentialsProvider(CredentialsProviderPtr credentials_provider);

  void serviceName(std::string service_name) { service_name_ = std::move(service_name); }
  const std::string& serviceName() const override { return service_name_; }

  void region(std::string region) { region_ = std::move(region); }
  const std::string& region() const override { return region_; }

  void tenantId(std::string tenant_id) { tenant_id_ = std::move(tenant_id); }
  const std::string& tenantId() const override { return tenant_id_; }

  static const char* CLIENT_VERSION;

protected:
  /**
   * Name of the service.
   */
  std::string service_name_{"ONS"};

  /**
   * Region of the service to connect to.
   */
  std::string region_;

  /**
   * RocketMQ instance namespace, in which topic, consumer group and any other abstract resources remain unique.
   */
  std::string resource_namespace_;

  /**
   * Tenant identifier.
   */
  std::string tenant_id_;

  std::string instance_name_;

  std::string group_name_;

  std::string unit_name_;

  CredentialsProviderPtr credentials_provider_;

  absl::Duration io_timeout_;

  absl::Duration long_polling_timeout_;

  std::atomic<bool> enable_tracing_{false};
};

ROCKETMQ_NAMESPACE_END