Add missing new keyword

lib/db.coffee

@@ -583,7 +583,7 @@ clearTasks = (taskIds, callback) ->
   if not taskIds?.length
     return callback()
 
-  tasksCollection.remove({'_id' : {'$in' : (mongodb.ObjectID(id) for id in taskIds)}}, callback)
+  tasksCollection.remove({'_id' : {'$in' : (new mongodb.ObjectID(id) for id in taskIds)}}, callback)
 
 
 syncFaults = (deviceId, faults, callback) ->
@@ -623,7 +623,7 @@ syncFaults = (deviceId, faults, callback) ->
             return counter = 0
 
           if channel.startsWith('_task_')
-            return tasksCollection.update({_id: mongodb.ObjectID(channel.slice(6))}, {$set: {fault: fault.fault, retries: fault.retries}}, (err) ->
+            return tasksCollection.update({_id: new mongodb.ObjectID(channel.slice(6))}, {$set: {fault: fault.fault, retries: fault.retries}}, (err) ->
               if err
                 callback(err) if counter
                 return counter = 0

lib/nbi.coffee

@@ -260,7 +260,7 @@ listener = (request, response) ->
           db.faultsCollection.remove({_id : faultId}, (err) ->
             throw err if err
             if channel.startsWith('_task_')
-              return db.tasksCollection.remove({_id : mongodb.ObjectID(channel.slice(6))}, (err) ->
+              return db.tasksCollection.remove({_id : new mongodb.ObjectID(channel.slice(6))}, (err) ->
                 throw err if err
               )
             response.writeHead(200)
@@ -334,7 +334,7 @@ listener = (request, response) ->
         response.end('405 Method Not Allowed')
     else if TASKS_REGEX.test(urlParts.pathname)
       r = TASKS_REGEX.exec(urlParts.pathname)
-      taskId = mongodb.ObjectID(querystring.unescape(r[1]))
+      taskId = new mongodb.ObjectID(querystring.unescape(r[1]))
       action = r[2]
       if not action? or action is '/'
         if request.method == 'DELETE'