-import { AllowNull, BelongsTo, Column, CreatedAt, DataType, DefaultScope, ForeignKey, Model, Table, UpdatedAt } from 'sequelize-typescript'
+import { Transaction } from 'sequelize'
+import {
+ AllowNull,
+ BeforeDestroy,
+ BelongsTo,
+ Column,
+ CreatedAt,
+ DataType,
+ DefaultScope,
+ ForeignKey,
+ Model,
+ Table,
+ UpdatedAt
+} from 'sequelize-typescript'
+import { CONFIG } from '@server/initializers/config'
import { WEBSERVER } from '@server/initializers/constants'
-import { MVideoLive, MVideoLiveVideo } from '@server/types/models'
-import { AttributesOnly } from '@shared/core-utils'
-import { LiveVideo, VideoState } from '@shared/models'
+import { MVideoLive, MVideoLiveVideoWithSetting } from '@server/types/models'
+import { LiveVideo, LiveVideoLatencyMode, VideoState } from '@shared/models'
+import { AttributesOnly } from '@shared/typescript-utils'
import { VideoModel } from './video'
import { VideoBlacklistModel } from './video-blacklist'
+import { VideoLiveReplaySettingModel } from './video-live-replay-setting'
@DefaultScope(() => ({
include: [
required: false
}
]
+ },
+ {
+ model: VideoLiveReplaySettingModel,
+ required: false
}
]
}))
{
fields: [ 'videoId' ],
unique: true
+ },
+ {
+ fields: [ 'replaySettingId' ],
+ unique: true
}
]
})
@Column
permanentLive: boolean
+ @AllowNull(false)
+ @Column
+ latencyMode: LiveVideoLatencyMode
+
@CreatedAt
createdAt: Date
})
Video: VideoModel
+ @ForeignKey(() => VideoLiveReplaySettingModel)
+ @Column
+ replaySettingId: number
+
+ @BelongsTo(() => VideoLiveReplaySettingModel, {
+ foreignKey: {
+ allowNull: true
+ },
+ onDelete: 'set null'
+ })
+ ReplaySetting: VideoLiveReplaySettingModel
+
+ @BeforeDestroy
+ static deleteReplaySetting (instance: VideoLiveModel, options: { transaction: Transaction }) {
+ return VideoLiveReplaySettingModel.destroy({
+ where: {
+ id: instance.replaySettingId
+ },
+ transaction: options.transaction
+ })
+ }
+
static loadByStreamKey (streamKey: string) {
const query = {
where: {
required: false
}
]
+ },
+ {
+ model: VideoLiveReplaySettingModel.unscoped(),
+ required: false
}
]
}
- return VideoLiveModel.findOne<MVideoLiveVideo>(query)
+ return VideoLiveModel.findOne<MVideoLiveVideoWithSetting>(query)
}
static loadByVideoId (videoId: number) {
return VideoLiveModel.findOne<MVideoLive>(query)
}
- toFormattedJSON (): LiveVideo {
+ toFormattedJSON (canSeePrivateInformation: boolean): LiveVideo {
+ let privateInformation: Pick<LiveVideo, 'rtmpUrl' | 'rtmpsUrl' | 'streamKey'> | {} = {}
+
+ // If we don't have a stream key, it means this is a remote live so we don't specify the rtmp URL
+ // We also display these private information only to the live owne/moderators
+ if (this.streamKey && canSeePrivateInformation === true) {
+ privateInformation = {
+ streamKey: this.streamKey,
+
+ rtmpUrl: CONFIG.LIVE.RTMP.ENABLED
+ ? WEBSERVER.RTMP_BASE_LIVE_URL
+ : null,
+
+ rtmpsUrl: CONFIG.LIVE.RTMPS.ENABLED
+ ? WEBSERVER.RTMPS_BASE_LIVE_URL
+ : null
+ }
+ }
+
+ const replaySettings = this.replaySettingId
+ ? this.ReplaySetting.toFormattedJSON()
+ : undefined
+
return {
- // If we don't have a stream key, it means this is a remote live so we don't specify the rtmp URL
- rtmpUrl: this.streamKey
- ? WEBSERVER.RTMP_URL
- : null,
+ ...privateInformation,
- streamKey: this.streamKey,
permanentLive: this.permanentLive,
- saveReplay: this.saveReplay
+ saveReplay: this.saveReplay,
+ replaySettings,
+ latencyMode: this.latencyMode
}
}
}