RageStudio/comty
1
0
Fork 0
mirror of https://github.com/ragestudio/comty.git synced 2025-06-10 02:54:15 +00:00
Code Issues Packages Projects Releases Wiki Activity

implement streaming categories endpoints

Browse Source
This commit is contained in:
SrGooglo 2022-11-28 16:17:25 +00:00 committed by root
parent beaca8a9de
commit e9b39ea63b
1 changed files with 53 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

56
packages/server/src/controllers/StreamingController/index.js
View File

@ -3,7 +3,8 @@ import { nanoid } from "nanoid"
import lodash from "lodash"
import axios from "axios"
import { User, StreamingKey, StreamingInfo } from "../../models"
import { Schematized } from "../../lib"
import { User, StreamingKey, StreamingInfo, StreamingCategory } from "../../models"
const streamingIngestServer = process.env.STREAMING_INGEST_SERVER
const streamingServerAPIAddress = process.env.STREAMING_API_SERVER
@ -147,6 +148,11 @@ export default class StreamingController extends Controller {
}
get = {
"/streaming/categories": async (req, res) => {
const categories = await StreamingCategory.find()
return res.json(categories)
},
"/streams": async (req, res) => {
await this.methods.regenerateStreamingList()
@ -161,6 +167,10 @@ export default class StreamingController extends Controller {
if (info) {
stream.info = info.toObject()
stream.info.category = await StreamingCategory.findOne({
key: stream.info.category
})
}
return stream
@ -189,11 +199,21 @@ export default class StreamingController extends Controller {
user_id = user_id["_id"].toString()
}
const info = await StreamingInfo.findOne({
let info = await StreamingInfo.findOne({
user_id,
})
return res.json(info)
const category = await StreamingCategory.findOne({
key: info.category
})
return res.json({
...info.toObject(),
["category"]: {
key: category.key,
label: category.label,
}
})
}
},
"/streaming/addresses": {
@ -257,6 +277,36 @@ export default class StreamingController extends Controller {
},
}
put = {
"/streaming/category": {
middlewares: ["withAuthentication", "onlyAdmin"],
fn: Schematized({
required: ["key", "label"]
}, async (req, res) => {
const { key, label } = req.selection
const existingCategory = await StreamingCategory.findOne({
key
})
if (existingCategory) {
return res.status(400).json({
error: "Category already exists"
})
}
const category = new StreamingCategory({
key,
label,
})
await category.save()
return res.json(category)
})
}
}
post = {
"/streaming/update_info": {
middlewares: ["withAuthentication"],