diff --git a/advanced-features/openvidu-recording-advanced-node-azure/.env b/advanced-features/openvidu-recording-advanced-node-azure/.env new file mode 100644 index 00000000..3cd075d6 --- /dev/null +++ b/advanced-features/openvidu-recording-advanced-node-azure/.env @@ -0,0 +1,15 @@ +SERVER_PORT=6080 + +# LiveKit configuration +LIVEKIT_URL=http://localhost:7880 +LIVEKIT_API_KEY=devkey +LIVEKIT_API_SECRET=secret + +# Recording configuration +RECORDINGS_PATH=recordings/ +RECORDING_PLAYBACK_STRATEGY=S3 + +# Azure Blob Storage configuration +AZURE_ACCOUNT_NAME=yourstorageaccountname +AZURE_ACCOUNT_KEY=youraccountkey +AZURE_CONTAINER_NAME=openvidu-appdata \ No newline at end of file diff --git a/advanced-features/openvidu-recording-advanced-node-azure/.gitignore b/advanced-features/openvidu-recording-advanced-node-azure/.gitignore new file mode 100644 index 00000000..fa6a20f5 --- /dev/null +++ b/advanced-features/openvidu-recording-advanced-node-azure/.gitignore @@ -0,0 +1,129 @@ +# Logs +logs +*.log +npm-debug.log* +yarn-debug.log* +yarn-error.log* +lerna-debug.log* +.pnpm-debug.log* + +# Diagnostic reports (https://nodejs.org/api/report.html) +report.[0-9]*.[0-9]*.[0-9]*.[0-9]*.json + +# Runtime data +pids +*.pid +*.seed +*.pid.lock + +# Directory for instrumented libs generated by jscoverage/JSCover +lib-cov + +# Coverage directory used by tools like istanbul +coverage +*.lcov + +# nyc test coverage +.nyc_output + +# Grunt intermediate storage (https://gruntjs.com/creating-plugins#storing-task-files) +.grunt + +# Bower dependency directory (https://bower.io/) +bower_components + +# node-waf configuration +.lock-wscript + +# Compiled binary addons (https://nodejs.org/api/addons.html) +build/Release + +# Dependency directories +node_modules/ +jspm_packages/ + +# Snowpack dependency directory (https://snowpack.dev/) +web_modules/ + +# TypeScript cache +*.tsbuildinfo + +# Optional npm cache directory +.npm + +# Optional eslint cache +.eslintcache + +# Optional stylelint cache +.stylelintcache + +# Microbundle cache +.rpt2_cache/ +.rts2_cache_cjs/ +.rts2_cache_es/ +.rts2_cache_umd/ + +# Optional REPL history +.node_repl_history + +# Output of 'npm pack' +*.tgz + +# Yarn Integrity file +.yarn-integrity + +# dotenv environment variable files +.env.development.local +.env.test.local +.env.production.local +.env.local + +# parcel-bundler cache (https://parceljs.org/) +.cache +.parcel-cache + +# Next.js build output +.next +out + +# Nuxt.js build / generate output +.nuxt +dist + +# Gatsby files +.cache/ +# Comment in the public line in if your project uses Gatsby and not Next.js +# https://nextjs.org/blog/next-9-1#public-directory-support +# public + +# vuepress build output +.vuepress/dist + +# vuepress v2.x temp and cache directory +.temp +.cache + +# Docusaurus cache and generated files +.docusaurus + +# Serverless directories +.serverless/ + +# FuseBox cache +.fusebox/ + +# DynamoDB Local files +.dynamodb/ + +# TernJS port file +.tern-port + +# Stores VSCode versions used for testing VSCode extensions +.vscode-test + +# yarn v2 +.yarn/cache +.yarn/unplugged +.yarn/build-state.yml +.yarn/install-state.gz +.pnp.* \ No newline at end of file diff --git a/advanced-features/openvidu-recording-advanced-node-azure/README.md b/advanced-features/openvidu-recording-advanced-node-azure/README.md new file mode 100644 index 00000000..78034fd5 --- /dev/null +++ b/advanced-features/openvidu-recording-advanced-node-azure/README.md @@ -0,0 +1,30 @@ +# OpenVidu Recording Advanced Node + +Simple video-call application with recording capabilities (advanced version). It includes a backend built with Node.js with Express and a frontend built with plain HTML, CSS and JavaScript. + +For further information, check the [tutorial documentation](https://livekit-tutorials.openvidu.io/tutorials/advanced-features/recording-advanced/). + +## Prerequisites + +- [Node](https://nodejs.org/en/download) + +## Run + +1. Download repository + +```bash +git clone https://github.com/OpenVidu/openvidu-livekit-tutorials.git +cd openvidu-livekit-tutorials/advanced-features/openvidu-recording-advanced-node +``` + +2. Install dependencies + +```bash +npm install +``` + +3. Run the application + +```bash +npm start +``` diff --git a/advanced-features/openvidu-recording-advanced-node-azure/package-lock.json b/advanced-features/openvidu-recording-advanced-node-azure/package-lock.json new file mode 100644 index 00000000..ad679a1b --- /dev/null +++ b/advanced-features/openvidu-recording-advanced-node-azure/package-lock.json @@ -0,0 +1,1290 @@ +{ + "name": "openvidu-recording-advanced-node", + "version": "1.0.0", + "lockfileVersion": 3, + "requires": true, + "packages": { + "": { + "name": "openvidu-recording-advanced-node", + "version": "1.0.0", + "dependencies": { + "@azure/storage-blob": "12.27.0", + "cors": "2.8.5", + "dotenv": "16.4.5", + "express": "4.21.0", + "livekit-server-sdk": "^2.7.2" + } + }, + "node_modules/@azure/abort-controller": { + "version": "2.1.2", + "resolved": "https://registry.npmjs.org/@azure/abort-controller/-/abort-controller-2.1.2.tgz", + "integrity": "sha512-nBrLsEWm4J2u5LpAPjxADTlq3trDgVZZXHNKabeXZtpq3d3AbN/KGO82R87rdDz5/lYB024rtEf10/q0urNgsA==", + "license": "MIT", + "dependencies": { + "tslib": "^2.6.2" + }, + "engines": { + "node": ">=18.0.0" + } + }, + "node_modules/@azure/core-auth": { + "version": "1.9.0", + "resolved": "https://registry.npmjs.org/@azure/core-auth/-/core-auth-1.9.0.tgz", + "integrity": "sha512-FPwHpZywuyasDSLMqJ6fhbOK3TqUdviZNF8OqRGA4W5Ewib2lEEZ+pBsYcBa88B2NGO/SEnYPGhyBqNlE8ilSw==", + "license": "MIT", + "dependencies": { + "@azure/abort-controller": "^2.0.0", + "@azure/core-util": "^1.11.0", + "tslib": "^2.6.2" + }, + "engines": { + "node": ">=18.0.0" + } + }, + "node_modules/@azure/core-client": { + "version": "1.9.4", + "resolved": "https://registry.npmjs.org/@azure/core-client/-/core-client-1.9.4.tgz", + "integrity": "sha512-f7IxTD15Qdux30s2qFARH+JxgwxWLG2Rlr4oSkPGuLWm+1p5y1+C04XGLA0vmX6EtqfutmjvpNmAfgwVIS5hpw==", + "license": "MIT", + "dependencies": { + "@azure/abort-controller": "^2.0.0", + "@azure/core-auth": "^1.4.0", + "@azure/core-rest-pipeline": "^1.20.0", + "@azure/core-tracing": "^1.0.0", + "@azure/core-util": "^1.6.1", + "@azure/logger": "^1.0.0", + "tslib": "^2.6.2" + }, + "engines": { + "node": ">=18.0.0" + } + }, + "node_modules/@azure/core-http-compat": { + "version": "2.3.0", + "resolved": "https://registry.npmjs.org/@azure/core-http-compat/-/core-http-compat-2.3.0.tgz", + "integrity": "sha512-qLQujmUypBBG0gxHd0j6/Jdmul6ttl24c8WGiLXIk7IHXdBlfoBqW27hyz3Xn6xbfdyVSarl1Ttbk0AwnZBYCw==", + "license": "MIT", + "dependencies": { + "@azure/abort-controller": "^2.0.0", + "@azure/core-client": "^1.3.0", + "@azure/core-rest-pipeline": "^1.20.0" + }, + "engines": { + "node": ">=18.0.0" + } + }, + "node_modules/@azure/core-lro": { + "version": "2.7.2", + "resolved": "https://registry.npmjs.org/@azure/core-lro/-/core-lro-2.7.2.tgz", + "integrity": "sha512-0YIpccoX8m/k00O7mDDMdJpbr6mf1yWo2dfmxt5A8XVZVVMz2SSKaEbMCeJRvgQ0IaSlqhjT47p4hVIRRy90xw==", + "license": "MIT", + "dependencies": { + "@azure/abort-controller": "^2.0.0", + "@azure/core-util": "^1.2.0", + "@azure/logger": "^1.0.0", + "tslib": "^2.6.2" + }, + "engines": { + "node": ">=18.0.0" + } + }, + "node_modules/@azure/core-paging": { + "version": "1.6.2", + "resolved": "https://registry.npmjs.org/@azure/core-paging/-/core-paging-1.6.2.tgz", + "integrity": "sha512-YKWi9YuCU04B55h25cnOYZHxXYtEvQEbKST5vqRga7hWY9ydd3FZHdeQF8pyh+acWZvppw13M/LMGx0LABUVMA==", + "license": "MIT", + "dependencies": { + "tslib": "^2.6.2" + }, + "engines": { + "node": ">=18.0.0" + } + }, + "node_modules/@azure/core-rest-pipeline": { + "version": "1.20.0", + "resolved": "https://registry.npmjs.org/@azure/core-rest-pipeline/-/core-rest-pipeline-1.20.0.tgz", + "integrity": "sha512-ASoP8uqZBS3H/8N8at/XwFr6vYrRP3syTK0EUjDXQy0Y1/AUS+QeIRThKmTNJO2RggvBBxaXDPM7YoIwDGeA0g==", + "license": "MIT", + "dependencies": { + "@azure/abort-controller": "^2.0.0", + "@azure/core-auth": "^1.8.0", + "@azure/core-tracing": "^1.0.1", + "@azure/core-util": "^1.11.0", + "@azure/logger": "^1.0.0", + "@typespec/ts-http-runtime": "^0.2.2", + "tslib": "^2.6.2" + }, + "engines": { + "node": ">=18.0.0" + } + }, + "node_modules/@azure/core-tracing": { + "version": "1.2.0", + "resolved": "https://registry.npmjs.org/@azure/core-tracing/-/core-tracing-1.2.0.tgz", + "integrity": "sha512-UKTiEJPkWcESPYJz3X5uKRYyOcJD+4nYph+KpfdPRnQJVrZfk0KJgdnaAWKfhsBBtAf/D58Az4AvCJEmWgIBAg==", + "license": "MIT", + "dependencies": { + "tslib": "^2.6.2" + }, + "engines": { + "node": ">=18.0.0" + } + }, + "node_modules/@azure/core-util": { + "version": "1.12.0", + "resolved": "https://registry.npmjs.org/@azure/core-util/-/core-util-1.12.0.tgz", + "integrity": "sha512-13IyjTQgABPARvG90+N2dXpC+hwp466XCdQXPCRlbWHgd3SJd5Q1VvaBGv6k1BIa4MQm6hAF1UBU1m8QUxV8sQ==", + "license": "MIT", + "dependencies": { + "@azure/abort-controller": "^2.0.0", + "@typespec/ts-http-runtime": "^0.2.2", + "tslib": "^2.6.2" + }, + "engines": { + "node": ">=18.0.0" + } + }, + "node_modules/@azure/core-xml": { + "version": "1.4.5", + "resolved": "https://registry.npmjs.org/@azure/core-xml/-/core-xml-1.4.5.tgz", + "integrity": "sha512-gT4H8mTaSXRz7eGTuQyq1aIJnJqeXzpOe9Ay7Z3FrCouer14CbV3VzjnJrNrQfbBpGBLO9oy8BmrY75A0p53cA==", + "license": "MIT", + "dependencies": { + "fast-xml-parser": "^5.0.7", + "tslib": "^2.8.1" + }, + "engines": { + "node": ">=18.0.0" + } + }, + "node_modules/@azure/logger": { + "version": "1.2.0", + "resolved": "https://registry.npmjs.org/@azure/logger/-/logger-1.2.0.tgz", + "integrity": "sha512-0hKEzLhpw+ZTAfNJyRrn6s+V0nDWzXk9OjBr2TiGIu0OfMr5s2V4FpKLTAK3Ca5r5OKLbf4hkOGDPyiRjie/jA==", + "license": "MIT", + "dependencies": { + "@typespec/ts-http-runtime": "^0.2.2", + "tslib": "^2.6.2" + }, + "engines": { + "node": ">=18.0.0" + } + }, + "node_modules/@azure/storage-blob": { + "version": "12.27.0", + "resolved": "https://registry.npmjs.org/@azure/storage-blob/-/storage-blob-12.27.0.tgz", + "integrity": "sha512-IQjj9RIzAKatmNca3D6bT0qJ+Pkox1WZGOg2esJF2YLHb45pQKOwGPIAV+w3rfgkj7zV3RMxpn/c6iftzSOZJQ==", + "license": "MIT", + "dependencies": { + "@azure/abort-controller": "^2.1.2", + "@azure/core-auth": "^1.4.0", + "@azure/core-client": "^1.6.2", + "@azure/core-http-compat": "^2.0.0", + "@azure/core-lro": "^2.2.0", + "@azure/core-paging": "^1.1.1", + "@azure/core-rest-pipeline": "^1.10.1", + "@azure/core-tracing": "^1.1.2", + "@azure/core-util": "^1.6.1", + "@azure/core-xml": "^1.4.3", + "@azure/logger": "^1.0.0", + "events": "^3.0.0", + "tslib": "^2.2.0" + }, + "engines": { + "node": ">=18.0.0" + } + }, + "node_modules/@bufbuild/protobuf": { + "version": "1.10.1", + "resolved": "https://registry.npmjs.org/@bufbuild/protobuf/-/protobuf-1.10.1.tgz", + "integrity": "sha512-wJ8ReQbHxsAfXhrf9ixl0aYbZorRuOWpBNzm8pL8ftmSxQx/wnJD5Eg861NwJU/czy2VXFIebCeZnZrI9rktIQ==", + "license": "(Apache-2.0 AND BSD-3-Clause)" + }, + "node_modules/@livekit/protocol": { + "version": "1.39.0", + "resolved": "https://registry.npmjs.org/@livekit/protocol/-/protocol-1.39.0.tgz", + "integrity": "sha512-Zar6711kJk1MjI+63DJoyCxv8deNphIIan7tK9C5f+Zy3v2Pvjs6Yz7cFoOeDK/rY7b7deA2wfYxUi2S5XLp7w==", + "license": "Apache-2.0", + "dependencies": { + "@bufbuild/protobuf": "^1.10.0" + } + }, + "node_modules/@typespec/ts-http-runtime": { + "version": "0.2.2", + "resolved": "https://registry.npmjs.org/@typespec/ts-http-runtime/-/ts-http-runtime-0.2.2.tgz", + "integrity": "sha512-Gz/Sm64+Sq/vklJu1tt9t+4R2lvnud8NbTD/ZfpZtMiUX7YeVpCA8j6NSW8ptwcoLL+NmYANwqP8DV0q/bwl2w==", + "license": "MIT", + "dependencies": { + "http-proxy-agent": "^7.0.0", + "https-proxy-agent": "^7.0.0", + "tslib": "^2.6.2" + }, + "engines": { + "node": ">=18.0.0" + } + }, + "node_modules/accepts": { + "version": "1.3.8", + "resolved": "https://registry.npmjs.org/accepts/-/accepts-1.3.8.tgz", + "integrity": "sha512-PYAthTa2m2VKxuvSD3DPC/Gy+U+sOA1LAuT8mkmRuvw+NACSaeXEQ+NHcVF7rONl6qcaxV3Uuemwawk+7+SJLw==", + "license": "MIT", + "dependencies": { + "mime-types": "~2.1.34", + "negotiator": "0.6.3" + }, + "engines": { + "node": ">= 0.6" + } + }, + "node_modules/agent-base": { + "version": "7.1.3", + "resolved": "https://registry.npmjs.org/agent-base/-/agent-base-7.1.3.tgz", + "integrity": "sha512-jRR5wdylq8CkOe6hei19GGZnxM6rBGwFl3Bg0YItGDimvjGtAvdZk4Pu6Cl4u4Igsws4a1fd1Vq3ezrhn4KmFw==", + "license": "MIT", + "engines": { + "node": ">= 14" + } + }, + "node_modules/array-flatten": { + "version": "1.1.1", + "resolved": "https://registry.npmjs.org/array-flatten/-/array-flatten-1.1.1.tgz", + "integrity": "sha512-PCVAQswWemu6UdxsDFFX/+gVeYqKAod3D3UVm91jHwynguOwAvYPhx8nNlM++NqRcK6CxxpUafjmhIdKiHibqg==", + "license": "MIT" + }, + "node_modules/body-parser": { + "version": "1.20.3", + "resolved": "https://registry.npmjs.org/body-parser/-/body-parser-1.20.3.tgz", + "integrity": "sha512-7rAxByjUMqQ3/bHJy7D6OGXvx/MMc4IqBn/X0fcM1QUcAItpZrBEYhWGem+tzXH90c+G01ypMcYJBO9Y30203g==", + "license": "MIT", + "dependencies": { + "bytes": "3.1.2", + "content-type": "~1.0.5", + "debug": "2.6.9", + "depd": "2.0.0", + "destroy": "1.2.0", + "http-errors": "2.0.0", + "iconv-lite": "0.4.24", + "on-finished": "2.4.1", + "qs": "6.13.0", + "raw-body": "2.5.2", + "type-is": "~1.6.18", + "unpipe": "1.0.0" + }, + "engines": { + "node": ">= 0.8", + "npm": "1.2.8000 || >= 1.4.16" + } + }, + "node_modules/bytes": { + "version": "3.1.2", + "resolved": "https://registry.npmjs.org/bytes/-/bytes-3.1.2.tgz", + "integrity": "sha512-/Nf7TyzTx6S3yRJObOAV7956r8cr2+Oj8AC5dt8wSP3BQAoeX58NoHyCU8P8zGkNXStjTSi6fzO6F0pBdcYbEg==", + "license": "MIT", + "engines": { + "node": ">= 0.8" + } + }, + "node_modules/call-bind-apply-helpers": { + "version": "1.0.2", + "resolved": "https://registry.npmjs.org/call-bind-apply-helpers/-/call-bind-apply-helpers-1.0.2.tgz", + "integrity": "sha512-Sp1ablJ0ivDkSzjcaJdxEunN5/XvksFJ2sMBFfq6x0ryhQV/2b/KwFe21cMpmHtPOSij8K99/wSfoEuTObmuMQ==", + "license": "MIT", + "dependencies": { + "es-errors": "^1.3.0", + "function-bind": "^1.1.2" + }, + "engines": { + "node": ">= 0.4" + } + }, + "node_modules/call-bound": { + "version": "1.0.4", + "resolved": "https://registry.npmjs.org/call-bound/-/call-bound-1.0.4.tgz", + "integrity": "sha512-+ys997U96po4Kx/ABpBCqhA9EuxJaQWDQg7295H4hBphv3IZg0boBKuwYpt4YXp6MZ5AmZQnU/tyMTlRpaSejg==", + "license": "MIT", + "dependencies": { + "call-bind-apply-helpers": "^1.0.2", + "get-intrinsic": "^1.3.0" + }, + "engines": { + "node": ">= 0.4" + }, + "funding": { + "url": "https://github.com/sponsors/ljharb" + } + }, + "node_modules/camelcase": { + "version": "8.0.0", + "resolved": "https://registry.npmjs.org/camelcase/-/camelcase-8.0.0.tgz", + "integrity": "sha512-8WB3Jcas3swSvjIeA2yvCJ+Miyz5l1ZmB6HFb9R1317dt9LCQoswg/BGrmAmkWVEszSrrg4RwmO46qIm2OEnSA==", + "license": "MIT", + "engines": { + "node": ">=16" + }, + "funding": { + "url": "https://github.com/sponsors/sindresorhus" + } + }, + "node_modules/camelcase-keys": { + "version": "9.1.3", + "resolved": "https://registry.npmjs.org/camelcase-keys/-/camelcase-keys-9.1.3.tgz", + "integrity": "sha512-Rircqi9ch8AnZscQcsA1C47NFdaO3wukpmIRzYcDOrmvgt78hM/sj5pZhZNec2NM12uk5vTwRHZ4anGcrC4ZTg==", + "license": "MIT", + "dependencies": { + "camelcase": "^8.0.0", + "map-obj": "5.0.0", + "quick-lru": "^6.1.1", + "type-fest": "^4.3.2" + }, + "engines": { + "node": ">=16" + }, + "funding": { + "url": "https://github.com/sponsors/sindresorhus" + } + }, + "node_modules/content-disposition": { + "version": "0.5.4", + "resolved": "https://registry.npmjs.org/content-disposition/-/content-disposition-0.5.4.tgz", + "integrity": "sha512-FveZTNuGw04cxlAiWbzi6zTAL/lhehaWbTtgluJh4/E95DqMwTmha3KZN1aAWA8cFIhHzMZUvLevkw5Rqk+tSQ==", + "license": "MIT", + "dependencies": { + "safe-buffer": "5.2.1" + }, + "engines": { + "node": ">= 0.6" + } + }, + "node_modules/content-type": { + "version": "1.0.5", + "resolved": "https://registry.npmjs.org/content-type/-/content-type-1.0.5.tgz", + "integrity": "sha512-nTjqfcBFEipKdXCv4YDQWCfmcLZKm81ldF0pAopTvyrFGVbcR6P/VAAd5G7N+0tTr8QqiU0tFadD6FK4NtJwOA==", + "license": "MIT", + "engines": { + "node": ">= 0.6" + } + }, + "node_modules/cookie": { + "version": "0.6.0", + "resolved": "https://registry.npmjs.org/cookie/-/cookie-0.6.0.tgz", + "integrity": "sha512-U71cyTamuh1CRNCfpGY6to28lxvNwPG4Guz/EVjgf3Jmzv0vlDp1atT9eS5dDjMYHucpHbWns6Lwf3BKz6svdw==", + "license": "MIT", + "engines": { + "node": ">= 0.6" + } + }, + "node_modules/cookie-signature": { + "version": "1.0.6", + "resolved": "https://registry.npmjs.org/cookie-signature/-/cookie-signature-1.0.6.tgz", + "integrity": "sha512-QADzlaHc8icV8I7vbaJXJwod9HWYp8uCqf1xa4OfNu1T7JVxQIrUgOWtHdNDtPiywmFbiS12VjotIXLrKM3orQ==", + "license": "MIT" + }, + "node_modules/cors": { + "version": "2.8.5", + "resolved": "https://registry.npmjs.org/cors/-/cors-2.8.5.tgz", + "integrity": "sha512-KIHbLJqu73RGr/hnbrO9uBeixNGuvSQjul/jdFvS/KFSIH1hWVd1ng7zOHx+YrEfInLG7q4n6GHQ9cDtxv/P6g==", + "license": "MIT", + "dependencies": { + "object-assign": "^4", + "vary": "^1" + }, + "engines": { + "node": ">= 0.10" + } + }, + "node_modules/debug": { + "version": "2.6.9", + "resolved": "https://registry.npmjs.org/debug/-/debug-2.6.9.tgz", + "integrity": "sha512-bC7ElrdJaJnPbAP+1EotYvqZsb3ecl5wi6Bfi6BJTUcNowp6cvspg0jXznRTKDjm/E7AdgFBVeAPVMNcKGsHMA==", + "license": "MIT", + "dependencies": { + "ms": "2.0.0" + } + }, + "node_modules/depd": { + "version": "2.0.0", + "resolved": "https://registry.npmjs.org/depd/-/depd-2.0.0.tgz", + "integrity": "sha512-g7nH6P6dyDioJogAAGprGpCtVImJhpPk/roCzdb3fIh61/s/nPsfR6onyMwkCAR/OlC3yBC0lESvUoQEAssIrw==", + "license": "MIT", + "engines": { + "node": ">= 0.8" + } + }, + "node_modules/destroy": { + "version": "1.2.0", + "resolved": "https://registry.npmjs.org/destroy/-/destroy-1.2.0.tgz", + "integrity": "sha512-2sJGJTaXIIaR1w4iJSNoN0hnMY7Gpc/n8D4qSCJw8QqFWXf7cuAgnEHxBpweaVcPevC2l3KpjYCx3NypQQgaJg==", + "license": "MIT", + "engines": { + "node": ">= 0.8", + "npm": "1.2.8000 || >= 1.4.16" + } + }, + "node_modules/dotenv": { + "version": "16.4.5", + "resolved": "https://registry.npmjs.org/dotenv/-/dotenv-16.4.5.tgz", + "integrity": "sha512-ZmdL2rui+eB2YwhsWzjInR8LldtZHGDoQ1ugH85ppHKwpUHL7j7rN0Ti9NCnGiQbhaZ11FpR+7ao1dNsmduNUg==", + "license": "BSD-2-Clause", + "engines": { + "node": ">=12" + }, + "funding": { + "url": "https://dotenvx.com" + } + }, + "node_modules/dunder-proto": { + "version": "1.0.1", + "resolved": "https://registry.npmjs.org/dunder-proto/-/dunder-proto-1.0.1.tgz", + "integrity": "sha512-KIN/nDJBQRcXw0MLVhZE9iQHmG68qAVIBg9CqmUYjmQIhgij9U5MFvrqkUL5FbtyyzZuOeOt0zdeRe4UY7ct+A==", + "license": "MIT", + "dependencies": { + "call-bind-apply-helpers": "^1.0.1", + "es-errors": "^1.3.0", + "gopd": "^1.2.0" + }, + "engines": { + "node": ">= 0.4" + } + }, + "node_modules/ee-first": { + "version": "1.1.1", + "resolved": "https://registry.npmjs.org/ee-first/-/ee-first-1.1.1.tgz", + "integrity": "sha512-WMwm9LhRUo+WUaRN+vRuETqG89IgZphVSNkdFgeb6sS/E4OrDIN7t48CAewSHXc6C8lefD8KKfr5vY61brQlow==", + "license": "MIT" + }, + "node_modules/encodeurl": { + "version": "2.0.0", + "resolved": "https://registry.npmjs.org/encodeurl/-/encodeurl-2.0.0.tgz", + "integrity": "sha512-Q0n9HRi4m6JuGIV1eFlmvJB7ZEVxu93IrMyiMsGC0lrMJMWzRgx6WGquyfQgZVb31vhGgXnfmPNNXmxnOkRBrg==", + "license": "MIT", + "engines": { + "node": ">= 0.8" + } + }, + "node_modules/es-define-property": { + "version": "1.0.1", + "resolved": "https://registry.npmjs.org/es-define-property/-/es-define-property-1.0.1.tgz", + "integrity": "sha512-e3nRfgfUZ4rNGL232gUgX06QNyyez04KdjFrF+LTRoOXmrOgFKDg4BCdsjW8EnT69eqdYGmRpJwiPVYNrCaW3g==", + "license": "MIT", + "engines": { + "node": ">= 0.4" + } + }, + "node_modules/es-errors": { + "version": "1.3.0", + "resolved": "https://registry.npmjs.org/es-errors/-/es-errors-1.3.0.tgz", + "integrity": "sha512-Zf5H2Kxt2xjTvbJvP2ZWLEICxA6j+hAmMzIlypy4xcBg1vKVnx89Wy0GbS+kf5cwCVFFzdCFh2XSCFNULS6csw==", + "license": "MIT", + "engines": { + "node": ">= 0.4" + } + }, + "node_modules/es-object-atoms": { + "version": "1.1.1", + "resolved": "https://registry.npmjs.org/es-object-atoms/-/es-object-atoms-1.1.1.tgz", + "integrity": "sha512-FGgH2h8zKNim9ljj7dankFPcICIK9Cp5bm+c2gQSYePhpaG5+esrLODihIorn+Pe6FGJzWhXQotPv73jTaldXA==", + "license": "MIT", + "dependencies": { + "es-errors": "^1.3.0" + }, + "engines": { + "node": ">= 0.4" + } + }, + "node_modules/escape-html": { + "version": "1.0.3", + "resolved": "https://registry.npmjs.org/escape-html/-/escape-html-1.0.3.tgz", + "integrity": "sha512-NiSupZ4OeuGwr68lGIeym/ksIZMJodUGOSCZ/FSnTxcrekbvqrgdUxlJOMpijaKZVjAJrWrGs/6Jy8OMuyj9ow==", + "license": "MIT" + }, + "node_modules/etag": { + "version": "1.8.1", + "resolved": "https://registry.npmjs.org/etag/-/etag-1.8.1.tgz", + "integrity": "sha512-aIL5Fx7mawVa300al2BnEE4iNvo1qETxLrPI/o05L7z6go7fCw1J6EQmbK4FmJ2AS7kgVF/KEZWufBfdClMcPg==", + "license": "MIT", + "engines": { + "node": ">= 0.6" + } + }, + "node_modules/events": { + "version": "3.3.0", + "resolved": "https://registry.npmjs.org/events/-/events-3.3.0.tgz", + "integrity": "sha512-mQw+2fkQbALzQ7V0MY0IqdnXNOeTtP4r0lN9z7AAawCXgqea7bDii20AYrIBrFd/Hx0M2Ocz6S111CaFkUcb0Q==", + "license": "MIT", + "engines": { + "node": ">=0.8.x" + } + }, + "node_modules/express": { + "version": "4.21.0", + "resolved": "https://registry.npmjs.org/express/-/express-4.21.0.tgz", + "integrity": "sha512-VqcNGcj/Id5ZT1LZ/cfihi3ttTn+NJmkli2eZADigjq29qTlWi/hAQ43t/VLPq8+UX06FCEx3ByOYet6ZFblng==", + "license": "MIT", + "dependencies": { + "accepts": "~1.3.8", + "array-flatten": "1.1.1", + "body-parser": "1.20.3", + "content-disposition": "0.5.4", + "content-type": "~1.0.4", + "cookie": "0.6.0", + "cookie-signature": "1.0.6", + "debug": "2.6.9", + "depd": "2.0.0", + "encodeurl": "~2.0.0", + "escape-html": "~1.0.3", + "etag": "~1.8.1", + "finalhandler": "1.3.1", + "fresh": "0.5.2", + "http-errors": "2.0.0", + "merge-descriptors": "1.0.3", + "methods": "~1.1.2", + "on-finished": "2.4.1", + "parseurl": "~1.3.3", + "path-to-regexp": "0.1.10", + "proxy-addr": "~2.0.7", + "qs": "6.13.0", + "range-parser": "~1.2.1", + "safe-buffer": "5.2.1", + "send": "0.19.0", + "serve-static": "1.16.2", + "setprototypeof": "1.2.0", + "statuses": "2.0.1", + "type-is": "~1.6.18", + "utils-merge": "1.0.1", + "vary": "~1.1.2" + }, + "engines": { + "node": ">= 0.10.0" + } + }, + "node_modules/fast-xml-parser": { + "version": "5.2.3", + "resolved": "https://registry.npmjs.org/fast-xml-parser/-/fast-xml-parser-5.2.3.tgz", + "integrity": "sha512-OdCYfRqfpuLUFonTNjvd30rCBZUneHpSQkCqfaeWQ9qrKcl6XlWeDBNVwGb+INAIxRshuN2jF+BE0L6gbBO2mw==", + "funding": [ + { + "type": "github", + "url": "https://github.com/sponsors/NaturalIntelligence" + } + ], + "license": "MIT", + "dependencies": { + "strnum": "^2.1.0" + }, + "bin": { + "fxparser": "src/cli/cli.js" + } + }, + "node_modules/finalhandler": { + "version": "1.3.1", + "resolved": "https://registry.npmjs.org/finalhandler/-/finalhandler-1.3.1.tgz", + "integrity": "sha512-6BN9trH7bp3qvnrRyzsBz+g3lZxTNZTbVO2EV1CS0WIcDbawYVdYvGflME/9QP0h0pYlCDBCTjYa9nZzMDpyxQ==", + "license": "MIT", + "dependencies": { + "debug": "2.6.9", + "encodeurl": "~2.0.0", + "escape-html": "~1.0.3", + "on-finished": "2.4.1", + "parseurl": "~1.3.3", + "statuses": "2.0.1", + "unpipe": "~1.0.0" + }, + "engines": { + "node": ">= 0.8" + } + }, + "node_modules/forwarded": { + "version": "0.2.0", + "resolved": "https://registry.npmjs.org/forwarded/-/forwarded-0.2.0.tgz", + "integrity": "sha512-buRG0fpBtRHSTCOASe6hD258tEubFoRLb4ZNA6NxMVHNw2gOcwHo9wyablzMzOA5z9xA9L1KNjk/Nt6MT9aYow==", + "license": "MIT", + "engines": { + "node": ">= 0.6" + } + }, + "node_modules/fresh": { + "version": "0.5.2", + "resolved": "https://registry.npmjs.org/fresh/-/fresh-0.5.2.tgz", + "integrity": "sha512-zJ2mQYM18rEFOudeV4GShTGIQ7RbzA7ozbU9I/XBpm7kqgMywgmylMwXHxZJmkVoYkna9d2pVXVXPdYTP9ej8Q==", + "license": "MIT", + "engines": { + "node": ">= 0.6" + } + }, + "node_modules/function-bind": { + "version": "1.1.2", + "resolved": "https://registry.npmjs.org/function-bind/-/function-bind-1.1.2.tgz", + "integrity": "sha512-7XHNxH7qX9xG5mIwxkhumTox/MIRNcOgDrxWsMt2pAr23WHp6MrRlN7FBSFpCpr+oVO0F744iUgR82nJMfG2SA==", + "license": "MIT", + "funding": { + "url": "https://github.com/sponsors/ljharb" + } + }, + "node_modules/get-intrinsic": { + "version": "1.3.0", + "resolved": "https://registry.npmjs.org/get-intrinsic/-/get-intrinsic-1.3.0.tgz", + "integrity": "sha512-9fSjSaos/fRIVIp+xSJlE6lfwhES7LNtKaCBIamHsjr2na1BiABJPo0mOjjz8GJDURarmCPGqaiVg5mfjb98CQ==", + "license": "MIT", + "dependencies": { + "call-bind-apply-helpers": "^1.0.2", + "es-define-property": "^1.0.1", + "es-errors": "^1.3.0", + "es-object-atoms": "^1.1.1", + "function-bind": "^1.1.2", + "get-proto": "^1.0.1", + "gopd": "^1.2.0", + "has-symbols": "^1.1.0", + "hasown": "^2.0.2", + "math-intrinsics": "^1.1.0" + }, + "engines": { + "node": ">= 0.4" + }, + "funding": { + "url": "https://github.com/sponsors/ljharb" + } + }, + "node_modules/get-proto": { + "version": "1.0.1", + "resolved": "https://registry.npmjs.org/get-proto/-/get-proto-1.0.1.tgz", + "integrity": "sha512-sTSfBjoXBp89JvIKIefqw7U2CCebsc74kiY6awiGogKtoSGbgjYE/G/+l9sF3MWFPNc9IcoOC4ODfKHfxFmp0g==", + "license": "MIT", + "dependencies": { + "dunder-proto": "^1.0.1", + "es-object-atoms": "^1.0.0" + }, + "engines": { + "node": ">= 0.4" + } + }, + "node_modules/gopd": { + "version": "1.2.0", + "resolved": "https://registry.npmjs.org/gopd/-/gopd-1.2.0.tgz", + "integrity": "sha512-ZUKRh6/kUFoAiTAtTYPZJ3hw9wNxx+BIBOijnlG9PnrJsCcSjs1wyyD6vJpaYtgnzDrKYRSqf3OO6Rfa93xsRg==", + "license": "MIT", + "engines": { + "node": ">= 0.4" + }, + "funding": { + "url": "https://github.com/sponsors/ljharb" + } + }, + "node_modules/has-symbols": { + "version": "1.1.0", + "resolved": "https://registry.npmjs.org/has-symbols/-/has-symbols-1.1.0.tgz", + "integrity": "sha512-1cDNdwJ2Jaohmb3sg4OmKaMBwuC48sYni5HUw2DvsC8LjGTLK9h+eb1X6RyuOHe4hT0ULCW68iomhjUoKUqlPQ==", + "license": "MIT", + "engines": { + "node": ">= 0.4" + }, + "funding": { + "url": "https://github.com/sponsors/ljharb" + } + }, + "node_modules/hasown": { + "version": "2.0.2", + "resolved": "https://registry.npmjs.org/hasown/-/hasown-2.0.2.tgz", + "integrity": "sha512-0hJU9SCPvmMzIBdZFqNPXWa6dqh7WdH0cII9y+CyS8rG3nL48Bclra9HmKhVVUHyPWNH5Y7xDwAB7bfgSjkUMQ==", + "license": "MIT", + "dependencies": { + "function-bind": "^1.1.2" + }, + "engines": { + "node": ">= 0.4" + } + }, + "node_modules/http-errors": { + "version": "2.0.0", + "resolved": "https://registry.npmjs.org/http-errors/-/http-errors-2.0.0.tgz", + "integrity": "sha512-FtwrG/euBzaEjYeRqOgly7G0qviiXoJWnvEH2Z1plBdXgbyjv34pHTSb9zoeHMyDy33+DWy5Wt9Wo+TURtOYSQ==", + "license": "MIT", + "dependencies": { + "depd": "2.0.0", + "inherits": "2.0.4", + "setprototypeof": "1.2.0", + "statuses": "2.0.1", + "toidentifier": "1.0.1" + }, + "engines": { + "node": ">= 0.8" + } + }, + "node_modules/http-proxy-agent": { + "version": "7.0.2", + "resolved": "https://registry.npmjs.org/http-proxy-agent/-/http-proxy-agent-7.0.2.tgz", + "integrity": "sha512-T1gkAiYYDWYx3V5Bmyu7HcfcvL7mUrTWiM6yOfa3PIphViJ/gFPbvidQ+veqSOHci/PxBcDabeUNCzpOODJZig==", + "license": "MIT", + "dependencies": { + "agent-base": "^7.1.0", + "debug": "^4.3.4" + }, + "engines": { + "node": ">= 14" + } + }, + "node_modules/http-proxy-agent/node_modules/debug": { + "version": "4.4.1", + "resolved": "https://registry.npmjs.org/debug/-/debug-4.4.1.tgz", + "integrity": "sha512-KcKCqiftBJcZr++7ykoDIEwSa3XWowTfNPo92BYxjXiyYEVrUQh2aLyhxBCwww+heortUFxEJYcRzosstTEBYQ==", + "license": "MIT", + "dependencies": { + "ms": "^2.1.3" + }, + "engines": { + "node": ">=6.0" + }, + "peerDependenciesMeta": { + "supports-color": { + "optional": true + } + } + }, + "node_modules/http-proxy-agent/node_modules/ms": { + "version": "2.1.3", + "resolved": "https://registry.npmjs.org/ms/-/ms-2.1.3.tgz", + "integrity": "sha512-6FlzubTLZG3J2a/NVCAleEhjzq5oxgHyaCU9yYXvcLsvoVaHJq/s5xXI6/XXP6tz7R9xAOtHnSO/tXtF3WRTlA==", + "license": "MIT" + }, + "node_modules/https-proxy-agent": { + "version": "7.0.6", + "resolved": "https://registry.npmjs.org/https-proxy-agent/-/https-proxy-agent-7.0.6.tgz", + "integrity": "sha512-vK9P5/iUfdl95AI+JVyUuIcVtd4ofvtrOr3HNtM2yxC9bnMbEdp3x01OhQNnjb8IJYi38VlTE3mBXwcfvywuSw==", + "license": "MIT", + "dependencies": { + "agent-base": "^7.1.2", + "debug": "4" + }, + "engines": { + "node": ">= 14" + } + }, + "node_modules/https-proxy-agent/node_modules/debug": { + "version": "4.4.1", + "resolved": "https://registry.npmjs.org/debug/-/debug-4.4.1.tgz", + "integrity": "sha512-KcKCqiftBJcZr++7ykoDIEwSa3XWowTfNPo92BYxjXiyYEVrUQh2aLyhxBCwww+heortUFxEJYcRzosstTEBYQ==", + "license": "MIT", + "dependencies": { + "ms": "^2.1.3" + }, + "engines": { + "node": ">=6.0" + }, + "peerDependenciesMeta": { + "supports-color": { + "optional": true + } + } + }, + "node_modules/https-proxy-agent/node_modules/ms": { + "version": "2.1.3", + "resolved": "https://registry.npmjs.org/ms/-/ms-2.1.3.tgz", + "integrity": "sha512-6FlzubTLZG3J2a/NVCAleEhjzq5oxgHyaCU9yYXvcLsvoVaHJq/s5xXI6/XXP6tz7R9xAOtHnSO/tXtF3WRTlA==", + "license": "MIT" + }, + "node_modules/iconv-lite": { + "version": "0.4.24", + "resolved": "https://registry.npmjs.org/iconv-lite/-/iconv-lite-0.4.24.tgz", + "integrity": "sha512-v3MXnZAcvnywkTUEZomIActle7RXXeedOR31wwl7VlyoXO4Qi9arvSenNQWne1TcRwhCL1HwLI21bEqdpj8/rA==", + "license": "MIT", + "dependencies": { + "safer-buffer": ">= 2.1.2 < 3" + }, + "engines": { + "node": ">=0.10.0" + } + }, + "node_modules/inherits": { + "version": "2.0.4", + "resolved": "https://registry.npmjs.org/inherits/-/inherits-2.0.4.tgz", + "integrity": "sha512-k/vGaX4/Yla3WzyMCvTQOXYeIHvqOKtnqBduzTHpzpQZzAskKMhZ2K+EnBiSM9zGSoIFeMpXKxa4dYeZIQqewQ==", + "license": "ISC" + }, + "node_modules/ipaddr.js": { + "version": "1.9.1", + "resolved": "https://registry.npmjs.org/ipaddr.js/-/ipaddr.js-1.9.1.tgz", + "integrity": "sha512-0KI/607xoxSToH7GjN1FfSbLoU0+btTicjsQSWQlh/hZykN8KpmMf7uYwPW3R+akZ6R/w18ZlXSHBYXiYUPO3g==", + "license": "MIT", + "engines": { + "node": ">= 0.10" + } + }, + "node_modules/jose": { + "version": "5.10.0", + "resolved": "https://registry.npmjs.org/jose/-/jose-5.10.0.tgz", + "integrity": "sha512-s+3Al/p9g32Iq+oqXxkW//7jk2Vig6FF1CFqzVXoTUXt2qz89YWbL+OwS17NFYEvxC35n0FKeGO2LGYSxeM2Gg==", + "license": "MIT", + "funding": { + "url": "https://github.com/sponsors/panva" + } + }, + "node_modules/livekit-server-sdk": { + "version": "2.13.0", + "resolved": "https://registry.npmjs.org/livekit-server-sdk/-/livekit-server-sdk-2.13.0.tgz", + "integrity": "sha512-fQJI/zEJRPeXKdKMkEfJNYSSnvmuPQsk2Q+X6tPfUrJPy7fnyYPax/icf/CZ8EYZQBhFgSD7WaKOYGSSfGSyZw==", + "license": "Apache-2.0", + "dependencies": { + "@bufbuild/protobuf": "^1.7.2", + "@livekit/protocol": "^1.38.0", + "camelcase-keys": "^9.0.0", + "jose": "^5.1.2" + }, + "engines": { + "node": ">=18" + } + }, + "node_modules/map-obj": { + "version": "5.0.0", + "resolved": "https://registry.npmjs.org/map-obj/-/map-obj-5.0.0.tgz", + "integrity": "sha512-2L3MIgJynYrZ3TYMriLDLWocz15okFakV6J12HXvMXDHui2x/zgChzg1u9mFFGbbGWE+GsLpQByt4POb9Or+uA==", + "license": "MIT", + "engines": { + "node": "^12.20.0 || ^14.13.1 || >=16.0.0" + }, + "funding": { + "url": "https://github.com/sponsors/sindresorhus" + } + }, + "node_modules/math-intrinsics": { + "version": "1.1.0", + "resolved": "https://registry.npmjs.org/math-intrinsics/-/math-intrinsics-1.1.0.tgz", + "integrity": "sha512-/IXtbwEk5HTPyEwyKX6hGkYXxM9nbj64B+ilVJnC/R6B0pH5G4V3b0pVbL7DBj4tkhBAppbQUlf6F6Xl9LHu1g==", + "license": "MIT", + "engines": { + "node": ">= 0.4" + } + }, + "node_modules/media-typer": { + "version": "0.3.0", + "resolved": "https://registry.npmjs.org/media-typer/-/media-typer-0.3.0.tgz", + "integrity": "sha512-dq+qelQ9akHpcOl/gUVRTxVIOkAJ1wR3QAvb4RsVjS8oVoFjDGTc679wJYmUmknUF5HwMLOgb5O+a3KxfWapPQ==", + "license": "MIT", + "engines": { + "node": ">= 0.6" + } + }, + "node_modules/merge-descriptors": { + "version": "1.0.3", + "resolved": "https://registry.npmjs.org/merge-descriptors/-/merge-descriptors-1.0.3.tgz", + "integrity": "sha512-gaNvAS7TZ897/rVaZ0nMtAyxNyi/pdbjbAwUpFQpN70GqnVfOiXpeUUMKRBmzXaSQ8DdTX4/0ms62r2K+hE6mQ==", + "license": "MIT", + "funding": { + "url": "https://github.com/sponsors/sindresorhus" + } + }, + "node_modules/methods": { + "version": "1.1.2", + "resolved": "https://registry.npmjs.org/methods/-/methods-1.1.2.tgz", + "integrity": "sha512-iclAHeNqNm68zFtnZ0e+1L2yUIdvzNoauKU4WBA3VvH/vPFieF7qfRlwUZU+DA9P9bPXIS90ulxoUoCH23sV2w==", + "license": "MIT", + "engines": { + "node": ">= 0.6" + } + }, + "node_modules/mime": { + "version": "1.6.0", + "resolved": "https://registry.npmjs.org/mime/-/mime-1.6.0.tgz", + "integrity": "sha512-x0Vn8spI+wuJ1O6S7gnbaQg8Pxh4NNHb7KSINmEWKiPE4RKOplvijn+NkmYmmRgP68mc70j2EbeTFRsrswaQeg==", + "license": "MIT", + "bin": { + "mime": "cli.js" + }, + "engines": { + "node": ">=4" + } + }, + "node_modules/mime-db": { + "version": "1.52.0", + "resolved": "https://registry.npmjs.org/mime-db/-/mime-db-1.52.0.tgz", + "integrity": "sha512-sPU4uV7dYlvtWJxwwxHD0PuihVNiE7TyAbQ5SWxDCB9mUYvOgroQOwYQQOKPJ8CIbE+1ETVlOoK1UC2nU3gYvg==", + "license": "MIT", + "engines": { + "node": ">= 0.6" + } + }, + "node_modules/mime-types": { + "version": "2.1.35", + "resolved": "https://registry.npmjs.org/mime-types/-/mime-types-2.1.35.tgz", + "integrity": "sha512-ZDY+bPm5zTTF+YpCrAU9nK0UgICYPT0QtT1NZWFv4s++TNkcgVaT0g6+4R2uI4MjQjzysHB1zxuWL50hzaeXiw==", + "license": "MIT", + "dependencies": { + "mime-db": "1.52.0" + }, + "engines": { + "node": ">= 0.6" + } + }, + "node_modules/ms": { + "version": "2.0.0", + "resolved": "https://registry.npmjs.org/ms/-/ms-2.0.0.tgz", + "integrity": "sha512-Tpp60P6IUJDTuOq/5Z8cdskzJujfwqfOTkrwIwj7IRISpnkJnT6SyJ4PCPnGMoFjC9ddhal5KVIYtAt97ix05A==", + "license": "MIT" + }, + "node_modules/negotiator": { + "version": "0.6.3", + "resolved": "https://registry.npmjs.org/negotiator/-/negotiator-0.6.3.tgz", + "integrity": "sha512-+EUsqGPLsM+j/zdChZjsnX51g4XrHFOIXwfnCVPGlQk/k5giakcKsuxCObBRu6DSm9opw/O6slWbJdghQM4bBg==", + "license": "MIT", + "engines": { + "node": ">= 0.6" + } + }, + "node_modules/object-assign": { + "version": "4.1.1", + "resolved": "https://registry.npmjs.org/object-assign/-/object-assign-4.1.1.tgz", + "integrity": "sha512-rJgTQnkUnH1sFw8yT6VSU3zD3sWmu6sZhIseY8VX+GRu3P6F7Fu+JNDoXfklElbLJSnc3FUQHVe4cU5hj+BcUg==", + "license": "MIT", + "engines": { + "node": ">=0.10.0" + } + }, + "node_modules/object-inspect": { + "version": "1.13.4", + "resolved": "https://registry.npmjs.org/object-inspect/-/object-inspect-1.13.4.tgz", + "integrity": "sha512-W67iLl4J2EXEGTbfeHCffrjDfitvLANg0UlX3wFUUSTx92KXRFegMHUVgSqE+wvhAbi4WqjGg9czysTV2Epbew==", + "license": "MIT", + "engines": { + "node": ">= 0.4" + }, + "funding": { + "url": "https://github.com/sponsors/ljharb" + } + }, + "node_modules/on-finished": { + "version": "2.4.1", + "resolved": "https://registry.npmjs.org/on-finished/-/on-finished-2.4.1.tgz", + "integrity": "sha512-oVlzkg3ENAhCk2zdv7IJwd/QUD4z2RxRwpkcGY8psCVcCYZNq4wYnVWALHM+brtuJjePWiYF/ClmuDr8Ch5+kg==", + "license": "MIT", + "dependencies": { + "ee-first": "1.1.1" + }, + "engines": { + "node": ">= 0.8" + } + }, + "node_modules/parseurl": { + "version": "1.3.3", + "resolved": "https://registry.npmjs.org/parseurl/-/parseurl-1.3.3.tgz", + "integrity": "sha512-CiyeOxFT/JZyN5m0z9PfXw4SCBJ6Sygz1Dpl0wqjlhDEGGBP1GnsUVEL0p63hoG1fcj3fHynXi9NYO4nWOL+qQ==", + "license": "MIT", + "engines": { + "node": ">= 0.8" + } + }, + "node_modules/path-to-regexp": { + "version": "0.1.10", + "resolved": "https://registry.npmjs.org/path-to-regexp/-/path-to-regexp-0.1.10.tgz", + "integrity": "sha512-7lf7qcQidTku0Gu3YDPc8DJ1q7OOucfa/BSsIwjuh56VU7katFvuM8hULfkwB3Fns/rsVF7PwPKVw1sl5KQS9w==", + "license": "MIT" + }, + "node_modules/proxy-addr": { + "version": "2.0.7", + "resolved": "https://registry.npmjs.org/proxy-addr/-/proxy-addr-2.0.7.tgz", + "integrity": "sha512-llQsMLSUDUPT44jdrU/O37qlnifitDP+ZwrmmZcoSKyLKvtZxpyV0n2/bD/N4tBAAZ/gJEdZU7KMraoK1+XYAg==", + "license": "MIT", + "dependencies": { + "forwarded": "0.2.0", + "ipaddr.js": "1.9.1" + }, + "engines": { + "node": ">= 0.10" + } + }, + "node_modules/qs": { + "version": "6.13.0", + "resolved": "https://registry.npmjs.org/qs/-/qs-6.13.0.tgz", + "integrity": "sha512-+38qI9SOr8tfZ4QmJNplMUxqjbe7LKvvZgWdExBOmd+egZTtjLB67Gu0HRX3u/XOq7UU2Nx6nsjvS16Z9uwfpg==", + "license": "BSD-3-Clause", + "dependencies": { + "side-channel": "^1.0.6" + }, + "engines": { + "node": ">=0.6" + }, + "funding": { + "url": "https://github.com/sponsors/ljharb" + } + }, + "node_modules/quick-lru": { + "version": "6.1.2", + "resolved": "https://registry.npmjs.org/quick-lru/-/quick-lru-6.1.2.tgz", + "integrity": "sha512-AAFUA5O1d83pIHEhJwWCq/RQcRukCkn/NSm2QsTEMle5f2hP0ChI2+3Xb051PZCkLryI/Ir1MVKviT2FIloaTQ==", + "license": "MIT", + "engines": { + "node": ">=12" + }, + "funding": { + "url": "https://github.com/sponsors/sindresorhus" + } + }, + "node_modules/range-parser": { + "version": "1.2.1", + "resolved": "https://registry.npmjs.org/range-parser/-/range-parser-1.2.1.tgz", + "integrity": "sha512-Hrgsx+orqoygnmhFbKaHE6c296J+HTAQXoxEF6gNupROmmGJRoyzfG3ccAveqCBrwr/2yxQ5BVd/GTl5agOwSg==", + "license": "MIT", + "engines": { + "node": ">= 0.6" + } + }, + "node_modules/raw-body": { + "version": "2.5.2", + "resolved": "https://registry.npmjs.org/raw-body/-/raw-body-2.5.2.tgz", + "integrity": "sha512-8zGqypfENjCIqGhgXToC8aB2r7YrBX+AQAfIPs/Mlk+BtPTztOvTS01NRW/3Eh60J+a48lt8qsCzirQ6loCVfA==", + "license": "MIT", + "dependencies": { + "bytes": "3.1.2", + "http-errors": "2.0.0", + "iconv-lite": "0.4.24", + "unpipe": "1.0.0" + }, + "engines": { + "node": ">= 0.8" + } + }, + "node_modules/safe-buffer": { + "version": "5.2.1", + "resolved": "https://registry.npmjs.org/safe-buffer/-/safe-buffer-5.2.1.tgz", + "integrity": "sha512-rp3So07KcdmmKbGvgaNxQSJr7bGVSVk5S9Eq1F+ppbRo70+YeaDxkw5Dd8NPN+GD6bjnYm2VuPuCXmpuYvmCXQ==", + "funding": [ + { + "type": "github", + "url": "https://github.com/sponsors/feross" + }, + { + "type": "patreon", + "url": "https://www.patreon.com/feross" + }, + { + "type": "consulting", + "url": "https://feross.org/support" + } + ], + "license": "MIT" + }, + "node_modules/safer-buffer": { + "version": "2.1.2", + "resolved": "https://registry.npmjs.org/safer-buffer/-/safer-buffer-2.1.2.tgz", + "integrity": "sha512-YZo3K82SD7Riyi0E1EQPojLz7kpepnSQI9IyPbHHg1XXXevb5dJI7tpyN2ADxGcQbHG7vcyRHk0cbwqcQriUtg==", + "license": "MIT" + }, + "node_modules/send": { + "version": "0.19.0", + "resolved": "https://registry.npmjs.org/send/-/send-0.19.0.tgz", + "integrity": "sha512-dW41u5VfLXu8SJh5bwRmyYUbAoSB3c9uQh6L8h/KtsFREPWpbX1lrljJo186Jc4nmci/sGUZ9a0a0J2zgfq2hw==", + "license": "MIT", + "dependencies": { + "debug": "2.6.9", + "depd": "2.0.0", + "destroy": "1.2.0", + "encodeurl": "~1.0.2", + "escape-html": "~1.0.3", + "etag": "~1.8.1", + "fresh": "0.5.2", + "http-errors": "2.0.0", + "mime": "1.6.0", + "ms": "2.1.3", + "on-finished": "2.4.1", + "range-parser": "~1.2.1", + "statuses": "2.0.1" + }, + "engines": { + "node": ">= 0.8.0" + } + }, + "node_modules/send/node_modules/encodeurl": { + "version": "1.0.2", + "resolved": "https://registry.npmjs.org/encodeurl/-/encodeurl-1.0.2.tgz", + "integrity": "sha512-TPJXq8JqFaVYm2CWmPvnP2Iyo4ZSM7/QKcSmuMLDObfpH5fi7RUGmd/rTDf+rut/saiDiQEeVTNgAmJEdAOx0w==", + "license": "MIT", + "engines": { + "node": ">= 0.8" + } + }, + "node_modules/send/node_modules/ms": { + "version": "2.1.3", + "resolved": "https://registry.npmjs.org/ms/-/ms-2.1.3.tgz", + "integrity": "sha512-6FlzubTLZG3J2a/NVCAleEhjzq5oxgHyaCU9yYXvcLsvoVaHJq/s5xXI6/XXP6tz7R9xAOtHnSO/tXtF3WRTlA==", + "license": "MIT" + }, + "node_modules/serve-static": { + "version": "1.16.2", + "resolved": "https://registry.npmjs.org/serve-static/-/serve-static-1.16.2.tgz", + "integrity": "sha512-VqpjJZKadQB/PEbEwvFdO43Ax5dFBZ2UECszz8bQ7pi7wt//PWe1P6MN7eCnjsatYtBT6EuiClbjSWP2WrIoTw==", + "license": "MIT", + "dependencies": { + "encodeurl": "~2.0.0", + "escape-html": "~1.0.3", + "parseurl": "~1.3.3", + "send": "0.19.0" + }, + "engines": { + "node": ">= 0.8.0" + } + }, + "node_modules/setprototypeof": { + "version": "1.2.0", + "resolved": "https://registry.npmjs.org/setprototypeof/-/setprototypeof-1.2.0.tgz", + "integrity": "sha512-E5LDX7Wrp85Kil5bhZv46j8jOeboKq5JMmYM3gVGdGH8xFpPWXUMsNrlODCrkoxMEeNi/XZIwuRvY4XNwYMJpw==", + "license": "ISC" + }, + "node_modules/side-channel": { + "version": "1.1.0", + "resolved": "https://registry.npmjs.org/side-channel/-/side-channel-1.1.0.tgz", + "integrity": "sha512-ZX99e6tRweoUXqR+VBrslhda51Nh5MTQwou5tnUDgbtyM0dBgmhEDtWGP/xbKn6hqfPRHujUNwz5fy/wbbhnpw==", + "license": "MIT", + "dependencies": { + "es-errors": "^1.3.0", + "object-inspect": "^1.13.3", + "side-channel-list": "^1.0.0", + "side-channel-map": "^1.0.1", + "side-channel-weakmap": "^1.0.2" + }, + "engines": { + "node": ">= 0.4" + }, + "funding": { + "url": "https://github.com/sponsors/ljharb" + } + }, + "node_modules/side-channel-list": { + "version": "1.0.0", + "resolved": "https://registry.npmjs.org/side-channel-list/-/side-channel-list-1.0.0.tgz", + "integrity": "sha512-FCLHtRD/gnpCiCHEiJLOwdmFP+wzCmDEkc9y7NsYxeF4u7Btsn1ZuwgwJGxImImHicJArLP4R0yX4c2KCrMrTA==", + "license": "MIT", + "dependencies": { + "es-errors": "^1.3.0", + "object-inspect": "^1.13.3" + }, + "engines": { + "node": ">= 0.4" + }, + "funding": { + "url": "https://github.com/sponsors/ljharb" + } + }, + "node_modules/side-channel-map": { + "version": "1.0.1", + "resolved": "https://registry.npmjs.org/side-channel-map/-/side-channel-map-1.0.1.tgz", + "integrity": "sha512-VCjCNfgMsby3tTdo02nbjtM/ewra6jPHmpThenkTYh8pG9ucZ/1P8So4u4FGBek/BjpOVsDCMoLA/iuBKIFXRA==", + "license": "MIT", + "dependencies": { + "call-bound": "^1.0.2", + "es-errors": "^1.3.0", + "get-intrinsic": "^1.2.5", + "object-inspect": "^1.13.3" + }, + "engines": { + "node": ">= 0.4" + }, + "funding": { + "url": "https://github.com/sponsors/ljharb" + } + }, + "node_modules/side-channel-weakmap": { + "version": "1.0.2", + "resolved": "https://registry.npmjs.org/side-channel-weakmap/-/side-channel-weakmap-1.0.2.tgz", + "integrity": "sha512-WPS/HvHQTYnHisLo9McqBHOJk2FkHO/tlpvldyrnem4aeQp4hai3gythswg6p01oSoTl58rcpiFAjF2br2Ak2A==", + "license": "MIT", + "dependencies": { + "call-bound": "^1.0.2", + "es-errors": "^1.3.0", + "get-intrinsic": "^1.2.5", + "object-inspect": "^1.13.3", + "side-channel-map": "^1.0.1" + }, + "engines": { + "node": ">= 0.4" + }, + "funding": { + "url": "https://github.com/sponsors/ljharb" + } + }, + "node_modules/statuses": { + "version": "2.0.1", + "resolved": "https://registry.npmjs.org/statuses/-/statuses-2.0.1.tgz", + "integrity": "sha512-RwNA9Z/7PrK06rYLIzFMlaF+l73iwpzsqRIFgbMLbTcLD6cOao82TaWefPXQvB2fOC4AjuYSEndS7N/mTCbkdQ==", + "license": "MIT", + "engines": { + "node": ">= 0.8" + } + }, + "node_modules/strnum": { + "version": "2.1.1", + "resolved": "https://registry.npmjs.org/strnum/-/strnum-2.1.1.tgz", + "integrity": "sha512-7ZvoFTiCnGxBtDqJ//Cu6fWtZtc7Y3x+QOirG15wztbdngGSkht27o2pyGWrVy0b4WAy3jbKmnoK6g5VlVNUUw==", + "funding": [ + { + "type": "github", + "url": "https://github.com/sponsors/NaturalIntelligence" + } + ], + "license": "MIT" + }, + "node_modules/toidentifier": { + "version": "1.0.1", + "resolved": "https://registry.npmjs.org/toidentifier/-/toidentifier-1.0.1.tgz", + "integrity": "sha512-o5sSPKEkg/DIQNmH43V0/uerLrpzVedkUh8tGNvaeXpfpuwjKenlSox/2O/BTlZUtEe+JG7s5YhEz608PlAHRA==", + "license": "MIT", + "engines": { + "node": ">=0.6" + } + }, + "node_modules/tslib": { + "version": "2.8.1", + "resolved": "https://registry.npmjs.org/tslib/-/tslib-2.8.1.tgz", + "integrity": "sha512-oJFu94HQb+KVduSUQL7wnpmqnfmLsOA/nAh6b6EH0wCEoK0/mPeXU6c3wKDV83MkOuHPRHtSXKKU99IBazS/2w==", + "license": "0BSD" + }, + "node_modules/type-fest": { + "version": "4.41.0", + "resolved": "https://registry.npmjs.org/type-fest/-/type-fest-4.41.0.tgz", + "integrity": "sha512-TeTSQ6H5YHvpqVwBRcnLDCBnDOHWYu7IvGbHT6N8AOymcr9PJGjc1GTtiWZTYg0NCgYwvnYWEkVChQAr9bjfwA==", + "license": "(MIT OR CC0-1.0)", + "engines": { + "node": ">=16" + }, + "funding": { + "url": "https://github.com/sponsors/sindresorhus" + } + }, + "node_modules/type-is": { + "version": "1.6.18", + "resolved": "https://registry.npmjs.org/type-is/-/type-is-1.6.18.tgz", + "integrity": "sha512-TkRKr9sUTxEH8MdfuCSP7VizJyzRNMjj2J2do2Jr3Kym598JVdEksuzPQCnlFPW4ky9Q+iA+ma9BGm06XQBy8g==", + "license": "MIT", + "dependencies": { + "media-typer": "0.3.0", + "mime-types": "~2.1.24" + }, + "engines": { + "node": ">= 0.6" + } + }, + "node_modules/unpipe": { + "version": "1.0.0", + "resolved": "https://registry.npmjs.org/unpipe/-/unpipe-1.0.0.tgz", + "integrity": "sha512-pjy2bYhSsufwWlKwPc+l3cN7+wuJlK6uz0YdJEOlQDbl6jo/YlPi4mb8agUkVC8BF7V8NuzeyPNqRksA3hztKQ==", + "license": "MIT", + "engines": { + "node": ">= 0.8" + } + }, + "node_modules/utils-merge": { + "version": "1.0.1", + "resolved": "https://registry.npmjs.org/utils-merge/-/utils-merge-1.0.1.tgz", + "integrity": "sha512-pMZTvIkT1d+TFGvDOqodOclx0QWkkgi6Tdoa8gC8ffGAAqz9pzPTZWAybbsHHoED/ztMtkv/VoYTYyShUn81hA==", + "license": "MIT", + "engines": { + "node": ">= 0.4.0" + } + }, + "node_modules/vary": { + "version": "1.1.2", + "resolved": "https://registry.npmjs.org/vary/-/vary-1.1.2.tgz", + "integrity": "sha512-BNGbWLfd0eUPabhkXUVm0j8uuvREyTh5ovRa/dyow/BqAbZJyC+5fU+IzQOzmAKzYqYRAISoRhdQr3eIZ/PXqg==", + "license": "MIT", + "engines": { + "node": ">= 0.8" + } + } + } +} diff --git a/advanced-features/openvidu-recording-advanced-node-azure/package.json b/advanced-features/openvidu-recording-advanced-node-azure/package.json new file mode 100644 index 00000000..bf756d33 --- /dev/null +++ b/advanced-features/openvidu-recording-advanced-node-azure/package.json @@ -0,0 +1,17 @@ +{ + "name": "openvidu-recording-advanced-node", + "version": "1.0.0", + "description": "Simple video-call application with recording capabilities (advanced version)", + "main": "src/index.js", + "type": "module", + "scripts": { + "start": "node src/index.js" + }, + "dependencies": { + "@azure/storage-blob": "12.27.0", + "cors": "2.8.5", + "dotenv": "16.4.5", + "express": "4.21.0", + "livekit-server-sdk": "^2.7.2" + } +} \ No newline at end of file diff --git a/advanced-features/openvidu-recording-advanced-node-azure/public/app.js b/advanced-features/openvidu-recording-advanced-node-azure/public/app.js new file mode 100644 index 00000000..54475f73 --- /dev/null +++ b/advanced-features/openvidu-recording-advanced-node-azure/public/app.js @@ -0,0 +1,432 @@ +// When running OpenVidu locally, leave this variable empty +// For other deployment type, configure it with correct URL depending on your deployment +var LIVEKIT_URL = ""; +configureLiveKitUrl(); + +const LivekitClient = window.LivekitClient; +var room; + +function configureLiveKitUrl() { + // If LIVEKIT_URL is not configured, use default value from OpenVidu Local deployment + if (!LIVEKIT_URL) { + if (window.location.hostname === "localhost") { + LIVEKIT_URL = "ws://localhost:7880/"; + } else { + LIVEKIT_URL = "wss://" + window.location.hostname + ":7443/"; + } + } +} + +async function joinRoom() { + // Disable 'Join' button + document.getElementById("join-button").disabled = true; + document.getElementById("join-button").innerText = "Joining..."; + + // Initialize a new Room object + room = new LivekitClient.Room(); + + // Specify the actions when events take place in the room + // On every new Track received... + room.on(LivekitClient.RoomEvent.TrackSubscribed, (track, _publication, participant) => { + addTrack(track, participant.identity); + }); + + // On every new Track destroyed... + room.on(LivekitClient.RoomEvent.TrackUnsubscribed, (track, _publication, participant) => { + track.detach(); + document.getElementById(track.sid)?.remove(); + + if (track.kind === "video") { + removeVideoContainer(participant.identity); + } + }); + + // When recording status changes... + room.on(LivekitClient.RoomEvent.RoomMetadataChanged, async (metadata) => { + const { recordingStatus } = JSON.parse(metadata); + await updateRecordingInfo(recordingStatus); + }); + + // When a message is received... + room.on(LivekitClient.RoomEvent.DataReceived, async (payload, _participant, _kind, topic) => { + // If the message is a recording deletion notification, remove the recording from the list + if (topic === "RECORDING_DELETED") { + const { recordingName } = JSON.parse(new TextDecoder().decode(payload)); + deleteRecordingContainer(recordingName); + } + }); + + try { + // Get the room name and participant name from the form + const roomName = document.getElementById("room-name").value; + const userName = document.getElementById("participant-name").value; + + // Get a token from your application server with the room name and participant name + const token = await getToken(roomName, userName); + + // Connect to the room with the LiveKit URL and the token + await room.connect(LIVEKIT_URL, token); + + // Hide the 'Join room' page and show the 'Room' page + document.getElementById("room-title").innerText = roomName; + document.getElementById("join").hidden = true; + document.getElementById("room").hidden = false; + + // Publish your camera and microphone + await room.localParticipant.enableCameraAndMicrophone(); + const localVideoTrack = this.room.localParticipant.videoTrackPublications.values().next().value.track; + addTrack(localVideoTrack, userName, true); + + // Update recording info + const { recordingStatus } = JSON.parse(room.metadata); + await updateRecordingInfo(recordingStatus); + + if (recordingStatus !== "STOPPED" && recordingStatus !== "FAILED") { + const roomId = await room.getSid(); + await listRecordings(room.name, roomId); + } + } catch (error) { + console.log("There was an error connecting to the room:", error.message); + await leaveRoom(); + } +} + +function addTrack(track, participantIdentity, local = false) { + const element = track.attach(); + element.id = track.sid; + + /* If the track is a video track, we create a container and append the video element to it + with the participant's identity */ + if (track.kind === "video") { + const videoContainer = createVideoContainer(participantIdentity, local); + videoContainer.append(element); + appendParticipantData(videoContainer, participantIdentity + (local ? " (You)" : "")); + } else { + document.getElementById("layout-container").append(element); + } +} + +async function leaveRoom() { + // Leave the room by calling 'disconnect' method over the Room object + await room.disconnect(); + + // Remove all HTML elements inside the layout container + removeAllLayoutElements(); + + // Remove all recordings from the list + removeAllRecordings(); + + // Reset recording state + document.getElementById("recording-button").disabled = false; + document.getElementById("recording-button").innerText = "Start Recording"; + document.getElementById("recording-button").className = "btn btn-primary"; + document.getElementById("recording-text").hidden = true; + + // Back to 'Join room' page + document.getElementById("join").hidden = false; + document.getElementById("room").hidden = true; + + // Enable 'Join' button + document.getElementById("join-button").disabled = false; + document.getElementById("join-button").innerText = "Join!"; +} + +window.onbeforeunload = () => { + room?.disconnect(); +}; + +document.addEventListener("DOMContentLoaded", async function () { + var currentPage = window.location.pathname; + + if (currentPage === "/recordings.html") { + await listRecordings(); + } else { + generateFormValues(); + } + + // Remove recording video when the dialog is closed + document.getElementById("recording-video-dialog").addEventListener("close", () => { + const recordingVideo = document.getElementById("recording-video"); + recordingVideo.src = ""; + }); +}); + +function generateFormValues() { + document.getElementById("room-name").value = "Test Room"; + document.getElementById("participant-name").value = "Participant" + Math.floor(Math.random() * 100); +} + +function createVideoContainer(participantIdentity, local = false) { + const videoContainer = document.createElement("div"); + videoContainer.id = `camera-${participantIdentity}`; + videoContainer.className = "video-container"; + const layoutContainer = document.getElementById("layout-container"); + + if (local) { + layoutContainer.prepend(videoContainer); + } else { + layoutContainer.append(videoContainer); + } + + return videoContainer; +} + +function appendParticipantData(videoContainer, participantIdentity) { + const dataElement = document.createElement("div"); + dataElement.className = "participant-data"; + dataElement.innerHTML = `

${participantIdentity}

`; + videoContainer.prepend(dataElement); +} + +function removeVideoContainer(participantIdentity) { + const videoContainer = document.getElementById(`camera-${participantIdentity}`); + videoContainer?.remove(); +} + +function removeAllLayoutElements() { + const layoutElements = document.getElementById("layout-container").children; + Array.from(layoutElements).forEach((element) => { + element.remove(); + }); +} + +/** + * -------------------------------------------- + * GETTING A TOKEN FROM YOUR APPLICATION SERVER + * -------------------------------------------- + * The method below request the creation of a token to + * your application server. This prevents the need to expose + * your LiveKit API key and secret to the client side. + * + * In this sample code, there is no user control at all. Anybody could + * access your application server endpoints. In a real production + * environment, your application server must identify the user to allow + * access to the endpoints. + */ +async function getToken(roomName, participantName) { + const [error, body] = await httpRequest("POST", "/token", { + roomName, + participantName + }); + + if (error) { + throw new Error(`Failed to get token: ${error.message}`); + } + + return body.token; +} + +async function updateRecordingInfo(recordingStatus) { + const recordingButton = document.getElementById("recording-button"); + const recordingText = document.getElementById("recording-text"); + + switch (recordingStatus) { + case "STARTING": + recordingButton.disabled = true; + recordingButton.innerText = "Starting..."; + break; + case "STARTED": + recordingButton.disabled = false; + recordingButton.innerText = "Stop Recording"; + recordingButton.className = "btn btn-danger"; + recordingText.hidden = false; + break; + case "STOPPING": + recordingButton.disabled = true; + recordingButton.innerText = "Stopping..."; + recordingButton.className = "btn btn-danger"; + recordingText.hidden = false; + break; + case "STOPPED": + case "FAILED": + recordingButton.disabled = false; + recordingButton.innerText = "Start Recording"; + recordingButton.className = "btn btn-primary"; + recordingText.hidden = true; + + const roomId = await room.getSid(); + await listRecordings(room.name, roomId); + break; + } +} + +async function manageRecording() { + const recordingButton = document.getElementById("recording-button"); + + if (recordingButton.innerText === "Start Recording") { + await startRecording(); + } else { + await stopRecording(); + } +} + +async function startRecording() { + return httpRequest("POST", "/recordings/start", { + roomName: room.name + }); +} + +async function stopRecording() { + return httpRequest("POST", "/recordings/stop", { + roomName: room.name + }); +} + +async function deleteRecording(recordingName) { + const [error, _] = await httpRequest("DELETE", `/recordings/${recordingName}`); + + if (!error || error.status === 404) { + deleteRecordingContainer(recordingName); + } +} + +function deleteRecordingContainer(recordingName) { + const recordingContainer = document.getElementById(recordingName); + + if (recordingContainer) { + recordingContainer.remove(); + + const recordingsList = document.getElementById("recording-list"); + + if (recordingsList.children.length === 0) { + recordingsList.innerHTML = "There are no recordings available"; + } + } +} + +async function listRecordings(roomName, roomId) { + const url = "/recordings" + (roomName ? `?roomName=${roomName}` + (roomId ? `&roomId=${roomId}` : "") : ""); + const [error, body] = await httpRequest("GET", url); + + if (!error) { + const recordings = body.recordings; + showRecordingList(recordings); + } +} + +async function listRecordingsByRoom() { + const roomName = document.getElementById("room-name").value; + await listRecordings(roomName); +} + +async function getRecordingUrl(recordingName) { + const [_, body] = await httpRequest("GET", `/recordings/${recordingName}/url`); + return body?.recordingUrl; +} + +async function httpRequest(method, url, body) { + try { + const response = await fetch(url, { + method, + headers: { + "Content-Type": "application/json" + }, + body: method !== "GET" ? JSON.stringify(body) : undefined + }); + + const responseBody = await response.json(); + + if (!response.ok) { + console.error(responseBody.errorMessage); + const error = { + status: response.status, + message: responseBody.errorMessage + }; + return [error, undefined]; + } + + return [undefined, responseBody]; + } catch (error) { + console.error(error.message); + const errorObj = { + status: 0, + message: error.message + }; + return [errorObj, undefined]; + } +} + +function showRecordingList(recordings) { + const recordingsList = document.getElementById("recording-list"); + + if (recordings.length === 0) { + recordingsList.innerHTML = "There are no recordings available"; + } else { + recordingsList.innerHTML = ""; + } + + recordings.forEach((recording) => { + const recordingName = recording.name; + const recordingDuration = secondsToHms(recording.duration ?? 0); + const recordingSize = formatBytes(recording.size ?? 0); + const recordingDate = new Date(recording.startedAt).toLocaleString(); + + const recordingContainer = document.createElement("div"); + recordingContainer.className = "recording-container"; + recordingContainer.id = recordingName; + + recordingContainer.innerHTML = ` + +
+

${recordingName}

+

${recordingDuration} | ${recordingSize}

+

${recordingDate}

+
+
+ + +
+ `; + + recordingsList.append(recordingContainer); + }); +} + +async function displayRecording(recordingName) { + const recordingVideoDialog = document.getElementById("recording-video-dialog"); + recordingVideoDialog.showModal(); + const recordingVideo = document.getElementById("recording-video"); + + const recordingUrl = await getRecordingUrl(recordingName); + recordingVideo.src = recordingUrl; +} + +function closeRecording() { + const recordingVideoDialog = document.getElementById("recording-video-dialog"); + recordingVideoDialog.close(); +} + +function removeAllRecordings() { + const recordingList = document.getElementById("recording-list").children; + Array.from(recordingList).forEach((recording) => { + recording.remove(); + }); +} + +function secondsToHms(seconds) { + const h = Math.floor(seconds / 3600); + const m = Math.floor((seconds % 3600) / 60); + const s = Math.floor((seconds % 3600) % 60); + + const hDisplay = h > 0 ? h + "h " : ""; + const mDisplay = m > 0 ? m + "m " : ""; + const sDisplay = s + "s"; + return hDisplay + mDisplay + sDisplay; +} + +function formatBytes(bytes) { + if (bytes === 0) { + return "0Bytes"; + } + + const k = 1024; + const sizes = ["Bytes", "KB", "MB", "GB"]; + const i = Math.floor(Math.log(bytes) / Math.log(k)); + const decimals = i < 2 ? 0 : 1; + + return (bytes / Math.pow(k, i)).toFixed(decimals) + sizes[i]; +} diff --git a/advanced-features/openvidu-recording-advanced-node-azure/public/images/favicon.ico b/advanced-features/openvidu-recording-advanced-node-azure/public/images/favicon.ico new file mode 100644 index 00000000..0e2249ad Binary files /dev/null and b/advanced-features/openvidu-recording-advanced-node-azure/public/images/favicon.ico differ diff --git a/advanced-features/openvidu-recording-advanced-node-azure/public/images/openvidu_logo.png b/advanced-features/openvidu-recording-advanced-node-azure/public/images/openvidu_logo.png new file mode 100644 index 00000000..e0309e62 Binary files /dev/null and b/advanced-features/openvidu-recording-advanced-node-azure/public/images/openvidu_logo.png differ diff --git a/advanced-features/openvidu-recording-advanced-node-azure/public/index.html b/advanced-features/openvidu-recording-advanced-node-azure/public/index.html new file mode 100644 index 00000000..9eab0532 --- /dev/null +++ b/advanced-features/openvidu-recording-advanced-node-azure/public/index.html @@ -0,0 +1,111 @@ + + + + OpenVidu Recording + + + + + + + + + + + + + + + + + +
+

OpenVidu Recording

+ +
+ +
+
+
+

Join a Video Room

+
+
+ + +
+
+ + +
+ +
+
+ View all recordings +
+ + +
+ + + + diff --git a/advanced-features/openvidu-recording-advanced-node-azure/public/recordings.html b/advanced-features/openvidu-recording-advanced-node-azure/public/recordings.html new file mode 100644 index 00000000..d7b40e4e --- /dev/null +++ b/advanced-features/openvidu-recording-advanced-node-azure/public/recordings.html @@ -0,0 +1,89 @@ + + + + OpenVidu Recording + + + + + + + + + + + + + + + + + +
+

OpenVidu Recording

+ +
+ +
+
+
+ +
+ + +
+
+ +

Recordings

+
+ + + + +
+
+ + + + diff --git a/advanced-features/openvidu-recording-advanced-node-azure/public/styles.css b/advanced-features/openvidu-recording-advanced-node-azure/public/styles.css new file mode 100644 index 00000000..86f3ef99 --- /dev/null +++ b/advanced-features/openvidu-recording-advanced-node-azure/public/styles.css @@ -0,0 +1,479 @@ +html { + height: 100%; +} + +body { + margin: 0; + padding: 0; + padding-top: 50px; + display: flex; + flex-direction: column; + height: 100%; +} + +header { + height: 50px; + width: 100%; + position: fixed; + top: 0; + left: 0; + z-index: 1; + display: flex; + justify-content: space-between; + align-items: center; + padding: 10px 30px; + background-color: #4d4d4d; +} + +header h1 { + margin: 0; + font-size: 1.5em; + font-weight: bold; +} + +header a { + color: #ccc; + text-decoration: none; +} + +header a:hover { + color: #a9a9a9; +} + +header i { + padding: 5px 5px; + font-size: 2em; +} + +main { + flex: 1; + padding: 20px; +} + +#join { + display: flex; + flex-direction: column; + justify-content: center; + align-items: center; + gap: 20px; + height: 100%; +} + +#join-dialog { + width: 70%; + max-width: 900px; + padding: 60px; + border-radius: 6px; + background-color: #f0f0f0; +} + +#join-dialog h2 { + color: #4d4d4d; + font-size: 60px; + font-weight: bold; + text-align: center; +} + +#join-dialog form { + text-align: left; +} + +#join-dialog label { + display: block; + margin-bottom: 10px; + color: #0088aa; + font-weight: bold; + font-size: 20px; +} + +.form-control { + width: 100%; + padding: 8px; + margin-bottom: 10px; + box-sizing: border-box; + color: #0088aa; + font-weight: bold; +} + +.form-control:focus { + color: #0088aa; + border-color: #0088aa; + -webkit-box-shadow: inset 0 1px 1px rgba(0, 0, 0, 0.075), 0 0 8px rgba(0, 136, 170, 0.6); + box-shadow: inset 0 1px 1px rgba(0, 0, 0, 0.075), 0 0 8px rgba(0, 136, 170, 0.6); +} + +#join-dialog button { + display: block; + margin: 20px auto 0; +} + +.btn { + font-weight: bold; +} + +.btn-success { + background-color: #06d362; + border-color: #06d362; +} + +.btn-success:hover { + background-color: #1abd61; + border-color: #1abd61; +} + +#room { + display: flex; + flex-direction: column; + justify-content: center; + align-items: center; +} + +#recording-text { + width: 100%; + max-width: 1000px; +} + +#recording-text span { + background-color: #ffeb3b; + color: #333; + border-radius: 5px; + padding: 0 5px; + font-weight: bold; + font-style: italic; + float: right; + margin-bottom: 10px; +} + +#room-header { + display: flex; + flex-wrap: wrap; + gap: 10px; + justify-content: space-between; + align-items: center; + width: 100%; + max-width: 1000px; + padding: 0 20px; + margin-bottom: 20px; +} + +#room-title { + font-size: 2em; + font-weight: bold; + margin: 0; +} + +#layout-container { + display: grid; + grid-template-columns: repeat(auto-fit, minmax(300px, 1fr)); + gap: 10px; + justify-content: center; + align-items: center; + width: 100%; + max-width: 1000px; + height: 100%; +} + +.video-container { + position: relative; + background: #3b3b3b; + aspect-ratio: 16/9; + border-radius: 6px; + overflow: hidden; +} + +.video-container video { + width: 100%; + height: 100%; +} + +.video-container .participant-data { + position: absolute; + top: 0; + left: 0; +} + +.participant-data p { + background: #f8f8f8; + margin: 0; + padding: 0 5px; + color: #777777; + font-weight: bold; + border-bottom-right-radius: 4px; +} + +#recordings { + display: flex; + flex-direction: column; + justify-content: center; + align-items: center; + width: 100%; + max-width: 1000px; +} + +#recording-header { + margin: 15px 0; + width: 100%; + display: grid; + grid-template-columns: 1fr 3fr 1fr; + align-items: center; + gap: 10px; +} + +#recording-header h3 { + margin: 0; + text-align: center; + font-size: 30px; + font-weight: bold; + color: #444; + grid-column-start: 2; +} + +#recording-header a { + margin-left: auto; +} + +#recording-list { + width: 600px; + max-width: 100%; +} + +#recording-list span { + font-size: 16px; + font-weight: bold; + font-style: italic; + color: #333; + display: block; + margin: 0; + text-align: center; +} + +.recording-container { + display: flex; + align-items: center; + border: 1px solid #dcdcdc; + border-radius: 5px; + padding: 10px; + background-color: #f4f4f4; + margin: 10px; +} + +.fa-file-video { + font-size: 30px; + color: #333; + margin-right: 10px; +} + +.recording-info { + flex-grow: 1; + font-size: 14px; + color: #333; +} + +.recording-info p { + margin: 0; +} + +.recording-name { + font-weight: bold; +} + +.recording-size, +.recording-date { + color: #777; +} + +.recording-date { + font-style: italic; +} + +.recording-actions { + display: flex; + align-items: center; +} + +.icon-button { + background-color: transparent; + border: none; + color: #333; + margin-left: 10px; + padding: 4px 12px; + text-align: center; + text-decoration: none; + display: inline-block; + font-size: 20px; + cursor: pointer; + border-radius: 50%; + transition: background-color 0.3s ease; +} + +.icon-button:hover { + background-color: #e0e0e0; +} + +.delete-button { + color: #d9534f; +} + +#recording-video-dialog { + width: 500px; + max-width: 90%; + border: none; + border-radius: 8px; + box-shadow: 0 4px 8px rgba(0, 0, 0, 0.2); + padding: 20px; + background-color: #fff; +} + +#recording-video { + width: 100%; + border-radius: 5px; +} + +#close-recording-video-dialog { + margin-top: 10px; + float: right; +} + +footer { + height: 60px; + width: 100%; + padding: 10px 30px; + display: flex; + justify-content: space-between; + align-items: center; + background-color: #4d4d4d; +} + +footer a { + color: #ffffff; + text-decoration: none; +} + +footer .text { + color: #ccc; + margin: 0; +} + +footer .text span { + color: white; + font-weight: bold; +} + +#openvidu-logo { + height: 35px; + -webkit-transition: all 0.1s ease-in-out; + -moz-transition: all 0.1s ease-in-out; + -o-transition: all 0.1s ease-in-out; + transition: all 0.1s ease-in-out; +} + +#openvidu-logo:hover { + -webkit-filter: grayscale(0.5); + filter: grayscale(0.5); +} + +/* Media Queries */ +@media screen and (max-width: 768px) { + header { + padding: 10px 15px; + } + + #join-dialog { + width: 90%; + padding: 30px; + } + + #join-dialog h2 { + font-size: 50px; + } + + #layout-container { + grid-template-columns: repeat(auto-fit, minmax(250px, 1fr)); + } + + footer { + padding: 10px 15px; + } +} + +@media screen and (max-width: 480px) { + header { + padding: 10px; + } + + #join-dialog { + width: 100%; + padding: 20px; + } + + #join-dialog h2 { + font-size: 40px; + } + + #layout-container { + grid-template-columns: repeat(auto-fit, minmax(150px, 1fr)); + } + + .video-container { + aspect-ratio: 9/16; + } + + footer { + padding: 10px; + } +} + +/* Recordings page styles */ +#actions { + display: flex; + justify-content: flex-end; + align-items: center; + gap: 10px; + width: 100%; + max-width: 1000px; + margin-bottom: 20px; +} + +#refresh-button { + margin: 0; + padding: 8px 13px; +} + +form input { + padding: 8px; + font-size: 16px; + border: 1px solid #ccc; + border-radius: 5px 0 0 5px; +} + +form button { + padding: 8px; + font-size: 16px; + border: 1px solid #ccc; + border-left: none; + background-color: #007bff; + color: #fff; + cursor: pointer; + border-radius: 0 5px 5px 0; +} + +.search-form button:hover { + background-color: #0056b3; +} + +#recordings-all { + display: flex; + flex-direction: column; + justify-content: center; + align-items: center; +} + +#recordings-all h2 { + width: 100%; + max-width: 1000px; + margin-bottom: 20px; + font-size: 40px; + font-weight: bold; + text-align: center; + color: #444; +} diff --git a/advanced-features/openvidu-recording-advanced-node-azure/src/config.js b/advanced-features/openvidu-recording-advanced-node-azure/src/config.js new file mode 100644 index 00000000..87ec21cd --- /dev/null +++ b/advanced-features/openvidu-recording-advanced-node-azure/src/config.js @@ -0,0 +1,25 @@ +export const SERVER_PORT = process.env.SERVER_PORT || 6080; +export const APP_NAME = "openvidu-recording-advanced-node"; + +// LiveKit configuration +export const LIVEKIT_URL = process.env.LIVEKIT_URL || "http://localhost:7880"; +export const LIVEKIT_API_KEY = process.env.LIVEKIT_API_KEY || "devkey"; +export const LIVEKIT_API_SECRET = process.env.LIVEKIT_API_SECRET || "secret"; + +// S3 configuration +export const S3_ENDPOINT = process.env.S3_ENDPOINT || "http://localhost:9000"; +export const S3_ACCESS_KEY = process.env.S3_ACCESS_KEY || "minioadmin"; +export const S3_SECRET_KEY = process.env.S3_SECRET_KEY || "minioadmin"; +export const AWS_REGION = process.env.AWS_REGION || "us-east-1"; +export const S3_BUCKET = process.env.S3_BUCKET || "openvidu"; + +// Azure Blob Storage configuration +export const AZURE_ACCOUNT_NAME = process.env.AZURE_ACCOUNT_NAME || "your_account_name"; +export const AZURE_ACCOUNT_KEY = process.env.AZURE_ACCOUNT_KEY || "your_account_key"; +export const AZURE_CONTAINER_NAME = process.env.AZURE_CONTAINER_NAME || "openvidu-appdata"; +export const AZURE_ENDPOINT = process.env.AZURE_ENDPOINT || `https://${AZURE_ACCOUNT_NAME}.blob.core.windows.net`; + +export const RECORDINGS_PATH = process.env.RECORDINGS_PATH ?? "recordings/"; +export const RECORDINGS_METADATA_PATH = ".metadata/"; +export const RECORDING_PLAYBACK_STRATEGY = process.env.RECORDING_PLAYBACK_STRATEGY || "S3"; // PROXY or S3 +export const RECORDING_FILE_PORTION_SIZE = 5 * 1024 * 1024; // 5MB diff --git a/advanced-features/openvidu-recording-advanced-node-azure/src/controllers/recording.controller.js b/advanced-features/openvidu-recording-advanced-node-azure/src/controllers/recording.controller.js new file mode 100644 index 00000000..ecac1868 --- /dev/null +++ b/advanced-features/openvidu-recording-advanced-node-azure/src/controllers/recording.controller.js @@ -0,0 +1,154 @@ +import { Router } from "express"; +import { RecordingService } from "../services/recording.service.js"; +import { RoomService } from "../services/room.service.js"; +import { RECORDING_PLAYBACK_STRATEGY } from "../config.js"; + +const recordingService = new RecordingService(); +const roomService = new RoomService(); + +export const recordingController = Router(); + +recordingController.post("/start", async (req, res) => { + const { roomName } = req.body; + + if (!roomName) { + res.status(400).json({ errorMessage: "roomName is required" }); + return; + } + + const activeRecording = await recordingService.getActiveRecordingByRoom(roomName); + + // Check if there is already an active recording for this room + if (activeRecording) { + res.status(409).json({ errorMessage: "Recording already started for this room" }); + return; + } + + try { + const recording = recordingService.startRecording(roomName); + res.json({ message: "Recording started", recording }); + } catch (error) { + console.error("Error starting recording.", error); + res.status(500).json({ errorMessage: "Error starting recording" }); + } +}); + +recordingController.post("/stop", async (req, res) => { + const { roomName } = req.body; + + if (!roomName) { + res.status(400).json({ errorMessage: "roomName is required" }); + return; + } + + const activeRecording = await recordingService.getActiveRecordingByRoom(roomName); + + // Check if there is an active recording for this room + if (!activeRecording) { + res.status(409).json({ errorMessage: "Recording not started for this room" }); + return; + } + + try { + const recording = await recordingService.stopRecording(activeRecording); + res.json({ message: "Recording stopped", recording }); + } catch (error) { + console.error("Error stopping recording.", error); + res.status(500).json({ errorMessage: "Error stopping recording" }); + } +}); + +recordingController.get("/", async (req, res) => { + const roomName = req.query.roomName?.toString(); + const roomId = req.query.roomId?.toString(); + + try { + const recordings = await recordingService.listRecordings(roomName, roomId); + res.json({ recordings }); + } catch (error) { + console.error("Error listing recordings.", error); + res.status(500).json({ errorMessage: "Error listing recordings" }); + } +}); + +recordingController.get("/:recordingName", async (req, res) => { + const { recordingName } = req.params; + const { range } = req.headers; + const exists = await recordingService.existsRecording(recordingName); + + if (!exists) { + res.status(404).json({ errorMessage: "Recording not found" }); + return; + } + + try { + // Get the recording file from Azure Blob Storage + const { stream, size, start, end } = await recordingService.getRecordingStream(recordingName, range); + + // Set response headers + res.status(206); + res.setHeader("Cache-Control", "no-cache"); + res.setHeader("Content-Type", "video/mp4"); + res.setHeader("Accept-Ranges", "bytes"); + res.setHeader("Content-Range", `bytes ${start}-${end}/${size}`); + res.setHeader("Content-Length", end - start + 1); + + // Pipe the recording file to the response + stream.pipe(res).on("finish", () => res.end()); + } catch (error) { + console.error("Error getting recording.", error); + res.status(500).json({ errorMessage: "Error getting recording" }); + } +}); + +recordingController.get("/:recordingName/url", async (req, res) => { + const { recordingName } = req.params; + const exists = await recordingService.existsRecording(recordingName); + + if (!exists) { + res.status(404).json({ errorMessage: "Recording not found" }); + return; + } + + // If the recording playback strategy is "PROXY", return the endpoint URL + if (RECORDING_PLAYBACK_STRATEGY === "PROXY") { + res.json({ recordingUrl: `/recordings/${recordingName}` }); + return; + } + + try { + // If the recording playback strategy is "Azure Blob Storage", return a signed URL to access the recording directly from Azure Blob Storage + const recordingUrl = await recordingService.getRecordingUrl(recordingName); + res.json({ recordingUrl }); + } catch (error) { + console.error("Error getting recording URL.", error); + res.status(500).json({ errorMessage: "Error getting recording URL" }); + } +}); + +recordingController.delete("/:recordingName", async (req, res) => { + const { recordingName } = req.params; + const exists = await recordingService.existsRecording(recordingName); + + if (!exists) { + res.status(404).json({ errorMessage: "Recording not found" }); + return; + } + + try { + const { roomName } = await recordingService.getRecordingMetadata(recordingName); + await recordingService.deleteRecording(recordingName); + + // Notify to all participants that the recording was deleted + const existsRoom = await roomService.exists(roomName); + + if (existsRoom) { + await roomService.sendDataToRoom(roomName, { recordingName }); + } + + res.json({ message: "Recording deleted" }); + } catch (error) { + console.error("Error deleting recording.", error); + res.status(500).json({ errorMessage: "Error deleting recording" }); + } +}); diff --git a/advanced-features/openvidu-recording-advanced-node-azure/src/controllers/room.controller.js b/advanced-features/openvidu-recording-advanced-node-azure/src/controllers/room.controller.js new file mode 100644 index 00000000..958265e2 --- /dev/null +++ b/advanced-features/openvidu-recording-advanced-node-azure/src/controllers/room.controller.js @@ -0,0 +1,38 @@ +import { Router } from "express"; +import { AccessToken } from "livekit-server-sdk"; +import { LIVEKIT_API_KEY, LIVEKIT_API_SECRET } from "../config.js"; +import { RoomService } from "../services/room.service.js"; + +const roomService = new RoomService(); + +export const roomController = Router(); + +roomController.post("/", async (req, res) => { + const roomName = req.body.roomName; + const participantName = req.body.participantName; + + if (!roomName || !participantName) { + res.status(400).json({ errorMessage: "roomName and participantName are required" }); + return; + } + + const at = new AccessToken(LIVEKIT_API_KEY, LIVEKIT_API_SECRET, { + identity: participantName + }); + at.addGrant({ room: roomName, roomJoin: true, roomRecord: true }); + const token = await at.toJwt(); + + try { + // Create room if it doesn't exist + const exists = await roomService.exists(roomName); + + if (!exists) { + await roomService.createRoom(roomName); + } + + res.json({ token }); + } catch (error) { + console.error("Error creating room.", error); + res.status(500).json({ errorMessage: "Error creating room" }); + } +}); diff --git a/advanced-features/openvidu-recording-advanced-node-azure/src/controllers/webhook.controller.js b/advanced-features/openvidu-recording-advanced-node-azure/src/controllers/webhook.controller.js new file mode 100644 index 00000000..a2a81817 --- /dev/null +++ b/advanced-features/openvidu-recording-advanced-node-azure/src/controllers/webhook.controller.js @@ -0,0 +1,76 @@ +import express, { Router } from "express"; +import { WebhookReceiver } from "livekit-server-sdk"; +import { LIVEKIT_API_KEY, LIVEKIT_API_SECRET, APP_NAME } from "../config.js"; +import { RoomService } from "../services/room.service.js"; +import { RecordingService } from "../services/recording.service.js"; + +const webhookReceiver = new WebhookReceiver(LIVEKIT_API_KEY, LIVEKIT_API_SECRET); +const roomService = new RoomService(); +const recordingService = new RecordingService(); + +export const webhookController = Router(); +webhookController.use(express.raw({ type: "application/webhook+json" })); + +webhookController.post("/", async (req, res) => { + try { + const webhookEvent = await webhookReceiver.receive(req.body, req.get("Authorization")); + const isWebhookRelatedToMe = await checkWebhookRelatedToMe(webhookEvent); + + if (isWebhookRelatedToMe) { + console.log(webhookEvent); + const { event: eventType, egressInfo } = webhookEvent; + + switch (eventType) { + case "egress_started": + case "egress_updated": + await notifyRecordingStatusUpdate(egressInfo); + break; + case "egress_ended": + await handleEgressEnded(egressInfo); + break; + } + } + } catch (error) { + console.error("Error validating webhook event.", error); + } + + res.status(200).send(); +}); + +const checkWebhookRelatedToMe = async (webhookEvent) => { + const { room, egressInfo, ingressInfo } = webhookEvent; + let roomInfo = room; + + if (!room || !room.metadata) { + const roomName = room?.name ?? egressInfo?.roomName ?? ingressInfo?.roomName; + roomInfo = await roomService.getRoom(roomName); + + if (!roomInfo) { + return false; + } + } + + const metadata = roomInfo.metadata ? JSON.parse(roomInfo.metadata) : null; + return metadata?.createdBy === APP_NAME; +}; + +const handleEgressEnded = async (egressInfo) => { + try { + await recordingService.saveRecordingMetadata(egressInfo); + } catch (error) { + console.error("Error saving recording metadata.", error); + } + + await notifyRecordingStatusUpdate(egressInfo); +}; + +const notifyRecordingStatusUpdate = async (egressInfo) => { + const roomName = egressInfo.roomName; + const recordingStatus = recordingService.getRecordingStatus(egressInfo.status); + + try { + await roomService.updateRoomMetadata(roomName, recordingStatus); + } catch (error) { + console.error("Error updating room metadata.", error); + } +}; diff --git a/advanced-features/openvidu-recording-advanced-node-azure/src/index.js b/advanced-features/openvidu-recording-advanced-node-azure/src/index.js new file mode 100644 index 00000000..120eff86 --- /dev/null +++ b/advanced-features/openvidu-recording-advanced-node-azure/src/index.js @@ -0,0 +1,27 @@ +import "dotenv/config.js"; +import express from "express"; +import cors from "cors"; +import path from "path"; +import { fileURLToPath } from "url"; +import { SERVER_PORT } from "./config.js"; +import { roomController } from "./controllers/room.controller.js"; +import { recordingController } from "./controllers/recording.controller.js"; +import { webhookController } from "./controllers/webhook.controller.js"; + +const app = express(); + +app.use(cors()); +app.use(express.json()); + +// Set the static files location +const __filename = fileURLToPath(import.meta.url); +const __dirname = path.dirname(__filename); +app.use(express.static(path.join(__dirname, "../public"))); + +app.use("/token", roomController); +app.use("/recordings", recordingController); +app.use("/livekit/webhook", webhookController); + +app.listen(SERVER_PORT, () => { + console.log("Server started on port:", SERVER_PORT); +}); diff --git a/advanced-features/openvidu-recording-advanced-node-azure/src/services/azure.blobstorage.service.js b/advanced-features/openvidu-recording-advanced-node-azure/src/services/azure.blobstorage.service.js new file mode 100644 index 00000000..319c1f75 --- /dev/null +++ b/advanced-features/openvidu-recording-advanced-node-azure/src/services/azure.blobstorage.service.js @@ -0,0 +1,147 @@ +import { + BlobServiceClient, + StorageSharedKeyCredential, + generateBlobSASQueryParameters, + BlobSASPermissions, + SASProtocol +} from "@azure/storage-blob"; +import { + AZURE_CONTAINER_NAME, + AZURE_ACCOUNT_NAME, + AZURE_ACCOUNT_KEY, + AZURE_ENDPOINT +} from "../config.js"; + +export class AzureBlobService { + static instance; + + constructor() { + if (AzureBlobService.instance) { + return AzureBlobService.instance; + } + const sharedKeyCredential = new StorageSharedKeyCredential( + AZURE_ACCOUNT_NAME, + AZURE_ACCOUNT_KEY + ); + + this.blobServiceClient = new BlobServiceClient( + AZURE_ENDPOINT, + sharedKeyCredential + ); + + this.containerClient = this.blobServiceClient.getContainerClient( + AZURE_CONTAINER_NAME + ); + + AzureBlobService.instance = this; + return this; + } + + static getInstance() { + if (!AzureBlobService.instance) { + AzureBlobService.instance = new AzureBlobService(); + } + return AzureBlobService.instance; + } + + // Sube un objeto (JSON) al contenedor + async uploadObject(key, body) { + const blockBlobClient = this.containerClient.getBlockBlobClient(key); + const data = JSON.stringify(body); + await blockBlobClient.upload(data, Buffer.byteLength(data)); + } + + // Comprueba si existe un blob + async exists(key) { + const blobClient = this.containerClient.getBlobClient(key); + return await blobClient.exists(); + } + + // Obtiene las propiedades del blob (equivalente a headObject) + async headObject(key) { + const blobClient = this.containerClient.getBlobClient(key); + return await blobClient.getProperties(); + } + + // Devuelve el tamaño del blob en bytes + async getObjectSize(key) { + const props = await this.headObject(key); + return props.contentLength || 0; + } + + // Descarga el blob completo o un rango, devolviendo el stream + async getObject(key, range) { + const blobClient = this.containerClient.getBlobClient(key); + let downloadResponse; + if (range) { + // range = { start: number, end: number } + const count = range.end - range.start + 1; + downloadResponse = await blobClient.download(range.start, count); + } else { + downloadResponse = await blobClient.download(); + } + if (!downloadResponse.readableStreamBody) { + throw new Error("No se pudo obtener el stream del blob"); + } + return downloadResponse.readableStreamBody; + } + + // Genera un URL SAS válido 24 horas + async getObjectUrl(key) { + if (!AZURE_ACCOUNT_NAME || !AZURE_ACCOUNT_KEY) { + throw new Error("Credenciales de cuenta de Azure no están definidas para generar SAS"); + } + const blobClient = this.containerClient.getBlobClient(key); + const expiresOn = new Date(new Date().valueOf() + 24 * 60 * 60 * 1000); // 24 horas + const sasPermissions = BlobSASPermissions.parse("r"); + const sasToken = generateBlobSASQueryParameters( + { + containerName: AZURE_CONTAINER_NAME, + blobName: key, + expiresOn, + permissions: sasPermissions, + protocol: SASProtocol.Https + }, + new StorageSharedKeyCredential(AZURE_ACCOUNT_NAME, AZURE_ACCOUNT_KEY) + ).toString(); + + return `${blobClient.url}?${sasToken}`; + } + + // Obtiene el contenido JSON del blob + async getObjectAsJson(key) { + const exists = await this.exists(key); + if (!exists) { + return undefined; + } + const stream = await this.getObject(key); + return new Promise((resolve, reject) => { + const chunks = []; + stream.on("data", (data) => { + chunks.push(Buffer.isBuffer(data) ? data : Buffer.from(data)); + }); + stream.on("end", () => { + const content = Buffer.concat(chunks).toString("utf-8"); + resolve(JSON.parse(content)); + }); + stream.on("error", reject); + }); + } + + // Lista blobs bajo un prefijo y filtra por expresión regular + async listObjects(prefix, regex) { + const results = []; + for await (const blob of this.containerClient.listBlobsFlat({ prefix })) { + if (blob.name && regex.test(blob.name)) { + results.push(blob.name); + } + } + return results; + } + + // Elimina un blob + async deleteObject(key) { + const blobClient = this.containerClient.getBlobClient(key); + await blobClient.delete(); + } +} diff --git a/advanced-features/openvidu-recording-advanced-node-azure/src/services/recording.service.js b/advanced-features/openvidu-recording-advanced-node-azure/src/services/recording.service.js new file mode 100644 index 00000000..adadea2c --- /dev/null +++ b/advanced-features/openvidu-recording-advanced-node-azure/src/services/recording.service.js @@ -0,0 +1,157 @@ +import { EgressClient, EgressStatus, EncodedFileOutput, EncodedFileType } from "livekit-server-sdk"; +import { + LIVEKIT_URL, + LIVEKIT_API_KEY, + LIVEKIT_API_SECRET, + RECORDINGS_PATH, + RECORDINGS_METADATA_PATH, + RECORDING_FILE_PORTION_SIZE +} from "../config.js"; +import { AzureBlobService } from "./azure.blobstorage.service.js"; + +const azureBlobService = new AzureBlobService(); + +export class RecordingService { + static instance; + + constructor() { + if (RecordingService.instance) { + return RecordingService.instance; + } + + this.egressClient = new EgressClient(LIVEKIT_URL, LIVEKIT_API_KEY, LIVEKIT_API_SECRET); + RecordingService.instance = this; + return this; + } + + async startRecording(roomName) { + // Use the EncodedFileOutput to save the recording to an MP4 file + const fileOutput = new EncodedFileOutput({ + fileType: EncodedFileType.MP4, + filepath: `${RECORDINGS_PATH}{room_name}-{room_id}-{time}`, + disableManifest: true + }); + // Start a RoomCompositeEgress to record all participants in the room + const egressInfo = await this.egressClient.startRoomCompositeEgress(roomName, { file: fileOutput }); + return this.convertToRecordingInfo(egressInfo); + } + + async stopRecording(recordingId) { + // Stop the egress to finish the recording + const egressInfo = await this.egressClient.stopEgress(recordingId); + return this.convertToRecordingInfo(egressInfo); + } + + async listRecordings(roomName, roomId) { + const keyStart = + RECORDINGS_PATH + RECORDINGS_METADATA_PATH + (roomName ? `${roomName}-` + (roomId ? roomId : "") : ""); + const keyEnd = ".json"; + const regex = new RegExp(`^${keyStart}.*${keyEnd}$`); + + // List all egress metadata files in the recordings path that match the regex + const metadataKeys = await azureBlobService.listObjects(RECORDINGS_PATH + RECORDINGS_METADATA_PATH, regex); + const recordings = await Promise.all(metadataKeys.map((metadataKey) => azureBlobService.getObjectAsJson(metadataKey))); + return this.filterAndSortRecordings(recordings, roomName, roomId); + } + + filterAndSortRecordings(recordings, roomName, roomId) { + let filteredRecordings = recordings; + + if (roomName || roomId) { + filteredRecordings = recordings.filter((recording) => { + return (!roomName || recording.roomName === roomName) && (!roomId || recording.roomId === roomId); + }); + } + + return filteredRecordings.sort((a, b) => b.startedAt - a.startedAt); + } + + async getActiveRecordingByRoom(roomName) { + try { + // List all active egresses for the room + const egresses = await this.egressClient.listEgress({ roomName, active: true }); + return egresses.length > 0 ? egresses[0].egressId : null; + } catch (error) { + console.error("Error listing egresses.", error); + return null; + } + } + + async getRecordingMetadata(recordingName) { + const key = this.getMetadataKey(recordingName); + return azureBlobService.getObjectAsJson(key); + } + + async getRecordingStream(recordingName, range) { + const key = this.getRecordingKey(recordingName); + const size = await azureBlobService.getObjectSize(key); + + // Get the requested range + const parts = range?.replace(/bytes=/, "").split("-"); + const start = range ? parseInt(parts[0], 10) : 0; + const endRange = parts[1] ? parseInt(parts[1], 10) : start + RECORDING_FILE_PORTION_SIZE; + const end = Math.min(endRange, size - 1); + + const stream = await azureBlobService.getObject(key, { start, end }); + return { stream, size, start, end }; + } + + async getRecordingUrl(recordingName) { + const key = this.getRecordingKey(recordingName); + return azureBlobService.getObjectUrl(key); + } + + async existsRecording(recordingName) { + const key = this.getRecordingKey(recordingName); + return azureBlobService.exists(key); + } + + async deleteRecording(recordingName) { + const recordingKey = this.getRecordingKey(recordingName); + const metadataKey = this.getMetadataKey(recordingName); + // Delete the recording file and metadata file from Azure + await Promise.all([azureBlobService.deleteObject(recordingKey), azureBlobService.deleteObject(metadataKey)]); + } + + async saveRecordingMetadata(egressInfo) { + const recordingInfo = this.convertToRecordingInfo(egressInfo); + const key = this.getMetadataKey(recordingInfo.name); + await azureBlobService.uploadObject(key, recordingInfo); + } + + convertToRecordingInfo(egressInfo) { + const file = egressInfo.fileResults[0]; + return { + id: egressInfo.egressId, + name: file.filename.split("/").pop(), + roomName: egressInfo.roomName, + roomId: egressInfo.roomId, + startedAt: Number(egressInfo.startedAt) / 1_000_000, + duration: Number(file.duration) / 1_000_000_000, + size: Number(file.size) + }; + } + + getRecordingStatus(egressStatus) { + switch (egressStatus) { + case EgressStatus.EGRESS_STARTING: + return "STARTING"; + case EgressStatus.EGRESS_ACTIVE: + return "STARTED"; + case EgressStatus.EGRESS_ENDING: + return "STOPPING"; + case EgressStatus.EGRESS_COMPLETE: + return "STOPPED"; + default: + return "FAILED"; + } + } + + getRecordingKey(recordingName) { + return RECORDINGS_PATH + recordingName; + } + + getMetadataKey(recordingName) { + return RECORDINGS_PATH + RECORDINGS_METADATA_PATH + recordingName.replace(".mp4", ".json"); + } +} diff --git a/advanced-features/openvidu-recording-advanced-node-azure/src/services/room.service.js b/advanced-features/openvidu-recording-advanced-node-azure/src/services/room.service.js new file mode 100644 index 00000000..2e057580 --- /dev/null +++ b/advanced-features/openvidu-recording-advanced-node-azure/src/services/room.service.js @@ -0,0 +1,61 @@ +import { DataPacket_Kind, RoomServiceClient } from "livekit-server-sdk"; +import { LIVEKIT_URL, LIVEKIT_API_KEY, LIVEKIT_API_SECRET, APP_NAME } from "../config.js"; + +const encoder = new TextEncoder(); + +export class RoomService { + static instance; + + constructor() { + if (RoomService.instance) { + return RoomService.instance; + } + + this.roomClient = new RoomServiceClient(LIVEKIT_URL, LIVEKIT_API_KEY, LIVEKIT_API_SECRET); + RoomService.instance = this; + return this; + } + + async createRoom(roomName) { + const roomOptions = { + name: roomName, + metadata: JSON.stringify({ + createdBy: APP_NAME, + recordingStatus: "STOPPED" + }) + }; + return this.roomClient.createRoom(roomOptions); + } + + async getRoom(roomName) { + const rooms = await this.roomClient.listRooms([roomName]); + return rooms.length > 0 ? rooms[0] : null; + } + + async exists(roomName) { + const room = await this.getRoom(roomName); + return room !== null; + } + + async updateRoomMetadata(roomName, recordingStatus) { + const metadata = { + createdBy: APP_NAME, + recordingStatus + }; + return this.roomClient.updateRoomMetadata(roomName, JSON.stringify(metadata)); + } + + async sendDataToRoom(roomName, rawData) { + const data = encoder.encode(JSON.stringify(rawData)); + const options = { + topic: "RECORDING_DELETED", + destinationSids: [] + }; + + try { + await this.roomClient.sendData(roomName, data, DataPacket_Kind.RELIABLE, options); + } catch (error) { + console.error("Error sending data to room", error); + } + } +}