933 lines
44 KiB
Java
933 lines
44 KiB
Java
package cn.wildfirechat.sdk;
|
|
|
|
import cn.wildfirechat.common.ErrorCode;
|
|
import cn.wildfirechat.pojos.*;
|
|
import cn.wildfirechat.proto.ProtoConstants;
|
|
import cn.wildfirechat.sdk.model.IMResult;
|
|
import cn.wildfirechat.sdk.utilities.AdminHttpUtils;
|
|
import cn.wildfirechat.sdk.utilities.RobotHttpUtils;
|
|
import io.netty.util.internal.StringUtil;
|
|
|
|
|
|
import java.util.ArrayList;
|
|
import java.util.Arrays;
|
|
import java.util.Date;
|
|
import java.util.List;
|
|
|
|
import static cn.wildfirechat.proto.ProtoConstants.SystemSettingType.Group_Max_Member_Count;
|
|
|
|
public class Main {
|
|
public static void main(String[] args) throws Exception {
|
|
//admin使用的是18080端口，超级管理接口，理论上不能对外开放端口，也不能让非内部服务知悉密钥。
|
|
testAdmin();
|
|
|
|
//Robot和Channel都是使用的80端口，第三方可以创建或者为第三方创建，第三方可以使用robot或者channel与IM系统进行对接。
|
|
testRobot();
|
|
//testChannel();
|
|
}
|
|
|
|
|
|
static void testAdmin() throws Exception {
|
|
//初始化服务API
|
|
AdminHttpUtils.init("http://localhost:18080", "123456");
|
|
|
|
testUser();
|
|
testUserRelation();
|
|
testGroup();
|
|
testChatroom();
|
|
testMessage();
|
|
testGeneralApi();
|
|
testDevice();
|
|
|
|
System.out.println("Congratulation, all admin test case passed!!!!!!!");
|
|
}
|
|
|
|
//***********************************************
|
|
//**** 用户相关的API
|
|
//***********************************************
|
|
static void testUser() throws Exception {
|
|
InputOutputUserInfo userInfo = new InputOutputUserInfo();
|
|
userInfo.setUserId("userId1");
|
|
userInfo.setName("user1");
|
|
userInfo.setMobile("13900000000");
|
|
userInfo.setDisplayName("user 1");
|
|
|
|
IMResult<OutputCreateUser> resultCreateUser = UserAdmin.createUser(userInfo);
|
|
if (resultCreateUser != null && resultCreateUser.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("Create user " + resultCreateUser.getResult().getName() + " success");
|
|
} else {
|
|
System.out.println("Create user failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
InputCreateRobot createRobot = new InputCreateRobot();
|
|
createRobot.setUserId("robot1");
|
|
createRobot.setName("robot1");
|
|
createRobot.setDisplayName("机器人");
|
|
createRobot.setOwner("userId1");
|
|
createRobot.setSecret("123456");
|
|
createRobot.setCallback("http://127.0.0.1:8883/robot/recvmsg");
|
|
IMResult<OutputCreateRobot> resultCreateRobot = UserAdmin.createRobot(createRobot);
|
|
if (resultCreateRobot != null && resultCreateRobot.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("Create robot " + resultCreateRobot.getResult().getUserId() + " success");
|
|
} else {
|
|
System.out.println("Create robot failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
|
|
|
|
IMResult<InputOutputUserInfo> resultGetUserInfo1 = UserAdmin.getUserByName(userInfo.getName());
|
|
if (resultGetUserInfo1 != null && resultGetUserInfo1.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
if (userInfo.getUserId().equals(resultGetUserInfo1.getResult().getUserId())
|
|
&& userInfo.getName().equals(resultGetUserInfo1.getResult().getName())
|
|
&& userInfo.getMobile().equals(resultGetUserInfo1.getResult().getMobile())
|
|
&& userInfo.getDisplayName().equals(resultGetUserInfo1.getResult().getDisplayName())) {
|
|
System.out.println("get user info success");
|
|
} else {
|
|
System.out.println("get user info by name failure");
|
|
System.exit(-1);
|
|
}
|
|
} else {
|
|
System.out.println("get user info by name failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
IMResult<InputOutputUserInfo> resultGetUserInfo2 = UserAdmin.getUserByMobile(userInfo.getMobile());
|
|
if (resultGetUserInfo2 != null && resultGetUserInfo2.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
if (userInfo.getUserId().equals(resultGetUserInfo2.getResult().getUserId())
|
|
&& userInfo.getName().equals(resultGetUserInfo2.getResult().getName())
|
|
&& userInfo.getMobile().equals(resultGetUserInfo2.getResult().getMobile())
|
|
&& userInfo.getDisplayName().equals(resultGetUserInfo2.getResult().getDisplayName())) {
|
|
System.out.println("get user info success");
|
|
} else {
|
|
System.out.println("get user info by mobile failure");
|
|
System.exit(-1);
|
|
}
|
|
} else {
|
|
System.out.println("get user info by mobile failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
IMResult<InputOutputUserInfo> resultGetUserInfo3 = UserAdmin.getUserByUserId(userInfo.getUserId());
|
|
if (resultGetUserInfo3 != null && resultGetUserInfo3.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
if (userInfo.getUserId().equals(resultGetUserInfo3.getResult().getUserId())
|
|
&& userInfo.getName().equals(resultGetUserInfo3.getResult().getName())
|
|
&& userInfo.getMobile().equals(resultGetUserInfo3.getResult().getMobile())
|
|
&& userInfo.getDisplayName().equals(resultGetUserInfo3.getResult().getDisplayName())) {
|
|
System.out.println("get user info success");
|
|
} else {
|
|
System.out.println("get user info by userId failure");
|
|
System.exit(-1);
|
|
}
|
|
} else {
|
|
System.out.println("get user info by userId failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
IMResult<OutputGetIMTokenData> resultGetToken = UserAdmin.getUserToken(userInfo.getUserId(), "client111", ProtoConstants.Platform.Platform_Android);
|
|
if (resultGetToken != null && resultGetToken.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("get token success: " + resultGetToken.getResult().getToken());
|
|
} else {
|
|
System.out.println("get user token failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
IMResult<Void> resultVoid =UserAdmin.updateUserBlockStatus(userInfo.getUserId(), 2);
|
|
if (resultVoid != null && resultVoid.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("block user done");
|
|
} else {
|
|
System.out.println("block user failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
IMResult<OutputUserStatus> resultCheckUserStatus = UserAdmin.checkUserBlockStatus(userInfo.getUserId());
|
|
if (resultCheckUserStatus != null && resultCheckUserStatus.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
if (resultCheckUserStatus.getResult().getStatus() == 2) {
|
|
System.out.println("check user status success");
|
|
} else {
|
|
System.out.println("user status not correct");
|
|
System.exit(-1);
|
|
}
|
|
} else {
|
|
System.out.println("block user failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
IMResult<OutputUserBlockStatusList> resultBlockStatusList = UserAdmin.getBlockedList();
|
|
if (resultBlockStatusList != null && resultBlockStatusList.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
boolean success = false;
|
|
for (InputOutputUserBlockStatus blockStatus : resultBlockStatusList.getResult().getStatusList()) {
|
|
if (blockStatus.getUserId().equals(userInfo.getUserId()) && blockStatus.getStatus() == 2) {
|
|
System.out.println("get block list done");
|
|
success = true;
|
|
break;
|
|
}
|
|
}
|
|
if (!success) {
|
|
System.out.println("block user status is not expected");
|
|
System.exit(-1);
|
|
}
|
|
} else {
|
|
System.out.println("block user failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
resultVoid =UserAdmin.updateUserBlockStatus(userInfo.getUserId(), 0);
|
|
if (resultVoid != null && resultVoid.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("block user done");
|
|
} else {
|
|
System.out.println("block user failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
resultCheckUserStatus = UserAdmin.checkUserBlockStatus(userInfo.getUserId());
|
|
if (resultCheckUserStatus != null && resultCheckUserStatus.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
if (resultCheckUserStatus.getResult().getStatus() == 0) {
|
|
System.out.println("check user status success");
|
|
} else {
|
|
System.out.println("user status not correct");
|
|
System.exit(-1);
|
|
}
|
|
} else {
|
|
System.out.println("block user failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
IMResult<OutputCheckUserOnline> outputCheckUserOnline = UserAdmin.checkUserOnlineStatus(userInfo.getUserId());
|
|
if (outputCheckUserOnline != null && outputCheckUserOnline.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("check user online status success:" + outputCheckUserOnline.getResult().getSessions().size());
|
|
} else {
|
|
System.out.println("block user online failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
//慎用，这个方法可能功能不完全，如果用户不在需要，建议使用block功能屏蔽用户
|
|
IMResult<Void> voidIMResult = UserAdmin.destroyUser("user11");
|
|
if (voidIMResult != null && voidIMResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("destroy user success");
|
|
} else {
|
|
System.out.println("destroy user failure");
|
|
System.exit(-1);
|
|
}
|
|
}
|
|
|
|
//***********************************************
|
|
//**** 用户关系相关的API
|
|
//***********************************************
|
|
static void testUserRelation() throws Exception {
|
|
|
|
//先创建2个用户
|
|
InputOutputUserInfo userInfo = new InputOutputUserInfo();
|
|
userInfo.setUserId("ff1");
|
|
userInfo.setName("ff1");
|
|
userInfo.setMobile("13800000000");
|
|
userInfo.setDisplayName("ff1");
|
|
|
|
IMResult<OutputCreateUser> resultCreateUser = UserAdmin.createUser(userInfo);
|
|
if (resultCreateUser != null && resultCreateUser.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("Create user " + resultCreateUser.getResult().getName() + " success");
|
|
} else {
|
|
System.out.println("Create user failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
userInfo = new InputOutputUserInfo();
|
|
userInfo.setUserId("ff2");
|
|
userInfo.setName("ff2");
|
|
userInfo.setMobile("13800000001");
|
|
userInfo.setDisplayName("ff2");
|
|
|
|
resultCreateUser = UserAdmin.createUser(userInfo);
|
|
if (resultCreateUser != null && resultCreateUser.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("Create user " + resultCreateUser.getResult().getName() + " success");
|
|
} else {
|
|
System.out.println("Create user failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
IMResult<Void> updateFriendStatusResult = RelationAdmin.setUserFriend("ff1", "ff2", true, "{\"from\":1}");
|
|
if (updateFriendStatusResult != null && updateFriendStatusResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("update friend status success");
|
|
} else {
|
|
System.out.println("update friend status failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
IMResult<OutputStringList> resultGetFriendList = RelationAdmin.getFriendList("ff1");
|
|
if (resultGetFriendList != null && resultGetFriendList.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS && resultGetFriendList.getResult().getList().contains("ff2")) {
|
|
System.out.println("get friend status success");
|
|
} else {
|
|
System.out.println("get friend status failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
IMResult<Void> updateBlacklistStatusResult = RelationAdmin.setUserBlacklist("ff1", "ff2", true);
|
|
if (updateBlacklistStatusResult != null && updateBlacklistStatusResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("update blacklist status success");
|
|
} else {
|
|
System.out.println("update blacklist status failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
resultGetFriendList = RelationAdmin.getUserBlacklist("ff1");
|
|
if (resultGetFriendList != null && resultGetFriendList.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS && resultGetFriendList.getResult().getList().contains("ff2")) {
|
|
System.out.println("get blacklist status success");
|
|
} else {
|
|
System.out.println("get blacklist status failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
String alias = "hello" + System.currentTimeMillis();
|
|
IMResult<Void> updateFriendAlias = RelationAdmin.updateFriendAlias("ff1", "ff2", alias);
|
|
if (updateFriendAlias != null && updateFriendAlias.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("update friend status success");
|
|
} else {
|
|
System.out.println("update friend status failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
IMResult<OutputGetAlias> getFriendAlias = RelationAdmin.getFriendAlias("ff1", "ff2");
|
|
if (getFriendAlias != null && getFriendAlias.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS && getFriendAlias.getResult().getAlias().equals(alias)) {
|
|
System.out.println("update friend status success");
|
|
} else {
|
|
System.out.println("update friend status failure");
|
|
System.exit(-1);
|
|
}
|
|
}
|
|
//***********************************************
|
|
//**** 群组相关功能
|
|
//***********************************************
|
|
static void testGroup() throws Exception {
|
|
|
|
IMResult<Void> voidIMResult1 = GroupAdmin.dismissGroup("user1", "groupId1", null, null);
|
|
|
|
PojoGroupInfo groupInfo = new PojoGroupInfo();
|
|
groupInfo.setTarget_id("groupId1");
|
|
groupInfo.setOwner("user1");
|
|
groupInfo.setName("test_group");
|
|
groupInfo.setExtra("hello extra");
|
|
groupInfo.setPortrait("http://portrait");
|
|
List<PojoGroupMember> members = new ArrayList<>();
|
|
PojoGroupMember member1 = new PojoGroupMember();
|
|
member1.setMember_id(groupInfo.getOwner());
|
|
members.add(member1);
|
|
|
|
PojoGroupMember member2 = new PojoGroupMember();
|
|
member2.setMember_id("user2");
|
|
members.add(member2);
|
|
|
|
PojoGroupMember member3 = new PojoGroupMember();
|
|
member3.setMember_id("user3");
|
|
members.add(member3);
|
|
|
|
IMResult<OutputCreateGroupResult> resultCreateGroup = GroupAdmin.createGroup(groupInfo.getOwner(), groupInfo, members, null, null);
|
|
if (resultCreateGroup != null && resultCreateGroup.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("create group success");
|
|
} else {
|
|
System.out.println("create group failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
IMResult<PojoGroupInfo> resultGetGroupInfo = GroupAdmin.getGroupInfo(groupInfo.getTarget_id());
|
|
if (resultGetGroupInfo != null && resultGetGroupInfo.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
if (groupInfo.getExtra().equals(resultGetGroupInfo.getResult().getExtra())
|
|
&& groupInfo.getName().equals(resultGetGroupInfo.getResult().getName())
|
|
&& groupInfo.getOwner().equals(resultGetGroupInfo.getResult().getOwner())) {
|
|
System.out.println("get group success");
|
|
} else {
|
|
System.out.println("group info is not expected");
|
|
System.exit(-1);
|
|
}
|
|
} else {
|
|
System.out.println("create group failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
IMResult<Void> voidIMResult = GroupAdmin.transferGroup(groupInfo.getOwner(), groupInfo.getTarget_id(), "user2", null, null);
|
|
if (voidIMResult != null && voidIMResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("transfer success");
|
|
} else {
|
|
System.out.println("create group failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
voidIMResult = GroupAdmin.modifyGroupInfo(groupInfo.getOwner(), groupInfo.getTarget_id(), ProtoConstants.ModifyGroupInfoType.Modify_Group_Name,"HelloWorld", null, null);
|
|
if (voidIMResult != null && voidIMResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("transfer success");
|
|
} else {
|
|
System.out.println("create group failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
|
|
resultGetGroupInfo = GroupAdmin.getGroupInfo(groupInfo.getTarget_id());
|
|
if (resultGetGroupInfo != null && resultGetGroupInfo.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
if ("user2".equals(resultGetGroupInfo.getResult().getOwner())) {
|
|
groupInfo.setOwner("user2");
|
|
} else {
|
|
System.out.println("group info is not expected");
|
|
System.exit(-1);
|
|
}
|
|
} else {
|
|
System.out.println("create group failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
IMResult<OutputGroupMemberList> resultGetMembers = GroupAdmin.getGroupMembers(groupInfo.getTarget_id());
|
|
if (resultGetMembers != null && resultGetMembers.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("get group member success");
|
|
} else {
|
|
System.out.println("create group failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
voidIMResult = GroupAdmin.addGroupMembers("user1", groupInfo.getTarget_id(), Arrays.asList("use4", "user5"), null, null);
|
|
if (voidIMResult != null && voidIMResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("add group member success");
|
|
} else {
|
|
System.out.println("add group member failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
voidIMResult = GroupAdmin.kickoffGroupMembers("user1", groupInfo.getTarget_id(), Arrays.asList("user3"), null, null);
|
|
if (voidIMResult != null && voidIMResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("kickoff group member success");
|
|
} else {
|
|
System.out.println("kickoff group member failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
voidIMResult = GroupAdmin.setGroupManager("user1", groupInfo.getTarget_id(), Arrays.asList("user4", "user5"), true, null, null);
|
|
if (voidIMResult != null && voidIMResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("set group manager success");
|
|
} else {
|
|
System.out.println("set group manager failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
voidIMResult = GroupAdmin.setGroupManager("user1", groupInfo.getTarget_id(), Arrays.asList("user4", "user5"), false, null, null);
|
|
if (voidIMResult != null && voidIMResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("cancel group manager success");
|
|
} else {
|
|
System.out.println("cancel group manager failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
voidIMResult = GroupAdmin.muteGroupMemeber("user1", groupInfo.getTarget_id(), Arrays.asList("user4", "user5"), true, null, null);
|
|
if (voidIMResult != null && voidIMResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("mute group member success");
|
|
} else {
|
|
System.out.println("mute group member failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
voidIMResult = GroupAdmin.muteGroupMemeber("user1", groupInfo.getTarget_id(), Arrays.asList("user4", "user5"), false, null, null);
|
|
if (voidIMResult != null && voidIMResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("unmute group member success");
|
|
} else {
|
|
System.out.println("unmute group member failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
|
|
|
|
voidIMResult = GroupAdmin.quitGroup("user4", groupInfo.getTarget_id(), null, null);
|
|
if (voidIMResult != null && voidIMResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("quit group success");
|
|
} else {
|
|
System.out.println("quit group failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
IMResult<OutputGroupIds> groupIdsIMResult = GroupAdmin.getUserGroups("user1");
|
|
if (groupIdsIMResult != null && groupIdsIMResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
if (groupIdsIMResult.getResult().getGroupIds().contains(groupInfo.getTarget_id())) {
|
|
System.out.println("get user groups success");
|
|
} else {
|
|
System.out.println("get user groups failure");
|
|
System.exit(-1);
|
|
}
|
|
} else {
|
|
System.out.println("get user groups failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
}
|
|
|
|
//***********************************************
|
|
//**** 消息相关功能
|
|
//***********************************************
|
|
static void testMessage() throws Exception {
|
|
Conversation conversation = new Conversation();
|
|
conversation.setTarget("user2");
|
|
conversation.setType(ProtoConstants.ConversationType.ConversationType_Private);
|
|
MessagePayload payload = new MessagePayload();
|
|
payload.setType(1);
|
|
payload.setSearchableContent("hello world");
|
|
|
|
IMResult<SendMessageResult> resultSendMessage = MessageAdmin.sendMessage("user1", conversation, payload);
|
|
if (resultSendMessage != null && resultSendMessage.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("send message success");
|
|
} else {
|
|
System.out.println("send message failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
|
|
IMResult<Void> voidIMResult = MessageAdmin.recallMessage("user1", resultSendMessage.getResult().getMessageUid());
|
|
if (voidIMResult != null && voidIMResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("recall message success");
|
|
} else {
|
|
System.out.println("recall message failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
voidIMResult = MessageAdmin.deleteMessage(resultSendMessage.getResult().getMessageUid());
|
|
if (voidIMResult != null && voidIMResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("delete message success");
|
|
} else {
|
|
System.out.println("delete message failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
IMResult<BroadMessageResult> resultBroadcastMessage = MessageAdmin.broadcastMessage("user1", 0, payload);
|
|
if (resultBroadcastMessage != null && resultBroadcastMessage.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("broad message success, send message to " + resultBroadcastMessage.getResult().getCount() + " users");
|
|
} else {
|
|
System.out.println("broad message failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
List<String> multicastReceivers = Arrays.asList("user2", "user3", "user4");
|
|
IMResult<MultiMessageResult> resultMulticastMessage = MessageAdmin.multicastMessage("user1", multicastReceivers, 0, payload);
|
|
if (resultMulticastMessage != null && resultMulticastMessage.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("multi message success, messageid is " + resultMulticastMessage.getResult().getMessageUid());
|
|
} else {
|
|
System.out.println("multi message failure");
|
|
System.exit(-1);
|
|
}
|
|
}
|
|
|
|
//***********************************************
|
|
//**** 一些其它的功能，比如创建频道，更新用户设置等
|
|
//***********************************************
|
|
static void testGeneralApi() throws Exception {
|
|
IMResult<SystemSettingPojo> resultGetSystemSetting = GeneralAdmin.getSystemSetting(Group_Max_Member_Count);
|
|
if (resultGetSystemSetting != null && resultGetSystemSetting.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("success");
|
|
} else {
|
|
System.out.println("get system setting failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
IMResult<Void> resultSetSystemSetting = GeneralAdmin.setSystemSetting(Group_Max_Member_Count, "2000", "最大群人数为2000");
|
|
if (resultSetSystemSetting != null && resultSetSystemSetting.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("success");
|
|
} else {
|
|
System.out.println("get system setting failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
resultGetSystemSetting = GeneralAdmin.getSystemSetting(Group_Max_Member_Count);
|
|
if (resultGetSystemSetting != null && resultGetSystemSetting.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS && resultGetSystemSetting.getResult().value.equals("2000")) {
|
|
System.out.println("success");
|
|
} else {
|
|
System.out.println("get system setting failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
InputCreateChannel inputCreateChannel = new InputCreateChannel();
|
|
inputCreateChannel.setName("MyChannel");
|
|
inputCreateChannel.setOwner("user1");
|
|
IMResult<OutputCreateChannel> resultCreateChannel = GeneralAdmin.createChannel(inputCreateChannel);
|
|
if (resultCreateChannel != null && resultCreateChannel.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("success");
|
|
} else {
|
|
System.out.println("create channel failure");
|
|
System.exit(-1);
|
|
}
|
|
}
|
|
static void testChatroom() throws Exception {
|
|
|
|
String chatroomId = "chatroomId1";
|
|
String chatroomTitle = "TESTCHATROM";
|
|
String chatroomDesc = "this is a test chatroom";
|
|
String chatroomPortrait = "http://pic.com/test123.png";
|
|
String chatroomExtra = "{\'managers:[\"user1\",\"user2\"]}";
|
|
IMResult<OutputCreateChatroom> chatroomIMResult = ChatroomAdmin.createChatroom(chatroomId,chatroomTitle, chatroomDesc, chatroomPortrait,chatroomExtra,ProtoConstants.ChatroomState.Chatroom_State_Normal);
|
|
if (chatroomIMResult != null && chatroomIMResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS && chatroomIMResult.getResult().getChatroomId().equals(chatroomId)) {
|
|
System.out.println("create chatroom success");
|
|
} else {
|
|
System.out.println("create chatroom failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
IMResult<OutputGetChatroomInfo> getChatroomInfoIMResult = ChatroomAdmin.getChatroomInfo(chatroomId);
|
|
if (getChatroomInfoIMResult != null && getChatroomInfoIMResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
if (!getChatroomInfoIMResult.getResult().getChatroomId().equals(chatroomId)
|
|
|| !getChatroomInfoIMResult.getResult().getTitle().equals(chatroomTitle)
|
|
|| !getChatroomInfoIMResult.getResult().getDesc().equals(chatroomDesc)
|
|
|| !getChatroomInfoIMResult.getResult().getPortrait().equals(chatroomPortrait)
|
|
|| !getChatroomInfoIMResult.getResult().getExtra().equals(chatroomExtra)
|
|
|| getChatroomInfoIMResult.getResult().getState() != ProtoConstants.ChatroomState.Chatroom_State_Normal) {
|
|
System.out.println("chatroom info incorrect");
|
|
System.exit(-1);
|
|
} else {
|
|
System.out.println("chatroom info incorrect");
|
|
}
|
|
} else {
|
|
System.out.println("get chatroom info failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
IMResult<OutputStringList> memberList = ChatroomAdmin.getChatroomMembers(chatroomId);
|
|
if (memberList != null && memberList.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("get chatroom member success");
|
|
} else {
|
|
System.out.println("get chatroom member failure: " + memberList.getErrorCode().msg);
|
|
}
|
|
|
|
IMResult<Void> voidIMResult = ChatroomAdmin.destroyChatroom(chatroomId);
|
|
if (voidIMResult != null && voidIMResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("destroy chatroom done!");
|
|
} else {
|
|
System.out.println("destroy chatroom failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
getChatroomInfoIMResult = ChatroomAdmin.getChatroomInfo(chatroomId);
|
|
if (getChatroomInfoIMResult != null && getChatroomInfoIMResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS && getChatroomInfoIMResult.getResult().getState() == ProtoConstants.ChatroomState.Chatroom_State_End) {
|
|
System.out.println("chatroom destroyed!");
|
|
} else {
|
|
System.out.println("chatroom not destroyed!");
|
|
System.exit(-1);
|
|
}
|
|
|
|
//下面仅专业版支持
|
|
/*
|
|
//设置用户聊天室黑名单。0正常；1禁言；2禁止加入。
|
|
IMResult<Void> voidIMResult1 = ChatroomAdmin.setChatroomBlacklist("chatroom1", "oto9o9__", 1);
|
|
if (voidIMResult1 != null && voidIMResult1.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("add chatroom black success");
|
|
} else {
|
|
System.out.println("add chatroom black failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
//获取聊天室黑名单
|
|
IMResult<OutputChatroomBlackInfos> blackInfos = ChatroomAdmin.getChatroomBlacklist("chatroom1");
|
|
if (blackInfos != null && blackInfos.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS && !blackInfos.getResult().infos.isEmpty()) {
|
|
boolean success = false;
|
|
for (OutputChatroomBlackInfos.OutputChatroomBlackInfo info : blackInfos.getResult().infos) {
|
|
if (info.userId.equals("oto9o9__")) {
|
|
success = true;
|
|
break;
|
|
}
|
|
}
|
|
if (success) {
|
|
System.out.println("add chatroom black success");
|
|
} else {
|
|
System.out.println("add chatroom black failure");
|
|
System.exit(-1);
|
|
}
|
|
} else {
|
|
System.out.println("add chatroom black failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
//取消用户聊天室黑名单。0正常；1禁言；2禁止加入。
|
|
voidIMResult1 = ChatroomAdmin.setChatroomBlacklist("chatroom1", "oto9o9__", 0);
|
|
if (voidIMResult1 != null && voidIMResult1.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("remove chatroom black success");
|
|
} else {
|
|
System.out.println("remove chatroom black failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
//获取聊天室黑名单
|
|
blackInfos = ChatroomAdmin.getChatroomBlacklist("chatroom1");
|
|
if (blackInfos != null && blackInfos.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
boolean success = true;
|
|
for (OutputChatroomBlackInfos.OutputChatroomBlackInfo info : blackInfos.getResult().infos) {
|
|
if (info.userId.equals("oto9o9__")) {
|
|
success = false;
|
|
break;
|
|
}
|
|
}
|
|
if (success) {
|
|
System.out.println("remove chatroom black success");
|
|
} else {
|
|
System.out.println("remove chatroom black failure");
|
|
System.exit(-1);
|
|
}
|
|
} else {
|
|
System.out.println("remove chatroom black failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
//设置聊天室管理员
|
|
IMResult<Void> voidIMResult2 = ChatroomAdmin.setChatroomManager("chatroom1", "UserId1", 1);
|
|
if (voidIMResult2 != null && voidIMResult2.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("add chatroom manager success");
|
|
} else {
|
|
System.out.println("add chatroom black failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
//获取聊天室管理员
|
|
IMResult<OutputStringList> managers = ChatroomAdmin.getChatroomManagerList("chatroom1");
|
|
if (managers != null && managers.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS && !managers.getResult().getList().isEmpty() && managers.getResult().getList().contains("UserId1")) {
|
|
System.out.println("add chatroom black success");
|
|
} else {
|
|
System.out.println("add chatroom black failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
//取消聊天室管理员
|
|
IMResult<Void> voidIMResult3 = ChatroomAdmin.setChatroomManager("chatroom1", "UserId1", 0);
|
|
if (voidIMResult3 != null && voidIMResult3.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("add chatroom manager success");
|
|
} else {
|
|
System.out.println("add chatroom black failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
//获取聊天室管理员
|
|
IMResult<OutputStringList> managers2 = ChatroomAdmin.getChatroomManagerList("chatroom1");
|
|
if (managers2 != null && managers2.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS && !managers2.getResult().getList().contains("UserId1")) {
|
|
System.out.println("add chatroom black success");
|
|
} else {
|
|
System.out.println("add chatroom black failure");
|
|
System.exit(-1);
|
|
}*/
|
|
|
|
}
|
|
|
|
static void testRobot() throws Exception {
|
|
//初始化机器人API
|
|
RobotHttpUtils.init("http://localhost", "robot1", "123456");
|
|
//***********************************************
|
|
//**** 机器人API
|
|
//***********************************************
|
|
Conversation conversation = new Conversation();
|
|
conversation.setTarget("user2");
|
|
conversation.setType(ProtoConstants.ConversationType.ConversationType_Private);
|
|
MessagePayload payload = new MessagePayload();
|
|
payload.setType(1);
|
|
payload.setSearchableContent("hello world");
|
|
|
|
IMResult<SendMessageResult> resultRobotSendMessage = RobotService.sendMessage("robot1", conversation, payload);
|
|
if (resultRobotSendMessage != null && resultRobotSendMessage.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("robot send message success");
|
|
} else {
|
|
System.out.println("robot send message failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
IMResult<InputOutputUserInfo> resultRobotGetUserInfo = RobotService.getUserInfo("userId1");
|
|
if (resultRobotGetUserInfo != null && resultRobotGetUserInfo.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("robot get user info success");
|
|
} else {
|
|
System.out.println("robot get user info by userId failure");
|
|
System.exit(-1);
|
|
}
|
|
}
|
|
|
|
//***测试频道API功能，仅专业版支持***
|
|
static void testChannel() throws Exception {
|
|
//初始化服务API
|
|
AdminHttpUtils.init("http://localhost:18080", "123456");
|
|
|
|
//先创建3个用户
|
|
InputOutputUserInfo userInfo = new InputOutputUserInfo();
|
|
userInfo.setUserId("userId1");
|
|
userInfo.setName("user1");
|
|
userInfo.setMobile("13900000000");
|
|
userInfo.setDisplayName("user 1");
|
|
|
|
IMResult<OutputCreateUser> resultCreateUser = UserAdmin.createUser(userInfo);
|
|
if (resultCreateUser != null && resultCreateUser.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("Create user " + resultCreateUser.getResult().getName() + " success");
|
|
} else {
|
|
System.out.println("Create user failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
userInfo = new InputOutputUserInfo();
|
|
userInfo.setUserId("userId2");
|
|
userInfo.setName("user2");
|
|
userInfo.setMobile("13900000002");
|
|
userInfo.setDisplayName("user 2");
|
|
|
|
resultCreateUser = UserAdmin.createUser(userInfo);
|
|
if (resultCreateUser != null && resultCreateUser.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("Create user " + resultCreateUser.getResult().getName() + " success");
|
|
} else {
|
|
System.out.println("Create user failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
userInfo = new InputOutputUserInfo();
|
|
userInfo.setUserId("userId3");
|
|
userInfo.setName("user3");
|
|
userInfo.setMobile("13900000003");
|
|
userInfo.setDisplayName("user 3");
|
|
|
|
resultCreateUser = UserAdmin.createUser(userInfo);
|
|
if (resultCreateUser != null && resultCreateUser.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("Create user " + resultCreateUser.getResult().getName() + " success");
|
|
} else {
|
|
System.out.println("Create user failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
//1. 先使用admin api创建频道
|
|
InputCreateChannel inputCreateChannel = new InputCreateChannel();
|
|
inputCreateChannel.setName("testChannel");
|
|
inputCreateChannel.setOwner("userId1");
|
|
IMResult<OutputCreateChannel> resultCreateChannel = GeneralAdmin.createChannel(inputCreateChannel);
|
|
if (resultCreateChannel != null && resultCreateChannel.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("create channel success");
|
|
} else {
|
|
System.out.println("create channel failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
//2. 初始化api
|
|
ChannelServiceApi channelServiceApi = new ChannelServiceApi("http://localhost", resultCreateChannel.getResult().getTargetId(), resultCreateChannel.getResult().getSecret());
|
|
|
|
//3. 测试channel api功能
|
|
IMResult<Void> resultVoid = channelServiceApi.subscribe("userId2");
|
|
if (resultVoid != null && resultVoid.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("subscribe success");
|
|
} else {
|
|
System.out.println("subscribe failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
resultVoid = channelServiceApi.subscribe("userId3");
|
|
if (resultVoid != null && resultVoid.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("subscribe done");
|
|
} else {
|
|
System.out.println("subscribe failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
IMResult<OutputStringList> resultStringList = channelServiceApi.getSubscriberList();
|
|
if (resultStringList != null && resultStringList.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS && resultStringList.getResult().getList().contains("userId2") && resultStringList.getResult().getList().contains("userId3")) {
|
|
System.out.println("get subscriber done");
|
|
} else {
|
|
System.out.println("get subscriber failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
resultVoid = channelServiceApi.unsubscribe("userId2");
|
|
if (resultVoid != null && resultVoid.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("unsubscriber done");
|
|
} else {
|
|
System.out.println("unsubscriber failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
resultStringList = channelServiceApi.getSubscriberList();
|
|
if (resultStringList != null && resultStringList.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS && resultStringList.getResult().getList().contains("userId3") && !resultStringList.getResult().getList().contains("userId2")) {
|
|
System.out.println("get subscriber done");
|
|
} else {
|
|
System.out.println("get subscriber failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
IMResult<InputOutputUserInfo> resultGetUserInfo1 = channelServiceApi.getUserInfo("userId3");
|
|
if (resultGetUserInfo1 != null && resultGetUserInfo1.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("get user info success");
|
|
} else {
|
|
System.out.println("get user info failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
|
|
MessagePayload payload = new MessagePayload();
|
|
payload.setType(1);
|
|
payload.setSearchableContent("hello world");
|
|
|
|
IMResult<SendMessageResult> resultSendMessage = channelServiceApi.sendMessage(0, null,payload);
|
|
if (resultSendMessage != null && resultSendMessage.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("send message to all the subscriber success");
|
|
} else {
|
|
System.out.println("send message to all the subscriber failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
payload.setSearchableContent("hello to user2");
|
|
|
|
resultSendMessage = channelServiceApi.sendMessage(0, Arrays.asList("userId2"),payload);
|
|
if (resultSendMessage != null && resultSendMessage.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("send message to user2 success");
|
|
} else {
|
|
System.out.println("send message to user2 failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
IMResult<Void> voidIMResult = channelServiceApi.modifyChannelInfo(ProtoConstants.ModifyChannelInfoType.Modify_Channel_Desc, "this is a test channel, update at:" + new Date().toString());
|
|
if (voidIMResult != null && voidIMResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("modify channel profile success");
|
|
} else {
|
|
System.out.println("modify channel profile failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
IMResult<OutputGetChannelInfo> outputGetChannelInfoIMResult = channelServiceApi.getChannelInfo();
|
|
if (outputGetChannelInfoIMResult != null && outputGetChannelInfoIMResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("destroy user success");
|
|
} else {
|
|
System.out.println("destroy user failure");
|
|
System.exit(-1);
|
|
}
|
|
}
|
|
|
|
//***********************************************
|
|
//**** 物联网相关的API，仅专业版支持
|
|
//***********************************************
|
|
static void testDevice() throws Exception {
|
|
InputCreateDevice createDevice = new InputCreateDevice();
|
|
createDevice.setDeviceId("deviceId1");
|
|
createDevice.setOwners(Arrays.asList("opoGoG__", "userId1"));
|
|
IMResult<OutputCreateDevice> resultCreateDevice = UserAdmin.createOrUpdateDevice(createDevice);
|
|
if (resultCreateDevice != null && resultCreateDevice.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
System.out.println("Create device " + resultCreateDevice.getResult().getDeviceId() + " success");
|
|
} else {
|
|
System.out.println("Create device failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
IMResult<OutputDevice> getDevice = UserAdmin.getDevice("deviceId1");
|
|
if (getDevice != null && getDevice.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS && getDevice.getResult().getDeviceId().equals("deviceId1") && getDevice.getResult().getOwners().contains("opoGoG__")) {
|
|
System.out.println("Get device " + resultCreateDevice.getResult().getDeviceId() + " success");
|
|
} else {
|
|
System.out.println("Get device failure");
|
|
System.exit(-1);
|
|
}
|
|
|
|
IMResult<OutputDeviceList> getUserDevices = UserAdmin.getUserDevices("userId1");
|
|
if (getUserDevices != null && getUserDevices.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
|
|
boolean success = false;
|
|
for (OutputDevice outputDevice : getUserDevices.getResult().getDevices()) {
|
|
if (outputDevice.getDeviceId().equals("deviceId1")) {
|
|
success = true;
|
|
break;
|
|
}
|
|
}
|
|
if (success) {
|
|
System.out.println("Get user device success");
|
|
} else {
|
|
System.out.println("Get user device failure");
|
|
System.exit(-1);
|
|
}
|
|
} else {
|
|
System.out.println("Get device failure");
|
|
System.exit(-1);
|
|
}
|
|
}
|
|
}
|