Kurento Toolbox for iOS¶

/*
Default media constraints:

Audio codec: Opus audio codec (higher quality)
Audio bandiwidth limit: none
Video codec: Software (VP8)
Video renderer: OpenGLES 2.0
Video bandwidth limit: none
Video format: 640 x 480 @ 30fps
*/
NBMMediaConfiguration *mediaConfig = [NBMMediaConfiguration defaultConfiguration];
//If necessary modify media configuration and use it to setup WebRTCPeer, 'nil' configuration means default values
NBMWebRTCPeer *webRTCPeer = [[NBMWebrTCPeer alloc] initWithDelegate:self configuration:mediaConfig];

//Create a new offer for connection with specified identifier
[webRTCPeer generateOffer:@"connectionId"];

#pragma mark -
#pragma mark NBMWebRTCPeerDelegate

//Handle SDP offer generation
- (void)webRTCPeer:(NBMWebRTCPeer *)peer didGenerateOffer:(RTCSessionDescription *)sdpOffer forConnection:(NBMPeerConnection*)connection {
//TODO: Signal SDP offer for connection
}

//Process an answer from connection with specified identifier
[webRTCPeer processAnswer:@"sdpAnswer" connectionId:@"connectionId"];

#pragma mark -
#pragma mark NBMWebRTCPeerDelegate

//Handle the gathering of ICE candidate for connection with specified identifier
- (void)webRTCPeer:(NBMWebRTCPeer *)peer hasICECandidate:(RTCICECandidate *)candidate forConnection:(NBMPeerConnection *)connection {
//TODO: Signal ICE candidate for connection
}

//Set remote candidate for connection with specified identifier
[webRTCPeer addICECandidate:candidate connectionId:@"connectionId"];

/*
Default client configuration:

Request timeout: 5 sec.
Timeout request retries: 1
Connect after initialization: YES
*/
NBMJSONRPCClientConfiguration *clientConfig = [NBMJSONRPCClientConfiguration defaultConfiguration];
//WebSocket URI
NSURL *wsURI = [NSURL URLWithString:@"http://localhost:8080/json-rpc"];
//If necessary modify client configuration, 'nil' configuration means default values
NBMJSONRPCClient *jsonRpcClient = [[NBMJSONRPCClient alloc] initWithURL:wsURI configuration:clientConfig delegate:self];

//Use NSArray for positional params
NSArray *positionalParams = @[@"param1", @"param2", @(1234), @YES];
//Use NSDictionary for named params
NSDictionary *namedParams = @{@"param1": @"value1", @"param2": @"value2", @"number": @(1234), @"boolean": @YES};

NSString *method = @"methodName";

[jsonRpcClient sendRequestWithMethod:method parameters:namedParams completion:^(NBMResponse *response) {
    //If no response is returned, request is gone on timeout
    if (!response) {
        NSLog(@"Request with method %@ is gone on timeout!", method);
    }

    //Evaluate the response

    //If has a response error
    NBMResponseError *responseError = response.error;
    if (responseError) {
        NSLog(@"Response error: %@", responseError);
    } else {
        //Response has a result
        NSLog(@"Response result: %@", response.result);
    }
}];

NSString *method = @"methodName";

//Send a notification with no parameters
[jsonRpcClient sendNotificationWithMethod:method parameters:nil];

#pragma mark -
#pragma mark NBMJSONRPCClientDelegate

- (void)client:(NBMJSONRPCClient *)client didReceiveRequest:(NBMRequest *)request {
    // Handle request/notification
    NSLog(@"Request received: %@", request);
}

//NBMRoom

//Local peer's identifier
NSString *username = ...
//Room name
NSString *roomName = ...
//WebSocket URI
NSURL *wsURI = [NSURL URLWithString:@"http://localhost:8080/room"];
NBMRoom *room = [[NBMRoom alloc] initWithUsername:username roomName:roomName roomURL:wsURI];

//NBMRoomClient

//NBMRoomClient with default timeout (5 sec)
NBMRoomClient *roomClient = [[NBMRoomClient alloc] initWithRoom:room delegate:self];

//Or

//NBMRoomClient with custom timeout (10 sec)
NSTimeInterval clientTimeout = 10;
NBMRoomClient *roomClient = [[NBMRoomClient alloc] initWithRoom:room timeout:clientTimeout delegate:self];

[roomClient connect];

#pragma mark -
#pragma mark NBMRoomClientDelegate

- (void)client:(NBMRoomClient *)client isConnected:(BOOL)connected {
    if (connected) {
        //TODO: Start using APIs, eg. "joinRoom"
        [client joinRoom];
    } else {
        //TODO: Handle client disconnection, eg. try to reconnect
        [client connect];
    }
}

[roomClient joinRoom]

#pragma mark -
#pragma mark NBMRoomClientDelegate

- (void)client:(NBMRoomClient *)client didJoinRoom:(NSError *)error {
    if (!error) {
        NSLog(@"Partecipants %@", client.peers);
    } else {
        NSLog(@"Join room error: %@", error);
    }
}

//Or

[roomClient joinRoom:^(NSDictionary *peers, NSError *error) {
    if (!error) {
        NSLog(@"Partecipants %@", [roomClient.peers]);
    } else {
        NSLog(@"Join room error: %@", error);
    }
}];

//Retrieve local peer identifier (username)
NBMRoom *room = roomClient.room;
NSString *localPeerId = room.localPeer.username;

//Generate SDP offer for local peer connection
[webRTCPeer generateOffer:localPeerId];

#pragma mark -
#pragma mark NBMWebRTCDelegate

- (void)webRTCPeer:(NBMWebRTCPeer *)peer didGenerateOffer:(RTCSessionDescription *)sdpOffer forConnection:(NBMPeerConnection*)connection {
    //Connection is related to local peer
    if ([localPeerId isEqualToString:connection.connectionId]) {
            //Publish video with looback enabled
            [roomClient publishVideo:sdpOffer loopback:YES completion:^(NSString *sdpAnswer, NSError *error) {
                if (sdpAnswer) {
                    [webRTCPeer processAnswer:sdpAnswer connectionId:connection.connectionId];
                }
            }];
        }
}

//Retrieve a partecipant
NBMPeer *aPeer = [roomClient peerWithIdentifier:@"peerId"];

//Verify that peer has joined and has already published its media
if (aPeer.streams.count > 0) {
    //Receive video from peer
    NSString *sdpOffer = ... //A generated SDP Offer by NBMWebRTCPeer
    [roomClient receiveVideoFromPeer:aPeer offer:sdpOffer];
}

#pragma mark -
#pragma mark NBMRoomClientDelegate

- (void)client:(NBMRoomClient *)client didReceiveVideoFrom:(NBMPeer *)peer sdpAnswer:(NSString *)sdpAnswer error:(NSError *)error {
    if (sdpAnswer) {
            [webRTCPeer processAnswer:sdpAnswer connectionId:connection.connectionId];
        }
}

#pragma mark -
#pragma mark NBMWebRTCDelegate

- (void)webRTCPeer:(NBMWebRTCPeer *)peer hasICECandidate:(RTCICECandidate *)candidate forConnection:(NBMPeerConnection *)connection    {
    //Find peer using connection's identifier
    NBMPeer *peer = [roomClient peerWithIdentifier:connection.connectionId];

    //Send ICE candidate
    [roomClient sendICECandidate:candidate forPeer:peer completion:^(NSError *error) {
        if (!error) {NSLog(@"ICE candidate sent for peer: %@", peer.identifier);
        }
    }]
}