RetroShare/libresapi/src/api/PeersHandler.h

#pragma once

#include "ResourceRouter.h"
#include "StateTokenServer.h"
#include "ChatHandler.h"
#include <retroshare/rsnotify.h>
#include <util/rsthreads.h>

class RsPeers;
class RsMsgs;

namespace resource_api
{

class PeersHandler: public ResourceRouter, NotifyClient, Tickable, public UnreadMsgNotify
{
public:
    PeersHandler(StateTokenServer* sts, RsNotify* notify, RsPeers* peers, RsMsgs* msgs);
    virtual ~PeersHandler();

    // from NotifyClient
    // note: this may get called from foreign threads
    virtual void notifyListChange(int list, int type); // friends list change
    virtual void notifyPeerHasNewAvatar(std::string /*peer_id*/);

    // from Tickable
    virtual void tick();

    // from UnreadMsgNotify
    // ChatHandler calls this to tell us about unreadmsgs
    // this allows to merge unread msgs info with the peers list
    virtual void notifyUnreadMsgCountChanged(const RsPeerId& peer, uint32_t count);

private:
    void handleWildcard(Request& req, Response& resp);
    void handleExamineCert(Request& req, Response& resp);

	void handleGetStateString(Request& req, Response& resp);
	void handleSetStateString(Request& req, Response& resp);

	void handleGetCustomStateString(Request& req, Response& resp);
	void handleSetCustomStateString(Request& req, Response& resp);

	void handleGetPGPOptions(Request& req, Response& resp);
	void handleSetPGPOptions(Request& req, Response& resp);

    // a helper which ensures proper mutex locking
    StateToken getCurrentStateToken();

    StateTokenServer* mStateTokenServer;
    RsNotify* mNotify;
    RsPeers* mRsPeers;
    RsMsgs* mRsMsgs; // required for avatar data

    std::list<RsPeerId> mOnlinePeers;
	uint32_t status;
	std::string custom_state_string;

    RsMutex mMtx;
    StateToken mStateToken; // mutex protected
	StateToken mStringStateToken; // mutex protected
	StateToken mCustomStateToken; // mutex protected

    std::map<RsPeerId, uint32_t> mUnreadMsgsCounts;
};
} // namespace resource_api