no message
This commit is contained in:
cpdl
201
windows/src/common/services/ChannelManager.cpp
Normal file
201
windows/src/common/services/ChannelManager.cpp
Normal file
@@ -0,0 +1,201 @@
|
||||
#include "ChannelManager.h"
|
||||
#include <libopenimsdk.h>
|
||||
#include "../NimResult.h"
|
||||
#include "../ZegoDataUtils.h"
|
||||
#include "ConstDefine.h"
|
||||
#include "Listen.h"
|
||||
|
||||
ChannelManagerService::ChannelManagerService() {
|
||||
m_serviceName = "channelManager";
|
||||
}
|
||||
|
||||
void ChannelManagerService::onMethodCalled(
|
||||
const std::string& method,
|
||||
const flutter::EncodableMap* arguments,
|
||||
std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result) {
|
||||
if (method == "setChannelListener") {
|
||||
setChannelListener(arguments, result);
|
||||
} else if (method == "getChannelMembersInfo") {
|
||||
getChannelMembersInfo(arguments, result);
|
||||
} else if (method == "getChannelMemberList") {
|
||||
getChannelMemberList(arguments, result);
|
||||
} else if (method == "getChannelsInfo") {
|
||||
getChannelsInfo(arguments, result);
|
||||
} else if (method == "joinChannel") {
|
||||
joinChannel(arguments, result);
|
||||
} else if (method == "quitChannel") {
|
||||
quitChannel(arguments, result);
|
||||
} else if (method == "changeChannelMute") {
|
||||
changeChannelMute(arguments, result);
|
||||
} else if (method == "changeChannelMemberMute") {
|
||||
changeChannelMemberMute(arguments, result);
|
||||
} else if (method == "isJoinChannel") {
|
||||
isJoinChannel(arguments, result);
|
||||
} else if (method == "getUsersInChannel") {
|
||||
getUsersInChannel(arguments, result);
|
||||
} else {
|
||||
result->NotImplemented();
|
||||
}
|
||||
}
|
||||
|
||||
void ChannelManagerService::setChannelListener(
|
||||
const flutter::EncodableMap* arguments,
|
||||
std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result) {
|
||||
if (arguments) {
|
||||
set_channel_listener(NewChannelListenCallBack());
|
||||
result->Success(flutter::EncodableValue());
|
||||
} else {
|
||||
result->Error("INVALID_ARGUMENT", "Arguments cannot be null");
|
||||
}
|
||||
}
|
||||
|
||||
void ChannelManagerService::getChannelMembersInfo(
|
||||
const flutter::EncodableMap* arguments,
|
||||
std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result) {
|
||||
if (arguments) {
|
||||
auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
|
||||
auto channelID = zego_value_get_string(arguments->at(flutter::EncodableValue("channelID")));
|
||||
auto userIDList = zego_value_get_string(arguments->at(flutter::EncodableValue("userIDList")));
|
||||
char* operationID_cs = const_cast<char*>(operationID.c_str());
|
||||
char* channelID_cs = const_cast<char*>(channelID.c_str());
|
||||
char* userIDList_cs = const_cast<char*>(userIDList.c_str());
|
||||
|
||||
get_specified_channel_members_info(NewBaseCallBack(result), operationID_cs, channelID_cs, userIDList_cs);
|
||||
} else {
|
||||
result->Error("INVALID_ARGUMENT", "Arguments cannot be null");
|
||||
}
|
||||
}
|
||||
|
||||
void ChannelManagerService::getChannelMemberList(
|
||||
const flutter::EncodableMap* arguments,
|
||||
std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result) {
|
||||
if (arguments) {
|
||||
auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
|
||||
auto channelID = zego_value_get_string(arguments->at(flutter::EncodableValue("channelID")));
|
||||
auto filter = zego_value_get_int(arguments->at(flutter::EncodableValue("filter")));
|
||||
auto offset = zego_value_get_int(arguments->at(flutter::EncodableValue("offset")));
|
||||
auto count = zego_value_get_int(arguments->at(flutter::EncodableValue("count")));
|
||||
char* operationID_cs = const_cast<char*>(operationID.c_str());
|
||||
char* channelID_cs = const_cast<char*>(channelID.c_str());
|
||||
|
||||
get_channel_member_list(NewBaseCallBack(result), operationID_cs, channelID_cs, filter, offset, count);
|
||||
} else {
|
||||
result->Error("INVALID_ARGUMENT", "Arguments cannot be null");
|
||||
}
|
||||
}
|
||||
|
||||
void ChannelManagerService::getChannelsInfo(
|
||||
const flutter::EncodableMap* arguments,
|
||||
std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result) {
|
||||
if (arguments) {
|
||||
auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
|
||||
auto channelIDList = zego_value_get_string(arguments->at(flutter::EncodableValue("channelIDList")));
|
||||
char* operationID_cs = const_cast<char*>(operationID.c_str());
|
||||
char* channelIDList_cs = const_cast<char*>(channelIDList.c_str());
|
||||
|
||||
get_specified_channels_info(NewBaseCallBack(result), operationID_cs, channelIDList_cs);
|
||||
} else {
|
||||
result->Error("INVALID_ARGUMENT", "Arguments cannot be null");
|
||||
}
|
||||
}
|
||||
|
||||
void ChannelManagerService::joinChannel(
|
||||
const flutter::EncodableMap* arguments,
|
||||
std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result) {
|
||||
if (arguments) {
|
||||
auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
|
||||
auto channelID = zego_value_get_string(arguments->at(flutter::EncodableValue("channelID")));
|
||||
auto reason = zego_value_get_string(arguments->at(flutter::EncodableValue("reason")));
|
||||
auto joinSource = zego_value_get_int(arguments->at(flutter::EncodableValue("joinSource")));
|
||||
auto ex = zego_value_get_string(arguments->at(flutter::EncodableValue("ex")));
|
||||
char* operationID_cs = const_cast<char*>(operationID.c_str());
|
||||
char* channelID_cs = const_cast<char*>(channelID.c_str());
|
||||
char* reason_cs = const_cast<char*>(reason.c_str());
|
||||
char* ex_cs = const_cast<char*>(ex.c_str());
|
||||
|
||||
join_channel(NewBaseCallBack(result), operationID_cs, channelID_cs, reason_cs, joinSource, ex_cs);
|
||||
} else {
|
||||
result->Error("INVALID_ARGUMENT", "Arguments cannot be null");
|
||||
}
|
||||
}
|
||||
|
||||
void ChannelManagerService::quitChannel(
|
||||
const flutter::EncodableMap* arguments,
|
||||
std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result) {
|
||||
if (arguments) {
|
||||
auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
|
||||
auto channelID = zego_value_get_string(arguments->at(flutter::EncodableValue("channelID")));
|
||||
char* operationID_cs = const_cast<char*>(operationID.c_str());
|
||||
char* channelID_cs = const_cast<char*>(channelID.c_str());
|
||||
|
||||
quit_channel(NewBaseCallBack(result), operationID_cs, channelID_cs);
|
||||
} else {
|
||||
result->Error("INVALID_ARGUMENT", "Arguments cannot be null");
|
||||
}
|
||||
}
|
||||
|
||||
void ChannelManagerService::changeChannelMute(
|
||||
const flutter::EncodableMap* arguments,
|
||||
std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result) {
|
||||
// if (arguments) {
|
||||
// auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
|
||||
// auto channelID = zego_value_get_string(arguments->at(flutter::EncodableValue("channelID")));
|
||||
// auto mute = zego_value_get_bool(arguments->at(flutter::EncodableValue("mute")));
|
||||
// char* operationID_cs = const_cast<char*>(operationID.c_str());
|
||||
// char* channelID_cs = const_cast<char*>(channelID.c_str());
|
||||
|
||||
// change_channel_mute(NewBaseCallBack(result), operationID_cs, channelID_cs, mute);
|
||||
// } else {
|
||||
// result->Error("INVALID_ARGUMENT", "Arguments cannot be null");
|
||||
// }
|
||||
}
|
||||
|
||||
void ChannelManagerService::changeChannelMemberMute(
|
||||
const flutter::EncodableMap* arguments,
|
||||
std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result) {
|
||||
// if (arguments) {
|
||||
// auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
|
||||
// auto channelID = zego_value_get_string(arguments->at(flutter::EncodableValue("channelID")));
|
||||
// auto userID = zego_value_get_string(arguments->at(flutter::EncodableValue("userID")));
|
||||
// auto seconds = zego_value_get_int(arguments->at(flutter::EncodableValue("seconds")));
|
||||
// char* operationID_cs = const_cast<char*>(operationID.c_str());
|
||||
// char* channelID_cs = const_cast<char*>(channelID.c_str());
|
||||
// char* userID_cs = const_cast<char*>(userID.c_str());
|
||||
|
||||
// change_channel_member_mute(NewBaseCallBack(result), operationID_cs, channelID_cs, userID_cs, seconds);
|
||||
// } else {
|
||||
// result->Error("INVALID_ARGUMENT", "Arguments cannot be null");
|
||||
// }
|
||||
}
|
||||
|
||||
void ChannelManagerService::isJoinChannel(
|
||||
const flutter::EncodableMap* arguments,
|
||||
std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result) {
|
||||
if (arguments) {
|
||||
auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
|
||||
auto channelID = zego_value_get_string(arguments->at(flutter::EncodableValue("channelID")));
|
||||
char* operationID_cs = const_cast<char*>(operationID.c_str());
|
||||
char* channelID_cs = const_cast<char*>(channelID.c_str());
|
||||
|
||||
is_join_channel(NewBaseCallBack(result), operationID_cs, channelID_cs);
|
||||
} else {
|
||||
result->Error("INVALID_ARGUMENT", "Arguments cannot be null");
|
||||
}
|
||||
}
|
||||
|
||||
void ChannelManagerService::getUsersInChannel(
|
||||
const flutter::EncodableMap* arguments,
|
||||
std::shared_ptr<flutter::MethodResult<flutter::EncodableValue>> result) {
|
||||
if (arguments) {
|
||||
auto operationID = zego_value_get_string(arguments->at(flutter::EncodableValue("operationID")));
|
||||
auto channelID = zego_value_get_string(arguments->at(flutter::EncodableValue("channelID")));
|
||||
auto userIDs = zego_value_get_string(arguments->at(flutter::EncodableValue("userIDs")));
|
||||
char* operationID_cs = const_cast<char*>(operationID.c_str());
|
||||
char* channelID_cs = const_cast<char*>(channelID.c_str());
|
||||
char* userIDs_cs = const_cast<char*>(userIDs.c_str());
|
||||
|
||||
get_users_in_channel(NewBaseCallBack(result), operationID_cs, channelID_cs, userIDs_cs);
|
||||
} else {
|
||||
result->Error("INVALID_ARGUMENT", "Arguments cannot be null");
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user