#ifndef FEIQENGINE_H

#define FEIQENGINE_H

#include "content.h"

#include "feiqcommu.h"

#include <string>

#include <tuple>

#include <list>

#include <unordered_map>

#include "feiqmodel.h"

#include "msgqueuethread.h"

#include "ifeiqview.h"

#include "asynwait.h"

using namespace std;

class Post;

class ContentSender;

/**

* @brief The FeiqEngine class

* feiq以mvc模式架构，FeiqEngine是control部分，负责逻辑控制（以及具体协议来往）

*/

class FeiqEngine

{

public:

FeiqEngine();

public:

pair<bool, string> send(shared_ptr<Fellow> fellow, shared_ptr<Content> content);

pair<bool, string> sendFiles(shared_ptr<Fellow> fellow, list<shared_ptr<FileContent> > &files);

bool downloadFile(FileTask* task);

public:

pair<bool, string> start();

void stop();

void addToBroadcast(const string& ip);

void setMyHost(string host);

void setMyName(string name);

void setView(IFeiqView* view){mView = view;}

void sendImOnLine(const string& ip = "");

/**

* @brief enableIntervalDetect 当接入路由，被禁止发送广播包时，

* 启用间隔检测可每隔一段时间发送一次上线通知到指定网段，以实现检测。

*/

void enableIntervalDetect(int seconds);

public:

FeiqModel &getModel();

private://trigers

void onAnsEntry(shared_ptr<Post> post);

void onBrEntry(shared_ptr<Post> post);

void onBrExit(shared_ptr<Post> post);

void onMsg(shared_ptr<Post> post);

void onSendCheck(shared_ptr<Post> post);

void onReadCheck(shared_ptr<Post> post);

void onSendTimeo(IdType packetId, const string &ip, shared_ptr<Content> content);

void onReadMessage(shared_ptr<Post> post);

private:

void fileServerHandler(unique_ptr<TcpSocket> client, int packetNo, int fileId, int offset);

private:

shared_ptr<Fellow> addOrUpdateFellow(shared_ptr<Fellow> fellow);

void dispatchMsg(shared_ptr<ViewEvent> msg);

void broadcastToCurstomGroup(SendProtocol& protocol);

private:

FeiqCommu mCommu;

vector<unique_ptr<RecvProtocol>> mRecvProtocols;

FeiqModel mModel;

string mHost;

string mName;

MsgQueueThread<ViewEvent> mMsgThd;

IFeiqView* mView;

vector<string> mBroadcast;

bool mStarted=false;

AsynWait mAsyncWait;//异步等待对方回包

struct EnumClassHash

{

template <typename T>

std::size_t operator()(T t) const

{

return static_cast<std::size_t>(t);

}

};

//可以用unique_ptr，但是unique_ptr要求知道具体定义

unordered_map<ContentType, shared_ptr<ContentSender>, EnumClassHash> mContentSender;

};

#endif // FEIQENGINE_H