Ei kuvausta

RCTAgora.m 95KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336
  1. //
  2. // RCTAgora.m
  3. // RCTAgora
  4. //
  5. // Created by 邓博 on 2017/6/13.
  6. // Copyright © 2017年 Syan. All rights reserved.
  7. //
  8. #import "RCTAgora.h"
  9. #import <React/RCTEventDispatcher.h>
  10. #import <React/RCTBridge.h>
  11. #import <React/RCTUIManager.h>
  12. #import <React/RCTView.h>
  13. #import <AgoraRtcEngineKit/AgoraRtcEngineKit.h>
  14. #import "AgoraConst.h"
  15. #define MAX_DATA_LENGTH 1024
  16. @interface RCTAgora ()
  17. @property (strong, nonatomic) AgoraRtcEngineKit *rtcEngine;
  18. @property (strong, nonatomic) NSString *appId;
  19. @property (strong, nonatomic) NSData *metadata;
  20. @end
  21. @implementation RCTAgora {
  22. RCTResponseSenderBlock _block;
  23. bool hasListeners;
  24. }
  25. +(BOOL)requiresMainQueueSetup {
  26. return YES;
  27. }
  28. - (NSInteger) metadataMaxSize {
  29. return MAX_DATA_LENGTH;
  30. }
  31. - (NSData *_Nullable)readyToSendMetadataAtTimestamp:(NSTimeInterval)timestamp
  32. {
  33. if (nil == _metadata) {
  34. return nil;
  35. }
  36. NSData *toSend = [_metadata copy];
  37. if ([toSend length] > MAX_DATA_LENGTH) {
  38. return nil;
  39. }
  40. _metadata = nil;
  41. return toSend;
  42. }
  43. - (void)receiveMetadata:(NSData *_Nonnull)data fromUser:(NSInteger)uid atTimestamp:(NSTimeInterval)timestamp {
  44. NSString *dataStr = [[NSString alloc] initWithData:data encoding:NSUTF8StringEncoding];
  45. [self sendEvent:AGMediaMetaDataReceived params:@{
  46. @"uid": @(uid),
  47. @"data": dataStr,
  48. @"ts": @(timestamp)
  49. }];
  50. }
  51. RCT_EXPORT_MODULE();
  52. - (UIColor *) UIColorFromRGB:(NSUInteger)rgbValue {
  53. return [UIColor colorWithRed:((float)((rgbValue & 0xFF0000) >> 16))/255.0 green:((float)((rgbValue & 0xFF00) >> 8))/255.0 blue:((float)(rgbValue & 0xFF))/255.0 alpha:1.0];
  54. }
  55. - (AgoraImage *) makeAgoraImage:(NSDictionary *)options {
  56. AgoraImage *img = [AgoraImage new];
  57. img.url = [NSURL URLWithString:options[@"url"]];
  58. img.rect = CGRectMake((CGFloat)[options[@"x"] floatValue],
  59. (CGFloat)[options[@"y"] floatValue],
  60. (CGFloat)[options[@"width"] floatValue],
  61. (CGFloat)[options[@"height"] floatValue]);
  62. return img;
  63. }
  64. - (NSDictionary *)constantsToExport {
  65. return @{
  66. @"FPS1": @(AgoraVideoFrameRateFps1),
  67. @"FPS7": @(AgoraVideoFrameRateFps7),
  68. @"FPS10": @(AgoraVideoFrameRateFps10),
  69. @"FPS15": @(AgoraVideoFrameRateFps15),
  70. @"FPS24": @(AgoraVideoFrameRateFps24),
  71. @"FPS30": @(AgoraVideoFrameRateFps30),
  72. @"FPS60": @(AgoraVideoFrameRateFps60),
  73. @"Adaptative": @(AgoraVideoOutputOrientationModeAdaptative),
  74. @"FixedLandscape": @(AgoraVideoOutputOrientationModeFixedLandscape),
  75. @"FixedPortrait": @(AgoraVideoOutputOrientationModeFixedPortrait),
  76. @"Host": @(AgoraClientRoleBroadcaster),
  77. @"Audience": @(AgoraClientRoleAudience),
  78. @"UserOfflineReasonQuit": @(AgoraUserOfflineReasonQuit),
  79. @"UserOfflineReasonDropped": @(AgoraUserOfflineReasonDropped),
  80. @"UserOfflineReasonBecomeAudience": @(AgoraUserOfflineReasonBecomeAudience),
  81. @"CodecTypeBaseLine": @(AgoraVideoCodecProfileTypeBaseLine),
  82. @"CodecTypeMain": @(AgoraVideoCodecProfileTypeMain),
  83. @"CodecTypeHigh": @(AgoraVideoCodecProfileTypeHigh),
  84. @"AudioSampleRateType32000": @(AgoraAudioSampleRateType32000),
  85. @"AudioSampleRateType44100": @(AgoraAudioSampleRateType44100),
  86. @"AudioSampleRateType48000": @(AgoraAudioSampleRateType48000),
  87. @"QualityLow": @(AgoraAudioRecordingQualityLow),
  88. @"QualityMedium": @(AgoraAudioRecordingQualityMedium),
  89. @"QualityHigh": @(AgoraAudioRecordingQualityHigh),
  90. @"Disconnected": @(AgoraConnectionStateDisconnected),
  91. @"Connecting": @(AgoraConnectionStateConnecting),
  92. @"Connected": @(AgoraConnectionStateConnected),
  93. @"Reconnecting": @(AgoraConnectionStateReconnecting),
  94. @"ConnectionFailed": @(AgoraConnectionStateFailed),
  95. @"ConnectionChangedConnecting": @(AgoraConnectionChangedConnecting),
  96. @"ConnectionChangedJoinSuccess": @(AgoraConnectionChangedJoinSuccess),
  97. @"ConnectionChangedInterrupted": @(AgoraConnectionChangedInterrupted),
  98. @"ConnectionChangedBannedByServer": @(AgoraConnectionChangedBannedByServer),
  99. @"ConnectionChangedJoinFailed": @(AgoraConnectionChangedJoinFailed),
  100. @"ConnectionChangedLeaveChannel": @(AgoraConnectionChangedLeaveChannel),
  101. @"AudioOutputRoutingDefault": @(AgoraAudioOutputRoutingDefault),
  102. @"AudioOutputRoutingHeadset": @(AgoraAudioOutputRoutingHeadset),
  103. @"AudioOutputRoutingEarpiece": @(AgoraAudioOutputRoutingEarpiece),
  104. @"AudioOutputRoutingHeadsetNoMic": @(AgoraAudioOutputRoutingHeadsetNoMic),
  105. @"AudioOutputRoutingSpeakerphone": @(AgoraAudioOutputRoutingSpeakerphone),
  106. @"AudioOutputRoutingLoudspeaker": @(AgoraAudioOutputRoutingLoudspeaker),
  107. @"AudioOutputRoutingHeadsetBluetooth": @(AgoraAudioOutputRoutingHeadsetBluetooth),
  108. @"NetworkQualityUnknown": @(AgoraNetworkQualityUnknown),
  109. @"NetworkQualityExcellent": @(AgoraNetworkQualityExcellent),
  110. @"NetworkQualityGood": @(AgoraNetworkQualityGood),
  111. @"NetworkQualityPoor": @(AgoraNetworkQualityPoor),
  112. @"NetworkQualityBad": @(AgoraNetworkQualityBad),
  113. @"NetworkQualityVBad": @(AgoraNetworkQualityVBad),
  114. @"NetworkQualityDown": @(AgoraNetworkQualityDown),
  115. @"ErrorCodeNoError": @(AgoraErrorCodeNoError),
  116. @"ErrorCodeFailed": @(AgoraErrorCodeFailed),
  117. @"ErrorCodeInvalidArgument": @(AgoraErrorCodeInvalidArgument),
  118. @"ErrorCodeTimedOut": @(AgoraErrorCodeTimedOut),
  119. @"ErrorCodeAlreadyInUse": @(AgoraErrorCodeAlreadyInUse),
  120. @"ErrorCodeAbort": @(AgoraErrorCodeAbort),
  121. @"ErrorCodeResourceLimited": @(AgoraErrorCodeResourceLimited),
  122. @"AudioProfileDefault": @(AgoraAudioProfileDefault),
  123. @"AudioProfileSpeechStandard": @(AgoraAudioProfileSpeechStandard),
  124. @"AudioProfileMusicStandard": @(AgoraAudioProfileMusicStandard),
  125. @"AudioProfileMusicStandardStereo": @(AgoraAudioProfileMusicStandardStereo),
  126. @"AudioProfileMusicHighQuality": @(AgoraAudioProfileMusicHighQuality),
  127. @"AudioProfileMusicHighQualityStereo": @(AgoraAudioProfileMusicHighQualityStereo),
  128. @"AudioScenarioDefault": @(AgoraAudioScenarioDefault),
  129. @"AudioScenarioChatRoomEntertainment": @(AgoraAudioScenarioChatRoomEntertainment),
  130. @"AudioScenarioEducation": @(AgoraAudioScenarioEducation),
  131. @"AudioScenarioGameStreaming": @(AgoraAudioScenarioGameStreaming),
  132. @"AudioScenarioShowRoom": @(AgoraAudioScenarioShowRoom),
  133. @"AudioScenarioChatRoomGaming": @(AgoraAudioScenarioChatRoomGaming),
  134. @"AudioEqualizationBand31": @(AgoraAudioEqualizationBand31),
  135. @"AudioEqualizationBand62": @(AgoraAudioEqualizationBand62),
  136. @"AudioEqualizationBand125": @(AgoraAudioEqualizationBand125),
  137. @"AudioEqualizationBand250": @(AgoraAudioEqualizationBand250),
  138. @"AudioEqualizationBand500": @(AgoraAudioEqualizationBand500),
  139. @"AudioEqualizationBand1K": @(AgoraAudioEqualizationBand1K),
  140. @"AudioEqualizationBand2K": @(AgoraAudioEqualizationBand2K),
  141. @"AudioEqualizationBand4K": @(AgoraAudioEqualizationBand4K),
  142. @"AudioEqualizationBand8K": @(AgoraAudioEqualizationBand8K),
  143. @"AudioEqualizationBand16K": @(AgoraAudioEqualizationBand16K),
  144. @"AudioRawFrameOperationModeReadOnly": @(AgoraAudioRawFrameOperationModeReadOnly),
  145. @"AudioRawFrameOperationModeWriteOnly": @(AgoraAudioRawFrameOperationModeWriteOnly),
  146. @"AudioRawFrameOperationModeReadWrite": @(AgoraAudioRawFrameOperationModeReadWrite),
  147. @"VideoStreamTypeHigh": @(AgoraVideoStreamTypeHigh),
  148. @"VideoStreamTypeLow": @(AgoraVideoStreamTypeLow),
  149. @"VideoMirrorModeAuto": @(AgoraVideoMirrorModeAuto),
  150. @"VideoMirrorModeEnabled": @(AgoraVideoMirrorModeEnabled),
  151. @"VideoMirrorModeDisabled": @(AgoraVideoMirrorModeDisabled),
  152. @"ChannelProfileCommunication": @(AgoraChannelProfileCommunication),
  153. @"ChannelProfileLiveBroadcasting": @(AgoraChannelProfileLiveBroadcasting),
  154. @"ChannelProfileGame": @(AgoraChannelProfileGame),
  155. @"AudioMode": @(AgoraAudioMode),
  156. @"VideoMode": @(AgoraVideoMode),
  157. };
  158. }
  159. // init
  160. RCT_EXPORT_METHOD(init:(NSDictionary *)options) {
  161. [self startObserving];
  162. [AgoraConst share].appid = options[@"appid"];
  163. self.rtcEngine = [AgoraRtcEngineKit sharedEngineWithAppId:options[@"appid"] delegate:self];
  164. self.appId = options[@"appid"];
  165. [AgoraConst share].rtcEngine = self.rtcEngine;
  166. [self.rtcEngine setAppType:AgoraRtc_APP_TYPE_REACTNATIVE];
  167. //channel mode
  168. [self.rtcEngine setChannelProfile:[options[@"channelProfile"] integerValue]];
  169. //enable dual stream
  170. if ([options objectForKey:@"dualStream"]) {
  171. [self.rtcEngine enableDualStreamMode:[options[@"dualStream"] boolValue]];
  172. }
  173. dispatch_sync(dispatch_get_main_queue(), ^{
  174. [self.rtcEngine enableVideo];
  175. [self.rtcEngine enableAudio];
  176. });
  177. if ([options objectForKey:@"mode"]) {
  178. switch([options[@"mode"] integerValue]) {
  179. case AgoraAudioMode: {
  180. [self.rtcEngine enableLocalAudio:true];
  181. [self.rtcEngine enableLocalVideo:false];
  182. break;
  183. }
  184. case AgoraVideoMode: {
  185. [self.rtcEngine enableLocalVideo:true];
  186. [self.rtcEngine enableLocalAudio:false];
  187. break;
  188. }
  189. }
  190. } else {
  191. [self.rtcEngine enableLocalVideo:true];
  192. [self.rtcEngine enableLocalAudio:true];
  193. }
  194. if ([options objectForKey:@"beauty"]) {
  195. AgoraBeautyOptions *beautyOption = [[AgoraBeautyOptions alloc] init];
  196. beautyOption.lighteningContrastLevel = [options[@"beauty"][@"lighteningContrastLevel"] integerValue];
  197. beautyOption.lighteningLevel = [options[@"beauty"][@"lighteningLevel"] floatValue];
  198. beautyOption.smoothnessLevel = [options[@"beauty"][@"smoothnessLevel"] floatValue];
  199. beautyOption.rednessLevel = [options[@"beauty"][@"rednessLevel"] floatValue];
  200. [self.rtcEngine setBeautyEffectOptions:true options:beautyOption];
  201. }
  202. if ([options objectForKey:@"voice"]) {
  203. NSInteger voiceValue = [options[@"voice"][@"value"] integerValue];
  204. NSString *voiceType = options[@"voice"][@"type"];
  205. if ([voiceType isEqualToString: @"changer"]) {
  206. [self.rtcEngine setLocalVoiceChanger:(AgoraAudioVoiceChanger)voiceValue];
  207. }
  208. if ([voiceType isEqualToString: @"reverbPreset"]) {
  209. [self.rtcEngine setLocalVoiceReverbPreset:(AgoraAudioReverbPreset)voiceValue];
  210. }
  211. }
  212. if (options[@"secret"] != nil) {
  213. [self.rtcEngine setEncryptionSecret:options[@"secret"]];
  214. if (options[@"secretMode"] != nil) {
  215. [self.rtcEngine setEncryptionMode:options[@"secretMode"]];
  216. }
  217. }
  218. AgoraVideoEncoderConfiguration *video_encoder_config = [[AgoraVideoEncoderConfiguration new] initWithWidth:[options[@"videoEncoderConfig"][@"width"] integerValue] height:[options[@"videoEncoderConfig"][@"height"] integerValue] frameRate:[options[@"videoEncoderConfig"][@"frameRate"] integerValue] bitrate:[options[@"videoEncoderConfig"][@"bitrate"] integerValue] orientationMode: (AgoraVideoOutputOrientationMode)[options[@"videoEncoderConfig"][@"orientationMode"] integerValue]];
  219. [self.rtcEngine setVideoEncoderConfiguration:video_encoder_config];
  220. [self.rtcEngine setClientRole:(AgoraClientRole)[options[@"clientRole"] integerValue]];
  221. [self.rtcEngine setAudioProfile:(AgoraAudioProfile)[options[@"audioProfile"] integerValue]
  222. scenario:(AgoraAudioScenario)[options[@"audioScenario"] integerValue]];
  223. //Enable Agora Native SDK be Interoperable with Agora Web SDK
  224. [self.rtcEngine enableWebSdkInteroperability:YES];
  225. }
  226. // renew token
  227. RCT_EXPORT_METHOD(renewToken
  228. :(NSString *)token
  229. resolve:(RCTPromiseResolveBlock)resolve
  230. reject:(RCTPromiseRejectBlock)reject) {
  231. NSInteger res = [self.rtcEngine renewToken:token];
  232. if (res == 0) {
  233. resolve(nil);
  234. } else {
  235. reject(@(-1).stringValue, @(res).stringValue, nil);
  236. }
  237. }
  238. // enable websdk interoperability
  239. RCT_EXPORT_METHOD(enableWebSdkInteroperability: (BOOL)enabled
  240. resolve:(RCTPromiseResolveBlock)resolve
  241. reject:(RCTPromiseRejectBlock)reject) {
  242. NSInteger res = [self.rtcEngine enableWebSdkInteroperability:enabled];
  243. if (res == 0) {
  244. resolve(nil);
  245. } else {
  246. reject(@(-1).stringValue, @(res).stringValue, nil);
  247. }
  248. }
  249. // get agora connection state
  250. RCT_EXPORT_METHOD(getConnectionState
  251. :(RCTPromiseResolveBlock) resolve
  252. reject:(RCTPromiseRejectBlock) reject) {
  253. resolve(@{@"state": @([self.rtcEngine getConnectionState])});
  254. }
  255. // set client role
  256. RCT_EXPORT_METHOD(setClientRole:(NSInteger)role
  257. resolve:(RCTPromiseResolveBlock)resolve
  258. reject:(RCTPromiseRejectBlock)reject) {
  259. NSInteger res = [self.rtcEngine setClientRole:(AgoraClientRole)role];
  260. if (res == 0) {
  261. resolve(nil);
  262. } else {
  263. reject(@(-1).stringValue, @(res).stringValue, nil);
  264. }
  265. }
  266. // join channel
  267. RCT_EXPORT_METHOD(joinChannel:(NSDictionary *)options
  268. resolve:(RCTPromiseResolveBlock)resolve
  269. reject:(RCTPromiseRejectBlock)reject) {
  270. [AgoraConst share].localUid = (NSUInteger)[options[@"uid"] integerValue];
  271. NSInteger res = [self.rtcEngine joinChannelByToken:options[@"token"] channelId:options[@"channelName"] info:options[@"info"] uid:[AgoraConst share].localUid joinSuccess:nil];
  272. if (res == 0) {
  273. resolve(nil);
  274. } else {
  275. reject(@(-1).stringValue, @(res).stringValue, nil);
  276. }
  277. }
  278. // switch channel
  279. RCT_EXPORT_METHOD(switchChannel:(NSDictionary *)options
  280. resolve:(RCTPromiseResolveBlock)resolve
  281. reject:(RCTPromiseRejectBlock)reject) {
  282. NSInteger res = [self.rtcEngine switchChannelByToken:options[@"token"] channelId:options[@"channelName"] joinSuccess:nil];
  283. if (res == 0) {
  284. resolve(nil);
  285. } else {
  286. reject(@(-1).stringValue, @(res).stringValue, nil);
  287. }
  288. }
  289. // startChannelMediaRelay
  290. RCT_EXPORT_METHOD(startChannelMediaRelay:(NSDictionary *)options
  291. resolve:(RCTPromiseResolveBlock)resolve
  292. reject:(RCTPromiseRejectBlock)reject) {
  293. AgoraChannelMediaRelayConfiguration *config = [[AgoraChannelMediaRelayConfiguration alloc] init];
  294. AgoraChannelMediaRelayInfo *src = [config sourceInfo];
  295. NSDictionary *srcOption = options[@"src"];
  296. if (srcOption != nil) {
  297. src.channelName = srcOption[@"channelName"];
  298. src.uid = [srcOption[@"uid"] integerValue];
  299. src.token = srcOption[@"token"];
  300. }
  301. NSArray *channels = options[@"channels"];
  302. for (NSDictionary *channel in channels) {
  303. AgoraChannelMediaRelayInfo *dst = [[AgoraChannelMediaRelayInfo alloc] init];
  304. dst.channelName = channel[@"channelName"];
  305. dst.uid = [channel[@"uid"] integerValue];
  306. dst.token = channel[@"token"];
  307. [config setDestinationInfo:dst forChannelName:dst.channelName];
  308. }
  309. NSInteger res = [self.rtcEngine startChannelMediaRelay:config];
  310. if (res == 0) {
  311. resolve(nil);
  312. } else {
  313. reject(@(-1).stringValue, @(res).stringValue, nil);
  314. }
  315. }
  316. // updateChannelMediaRelay
  317. RCT_EXPORT_METHOD(updateChannelMediaRelay:(NSDictionary *)options
  318. resolve:(RCTPromiseResolveBlock)resolve
  319. reject:(RCTPromiseRejectBlock)reject) {
  320. AgoraChannelMediaRelayConfiguration *config = [[AgoraChannelMediaRelayConfiguration alloc] init];
  321. AgoraChannelMediaRelayInfo *src = [config sourceInfo];
  322. NSDictionary *srcOption = options[@"src"];
  323. if (srcOption != nil) {
  324. src.channelName = srcOption[@"channelName"];
  325. src.uid = [srcOption[@"uid"] integerValue];
  326. src.token = srcOption[@"token"];
  327. }
  328. NSArray *channels = options[@"channels"];
  329. for (NSDictionary *channel in channels) {
  330. AgoraChannelMediaRelayInfo *dst = [[AgoraChannelMediaRelayInfo alloc] init];
  331. dst.channelName = channel[@"channelName"];
  332. dst.uid = [channel[@"uid"] integerValue];
  333. dst.token = channel[@"token"];
  334. [config setDestinationInfo:dst forChannelName:dst.channelName];
  335. }
  336. NSInteger res = [self.rtcEngine updateChannelMediaRelay:config];
  337. if (res == 0) {
  338. resolve(nil);
  339. } else {
  340. reject(@(-1).stringValue, @(res).stringValue, nil);
  341. }
  342. }
  343. // removeChannelMediaRelay
  344. RCT_EXPORT_METHOD(removeChannelMediaRelay:(NSDictionary *)options
  345. resolve:(RCTPromiseResolveBlock)resolve
  346. reject:(RCTPromiseRejectBlock)reject) {
  347. AgoraChannelMediaRelayConfiguration *config = [[AgoraChannelMediaRelayConfiguration alloc] init];
  348. AgoraChannelMediaRelayInfo *src = [config sourceInfo];
  349. NSDictionary *srcOption = options[@"src"];
  350. if (srcOption != nil) {
  351. src.channelName = srcOption[@"channelName"];
  352. src.uid = [srcOption[@"uid"] integerValue];
  353. src.token = srcOption[@"token"];
  354. }
  355. NSArray *channels = options[@"channels"];
  356. for (NSDictionary *channel in channels) {
  357. if (channel[@"channelName"] != nil) {
  358. [config removeDestinationInfoForChannelName:channel[@"channelName"]];
  359. }
  360. }
  361. NSInteger res = [self.rtcEngine updateChannelMediaRelay:config];
  362. if (res == 0) {
  363. resolve(nil);
  364. } else {
  365. reject(@(-1).stringValue, @(res).stringValue, nil);
  366. }
  367. }
  368. // stopChannelMediaRelay
  369. RCT_EXPORT_METHOD(stopChannelMediaRelay:(RCTPromiseResolveBlock)resolve
  370. reject:(RCTPromiseRejectBlock)reject) {
  371. NSInteger res = [self.rtcEngine stopChannelMediaRelay];
  372. if (res == 0) {
  373. resolve(nil);
  374. } else {
  375. reject(@(-1).stringValue, @(res).stringValue, nil);
  376. }
  377. }
  378. // register user account
  379. RCT_EXPORT_METHOD(registerLocalUserAccount:(NSDictionary *)options
  380. resolve:(RCTPromiseResolveBlock)resolve
  381. reject:(RCTPromiseRejectBlock)reject) {
  382. NSInteger res = [self.rtcEngine registerLocalUserAccount:options[@"userAccount"] appId:self.appId];
  383. if (res == 0) {
  384. resolve(nil);
  385. } else {
  386. reject(@(-1).stringValue, @(res).stringValue, nil);
  387. }
  388. }
  389. // join channel with user account
  390. RCT_EXPORT_METHOD(joinChannelWithUserAccount:(NSDictionary *)options
  391. resolve:(RCTPromiseResolveBlock)resolve
  392. reject:(RCTPromiseRejectBlock)reject) {
  393. NSString *token = [options objectForKey:@"token"] != nil ? options[@"token"] : nil;
  394. NSInteger res = [self.rtcEngine joinChannelByUserAccount:options[@"userAccount"] token:token channelId:options[@"channelName"] joinSuccess:nil];
  395. if (res == 0) {
  396. resolve(nil);
  397. } else {
  398. reject(@(-1).stringValue, @(res).stringValue, nil);
  399. }
  400. }
  401. // get user info by uid
  402. RCT_EXPORT_METHOD(getUserInfoByUid:(NSUInteger)uid
  403. resolve:(RCTPromiseResolveBlock)resolve
  404. reject:(RCTPromiseRejectBlock)reject) {
  405. AgoraErrorCode code = 0;
  406. AgoraUserInfo *info = [self.rtcEngine getUserInfoByUid:uid withError:&code];
  407. if ((int)code == 0) {
  408. resolve(@{
  409. @"uid": @(info.uid),
  410. @"userAccount": info.userAccount
  411. });
  412. } else {
  413. reject(@(-1).stringValue, @((int)code).stringValue, nil);
  414. }
  415. }
  416. // get user info by user account
  417. RCT_EXPORT_METHOD(getUserInfoByUserAccount:(NSString *)userAccount
  418. resolve:(RCTPromiseResolveBlock)resolve
  419. reject:(RCTPromiseRejectBlock)reject) {
  420. AgoraErrorCode code = 0;
  421. AgoraUserInfo *info = [self.rtcEngine getUserInfoByUserAccount:userAccount withError:&code];
  422. if ((int)code == 0) {
  423. resolve(@{
  424. @"uid": @(info.uid),
  425. @"userAccount": info.userAccount
  426. });
  427. } else {
  428. reject(@(-1).stringValue, @((int)code).stringValue, nil);
  429. }
  430. }
  431. // leave channel
  432. RCT_EXPORT_METHOD(leaveChannel
  433. :(RCTPromiseResolveBlock) resolve
  434. reject:(RCTPromiseRejectBlock) reject) {
  435. NSInteger res = [self.rtcEngine leaveChannel:^(AgoraChannelStats * _Nonnull stats) {
  436. [self sendEvent:AGLeaveChannel params:@{
  437. @"message": @"leaveChannel",
  438. @"duration": @(stats.duration),
  439. @"txBytes": @(stats.txBytes),
  440. @"rxBytes": @(stats.rxBytes),
  441. @"txAudioBytes": @(stats.txAudioBytes),
  442. @"txVideoBytes": @(stats.txVideoBytes),
  443. @"rxAudioBytes": @(stats.rxAudioBytes),
  444. @"rxVideoBytes": @(stats.rxVideoBytes),
  445. @"txPacketLossRate": @(stats.txPacketLossRate),
  446. @"rxPacketLossRate": @(stats.rxPacketLossRate),
  447. @"txAudioKBitrate": @(stats.txAudioKBitrate),
  448. @"rxAudioKBitrate": @(stats.rxAudioKBitrate),
  449. @"txVideoKBitrate": @(stats.txVideoKBitrate),
  450. @"rxVideoKBitrate": @(stats.rxVideoKBitrate),
  451. @"lastmileDelay": @(stats.lastmileDelay),
  452. @"userCount": @(stats.userCount),
  453. @"cpuAppUsage": @(stats.cpuAppUsage),
  454. @"cpuTotalUsage": @(stats.cpuTotalUsage)
  455. }];
  456. }];
  457. if (res == 0) {
  458. resolve(nil);
  459. } else {
  460. reject(@(-1).stringValue, @(res).stringValue, nil);
  461. }
  462. }
  463. // destroy
  464. RCT_EXPORT_METHOD(destroy) {
  465. [self stopObserving];
  466. [AgoraRtcEngineKit destroy];
  467. }
  468. // set local video render mode
  469. RCT_EXPORT_METHOD(setLocalRenderMode:(NSInteger) mode
  470. :(RCTPromiseResolveBlock) resolve
  471. reject:(RCTPromiseRejectBlock) reject) {
  472. NSInteger res = [self.rtcEngine setLocalRenderMode:mode];
  473. if (res == 0) {
  474. resolve(nil);
  475. } else {
  476. reject(@(-1).stringValue, @(res).stringValue, nil);
  477. }
  478. }
  479. // set remote video render mode
  480. RCT_EXPORT_METHOD(setRemoteRenderMode:(NSUInteger) uid
  481. mode:(NSInteger) mode
  482. resolve:(RCTPromiseResolveBlock) resolve
  483. reject:(RCTPromiseRejectBlock) reject) {
  484. NSInteger res = [self.rtcEngine setRemoteRenderMode:uid mode:mode];
  485. if (res == 0) {
  486. resolve(nil);
  487. } else {
  488. reject(@(-1).stringValue, @(res).stringValue, nil);
  489. }
  490. }
  491. // start video preview
  492. RCT_EXPORT_METHOD(startPreview
  493. :(RCTPromiseResolveBlock) resolve
  494. reject:(RCTPromiseRejectBlock) reject) {
  495. NSInteger res = [self.rtcEngine startPreview];
  496. if (res == 0) {
  497. resolve(nil);
  498. } else {
  499. reject(@(-1).stringValue, @(res).stringValue, nil);
  500. }
  501. }
  502. // stop video preview
  503. RCT_EXPORT_METHOD(stopPreview
  504. :(RCTPromiseResolveBlock) resolve
  505. reject:(RCTPromiseRejectBlock) reject) {
  506. NSInteger res = [self.rtcEngine stopPreview];
  507. if (res == 0) {
  508. resolve(nil);
  509. } else {
  510. reject(@(-1).stringValue, @(res).stringValue, nil);
  511. }
  512. }
  513. /* enable speaker phone
  514. * @params enableSpeaker: BOOL
  515. YES: Audio output to speaker
  516. No: Audio output to the handset
  517. */
  518. RCT_EXPORT_METHOD(setEnableSpeakerphone:(BOOL)enableSpeaker
  519. :(RCTPromiseResolveBlock) resolve
  520. reject:(RCTPromiseRejectBlock) reject) {
  521. NSInteger res = [self.rtcEngine setEnableSpeakerphone: enableSpeaker];
  522. if (res == 0) {
  523. resolve(nil);
  524. } else {
  525. reject(@(-1).stringValue, @(res).stringValue, nil);
  526. }
  527. }
  528. /* set default audio speaker
  529. * @params defaultToSpeaker: BOOL
  530. YES: Audio output to speaker
  531. No: Audio output to the handset
  532. */
  533. RCT_EXPORT_METHOD(setDefaultAudioRouteToSpeakerphone:(BOOL)defaultToSpeaker
  534. resolve:(RCTPromiseResolveBlock) resolve
  535. reject:(RCTPromiseRejectBlock) reject) {
  536. NSInteger res = [self.rtcEngine setDefaultAudioRouteToSpeakerphone:defaultToSpeaker];
  537. if (res == 0) {
  538. resolve(nil);
  539. } else {
  540. reject(@(-1).stringValue, @(res).stringValue, nil);
  541. }
  542. }
  543. RCT_EXPORT_METHOD(setDefaultMuteAllRemoteAudioStreams:(BOOL)defaultToSpeaker
  544. resolve:(RCTPromiseResolveBlock) resolve
  545. reject:(RCTPromiseRejectBlock) reject) {
  546. NSInteger res = [self.rtcEngine setDefaultMuteAllRemoteAudioStreams:defaultToSpeaker];
  547. if (res == 0) {
  548. resolve(nil);
  549. } else {
  550. reject(@(-1).stringValue, @(res).stringValue, nil);
  551. }
  552. }
  553. // enable video
  554. RCT_EXPORT_METHOD(enableVideo:(RCTPromiseResolveBlock) resolve
  555. reject:(RCTPromiseRejectBlock) reject) {
  556. NSInteger res = [self.rtcEngine enableVideo];
  557. if (res == 0) {
  558. resolve(nil);
  559. } else {
  560. reject(@(-1).stringValue, @(res).stringValue, nil);
  561. }
  562. }
  563. // disable Video
  564. RCT_EXPORT_METHOD(disableVideo:(RCTPromiseResolveBlock) resolve
  565. reject:(RCTPromiseRejectBlock) reject) {
  566. NSInteger res = [self.rtcEngine disableVideo];
  567. if (res == 0) {
  568. resolve(nil);
  569. } else {
  570. reject(@(-1).stringValue, @(res).stringValue, nil);
  571. }
  572. }
  573. // enable local video
  574. RCT_EXPORT_METHOD(enableLocalVideo:(BOOL)enabled
  575. resolve:(RCTPromiseResolveBlock)resolve
  576. reject:(RCTPromiseRejectBlock)reject) {
  577. NSInteger res = [self.rtcEngine enableLocalVideo:enabled];
  578. if (res == 0) {
  579. resolve(nil);
  580. } else {
  581. reject(@(-1).stringValue, @(res).stringValue, nil);
  582. }
  583. }
  584. // mute local video stream
  585. RCT_EXPORT_METHOD(muteLocalVideoStream:(BOOL)muted
  586. resolve:(RCTPromiseResolveBlock)resolve
  587. reject:(RCTPromiseRejectBlock)reject) {
  588. NSInteger res = [self.rtcEngine muteLocalVideoStream:muted];
  589. if (res == 0) {
  590. resolve(nil);
  591. } else {
  592. reject(@(-1).stringValue, @(res).stringValue, nil);
  593. }
  594. }
  595. // mute all remote video streams
  596. RCT_EXPORT_METHOD(muteAllRemoteVideoStreams:(BOOL)muted
  597. resolve:(RCTPromiseResolveBlock)resolve
  598. reject:(RCTPromiseRejectBlock)reject) {
  599. NSInteger res = [self.rtcEngine muteAllRemoteVideoStreams:muted];
  600. if (res == 0) {
  601. resolve(nil);
  602. } else {
  603. reject(@(-1).stringValue, @(res).stringValue, nil);
  604. }
  605. }
  606. // mute video stream by uid
  607. RCT_EXPORT_METHOD(muteRemoteVideoStream:(NSUInteger)uid mute:(BOOL)mute
  608. resolve:(RCTPromiseResolveBlock)resolve
  609. reject:(RCTPromiseRejectBlock)reject) {
  610. NSInteger res = [self.rtcEngine muteRemoteVideoStream:uid mute:mute];
  611. if (res == 0) {
  612. resolve(nil);
  613. } else {
  614. reject(@(-1).stringValue, @(res).stringValue, nil);
  615. }
  616. }
  617. RCT_EXPORT_METHOD(setDefaultMuteAllRemoteVideoStreams:(BOOL)mute
  618. resolve:(RCTPromiseResolveBlock)resolve
  619. reject:(RCTPromiseRejectBlock)reject) {
  620. NSInteger res = [self.rtcEngine setDefaultMuteAllRemoteVideoStreams:mute];
  621. if (res == 0) {
  622. resolve(nil);
  623. } else {
  624. reject(@(-1).stringValue, @(res).stringValue, nil);
  625. }
  626. }
  627. // enable audio
  628. RCT_EXPORT_METHOD(enableAudio:(RCTPromiseResolveBlock)resolve
  629. reject:(RCTPromiseRejectBlock)reject) {
  630. NSInteger res = [self.rtcEngine enableAudio];
  631. if (res == 0) {
  632. resolve(nil);
  633. } else {
  634. reject(@(-1).stringValue, @(res).stringValue, nil);
  635. }
  636. }
  637. // disable audio
  638. RCT_EXPORT_METHOD(disableAudio:(RCTPromiseResolveBlock)resolve
  639. reject:(RCTPromiseRejectBlock)reject) {
  640. NSInteger res = [self.rtcEngine disableAudio];
  641. if (res == 0) {
  642. resolve(nil);
  643. } else {
  644. reject(@(-1).stringValue, @(res).stringValue, nil);
  645. }
  646. }
  647. // enable local audio
  648. RCT_EXPORT_METHOD(enableLocalAudio:(BOOL)enabled
  649. resolve:(RCTPromiseResolveBlock)resolve
  650. reject:(RCTPromiseRejectBlock)reject) {
  651. NSInteger res = [self.rtcEngine enableLocalAudio:enabled];
  652. if (res == 0) {
  653. resolve(nil);
  654. } else {
  655. reject(@(-1).stringValue, @(res).stringValue, nil);
  656. }
  657. }
  658. // mute local audio stream
  659. RCT_EXPORT_METHOD(muteLocalAudioStream:(BOOL)mute
  660. resolve:(RCTPromiseResolveBlock)resolve
  661. reject:(RCTPromiseRejectBlock)reject) {
  662. NSInteger res = [self.rtcEngine muteLocalAudioStream:mute];
  663. if (res == 0) {
  664. resolve(nil);
  665. } else {
  666. reject(@(-1).stringValue, @(res).stringValue, nil);
  667. }
  668. }
  669. // mute all remote audio stream
  670. RCT_EXPORT_METHOD(muteAllRemoteAudioStreams:(BOOL)mute
  671. resolve:(RCTPromiseResolveBlock)resolve
  672. reject:(RCTPromiseRejectBlock)reject) {
  673. NSInteger res = [self.rtcEngine muteAllRemoteAudioStreams:mute];
  674. if (res == 0) {
  675. resolve(nil);
  676. } else {
  677. reject(@(-1).stringValue, @(res).stringValue, nil);
  678. }
  679. }
  680. // mute one remote audio stream by uid
  681. RCT_EXPORT_METHOD(muteRemoteAudioStream:(NSUInteger)uid muted:(BOOL)mute
  682. resolve:(RCTPromiseResolveBlock)resolve
  683. reject:(RCTPromiseRejectBlock)reject) {
  684. NSInteger res = [self.rtcEngine muteRemoteAudioStream:uid mute:mute];
  685. if (res == 0) {
  686. resolve(nil);
  687. } else {
  688. reject(@(-1).stringValue, @(res).stringValue, nil);
  689. }
  690. }
  691. // adjust recorcding signal volume
  692. RCT_EXPORT_METHOD(adjustRecordingSignalVolume: (NSInteger) volume
  693. resolve:(RCTPromiseResolveBlock)resolve
  694. reject:(RCTPromiseRejectBlock)reject) {
  695. NSInteger res = [self.rtcEngine adjustRecordingSignalVolume:volume];
  696. if (res == 0) {
  697. resolve(nil);
  698. } else {
  699. reject(@(-1).stringValue, @(res).stringValue, nil);
  700. }
  701. }
  702. // adjust playback signal volume
  703. RCT_EXPORT_METHOD(adjustPlaybackSignalVolume: (NSInteger) volume
  704. resolve:(RCTPromiseResolveBlock)resolve
  705. reject:(RCTPromiseRejectBlock)reject) {
  706. NSInteger res = [self.rtcEngine adjustPlaybackSignalVolume:volume];
  707. if (res == 0) {
  708. resolve(nil);
  709. } else {
  710. reject(@(-1).stringValue, @(res).stringValue, nil);
  711. }
  712. }
  713. // enable audio volume indication
  714. RCT_EXPORT_METHOD(enableAudioVolumeIndication: (NSInteger) interval smooth:(NSInteger)smooth
  715. report_vad:(BOOL)report_vad
  716. resolve:(RCTPromiseResolveBlock)resolve
  717. reject:(RCTPromiseRejectBlock)reject) {
  718. NSInteger res = [self.rtcEngine enableAudioVolumeIndication:interval smooth:smooth report_vad:report_vad];
  719. if (res == 0) {
  720. resolve(nil);
  721. } else {
  722. reject(@(-1).stringValue, @(res).stringValue, nil);
  723. }
  724. }
  725. // is speaker phone enabled
  726. RCT_EXPORT_METHOD(isSpeakerphoneEnabled:(RCTResponseSenderBlock)callback) {
  727. callback(@[@{@"status": @([self.rtcEngine isSpeakerphoneEnabled])}]);
  728. }
  729. // enable in ear monitoring
  730. RCT_EXPORT_METHOD(enableInEarMonitoring:(BOOL)enabled
  731. resolve:(RCTPromiseResolveBlock)resolve
  732. reject:(RCTPromiseRejectBlock)reject) {
  733. NSInteger res = [self.rtcEngine enableInEarMonitoring:enabled];
  734. if (res == 0) {
  735. resolve(nil);
  736. } else {
  737. reject(@(-1).stringValue, @(res).stringValue, nil);
  738. }
  739. }
  740. // set in ear monitoring
  741. RCT_EXPORT_METHOD(setInEarMonitoringVolume:(NSInteger) volume
  742. resolve:(RCTPromiseResolveBlock)resolve
  743. reject:(RCTPromiseRejectBlock)reject) {
  744. NSInteger res = [self.rtcEngine setInEarMonitoringVolume:volume];
  745. if (res == 0) {
  746. resolve(nil);
  747. } else {
  748. reject(@(-1).stringValue, @(res).stringValue, nil);
  749. }
  750. }
  751. // set local voice pitch
  752. RCT_EXPORT_METHOD(setLocalVoicePitch:(double) pitch
  753. resolve:(RCTPromiseResolveBlock)resolve
  754. reject:(RCTPromiseRejectBlock)reject) {
  755. NSInteger res = [self.rtcEngine setLocalVoicePitch:pitch];
  756. if (res == 0) {
  757. resolve(nil);
  758. } else {
  759. reject(@(-1).stringValue, @(res).stringValue, nil);
  760. }
  761. }
  762. // set local video equalization of band frequency
  763. RCT_EXPORT_METHOD(setLocalVoiceEqualization:(NSInteger)band
  764. gain:(NSInteger)gain
  765. resolve:(RCTPromiseResolveBlock)resolve
  766. reject:(RCTPromiseRejectBlock)reject) {
  767. NSInteger res = [self.rtcEngine setLocalVoiceEqualizationOfBandFrequency:(AgoraAudioEqualizationBandFrequency)band withGain:gain];
  768. if (res == 0) {
  769. resolve(nil);
  770. } else {
  771. reject(@(-1).stringValue, @(res).stringValue, nil);
  772. }
  773. }
  774. // set local voice reverb of type
  775. RCT_EXPORT_METHOD(setLocalVoiceReverb:(NSInteger)reverb value:(NSInteger)value
  776. resolve:(RCTPromiseResolveBlock)resolve
  777. reject:(RCTPromiseRejectBlock)reject) {
  778. NSInteger res = [self.rtcEngine setLocalVoiceReverbOfType:(AgoraAudioReverbType)reverb withValue:value];
  779. if (res == 0) {
  780. resolve(nil);
  781. } else {
  782. reject(@(-1).stringValue, @(res).stringValue, nil);
  783. }
  784. }
  785. // start audio mixing
  786. RCT_EXPORT_METHOD(startAudioMixing:(NSDictionary *) options
  787. resolve:(RCTPromiseResolveBlock)resolve
  788. reject:(RCTPromiseRejectBlock)reject) {
  789. NSInteger res = [self.rtcEngine startAudioMixing:options[@"filepath"]
  790. loopback:[options[@"loopback"] boolValue]
  791. replace:[options[@"replace"] boolValue]
  792. cycle:[options[@"cycle"] integerValue]];
  793. if (res == 0) {
  794. resolve(nil);
  795. } else {
  796. reject(@(-1).stringValue, @(res).stringValue, nil);
  797. }
  798. }
  799. // stop audio mixing
  800. RCT_EXPORT_METHOD(stopAudioMixing:(RCTPromiseResolveBlock)resolve
  801. reject:(RCTPromiseRejectBlock)reject) {
  802. NSInteger res = [self.rtcEngine stopAudioMixing];
  803. if (res == 0) {
  804. resolve(nil);
  805. } else {
  806. reject(@(-1).stringValue, @(res).stringValue, nil);
  807. }
  808. }
  809. // pause audio mixing
  810. RCT_EXPORT_METHOD(pauseAudioMixing:(RCTPromiseResolveBlock)resolve
  811. reject:(RCTPromiseRejectBlock)reject) {
  812. NSInteger res = [self.rtcEngine pauseAudioMixing];
  813. if (res == 0) {
  814. resolve(nil);
  815. } else {
  816. reject(@(-1).stringValue, @(res).stringValue, nil);
  817. }
  818. }
  819. // resume audio mixing
  820. RCT_EXPORT_METHOD(resumeAudioMixing:(RCTPromiseResolveBlock)resolve
  821. reject:(RCTPromiseRejectBlock)reject) {
  822. NSInteger res = [self.rtcEngine resumeAudioMixing];
  823. if (res == 0) {
  824. resolve(nil);
  825. } else {
  826. reject(@(-1).stringValue, @(res).stringValue, nil);
  827. }
  828. }
  829. // adjust audio mixing volume
  830. RCT_EXPORT_METHOD(adjustAudioMixingVolume:(NSInteger) volume
  831. resolve:(RCTPromiseResolveBlock)resolve
  832. reject:(RCTPromiseRejectBlock)reject) {
  833. NSInteger res = [self.rtcEngine adjustAudioMixingVolume:volume];
  834. if (res == 0) {
  835. resolve(nil);
  836. } else {
  837. reject(@(-1).stringValue, @(res).stringValue, nil);
  838. }
  839. }
  840. // adjust audio mixing playout volume
  841. RCT_EXPORT_METHOD(adjustAudioMixingPlayoutVolume:(NSInteger) volume
  842. resolve:(RCTPromiseResolveBlock)resolve
  843. reject:(RCTPromiseRejectBlock)reject) {
  844. NSInteger res = [self.rtcEngine adjustAudioMixingPlayoutVolume:volume];
  845. if (res == 0) {
  846. resolve(nil);
  847. } else {
  848. reject(@(-1).stringValue, @(res).stringValue, nil);
  849. }
  850. }
  851. // adjust audio mixing publish volume
  852. RCT_EXPORT_METHOD(adjustAudioMixingPublishVolume:(NSInteger) volume
  853. resolve:(RCTPromiseResolveBlock)resolve
  854. reject:(RCTPromiseRejectBlock)reject) {
  855. NSInteger res = [self.rtcEngine adjustAudioMixingPublishVolume:volume];
  856. if (res == 0) {
  857. resolve(nil);
  858. } else {
  859. reject(@(-1).stringValue, @(res).stringValue, nil);
  860. }
  861. }
  862. // get audio mixing duration
  863. RCT_EXPORT_METHOD(getAudioMixingDuration
  864. :(RCTPromiseResolveBlock)resolve
  865. reject:(RCTPromiseRejectBlock)reject) {
  866. NSInteger res = [self.rtcEngine getAudioMixingDuration];
  867. if (res == 0) {
  868. resolve(nil);
  869. } else {
  870. reject(@(-1).stringValue, @(res).stringValue, nil);
  871. }
  872. }
  873. // get the volume of local audio mixing
  874. RCT_EXPORT_METHOD(getAudioMixingPlayoutVolume
  875. :(RCTPromiseResolveBlock)resolve
  876. reject:(RCTPromiseRejectBlock)reject) {
  877. int res = [self.rtcEngine getAudioMixingPlayoutVolume];
  878. if (res == 0) {
  879. resolve(nil);
  880. } else {
  881. reject(@(-1).stringValue, @(res).stringValue, nil);
  882. }
  883. }
  884. // get the volume of remote audio mixing
  885. RCT_EXPORT_METHOD(getAudioMixingPublishVolume
  886. :(RCTPromiseResolveBlock)resolve
  887. reject:(RCTPromiseRejectBlock)reject) {
  888. int res = [_rtcEngine getAudioMixingPublishVolume];
  889. if (res == 0) {
  890. resolve(nil);
  891. } else {
  892. reject(@(-1).stringValue, @(res).stringValue, nil);
  893. }
  894. }
  895. // get audio mixing current position
  896. RCT_EXPORT_METHOD(getAudioMixingCurrentPosition
  897. :(RCTPromiseResolveBlock)resolve
  898. reject:(RCTPromiseRejectBlock)reject) {
  899. NSInteger res = [self.rtcEngine getAudioMixingDuration];
  900. if (res == 0) {
  901. resolve(nil);
  902. } else {
  903. reject(@(-1).stringValue, @(res).stringValue, nil);
  904. }
  905. }
  906. // set audio mixing position
  907. RCT_EXPORT_METHOD(setAudioMixingPosition
  908. :(NSInteger) pos
  909. resolve:(RCTPromiseResolveBlock)resolve
  910. reject:(RCTPromiseRejectBlock)reject) {
  911. NSInteger res = [self.rtcEngine setAudioMixingPosition:pos];
  912. if (res == 0) {
  913. resolve(nil);
  914. } else {
  915. reject(@(-1).stringValue, @(res).stringValue, nil);
  916. }
  917. }
  918. // get effects volume
  919. RCT_EXPORT_METHOD(getEffectsVolume
  920. :(RCTPromiseResolveBlock)resolve
  921. reject:(RCTPromiseRejectBlock)reject) {
  922. double res = [self.rtcEngine getEffectsVolume];
  923. if (res == 0) {
  924. resolve(nil);
  925. } else {
  926. reject(@(-1).stringValue, @(res).stringValue, nil);
  927. }
  928. }
  929. // set effects volume
  930. RCT_EXPORT_METHOD(setEffectsVolume
  931. :(double) volume
  932. resolve:(RCTPromiseResolveBlock)resolve
  933. reject:(RCTPromiseRejectBlock)reject) {
  934. NSInteger res = [self.rtcEngine setEffectsVolume:volume];
  935. if (res == 0) {
  936. resolve(nil);
  937. } else {
  938. reject(@(-1).stringValue, @(res).stringValue, nil);
  939. }
  940. }
  941. // set volume of effect
  942. RCT_EXPORT_METHOD(setVolumeOfEffect
  943. :(int) soundId
  944. volume:(double)volume
  945. resolve:(RCTPromiseResolveBlock)resolve
  946. reject:(RCTPromiseRejectBlock)reject) {
  947. NSInteger res = [self.rtcEngine setVolumeOfEffect:soundId withVolume:volume];
  948. if (res == 0) {
  949. resolve(nil);
  950. } else {
  951. reject(@(-1).stringValue, @(res).stringValue, nil);
  952. }
  953. }
  954. // play effect
  955. RCT_EXPORT_METHOD(playEffect
  956. :(NSDictionary *)options
  957. resolve:(RCTPromiseResolveBlock)resolve
  958. reject:(RCTPromiseRejectBlock)reject) {
  959. NSInteger res = [self.rtcEngine playEffect:(int)[options[@"soundid"] integerValue]
  960. filePath:options[@"filepath"]
  961. loopCount:(int)[options[@"loopcount"] integerValue]
  962. pitch:[options[@"pitch"] doubleValue]
  963. pan:[options[@"pan"] doubleValue]
  964. gain:[options[@"gain"] doubleValue]
  965. publish:[options[@"publish"] boolValue]];
  966. if (res == 0) {
  967. resolve(nil);
  968. } else {
  969. reject(@(-1).stringValue, @(res).stringValue, nil);
  970. }
  971. }
  972. // stop effect by soundId
  973. RCT_EXPORT_METHOD(stopEffect
  974. :(NSInteger) soundId
  975. resolve:(RCTPromiseResolveBlock)resolve
  976. reject:(RCTPromiseRejectBlock)reject) {
  977. NSInteger res = [self.rtcEngine stopEffect:(int)soundId];
  978. if (res == 0) {
  979. resolve(nil);
  980. } else {
  981. reject(@(-1).stringValue, @(res).stringValue, nil);
  982. }
  983. }
  984. // stopAllEffects
  985. RCT_EXPORT_METHOD(stopAllEffects
  986. :(RCTPromiseResolveBlock)resolve
  987. reject:(RCTPromiseRejectBlock)reject) {
  988. NSInteger res = [self.rtcEngine stopAllEffects];
  989. if (res == 0) {
  990. resolve(nil);
  991. } else {
  992. reject(@(-1).stringValue, @(res).stringValue, nil);
  993. }
  994. }
  995. // preloadEffect
  996. RCT_EXPORT_METHOD(preloadEffect
  997. :(NSInteger) soundId
  998. filePath:(NSString *)filePath
  999. resolve:(RCTPromiseResolveBlock)resolve
  1000. reject:(RCTPromiseRejectBlock)reject) {
  1001. NSInteger res = [self.rtcEngine preloadEffect:(int)soundId filePath:filePath];
  1002. if (res == 0) {
  1003. resolve(nil);
  1004. } else {
  1005. reject(@(-1).stringValue, @(res).stringValue, nil);
  1006. }
  1007. }
  1008. // unload effect
  1009. RCT_EXPORT_METHOD(unloadEffect
  1010. :(NSInteger) soundId
  1011. resolve:(RCTPromiseResolveBlock)resolve
  1012. reject:(RCTPromiseRejectBlock)reject) {
  1013. NSInteger res = [self.rtcEngine unloadEffect:(int)soundId];
  1014. if (res == 0) {
  1015. resolve(nil);
  1016. } else {
  1017. reject(@(-1).stringValue, @(res).stringValue, nil);
  1018. }
  1019. }
  1020. // pause effect by id
  1021. RCT_EXPORT_METHOD(pauseEffect
  1022. :(NSInteger) soundId
  1023. resolve:(RCTPromiseResolveBlock)resolve
  1024. reject:(RCTPromiseRejectBlock)reject) {
  1025. NSInteger res = [self.rtcEngine pauseEffect:(int)soundId];
  1026. if (res == 0) {
  1027. resolve(nil);
  1028. } else {
  1029. reject(@(-1).stringValue, @(res).stringValue, nil);
  1030. }
  1031. }
  1032. // pause all effects
  1033. RCT_EXPORT_METHOD(pauseAllEffects
  1034. :(RCTPromiseResolveBlock)resolve
  1035. reject:(RCTPromiseRejectBlock)reject) {
  1036. NSInteger res = [self.rtcEngine pauseAllEffects];
  1037. if (res == 0) {
  1038. resolve(nil);
  1039. } else {
  1040. reject(@(-1).stringValue, @(res).stringValue, nil);
  1041. }
  1042. }
  1043. // resume effect by id
  1044. RCT_EXPORT_METHOD(resumeEffect:(NSInteger) soundId
  1045. resolve:(RCTPromiseResolveBlock)resolve
  1046. reject:(RCTPromiseRejectBlock)reject) {
  1047. NSInteger res = [self.rtcEngine resumeEffect:(int)soundId];
  1048. if (res == 0) {
  1049. resolve(nil);
  1050. } else {
  1051. reject(@(-1).stringValue, @(res).stringValue, nil);
  1052. }
  1053. }
  1054. // resume all effect
  1055. RCT_EXPORT_METHOD(resumeAllEffects
  1056. :(RCTPromiseResolveBlock)resolve
  1057. reject:(RCTPromiseRejectBlock)reject) {
  1058. NSInteger res = [self.rtcEngine resumeAllEffects];
  1059. if (res == 0) {
  1060. resolve(nil);
  1061. } else {
  1062. reject(@(-1).stringValue, @(res).stringValue, nil);
  1063. }
  1064. }
  1065. // start audio recording quality
  1066. RCT_EXPORT_METHOD(startAudioRecording:(NSDictionary *)options
  1067. resolve:(RCTPromiseResolveBlock)resolve
  1068. reject:(RCTPromiseRejectBlock)reject) {
  1069. AgoraAudioRecordingQuality qualityType = (AgoraAudioRecordingQuality)[options[@"quality"] integerValue];
  1070. NSInteger res = [self.rtcEngine startAudioRecording:options[@"filepath"] quality:qualityType];
  1071. if (res == 0) {
  1072. resolve(nil);
  1073. } else {
  1074. reject(@(-1).stringValue, @(res).stringValue, nil);
  1075. }
  1076. }
  1077. // stop audio recording
  1078. RCT_EXPORT_METHOD(stopAudioRecording
  1079. :(RCTPromiseResolveBlock)resolve
  1080. reject:(RCTPromiseRejectBlock)reject) {
  1081. NSInteger res = [self.rtcEngine stopAudioRecording];
  1082. if (res == 0) {
  1083. resolve(nil);
  1084. } else {
  1085. reject(@(-1).stringValue, @(res).stringValue, nil);
  1086. }
  1087. }
  1088. // set audio session operation restriction
  1089. RCT_EXPORT_METHOD(setAudioSessionOperationRestriction
  1090. :(NSInteger) restriction) {
  1091. AgoraAudioSessionOperationRestriction restrictionType = (AgoraAudioSessionOperationRestriction)restriction;
  1092. [self.rtcEngine setAudioSessionOperationRestriction:restrictionType];
  1093. }
  1094. // gateway test stop echo
  1095. RCT_EXPORT_METHOD(stopEchoTest
  1096. :(RCTPromiseResolveBlock)resolve
  1097. reject:(RCTPromiseRejectBlock)reject) {
  1098. NSInteger res = [self.rtcEngine stopEchoTest];
  1099. if (res == 0) {
  1100. resolve(nil);
  1101. } else {
  1102. reject(@(-1).stringValue, @(res).stringValue, nil);
  1103. }
  1104. }
  1105. // enable last mile test
  1106. RCT_EXPORT_METHOD(enableLastmileTest
  1107. :(RCTPromiseResolveBlock)resolve
  1108. reject:(RCTPromiseRejectBlock)reject) {
  1109. NSInteger res = [self.rtcEngine enableLastmileTest];
  1110. if (res == 0) {
  1111. resolve(nil);
  1112. } else {
  1113. reject(@(-1).stringValue, @(res).stringValue, nil);
  1114. }
  1115. }
  1116. // disable last mile test
  1117. RCT_EXPORT_METHOD(disableLastmileTest
  1118. :(RCTPromiseResolveBlock)resolve
  1119. reject:(RCTPromiseRejectBlock)reject) {
  1120. NSInteger res = [self.rtcEngine disableLastmileTest];
  1121. if (res == 0) {
  1122. resolve(nil);
  1123. } else {
  1124. reject(@(-1).stringValue, @(res).stringValue, nil);
  1125. }
  1126. }
  1127. // set recording audioframe parameters with samplerate
  1128. RCT_EXPORT_METHOD(setRecordingAudioFrameParameters:(NSDictionary *) options
  1129. resolve:(RCTPromiseResolveBlock)resolve
  1130. reject:(RCTPromiseRejectBlock)reject) {
  1131. NSInteger res = [self.rtcEngine setRecordingAudioFrameParametersWithSampleRate:[options[@"sampleRate"] integerValue]
  1132. channel:[options[@"channel"] integerValue]
  1133. mode:(AgoraAudioRawFrameOperationMode)[options[@"mode"] integerValue]
  1134. samplesPerCall:[options[@"samplesPerCall"] integerValue]
  1135. ];
  1136. if (res == 0) {
  1137. resolve(nil);
  1138. } else {
  1139. reject(@(-1).stringValue, @(res).stringValue, nil);
  1140. }
  1141. }
  1142. // set playback audioframe parameters with samplerate
  1143. RCT_EXPORT_METHOD(setPlaybackAudioFrameParameters:(NSDictionary *) options
  1144. resolve:(RCTPromiseResolveBlock)resolve
  1145. reject:(RCTPromiseRejectBlock)reject) {
  1146. NSInteger res = [self.rtcEngine setPlaybackAudioFrameParametersWithSampleRate:[options[@"sampleRate"] integerValue]
  1147. channel:[options[@"channel"] integerValue]
  1148. mode:(AgoraAudioRawFrameOperationMode)[options[@"mode"] integerValue]
  1149. samplesPerCall:[options[@"samplesPerCall"] integerValue]
  1150. ];
  1151. if (res == 0) {
  1152. resolve(nil);
  1153. } else {
  1154. reject(@(-1).stringValue, @(res).stringValue, nil);
  1155. }
  1156. }
  1157. // set mixed audio frame parameters with sample rate
  1158. RCT_EXPORT_METHOD(setMixedAudioFrameParametersWithSampleRate
  1159. :(NSDictionary *)options
  1160. resolve:(RCTPromiseResolveBlock)resolve
  1161. reject:(RCTPromiseRejectBlock)reject) {
  1162. NSInteger res = [self.rtcEngine setMixedAudioFrameParametersWithSampleRate:[options[@"sampleRate"] integerValue] samplesPerCall:[options[@"samplesPerCall"] integerValue]];
  1163. if (res == 0) {
  1164. resolve(nil);
  1165. } else {
  1166. reject(@(-1).stringValue, @(res).stringValue, nil);
  1167. }
  1168. }
  1169. // add video watermark
  1170. RCT_EXPORT_METHOD(addVideoWatermark:(NSDictionary *)options
  1171. resolve:(RCTPromiseResolveBlock)resolve
  1172. reject:(RCTPromiseRejectBlock)reject) {
  1173. NSString *urlStr = options[@"url"];
  1174. NSDictionary *watermarkOptions = options[@"options"];
  1175. WatermarkOptions *watermarkOpts = [WatermarkOptions new];
  1176. watermarkOpts.visibleInPreview = [watermarkOptions[@"visibleInPreview"] boolValue];
  1177. NSDictionary *optionPortrait = watermarkOptions[@"positionInPortraitMode"];
  1178. watermarkOpts.positionInPortraitMode = CGRectMake((CGFloat)[optionPortrait[@"x"] floatValue],
  1179. (CGFloat)[optionPortrait[@"y"] floatValue],
  1180. (CGFloat)[optionPortrait[@"width"] floatValue],
  1181. (CGFloat)[optionPortrait[@"height"] floatValue]);
  1182. NSDictionary *optionLandscape = watermarkOptions[@"positionInLandscapeMode"];
  1183. watermarkOpts.positionInLandscapeMode = CGRectMake((CGFloat)[optionLandscape[@"x"] floatValue],
  1184. (CGFloat)[optionLandscape[@"y"] floatValue],
  1185. (CGFloat)[optionLandscape[@"width"] floatValue],
  1186. (CGFloat)[optionLandscape[@"height"] floatValue]);
  1187. NSURL *url = [NSURL URLWithString:urlStr];
  1188. NSInteger res = [self.rtcEngine addVideoWatermark:url options:watermarkOpts];
  1189. if (res == 0) {
  1190. resolve(nil);
  1191. } else {
  1192. reject(@(-1).stringValue, @(res).stringValue, nil);
  1193. }
  1194. }
  1195. // clear video watermark
  1196. RCT_EXPORT_METHOD(clearVideoWatermarks
  1197. :(RCTPromiseResolveBlock)resolve
  1198. reject:(RCTPromiseRejectBlock)reject) {
  1199. NSInteger res = [self.rtcEngine clearVideoWatermarks];
  1200. if (res == 0) {
  1201. resolve(nil);
  1202. } else {
  1203. reject(@(-1).stringValue, @(res).stringValue, nil);
  1204. }
  1205. }
  1206. // set local publish fallback option
  1207. RCT_EXPORT_METHOD(setLocalPublishFallbackOption:(NSInteger)option
  1208. resolve:(RCTPromiseResolveBlock)resolve
  1209. reject:(RCTPromiseRejectBlock)reject) {
  1210. NSInteger res = [self.rtcEngine setLocalPublishFallbackOption:option];
  1211. if (res == 0) {
  1212. resolve(nil);
  1213. } else {
  1214. reject(@(-1).stringValue, @(res).stringValue, nil);
  1215. }
  1216. }
  1217. // set remote subscribe fallback option
  1218. RCT_EXPORT_METHOD(setRemoteSubscribeFallbackOption:(NSInteger)option
  1219. resolve:(RCTPromiseResolveBlock)resolve
  1220. reject:(RCTPromiseRejectBlock)reject) {
  1221. NSInteger res = [self.rtcEngine setRemoteSubscribeFallbackOption:option];
  1222. if (res == 0) {
  1223. resolve(nil);
  1224. } else {
  1225. reject(@(-1).stringValue, @(res).stringValue, nil);
  1226. }
  1227. }
  1228. // enable dual stream mode
  1229. RCT_EXPORT_METHOD(enableDualStreamMode
  1230. :(BOOL) enabled
  1231. resolve:(RCTPromiseResolveBlock)resolve
  1232. reject:(RCTPromiseRejectBlock)reject) {
  1233. NSInteger res = [self.rtcEngine enableDualStreamMode:enabled];
  1234. if (res == 0) {
  1235. resolve(nil);
  1236. } else {
  1237. reject(@(-1).stringValue, @(res).stringValue, nil);
  1238. }
  1239. }
  1240. // set remote video stream
  1241. RCT_EXPORT_METHOD(setRemoteVideoStreamType
  1242. :(NSDictionary *) options
  1243. resolve:(RCTPromiseResolveBlock)resolve
  1244. reject:(RCTPromiseRejectBlock)reject) {
  1245. NSInteger res = [self.rtcEngine setRemoteVideoStream:[options[@"uid"] integerValue]
  1246. type:(AgoraVideoStreamType)[options[@"streamType"] integerValue]];
  1247. if (res == 0) {
  1248. resolve(nil);
  1249. } else {
  1250. reject(@(-1).stringValue, @(res).stringValue, nil);
  1251. }
  1252. }
  1253. // set remote default video stream
  1254. RCT_EXPORT_METHOD(setRemoteDefaultVideoStreamType
  1255. :(NSDictionary *) options
  1256. resolve:(RCTPromiseResolveBlock)resolve
  1257. reject:(RCTPromiseRejectBlock)reject) {
  1258. NSInteger res = [self.rtcEngine setRemoteDefaultVideoStreamType:(AgoraVideoStreamType)[options[@"streamType"] integerValue]];
  1259. if (res == 0) {
  1260. resolve(nil);
  1261. } else {
  1262. reject(@(-1).stringValue, @(res).stringValue, nil);
  1263. }
  1264. }
  1265. // add injection stream url
  1266. RCT_EXPORT_METHOD(addInjectStreamUrl
  1267. :(NSDictionary *)options
  1268. resolve:(RCTPromiseResolveBlock)resolve
  1269. reject:(RCTPromiseRejectBlock)reject) {
  1270. AgoraLiveInjectStreamConfig *config = [AgoraLiveInjectStreamConfig new];
  1271. config.size = CGSizeMake([options[@"config"][@"size"][@"width"] floatValue], [options[@"config"][@"size"][@"height"] floatValue]);
  1272. config.videoGop = [options[@"config"][@"videoGop"] integerValue];
  1273. config.videoFramerate = [options[@"config"][@"videoFramerate"] integerValue];
  1274. config.videoBitrate = [options[@"config"][@"videoBitrate"] integerValue];
  1275. config.audioSampleRate = (AgoraAudioSampleRateType)[options[@"config"][@"audioSampleRate"] integerValue];
  1276. config.audioBitrate = [options[@"config"][@"audioBitrate"] integerValue];
  1277. config.audioChannels = [options[@"config"][@"audioChannels"] integerValue];
  1278. NSInteger res = [self.rtcEngine addInjectStreamUrl:options[@"url"]
  1279. config:config];
  1280. if (res == 0) {
  1281. resolve(nil);
  1282. } else {
  1283. reject(@(-1).stringValue, @(res).stringValue, nil);
  1284. }
  1285. }
  1286. // remove injection stream url
  1287. RCT_EXPORT_METHOD(removeInjectStreamUrl
  1288. :(NSString *)url
  1289. resolve:(RCTPromiseResolveBlock)resolve
  1290. reject:(RCTPromiseRejectBlock)reject) {
  1291. NSInteger res = [self.rtcEngine removeInjectStreamUrl:url];
  1292. if (res == 0) {
  1293. resolve(nil);
  1294. } else {
  1295. reject(@(-1).stringValue, @(res).stringValue, nil);
  1296. }
  1297. }
  1298. // set local video mirror mode
  1299. RCT_EXPORT_METHOD(setLocalVideoMirrorMode
  1300. :(NSInteger) mode
  1301. resolve:(RCTPromiseResolveBlock)resolve
  1302. reject:(RCTPromiseRejectBlock)reject) {
  1303. NSInteger res = [self.rtcEngine setLocalVideoMirrorMode:(AgoraVideoMirrorMode) mode];
  1304. if (res == 0) {
  1305. resolve(nil);
  1306. } else {
  1307. reject(@(-1).stringValue, @(res).stringValue, nil);
  1308. }
  1309. }
  1310. // switchCamera
  1311. RCT_EXPORT_METHOD(switchCamera
  1312. :(RCTPromiseResolveBlock)resolve
  1313. reject:(RCTPromiseRejectBlock)reject) {
  1314. NSInteger res = [self.rtcEngine switchCamera];
  1315. if (res == 0) {
  1316. resolve(nil);
  1317. } else {
  1318. reject(@(-1).stringValue, @(res).stringValue, nil);
  1319. }
  1320. }
  1321. // getCameraInfo
  1322. RCT_EXPORT_METHOD(getCameraInfo
  1323. :(RCTPromiseResolveBlock)resolve
  1324. reject:(RCTPromiseRejectBlock)reject) {
  1325. resolve(@{
  1326. @"support": @{
  1327. @"zoom": @([self.rtcEngine isCameraZoomSupported]),
  1328. @"torch": @([self.rtcEngine isCameraTorchSupported]),
  1329. @"focusPositionInPreview": @([self.rtcEngine isCameraFocusPositionInPreviewSupported]),
  1330. @"exposurePosition": @([self.rtcEngine isCameraExposurePositionSupported]),
  1331. @"autoFocusFaceMode": @([self.rtcEngine isCameraAutoFocusFaceModeSupported])
  1332. }
  1333. });
  1334. }
  1335. // setCameraZoomFactor
  1336. RCT_EXPORT_METHOD(setCameraZoomFactor
  1337. :(float)zoomFactor
  1338. resolve:(RCTPromiseResolveBlock)resolve
  1339. reject:(RCTPromiseRejectBlock)reject) {
  1340. BOOL res = [self.rtcEngine setCameraZoomFactor:(CGFloat)zoomFactor];
  1341. if (res) {
  1342. resolve(nil);
  1343. } else {
  1344. reject(@(-1).stringValue, @(res).stringValue, nil);
  1345. }
  1346. }
  1347. // setCameraFocusPositionInPreview
  1348. RCT_EXPORT_METHOD(setCameraFocusPositionInPreview
  1349. :(NSDictionary *)options
  1350. resolve:(RCTPromiseResolveBlock)resolve
  1351. reject:(RCTPromiseRejectBlock)reject) {
  1352. BOOL res = [self.rtcEngine setCameraFocusPositionInPreview:CGPointMake((CGFloat)[options[@"x"] floatValue], (CGFloat)[options[@"y"] floatValue])];
  1353. if (res) {
  1354. resolve(nil);
  1355. } else {
  1356. reject(@(-1).stringValue, @(res).stringValue, nil);
  1357. }
  1358. }
  1359. // setCameraExposurePosition
  1360. RCT_EXPORT_METHOD(setCameraExposurePosition
  1361. :(NSDictionary *)options
  1362. resolve:(RCTPromiseResolveBlock)resolve
  1363. reject:(RCTPromiseRejectBlock)reject) {
  1364. BOOL res = [self.rtcEngine setCameraExposurePosition:CGPointMake((CGFloat)[options[@"x"] floatValue], (CGFloat)[options[@"y"] floatValue])];
  1365. if (res == YES) {
  1366. resolve(nil);
  1367. } else {
  1368. reject(@(-1).stringValue, @(res).stringValue, nil);
  1369. }
  1370. }
  1371. // enable camera torch
  1372. RCT_EXPORT_METHOD(setCameraTorchOn:(BOOL)isOn
  1373. resolve:(RCTPromiseResolveBlock)resolve
  1374. reject:(RCTPromiseRejectBlock)reject) {
  1375. BOOL res = [self.rtcEngine setCameraTorchOn:isOn];
  1376. if (res == YES) {
  1377. resolve(nil);
  1378. } else {
  1379. reject(@(-1).stringValue, @(res).stringValue, nil);
  1380. }
  1381. }
  1382. // enable auto focus face mode
  1383. RCT_EXPORT_METHOD(setCameraAutoFocusFaceModeEnabled:(BOOL)enable
  1384. resolve:(RCTPromiseResolveBlock)resolve
  1385. reject:(RCTPromiseRejectBlock)reject) {
  1386. BOOL res = [self.rtcEngine setCameraAutoFocusFaceModeEnabled:enable];
  1387. if (res == YES) {
  1388. resolve(nil);
  1389. } else {
  1390. reject(@(-1).stringValue, @(res).stringValue, nil);
  1391. }
  1392. }
  1393. // getCallId
  1394. RCT_EXPORT_METHOD(getCallId
  1395. :(RCTPromiseResolveBlock)resolve
  1396. reject:(RCTPromiseRejectBlock)reject) {
  1397. resolve(@{
  1398. @"id": [self.rtcEngine getCallId]
  1399. });
  1400. }
  1401. // setLogFile and setLogFilter
  1402. RCT_EXPORT_METHOD(setLog
  1403. :(NSString *)filePath
  1404. level:(NSUInteger)level
  1405. size:(NSUInteger)size
  1406. resolve:(RCTPromiseResolveBlock)resolve
  1407. reject:(RCTPromiseRejectBlock)reject) {
  1408. NSInteger res = [self.rtcEngine setLogFileSize:size];
  1409. if (res < 0) return reject(@(-1).stringValue, @(res).stringValue, nil);
  1410. res = [self.rtcEngine setLogFilter:level];
  1411. if (res < 0) return reject(@(-1).stringValue, @(res).stringValue, nil);
  1412. res = [self.rtcEngine setLogFile:filePath];
  1413. if (res < 0) return reject(@(-1).stringValue, @(res).stringValue, nil);
  1414. resolve(nil);
  1415. }
  1416. // get sdk version
  1417. RCT_EXPORT_METHOD(getSdkVersion
  1418. :(RCTPromiseResolveBlock) resolve
  1419. reject:(RCTPromiseRejectBlock) reject) {
  1420. resolve(@[[AgoraRtcEngineKit getSdkVersion]]);
  1421. }
  1422. // add publish stream url
  1423. RCT_EXPORT_METHOD(addPublishStreamUrl:(NSDictionary *)options
  1424. resolve:(RCTPromiseResolveBlock) resolve
  1425. reject:(RCTPromiseRejectBlock) reject) {
  1426. NSInteger res = [self.rtcEngine addPublishStreamUrl:options[@"url"] transcodingEnabled:[options[@"enable"] boolValue]];
  1427. if (res == 0) {
  1428. resolve(nil);
  1429. } else {
  1430. reject(@(-1).stringValue, @(res).stringValue, nil);
  1431. }
  1432. }
  1433. // remove publish stream url
  1434. RCT_EXPORT_METHOD(removePublishStreamUrl:(NSDictionary *)options
  1435. resolve:(RCTPromiseResolveBlock) resolve
  1436. reject:(RCTPromiseRejectBlock) reject) {
  1437. NSInteger res = [self.rtcEngine removePublishStreamUrl:options[@"url"]];
  1438. if (res == 0) {
  1439. resolve(nil);
  1440. } else {
  1441. reject(@(-1).stringValue, @(res).stringValue, nil);
  1442. }
  1443. }
  1444. // set living transcoding
  1445. RCT_EXPORT_METHOD(setLiveTranscoding:(NSDictionary *)options
  1446. resolve:(RCTPromiseResolveBlock) resolve
  1447. reject:(RCTPromiseRejectBlock) reject) {
  1448. AgoraLiveTranscoding *transcoding = AgoraLiveTranscoding.defaultTranscoding;
  1449. if ([options objectForKey:@"size"]) {
  1450. transcoding.size = CGSizeMake([options[@"size"][@"width"] doubleValue], [options[@"size"][@"height"] doubleValue]);
  1451. }
  1452. if ([options objectForKey:@"videoBitrate"]) {
  1453. transcoding.videoBitrate = [options[@"videoBitrate"] integerValue];
  1454. }
  1455. if ([options objectForKey:@"videoFramerate"]) {
  1456. transcoding.videoFramerate = [options[@"videoFramerate"] integerValue];
  1457. }
  1458. if ([options objectForKey:@"videoGop"]) {
  1459. transcoding.videoGop = [options[@"videoGop"] integerValue];
  1460. }
  1461. if ([options objectForKey:@"videoCodecProfile"]) {
  1462. transcoding.videoCodecProfile = (AgoraVideoCodecProfileType)[options[@"videoCodecProfile"] integerValue];
  1463. }
  1464. if ([options objectForKey:@"audioCodecProfile"]) {
  1465. transcoding.audioCodecProfile = (AgoraAudioCodecProfileType)[options[@"audioCodecProfile"] integerValue];
  1466. }
  1467. if ([options objectForKey:@"audioSampleRate"]) {
  1468. transcoding.audioSampleRate = (AgoraAudioSampleRateType)[options[@"audioSampleRate"] integerValue];
  1469. }
  1470. if ([options objectForKey:@"watermark"]) {
  1471. transcoding.watermark = [self makeAgoraImage:@{
  1472. @"url": options[@"watermark"][@"url"],
  1473. @"x": options[@"watermark"][@"x"],
  1474. @"y": options[@"watermark"][@"y"],
  1475. @"width": options[@"watermark"][@"width"],
  1476. @"height": options[@"watermark"][@"height"]
  1477. }];
  1478. }
  1479. if ([options objectForKey:@"backgroundImage"]) {
  1480. transcoding.backgroundImage = [self makeAgoraImage:@{
  1481. @"url": options[@"backgroundImage"][@"url"],
  1482. @"x": options[@"backgroundImage"][@"x"],
  1483. @"y": options[@"backgroundImage"][@"y"],
  1484. @"width": options[@"backgroundImage"][@"width"],
  1485. @"height": options[@"backgroundImage"][@"height"]
  1486. }];
  1487. }
  1488. if ([options objectForKey:@"backgroundColor"]) {
  1489. transcoding.backgroundColor = [self UIColorFromRGB:(NSUInteger)[options[@"backgroundColor"] integerValue]];
  1490. }
  1491. if ([options objectForKey:@"audioBitrate"]) {
  1492. transcoding.audioBitrate = [options[@"audioBitrate"] integerValue];
  1493. }
  1494. if ([options objectForKey:@"audioChannels"]) {
  1495. transcoding.audioChannels = [options[@"audioChannels"] integerValue];
  1496. }
  1497. if ([options objectForKey:@"transcodingUsers"]) {
  1498. NSMutableArray<AgoraLiveTranscodingUser*> *transcodingUsers = [NSMutableArray new];
  1499. for (NSDictionary *optionUser in options[@"transcodingUsers"]) {
  1500. AgoraLiveTranscodingUser *liveUser = [AgoraLiveTranscodingUser new];
  1501. liveUser.uid = (NSUInteger)[optionUser[@"uid"] integerValue];
  1502. liveUser.rect = CGRectMake((CGFloat)[optionUser[@"x"] floatValue],
  1503. (CGFloat)[optionUser[@"y"] floatValue],
  1504. (CGFloat)[optionUser[@"width"] floatValue],
  1505. (CGFloat)[optionUser[@"height"] floatValue]);
  1506. liveUser.zOrder = [optionUser[@"zOrder"] integerValue];
  1507. liveUser.alpha = [optionUser[@"alpha"] doubleValue];
  1508. liveUser.audioChannel = [optionUser[@"audioChannel"] integerValue];
  1509. [transcodingUsers addObject:liveUser];
  1510. }
  1511. transcoding.transcodingUsers = transcodingUsers;
  1512. }
  1513. if ([options objectForKey:@"transcodingExtraInfo"]) {
  1514. transcoding.transcodingExtraInfo = options[@"transcodingExtraInfo"];
  1515. }
  1516. NSInteger res = [self.rtcEngine setLiveTranscoding:transcoding];
  1517. if (res == 0) {
  1518. resolve(nil);
  1519. } else {
  1520. reject(@(-1).stringValue, @(res).stringValue, nil);
  1521. }
  1522. }
  1523. RCT_EXPORT_METHOD(setBeautyEffectOptions:(bool) enabled
  1524. options:(NSDictionary *)options
  1525. resolve:(RCTPromiseResolveBlock)resolve
  1526. reject:(RCTPromiseRejectBlock)reject) {
  1527. int res = [self.rtcEngine setBeautyEffectOptions:enabled options:options];
  1528. if (res == 0) {
  1529. resolve(nil);
  1530. } else {
  1531. reject(@(-1).stringValue, @(res).stringValue, nil);
  1532. }
  1533. }
  1534. RCT_EXPORT_METHOD(setLocalVoiceChanger:(NSInteger) voiceChanger
  1535. resolve:(RCTPromiseResolveBlock)resolve
  1536. reject:(RCTPromiseRejectBlock)reject) {
  1537. NSInteger res = [self.rtcEngine setLocalVoiceChanger:(AgoraAudioVoiceChanger)voiceChanger];
  1538. if (res == 0) {
  1539. resolve(nil);
  1540. } else {
  1541. reject(@(-1).stringValue, @(res).stringValue, nil);
  1542. }
  1543. }
  1544. RCT_EXPORT_METHOD(setLocalVoiceReverbPreset:(NSInteger) reverbPreset
  1545. resolve:(RCTPromiseResolveBlock)resolve
  1546. reject:(RCTPromiseRejectBlock)reject) {
  1547. NSInteger res = [self.rtcEngine setLocalVoiceReverbPreset:(AgoraAudioReverbPreset)reverbPreset];
  1548. if (res == 0) {
  1549. resolve(nil);
  1550. } else {
  1551. reject(@(-1).stringValue, @(res).stringValue, nil);
  1552. }
  1553. }
  1554. RCT_EXPORT_METHOD(enableSoundPositionIndication:(bool) enabled
  1555. resolve:(RCTPromiseResolveBlock)resolve
  1556. reject:(RCTPromiseRejectBlock)reject) {
  1557. NSInteger res = [self.rtcEngine enableSoundPositionIndication:enabled];
  1558. if (res == 0) {
  1559. resolve(nil);
  1560. } else {
  1561. reject(@(-1).stringValue, @(res).stringValue, nil);
  1562. }
  1563. }
  1564. RCT_EXPORT_METHOD(setRemoteVoicePosition:(NSUInteger) uid
  1565. pan:(float)pan
  1566. gain:(float)gain
  1567. resolve:(RCTPromiseResolveBlock)resolve
  1568. reject:(RCTPromiseRejectBlock)reject) {
  1569. NSInteger res = [self.rtcEngine setRemoteVoicePosition:uid pan:pan gain: gain];
  1570. if (res == 0) {
  1571. resolve(nil);
  1572. } else {
  1573. reject(@(-1).stringValue, @(res).stringValue, nil);
  1574. }
  1575. }
  1576. RCT_EXPORT_METHOD(startLastmileProbeTest:(NSDictionary*)config
  1577. resolve:(RCTPromiseResolveBlock)resolve
  1578. reject:(RCTPromiseRejectBlock)reject) {
  1579. AgoraLastmileProbeConfig* probeConfig = [[AgoraLastmileProbeConfig alloc] init];
  1580. probeConfig.probeUplink = [config[@"probeUplink"] boolValue];
  1581. probeConfig.probeDownlink = [config[@"probeDownlink"] boolValue];
  1582. probeConfig.expectedUplinkBitrate = [config[@"expectedUplinkBitrate"] integerValue];
  1583. probeConfig.expectedDownlinkBitrate = [config[@"expectedDownlinkBitrate"] integerValue];
  1584. NSInteger res = [self.rtcEngine startLastmileProbeTest:probeConfig];
  1585. if (res == 0) {
  1586. resolve(nil);
  1587. } else {
  1588. reject(@(-1).stringValue, @(res).stringValue, nil);
  1589. }
  1590. }
  1591. RCT_EXPORT_METHOD(setRemoteUserPriority:(NSUInteger)uid
  1592. userPriority:(NSInteger)userPriority
  1593. resolve:(RCTPromiseResolveBlock)resolve
  1594. reject:(RCTPromiseRejectBlock)reject) {
  1595. NSInteger res = [self.rtcEngine setRemoteUserPriority:uid type:(AgoraUserPriority)userPriority];
  1596. if (res == 0) {
  1597. resolve(nil);
  1598. } else {
  1599. reject(@(-1).stringValue, @(res).stringValue, nil);
  1600. }
  1601. }
  1602. RCT_EXPORT_METHOD(startEchoTestWithInterval:(NSInteger)interval
  1603. resolve:(RCTPromiseResolveBlock)resolve
  1604. reject:(RCTPromiseRejectBlock)reject) {
  1605. NSInteger res = [self.rtcEngine startEchoTestWithInterval:interval successBlock:^(NSString * _Nonnull channel, NSUInteger uid, NSInteger elapsed) {
  1606. [self sendEvent:AGIntervalTest params:@{
  1607. @"message": @"StartEchoTestWithInterval",
  1608. @"channel": channel,
  1609. @"uid": @(uid),
  1610. @"elapsed": @(elapsed),
  1611. }];
  1612. }];
  1613. if (res == 0) {
  1614. resolve(nil);
  1615. } else {
  1616. reject(@(-1).stringValue, @(res).stringValue, nil);
  1617. }
  1618. }
  1619. RCT_EXPORT_METHOD(setCameraCapturerConfiguration:(NSDictionary *)config
  1620. resolve:(RCTPromiseResolveBlock)resolve
  1621. reject:(RCTPromiseRejectBlock)reject) {
  1622. AgoraCameraCapturerConfiguration* configuration = [[AgoraCameraCapturerConfiguration alloc] init];
  1623. configuration.preference = [config[@"preference"] integerValue];
  1624. configuration.cameraDirection = [config[@"cameraDirection"] integerValue];
  1625. NSInteger res = [self.rtcEngine setCameraCapturerConfiguration:configuration];
  1626. if (res == 0) {
  1627. resolve(nil);
  1628. } else {
  1629. reject(@(-1).stringValue, @(res).stringValue, nil);
  1630. }
  1631. }
  1632. RCT_EXPORT_METHOD(sendMediaData:(NSString *)dataStr
  1633. resolve:(RCTPromiseResolveBlock)resolve
  1634. reject:(RCTPromiseRejectBlock)reject) {
  1635. BOOL res = [self respondsToSelector:@selector(readyToSendMetadataAtTimestamp:)];
  1636. if (res == YES) {
  1637. self.metadata = [dataStr dataUsingEncoding:NSUTF8StringEncoding];
  1638. resolve(nil);
  1639. } else {
  1640. reject(@(-1).stringValue, @(res).stringValue, nil);
  1641. }
  1642. }
  1643. RCT_EXPORT_METHOD(registerMediaMetadataObserver
  1644. :(RCTPromiseResolveBlock)resolve
  1645. reject:(RCTPromiseRejectBlock)reject) {
  1646. if (YES == [_rtcEngine setMediaMetadataDataSource:self withType:AgoraMetadataTypeVideo] &&
  1647. YES == [_rtcEngine setMediaMetadataDelegate:self withType:AgoraMetadataTypeVideo]
  1648. ) {
  1649. resolve(nil);
  1650. } else {
  1651. reject(@(-1).stringValue, @(-1).stringValue, nil);
  1652. }
  1653. }
  1654. RCT_EXPORT_METHOD(setParameters:(NSString *)paramStr
  1655. resolve:(RCTPromiseResolveBlock)resolve
  1656. reject:(RCTPromiseRejectBlock)reject) {
  1657. NSInteger res = [self.rtcEngine setParameters:paramStr];
  1658. if (res == 0) {
  1659. resolve(nil);
  1660. } else {
  1661. reject(@(-1).stringValue, @(-1).stringValue, nil);
  1662. }
  1663. }
  1664. RCT_EXPORT_METHOD(getParameter:(NSString *)paramStr
  1665. args:(NSString *)args
  1666. resolve:(RCTPromiseResolveBlock)resolve
  1667. reject:(RCTPromiseRejectBlock)reject) {
  1668. NSString *res = [self.rtcEngine getParameter:paramStr args:args];
  1669. resolve(res);
  1670. }
  1671. RCT_EXPORT_METHOD(getParameters:(NSString *)paramStr
  1672. resolve:(RCTPromiseResolveBlock)resolve
  1673. reject:(RCTPromiseRejectBlock)reject) {
  1674. NSString *res = [self.rtcEngine getParameters:paramStr];
  1675. resolve(res);
  1676. }
  1677. - (NSArray<NSString *> *)supportedEvents {
  1678. return [AgoraConst supportEvents];
  1679. }
  1680. - (void) sendEvent:(NSString *)msg params:(NSDictionary *)params {
  1681. if (hasListeners) {
  1682. NSString *evtName = [NSString stringWithFormat:@"%@%@", AG_PREFIX, msg];
  1683. [self sendEventWithName:evtName body:params];
  1684. }
  1685. }
  1686. - (void) startObserving {
  1687. hasListeners = YES;
  1688. }
  1689. - (void) stopObserving {
  1690. hasListeners = NO;
  1691. }
  1692. #pragma mark - <AgoraRtcEngineDelegate>
  1693. // EVENT CALLBACKS
  1694. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine didOccurWarning:(AgoraWarningCode)warningCode {
  1695. [self sendEvent:AGWarning params:@{@"message": @"AgoraWarning", @"errorCode": @(warningCode)}];
  1696. }
  1697. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine didOccurError:(AgoraErrorCode)errorCode {
  1698. [self sendEvent:AGError params:@{@"message": @"AgoraError", @"errorCode": @(errorCode)}];
  1699. }
  1700. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine didApiCallExecute:(NSInteger)error api:(NSString *_Nonnull)api result:(NSString *_Nonnull)result {
  1701. if (error != 0) {
  1702. [self sendEvent:AGError params:@{
  1703. @"api": api,
  1704. @"result": result,
  1705. @"errorCode": @(error)
  1706. }];
  1707. } else {
  1708. [self sendEvent:AGApiCallExecute params:@{
  1709. @"api": api,
  1710. @"result": result,
  1711. @"errorCode": @(error)
  1712. }];
  1713. }
  1714. }
  1715. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine didJoinChannel:(NSString *_Nonnull)channel withUid:(NSUInteger)uid elapsed:(NSInteger)elapsed {
  1716. [self sendEvent:AGJoinChannelSuccess params:@{
  1717. @"channel": channel,
  1718. @"uid": @(uid),
  1719. @"elapsed": @(elapsed)
  1720. }];
  1721. }
  1722. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine didRejoinChannel:(NSString *_Nonnull)channel withUid:(NSUInteger)uid elapsed:(NSInteger)elapsed {
  1723. [self sendEvent:AGRejoinChannelSuccess params:@{
  1724. @"channel": channel,
  1725. @"uid": @(uid),
  1726. @"elapsed": @(elapsed)
  1727. }];
  1728. }
  1729. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine didLeaveChannelWithStats:(AgoraChannelStats *_Nonnull)stats {
  1730. [self sendEvent:AGLeaveChannel params:@{
  1731. @"stats": @{
  1732. @"duration": @(stats.duration),
  1733. @"txBytes": @(stats.txBytes),
  1734. @"rxBytes": @(stats.rxBytes),
  1735. @"txAudioBytes": @(stats.txAudioBytes),
  1736. @"txVideoBytes": @(stats.txVideoBytes),
  1737. @"rxAudioBytes": @(stats.rxAudioBytes),
  1738. @"rxVideoBytes": @(stats.rxVideoBytes),
  1739. @"txPacketLossRate": @(stats.txPacketLossRate),
  1740. @"rxPacketLossRate": @(stats.rxPacketLossRate),
  1741. @"txAudioKBitrate": @(stats.txAudioKBitrate),
  1742. @"rxAudioKBitrate": @(stats.rxVideoKBitrate),
  1743. @"txVideoKBitrate": @(stats.txVideoKBitrate),
  1744. @"rxVideoKBitrate": @(stats.rxVideoKBitrate),
  1745. @"lastmileDelay": @(stats.lastmileDelay),
  1746. @"userCount": @(stats.userCount),
  1747. @"cpuAppUsage": @(stats.cpuAppUsage),
  1748. @"cpuTotalUsage": @(stats.cpuTotalUsage)
  1749. }
  1750. }];
  1751. }
  1752. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine didClientRoleChanged:(AgoraClientRole)oldRole newRole:(AgoraClientRole)newRole {
  1753. [self sendEvent:AGClientRoleChanged params:@{
  1754. @"oldRole": @(oldRole),
  1755. @"newRole": @(newRole)
  1756. }];
  1757. }
  1758. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine didJoinedOfUid:(NSUInteger)uid elapsed:(NSInteger)elapsed {
  1759. [self sendEvent:AGUserJoined params:@{
  1760. @"uid": @(uid),
  1761. @"elapsed": @(elapsed)
  1762. }];
  1763. }
  1764. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine didRegisteredLocalUser:(NSString *_Nonnull)userAccount withUid:(NSUInteger)uid {
  1765. [self sendEvent:AGLocalUserRegistered params:@{
  1766. @"uid": @(uid),
  1767. @"userAccount": userAccount
  1768. }];
  1769. }
  1770. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine didUpdatedUserInfo:(AgoraUserInfo *_Nonnull)userInfo withUid:(NSUInteger)uid {
  1771. [self sendEvent:AGUserInfoUpdated params:@{
  1772. @"uid": @(uid),
  1773. @"peer": @{
  1774. @"uid": @(userInfo.uid),
  1775. @"userAccount": userInfo.userAccount
  1776. }}];
  1777. }
  1778. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine didOfflineOfUid:(NSUInteger)uid reason:(AgoraUserOfflineReason)reason {
  1779. [self sendEvent:AGUserOffline params:@{
  1780. @"uid": @(uid),
  1781. @"reason": @(reason)
  1782. }];
  1783. }
  1784. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine networkTypeChangedToType:(AgoraNetworkType)type {
  1785. [self sendEvent:AGNetworkTypeChanged params:@{
  1786. @"type": @(type)
  1787. }];
  1788. }
  1789. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine connectionChangedToState:(AgoraConnectionStateType)state reason:(AgoraConnectionChangedReason)reason {
  1790. [self sendEvent:AGConnectionStateChanged params:@{
  1791. @"state": @(state),
  1792. @"reason": @(reason)
  1793. }];
  1794. }
  1795. - (void)rtcEngineConnectionDidLost:(AgoraRtcEngineKit *_Nonnull)engine {
  1796. [self sendEvent:AGConnectionLost params:@{
  1797. @"message": @"connectionLost"
  1798. }];
  1799. }
  1800. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine tokenPrivilegeWillExpire:(NSString *_Nonnull)token {
  1801. [self sendEvent:AGTokenPrivilegeWillExpire params:@{
  1802. @"token": token
  1803. }];
  1804. }
  1805. - (void)rtcEngineRequestToken:(AgoraRtcEngineKit *_Nonnull)engine {
  1806. [self sendEvent:AGRequestToken params:@{
  1807. @"message": @"RequestToken"
  1808. }];
  1809. }
  1810. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine localAudioStateChange:(AgoraAudioLocalState)state error:(AgoraAudioLocalError)error {
  1811. [self sendEvent:AGLocalAudioStateChanged params:@{
  1812. @"state": @(state),
  1813. @"errorCode": @(error)
  1814. }];
  1815. }
  1816. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine remoteAudioStateChangedOfUid:(NSUInteger)uid state:(AgoraAudioRemoteState)state reason:(AgoraAudioRemoteStateReason)reason elapsed:(NSInteger)elapsed {
  1817. [self sendEvent:AGRemoteAudioStateChanged params:@{
  1818. @"uid": @(uid),
  1819. @"state": @(state),
  1820. @"reason": @(reason),
  1821. @"elapsed": @(elapsed)
  1822. }];
  1823. }
  1824. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine localAudioStats:(AgoraRtcLocalAudioStats *_Nonnull)stats {
  1825. [self sendEvent:AGLocalAudioStats params:@{
  1826. @"numChannels": @(stats.numChannels),
  1827. @"sentSampleRate": @(stats.sentSampleRate),
  1828. @"sentBitrate": @(stats.sentBitrate),
  1829. }];
  1830. }
  1831. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine reportAudioVolumeIndicationOfSpeakers:(NSArray<AgoraRtcAudioVolumeInfo*> *_Nonnull)speakers totalVolume:(NSInteger)totalVolume {
  1832. NSMutableArray *result = [NSMutableArray new];
  1833. for (AgoraRtcAudioVolumeInfo *speaker in speakers) {
  1834. [result addObject:@{
  1835. @"uid": @(speaker.uid),
  1836. @"volume": @(speaker.volume),
  1837. @"vad": @(speaker.vad),
  1838. }];
  1839. }
  1840. [self sendEvent:AGAudioVolumeIndication params:@{
  1841. @"speakers": result,
  1842. @"totalVolume": @(totalVolume)
  1843. }];
  1844. }
  1845. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine activeSpeaker:(NSUInteger)speakerUid {
  1846. [self sendEvent:AGActiveSpeaker params:@{
  1847. @"uid": @(speakerUid)
  1848. }];
  1849. }
  1850. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine firstLocalAudioFrame:(NSInteger)elapsed {
  1851. [self sendEvent:AGFirstLocalAudioFrame params:@{
  1852. @"elapsed": @(elapsed)
  1853. }];
  1854. }
  1855. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine firstRemoteAudioFrameOfUid:(NSUInteger)uid elapsed:(NSInteger)elapsed {
  1856. [self sendEvent:AGFirstRemoteAudioFrame params:@{
  1857. @"uid": @(uid),
  1858. @"elapsed": @(elapsed)
  1859. }];
  1860. }
  1861. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine firstRemoteAudioFrameDecodedOfUid:(NSUInteger)uid elapsed:(NSInteger)elapsed {
  1862. [self sendEvent:AGFirstRemoteAudioDecoded params:@{
  1863. @"uid": @(uid),
  1864. @"elapsed": @(elapsed)
  1865. }];
  1866. }
  1867. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine firstLocalVideoFrameWithSize:(CGSize)size elapsed:(NSInteger)elapsed {
  1868. [self sendEvent:AGFirstLocalVideoFrame params:@{
  1869. @"width": @(size.width),
  1870. @"height": @(size.height),
  1871. @"elapsed": @(elapsed)
  1872. }];
  1873. }
  1874. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine firstRemoteVideoFrameOfUid:(NSUInteger)uid size:(CGSize)size elapsed:(NSInteger)elapsed {
  1875. [self sendEvent:AGFirstRemoteVideoFrame params:@{
  1876. @"uid": @(uid),
  1877. @"width": @(size.width),
  1878. @"height": @(size.height),
  1879. @"elapsed": @(elapsed)}];
  1880. }
  1881. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine didAudioMuted:(BOOL)muted byUid:(NSUInteger)uid {
  1882. [self sendEvent:AGUserMuteAudio params:@{
  1883. @"muted": @(muted),
  1884. @"uid": @(uid)
  1885. }];
  1886. }
  1887. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine videoSizeChangedOfUid:(NSUInteger)uid size:(CGSize)size rotation:(NSInteger)rotation {
  1888. [self sendEvent:AGVideoSizeChanged params:@{
  1889. @"uid": @(uid),
  1890. @"width": @(size.width),
  1891. @"height": @(size.height),
  1892. @"rotation": @(rotation)
  1893. }];
  1894. }
  1895. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine remoteVideoStateChangedOfUid:(NSUInteger)uid state:(AgoraVideoRemoteState)state reason:(AgoraVideoRemoteStateReason)reason elapsed:(NSInteger)elapsed {
  1896. [self sendEvent:AGRemoteVideoStateChanged params:@{
  1897. @"uid": @(uid),
  1898. @"state": @(state),
  1899. @"reason": @(reason),
  1900. @"elapsed": @(elapsed)
  1901. }];
  1902. }
  1903. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine didLocalPublishFallbackToAudioOnly:(BOOL)isFallbackOrRecover {
  1904. [self sendEvent:AGLocalPublishFallbackToAudioOnly params:@{
  1905. @"isFallbackOrRecover": @(isFallbackOrRecover)
  1906. }];
  1907. }
  1908. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine didRemoteSubscribeFallbackToAudioOnly:(BOOL)isFallbackOrRecover byUid:(NSUInteger)uid {
  1909. [self sendEvent:AGRemoteSubscribeFallbackToAudioOnly params:@{
  1910. @"isFallbackOrRecover": @(isFallbackOrRecover),
  1911. @"uid": @(uid)
  1912. }];
  1913. }
  1914. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine didAudioRouteChanged:(AgoraAudioOutputRouting)routing {
  1915. [self sendEvent:AGAudioRouteChanged params:@{
  1916. @"routing": @(routing)
  1917. }];
  1918. }
  1919. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine cameraFocusDidChangedToRect:(CGRect)rect {
  1920. [self sendEvent:AGCameraFocusAreaChanged params:@{
  1921. @"rect": @(rect)
  1922. }];
  1923. }
  1924. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine cameraExposureDidChangedToRect:(CGRect)rect {
  1925. [self sendEvent:AGCameraExposureAreaChanged params:@{
  1926. @"rect": @(rect)
  1927. }];
  1928. }
  1929. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine remoteAudioStats:(AgoraRtcRemoteAudioStats *_Nonnull)stats {
  1930. [self sendEvent:AGRemoteAudioStats params:@{
  1931. @"stats": @{
  1932. @"uid": @(stats.uid),
  1933. @"quality": @(stats.quality),
  1934. @"networkTransportDelay": @(stats.networkTransportDelay),
  1935. @"jitterBufferDelay": @(stats.jitterBufferDelay),
  1936. @"audioLossRate": @(stats.audioLossRate),
  1937. @"totalFrozenTime": @(stats.totalFrozenTime),
  1938. @"frozenRate": @(stats.frozenRate),
  1939. @"numChannels": @(stats.numChannels),
  1940. @"receivedSampleRate": @(stats.receivedSampleRate),
  1941. @"receivedBitrate": @(stats.receivedBitrate),
  1942. }
  1943. }];
  1944. }
  1945. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine reportRtcStats:(AgoraChannelStats *_Nonnull)stats {
  1946. [self sendEvent:AGRtcStats params:@{
  1947. @"stats": @{
  1948. @"duration": @(stats.duration),
  1949. @"txBytes": @(stats.txBytes),
  1950. @"rxBytes": @(stats.rxBytes),
  1951. @"txAudioBytes": @(stats.txAudioBytes),
  1952. @"txVideoBytes": @(stats.txVideoBytes),
  1953. @"rxAudioBytes": @(stats.rxAudioBytes),
  1954. @"rxVideoBytes": @(stats.rxVideoBytes),
  1955. @"txPacketLossRate": @(stats.txPacketLossRate),
  1956. @"rxPacketLossRate": @(stats.rxPacketLossRate),
  1957. @"txAudioKBitrate": @(stats.txAudioKBitrate),
  1958. @"rxAudioKBitrate": @(stats.rxAudioKBitrate),
  1959. @"txVideoKBitrate": @(stats.txVideoKBitrate),
  1960. @"rxVideoKBitrate": @(stats.rxVideoKBitrate),
  1961. @"lastmileDelay": @(stats.lastmileDelay),
  1962. @"userCount": @(stats.userCount),
  1963. @"cpuAppUsage": @(stats.cpuAppUsage),
  1964. @"cpuTotalUsage": @(stats.cpuTotalUsage)
  1965. }
  1966. }];
  1967. }
  1968. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine lastmileQuality:(AgoraNetworkQuality)quality {
  1969. [self sendEvent:AGLastmileQuality params:@{
  1970. @"quality": @(quality)
  1971. }];
  1972. }
  1973. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine networkQuality:(NSUInteger)uid txQuality:(AgoraNetworkQuality)txQuality rxQuality:(AgoraNetworkQuality)rxQuality {
  1974. [self sendEvent:AGNetworkQuality params:@{
  1975. @"uid": @(uid),
  1976. @"txQuality": @(txQuality),
  1977. @"rxQuality": @(rxQuality)
  1978. }];
  1979. }
  1980. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine localVideoStats:(AgoraRtcLocalVideoStats *_Nonnull)stats {
  1981. [self sendEvent:AGLocalVideoStats params:@{
  1982. @"stats": @{
  1983. @"sentBitrate": @(stats.sentBitrate),
  1984. @"sentFrameRate": @(stats.sentFrameRate)
  1985. },
  1986. @"encoderOutputFrameRate": @(stats.encoderOutputFrameRate),
  1987. @"rendererOutputFrameRate":
  1988. @(stats.rendererOutputFrameRate)
  1989. }];
  1990. }
  1991. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine remoteVideoStats:(AgoraRtcRemoteVideoStats *_Nonnull)stats {
  1992. [self sendEvent:AGRemoteVideoStats params:@{
  1993. @"stats": @{
  1994. @"uid": @(stats.uid),
  1995. @"width": @(stats.width),
  1996. @"height": @(stats.height),
  1997. @"receivedBitrate": @(stats.receivedBitrate),
  1998. @"rendererOutputFrameRate": @(stats.rendererOutputFrameRate),
  1999. @"rxStreamType": @(stats.rxStreamType),
  2000. @"decoderOutputFrameRate": @(stats.decoderOutputFrameRate),
  2001. @"totalFrozenTime": @(stats.totalFrozenTime),
  2002. @"frozenRate": @(stats.frozenRate)
  2003. }
  2004. }];
  2005. }
  2006. - (void)rtcEngineRemoteAudioMixingDidStart:(AgoraRtcEngineKit *_Nonnull)engine {
  2007. [self sendEvent:AGRemoteAudioMixingStart params:@{
  2008. @"message": @"RemoteAudioMixingStarted"
  2009. }];
  2010. }
  2011. - (void)rtcEngineRemoteAudioMixingDidFinish:(AgoraRtcEngineKit *_Nonnull)engine {
  2012. [self sendEvent:AGRemoteAudioMixingFinish params:@{
  2013. @"message": @"RemoteAudioMixingFinish"
  2014. }];
  2015. }
  2016. - (void)rtcEngineDidAudioEffectFinish:(AgoraRtcEngineKit *_Nonnull)engine soundId:(NSInteger)soundId {
  2017. [self sendEvent:AGAudioEffectFinish params:@{
  2018. @"soundid": @(soundId)
  2019. }];
  2020. }
  2021. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine streamPublishedWithUrl:(NSString *_Nonnull)url errorCode:(AgoraErrorCode)errorCode {
  2022. [self sendEvent:AGStreamPublished params:@{
  2023. @"url": url,
  2024. @"errorCode": @(errorCode)
  2025. }];
  2026. }
  2027. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine rtmpStreamingChangedToState:(NSString *_Nonnull)url state:(AgoraRtmpStreamingState)state errorCode:(AgoraRtmpStreamingErrorCode)errorCode {
  2028. [self sendEvent:AGRtmpStreamingStateChanged params:@{
  2029. @"url": url,
  2030. @"state": @(state),
  2031. @"errorCode": @(errorCode)
  2032. }];
  2033. }
  2034. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine streamUnpublishedWithUrl:(NSString *_Nonnull)url {
  2035. [self sendEvent:AGStreamUnpublish params:@{
  2036. @"url": url,
  2037. }];
  2038. }
  2039. - (void)rtcEngineTranscodingUpdated:(AgoraRtcEngineKit *_Nonnull)engine {
  2040. [self sendEvent:AGTranscodingUpdate params:@{
  2041. @"message": @"AGTranscodingUpdate"
  2042. }];
  2043. }
  2044. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine localVideoStateChange:(AgoraLocalVideoStreamState)state error:(AgoraLocalVideoStreamError)error {
  2045. [self sendEvent:AGLocalVideoChanged params:@{
  2046. @"state": @(state),
  2047. @"errorCode": @(error)
  2048. }];
  2049. }
  2050. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine streamInjectedStatusOfUrl:(NSString *_Nonnull)url uid:(NSUInteger)uid status:(AgoraInjectStreamStatus)status {
  2051. [self sendEvent:AGStreamInjectedStatus params:@{
  2052. @"uid": @(uid),
  2053. @"url": url,
  2054. @"status": @(status)
  2055. }];
  2056. }
  2057. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine channelMediaRelayStateDidChange:(AgoraChannelMediaRelayState)state error:(AgoraChannelMediaRelayError)error {
  2058. [self sendEvent:AGMediaRelayStateChanged params:@{
  2059. @"state": @(state),
  2060. @"errorCode": @(error),
  2061. }];
  2062. }
  2063. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine didReceiveChannelMediaRelayEvent:(AgoraChannelMediaRelayEvent)event {
  2064. [self sendEvent:AGReceivedChannelMediaRelay params:@{
  2065. @"event": @(event),
  2066. }];
  2067. }
  2068. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine receiveStreamMessageFromUid:(NSUInteger)uid streamId:(NSInteger)streamId data:(NSData *_Nonnull)data {
  2069. NSString *_data = [[NSString alloc] initWithData:data encoding:NSUTF8StringEncoding];
  2070. [self sendEvent:AGReceiveStreamMessage params:@{
  2071. @"uid": @(uid),
  2072. @"streamId": @(streamId),
  2073. @"data": _data}];
  2074. }
  2075. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine didOccurStreamMessageErrorFromUid:(NSUInteger)uid streamId:(NSInteger)streamId error:(NSInteger)error missed:(NSInteger)missed cached:(NSInteger)cached {
  2076. [self sendEvent:AGOccurStreamMessageError params:@{
  2077. @"uid": @(uid),
  2078. @"streamId": @(streamId),
  2079. @"errorCode": @(error),
  2080. @"missed": @(missed),
  2081. @"cached": @(cached)
  2082. }];
  2083. }
  2084. - (void)rtcEngineMediaEngineDidLoaded:(AgoraRtcEngineKit *_Nonnull)engine {
  2085. [self sendEvent:AGMediaEngineLoaded params:@{
  2086. @"message": @"MediaEngineLoaded"
  2087. }];
  2088. }
  2089. - (void)rtcEngineMediaEngineDidStartCall:(AgoraRtcEngineKit *_Nonnull)engine {
  2090. [self sendEvent:AGMediaEngineStartCall params:@{
  2091. @"message": @"AGMediaEngineStartCall"
  2092. }];
  2093. }
  2094. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine localAudioMixingStateDidChanged:(AgoraAudioMixingStateCode)state errorCode:(AgoraAudioMixingErrorCode)errorCode {
  2095. [self sendEvent:AGAudioMixingStateChanged params:@{
  2096. @"message": @"AudioMixingStateChanged",
  2097. @"state": @(state),
  2098. @"errorCode": @(errorCode)
  2099. }];
  2100. }
  2101. - (void)rtcEngine:(AgoraRtcEngineKit *_Nonnull)engine lastmileProbeTestResult:(AgoraLastmileProbeResult *_Nonnull)result {
  2102. [self sendEvent:AGLastmileProbeTestResult params:@{
  2103. @"message":@"LastmileProbeTestResult",
  2104. @"result": @{
  2105. @"state": @(result.state),
  2106. @"rtt": @(result.rtt),
  2107. @"uplinkReport": @{
  2108. @"packetLossRate": @(result.uplinkReport.packetLossRate),
  2109. @"jitter": @(result.uplinkReport.jitter),
  2110. @"availableBandwidth": @(result.uplinkReport.availableBandwidth),
  2111. },
  2112. @"downlinkReport": @{
  2113. @"packetLossRate": @(result.downlinkReport.packetLossRate),
  2114. @"jitter": @(result.downlinkReport.jitter),
  2115. @"availableBandwidth": @(result.downlinkReport.availableBandwidth),
  2116. }
  2117. }
  2118. }];
  2119. }
  2120. @end