2 // System.Net.Mail.SmtpClient.cs
5 // Tim Coleman (tim@timcoleman.com)
7 // Copyright (C) Tim Coleman, 2004
11 // Permission is hereby granted, free of charge, to any person obtaining
12 // a copy of this software and associated documentation files (the
13 // "Software"), to deal in the Software without restriction, including
14 // without limitation the rights to use, copy, modify, merge, publish,
15 // distribute, sublicense, and/or sell copies of the Software, and to
16 // permit persons to whom the Software is furnished to do so, subject to
17 // the following conditions:
19 // The above copyright notice and this permission notice shall be
20 // included in all copies or substantial portions of the Software.
22 // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
23 // EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
24 // MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
25 // NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
26 // LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
27 // OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
28 // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
33 #if MONOTOUCH || MONODROID
34 using System.Security.Cryptography.X509Certificates;
36 extern alias PrebuiltSystem;
37 using X509CertificateCollection = PrebuiltSystem::System.Security.Cryptography.X509Certificates.X509CertificateCollection;
38 using System.Security.Cryptography.X509Certificates;
44 using System.Collections.Generic;
45 using System.ComponentModel;
46 using System.Globalization;
49 using System.Net.Mime;
50 using System.Net.Sockets;
52 using System.Threading;
53 using System.Reflection;
54 using System.Net.Configuration;
55 using System.Configuration;
56 using System.Net.Security;
57 using System.Security.Authentication;
59 using System.Threading.Tasks;
62 namespace System.Net.Mail {
63 public class SmtpClient
73 ICredentialsByHost credentials;
74 string pickupDirectoryLocation;
75 SmtpDeliveryMethod deliveryMethod;
78 X509CertificateCollection clientCertificates;
86 MailAddress defaultFrom;
88 MailMessage messageInProcess;
90 BackgroundWorker worker;
91 object user_async_state;
100 class CancellationException : Exception
105 Mutex mutex = new Mutex ();
116 public SmtpClient (string host)
121 public SmtpClient (string host, int port) {
122 #if CONFIGURATION_DEP
123 SmtpSection cfg = (SmtpSection) ConfigurationManager.GetSection ("system.net/mailSettings/smtp");
126 this.host = cfg.Network.Host;
127 this.port = cfg.Network.Port;
129 this.enableSsl = cfg.Network.EnableSsl;
131 TargetName = cfg.Network.TargetName;
132 if (this.TargetName == null)
133 TargetName = "SMTPSVC/" + (host != null ? host : "");
136 if (cfg.Network.UserName != null) {
137 string password = String.Empty;
139 if (cfg.Network.Password != null)
140 password = cfg.Network.Password;
142 Credentials = new CCredentialsByHost (cfg.Network.UserName, password);
145 if (!String.IsNullOrEmpty (cfg.From))
146 defaultFrom = new MailAddress (cfg.From);
149 // Just to eliminate the warning, this codepath does not end up in production.
153 if (!String.IsNullOrEmpty (host))
158 else if (this.port == 0)
162 #endregion // Constructors
167 [MonoTODO("Client certificates not used")]
168 public X509CertificateCollection ClientCertificates {
170 if (clientCertificates == null)
171 clientCertificates = new X509CertificateCollection ();
172 return clientCertificates;
180 string TargetName { get; set; }
182 public ICredentialsByHost Credentials {
183 get { return credentials; }
190 public SmtpDeliveryMethod DeliveryMethod {
191 get { return deliveryMethod; }
194 deliveryMethod = value;
198 public bool EnableSsl {
199 get { return enableSsl; }
210 throw new ArgumentNullException ("value");
211 if (value.Length == 0)
212 throw new ArgumentException ("An empty string is not allowed.", "value");
218 public string PickupDirectoryLocation {
219 get { return pickupDirectoryLocation; }
220 set { pickupDirectoryLocation = value; }
227 throw new ArgumentOutOfRangeException ("value");
234 public ServicePoint ServicePoint {
235 get { throw new NotImplementedException (); }
239 get { return timeout; }
242 throw new ArgumentOutOfRangeException ("value");
248 public bool UseDefaultCredentials {
249 get { return false; }
250 [MonoNotSupported ("no DefaultCredential support in Mono")]
253 throw new NotImplementedException ("Default credentials are not supported");
258 #endregion // Properties
262 public event SendCompletedEventHandler SendCompleted;
268 public void Dispose ()
273 [MonoTODO ("Does nothing at the moment.")]
274 protected virtual void Dispose (bool disposing)
276 // TODO: We should close all the connections and abort any async operations here
279 private void CheckState ()
281 if (messageInProcess != null)
282 throw new InvalidOperationException ("Cannot set Timeout while Sending a message");
285 private static string EncodeAddress(MailAddress address)
287 if (!String.IsNullOrEmpty (address.DisplayName)) {
288 string encodedDisplayName = ContentType.EncodeSubjectRFC2047 (address.DisplayName, Encoding.UTF8);
289 return "\"" + encodedDisplayName + "\" <" + address.Address + ">";
291 return address.ToString ();
294 private static string EncodeAddresses(MailAddressCollection addresses)
296 StringBuilder sb = new StringBuilder();
298 foreach (MailAddress address in addresses) {
302 sb.Append(EncodeAddress(address));
305 return sb.ToString();
308 private string EncodeSubjectRFC2047 (MailMessage message)
310 return ContentType.EncodeSubjectRFC2047 (message.Subject, message.SubjectEncoding);
313 private string EncodeBody (MailMessage message)
315 string body = message.Body;
316 Encoding encoding = message.BodyEncoding;
318 switch (message.ContentTransferEncoding) {
319 case TransferEncoding.SevenBit:
321 case TransferEncoding.Base64:
322 return Convert.ToBase64String (encoding.GetBytes (body), Base64FormattingOptions.InsertLineBreaks);
324 return ToQuotedPrintable (body, encoding);
328 private string EncodeBody (AlternateView av)
330 //Encoding encoding = av.ContentType.CharSet != null ? Encoding.GetEncoding (av.ContentType.CharSet) : Encoding.UTF8;
332 byte [] bytes = new byte [av.ContentStream.Length];
333 av.ContentStream.Read (bytes, 0, bytes.Length);
336 switch (av.TransferEncoding) {
337 case TransferEncoding.SevenBit:
338 return Encoding.ASCII.GetString (bytes);
339 case TransferEncoding.Base64:
340 return Convert.ToBase64String (bytes, Base64FormattingOptions.InsertLineBreaks);
342 return ToQuotedPrintable (bytes);
347 private void EndSection (string section)
349 SendData (String.Format ("--{0}--", section));
350 SendData (string.Empty);
353 private string GenerateBoundary ()
355 string output = GenerateBoundary (boundaryIndex);
360 private static string GenerateBoundary (int index)
362 return String.Format ("--boundary_{0}_{1}", index, Guid.NewGuid ().ToString ("D"));
365 private bool IsError (SmtpResponse status)
367 return ((int) status.StatusCode) >= 400;
370 protected void OnSendCompleted (AsyncCompletedEventArgs e)
373 if (SendCompleted != null)
374 SendCompleted (this, e);
377 user_async_state = null;
381 private void CheckCancellation ()
383 if (worker != null && worker.CancellationPending)
384 throw new CancellationException ();
387 private SmtpResponse Read () {
388 byte [] buffer = new byte [512];
390 bool lastLine = false;
393 CheckCancellation ();
395 int readLength = stream.Read (buffer, position, buffer.Length - position);
396 if (readLength > 0) {
397 int available = position + readLength - 1;
398 if (available > 4 && (buffer [available] == '\n' || buffer [available] == '\r'))
399 for (int index = available - 3; ; index--) {
400 if (index < 0 || buffer [index] == '\n' || buffer [index] == '\r') {
401 lastLine = buffer [index + 4] == ' ';
407 position += readLength;
409 // check if buffer is full
410 if (position == buffer.Length) {
411 byte [] newBuffer = new byte [buffer.Length * 2];
412 Array.Copy (buffer, 0, newBuffer, 0, buffer.Length);
422 Encoding encoding = new ASCIIEncoding ();
424 string line = encoding.GetString (buffer, 0, position - 1);
426 // parse the line to the lastResponse object
427 SmtpResponse response = SmtpResponse.Parse (line);
431 throw new System.IO.IOException ("Connection closed");
435 void ResetExtensions()
437 authMechs = AuthMechs.None;
440 void ParseExtensions (string extens)
442 string[] parts = extens.Split ('\n');
444 foreach (string part in parts) {
448 string start = part.Substring (4);
449 if (start.StartsWith ("AUTH ", StringComparison.Ordinal)) {
450 string[] options = start.Split (' ');
451 for (int k = 1; k < options.Length; k++) {
452 string option = options[k].Trim();
453 // GSSAPI, KERBEROS_V4, NTLM not supported
457 authMechs |= AuthMechs.CramMD5;
460 authMechs |= AuthMechs.DigestMD5;
464 authMechs |= AuthMechs.Login;
467 authMechs |= AuthMechs.Plain;
475 public void Send (MailMessage message)
478 throw new ArgumentNullException ("message");
480 if (deliveryMethod == SmtpDeliveryMethod.Network && (Host == null || Host.Trim ().Length == 0))
481 throw new InvalidOperationException ("The SMTP host was not specified");
482 else if (deliveryMethod == SmtpDeliveryMethod.PickupDirectoryFromIis)
483 throw new NotSupportedException("IIS delivery is not supported");
488 // Block while sending
491 messageInProcess = message;
492 if (deliveryMethod == SmtpDeliveryMethod.SpecifiedPickupDirectory)
493 SendToFile (message);
495 SendInternal (message);
496 } catch (CancellationException) {
497 // This exception is introduced for convenient cancellation process.
498 } catch (SmtpException) {
500 } catch (Exception ex) {
501 throw new SmtpException ("Message could not be sent.", ex);
503 // Release the mutex to allow other threads access
504 mutex.ReleaseMutex ();
505 messageInProcess = null;
509 private void SendInternal (MailMessage message)
511 CheckCancellation ();
514 client = new TcpClient (host, port);
515 stream = client.GetStream ();
516 // FIXME: this StreamWriter creation is bogus.
517 // It expects as if a Stream were able to switch to SSL
518 // mode (such behavior is only in Mainsoft Socket API).
519 writer = new StreamWriter (stream);
520 reader = new StreamReader (stream);
535 // FIXME: simple implementation, could be brushed up.
536 private void SendToFile (MailMessage message)
538 if (!Path.IsPathRooted (pickupDirectoryLocation))
539 throw new SmtpException("Only absolute directories are allowed for pickup directory.");
541 string filename = Path.Combine (pickupDirectoryLocation,
542 Guid.NewGuid() + ".eml");
545 writer = new StreamWriter(filename);
547 // FIXME: See how Microsoft fixed the bug about envelope senders, and how it actually represents the info in .eml file headers
548 // For all we know, defaultFrom may be the envelope sender
549 // For now, we are no worse than some versions of .NET
550 MailAddress from = message.From;
554 string dt = DateTime.Now.ToString("ddd, dd MMM yyyy HH':'mm':'ss zzz", DateTimeFormatInfo.InvariantInfo);
555 // remove ':' from time zone offset (e.g. from "+01:00")
556 dt = dt.Remove(dt.Length - 3, 1);
557 SendHeader(HeaderName.Date, dt);
559 SendHeader (HeaderName.From, EncodeAddress(from));
560 SendHeader (HeaderName.To, EncodeAddresses(message.To));
561 if (message.CC.Count > 0)
562 SendHeader (HeaderName.Cc, EncodeAddresses(message.CC));
563 SendHeader (HeaderName.Subject, EncodeSubjectRFC2047 (message));
565 foreach (string s in message.Headers.AllKeys)
566 SendHeader (s, message.Headers [s]);
568 AddPriorityHeader (message);
571 if (message.Attachments.Count > 0)
572 SendWithAttachments (message);
574 SendWithoutAttachments (message, null, false);
578 if (writer != null) writer.Close(); writer = null;
582 private void SendCore (MailMessage message)
587 if (IsError (status))
588 throw new SmtpException (status.StatusCode, status.Description);
592 // FIXME: parse the list of extensions so we don't bother wasting
593 // our time trying commands if they aren't supported.
594 status = SendCommand ("EHLO " + Dns.GetHostName ());
596 if (IsError (status)) {
597 status = SendCommand ("HELO " + Dns.GetHostName ());
599 if (IsError (status))
600 throw new SmtpException (status.StatusCode, status.Description);
602 // Parse ESMTP extensions
603 string extens = status.Description;
606 ParseExtensions (extens);
610 InitiateSecureConnection ();
612 writer = new StreamWriter (stream);
613 reader = new StreamReader (stream);
614 status = SendCommand ("EHLO " + Dns.GetHostName ());
616 if (IsError (status)) {
617 status = SendCommand ("HELO " + Dns.GetHostName ());
619 if (IsError (status))
620 throw new SmtpException (status.StatusCode, status.Description);
622 // Parse ESMTP extensions
623 string extens = status.Description;
625 ParseExtensions (extens);
629 if (authMechs != AuthMechs.None)
632 // The envelope sender: use 'Sender:' in preference of 'From:'
633 MailAddress sender = message.Sender;
635 sender = message.From;
637 sender = defaultFrom;
640 status = SendCommand ("MAIL FROM:<" + sender.Address + '>');
641 if (IsError (status)) {
642 throw new SmtpException (status.StatusCode, status.Description);
645 // Send RCPT TO: for all recipients
646 List<SmtpFailedRecipientException> sfre = new List<SmtpFailedRecipientException> ();
648 for (int i = 0; i < message.To.Count; i ++) {
649 status = SendCommand ("RCPT TO:<" + message.To [i].Address + '>');
650 if (IsError (status))
651 sfre.Add (new SmtpFailedRecipientException (status.StatusCode, message.To [i].Address));
653 for (int i = 0; i < message.CC.Count; i ++) {
654 status = SendCommand ("RCPT TO:<" + message.CC [i].Address + '>');
655 if (IsError (status))
656 sfre.Add (new SmtpFailedRecipientException (status.StatusCode, message.CC [i].Address));
658 for (int i = 0; i < message.Bcc.Count; i ++) {
659 status = SendCommand ("RCPT TO:<" + message.Bcc [i].Address + '>');
660 if (IsError (status))
661 sfre.Add (new SmtpFailedRecipientException (status.StatusCode, message.Bcc [i].Address));
664 #if TARGET_JVM // List<T>.ToArray () is not supported
665 if (sfre.Count > 0) {
666 SmtpFailedRecipientException[] xs = new SmtpFailedRecipientException[sfre.Count];
668 throw new SmtpFailedRecipientsException ("failed recipients", xs);
672 throw new SmtpFailedRecipientsException ("failed recipients", sfre.ToArray ());
676 status = SendCommand ("DATA");
677 if (IsError (status))
678 throw new SmtpException (status.StatusCode, status.Description);
680 // Send message headers
681 string dt = DateTime.Now.ToString ("ddd, dd MMM yyyy HH':'mm':'ss zzz", DateTimeFormatInfo.InvariantInfo);
682 // remove ':' from time zone offset (e.g. from "+01:00")
683 dt = dt.Remove (dt.Length - 3, 1);
684 SendHeader (HeaderName.Date, dt);
686 MailAddress from = message.From;
690 SendHeader (HeaderName.From, EncodeAddress (from));
691 SendHeader (HeaderName.To, EncodeAddresses (message.To));
692 if (message.CC.Count > 0)
693 SendHeader (HeaderName.Cc, EncodeAddresses (message.CC));
694 SendHeader (HeaderName.Subject, EncodeSubjectRFC2047 (message));
698 switch (message.Priority){
699 case MailPriority.Normal:
703 case MailPriority.Low:
707 case MailPriority.High:
711 SendHeader ("Priority", v);
712 if (message.Sender != null)
713 SendHeader ("Sender", EncodeAddress (message.Sender));
714 if (message.ReplyToList.Count > 0)
715 SendHeader ("Reply-To", EncodeAddresses (message.ReplyToList));
718 foreach (string s in message.Headers.AllKeys)
719 SendHeader (s, ContentType.EncodeSubjectRFC2047 (message.Headers [s], message.HeadersEncoding));
721 foreach (string s in message.Headers.AllKeys)
722 SendHeader (s, message.Headers [s]);
725 AddPriorityHeader (message);
728 if (message.Attachments.Count > 0)
729 SendWithAttachments (message);
731 SendWithoutAttachments (message, null, false);
736 if (IsError (status))
737 throw new SmtpException (status.StatusCode, status.Description);
740 status = SendCommand ("QUIT");
741 } catch (System.IO.IOException) {
742 // We excuse server for the rude connection closing as a response to QUIT
746 public void Send (string from, string to, string subject, string body)
748 Send (new MailMessage (from, to, subject, body));
752 public Task SendMailAsync (MailMessage message)
754 var tcs = new TaskCompletionSource<object> ();
755 SendCompletedEventHandler handler = null;
756 handler = (s, e) => SendMailAsyncCompletedHandler (tcs, e, handler, this);
757 SendCompleted += handler;
758 SendAsync (message, tcs);
762 public Task SendMailAsync (string from, string recipients, string subject, string body)
764 return SendMailAsync (new MailMessage (from, recipients, subject, body));
767 static void SendMailAsyncCompletedHandler (TaskCompletionSource<object> source, AsyncCompletedEventArgs e, SendCompletedEventHandler handler, SmtpClient client)
769 if (handler != e.UserState)
772 client.SendCompleted -= handler;
774 if (e.Error != null) {
775 source.SetException (e.Error);
780 source.SetCanceled ();
784 source.SetResult (null);
788 private void SendDot()
790 writer.Write(".\r\n");
794 private void SendData (string data)
796 if (String.IsNullOrEmpty (data)) {
797 writer.Write("\r\n");
802 StringReader sr = new StringReader (data);
804 bool escapeDots = deliveryMethod == SmtpDeliveryMethod.Network;
805 while ((line = sr.ReadLine ()) != null) {
806 CheckCancellation ();
810 for (i = 0; i < line.Length; i++) {
814 if (i > 0 && i == line.Length) {
819 writer.Write ("\r\n");
824 public void SendAsync (MailMessage message, object userToken)
827 throw new InvalidOperationException ("Another SendAsync operation is in progress");
829 worker = new BackgroundWorker ();
830 worker.DoWork += delegate (object o, DoWorkEventArgs ea) {
832 user_async_state = ea.Argument;
834 } catch (Exception ex) {
839 worker.WorkerSupportsCancellation = true;
840 worker.RunWorkerCompleted += delegate (object o, RunWorkerCompletedEventArgs ea) {
841 // Note that RunWorkerCompletedEventArgs.UserState cannot be used (LAMESPEC)
842 OnSendCompleted (new AsyncCompletedEventArgs (ea.Error, ea.Cancelled, user_async_state));
844 worker.RunWorkerAsync (userToken);
847 public void SendAsync (string from, string to, string subject, string body, object userToken)
849 SendAsync (new MailMessage (from, to, subject, body), userToken);
852 public void SendAsyncCancel ()
855 throw new InvalidOperationException ("SendAsync operation is not in progress");
856 worker.CancelAsync ();
859 private void AddPriorityHeader (MailMessage message) {
860 switch (message.Priority) {
861 case MailPriority.High:
862 SendHeader (HeaderName.Priority, "Urgent");
863 SendHeader (HeaderName.Importance, "high");
864 SendHeader (HeaderName.XPriority, "1");
866 case MailPriority.Low:
867 SendHeader (HeaderName.Priority, "Non-Urgent");
868 SendHeader (HeaderName.Importance, "low");
869 SendHeader (HeaderName.XPriority, "5");
874 private void SendSimpleBody (MailMessage message) {
875 SendHeader (HeaderName.ContentType, message.BodyContentType.ToString ());
876 if (message.ContentTransferEncoding != TransferEncoding.SevenBit)
877 SendHeader (HeaderName.ContentTransferEncoding, GetTransferEncodingName (message.ContentTransferEncoding));
878 SendData (string.Empty);
880 SendData (EncodeBody (message));
883 private void SendBodylessSingleAlternate (AlternateView av) {
884 SendHeader (HeaderName.ContentType, av.ContentType.ToString ());
885 if (av.TransferEncoding != TransferEncoding.SevenBit)
886 SendHeader (HeaderName.ContentTransferEncoding, GetTransferEncodingName (av.TransferEncoding));
887 SendData (string.Empty);
889 SendData (EncodeBody (av));
892 private void SendWithoutAttachments (MailMessage message, string boundary, bool attachmentExists)
894 if (message.Body == null && message.AlternateViews.Count == 1)
895 SendBodylessSingleAlternate (message.AlternateViews [0]);
896 else if (message.AlternateViews.Count > 0)
897 SendBodyWithAlternateViews (message, boundary, attachmentExists);
899 SendSimpleBody (message);
903 private void SendWithAttachments (MailMessage message) {
904 string boundary = GenerateBoundary ();
906 // first "multipart/mixed"
907 ContentType messageContentType = new ContentType ();
908 messageContentType.Boundary = boundary;
909 messageContentType.MediaType = "multipart/mixed";
910 messageContentType.CharSet = null;
912 SendHeader (HeaderName.ContentType, messageContentType.ToString ());
913 SendData (String.Empty);
916 Attachment body = null;
918 if (message.AlternateViews.Count > 0)
919 SendWithoutAttachments (message, boundary, true);
921 body = Attachment.CreateAttachmentFromString (message.Body, null, message.BodyEncoding, message.IsBodyHtml ? "text/html" : "text/plain");
922 message.Attachments.Insert (0, body);
926 SendAttachments (message, body, boundary);
929 message.Attachments.Remove (body);
932 EndSection (boundary);
935 private void SendBodyWithAlternateViews (MailMessage message, string boundary, bool attachmentExists)
937 AlternateViewCollection alternateViews = message.AlternateViews;
939 string inner_boundary = GenerateBoundary ();
941 ContentType messageContentType = new ContentType ();
942 messageContentType.Boundary = inner_boundary;
943 messageContentType.MediaType = "multipart/alternative";
945 if (!attachmentExists) {
946 SendHeader (HeaderName.ContentType, messageContentType.ToString ());
947 SendData (String.Empty);
951 AlternateView body = null;
952 if (message.Body != null) {
953 body = AlternateView.CreateAlternateViewFromString (message.Body, message.BodyEncoding, message.IsBodyHtml ? "text/html" : "text/plain");
954 alternateViews.Insert (0, body);
955 StartSection (boundary, messageContentType);
959 // alternate view sections
960 foreach (AlternateView av in alternateViews) {
962 string alt_boundary = null;
963 ContentType contentType;
964 if (av.LinkedResources.Count > 0) {
965 alt_boundary = GenerateBoundary ();
966 contentType = new ContentType ("multipart/related");
967 contentType.Boundary = alt_boundary;
969 contentType.Parameters ["type"] = av.ContentType.ToString ();
970 StartSection (inner_boundary, contentType);
971 StartSection (alt_boundary, av.ContentType, av);
973 contentType = new ContentType (av.ContentType.ToString ());
974 StartSection (inner_boundary, contentType, av);
977 switch (av.TransferEncoding) {
978 case TransferEncoding.Base64:
979 byte [] content = new byte [av.ContentStream.Length];
980 av.ContentStream.Read (content, 0, content.Length);
982 SendData (Convert.ToBase64String (content));
984 SendData (Convert.ToBase64String (content, Base64FormattingOptions.InsertLineBreaks));
987 case TransferEncoding.QuotedPrintable:
988 byte [] bytes = new byte [av.ContentStream.Length];
989 av.ContentStream.Read (bytes, 0, bytes.Length);
990 SendData (ToQuotedPrintable (bytes));
992 case TransferEncoding.SevenBit:
993 case TransferEncoding.Unknown:
994 content = new byte [av.ContentStream.Length];
995 av.ContentStream.Read (content, 0, content.Length);
996 SendData (Encoding.ASCII.GetString (content));
1000 if (av.LinkedResources.Count > 0) {
1001 SendLinkedResources (message, av.LinkedResources, alt_boundary);
1002 EndSection (alt_boundary);
1005 if (!attachmentExists)
1006 SendData (string.Empty);
1011 alternateViews.Remove (body);
1013 EndSection (inner_boundary);
1016 private void SendLinkedResources (MailMessage message, LinkedResourceCollection resources, string boundary)
1018 foreach (LinkedResource lr in resources) {
1019 StartSection (boundary, lr.ContentType, lr);
1021 switch (lr.TransferEncoding) {
1022 case TransferEncoding.Base64:
1023 byte [] content = new byte [lr.ContentStream.Length];
1024 lr.ContentStream.Read (content, 0, content.Length);
1026 SendData (Convert.ToBase64String (content));
1028 SendData (Convert.ToBase64String (content, Base64FormattingOptions.InsertLineBreaks));
1031 case TransferEncoding.QuotedPrintable:
1032 byte [] bytes = new byte [lr.ContentStream.Length];
1033 lr.ContentStream.Read (bytes, 0, bytes.Length);
1034 SendData (ToQuotedPrintable (bytes));
1036 case TransferEncoding.SevenBit:
1037 case TransferEncoding.Unknown:
1038 content = new byte [lr.ContentStream.Length];
1039 lr.ContentStream.Read (content, 0, content.Length);
1040 SendData (Encoding.ASCII.GetString (content));
1046 private void SendAttachments (MailMessage message, Attachment body, string boundary) {
1047 foreach (Attachment att in message.Attachments) {
1048 ContentType contentType = new ContentType (att.ContentType.ToString ());
1049 if (att.Name != null) {
1050 contentType.Name = att.Name;
1051 if (att.NameEncoding != null)
1052 contentType.CharSet = att.NameEncoding.HeaderName;
1053 att.ContentDisposition.FileName = att.Name;
1055 StartSection (boundary, contentType, att, att != body);
1057 byte [] content = new byte [att.ContentStream.Length];
1058 att.ContentStream.Read (content, 0, content.Length);
1059 switch (att.TransferEncoding) {
1060 case TransferEncoding.Base64:
1062 SendData (Convert.ToBase64String (content));
1064 SendData (Convert.ToBase64String (content, Base64FormattingOptions.InsertLineBreaks));
1067 case TransferEncoding.QuotedPrintable:
1068 SendData (ToQuotedPrintable (content));
1070 case TransferEncoding.SevenBit:
1071 case TransferEncoding.Unknown:
1072 SendData (Encoding.ASCII.GetString (content));
1076 SendData (string.Empty);
1080 private SmtpResponse SendCommand (string command)
1082 writer.Write (command);
1083 // Certain SMTP servers will reject mail sent with unix line-endings; see http://cr.yp.to/docs/smtplf.html
1084 writer.Write ("\r\n");
1089 private void SendHeader (string name, string value)
1091 SendData (String.Format ("{0}: {1}", name, value));
1094 private void StartSection (string section, ContentType sectionContentType)
1096 SendData (String.Format ("--{0}", section));
1097 SendHeader ("content-type", sectionContentType.ToString ());
1098 SendData (string.Empty);
1101 private void StartSection (string section, ContentType sectionContentType, AttachmentBase att)
1103 SendData (String.Format ("--{0}", section));
1104 SendHeader ("content-type", sectionContentType.ToString ());
1105 SendHeader ("content-transfer-encoding", GetTransferEncodingName (att.TransferEncoding));
1106 if (!string.IsNullOrEmpty (att.ContentId))
1107 SendHeader("content-ID", "<" + att.ContentId + ">");
1108 SendData (string.Empty);
1111 private void StartSection (string section, ContentType sectionContentType, Attachment att, bool sendDisposition) {
1112 SendData (String.Format ("--{0}", section));
1113 if (!string.IsNullOrEmpty (att.ContentId))
1114 SendHeader("content-ID", "<" + att.ContentId + ">");
1115 SendHeader ("content-type", sectionContentType.ToString ());
1116 SendHeader ("content-transfer-encoding", GetTransferEncodingName (att.TransferEncoding));
1117 if (sendDisposition)
1118 SendHeader ("content-disposition", att.ContentDisposition.ToString ());
1119 SendData (string.Empty);
1122 // use proper encoding to escape input
1123 private string ToQuotedPrintable (string input, Encoding enc)
1125 byte [] bytes = enc.GetBytes (input);
1126 return ToQuotedPrintable (bytes);
1129 private string ToQuotedPrintable (byte [] bytes)
1131 StringWriter writer = new StringWriter ();
1132 int charsInLine = 0;
1134 StringBuilder sb = new StringBuilder("=", 3);
1135 byte equalSign = (byte)'=';
1138 foreach (byte i in bytes) {
1139 if (i > 127 || i == equalSign) {
1141 sb.Append(Convert.ToString (i, 16).ToUpperInvariant ());
1144 c = Convert.ToChar (i);
1145 if (c == '\r' || c == '\n') {
1153 charsInLine += curLen;
1154 if (charsInLine > 75) {
1155 writer.Write ("=\r\n");
1156 charsInLine = curLen;
1161 writer.Write (sb.ToString ());
1164 return writer.ToString ();
1166 private static string GetTransferEncodingName (TransferEncoding encoding)
1169 case TransferEncoding.QuotedPrintable:
1170 return "quoted-printable";
1171 case TransferEncoding.SevenBit:
1173 case TransferEncoding.Base64:
1180 RemoteCertificateValidationCallback callback = delegate (object sender,
1181 X509Certificate certificate,
1183 SslPolicyErrors sslPolicyErrors) {
1184 // honor any exciting callback defined on ServicePointManager
1185 if (ServicePointManager.ServerCertificateValidationCallback != null)
1186 return ServicePointManager.ServerCertificateValidationCallback (sender, certificate, chain, sslPolicyErrors);
1187 // otherwise provide our own
1188 if (sslPolicyErrors != SslPolicyErrors.None)
1189 throw new InvalidOperationException ("SSL authentication error: " + sslPolicyErrors);
1194 private void InitiateSecureConnection () {
1195 SmtpResponse response = SendCommand ("STARTTLS");
1197 if (IsError (response)) {
1198 throw new SmtpException (SmtpStatusCode.GeneralFailure, "Server does not support secure connections.");
1202 ((NetworkStream) stream).ChangeToSSLSocket ();
1204 SslStream sslStream = new SslStream (stream, false, callback, null);
1205 CheckCancellation ();
1206 sslStream.AuthenticateAsClient (Host, this.ClientCertificates, SslProtocols.Default, false);
1210 throw new SystemException ("You are using an incomplete System.dll build");
1214 void Authenticate ()
1216 string user = null, pass = null;
1218 if (UseDefaultCredentials) {
1219 user = CredentialCache.DefaultCredentials.GetCredential (new System.Uri ("smtp://" + host), "basic").UserName;
1220 pass = CredentialCache.DefaultCredentials.GetCredential (new System.Uri ("smtp://" + host), "basic").Password;
1221 } else if (Credentials != null) {
1222 user = Credentials.GetCredential (host, port, "smtp").UserName;
1223 pass = Credentials.GetCredential (host, port, "smtp").Password;
1228 Authenticate (user, pass);
1231 void CheckStatus (SmtpResponse status, int i)
1233 if (((int) status.StatusCode) != i)
1234 throw new SmtpException (status.StatusCode, status.Description);
1237 void ThrowIfError (SmtpResponse status)
1239 if (IsError (status))
1240 throw new SmtpException (status.StatusCode, status.Description);
1243 void Authenticate (string user, string password)
1245 if (authMechs == AuthMechs.None)
1248 SmtpResponse status;
1250 if ((authMechs & AuthMechs.DigestMD5) != 0) {
1251 status = SendCommand ("AUTH DIGEST-MD5");
1252 CheckStatus (status, 334);
1253 string challenge = Encoding.ASCII.GetString (Convert.FromBase64String (status.Description.Substring (4)));
1254 Console.WriteLine ("CHALLENGE: {0}", challenge);
1255 DigestSession session = new DigestSession ();
1256 session.Parse (false, challenge);
1257 string response = session.Authenticate (this, user, password);
1258 status = SendCommand (Convert.ToBase64String (Encoding.UTF8.GetBytes (response)));
1259 CheckStatus (status, 235);
1261 if ((authMechs & AuthMechs.Login) != 0) {
1262 status = SendCommand ("AUTH LOGIN");
1263 CheckStatus (status, 334);
1264 status = SendCommand (Convert.ToBase64String (Encoding.UTF8.GetBytes (user)));
1265 CheckStatus (status, 334);
1266 status = SendCommand (Convert.ToBase64String (Encoding.UTF8.GetBytes (password)));
1267 CheckStatus (status, 235);
1268 } else if ((authMechs & AuthMechs.Plain) != 0) {
1269 string s = String.Format ("\0{0}\0{1}", user, password);
1270 s = Convert.ToBase64String (Encoding.UTF8.GetBytes (s));
1271 status = SendCommand ("AUTH PLAIN " + s);
1272 CheckStatus (status, 235);
1274 throw new SmtpException ("AUTH types PLAIN, LOGIN not supported by the server");
1278 #endregion // Methods
1280 // The HeaderName struct is used to store constant string values representing mail headers.
1281 private struct HeaderName {
1282 public const string ContentTransferEncoding = "Content-Transfer-Encoding";
1283 public const string ContentType = "Content-Type";
1284 public const string Bcc = "Bcc";
1285 public const string Cc = "Cc";
1286 public const string From = "From";
1287 public const string Subject = "Subject";
1288 public const string To = "To";
1289 public const string MimeVersion = "MIME-Version";
1290 public const string MessageId = "Message-ID";
1291 public const string Priority = "Priority";
1292 public const string Importance = "Importance";
1293 public const string XPriority = "X-Priority";
1294 public const string Date = "Date";
1297 // This object encapsulates the status code and description of an SMTP response.
1298 private struct SmtpResponse {
1299 public SmtpStatusCode StatusCode;
1300 public string Description;
1302 public static SmtpResponse Parse (string line) {
1303 SmtpResponse response = new SmtpResponse ();
1305 if (line.Length < 4)
1306 throw new SmtpException ("Response is to short " +
1309 if ((line [3] != ' ') && (line [3] != '-'))
1310 throw new SmtpException ("Response format is wrong.(" +
1313 // parse the response code
1314 response.StatusCode = (SmtpStatusCode) Int32.Parse (line.Substring (0, 3));
1316 // set the raw response
1317 response.Description = line;
1324 class CCredentialsByHost : ICredentialsByHost
1326 public CCredentialsByHost (string userName, string password) {
1327 this.userName = userName;
1328 this.password = password;
1331 public NetworkCredential GetCredential (string host, int port, string authenticationType) {
1332 return new NetworkCredential (userName, password);
1335 private string userName;
1336 private string password;