server/relation
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
aozhiwei 2020-06-19 10:50:22 +08:00
parent a3c78fa43a
commit 06f5d92c96
7 changed files with 46 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
server/imserver/app.cc
View File

@ -397,6 +397,9 @@ void App::ProcessIMServerMsg(f8::MsgHdr& hdr)
case HID_IMListener:
ProcessNetMsg(handler, IMListener::Instance(), hdr);
break;
case HID_SyncHelper:
ProcessNetMsg(handler, SyncHelper::Instance(), hdr);
break;
default:
{
}

1
server/imserver/constant.h
View File

@ -31,6 +31,7 @@ enum NetHandler_e
HID_Player,
HID_GroupMgr,
HID_IMConnMgr,
HID_SyncHelper
};
const char* const PROJ_NAME_FMT = "friend_imserver";

6
server/imserver/handlermgr.cc
View File

@ -11,6 +11,7 @@
#include "playermgr.h"
#include "groupmgr.h"
#include "IMConnMgr.h"
#include "synchelper.h"
#include "ss_proto.pb.h"
#include "cs_proto.pb.h"
@ -37,6 +38,9 @@ void HandlerMgr::RegisterNetMsgHandlers()
{
RegisterNetMsgHandler(&immsghandler, &IMListener::_SS_Ping);
RegisterNetMsgHandler(&immsghandler, &SyncHelper::_SS_IM_FriendAgreeResponse);
RegisterNetMsgHandler(&immsghandler, &SyncHelper::_SS_IM_FriendDeleteResponse);
RegisterNetMsgHandler(&mscmsghandler, &PlayerMgr::_SS_MS_PushUserList);
RegisterNetMsgHandler(&mscmsghandler, &GroupMgr::_SS_MS_LoadGroup);
RegisterNetMsgHandler(&mscmsghandler, &GroupMgr::_SS_MS_ForwardGroupCMMsg);
@ -47,6 +51,8 @@ void HandlerMgr::RegisterNetMsgHandlers()
RegisterNetMsgHandler(&imcmsghandler, &PlayerMgr::_SS_IM_SendChatMsg);
RegisterNetMsgHandler(&imcmsghandler, &PlayerMgr::_SS_IM_SendCustomMsg);
RegisterNetMsgHandler(&imcmsghandler, &PlayerMgr::_SS_IM_UpdateUserInfo);
RegisterNetMsgHandler(&imcmsghandler, &PlayerMgr::_SS_IM_FriendAgreeRequest);
RegisterNetMsgHandler(&imcmsghandler, &PlayerMgr::_SS_IM_FriendDeleteRequest);
RegisterNetMsgHandler(&wsmsghandler, &WSListener::_SS_Ping);

10
server/imserver/playermgr.cc
View File

@ -56,6 +56,16 @@ void PlayerMgr::_SS_IM_SendCustomMsg(f8::MsgHdr& hdr, const ss::SS_IM_SendCustom
}
}
void PlayerMgr::_SS_IM_FriendAgreeRequest(f8::MsgHdr& hdr, const ss::SS_IM_FriendAgreeRequest& msg)
{
}
void PlayerMgr::_SS_IM_FriendDeleteRequest(f8::MsgHdr& hdr, const ss::SS_IM_FriendDeleteRequest& msg)
{
}
void PlayerMgr::_SS_IM_UpdateUserInfo(f8::MsgHdr& hdr, const ss::SS_IM_UpdateUserInfo& msg)
{
auto itr = watch_players_.find(msg.user_info().base_data().account_id());

4
server/imserver/playermgr.h
View File

@ -12,6 +12,8 @@ namespace ss
class SS_IM_SendChatMsg;
class SS_IM_SendCustomMsg;
class SS_IM_UpdateUserInfo;
class SS_IM_FriendAgreeRequest;
class SS_IM_FriendDeleteRequest;
}
class Player;
@ -32,6 +34,8 @@ class PlayerMgr : public a8::Singleton<PlayerMgr>
void _SS_MS_PushUserList(f8::MsgHdr& hdr, const ss::SS_MS_PushUserList& msg);
void _SS_IM_SendChatMsg(f8::MsgHdr& hdr, const ss::SS_IM_SendChatMsg& msg);
void _SS_IM_SendCustomMsg(f8::MsgHdr& hdr, const ss::SS_IM_SendCustomMsg& msg);
void _SS_IM_FriendAgreeRequest(f8::MsgHdr& hdr, const ss::SS_IM_FriendAgreeRequest& msg);
void _SS_IM_FriendDeleteRequest(f8::MsgHdr& hdr, const ss::SS_IM_FriendDeleteRequest& msg);
void _SS_IM_UpdateUserInfo(f8::MsgHdr& hdr, const ss::SS_IM_UpdateUserInfo& msg);

10
server/imserver/synchelper.cc
View File

@ -69,3 +69,13 @@ void SyncHelper::BroadcastIMConnMsg(int msgid, ::google::protobuf::Message& msg)
free(buff);
}
}
void SyncHelper::_SS_IM_FriendAgreeResponse(f8::MsgHdr& hdr, const ss::SS_IM_FriendAgreeResponse& msg)
{
}
void SyncHelper::_SS_IM_FriendDeleteResponse(f8::MsgHdr& hdr, const ss::SS_IM_FriendDeleteResponse& msg)
{
}

12
server/imserver/synchelper.h
View File

@ -1,8 +1,17 @@
#pragma once
namespace ss
{
class SS_IM_FriendAgreeResponse;
class SS_IM_FriendDeleteResponse;
}
class Player;
class SyncHelper : public a8::Singleton<SyncHelper>
{
public:
enum { HID = HID_SyncHelper };
private:
SyncHelper() {};
friend class a8::Singleton<SyncHelper>;
@ -15,6 +24,9 @@ class SyncHelper : public a8::Singleton<SyncHelper>
void SyncDeleteFriend(Player* hum, const std::string& target_id);
void SyncUpdateFriend(Player* hum, const std::string& target_id);
void _SS_IM_FriendAgreeResponse(f8::MsgHdr& hdr, const ss::SS_IM_FriendAgreeResponse& msg);
void _SS_IM_FriendDeleteResponse(f8::MsgHdr& hdr, const ss::SS_IM_FriendDeleteResponse& msg);
private:
template <typename T>
void BroadcastIMConnMsg(T& msg)