test-Transport.js

'use strict';

const tap = require('tap');
const mediasoup = require('../');
const roomOptions = require('./data/options').roomOptions;

function initTest(t)
{
	let server = mediasoup.Server();
	let peer;

	t.tearDown(() => server.close());

	return server.createRoom(roomOptions)
		.then((room) =>
		{
			peer = room.Peer('alice');

			return peer.createTransport({ tcp: false });
		})
		.then((transport) =>
		{
			return { peer, transport };
		});
}

tap.test('transport.setRemoteDtlsParameters() with "server" role must succeed', { timeout: 2000 }, (t) =>
{
	return initTest(t)
		.then((data) =>
		{
			let transport = data.transport;

			t.equal(transport.dtlsLocalParameters.role, 'auto', 'default local DTLS role must be "auto"');

			return transport.setRemoteDtlsParameters(
				{
					role        : 'server',
					fingerprint :
					{
						algorithm : 'sha-1',
						value     : '751b8193b7ed277e42bed6c48ef7043a49ce3faa'
					}
				})
				.then(() =>
				{
					t.pass('transport.setRemoteDtlsParameters() succeeded');
					t.equal(transport.dtlsLocalParameters.role, 'client', 'new local DTLS role must be "client"');

					return transport.dump();
				})
				.then((data) =>
				{
					t.pass('transport.dump() succeeded');
					t.equal(data.dtlsLocalParameters.role, 'client', 'local DTLS role must be "client"');
				});
		});
});

tap.test('transport.setRemoteDtlsParameters() with "auto" role must succeed', { timeout: 2000 }, (t) =>
{
	return initTest(t)
		.then((data) =>
		{
			let transport = data.transport;

			return transport.setRemoteDtlsParameters(
				{
					role        : 'auto',
					fingerprint :
					{
						algorithm : 'sha-1',
						value     : '751b8193b7ed277e42bed6c48ef7043a49ce3faa'
					}
				})
				.then(() =>
				{
					t.pass('transport.setRemoteDtlsParameters() succeeded');
					t.equal(transport.dtlsLocalParameters.role, 'client', 'new local DTLS role must be "client"');

					return transport.dump();
				})
				.then((data) =>
				{
					t.pass('transport.dump() succeeded');
					t.equal(data.dtlsLocalParameters.role, 'client', 'local DTLS role must be "client"');
				});
		});
});

tap.test('transport.setRemoteDtlsParameters() with no role must succeed', { timeout: 2000 }, (t) =>
{
	return initTest(t)
		.then((data) =>
		{
			let transport = data.transport;

			return transport.setRemoteDtlsParameters(
				{
					fingerprint :
					{
						algorithm : 'sha-1',
						value     : '751b8193b7ed277e42bed6c48ef7043a49ce3faa'
					}
				})
				.then(() =>
				{
					t.pass('transport.setRemoteDtlsParameters() succeeded');
					t.equal(transport.dtlsLocalParameters.role, 'client', 'new local DTLS role must be "client"');

					return transport.dump();
				})
				.then((data) =>
				{
					t.pass('transport.dump() succeeded');
					t.equal(data.dtlsLocalParameters.role, 'client', 'local DTLS role must be "client"');
				});
		});
});

tap.test('transport.setRemoteDtlsParameters() with invalid role must fail', { timeout: 2000 }, (t) =>
{
	return initTest(t)
		.then((data) =>
		{
			let transport = data.transport;

			return transport.setRemoteDtlsParameters(
				{
					role        : 'INVALID_ROLE',
					fingerprint :
					{
						algorithm : 'sha-1',
						value     : '751b8193b7ed277e42bed6c48ef7043a49ce3faa'
					}
				})
				.then(() => t.fail('transport.setRemoteDtlsParameters() succeeded'))
				.catch((error) =>
				{
					t.pass(`transport.setRemoteDtlsParameters() failed: ${error}`);
					t.equal(transport.dtlsLocalParameters.role, 'auto', 'local DTLS role must be "auto"');
				});
		});
});

tap.test('transport.setRemoteDtlsParameters() without fingerprint must fail', { timeout: 2000 }, (t) =>
{
	return initTest(t)
		.then((data) =>
		{
			let transport = data.transport;

			return transport.setRemoteDtlsParameters(
				{
					role : 'server'
				})
				.then(() => t.fail('transport.setRemoteDtlsParameters() succeeded'))
				.catch((error) =>
				{
					t.pass(`transport.setRemoteDtlsParameters() failed: ${error}`);
					t.equal(transport.dtlsLocalParameters.role, 'auto', 'local DTLS role must be "auto"');
				});
		});
});

tap.test('transport.close() must succeed', { timeout: 2000 }, (t) =>
{
	let server = mediasoup.Server();

	t.plan(6);
	t.tearDown(() => server.close());

	server.createRoom(roomOptions)
		.then((room) =>
		{
			let peer = room.Peer('alice');

			peer.createTransport({ tcp: false })
				.then((transport) =>
				{
					t.pass('peer.createTransport() succeeded');

					transport.on('close', (error) =>
					{
						t.error(error, 'transport must close cleanly');
						t.equal(transport.iceState, 'closed', 'transport.iceState must be "closed"');
						t.equal(transport.dtlsState, 'closed', 'transport.dtlsState must be "closed"');

						peer.dump()
							.then((data) =>
							{
								t.pass('peer.dump() succeeded');
								t.equal(Object.keys(data.transports).length, 0, 'peer.dump() must retrieve zero transports');
							})
							.catch((error) => t.fail(`peer.dump() failed: ${error}`));
					});

					setTimeout(() => transport.close(), 100);
				})
				.catch((error) => t.fail(`peer.createTransport() failed: ${error}`));
		});
});

tap.test('create transport in a server with rtcAnnouncedIPv4', { timeout: 2000 }, (t) =>
{
	let server = mediasoup.Server(
		{
			rtcIPv4          : true,
			rtcIPv6          : false,
			rtcAnnouncedIPv4 : 'test.foo.com'
		});
	let peer;

	t.tearDown(() => server.close());

	return server.createRoom(roomOptions)
		.then((room) =>
		{
			peer = room.Peer('alice');
		})
		.then(() =>
		{
			return peer.createTransport({ tcp: false });
		})
		.then((transport) =>
		{
			let candidates = transport.iceLocalCandidates;
			let candidate = candidates[0];

			t.equal(candidates.length, 1, 'transport has 1 ICE local candidate');
			t.equal(candidate.protocol, 'udp', 'candidate.protocol must be udp');
			t.equal(candidate.family, 'ipv4', 'candidate.family must be ipv4');
			t.equal(candidate.ip, 'test.foo.com', 'candidate.ip must be test.foo.com');
		})
		.then(() =>
		{
			return peer.createTransport({ udp: false });
		})
		.then((transport) =>
		{
			let candidates = transport.iceLocalCandidates;
			let candidate = candidates[0];

			t.equal(candidates.length, 1, 'transport has 1 ICE local candidate');
			t.equal(candidate.protocol, 'tcp', 'candidate.protocol must be tcp');
			t.equal(candidate.family, 'ipv4', 'candidate.family must be ipv4');
			t.equal(candidate.ip, 'test.foo.com', 'candidate.ip must be test.foo.com');
		});
});