Playing around with session.

Author: michalchudziak

RCTOpenTokSession.h

@@ -6,8 +6,9 @@
  * LICENSE file in the root directory of this source tree.
  */
 
- #import "RCTBridgeModule.h"
- #import "RCTOpenTokSession.h"
+#import "RCTBridgeModule.h"
+#import <OpenTok/OpenTok.h>
 
- @interface RCTOpenTokSessionManager : NSObject <RCTBridgeModule>
- @end
+@interface RCTOpenTokSessionManager : NSObject <RCTBridgeModule, OTSessionDelegate>
+
+@end

RCTOpenTokSession.m

@@ -7,12 +7,50 @@
  */
 
 #import "RCTOpenTokSessionManager.h"
-#import "RCTOpenTokSession.h"
+#import "RCTEventDispatcher.h"
+#import <OpenTok/OpenTok.h>
 
-@implementation RCTOpenTokSessionManager
+@implementation RCTOpenTokSessionManager {
+    OTSession *_session;
+}
 
 RCT_EXPORT_MODULE();
 
-RCT_EXPORT_METHOD();
+RCT_EXPORT_METHOD(connect:(NSString *)apiKey sessionId:(NSString *)sessionId token:(NSString *)token)
+{
+  _session = [[OTSession alloc] initWithApiKey:apiKey sessionId:sessionId delegate:self];
+
+  OTError *error = nil;
+  [_session connectWithToken:token error:&error];
+
+  if (error) {
+    NSLog(@"connect failed with error: (%@)", error);
+  } else {
+    NSLog(@"session created");
+  }
+}
+
+RCT_EXPORT_METHOD(sendMessage:(NSString *)message)
+{
+  OTError* error = nil;
+  [_session signalWithType:type string:message connection:nil error:&error)];
+  if (error) {
+      NSLog(@"signal error %@", error);
+  } else {
+      NSLog(@"signal sent");
+  }
+}
+
+# pragma mark - OTSession delegate callbacks
+- (void)session:(OTSession*)session receivedSignalType:(NSString*)type fromConnection:(OTConnection*)connection withString:(NSString*)string {
+    NSLog(@"Received signal %@", string);
+    [self onMessageRecieved:string];
+}
+
+- (void)onMessageRecieved:(NSString *)message
+{
+  [self.bridge.eventDispatcher sendAppEventWithName:@"onMessageRecieved"
+                                               body:@{@"message": message}];
+}
 
 @end

RCTOpenTokSessionManager.h

@@ -0,0 +1,18 @@
+import { NativeModules, NativeAppEventEmitter } from 'react-native';
+const SessionManager = NativeModules.RCTOpenTokSessionManager;
+
+const listener = null;
+
+console.log(NativeModules);
+
+export const connect = SessionManager.connect;
+export const sendMessage = SessionManager.sendMessage;
+
+export const onMessageRecieved = (callback) => {
+  listener = NativeAppEventEmitter.addListener(
+    'onMessageRecieved',
+    (e) => callback(e.message)
+  );
+};
+
+export const stopListener = () => listener.remove();

RCTOpenTokSessionManager.m

@@ -10,3 +10,4 @@ import { requireNativeComponent } from 'react-native';
 
 export const PublisherView = require('./PublisherView').default;
 export const SubscriberView = require('./SubscriberView').default;
+export const Session = require('./Session');