From 807df9e6682d1995d3d46e2461ca1b7b47eaf9d5 Mon Sep 17 00:00:00 2001 From: Chocobozzz Date: Fri, 13 May 2016 21:14:14 +0200 Subject: [PATCH] Use async waterfall in videos controller for better readability --- server/controllers/api/v1/videos.js | 175 ++++++++++++++++++---------- 1 file changed, 115 insertions(+), 60 deletions(-) diff --git a/server/controllers/api/v1/videos.js b/server/controllers/api/v1/videos.js index 641fef6ea..231309c5e 100644 --- a/server/controllers/api/v1/videos.js +++ b/server/controllers/api/v1/videos.js @@ -1,5 +1,6 @@ 'use strict' +const async = require('async') const config = require('config') const express = require('express') const fs = require('fs') @@ -81,63 +82,92 @@ function addVideo (req, res, next) { const videoFile = req.files.videofile[0] const videoInfos = req.body - videos.seed(videoFile.path, function (err, torrent) { - if (err) { - logger.error('Cannot seed this video.') - return next(err) - } + async.waterfall([ + function (callback) { + videos.seed(videoFile.path, callback) + }, - videos.getVideoDuration(videoFile.path, function (err, duration) { - if (err) { - // TODO: unseed the video - logger.error('Cannot retrieve metadata of the file.') - return next(err) - } + function seed (torrent, callback) { + videos.getVideoDuration(videoFile.path, function (err, duration) { + if (err) { + // TODO: unseed the video + logger.error('Cannot retrieve metadata of the file.') + return next(err) + } + + callback(null, torrent, duration) + }) + }, + function createThumbnail (torrent, duration, callback) { videos.createVideoThumbnail(videoFile.path, function (err, thumbnailName) { if (err) { // TODO: unseed the video logger.error('Cannot make a thumbnail of the video file.') - return next(err) + return callback(err) } - const videoData = { - name: videoInfos.name, - namePath: videoFile.filename, - description: videoInfos.description, - magnetUri: torrent.magnetURI, - author: res.locals.oauth.token.user.username, - duration: duration, - thumbnail: thumbnailName + callback(null, torrent, duration, thumbnailName) + }) + }, + + function insertIntoDB (torrent, duration, thumbnailName, callback) { + const videoData = { + name: videoInfos.name, + namePath: videoFile.filename, + description: videoInfos.description, + magnetUri: torrent.magnetURI, + author: res.locals.oauth.token.user.username, + duration: duration, + thumbnail: thumbnailName + } + + Videos.add(videoData, function (err, insertedVideo) { + if (err) { + // TODO unseed the video + // TODO remove thumbnail + logger.error('Cannot insert this video in the database.') + return callback(err) } - Videos.add(videoData, function (err, insertedVideo) { - if (err) { - // TODO unseed the video - logger.error('Cannot insert this video in the database.') - return next(err) - } - - videoData.createdDate = insertedVideo.createdDate - - fs.readFile(thumbnailsDir + thumbnailName, function (err, data) { - if (err) { - // TODO: remove video? - logger.error('Cannot read the thumbnail of the video') - return next(err) - } - - // Set the image in base64 - videoData.thumbnailBase64 = new Buffer(data).toString('base64') - // Now we'll add the video's meta data to our friends - friends.addVideoToFriends(videoData) - - // TODO : include Location of the new video -> 201 - res.type('json').status(204).end() - }) - }) + return callback(null, torrent, duration, thumbnailName, videoData, insertedVideo) }) - }) + }, + + function getThumbnailBase64 (torrent, duration, thumbnailName, videoData, insertedVideo, callback) { + videoData.createdDate = insertedVideo.createdDate + + fs.readFile(thumbnailsDir + thumbnailName, function (err, thumbnailData) { + if (err) { + // TODO unseed the video + // TODO remove thumbnail + // TODO: remove video + logger.error('Cannot read the thumbnail of the video') + return callback(err) + } + + return callback(null, videoData, thumbnailData) + }) + }, + + function sendToFriends (videoData, thumbnailData, callback) { + // Set the image in base64 + videoData.thumbnailBase64 = new Buffer(thumbnailData).toString('base64') + + // Now we'll add the video's meta data to our friends + friends.addVideoToFriends(videoData) + + return callback(null) + } + + ], function (err) { + if (err) { + logger.error('Cannot insert the video.') + return next(err) + } + + // TODO : include Location of the new video -> 201 + return res.type('json').status(204).end() }) } @@ -164,26 +194,51 @@ function listVideos (req, res, next) { function removeVideo (req, res, next) { const videoId = req.params.id - Videos.get(videoId, function (err, video) { - if (err) return next(err) - removeTorrent(video.magnetUri, function () { + async.waterfall([ + function getVideo (callback) { + Videos.get(videoId, callback) + }, + + function removeVideoTorrent (video, callback) { + removeTorrent(video.magnetUri, function () { + return callback(null, video) + }) + }, + + function removeFromDB (video, callback) { Videos.removeOwned(req.params.id, function (err) { - if (err) return next(err) + if (err) return callback(err) - videos.removeVideosDataFromDisk([ video ], function (err) { - if (err) logger.error('Cannot remove video data from disk.', { video: video }) + return callback(null, video) + }) + }, - const params = { - name: video.name, - magnetUri: video.magnetUri - } + function removeVideoData (video, callback) { + videos.removeVideosDataFromDisk([ video ], function (err) { + if (err) logger.error('Cannot remove video data from disk.', { video: video }) - friends.removeVideoToFriends(params) - res.type('json').status(204).end() - }) + return callback(null, video) }) - }) + }, + + function sendInformationToFriends (video, callback) { + const params = { + name: video.name, + magnetUri: video.magnetUri + } + + friends.removeVideoToFriends(params) + + return callback(null) + } + ], function (err) { + if (err) { + logger.error('Errors when removed the video.', { error: err }) + return next(err) + } + + return res.type('json').status(204).end() }) } -- 2.41.0