update version to 0.61

README.md

@@ -74,6 +74,7 @@
 1. 从0.42 版本增加了群成员数限制，默认为2000。如果您从之前的版本升级到这个版本或以后，需要注意到群成员数的限制。升级之后超出限制的群不受影响，但不能继续加人，如果您想修改默认值，可以在升级版本之后，修改t_setting表，把默认的大小改为您期望的人数。另外修改t_group表，把已经存在的群组max_member_count改成您期望的，然后重启。
 2. 0.46和0.47版本升级到0.48及以后版本时，可能会提示flyway migrate 38错误，请执行 [修复脚本](https://github.com/wildfirechat/server/blob/wildfirechat/flyway_repaire_migrate_38.sql) 进行修复。0.46和0.47版本之外的版本不会出现此问题。
 3. 从0.54之前版本升级到0.54及以后版本时，会提示flyway migrate错误。因为0.54版本删除了sql脚本中默认敏感词的内容，flyway checksum失败。请执行```update flyway_schema_history set checksum = 0 where script = 'V17__add_default_sensitive_word.sql';```来修复。
+4. 从0.59之前的版本升级到之后的版本执行数据库升级时间比较长，请耐心等待提示运行成功，避免中途中断。
 
 ## 特别感谢
 1. [moquette](https://github.com/moquette-io/moquette) 本项目是基于此项目二次开发而来，处理MQTT相关业务。

broker/config/wildfirechat.conf

@@ -81,6 +81,15 @@ message.recall_time_limit 120
 ## 一般用于重要类型消息，比如交易、充值等，禁止客户端发送，仅限于服务器发送，提高安全性。
 message.forbidden_client_send_types 3999,4000,4001
 
+## 当禁止发送消息时，允许例外发送的消息。这种一般用户需要被动回应的消息。比如群中被禁言的用户，他无法主动发起音视频，但可以接听未被禁言用户的音视频
+## 因为音视频使用了消息作为信令，所以就需要允许发送音视频信令。如果开发了其它场景也需要被动回应消息，可以加在这里。
+## 黑名单时允许发送的消息类型
+message.blacklist_exception_types 401,402,403,404,405,407,408,410,411
+## 群禁言或者聊天室或者频道禁言时允许发送的消息类型
+message.group_mute_exception_types 401,402,403,404,405,407,408,410,411
+## 用户被全局禁言时允许发送的消息类型
+message.global_mute_exception_types 401,402,403,404,405,407,408,410,411
+
 ##禁止搜索用户
 friend.disable_search false
 

broker/migrate/h2/V38__add_user_messages_conv_info.sql

@@ -0,0 +1,4 @@
+alter table `t_user_messages` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages` add column `_target` varchar(129) NOT NULL DEFAULT '';
+alter table `t_user_messages` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);

broker/migrate/mysql/V43__add_user_messages_conv_info.sql

@@ -0,0 +1,644 @@
+alter table `t_user_messages` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_0` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_0` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_0` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_0` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_1` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_1` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_1` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_1` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_2` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_2` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_2` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_2` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_3` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_3` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_3` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_3` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_4` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_4` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_4` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_4` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_5` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_5` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_5` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_5` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_6` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_6` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_6` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_6` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_7` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_7` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_7` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_7` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_8` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_8` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_8` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_8` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_9` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_9` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_9` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_9` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_10` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_10` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_10` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_10` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_11` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_11` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_11` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_11` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_12` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_12` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_12` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_12` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_13` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_13` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_13` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_13` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_14` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_14` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_14` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_14` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_15` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_15` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_15` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_15` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_16` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_16` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_16` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_16` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_17` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_17` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_17` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_17` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_18` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_18` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_18` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_18` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_19` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_19` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_19` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_19` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_20` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_20` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_20` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_20` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_21` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_21` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_21` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_21` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_22` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_22` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_22` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_22` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_23` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_23` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_23` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_23` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_24` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_24` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_24` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_24` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_25` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_25` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_25` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_25` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_26` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_26` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_26` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_26` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_27` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_27` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_27` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_27` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_28` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_28` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_28` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_28` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_29` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_29` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_29` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_29` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_30` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_30` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_30` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_30` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_31` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_31` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_31` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_31` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_32` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_32` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_32` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_32` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_33` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_33` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_33` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_33` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_34` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_34` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_34` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_34` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_35` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_35` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_35` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_35` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_36` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_36` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_36` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_36` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_37` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_37` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_37` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_37` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_38` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_38` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_38` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_38` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_39` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_39` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_39` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_39` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_40` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_40` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_40` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_40` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_41` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_41` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_41` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_41` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_42` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_42` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_42` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_42` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_43` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_43` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_43` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_43` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_44` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_44` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_44` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_44` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_45` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_45` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_45` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_45` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_46` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_46` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_46` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_46` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_47` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_47` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_47` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_47` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_48` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_48` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_48` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_48` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_49` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_49` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_49` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_49` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_50` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_50` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_50` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_50` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_51` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_51` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_51` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_51` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_52` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_52` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_52` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_52` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_53` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_53` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_53` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_53` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_54` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_54` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_54` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_54` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_55` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_55` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_55` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_55` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_56` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_56` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_56` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_56` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_57` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_57` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_57` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_57` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_58` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_58` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_58` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_58` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_59` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_59` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_59` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_59` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_60` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_60` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_60` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_60` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_61` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_61` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_61` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_61` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_62` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_62` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_62` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_62` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_63` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_63` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_63` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_63` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_64` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_64` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_64` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_64` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_65` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_65` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_65` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_65` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_66` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_66` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_66` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_66` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_67` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_67` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_67` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_67` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_68` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_68` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_68` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_68` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_69` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_69` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_69` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_69` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_70` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_70` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_70` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_70` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_71` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_71` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_71` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_71` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_72` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_72` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_72` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_72` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_73` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_73` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_73` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_73` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_74` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_74` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_74` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_74` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_75` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_75` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_75` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_75` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_76` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_76` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_76` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_76` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_77` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_77` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_77` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_77` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_78` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_78` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_78` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_78` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_79` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_79` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_79` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_79` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_80` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_80` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_80` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_80` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_81` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_81` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_81` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_81` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_82` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_82` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_82` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_82` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_83` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_83` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_83` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_83` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_84` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_84` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_84` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_84` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_85` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_85` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_85` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_85` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_86` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_86` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_86` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_86` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_87` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_87` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_87` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_87` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_88` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_88` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_88` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_88` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_89` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_89` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_89` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_89` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_90` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_90` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_90` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_90` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_91` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_91` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_91` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_91` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_92` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_92` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_92` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_92` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_93` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_93` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_93` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_93` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_94` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_94` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_94` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_94` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_95` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_95` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_95` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_95` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_96` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_96` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_96` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_96` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_97` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_97` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_97` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_97` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_98` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_98` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_98` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_98` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_99` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_99` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_99` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_99` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_100` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_100` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_100` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_100` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_101` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_101` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_101` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_101` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_102` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_102` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_102` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_102` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_103` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_103` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_103` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_103` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_104` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_104` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_104` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_104` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_105` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_105` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_105` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_105` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_106` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_106` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_106` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_106` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_107` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_107` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_107` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_107` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_108` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_108` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_108` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_108` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_109` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_109` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_109` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_109` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_110` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_110` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_110` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_110` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_111` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_111` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_111` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_111` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_112` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_112` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_112` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_112` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_113` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_113` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_113` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_113` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_114` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_114` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_114` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_114` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_115` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_115` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_115` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_115` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_116` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_116` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_116` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_116` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_117` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_117` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_117` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_117` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_118` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_118` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_118` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_118` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_119` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_119` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_119` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_119` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_120` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_120` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_120` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_120` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_121` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_121` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_121` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_121` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_122` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_122` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_122` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_122` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_123` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_123` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_123` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_123` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_124` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_124` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_124` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_124` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_125` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_125` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_125` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_125` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_126` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_126` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_126` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_126` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);
+
+alter table `t_user_messages_127` add column `_type` tinyint(4) NOT NULL DEFAULT '0';
+alter table `t_user_messages_127` add column `_target` varchar(129) COLLATE utf8mb4_unicode_ci NOT NULL DEFAULT '';
+alter table `t_user_messages_127` add column `_directing` tinyint(1) NOT NULL DEFAULT '0';
+alter table `t_user_messages_127` add INDEX `user_messages_conv_index` ( `_uid`, `_type`, `_target`, `_line`, `_mid` desc);

broker/pom.xml

@@ -5,7 +5,7 @@
         <relativePath>../</relativePath>
         <artifactId>wildfirechat-parent</artifactId>
         <groupId>cn.wildfirechat</groupId>
-        <version>0.57</version>
+        <version>0.61</version>
     </parent>
 
     <artifactId>moquette-broker</artifactId>
@@ -118,7 +118,7 @@
         <dependency>
             <groupId>com.hazelcast</groupId>
             <artifactId>hazelcast</artifactId>
-            <version>3.9.4</version>
+            <version>3.11.5</version>
         </dependency>
 
         <!-- https://mvnrepository.com/artifact/com.xiaoleilu/hutool -->

broker/src/main/java/cn/wildfirechat/push/PushMessage.java

@@ -43,7 +43,7 @@ public class PushMessage {
         this.cntType = messageContentType;
         this.serverTime = serverTime;
         this.unReceivedMsg = unReceivedMsg;
-        if (cntType == 400) {
+        if (cntType == 400 || cntType == 406) {
             this.pushMessageType = PushServer.PushMessageType.PUSH_MESSAGE_TYPE_VOIP_INVITE;
         } else if(cntType == 402) {
             this.pushMessageType = PushServer.PushMessageType.PUSH_MESSAGE_TYPE_VOIP_BYE;

broker/src/main/java/com/xiaoleilu/loServer/action/UploadFileAction.java

@@ -201,7 +201,7 @@ public class UploadFileAction extends Action {
                     return false;
                 }
 
-                if (remoteFileSize > 50 * 1024 * 1024) {
+                if (remoteFileSize > 200 * 1024 * 1024) {
                     logger.warn("file over limite!(" + remoteFileSize + ")");
                     response.setStatus(HttpResponseStatus.BAD_REQUEST);
                     response.setContent("file over limite!");

broker/src/main/java/com/xiaoleilu/loServer/action/admin/AdminAction.java

@@ -59,7 +59,7 @@ abstract public class AdminAction extends Action {
         }
         
         if (StringUtil.isNullOrEmpty(nonce) || StringUtil.isNullOrEmpty(timestamp) || StringUtil.isNullOrEmpty(sign)) {
-            return ErrorCode.INVALID_PARAMETER;
+            return ErrorCode.ERROR_CODE_API_NOT_SIGNED;
         }
 
         Long ts;
@@ -68,7 +68,7 @@ abstract public class AdminAction extends Action {
         } catch (Exception e) {
             e.printStackTrace();
             Utility.printExecption(LOG, e);
-            return ErrorCode.INVALID_PARAMETER;
+            return ErrorCode.ERROR_CODE_API_NOT_SIGNED;
         }
 
         if (!NO_CHECK_TIME && System.currentTimeMillis() - ts > 2 * 60 * 60 * 1000) {

broker/src/main/java/com/xiaoleilu/loServer/action/channel/ChannelAction.java

@@ -51,7 +51,7 @@ abstract public class ChannelAction extends Action {
         }
 
         if (StringUtil.isNullOrEmpty(nonce) || StringUtil.isNullOrEmpty(timestamp) || StringUtil.isNullOrEmpty(sign) || StringUtil.isNullOrEmpty(cid)) {
-            return ErrorCode.INVALID_PARAMETER;
+            return ErrorCode.ERROR_CODE_API_NOT_SIGNED;
         }
 
         if (!mLimitCounter.isGranted(cid)) {
@@ -64,7 +64,7 @@ abstract public class ChannelAction extends Action {
         } catch (Exception e) {
             e.printStackTrace();
             Utility.printExecption(LOG, e, IMExceptionEvent.EventType.CHANNEL_API_Exception);
-            return ErrorCode.INVALID_PARAMETER;
+            return ErrorCode.ERROR_CODE_API_NOT_SIGNED;
         }
 
         if (System.currentTimeMillis() - ts > 2 * 60 * 60 * 1000) {

broker/src/main/java/com/xiaoleilu/loServer/action/channel/GetChannelAction.java

@@ -0,0 +1,41 @@
+/*
+ * This file is part of the Wildfire Chat package.
+ * (c) Heavyrain2012 <[email protected]>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+package com.xiaoleilu.loServer.action.channel;
+
+import cn.wildfirechat.common.APIPath;
+import cn.wildfirechat.common.ErrorCode;
+import cn.wildfirechat.pojos.InputGetUserInfo;
+import cn.wildfirechat.pojos.InputOutputUserInfo;
+import cn.wildfirechat.pojos.OutputGetChannelInfo;
+import cn.wildfirechat.proto.WFCMessage;
+import com.google.gson.Gson;
+import com.xiaoleilu.loServer.RestResult;
+import com.xiaoleilu.loServer.annotation.HttpMethod;
+import com.xiaoleilu.loServer.annotation.Route;
+import com.xiaoleilu.loServer.handler.Request;
+import com.xiaoleilu.loServer.handler.Response;
+import io.netty.handler.codec.http.FullHttpRequest;
+import io.netty.handler.codec.http.HttpResponseStatus;
+import io.netty.util.internal.StringUtil;
+
+@Route(APIPath.Channel_Get_Profile)
+@HttpMethod("POST")
+public class GetChannelAction extends ChannelAction {
+
+    @Override
+    public boolean action(Request request, Response response) {
+        if (request.getNettyRequest() instanceof FullHttpRequest) {
+            response.setStatus(HttpResponseStatus.OK);
+            RestResult result = RestResult.ok(OutputGetChannelInfo.fromPbInfo(channelInfo));
+
+            response.setContent(new Gson().toJson(result));
+        }
+        return true;
+    }
+}

broker/src/main/java/com/xiaoleilu/loServer/action/channel/GetChannelSubscribersAction.java

@@ -0,0 +1,46 @@
+/*
+ * This file is part of the Wildfire Chat package.
+ * (c) Heavyrain2012 <[email protected]>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+package com.xiaoleilu.loServer.action.channel;
+
+import cn.wildfirechat.common.APIPath;
+import cn.wildfirechat.common.ErrorCode;
+import cn.wildfirechat.pojos.InputGetUserInfo;
+import cn.wildfirechat.pojos.InputOutputUserInfo;
+import cn.wildfirechat.pojos.OutputStringList;
+import cn.wildfirechat.proto.WFCMessage;
+import com.google.gson.Gson;
+import com.xiaoleilu.loServer.RestResult;
+import com.xiaoleilu.loServer.annotation.HttpMethod;
+import com.xiaoleilu.loServer.annotation.Route;
+import com.xiaoleilu.loServer.handler.Request;
+import com.xiaoleilu.loServer.handler.Response;
+import io.netty.handler.codec.http.FullHttpRequest;
+import io.netty.handler.codec.http.HttpResponseStatus;
+import io.netty.util.internal.StringUtil;
+
+import java.util.ArrayList;
+
+@Route(APIPath.Channel_Subscriber_List)
+@HttpMethod("POST")
+public class GetChannelSubscribersAction extends ChannelAction {
+
+    @Override
+    public boolean action(Request request, Response response) {
+        if (request.getNettyRequest() instanceof FullHttpRequest) {
+            OutputStringList outputStringList = new OutputStringList();
+            outputStringList.setList(new ArrayList<>());
+            outputStringList.getList().addAll(messagesStore.getChannelSubscriber(channelInfo.getTargetId()));
+
+            response.setStatus(HttpResponseStatus.OK);
+            RestResult result = RestResult.ok(outputStringList);
+            response.setContent(new Gson().toJson(result));
+        }
+        return true;
+    }
+}

broker/src/main/java/com/xiaoleilu/loServer/action/channel/GetUserAction.java

@@ -0,0 +1,83 @@
+/*
+ * This file is part of the Wildfire Chat package.
+ * (c) Heavyrain2012 <[email protected]>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+package com.xiaoleilu.loServer.action.channel;
+
+import cn.wildfirechat.common.APIPath;
+import cn.wildfirechat.common.ErrorCode;
+import cn.wildfirechat.pojos.InputGetUserInfo;
+import cn.wildfirechat.pojos.InputOutputUserInfo;
+import cn.wildfirechat.proto.ProtoConstants;
+import cn.wildfirechat.proto.WFCMessage;
+import com.google.gson.Gson;
+import com.xiaoleilu.loServer.RestResult;
+import com.xiaoleilu.loServer.action.admin.AdminAction;
+import com.xiaoleilu.loServer.action.robot.RobotAction;
+import com.xiaoleilu.loServer.annotation.HttpMethod;
+import com.xiaoleilu.loServer.annotation.Route;
+import com.xiaoleilu.loServer.handler.Request;
+import com.xiaoleilu.loServer.handler.Response;
+import io.netty.handler.codec.http.FullHttpRequest;
+import io.netty.handler.codec.http.HttpResponseStatus;
+import io.netty.util.internal.StringUtil;
+
+@Route(APIPath.Channel_User_Info)
+@HttpMethod("POST")
+public class GetUserAction extends ChannelAction {
+
+    @Override
+    public boolean action(Request request, Response response) {
+        if (request.getNettyRequest() instanceof FullHttpRequest) {
+            InputGetUserInfo inputUserId = getRequestBody(request.getNettyRequest(), InputGetUserInfo.class);
+            if (inputUserId != null
+                && (!StringUtil.isNullOrEmpty(inputUserId.getUserId()) || !StringUtil.isNullOrEmpty(inputUserId.getName()) || !StringUtil.isNullOrEmpty(inputUserId.getMobile()))) {
+
+                WFCMessage.User user = null;
+                if(!StringUtil.isNullOrEmpty(inputUserId.getUserId())) {
+                    user = messagesStore.getUserInfo(inputUserId.getUserId());
+                } else if(!StringUtil.isNullOrEmpty(inputUserId.getName())) {
+                    user = messagesStore.getUserInfoByName(inputUserId.getName());
+                } else if(!StringUtil.isNullOrEmpty(inputUserId.getMobile())) {
+                    user = messagesStore.getUserInfoByMobile(inputUserId.getMobile());
+                }
+
+                response.setStatus(HttpResponseStatus.OK);
+                RestResult result;
+
+                if (user == null || StringUtil.isNullOrEmpty(user.getName())) {
+                    result = RestResult.resultOf(ErrorCode.ERROR_CODE_NOT_EXIST);
+                } else {
+                    if (channelInfo.getOwner().equals(inputUserId.getUserId()) ||
+                            messagesStore.checkUserInChannel(user.getUid(), channelInfo.getTargetId())) {
+                        if((channelInfo.getStatus() & ProtoConstants.ChannelState.Channel_State_Mask_FullInfo) > 0) {
+                            result = RestResult.ok(InputOutputUserInfo.fromPbUser(user));
+                        } else {
+                            WFCMessage.User outUser = WFCMessage.User.newBuilder().setUid(user.getUid()).setName(user.getName()).setPortrait(user.getPortrait()).setDisplayName(user.getDisplayName()).build();
+                            result = RestResult.ok(InputOutputUserInfo.fromPbUser(outUser));
+                        }
+                    } else {
+                        if((channelInfo.getStatus() & ProtoConstants.ChannelState.Channel_State_Mask_Unsubscribed_User_Access) > 0) {
+                            WFCMessage.User outUser = WFCMessage.User.newBuilder().setUid(user.getUid()).setName(user.getName()).setPortrait(user.getPortrait()).setDisplayName(user.getDisplayName()).build();
+                            result = RestResult.ok(InputOutputUserInfo.fromPbUser(outUser));
+                        } else {
+                            result = RestResult.resultOf(ErrorCode.ERROR_CODE_NOT_RIGHT);
+                        }
+                    }
+                }
+
+                response.setContent(new Gson().toJson(result));
+            } else {
+                response.setStatus(HttpResponseStatus.OK);
+                RestResult result = RestResult.resultOf(ErrorCode.INVALID_PARAMETER);
+                response.setContent(new Gson().toJson(result));
+            }
+
+        }
+        return true;
+    }
+}

broker/src/main/java/com/xiaoleilu/loServer/action/channel/ModifyChannelProfileAction.java

@@ -0,0 +1,84 @@
+/*
+ * This file is part of the Wildfire Chat package.
+ * (c) Heavyrain2012 <[email protected]>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+package com.xiaoleilu.loServer.action.channel;
+
+import cn.wildfirechat.common.APIPath;
+import cn.wildfirechat.common.ErrorCode;
+import cn.wildfirechat.pojos.InputGetUserInfo;
+import cn.wildfirechat.pojos.InputModifyChannelInfo;
+import cn.wildfirechat.pojos.InputOutputUserInfo;
+import cn.wildfirechat.pojos.SendMessageResult;
+import cn.wildfirechat.proto.WFCMessage;
+import com.google.gson.Gson;
+import com.xiaoleilu.loServer.RestResult;
+import com.xiaoleilu.loServer.annotation.HttpMethod;
+import com.xiaoleilu.loServer.annotation.Route;
+import com.xiaoleilu.loServer.handler.Request;
+import com.xiaoleilu.loServer.handler.Response;
+import io.moquette.persistence.RPCCenter;
+import io.moquette.persistence.TargetEntry;
+import io.netty.buffer.ByteBuf;
+import io.netty.buffer.Unpooled;
+import io.netty.handler.codec.http.FullHttpRequest;
+import io.netty.handler.codec.http.HttpResponseStatus;
+import io.netty.util.internal.StringUtil;
+import win.liyufan.im.IMTopic;
+
+import java.util.concurrent.Executor;
+
+@Route(APIPath.Channel_Update_Profile)
+@HttpMethod("POST")
+public class ModifyChannelProfileAction extends ChannelAction {
+    @Override
+    public boolean action(Request request, Response response) {
+        if (request.getNettyRequest() instanceof FullHttpRequest) {
+            InputModifyChannelInfo input = getRequestBody(request.getNettyRequest(), InputModifyChannelInfo.class);
+            if (input != null) {
+                WFCMessage.ModifyChannelInfo modifyChannelInfo = WFCMessage.ModifyChannelInfo.newBuilder().setChannelId(channelInfo.getTargetId()).setType(input.getType()).setValue(input.getValue()).build();
+                RPCCenter.getInstance().sendRequest(channelInfo.getOwner(), null, IMTopic.ModifyChannelInfoTopic, modifyChannelInfo.toByteArray(), channelInfo.getOwner(), TargetEntry.Type.TARGET_TYPE_USER, new RPCCenter.Callback() {
+                    @Override
+                    public void onSuccess(byte[] result) {
+                        ByteBuf byteBuf = Unpooled.buffer();
+                        byteBuf.writeBytes(result);
+                        ErrorCode errorCode = ErrorCode.fromCode(byteBuf.readByte());
+                        if (errorCode == ErrorCode.ERROR_CODE_SUCCESS) {
+                            sendResponse(response, null, null);
+                        } else {
+                            sendResponse(response, errorCode, null);
+                        }
+                    }
+
+                    @Override
+                    public void onError(ErrorCode errorCode) {
+                        sendResponse(response, errorCode, null);
+                    }
+
+                    @Override
+                    public void onTimeout() {
+                        sendResponse(response, ErrorCode.ERROR_CODE_TIMEOUT, null);
+                    }
+
+                    @Override
+                    public Executor getResponseExecutor() {
+                        return command -> {
+                            ctx.executor().execute(command);
+                        };
+                    }
+                }, false);
+                return false;
+            } else {
+                response.setStatus(HttpResponseStatus.OK);
+                RestResult result = RestResult.resultOf(ErrorCode.INVALID_PARAMETER);
+                response.setContent(new Gson().toJson(result));
+            }
+
+        }
+        return true;
+    }
+}

broker/src/main/java/com/xiaoleilu/loServer/action/channel/SubscriberChannelAction.java

@@ -0,0 +1,90 @@
+/*
+ * This file is part of the Wildfire Chat package.
+ * (c) Heavyrain2012 <[email protected]>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+package com.xiaoleilu.loServer.action.channel;
+
+import cn.wildfirechat.common.APIPath;
+import cn.wildfirechat.common.ErrorCode;
+import cn.wildfirechat.pojos.InputChannelSubscribe;
+import cn.wildfirechat.pojos.InputModifyChannelInfo;
+import cn.wildfirechat.proto.ProtoConstants;
+import cn.wildfirechat.proto.WFCMessage;
+import com.google.gson.Gson;
+import com.hazelcast.util.StringUtil;
+import com.xiaoleilu.loServer.RestResult;
+import com.xiaoleilu.loServer.annotation.HttpMethod;
+import com.xiaoleilu.loServer.annotation.Route;
+import com.xiaoleilu.loServer.handler.Request;
+import com.xiaoleilu.loServer.handler.Response;
+import io.moquette.persistence.RPCCenter;
+import io.moquette.persistence.TargetEntry;
+import io.netty.buffer.ByteBuf;
+import io.netty.buffer.Unpooled;
+import io.netty.handler.codec.http.FullHttpRequest;
+import io.netty.handler.codec.http.HttpResponseStatus;
+import win.liyufan.im.IMTopic;
+
+import java.util.concurrent.Executor;
+
+@Route(APIPath.Channel_Subscribe)
+@HttpMethod("POST")
+public class SubscriberChannelAction extends ChannelAction {
+
+    @Override
+    public boolean action(Request request, Response response) {
+        if (request.getNettyRequest() instanceof FullHttpRequest) {
+            InputChannelSubscribe input = getRequestBody(request.getNettyRequest(), InputChannelSubscribe.class);
+            if (input != null && !StringUtil.isNullOrEmpty(input.getTarget())) {
+                if(input.getSubscribe() > 0 && (channelInfo.getStatus() & ProtoConstants.ChannelState.Channel_State_Mask_Active_Subscribe) == 0) {
+                    response.setStatus(HttpResponseStatus.OK);
+                    RestResult result = RestResult.resultOf(ErrorCode.ERROR_CODE_NOT_RIGHT);
+                    response.setContent(new Gson().toJson(result));
+                    return true;
+                }
+                WFCMessage.ListenChannel listenChannel = WFCMessage.ListenChannel.newBuilder().setChannelId(channelInfo.getTargetId()).setListen(input.getSubscribe()).build();
+                RPCCenter.getInstance().sendRequest(input.getTarget(), null, IMTopic.ChannelListenTopic, listenChannel.toByteArray(), input.getTarget(), TargetEntry.Type.TARGET_TYPE_USER, new RPCCenter.Callback() {
+                    @Override
+                    public void onSuccess(byte[] result) {
+                        ByteBuf byteBuf = Unpooled.buffer();
+                        byteBuf.writeBytes(result);
+                        ErrorCode errorCode = ErrorCode.fromCode(byteBuf.readByte());
+                        if (errorCode == ErrorCode.ERROR_CODE_SUCCESS) {
+                            sendResponse(response, null, null);
+                        } else {
+                            sendResponse(response, errorCode, null);
+                        }
+                    }
+
+                    @Override
+                    public void onError(ErrorCode errorCode) {
+                        sendResponse(response, errorCode, null);
+                    }
+
+                    @Override
+                    public void onTimeout() {
+                        sendResponse(response, ErrorCode.ERROR_CODE_TIMEOUT, null);
+                    }
+
+                    @Override
+                    public Executor getResponseExecutor() {
+                        return command -> {
+                            ctx.executor().execute(command);
+                        };
+                    }
+                }, true);
+                return false;
+            } else {
+                response.setStatus(HttpResponseStatus.OK);
+                RestResult result = RestResult.resultOf(ErrorCode.INVALID_PARAMETER);
+                response.setContent(new Gson().toJson(result));
+            }
+
+        }
+        return true;
+    }
+}

broker/src/main/java/com/xiaoleilu/loServer/action/robot/RobotAction.java

@@ -55,7 +55,7 @@ abstract public class RobotAction extends Action {
         }
 
         if (StringUtil.isNullOrEmpty(nonce) || StringUtil.isNullOrEmpty(timestamp) || StringUtil.isNullOrEmpty(sign) || StringUtil.isNullOrEmpty(rid)) {
-            return ErrorCode.INVALID_PARAMETER;
+            return ErrorCode.ERROR_CODE_API_NOT_SIGNED;
         }
 
         if (!mLimitCounter.isGranted(rid)) {
@@ -68,7 +68,7 @@ abstract public class RobotAction extends Action {
         } catch (Exception e) {
             e.printStackTrace();
             Utility.printExecption(LOG, e, IMExceptionEvent.EventType.ROBOT_API_Exception);
-            return ErrorCode.INVALID_PARAMETER;
+            return ErrorCode.ERROR_CODE_API_NOT_SIGNED;
         }
 
         if (System.currentTimeMillis() - ts > 2 * 60 * 60 * 1000) {

broker/src/main/java/io/moquette/BrokerConstants.java

@@ -157,6 +157,9 @@ public final class BrokerConstants {
     public static final String USER_HIDE_PROPERTIES = "user.hide_properties";
 
     public static final String MESSAGES_FORBIDDEN_CLIENT_SEND_TYPES = "message.forbidden_client_send_types";
+    public static final String MESSAGES_BLACKLIST_EXCEPTION_TYPES = "message.blacklist_exception_types";
+    public static final String MESSAGES_GROUP_MUTE_EXCEPTION_TYPES = "message.group_mute_exception_types";
+    public static final String MESSAGES_GLOBAL_MUTE_EXCEPTION_TYPES = "message.global_mute_exception_types";
 
     public static final String MESSAGES_DISABLE_REMOTE_SEARCH = "message.disable_remote_search";
 

broker/src/main/java/io/moquette/imhandler/ModifyGroupInfoHandler.java

@@ -44,6 +44,8 @@ public class ModifyGroupInfoHandler extends GroupHandler<WFCMessage.ModifyGroupI
                     content = new GroupNotificationBinaryContent(request.getGroupId(), fromUser, request.getValue(), "").getChangeGroupPrivatechatNotifyContent();
                 } else if(request.getType() == Modify_Group_Searchable) {
                     content = new GroupNotificationBinaryContent(request.getGroupId(), fromUser, request.getValue(), "").getChangeGroupSearchableNotifyContent();
+                } else if(request.getType() == Modify_Group_Extra) {
+                    content = new GroupNotificationBinaryContent(request.getGroupId(), fromUser, request.getValue(), "").getChangeGroupExtraNotifyContent();
                 }
 
                 if (content != null) {

broker/src/main/java/io/moquette/imhandler/SendMessageHandler.java

@@ -105,17 +105,21 @@ public class SendMessageHandler extends IMHandler<WFCMessage.Message> {
 
                 int userStatus = m_messagesStore.getUserStatus(fromUser);
                 if (userStatus == ProtoConstants.UserStatus.Muted || userStatus == ProtoConstants.UserStatus.Forbidden) {
-                    return ErrorCode.ERROR_CODE_FORBIDDEN_SEND_MSG;
+                    if(!m_messagesStore.getGlobalMuteExceptionTypes().contains(message.getContent().getType())) {
+                        return ErrorCode.ERROR_CODE_FORBIDDEN_SEND_MSG;
+                    }
                 }
 
                 if (message.getConversation().getType() == ProtoConstants.ConversationType.ConversationType_Private) {
-                    errorCode = m_messagesStore.isAllowUserMessage(message.getConversation().getTarget(), fromUser);
+                    if(!m_messagesStore.getBlackListExceptionTypes().contains(message.getContent().getType())) {
-                    if (errorCode != ErrorCode.ERROR_CODE_SUCCESS) {
+                        errorCode = m_messagesStore.isAllowUserMessage(message.getConversation().getTarget(), fromUser);
-                        if (errorCode == ErrorCode.ERROR_CODE_IN_BLACK_LIST && mBlacklistStrategy != ProtoConstants.BlacklistStrategy.Message_Reject) {
+                        if (errorCode != ErrorCode.ERROR_CODE_SUCCESS) {
-                            ignoreMsg = true;
+                            if (errorCode == ErrorCode.ERROR_CODE_IN_BLACK_LIST && mBlacklistStrategy != ProtoConstants.BlacklistStrategy.Message_Reject) {
-                            errorCode = ErrorCode.ERROR_CODE_SUCCESS;
+                                ignoreMsg = true;
-                        } else {
+                                errorCode = ErrorCode.ERROR_CODE_SUCCESS;
-                            return errorCode;
+                            } else {
+                                return errorCode;
+                            }
                         }
                     }
 
@@ -126,17 +130,23 @@ public class SendMessageHandler extends IMHandler<WFCMessage.Message> {
                 }
 
                 if (message.getConversation().getType() == ProtoConstants.ConversationType.ConversationType_Group ) {
-                    errorCode = m_messagesStore.canSendMessageInGroup(fromUser, message.getConversation().getTarget());
+                    if(!m_messagesStore.getGroupMuteExceptionTypes().contains(message.getContent().getType())) {
-                    if (errorCode != ErrorCode.ERROR_CODE_SUCCESS) {
+                        errorCode = m_messagesStore.canSendMessageInGroup(fromUser, message.getConversation().getTarget());
-                        return errorCode;
+                        if (errorCode != ErrorCode.ERROR_CODE_SUCCESS) {
+                            return errorCode;
+                        }
                     }
                 } else if (message.getConversation().getType() == ProtoConstants.ConversationType.ConversationType_ChatRoom) {
-                    if(!m_messagesStore.checkUserClientInChatroom(fromUser, clientID, message.getConversation().getTarget())) {
+                    if(!m_messagesStore.getGroupMuteExceptionTypes().contains(message.getContent().getType())) {
-                        return ErrorCode.ERROR_CODE_NOT_IN_CHATROOM;
+                        if (!m_messagesStore.checkUserClientInChatroom(fromUser, clientID, message.getConversation().getTarget())) {
+                            return ErrorCode.ERROR_CODE_NOT_IN_CHATROOM;
+                        }
                     }
                 } else if (message.getConversation().getType() == ProtoConstants.ConversationType.ConversationType_Channel) {
-                    if(!m_messagesStore.checkUserInChannel(fromUser, message.getConversation().getTarget())) {
+                    if(!m_messagesStore.getGroupMuteExceptionTypes().contains(message.getContent().getType())) {
-                        return ErrorCode.ERROR_CODE_NOT_IN_CHANNEL;
+                        if (!m_messagesStore.checkUserInChannel(fromUser, message.getConversation().getTarget())) {
+                            return ErrorCode.ERROR_CODE_NOT_IN_CHANNEL;
+                        }
                     }
                 }
             }

broker/src/main/java/io/moquette/persistence/DatabaseStore.java

@@ -1702,7 +1702,7 @@ public class DatabaseStore {
         }
     }
 
-    void persistGroupMember(final String groupId, final List<WFCMessage.GroupMember> memberList) {
+    void persistGroupMember(final String groupId, final List<WFCMessage.GroupMember> memberList, boolean updateCreateTime) {
             Connection connection = null;
             PreparedStatement statement = null;
             try {
@@ -1718,6 +1718,9 @@ public class DatabaseStore {
                     "`_alias` = ?," +
                     "`_type` = ?," +
                     "`_dt` = ?";
+                if(updateCreateTime) {
+                    sql += ", `_create_dt` = ?";
+                }
 
                 statement = connection.prepareStatement(sql);
 
@@ -1738,14 +1741,17 @@ public class DatabaseStore {
                     statement.setString(index++, member.getAlias());
                     statement.setInt(index++, member.getType());
                     statement.setLong(index++, dt);
+                    if(updateCreateTime) {
+                        statement.setLong(index++, dt);
+                    }
                     int count = statement.executeUpdate();
                     LOG.info("Update rows {}", count);
                 }
-
-                connection.commit();
-                connection.setAutoCommit(true);
             } catch (SQLException e) {
                 // TODO Auto-generated catch block
+                e.printStackTrace();
+                Utility.printExecption(LOG, e, RDBS_Exception);
+            } finally {
                 if (connection != null) {
                     try {
                         connection.commit();
@@ -1754,9 +1760,6 @@ public class DatabaseStore {
                         e1.printStackTrace();
                     }
                 }
-                e.printStackTrace();
-                Utility.printExecption(LOG, e, RDBS_Exception);
-            } finally {
                 DBUtil.closeDB(connection, statement);
             }
     }
@@ -3082,11 +3085,11 @@ public class DatabaseStore {
                     int count = statement.executeUpdate();
                     LOG.info("Update rows {}", count);
                 }
-
-                connection.commit();
-                connection.setAutoCommit(true);
             } catch (SQLException e) {
                 // TODO Auto-generated catch block
+                e.printStackTrace();
+                Utility.printExecption(LOG, e, RDBS_Exception);
+            } finally {
                 if (connection != null) {
                     try {
                         connection.commit();
@@ -3095,9 +3098,6 @@ public class DatabaseStore {
                         e1.printStackTrace();
                     }
                 }
-                e.printStackTrace();
-                Utility.printExecption(LOG, e, RDBS_Exception);
-            } finally {
                 DBUtil.closeDB(connection, statement);
             }
         });

broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java

@@ -139,6 +139,9 @@ public class MemoryMessagesStore implements IMessagesStore {
     private boolean mChatroomRejoinWhenActive = true;
 
     private List<Integer> mForbiddenClientSendTypes = new ArrayList<>();
+    private List<Integer> mBlackListExceptionTypes = new ArrayList<>();
+    private List<Integer> mGroupMuteExceptionTypes = new ArrayList<>();
+    private List<Integer> mGlobalMuteExceptionTypes = new ArrayList<>();
 
     private long mRecallTimeLimit = 300;
 
@@ -275,7 +278,48 @@ public class MemoryMessagesStore implements IMessagesStore {
         } catch (Exception e) {
         }
 
+        try {
+            String strTypes = m_Server.getConfig().getProperty(BrokerConstants.MESSAGES_BLACKLIST_EXCEPTION_TYPES);
+            if(!StringUtil.isNullOrEmpty(strTypes)) {
+                for (String strType:strTypes.split(",")) {
+                    try {
+                        int type = Integer.parseInt(strType);
+                        mBlackListExceptionTypes.add(type);
+                    } catch (NumberFormatException e) {
 
+                    }
+                }
+            }
+        } catch (Exception e) {
+        }
+        try {
+            String strTypes = m_Server.getConfig().getProperty(BrokerConstants.MESSAGES_GROUP_MUTE_EXCEPTION_TYPES);
+            if(!StringUtil.isNullOrEmpty(strTypes)) {
+                for (String strType:strTypes.split(",")) {
+                    try {
+                        int type = Integer.parseInt(strType);
+                        mGroupMuteExceptionTypes.add(type);
+                    } catch (NumberFormatException e) {
+
+                    }
+                }
+            }
+        } catch (Exception e) {
+        }
+        try {
+            String strTypes = m_Server.getConfig().getProperty(BrokerConstants.MESSAGES_GLOBAL_MUTE_EXCEPTION_TYPES);
+            if(!StringUtil.isNullOrEmpty(strTypes)) {
+                for (String strType:strTypes.split(",")) {
+                    try {
+                        int type = Integer.parseInt(strType);
+                        mGlobalMuteExceptionTypes.add(type);
+                    } catch (NumberFormatException e) {
+
+                    }
+                }
+            }
+        } catch (Exception e) {
+        }
 
         try {
             mGroupInfoUpdateCallback = server.getConfig().getProperty(GROUP_INFO_UPDATE_CALLBACK);
@@ -928,7 +972,7 @@ public class MemoryMessagesStore implements IMessagesStore {
             .build();
 
         mIMap.set(groupId, groupInfo);
-        databaseStore.persistGroupMember(groupId, updatedMemberList);
+        databaseStore.persistGroupMember(groupId, updatedMemberList, false);
 
         callbackGroupEvent(fromUser, groupInfo.getTargetId(), ProtoConstants.GroupUpdateEventType.Group_Event_Create);
         return groupInfo;
@@ -1147,7 +1191,7 @@ public class MemoryMessagesStore implements IMessagesStore {
             }
         }
 
-        databaseStore.persistGroupMember(groupId, memberList);
+        databaseStore.persistGroupMember(groupId, memberList, true);
         databaseStore.updateGroupMemberCountDt(groupId);
 
         groupMembers.remove(groupId);
@@ -1472,7 +1516,7 @@ public class MemoryMessagesStore implements IMessagesStore {
             if (member.getMemberId().equals(memberId)) {
                 groupMembers.remove(groupId, member);
                 member = member.toBuilder().setAlias(alias).setUpdateDt(updateDt).build();
-                databaseStore.persistGroupMember(groupId, Arrays.asList(member));
+                databaseStore.persistGroupMember(groupId, Arrays.asList(member), false);
                 databaseStore.updateGroupMemberDt(groupId, updateDt);
                 groupMembers.put(groupId, member);
 
@@ -1629,13 +1673,13 @@ public class MemoryMessagesStore implements IMessagesStore {
             if (newOwner.equals(member.getMemberId())) {
                 groupMembers.remove(groupId, member);
                 member = member.toBuilder().setType(GroupMemberType_Owner).setUpdateDt(updateDt).build();
-                databaseStore.persistGroupMember(groupId, Arrays.asList(member));
+                databaseStore.persistGroupMember(groupId, Arrays.asList(member), false);
                 groupMembers.put(groupId, member);
                 modifyMemeberCount++;
             } else if(member.getType() == GroupMemberType_Owner) {
                 groupMembers.remove(groupId, member);
                 member = member.toBuilder().setType(GroupMemberType_Normal).setUpdateDt(updateDt).build();
-                databaseStore.persistGroupMember(groupId, Arrays.asList(member));
+                databaseStore.persistGroupMember(groupId, Arrays.asList(member), false);
                 groupMembers.put(groupId, member);
                 modifyMemeberCount++;
             }
@@ -1673,7 +1717,7 @@ public class MemoryMessagesStore implements IMessagesStore {
             if (userList.contains(member.getMemberId())) {
                 groupMembers.remove(groupId, member);
                 member = member.toBuilder().setType(type == 0 ? ProtoConstants.GroupMemberType.GroupMemberType_Normal : ProtoConstants.GroupMemberType.GroupMemberType_Manager).setUpdateDt(updateDt).build();
-                databaseStore.persistGroupMember(groupId, Arrays.asList(member));
+                databaseStore.persistGroupMember(groupId, Arrays.asList(member), false);
                 groupMembers.put(groupId, member);
             }
         }
@@ -2162,6 +2206,13 @@ public class MemoryMessagesStore implements IMessagesStore {
         if((flag & Update_User_Extra) > 0) {
             builder.setExtra(userInfo.getExtra());
         }
+        if((flag & Update_User_Name) > 0) {
+            if(StringUtil.isNullOrEmpty(userInfo.getName())) {
+                LOG.error("Modify user info failure, name not exist!");
+                return ErrorCode.INVALID_PARAMETER;
+            }
+            builder.setName(userInfo.getName());
+        }
         builder.setUpdateDt(System.currentTimeMillis());
         user = builder.build();
         try {
@@ -3467,6 +3518,21 @@ public class MemoryMessagesStore implements IMessagesStore {
         return mForbiddenClientSendTypes;
     }
 
+    @Override
+    public List<Integer> getBlackListExceptionTypes() {
+        return mBlackListExceptionTypes;
+    }
+
+    @Override
+    public List<Integer> getGroupMuteExceptionTypes() {
+        return mGroupMuteExceptionTypes;
+    }
+
+    @Override
+    public List<Integer> getGlobalMuteExceptionTypes() {
+        return mGlobalMuteExceptionTypes;
+    }
+
     @Override
     public long getMessageHead(String user) {
         TreeMap<Long, Long> maps = userMessages.get(user);

broker/src/main/java/io/moquette/server/netty/NettyAcceptor.java

@@ -150,8 +150,8 @@ public class NettyAcceptor implements ServerAcceptor {
             LOG.error("An interruptedException was caught while initializing server. Protocol={}", protocol, ex);
         } catch (Exception e) {
             e.printStackTrace();
-            LOG.error("端口 {} 已经被占用。请检查该端口被那个程序占用，找到程序停掉。\n查找端口被那个程序占用的命令是: netstat -tunlp | grep {}", port, port);
+            LOG.error("端口 {} 已经被占用或者无权限使用。如果无权限使用，请以root权限运行；如果被占用，请检查该端口被那个程序占用，找到程序停掉。\n查找端口被那个程序占用的命令是: netstat -tunlp | grep {}", port, port);
-            System.out.println("端口 " + port + " 已经被占用。请检查该端口被那个程序占用，找到程序停掉。\n查找端口被那个程序占用的命令是: netstat -tunlp | grep " + port);
+            System.out.println("端口 " + port + " 已经被占用或者无权限使用。如果无权限使用，请以root权限运行；如果被占用，请检查该端口被那个程序占用，找到程序停掉。\n查找端口被那个程序占用的命令是: netstat -tunlp | grep " + port);
             System.exit(-1);
         }
     }

broker/src/main/java/io/moquette/spi/IMessagesStore.java

@@ -220,6 +220,9 @@ public interface IMessagesStore {
     int getVisibleQuitKickoffNotification();
 
     List<Integer> getClientForbiddenSendTypes();
+    List<Integer> getBlackListExceptionTypes();
+    List<Integer> getGroupMuteExceptionTypes();
+    List<Integer> getGlobalMuteExceptionTypes();
 
     long getMessageHead(String user);
     long getFriendHead(String user);

broker/src/main/java/io/moquette/spi/impl/MessagesPublisher.java

@@ -332,7 +332,7 @@ public class MessagesPublisher {
                         }
                     }
 
-                    if ((StringUtil.isNullOrEmpty(pushContent) && messageContentType != 402 && messageContentType != 400 && messageContentType != 401)) {
+                    if ((StringUtil.isNullOrEmpty(pushContent) && messageContentType != 402 && messageContentType != 400 && messageContentType != 401 && messageContentType != 406)) {
                         LOG.info("push content is empty and contenttype is {}", messageContentType);
                         continue;
                     }

broker/src/main/java/win/liyufan/im/SensitiveFilter.java

@@ -17,33 +17,6 @@ public class SensitiveFilter {
 
     private static final String END_FLAG="end";
 
-    public static void main(String[] args) {
-        Set<String> sensitiveWords=new HashSet<>();
-        sensitiveWords.add("你是傻逼");
-        sensitiveWords.add("你是傻逼啊");
-        sensitiveWords.add("你是坏蛋");
-        sensitiveWords.add("你个大笨蛋");
-        sensitiveWords.add("我去年买了个表");
-        sensitiveWords.add("shit");
-
-        SensitiveFilter textFilter=new SensitiveFilter(sensitiveWords);
-        String text="你你你你是傻逼啊你，说你呢，你个大笨蛋。";
-        System.out.println(textFilter.getSensitiveWords(text,MatchType.MAX_MATCH));
-        for (int i = 0; i < 100; i++) {
-            new Thread(new Runnable() {
-                @Override
-                public void run() {
-                    System.out.println(textFilter.getSensitiveWords(text,MatchType.MAX_MATCH));
-                }
-            }).start();
-        }
-        try {
-            Thread.sleep(1000 * 100);
-        } catch (InterruptedException e) {
-            e.printStackTrace();
-        }
-    }
-
     public boolean isContainSensitiveWord(String text){
         Set<String> sensitiveWords = getSensitiveWords(text, MatchType.MIN_MATCH);
         if(sensitiveWords!=null&&sensitiveWords.size()>0){

common/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>wildfirechat-parent</artifactId>
         <groupId>cn.wildfirechat</groupId>
-        <version>0.57</version>
+        <version>0.61</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

common/src/main/java/cn/wildfirechat/common/ErrorCode.java

@@ -40,8 +40,9 @@ public enum ErrorCode {
 
     ERROR_CODE_ALREADY_FRIENDS(23, "already friends"),
 
-    ERROR_CODE_RECALL_TIME_EXPIRED(24, "time expired"),
+    ERROR_CODE_RECALL_TIME_EXPIRED(24, "recall time expired"),
 
+    ERROR_CODE_API_NOT_SIGNED(239, "api not signed or sign parameter not completion"),
     ERROR_CODE_GROUP_EXCEED_MAX_MEMBER_COUNT(240, "group exceed max member count"),
     ERROR_CODE_GROUP_MUTED(241, "group is muted"),
     ERROR_CODE_SENSITIVE_MATCHED(242, "sensitive matched"),

common/src/main/java/cn/wildfirechat/pojos/GroupNotificationBinaryContent.java

@@ -160,4 +160,9 @@ public class GroupNotificationBinaryContent {
     public WFCMessage.MessageContent getAllowGroupMemberNotifyContent() {
         return getGroupNotifyContent(ProtoConstants.MESSAGE_CONTENT_TYPE_ALLOW_MEMBER);
     }
+
+    public WFCMessage.MessageContent getChangeGroupExtraNotifyContent() {
+        return getGroupNotifyContent(ProtoConstants.MESSAGE_CONTENT_TYPE_MODIFY_GROUP_EXTRA);
+    }
+
 }

common/src/main/java/cn/wildfirechat/pojos/InputModifyGroupInfo.java

@@ -49,11 +49,21 @@ public class InputModifyGroupInfo extends InputGroupBase {
     }
 
     public WFCMessage.ModifyGroupInfoRequest toProtoGroupRequest() {
-        return WFCMessage.ModifyGroupInfoRequest.newBuilder()
+        if(notify_message != null && notify_message.getType() > 0) {
-            .setGroupId(group_id)
+            return WFCMessage.ModifyGroupInfoRequest.newBuilder()
-            .setType(type)
+                .setGroupId(group_id)
-            .setValue(value)
+                .setType(type)
-            .addAllToLine(to_lines == null || to_lines.isEmpty() ? Arrays.asList(0) : to_lines)
+                .setValue(value)
-            .build();
+                .addAllToLine(to_lines == null || to_lines.isEmpty() ? Arrays.asList(0) : to_lines)
+                .setNotifyContent(notify_message.toProtoMessageContent())
+                .build();
+        } else {
+            return WFCMessage.ModifyGroupInfoRequest.newBuilder()
+                .setGroupId(group_id)
+                .setType(type)
+                .setValue(value)
+                .addAllToLine(to_lines == null || to_lines.isEmpty() ? Arrays.asList(0) : to_lines)
+                .build();
+        }
     }
 }

common/src/main/java/cn/wildfirechat/proto/ProtoConstants.java

@@ -211,6 +211,7 @@ public class ProtoConstants {
         int Update_User_Company = 0x40;
         int Update_User_Social = 0x80;
         int Update_User_Extra = 0x100;
+        int Update_User_Name = 0x200;
     }
 
 
@@ -234,5 +235,7 @@ public class ProtoConstants {
     public static final int MESSAGE_CONTENT_TYPE_ALLOW_MEMBER = 119;
     public static final int MESSAGE_CONTENT_TYPE_KICKOF_GROUP_MEMBER_VISIBLE = 120;
     public static final int MESSAGE_CONTENT_TYPE_QUIT_GROUP_VISIBLE = 121;
+
+    public static final int MESSAGE_CONTENT_TYPE_MODIFY_GROUP_EXTRA = 122;
 }
 

distribution/pom.xml

@@ -6,7 +6,7 @@
         <!--<relativePath>../pom.xml</relativePath>-->
         <artifactId>wildfirechat-parent</artifactId>
         <groupId>cn.wildfirechat</groupId>
-        <version>0.57</version>
+        <version>0.61</version>
     </parent>
 
     <artifactId>distribution</artifactId>

distribution/src/main/assembly/assembly.xml

@@ -74,12 +74,6 @@
             <destName>moquette-broker-${project.version}.jar</destName>
         </file>
 
-        <file>
-            <source>../common/target/common-${project.version}.jar</source>
-            <outputDirectory>java_client/</outputDirectory>
-            <destName>common-${project.version}.jar</destName>
-        </file>
-
         <file>
             <source>../sdk/target/sdk-${project.version}.jar</source>
             <outputDirectory>server_sdk/</outputDirectory>

distribution/src/main/resources/wildfirechat.conf

@@ -76,6 +76,14 @@ message.recall_time_limit 120
 ## 一般用于重要类型消息，比如交易、充值等，禁止客户端发送，仅限于服务器发送，提高安全性。
 message.forbidden_client_send_types 3999,4000,4001
 
+## 当禁止发送消息时，允许例外发送的消息。这种一般用户需要被动回应的消息。比如群中被禁言的用户，他无法主动发起音视频，但可以接听未被禁言用户的音视频
+## 因为音视频使用了消息作为信令，所以就需要允许发送音视频信令。如果开发了其它场景也需要被动回应消息，可以加在这里。
+## 黑名单时允许发送的消息类型
+message.blacklist_exception_types 401,402,403,404,405,407,408,410,411
+## 群禁言或者聊天室或者频道禁言时允许发送的消息类型
+message.group_mute_exception_types 401,402,403,404,405,407,408,410,411
+## 用户被全局禁言时允许发送的消息类型
+message.global_mute_exception_types 401,402,403,404,405,407,408,410,411
 ##禁止搜索用户
 friend.disable_search false
 

distribution/src/main/scripts/wildfirechat.bat

@@ -72,4 +72,8 @@ rem set JAVA_OPTS=%JAVA_OPTS% -XX:+UseGCLogFileRotation
 rem set JAVA_OPTS=%JAVA_OPTS% -XX:NumberOfGCLogFiles=10
 rem set JAVA_OPTS=%JAVA_OPTS% -XX:GCLogFileSize=10M"
 
+echo 请设置JVM参数Xmx和Xms！！！
+rem set JAVA_OPTS=%JAVA_OPTS% -Xmx2G
+rem set JAVA_OPTS=%JAVA_OPTS% -Xms2G
+
 %JAVA% -server %JAVA_OPTS% %JAVA_OPTS_SCRIPT% -Dlog4j.configuration=file:%LOG_FILE% -Dcom.mchange.v2.c3p0.cfg.xml=%C3P0_CONF_FILE% -Dhazelcast.configuration=file:%HZ_CONF_FILE% -Dwildfirechat.path=%WILDFIRECHAT_PATH% -cp %WILDFIRECHAT_HOME%\lib\* cn.wildfirechat.server.Server

distribution/src/main/scripts/wildfirechat.sh

@@ -83,8 +83,9 @@ JAVA_OPTS="$JAVA_OPTS -XX:+UseGCLogFileRotation"
 JAVA_OPTS="$JAVA_OPTS -XX:NumberOfGCLogFiles=10"
 JAVA_OPTS="$JAVA_OPTS -XX:GCLogFileSize=10M"
 
-#JAVA_OPTS="$JAVA_OPTS -Xmx128M"
+echo "请设置JVM参数Xmx和Xms！！！"
-#JAVA_OPTS="$JAVA_OPTS -Xms128M"
+#JAVA_OPTS="$JAVA_OPTS -Xmx2G"
+#JAVA_OPTS="$JAVA_OPTS -Xms2G"
 
 
 $JAVA -server $JAVA_OPTS $JAVA_OPTS_SCRIPT -Dlog4j.configuration="file:$LOG_FILE" -Dcom.mchange.v2.c3p0.cfg.xml="$C3P0_CONF_FILE" -Dhazelcast.configuration="file:$HZ_CONF_FILE" -Dwildfirechat.path="$WILDFIRECHAT_PATH" -cp "$WILDFIRECHAT_HOME/lib/*" cn.wildfirechat.server.Server

pom.xml

@@ -12,7 +12,7 @@
     <artifactId>wildfirechat-parent</artifactId>
 
     <packaging>pom</packaging>
-    <version>0.57</version>
+    <version>0.61</version>
     <name>Wildfire Chat</name>
     <description>Wildfire Chat Server</description>
     <inceptionYear>2019</inceptionYear>

sdk/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>wildfirechat-parent</artifactId>
         <groupId>cn.wildfirechat</groupId>
-        <version>0.57</version>
+        <version>0.61</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

sdk/src/main/java/cn/wildfirechat/sdk/Main.java

@@ -1184,8 +1184,6 @@ public class Main {
         ChannelServiceApi channelServiceApi = new ChannelServiceApi("http://localhost", resultCreateChannel.getResult().getTargetId(), secret);
 
 
-
-        if (commercialServer) {
             //3. 测试channel api功能
             IMResult<Void> resultVoid = channelServiceApi.subscribe("userId2");
             if (resultVoid != null && resultVoid.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
@@ -1234,7 +1232,7 @@ public class Main {
                 System.out.println("get user info failure");
                 System.exit(-1);
             }
-        }
+
 
 
         MessagePayload payload = new MessagePayload();