#pragma once

#include <string>
#include <future>
#include <map>
#include <mutex>
#include <regex>

#include "IRCDDB.h"
#include "IRCMessageQueue.h"

class IRCDDBApp
{
public:
	IRCDDBApp(const std::string &update_channel, CCacheManager *cache, bool log_irc);
	~IRCDDBApp();

	void userJoin(const std::string &nick, const std::string &name, const std::string &host);

	void userLeave(const std::string &nick);

	void userListReset();

	void msgChannel(IRCMessage *m);
	void msgQuery(IRCMessage *m);

	void setCurrentNick(const std::string &nick);

	void setBestServer(const std::string &ircUser);

	void setSendQ(IRCMessageQueue *s);
	IRCMessageQueue *getSendQ();

	void putReplyMessage(IRCMessage *m);
	void sendPing(const std::string &to, const std::string &from);

	bool startWork();
	void stopWork();

	IRCDDB_RESPONSE_TYPE getReplyMessageType();

	IRCMessage *getReplyMessage();

	bool findUser(const std::string &s);

	bool sendHeard(const std::string &myCall, const std::string &myCallExt, const std::string &yourCall, const std::string &rpt1, const std::string &rpt2, unsigned char flag1, unsigned char flag2, unsigned char flag3, const std::string &destination, const std::string &tx_msg, const std::string &tx_stats);

	int getConnectionState();

	void rptrQRG(const std::string &rptrcall, double txFrequency, double duplexShift, double range, double agl);

	void rptrQTH(const std::string &rtprcall, double latitude, double longitude, const std::string &desc1, const std::string &desc2, const std::string &infoURL, const std::string &swVersion);

	void kickWatchdog(const std::string &wdInfo);

protected:
	void Entry();

private:
	const int numberOfTables;
	void doUpdate(std::string &msg);
	void doNotFound(std::string &msg, std::string &retval);
	bool findServerUser();
	std::string getTableIDString(int tableID, bool spaceBeforeNumber);
	std::string getLastEntryTime(int tableID);
	std::future<void> worker_thread;
	IRCMessageQueue *sendQ;
	IRCMessageQueue replyQ;
	CCacheManager *cache;

	std::map<std::string, std::string> moduleMap;
	std::mutex moduleMapMutex;
	std::map<std::string, std::string> locationMap;
	std::mutex locationMapMutex;
	std::map<std::string, std::string> urlMap;
	std::mutex urlMapMutex;
	std::map<std::string, std::string> swMap;
	std::mutex swMapMutex;

	std::string currentServer;
	std::string myNick;

	std::regex tablePattern, datePattern, timePattern, dbPattern, modulePattern;

	int state;
	int timer;
	int infoTimer;
	int wdTimer;
	time_t maxTime;

	std::string updateChannel;
	std::string channelTopic;
	std::string bestServer;
	std::string wdInfo;

	bool initReady;
	bool terminateThread;
	bool logIRC;
};