/*
	Copyright 2009-2020, Sumeet Chhetri

    Licensed under the Apache License, Version 2.0 (the "License");
    you may not use this file except in compliance with the License.
    You may obtain a copy of the License at

        http://www.apache.org/licenses/LICENSE-2.0

    Unless required by applicable law or agreed to in writing, software
    distributed under the License is distributed on an "AS IS" BASIS,
    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    See the License for the specific language governing permissions and
    limitations under the License.
*/
/*
 * TeBkUmLpqQwAsync.h
 *
 *  Created on: 03-Feb-2020
 *      Author: sumeetc
 */

#ifndef WEB_t1_INCLUDE_TeBkUmLpqQwAsync_H_
#define WEB_t1_INCLUDE_TeBkUmLpqQwAsync_H_
#include "TemplateHandler.h"
#include "vector"
#ifndef OS_MINGW
#include <netinet/in.h>
#include <arpa/inet.h>
#endif
#include "DataSourceManager.h"
#include <stdlib.h>
#include <algorithm>
#include "CryptoHandler.h"
#include "vector"
#include "CastUtil.h"
#include "CacheManager.h"
#include <stdlib.h>
#include "HttpRequest.h"
#include "HttpResponse.h"
#include "JSONSerialize.h"
#include "string"
#include "yuarel.h"
#include "Router.h"
#include <unordered_map>
#include "ConfigurationData.h"

class TeBkUmLpqQwAsyncWorld;

class TeBkUmLpqQwAsyncWorld {
	int id;
	int randomNumber;
public:
	TeBkUmLpqQwAsyncWorld();
	TeBkUmLpqQwAsyncWorld(int id);
	TeBkUmLpqQwAsyncWorld(int id, int randomNumber);
	virtual ~TeBkUmLpqQwAsyncWorld();
	int getId() const;
	void setId(int id);
	int getRandomNumber() const;
	void setRandomNumber(int randomNumber);
#ifdef HAVE_RAPID_JSON
	void toJson(rapidjson::Writer<rapidjson::StringBuffer>& w) {
		w.StartObject();
		w.String("id", 2);
	    w.Int(id);
		w.String("randomNumber", 12);
	    w.Int(randomNumber);
		w.EndObject();
	}
#endif
#ifdef HAVE_RAPID_JSON
	static void toJson(std::vector<TeBkUmLpqQwAsyncWorld>& vec, rapidjson::Writer<rapidjson::StringBuffer>& w) {
		w.StartArray();
		for(auto el: vec) {
			el.toJson(w);
		}
		w.EndArray();
	}
#endif
};

class TeBkUmLpqQwAsyncFortune {
	int id;
public:
	std::string message_i;
	std::string_view message;
	bool allocd;
	TeBkUmLpqQwAsyncFortune(int id);
	TeBkUmLpqQwAsyncFortune(int id, std::string message);
	TeBkUmLpqQwAsyncFortune();
	virtual ~TeBkUmLpqQwAsyncFortune();
	int getId() const;
	void setId(int id);
	bool operator < (const TeBkUmLpqQwAsyncFortune& other) const;
};

class TeBkUmLpqQwAsyncMessage {
	std::string message;
public:
	TeBkUmLpqQwAsyncMessage();
	TeBkUmLpqQwAsyncMessage(std::string message);
	virtual ~TeBkUmLpqQwAsyncMessage();
	const std::string& getMessage() const;
	void setMessage(const std::string& message);
#ifdef HAVE_RAPID_JSON
	void toJson(rapidjson::Writer<rapidjson::StringBuffer>& w) {
		w.StartObject();
		w.String("message", 7);
	    w.String(message.c_str(), static_cast<rapidjson::SizeType>(message.length()));
		w.EndObject();
	}
#endif
};

struct AsyncUpdatesReqWq {
	float httpVers;
	bool conn_clos;
	BaseSocket* sif;
	LibpqDataSourceImpl* sqli;
	std::vector<TeBkUmLpqQwAsyncWorld> vec;
};

class TeBkUmLpqQwAsyncRouter : public Router {
	static const std::string HELLO_WORLD;
	static const std::string WORLD;
	static const std::string WORLD_ONE_QUERY;
	static const std::string WORLD_ALL_QUERY;
	static const std::string FORTUNE_ALL_QUERY;
	static int g_seed;

	static TemplatePtr tmplFunc;

	static Ser m_ser;
	static Ser w_ser;
	static SerCont wcont_ser;

	static std::string& getUpdQuery(int count);
	void dbAsync(BaseSocket* sif);
	void queriesAsync(const char* q, int ql, BaseSocket* sif);
	void updatesAsync(const char* q, int ql, AsyncUpdatesReqWq* req);
	void updatesAsyncb(const char* q, int ql, AsyncUpdatesReqWq* req);
	void fortunes(BaseSocket* sif);

	void queriesMultiAsync(const char*, int, BaseSocket* sif);
	void updatesMulti(const char*, int, AsyncUpdatesReqWq*);

	static std::unordered_map<int, std::string> _qC;
	LibpqDataSourceImpl* sqli;
protected:
	virtual LibpqDataSourceImpl* getDb(int max = 0);
public:
	TeBkUmLpqQwAsyncRouter& operator=(const TeBkUmLpqQwAsyncRouter& a) {
		return *this;
	}
	TeBkUmLpqQwAsyncRouter(const TeBkUmLpqQwAsyncRouter& a) {
		sqli = NULL;
	}
	TeBkUmLpqQwAsyncRouter();
	virtual ~TeBkUmLpqQwAsyncRouter();
	/* These functions are here just for test purposes and serve no purpose START */
	static void temp() {
	}
	virtual void temp1() const {
	}
	std::map<std::string, std::string> l(std::map<std::string, std::string> a1, std::map<std::string, std::string> a2) {
		return std::map<std::string, std::string>();
	}
	/* END */
	bool route(HttpRequest* req, HttpResponse* res, BaseSocket* sif);
};

class TeBkUmLpqQwAsyncRouterPooled : public TeBkUmLpqQwAsyncRouter {
	LibpqDataSourceImpl* getDb(int max = 0);
	std::atomic<int> opt;
	bool inited;
	int maxconns;
	std::vector<LibpqDataSourceImpl*> pool;
public:
	TeBkUmLpqQwAsyncRouterPooled& operator=(const TeBkUmLpqQwAsyncRouterPooled& a) {
		return *this;
	}
	TeBkUmLpqQwAsyncRouterPooled(const TeBkUmLpqQwAsyncRouterPooled& a) {
		this->opt = 0;
		this->inited = false;
		this->maxconns = 7;
	}
	TeBkUmLpqQwAsyncRouterPooled();
	virtual ~TeBkUmLpqQwAsyncRouterPooled();
};

#endif /* WEB_t1_INCLUDE_TeBkUmLpqQwAsync_H_ */