diff --git a/controller/websocket.js b/controller/websocket.js index 98caaa1..3b6174d 100644 --- a/controller/websocket.js +++ b/controller/websocket.js @@ -160,7 +160,7 @@ exports.playlist = async (ws, req) => { ws.send(`DATA - Uploaded ${video.title}`) fs.unlinkSync(`./videos/${id}.webm`) - await websocket.createDatabaseVideo(id, videoUrl) + await websocket.createDatabaseVideo(id, videoUrl, playlistId) ws.send(`DATA - Created video page for ${video.title}`) } else { ws.send(`DATA - Failed to find file for ${video.title}. Going to next video in the playlist`) diff --git a/prisma/schema.prisma b/prisma/schema.prisma index c443776..2d4a9fe 100644 --- a/prisma/schema.prisma +++ b/prisma/schema.prisma @@ -12,7 +12,7 @@ datasource db { model videos { uuid String @id @default(uuid()) - id String + id String @unique title String description String thumbnail String diff --git a/utils/websocket.js b/utils/websocket.js index 54b4a16..a9ed6d9 100644 --- a/utils/websocket.js +++ b/utils/websocket.js @@ -4,7 +4,7 @@ const prisma = new PrismaClient() const metadata = require('./metadata.js') const upload = require('./upload.js') -async function createDatabaseVideo(id, videoUrl) { +async function createDatabaseVideo(id, videoUrl, playlistId) { const instance = await metadata.getInstance() const data = await metadata.getVideoMetadata(instance, id) const uploaderAvatar = await upload.uploadImage((data.uploaderUrl).replace('/channel/', ''), data.uploaderAvatar) @@ -22,7 +22,8 @@ async function createDatabaseVideo(id, videoUrl) { channel: data.uploader, channelId: (data.uploaderUrl).replace('/channel/', ''), channelAvatar: uploaderAvatar, - channelVerified: data.uploaderVerified + channelVerified: data.uploaderVerified, + playlist: playlistId } })