Update dependencies

This commit is contained in:
Zaid Abdulla committed 2016-03-06 06:19:50 +03:00
1 parent c3a956ad27
commit dff95c3c80
5 files changed
+22 -19

No files matched your search

+3 -3
View File
@@ -225,7 +225,7 @@ insertTasks = (tasks, aliases, callback) ->
for task in tasks for task in tasks
sanitizeTask(task, aliases, (t) -> sanitizeTask(task, aliases, (t) ->
if t.uniqueKey? if t.uniqueKey?
db.tasksCollection.remove({device : t.device, uniqueKey : t.uniqueKey}, (err, removed) -> db.tasksCollection.remove({device : t.device, uniqueKey : t.uniqueKey}, (err) ->
) )
--counter --counter
@@ -238,9 +238,9 @@ insertTasks = (tasks, aliases, callback) ->
deleteDevice = (deviceId, callback) -> deleteDevice = (deviceId, callback) ->
db.tasksCollection.remove({'device' : deviceId}, (err, removed) -> db.tasksCollection.remove({'device' : deviceId}, (err) ->
return callback(err) if err return callback(err) if err
db.devicesCollection.remove({'_id' : deviceId}, (err, removed) -> db.devicesCollection.remove({'_id' : deviceId}, (err) ->
return callback(err) if err return callback(err) if err
db.redisClient.del("#{deviceId}_presets_hash", "#{deviceId}_inform_hash", (err) -> db.redisClient.del("#{deviceId}_presets_hash", "#{deviceId}_inform_hash", (err) ->
callback(err) callback(err)
+2 -2
View File
@@ -468,8 +468,8 @@ saveDevice = (deviceId, diff, isNew, callback) ->
return callback() if Object.keys(update).length == 0 return callback() if Object.keys(update).length == 0
devicesCollection.update({'_id' : deviceId}, update, {upsert: isNew}, (err, count) => devicesCollection.update({'_id' : deviceId}, update, {upsert: isNew}, (err, result) ->
if not err and count != 1 if not err and result.result.n != 1
return callback(new Error("Device #{deviceId} not found in database")) return callback(new Error("Device #{deviceId} not found in database"))
return callback(err) return callback(err)
+11 -8
View File
@@ -103,7 +103,7 @@ listener = (request, response) ->
response.end() response.end()
) )
else if request.method == 'DELETE' else if request.method == 'DELETE'
db.presetsCollection.remove({'_id' : presetName}, (err, removedCount) -> db.presetsCollection.remove({'_id' : presetName}, (err) ->
db.redisClient.del('presets', 'presets_hash', (err) -> db.redisClient.del('presets', 'presets_hash', (err) ->
throw err if err throw err if err
) )
@@ -135,7 +135,7 @@ listener = (request, response) ->
response.end() response.end()
) )
else if request.method == 'DELETE' else if request.method == 'DELETE'
db.objectsCollection.remove({'_id' : objectName}, (err, removedCount) -> db.objectsCollection.remove({'_id' : objectName}, (err) ->
db.redisClient.del('objects', 'presets_hash', (err) -> db.redisClient.del('objects', 'presets_hash', (err) ->
throw err if err throw err if err
) )
@@ -253,7 +253,7 @@ listener = (request, response) ->
action = r[2] action = r[2]
if not action? or action is '/' if not action? or action is '/'
if request.method == 'DELETE' if request.method == 'DELETE'
db.tasksCollection.remove({'_id' : taskId}, (err, removedCount) -> db.tasksCollection.remove({'_id' : taskId}, (err) ->
if err if err
response.writeHead(500) response.writeHead(500)
response.end(errorToString(err)) response.end(errorToString(err))
@@ -385,8 +385,8 @@ listener = (request, response) ->
cur.sort(sort) cur.sort(sort)
cur.skip(parseInt(urlParts.query.skip)) if urlParts.query.skip? cur.skip(parseInt(urlParts.query.skip)) if urlParts.query.skip?
cur.limit(parseInt(urlParts.query.limit)) if urlParts.query.limit? cur.limit(limit = parseInt(urlParts.query.limit)) if urlParts.query.limit?
cur.count((err, total) -> cur.count(false, (err, total) ->
response.writeHead(200, {'Content-Type' : 'application/json', 'total' : total}) response.writeHead(200, {'Content-Type' : 'application/json', 'total' : total})
if request.method is 'HEAD' if request.method is 'HEAD'
response.end() response.end()
@@ -394,12 +394,15 @@ listener = (request, response) ->
response.write("[\n") response.write("[\n")
i = 0 i = 0
cur.each((err, item) -> cur.each((err, item) ->
if item is null throw err if err
response.end("\n]")
else if item?
response.write(",\n") if i++ response.write(",\n") if i++
apiFunctions.addAliases(item, aliases) if collectionName is 'devices' apiFunctions.addAliases(item, aliases) if collectionName is 'devices'
response.write(JSON.stringify(item)) response.write(JSON.stringify(item))
if not item? or (limit? and i >= limit)
response.end("\n]")
) )
) )
+1 -1
View File
@@ -363,7 +363,7 @@ load = (id, callback) ->
save = (sessionData, callback) -> save = (sessionData, callback) ->
sessionData.id ?= crypto.randomBytes(8).toString('hex') sessionData.id ?= crypto.randomBytes(8).toString('hex')
db.redisClient.setex("session_#{sessionData.id}", sessionData.timeout, JSON.stringify(sessionData), (err) => db.redisClient.setex("session_#{sessionData.id}", sessionData.timeout, JSON.stringify(sessionData), (err) ->
return callback(err, sessionData.id) return callback(err, sessionData.id)
) )
return return
+5 -5
View File
@@ -20,13 +20,13 @@
"bin": "bin" "bin": "bin"
}, },
"dependencies": { "dependencies": {
"libxmljs": "~0.11.0", "libxmljs": "^0.17.1",
"redis": "~0.12.1", "redis": "^2.4.2",
"hiredis": "~0.1.17", "hiredis": "^0.4.1",
"mongodb": "~1.4.8" "mongodb": "^2.1.7"
}, },
"devDependencies": { "devDependencies": {
"coffee-script": "~1.7.1" "coffee-script": "^1.10.0"
}, },
"engines": { "engines": {
"node": ">=0.10.0 <0.12" "node": ">=0.10.0 <0.12"