BigBlueButton/bigbluebutton-Github
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge pull request #5149 from ritzalam/air-mobile-client

Browse Source 
- allow connecting to server using rtmps
This commit is contained in:
Richard Alam 2018-02-21 11:41:26 -05:00 committed by GitHub
commit 3d01c44268
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 83 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

77
clients/flash/common-library/src/main/actionscript/org/bigbluebutton/lib/common/services/BaseConnection.as
View File

@ -4,16 +4,19 @@ package org.bigbluebutton.lib.common.services {
import flash.events.IOErrorEvent;
import flash.events.NetStatusEvent;
import flash.events.SecurityErrorEvent;
import flash.events.TimerEvent;
import flash.net.NetConnection;
import flash.net.Responder;
import flash.utils.Timer;
import mx.utils.ObjectUtil;
import org.bigbluebutton.lib.main.commands.DisconnectUserSignal;
import org.bigbluebutton.lib.main.models.ConnectionFailedEvent;
import org.bigbluebutton.lib.main.utils.DisconnectEnum;
import org.bigbluebutton.lib.util.ConnUtil;
import org.osflash.signals.ISignal;
import org.osflash.signals.Signal;
import org.osflash.signals.Signal;
public class BaseConnection implements IBaseConnection {
private const LOG:String = "BaseConnection::";
@ -28,12 +31,14 @@ package org.bigbluebutton.lib.common.services {
protected var _netConnection:NetConnection;
protected var _uri:String;
private var bbbAppsUrl:String;
protected var _onUserCommand:Boolean;
public function BaseConnection() {
}
private var connectAttemptTimeout:Number = 5000;
private var connectionTimer:Timer;
private var triedTunneling:Boolean = false;
private var params: Array;
public function init(callback:DefaultConnectionCallback):void {
_netConnection = new NetConnection();
@ -58,9 +63,39 @@ package org.bigbluebutton.lib.common.services {
public function connect(uri:String, ... parameters):void {
_uri = uri;
params = parameters;
var pattern:RegExp = /(?P<protocol>.+):\/\/(?P<server>.+)\/(?P<app>.+)/;
var result:Array = pattern.exec(uri);
_netConnection.proxyType = ConnUtil.PROXY_NONE;
var nativeProtocol: String = ConnUtil.RTMP;
bbbAppsUrl = uri;
var useRTMPS: Boolean = result.protocol == ConnUtil.RTMPS;
if (useRTMPS) {
_netConnection.proxyType = ConnUtil.PROXY_BEST;
nativeProtocol = ConnUtil.RTMPS;
bbbAppsUrl = nativeProtocol + "://" + result.server + "/" + result.app;
} else {
if (triedTunneling) {
trace("ATTEMPT CONNECTING USING TUNNEL");
nativeProtocol = ConnUtil.RTMPT;
}
bbbAppsUrl = nativeProtocol + "://" + result.server + "/" + result.app;
connectionTimer = new Timer(connectAttemptTimeout, 1);
connectionTimer.addEventListener(TimerEvent.TIMER, connectionTimeout);
connectionTimer.start();
}
trace("CONNECTING TO " + "url=" + bbbAppsUrl);
try {
trace("Trying to connect to [" + uri + "] ...");
trace("parameters: " + parameters);
// passing an array to a method that expects a variable number of parameters
// http://stackoverflow.com/a/3852920
@ -80,6 +115,18 @@ package org.bigbluebutton.lib.common.services {
}
}
public function connectionTimeout (e:TimerEvent) : void {
trace("Timedout connecting to " + bbbAppsUrl);
if (triedTunneling) {
sendConnectionFailedSignal("Failed to connect to server.");
} else {
triedTunneling = true;
connect(_uri, params);
}
}
public function disconnect(onUserCommand:Boolean):void {
_onUserCommand = onUserCommand;
_netConnection.removeEventListener(NetStatusEvent.NET_STATUS, netStatus);
@ -90,31 +137,37 @@ package org.bigbluebutton.lib.common.services {
}
protected function netStatus(event:NetStatusEvent):void {
//Stop timeout timer when connected/rejected
if (connectionTimer != null && connectionTimer.running) {
connectionTimer.stop();
connectionTimer = null;
}
var info:Object = event.info;
var statusCode:String = info.code;
switch (statusCode) {
case "NetConnection.Connect.Success":
trace(LOG + " Connection succeeded. Uri: " + _uri);
trace(LOG + " Connection succeeded. Uri: " + bbbAppsUrl);
sendConnectionSuccessEvent();
break;
case "NetConnection.Connect.Failed":
trace(LOG + " Connection failed. Uri: " + _uri);
trace(LOG + " Connection failed. Uri: " + bbbAppsUrl);
sendConnectionFailedSignal(ConnectionFailedEvent.CONNECTION_FAILED);
break;
case "NetConnection.Connect.Closed":
trace(LOG + " Connection closed. Uri: " + _uri);
trace(LOG + " Connection closed. Uri: " + bbbAppsUrl);
sendConnectionFailedSignal(ConnectionFailedEvent.CONNECTION_CLOSED);
break;
case "NetConnection.Connect.InvalidApp":
trace(LOG + " application not found on server. Uri: " + _uri);
trace(LOG + " application not found on server. Uri: " + bbbAppsUrl);
sendConnectionFailedSignal(ConnectionFailedEvent.INVALID_APP);
break;
case "NetConnection.Connect.AppShutDown":
trace(LOG + " application has been shutdown. Uri: " + _uri);
trace(LOG + " application has been shutdown. Uri: " + bbbAppsUrl);
sendConnectionFailedSignal(ConnectionFailedEvent.APP_SHUTDOWN);
break;
case "NetConnection.Connect.Rejected":
trace(LOG + " Connection to the server rejected. Uri: " + _uri + ". Check if the red5 specified in the uri exists and is running");
trace(LOG + " Connection to the server rejected. Uri: " + bbbAppsUrl + ". Check if the red5 specified in the uri exists and is running");
sendConnectionFailedSignal(ConnectionFailedEvent.CONNECTION_REJECTED);
break;
case "NetConnection.Connect.NetworkChange":
@ -146,7 +199,7 @@ package org.bigbluebutton.lib.common.services {
}
protected function netASyncError(event:AsyncErrorEvent):void {
trace(LOG + "Asynchronous code error - " + event.error + " on " + _uri);
trace(LOG + "Asynchronous code error - " + event.error + " on " + bbbAppsUrl);
trace(event.toString());
sendConnectionFailedSignal(ConnectionFailedEvent.UNKNOWN_REASON);
}

18
clients/flash/common-library/src/main/actionscript/org/bigbluebutton/lib/util/ConnUtil.as Executable file
View File

@ -0,0 +1,18 @@
package org.bigbluebutton.lib.util
{
public class ConnUtil
{
public static const RTMPS: String = "rtmps";
public static const RTMPT: String = "rtmpt";
public static const RTMP: String = "rtmp";
public static const PROXY_NONE: String = "none";
public static const PROXY_BEST: String = "best";
public static function parseRTMPConn(appURL: String):Array {
var pattern:RegExp = /(?P<protocol>.+):\/\/(?P<server>.+)\/(?P<app>.+)/;
var result:Array = pattern.exec(appURL);
return result;
}
}
}