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
130
131
132
133
134
|
using System;
using System.Collections.Generic;
using System.Collections.Specialized;
using System.IO;
using System.Linq;
using System.Net;
using System.Net.Mail;
using System.Text;
using System.Web;
using System.Xml;
using CodeScales.Http;
using CodeScales.Http.Entity;
using CodeScales.Http.Entity.Mime;
using CodeScales.Http.Methods;
using HttpResponse = System.Web.HttpResponse;
namespace SendGridMail.Transport
{
public class REST : ITransport
{
// REST delivery settings
public const String Endpoint = "http://sendgrid.com/api/mail.send";
public const String JsonFormat = "json";
public const String XmlFormat = "xml";
private readonly List<KeyValuePair<String, String>> _query;
private readonly NetworkCredential _credentials;
private readonly NameValueCollection _queryParameters;
private readonly String _restEndpoint;
private readonly String _format;
public static REST GetInstance(NetworkCredential credentials, String url = Endpoint)
{
return new REST(credentials, url);
}
internal REST(NetworkCredential credentials, String url = Endpoint)
{
_credentials = credentials;
_format = XmlFormat;
_restEndpoint = url + "." + _format;
}
private List<KeyValuePair<String, String>> FetchFormParams(ISendGrid message)
{
var result = new List<KeyValuePair<string, string>>()
{
new KeyValuePair<String, String>("api_user", _credentials.UserName),
new KeyValuePair<String, String>("api_key", _credentials.Password),
new KeyValuePair<String, String>("headers", message.Headers.Count == 0 ? null : Utils.SerializeDictionary(message.Headers)),
new KeyValuePair<String, String>("replyto", message.ReplyTo.Length == 0 ? null : message.ReplyTo.ToList().First().Address),
new KeyValuePair<String, String>("from", message.From.Address),
new KeyValuePair<String, String>("fromname", message.From.DisplayName),
new KeyValuePair<String, String>("subject", message.Subject),
new KeyValuePair<String, String>("text", message.Text),
new KeyValuePair<String, String>("html", message.Html),
new KeyValuePair<String, String>("x-smtpapi", message.Header.AsJson())
};
if(message.To != null)
{
result = result.Concat(message.To.ToList().Select(a => new KeyValuePair<String, String>("to[]", a.Address)))
.Concat(message.To.ToList().Select(a => new KeyValuePair<String, String>("toname[]", a.DisplayName)))
.ToList();
}
if(message.Bcc != null)
{
result = result.Concat(message.Bcc.ToList().Select(a => new KeyValuePair<String, String>("bcc[]", a.Address)))
.ToList();
}
if(message.Cc != null)
{
result = result.Concat(message.Cc.ToList().Select(a => new KeyValuePair<String, String>("cc[]", a.Address)))
.ToList();
}
return result.Where(r => !String.IsNullOrEmpty(r.Value)).ToList();
}
private List<KeyValuePair<String, FileInfo>> FetchFileBodies(ISendGrid message)
{
if(message.Attachments == null)
return new List<KeyValuePair<string, FileInfo>>();
return message.Attachments.Select(name => new KeyValuePair<String, FileInfo>(name, new FileInfo(name))).ToList();
}
public void Deliver(ISendGrid message)
{
var client = new HttpClient();
var postMethod = new HttpPost(new Uri(_restEndpoint));
var multipartEntity = new MultipartEntity();
postMethod.Entity = multipartEntity;
var formParams = FetchFormParams(message);
formParams.ForEach(kvp => multipartEntity.AddBody(new StringBody(Encoding.UTF8, kvp.Key, kvp.Value)));
var files = FetchFileBodies(message);
files.ForEach(kvp => multipartEntity.AddBody(new FileBody("files["+kvp.Key+"]", kvp.Key, kvp.Value)));
CodeScales.Http.Methods.HttpResponse response = client.Execute(postMethod);
Console.WriteLine("Response Code: " + response.ResponseCode);
Console.WriteLine("Response Content: " + EntityUtils.ToString(response.Entity));
Console.WriteLine("Res");
var status = EntityUtils.ToString(response.Entity);
var stream = new MemoryStream(Encoding.UTF8.GetBytes(status));
using (var reader = XmlReader.Create(stream))
{
while (reader.Read())
{
if (reader.IsStartElement())
{
switch (reader.Name)
{
case "result":
break;
case "message": // success
return;
case "error": // failure
throw new ProtocolViolationException(status);
default:
throw new ArgumentException("Unknown element: " + reader.Name);
}
}
}
}
}
}
}
|
