/*
 * Copyright 2009-2011, Andrea Anzani. All rights reserved.
 * Copyright 2009-2011, Pier Luigi Fiorini. All rights reserved.
 * Copyright 2021-2022, Jaidyn Levesque. All rights reserved.
 * Distributed under the terms of the MIT License.
 */
#ifndef _SERVER_H
#define _SERVER_H
 
#include <Message.h>
#include <MessageFilter.h>
#include <Notification.h>

#include <libsupport/KeyMap.h>

#include "AppConstants.h"
#include "ChatCommand.h"
#include "Contact.h"
#include "Conversation.h"
#include "Notifier.h"
#include "ProtocolLooper.h"
#include "User.h"

class ChatProtocol;
class RosterItem;
class ProtocolLooper;


class Server: public BMessageFilter, public Notifier {
public:
							Server();
	 static	Server*			Get();
			void			Quit();
			void			LoginAll();
			void			Login(ProtocolLooper* looper);

	virtual	filter_result	Filter(BMessage* message, BHandler** target);
			filter_result	ImMessage(BMessage* msg);
			void			ImError(BMessage* msg);

			void			AddProtocolLooper(bigtime_t instanceId,
								ChatProtocol* cayap);
			void			RemoveProtocolLooper(bigtime_t instanceId);
			ProtocolLooper*	GetProtocolLooper(bigtime_t instanceId);

			AccountInstances GetAccounts();
			AccountInstances GetActiveAccounts();

			void			SendProtocolMessage(BMessage* msg);
			void			SendAllProtocolMessage(BMessage* msg);

			RosterMap		Contacts() const;
			Contact*		ContactById(BString id, int64 instance);
			void			AddContact(Contact* contact, int64 instance);

			UserMap			Users() const;
			User*			UserById(BString id, int64 instance);
			void			AddUser(User* user, int64 instance);

			ChatMap			Conversations() const;
			Conversation*	ConversationById(BString id, int64 instance);
			void			AddConversation(Conversation* chat, int64 instance);

			CommandMap		Commands(int64 instance);
			ChatCommand*	CommandById(BString id, int64 instance);

			BObjectList<BMessage> UserPopUpItems();

private:
	typedef KeyMap<BString, bool> BoolMap;
	typedef KeyMap<bigtime_t, ProtocolLooper*> ProtocolLoopers;

			ProtocolLooper*	_LooperFromMessage(BMessage* message);

			Contact*		_EnsureContact(BMessage* message);
			User*			_EnsureUser(BMessage* message);
			User*			_EnsureUser(BString id, ProtocolLooper* protoLooper);
			Contact*		_GetOwnContact(BMessage* message);
			Conversation*	_EnsureConversation(BMessage* message);

			void			_ProtocolNotification(ProtocolLooper* looper,
								BString title, BString desc,
								notification_type type=B_INFORMATION_NOTIFICATION);
			void			_SendNotification(BString title, BString content,
								BString id, BBitmap* icon=NULL,
								notification_type type=B_INFORMATION_NOTIFICATION);

			void			_ReplicantStatusNotify(UserStatus status);

			static Server* fInstance;

			ProtocolLoopers	fLoopers;
			AccountInstances fAccounts;
			BoolMap fAccountEnabled;
			bool fStarted;

			CommandMap fCommands;
			BObjectList<BMessage> fUserItems;
};

#endif	// _SERVER_H