Bug fixes in ACS
This commit is contained in:
1 parent
76758f35b3
commit
83d05462bf
1 file changed
+3
-5
+3
-5
@@ -77,8 +77,7 @@ updateDevice = (deviceId, actions, callback) ->
|
|||||||
|
|
||||||
if count == 0
|
if count == 0
|
||||||
util.log("#{deviceId}: new device detected")
|
util.log("#{deviceId}: new device detected")
|
||||||
updates['_id'] = deviceId
|
devicesCollection.update({'_id' : deviceId}, {'$set' : updates}, {upsert: true, safe: true}, (err) ->
|
||||||
devicesCollection.save(updates, {safe: true}, (err) ->
|
|
||||||
if err?
|
if err?
|
||||||
callback(err) if callback?
|
callback(err) if callback?
|
||||||
return
|
return
|
||||||
@@ -103,7 +102,7 @@ runTask = (sessionId, deviceId, task, reqParams, response) ->
|
|||||||
|
|
||||||
if Object.keys(resParams).length > 0
|
if Object.keys(resParams).length > 0
|
||||||
memcached.set(String(task._id), task, config.CACHE_DURATION, (err, result) ->
|
memcached.set(String(task._id), task, config.CACHE_DURATION, (err, result) ->
|
||||||
res = tr069.response(reqParams.sessionId, resParams, {task : String(task._id)})
|
res = tr069.response(sessionId, resParams, {task : String(task._id)})
|
||||||
writeResponse response, res
|
writeResponse response, res
|
||||||
)
|
)
|
||||||
return
|
return
|
||||||
@@ -210,7 +209,7 @@ else
|
|||||||
util.log("#{deviceId}: inform (#{reqParams.eventCodes}); retry count #{reqParams.retryCount}")
|
util.log("#{deviceId}: inform (#{reqParams.eventCodes}); retry count #{reqParams.retryCount}")
|
||||||
|
|
||||||
updateDevice(deviceId, {'inform' : true, 'parameterValues' : reqParams.informParameterValues}, (err) ->
|
updateDevice(deviceId, {'inform' : true, 'parameterValues' : reqParams.informParameterValues}, (err) ->
|
||||||
res = tr069.response(reqParams.sessionId, resParams, cookies)
|
res = tr069.response(sessionId, resParams, cookies)
|
||||||
writeResponse response, res
|
writeResponse response, res
|
||||||
)
|
)
|
||||||
return
|
return
|
||||||
@@ -221,7 +220,6 @@ else
|
|||||||
|
|
||||||
if not taskId
|
if not taskId
|
||||||
nextTask(sessionId, deviceId, response, cookies)
|
nextTask(sessionId, deviceId, response, cookies)
|
||||||
return
|
|
||||||
else
|
else
|
||||||
memcached.get(taskId, (err, task) ->
|
memcached.get(taskId, (err, task) ->
|
||||||
runTask(sessionId, deviceId, task, reqParams, response)
|
runTask(sessionId, deviceId, task, reqParams, response)
|
||||||
|
|||||||
Reference in new issue
Block a user