Send Notification To iPhone Using WCF.

Hi,

I have used the below code,

public class PushNotification
{
// private static readonly Logger Logger = LogManager.GetCurrentClassLogger();
private TcpClient _apnsClient;
private SslStream _apnsSSLStream;
private X509Certificate2 _clientCertificate;
private X509CertificateCollection _certificatesCollection;
private bool _conected = false;
private Dictionary<int, string> _errorList = new Dictionary<int, string>();
private List _rejected = new List();
// private List _loglist = new List();
public void PushMessage(List DeviceTokens, string Messagetext, byte[] Certificate, string Certificatepassword, string HostName, int Port)
{
try
{
// Loading Apple error response list.
_errorList.Add(0, "No errors encountered");
_errorList.Add(1, "Processing error");
_errorList.Add(2, "Missing device token");
_errorList.Add(3, "Missing topic");
_errorList.Add(4, "Missing payload");
_errorList.Add(5, "Invalid token size");
_errorList.Add(6, "Invalid topic size");
_errorList.Add(7, "Invalid payload size");
_errorList.Add(8, "Invalid token");
_errorList.Add(255, "None (unknown)");
Messagetext = Messagetext.Replace("\n", "\\n");
_clientCertificate = new X509Certificate2(Certificate, Certificatepassword);
_certificatesCollection = new X509Certificate2Collection(_clientCertificate);
var PayLoad = "{\"aps\":{\"alert\":\"" + Messagetext + "\",\"badge\":0,\"sound\":\"default\"},\"content-available\":1}";
//var PayLoad = "{\"aps\":{\"alert\":\"" + Messagetext + "\",\"badge\":0,\"sound\":\"default\"}}";
if (!_conected)
Connect(HostName, Port, _certificatesCollection);
if (DeviceTokens.Count < 8999)
Send(DeviceTokens, Messagetext, PayLoad, HostName, Port);
else
{
const int pageSize = 8999;
int numberOfPages = (DeviceTokens.Count / pageSize) + (DeviceTokens.Count % pageSize == 0 ? 0 : 1);
int currentPage = 0;
while (currentPage < numberOfPages)
{
DeviceTokens = (DeviceTokens.Skip(currentPage * pageSize).Take(pageSize)).ToList();
Send(DeviceTokens, Messagetext, PayLoad, HostName, Port);
currentPage++;
}
}
Disconnect();
}
catch (Exception)
{
_conected = false;
throw;
}
}
private void Send(List DeviceTokenList, string Messagetext, String payload, string HostName, int Port)
{
//_loglist.Add("PushStarted On: " + DateTime.Now.ToString("d-m-yyyy HH:mm:ss:fff"));
foreach (var token in DeviceTokenList)
{
try
{
if (!_conected)
{
Connect(HostName, Port, _certificatesCollection);
//_loglist.Add("Connection Opened : " + DateTime.Now.ToString("d-mm-yyyy HH:mm:ss:fff"));
}
if (token.Length == 64) //check lenght of device token, if its shorter or longer stop generating Payload.
{
var memoryStream = new MemoryStream();
var binariwriter = new BinaryWriter(memoryStream);
binariwriter.Write((byte)2); // The command (version 2)
int frameLength = 1 + 2 + 32 + 1 + 2 + payload.Length;
this.writeIntBytes(binariwriter, frameLength, 4);
// DEVICE ID
binariwriter.Write((byte)1);
byte[] deviceTokenBytes = HexStringToByteArray(token);
this.writeIntBytes(binariwriter, deviceTokenBytes.Length, 2);
binariwriter.Write(deviceTokenBytes);
// PAYLOAD
binariwriter.Write((byte)2);
this.writeIntBytes(binariwriter, payload.Length, 2);
binariwriter.Write(Encoding.ASCII.GetBytes(payload), 0, payload.Length);
binariwriter.Flush();
_apnsSSLStream.Write(memoryStream.ToArray());
Disconnect();
//_loglist.Add("Connection Closed : " + DateTime.Now.ToString("d-mm-yyyy HH:mm:ss:fff"));
////Thread.Sleep(1000);
//var response = new byte[6];
//_apnsSSLStream.BeginRead(response, 0, 6, ReadResponse, new MyAsyncInfo(response, _apnsSSLStream));
}
}
catch (AuthenticationException ex)
{
Disconnect();
}
catch (Exception e)
{
Disconnect();
}
}
// _loglist.Add("PushCompleted On: " + DateTime.Now.ToString("d-m-yyyy HH:mm:ss:fff"));
}
private static byte[] HexStringToByteArray(string hexValue)
{
return Enumerable.Range(0, hexValue.Length)
.Where(x => x % 2 == 0)
.Select(x => Convert.ToByte(hexValue.Substring(x, 2), 16))
.ToArray();
}
private void writeIntBytes(BinaryWriter writer, int value, int Count)
{
byte[] bytes = null;
if (Count == 2)
bytes = BitConverter.GetBytes((Int16)value);
else if (Count == 4)
bytes = BitConverter.GetBytes((Int32)value);
else if (Count == 8)
bytes = BitConverter.GetBytes((Int64)value);
if (bytes != null)
{
Array.Reverse(bytes);
writer.Write(bytes, 0, Count);
}
}
private void Connect(string host, int port, X509CertificateCollection certificates)
{
try
{
_apnsClient = new TcpClient();
_apnsClient.Connect(host, port);
}
catch (SocketException ex)
{
//Logger.Error("An error occurred while connecting to APNS servers - " + ex.Message);
}
var sslOpened = OpenSslStream(host, certificates);
if (sslOpened)
{
_conected = true;
//Logger.Info("Conected.");
}
}
private bool OpenSslStream(string host, X509CertificateCollection certificates)
{
_apnsSSLStream = new SslStream(_apnsClient.GetStream(), false, new RemoteCertificateValidationCallback(validateServerCertificate), SelectLocalCertificate);
try
{
_apnsSSLStream.AuthenticateAsClient(host, certificates, SslProtocols.Tls, true);
}
catch (AuthenticationException ex)
{
//Logger.Error(ex.Message);
return false;
}
if (!_apnsSSLStream.IsMutuallyAuthenticated)
{
//Logger.Error("SSL Stream Failed to Authenticate");
return false;
}
if (!_apnsSSLStream.CanWrite)
{
// Logger.Error("SSL Stream is not Writable");
return false;
}
return true;
}
private bool validateServerCertificate(object sender, X509Certificate certificate, X509Chain chain, SslPolicyErrors sslPolicyErrors)
{
if (sslPolicyErrors == SslPolicyErrors.None)
return true;
return false;
}
private X509Certificate SelectLocalCertificate(object sender, string targetHost, X509CertificateCollection localCertificates, X509Certificate remoteCertificate, string[] acceptableIssuers)
{
return _clientCertificate;
}
private void Disconnect()
{
try
{
Thread.Sleep(500);
_apnsClient.Close();
_apnsSSLStream.Close();
_apnsSSLStream.Dispose();
_apnsSSLStream = null;
_conected = false;
//Logger.Info("Disconnected.");
}
catch (Exception ex)
{
// Logger.Error("An error occurred while disconnecting. - " + ex.Message);
}
}
private byte[] ReadMessage(SslStream sslStream)
{
var ms = new MemoryStream();
byte[] buffer = new byte[1024];
int bytes = -1;
do
{
bytes = sslStream.Read(buffer, 0, buffer.Length);
ms.Write(buffer, 0, bytes);
} while (bytes != 0);
return ms.ToArray();
}
}

1 Reply

Know the answer? Post it — somebody with the same question will find it here.

Esakki Muthu8y ago
Hi,
I have used the below code,
public class PushNotification

  {
      // private static readonly Logger Logger = LogManager.GetCurrentClassLogger();
      private TcpClient _apnsClient;
      private SslStream _apnsSSLStream;
      private X509Certificate2 _clientCertificate;
      private X509CertificateCollection _certificatesCollection;
      private bool _conected = false;
      private Dictionary<int, string> _errorList = new Dictionary<int, string>();
      private List _rejected = new List();
     // private List _loglist = new List();
      public void PushMessage(List DeviceTokens, string Messagetext, byte[] Certificate, string Certificatepassword, string HostName, int Port)
      {
          try
          {
              // Loading Apple error response list.
              _errorList.Add(0, "No errors encountered");
              _errorList.Add(1, "Processing error");
              _errorList.Add(2, "Missing device token");
              _errorList.Add(3, "Missing topic");
              _errorList.Add(4, "Missing payload");
              _errorList.Add(5, "Invalid token size");
              _errorList.Add(6, "Invalid topic size");
              _errorList.Add(7, "Invalid payload size");
              _errorList.Add(8, "Invalid token");
              _errorList.Add(255, "None (unknown)");

              Messagetext = Messagetext.Replace("\n", "\\n");
              _clientCertificate = new X509Certificate2(Certificate, Certificatepassword);
              _certificatesCollection = new X509Certificate2Collection(_clientCertificate);
              var PayLoad = "{\"aps\":{\"alert\":\"" + Messagetext + "\",\"badge\":0,\"sound\":\"default\"},\"content-available\":1}";
              //var PayLoad = "{\"aps\":{\"alert\":\"" + Messagetext + "\",\"badge\":0,\"sound\":\"default\"}}";
              if (!_conected)
                  Connect(HostName, Port, _certificatesCollection);

              if (DeviceTokens.Count < 8999)
                  Send(DeviceTokens, Messagetext, PayLoad, HostName, Port);
              else
              {
                  const int pageSize = 8999;
                  int numberOfPages = (DeviceTokens.Count / pageSize) + (DeviceTokens.Count % pageSize == 0 ? 0 : 1);
                  int currentPage = 0;

                  while (currentPage < numberOfPages)
                  {
                      DeviceTokens = (DeviceTokens.Skip(currentPage * pageSize).Take(pageSize)).ToList();
                      Send(DeviceTokens, Messagetext, PayLoad, HostName, Port);
                      currentPage++;
                  }
              }
              Disconnect();
          }
          catch (Exception)
          {
              _conected = false;
              throw;
          }

      }
      private void Send(List DeviceTokenList, string Messagetext, String payload, string HostName, int Port)
      {
          //_loglist.Add("PushStarted On: " + DateTime.Now.ToString("d-m-yyyy HH:mm:ss:fff"));
          foreach (var token in DeviceTokenList)
          {
              try
              {
                  if (!_conected)
                  {
                      Connect(HostName, Port, _certificatesCollection);
                      //_loglist.Add("Connection Opened : " + DateTime.Now.ToString("d-mm-yyyy HH:mm:ss:fff"));
                  }

                  if (token.Length == 64) //check lenght of device token, if its shorter or longer stop generating Payload.
                  {
                      var memoryStream = new MemoryStream();
                      var binariwriter = new BinaryWriter(memoryStream);
                      binariwriter.Write((byte)2);  // The command (version 2)
                      int frameLength = 1 + 2 + 32 + 1 + 2 + payload.Length;
                      this.writeIntBytes(binariwriter, frameLength, 4);
                      // DEVICE ID
                      binariwriter.Write((byte)1);
                      byte[] deviceTokenBytes = HexStringToByteArray(token);
                      this.writeIntBytes(binariwriter, deviceTokenBytes.Length, 2);
                      binariwriter.Write(deviceTokenBytes);
                      // PAYLOAD
                      binariwriter.Write((byte)2);
                      this.writeIntBytes(binariwriter, payload.Length, 2);
                      binariwriter.Write(Encoding.ASCII.GetBytes(payload), 0, payload.Length);
                      binariwriter.Flush();
                      _apnsSSLStream.Write(memoryStream.ToArray());
                      Disconnect();
                      //_loglist.Add("Connection Closed : " + DateTime.Now.ToString("d-mm-yyyy HH:mm:ss:fff"));
                      ////Thread.Sleep(1000);
                      //var response = new byte[6];
                      //_apnsSSLStream.BeginRead(response, 0, 6, ReadResponse, new MyAsyncInfo(response, _apnsSSLStream));

                  }
              }
              catch (AuthenticationException ex)
              {

                  Disconnect();
              }
              catch (Exception e)
              {
                  Disconnect();
              }
          }
         // _loglist.Add("PushCompleted On: " + DateTime.Now.ToString("d-m-yyyy HH:mm:ss:fff"));

      }
      private static byte[] HexStringToByteArray(string hexValue)
      {
          return Enumerable.Range(0, hexValue.Length)
                   .Where(x => x % 2 == 0)
                   .Select(x => Convert.ToByte(hexValue.Substring(x, 2), 16))
                   .ToArray();
      }
      private void writeIntBytes(BinaryWriter writer, int value, int Count)
      {
          byte[] bytes = null;
          if (Count == 2)
              bytes = BitConverter.GetBytes((Int16)value);
          else if (Count == 4)
              bytes = BitConverter.GetBytes((Int32)value);
          else if (Count == 8)
              bytes = BitConverter.GetBytes((Int64)value);

          if (bytes != null)
          {
              Array.Reverse(bytes);
              writer.Write(bytes, 0, Count);
          }
      }
      private void Connect(string host, int port, X509CertificateCollection certificates)
      {
          try
          {
              _apnsClient = new TcpClient();
              _apnsClient.Connect(host, port);
          }
          catch (SocketException ex)
          {
              //Logger.Error("An error occurred while connecting to APNS servers - " + ex.Message);
          }

          var sslOpened = OpenSslStream(host, certificates);

          if (sslOpened)
          {
              _conected = true;
              //Logger.Info("Conected.");
          }

      }
      private bool OpenSslStream(string host, X509CertificateCollection certificates)
      {
          _apnsSSLStream = new SslStream(_apnsClient.GetStream(), false, new RemoteCertificateValidationCallback(validateServerCertificate), SelectLocalCertificate);

          try
          {
              _apnsSSLStream.AuthenticateAsClient(host, certificates, SslProtocols.Tls, true);
          }
          catch (AuthenticationException ex)
          {
              //Logger.Error(ex.Message);
              return false;
          }

          if (!_apnsSSLStream.IsMutuallyAuthenticated)
          {
              //Logger.Error("SSL Stream Failed to Authenticate");
              return false;
          }

          if (!_apnsSSLStream.CanWrite)
          {
              // Logger.Error("SSL Stream is not Writable");
              return false;
          }
          return true;
      }
      private bool validateServerCertificate(object sender, X509Certificate certificate, X509Chain chain, SslPolicyErrors sslPolicyErrors)
      {
          if (sslPolicyErrors == SslPolicyErrors.None)
              return true;
          return false;
      }
      private X509Certificate SelectLocalCertificate(object sender, string targetHost, X509CertificateCollection localCertificates, X509Certificate remoteCertificate, string[] acceptableIssuers)
      {
          return _clientCertificate;
      }
      private void Disconnect()
      {
          try
          {
              Thread.Sleep(500);
              _apnsClient.Close();
              _apnsSSLStream.Close();
              _apnsSSLStream.Dispose();
              _apnsSSLStream = null;
              _conected = false;
              //Logger.Info("Disconnected.");
          }
          catch (Exception ex)
          {
              // Logger.Error("An error occurred while disconnecting. - " + ex.Message);
          }
      }
      private byte[] ReadMessage(SslStream sslStream)
      {
          var ms = new MemoryStream();
          byte[] buffer = new byte[1024];

          int bytes = -1;
          do
          {
              bytes = sslStream.Read(buffer, 0, buffer.Length);

              ms.Write(buffer, 0, bytes);

          } while (bytes != 0);

          return ms.ToArray();
      }


  }