neoris/openvidu-livekit-tutorials
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Refactor egress controller in Node.js API to improve variable naming and update endpoint path to add/remove stream URLs to an egress

Browse Source
This commit is contained in:
juancarmore 2025-02-24 15:03:05 +01:00
parent 2780be22e5
commit 9f5e17519d
2 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
application-server/application-server-tutorials.postman_collection.json
View File

@ -538,13 +538,13 @@
}
},
"url": {
"raw": "{{EGRESS_URL}}/{{EGRESS_ID}}/stream",
"raw": "{{EGRESS_URL}}/{{EGRESS_ID}}/streams",
"host": [
"{{EGRESS_URL}}"
],
"path": [
"{{EGRESS_ID}}",
"stream"
"streams"
]
}
},

12
application-server/node/src/controllers/egress.controller.js
View File

@ -203,8 +203,8 @@ egressController.post("/:egressId/layout", async (req, res) => {
}
try {
const egressInfo = await egressClient.updateLayout(egressId, layout);
res.json({ egressInfo });
const egress = await egressClient.updateLayout(egressId, layout);
res.json({ egress });
} catch (error) {
const errorMessage = "Error updating egress layout";
console.error(errorMessage, error);
@ -213,7 +213,7 @@ egressController.post("/:egressId/layout", async (req, res) => {
});
// Add/remove stream URLs to an egress
egressController.post("/:egressId/stream", async (req, res) => {
egressController.post("/:egressId/streams", async (req, res) => {
const { egressId } = req.params;
const { streamUrlsToAdd, streamUrlsToRemove } = req.body;
@ -223,8 +223,8 @@ egressController.post("/:egressId/stream", async (req, res) => {
}
try {
const egressInfo = await egressClient.updateStream(egressId, streamUrlsToAdd, streamUrlsToRemove);
res.json({ egressInfo });
const egress = await egressClient.updateStream(egressId, streamUrlsToAdd, streamUrlsToRemove);
res.json({ egress });
} catch (error) {
const errorMessage = "Error updating egress streams";
console.error(errorMessage, error);
@ -237,7 +237,7 @@ egressController.delete("/:egressId", async (req, res) => {
const { egressId } = req.params;
try {
const egressInfo = await egressClient.stopEgress(egressId);
await egressClient.stopEgress(egressId);
res.json({ message: "Egress stopped" });
} catch (error) {
const errorMessage = "Error stopping egress";