Skip to content

Add Firebase Messaging #765

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
wants to merge 7 commits into
base: master
Choose a base branch
from
Open

Add Firebase Messaging #765

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
7 commits
Select commit Hold shift + click to select a range
39cd3b5
Reformat all cods and update packages and .net
Freydoonk Oct 24, 2016
c7f8f98
Reformat all cods and update packages and upgrate to .net 4.6.1
Freydoonk Oct 24, 2016
cd08108
Merge branch 'master' of https://github.com/Freydoonk/PushSharp
Freydoonk Oct 24, 2016
6481ab1
Add Firebase Messaging
Freydoonk Oct 29, 2016
cfa9fdc
Add settings-sample.json to project
Freydoonk Oct 29, 2016
75e1111
Add AssemblyInfo to Firebase project
Freydoonk Nov 5, 2016
ac6dc85
Merge from head project
Freydoonk Dec 7, 2016
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions .gitignore
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -33,3 +33,4 @@ node_modules/
.vs/

settings.json
/UnitTestProject1
51 changes: 25 additions & 26 deletions PushSharp.Amazon/AdmConfiguration.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,34 +2,33 @@

namespace PushSharp.Amazon
{
public class AdmConfiguration
{
const string ADM_SEND_URL = "https://api.amazon.com/messaging/registrations/{0}/messages";
const string ADM_AUTH_URL = "https://api.amazon.com/auth/O2/token";
public class AdmConfiguration
{
const string ADM_SEND_URL = "https://api.amazon.com/messaging/registrations/{0}/messages";
const string ADM_AUTH_URL = "https://api.amazon.com/auth/O2/token";

public AdmConfiguration (string clientId, string clientSecret)
{
ClientId = clientId;
ClientSecret = clientSecret;
AdmSendUrl = ADM_SEND_URL;
AdmAuthUrl = ADM_AUTH_URL;
}
public AdmConfiguration(string clientId, string clientSecret)
{
ClientId = clientId;
ClientSecret = clientSecret;
AdmSendUrl = ADM_SEND_URL;
AdmAuthUrl = ADM_AUTH_URL;
}

public string ClientId { get; private set; }
public string ClientSecret { get; private set; }
public string ClientId { get; private set; }
public string ClientSecret { get; private set; }

public string AdmSendUrl { get; private set; }
public string AdmAuthUrl { get; private set; }
public string AdmSendUrl { get; private set; }
public string AdmAuthUrl { get; private set; }

public void OverrideSendUrl(string url)
{
AdmSendUrl = url;
}

public void OverrideAuthUrl(string url)
{
AdmAuthUrl = url;
}
}
}
public void OverrideSendUrl(string url)
{
AdmSendUrl = url;
}

public void OverrideAuthUrl(string url)
{
AdmAuthUrl = url;
}
}
}
291 changes: 146 additions & 145 deletions PushSharp.Amazon/AdmConnection.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,154 +1,155 @@
using System;
using System.Threading.Tasks;
using System.Collections.Generic;
using System.Net;
using System.Net.Http;
using System.Net.Http.Headers;
using System.Threading.Tasks;
using Newtonsoft.Json.Linq;
using System.Net;
using PushSharp.Core;
using System.Collections.Generic;
using System.Linq;
using System.Runtime.Serialization;
using System.Threading;

namespace PushSharp.Amazon
{
public class AdmServiceConnectionFactory : IServiceConnectionFactory<AdmNotification>
{
public AdmServiceConnectionFactory (AdmConfiguration configuration)
{
Configuration = configuration;
}

public AdmConfiguration Configuration { get; private set; }

public IServiceConnection<AdmNotification> Create()
{
return new AdmServiceConnection (Configuration);
}
}

public class AdmServiceBroker : ServiceBroker<AdmNotification>
{
public AdmServiceBroker (AdmConfiguration configuration) : base (new AdmServiceConnectionFactory (configuration))
{
}
}

public class AdmServiceConnection : IServiceConnection<AdmNotification>
{
public AdmServiceConnection (AdmConfiguration configuration)
{
Configuration = configuration;

Expires = DateTime.UtcNow.AddYears(-1);

http.DefaultRequestHeaders.Add ("X-Amzn-Type-Version", "[email protected]");
http.DefaultRequestHeaders.Add ("X-Amzn-Accept-Type", "[email protected]");
http.DefaultRequestHeaders.Add ("Accept", "application/json");
http.DefaultRequestHeaders.ConnectionClose = true;

http.DefaultRequestHeaders.Remove("connection");
}

public AdmConfiguration Configuration { get; private set; }

public DateTime Expires { get; set; }
public DateTime LastRequest { get; private set; }
public string LastAmazonRequestId { get; private set; }
public string AccessToken { get; private set; }

readonly HttpClient http = new HttpClient ();

public async Task Send (AdmNotification notification)
{
try
{
if (string.IsNullOrEmpty(AccessToken) || Expires <= DateTime.UtcNow) {
await UpdateAccessToken ();
http.DefaultRequestHeaders.TryAddWithoutValidation("Authorization", "Bearer " + AccessToken);
//http.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", AccessToken);
}

var sc = new StringContent(notification.ToJson ());
sc.Headers.ContentType = new MediaTypeHeaderValue("application/json");

var response = await http.PostAsync (string.Format(Configuration.AdmSendUrl, notification.RegistrationId), sc);

// We're done here if it was a success
if (response.IsSuccessStatusCode) {
return;
}

var data = await response.Content.ReadAsStringAsync();

var json = JObject.Parse (data);

var reason = json ["reason"].ToString ();

var regId = notification.RegistrationId;

if (json["registrationID"] != null)
regId = json["registrationID"].ToString();

switch (response.StatusCode)
{
case HttpStatusCode.BadGateway: //400
case HttpStatusCode.BadRequest: //
if ("InvalidRegistrationId".Equals (reason, StringComparison.InvariantCultureIgnoreCase)) {
throw new DeviceSubscriptionExpiredException (notification) {
OldSubscriptionId = regId,
ExpiredAt = DateTime.UtcNow
};
}
throw new NotificationException ("Notification Failed: " + reason, notification);
case HttpStatusCode.Unauthorized: //401
//Access token expired
AccessToken = null;
throw new UnauthorizedAccessException ("Access token failed authorization");
case HttpStatusCode.Forbidden: //403
throw new AdmRateLimitExceededException (reason, notification);
case HttpStatusCode.RequestEntityTooLarge: //413
throw new AdmMessageTooLargeException (notification);
default:
throw new NotificationException ("Unknown ADM Failure", notification);
}
}
catch (Exception ex)
{
throw new NotificationException ("Unknown ADM Failure", notification, ex);
}
}


async Task UpdateAccessToken()
{
var http = new HttpClient ();

var param = new Dictionary<string, string> ();
param.Add ("grant_type", "client_credentials");
param.Add ("scope", "messaging:push");
param.Add ("client_id", Configuration.ClientId);
param.Add ("client_secret", Configuration.ClientSecret);


var result = await http.PostAsync (Configuration.AdmAuthUrl, new FormUrlEncodedContent (param));
var data = await result.Content.ReadAsStringAsync();

var json = JObject.Parse (data);

AccessToken = json ["access_token"].ToString ();

JToken expiresJson = new JValue(3540);
if (json.TryGetValue("expires_in", out expiresJson))
Expires = DateTime.UtcNow.AddSeconds(expiresJson.ToObject<int>() - 60);
else
Expires = DateTime.UtcNow.AddSeconds(3540);

if (result.Headers.Contains ("X-Amzn-RequestId"))
this.LastAmazonRequestId = string.Join("; ", result.Headers.GetValues("X-Amzn-RequestId"));

LastRequest = DateTime.UtcNow;
}

}
public class AdmServiceConnectionFactory : IServiceConnectionFactory<AdmNotification>
{
public AdmServiceConnectionFactory(AdmConfiguration configuration)
{
Configuration = configuration;
}

public AdmConfiguration Configuration { get; private set; }

public IServiceConnection<AdmNotification> Create()
{
return new AdmServiceConnection(Configuration);
}
}

public class AdmServiceBroker : ServiceBroker<AdmNotification>
{
public AdmServiceBroker(AdmConfiguration configuration) : base(new AdmServiceConnectionFactory(configuration))
{
}
}

public class AdmServiceConnection : IServiceConnection<AdmNotification>
{
public AdmServiceConnection(AdmConfiguration configuration)
{
Configuration = configuration;

Expires = DateTime.UtcNow.AddYears(-1);

http.DefaultRequestHeaders.Add("X-Amzn-Type-Version", "[email protected]");
http.DefaultRequestHeaders.Add("X-Amzn-Accept-Type", "[email protected]");
http.DefaultRequestHeaders.Add("Accept", "application/json");
http.DefaultRequestHeaders.ConnectionClose = true;

http.DefaultRequestHeaders.Remove("connection");
}

public AdmConfiguration Configuration { get; private set; }

public DateTime Expires { get; set; }
public DateTime LastRequest { get; private set; }
public string LastAmazonRequestId { get; private set; }
public string AccessToken { get; private set; }

readonly HttpClient http = new HttpClient();

public async Task Send(AdmNotification notification)
{
try
{
if (string.IsNullOrEmpty(AccessToken) || Expires <= DateTime.UtcNow)
{
await UpdateAccessToken();
http.DefaultRequestHeaders.TryAddWithoutValidation("Authorization", "Bearer " + AccessToken);
//http.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", AccessToken);
}

var sc = new StringContent(notification.ToJson());
sc.Headers.ContentType = new MediaTypeHeaderValue("application/json");

var response = await http.PostAsync(string.Format(Configuration.AdmSendUrl, notification.RegistrationId), sc);

// We're done here if it was a success
if (response.IsSuccessStatusCode)
{
return;
}

var data = await response.Content.ReadAsStringAsync();

var json = JObject.Parse(data);

var reason = json["reason"].ToString();

var regId = notification.RegistrationId;

if (json["registrationID"] != null)
regId = json["registrationID"].ToString();

switch (response.StatusCode)
{
case HttpStatusCode.BadGateway: //400
case HttpStatusCode.BadRequest: //
if ("InvalidRegistrationId".Equals(reason, StringComparison.InvariantCultureIgnoreCase))
{
throw new DeviceSubscriptionExpiredException(notification)
{
OldSubscriptionId = regId,
ExpiredAt = DateTime.UtcNow
};
}
throw new NotificationException("Notification Failed: " + reason, notification);
case HttpStatusCode.Unauthorized: //401
//Access token expired
AccessToken = null;
throw new UnauthorizedAccessException("Access token failed authorization");
case HttpStatusCode.Forbidden: //403
throw new AdmRateLimitExceededException(reason, notification);
case HttpStatusCode.RequestEntityTooLarge: //413
throw new AdmMessageTooLargeException(notification);
default:
throw new NotificationException("Unknown ADM Failure", notification);
}
}
catch (Exception ex)
{
throw new NotificationException("Unknown ADM Failure", notification, ex);
}
}


async Task UpdateAccessToken()
{
var http = new HttpClient();

var param = new Dictionary<string, string>();
param.Add("grant_type", "client_credentials");
param.Add("scope", "messaging:push");
param.Add("client_id", Configuration.ClientId);
param.Add("client_secret", Configuration.ClientSecret);


var result = await http.PostAsync(Configuration.AdmAuthUrl, new FormUrlEncodedContent(param));
var data = await result.Content.ReadAsStringAsync();

var json = JObject.Parse(data);

AccessToken = json["access_token"].ToString();

JToken expiresJson = new JValue(3540);
if (json.TryGetValue("expires_in", out expiresJson))
Expires = DateTime.UtcNow.AddSeconds(expiresJson.ToObject<int>() - 60);
else
Expires = DateTime.UtcNow.AddSeconds(3540);

if (result.Headers.Contains("X-Amzn-RequestId"))
this.LastAmazonRequestId = string.Join("; ", result.Headers.GetValues("X-Amzn-RequestId"));

LastRequest = DateTime.UtcNow;
}

}
}
Loading