mirror of
https://github.com/ragestudio/comty.js.git
synced 2025-06-09 02:24:18 +00:00
Route Spectrum API through main API in development
This commit is contained in:
parent
2dbf36fe4f
commit
f1f7c03470
@ -1,5 +1,7 @@
|
|||||||
import axios from "axios"
|
import axios from "axios"
|
||||||
import { RTEngineClient } from "linebridge-client/src"
|
import request from "../../request"
|
||||||
|
|
||||||
|
import { RTEngineClient } from "linebridge-client"
|
||||||
|
|
||||||
import SessionModel from "../session"
|
import SessionModel from "../session"
|
||||||
import UserModel from "../user"
|
import UserModel from "../user"
|
||||||
@ -36,34 +38,12 @@ async function injectUserDataOnList(list) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
export default class Streaming {
|
export default class Streaming {
|
||||||
static apiHostname = "https://live.ragestudio.net"
|
static get baseUrl() {
|
||||||
|
if (process.env.NODE_ENV === "production") {
|
||||||
static get base() {
|
return "https://live.ragestudio.net"
|
||||||
const baseInstance = axios.create({
|
|
||||||
baseURL: Streaming.apiHostname,
|
|
||||||
headers: {
|
|
||||||
Accept: "application/json",
|
|
||||||
"ngrok-skip-browser-warning": "any",
|
|
||||||
},
|
|
||||||
})
|
|
||||||
|
|
||||||
if (SessionModel.token) {
|
|
||||||
baseInstance.defaults.headers.common["Authorization"] =
|
|
||||||
`Bearer ${SessionModel.token}`
|
|
||||||
}
|
}
|
||||||
|
|
||||||
return baseInstance
|
return __comty_shared_state.baseRequest.defaults.baseURL + "/spectrum"
|
||||||
}
|
|
||||||
|
|
||||||
static async serverInfo() {
|
|
||||||
const { data } = await Streaming.base({
|
|
||||||
method: "get",
|
|
||||||
})
|
|
||||||
|
|
||||||
return {
|
|
||||||
...data,
|
|
||||||
hostname: Streaming.apiHostname,
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
static async getStream(stream_id) {
|
static async getStream(stream_id) {
|
||||||
@ -71,7 +51,8 @@ export default class Streaming {
|
|||||||
return null
|
return null
|
||||||
}
|
}
|
||||||
|
|
||||||
const { data } = await Streaming.base({
|
const { data } = await request({
|
||||||
|
baseURL: Streaming.baseUrl,
|
||||||
method: "get",
|
method: "get",
|
||||||
url: `/stream/${stream_id}/data`,
|
url: `/stream/${stream_id}/data`,
|
||||||
})
|
})
|
||||||
@ -80,7 +61,8 @@ export default class Streaming {
|
|||||||
}
|
}
|
||||||
|
|
||||||
static async getOwnProfiles() {
|
static async getOwnProfiles() {
|
||||||
const { data } = await Streaming.base({
|
const { data } = await request({
|
||||||
|
baseURL: Streaming.baseUrl,
|
||||||
method: "GET",
|
method: "GET",
|
||||||
url: "/streaming/profiles/self",
|
url: "/streaming/profiles/self",
|
||||||
})
|
})
|
||||||
@ -93,7 +75,8 @@ export default class Streaming {
|
|||||||
return null
|
return null
|
||||||
}
|
}
|
||||||
|
|
||||||
const { data } = await Streaming.base({
|
const { data } = await request({
|
||||||
|
baseURL: Streaming.baseUrl,
|
||||||
method: "GET",
|
method: "GET",
|
||||||
url: `/streaming/profiles/${profile_id}`,
|
url: `/streaming/profiles/${profile_id}`,
|
||||||
})
|
})
|
||||||
@ -102,7 +85,8 @@ export default class Streaming {
|
|||||||
}
|
}
|
||||||
|
|
||||||
static async createProfile(payload) {
|
static async createProfile(payload) {
|
||||||
const { data } = await Streaming.base({
|
const { data } = await request({
|
||||||
|
baseURL: Streaming.baseUrl,
|
||||||
method: "POST",
|
method: "POST",
|
||||||
url: "/streaming/profiles/new",
|
url: "/streaming/profiles/new",
|
||||||
data: payload,
|
data: payload,
|
||||||
@ -116,7 +100,8 @@ export default class Streaming {
|
|||||||
return null
|
return null
|
||||||
}
|
}
|
||||||
|
|
||||||
const { data } = await Streaming.base({
|
const { data } = await request({
|
||||||
|
baseURL: Streaming.baseUrl,
|
||||||
method: "PUT",
|
method: "PUT",
|
||||||
url: `/streaming/profiles/${profile_id}`,
|
url: `/streaming/profiles/${profile_id}`,
|
||||||
data: update,
|
data: update,
|
||||||
@ -130,7 +115,8 @@ export default class Streaming {
|
|||||||
return null
|
return null
|
||||||
}
|
}
|
||||||
|
|
||||||
const { data } = await Streaming.base({
|
const { data } = await request({
|
||||||
|
baseURL: Streaming.baseUrl,
|
||||||
method: "delete",
|
method: "delete",
|
||||||
url: `/streaming/profiles/${profile_id}`,
|
url: `/streaming/profiles/${profile_id}`,
|
||||||
})
|
})
|
||||||
@ -144,7 +130,8 @@ export default class Streaming {
|
|||||||
return null
|
return null
|
||||||
}
|
}
|
||||||
|
|
||||||
const { data } = await Streaming.base({
|
const { data } = await request({
|
||||||
|
baseURL: Streaming.baseUrl,
|
||||||
method: "put",
|
method: "put",
|
||||||
url: `/streaming/profiles/${profileId}/restreams`,
|
url: `/streaming/profiles/${profileId}/restreams`,
|
||||||
data: restreamData,
|
data: restreamData,
|
||||||
@ -159,7 +146,8 @@ export default class Streaming {
|
|||||||
return null
|
return null
|
||||||
}
|
}
|
||||||
|
|
||||||
const { data } = await Streaming.base({
|
const { data } = await request({
|
||||||
|
baseURL: Streaming.baseUrl,
|
||||||
method: "delete",
|
method: "delete",
|
||||||
url: `/streaming/profiles/${profileId}/restreams`,
|
url: `/streaming/profiles/${profileId}/restreams`,
|
||||||
data: restreamIndexData,
|
data: restreamIndexData,
|
||||||
@ -169,7 +157,8 @@ export default class Streaming {
|
|||||||
}
|
}
|
||||||
|
|
||||||
static async list({ limit, offset } = {}) {
|
static async list({ limit, offset } = {}) {
|
||||||
let { data } = await Streaming.base({
|
let { data } = await request({
|
||||||
|
baseURL: Streaming.baseUrl,
|
||||||
method: "get",
|
method: "get",
|
||||||
url: "/streaming/list",
|
url: "/streaming/list",
|
||||||
params: {
|
params: {
|
||||||
@ -183,6 +172,16 @@ export default class Streaming {
|
|||||||
return data
|
return data
|
||||||
}
|
}
|
||||||
|
|
||||||
|
static createWebsocket(params = {}) {
|
||||||
|
const client = new RTEngineClient({
|
||||||
|
...params,
|
||||||
|
url: Streaming.baseUrl,
|
||||||
|
token: SessionModel.token,
|
||||||
|
})
|
||||||
|
|
||||||
|
return client
|
||||||
|
}
|
||||||
|
|
||||||
static async createStreamWebsocket(stream_id, params = {}) {
|
static async createStreamWebsocket(stream_id, params = {}) {
|
||||||
if (!stream_id) {
|
if (!stream_id) {
|
||||||
console.error("stream_id is required")
|
console.error("stream_id is required")
|
||||||
@ -211,14 +210,4 @@ export default class Streaming {
|
|||||||
|
|
||||||
return client
|
return client
|
||||||
}
|
}
|
||||||
|
|
||||||
static createWebsocket(params = {}) {
|
|
||||||
const client = new RTEngineClient({
|
|
||||||
...params,
|
|
||||||
url: Streaming.apiHostname,
|
|
||||||
token: SessionModel.token,
|
|
||||||
})
|
|
||||||
|
|
||||||
return client
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
@ -1,5 +1,5 @@
|
|||||||
const envOrigins = {
|
const envOrigins = {
|
||||||
development: `https://fr01.ragestudio.net:9000`, //`${location.origin}/api`,
|
development: `${location.origin}/api`,
|
||||||
indev: "https://indev.comty.app/api",
|
indev: "https://indev.comty.app/api",
|
||||||
production: "https://api.comty.app",
|
production: "https://api.comty.app",
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user