Using the new MongoClient interface
This commit is contained in:
1 parent
76bc1eff0c
commit
199adf5bcd
2 files changed
+11
-9
No files matched your search
+2
-2
@@ -246,7 +246,7 @@ else
|
|||||||
Manufacturer : request.headers.manufacturer,
|
Manufacturer : request.headers.manufacturer,
|
||||||
}
|
}
|
||||||
|
|
||||||
gs = new mongodb.GridStore(db.mongo.db, filename, 'w', {metadata : metadata})
|
gs = new mongodb.GridStore(db.mongoDb, filename, 'w', {metadata : metadata})
|
||||||
gs.open((err, gs) ->
|
gs.open((err, gs) ->
|
||||||
gs.write(request.getBody('binary'), (err, res) ->
|
gs.write(request.getBody('binary'), (err, res) ->
|
||||||
gs.close((err) ->
|
gs.close((err) ->
|
||||||
@@ -256,7 +256,7 @@ else
|
|||||||
)
|
)
|
||||||
)
|
)
|
||||||
else if request.method == 'DELETE'
|
else if request.method == 'DELETE'
|
||||||
mongodb.GridStore.unlink(db.mongo.db, filename, (err) ->
|
mongodb.GridStore.unlink(db.mongoDb, filename, (err) ->
|
||||||
response.writeHead(200)
|
response.writeHead(200)
|
||||||
response.end()
|
response.end()
|
||||||
)
|
)
|
||||||
|
|||||||
@@ -12,15 +12,17 @@ devicesCollection = null
|
|||||||
presetsCollection = null
|
presetsCollection = null
|
||||||
objectsCollection = null
|
objectsCollection = null
|
||||||
|
|
||||||
dbserver = new mongodb.Server(config.MONGODB_SOCKET, 0, {auto_reconnect: true})
|
options = {
|
||||||
db = new mongodb.Db(config.DATABASE_NAME, dbserver, {native_parser:true, safe:true})
|
db : {
|
||||||
|
native_parser: true
|
||||||
exports.mongo = {
|
}
|
||||||
db : db,
|
server : {
|
||||||
server : dbserver
|
auto_reconnect : true
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
db.open( (err, db) ->
|
mongodb.MongoClient.connect("mongodb://#{config.MONGODB_SOCKET}/#{config.DATABASE_NAME}", options, (err, db) ->
|
||||||
|
exports.mongoDb = db
|
||||||
db.collection('tasks', (err, collection) ->
|
db.collection('tasks', (err, collection) ->
|
||||||
exports.tasksCollection = tasksCollection = collection
|
exports.tasksCollection = tasksCollection = collection
|
||||||
collection.ensureIndex({device: 1, timestamp: 1}, (err) ->
|
collection.ensureIndex({device: 1, timestamp: 1}, (err) ->
|
||||||
|
|||||||
Reference in new issue
Block a user