Skip to content

Commit

Permalink
Merge pull request #2 from Ni55aN/master
Browse files Browse the repository at this point in the history
capped collection
  • Loading branch information
nemanjapetrovic authored Aug 28, 2018
2 parents b1d2600 + 91d9362 commit aa3fabc
Showing 1 changed file with 14 additions and 10 deletions.
24 changes: 14 additions & 10 deletions index.js
Original file line number Diff line number Diff line change
Expand Up @@ -5,15 +5,6 @@ var carrier = require('carrier')

var PassThroughStream = stream.PassThrough

// Schema
var logSchema = mongoose.Schema({
date: {
type: Date,
default: Date.now
},
log: String
});

/**
* MongooseMorgan object
* @param {object} mongoData - represents mongo database data, requires { connectionString : '{MONGO_URL}' } parameter.
Expand Down Expand Up @@ -43,6 +34,10 @@ function MongooseMorgan(mongoData, options, format) {
var collection = mongoData.collection || 'logs';
var user = mongoData.user || null;
var pass = mongoData.pass || null;
var capped = mongoData.capped;
var cappedSize = (mongoData.cappedSize || 10000000);
var cappedMax = mongoData.cappedMax;

mongoose.connect(mongoData.connectionString, {
user: user,
pass: pass,
Expand All @@ -58,6 +53,15 @@ function MongooseMorgan(mongoData, options, format) {
// Morgan options stream
options.stream = stream;

// Schema
var logSchema = mongoose.Schema({
date: {
type: Date,
default: Date.now
},
log: String
}, capped ? { capped: { size: cappedSize, max: cappedMax } } : {} );

// Create mongoose model
var Log = mongoose.model('Log', logSchema, collection);

Expand All @@ -75,4 +79,4 @@ function MongooseMorgan(mongoData, options, format) {
return morgan(format, options);
}

module.exports = MongooseMorgan;
module.exports = MongooseMorgan;

0 comments on commit aa3fabc

Please sign in to comment.