[ISSUE #86]🎉Namesrv support get system topic list (request code 304) (#96)

Author: mxsm

README.md

@@ -99,7 +99,7 @@ Feature list:
 | Delete topic in name server            | 216          | :sparkling_heart: :white_check_mark: |        |
 | Register topic in name server          | 217          | :sparkling_heart: :white_check_mark: |        |
 | Get topics by cluster                  | 224          | :sparkling_heart: :white_check_mark: |        |
-| Get system topic list from name server | 304          | :broken_heart: :x: |        |
+| Get system topic list from name server | 304          | :sparkling_heart: :white_check_mark: |        |
 | Get unit topic list                    | 311          | :broken_heart: :x: |        |
 | Get has unit sub topic list            | 312          | :broken_heart: :x: |        |
 | Get has unit sub ununit topic list     | 313          | :broken_heart: :x: |        |

rocketmq-namesrv/README.md

@@ -32,7 +32,7 @@ Feature list:
 | Delete topic in name server            | 216          | :sparkling_heart: :white_check_mark: |        |
 | Register topic in name server          | 217          | :sparkling_heart: :white_check_mark: |        |
 | Get topics by cluster                  | 224          | :sparkling_heart: :white_check_mark: |        |
-| Get system topic list from name server | 304          | :broken_heart: :x:                   |        |
+| Get system topic list from name server | 304          | :sparkling_heart: :white_check_mark: |        |
 | Get unit topic list                    | 311          | :broken_heart: :x:                   |        |
 | Get has unit sub topic list            | 312          | :broken_heart: :x:                   |        |
 | Get has unit sub ununit topic list     | 313          | :broken_heart: :x:                   |        |

rocketmq-namesrv/src/processor/default_request_processor.rs

@@ -98,6 +98,9 @@ impl RequestProcessor for DefaultRequestProcessor {
             Some(RequestCode::RegisterTopicInNamesrv) => self.register_topic_to_name_srv(request),
             Some(RequestCode::GetKvlistByNamespace) => self.get_kv_list_by_namespace(request),
             Some(RequestCode::GetTopicsByCluster) => self.get_topics_by_cluster(request),
+            Some(RequestCode::GetSystemTopicListFromNs) => {
+                self.get_system_topic_list_from_ns(request)
+            }
             _ => RemotingCommand::create_response_command_with_code(
                 RemotingSysResponseCode::SystemError,
             ),
@@ -442,6 +445,11 @@ impl DefaultRequestProcessor {
             .get_topics_by_cluster(request_header.cluster.as_str());
         RemotingCommand::create_response_command().set_body(Some(topics_by_cluster.encode()))
     }
+
+    fn get_system_topic_list_from_ns(&mut self, _request: RemotingCommand) -> RemotingCommand {
+        let topic_list = self.route_info_manager.read().get_system_topic_list();
+        RemotingCommand::create_response_command().set_body(Some(topic_list.encode()))
+    }
 }
 
 fn extract_register_topic_config_from_request(

rocketmq-namesrv/src/route/route_info_manager.rs

@@ -776,4 +776,26 @@ impl RouteInfoManager {
             broker_addr: None,
         }
     }
+
+    pub(crate) fn get_system_topic_list(&self) -> TopicList {
+        let mut topic_list = Vec::new();
+        let mut broker_addr_out = String::new();
+        for (cluster_name, broker_set) in self.cluster_addr_table.iter() {
+            topic_list.push(cluster_name.clone());
+            broker_set.iter().for_each(|broker_name| {
+                topic_list.push(broker_name.clone());
+            });
+        }
+        if !self.broker_addr_table.is_empty() {
+            for broker_addr in self.broker_addr_table.values() {
+                for ip in broker_addr.broker_addrs().values() {
+                    broker_addr_out = ip.clone();
+                }
+            }
+        }
+        TopicList {
+            topic_list,
+            broker_addr: Some(broker_addr_out),
+        }
+    }
 }