add chatroom event

Author: huangminlinux

ios/RCTJMessageModule/JMessageHelper.h

@@ -10,6 +10,7 @@
 #import <JMessage/JMessage.h>
 
 #define kJJMessageReceiveMessage     @"kJJMessageReceiveMessage"
+#define kJJMessageReceiveChatRoomMessage     @"kJJMessageReceiveChatRoomMessage"
 #define kJJMessageSendMessageRespone @"kJJMessageSendMessageRespone"
 
 //Conversation 回调

ios/RCTJMessageModule/JMessageHelper.m

@@ -78,6 +78,16 @@ - (void)onReceiveMessage:(JMSGMessage *)message error:(NSError *)error{
   [[NSNotificationCenter defaultCenter] postNotificationName:kJJMessageReceiveMessage object:dict];
 }
 
+- (void)onReceiveChatRoomConversation:(JMSGConversation *)conversation messages:(NSArray<__kindof JMSGMessage *> *)messages {
+
+  NSArray *msgDicArr = [messages mapObjectsUsingBlock:^id(id obj, NSUInteger idx) {
+    JMSGMessage *msg = obj;
+    return [msg messageToDictionary];
+  }];
+  
+  [[NSNotificationCenter defaultCenter] postNotificationName:kJJMessageReceiveChatRoomMessage object:msgDicArr];
+}
+
 - (void)onReceiveNotificationEvent:(JMSGNotificationEvent *)event {
   switch (event.eventType) {
     case kJMSGEventNotificationLoginKicked:

ios/RCTJMessageModule/RCTJMessageModule.h

@@ -18,6 +18,7 @@
 
 
 #define receiveMsgEvent @"JMessage.ReceiveMsgEvent" // 接收到消息事件
+#define receiveChatRoomMsgEvent @"JMessage.ReceiveChatRoomMsgEvent" // 接收到消息事件
 #define conversationChangeEvent @"JMessage.conversationChange" // 会话变更事件
 #define loginStateChangedEvent @"JMessage.LoginStateChanged" //
 #define clickMessageNotificationEvent @"JMessage.ClickMessageNotification" // 点击推送 Android Only

ios/RCTJMessageModule/RCTJMessageModule.m

@@ -62,17 +62,21 @@ -(void)initNotifications {
   [[NSNotificationCenter defaultCenter] removeObserver:self]; 
 
   NSNotificationCenter *defaultCenter = [NSNotificationCenter defaultCenter];
-  // have
   [defaultCenter addObserver:self
                     selector:@selector(didReceiveJMessageMessage:)
                         name:kJJMessageReceiveMessage
                       object:nil];
 
+  [defaultCenter addObserver:self
+                    selector:@selector(didReceiveJMessageChatRoomMessage:)
+                        name:kJJMessageReceiveChatRoomMessage
+                      object:nil];
+  
   [defaultCenter addObserver:self
                     selector:@selector(conversationChanged:)
                         name:kJJMessageConversationChanged
                       object:nil];
-  // have
+  
   [defaultCenter addObserver:self
                     selector:@selector(didSendMessage:)
                         name:kJJMessageSendMessageRespone
@@ -82,7 +86,7 @@ -(void)initNotifications {
 //                    selector:@selector(unreadChanged:)
 //                        name:kJJMessageUnreadChanged
 //                      object:nil];
-  // have
+  
   [defaultCenter addObserver:self
                     selector:@selector(loginStateChanged:)
                         name:kJJMessageLoginStateChanged
@@ -399,6 +403,11 @@ - (void)didReceiveJMessageMessage:(NSNotification *)notification {
   [self.bridge.eventDispatcher sendAppEventWithName:receiveMsgEvent body:notification.object];
 }
 
+- (void)didReceiveJMessageChatRoomMessage:(NSNotification *)notification {
+  [self.bridge.eventDispatcher sendAppEventWithName:receiveChatRoomMsgEvent body:notification.object];
+}
+
+
 - (void)conversationChanged:(NSNotification *)notification {
   [self.bridge.eventDispatcher sendAppEventWithName:conversationChangeEvent body:notification.object];
 }
@@ -2416,5 +2425,35 @@ - (JMSGOptionalContent *)convertDicToJMSGOptionalContent:(NSDictionary *)dic {
   }];
 }
 
+RCT_EXPORT_METHOD(getChatRoomOwner:(NSDictionary *)param
+                  successCallback:(RCTResponseSenderBlock)successCallback
+                  failCallBack:(RCTResponseSenderBlock)failCallback) {
+  if (!param[@"roomId"]) {
+    failCallback(@[[self getParamError]]);
+    return;
+  }
+  
+  [JMSGChatRoom getChatRoomInfosWithRoomIds:@[param[@"roomId"]] completionHandler:^(id resultObject, NSError *error) {
+    if (error) {
+      failCallback(@[[error errorToDictionary]]);
+      return;
+    }
+    NSArray *chatRoomArr = resultObject;
+    if (chatRoomArr == nil || chatRoomArr.count == 0) {
+      failCallback(@[[self getErrorWithLog:@"cann't found chat room from this roomId!"]]);
+      return;
+    }
+    JMSGChatRoom *chatRoom = chatRoomArr[0];
+    [chatRoom getChatRoomOwnerInfo:^(id resultObject, NSError *error) {
+      if (error) {
+        failCallback(@[[error errorToDictionary]]);
+        return;
+      }
+      JMSGUser *user = resultObject;
+      successCallback(@[[user userToDictionary]]);
+    }];
+  }];
+}
+
 
 @end