Live streaming implementation first step

1 files changed, 74 insertions, 0 deletions

diff --git a/server/models/video/video-live.ts b/server/models/video/video-live.ts
new file mode 100644
index 000000000..6929b9688
--- /dev/null
+++ b/server/models/video/video-live.ts
@@ -0,0 +1,74 @@
+import { AllowNull, BelongsTo, Column, CreatedAt, DataType, DefaultScope, ForeignKey, Model, Table, UpdatedAt } from 'sequelize-typescript'
+import { WEBSERVER } from '@server/initializers/constants'
+import { MVideoLive, MVideoLiveVideo } from '@server/types/models'
+import { VideoLive } from '@shared/models/videos/video-live.model'
+import { VideoModel } from './video'
+
+@DefaultScope(() => ({
+  include: [
+    {
+      model: VideoModel,
+      required: true
+    }
+  ]
+}))
+@Table({
+  tableName: 'videoLive',
+  indexes: [
+    {
+      fields: [ 'videoId' ],
+      unique: true
+    }
+  ]
+})
+export class VideoLiveModel extends Model<VideoLiveModel> {
+
+  @AllowNull(false)
+  @Column(DataType.STRING)
+  streamKey: string
+
+  @CreatedAt
+  createdAt: Date
+
+  @UpdatedAt
+  updatedAt: Date
+
+  @ForeignKey(() => VideoModel)
+  @Column
+  videoId: number
+
+  @BelongsTo(() => VideoModel, {
+    foreignKey: {
+      allowNull: false
+    },
+    onDelete: 'cascade'
+  })
+  Video: VideoModel
+
+  static loadByStreamKey (streamKey: string) {
+    const query = {
+      where: {
+        streamKey
+      }
+    }
+
+    return VideoLiveModel.findOne<MVideoLiveVideo>(query)
+  }
+
+  static loadByVideoId (videoId: number) {
+    const query = {
+      where: {
+        videoId
+      }
+    }
+
+    return VideoLiveModel.findOne<MVideoLive>(query)
+  }
+
+  toFormattedJSON (): VideoLive {
+    return {
+      rtmpUrl: WEBSERVER.RTMP_URL,
+      streamKey: this.streamKey
+    }
+  }
+}