feat: Add SendBroadcast method and update BroadcastReceiver interface to include topic in message handling

Author: lijy91

src/broadcast_center.cpp

@@ -12,21 +12,15 @@ BroadcastCenter::~BroadcastCenter() {
   std::cout << "BroadcastCenter::~BroadcastCenter()" << std::endl;
 };
 
-void BroadcastCenter::NotifyReceivers(
-    const std::string& topic,
-    std::function<void(BroadcastReceiver*)> callback) {
-  for (const auto& receiver : receivers_) {
-    callback(receiver);
-  }
-}
-
 BroadcastEventHandler::BroadcastEventHandler(
-    std::function<void(const std::string& message)> onBroadcastReceivedCallback)
+    std::function<void(const std::string& topic, const std::string& message)>
+        onBroadcastReceivedCallback)
     : onBroadcastReceivedCallback_(std::move(onBroadcastReceivedCallback)) {}
 
-void BroadcastEventHandler::OnBroadcastReceived(const std::string& message) {
+void BroadcastEventHandler::OnBroadcastReceived(const std::string& topic,
+                                                const std::string& message) {
   if (onBroadcastReceivedCallback_) {
-    onBroadcastReceivedCallback_(message);
+    onBroadcastReceivedCallback_(topic, message);
   }
 }
 

src/broadcast_center.h

@@ -14,7 +14,8 @@ namespace nativeapi {
 // want to listen for broadcasts.
 class BroadcastReceiver {
  public:
-  virtual void OnBroadcastReceived(const std::string& message) = 0;
+  virtual void OnBroadcastReceived(const std::string& topic,
+                                   const std::string& message) = 0;
 };
 
 // BroadcastCenter is a singleton that manages all broadcasts on the system.
@@ -23,17 +24,16 @@ class BroadcastCenter {
   BroadcastCenter();
   virtual ~BroadcastCenter();
 
+  // Send a broadcast message to all receivers of a given topic
+  void SendBroadcast(const std::string& topic, const std::string& message);
+
   // Register a receiver to the broadcast center
   void RegisterReceiver(const std::string& topic, BroadcastReceiver* receiver);
 
   // Unregister a receiver from the broadcast center
   void UnregisterReceiver(const std::string& topic,
                           BroadcastReceiver* receiver);
 
-  // Notify all receivers of a given topic
-  void NotifyReceivers(const std::string& topic,
-                       std::function<void(BroadcastReceiver*)> callback);
-
  private:
   std::vector<BroadcastReceiver*> receivers_;
 };
@@ -43,14 +43,17 @@ class BroadcastCenter {
 class BroadcastEventHandler : public BroadcastReceiver {
  public:
   // Constructor that takes callbacks for broadcast events
-  BroadcastEventHandler(std::function<void(const std::string& message)>
-                            onBroadcastReceivedCallback);
+  BroadcastEventHandler(
+      std::function<void(const std::string& topic, const std::string& message)>
+          onBroadcastReceivedCallback);
 
   // Implementation of OnBroadcastReceive from BroadcastReceiver interface
-  void OnBroadcastReceived(const std::string& message) override;
+  void OnBroadcastReceived(const std::string& topic,
+                           const std::string& message) override;
 
  private:
-  std::function<void(const std::string&)> onBroadcastReceivedCallback_;
+  std::function<void(const std::string& topic, const std::string& message)>
+      onBroadcastReceivedCallback_;
 };
 
 }  // namespace nativeapi

src/broadcast_center_macos.mm

@@ -13,19 +13,27 @@
 // Static map to store BroadcastCenter instances
 static std::map<BroadcastCenter*, std::string> g_broadcast_centers;
 
-void BroadcastCenter::RegisterReceiver(const std::string& topic, BroadcastReceiver* receiver) {
-  receivers_.push_back(receiver);
+void BroadcastCenter::SendBroadcast(const std::string& topic, const std::string& message) {
+  NSDistributedNotificationCenter* center = [NSDistributedNotificationCenter defaultCenter];
+  [center postNotificationName:[NSString stringWithUTF8String:topic.c_str()]
+                        object:nil
+                      userInfo:@{@"message" : [NSString stringWithUTF8String:message.c_str()]}
+            deliverImmediately:YES];
+}
 
+void BroadcastCenter::RegisterReceiver(const std::string& topic, BroadcastReceiver* receiver) {
   NSDistributedNotificationCenter* center = [NSDistributedNotificationCenter defaultCenter];
   [center addObserverForName:[NSString stringWithUTF8String:topic.c_str()]
                       object:nil
                        queue:[NSOperationQueue mainQueue]
                   usingBlock:^(NSNotification* notification) {
                     std::string message = [notification.userInfo[@"message"] UTF8String];
-                    receiver->OnBroadcastReceived(message);
+                    receiver->OnBroadcastReceived(topic, message);
                   }];
 }
 
-void BroadcastCenter::UnregisterReceiver(const std::string& topic, BroadcastReceiver* receiver) {}
+void BroadcastCenter::UnregisterReceiver(const std::string& topic, BroadcastReceiver* receiver) {
+  // TODO: Implement
+}
 
 }  // namespace nativeapi