//

// RNClientWrapper.m

// RNStringee

//

// Created by HoangDuoc on 5/20/20.

//

#import "RNClientWrapper.h"

#import "RNStringeeInstanceManager.h"

#import "RNStringeeClient.h"

#import "RCTConvert+StringeeHelper.h"

@implementation RNClientWrapper {

NSMutableArray<NSString *> *jsEvents;

NSArray<StringeeServerAddress *> *_serverAddresses;

NSString *_baseUrl;

NSString *_stringeexBaseUrl;

BOOL _firstConnectTime;

}

- (instancetype)initWithIdentifier:(NSString *)identifier baseUrl:(NSString *)baseUrl serverAddresses:(NSArray<StringeeServerAddress *> *)serverAddresses stringeeXBaseUrl:(NSString *)stringeeXBaseUrl

{

self = [super init];

if (self) {

self.identifier = identifier;

jsEvents = [[NSMutableArray alloc] init];

_messages = [[NSMutableDictionary alloc] init];

_serverAddresses = serverAddresses;

_baseUrl = baseUrl;

_stringeexBaseUrl = stringeeXBaseUrl;

// Fix cho phan live-chat

_firstConnectTime = true;

_client = [[StringeeClient alloc] init];

[_client setStringeeXBaseUrl:stringeeXBaseUrl completionHandler:^(BOOL status, int code, NSString *message) {

}];

}

return self;

}

- (void)dealloc

{

[_client disconnect];

_client = nil;

[[NSNotificationCenter defaultCenter] removeObserver:self];

}

- (void)setNativeEvent:(NSString *)event {

[jsEvents addObject:event];

}

- (void)removeNativeEvent:(NSString *)event {

int index = -1;

index = (int)[jsEvents indexOfObject:event];

if (index >= 0) {

[jsEvents removeObjectAtIndex:index];

}

}

- (void)createClientIfNeed {

if (!_client || _firstConnectTime) {

if (_serverAddresses != nil && _serverAddresses.count > 0) {

_client = [[StringeeClient alloc] initWithServerAddress:_serverAddresses];

} else {

_client = [[StringeeClient alloc] init];

}

_client.connectionDelegate = self;

_client.incomingCallDelegate = self;

if (_baseUrl != nil && _baseUrl.length > 0) {

[_client setRestBaseUrl:_baseUrl completionHandler:^(BOOL status, int code, NSString *message) {

}];

}

if (_stringeexBaseUrl != nil && _stringeexBaseUrl.length > 0) {

[_client setStringeeXBaseUrl:_stringeexBaseUrl completionHandler:^(BOOL status, int code, NSString *message) {

}];

}

[[NSNotificationCenter defaultCenter] addObserver:self selector:@selector(handleObjectChangeNotification:) name:StringeeClientObjectsDidChangeNotification object:_client];

[[NSNotificationCenter defaultCenter] addObserver:self selector:@selector(handleNewMessageNotification:) name:StringeeClientNewMessageNotification object:_client];

[[NSNotificationCenter defaultCenter] addObserver:self selector:@selector(handleUserTypingNotification:) name:StringeeChatUserTypingNotification object:_client];

_firstConnectTime = false;

}

}

#pragma mark Connection Delelgate

- (void)requestAccessToken:(StringeeClient *)stringeeClient {

_isConnecting = NO;

[RNStringeeInstanceManager.instance.rnClient sendEventWithName:requestAccessToken body: @{ @"uuid" : _identifier, @"data" : @{ @"userId" : stringeeClient.userId}}];

}

- (void)didConnect:(StringeeClient *)stringeeClient isReconnecting:(BOOL)isReconnecting {

if ([jsEvents containsObject:didConnect]) {

[RNStringeeInstanceManager.instance.rnClient sendEventWithName:didConnect body: @{ @"uuid" : _identifier, @"data" : @{ @"userId" : stringeeClient.userId, @"projectId" : stringeeClient.projectId, @"isReconnecting" : @(isReconnecting) } }];

}

}

- (void)didDisConnect:(StringeeClient *)stringeeClient isReconnecting:(BOOL)isReconnecting {

if ([jsEvents containsObject:didDisConnect]) {

[RNStringeeInstanceManager.instance.rnClient sendEventWithName:didDisConnect body: @{ @"uuid" : _identifier, @"data" : @{ @"userId" : stringeeClient.userId, @"projectId" : stringeeClient.projectId, @"isReconnecting" : @(isReconnecting) }}];

}

}

- (void)didFailWithError:(StringeeClient *)stringeeClient code:(int)code message:(NSString *)message {

if ([jsEvents containsObject:didFailWithError]) {

[RNStringeeInstanceManager.instance.rnClient sendEventWithName:didFailWithError body: @{ @"uuid" : _identifier, @"data" : @{ @"userId" : stringeeClient.userId, @"code" : @(code), @"message" : message }}];

}

}

- (void)didReceiveCustomMessage:(StringeeClient *)stringeeClient message:(NSDictionary *)message fromUserId:(NSString *)userId {

if ([jsEvents containsObject:didReceiveCustomMessage]) {

NSString *data;

if (message) {

NSError *err;

NSData *jsonData = [NSJSONSerialization dataWithJSONObject:message options:0 error:&err];

data = [[NSString alloc] initWithData:jsonData encoding:NSUTF8StringEncoding];

}

data = (data != nil) ? data : @"";

[RNStringeeInstanceManager.instance.rnClient sendEventWithName:didReceiveCustomMessage body: @{ @"uuid" : _identifier, @"data" : @{ @"from" : userId, @"data" : data }}];

}

}

- (void)didReceiveChatRequest:(StringeeClient *)stringeeClient request:(StringeeChatRequest *)request {

if ([jsEvents containsObject:didReceiveChatRequest]) {

[RNStringeeInstanceManager.instance.rnClient sendEventWithName:didReceiveChatRequest body: @{ @"uuid" : _identifier, @"data" : @{ @"request" : [RCTConvert StringeeChatRequest:request] }}];

}

}

- (void)didReceiveTransferChatRequest:(StringeeClient *)stringeeClient request:(StringeeChatRequest *)request {

if ([jsEvents containsObject:didReceiveTransferChatRequest]) {

[RNStringeeInstanceManager.instance.rnClient sendEventWithName:didReceiveTransferChatRequest body: @{ @"uuid" : _identifier, @"data" : @{ @"request" : [RCTConvert StringeeChatRequest:request] }}];

}

}

- (void)timeoutAnswerChat:(StringeeClient *)stringeeClient request:(StringeeChatRequest *)request {

if ([jsEvents containsObject:timeoutAnswerChat]) {

[RNStringeeInstanceManager.instance.rnClient sendEventWithName:timeoutAnswerChat body: @{ @"uuid" : _identifier, @"data" : @{ @"request" : [RCTConvert StringeeChatRequest:request] }}];

}

}

- (void)timeoutInQueue:(StringeeClient *)stringeeClient info:(NSDictionary *)info {

if ([jsEvents containsObject:timeoutInQueue]) {

id rInfo = info != nil ? info : [NSNull null];

[RNStringeeInstanceManager.instance.rnClient sendEventWithName:timeoutInQueue body: @{ @"uuid" : _identifier, @"data" : info}];

}

}

- (void)conversationEnded:(StringeeClient *)stringeeClient info:(NSDictionary *)info {

if ([jsEvents containsObject:conversationEnded]) {

id rInfo = info != nil ? info : [NSNull null];

[RNStringeeInstanceManager.instance.rnClient sendEventWithName:conversationEnded body: @{ @"uuid" : _identifier, @"data" : info}];

}

}

#pragma mark Call Delelgate

- (void)incomingCallWithStringeeClient:(StringeeClient *)stringeeClient stringeeCall:(StringeeCall *)stringeeCall {

[[RNStringeeInstanceManager instance].calls setObject:stringeeCall forKey:stringeeCall.callId];

if ([jsEvents containsObject:incomingCall]) {

int index = 0;

if (stringeeCall.callType == CallTypeCallIn) {

// Phone-to-app

index = 3;

} else if (stringeeCall.callType == CallTypeCallOut) {

// App-to-phone

index = 2;

} else if (stringeeCall.callType == CallTypeInternalIncomingCall) {

// App-to-app-incoming-call

index = 1;

} else {

// App-to-app-outgoing-call

index = 0;

}

id returnUserId = stringeeClient.userId ? stringeeClient.userId : [NSNull null];

id returnCallId = stringeeCall.callId ? stringeeCall.callId : [NSNull null];

id returnFrom = stringeeCall.from ? stringeeCall.from : [NSNull null];

id returnTo = stringeeCall.to ? stringeeCall.to : [NSNull null];

id returnFromAlias = stringeeCall.fromAlias ? stringeeCall.fromAlias : [NSNull null];

id returnToAlias = stringeeCall.toAlias ? stringeeCall.toAlias : [NSNull null];

id returnCustomData = stringeeCall.customDataFromYourServer ? stringeeCall.customDataFromYourServer : [NSNull null];

[RNStringeeInstanceManager.instance.rnClient sendEventWithName:incomingCall body: @{ @"uuid" : _identifier, @"data" : @{ @"userId" : returnUserId, @"callId" : returnCallId, @"from" : returnFrom, @"to" : returnTo, @"fromAlias" : returnFromAlias, @"toAlias" : returnToAlias, @"callType" : @(index), @"isVideoCall" : @(stringeeCall.isVideoCall), @"customDataFromYourServer" : returnCustomData, @"serial" : @(stringeeCall.serial)}}];

}

}

- (void)incomingCallWithStringeeClient:(StringeeClient *)stringeeClient stringeeCall2:(StringeeCall2 *)stringeeCall2 {

if (stringeeCall2.callId) {

[[RNStringeeInstanceManager instance].call2s setObject:stringeeCall2 forKey:stringeeCall2.callId];

}

if ([jsEvents containsObject:incomingCall2]) {

int index = 0;

if (stringeeCall2.callType == CallTypeCallIn) {

// Phone-to-app

index = 3;

} else if (stringeeCall2.callType == CallTypeCallOut) {

// App-to-phone

index = 2;

} else if (stringeeCall2.callType == CallTypeInternalIncomingCall) {

// App-to-app-incoming-call

index = 1;

} else {

// App-to-app-outgoing-call

index = 0;

}

id returnUserId = stringeeClient.userId ? stringeeClient.userId : [NSNull null];

id returnCallId = stringeeCall2.callId ? stringeeCall2.callId : [NSNull null];

id returnFrom = stringeeCall2.from ? stringeeCall2.from : [NSNull null];

id returnTo = stringeeCall2.to ? stringeeCall2.to : [NSNull null];

id returnFromAlias = stringeeCall2.fromAlias ? stringeeCall2.fromAlias : [NSNull null];

id returnToAlias = stringeeCall2.toAlias ? stringeeCall2.toAlias : [NSNull null];

id returnCustomData = stringeeCall2.customDataFromYourServer ? stringeeCall2.customDataFromYourServer : [NSNull null];

[RNStringeeInstanceManager.instance.rnClient sendEventWithName:incomingCall2 body: @{ @"uuid" : _identifier, @"data" : @{ @"userId" : returnUserId, @"callId" : returnCallId, @"from" : returnFrom, @"to" : returnTo, @"fromAlias" : returnFromAlias, @"toAlias" : returnToAlias, @"callType" : @(index), @"isVideoCall" : @(stringeeCall2.isVideoCall), @"customDataFromYourServer" : returnCustomData, @"serial" : @(stringeeCall2.serial)}}];

}

}

#pragma mark Handle chat event

- (void)handleObjectChangeNotification:(NSNotification *)notification {

if (![jsEvents containsObject:objectChangeNotification]) return;

NSArray *objectChanges = [notification.userInfo objectForKey:StringeeClientObjectChangesUserInfoKey];

if (!objectChanges.count) {

return;

}

NSMutableArray *objects = [[NSMutableArray alloc] init];

for (StringeeObjectChange *objectChange in objectChanges) {

[objects addObject:objectChange.object];

}

StringeeObjectChange *firstObjectChange = [objectChanges firstObject];

id firstObject = [objects firstObject];

int objectType;

NSArray *jsObjectDatas;

if ([firstObject isKindOfClass:[StringeeConversation class]]) {

objectType = 0;

jsObjectDatas = [RCTConvert StringeeConversations:objects];

} else if ([firstObject isKindOfClass:[StringeeMessage class]]) {

objectType = 1;

jsObjectDatas = [RCTConvert StringeeMessages:objects];

// Xoá đối tượng message đã lưu

for (NSDictionary *message in jsObjectDatas) {

NSNumber *state = message[@"state"];

if (state.intValue == StringeeMessageStatusRead) {

NSString *localId = message[@"localId"];

if (localId) {

[_messages removeObjectForKey:localId];

}

}

}

} else {

objectType = 2;

}

id returnObjects = jsObjectDatas ? jsObjectDatas : [NSNull null];

[RNStringeeInstanceManager.instance.rnClient sendEventWithName:objectChangeNotification body: @{ @"uuid" : _identifier, @"data" : @{ @"objectType" : @(objectType), @"objects" : returnObjects, @"changeType" : @(firstObjectChange.type) }}];

}

- (void)handleNewMessageNotification:(NSNotification *)notification {

if (![jsEvents containsObject:objectChangeNotification]) return;

NSDictionary *userInfo = [notification userInfo];

if (!userInfo) return;

NSString *convId = [userInfo objectForKey:StringeeClientNewMessageConversationIDKey];

if (convId == nil || convId.length == 0) {

return;

}

// Lấy về conversation

__weak RNClientWrapper *weakSelf = self;

[_client getConversationWithConversationId:convId completionHandler:^(BOOL status, int code, NSString *message, StringeeConversation *conversation) {

if (!conversation) {

return;

}

if (weakSelf == nil) {

return;

}

RNClientWrapper *strongSelf = weakSelf;

[RNStringeeInstanceManager.instance.rnClient sendEventWithName:objectChangeNotification body: @{ @"uuid" : strongSelf.identifier, @"data" : @{ @"objectType" : @(0), @"objects" : @[[RCTConvert StringeeConversation:conversation]], @"changeType" : @(StringeeObjectChangeTypeCreate) }}];

}];

}

- (void)handleUserTypingNotification:(NSNotification *)notification {

if (![jsEvents containsObject:userBeginTyping] && ![jsEvents containsObject:userEndTyping]) return;

NSDictionary *userInfo = [notification userInfo];

if (!userInfo) return;

NSString *convId = [userInfo objectForKey:@"convId"] != nil ? [userInfo objectForKey:@"convId"] : @"";

NSString *userId = [userInfo objectForKey:@"userId"] != nil ? [userInfo objectForKey:@"userId"] : @"";

NSString *displayName = [userInfo objectForKey:@"displayName"] != nil ? [userInfo objectForKey:@"displayName"] : @"";

BOOL begin = [[userInfo objectForKey:@"begin"] boolValue];

NSDictionary *infos = @{

@"convId" : convId,

@"userId" : userId,

@"displayName" : displayName

};

NSString *eventName = begin ? userBeginTyping : userEndTyping;

[RNStringeeInstanceManager.instance.rnClient sendEventWithName:eventName body: @{ @"uuid" : _identifier, @"data" : infos}];

}

@end