1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
|
"use strict";
var package_json = require('./../package.json');
var nodemailer = require('nodemailer');
var request = require('request');
var Email = require('./email');
var SmtpapiHeaders = require('./smtpapi_headers');
module.exports = function(api_user, api_key) {
var self;
var send = function(email, callback) {
web(email, callback);
}
/*
* Sends an email via web and returns true if the
* message was sent successfully.
*
* @param {Email|Object} email An email object or a hash that has
* the values for the email to be sent.
* @param {Function} callback A function to call when the processing is done.
* This parameter is optional.
*/
var web = function(email, callback) {
self = this;
var callback = callback || function() { };
if (email.constructor !== Email) {
email = new Email(email);
}
_sendWeb(email, callback);
};
/*
* Sends an email via SMTP and returns true if the
* message was sent successfully.
*
* @param {Email|Object} email An email object or a hash that has
* the values for the email to be sent.
* @param {Function} callback A function to call when the processing is done.
* This parameter is optional.
*/
var smtp = function(email, callback) {
self = this;
var callback = callback || function() { };
if (email.constructor !== Email) {
email = new Email(email);
}
_sendSmtp(email, callback);
};
/*
* Psuedo-private methods
*/
var _sendWeb = function(email, callback) {
var req = request({
method : 'POST',
uri : "https://sendgrid.com/api/mail.send.json"
}, function(err, resp, body) {
if(err) return callback(err, null);
var json = JSON.parse(body);
if (json.message !== 'success') {
var error = 'sendgrid error';
if (json.errors) { error = json.errors.shift(); }
return callback(new Error(error), null);
}
return callback(null, json);
});
var form = email.toWebFormat();
form['api_user'] = api_user;
form['api_key'] = api_key;
var reqForm = req.form();
for (var field in form) {
var value = form[field];
if (value && value.filename) {
if (value.cid) {
reqForm.append("content["+value.filename+"]", value.cid);
}
reqForm.append("files["+value.filename+"]", value.content, {filename: value.filename, contentType: value.contentType});
} else {
try {
reqForm.append(field, value);
} catch(err) {}
}
}
}
var _sendSmtp = function(email, callback) {
// SMTP settings
var smtpTransport = nodemailer.createTransport(self.SMTP, {
service: 'SendGrid',
auth: {
user: api_user,
pass: api_key
}
});
smtpTransport.sendMail(email.toSmtpFormat(), function(error, response) {
smtpTransport.close();
if(error) { return callback(new Error(error.data), null);}
return callback(null, {'message': 'success'});
});
}
/*
* Expose public API calls
*/
return {
version : package_json.version,
SMTP : "SMTP",
Email : Email,
SmtpapiHeaders : SmtpapiHeaders,
api_user : api_user,
api_key : api_key,
web : web,
smtp : smtp,
send : send
};
}
|
