Mark unknown state on restart. Use UTF8 for database. Allow host specification.

Author: Sjoerd Tieleman

lib/job.js

@@ -29,7 +29,8 @@ var JobUtils = {
       } else {
         JobUtils.sql = new Sequelize(config['database']['database'], config['database']['username'], config['database']['password'], {
           dialect: config['database']['dialect'],
-          storage: config['database']['database']
+          storage: config['database']['database'],
+          host: config['database']['host']
         });
       }
     }
@@ -40,6 +41,19 @@ var JobUtils = {
     return JobUtils.pad((process.umask() ^ 0777).toString(8), '0', 4);
   },
 
+  markUnknownState: function(callback) {
+    Job.findAll({ where: { status: StatusCodes.PROCESSING }}).success(function(result) {
+      if (result.length > 0) {
+        for (var job in result) {
+          result[job].status = StatusCodes.UNKNOWN;
+          result[job].message = "The transcoder quit unexpectedly or the database was unavailable for some period.";
+          result[job].save();
+        }
+      }
+    });
+    callback(null);
+  },
+  
   migrateDatabase: function(callback) {
     var migrator = JobUtils.getDatabase().getMigrator({path: __dirname + "/../migrations" });
     migrator.migrate().success(function() {
@@ -73,7 +87,13 @@ var Job = JobUtils.getDatabase().define('Job', {
   classMethods: {
     prepareDatabase: function(callback) {
       JobUtils.migrateDatabase(function (err) {
-        err ? callback(err) : callback(null);
+        if (err) {
+          callback(err);
+        } else {
+          JobUtils.markUnknownState(function (err) {
+            err ? callback(err) : callback(null);
+          })
+        }
       });
     },
     create: function(opts, callback, completeCallback) {

migrations/20130305100924-create-jobs.js

@@ -13,6 +13,10 @@ module.exports = {
         message:     { type: DataTypes.TEXT, defaultValue: null },
         createdAt:   DataTypes.DATE,
         updatedAt:   DataTypes.DATE
+      },
+      {
+        charset: 'utf8',
+        collate: 'utf8_general_ci'
       }
     )
     migration.addIndex('jobs', ['internalId'])