feat: generate code (#220)

Generate code with the following content:

base branch: dev_2109

public headers: rtm_2.2.5

> This pull request is trigger by bot, you can checkout this branch and
update it.

---------

Co-authored-by: ZGaopeng <ZGaopeng@users.noreply.github.com>
Co-authored-by: Gopein <z_gaopeng@sina.com>

Author: github-actions[bot]

.github/workflows/on_pr_closed.yml

@@ -12,7 +12,7 @@ jobs:
   # 3. The PR has `ci:prepare_release` label
   release_if_merged:
     if: ${{ github.event.pull_request.merged == true && 
-            (github.event.pull_request.base.ref == 'main' || github.event.pull_request.base.ref == 'master') && 
+            github.event.pull_request.base.ref == 'main' && 
             contains(github.event.pull_request.labels.*.name, 'ci:prepare_release') }}
     outputs:
       release_version: ${{steps.release.outputs.version}}

android/build.gradle

@@ -68,8 +68,8 @@ dependencies {
     println("Include libs/*jar for debugging.")
     api fileTree(dir: "libs", include: ["*.jar"])
   } else {
-    api 'io.agora.rtm:iris-rtm:2.2.1-build.1'
-    api 'io.agora:agora-rtm:2.2.1'
+    api 'io.agora.rtm:iris-rtm:2.2.5-build.2'
+    api 'io.agora:agora-rtm:2.2.5'
   }
 }
 

example/lib/src/rtm_api_demo.dart

@@ -35,6 +35,7 @@ class _RtmApiDemoState extends State<RtmApiDemo> {
 
   bool _isWhoNowIncludeUserId = true;
   bool _isWhoNowIncludeState = false;
+  bool _ispPolicyEnabled = false;
   late TextEditingController _isWhoNowPageController;
 
   late TextEditingController _rtmClientMessageController;
@@ -46,6 +47,10 @@ class _RtmApiDemoState extends State<RtmApiDemo> {
 
   late RtmClient _rtmClient;
   late RtcEngine _rtcEngine;
+  bool _publishStoreInHistory = true;
+  late TextEditingController _historyCountController;
+  late TextEditingController _historyStartController;
+  late TextEditingController _historyEndController;
 
   @override
   void initState() {
@@ -60,6 +65,11 @@ class _RtmApiDemoState extends State<RtmApiDemo> {
     _isWhoNowPageController = TextEditingController();
     _rtmClientPublishCustomTypeController = TextEditingController();
     _keyValueInputGroupWidgetController = KeyValueInputGroupWidgetController();
+
+    _historyCountController = TextEditingController(text: '100');
+    _historyStartController = TextEditingController(text: '0');
+    _historyEndController = TextEditingController(text: '0');
+
   }
 
   @override
@@ -73,6 +83,9 @@ class _RtmApiDemoState extends State<RtmApiDemo> {
     _isWhoNowPageController.dispose();
     _rtmClientPublishCustomTypeController.dispose();
     _keyValueInputGroupWidgetController.dispose();
+    _historyCountController.dispose();
+    _historyStartController.dispose();
+    _historyEndController.dispose();
     super.dispose();
   }
 
@@ -158,8 +171,12 @@ class _RtmApiDemoState extends State<RtmApiDemo> {
           children: [
             _textField(_userIdController, 'Input user id'),
             _button('create RTM', () async {
-              final (status, client) =
-                  await RTM(config.appId, _userIdController.text);
+              final (status, client) = _ispPolicyEnabled
+                  ? await RTM(config.appId, _userIdController.text,
+                      config: RtmConfig(
+                        ispPolicyEnabled: _ispPolicyEnabled,
+                      ))
+                  : await RTM(config.appId, _userIdController.text);
               if (status.error) {
                 logSink.log(
                     '[error] errorCode: ${status.errorCode}, operation: ${status.operation}, reason: ${status.reason}');
@@ -193,6 +210,12 @@ class _RtmApiDemoState extends State<RtmApiDemo> {
               );
               await _rtmClient.setParameters('{"rtm.log_filter":2063}');
             }),
+            _switch('ispPolicyEnabled', _ispPolicyEnabled, (v) {
+              setState(() {
+                _ispPolicyEnabled = v;
+              });
+            }),
+
             _textField(_channelNameController, 'Input channel name'),
             _button('RtmClient.login', () async {
               final (status, _) = await _rtmClient.login(config.token);
@@ -406,25 +429,70 @@ class _RtmApiDemoState extends State<RtmApiDemo> {
                     _rtmClientPublishCustomTypeController, 'Input customType'),
                 _button('RtmClient.publish', () async {
                   final (status, _) = await _rtmClient.publish(
-                      _channelNameController.text,
-                      _rtmClientMessageController.text,
-                      channelType: _rtmChannelType,
-                      customType: _rtmClientPublishCustomTypeController.text);
-
+                    _channelNameController.text,
+                    _rtmClientMessageController.text,
+                    channelType: _rtmChannelType,
+                    customType: _rtmClientPublishCustomTypeController.text,
+                    storeInHistory: _publishStoreInHistory,
+                  );
                   logSink.log('[PublishResult] errorCode: ${status.errorCode}');
                 }),
                 _button('RtmClient.publishBinaryMessage', () async {
                   final (status, _) = await _rtmClient.publishBinaryMessage(
-                      _channelNameController.text,
-                      Uint8List.fromList(
-                          utf8.encode(_rtmClientMessageController.text)),
-                      channelType: _rtmChannelType,
-                      customType: _rtmClientPublishCustomTypeController.text);
-
+                    _channelNameController.text,
+                    Uint8List.fromList(
+                        utf8.encode(_rtmClientMessageController.text)),
+                    channelType: _rtmChannelType,
+                    customType: _rtmClientPublishCustomTypeController.text,
+                    storeInHistory: _publishStoreInHistory,
+                  );
                   logSink.log('[PublishResult] errorCode: ${status.errorCode}');
                 }),
               ],
             ),
+            _card(
+              [
+                Wrap(
+                  children: [
+                    _switch('storeInHistory', _publishStoreInHistory, (v) {
+                      setState(() => _publishStoreInHistory = v);
+                    }),
+                  ],
+                ),
+                _textField(_historyCountController, 'Input messageCount'),
+                _textField(_historyStartController, 'Input start'),
+                _textField(_historyEndController, 'Input end'),
+                _button('RtmHistory.getMessages', () async {
+                  final history = _rtmClient.getHistory();
+
+                  final (s2, result) = await history.getMessages(
+                    _channelNameController.text,
+                    _rtmChannelType,
+                    messageCount:
+                        int.tryParse(_historyCountController.text) ?? 100,
+                    start: int.tryParse(_historyStartController.text) ?? 0,
+                    end: int.tryParse(_historyEndController.text) ?? 0,
+                  );
+                  logSink.log('[getMessages] errorCode: ${s2.errorCode}, '
+                      'count: ${result?.count}, newStart: ${result?.newStart}');
+
+                  for (final event in (result?.messageList ?? [])) {
+                    logSink.log('[history] publisher=${event.publisher}, '
+                        'type=${event.messageType}, customType=${event.customType}, '
+                        'ts=${event.timestamp}, message=${event.message}');
+                    if (event.messageType == RtmMessageType.string) {
+                      final messageText = utf8.decode(event.message!);
+                      logSink.log(
+                          'event : ${event.toJson()} \nmessage: $messageText');
+                    } else if (event.messageType == RtmMessageType.binary) {
+                      final binaryData = event.message;
+                      logSink.log(
+                          'event : ${event.toJson()} \n binaryData length: ${binaryData?.length}');
+                    }
+                  }
+                }),
+              ],
+            ),
             _card(
               [
                 const Text('Work with Agora Rtc Engine'),

ios/agora_rtm.podspec

@@ -25,8 +25,8 @@ Pod::Spec.new do |s|
     puts '[plugin_dev] Found .plugin_dev file, use vendored_frameworks instead.'
     s.vendored_frameworks = 'libs/*.xcframework'
   else
-  s.dependency 'AgoraIrisRTM_iOS', '2.2.1-build.1'
-  s.dependency 'AgoraRtm', '2.2.1'
+  s.dependency 'AgoraIrisRTM_iOS', '2.2.5-build.2'
+  s.dependency 'AgoraRtm', '2.2.5'
   end
 
   # Flutter.framework does not contain a i386 slice.