mcs/class/System/System.Net.Mail/SmtpClient.cs

   1 //
   2 // System.Net.Mail.SmtpClient.cs
   3 //
   4 // Author:
   5 //      Tim Coleman (tim@timcoleman.com)
   6 //
   7 // Copyright (C) Tim Coleman, 2004
   8 //
   9
  10 //
  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:
  18 //
  19 // The above copyright notice and this permission notice shall be
  20 // included in all copies or substantial portions of the Software.
  21 //
  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.
  29 //
  30
  31 #if SECURITY_DEP
  32 #if MONO_SECURITY_ALIAS
  33 extern alias MonoSecurity;
  34 #endif
  35 #if MONO_X509_ALIAS
  36 extern alias PrebuiltSystem;
  37 #endif
  38
  39 #if MONO_SECURITY_ALIAS
  40 using MSI = MonoSecurity::Mono.Security.Interface;
  41 #else
  42 using MSI = Mono.Security.Interface;
  43 #endif
  44 #if MONO_X509_ALIAS
  45 using X509CertificateCollection = PrebuiltSystem::System.Security.Cryptography.X509Certificates.X509CertificateCollection;
  46 #else
  47 using X509CertificateCollection = System.Security.Cryptography.X509Certificates.X509CertificateCollection;
  48 #endif
  49 using System.Security.Cryptography.X509Certificates;
  50 #endif
  51
  52 using System;
  53 using System.Collections.Generic;
  54 using System.ComponentModel;
  55 using System.Globalization;
  56 using System.IO;
  57 using System.Net;
  58 using System.Net.Mime;
  59 using System.Net.Sockets;
  60 using System.Text;
  61 using System.Threading;
  62 using System.Net.Configuration;
  63 using System.Configuration;
  64 using System.Net.Security;
  65 using System.Security.Authentication;
  66 using System.Threading.Tasks;
  67 using Mono.Net.Security;
  68
  69 namespace System.Net.Mail {
  70         [Obsolete ("SmtpClient and its network of types are poorly designed, we strongly recommend you use https://github.com/jstedfast/MailKit and https://github.com/jstedfast/MimeKit instead")]
  71         public class SmtpClient
  72         : IDisposable
  73         {
  74                 #region Fields
  75
  76                 string host;
  77                 int port;
  78                 int timeout = 100000;
  79                 ICredentialsByHost credentials;
  80                 string pickupDirectoryLocation;
  81                 SmtpDeliveryMethod deliveryMethod;
  82                 bool enableSsl;
  83 #if SECURITY_DEP
  84                 X509CertificateCollection clientCertificates;
  85 #endif
  86
  87                 TcpClient client;
  88                 Stream stream;
  89                 StreamWriter writer;
  90                 StreamReader reader;
  91                 int boundaryIndex;
  92                 MailAddress defaultFrom;
  93
  94                 MailMessage messageInProcess;
  95
  96                 BackgroundWorker worker;
  97                 object user_async_state;
  98
  99                 [Flags]
 100                 enum AuthMechs {
 101                         None        = 0,
 102                         Login       = 0x01,
 103                         Plain       = 0x02,
 104                 }
 105
 106                 class CancellationException : Exception
 107                 {
 108                 }
 109
 110                 AuthMechs authMechs;
 111                 Mutex mutex = new Mutex ();
 112
 113                 #endregion // Fields
 114
 115                 #region Constructors
 116
 117                 public SmtpClient ()
 118                         : this (null, 0)
 119                 {
 120                 }
 121
 122                 public SmtpClient (string host)
 123                         : this (host, 0)
 124                 {
 125                 }
 126
 127                 public SmtpClient (string host, int port) {
 128 #if CONFIGURATION_DEP
 129                         SmtpSection cfg = (SmtpSection) ConfigurationManager.GetSection ("system.net/mailSettings/smtp");
 130
 131                         if (cfg != null) {
 132                                 this.host = cfg.Network.Host;
 133                                 this.port = cfg.Network.Port;
 134                                 this.enableSsl = cfg.Network.EnableSsl;
 135                                 TargetName = cfg.Network.TargetName;
 136                                 if (this.TargetName == null)
 137                                         TargetName = "SMTPSVC/" + (host != null ? host : "");
 138
 139
 140                                 if (cfg.Network.UserName != null) {
 141                                         string password = String.Empty;
 142
 143                                         if (cfg.Network.Password != null)
 144                                                 password = cfg.Network.Password;
 145
 146                                         Credentials = new CCredentialsByHost (cfg.Network.UserName, password);
 147                                 }
 148
 149                                 if (!String.IsNullOrEmpty (cfg.From))
 150                                         defaultFrom = new MailAddress (cfg.From);
 151                         }
 152 #else
 153                         // Just to eliminate the warning, this codepath does not end up in production.
 154                         defaultFrom = null;
 155 #endif
 156
 157                         if (!String.IsNullOrEmpty (host))
 158                                 this.host = host;
 159
 160                         if (port != 0)
 161                                 this.port = port;
 162                         else if (this.port == 0)
 163                                 this.port = 25;
 164                 }
 165
 166                 #endregion // Constructors
 167
 168                 #region Properties
 169
 170 #if SECURITY_DEP
 171                 [MonoTODO("Client certificates not used")]
 172                 public X509CertificateCollection ClientCertificates {
 173                         get {
 174                                 if (clientCertificates == null)
 175                                         clientCertificates = new X509CertificateCollection ();
 176                                 return clientCertificates;
 177                         }
 178                 }
 179 #endif
 180
 181                 public
 182                 string TargetName { get; set; }
 183
 184                 public ICredentialsByHost Credentials {
 185                         get { return credentials; }
 186                         set {
 187                                 CheckState ();
 188                                 credentials = value;
 189                         }
 190                 }
 191
 192                 public SmtpDeliveryMethod DeliveryMethod {
 193                         get { return deliveryMethod; }
 194                         set {
 195                                 CheckState ();
 196                                 deliveryMethod = value;
 197                         }
 198                 }
 199
 200                 public bool EnableSsl {
 201                         get { return enableSsl; }
 202                         set {
 203                                 CheckState ();
 204                                 enableSsl = value;
 205                         }
 206                 }
 207
 208                 public string Host {
 209                         get { return host; }
 210                         set {
 211                                 if (value == null)
 212                                         throw new ArgumentNullException ("value");
 213                                 if (value.Length == 0)
 214                                         throw new ArgumentException ("An empty string is not allowed.", "value");
 215                                 CheckState ();
 216                                 host = value;
 217                         }
 218                 }
 219
 220                 public string PickupDirectoryLocation {
 221                         get { return pickupDirectoryLocation; }
 222                         set { pickupDirectoryLocation = value; }
 223                 }
 224
 225                 public int Port {
 226                         get { return port; }
 227                         set {
 228                                 if (value <= 0)
 229                                         throw new ArgumentOutOfRangeException ("value");
 230                                 CheckState ();
 231                                 port = value;
 232                         }
 233                 }
 234
 235                 [MonoTODO]
 236                 public ServicePoint ServicePoint {
 237                         get { throw new NotImplementedException (); }
 238                 }
 239
 240                 public int Timeout {
 241                         get { return timeout; }
 242                         set {
 243                                 if (value < 0)
 244                                         throw new ArgumentOutOfRangeException ("value");
 245                                 CheckState ();
 246                                 timeout = value;
 247                         }
 248                 }
 249
 250                 public bool UseDefaultCredentials {
 251                         get { return false; }
 252                         [MonoNotSupported ("no DefaultCredential support in Mono")]
 253                         set {
 254                                 if (value)
 255                                         throw new NotImplementedException ("Default credentials are not supported");
 256                                 CheckState ();
 257                         }
 258                 }
 259
 260                 #endregion // Properties
 261
 262                 #region Events
 263
 264                 public event SendCompletedEventHandler SendCompleted;
 265
 266                 #endregion // Events
 267
 268                 #region Methods
 269                 public void Dispose ()
 270                 {
 271                         Dispose (true);
 272                 }
 273
 274                 [MonoTODO ("Does nothing at the moment.")]
 275                 protected virtual void Dispose (bool disposing)
 276                 {
 277                         // TODO: We should close all the connections and abort any async operations here
 278                 }
 279                 private void CheckState ()
 280                 {
 281                         if (messageInProcess != null)
 282                                 throw new InvalidOperationException ("Cannot set Timeout while Sending a message");
 283                 }
 284
 285                 private static string EncodeAddress(MailAddress address)
 286                 {
 287                         if (!String.IsNullOrEmpty (address.DisplayName)) {
 288                                 string encodedDisplayName = ContentType.EncodeSubjectRFC2047 (address.DisplayName, Encoding.UTF8);
 289                                 return "\"" + encodedDisplayName + "\" <" + address.Address + ">";
 290                         }
 291                         return address.ToString ();
 292                 }
 293
 294                 private static string EncodeAddresses(MailAddressCollection addresses)
 295                 {
 296                         StringBuilder sb = new StringBuilder();
 297                         bool first = true;
 298                         foreach (MailAddress address in addresses) {
 299                                 if (!first) {
 300                                         sb.Append(", ");
 301                                 }
 302                                 sb.Append(EncodeAddress(address));
 303                                 first = false;
 304                         }
 305                         return sb.ToString();
 306                 }
 307
 308                 private string EncodeSubjectRFC2047 (MailMessage message)
 309                 {
 310                         return ContentType.EncodeSubjectRFC2047 (message.Subject, message.SubjectEncoding);
 311                 }
 312
 313                 private string EncodeBody (MailMessage message)
 314                 {
 315                         string body = message.Body;
 316                         Encoding encoding = message.BodyEncoding;
 317                         // RFC 2045 encoding
 318                         switch (message.ContentTransferEncoding) {
 319                         case TransferEncoding.SevenBit:
 320                                 return body;
 321                         case TransferEncoding.Base64:
 322                                 return Convert.ToBase64String (encoding.GetBytes (body), Base64FormattingOptions.InsertLineBreaks);
 323                         default:
 324                                 return ToQuotedPrintable (body, encoding);
 325                         }
 326                 }
 327
 328                 private string EncodeBody (AlternateView av)
 329                 {
 330                         //Encoding encoding = av.ContentType.CharSet != null ? Encoding.GetEncoding (av.ContentType.CharSet) : Encoding.UTF8;
 331
 332                         byte [] bytes = new byte [av.ContentStream.Length];
 333                         av.ContentStream.Read (bytes, 0, bytes.Length);
 334
 335                         // RFC 2045 encoding
 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);
 341                         default:
 342                                 return ToQuotedPrintable (bytes);
 343                         }
 344                 }
 345
 346
 347                 private void EndSection (string section)
 348                 {
 349                         SendData (String.Format ("--{0}--", section));
 350                         SendData (string.Empty);
 351                 }
 352
 353                 private string GenerateBoundary ()
 354                 {
 355                         string output = GenerateBoundary (boundaryIndex);
 356                         boundaryIndex += 1;
 357                         return output;
 358                 }
 359
 360                 private static string GenerateBoundary (int index)
 361                 {
 362                         return String.Format ("--boundary_{0}_{1}", index, Guid.NewGuid ().ToString ("D"));
 363                 }
 364
 365                 private bool IsError (SmtpResponse status)
 366                 {
 367                         return ((int) status.StatusCode) >= 400;
 368                 }
 369
 370                 protected void OnSendCompleted (AsyncCompletedEventArgs e)
 371                 {
 372                         try {
 373                                 if (SendCompleted != null)
 374                                         SendCompleted (this, e);
 375                         } finally {
 376                                 worker = null;
 377                                 user_async_state = null;
 378                         }
 379                 }
 380
 381                 private void CheckCancellation ()
 382                 {
 383                         if (worker != null && worker.CancellationPending)
 384                                 throw new CancellationException ();
 385                 }
 386
 387                 private SmtpResponse Read () {
 388                         byte [] buffer = new byte [512];
 389                         int position = 0;
 390                         bool lastLine = false;
 391
 392                         do {
 393                                 CheckCancellation ();
 394
 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] == ' ';
 402                                                                 break;
 403                                                         }
 404                                                 }
 405
 406                                         // move position
 407                                         position += readLength;
 408
 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);
 413                                                 buffer = newBuffer;
 414                                         }
 415                                 }
 416                                 else {
 417                                         break;
 418                                 }
 419                         } while (!lastLine);
 420
 421                         if (position > 0) {
 422                                 Encoding encoding = new ASCIIEncoding ();
 423
 424                                 string line = encoding.GetString (buffer, 0, position - 1);
 425
 426                                 // parse the line to the lastResponse object
 427                                 SmtpResponse response = SmtpResponse.Parse (line);
 428
 429                                 return response;
 430                         } else {
 431                                 throw new System.IO.IOException ("Connection closed");
 432                         }
 433                 }
 434
 435                 void ResetExtensions()
 436                 {
 437                         authMechs = AuthMechs.None;
 438                 }
 439
 440                 void ParseExtensions (string extens)
 441                 {
 442                         string[] parts = extens.Split ('\n');
 443
 444                         foreach (string part in parts) {
 445                                 if (part.Length < 4)
 446                                         continue;
 447
 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
 454                                                 switch (option) {
 455                                                 /*
 456                                                 case "CRAM-MD5":
 457                                                         authMechs |= AuthMechs.CramMD5;
 458                                                         break;
 459                                                 case "DIGEST-MD5":
 460                                                         authMechs |= AuthMechs.DigestMD5;
 461                                                         break;
 462                                                 */
 463                                                 case "LOGIN":
 464                                                         authMechs |= AuthMechs.Login;
 465                                                         break;
 466                                                 case "PLAIN":
 467                                                         authMechs |= AuthMechs.Plain;
 468                                                         break;
 469                                                 }
 470                                         }
 471                                 }
 472                         }
 473                 }
 474
 475                 public void Send (MailMessage message)
 476                 {
 477                         if (message == null)
 478                                 throw new ArgumentNullException ("message");
 479
 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");
 484
 485                         if (port == 0)
 486                                 port = 25;
 487
 488                         // Block while sending
 489                         mutex.WaitOne ();
 490                         try {
 491                                 messageInProcess = message;
 492                                 if (deliveryMethod == SmtpDeliveryMethod.SpecifiedPickupDirectory)
 493                                         SendToFile (message);
 494                                 else
 495                                         SendInternal (message);
 496                         } catch (CancellationException) {
 497                                 // This exception is introduced for convenient cancellation process.
 498                         } catch (SmtpException) {
 499                                 throw;
 500                         } catch (Exception ex) {
 501                                 throw new SmtpException ("Message could not be sent.", ex);
 502                         } finally {
 503                                 // Release the mutex to allow other threads access
 504                                 mutex.ReleaseMutex ();
 505                                 messageInProcess = null;
 506                         }
 507                 }
 508
 509                 private void SendInternal (MailMessage message)
 510                 {
 511                         CheckCancellation ();
 512
 513                         try {
 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);
 521
 522                                 SendCore (message);
 523                         } finally {
 524                                 if (writer != null)
 525                                         writer.Close ();
 526                                 if (reader != null)
 527                                         reader.Close ();
 528                                 if (stream != null)
 529                                         stream.Close ();
 530                                 if (client != null)
 531                                         client.Close ();
 532                         }
 533                 }
 534
 535                 // FIXME: simple implementation, could be brushed up.
 536                 private void SendToFile (MailMessage message)
 537                 {
 538                         if (!Path.IsPathRooted (pickupDirectoryLocation))
 539                                 throw new SmtpException("Only absolute directories are allowed for pickup directory.");
 540
 541                         string filename = Path.Combine (pickupDirectoryLocation,
 542                                 Guid.NewGuid() + ".eml");
 543
 544                         try {
 545                                 writer = new StreamWriter(filename);
 546
 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;
 551                                 if (from == null)
 552                                         from = defaultFrom;
 553
 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);
 558
 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));
 564
 565                                 foreach (string s in message.Headers.AllKeys)
 566                                         SendHeader (s, message.Headers [s]);
 567
 568                                 AddPriorityHeader (message);
 569
 570                                 boundaryIndex = 0;
 571                                 if (message.Attachments.Count > 0)
 572                                         SendWithAttachments (message);
 573                                 else
 574                                         SendWithoutAttachments (message, null, false);
 575
 576
 577                         } finally {
 578                                 if (writer != null) writer.Close(); writer = null;
 579                         }
 580                 }
 581
 582                 private void SendCore (MailMessage message)
 583                 {
 584                         SmtpResponse status;
 585
 586                         status = Read ();
 587                         if (IsError (status))
 588                                 throw new SmtpException (status.StatusCode, status.Description);
 589
 590                         // EHLO
 591
 592                         // FIXME: parse the list of extensions so we don't bother wasting
 593                         // our time trying commands if they aren't supported.
 594
 595                         // Get the FQDN of the local machine
 596                         string fqdn = Dns.GetHostEntry (Dns.GetHostName ()).HostName;
 597                         status = SendCommand ("EHLO " + fqdn);
 598
 599                         if (IsError (status)) {
 600                                 status = SendCommand ("HELO " + fqdn);
 601
 602                                 if (IsError (status))
 603                                         throw new SmtpException (status.StatusCode, status.Description);
 604                         } else {
 605                                 // Parse ESMTP extensions
 606                                 string extens = status.Description;
 607
 608                                 if (extens != null)
 609                                         ParseExtensions (extens);
 610                         }
 611
 612                         if (enableSsl) {
 613                                 InitiateSecureConnection ();
 614                                 ResetExtensions();
 615                                 writer = new StreamWriter (stream);
 616                                 reader = new StreamReader (stream);
 617                                 status = SendCommand ("EHLO " + fqdn);
 618
 619                                 if (IsError (status)) {
 620                                         status = SendCommand ("HELO " + fqdn);
 621
 622                                         if (IsError (status))
 623                                                 throw new SmtpException (status.StatusCode, status.Description);
 624                                 } else {
 625                                         // Parse ESMTP extensions
 626                                         string extens = status.Description;
 627                                         if (extens != null)
 628                                                 ParseExtensions (extens);
 629                                 }
 630                         }
 631
 632                         if (authMechs != AuthMechs.None)
 633                                 Authenticate ();
 634
 635                         // The envelope sender: use 'Sender:' in preference of 'From:'
 636                         MailAddress sender = message.Sender;
 637                         if (sender == null)
 638                                 sender = message.From;
 639                         if (sender == null)
 640                                 sender = defaultFrom;
 641
 642                         // MAIL FROM:
 643                         status = SendCommand ("MAIL FROM:<" + sender.Address + '>');
 644                         if (IsError (status)) {
 645                                 throw new SmtpException (status.StatusCode, status.Description);
 646                         }
 647
 648                         // Send RCPT TO: for all recipients
 649                         List<SmtpFailedRecipientException> sfre = new List<SmtpFailedRecipientException> ();
 650
 651                         for (int i = 0; i < message.To.Count; i ++) {
 652                                 status = SendCommand ("RCPT TO:<" + message.To [i].Address + '>');
 653                                 if (IsError (status))
 654                                         sfre.Add (new SmtpFailedRecipientException (status.StatusCode, message.To [i].Address));
 655                         }
 656                         for (int i = 0; i < message.CC.Count; i ++) {
 657                                 status = SendCommand ("RCPT TO:<" + message.CC [i].Address + '>');
 658                                 if (IsError (status))
 659                                         sfre.Add (new SmtpFailedRecipientException (status.StatusCode, message.CC [i].Address));
 660                         }
 661                         for (int i = 0; i < message.Bcc.Count; i ++) {
 662                                 status = SendCommand ("RCPT TO:<" + message.Bcc [i].Address + '>');
 663                                 if (IsError (status))
 664                                         sfre.Add (new SmtpFailedRecipientException (status.StatusCode, message.Bcc [i].Address));
 665                         }
 666
 667                         if (sfre.Count >0)
 668                                 throw new SmtpFailedRecipientsException ("failed recipients", sfre.ToArray ());
 669
 670                         // DATA
 671                         status = SendCommand ("DATA");
 672                         if (IsError (status))
 673                                 throw new SmtpException (status.StatusCode, status.Description);
 674
 675                         // Send message headers
 676                         string dt = DateTime.Now.ToString ("ddd, dd MMM yyyy HH':'mm':'ss zzz", DateTimeFormatInfo.InvariantInfo);
 677                         // remove ':' from time zone offset (e.g. from "+01:00")
 678                         dt = dt.Remove (dt.Length - 3, 1);
 679                         SendHeader (HeaderName.Date, dt);
 680
 681                         MailAddress from = message.From;
 682                         if (from == null)
 683                                 from = defaultFrom;
 684
 685                         SendHeader (HeaderName.From, EncodeAddress (from));
 686                         SendHeader (HeaderName.To, EncodeAddresses (message.To));
 687                         if (message.CC.Count > 0)
 688                                 SendHeader (HeaderName.Cc, EncodeAddresses (message.CC));
 689                         SendHeader (HeaderName.Subject, EncodeSubjectRFC2047 (message));
 690
 691                         string v = "normal";
 692
 693                         switch (message.Priority){
 694                         case MailPriority.Normal:
 695                                 v = "normal";
 696                                 break;
 697
 698                         case MailPriority.Low:
 699                                 v = "non-urgent";
 700                                 break;
 701
 702                         case MailPriority.High:
 703                                 v = "urgent";
 704                                 break;
 705                         }
 706                         SendHeader ("Priority", v);
 707                         if (message.Sender != null)
 708                                 SendHeader ("Sender", EncodeAddress (message.Sender));
 709                         if (message.ReplyToList.Count > 0)
 710                                 SendHeader ("Reply-To", EncodeAddresses (message.ReplyToList));
 711
 712                         foreach (string s in message.Headers.AllKeys)
 713                                 SendHeader (s, ContentType.EncodeSubjectRFC2047 (message.Headers [s], message.HeadersEncoding));
 714
 715                         AddPriorityHeader (message);
 716
 717                         boundaryIndex = 0;
 718                         if (message.Attachments.Count > 0)
 719                                 SendWithAttachments (message);
 720                         else
 721                                 SendWithoutAttachments (message, null, false);
 722
 723                         SendDot ();
 724
 725                         status = Read ();
 726                         if (IsError (status))
 727                                 throw new SmtpException (status.StatusCode, status.Description);
 728
 729                         try {
 730                                 status = SendCommand ("QUIT");
 731                         } catch (System.IO.IOException) {
 732                                 // We excuse server for the rude connection closing as a response to QUIT
 733                         }
 734                 }
 735
 736                 public void Send (string from, string to, string subject, string body)
 737                 {
 738                         Send (new MailMessage (from, to, subject, body));
 739                 }
 740
 741                 public Task SendMailAsync (MailMessage message)
 742                 {
 743                         var tcs = new TaskCompletionSource<object> ();
 744                         SendCompletedEventHandler handler = null;
 745                         handler = (s, e) => SendMailAsyncCompletedHandler (tcs, e, handler, this);
 746                         SendCompleted += handler;
 747                         SendAsync (message, tcs);
 748                         return tcs.Task;
 749                 }
 750
 751                 public Task SendMailAsync (string from, string recipients, string subject, string body)
 752                 {
 753                         return SendMailAsync (new MailMessage (from, recipients, subject, body));
 754                 }
 755
 756                 static void SendMailAsyncCompletedHandler (TaskCompletionSource<object> source, AsyncCompletedEventArgs e, SendCompletedEventHandler handler, SmtpClient client)
 757                 {
 758                         if (source != e.UserState)
 759                                 return;
 760
 761                         client.SendCompleted -= handler;
 762
 763                         if (e.Error != null) {
 764                                 source.SetException (e.Error);
 765                                 return;
 766                         }
 767
 768                         if (e.Cancelled) {
 769                                 source.SetCanceled ();
 770                                 return;
 771                         }
 772
 773                         source.SetResult (null);
 774                 }
 775
 776                 private void SendDot()
 777                 {
 778                         writer.Write(".\r\n");
 779                         writer.Flush();
 780                 }
 781
 782                 private void SendData (string data)
 783                 {
 784                         if (String.IsNullOrEmpty (data)) {
 785                                 writer.Write("\r\n");
 786                                 writer.Flush();
 787                                 return;
 788                         }
 789
 790                         StringReader sr = new StringReader (data);
 791                         string line;
 792                         bool escapeDots = deliveryMethod == SmtpDeliveryMethod.Network;
 793                         while ((line = sr.ReadLine ()) != null) {
 794                                 CheckCancellation ();
 795
 796                                 if (escapeDots) {
 797                                         int i;
 798                                         for (i = 0; i < line.Length; i++) {
 799                                                 if (line[i] != '.')
 800                                                         break;
 801                                         }
 802                                         if (i > 0 && i == line.Length) {
 803                                                 line += ".";
 804                                         }
 805                                 }
 806                                 writer.Write (line);
 807                                 writer.Write ("\r\n");
 808                         }
 809                         writer.Flush ();
 810                 }
 811
 812                 public void SendAsync (MailMessage message, object userToken)
 813                 {
 814                         if (worker != null)
 815                                 throw new InvalidOperationException ("Another SendAsync operation is in progress");
 816
 817                         worker = new BackgroundWorker ();
 818                         worker.DoWork += delegate (object o, DoWorkEventArgs ea) {
 819                                 try {
 820                                         user_async_state = ea.Argument;
 821                                         Send (message);
 822                                 } catch (Exception ex) {
 823                                         ea.Result = ex;
 824                                         throw ex;
 825                                 }
 826                         };
 827                         worker.WorkerSupportsCancellation = true;
 828                         worker.RunWorkerCompleted += delegate (object o, RunWorkerCompletedEventArgs ea) {
 829                                 // Note that RunWorkerCompletedEventArgs.UserState cannot be used (LAMESPEC)
 830                                 OnSendCompleted (new AsyncCompletedEventArgs (ea.Error, ea.Cancelled, user_async_state));
 831                         };
 832                         worker.RunWorkerAsync (userToken);
 833                 }
 834
 835                 public void SendAsync (string from, string to, string subject, string body, object userToken)
 836                 {
 837                         SendAsync (new MailMessage (from, to, subject, body), userToken);
 838                 }
 839
 840                 public void SendAsyncCancel ()
 841                 {
 842                         if (worker == null)
 843                                 throw new InvalidOperationException ("SendAsync operation is not in progress");
 844                         worker.CancelAsync ();
 845                 }
 846
 847                 private void AddPriorityHeader (MailMessage message) {
 848                         switch (message.Priority) {
 849                         case MailPriority.High:
 850                                 SendHeader (HeaderName.Priority, "Urgent");
 851                                 SendHeader (HeaderName.Importance, "high");
 852                                 SendHeader (HeaderName.XPriority, "1");
 853                                 break;
 854                         case MailPriority.Low:
 855                                 SendHeader (HeaderName.Priority, "Non-Urgent");
 856                                 SendHeader (HeaderName.Importance, "low");
 857                                 SendHeader (HeaderName.XPriority, "5");
 858                                 break;
 859                         }
 860                 }
 861
 862                 private void SendSimpleBody (MailMessage message) {
 863                         SendHeader (HeaderName.ContentType, message.BodyContentType.ToString ());
 864                         if (message.ContentTransferEncoding != TransferEncoding.SevenBit)
 865                                 SendHeader (HeaderName.ContentTransferEncoding, GetTransferEncodingName (message.ContentTransferEncoding));
 866                         SendData (string.Empty);
 867
 868                         SendData (EncodeBody (message));
 869                 }
 870
 871                 private void SendBodylessSingleAlternate (AlternateView av) {
 872                         SendHeader (HeaderName.ContentType, av.ContentType.ToString ());
 873                         if (av.TransferEncoding != TransferEncoding.SevenBit)
 874                                 SendHeader (HeaderName.ContentTransferEncoding, GetTransferEncodingName (av.TransferEncoding));
 875                         SendData (string.Empty);
 876
 877                         SendData (EncodeBody (av));
 878                 }
 879
 880                 private void SendWithoutAttachments (MailMessage message, string boundary, bool attachmentExists)
 881                 {
 882                         if (message.Body == null && message.AlternateViews.Count == 1)
 883                                 SendBodylessSingleAlternate (message.AlternateViews [0]);
 884                         else if (message.AlternateViews.Count > 0)
 885                                 SendBodyWithAlternateViews (message, boundary, attachmentExists);
 886                         else
 887                                 SendSimpleBody (message);
 888                 }
 889
 890
 891                 private void SendWithAttachments (MailMessage message) {
 892                         string boundary = GenerateBoundary ();
 893
 894                         // first "multipart/mixed"
 895                         ContentType messageContentType = new ContentType ();
 896                         messageContentType.Boundary = boundary;
 897                         messageContentType.MediaType = "multipart/mixed";
 898                         messageContentType.CharSet = null;
 899
 900                         SendHeader (HeaderName.ContentType, messageContentType.ToString ());
 901                         SendData (String.Empty);
 902
 903                         // body section
 904                         Attachment body = null;
 905
 906                         if (message.AlternateViews.Count > 0)
 907                                 SendWithoutAttachments (message, boundary, true);
 908                         else {
 909                                 body = Attachment.CreateAttachmentFromString (message.Body, null, message.BodyEncoding, message.IsBodyHtml ? "text/html" : "text/plain");
 910                                 message.Attachments.Insert (0, body);
 911                         }
 912
 913                         try {
 914                                 SendAttachments (message, body, boundary);
 915                         } finally {
 916                                 if (body != null)
 917                                         message.Attachments.Remove (body);
 918                         }
 919
 920                         EndSection (boundary);
 921                 }
 922
 923                 private void SendBodyWithAlternateViews (MailMessage message, string boundary, bool attachmentExists)
 924                 {
 925                         AlternateViewCollection alternateViews = message.AlternateViews;
 926
 927                         string inner_boundary = GenerateBoundary ();
 928
 929                         ContentType messageContentType = new ContentType ();
 930                         messageContentType.Boundary = inner_boundary;
 931                         messageContentType.MediaType = "multipart/alternative";
 932
 933                         if (!attachmentExists) {
 934                                 SendHeader (HeaderName.ContentType, messageContentType.ToString ());
 935                                 SendData (String.Empty);
 936                         }
 937
 938                         // body section
 939                         AlternateView body = null;
 940                         if (message.Body != null) {
 941                                 body = AlternateView.CreateAlternateViewFromString (message.Body, message.BodyEncoding, message.IsBodyHtml ? "text/html" : "text/plain");
 942                                 alternateViews.Insert (0, body);
 943                                 StartSection (boundary, messageContentType);
 944                         }
 945
 946 try {
 947                         // alternate view sections
 948                         foreach (AlternateView av in alternateViews) {
 949
 950                                 string alt_boundary = null;
 951                                 ContentType contentType;
 952                                 if (av.LinkedResources.Count > 0) {
 953                                         alt_boundary = GenerateBoundary ();
 954                                         contentType = new ContentType ("multipart/related");
 955                                         contentType.Boundary = alt_boundary;
 956
 957                                         contentType.Parameters ["type"] = av.ContentType.ToString ();
 958                                         StartSection (inner_boundary, contentType);
 959                                         StartSection (alt_boundary, av.ContentType, av);
 960                                 } else {
 961                                         contentType = new ContentType (av.ContentType.ToString ());
 962                                         StartSection (inner_boundary, contentType, av);
 963                                 }
 964
 965                                 switch (av.TransferEncoding) {
 966                                 case TransferEncoding.Base64:
 967                                         byte [] content = new byte [av.ContentStream.Length];
 968                                         av.ContentStream.Read (content, 0, content.Length);
 969                                             SendData (Convert.ToBase64String (content, Base64FormattingOptions.InsertLineBreaks));
 970                                         break;
 971                                 case TransferEncoding.QuotedPrintable:
 972                                         byte [] bytes = new byte [av.ContentStream.Length];
 973                                         av.ContentStream.Read (bytes, 0, bytes.Length);
 974                                         SendData (ToQuotedPrintable (bytes));
 975                                         break;
 976                                 case TransferEncoding.SevenBit:
 977                                 case TransferEncoding.Unknown:
 978                                         content = new byte [av.ContentStream.Length];
 979                                         av.ContentStream.Read (content, 0, content.Length);
 980                                         SendData (Encoding.ASCII.GetString (content));
 981                                         break;
 982                                 }
 983
 984                                 if (av.LinkedResources.Count > 0) {
 985                                         SendLinkedResources (message, av.LinkedResources, alt_boundary);
 986                                         EndSection (alt_boundary);
 987                                 }
 988
 989                                 if (!attachmentExists)
 990                                         SendData (string.Empty);
 991                         }
 992
 993 } finally {
 994                         if (body != null)
 995                                 alternateViews.Remove (body);
 996 }
 997                         EndSection (inner_boundary);
 998                 }
 999
1000                 private void SendLinkedResources (MailMessage message, LinkedResourceCollection resources, string boundary)
1001                 {
1002                         foreach (LinkedResource lr in resources) {
1003                                 StartSection (boundary, lr.ContentType, lr);
1004
1005                                 switch (lr.TransferEncoding) {
1006                                 case TransferEncoding.Base64:
1007                                         byte [] content = new byte [lr.ContentStream.Length];
1008                                         lr.ContentStream.Read (content, 0, content.Length);
1009                                             SendData (Convert.ToBase64String (content, Base64FormattingOptions.InsertLineBreaks));
1010                                         break;
1011                                 case TransferEncoding.QuotedPrintable:
1012                                         byte [] bytes = new byte [lr.ContentStream.Length];
1013                                         lr.ContentStream.Read (bytes, 0, bytes.Length);
1014                                         SendData (ToQuotedPrintable (bytes));
1015                                         break;
1016                                 case TransferEncoding.SevenBit:
1017                                 case TransferEncoding.Unknown:
1018                                         content = new byte [lr.ContentStream.Length];
1019                                         lr.ContentStream.Read (content, 0, content.Length);
1020                                         SendData (Encoding.ASCII.GetString (content));
1021                                         break;
1022                                 }
1023                         }
1024                 }
1025
1026                 private void SendAttachments (MailMessage message, Attachment body, string boundary) {
1027                         foreach (Attachment att in message.Attachments) {
1028                                 ContentType contentType = new ContentType (att.ContentType.ToString ());
1029                                 if (att.Name != null) {
1030                                         contentType.Name = att.Name;
1031                                         if (att.NameEncoding != null)
1032                                                 contentType.CharSet = att.NameEncoding.HeaderName;
1033                                         att.ContentDisposition.FileName = att.Name;
1034                                 }
1035                                 StartSection (boundary, contentType, att, att != body);
1036
1037                                 byte [] content = new byte [att.ContentStream.Length];
1038                                 att.ContentStream.Read (content, 0, content.Length);
1039                                 switch (att.TransferEncoding) {
1040                                 case TransferEncoding.Base64:
1041                                         SendData (Convert.ToBase64String (content, Base64FormattingOptions.InsertLineBreaks));
1042                                         break;
1043                                 case TransferEncoding.QuotedPrintable:
1044                                         SendData (ToQuotedPrintable (content));
1045                                         break;
1046                                 case TransferEncoding.SevenBit:
1047                                 case TransferEncoding.Unknown:
1048                                         SendData (Encoding.ASCII.GetString (content));
1049                                         break;
1050                                 }
1051
1052                                 SendData (string.Empty);
1053                         }
1054                 }
1055
1056                 private SmtpResponse SendCommand (string command)
1057                 {
1058                         writer.Write (command);
1059                         // Certain SMTP servers will reject mail sent with unix line-endings; see http://cr.yp.to/docs/smtplf.html
1060                         writer.Write ("\r\n");
1061                         writer.Flush ();
1062                         return Read ();
1063                 }
1064
1065                 private void SendHeader (string name, string value)
1066                 {
1067                         SendData (String.Format ("{0}: {1}", name, value));
1068                 }
1069
1070                 private void StartSection (string section, ContentType sectionContentType)
1071                 {
1072                         SendData (String.Format ("--{0}", section));
1073                         SendHeader ("content-type", sectionContentType.ToString ());
1074                         SendData (string.Empty);
1075                 }
1076
1077                 private void StartSection (string section, ContentType sectionContentType, AttachmentBase att)
1078                 {
1079                         SendData (String.Format ("--{0}", section));
1080                         SendHeader ("content-type", sectionContentType.ToString ());
1081                         SendHeader ("content-transfer-encoding", GetTransferEncodingName (att.TransferEncoding));
1082                         if (!string.IsNullOrEmpty (att.ContentId))
1083                                 SendHeader("content-ID", "<" + att.ContentId + ">");
1084                         SendData (string.Empty);
1085                 }
1086
1087                 private void StartSection (string section, ContentType sectionContentType, Attachment att, bool sendDisposition) {
1088                         SendData (String.Format ("--{0}", section));
1089                         if (!string.IsNullOrEmpty (att.ContentId))
1090                                 SendHeader("content-ID", "<" + att.ContentId + ">");
1091                         SendHeader ("content-type", sectionContentType.ToString ());
1092                         SendHeader ("content-transfer-encoding", GetTransferEncodingName (att.TransferEncoding));
1093                         if (sendDisposition)
1094                                 SendHeader ("content-disposition", att.ContentDisposition.ToString ());
1095                         SendData (string.Empty);
1096                 }
1097
1098                 // use proper encoding to escape input
1099                 private string ToQuotedPrintable (string input, Encoding enc)
1100                 {
1101                         byte [] bytes = enc.GetBytes (input);
1102                         return ToQuotedPrintable (bytes);
1103                 }
1104
1105                 private string ToQuotedPrintable (byte [] bytes)
1106                 {
1107                         StringWriter writer = new StringWriter ();
1108                         int charsInLine = 0;
1109                         int curLen;
1110                         StringBuilder sb = new StringBuilder("=", 3);
1111                         byte equalSign = (byte)'=';
1112                         char c = (char)0;
1113
1114                         foreach (byte i in bytes) {
1115                                 if (i > 127 || i == equalSign) {
1116                                         sb.Length = 1;
1117                                         sb.Append(Convert.ToString (i, 16).ToUpperInvariant ());
1118                                         curLen = 3;
1119                                 } else {
1120                                         c = Convert.ToChar (i);
1121                                         if (c == '\r' || c == '\n') {
1122                                                 writer.Write (c);
1123                                                 charsInLine = 0;
1124                                                 continue;
1125                                         }
1126                                         curLen = 1;
1127                                 }
1128
1129                                 charsInLine += curLen;
1130                                 if (charsInLine > 75) {
1131                                         writer.Write ("=\r\n");
1132                                         charsInLine = curLen;
1133                                 }
1134                                 if (curLen == 1)
1135                                         writer.Write (c);
1136                                 else
1137                                         writer.Write (sb.ToString ());
1138                         }
1139
1140                         return writer.ToString ();
1141                 }
1142                 private static string GetTransferEncodingName (TransferEncoding encoding)
1143                 {
1144                         switch (encoding) {
1145                         case TransferEncoding.QuotedPrintable:
1146                                 return "quoted-printable";
1147                         case TransferEncoding.SevenBit:
1148                                 return "7bit";
1149                         case TransferEncoding.Base64:
1150                                 return "base64";
1151                         }
1152                         return "unknown";
1153                 }
1154
1155                 private void InitiateSecureConnection () {
1156                         SmtpResponse response = SendCommand ("STARTTLS");
1157
1158                         if (IsError (response)) {
1159                                 throw new SmtpException (SmtpStatusCode.GeneralFailure, "Server does not support secure connections.");
1160                         }
1161
1162 #if SECURITY_DEP
1163                         var tlsProvider = MonoTlsProviderFactory.GetProviderInternal ();
1164                         var settings = new MSI.MonoTlsSettings ();
1165                         settings.UseServicePointManagerCallback = true;
1166                         var sslStream = tlsProvider.CreateSslStream (stream, false, settings);
1167                         CheckCancellation ();
1168                         sslStream.AuthenticateAsClient (Host, this.ClientCertificates, SslProtocols.Default, false);
1169                         stream = sslStream.AuthenticatedStream;
1170
1171 #else
1172                         throw new SystemException ("You are using an incomplete System.dll build");
1173 #endif
1174                 }
1175
1176                 void Authenticate ()
1177                 {
1178                         string user = null, pass = null;
1179
1180                         if (UseDefaultCredentials) {
1181                                 user = CredentialCache.DefaultCredentials.GetCredential (new System.Uri ("smtp://" + host), "basic").UserName;
1182                                 pass =  CredentialCache.DefaultCredentials.GetCredential (new System.Uri ("smtp://" + host), "basic").Password;
1183                         } else if (Credentials != null) {
1184                                 user = Credentials.GetCredential (host, port, "smtp").UserName;
1185                                 pass = Credentials.GetCredential (host, port, "smtp").Password;
1186                         } else {
1187                                 return;
1188                         }
1189
1190                         Authenticate (user, pass);
1191                 }
1192
1193                 void CheckStatus (SmtpResponse status, int i)
1194                 {
1195                         if (((int) status.StatusCode) != i)
1196                                 throw new SmtpException (status.StatusCode, status.Description);
1197                 }
1198
1199                 void ThrowIfError (SmtpResponse status)
1200                 {
1201                         if (IsError (status))
1202                                 throw new SmtpException (status.StatusCode, status.Description);
1203                 }
1204
1205                 void Authenticate (string user, string password)
1206                 {
1207                         if (authMechs == AuthMechs.None)
1208                                 return;
1209
1210                         SmtpResponse status;
1211                         /*
1212                         if ((authMechs & AuthMechs.DigestMD5) != 0) {
1213                                 status = SendCommand ("AUTH DIGEST-MD5");
1214                                 CheckStatus (status, 334);
1215                                 string challenge = Encoding.ASCII.GetString (Convert.FromBase64String (status.Description.Substring (4)));
1216                                 Console.WriteLine ("CHALLENGE: {0}", challenge);
1217                                 DigestSession session = new DigestSession ();
1218                                 session.Parse (false, challenge);
1219                                 string response = session.Authenticate (this, user, password);
1220                                 status = SendCommand (Convert.ToBase64String (Encoding.UTF8.GetBytes (response)));
1221                                 CheckStatus (status, 235);
1222                         } else */
1223                         if ((authMechs & AuthMechs.Login) != 0) {
1224                                 status = SendCommand ("AUTH LOGIN");
1225                                 CheckStatus (status, 334);
1226                                 status = SendCommand (Convert.ToBase64String (Encoding.UTF8.GetBytes (user)));
1227                                 CheckStatus (status, 334);
1228                                 status = SendCommand (Convert.ToBase64String (Encoding.UTF8.GetBytes (password)));
1229                                 CheckStatus (status, 235);
1230                         } else if ((authMechs & AuthMechs.Plain) != 0) {
1231                                 string s = String.Format ("\0{0}\0{1}", user, password);
1232                                 s = Convert.ToBase64String (Encoding.UTF8.GetBytes (s));
1233                                 status = SendCommand ("AUTH PLAIN " + s);
1234                                 CheckStatus (status, 235);
1235                         } else {
1236                                 throw new SmtpException ("AUTH types PLAIN, LOGIN not supported by the server");
1237                         }
1238                 }
1239
1240                 #endregion // Methods
1241
1242                 // The HeaderName struct is used to store constant string values representing mail headers.
1243                 private struct HeaderName {
1244                         public const string ContentTransferEncoding = "Content-Transfer-Encoding";
1245                         public const string ContentType = "Content-Type";
1246                         public const string Bcc = "Bcc";
1247                         public const string Cc = "Cc";
1248                         public const string From = "From";
1249                         public const string Subject = "Subject";
1250                         public const string To = "To";
1251                         public const string MimeVersion = "MIME-Version";
1252                         public const string MessageId = "Message-ID";
1253                         public const string Priority = "Priority";
1254                         public const string Importance = "Importance";
1255                         public const string XPriority = "X-Priority";
1256                         public const string Date = "Date";
1257                 }
1258
1259                 // This object encapsulates the status code and description of an SMTP response.
1260                 private struct SmtpResponse {
1261                         public SmtpStatusCode StatusCode;
1262                         public string Description;
1263
1264                         public static SmtpResponse Parse (string line) {
1265                                 SmtpResponse response = new SmtpResponse ();
1266
1267                                 if (line.Length < 4)
1268                                         throw new SmtpException ("Response is to short " +
1269                                                                  line.Length + ".");
1270
1271                                 if ((line [3] != ' ') && (line [3] != '-'))
1272                                         throw new SmtpException ("Response format is wrong.(" +
1273                                                                  line + ")");
1274
1275                                 // parse the response code
1276                                 response.StatusCode = (SmtpStatusCode) Int32.Parse (line.Substring (0, 3));
1277
1278                                 // set the raw response
1279                                 response.Description = line;
1280
1281                                 return response;
1282                         }
1283                 }
1284         }
1285
1286         class CCredentialsByHost : ICredentialsByHost
1287         {
1288                 public CCredentialsByHost (string userName, string password) {
1289                         this.userName = userName;
1290                         this.password = password;
1291                 }
1292
1293                 public NetworkCredential GetCredential (string host, int port, string authenticationType) {
1294                         return new NetworkCredential (userName, password);
1295                 }
1296
1297                 private string userName;
1298                 private string password;
1299         }
1300 }
1301