Basic video fetch

Author: MiloNguyen95

resources/video-data-from-playlistItems.json

@@ -0,0 +1,17 @@
+{ kind: 'youtube#playlistItem',
+  etag: '"p4VTdlkQv3HQeTEaXgvLePAydmU/lBwcYm3PmDCF7c0jJvf9quujp1s"',
+  id: 'VVVBMnRGazJOZHpPektwU0pkZjI0Y0FnLmU0T2lkZTlCc0g4',
+  snippet: { publishedAt: '2020-01-04T16: 05: 16.000Z',
+     channelId: 'UCA2tFk2NdzOzKpSJdf24cAg',
+     title: 'Radix Sort Algorithm | Thuật toán sắp xếp theo cơ số',
+     description:
+      'Hế lô hế lô, Ông dev đây!\n\nTrong phần này mình sẽ giới thiệu và giải thích cơ chế hoạt động của Radix Sort Algorithm -  thuật toán sắp xếp theo cơ số.\n\n--- Để xem những video về lập trình và gaming ---\nNhấn vào đây để theo dõi kênh mình nhé: https: //duyngd.com/Subscribe\n\n--- Blog của mình ---\nhttps://duyngd.com\n\n--- Facebook page của mình ---\nhttps://www.facebook.com/ongdevvuitinh\n\n--- Ủng hộ Ông Dev ---\nhttps://unghotoi.com/ongdev\n\nCảm ơn các bạn đã quan tâm theo dõi\n#ôngdev #algorithm #radixsort',
+     thumbnails: [Object
+    ],
+     channelTitle: 'Ông Dev',
+     playlistId: 'UUA2tFk2NdzOzKpSJdf24cAg',
+     position: 0,
+     resourceId: [Object
+    ]
+  }
+}

src/models/video.model.js

@@ -1,4 +1,5 @@
 import mongoose from 'mongoose';
+// eslint-disable-next-line no-unused-vars
 import PlaylistModel from './playlist.model';
 
 const { Schema } = mongoose;
@@ -10,31 +11,23 @@ const VideoSchema = Schema({
   },
   title: String,
   description: String,
-  tags: [
-    {
-      type: String,
-    },
-  ],
-  status: {
-    privacyStatus: String,
-    publishAt: Date,
-  },
   statistics: {
     viewCount: Number,
     likeCount: Number,
     dislikeCount: Number,
     commentCount: Number,
   },
-  thumbnails: {
+  thumbnails: [{
     url: String,
     width: Number,
     height: Number,
+  }],
+  position: {
+    type: Number,
+    unique: true,
   },
-  comments: [
-    // Do not work on it for now
-  ],
-  playlists: [{ type: PlaylistModel.id, ref: 'PlaylistModel' }],
-}, { _id: false });
+  playlists: [{ type: String, ref: 'PlaylistModel' }],
+});
 
 const VideoModel = mongoose.model('Videos', VideoSchema, 'videos');
 

src/tasks/video.background.js

@@ -2,6 +2,7 @@ import cron from 'node-cron';
 import dotenv from 'dotenv';
 
 import YoutubeApi from '../configs/yt.config';
+import VideoModel from '../models/video.model';
 
 dotenv.config();
 
@@ -19,9 +20,26 @@ YoutubeBackgroundTasks.getAllAvailableVideosFromYoutube = async () => {
   }
 };
 
+YoutubeBackgroundTasks
+  .saveAllVideosToDatabase = async (videos) => videos && videos.forEach(async (video) => {
+    const {
+      title, description, thumbnails, position,
+    } = video.snippet;
+    await VideoModel.deleteMany({});
+    const newVideo = new VideoModel({
+      id: video.id,
+      title,
+      description,
+      thumbnails,
+      position,
+    });
+    newVideo.save();
+  });
+
 // Request every 10 mins
-YoutubeBackgroundTasks.autoUpdateYoutubeVideos = cron.schedule('*/10 * * * *', () => {
-  console.log('running a task every 10 minutes');
+YoutubeBackgroundTasks.autoUpdateYoutubeVideos = cron.schedule('*/10 * * * *', async () => {
+  const videos = await YoutubeBackgroundTasks.getAllAvailableVideosFromYoutube();
+  await YoutubeBackgroundTasks.saveAllVideosToDatabase(videos);
 });
 
 export default YoutubeBackgroundTasks;