Add admin setting to specify a TURN server and a shared secret

css/settings-admin.css

@@ -0,0 +1,8 @@
+#spreed_settings_form label {
+	min-width: 200px;
+	display: inline-block;
+}
+
+#spreed_settings_form input {
+	width: 300px;
+}

js/settings-admin.js

@@ -5,6 +5,8 @@ $(document).ready(function(){
 		var post = $( "#spreed_settings_form" ).serialize();
 		$.post(OC.generateUrl('/apps/spreed/settings/admin'), post, function(data){
 			OC.msg.finishedSaving('#spreed_settings_msg', data);
+		}).fail(function(){
+			OC.msg.finishedError('#spreed_settings_msg', t('spreed', 'Saving failed'));
 		});
 	});
 

lib/Controller/AppSettingsController.php

@@ -53,8 +53,10 @@ public function __construct($appName,
 	 * in the form "stunserver:port", e.g. "stun.domain.invalid:1234".
 	 *
 	 * @param string $stun_server
+	 * @param string $turn_server
+	 * @param string $turn_server_secret
 	 */
-	public function setSpreedSettings($stun_server) {
+	public function setSpreedSettings($stun_server, $turn_server, $turn_server_secret, $turn_server_protocols) {
 		$stun_server = trim($stun_server);
 		if ($stun_server !== "") {
 			if (substr($stun_server, 0, 5) === "stun:") {
@@ -87,8 +89,36 @@ public function setSpreedSettings($stun_server) {
 				);
 			}
 		}
+		if ($turn_server_protocols !== '') {
+			if (!in_array($turn_server_protocols, array('udp,tcp', 'tcp', 'udp'))) {
+				return array('data' =>
+					array('message' =>
+						(string) $this->l10n->t('Invalid protocols specified.')
+					),
+					'status' => 'error'
+				);
+			}
+		}
 
-		$this->config->setAppValue('spreed', 'stun_server', $stun_server);
+		$currentStunServer = $this->config->getAppValue('spreed', 'stun_server', '');
+		if ( $currentStunServer !== $stun_server ) {
+			$this->config->setAppValue('spreed', 'stun_server', $stun_server);
+		}
+
+		$currentTurnServer = $this->config->getAppValue('spreed', 'turn_server', '');
+		if ( $currentTurnServer !== $turn_server ) {
+			$this->config->setAppValue('spreed', 'turn_server', $turn_server);
+		}
+
+		$currentTurnServerSecret = $this->config->getAppValue('spreed', 'turn_server_secret', '');
+		if ( $currentTurnServerSecret !== $turn_server_secret ) {
+			$this->config->setAppValue('spreed', 'turn_server_secret', $turn_server_secret);
+		}
+
+		$currentTurnServerProtocols = $this->config->getAppValue('spreed', 'turn_server_protocols', '');
+		if ( $currentTurnServerProtocols !== $turn_server_protocols ) {
+			$this->config->setAppValue('spreed', 'turn_server_protocols', $turn_server_protocols);
+		}
 
 		return array('data' =>
 			array('message' =>

lib/Controller/SignallingController.php

@@ -25,11 +25,13 @@
 
 use OCP\AppFramework\Controller;
 use OCP\AppFramework\Http\JSONResponse;
+use OCP\AppFramework\Utility\ITimeFactory;
 use OCP\IConfig;
 use OCP\IDBConnection;
 use OCP\IRequest;
 
 use OCA\Spreed\Util;
+use OCP\ISession;
 
 class SignallingController extends Controller {
 	/** @var IConfig */
@@ -38,6 +40,10 @@ class SignallingController extends Controller {
 	private $dbConnection;
 	/** @var string */
 	private $userId;
+	/** @var ISession */
+	private $session;
+	/** @var ITimeFactory */
+	private $timeFactory;
 
 
 	/**
@@ -46,16 +52,22 @@ class SignallingController extends Controller {
 	 * @param IConfig $config
 	 * @param IDBConnection $connection
 	 * @param string $UserId
+	 * @param ISession $session
+	 * @param ITimeFactory $timeFactory
 	 */
 	public function __construct($appName,
 								IRequest $request,
 								IConfig $config,
 								IDBConnection $connection,
-								$UserId) {
+								$UserId,
+								ISession $session,
+								ITimeFactory $timeFactory) {
 		parent::__construct($appName, $request);
 		$this->config = $config;
 		$this->dbConnection = $connection;
 		$this->userId = $UserId;
+		$this->session = $session;
+		$this->timeFactory = $timeFactory;
 	}
 
 	/**
@@ -106,6 +118,9 @@ public function signalling($messages) {
 				case 'turnservers':
 					$response = [];
 					$turnSettings = Util::getTurnSettings($this->config, $this->userId);
+					if(empty($turnSettings)) {
+						$turnSettings = Util::generateTurnSettings($this->config, $this->session, $this->timeFactory);
+					}
 					if (!empty($turnSettings)) {
 						$protocols = explode(",", $turnSettings['protocols']);
 						foreach ($protocols as $proto) {

lib/Settings/Admin.php

@@ -42,6 +42,8 @@ public function __construct(IConfig $config) {
     public function getForm() {
         $parameters = [
             'stunServer' => Util::getStunServer($this->config),
+			'turnServer' => $this->config->getAppValue('spreed', 'turn_server', ''),
+			'turnServerSecret' => $this->config->getAppValue('spreed', 'turn_server_secret', ''),
         ];
 
         return new TemplateResponse('spreed', 'settings-admin', $parameters, '');

lib/Util.php

@@ -21,7 +21,9 @@
 
 namespace OCA\Spreed;
 
+use OCP\AppFramework\Utility\ITimeFactory;
 use OCP\IConfig;
+use OCP\ISession;
 use OCP\IUser;
 
 class Util {
@@ -52,11 +54,45 @@ public static function deleteUser(IUser $user) {
 	}
 
     public static function getTurnSettings(IConfig $config, $uid) {
-        $value = $config->getUserValue($uid, 'spreed', 'turn_settings');
-        if (empty($value)) {
-            return array();
+		$value = $config->getUserValue($uid, 'spreed', 'turn_settings');
+		if (empty($value)) {
+			return array();
         }
-        return json_decode($value, true);
+		return json_decode($value, true);
     }
 
+	/**
+	 * Generates a username and password for the TURN server based on the
+	 *
+	 * @param IConfig $config
+	 * @param ISession $session
+	 * @param ITimeFactory $timeFactory
+	 * @return array
+	 */
+    public static function generateTurnSettings(IConfig $config, ISession $session, ITimeFactory $timeFactory) {
+		// generate from shared secret
+		$turnServer = $config->getAppValue('spreed', 'turn_server', '');
+		$turnServerSecret = $config->getAppValue('spreed', 'turn_server_secret', '');
+		$turnServerProtocols = $config->getAppValue('spreed', 'turn_server_protocols', '');
+		$sessionId = $session->get('spreed-session');
+
+		if ($turnServer === '' || $turnServerSecret === '' || $turnServerProtocols === '' || empty($session)) {
+			return array();
+		}
+
+		$time = $timeFactory->getTime();
+
+		// the credentials are valid for 24h - FIXME add the TTL to the response and properly reconnect then
+		$string = sprintf('%d:%s', $time + 86400, $sessionId);
+		$hashedString = hash_hmac('sha1', $string, $turnServerSecret, true);
+		$password = base64_encode($hashedString);
+
+		return array(
+			'server' => $turnServer,
+			'username' => $sessionId,
+			'password' => $password,
+			'protocols' => $turnServerProtocols,
+		);
+	}
+
 }

templates/settings-admin.php

@@ -1,5 +1,6 @@
 <?php
 script('spreed', ['settings-admin']);
+style('spreed', ['settings-admin']);
 ?>
 
 <div id="spreed" class="section">
@@ -8,13 +9,41 @@
         <span id="spreed_settings_msg" class="msg"></span>
         <p>
             <label for="stun_server"><?php p($l->t('STUN server')) ?></label>
-            <!-- TODO(fancycode): Should use CSS style to make input wider. -->
-            <input type="text" style="width:300px" id="stun_server"
+            <input type="text" id="stun_server"
                    name="stun_server" placeholder="stunserver:port"
                    value="<?php p($_['stunServer']) ?>" />
-            <p>
-                <em><?php p($l->t('The STUN server is used to determine the public address of participants behind a router.')) ?></em>
-            </p>
+        </p>
+        <p>
+            <em><?php p($l->t('The STUN server is used to determine the public address of participants behind a router.')) ?></em>
+        </p>
+        <p>
+            <label for="turn_server"><?php p($l->t('TURN server')) ?></label>
+            <input type="text" id="turn_server"
+                   name="turn_server" placeholder="https://turn.example.org"
+                   value="<?php p($_['turnServer']) ?>" />
+        </p>
+        <p>
+            <label for="turn_server_secret"><?php p($l->t('TURN server shared secret')) ?></label>
+            <input type="text" id="turn_server_secret"
+                   name="turn_server_secret" placeholder="shared secret"
+                   value="<?php p($_['turnServerSecret']) ?>" />
+        </p>
+        <p>
+            <label for="turn_server_protocols"><?php p($l->t('TURN server protocols')) ?></label>
+            <select id="turn_server_protocols" name="turn_server_protocols">
+                <option value="udp,tcp"
+                    <?php p($_['turnServerProtocols'] === 'udp,tcp' ? 'selected' : '') ?>>
+                    udp and tcp</option>
+                <option value="udp"
+                    <?php p($_['turnServerProtocols'] === 'udp' ? 'selected' : '') ?>>
+                    udp only</option>
+                <option value="tcp"
+                    <?php p($_['turnServerProtocols'] === 'tcp' ? 'selected' : '') ?>>
+                    tcp only</option>
+            </select>
+        </p>
+        <p>
+            <em><?php p($l->t('The TURN server is used to proxy the traffic from participants behind a firewall.')) ?></em>
         </p>
     </form>
 </div>

tests/php/UtilTest.php

@@ -21,7 +21,9 @@
 namespace OCA\Spreed\Tests\php;
 
 use OCA\Spreed\Util;
+use OCP\AppFramework\Utility\ITimeFactory;
 use OCP\IConfig;
+use OCP\ISession;
 use Test\TestCase;
 
 class UtilTest extends TestCase {
@@ -34,7 +36,7 @@ public function setUp() {
 	}
 
 	public function testGetStunServer() {
-		$config = $this->getMock(IConfig::class);
+		$config = $this->createMock(IConfig::class);
 		$config
 			->expects($this->once())
 			->method('getAppValue')
@@ -43,4 +45,44 @@ public function testGetStunServer() {
 
 		$this->assertSame('88.198.160.129', $this->util->getStunServer($config));
 	}
+
+	public function testGenerateTurnSettings() {
+		$session = $this->createMock(ISession::class);
+		$session
+			->expects($this->once())
+			->method('get')
+			->with('spreed-session')
+			->willReturn('thisisalongsessionid');
+		$config = $this->createMock(IConfig::class);
+		$config
+			->expects($this->at(0))
+			->method('getAppValue')
+			->with('spreed', 'turn_server', '')
+			->willReturn('turn.example.org');
+		$config
+			->expects($this->at(1))
+			->method('getAppValue')
+			->with('spreed', 'turn_server_secret', '')
+			->willReturn('thisisasupersecretsecret');
+		$config
+			->expects($this->at(2))
+			->method('getAppValue')
+			->with('spreed', 'turn_server_protocols', '')
+			->willReturn('udp,tcp');
+		$time = $this->createMock(ITimeFactory::class);
+		$time
+			->expects($this->once())
+			->method('getTime')
+			->willReturn(1479743025);
+
+		$this->assertSame(array(
+			'server' => 'turn.example.org',
+			'username' => 'thisisalongsessionid',
+			'password' => '4rx+b/38p1nKK9vf6YAqXObKSco=',
+			'protocols' => 'udp,tcp',
+		), $this->util->generateTurnSettings($config, $session, $time));
+
+		// command to calculate this by manually
+		// echo -n "$(($(date +"%s")+3600)):USERNAME" | openssl dgst -sha1 -hmac "SECRET" -binary | base64
+	}
 }