mirror of
https://github.com/ragestudio/comty.git
synced 2025-06-10 19:14:16 +00:00
get streams from username
This commit is contained in:
parent
cdce50bdd0
commit
15041c266d
@ -136,14 +136,14 @@ class StreamingServer {
|
||||
"/streams": {
|
||||
method: "get",
|
||||
fn: async (req, res) => {
|
||||
if (req.query?.user_id) {
|
||||
const streams = await this.Sessions.getStreamsByUserId(req.query.user_id)
|
||||
let streams = []
|
||||
|
||||
return res.json(streams)
|
||||
if (req.query?.username) {
|
||||
streams = await this.Sessions.getStreamsByUsername(req.query?.username)
|
||||
} else {
|
||||
streams = this.Sessions.getPublicStreams()
|
||||
}
|
||||
|
||||
let streams = this.Sessions.getPublicStreams()
|
||||
|
||||
// retrieve streams details from internal media server api
|
||||
let streamsListDetails = await axios.get(`${internalMediaServerURI}/api/streams`)
|
||||
|
||||
@ -172,6 +172,12 @@ class StreamingServer {
|
||||
}
|
||||
})
|
||||
|
||||
// if username is provided, return only streams for that user
|
||||
// is supposed to be allowed only one stream per user
|
||||
if (req.query?.username) {
|
||||
return res.json(streams[0])
|
||||
}
|
||||
|
||||
return res.json(streams)
|
||||
}
|
||||
},
|
||||
|
Loading…
x
Reference in New Issue
Block a user