diff options
author | Shauren <shauren.trinity@gmail.com> | 2020-05-09 01:09:07 +0200 |
---|---|---|
committer | Shauren <shauren.trinity@gmail.com> | 2020-05-09 01:09:07 +0200 |
commit | 13053538f24a5cc86bd1c465d763a4ebe993ea24 (patch) | |
tree | 4016083c833b43454ff01d80ff057345e68079f5 /src | |
parent | 4c85198ed6135b42f9dfe0ad16901f7d741b64c6 (diff) |
Core/Battlenet: Add club services
Diffstat (limited to 'src')
-rw-r--r-- | src/server/bnetserver/Services/ServiceDispatcher.cpp | 1 | ||||
-rw-r--r-- | src/server/bnetserver/Services/ServiceDispatcher.h | 2 | ||||
-rw-r--r-- | src/server/game/Services/WorldserverService.h | 2 | ||||
-rw-r--r-- | src/server/game/Services/WorldserverServiceDispatcher.cpp | 1 | ||||
-rw-r--r-- | src/server/game/Services/WorldserverServiceDispatcher.h | 2 | ||||
-rw-r--r-- | src/server/proto/Client/club_listener.pb.cc | 294 | ||||
-rw-r--r-- | src/server/proto/Client/club_listener.pb.h | 115 | ||||
-rw-r--r-- | src/server/proto/Client/club_listener.proto | 123 | ||||
-rw-r--r-- | src/server/proto/Client/club_service.pb.cc | 2012 | ||||
-rw-r--r-- | src/server/proto/Client/club_service.pb.h | 150 | ||||
-rw-r--r-- | src/server/proto/Client/club_service.proto | 293 |
11 files changed, 2995 insertions, 0 deletions
diff --git a/src/server/bnetserver/Services/ServiceDispatcher.cpp b/src/server/bnetserver/Services/ServiceDispatcher.cpp index e4ddf306d7a..7408c2350fa 100644 --- a/src/server/bnetserver/Services/ServiceDispatcher.cpp +++ b/src/server/bnetserver/Services/ServiceDispatcher.cpp @@ -22,6 +22,7 @@ Battlenet::ServiceDispatcher::ServiceDispatcher() AddService<Services::Account>(); AddService<Services::Authentication>(); AddService<Service<club::v1::membership::ClubMembershipService>>(); + AddService<Service<club::v1::ClubService>>(); AddService<Services::Connection>(); AddService<Service<friends::v1::FriendsService>>(); AddService<Services::GameUtilities>(); diff --git a/src/server/bnetserver/Services/ServiceDispatcher.h b/src/server/bnetserver/Services/ServiceDispatcher.h index eaf9737731e..3c0c426fa73 100644 --- a/src/server/bnetserver/Services/ServiceDispatcher.h +++ b/src/server/bnetserver/Services/ServiceDispatcher.h @@ -24,8 +24,10 @@ #include "AccountService.h" #include "AuthenticationService.h" #include "challenge_service.pb.h" +#include "club_listener.pb.h" #include "club_membership_listener.pb.h" #include "club_membership_service.pb.h" +#include "club_service.pb.h" #include "ConnectionService.h" #include "friends_service.pb.h" #include "GameUtilitiesService.h" diff --git a/src/server/game/Services/WorldserverService.h b/src/server/game/Services/WorldserverService.h index 0eaaa91524e..35c252f9b16 100644 --- a/src/server/game/Services/WorldserverService.h +++ b/src/server/game/Services/WorldserverService.h @@ -22,8 +22,10 @@ #include "account_service.pb.h" #include "authentication_service.pb.h" #include "challenge_service.pb.h" +#include "club_listener.pb.h" #include "club_membership_listener.pb.h" #include "club_membership_service.pb.h" +#include "club_service.pb.h" #include "connection_service.pb.h" #include "friends_service.pb.h" #include "game_utilities_service.pb.h" diff --git a/src/server/game/Services/WorldserverServiceDispatcher.cpp b/src/server/game/Services/WorldserverServiceDispatcher.cpp index 2826b65bcab..4946f92565b 100644 --- a/src/server/game/Services/WorldserverServiceDispatcher.cpp +++ b/src/server/game/Services/WorldserverServiceDispatcher.cpp @@ -23,6 +23,7 @@ Battlenet::WorldserverServiceDispatcher::WorldserverServiceDispatcher() AddService<WorldserverService<account::v1::AccountService>>(); AddService<WorldserverService<authentication::v1::AuthenticationService>>(); AddService<WorldserverService<club::v1::membership::ClubMembershipService>>(); + AddService<WorldserverService<club::v1::ClubService>>(); AddService<WorldserverService<connection::v1::ConnectionService>>(); AddService<WorldserverService<friends::v1::FriendsService>>(); AddService<GameUtilitiesService>(); diff --git a/src/server/game/Services/WorldserverServiceDispatcher.h b/src/server/game/Services/WorldserverServiceDispatcher.h index 3b305aae5e0..878c1fbc2c0 100644 --- a/src/server/game/Services/WorldserverServiceDispatcher.h +++ b/src/server/game/Services/WorldserverServiceDispatcher.h @@ -25,8 +25,10 @@ #include "account_service.pb.h" #include "authentication_service.pb.h" #include "challenge_service.pb.h" +#include "club_listener.pb.h" #include "club_membership_listener.pb.h" #include "club_membership_service.pb.h" +#include "club_service.pb.h" #include "connection_service.pb.h" #include "friends_service.pb.h" #include "game_utilities_service.pb.h" diff --git a/src/server/proto/Client/club_listener.pb.cc b/src/server/proto/Client/club_listener.pb.cc new file mode 100644 index 00000000000..be1c9bf73ba --- /dev/null +++ b/src/server/proto/Client/club_listener.pb.cc @@ -0,0 +1,294 @@ +// Generated by the protocol buffer compiler. DO NOT EDIT! +// source: club_listener.proto + +#define INTERNAL_SUPPRESS_PROTOBUF_FIELD_DEPRECATION +#include "club_listener.pb.h" + +#include <algorithm> +#include <utility> + +#include <google/protobuf/stubs/common.h> +#include <google/protobuf/stubs/once.h> +#include <google/protobuf/io/coded_stream.h> +#include <google/protobuf/wire_format_lite_inl.h> +#include <google/protobuf/descriptor.h> +#include <google/protobuf/generated_message_reflection.h> +#include <google/protobuf/reflection_ops.h> +#include <google/protobuf/wire_format.h> +#include "Log.h" +#include "Errors.h" +#include "BattlenetRpcErrorCodes.h" +// @@protoc_insertion_point(includes) + +namespace bgs { +namespace protocol { +namespace club { +namespace v1 { + +namespace { + +const ::google::protobuf::ServiceDescriptor* ClubListener_descriptor_ = NULL; + +} // namespace + + +void protobuf_AssignDesc_club_5flistener_2eproto() { + protobuf_AddDesc_club_5flistener_2eproto(); + const ::google::protobuf::FileDescriptor* file = + ::google::protobuf::DescriptorPool::generated_pool()->FindFileByName( + "club_listener.proto"); + GOOGLE_CHECK(file != NULL); + ClubListener_descriptor_ = file->service(0); +} + +namespace { + +GOOGLE_PROTOBUF_DECLARE_ONCE(protobuf_AssignDescriptors_once_); +inline void protobuf_AssignDescriptorsOnce() { + ::google::protobuf::GoogleOnceInit(&protobuf_AssignDescriptors_once_, + &protobuf_AssignDesc_club_5flistener_2eproto); +} + +void protobuf_RegisterTypes(const ::std::string&) { + protobuf_AssignDescriptorsOnce(); +} + +} // namespace + +void protobuf_ShutdownFile_club_5flistener_2eproto() { +} + +void protobuf_AddDesc_club_5flistener_2eproto() { + static bool already_here = false; + if (already_here) return; + already_here = true; + GOOGLE_PROTOBUF_VERIFY_VERSION; + + ::bgs::protocol::club::v1::protobuf_AddDesc_club_5fnotification_2eproto(); + ::google::protobuf::DescriptorPool::InternalAddGeneratedFile( + "\n\023club_listener.proto\022\024bgs.protocol.club" + ".v1\032\027club_notification.proto2\262\022\n\014ClubLis" + "tener\022]\n\013OnSubscribe\022+.bgs.protocol.club" + ".v1.SubscribeNotification\032\031.bgs.protocol" + ".NO_RESPONSE\"\006\202\371+\002\010\001\022a\n\rOnUnsubscribe\022-." + "bgs.protocol.club.v1.UnsubscribeNotifica" + "tion\032\031.bgs.protocol.NO_RESPONSE\"\006\202\371+\002\010\002\022" + "c\n\016OnStateChanged\022..bgs.protocol.club.v1" + ".StateChangedNotification\032\031.bgs.protocol" + ".NO_RESPONSE\"\006\202\371+\002\010\003\022i\n\021OnSettingsChange" + "d\0221.bgs.protocol.club.v1.SettingsChanged" + "Notification\032\031.bgs.protocol.NO_RESPONSE\"" + "\006\202\371+\002\010\004\022a\n\rOnMemberAdded\022-.bgs.protocol." + "club.v1.MemberAddedNotification\032\031.bgs.pr" + "otocol.NO_RESPONSE\"\006\202\371+\002\010\036\022e\n\017OnMemberRe" + "moved\022/.bgs.protocol.club.v1.MemberRemov" + "edNotification\032\031.bgs.protocol.NO_RESPONS" + "E\"\006\202\371+\002\010\037\022o\n\024OnMemberStateChanged\0224.bgs." + "protocol.club.v1.MemberStateChangedNotif" + "ication\032\031.bgs.protocol.NO_RESPONSE\"\006\202\371+\002" + "\010 \022w\n\030OnSubscriberStateChanged\0228.bgs.pro" + "tocol.club.v1.SubscriberStateChangedNoti" + "fication\032\031.bgs.protocol.NO_RESPONSE\"\006\202\371+" + "\002\010!\022m\n\023OnMemberRoleChanged\0223.bgs.protoco" + "l.club.v1.MemberRoleChangedNotification\032" + "\031.bgs.protocol.NO_RESPONSE\"\006\202\371+\002\010\"\022i\n\021On" + "InvitationAdded\0221.bgs.protocol.club.v1.I" + "nvitationAddedNotification\032\031.bgs.protoco" + "l.NO_RESPONSE\"\006\202\371+\002\0102\022m\n\023OnInvitationRem" + "oved\0223.bgs.protocol.club.v1.InvitationRe" + "movedNotification\032\031.bgs.protocol.NO_RESP" + "ONSE\"\006\202\371+\002\0103\022i\n\021OnSuggestionAdded\0221.bgs." + "protocol.club.v1.SuggestionAddedNotifica" + "tion\032\031.bgs.protocol.NO_RESPONSE\"\006\202\371+\002\010F\022" + "m\n\023OnSuggestionRemoved\0223.bgs.protocol.cl" + "ub.v1.SuggestionRemovedNotification\032\031.bg" + "s.protocol.NO_RESPONSE\"\006\202\371+\002\010G\022a\n\rOnStre" + "amAdded\022-.bgs.protocol.club.v1.StreamAdd" + "edNotification\032\031.bgs.protocol.NO_RESPONS" + "E\"\006\202\371+\002\010d\022e\n\017OnStreamRemoved\022/.bgs.proto" + "col.club.v1.StreamRemovedNotification\032\031." + "bgs.protocol.NO_RESPONSE\"\006\202\371+\002\010e\022o\n\024OnSt" + "reamStateChanged\0224.bgs.protocol.club.v1." + "StreamStateChangedNotification\032\031.bgs.pro" + "tocol.NO_RESPONSE\"\006\202\371+\002\010f\022p\n\024OnStreamMes" + "sageAdded\0224.bgs.protocol.club.v1.StreamM" + "essageAddedNotification\032\031.bgs.protocol.N" + "O_RESPONSE\"\007\202\371+\003\010\226\001\022t\n\026OnStreamMessageUp" + "dated\0226.bgs.protocol.club.v1.StreamMessa" + "geUpdatedNotification\032\031.bgs.protocol.NO_" + "RESPONSE\"\007\202\371+\003\010\230\001\022v\n\027OnStreamTypingIndic" + "ator\0227.bgs.protocol.club.v1.StreamTyping" + "IndicatorNotification\032\031.bgs.protocol.NO_" + "RESPONSE\"\007\202\371+\003\010\231\001\022v\n\027OnStreamUnreadIndic" + "ator\0227.bgs.protocol.club.v1.StreamUnread" + "IndicatorNotification\032\031.bgs.protocol.NO_" + "RESPONSE\"\007\202\371+\003\010\232\001\022v\n\027OnStreamAdvanceView" + "Time\0227.bgs.protocol.club.v1.StreamAdvanc" + "eViewTimeNotification\032\031.bgs.protocol.NO_" + "RESPONSE\"\007\202\371+\003\010\233\001\032.\202\371+$\n\"bnet.protocol.c" + "lub.v1.ClubListener\212\371+\002\010\001B\005H\001\200\001\000", 2432); + ::google::protobuf::MessageFactory::InternalRegisterGeneratedFile( + "club_listener.proto", &protobuf_RegisterTypes); + ::google::protobuf::internal::OnShutdown(&protobuf_ShutdownFile_club_5flistener_2eproto); +} + +// Force AddDescriptors() to be called at static initialization time. +struct StaticDescriptorInitializer_club_5flistener_2eproto { + StaticDescriptorInitializer_club_5flistener_2eproto() { + protobuf_AddDesc_club_5flistener_2eproto(); + } +} static_descriptor_initializer_club_5flistener_2eproto_; + +// =================================================================== + +ClubListener::ClubListener(bool use_original_hash) : service_hash_(use_original_hash ? OriginalHash::value : NameHash::value) { +} + +ClubListener::~ClubListener() { +} + +google::protobuf::ServiceDescriptor const* ClubListener::descriptor() { + protobuf_AssignDescriptorsOnce(); + return ClubListener_descriptor_; +} + +void ClubListener::OnSubscribe(::bgs::protocol::club::v1::SubscribeNotification const* request, bool client /*= false*/, bool server /*= false*/) { + TC_LOG_DEBUG("service.protobuf", "%s Server called client method ClubListener.OnSubscribe(bgs.protocol.club.v1.SubscribeNotification{ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + SendRequest(service_hash_, 1 | (client ? 0x40000000 : 0) | (server ? 0x80000000 : 0), request); +} + +void ClubListener::OnUnsubscribe(::bgs::protocol::club::v1::UnsubscribeNotification const* request, bool client /*= false*/, bool server /*= false*/) { + TC_LOG_DEBUG("service.protobuf", "%s Server called client method ClubListener.OnUnsubscribe(bgs.protocol.club.v1.UnsubscribeNotification{ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + SendRequest(service_hash_, 2 | (client ? 0x40000000 : 0) | (server ? 0x80000000 : 0), request); +} + +void ClubListener::OnStateChanged(::bgs::protocol::club::v1::StateChangedNotification const* request, bool client /*= false*/, bool server /*= false*/) { + TC_LOG_DEBUG("service.protobuf", "%s Server called client method ClubListener.OnStateChanged(bgs.protocol.club.v1.StateChangedNotification{ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + SendRequest(service_hash_, 3 | (client ? 0x40000000 : 0) | (server ? 0x80000000 : 0), request); +} + +void ClubListener::OnSettingsChanged(::bgs::protocol::club::v1::SettingsChangedNotification const* request, bool client /*= false*/, bool server /*= false*/) { + TC_LOG_DEBUG("service.protobuf", "%s Server called client method ClubListener.OnSettingsChanged(bgs.protocol.club.v1.SettingsChangedNotification{ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + SendRequest(service_hash_, 4 | (client ? 0x40000000 : 0) | (server ? 0x80000000 : 0), request); +} + +void ClubListener::OnMemberAdded(::bgs::protocol::club::v1::MemberAddedNotification const* request, bool client /*= false*/, bool server /*= false*/) { + TC_LOG_DEBUG("service.protobuf", "%s Server called client method ClubListener.OnMemberAdded(bgs.protocol.club.v1.MemberAddedNotification{ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + SendRequest(service_hash_, 30 | (client ? 0x40000000 : 0) | (server ? 0x80000000 : 0), request); +} + +void ClubListener::OnMemberRemoved(::bgs::protocol::club::v1::MemberRemovedNotification const* request, bool client /*= false*/, bool server /*= false*/) { + TC_LOG_DEBUG("service.protobuf", "%s Server called client method ClubListener.OnMemberRemoved(bgs.protocol.club.v1.MemberRemovedNotification{ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + SendRequest(service_hash_, 31 | (client ? 0x40000000 : 0) | (server ? 0x80000000 : 0), request); +} + +void ClubListener::OnMemberStateChanged(::bgs::protocol::club::v1::MemberStateChangedNotification const* request, bool client /*= false*/, bool server /*= false*/) { + TC_LOG_DEBUG("service.protobuf", "%s Server called client method ClubListener.OnMemberStateChanged(bgs.protocol.club.v1.MemberStateChangedNotification{ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + SendRequest(service_hash_, 32 | (client ? 0x40000000 : 0) | (server ? 0x80000000 : 0), request); +} + +void ClubListener::OnSubscriberStateChanged(::bgs::protocol::club::v1::SubscriberStateChangedNotification const* request, bool client /*= false*/, bool server /*= false*/) { + TC_LOG_DEBUG("service.protobuf", "%s Server called client method ClubListener.OnSubscriberStateChanged(bgs.protocol.club.v1.SubscriberStateChangedNotification{ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + SendRequest(service_hash_, 33 | (client ? 0x40000000 : 0) | (server ? 0x80000000 : 0), request); +} + +void ClubListener::OnMemberRoleChanged(::bgs::protocol::club::v1::MemberRoleChangedNotification const* request, bool client /*= false*/, bool server /*= false*/) { + TC_LOG_DEBUG("service.protobuf", "%s Server called client method ClubListener.OnMemberRoleChanged(bgs.protocol.club.v1.MemberRoleChangedNotification{ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + SendRequest(service_hash_, 34 | (client ? 0x40000000 : 0) | (server ? 0x80000000 : 0), request); +} + +void ClubListener::OnInvitationAdded(::bgs::protocol::club::v1::InvitationAddedNotification const* request, bool client /*= false*/, bool server /*= false*/) { + TC_LOG_DEBUG("service.protobuf", "%s Server called client method ClubListener.OnInvitationAdded(bgs.protocol.club.v1.InvitationAddedNotification{ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + SendRequest(service_hash_, 50 | (client ? 0x40000000 : 0) | (server ? 0x80000000 : 0), request); +} + +void ClubListener::OnInvitationRemoved(::bgs::protocol::club::v1::InvitationRemovedNotification const* request, bool client /*= false*/, bool server /*= false*/) { + TC_LOG_DEBUG("service.protobuf", "%s Server called client method ClubListener.OnInvitationRemoved(bgs.protocol.club.v1.InvitationRemovedNotification{ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + SendRequest(service_hash_, 51 | (client ? 0x40000000 : 0) | (server ? 0x80000000 : 0), request); +} + +void ClubListener::OnSuggestionAdded(::bgs::protocol::club::v1::SuggestionAddedNotification const* request, bool client /*= false*/, bool server /*= false*/) { + TC_LOG_DEBUG("service.protobuf", "%s Server called client method ClubListener.OnSuggestionAdded(bgs.protocol.club.v1.SuggestionAddedNotification{ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + SendRequest(service_hash_, 70 | (client ? 0x40000000 : 0) | (server ? 0x80000000 : 0), request); +} + +void ClubListener::OnSuggestionRemoved(::bgs::protocol::club::v1::SuggestionRemovedNotification const* request, bool client /*= false*/, bool server /*= false*/) { + TC_LOG_DEBUG("service.protobuf", "%s Server called client method ClubListener.OnSuggestionRemoved(bgs.protocol.club.v1.SuggestionRemovedNotification{ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + SendRequest(service_hash_, 71 | (client ? 0x40000000 : 0) | (server ? 0x80000000 : 0), request); +} + +void ClubListener::OnStreamAdded(::bgs::protocol::club::v1::StreamAddedNotification const* request, bool client /*= false*/, bool server /*= false*/) { + TC_LOG_DEBUG("service.protobuf", "%s Server called client method ClubListener.OnStreamAdded(bgs.protocol.club.v1.StreamAddedNotification{ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + SendRequest(service_hash_, 100 | (client ? 0x40000000 : 0) | (server ? 0x80000000 : 0), request); +} + +void ClubListener::OnStreamRemoved(::bgs::protocol::club::v1::StreamRemovedNotification const* request, bool client /*= false*/, bool server /*= false*/) { + TC_LOG_DEBUG("service.protobuf", "%s Server called client method ClubListener.OnStreamRemoved(bgs.protocol.club.v1.StreamRemovedNotification{ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + SendRequest(service_hash_, 101 | (client ? 0x40000000 : 0) | (server ? 0x80000000 : 0), request); +} + +void ClubListener::OnStreamStateChanged(::bgs::protocol::club::v1::StreamStateChangedNotification const* request, bool client /*= false*/, bool server /*= false*/) { + TC_LOG_DEBUG("service.protobuf", "%s Server called client method ClubListener.OnStreamStateChanged(bgs.protocol.club.v1.StreamStateChangedNotification{ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + SendRequest(service_hash_, 102 | (client ? 0x40000000 : 0) | (server ? 0x80000000 : 0), request); +} + +void ClubListener::OnStreamMessageAdded(::bgs::protocol::club::v1::StreamMessageAddedNotification const* request, bool client /*= false*/, bool server /*= false*/) { + TC_LOG_DEBUG("service.protobuf", "%s Server called client method ClubListener.OnStreamMessageAdded(bgs.protocol.club.v1.StreamMessageAddedNotification{ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + SendRequest(service_hash_, 150 | (client ? 0x40000000 : 0) | (server ? 0x80000000 : 0), request); +} + +void ClubListener::OnStreamMessageUpdated(::bgs::protocol::club::v1::StreamMessageUpdatedNotification const* request, bool client /*= false*/, bool server /*= false*/) { + TC_LOG_DEBUG("service.protobuf", "%s Server called client method ClubListener.OnStreamMessageUpdated(bgs.protocol.club.v1.StreamMessageUpdatedNotification{ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + SendRequest(service_hash_, 152 | (client ? 0x40000000 : 0) | (server ? 0x80000000 : 0), request); +} + +void ClubListener::OnStreamTypingIndicator(::bgs::protocol::club::v1::StreamTypingIndicatorNotification const* request, bool client /*= false*/, bool server /*= false*/) { + TC_LOG_DEBUG("service.protobuf", "%s Server called client method ClubListener.OnStreamTypingIndicator(bgs.protocol.club.v1.StreamTypingIndicatorNotification{ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + SendRequest(service_hash_, 153 | (client ? 0x40000000 : 0) | (server ? 0x80000000 : 0), request); +} + +void ClubListener::OnStreamUnreadIndicator(::bgs::protocol::club::v1::StreamUnreadIndicatorNotification const* request, bool client /*= false*/, bool server /*= false*/) { + TC_LOG_DEBUG("service.protobuf", "%s Server called client method ClubListener.OnStreamUnreadIndicator(bgs.protocol.club.v1.StreamUnreadIndicatorNotification{ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + SendRequest(service_hash_, 154 | (client ? 0x40000000 : 0) | (server ? 0x80000000 : 0), request); +} + +void ClubListener::OnStreamAdvanceViewTime(::bgs::protocol::club::v1::StreamAdvanceViewTimeNotification const* request, bool client /*= false*/, bool server /*= false*/) { + TC_LOG_DEBUG("service.protobuf", "%s Server called client method ClubListener.OnStreamAdvanceViewTime(bgs.protocol.club.v1.StreamAdvanceViewTimeNotification{ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + SendRequest(service_hash_, 155 | (client ? 0x40000000 : 0) | (server ? 0x80000000 : 0), request); +} + +void ClubListener::CallServerMethod(uint32 token, uint32 methodId, MessageBuffer /*buffer*/) { + TC_LOG_ERROR("service.protobuf", "%s Server tried to call server method %u", + GetCallerInfo().c_str(), methodId); +} + + +// @@protoc_insertion_point(namespace_scope) + +} // namespace v1 +} // namespace club +} // namespace protocol +} // namespace bgs + +// @@protoc_insertion_point(global_scope) diff --git a/src/server/proto/Client/club_listener.pb.h b/src/server/proto/Client/club_listener.pb.h new file mode 100644 index 00000000000..7e76098cd65 --- /dev/null +++ b/src/server/proto/Client/club_listener.pb.h @@ -0,0 +1,115 @@ +// Generated by the protocol buffer compiler. DO NOT EDIT! +// source: club_listener.proto + +#ifndef PROTOBUF_club_5flistener_2eproto__INCLUDED +#define PROTOBUF_club_5flistener_2eproto__INCLUDED + +#include <string> + +#include <google/protobuf/stubs/common.h> + +#if GOOGLE_PROTOBUF_VERSION < 2006000 +#error This file was generated by a newer version of protoc which is +#error incompatible with your Protocol Buffer headers. Please update +#error your headers. +#endif +#if 2006001 < GOOGLE_PROTOBUF_MIN_PROTOC_VERSION +#error This file was generated by an older version of protoc which is +#error incompatible with your Protocol Buffer headers. Please +#error regenerate this file with a newer version of protoc. +#endif + +#include <google/protobuf/generated_message_util.h> +#include <google/protobuf/repeated_field.h> +#include <google/protobuf/extension_set.h> +#include "club_notification.pb.h" +#include "ServiceBase.h" +#include "MessageBuffer.h" +#include <functional> +#include <type_traits> +// @@protoc_insertion_point(includes) + +namespace bgs { +namespace protocol { +namespace club { +namespace v1 { + +// Internal implementation detail -- do not call these. +void TC_PROTO_API protobuf_AddDesc_club_5flistener_2eproto(); +void protobuf_AssignDesc_club_5flistener_2eproto(); +void protobuf_ShutdownFile_club_5flistener_2eproto(); + + +// =================================================================== + + +// =================================================================== + +class TC_PROTO_API ClubListener : public ServiceBase +{ + public: + + explicit ClubListener(bool use_original_hash); + virtual ~ClubListener(); + + typedef std::integral_constant<uint32, 0x80909D73u> OriginalHash; + typedef std::integral_constant<uint32, 0x40BE3344u> NameHash; + + static google::protobuf::ServiceDescriptor const* descriptor(); + + // client methods -------------------------------------------------- + void OnSubscribe(::bgs::protocol::club::v1::SubscribeNotification const* request, bool client = false, bool server = false); + void OnUnsubscribe(::bgs::protocol::club::v1::UnsubscribeNotification const* request, bool client = false, bool server = false); + void OnStateChanged(::bgs::protocol::club::v1::StateChangedNotification const* request, bool client = false, bool server = false); + void OnSettingsChanged(::bgs::protocol::club::v1::SettingsChangedNotification const* request, bool client = false, bool server = false); + void OnMemberAdded(::bgs::protocol::club::v1::MemberAddedNotification const* request, bool client = false, bool server = false); + void OnMemberRemoved(::bgs::protocol::club::v1::MemberRemovedNotification const* request, bool client = false, bool server = false); + void OnMemberStateChanged(::bgs::protocol::club::v1::MemberStateChangedNotification const* request, bool client = false, bool server = false); + void OnSubscriberStateChanged(::bgs::protocol::club::v1::SubscriberStateChangedNotification const* request, bool client = false, bool server = false); + void OnMemberRoleChanged(::bgs::protocol::club::v1::MemberRoleChangedNotification const* request, bool client = false, bool server = false); + void OnInvitationAdded(::bgs::protocol::club::v1::InvitationAddedNotification const* request, bool client = false, bool server = false); + void OnInvitationRemoved(::bgs::protocol::club::v1::InvitationRemovedNotification const* request, bool client = false, bool server = false); + void OnSuggestionAdded(::bgs::protocol::club::v1::SuggestionAddedNotification const* request, bool client = false, bool server = false); + void OnSuggestionRemoved(::bgs::protocol::club::v1::SuggestionRemovedNotification const* request, bool client = false, bool server = false); + void OnStreamAdded(::bgs::protocol::club::v1::StreamAddedNotification const* request, bool client = false, bool server = false); + void OnStreamRemoved(::bgs::protocol::club::v1::StreamRemovedNotification const* request, bool client = false, bool server = false); + void OnStreamStateChanged(::bgs::protocol::club::v1::StreamStateChangedNotification const* request, bool client = false, bool server = false); + void OnStreamMessageAdded(::bgs::protocol::club::v1::StreamMessageAddedNotification const* request, bool client = false, bool server = false); + void OnStreamMessageUpdated(::bgs::protocol::club::v1::StreamMessageUpdatedNotification const* request, bool client = false, bool server = false); + void OnStreamTypingIndicator(::bgs::protocol::club::v1::StreamTypingIndicatorNotification const* request, bool client = false, bool server = false); + void OnStreamUnreadIndicator(::bgs::protocol::club::v1::StreamUnreadIndicatorNotification const* request, bool client = false, bool server = false); + void OnStreamAdvanceViewTime(::bgs::protocol::club::v1::StreamAdvanceViewTimeNotification const* request, bool client = false, bool server = false); + + void CallServerMethod(uint32 token, uint32 methodId, MessageBuffer buffer) final; + + private: + uint32 service_hash_; + + GOOGLE_DISALLOW_EVIL_CONSTRUCTORS(ClubListener); +}; + +// =================================================================== + + +// =================================================================== + + +// @@protoc_insertion_point(namespace_scope) + +} // namespace v1 +} // namespace club +} // namespace protocol +} // namespace bgs + +#ifndef SWIG +namespace google { +namespace protobuf { + + +} // namespace google +} // namespace protobuf +#endif // SWIG + +// @@protoc_insertion_point(global_scope) + +#endif // PROTOBUF_club_5flistener_2eproto__INCLUDED diff --git a/src/server/proto/Client/club_listener.proto b/src/server/proto/Client/club_listener.proto new file mode 100644 index 00000000000..df22b4a576d --- /dev/null +++ b/src/server/proto/Client/club_listener.proto @@ -0,0 +1,123 @@ +syntax = "proto2"; + +import "club_notification.proto"; +package bgs.protocol.club.v1; + +option optimize_for = SPEED; +option cc_generic_services = false; + +service ClubListener { + option (.bgs.protocol.service_options) = { + descriptor_name: "bnet.protocol.club.v1.ClubListener" + }; + option (.bgs.protocol.sdk_service_options) = { + inbound: true + }; + rpc OnSubscribe(.bgs.protocol.club.v1.SubscribeNotification) returns (.bgs.protocol.NO_RESPONSE) { + option (.bgs.protocol.method_options) = { + id: 1 + }; + } + rpc OnUnsubscribe(.bgs.protocol.club.v1.UnsubscribeNotification) returns (.bgs.protocol.NO_RESPONSE) { + option (.bgs.protocol.method_options) = { + id: 2 + }; + } + rpc OnStateChanged(.bgs.protocol.club.v1.StateChangedNotification) returns (.bgs.protocol.NO_RESPONSE) { + option (.bgs.protocol.method_options) = { + id: 3 + }; + } + rpc OnSettingsChanged(.bgs.protocol.club.v1.SettingsChangedNotification) returns (.bgs.protocol.NO_RESPONSE) { + option (.bgs.protocol.method_options) = { + id: 4 + }; + } + rpc OnMemberAdded(.bgs.protocol.club.v1.MemberAddedNotification) returns (.bgs.protocol.NO_RESPONSE) { + option (.bgs.protocol.method_options) = { + id: 30 + }; + } + rpc OnMemberRemoved(.bgs.protocol.club.v1.MemberRemovedNotification) returns (.bgs.protocol.NO_RESPONSE) { + option (.bgs.protocol.method_options) = { + id: 31 + }; + } + rpc OnMemberStateChanged(.bgs.protocol.club.v1.MemberStateChangedNotification) returns (.bgs.protocol.NO_RESPONSE) { + option (.bgs.protocol.method_options) = { + id: 32 + }; + } + rpc OnSubscriberStateChanged(.bgs.protocol.club.v1.SubscriberStateChangedNotification) returns (.bgs.protocol.NO_RESPONSE) { + option (.bgs.protocol.method_options) = { + id: 33 + }; + } + rpc OnMemberRoleChanged(.bgs.protocol.club.v1.MemberRoleChangedNotification) returns (.bgs.protocol.NO_RESPONSE) { + option (.bgs.protocol.method_options) = { + id: 34 + }; + } + rpc OnInvitationAdded(.bgs.protocol.club.v1.InvitationAddedNotification) returns (.bgs.protocol.NO_RESPONSE) { + option (.bgs.protocol.method_options) = { + id: 50 + }; + } + rpc OnInvitationRemoved(.bgs.protocol.club.v1.InvitationRemovedNotification) returns (.bgs.protocol.NO_RESPONSE) { + option (.bgs.protocol.method_options) = { + id: 51 + }; + } + rpc OnSuggestionAdded(.bgs.protocol.club.v1.SuggestionAddedNotification) returns (.bgs.protocol.NO_RESPONSE) { + option (.bgs.protocol.method_options) = { + id: 70 + }; + } + rpc OnSuggestionRemoved(.bgs.protocol.club.v1.SuggestionRemovedNotification) returns (.bgs.protocol.NO_RESPONSE) { + option (.bgs.protocol.method_options) = { + id: 71 + }; + } + rpc OnStreamAdded(.bgs.protocol.club.v1.StreamAddedNotification) returns (.bgs.protocol.NO_RESPONSE) { + option (.bgs.protocol.method_options) = { + id: 100 + }; + } + rpc OnStreamRemoved(.bgs.protocol.club.v1.StreamRemovedNotification) returns (.bgs.protocol.NO_RESPONSE) { + option (.bgs.protocol.method_options) = { + id: 101 + }; + } + rpc OnStreamStateChanged(.bgs.protocol.club.v1.StreamStateChangedNotification) returns (.bgs.protocol.NO_RESPONSE) { + option (.bgs.protocol.method_options) = { + id: 102 + }; + } + rpc OnStreamMessageAdded(.bgs.protocol.club.v1.StreamMessageAddedNotification) returns (.bgs.protocol.NO_RESPONSE) { + option (.bgs.protocol.method_options) = { + id: 150 + }; + } + rpc OnStreamMessageUpdated(.bgs.protocol.club.v1.StreamMessageUpdatedNotification) returns (.bgs.protocol.NO_RESPONSE) { + option (.bgs.protocol.method_options) = { + id: 152 + }; + } + rpc OnStreamTypingIndicator(.bgs.protocol.club.v1.StreamTypingIndicatorNotification) returns (.bgs.protocol.NO_RESPONSE) { + option (.bgs.protocol.method_options) = { + id: 153 + }; + } + rpc OnStreamUnreadIndicator(.bgs.protocol.club.v1.StreamUnreadIndicatorNotification) returns (.bgs.protocol.NO_RESPONSE) { + option (.bgs.protocol.method_options) = { + id: 154 + }; + } + rpc OnStreamAdvanceViewTime(.bgs.protocol.club.v1.StreamAdvanceViewTimeNotification) returns (.bgs.protocol.NO_RESPONSE) { + option (.bgs.protocol.method_options) = { + id: 155 + }; + } +} + + diff --git a/src/server/proto/Client/club_service.pb.cc b/src/server/proto/Client/club_service.pb.cc new file mode 100644 index 00000000000..7e9809655d5 --- /dev/null +++ b/src/server/proto/Client/club_service.pb.cc @@ -0,0 +1,2012 @@ +// Generated by the protocol buffer compiler. DO NOT EDIT! +// source: club_service.proto + +#define INTERNAL_SUPPRESS_PROTOBUF_FIELD_DEPRECATION +#include "club_service.pb.h" + +#include <algorithm> +#include <utility> + +#include <google/protobuf/stubs/common.h> +#include <google/protobuf/stubs/once.h> +#include <google/protobuf/io/coded_stream.h> +#include <google/protobuf/wire_format_lite_inl.h> +#include <google/protobuf/descriptor.h> +#include <google/protobuf/generated_message_reflection.h> +#include <google/protobuf/reflection_ops.h> +#include <google/protobuf/wire_format.h> +#include "Log.h" +#include "Errors.h" +#include "BattlenetRpcErrorCodes.h" +// @@protoc_insertion_point(includes) + +namespace bgs { +namespace protocol { +namespace club { +namespace v1 { + +namespace { + +const ::google::protobuf::ServiceDescriptor* ClubService_descriptor_ = NULL; + +} // namespace + + +void protobuf_AssignDesc_club_5fservice_2eproto() { + protobuf_AddDesc_club_5fservice_2eproto(); + const ::google::protobuf::FileDescriptor* file = + ::google::protobuf::DescriptorPool::generated_pool()->FindFileByName( + "club_service.proto"); + GOOGLE_CHECK(file != NULL); + ClubService_descriptor_ = file->service(0); +} + +namespace { + +GOOGLE_PROTOBUF_DECLARE_ONCE(protobuf_AssignDescriptors_once_); +inline void protobuf_AssignDescriptorsOnce() { + ::google::protobuf::GoogleOnceInit(&protobuf_AssignDescriptors_once_, + &protobuf_AssignDesc_club_5fservice_2eproto); +} + +void protobuf_RegisterTypes(const ::std::string&) { + protobuf_AssignDescriptorsOnce(); +} + +} // namespace + +void protobuf_ShutdownFile_club_5fservice_2eproto() { +} + +void protobuf_AddDesc_club_5fservice_2eproto() { + static bool already_here = false; + if (already_here) return; + already_here = true; + GOOGLE_PROTOBUF_VERIFY_VERSION; + + ::bgs::protocol::club::v1::protobuf_AddDesc_club_5frequest_2eproto(); + ::google::protobuf::DescriptorPool::InternalAddGeneratedFile( + "\n\022club_service.proto\022\024bgs.protocol.club." + "v1\032\022club_request.proto2\260+\n\013ClubService\022Q" + "\n\tSubscribe\022&.bgs.protocol.club.v1.Subsc" + "ribeRequest\032\024.bgs.protocol.NoData\"\006\202\371+\002\010" + "\001\022U\n\013Unsubscribe\022(.bgs.protocol.club.v1." + "UnsubscribeRequest\032\024.bgs.protocol.NoData" + "\"\006\202\371+\002\010\002\022[\n\006Create\022#.bgs.protocol.club.v" + "1.CreateRequest\032$.bgs.protocol.club.v1.C" + "reateResponse\"\006\202\371+\002\010\003\022M\n\007Destroy\022$.bgs.p" + "rotocol.club.v1.DestroyRequest\032\024.bgs.pro" + "tocol.NoData\"\006\202\371+\002\010\004\022s\n\016GetDescription\022+" + ".bgs.protocol.club.v1.GetDescriptionRequ" + "est\032,.bgs.protocol.club.v1.GetDescriptio" + "nResponse\"\006\202\371+\002\010\005\022j\n\013GetClubType\022(.bgs.p" + "rotocol.club.v1.GetClubTypeRequest\032).bgs" + ".protocol.club.v1.GetClubTypeResponse\"\006\202" + "\371+\002\010\006\022]\n\017UpdateClubState\022,.bgs.protocol." + "club.v1.UpdateClubStateRequest\032\024.bgs.pro" + "tocol.NoData\"\006\202\371+\002\010\007\022c\n\022UpdateClubSettin" + "gs\022/.bgs.protocol.club.v1.UpdateClubSett" + "ingsRequest\032\024.bgs.protocol.NoData\"\006\202\371+\002\010" + "\010\022G\n\004Join\022!.bgs.protocol.club.v1.JoinReq" + "uest\032\024.bgs.protocol.NoData\"\006\202\371+\002\010\036\022I\n\005Le" + "ave\022\".bgs.protocol.club.v1.LeaveRequest\032" + "\024.bgs.protocol.NoData\"\006\202\371+\002\010\037\022G\n\004Kick\022!." + "bgs.protocol.club.v1.KickRequest\032\024.bgs.p" + "rotocol.NoData\"\006\202\371+\002\010 \022d\n\tGetMember\022&.bg" + "s.protocol.club.v1.GetMemberRequest\032\'.bg" + "s.protocol.club.v1.GetMemberResponse\"\006\202\371" + "+\002\010!\022g\n\nGetMembers\022\'.bgs.protocol.club.v" + "1.GetMembersRequest\032(.bgs.protocol.club." + "v1.GetMembersResponse\"\006\202\371+\002\010\"\022a\n\021UpdateM" + "emberState\022..bgs.protocol.club.v1.Update" + "MemberStateRequest\032\024.bgs.protocol.NoData" + "\"\006\202\371+\002\010#\022i\n\025UpdateSubscriberState\0222.bgs." + "protocol.club.v1.UpdateSubscriberStateRe" + "quest\032\024.bgs.protocol.NoData\"\006\202\371+\002\010$\022S\n\nA" + "ssignRole\022\'.bgs.protocol.club.v1.AssignR" + "oleRequest\032\024.bgs.protocol.NoData\"\006\202\371+\002\010%" + "\022W\n\014UnassignRole\022).bgs.protocol.club.v1." + "UnassignRoleRequest\032\024.bgs.protocol.NoDat" + "a\"\006\202\371+\002\010&\022[\n\016SendInvitation\022+.bgs.protoc" + "ol.club.v1.SendInvitationRequest\032\024.bgs.p" + "rotocol.NoData\"\006\202\371+\002\0102\022_\n\020AcceptInvitati" + "on\022-.bgs.protocol.club.v1.AcceptInvitati" + "onRequest\032\024.bgs.protocol.NoData\"\006\202\371+\002\0103\022" + "a\n\021DeclineInvitation\022..bgs.protocol.club" + ".v1.DeclineInvitationRequest\032\024.bgs.proto" + "col.NoData\"\006\202\371+\002\0104\022_\n\020RevokeInvitation\022-" + ".bgs.protocol.club.v1.RevokeInvitationRe" + "quest\032\024.bgs.protocol.NoData\"\006\202\371+\002\0105\022p\n\rG" + "etInvitation\022*.bgs.protocol.club.v1.GetI" + "nvitationRequest\032+.bgs.protocol.club.v1." + "GetInvitationResponse\"\006\202\371+\002\0106\022s\n\016GetInvi" + "tations\022+.bgs.protocol.club.v1.GetInvita" + "tionsRequest\032,.bgs.protocol.club.v1.GetI" + "nvitationsResponse\"\006\202\371+\002\0107\022[\n\016SendSugges" + "tion\022+.bgs.protocol.club.v1.SendSuggesti" + "onRequest\032\024.bgs.protocol.NoData\"\006\202\371+\002\010<\022" + "_\n\020AcceptSuggestion\022-.bgs.protocol.club." + "v1.AcceptSuggestionRequest\032\024.bgs.protoco" + "l.NoData\"\006\202\371+\002\010=\022a\n\021DeclineSuggestion\022.." + "bgs.protocol.club.v1.DeclineSuggestionRe" + "quest\032\024.bgs.protocol.NoData\"\006\202\371+\002\010>\022p\n\rG" + "etSuggestion\022*.bgs.protocol.club.v1.GetS" + "uggestionRequest\032+.bgs.protocol.club.v1." + "GetSuggestionResponse\"\006\202\371+\002\010\?\022s\n\016GetSugg" + "estions\022+.bgs.protocol.club.v1.GetSugges" + "tionsRequest\032,.bgs.protocol.club.v1.GetS" + "uggestionsResponse\"\006\202\371+\002\010@\022m\n\014CreateTick" + "et\022).bgs.protocol.club.v1.CreateTicketRe" + "quest\032*.bgs.protocol.club.v1.CreateTicke" + "tResponse\"\006\202\371+\002\010F\022Y\n\rDestroyTicket\022*.bgs" + ".protocol.club.v1.DestroyTicketRequest\032\024" + ".bgs.protocol.NoData\"\006\202\371+\002\010G\022W\n\014RedeemTi" + "cket\022).bgs.protocol.club.v1.RedeemTicket" + "Request\032\024.bgs.protocol.NoData\"\006\202\371+\002\010H\022d\n" + "\tGetTicket\022&.bgs.protocol.club.v1.GetTic" + "ketRequest\032\'.bgs.protocol.club.v1.GetTic" + "ketResponse\"\006\202\371+\002\010I\022g\n\nGetTickets\022\'.bgs." + "protocol.club.v1.GetTicketsRequest\032(.bgs" + ".protocol.club.v1.GetTicketsResponse\"\006\202\371" + "+\002\010J\022K\n\006AddBan\022#.bgs.protocol.club.v1.Ad" + "dBanRequest\032\024.bgs.protocol.NoData\"\006\202\371+\002\010" + "P\022Q\n\tRemoveBan\022&.bgs.protocol.club.v1.Re" + "moveBanRequest\032\024.bgs.protocol.NoData\"\006\202\371" + "+\002\010Q\022[\n\006GetBan\022#.bgs.protocol.club.v1.Ge" + "tBanRequest\032$.bgs.protocol.club.v1.GetBa" + "nResponse\"\006\202\371+\002\010R\022^\n\007GetBans\022$.bgs.proto" + "col.club.v1.GetBansRequest\032%.bgs.protoco" + "l.club.v1.GetBansResponse\"\006\202\371+\002\010S\022]\n\017Sub" + "scribeStream\022,.bgs.protocol.club.v1.Subs" + "cribeStreamRequest\032\024.bgs.protocol.NoData" + "\"\006\202\371+\002\010d\022a\n\021UnsubscribeStream\022..bgs.prot" + "ocol.club.v1.UnsubscribeStreamRequest\032\024." + "bgs.protocol.NoData\"\006\202\371+\002\010e\022m\n\014CreateStr" + "eam\022).bgs.protocol.club.v1.CreateStreamR" + "equest\032*.bgs.protocol.club.v1.CreateStre" + "amResponse\"\006\202\371+\002\010f\022Y\n\rDestroyStream\022*.bg" + "s.protocol.club.v1.DestroyStreamRequest\032" + "\024.bgs.protocol.NoData\"\006\202\371+\002\010g\022d\n\tGetStre" + "am\022&.bgs.protocol.club.v1.GetStreamReque" + "st\032\'.bgs.protocol.club.v1.GetStreamRespo" + "nse\"\006\202\371+\002\010h\022g\n\nGetStreams\022\'.bgs.protocol" + ".club.v1.GetStreamsRequest\032(.bgs.protoco" + "l.club.v1.GetStreamsResponse\"\006\202\371+\002\010i\022a\n\021" + "UpdateStreamState\022..bgs.protocol.club.v1" + ".UpdateStreamStateRequest\032\024.bgs.protocol" + ".NoData\"\006\202\371+\002\010j\022[\n\016SetStreamFocus\022+.bgs." + "protocol.club.v1.SetStreamFocusRequest\032\024" + ".bgs.protocol.NoData\"\006\202\371+\002\010k\022\202\001\n\023GetStre" + "amVoiceToken\0220.bgs.protocol.club.v1.GetS" + "treamVoiceTokenRequest\0321.bgs.protocol.cl" + "ub.v1.GetStreamVoiceTokenResponse\"\006\202\371+\002\010" + "l\022e\n\023KickFromStreamVoice\0220.bgs.protocol." + "club.v1.KickFromStreamVoiceRequest\032\024.bgs" + ".protocol.NoData\"\006\202\371+\002\010m\022q\n\rCreateMessag" + "e\022*.bgs.protocol.club.v1.CreateMessageRe" + "quest\032+.bgs.protocol.club.v1.CreateMessa" + "geResponse\"\007\202\371+\003\010\226\001\022t\n\016DestroyMessage\022+." + "bgs.protocol.club.v1.DestroyMessageReque" + "st\032,.bgs.protocol.club.v1.DestroyMessage" + "Response\"\007\202\371+\003\010\227\001\022k\n\013EditMessage\022(.bgs.p" + "rotocol.club.v1.EditMessageRequest\032).bgs" + ".protocol.club.v1.EditMessageResponse\"\007\202" + "\371+\003\010\230\001\022`\n\020SetMessagePinned\022-.bgs.protoco" + "l.club.v1.SetMessagePinnedRequest\032\024.bgs." + "protocol.NoData\"\007\202\371+\003\010\231\001\022d\n\022SetTypingInd" + "icator\022/.bgs.protocol.club.v1.SetTypingI" + "ndicatorRequest\032\024.bgs.protocol.NoData\"\007\202" + "\371+\003\010\232\001\022j\n\025AdvanceStreamViewTime\0222.bgs.pr" + "otocol.club.v1.AdvanceStreamViewTimeRequ" + "est\032\024.bgs.protocol.NoData\"\007\202\371+\003\010\233\001\022z\n\020Ge" + "tStreamHistory\022-.bgs.protocol.club.v1.Ge" + "tStreamHistoryRequest\032..bgs.protocol.clu" + "b.v1.GetStreamHistoryResponse\"\007\202\371+\003\010\234\001\022z" + "\n\020GetStreamMessage\022-.bgs.protocol.club.v" + "1.GetStreamMessageRequest\032..bgs.protocol" + ".club.v1.GetStreamMessageResponse\"\007\202\371+\003\010" + "\235\001\0325\202\371+)\n!bnet.protocol.club.v1.ClubServ" + "ice*\004club\212\371+\004\020\001\030\001B\005H\001\200\001\000", 5624); + ::google::protobuf::MessageFactory::InternalRegisterGeneratedFile( + "club_service.proto", &protobuf_RegisterTypes); + ::google::protobuf::internal::OnShutdown(&protobuf_ShutdownFile_club_5fservice_2eproto); +} + +// Force AddDescriptors() to be called at static initialization time. +struct StaticDescriptorInitializer_club_5fservice_2eproto { + StaticDescriptorInitializer_club_5fservice_2eproto() { + protobuf_AddDesc_club_5fservice_2eproto(); + } +} static_descriptor_initializer_club_5fservice_2eproto_; + +// =================================================================== + +ClubService::ClubService(bool use_original_hash) : service_hash_(use_original_hash ? OriginalHash::value : NameHash::value) { +} + +ClubService::~ClubService() { +} + +google::protobuf::ServiceDescriptor const* ClubService::descriptor() { + protobuf_AssignDescriptorsOnce(); + return ClubService_descriptor_; +} + +void ClubService::CallServerMethod(uint32 token, uint32 methodId, MessageBuffer buffer) { + switch(methodId & 0x3FFFFFFF) { + case 1: { + ::bgs::protocol::club::v1::SubscribeRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.Subscribe server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.Subscribe(bgs.protocol.club.v1.SubscribeRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::NoData::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.Subscribe() returned bgs.protocol.NoData{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::NoData response; + uint32 status = HandleSubscribe(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 2: { + ::bgs::protocol::club::v1::UnsubscribeRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.Unsubscribe server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.Unsubscribe(bgs.protocol.club.v1.UnsubscribeRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::NoData::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.Unsubscribe() returned bgs.protocol.NoData{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::NoData response; + uint32 status = HandleUnsubscribe(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 3: { + ::bgs::protocol::club::v1::CreateRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.Create server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.Create(bgs.protocol.club.v1.CreateRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::club::v1::CreateResponse::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.Create() returned bgs.protocol.club.v1.CreateResponse{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::club::v1::CreateResponse response; + uint32 status = HandleCreate(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 4: { + ::bgs::protocol::club::v1::DestroyRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.Destroy server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.Destroy(bgs.protocol.club.v1.DestroyRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::NoData::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.Destroy() returned bgs.protocol.NoData{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::NoData response; + uint32 status = HandleDestroy(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 5: { + ::bgs::protocol::club::v1::GetDescriptionRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.GetDescription server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.GetDescription(bgs.protocol.club.v1.GetDescriptionRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::club::v1::GetDescriptionResponse::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.GetDescription() returned bgs.protocol.club.v1.GetDescriptionResponse{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::club::v1::GetDescriptionResponse response; + uint32 status = HandleGetDescription(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 6: { + ::bgs::protocol::club::v1::GetClubTypeRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.GetClubType server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.GetClubType(bgs.protocol.club.v1.GetClubTypeRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::club::v1::GetClubTypeResponse::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.GetClubType() returned bgs.protocol.club.v1.GetClubTypeResponse{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::club::v1::GetClubTypeResponse response; + uint32 status = HandleGetClubType(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 7: { + ::bgs::protocol::club::v1::UpdateClubStateRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.UpdateClubState server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.UpdateClubState(bgs.protocol.club.v1.UpdateClubStateRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::NoData::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.UpdateClubState() returned bgs.protocol.NoData{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::NoData response; + uint32 status = HandleUpdateClubState(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 8: { + ::bgs::protocol::club::v1::UpdateClubSettingsRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.UpdateClubSettings server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.UpdateClubSettings(bgs.protocol.club.v1.UpdateClubSettingsRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::NoData::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.UpdateClubSettings() returned bgs.protocol.NoData{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::NoData response; + uint32 status = HandleUpdateClubSettings(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 30: { + ::bgs::protocol::club::v1::JoinRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.Join server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.Join(bgs.protocol.club.v1.JoinRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::NoData::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.Join() returned bgs.protocol.NoData{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::NoData response; + uint32 status = HandleJoin(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 31: { + ::bgs::protocol::club::v1::LeaveRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.Leave server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.Leave(bgs.protocol.club.v1.LeaveRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::NoData::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.Leave() returned bgs.protocol.NoData{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::NoData response; + uint32 status = HandleLeave(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 32: { + ::bgs::protocol::club::v1::KickRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.Kick server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.Kick(bgs.protocol.club.v1.KickRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::NoData::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.Kick() returned bgs.protocol.NoData{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::NoData response; + uint32 status = HandleKick(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 33: { + ::bgs::protocol::club::v1::GetMemberRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.GetMember server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.GetMember(bgs.protocol.club.v1.GetMemberRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::club::v1::GetMemberResponse::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.GetMember() returned bgs.protocol.club.v1.GetMemberResponse{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::club::v1::GetMemberResponse response; + uint32 status = HandleGetMember(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 34: { + ::bgs::protocol::club::v1::GetMembersRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.GetMembers server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.GetMembers(bgs.protocol.club.v1.GetMembersRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::club::v1::GetMembersResponse::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.GetMembers() returned bgs.protocol.club.v1.GetMembersResponse{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::club::v1::GetMembersResponse response; + uint32 status = HandleGetMembers(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 35: { + ::bgs::protocol::club::v1::UpdateMemberStateRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.UpdateMemberState server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.UpdateMemberState(bgs.protocol.club.v1.UpdateMemberStateRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::NoData::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.UpdateMemberState() returned bgs.protocol.NoData{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::NoData response; + uint32 status = HandleUpdateMemberState(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 36: { + ::bgs::protocol::club::v1::UpdateSubscriberStateRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.UpdateSubscriberState server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.UpdateSubscriberState(bgs.protocol.club.v1.UpdateSubscriberStateRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::NoData::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.UpdateSubscriberState() returned bgs.protocol.NoData{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::NoData response; + uint32 status = HandleUpdateSubscriberState(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 37: { + ::bgs::protocol::club::v1::AssignRoleRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.AssignRole server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.AssignRole(bgs.protocol.club.v1.AssignRoleRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::NoData::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.AssignRole() returned bgs.protocol.NoData{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::NoData response; + uint32 status = HandleAssignRole(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 38: { + ::bgs::protocol::club::v1::UnassignRoleRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.UnassignRole server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.UnassignRole(bgs.protocol.club.v1.UnassignRoleRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::NoData::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.UnassignRole() returned bgs.protocol.NoData{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::NoData response; + uint32 status = HandleUnassignRole(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 50: { + ::bgs::protocol::club::v1::SendInvitationRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.SendInvitation server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.SendInvitation(bgs.protocol.club.v1.SendInvitationRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::NoData::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.SendInvitation() returned bgs.protocol.NoData{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::NoData response; + uint32 status = HandleSendInvitation(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 51: { + ::bgs::protocol::club::v1::AcceptInvitationRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.AcceptInvitation server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.AcceptInvitation(bgs.protocol.club.v1.AcceptInvitationRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::NoData::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.AcceptInvitation() returned bgs.protocol.NoData{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::NoData response; + uint32 status = HandleAcceptInvitation(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 52: { + ::bgs::protocol::club::v1::DeclineInvitationRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.DeclineInvitation server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.DeclineInvitation(bgs.protocol.club.v1.DeclineInvitationRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::NoData::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.DeclineInvitation() returned bgs.protocol.NoData{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::NoData response; + uint32 status = HandleDeclineInvitation(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 53: { + ::bgs::protocol::club::v1::RevokeInvitationRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.RevokeInvitation server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.RevokeInvitation(bgs.protocol.club.v1.RevokeInvitationRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::NoData::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.RevokeInvitation() returned bgs.protocol.NoData{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::NoData response; + uint32 status = HandleRevokeInvitation(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 54: { + ::bgs::protocol::club::v1::GetInvitationRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.GetInvitation server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.GetInvitation(bgs.protocol.club.v1.GetInvitationRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::club::v1::GetInvitationResponse::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.GetInvitation() returned bgs.protocol.club.v1.GetInvitationResponse{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::club::v1::GetInvitationResponse response; + uint32 status = HandleGetInvitation(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 55: { + ::bgs::protocol::club::v1::GetInvitationsRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.GetInvitations server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.GetInvitations(bgs.protocol.club.v1.GetInvitationsRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::club::v1::GetInvitationsResponse::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.GetInvitations() returned bgs.protocol.club.v1.GetInvitationsResponse{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::club::v1::GetInvitationsResponse response; + uint32 status = HandleGetInvitations(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 60: { + ::bgs::protocol::club::v1::SendSuggestionRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.SendSuggestion server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.SendSuggestion(bgs.protocol.club.v1.SendSuggestionRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::NoData::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.SendSuggestion() returned bgs.protocol.NoData{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::NoData response; + uint32 status = HandleSendSuggestion(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 61: { + ::bgs::protocol::club::v1::AcceptSuggestionRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.AcceptSuggestion server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.AcceptSuggestion(bgs.protocol.club.v1.AcceptSuggestionRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::NoData::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.AcceptSuggestion() returned bgs.protocol.NoData{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::NoData response; + uint32 status = HandleAcceptSuggestion(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 62: { + ::bgs::protocol::club::v1::DeclineSuggestionRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.DeclineSuggestion server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.DeclineSuggestion(bgs.protocol.club.v1.DeclineSuggestionRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::NoData::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.DeclineSuggestion() returned bgs.protocol.NoData{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::NoData response; + uint32 status = HandleDeclineSuggestion(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 63: { + ::bgs::protocol::club::v1::GetSuggestionRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.GetSuggestion server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.GetSuggestion(bgs.protocol.club.v1.GetSuggestionRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::club::v1::GetSuggestionResponse::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.GetSuggestion() returned bgs.protocol.club.v1.GetSuggestionResponse{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::club::v1::GetSuggestionResponse response; + uint32 status = HandleGetSuggestion(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 64: { + ::bgs::protocol::club::v1::GetSuggestionsRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.GetSuggestions server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.GetSuggestions(bgs.protocol.club.v1.GetSuggestionsRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::club::v1::GetSuggestionsResponse::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.GetSuggestions() returned bgs.protocol.club.v1.GetSuggestionsResponse{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::club::v1::GetSuggestionsResponse response; + uint32 status = HandleGetSuggestions(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 70: { + ::bgs::protocol::club::v1::CreateTicketRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.CreateTicket server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.CreateTicket(bgs.protocol.club.v1.CreateTicketRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::club::v1::CreateTicketResponse::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.CreateTicket() returned bgs.protocol.club.v1.CreateTicketResponse{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::club::v1::CreateTicketResponse response; + uint32 status = HandleCreateTicket(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 71: { + ::bgs::protocol::club::v1::DestroyTicketRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.DestroyTicket server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.DestroyTicket(bgs.protocol.club.v1.DestroyTicketRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::NoData::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.DestroyTicket() returned bgs.protocol.NoData{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::NoData response; + uint32 status = HandleDestroyTicket(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 72: { + ::bgs::protocol::club::v1::RedeemTicketRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.RedeemTicket server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.RedeemTicket(bgs.protocol.club.v1.RedeemTicketRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::NoData::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.RedeemTicket() returned bgs.protocol.NoData{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::NoData response; + uint32 status = HandleRedeemTicket(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 73: { + ::bgs::protocol::club::v1::GetTicketRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.GetTicket server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.GetTicket(bgs.protocol.club.v1.GetTicketRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::club::v1::GetTicketResponse::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.GetTicket() returned bgs.protocol.club.v1.GetTicketResponse{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::club::v1::GetTicketResponse response; + uint32 status = HandleGetTicket(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 74: { + ::bgs::protocol::club::v1::GetTicketsRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.GetTickets server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.GetTickets(bgs.protocol.club.v1.GetTicketsRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::club::v1::GetTicketsResponse::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.GetTickets() returned bgs.protocol.club.v1.GetTicketsResponse{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::club::v1::GetTicketsResponse response; + uint32 status = HandleGetTickets(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 80: { + ::bgs::protocol::club::v1::AddBanRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.AddBan server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.AddBan(bgs.protocol.club.v1.AddBanRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::NoData::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.AddBan() returned bgs.protocol.NoData{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::NoData response; + uint32 status = HandleAddBan(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 81: { + ::bgs::protocol::club::v1::RemoveBanRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.RemoveBan server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.RemoveBan(bgs.protocol.club.v1.RemoveBanRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::NoData::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.RemoveBan() returned bgs.protocol.NoData{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::NoData response; + uint32 status = HandleRemoveBan(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 82: { + ::bgs::protocol::club::v1::GetBanRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.GetBan server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.GetBan(bgs.protocol.club.v1.GetBanRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::club::v1::GetBanResponse::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.GetBan() returned bgs.protocol.club.v1.GetBanResponse{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::club::v1::GetBanResponse response; + uint32 status = HandleGetBan(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 83: { + ::bgs::protocol::club::v1::GetBansRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.GetBans server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.GetBans(bgs.protocol.club.v1.GetBansRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::club::v1::GetBansResponse::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.GetBans() returned bgs.protocol.club.v1.GetBansResponse{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::club::v1::GetBansResponse response; + uint32 status = HandleGetBans(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 100: { + ::bgs::protocol::club::v1::SubscribeStreamRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.SubscribeStream server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.SubscribeStream(bgs.protocol.club.v1.SubscribeStreamRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::NoData::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.SubscribeStream() returned bgs.protocol.NoData{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::NoData response; + uint32 status = HandleSubscribeStream(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 101: { + ::bgs::protocol::club::v1::UnsubscribeStreamRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.UnsubscribeStream server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.UnsubscribeStream(bgs.protocol.club.v1.UnsubscribeStreamRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::NoData::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.UnsubscribeStream() returned bgs.protocol.NoData{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::NoData response; + uint32 status = HandleUnsubscribeStream(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 102: { + ::bgs::protocol::club::v1::CreateStreamRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.CreateStream server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.CreateStream(bgs.protocol.club.v1.CreateStreamRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::club::v1::CreateStreamResponse::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.CreateStream() returned bgs.protocol.club.v1.CreateStreamResponse{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::club::v1::CreateStreamResponse response; + uint32 status = HandleCreateStream(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 103: { + ::bgs::protocol::club::v1::DestroyStreamRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.DestroyStream server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.DestroyStream(bgs.protocol.club.v1.DestroyStreamRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::NoData::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.DestroyStream() returned bgs.protocol.NoData{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::NoData response; + uint32 status = HandleDestroyStream(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 104: { + ::bgs::protocol::club::v1::GetStreamRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.GetStream server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.GetStream(bgs.protocol.club.v1.GetStreamRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::club::v1::GetStreamResponse::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.GetStream() returned bgs.protocol.club.v1.GetStreamResponse{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::club::v1::GetStreamResponse response; + uint32 status = HandleGetStream(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 105: { + ::bgs::protocol::club::v1::GetStreamsRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.GetStreams server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.GetStreams(bgs.protocol.club.v1.GetStreamsRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::club::v1::GetStreamsResponse::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.GetStreams() returned bgs.protocol.club.v1.GetStreamsResponse{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::club::v1::GetStreamsResponse response; + uint32 status = HandleGetStreams(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 106: { + ::bgs::protocol::club::v1::UpdateStreamStateRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.UpdateStreamState server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.UpdateStreamState(bgs.protocol.club.v1.UpdateStreamStateRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::NoData::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.UpdateStreamState() returned bgs.protocol.NoData{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::NoData response; + uint32 status = HandleUpdateStreamState(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 107: { + ::bgs::protocol::club::v1::SetStreamFocusRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.SetStreamFocus server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.SetStreamFocus(bgs.protocol.club.v1.SetStreamFocusRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::NoData::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.SetStreamFocus() returned bgs.protocol.NoData{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::NoData response; + uint32 status = HandleSetStreamFocus(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 108: { + ::bgs::protocol::club::v1::GetStreamVoiceTokenRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.GetStreamVoiceToken server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.GetStreamVoiceToken(bgs.protocol.club.v1.GetStreamVoiceTokenRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::club::v1::GetStreamVoiceTokenResponse::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.GetStreamVoiceToken() returned bgs.protocol.club.v1.GetStreamVoiceTokenResponse{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::club::v1::GetStreamVoiceTokenResponse response; + uint32 status = HandleGetStreamVoiceToken(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 109: { + ::bgs::protocol::club::v1::KickFromStreamVoiceRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.KickFromStreamVoice server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.KickFromStreamVoice(bgs.protocol.club.v1.KickFromStreamVoiceRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::NoData::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.KickFromStreamVoice() returned bgs.protocol.NoData{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::NoData response; + uint32 status = HandleKickFromStreamVoice(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 150: { + ::bgs::protocol::club::v1::CreateMessageRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.CreateMessage server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.CreateMessage(bgs.protocol.club.v1.CreateMessageRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::club::v1::CreateMessageResponse::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.CreateMessage() returned bgs.protocol.club.v1.CreateMessageResponse{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::club::v1::CreateMessageResponse response; + uint32 status = HandleCreateMessage(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 151: { + ::bgs::protocol::club::v1::DestroyMessageRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.DestroyMessage server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.DestroyMessage(bgs.protocol.club.v1.DestroyMessageRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::club::v1::DestroyMessageResponse::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.DestroyMessage() returned bgs.protocol.club.v1.DestroyMessageResponse{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::club::v1::DestroyMessageResponse response; + uint32 status = HandleDestroyMessage(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 152: { + ::bgs::protocol::club::v1::EditMessageRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.EditMessage server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.EditMessage(bgs.protocol.club.v1.EditMessageRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::club::v1::EditMessageResponse::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.EditMessage() returned bgs.protocol.club.v1.EditMessageResponse{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::club::v1::EditMessageResponse response; + uint32 status = HandleEditMessage(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 153: { + ::bgs::protocol::club::v1::SetMessagePinnedRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.SetMessagePinned server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.SetMessagePinned(bgs.protocol.club.v1.SetMessagePinnedRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::NoData::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.SetMessagePinned() returned bgs.protocol.NoData{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::NoData response; + uint32 status = HandleSetMessagePinned(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 154: { + ::bgs::protocol::club::v1::SetTypingIndicatorRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.SetTypingIndicator server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.SetTypingIndicator(bgs.protocol.club.v1.SetTypingIndicatorRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::NoData::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.SetTypingIndicator() returned bgs.protocol.NoData{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::NoData response; + uint32 status = HandleSetTypingIndicator(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 155: { + ::bgs::protocol::club::v1::AdvanceStreamViewTimeRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.AdvanceStreamViewTime server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.AdvanceStreamViewTime(bgs.protocol.club.v1.AdvanceStreamViewTimeRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::NoData::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.AdvanceStreamViewTime() returned bgs.protocol.NoData{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::NoData response; + uint32 status = HandleAdvanceStreamViewTime(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 156: { + ::bgs::protocol::club::v1::GetStreamHistoryRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.GetStreamHistory server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.GetStreamHistory(bgs.protocol.club.v1.GetStreamHistoryRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::club::v1::GetStreamHistoryResponse::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.GetStreamHistory() returned bgs.protocol.club.v1.GetStreamHistoryResponse{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::club::v1::GetStreamHistoryResponse response; + uint32 status = HandleGetStreamHistory(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + case 157: { + ::bgs::protocol::club::v1::GetStreamMessageRequest request; + if (!request.ParseFromArray(buffer.GetReadPointer(), buffer.GetActiveSize())) { + TC_LOG_DEBUG("service.protobuf", "%s Failed to parse request for ClubService.GetStreamMessage server method call.", GetCallerInfo().c_str()); + SendResponse(service_hash_, methodId, token, ERROR_RPC_MALFORMED_REQUEST); + return; + } + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.GetStreamMessage(bgs.protocol.club.v1.GetStreamMessageRequest{ %s }).", + GetCallerInfo().c_str(), request.ShortDebugString().c_str()); + std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)> continuation = [token, methodId](ServiceBase* service, uint32 status, ::google::protobuf::Message const* response) + { + ASSERT(response->GetDescriptor() == ::bgs::protocol::club::v1::GetStreamMessageResponse::descriptor()); + ClubService* self = static_cast<ClubService*>(service); + TC_LOG_DEBUG("service.protobuf", "%s Client called server method ClubService.GetStreamMessage() returned bgs.protocol.club.v1.GetStreamMessageResponse{ %s } status %u.", + self->GetCallerInfo().c_str(), response->ShortDebugString().c_str(), status); + if (!status) + self->SendResponse(self->service_hash_, methodId, token, response); + else + self->SendResponse(self->service_hash_, methodId, token, status); + }; + ::bgs::protocol::club::v1::GetStreamMessageResponse response; + uint32 status = HandleGetStreamMessage(&request, &response, continuation); + if (continuation) + continuation(this, status, &response); + break; + } + default: + TC_LOG_ERROR("service.protobuf", "Bad method id %u.", methodId); + SendResponse(service_hash_, methodId, token, ERROR_RPC_INVALID_METHOD); + break; + } +} + +uint32 ClubService::HandleSubscribe(::bgs::protocol::club::v1::SubscribeRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.Subscribe({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleUnsubscribe(::bgs::protocol::club::v1::UnsubscribeRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.Unsubscribe({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleCreate(::bgs::protocol::club::v1::CreateRequest const* request, ::bgs::protocol::club::v1::CreateResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.Create({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleDestroy(::bgs::protocol::club::v1::DestroyRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.Destroy({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleGetDescription(::bgs::protocol::club::v1::GetDescriptionRequest const* request, ::bgs::protocol::club::v1::GetDescriptionResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.GetDescription({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleGetClubType(::bgs::protocol::club::v1::GetClubTypeRequest const* request, ::bgs::protocol::club::v1::GetClubTypeResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.GetClubType({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleUpdateClubState(::bgs::protocol::club::v1::UpdateClubStateRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.UpdateClubState({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleUpdateClubSettings(::bgs::protocol::club::v1::UpdateClubSettingsRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.UpdateClubSettings({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleJoin(::bgs::protocol::club::v1::JoinRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.Join({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleLeave(::bgs::protocol::club::v1::LeaveRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.Leave({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleKick(::bgs::protocol::club::v1::KickRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.Kick({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleGetMember(::bgs::protocol::club::v1::GetMemberRequest const* request, ::bgs::protocol::club::v1::GetMemberResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.GetMember({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleGetMembers(::bgs::protocol::club::v1::GetMembersRequest const* request, ::bgs::protocol::club::v1::GetMembersResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.GetMembers({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleUpdateMemberState(::bgs::protocol::club::v1::UpdateMemberStateRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.UpdateMemberState({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleUpdateSubscriberState(::bgs::protocol::club::v1::UpdateSubscriberStateRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.UpdateSubscriberState({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleAssignRole(::bgs::protocol::club::v1::AssignRoleRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.AssignRole({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleUnassignRole(::bgs::protocol::club::v1::UnassignRoleRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.UnassignRole({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleSendInvitation(::bgs::protocol::club::v1::SendInvitationRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.SendInvitation({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleAcceptInvitation(::bgs::protocol::club::v1::AcceptInvitationRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.AcceptInvitation({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleDeclineInvitation(::bgs::protocol::club::v1::DeclineInvitationRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.DeclineInvitation({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleRevokeInvitation(::bgs::protocol::club::v1::RevokeInvitationRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.RevokeInvitation({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleGetInvitation(::bgs::protocol::club::v1::GetInvitationRequest const* request, ::bgs::protocol::club::v1::GetInvitationResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.GetInvitation({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleGetInvitations(::bgs::protocol::club::v1::GetInvitationsRequest const* request, ::bgs::protocol::club::v1::GetInvitationsResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.GetInvitations({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleSendSuggestion(::bgs::protocol::club::v1::SendSuggestionRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.SendSuggestion({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleAcceptSuggestion(::bgs::protocol::club::v1::AcceptSuggestionRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.AcceptSuggestion({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleDeclineSuggestion(::bgs::protocol::club::v1::DeclineSuggestionRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.DeclineSuggestion({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleGetSuggestion(::bgs::protocol::club::v1::GetSuggestionRequest const* request, ::bgs::protocol::club::v1::GetSuggestionResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.GetSuggestion({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleGetSuggestions(::bgs::protocol::club::v1::GetSuggestionsRequest const* request, ::bgs::protocol::club::v1::GetSuggestionsResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.GetSuggestions({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleCreateTicket(::bgs::protocol::club::v1::CreateTicketRequest const* request, ::bgs::protocol::club::v1::CreateTicketResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.CreateTicket({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleDestroyTicket(::bgs::protocol::club::v1::DestroyTicketRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.DestroyTicket({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleRedeemTicket(::bgs::protocol::club::v1::RedeemTicketRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.RedeemTicket({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleGetTicket(::bgs::protocol::club::v1::GetTicketRequest const* request, ::bgs::protocol::club::v1::GetTicketResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.GetTicket({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleGetTickets(::bgs::protocol::club::v1::GetTicketsRequest const* request, ::bgs::protocol::club::v1::GetTicketsResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.GetTickets({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleAddBan(::bgs::protocol::club::v1::AddBanRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.AddBan({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleRemoveBan(::bgs::protocol::club::v1::RemoveBanRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.RemoveBan({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleGetBan(::bgs::protocol::club::v1::GetBanRequest const* request, ::bgs::protocol::club::v1::GetBanResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.GetBan({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleGetBans(::bgs::protocol::club::v1::GetBansRequest const* request, ::bgs::protocol::club::v1::GetBansResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.GetBans({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleSubscribeStream(::bgs::protocol::club::v1::SubscribeStreamRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.SubscribeStream({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleUnsubscribeStream(::bgs::protocol::club::v1::UnsubscribeStreamRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.UnsubscribeStream({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleCreateStream(::bgs::protocol::club::v1::CreateStreamRequest const* request, ::bgs::protocol::club::v1::CreateStreamResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.CreateStream({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleDestroyStream(::bgs::protocol::club::v1::DestroyStreamRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.DestroyStream({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleGetStream(::bgs::protocol::club::v1::GetStreamRequest const* request, ::bgs::protocol::club::v1::GetStreamResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.GetStream({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleGetStreams(::bgs::protocol::club::v1::GetStreamsRequest const* request, ::bgs::protocol::club::v1::GetStreamsResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.GetStreams({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleUpdateStreamState(::bgs::protocol::club::v1::UpdateStreamStateRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.UpdateStreamState({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleSetStreamFocus(::bgs::protocol::club::v1::SetStreamFocusRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.SetStreamFocus({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleGetStreamVoiceToken(::bgs::protocol::club::v1::GetStreamVoiceTokenRequest const* request, ::bgs::protocol::club::v1::GetStreamVoiceTokenResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.GetStreamVoiceToken({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleKickFromStreamVoice(::bgs::protocol::club::v1::KickFromStreamVoiceRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.KickFromStreamVoice({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleCreateMessage(::bgs::protocol::club::v1::CreateMessageRequest const* request, ::bgs::protocol::club::v1::CreateMessageResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.CreateMessage({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleDestroyMessage(::bgs::protocol::club::v1::DestroyMessageRequest const* request, ::bgs::protocol::club::v1::DestroyMessageResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.DestroyMessage({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleEditMessage(::bgs::protocol::club::v1::EditMessageRequest const* request, ::bgs::protocol::club::v1::EditMessageResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.EditMessage({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleSetMessagePinned(::bgs::protocol::club::v1::SetMessagePinnedRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.SetMessagePinned({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleSetTypingIndicator(::bgs::protocol::club::v1::SetTypingIndicatorRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.SetTypingIndicator({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleAdvanceStreamViewTime(::bgs::protocol::club::v1::AdvanceStreamViewTimeRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.AdvanceStreamViewTime({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleGetStreamHistory(::bgs::protocol::club::v1::GetStreamHistoryRequest const* request, ::bgs::protocol::club::v1::GetStreamHistoryResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.GetStreamHistory({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + +uint32 ClubService::HandleGetStreamMessage(::bgs::protocol::club::v1::GetStreamMessageRequest const* request, ::bgs::protocol::club::v1::GetStreamMessageResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation) { + TC_LOG_ERROR("service.protobuf", "%s Client tried to call not implemented method ClubService.GetStreamMessage({ %s })", + GetCallerInfo().c_str(), request->ShortDebugString().c_str()); + return ERROR_RPC_NOT_IMPLEMENTED; +} + + +// @@protoc_insertion_point(namespace_scope) + +} // namespace v1 +} // namespace club +} // namespace protocol +} // namespace bgs + +// @@protoc_insertion_point(global_scope) diff --git a/src/server/proto/Client/club_service.pb.h b/src/server/proto/Client/club_service.pb.h new file mode 100644 index 00000000000..b5d7de9af0b --- /dev/null +++ b/src/server/proto/Client/club_service.pb.h @@ -0,0 +1,150 @@ +// Generated by the protocol buffer compiler. DO NOT EDIT! +// source: club_service.proto + +#ifndef PROTOBUF_club_5fservice_2eproto__INCLUDED +#define PROTOBUF_club_5fservice_2eproto__INCLUDED + +#include <string> + +#include <google/protobuf/stubs/common.h> + +#if GOOGLE_PROTOBUF_VERSION < 2006000 +#error This file was generated by a newer version of protoc which is +#error incompatible with your Protocol Buffer headers. Please update +#error your headers. +#endif +#if 2006001 < GOOGLE_PROTOBUF_MIN_PROTOC_VERSION +#error This file was generated by an older version of protoc which is +#error incompatible with your Protocol Buffer headers. Please +#error regenerate this file with a newer version of protoc. +#endif + +#include <google/protobuf/generated_message_util.h> +#include <google/protobuf/repeated_field.h> +#include <google/protobuf/extension_set.h> +#include "club_request.pb.h" +#include "ServiceBase.h" +#include "MessageBuffer.h" +#include <functional> +#include <type_traits> +// @@protoc_insertion_point(includes) + +namespace bgs { +namespace protocol { +namespace club { +namespace v1 { + +// Internal implementation detail -- do not call these. +void TC_PROTO_API protobuf_AddDesc_club_5fservice_2eproto(); +void protobuf_AssignDesc_club_5fservice_2eproto(); +void protobuf_ShutdownFile_club_5fservice_2eproto(); + + +// =================================================================== + + +// =================================================================== + +class TC_PROTO_API ClubService : public ServiceBase +{ + public: + + explicit ClubService(bool use_original_hash); + virtual ~ClubService(); + + typedef std::integral_constant<uint32, 0xE273DE0Eu> OriginalHash; + typedef std::integral_constant<uint32, 0xCBEDD5C7u> NameHash; + + static google::protobuf::ServiceDescriptor const* descriptor(); + + void CallServerMethod(uint32 token, uint32 methodId, MessageBuffer buffer) final; + + protected: + // server methods -------------------------------------------------- + virtual uint32 HandleSubscribe(::bgs::protocol::club::v1::SubscribeRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleUnsubscribe(::bgs::protocol::club::v1::UnsubscribeRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleCreate(::bgs::protocol::club::v1::CreateRequest const* request, ::bgs::protocol::club::v1::CreateResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleDestroy(::bgs::protocol::club::v1::DestroyRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleGetDescription(::bgs::protocol::club::v1::GetDescriptionRequest const* request, ::bgs::protocol::club::v1::GetDescriptionResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleGetClubType(::bgs::protocol::club::v1::GetClubTypeRequest const* request, ::bgs::protocol::club::v1::GetClubTypeResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleUpdateClubState(::bgs::protocol::club::v1::UpdateClubStateRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleUpdateClubSettings(::bgs::protocol::club::v1::UpdateClubSettingsRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleJoin(::bgs::protocol::club::v1::JoinRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleLeave(::bgs::protocol::club::v1::LeaveRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleKick(::bgs::protocol::club::v1::KickRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleGetMember(::bgs::protocol::club::v1::GetMemberRequest const* request, ::bgs::protocol::club::v1::GetMemberResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleGetMembers(::bgs::protocol::club::v1::GetMembersRequest const* request, ::bgs::protocol::club::v1::GetMembersResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleUpdateMemberState(::bgs::protocol::club::v1::UpdateMemberStateRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleUpdateSubscriberState(::bgs::protocol::club::v1::UpdateSubscriberStateRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleAssignRole(::bgs::protocol::club::v1::AssignRoleRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleUnassignRole(::bgs::protocol::club::v1::UnassignRoleRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleSendInvitation(::bgs::protocol::club::v1::SendInvitationRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleAcceptInvitation(::bgs::protocol::club::v1::AcceptInvitationRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleDeclineInvitation(::bgs::protocol::club::v1::DeclineInvitationRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleRevokeInvitation(::bgs::protocol::club::v1::RevokeInvitationRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleGetInvitation(::bgs::protocol::club::v1::GetInvitationRequest const* request, ::bgs::protocol::club::v1::GetInvitationResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleGetInvitations(::bgs::protocol::club::v1::GetInvitationsRequest const* request, ::bgs::protocol::club::v1::GetInvitationsResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleSendSuggestion(::bgs::protocol::club::v1::SendSuggestionRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleAcceptSuggestion(::bgs::protocol::club::v1::AcceptSuggestionRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleDeclineSuggestion(::bgs::protocol::club::v1::DeclineSuggestionRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleGetSuggestion(::bgs::protocol::club::v1::GetSuggestionRequest const* request, ::bgs::protocol::club::v1::GetSuggestionResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleGetSuggestions(::bgs::protocol::club::v1::GetSuggestionsRequest const* request, ::bgs::protocol::club::v1::GetSuggestionsResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleCreateTicket(::bgs::protocol::club::v1::CreateTicketRequest const* request, ::bgs::protocol::club::v1::CreateTicketResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleDestroyTicket(::bgs::protocol::club::v1::DestroyTicketRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleRedeemTicket(::bgs::protocol::club::v1::RedeemTicketRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleGetTicket(::bgs::protocol::club::v1::GetTicketRequest const* request, ::bgs::protocol::club::v1::GetTicketResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleGetTickets(::bgs::protocol::club::v1::GetTicketsRequest const* request, ::bgs::protocol::club::v1::GetTicketsResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleAddBan(::bgs::protocol::club::v1::AddBanRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleRemoveBan(::bgs::protocol::club::v1::RemoveBanRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleGetBan(::bgs::protocol::club::v1::GetBanRequest const* request, ::bgs::protocol::club::v1::GetBanResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleGetBans(::bgs::protocol::club::v1::GetBansRequest const* request, ::bgs::protocol::club::v1::GetBansResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleSubscribeStream(::bgs::protocol::club::v1::SubscribeStreamRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleUnsubscribeStream(::bgs::protocol::club::v1::UnsubscribeStreamRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleCreateStream(::bgs::protocol::club::v1::CreateStreamRequest const* request, ::bgs::protocol::club::v1::CreateStreamResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleDestroyStream(::bgs::protocol::club::v1::DestroyStreamRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleGetStream(::bgs::protocol::club::v1::GetStreamRequest const* request, ::bgs::protocol::club::v1::GetStreamResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleGetStreams(::bgs::protocol::club::v1::GetStreamsRequest const* request, ::bgs::protocol::club::v1::GetStreamsResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleUpdateStreamState(::bgs::protocol::club::v1::UpdateStreamStateRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleSetStreamFocus(::bgs::protocol::club::v1::SetStreamFocusRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleGetStreamVoiceToken(::bgs::protocol::club::v1::GetStreamVoiceTokenRequest const* request, ::bgs::protocol::club::v1::GetStreamVoiceTokenResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleKickFromStreamVoice(::bgs::protocol::club::v1::KickFromStreamVoiceRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleCreateMessage(::bgs::protocol::club::v1::CreateMessageRequest const* request, ::bgs::protocol::club::v1::CreateMessageResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleDestroyMessage(::bgs::protocol::club::v1::DestroyMessageRequest const* request, ::bgs::protocol::club::v1::DestroyMessageResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleEditMessage(::bgs::protocol::club::v1::EditMessageRequest const* request, ::bgs::protocol::club::v1::EditMessageResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleSetMessagePinned(::bgs::protocol::club::v1::SetMessagePinnedRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleSetTypingIndicator(::bgs::protocol::club::v1::SetTypingIndicatorRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleAdvanceStreamViewTime(::bgs::protocol::club::v1::AdvanceStreamViewTimeRequest const* request, ::bgs::protocol::NoData* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleGetStreamHistory(::bgs::protocol::club::v1::GetStreamHistoryRequest const* request, ::bgs::protocol::club::v1::GetStreamHistoryResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + virtual uint32 HandleGetStreamMessage(::bgs::protocol::club::v1::GetStreamMessageRequest const* request, ::bgs::protocol::club::v1::GetStreamMessageResponse* response, std::function<void(ServiceBase*, uint32, ::google::protobuf::Message const*)>& continuation); + + private: + uint32 service_hash_; + + GOOGLE_DISALLOW_EVIL_CONSTRUCTORS(ClubService); +}; + +// =================================================================== + + +// =================================================================== + + +// @@protoc_insertion_point(namespace_scope) + +} // namespace v1 +} // namespace club +} // namespace protocol +} // namespace bgs + +#ifndef SWIG +namespace google { +namespace protobuf { + + +} // namespace google +} // namespace protobuf +#endif // SWIG + +// @@protoc_insertion_point(global_scope) + +#endif // PROTOBUF_club_5fservice_2eproto__INCLUDED diff --git a/src/server/proto/Client/club_service.proto b/src/server/proto/Client/club_service.proto new file mode 100644 index 00000000000..c1acbda088e --- /dev/null +++ b/src/server/proto/Client/club_service.proto @@ -0,0 +1,293 @@ +syntax = "proto2"; + +import "club_request.proto"; +package bgs.protocol.club.v1; + +option optimize_for = SPEED; +option cc_generic_services = false; + +service ClubService { + option (.bgs.protocol.service_options) = { + descriptor_name: "bnet.protocol.club.v1.ClubService" + shard_name: "club" + }; + option (.bgs.protocol.sdk_service_options) = { + outbound: true + use_client_id: true + }; + rpc Subscribe(.bgs.protocol.club.v1.SubscribeRequest) returns (.bgs.protocol.NoData) { + option (.bgs.protocol.method_options) = { + id: 1 + }; + } + rpc Unsubscribe(.bgs.protocol.club.v1.UnsubscribeRequest) returns (.bgs.protocol.NoData) { + option (.bgs.protocol.method_options) = { + id: 2 + }; + } + rpc Create(.bgs.protocol.club.v1.CreateRequest) returns (.bgs.protocol.club.v1.CreateResponse) { + option (.bgs.protocol.method_options) = { + id: 3 + }; + } + rpc Destroy(.bgs.protocol.club.v1.DestroyRequest) returns (.bgs.protocol.NoData) { + option (.bgs.protocol.method_options) = { + id: 4 + }; + } + rpc GetDescription(.bgs.protocol.club.v1.GetDescriptionRequest) returns (.bgs.protocol.club.v1.GetDescriptionResponse) { + option (.bgs.protocol.method_options) = { + id: 5 + }; + } + rpc GetClubType(.bgs.protocol.club.v1.GetClubTypeRequest) returns (.bgs.protocol.club.v1.GetClubTypeResponse) { + option (.bgs.protocol.method_options) = { + id: 6 + }; + } + rpc UpdateClubState(.bgs.protocol.club.v1.UpdateClubStateRequest) returns (.bgs.protocol.NoData) { + option (.bgs.protocol.method_options) = { + id: 7 + }; + } + rpc UpdateClubSettings(.bgs.protocol.club.v1.UpdateClubSettingsRequest) returns (.bgs.protocol.NoData) { + option (.bgs.protocol.method_options) = { + id: 8 + }; + } + rpc Join(.bgs.protocol.club.v1.JoinRequest) returns (.bgs.protocol.NoData) { + option (.bgs.protocol.method_options) = { + id: 30 + }; + } + rpc Leave(.bgs.protocol.club.v1.LeaveRequest) returns (.bgs.protocol.NoData) { + option (.bgs.protocol.method_options) = { + id: 31 + }; + } + rpc Kick(.bgs.protocol.club.v1.KickRequest) returns (.bgs.protocol.NoData) { + option (.bgs.protocol.method_options) = { + id: 32 + }; + } + rpc GetMember(.bgs.protocol.club.v1.GetMemberRequest) returns (.bgs.protocol.club.v1.GetMemberResponse) { + option (.bgs.protocol.method_options) = { + id: 33 + }; + } + rpc GetMembers(.bgs.protocol.club.v1.GetMembersRequest) returns (.bgs.protocol.club.v1.GetMembersResponse) { + option (.bgs.protocol.method_options) = { + id: 34 + }; + } + rpc UpdateMemberState(.bgs.protocol.club.v1.UpdateMemberStateRequest) returns (.bgs.protocol.NoData) { + option (.bgs.protocol.method_options) = { + id: 35 + }; + } + rpc UpdateSubscriberState(.bgs.protocol.club.v1.UpdateSubscriberStateRequest) returns (.bgs.protocol.NoData) { + option (.bgs.protocol.method_options) = { + id: 36 + }; + } + rpc AssignRole(.bgs.protocol.club.v1.AssignRoleRequest) returns (.bgs.protocol.NoData) { + option (.bgs.protocol.method_options) = { + id: 37 + }; + } + rpc UnassignRole(.bgs.protocol.club.v1.UnassignRoleRequest) returns (.bgs.protocol.NoData) { + option (.bgs.protocol.method_options) = { + id: 38 + }; + } + rpc SendInvitation(.bgs.protocol.club.v1.SendInvitationRequest) returns (.bgs.protocol.NoData) { + option (.bgs.protocol.method_options) = { + id: 50 + }; + } + rpc AcceptInvitation(.bgs.protocol.club.v1.AcceptInvitationRequest) returns (.bgs.protocol.NoData) { + option (.bgs.protocol.method_options) = { + id: 51 + }; + } + rpc DeclineInvitation(.bgs.protocol.club.v1.DeclineInvitationRequest) returns (.bgs.protocol.NoData) { + option (.bgs.protocol.method_options) = { + id: 52 + }; + } + rpc RevokeInvitation(.bgs.protocol.club.v1.RevokeInvitationRequest) returns (.bgs.protocol.NoData) { + option (.bgs.protocol.method_options) = { + id: 53 + }; + } + rpc GetInvitation(.bgs.protocol.club.v1.GetInvitationRequest) returns (.bgs.protocol.club.v1.GetInvitationResponse) { + option (.bgs.protocol.method_options) = { + id: 54 + }; + } + rpc GetInvitations(.bgs.protocol.club.v1.GetInvitationsRequest) returns (.bgs.protocol.club.v1.GetInvitationsResponse) { + option (.bgs.protocol.method_options) = { + id: 55 + }; + } + rpc SendSuggestion(.bgs.protocol.club.v1.SendSuggestionRequest) returns (.bgs.protocol.NoData) { + option (.bgs.protocol.method_options) = { + id: 60 + }; + } + rpc AcceptSuggestion(.bgs.protocol.club.v1.AcceptSuggestionRequest) returns (.bgs.protocol.NoData) { + option (.bgs.protocol.method_options) = { + id: 61 + }; + } + rpc DeclineSuggestion(.bgs.protocol.club.v1.DeclineSuggestionRequest) returns (.bgs.protocol.NoData) { + option (.bgs.protocol.method_options) = { + id: 62 + }; + } + rpc GetSuggestion(.bgs.protocol.club.v1.GetSuggestionRequest) returns (.bgs.protocol.club.v1.GetSuggestionResponse) { + option (.bgs.protocol.method_options) = { + id: 63 + }; + } + rpc GetSuggestions(.bgs.protocol.club.v1.GetSuggestionsRequest) returns (.bgs.protocol.club.v1.GetSuggestionsResponse) { + option (.bgs.protocol.method_options) = { + id: 64 + }; + } + rpc CreateTicket(.bgs.protocol.club.v1.CreateTicketRequest) returns (.bgs.protocol.club.v1.CreateTicketResponse) { + option (.bgs.protocol.method_options) = { + id: 70 + }; + } + rpc DestroyTicket(.bgs.protocol.club.v1.DestroyTicketRequest) returns (.bgs.protocol.NoData) { + option (.bgs.protocol.method_options) = { + id: 71 + }; + } + rpc RedeemTicket(.bgs.protocol.club.v1.RedeemTicketRequest) returns (.bgs.protocol.NoData) { + option (.bgs.protocol.method_options) = { + id: 72 + }; + } + rpc GetTicket(.bgs.protocol.club.v1.GetTicketRequest) returns (.bgs.protocol.club.v1.GetTicketResponse) { + option (.bgs.protocol.method_options) = { + id: 73 + }; + } + rpc GetTickets(.bgs.protocol.club.v1.GetTicketsRequest) returns (.bgs.protocol.club.v1.GetTicketsResponse) { + option (.bgs.protocol.method_options) = { + id: 74 + }; + } + rpc AddBan(.bgs.protocol.club.v1.AddBanRequest) returns (.bgs.protocol.NoData) { + option (.bgs.protocol.method_options) = { + id: 80 + }; + } + rpc RemoveBan(.bgs.protocol.club.v1.RemoveBanRequest) returns (.bgs.protocol.NoData) { + option (.bgs.protocol.method_options) = { + id: 81 + }; + } + rpc GetBan(.bgs.protocol.club.v1.GetBanRequest) returns (.bgs.protocol.club.v1.GetBanResponse) { + option (.bgs.protocol.method_options) = { + id: 82 + }; + } + rpc GetBans(.bgs.protocol.club.v1.GetBansRequest) returns (.bgs.protocol.club.v1.GetBansResponse) { + option (.bgs.protocol.method_options) = { + id: 83 + }; + } + rpc SubscribeStream(.bgs.protocol.club.v1.SubscribeStreamRequest) returns (.bgs.protocol.NoData) { + option (.bgs.protocol.method_options) = { + id: 100 + }; + } + rpc UnsubscribeStream(.bgs.protocol.club.v1.UnsubscribeStreamRequest) returns (.bgs.protocol.NoData) { + option (.bgs.protocol.method_options) = { + id: 101 + }; + } + rpc CreateStream(.bgs.protocol.club.v1.CreateStreamRequest) returns (.bgs.protocol.club.v1.CreateStreamResponse) { + option (.bgs.protocol.method_options) = { + id: 102 + }; + } + rpc DestroyStream(.bgs.protocol.club.v1.DestroyStreamRequest) returns (.bgs.protocol.NoData) { + option (.bgs.protocol.method_options) = { + id: 103 + }; + } + rpc GetStream(.bgs.protocol.club.v1.GetStreamRequest) returns (.bgs.protocol.club.v1.GetStreamResponse) { + option (.bgs.protocol.method_options) = { + id: 104 + }; + } + rpc GetStreams(.bgs.protocol.club.v1.GetStreamsRequest) returns (.bgs.protocol.club.v1.GetStreamsResponse) { + option (.bgs.protocol.method_options) = { + id: 105 + }; + } + rpc UpdateStreamState(.bgs.protocol.club.v1.UpdateStreamStateRequest) returns (.bgs.protocol.NoData) { + option (.bgs.protocol.method_options) = { + id: 106 + }; + } + rpc SetStreamFocus(.bgs.protocol.club.v1.SetStreamFocusRequest) returns (.bgs.protocol.NoData) { + option (.bgs.protocol.method_options) = { + id: 107 + }; + } + rpc GetStreamVoiceToken(.bgs.protocol.club.v1.GetStreamVoiceTokenRequest) returns (.bgs.protocol.club.v1.GetStreamVoiceTokenResponse) { + option (.bgs.protocol.method_options) = { + id: 108 + }; + } + rpc KickFromStreamVoice(.bgs.protocol.club.v1.KickFromStreamVoiceRequest) returns (.bgs.protocol.NoData) { + option (.bgs.protocol.method_options) = { + id: 109 + }; + } + rpc CreateMessage(.bgs.protocol.club.v1.CreateMessageRequest) returns (.bgs.protocol.club.v1.CreateMessageResponse) { + option (.bgs.protocol.method_options) = { + id: 150 + }; + } + rpc DestroyMessage(.bgs.protocol.club.v1.DestroyMessageRequest) returns (.bgs.protocol.club.v1.DestroyMessageResponse) { + option (.bgs.protocol.method_options) = { + id: 151 + }; + } + rpc EditMessage(.bgs.protocol.club.v1.EditMessageRequest) returns (.bgs.protocol.club.v1.EditMessageResponse) { + option (.bgs.protocol.method_options) = { + id: 152 + }; + } + rpc SetMessagePinned(.bgs.protocol.club.v1.SetMessagePinnedRequest) returns (.bgs.protocol.NoData) { + option (.bgs.protocol.method_options) = { + id: 153 + }; + } + rpc SetTypingIndicator(.bgs.protocol.club.v1.SetTypingIndicatorRequest) returns (.bgs.protocol.NoData) { + option (.bgs.protocol.method_options) = { + id: 154 + }; + } + rpc AdvanceStreamViewTime(.bgs.protocol.club.v1.AdvanceStreamViewTimeRequest) returns (.bgs.protocol.NoData) { + option (.bgs.protocol.method_options) = { + id: 155 + }; + } + rpc GetStreamHistory(.bgs.protocol.club.v1.GetStreamHistoryRequest) returns (.bgs.protocol.club.v1.GetStreamHistoryResponse) { + option (.bgs.protocol.method_options) = { + id: 156 + }; + } + rpc GetStreamMessage(.bgs.protocol.club.v1.GetStreamMessageRequest) returns (.bgs.protocol.club.v1.GetStreamMessageResponse) { + option (.bgs.protocol.method_options) = { + id: 157 + }; + } +} |