Comparing version 0.1.4 to 0.1.5
@@ -25,3 +25,3 @@ 'use strict'; | ||
Logger.prototype.init = function(options) { | ||
Logger.prototype.init = function() { | ||
if (mongoose.connections[0].readyState === 0) { | ||
@@ -31,8 +31,8 @@ var dbOptions = this.mailer.options.dbs.mongoDB; | ||
mongoose.connection.on('error', function (err) { | ||
console.error('MongoDB connection error: ' + err); | ||
process.exit(-1); | ||
console.error('MongoDB connection error: ' + err); | ||
process.exit(-1); | ||
}); | ||
if (dbOptions.debug) { | ||
mongoose.set('debug', true); | ||
mongoose.set('debug', true); | ||
} | ||
@@ -61,2 +61,8 @@ } | ||
console.error(new Date(), message._id.toString(), 'message queued'); | ||
LogElement.create({ | ||
createdAt: new Date(), | ||
messageId: message._id, | ||
status: 'queued', | ||
data: {message: message} | ||
}); | ||
}; | ||
@@ -86,2 +92,8 @@ | ||
console.error(new Date(), message._id.toString(), 'sended failed', response); | ||
LogElement.create({ | ||
createdAt: new Date(), | ||
messageId: message._id, | ||
status: 'error', | ||
data: {error: response, message: message}, | ||
}); | ||
}; | ||
@@ -111,2 +123,8 @@ | ||
console.log(new Date(), message._id.toString(), 'sended success'); | ||
LogElement.create({ | ||
createdAt: new Date(), | ||
messageId: message._id, | ||
status: 'send_success', | ||
data: {message: message} | ||
}); | ||
}; | ||
@@ -117,2 +135,2 @@ | ||
return new Logger(mailer); | ||
} | ||
}; |
@@ -32,3 +32,3 @@ var events = require('events'); | ||
Dispatcher.prototype.set = function(key, value) { | ||
if (arguments.length == 1) { | ||
if (arguments.length === 1) { | ||
return this.options[key]; | ||
@@ -35,0 +35,0 @@ } |
@@ -13,3 +13,3 @@ 'use strict'; | ||
this.options = {}; | ||
this.dispatcher = dispatcher(mailer, { sendWrapper: require('./send')(mailer) } ); | ||
this.dispatcher = dispatcher(mailer, {sendWrapper: require('./send')(mailer)}); | ||
} | ||
@@ -30,3 +30,3 @@ | ||
Queue.prototype.set = function(key, value) { | ||
if (arguments.length == 1) { | ||
if (arguments.length === 1) { | ||
return this.options[key]; | ||
@@ -33,0 +33,0 @@ } |
@@ -20,3 +20,5 @@ var should = require('should'); | ||
var doneCol = function (err) { | ||
if(err || ++count == 2) return done(err); | ||
if (err || ++count === 2) { | ||
return done(err); | ||
} | ||
}; | ||
@@ -23,0 +25,0 @@ var mailer = { |
{ | ||
"name": "posteon", | ||
"description": " ", | ||
"version": "0.1.4", | ||
"version": "0.1.5", | ||
"keywords": [ | ||
@@ -27,3 +27,4 @@ "mailer", | ||
"dependencies": { | ||
"lodash": "~4.7.0" | ||
"lodash": "~4.7.0", | ||
"mongoose": "^4.6.0" | ||
}, | ||
@@ -30,0 +31,0 @@ "devDependencies": { |
23525
862
2
18
+ Addedmongoose@^4.6.0
+ Addedasync@2.6.0(transitive)
+ Addedbluebird@3.5.0(transitive)
+ Addedbson@1.0.9(transitive)
+ Addedbuffer-shims@1.0.0(transitive)
+ Addedcore-util-is@1.0.3(transitive)
+ Addeddebug@2.6.9(transitive)
+ Addedes6-promise@3.2.1(transitive)
+ Addedhooks-fixed@2.0.2(transitive)
+ Addedinherits@2.0.4(transitive)
+ Addedisarray@1.0.0(transitive)
+ Addedkareem@1.5.0(transitive)
+ Addedlodash@4.17.21(transitive)
+ Addedlodash.get@4.4.2(transitive)
+ Addedmongodb@2.2.34(transitive)
+ Addedmongodb-core@2.1.18(transitive)
+ Addedmongoose@4.13.21(transitive)
+ Addedmpath@0.5.1(transitive)
+ Addedmpromise@0.5.5(transitive)
+ Addedmquery@2.3.3(transitive)
+ Addedms@2.0.0(transitive)
+ Addedmuri@1.3.0(transitive)
+ Addedprocess-nextick-args@1.0.7(transitive)
+ Addedreadable-stream@2.2.7(transitive)
+ Addedregexp-clone@0.0.1(transitive)
+ Addedrequire_optional@1.0.1(transitive)
+ Addedresolve-from@2.0.0(transitive)
+ Addedsafe-buffer@5.1.2(transitive)
+ Addedsemver@5.7.2(transitive)
+ Addedsliced@0.0.51.0.1(transitive)
+ Addedstring_decoder@1.0.3(transitive)
+ Addedutil-deprecate@1.0.2(transitive)