1. module connect-mongodb-session
   1. function connect-mongodb-session (connect)

module connect-mongodb-session

function connect-mongodb-session (connect)

• description and source-code

  connect-mongodb-session = function (connect) {
    var Store = connect.Store || connect.session.Store;
    var defaults = {
      uri: 'mongodb://localhost:27017/test',
      collection: 'sessions',
      connectionOptions: {},
      expires: 1000 * 60 * 60 * 24 * 14, // 2 weeks
      idField: '_id'
    };
  
    var MongoDBStore = function(options, callback) {
      var _this = this;
      this._emitter = new EventEmitter();
      this._errorHandler = handleError.bind(this);
  
      if (typeof options === 'function') {
        callback = options;
        options = {};
      } else {
        options = options || {};
      }
  
      mergeOptions(options, defaults);
  
      Store.call(this, options);
      this.options = options;
  
      var connOptions = options.connectionOptions;
      mongodb.MongoClient.connect(options.uri, connOptions, function(error, db) {
        if (error) {
          var e = new Error('Error connecting to db: ' + error.message);
          return _this._errorHandler(e, callback);
        }
  
        db.
          collection(options.collection).
          ensureIndex({ expires: 1 }, { expireAfterSeconds: 0 }, function(error) {
            if (error) {
              var e = new Error('Error creating index: ' + error.message);
              return _this._errorHandler(e, callback);
            }
  
            _this.db = db;
            _this._emitter.emit('connected');
  
            return callback && callback();
          });
      });
    };
  
    MongoDBStore.prototype = Object.create(Store.prototype);
  
    MongoDBStore.prototype._generateQuery = function(id) {
      var ret = {};
      ret[this.options.idField] = id;
      return ret;
    };
  
    MongoDBStore.prototype.get = function(id, callback) {
      var _this = this;
  
      if (!this.db) {
        return this._emitter.once('connected', function() {
          _this.get.call(_this, id, callback);
        });
      }
  
      this.db.collection(this.options.collection).
        findOne(this._generateQuery(id), function(error, session) {
          if (error) {
            var e = new Error('Error finding ' + id + ': ' + error.message);
            return _this._errorHandler(e, callback);
          } else if (session) {
            if (!session.expires || new Date < session.expires) {
              return callback(null, session.session);
            } else {
              return _this.destroy(id, callback);
            }
          } else {
            return callback();
          }
        });
    };
  
    MongoDBStore.prototype.destroy = function(id, callback) {
      var _this = this;
      if (!this.db) {
        return this._emitter.once('connected', function() {
          _this.destroy.call(_this, id, callback);
        });
      }
  
      this.db.collection(this.options.collection).
        remove(this._generateQuery(id), function(error) {
          if (error) {
            var e = new Error('Error destroying ' + id + ': ' + error.message);
            return _this._errorHandler(e, callback);
          }
          callback && callback();
        });
    };
  
    MongoDBStore.prototype.clear = function(callback) {
      var _this = this;
      if (!this.db) {
        return this._emitter.once('connected', function() {
          _this.clear.call(_this, callback);
        });
      }
  
      this.db.collection(this.options.collection).
        remove({}, function(error) {
          if (error) {
            var e = new Error('Error clearing all sessions: ' + error.message);
            return _this._errorHandler(e, callback);
          }
          callback && callback();
        });
    };
  
    MongoDBStore.prototype.set = function(id, session, callback) {
      var _this = this;
  
      if (!this.db) {
        return this._emitter.once('connected', function() {
          _this.set.call(_this, id, session, callback);
        });
      }
  
      var sess = {};
      for (var key in session) {
        if (key === 'cookie') {
          sess[key] = session[key].toJSON ? session[key].toJSON() : session[key];
        } else {
          sess[key] = session[key];
        }
      }
  
      var s = this._generateQuery(id);
      s.session = sess;
      if (session && session.cookie && session.cookie.expires) {
        s.expires = new Date(session.cookie.expires);
      } else {
        var now = new Date();
        s.expires = new Date(now. ...

• example usage

  n/a