/*
	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.
*/
/*
 * TeBkUmLpq.h
 *
 *  Created on: 03-Feb-2020
 *      Author: sumeetc
 */

#ifndef WEB_TE_BENCHMARK_UM_INCLUDE_TeBkUmLpq_H_
#define WEB_TE_BENCHMARK_UM_INCLUDE_TeBkUmLpq_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 <stdlib.h>
#include "CacheManager.h"
#include "HttpRequest.h"
#include "HttpResponse.h"
#include "JSONSerialize.h"
#include "string"
#include "yuarel.h"
#include "Router.h"

typedef void (*TeBkUmLpqTemplatePtr) (Context*, std::string&);

class TeBkUmLpqWorld {
	int id;
	int randomNumber;
public:
	TeBkUmLpqWorld();
	virtual ~TeBkUmLpqWorld();
	int getId() const;
	void setId(int id);
	int getRandomNumber() const;
	void setRandomNumber(int randomNumber);
};

struct UpdQrData {
	std::vector<TeBkUmLpqWorld>* wlist;
	std::stringstream* ss;
	bool status;
	int queryCount;
};

class TeBkUmLpqFortune {
	int id;
	std::string message;
public:
	TeBkUmLpqFortune();
	virtual ~TeBkUmLpqFortune();
	int getId() const;
	void setId(int id);
	const std::string& getMessage() const;
	void setMessage(const std::string& message);
	bool operator < (const TeBkUmLpqFortune& other) const;
};

class TeBkUmLpqMessage {
	std::string message;
public:
	virtual ~TeBkUmLpqMessage();
	const std::string& getMessage() const;
	void setMessage(const std::string& message);
};

class TeBkUmLpqRouter : public Router {
	static const std::string HELLO_WORLD;
	static std::string WORLD;
	static std::string WORLD_ONE_QUERY;
	static std::string WORLD_ALL_QUERY;
	static std::string FORTUNE_ALL_QUERY;

	static std::string APP_NAME;
	static std::string TPE_FN_NAME;

	static bool strToNum(const char* str, int len, int& ret);

	void db(TeBkUmLpqWorld&);
	void queries(const char*, int, std::vector<TeBkUmLpqWorld>&);
	void queriesMulti(const char*, int, std::vector<TeBkUmLpqWorld>&);
	static void dbUtil(void* ctx, int, int, char *);
	static void queriesMultiUtil(void* ctx, int, int, char *, int);

	void updates(const char*, int, std::vector<TeBkUmLpqWorld>&);
	static void updatesUtil(void* ctx, int, int, char *);
	void updatesMulti(const char*, int, std::vector<TeBkUmLpqWorld>&);
	static void updatesMultiUtil(void* ctx, int, int, char *, int);
	static void updatesMultiUtilCh(void* ctx, bool status, const std::string& query, int counter);
	
	void cachedWorlds(const char*, int, std::vector<TeBkUmLpqWorld>&);
	static void updateCacheUtil(void* ctx, int rn, std::vector<LibpqRes>& data);

	void getContext(HttpRequest* request, Context* context);
	static void getContextUtil(void* ctx, int, int, char *, int);

	std::map<int, std::string> _qC;
	LibpqDataSourceImpl* sqli;
	LibpqDataSourceImpl* getDb();

	std::string& getUpdQuery(int count);
public:
	TeBkUmLpqRouter();
	virtual ~TeBkUmLpqRouter();
	void updateCache();
	bool route(HttpRequest* req, HttpResponse* res, void* dlib, void* ddlib, SocketInterface* sif);
};

#endif /* WEB_TE_BENCHMARK_UM_INCLUDE_TeBkUmLpq_H_ */