Server: always check commit result

diff --git a/server/controllers/api/remote/videos.js b/server/controllers/api/remote/videos.js
index 6d768eae885a54d62b6fb306308ba56a090d1fe4..17bdce01995fdd0fbdb5293b51bd4b2e2034890a 100644 (file)
--- a/server/controllers/api/remote/videos.js
+++ b/server/controllers/api/remote/videos.js
@@ -171,9 +171,12 @@ function addRemoteVideo (videoToCreateData, fromPod, finalCallback) {
     }
 
     // Commit transaction
-    t.commit()
+    t.commit().asCallback(function (err) {
+      if (err) return finalCallback(err)
 
-    return finalCallback()
+      logger.info('Remote video %s inserted.', videoToCreateData.videoToCreateData.name)
+      return finalCallback(null)
+    })
   })
 }
 
@@ -254,10 +257,13 @@ function updateRemoteVideo (videoAttributesToUpdate, fromPod, finalCallback) {
       return finalCallback(err)
     }
 
-    // Commit transaction
-    t.commit()
+   // Commit transaction
+    t.commit().asCallback(function (err) {
+      if (err) return finalCallback(err)
 
-    return finalCallback()
+      logger.info('Remote video %s updated', videoAttributesToUpdate.name)
+      return finalCallback(null)
+    })
   })
 }
 

diff --git a/server/controllers/api/videos.js b/server/controllers/api/videos.js
index 6573b12103efa9c30870b8905e83b6a37434601e..df068f961797d36897b582ed14abdf0338915658 100644 (file)
--- a/server/controllers/api/videos.js
+++ b/server/controllers/api/videos.js
@@ -231,11 +231,12 @@ function addVideo (req, res, videoFile, callback) {
     }
 
     // Commit transaction
-    t.commit()
+    t.commit().asCallback(function (err) {
+      if (err) return callback(err)
 
-    logger.info('Video with name %s created.', videoInfos.name)
-
-    return callback(null)
+      logger.info('Video with name %s created.', videoInfos.name)
+      return callback(null)
+    })
   })
 }
 
@@ -324,9 +325,12 @@ function updateVideo (req, res, finalCallback) {
     }
 
     // Commit transaction
-    t.commit()
+    t.commit().asCallback(function (err) {
+      if (err) return finalCallback(err)
 
-    return finalCallback(null)
+      logger.info('Video with name %s updated.', videoInfosToUpdate.name)
+      return finalCallback(null)
+    })
   })
 }
 
@@ -442,9 +446,12 @@ function reportVideoAbuse (req, res, finalCallback) {
     }
 
     // Commit transaction
-    t.commit()
+    t.commit().asCallback(function (err) {
+      if (err) return finalCallback(err)
 
-    return finalCallback(null)
+      logger.info('Abuse report for video %s created.', videoInstance.name)
+      return finalCallback(null)
+    })
   })
 }
 

diff --git a/server/initializers/migrator.js b/server/initializers/migrator.js
index eaecb4936a1af3494ac16cec39ab39836cf5a14a..e5288b61589a3646b7f99a8b9079064e8dc2b04a 100644 (file)
--- a/server/initializers/migrator.js
+++ b/server/initializers/migrator.js
@@ -91,7 +91,7 @@ function executeMigration (actualVersion, entity, callback) {
           return callback(err)
         }
 
-        t.commit()
+        t.commit().asCallback(callback)
       })
     })
   })