#pragma once

#include <algorithm>
#include <functional>
#include <td/common/NonCopyable.h>
#include <vector>

namespace td {
namespace utils {

/**
 * \brief Signal class
 */
template <typename... Args>
class SignalRaw : private NonCopyable {
  public:
	using FnType = void(Args...);
	using CallBack = std::function<FnType>;

  private:
	std::vector<CallBack> m_Callbacks;

  public:
	void Connect(const CallBack& a_Callback) {
		m_Callbacks.push_back(a_Callback);
	}

	void Disconnect(const CallBack& a_Callback) {
		auto it = std::find_if(m_Callbacks.begin(), m_Callbacks.end(),
			[&a_Callback](CallBack& callback) { return a_Callback.template target<FnType>() == callback.template target<FnType>(); });
		m_Callbacks.erase(it);
	}

	void operator()(Args... args) const {
		for (const CallBack& callback : m_Callbacks) {
			callback(args...);
		}
	}
};

/**
 * \brief Memory managed Signal class
 */
template <typename... Args>
class Signal {
  public:
	using SignalBase = SignalRaw<Args...>;
	using CallBack = typename SignalBase::CallBack;
	using SignalPtr = std::shared_ptr<SignalBase>;
	class ConnectionGuard;

  private:
	SignalPtr m_Signal;

  public:
	Signal() : m_Signal(std::make_shared<SignalBase>()) {}
	Signal(const Signal&) = default;

	void Connect(const CallBack& a_Callback) {
		m_Signal->Connect(a_Callback);
	}

	[[nodiscard]] std::unique_ptr<ConnectionGuard> ConnectSafe(const CallBack& a_Callback) {
		Connect(a_Callback);
		return std::make_unique<ConnectionGuard>(*this, a_Callback);
	}

	void Disconnect(const CallBack& a_Callback) {
		m_Signal->Disconnect(a_Callback);
	}

	void operator()(Args... args) const {
		m_Signal->operator()(args...);
	}
};

class Connection {
  public:
	virtual ~Connection() {}
};

template <typename... Args>
class Signal<Args...>::ConnectionGuard : public Connection {
  private:
	using CallBack = typename Signal<Args...>::CallBack;

	std::weak_ptr<SignalRaw<Args...>> m_Signal;
	CallBack m_Callback;

  public:
	ConnectionGuard(const Signal<Args...>& a_Signal, const CallBack& a_Callback) : m_Signal(a_Signal.m_Signal), m_Callback(a_Callback) {}

	~ConnectionGuard() {
		if (!m_Signal.expired())
			m_Signal.lock()->Disconnect(m_Callback);
	}
};

}  // namespace utils
}  // namespace td