#include "webcc/client_pool.h"

#include "webcc/logger.h"

namespace webcc {

ClientPool::~ClientPool() {
  if (!clients_.empty()) {
    LOG_INFO("Close socket for all (%u) connections in the pool",
             clients_.size());

    for (auto& pair : clients_) {
      pair.second->Close();
    }
  }
}

ClientPtr ClientPool::Get(const Key& key) const {
  auto it = clients_.find(key);

  if (it != clients_.end()) {
    return it->second;
  } else {
    return {};
  }
}

void ClientPool::Add(const Key& key, ClientPtr client) {
  clients_[key] = client;

  LOG_INFO("Connection added to pool (%s, %s, %s)",
           key.scheme.c_str(), key.host.c_str(), key.port.c_str());
}

void ClientPool::Remove(const Key& key) {
  clients_.erase(key);

  LOG_INFO("Connection removed from pool (%s, %s, %s)",
           key.scheme.c_str(), key.host.c_str(), key.port.c_str());
}

}  // namespace webcc