MongoDB backed session middleware for koa.js
$npminstallkoa-mongodb-sessionView counter example:
varsession=require('koa-mongodb-session');varmongo=require('mongodb').MongoClient;varkoa=require('koa');mongo.connect(uri,function(err,db){if(err)throwerr;varapp=koa();app.keys=['some secret'];app.use(session({key: 'sid',collection: db.collection('session')}));app.use(function*(){this.session.$inc('views',1);this.body=this.session.views+' views';})app.listen(3000);console.log('listening on port 3000');})This module provides "guest" sessions, meaning any visitor will have a session, authenticated or not. If a session is new a Set-Cookie will be produced regardless of populating the session.
A mongodb collection object in which all session objects will be stored is required.
The cookie name is controlled by the key option, which defaults
to "sid". All other options are passed to ctx.cookies.get() and
ctx.cookies.set() allowing you to control security, domain, path,
and signing among other settings.
To destroy a session simply set it to null:
this.session=null;Use the following helper methods to modify a session. These allow us to buffer atomic operations and perform a single update statement at the end of the request for efficiency.
If you wish to flush all buffered operations before the end of the request,
simply yield your session modifier (works for all modifier methods):
app.use(function*(){yieldthis.session.$set('name','koa');// $set and other buffered ops will be committed to mongodb})Note that changing session properties directly (this.session.x = 3) will have no effect.
You must use the following $atomic modifier methods.
Sets key to val.
app.use(function*(){this.session.$set('email','aaron.heckmann+github@gmail.com');})Unsets key.
app.use(function*(){this.session.$unset('email');console.log(this.session.email);// undefined})Increments key by val.
app.use(function*(){this.session.$inc('views',1);})Note that negative values are supported for decrementing.
app.use(function*(){this.session.$inc('views',-1);})Renames oldKey to newKey.
app.use(function*(){this.session.$rename('vews','views');console.log(this.session.vews)// undefinedconsole.log(this.session.views)// 1})Pushes val onto the array at key. If no array exists it will be created for you.
app.use(function*(){this.session.$push('pages','pricing');this.session.$push('pages','features');console.log(this.session.pages);// ['pricing', 'features']})Pushes all vals onto the array at key. If no array exists it will be created for you.
app.use(function*(){this.session.$pushAll('pages',['home','contact-us']);})Pushes all vals onto the array at key if they are not already in the array. If no array exists it will be created for you.
app.use(function*(){console.log(this.session.uniquePages);// [5, [37], 12, 2, { x: { y: 'deep' }}]this.session.$addToSet('uniquePages',[5,[37],{x:{y: 'deep'}},11,2]);console.log(this.session.uniquePages);// [5, [37], 12, 2, { x: { y: 'deep' }}, 11]})Removes all instances of val from the array at key.
app.use(function*(){console.log(this.session.cart);// ['asdf-123', 'qwer-94']this.session.$pull('cart','asdf-123');console.log(this.session.cart);// ['qwer-94']})Removes all instances of all vals from the array at key.
app.use(function*(){console.log(this.session.cart);// ['asdf-123', 'qwer-94']this.session.$pullAll('cart',['asdf-123','qwer-94']);console.log(this.session.cart);// []})Removes the last element of the array at key.
app.use(function*(){console.log(this.session.queue);// [5435, 2341, 43]this.session.$pop('queue');console.log(this.session.queue);// [5435, 2341]})Removes the first element of the array at key.
app.use(function*(){console.log(this.session.queue);// [5435, 2341, 43]this.session.$shift('queue');console.log(this.session.queue);// [2341, 43]})Returns a thunk which can be yielded to reload the session from the state in the db
(blowing away any in-memory changes).
app.use(function*(){yieldthis.session.$reload();})Returns true if the session is new, otherwise false.
app.use(function*(){console.log(this.session.isNew);})The session modifiers not only buffer atomic operations for later execution but also operate directly on the in-memory session object.
app.use(function*(){this.session.$set('namme','aaron');this.session.$rename('namme','name');console.log(this.session.namme)// undefinedconsole.log(this.session.name)// 'aaron'})If an error occurs during a database update it will be passed back to koa.