No Description

RCTAgora.m 89KB

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