Compare commits
1 Commits
develop
...
LINXD-2180
Author | SHA1 | Date | |
---|---|---|---|
801652170e |
@ -1,2 +0,0 @@
|
|||||||
node_modules
|
|
||||||
doc
|
|
12
.env
@ -1,11 +1,3 @@
|
|||||||
PORT=3000
|
PORT=3000
|
||||||
IP=0.0.0.0 # Listening IPv4 or IPv6.
|
IP=0.0.0.0 # Listening IPv4 or IPv6.
|
||||||
ANNOUNCED_IP=192.168.1.199 # Announced IPv4 or IPv6 (useful when running mediasoup behind NAT with private IP).
|
ANNOUNCED_IP=185.8.154.190 # Announced IPv4 or IPv6 (useful when running mediasoup behind NAT with private IP).
|
||||||
RTC_MIN_PORT=40000
|
|
||||||
RTC_MAX_PORT=49999
|
|
||||||
SERVER_CERT="./server/ssl/cert.pem"
|
|
||||||
SERVER_KEY="./server/ssl/key.pem"
|
|
||||||
ENABLE_UDP=true
|
|
||||||
ENABLE_TCP=true
|
|
||||||
PREFER_UDP=true
|
|
||||||
PREFER_TCP=false
|
|
||||||
|
2
.gitignore
vendored
@ -1,3 +1 @@
|
|||||||
/node_modules
|
/node_modules
|
||||||
/dist
|
|
||||||
.idea
|
|
26
Dockerfile
@ -1,25 +1,11 @@
|
|||||||
FROM ubuntu:22.04
|
FROM ubuntu
|
||||||
|
|
||||||
WORKDIR /app
|
|
||||||
|
|
||||||
RUN apt-get update && \
|
RUN apt-get update && \
|
||||||
apt-get install -y build-essential pip net-tools iputils-ping iproute2 curl
|
apt-get install -y build-essential pip net-tools iputils-ping iproute2 curl
|
||||||
|
|
||||||
RUN curl -fsSL https://deb.nodesource.com/setup_20.x | bash -
|
RUN curl -fsSL https://deb.nodesource.com/setup_16.x | bash -
|
||||||
RUN apt-get install -y nodejs
|
RUN apt-get install -y nodejs
|
||||||
|
RUN npm install -g watchify
|
||||||
|
|
||||||
COPY . /app/
|
EXPOSE 3000
|
||||||
|
EXPOSE 2000-2020
|
||||||
RUN npm install
|
EXPOSE 10000-10100
|
||||||
|
|
||||||
EXPOSE 3000/tcp
|
|
||||||
EXPOSE 2000-2200/udp
|
|
||||||
|
|
||||||
CMD node app.js
|
|
||||||
|
|
||||||
#docker build -t linx-video .
|
|
||||||
# docker run -it -d --restart always -p 3000:3000/tcp -p 2000-2200:2000-2200/udp linx-video
|
|
||||||
#Run under host network
|
|
||||||
# docker run -it -d --network host --restart always -p 3000:3000/tcp -p 2000-2200:2000-2200/udp linx-video
|
|
||||||
#https://docs.docker.com/config/containers/resource_constraints/
|
|
||||||
#docker run -it -d --network host --cpus="0.25" --memory="512m" --restart always -p 3000:3000/tcp -p 2000-2200:2000-2200/udp linx-video
|
|
52
README.md
@ -1,59 +1,29 @@
|
|||||||
# Video server
|
# Video server
|
||||||
|
|
||||||
### Generating certificates
|
|
||||||
|
|
||||||
##### To generate SSL certificates you must:
|
|
||||||
1. Go to `/server/ssl`
|
|
||||||
2. Execute `openssl req -newkey rsa:2048 -new -nodes -x509 -days 3650 -keyout key.pem -out cert.pem`
|
|
||||||
|
|
||||||
### Development
|
### Development
|
||||||
|
|
||||||
##### To start in development mode you must:
|
##### To start in development mode you must:
|
||||||
|
|
||||||
1. Install the dependencies `npm install`.
|
1. Install the dependencies `npm install`.
|
||||||
|
2. Run the `npm start:dev` command to start the server in dev mode.
|
||||||
|
(Any change will trigger a refresh of the server)
|
||||||
|
|
||||||
2. Go to the `linx-devops/scaling-tools/private-system-truste-cert` project and generate a new server certificate and key:
|
|
||||||
|
|
||||||
sh create_certificate_for_domain.sh 192.168.1.110 #local IP
|
|
||||||
# generates files
|
|
||||||
nginx-selfsigned.crt
|
|
||||||
device.key
|
|
||||||
|
|
||||||
3. You need to update the Video Server in the provisioning to point to your private IP. ex: https://192.168.1.199:3000
|
|
||||||
|
|
||||||
4. The generated files must be moved to server/ssl and renamed as follows:
|
|
||||||
|
|
||||||
cp device.key {mediasoup_project}/server/ssl/key.pem
|
|
||||||
cp nginx-selfsigned.crt {mediosup_project}/server/ssl/cert.pem
|
|
||||||
|
|
||||||
5. Go to https://dev.linx.safemobile.com/dispatcher/resources/help/LINXHelp.html#safemobile-certificate-import and import the certificate for your system type
|
|
||||||
|
|
||||||
6. The ANNOUNCED IP in .env must be configured to use the same private IP used in generating the certificate.
|
|
||||||
|
|
||||||
7. Run the `npm start:dev` command to start the server in dev mode.
|
|
||||||
(Any change will trigger a refresh of the server)
|
|
||||||
|
|
||||||
### Production
|
### Production
|
||||||
|
|
||||||
##### To start in production mode you must:
|
##### To start in production mode you must:
|
||||||
1. Install the dependencies `npm install`.
|
1. Install the dependencies `npm install`.
|
||||||
2. Run the `npm start:prod` command to start the server in production mode.
|
2. Run the `npm start:prod` command to start the server in production mode.
|
||||||
(To connect to the terminal, use `pm2 log video-server`)
|
(To connect to the terminal, use `pm2 log video-server`)
|
||||||
|
|
||||||
|
---
|
||||||
### Web client
|
|
||||||
|
|
||||||
- The server will start by default on port 3000, and the ssl certificates will have to be configured
|
- The server will start by default on port 3000, and the ssl certificates will have to be configured
|
||||||
- The web client can be accessed using the /sfu path
|
- The web client can be accessed using the /sfu path
|
||||||
ex: https://HOST/sfu/?assetId=1&&accountId=1&producer=true&dest_asset_id=75&assetName=Adi
|
ex: http://localhost:3000/sfu/?assetId=1&&accountId=1&producer=true&assetName=Adi&assetType=linx
|
||||||
assetId = asset id of the unit on which you are doing the test
|
assetId = asset id of the unit on which you are doing the test
|
||||||
accountId = account id of the unit on which you are doing the test
|
accountId = account id of the unit on which you are doing the test
|
||||||
producer = it will always be true because you are the producer
|
producer = it will always be true because you are the producer
|
||||||
(it's possible to put false, but then you have to have another client with producer true)
|
(it's possible to put false, but then you have to have another client with producer true)
|
||||||
assetName = asset name of the unit on which you are doing the test
|
assetName = asset name of the unit on which you are doing the test
|
||||||
dest_asset_id= the addressee with whom the call is made
|
assetType = asset type of the unit on which you are doing the test
|
||||||
- To make a call using this client, you need a microphone and permission to use it
|
|
||||||
- For any changes related to the client, the command `npm run watch' will have to be used to generate the bundle.js used by the web client
|
|
||||||
|
|
||||||
### Demo project
|
|
||||||
The demo project used initially and then modified for our needs `https://github.com/jamalag/mediasoup2`
|
|
75
build.sh
@ -1,75 +0,0 @@
|
|||||||
#/!bin/bash
|
|
||||||
## FUNCTIONS
|
|
||||||
function getGitVersion(){
|
|
||||||
version=$(git describe)
|
|
||||||
count=$(echo ${version%%-*} | grep -o "\." | wc -l)
|
|
||||||
if (( $count > 1 )); then
|
|
||||||
version=${version%%-*}
|
|
||||||
elif (( $count == 0 ));then
|
|
||||||
echo -e "Error: Git version \"${version%%-*}\" not respecting Safemobile standard.\n Must be like 4.xx or 4.xx.xx"
|
|
||||||
version="0.0.0"
|
|
||||||
else
|
|
||||||
if [[ "$1" == "dev" ]];then
|
|
||||||
cleanprefix=${version#*-} # remove everything before `-` including `-`
|
|
||||||
cleansuffix=${cleanprefix%-*} # remove everything after `-` including `-`
|
|
||||||
version="${version%%-*}.${cleansuffix}"
|
|
||||||
else
|
|
||||||
version="${version%%-*}.0" # one `%` remove everything after last `-`, two `%%` remove everything after all `-`
|
|
||||||
fi
|
|
||||||
fi
|
|
||||||
}
|
|
||||||
|
|
||||||
function addVersionPm2(){
|
|
||||||
file_pkg="package.json"
|
|
||||||
key=" \"version\": \""
|
|
||||||
|
|
||||||
if [ -f "$file_pkg" ] && [ ! -z "$version" ]; then
|
|
||||||
versionApp=" \"version\": \"$version\","
|
|
||||||
sed -i "s|^.*$key.*|${versionApp//\//\\/}|g" $file_pkg
|
|
||||||
text=$(cat $file_pkg | grep -c "$version")
|
|
||||||
if [ $text -eq 0 ]; then
|
|
||||||
echo "Version couldn't be set"
|
|
||||||
else
|
|
||||||
echo "Version $version successfully applied to App"
|
|
||||||
fi
|
|
||||||
fi
|
|
||||||
}
|
|
||||||
|
|
||||||
## PREBUILD PROCESS
|
|
||||||
# check dist dir to be present and empty
|
|
||||||
if [ ! -d "dist" ]; then
|
|
||||||
## MAKE DIR
|
|
||||||
mkdir "dist"
|
|
||||||
echo "Directory dist created."
|
|
||||||
else
|
|
||||||
## CLEANUP
|
|
||||||
rm -fr dist/*
|
|
||||||
fi
|
|
||||||
|
|
||||||
if [ -d "node_modules" ]; then
|
|
||||||
rm -fr node_modules
|
|
||||||
fi
|
|
||||||
|
|
||||||
# Install dependencies
|
|
||||||
#npm install
|
|
||||||
|
|
||||||
## PROJECT NEEDS
|
|
||||||
echo "Building app... from $(git rev-parse --abbrev-ref HEAD)"
|
|
||||||
#npm run-script build
|
|
||||||
cp -r {.env,app.js,package.json,server,public,doc,Dockerfile,tsconfig.json,.dockerignore} dist/
|
|
||||||
#cp -r ./* dist/
|
|
||||||
|
|
||||||
# Generate Git log
|
|
||||||
dateString=$(date +"%Y%m%d-%H%M%S")
|
|
||||||
git log --pretty=format:"%ad%x09%an%x09%s" --no-merges -20 > "dist/git-$dateString.log"
|
|
||||||
|
|
||||||
# Get Git version control
|
|
||||||
getGitVersion $1
|
|
||||||
|
|
||||||
# Add version control for pm2
|
|
||||||
cd dist
|
|
||||||
addVersionPm2
|
|
||||||
|
|
||||||
## POST BUILD
|
|
||||||
|
|
||||||
cd -
|
|
Before Width: | Height: | Size: 1.2 MiB |
Before Width: | Height: | Size: 419 KiB |
Before Width: | Height: | Size: 1.0 MiB |
Before Width: | Height: | Size: 968 KiB |
Before Width: | Height: | Size: 606 KiB |
Before Width: | Height: | Size: 349 KiB |
Before Width: | Height: | Size: 412 KiB |
Before Width: | Height: | Size: 421 KiB |
Before Width: | Height: | Size: 215 KiB |
Before Width: | Height: | Size: 567 KiB |
Before Width: | Height: | Size: 660 KiB |
1913
package-lock.json
generated
@ -5,18 +5,21 @@
|
|||||||
"main": "app.js",
|
"main": "app.js",
|
||||||
"scripts": {
|
"scripts": {
|
||||||
"test": "echo \"Error: no test specified\" && exit 1",
|
"test": "echo \"Error: no test specified\" && exit 1",
|
||||||
"start:dev": "nodemon app.js",
|
"start:dev": "nodemon app.ts",
|
||||||
"start:prod": "pm2 start ./app.js -n video-server",
|
"start:prod": "pm2 start ./app.js -n video-server",
|
||||||
"watch": "watchify public/index.js -o public/bundle.js -v"
|
"watch": "watchify public/index.js -o public/bundle.js -v"
|
||||||
},
|
},
|
||||||
"keywords": [],
|
"keywords": [],
|
||||||
"author": "",
|
"author": "",
|
||||||
"license": "ISC",
|
"license": "ISC",
|
||||||
|
"type": "module",
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"@types/express": "^4.17.13",
|
"@types/express": "^4.17.13",
|
||||||
"dotenv": "^16.0.1",
|
"dotenv": "^16.0.1",
|
||||||
"express": "^4.18.1",
|
"express": "^4.18.1",
|
||||||
"mediasoup": "^3.15.5",
|
"ffmpeg-static": "^5.0.2",
|
||||||
|
"httpolyglot": "^0.1.2",
|
||||||
|
"mediasoup": "^3.10.4",
|
||||||
"mediasoup-client": "^3.6.54",
|
"mediasoup-client": "^3.6.54",
|
||||||
"parcel": "^2.7.0",
|
"parcel": "^2.7.0",
|
||||||
"socket.io": "^2.0.3",
|
"socket.io": "^2.0.3",
|
||||||
|
1372
public/bundle.js
@ -1,4 +1,5 @@
|
|||||||
module.exports = {
|
module.exports = {
|
||||||
hubAddress: 'https://hub.dev.linx.safemobile.com/',
|
hubAddress: 'https://hub.dev.linx.safemobile.com/',
|
||||||
mediasoupAddress: 'https://testing.video.safemobile.org/',
|
// mediasoupAddress: 'https://video.safemobile.org/mediasoup',
|
||||||
|
mediasoupAddress: 'http://localhost:3000/mediasoup',
|
||||||
}
|
}
|
@ -34,9 +34,6 @@
|
|||||||
<body>
|
<body>
|
||||||
<body>
|
<body>
|
||||||
<div id="video">
|
<div id="video">
|
||||||
<legend>Client options:</legend>
|
|
||||||
<input type="checkbox" id="produceAudio" name="produceAudio">
|
|
||||||
<label for="produceAudio">Produce audio</label><br>
|
|
||||||
<table>
|
<table>
|
||||||
<thead>
|
<thead>
|
||||||
<th>Local Video</th>
|
<th>Local Video</th>
|
||||||
@ -46,24 +43,12 @@
|
|||||||
<tr>
|
<tr>
|
||||||
<td>
|
<td>
|
||||||
<div id="sharedBtns">
|
<div id="sharedBtns">
|
||||||
<video
|
<video id="localVideo" autoplay class="video" ></video>
|
||||||
id="localVideo"
|
|
||||||
class="video"
|
|
||||||
autoplay
|
|
||||||
muted
|
|
||||||
playsinline
|
|
||||||
></video>
|
|
||||||
</div>
|
</div>
|
||||||
</td>
|
</td>
|
||||||
<td>
|
<td>
|
||||||
<div id="sharedBtns">
|
<div id="sharedBtns">
|
||||||
<video
|
<video id="remoteVideo" autoplay class="video" ></video>
|
||||||
id="remoteVideo"
|
|
||||||
class="video"
|
|
||||||
autoplay
|
|
||||||
muted
|
|
||||||
playsinline
|
|
||||||
></video>
|
|
||||||
</div>
|
</div>
|
||||||
</td>
|
</td>
|
||||||
</tr>
|
</tr>
|
||||||
@ -75,11 +60,34 @@
|
|||||||
</td>
|
</td>
|
||||||
<td>
|
<td>
|
||||||
<div id="sharedBtns">
|
<div id="sharedBtns">
|
||||||
<!-- <button id="btnRecvSendTransport">Consume</button> -->
|
<button id="btnRecvSendTransport">Consume</button>
|
||||||
<button id="remoteSoundControl">Unmute</button>
|
|
||||||
</div>
|
</div>
|
||||||
</td>
|
</td>
|
||||||
</tr>
|
</tr>
|
||||||
|
<!-- <tr>
|
||||||
|
<td colspan="2">
|
||||||
|
<div id="sharedBtns">
|
||||||
|
<button id="btnRtpCapabilities">2. Get Rtp Capabilities</button>
|
||||||
|
<br />
|
||||||
|
<button id="btnDevice">3. Create Device</button>
|
||||||
|
</div>
|
||||||
|
</td>
|
||||||
|
</tr>
|
||||||
|
<tr>
|
||||||
|
<td>
|
||||||
|
<div id="sharedBtns">
|
||||||
|
<button id="btnCreateSendTransport">4. Create Send Transport</button>
|
||||||
|
<br />
|
||||||
|
<button id="btnConnectSendTransport">5. Connect Send Transport & Produce</button></td>
|
||||||
|
</div>
|
||||||
|
<td>
|
||||||
|
<div id="sharedBtns">
|
||||||
|
<button id="btnRecvSendTransport">6. Create Recv Transport</button>
|
||||||
|
<br />
|
||||||
|
<button id="btnConnectRecvTransport">7. Connect Recv Transport & Consume</button>
|
||||||
|
</div>
|
||||||
|
</td>
|
||||||
|
</tr> -->
|
||||||
</tbody>
|
</tbody>
|
||||||
</table>
|
</table>
|
||||||
<div id="closeCallBtn">
|
<div id="closeCallBtn">
|
||||||
|
459
public/index.js
@ -10,201 +10,147 @@ const ASSET_NAME = urlParams.get('assetName') || null;
|
|||||||
const ASSET_TYPE = urlParams.get('assetType') || null;
|
const ASSET_TYPE = urlParams.get('assetType') || null;
|
||||||
let callId = parseInt(urlParams.get('callId')) || null;
|
let callId = parseInt(urlParams.get('callId')) || null;
|
||||||
const IS_PRODUCER = urlParams.get('producer') === 'true' ? true : false
|
const IS_PRODUCER = urlParams.get('producer') === 'true' ? true : false
|
||||||
let remoteVideo = document.getElementById('remoteVideo')
|
|
||||||
remoteVideo.defaultMuted = true
|
|
||||||
let produceAudio = false
|
|
||||||
|
|
||||||
console.log('[URL] ASSET_ID', ASSET_ID, '| ACCOUNT_ID', ACCOUNT_ID, '| callId', callId, ' | IS_PRODUCER', IS_PRODUCER)
|
console.log('[URL] ASSET_ID', ASSET_ID, '| ACCOUNT_ID', ACCOUNT_ID, '| callId', callId, ' | IS_PRODUCER', IS_PRODUCER)
|
||||||
|
|
||||||
console.log('🟩 config', config)
|
let socket
|
||||||
|
hub = io(config.hubAddress)
|
||||||
|
|
||||||
produceAudioSelector = document.getElementById('produceAudio');
|
const connectToMediasoup = () => {
|
||||||
produceAudioSelector.addEventListener('change', e => {
|
|
||||||
if(e.target.checked) {
|
socket = io(config.mediasoupAddress, {
|
||||||
produceAudio = true
|
reconnection: true,
|
||||||
console.log('produce audio');
|
reconnectionDelay: 1000,
|
||||||
} else {
|
reconnectionDelayMax : 5000,
|
||||||
produceAudio = false
|
reconnectionAttempts: Infinity
|
||||||
|
})
|
||||||
|
|
||||||
|
socket.on('connection-success', ({ _socketId, existsProducer }) => {
|
||||||
|
console.log(`[MEDIA] ${config.mediasoupAddress} | connected: ${socket.connected} | existsProducer: ${existsProducer}`)
|
||||||
|
if (!IS_PRODUCER && existsProducer && consumer === undefined) {
|
||||||
|
goConnect()
|
||||||
|
// document.getElementById('btnRecvSendTransport').click();
|
||||||
}
|
}
|
||||||
});
|
if (IS_PRODUCER && urlParams.get('testing') === 'true') { getLocalStream() }
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
|
if (IS_PRODUCER === true) {
|
||||||
|
hub.on('connect', async () => {
|
||||||
|
console.log(`[HUB] ${config.hubAddress} | connected: ${hub.connected}`)
|
||||||
|
connectToMediasoup()
|
||||||
|
|
||||||
|
hub.emit(
|
||||||
|
'ars',
|
||||||
|
JSON.stringify({
|
||||||
|
ars: true,
|
||||||
|
asset_id: ASSET_ID,
|
||||||
|
account_id: ACCOUNT_ID,
|
||||||
|
})
|
||||||
|
)
|
||||||
|
|
||||||
|
hub.on('video', (data) => {
|
||||||
|
const parsedData = JSON.parse(data);
|
||||||
|
|
||||||
|
if (parsedData.type === 'notify-request') {
|
||||||
|
console.log('video', parsedData)
|
||||||
|
originAssetId = parsedData.origin_asset_id;
|
||||||
|
// originAssetName = parsedData.origin_asset_name;
|
||||||
|
// originAssetTypeName = parsedData.origin_asset_type_name;
|
||||||
|
callId = parsedData.video_call_id;
|
||||||
|
|
||||||
|
console.log('[VIDEO] notify-request | IS_PRODUCER', IS_PRODUCER, 'callId', callId);
|
||||||
|
getLocalStream()
|
||||||
|
}
|
||||||
|
|
||||||
|
if (parsedData.type === 'notify-end') {
|
||||||
|
console.log('[VIDEO] notify-end | IS_PRODUCER', IS_PRODUCER, 'callId', callId);
|
||||||
|
resetCallSettings()
|
||||||
|
}
|
||||||
|
})
|
||||||
|
})
|
||||||
|
|
||||||
|
hub.on('connect_error', (error) => {
|
||||||
|
console.log('connect_error', error);
|
||||||
|
});
|
||||||
|
|
||||||
|
hub.on('connection', () => {
|
||||||
|
console.log('connection')
|
||||||
|
})
|
||||||
|
|
||||||
|
hub.on('disconnect', () => {
|
||||||
|
console.log('disconnect')
|
||||||
|
})
|
||||||
|
} else {
|
||||||
|
connectToMediasoup()
|
||||||
|
}
|
||||||
|
|
||||||
let socket, hub
|
|
||||||
let device
|
let device
|
||||||
let rtpCapabilities
|
let rtpCapabilities
|
||||||
let producerTransport
|
let producerTransport
|
||||||
let consumerTransport
|
let consumerTransport
|
||||||
let producerVideo
|
let producer
|
||||||
let producerAudio
|
|
||||||
let consumer
|
let consumer
|
||||||
let originAssetId
|
let originAssetId
|
||||||
let consumerVideo // local consumer video(consumer not transport)
|
// let originAssetName = 'Adi'
|
||||||
let consumerAudio // local consumer audio(consumer not transport)
|
// let originAssetTypeName = 'linx'
|
||||||
|
|
||||||
const remoteSoundControl = document.getElementById('remoteSoundControl');
|
|
||||||
|
|
||||||
remoteSoundControl.addEventListener('click', function handleClick() {
|
|
||||||
console.log('remoteSoundControl.textContent', remoteSoundControl.textContent);
|
|
||||||
if (remoteSoundControl.textContent === 'Unmute') {
|
|
||||||
remoteVideo.muted = false
|
|
||||||
remoteSoundControl.textContent = 'Mute';
|
|
||||||
} else {
|
|
||||||
remoteVideo.muted = true
|
|
||||||
remoteSoundControl.textContent = 'Unmute';
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
// https://mediasoup.org/documentation/v3/mediasoup-client/api/#ProducerOptions
|
// https://mediasoup.org/documentation/v3/mediasoup-client/api/#ProducerOptions
|
||||||
// https://mediasoup.org/documentation/v3/mediasoup-client/api/#transport-produce
|
// https://mediasoup.org/documentation/v3/mediasoup-client/api/#transport-produce
|
||||||
let videoParams = {
|
let params = {
|
||||||
|
// mediasoup params
|
||||||
encodings: [
|
encodings: [
|
||||||
{ scaleResolutionDownBy: 4, maxBitrate: 500000 },
|
{
|
||||||
{ scaleResolutionDownBy: 2, maxBitrate: 1000000 },
|
rid: 'r0',
|
||||||
{ scaleResolutionDownBy: 1, maxBitrate: 5000000 },
|
maxBitrate: 100000,
|
||||||
{ scalabilityMode: 'S3T3_KEY' }
|
scalabilityMode: 'S1T3',
|
||||||
|
},
|
||||||
|
{
|
||||||
|
rid: 'r1',
|
||||||
|
maxBitrate: 300000,
|
||||||
|
scalabilityMode: 'S1T3',
|
||||||
|
},
|
||||||
|
{
|
||||||
|
rid: 'r2',
|
||||||
|
maxBitrate: 900000,
|
||||||
|
scalabilityMode: 'S1T3',
|
||||||
|
},
|
||||||
],
|
],
|
||||||
|
// https://mediasoup.org/documentation/v3/mediasoup-client/api/#ProducerCodecOptions
|
||||||
codecOptions: {
|
codecOptions: {
|
||||||
videoGoogleStartBitrate: 1000
|
videoGoogleStartBitrate: 1000
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
let audioParams = {
|
|
||||||
codecOptions :
|
|
||||||
{
|
|
||||||
opusStereo : true,
|
|
||||||
opusDtx : true
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
setTimeout(() => {
|
|
||||||
hub = io(config.hubAddress)
|
|
||||||
|
|
||||||
const connectToMediasoup = () => {
|
|
||||||
|
|
||||||
socket = io(config.mediasoupAddress, {
|
|
||||||
reconnection: true,
|
|
||||||
reconnectionDelay: 1000,
|
|
||||||
reconnectionDelayMax : 5000,
|
|
||||||
reconnectionAttempts: Infinity
|
|
||||||
})
|
|
||||||
|
|
||||||
socket.on('connection-success', ({ _socketId, existsProducer }) => {
|
|
||||||
console.log(`[MEDIA] ${config.mediasoupAddress} | connected: ${socket.connected} | existsProducer: ${existsProducer}`)
|
|
||||||
if (!IS_PRODUCER && existsProducer && consumer === undefined) {
|
|
||||||
goConnect()
|
|
||||||
}
|
|
||||||
if (IS_PRODUCER && urlParams.get('testing') === 'true') { getLocalStream() }
|
|
||||||
})
|
|
||||||
|
|
||||||
socket.on('new-producer', ({ callId, kind }) => {
|
|
||||||
console.log(`🟢 new-producer | callId: ${callId} | kind: ${kind} | Ready to consume`);
|
|
||||||
connectRecvTransport();
|
|
||||||
})
|
|
||||||
|
|
||||||
socket.on('close-producer', ({ callId, kind }) => {
|
|
||||||
console.log(`🔴 close-producer | callId: ${callId} | kind: ${kind}`);
|
|
||||||
if (kind === 'video') {
|
|
||||||
consumerVideo.close()
|
|
||||||
remoteVideo.srcObject = null
|
|
||||||
}
|
|
||||||
else if (kind === 'audio') consumerAudio.close()
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
if (IS_PRODUCER === true) {
|
|
||||||
hub.on('connect', async () => {
|
|
||||||
console.log(`[HUB]! ${config.hubAddress} | connected: ${hub.connected}`)
|
|
||||||
connectToMediasoup()
|
|
||||||
|
|
||||||
hub.emit(
|
|
||||||
'ars',
|
|
||||||
JSON.stringify({
|
|
||||||
ars: true,
|
|
||||||
asset_id: ASSET_ID,
|
|
||||||
account_id: ACCOUNT_ID,
|
|
||||||
})
|
|
||||||
)
|
|
||||||
|
|
||||||
hub.on('video', (data) => {
|
|
||||||
const parsedData = JSON.parse(data);
|
|
||||||
|
|
||||||
if (parsedData.type === 'notify-request') {
|
|
||||||
console.log('video', parsedData)
|
|
||||||
originAssetId = parsedData.origin_asset_id;
|
|
||||||
// originAssetName = parsedData.origin_asset_name;
|
|
||||||
// originAssetTypeName = parsedData.origin_asset_type_name;
|
|
||||||
callId = parsedData.video_call_id;
|
|
||||||
|
|
||||||
console.log('[VIDEO] notify-request | IS_PRODUCER', IS_PRODUCER, 'callId', callId);
|
|
||||||
getLocalStream()
|
|
||||||
}
|
|
||||||
|
|
||||||
if (parsedData.type === 'notify-end') {
|
|
||||||
console.log('[VIDEO] notify-end | IS_PRODUCER', IS_PRODUCER, 'callId', callId);
|
|
||||||
resetCallSettings()
|
|
||||||
}
|
|
||||||
})
|
|
||||||
})
|
|
||||||
|
|
||||||
hub.on('connect_error', (error) => {
|
|
||||||
console.log('connect_error', error);
|
|
||||||
});
|
|
||||||
|
|
||||||
hub.on('connection', () => {
|
|
||||||
console.log('connection')
|
|
||||||
})
|
|
||||||
|
|
||||||
hub.on('disconnect', () => {
|
|
||||||
console.log('disconnect')
|
|
||||||
})
|
|
||||||
} else {
|
|
||||||
connectToMediasoup()
|
|
||||||
}
|
|
||||||
|
|
||||||
}, 1600);
|
|
||||||
|
|
||||||
const streamSuccess = (stream) => {
|
const streamSuccess = (stream) => {
|
||||||
console.log('[streamSuccess] device', device);
|
console.log('[streamSuccess]');
|
||||||
localVideo.srcObject = stream
|
localVideo.srcObject = stream
|
||||||
console.log('stream', stream);
|
const track = stream.getVideoTracks()[0]
|
||||||
const videoTrack = stream.getVideoTracks()[0]
|
params = {
|
||||||
const audioTrack = stream.getAudioTracks()[0]
|
track,
|
||||||
|
...params
|
||||||
videoParams = {
|
|
||||||
track: videoTrack,
|
|
||||||
...videoParams
|
|
||||||
}
|
}
|
||||||
|
|
||||||
audioParams = {
|
|
||||||
track: audioTrack,
|
|
||||||
...audioParams
|
|
||||||
}
|
|
||||||
|
|
||||||
console.log('[streamSuccess] videoParams', videoParams, ' | audioParams', audioParams);
|
|
||||||
goConnect()
|
goConnect()
|
||||||
}
|
}
|
||||||
|
|
||||||
const getLocalStream = () => {
|
const getLocalStream = () => {
|
||||||
console.log('[getLocalStream]');
|
console.log('[getLocalStream]');
|
||||||
navigator.mediaDevices.getUserMedia({
|
navigator.mediaDevices.getUserMedia({
|
||||||
audio: produceAudio ? true : false,
|
audio: false,
|
||||||
video: {
|
video: {
|
||||||
qvga : { width: { ideal: 320 }, height: { ideal: 240 } },
|
width: {
|
||||||
vga : { width: { ideal: 640 }, height: { ideal: 480 } },
|
min: 640,
|
||||||
hd : { width: { ideal: 1280 }, height: { ideal: 720 } }
|
max: 1920,
|
||||||
|
},
|
||||||
|
height: {
|
||||||
|
min: 400,
|
||||||
|
max: 1080,
|
||||||
|
}
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
.then(streamSuccess)
|
.then(streamSuccess)
|
||||||
.catch(error => {
|
.catch(error => {
|
||||||
console.log(error.message)
|
console.log('getLocalStream', error)
|
||||||
})
|
})
|
||||||
|
|
||||||
navigator.permissions.query(
|
|
||||||
{ name: 'microphone' }
|
|
||||||
).then((permissionStatus) =>{
|
|
||||||
console.log('🟨 [PERMISSION] permissionStatus', permissionStatus); // granted, denied, prompt
|
|
||||||
// It will block the code from execution and display "Permission denied" if we don't have microphone permissions
|
|
||||||
})
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
const goConnect = () => {
|
const goConnect = () => {
|
||||||
@ -221,6 +167,7 @@ const goCreateTransport = () => {
|
|||||||
// server side to send/recive media
|
// server side to send/recive media
|
||||||
const createDevice = async () => {
|
const createDevice = async () => {
|
||||||
try {
|
try {
|
||||||
|
console.log('[createDevice]');
|
||||||
device = new mediasoupClient.Device()
|
device = new mediasoupClient.Device()
|
||||||
|
|
||||||
// https://mediasoup.org/documentation/v3/mediasoup-client/api/#device-load
|
// https://mediasoup.org/documentation/v3/mediasoup-client/api/#device-load
|
||||||
@ -231,7 +178,6 @@ const createDevice = async () => {
|
|||||||
})
|
})
|
||||||
|
|
||||||
console.log('Device RTP Capabilities', device.rtpCapabilities)
|
console.log('Device RTP Capabilities', device.rtpCapabilities)
|
||||||
console.log('[createDevice] device', device);
|
|
||||||
|
|
||||||
// once the device loads, create transport
|
// once the device loads, create transport
|
||||||
goCreateTransport()
|
goCreateTransport()
|
||||||
@ -261,20 +207,18 @@ const getRtpCapabilities = () => {
|
|||||||
}
|
}
|
||||||
|
|
||||||
const createSendTransport = () => {
|
const createSendTransport = () => {
|
||||||
console.log('[createSendTransport');
|
|
||||||
// see server's socket.on('createWebRtcTransport', sender?, ...)
|
// see server's socket.on('createWebRtcTransport', sender?, ...)
|
||||||
// this is a call from Producer, so sender = true
|
// this is a call from Producer, so sender = true
|
||||||
socket.emit('createWebRtcTransport', { sender: true }, (value) => {
|
socket.emit('createWebRtcTransport', { sender: true, callId }, ({ params }) => {
|
||||||
|
|
||||||
console.log(`[createWebRtcTransport] value: ${JSON.stringify(value)}`);
|
|
||||||
|
|
||||||
const params = value.params;
|
|
||||||
// The server sends back params needed
|
// The server sends back params needed
|
||||||
// to create Send Transport on the client side
|
// to create Send Transport on the client side
|
||||||
if (params.error) {
|
if (params.error) {
|
||||||
console.log(params.error)
|
console.log(params.error)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
|
console.log(params)
|
||||||
|
|
||||||
// creates a new WebRTC Transport to send media
|
// creates a new WebRTC Transport to send media
|
||||||
// based on the server's producer transport params
|
// based on the server's producer transport params
|
||||||
// https://mediasoup.org/documentation/v3/mediasoup-client/api/#TransportOptions
|
// https://mediasoup.org/documentation/v3/mediasoup-client/api/#TransportOptions
|
||||||
@ -300,17 +244,17 @@ const createSendTransport = () => {
|
|||||||
})
|
})
|
||||||
|
|
||||||
producerTransport.on('produce', async (parameters, callback, errback) => {
|
producerTransport.on('produce', async (parameters, callback, errback) => {
|
||||||
console.log('[produce] parameters', parameters)
|
console.log('produce', parameters)
|
||||||
|
|
||||||
try {
|
try {
|
||||||
// Tell the server to create a Producer
|
// tell the server to create a Producer
|
||||||
// with the following parameters and produce
|
// with the following parameters and produce
|
||||||
// and expect back a server side producer id
|
// and expect back a server side producer id
|
||||||
// see server's socket.on('transport-produce', ...)
|
// see server's socket.on('transport-produce', ...)
|
||||||
await socket.emit('transport-produce', {
|
await socket.emit('transport-produce', {
|
||||||
kind: parameters.kind,
|
kind: parameters.kind,
|
||||||
rtpParameters: parameters.rtpParameters,
|
rtpParameters: parameters.rtpParameters,
|
||||||
appData: parameters.appData,
|
callId: callId
|
||||||
}, ({ id }) => {
|
}, ({ id }) => {
|
||||||
// Tell the transport that parameters were transmitted and provide it with the
|
// Tell the transport that parameters were transmitted and provide it with the
|
||||||
// server side producer's id.
|
// server side producer's id.
|
||||||
@ -326,46 +270,22 @@ const createSendTransport = () => {
|
|||||||
}
|
}
|
||||||
|
|
||||||
const connectSendTransport = async () => {
|
const connectSendTransport = async () => {
|
||||||
|
// we now call produce() to instruct the producer transport
|
||||||
console.log('[connectSendTransport] producerTransport');
|
|
||||||
|
|
||||||
// We now call produce() to instruct the producer transport
|
|
||||||
// to send media to the Router
|
// to send media to the Router
|
||||||
// https://mediasoup.org/documentation/v3/mediasoup-client/api/#transport-produce
|
// https://mediasoup.org/documentation/v3/mediasoup-client/api/#transport-produce
|
||||||
// this action will trigger the 'connect' and 'produce' events above
|
// this action will trigger the 'connect' and 'produce' events above
|
||||||
|
producer = await producerTransport.produce(params)
|
||||||
|
|
||||||
// Produce video
|
producer.on('trackended', () => {
|
||||||
let producerVideoHandler = await producerTransport.produce(videoParams)
|
|
||||||
console.log('videoParams', videoParams);
|
|
||||||
console.log('producerVideo', producerVideo);
|
|
||||||
|
|
||||||
producerVideoHandler.on('trackended', () => {
|
|
||||||
console.log('track ended')
|
console.log('track ended')
|
||||||
// close video track
|
// close video track
|
||||||
})
|
})
|
||||||
|
|
||||||
producerVideoHandler.on('transportclose', () => {
|
producer.on('transportclose', () => {
|
||||||
console.log('transport ended')
|
console.log('transport ended')
|
||||||
// close video track
|
// close video track
|
||||||
})
|
})
|
||||||
|
|
||||||
// Produce audio
|
|
||||||
if (produceAudio) {
|
|
||||||
let producerAudioHandler = await producerTransport.produce(audioParams)
|
|
||||||
console.log('audioParams', audioParams);
|
|
||||||
console.log('producerAudio', producerAudio);
|
|
||||||
|
|
||||||
producerAudioHandler.on('trackended', () => {
|
|
||||||
console.log('track ended')
|
|
||||||
// close audio track
|
|
||||||
})
|
|
||||||
|
|
||||||
producerAudioHandler.on('transportclose', () => {
|
|
||||||
console.log('transport ended')
|
|
||||||
// close audio track
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
const answer = {
|
const answer = {
|
||||||
origin_asset_id: ASSET_ID,
|
origin_asset_id: ASSET_ID,
|
||||||
dest_asset_id: originAssetId || parseInt(urlParams.get('dest_asset_id')),
|
dest_asset_id: originAssetId || parseInt(urlParams.get('dest_asset_id')),
|
||||||
@ -374,7 +294,7 @@ const connectSendTransport = async () => {
|
|||||||
origin_asset_type_name: ASSET_TYPE,
|
origin_asset_type_name: ASSET_TYPE,
|
||||||
origin_asset_name: ASSET_NAME,
|
origin_asset_name: ASSET_NAME,
|
||||||
video_call_id: callId,
|
video_call_id: callId,
|
||||||
answer: 'accepted', // answer: accepted/rejected
|
answer: 'accepted', // answer: 'rejected'
|
||||||
};
|
};
|
||||||
console.log('SEND answer', answer);
|
console.log('SEND answer', answer);
|
||||||
|
|
||||||
@ -386,13 +306,11 @@ const connectSendTransport = async () => {
|
|||||||
// Enable Close call button
|
// Enable Close call button
|
||||||
const closeCallBtn = document.getElementById('btnCloseCall');
|
const closeCallBtn = document.getElementById('btnCloseCall');
|
||||||
closeCallBtn.removeAttribute('disabled');
|
closeCallBtn.removeAttribute('disabled');
|
||||||
|
|
||||||
createRecvTransport();
|
|
||||||
}
|
}
|
||||||
|
|
||||||
const createRecvTransport = async () => {
|
const createRecvTransport = async () => {
|
||||||
console.log('createRecvTransport');
|
console.log('createRecvTransport');
|
||||||
// See server's socket.on('consume', sender?, ...)
|
// see server's socket.on('consume', sender?, ...)
|
||||||
// this is a call from Consumer, so sender = false
|
// this is a call from Consumer, so sender = false
|
||||||
await socket.emit('createWebRtcTransport', { sender: false, callId }, ({ params }) => {
|
await socket.emit('createWebRtcTransport', { sender: false, callId }, ({ params }) => {
|
||||||
// The server sends back params needed
|
// The server sends back params needed
|
||||||
@ -402,15 +320,15 @@ const createRecvTransport = async () => {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
console.log('[createRecvTransport] params', params)
|
console.log(params)
|
||||||
|
|
||||||
// Creates a new WebRTC Transport to receive media
|
// creates a new WebRTC Transport to receive media
|
||||||
// based on server's consumer transport params
|
// based on server's consumer transport params
|
||||||
// https://mediasoup.org/documentation/v3/mediasoup-client/api/#device-createRecvTransport
|
// https://mediasoup.org/documentation/v3/mediasoup-client/api/#device-createRecvTransport
|
||||||
consumerTransport = device.createRecvTransport(params)
|
consumerTransport = device.createRecvTransport(params)
|
||||||
|
|
||||||
// https://mediasoup.org/documentation/v3/communication-between-client-and-server/#producing-media
|
// https://mediasoup.org/documentation/v3/communication-between-client-and-server/#producing-media
|
||||||
// This event is raised when a first call to transport.produce() is made
|
// this event is raised when a first call to transport.produce() is made
|
||||||
// see connectRecvTransport() below
|
// see connectRecvTransport() below
|
||||||
consumerTransport.on('connect', async ({ dtlsParameters }, callback, errback) => {
|
consumerTransport.on('connect', async ({ dtlsParameters }, callback, errback) => {
|
||||||
try {
|
try {
|
||||||
@ -427,8 +345,7 @@ const createRecvTransport = async () => {
|
|||||||
errback(error)
|
errback(error)
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
// We call it in new-rpoducer, we don't need it here anymore
|
connectRecvTransport()
|
||||||
// connectRecvTransport()
|
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -436,8 +353,7 @@ const resetCallSettings = () => {
|
|||||||
localVideo.srcObject = null
|
localVideo.srcObject = null
|
||||||
remoteVideo.srcObject = null
|
remoteVideo.srcObject = null
|
||||||
consumer = null
|
consumer = null
|
||||||
producerVideo = null
|
producer = null
|
||||||
producerAudio = null
|
|
||||||
producerTransport = null
|
producerTransport = null
|
||||||
consumerTransport = null
|
consumerTransport = null
|
||||||
device = undefined
|
device = undefined
|
||||||
@ -445,97 +361,40 @@ const resetCallSettings = () => {
|
|||||||
|
|
||||||
const connectRecvTransport = async () => {
|
const connectRecvTransport = async () => {
|
||||||
console.log('connectRecvTransport');
|
console.log('connectRecvTransport');
|
||||||
// For consumer, we need to tell the server first
|
// for consumer, we need to tell the server first
|
||||||
// to create a consumer based on the rtpCapabilities and consume
|
// to create a consumer based on the rtpCapabilities and consume
|
||||||
// if the router can consume, it will send back a set of params as below
|
// if the router can consume, it will send back a set of params as below
|
||||||
await socket.emit('consume', {
|
await socket.emit('consume', {
|
||||||
rtpCapabilities: device.rtpCapabilities,
|
rtpCapabilities: device.rtpCapabilities,
|
||||||
callId
|
callId
|
||||||
}, async ({videoParams, audioParams}) => {
|
}, async ({ params }) => {
|
||||||
console.log(`[consume] 🟩 videoParams`, videoParams)
|
if (params.error) {
|
||||||
console.log(`[consume] 🟩 audioParams`, audioParams)
|
console.log('Cannot Consume')
|
||||||
console.log('[consume] 🟩 consumerTransport', consumerTransport)
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
// then consume with the local consumer transport
|
||||||
|
// which creates a consumer
|
||||||
|
consumer = await consumerTransport.consume({
|
||||||
|
id: params.id,
|
||||||
|
producerId: params.producerId,
|
||||||
|
kind: params.kind,
|
||||||
|
rtpParameters: params.rtpParameters
|
||||||
|
})
|
||||||
|
|
||||||
|
// destructure and retrieve the video track from the producer
|
||||||
|
const { track } = consumer
|
||||||
|
|
||||||
let stream = new MediaStream()
|
let stream = new MediaStream()
|
||||||
|
stream.addTrack(track)
|
||||||
// Maybe the unit does not produce video or audio, so we must only consume what is produced
|
// stream.removeTrack(track)
|
||||||
if (videoParams) {
|
|
||||||
console.log('❗ Have VIDEO stream to consume');
|
|
||||||
stream.addTrack(await getVideoTrask(videoParams))
|
|
||||||
} else {
|
|
||||||
console.log('❗ Don\'t have VIDEO stream to consume');
|
|
||||||
}
|
|
||||||
|
|
||||||
if (audioParams) {
|
|
||||||
console.log('❗ Have AUDIO stream to consume');
|
|
||||||
let audioTrack = await getAudioTrask(audioParams)
|
|
||||||
stream.addTrack(audioTrack)
|
|
||||||
} else {
|
|
||||||
console.log('❗ Don\'t have AUDIO stream to consume');
|
|
||||||
}
|
|
||||||
|
|
||||||
socket.emit('consumer-resume')
|
|
||||||
|
|
||||||
remoteVideo.srcObject = stream
|
remoteVideo.srcObject = stream
|
||||||
remoteVideo.setAttribute('autoplay', true)
|
socket.emit('consumer-resume')
|
||||||
|
console.log('consumer', consumer);
|
||||||
|
|
||||||
remoteVideo.play()
|
|
||||||
.then(() => {
|
|
||||||
console.log('remoteVideo PLAY')
|
|
||||||
})
|
|
||||||
.catch((error) => {
|
|
||||||
console.error(`remoteVideo PLAY ERROR | ${error.message}`)
|
|
||||||
})
|
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
const getVideoTrask = async (videoParams) => {
|
|
||||||
consumerVideo = await consumerTransport.consume({
|
|
||||||
id: videoParams.id,
|
|
||||||
producerId: videoParams.producerId,
|
|
||||||
kind: videoParams.kind,
|
|
||||||
rtpParameters: videoParams.rtpParameters
|
|
||||||
})
|
|
||||||
|
|
||||||
return consumerVideo.track
|
|
||||||
}
|
|
||||||
|
|
||||||
const getAudioTrask = async (audioParams) => {
|
|
||||||
consumerAudio = await consumerTransport.consume({
|
|
||||||
id: audioParams.id,
|
|
||||||
producerId: audioParams.producerId,
|
|
||||||
kind: audioParams.kind,
|
|
||||||
rtpParameters: audioParams.rtpParameters
|
|
||||||
})
|
|
||||||
|
|
||||||
consumerAudio.on('transportclose', () => {
|
|
||||||
console.log('transport closed so consumer closed')
|
|
||||||
})
|
|
||||||
|
|
||||||
const audioTrack = consumerAudio.track
|
|
||||||
|
|
||||||
audioTrack.applyConstraints({
|
|
||||||
audio: {
|
|
||||||
advanced: [
|
|
||||||
{
|
|
||||||
echoCancellation: {exact: true}
|
|
||||||
},
|
|
||||||
{
|
|
||||||
autoGainControl: {exact: true}
|
|
||||||
},
|
|
||||||
{
|
|
||||||
noiseSuppression: {exact: true}
|
|
||||||
},
|
|
||||||
{
|
|
||||||
highpassFilter: {exact: true}
|
|
||||||
}
|
|
||||||
]
|
|
||||||
}
|
|
||||||
})
|
|
||||||
|
|
||||||
return audioTrack
|
|
||||||
}
|
|
||||||
|
|
||||||
const closeCall = () => {
|
const closeCall = () => {
|
||||||
console.log('closeCall');
|
console.log('closeCall');
|
||||||
|
|
||||||
@ -557,30 +416,6 @@ const closeCall = () => {
|
|||||||
resetCallSettings()
|
resetCallSettings()
|
||||||
}
|
}
|
||||||
|
|
||||||
// const consume = async (kind) => {
|
|
||||||
// console.log(`[consume] kind: ${kind}`)
|
|
||||||
// console.log('createRecvTransport Consumer')
|
|
||||||
// await socket.emit('createWebRtcTransport', { sender: false, callId, dispatcher: true }, ({ params }) => {
|
|
||||||
// if (params.error) {
|
|
||||||
// console.log('createRecvTransport | createWebRtcTransport | Error', params.error)
|
|
||||||
// return
|
|
||||||
// }
|
|
||||||
// consumerTransport = device.createRecvTransport(params)
|
|
||||||
// consumerTransport.on('connect', async ({ dtlsParameters }, callback, errback) => {
|
|
||||||
// try {
|
|
||||||
// await socket.emit('transport-recv-connect', {
|
|
||||||
// dtlsParameters,
|
|
||||||
// })
|
|
||||||
// callback()
|
|
||||||
// } catch (error) {
|
|
||||||
// errback(error)
|
|
||||||
// }
|
|
||||||
// })
|
|
||||||
|
|
||||||
// connectRecvTransport()
|
|
||||||
// })
|
|
||||||
// }
|
|
||||||
|
|
||||||
btnLocalVideo.addEventListener('click', getLocalStream)
|
btnLocalVideo.addEventListener('click', getLocalStream)
|
||||||
// btnRecvSendTransport.addEventListener('click', consume)
|
btnRecvSendTransport.addEventListener('click', goConnect)
|
||||||
btnCloseCall.addEventListener('click', closeCall)
|
btnCloseCall.addEventListener('click', closeCall)
|
@ -1,22 +0,0 @@
|
|||||||
-----BEGIN CERTIFICATE-----
|
|
||||||
MIIDrzCCApegAwIBAgIUfpwrZVz3ogv3YeXbtL5wqIGEXGMwDQYJKoZIhvcNAQEL
|
|
||||||
BQAwZzELMAkGA1UEBhMCUk8xDTALBgNVBAgMBEFsYmExDTALBgNVBAcMBEFsYmEx
|
|
||||||
DDAKBgNVBAoMA0FBQTEQMA4GA1UEAwwHQUFBIENPTTEaMBgGCSqGSIb3DQEJARYL
|
|
||||||
YXNkQGFzZC5jb20wHhcNMjUwMjE4MTAwMDM5WhcNMzUwMjE2MTAwMDM5WjBnMQsw
|
|
||||||
CQYDVQQGEwJSTzENMAsGA1UECAwEQWxiYTENMAsGA1UEBwwEQWxiYTEMMAoGA1UE
|
|
||||||
CgwDQUFBMRAwDgYDVQQDDAdBQUEgQ09NMRowGAYJKoZIhvcNAQkBFgthc2RAYXNk
|
|
||||||
LmNvbTCCASIwDQYJKoZIhvcNAQEBBQADggEPADCCAQoCggEBAL7itjfKeuH5+f7c
|
|
||||||
43gAI+ppmxiwvzqhHLmkmlQrVbSC+P93yGekHIuXpbM3sqGRnvSJL3c9SIEdtVVj
|
|
||||||
yfJCs6KIsujxtiGn3hgQD01B6LqzFjSKnfYSGz8XDsjFW8cnpD1yRi3J7DhUjleM
|
|
||||||
bhQ0ileu9joS2OOhf84mtOkXJyY8q9xJH4ypimogcR98eM6ewnrb5Vhjo8YDaix2
|
|
||||||
6rceNmO/g4biknhXnBGc58/MnyAHtwzZxsu/k1IYtZuBYMPcAo7CQEX4XxXqQpaF
|
|
||||||
zaaoEUYB8KzVDlsr+i5SJzLtrHkyiuJijHq6YyOFkTwUULuJ7Wz0YL1redDCZV4i
|
|
||||||
EIVzBAcCAwEAAaNTMFEwHQYDVR0OBBYEFErSYY3J7ukx2KaRcHmazbMlKNBlMB8G
|
|
||||||
A1UdIwQYMBaAFErSYY3J7ukx2KaRcHmazbMlKNBlMA8GA1UdEwEB/wQFMAMBAf8w
|
|
||||||
DQYJKoZIhvcNAQELBQADggEBAC3TQY6jMGeHIEDEYS7sUbNZxe+azdDlx0DdwgLK
|
|
||||||
t+Zo2O40F55nVTZOUfypjCnLJnZitekptl5P6CPGrp2VX4/C0Ok4swwr+xamsjWt
|
|
||||||
9RR9yG0IpVfnCEziT4dpBPhNf/6ilgdpnkJUWY3LO3BJhM4Js7rfP4D9NgEYHeSR
|
|
||||||
YDN3TuEbi//bp43bhDh8EBQtDx9lPGOSUiKd3I7KfRttsxvLG2wBz3M5HXRc++6p
|
|
||||||
pHE+64YfkwV5xZDvU2M/EqePLp7DdQ9g+vQ68FxI6jMCegBoz+ueyE9RhZOk/cUh
|
|
||||||
uIXwIdFowjkUXgNncuGrR1gWf1mJVCHOsdnGZf3VSykGdWg=
|
|
||||||
-----END CERTIFICATE-----
|
|
@ -1,24 +1,25 @@
|
|||||||
-----BEGIN CERTIFICATE-----
|
-----BEGIN CERTIFICATE-----
|
||||||
MIID9TCCAt2gAwIBAgIJAJZHglUuIBjtMA0GCSqGSIb3DQEBCwUAMIGZMQswCQYD
|
MIIEJTCCAw2gAwIBAgIURHg2am+RarQxIVY1f3CicUQgRowwDQYJKoZIhvcNAQEL
|
||||||
VQQGEwJVUzERMA8GA1UECAwISWxsaW5vaXMxGDAWBgNVBAcMD1JvbGxpbmcgTWVh
|
BQAwgaExCzAJBgNVBAYTAlJPMRIwEAYDVQQIDAlCdWNoYXJlc3QxEjAQBgNVBAcM
|
||||||
ZGl3czEYMBYGA1UECgwPU2FmZW1vYmlsZSBMTEMuMQ0wCwYDVQQLDARMSU5YMQ0w
|
CUJ1Y2hhcmVzdDETMBEGA1UECgwKU2FmZW1vYmlsZTETMBEGA1UECwwKU2FmZW1v
|
||||||
CwYDVQQDDARMSU5YMSUwIwYJKoZIhvcNAQkBFhZzdXBwb3J0QHNhZmVtb2JpbGUu
|
YmlsZTETMBEGA1UEAwwKU2FmZW1vYmlsZTErMCkGCSqGSIb3DQEJARYcbWloYWku
|
||||||
Y29tMB4XDTI1MDIyNDEwMTAzNFoXDTM1MDIyMjEwMTAzNFowXjELMAkGA1UEBhMC
|
Ym96aWVydUBzYWZlbW9iaWxlLmNvbTAeFw0yMjA4MDEyMjA0MjFaFw0zMjA3Mjky
|
||||||
VVMxETAPBgNVBAgMCElsbGlub2lzMRgwFgYDVQQHDA9Sb2xsaW5nIE1lYWRpd3Mx
|
MjA0MjFaMIGhMQswCQYDVQQGEwJSTzESMBAGA1UECAwJQnVjaGFyZXN0MRIwEAYD
|
||||||
EzARBgNVBAoMClNhZmVtb2JpbGUxDTALBgNVBAMMBExJTlgwggEiMA0GCSqGSIb3
|
VQQHDAlCdWNoYXJlc3QxEzARBgNVBAoMClNhZmVtb2JpbGUxEzARBgNVBAsMClNh
|
||||||
DQEBAQUAA4IBDwAwggEKAoIBAQDEd8LMvdkD4CyZkwVYh4V/RIBMH8d9jK1Yvozd
|
ZmVtb2JpbGUxEzARBgNVBAMMClNhZmVtb2JpbGUxKzApBgkqhkiG9w0BCQEWHG1p
|
||||||
0kPSGrC+ZXemmF7qHAD5g8RDkg1odkVuZa+jj0KlKHKtReF0p9OB/J6fNavlD7mM
|
aGFpLmJvemllcnVAc2FmZW1vYmlsZS5jb20wggEiMA0GCSqGSIb3DQEBAQUAA4IB
|
||||||
UiAtEpEgoKx3VlhrYEtIoFk+EJWaN1WObhYNfPtEw8Ncfww1cyDNmOnsifkLg+yh
|
DwAwggEKAoIBAQCSEk80aBAbmWtPBLcTjFLbvVmxuzDgzrjH7h2Hg/ly8lE/o2nZ
|
||||||
+aNxXzrR3toRF7pxFehrTpMRxx4LiIN2z4vHCdelvu9yJspzRAWd5QSQ6eGr3OPY
|
1T2ESSuaQFsxw54ukqbj1ooQXF1DoIxSp+CiNzf/FTB6BaMkaG0ayE2Wnm2wkjKp
|
||||||
yn+9v4XfN0YgnWSbH8aJ24bysIB3vOtsULjOfNJivNcx+/gQ9yP4AFhycperiDcu
|
POnAzZgTabJoB/qeUlr9i4xiAyBhiQDk5KjdWYHxeZnSznqfIOPzAdw7ZJVYvqvT
|
||||||
GGTiw+fwk1y6e04XulQ65mgxGTXNHlnM2ZvDyOwDZqL89Uf3AgMBAAGjejB4MB8G
|
GciHnoina5TzPUbpnLcR2LvHcLxuSuWQ6dTz/sfdZRx8lkbR3qltUazmJX+yxJJr
|
||||||
A1UdIwQYMBaAFGQaM9lRXGKKghjag6SPD+uHK3K5MAkGA1UdEwQCMAAwCwYDVR0P
|
kagq2V3cfpfLM8DOzPPEzuKHM6sK6ZgTqbc4ti+ul7Q1V+e0v2xNDtuYHkbaOuyd
|
||||||
BAQDAgTwMB4GA1UdEQQXMBWHBMCoAceCDTE5Mi4xNjguMS4xOTkwHQYDVR0OBBYE
|
ucmaZ3R++0ryoWWan5OFWZIKjttKy/yq8MUrAgMBAAGjUzBRMB0GA1UdDgQWBBSM
|
||||||
FHNfBgu/Ixj2j6yDTiDluw6/i3cEMA0GCSqGSIb3DQEBCwUAA4IBAQAojT+cdzfU
|
nlDraef71C/filHpA7dDpwmB7zAfBgNVHSMEGDAWgBSMnlDraef71C/filHpA7dD
|
||||||
sVq/ODttG8wS23Du20W2iNdvlAwkgni0UgxTJQ12odtIH9WZAVS46G++t2so87Ki
|
pwmB7zAPBgNVHRMBAf8EBTADAQH/MA0GCSqGSIb3DQEBCwUAA4IBAQBNySms9mXG
|
||||||
gp6OK25AWtsQ7oLFK2P6VpaVGH6FwRSODFTly7Wv+7US7NmB/DO215+rG7q7C7Ag
|
PVOmFAm9YjMjRY+cUpa0Gm6saxp9VOyrAg2KzdwG6LNGgauNsIra1ytM40NASspN
|
||||||
J6zrsQgLPR6M6rZRrOs9Hd12oX6zRgEaYnbIc/Z1DVPRmCDiQISE5M8LihIO4sOW
|
r+L49gUCmASUGOqeZCpJjkKAsGspQ4WQKKI6YW8h5dsSuud2qyQtm+w1RKDq+wih
|
||||||
gmDacLhM9lbuMvbHEkCNnOuAzdWRmvR06CyBXmu/9iusyWYvgwI6bHFAZRYCOTmB
|
A+B82xWXcFFd52gp6nerib4Pf9ATooOmBMCHFZwC+74sKCv7fXDlzLGdCII8lmI4
|
||||||
+poHSGAlTmivcbNhHyZjS63NafRU7sSuc0JDzWQAdkA1AclSokfC8dJC6fnKBujY
|
uq5eFrSS1NeT3iQCwGb9SHfyFkCliaEdpskqmWhonckN0tJVV118SvknV/h9oIsw
|
||||||
o2WFKJMFrFS3
|
uEMIib6YOBlrU+FInnpqpc8VuR4vv0Yro9XrvmurzLuN8k/lVVkr6NMzyNY9mbkF
|
||||||
|
9p/Sxd5yIeam
|
||||||
-----END CERTIFICATE-----
|
-----END CERTIFICATE-----
|
||||||
|
@ -1,28 +0,0 @@
|
|||||||
-----BEGIN PRIVATE KEY-----
|
|
||||||
MIIEvgIBADANBgkqhkiG9w0BAQEFAASCBKgwggSkAgEAAoIBAQC+4rY3ynrh+fn+
|
|
||||||
3ON4ACPqaZsYsL86oRy5pJpUK1W0gvj/d8hnpByLl6WzN7KhkZ70iS93PUiBHbVV
|
|
||||||
Y8nyQrOiiLLo8bYhp94YEA9NQei6sxY0ip32Ehs/Fw7IxVvHJ6Q9ckYtyew4VI5X
|
|
||||||
jG4UNIpXrvY6EtjjoX/OJrTpFycmPKvcSR+MqYpqIHEffHjOnsJ62+VYY6PGA2os
|
|
||||||
duq3HjZjv4OG4pJ4V5wRnOfPzJ8gB7cM2cbLv5NSGLWbgWDD3AKOwkBF+F8V6kKW
|
|
||||||
hc2mqBFGAfCs1Q5bK/ouUicy7ax5MoriYox6umMjhZE8FFC7ie1s9GC9a3nQwmVe
|
|
||||||
IhCFcwQHAgMBAAECggEAMJWSjGuwUCDoZNqC2PGsMoczjxq5aWpFXejL0P2AoGOv
|
|
||||||
jZJGwz5Nd6ge6BkWkbH3M8VQ+/fwotBVbYjrBwq8HvPNGaYf1bwctqIryt2qJw7a
|
|
||||||
6X+Yid986NdtD2PQIsXvsyYJP7FDuuimnBjlkaX3yi6BhDF026co2OcYJ7WZZM0e
|
|
||||||
nc6JR7wGFZM3Dw3ybFvGrK4k7/Iq2N6wqedzCOvDbLXUC16UtmRVIOuiuNm+THrl
|
|
||||||
BiD37AKwB/LZRcdSQ1HeiWlK42Zc+IikHPJhl0PACcJNFNB3u2rdP8maSu5aMLku
|
|
||||||
yHnKCz6w9C1vDKrI/iszW2QCky+mGBD9WKK2u6hxFQKBgQDtcfL8hMKj6Ki/dsqR
|
|
||||||
McGPs1rLgZFAH9axubUth0uLdsEQDZtkoJIzXt8RLS3exuHMKt+Ln6YAOEhKm8Cl
|
|
||||||
OqIg0E/8SNi7QryU9yfqFqcE2QBZL0QVtvYZeUuiHIOrpc0bmTdNvp8i7zWw/oz6
|
|
||||||
ymeJ6vpEWKDpOvUnfm79XJbh+wKBgQDNzVjUNfo5s6QNnZlJvwI3J2mAsfLMVQxp
|
|
||||||
++P41f+dUCoAsEPujxASthdDxRND9oIfsTodA+VkrlLhs1JyTe4PlPcfSl7D5QSV
|
|
||||||
ayXVHF9iLbGM8fWMf6zBTebdaw9GqY3KTOHBH+X+JOHPP9dI6a4l7Ok8tFE9ia8M
|
|
||||||
G8Ce7djUZQKBgDSfGDaWRXyFx0AHV4Ut/bOXD/whzsrjQ3VHrrtUTI2v18FzAoke
|
|
||||||
fMgdslngJVZFxSy2I6yRyPwrfPnr4pm7kMqs380NZ9q4Q4rP62yZcJJGdSlOrEwT
|
|
||||||
rB6hHv3iS9vydq4zGmqEYEghs0hyYVQDH0cVaDlVWvPVORdzka1co6OZAoGBAJHl
|
|
||||||
TV/DlExrqZVtcEnzeyKWchimDjYE5PQNeiPhsYBYYC50xvPLv91D8WI9x9aaXs0Q
|
|
||||||
2t3O8URawK74bS5TSL0LIdWw51WAeatjdkKKBqSXOBNvRGAB8vpmu4+kYgP6F2ae
|
|
||||||
8jvy3R06EErYO0qZPrfsJ7y9KAq0HMA8vGTuwJRxAoGBAMfWJLseheDXKUXndnR9
|
|
||||||
ovNA+spTTFECtoLwhWxwgoL3GYVqSA96RfnmdKHY4d5isQ1g/JN05Uo6bL7HKJCG
|
|
||||||
BwS9WCsa6fHhbJR31fP16UQNNknNSwTtUoeJavwarQ7MB5CT9Fz5HsaC4NGaQkve
|
|
||||||
86Barwb6tt4iu4Y8a2bcG/sE
|
|
||||||
-----END PRIVATE KEY-----
|
|
@ -1,28 +1,28 @@
|
|||||||
-----BEGIN PRIVATE KEY-----
|
-----BEGIN PRIVATE KEY-----
|
||||||
MIIEvQIBADANBgkqhkiG9w0BAQEFAASCBKcwggSjAgEAAoIBAQDEd8LMvdkD4CyZ
|
MIIEvAIBADANBgkqhkiG9w0BAQEFAASCBKYwggSiAgEAAoIBAQCSEk80aBAbmWtP
|
||||||
kwVYh4V/RIBMH8d9jK1Yvozd0kPSGrC+ZXemmF7qHAD5g8RDkg1odkVuZa+jj0Kl
|
BLcTjFLbvVmxuzDgzrjH7h2Hg/ly8lE/o2nZ1T2ESSuaQFsxw54ukqbj1ooQXF1D
|
||||||
KHKtReF0p9OB/J6fNavlD7mMUiAtEpEgoKx3VlhrYEtIoFk+EJWaN1WObhYNfPtE
|
oIxSp+CiNzf/FTB6BaMkaG0ayE2Wnm2wkjKpPOnAzZgTabJoB/qeUlr9i4xiAyBh
|
||||||
w8Ncfww1cyDNmOnsifkLg+yh+aNxXzrR3toRF7pxFehrTpMRxx4LiIN2z4vHCdel
|
iQDk5KjdWYHxeZnSznqfIOPzAdw7ZJVYvqvTGciHnoina5TzPUbpnLcR2LvHcLxu
|
||||||
vu9yJspzRAWd5QSQ6eGr3OPYyn+9v4XfN0YgnWSbH8aJ24bysIB3vOtsULjOfNJi
|
SuWQ6dTz/sfdZRx8lkbR3qltUazmJX+yxJJrkagq2V3cfpfLM8DOzPPEzuKHM6sK
|
||||||
vNcx+/gQ9yP4AFhycperiDcuGGTiw+fwk1y6e04XulQ65mgxGTXNHlnM2ZvDyOwD
|
6ZgTqbc4ti+ul7Q1V+e0v2xNDtuYHkbaOuyducmaZ3R++0ryoWWan5OFWZIKjttK
|
||||||
ZqL89Uf3AgMBAAECggEAM0xx+LO5bmGiQ5c31h3MpaZlOXsyw31v5bQbY+/69Wky
|
y/yq8MUrAgMBAAECggEAMRH1iaVrw9nGMsViuy5op2j0uMApq1vGt2NGiD/NjM/a
|
||||||
rQQhccZnQgl916ioHlyMU7JN/r1eVv6ZEDa3era8X5FSkKY9ZKTG9VBdyl3HOP2Y
|
e4ZqCMOZ5tatzyPPfug4O20Io4Fu4BAnRJCqkxnSXKwwI4D6yAMcyx5JiLXBWtfe
|
||||||
F0Tcw2wwOhkyjwwPQT1jUpkQJdhouazgjtvursAdl/cvoX9D1RdRh8gyiTh9jKQz
|
AXMbkb7kx+BJNjxLsqb7ijQgXQyEHGjwd9OOeVZXZAStonE3O5ohl1N1QC1fzpN5
|
||||||
Afnbwe/KOje9xsEqJRDXra8erpwBV/7TKlLqvSiGExZqGx9X5pNzU02vfl7L3WTi
|
qBFPaAiNhZgaxrB+pp/uRruZXzNGCwLdhpd2HuryJfxkaAD53mqpHwHJbM7wRQl4
|
||||||
2f48Ad2P3rSGv5XcOCtGvDGRHtSLWknUCyb0a1qy2aFF1bJo9wVFNAPFD4zrukhA
|
NJCbFR/lf4sqPO7zWJGyfU8fFVLuNspSW8AdLcsapOUSMhXTEU+vKbdWM+MYRNuk
|
||||||
/WaxkS3p/Fai8f+YdHPV9sgZO+2qrjMXNvmh1+V8gQKBgQD7HPbDDk9UQ9XUwAKu
|
ltJVWG1nPkbyyGQoUNEh4rSFOX+3aiN435qkPw7wAQKBgQDEPFQJe+2DpS+M0zvq
|
||||||
o4Np2G6CddR1wxdE2qDDG3Ej5LBxi5OdwVdywim5Cgf/TAySIiNi5qeRSKJi5Sbg
|
sZVVkEDxwGZfHnO0h57C4dsGPyLSX7A1r+EM8ooZhCgrXZFru3EDzFuO5isCIeml
|
||||||
/jt0x6v3R/0c14kRXsd09RtcqvRL09jI2eZl+uAINAqtKXsGsSCQXwkiO/MQ0Klc
|
bBET5q2qGEozdb+wUfcHOBZZKR4imY0SYi3lyJdxBeNIOPhUkEpOg3uo2RRklpi6
|
||||||
gm2eMKK0VUENQ0qTzhvjFoJtnwKBgQDISo5cuo+6Kd6n26ny8FBwXKY0vY9AzUAU
|
Fk4LYXReJ+t36yZyocTn3PfmxwKBgQC+juTHoJGZjqWtVMygUC8kP5G5GXxY9Yk1
|
||||||
gvpupDb6hQ3vfFWqORTbuPlg9oUSRh+eqVBbYr+VYfuSf0u/9JWdlpHFlGJMJ3cw
|
7j4Iv8ok1c5xWM6N4GBNG9rKKOD7WQX4dD9IOs35pZqGDaNE44q7na9UabRFR92M
|
||||||
mraOmvXv8u9YGMf0d2wOXVf6/C2frfmZ89BntNs0cSHflzNvMn7qJxqVfTzIAtxV
|
I+VAsi1Q2gQPyihW84ESXw6uH85pO5FfGO3fF/ppLXBCVYN85VT+1HFxG+Je2GXE
|
||||||
bLEva8jWqQKBgBtpU/6C52H5bbQlqaVKsCOzvox7NFAOldGsU/Q4YKdcZW5foCOO
|
50/3e4Q6fQKBgBl/zVu+IsrseBVQjYSdts37hLTlT2gkyNw4k0S3nIJfSeMUVA1l
|
||||||
YW9jho5ua+UQdibVlytKpmwTk7Zb8VyKJA9hZII/1394f7vnrrozr2L0Pmqwm2+B
|
4VSRX6iZJ68a5X6eSL05nNwgxI3uYjIArOdtHjvwFBRDxLjgrbzeaOkFEslkMpSk
|
||||||
acckFaSPmcLBTm6yky1vUl3sUWI6hOJWUoT8JiatT8aU2+U6kIy/fkldAoGBALyx
|
9VnaivNA1JvZ60rxxPYW18bFDoVTnFzx8QpBi6GAhnR6tfBHXRLT/9KZAoGAStHI
|
||||||
cLlvkWSDeZ6OVefn+wBAaN0bENCuDYbFdoWx85HEtEJA0rvRlxMBiv+MgAWdRsDF
|
OiltgaFko73b6kYRfGYJTWgYTsV5bldwu/ax4+ye9hosX8Btj1kUerO6QnYdxgO+
|
||||||
Jk1SFMf5TXbQsl6fYCzc42xOxOSV8bY6q25iEv0B0/cdMZPgxk4qJm7wEVN0Jcii
|
pRmRrie7mE7agD3nRusO4FHwmhMxhcjCRriu2kP/vENfu2Q4lYIFPZD3dpIQ7gnX
|
||||||
aF6rhjA7vPvWiMBjxCl4uZTILfEIsOdRxQO1+boxAoGACrkNBikkV8mSsBSEkfDQ
|
u/SqOYnBvgndariQus2nDQYpx5unubwoxb8Vl/ECgYAV7nkyMjkakwbFyiAsUMz6
|
||||||
KAqGCl9zt6hI6cxQ9mSD60JJADXifBDLqMVcNDbTo+leHVAooLxI00kziAz9tfml
|
QvSxWC+x5OBv79Nm02bgecdwJny/PULA/R/KHNI/WXHSkM2DdeoMv4XZPdI8TNRo
|
||||||
bDdr3OCLeOMqwWAZervH+rx3gvWqq7cdfMLlmyLwljZEloGjd1gnA4ekNnYwS+c9
|
bBD217yfRfOMIX2jIhZeTtTAIiOafBdIG0fUtM9nMPkgQGTvgM0FZPdfAtNY/nFu
|
||||||
P4Hmmp4712UC4HkhQLSJ6HU=
|
xvrhZIQLy0ujoDPPBE8+3Q==
|
||||||
-----END PRIVATE KEY-----
|
-----END PRIVATE KEY-----
|
||||||
|