notazof/yavsc
1
1
Fork 0
Code Issues 1 Pull requests 1 Projects 2 Releases 9 Packages Wiki Activity Actions

use SimpleMethodPostJson to send the GCM

Browse source
This commit is contained in:
Paul Schneider 2016-07-21 12:25:01 +02:00
commit 35b3480837
2 changed files with 58 additions and 46 deletions
Download patch file Download diff file Expand all files Collapse all files

12
Yavsc/Controllers/CommandController.cs
View file

@ -148,11 +148,13 @@ namespace Yavsc.Controllers
if (pro.AcceptNotifications if (pro.AcceptNotifications
&& pro.AcceptPublicContact) && pro.AcceptPublicContact)
{ {
if (pro.Performer.Devices.Count > 0) if (pro.Performer.Devices.Count > 0) {
grep = await _GCMSender.NotifyAsync(_googleSettings, var regids = command.PerformerProfile.Performer
command.PerformerProfile.Performer.Devices.Select(d => d.GCMRegistrationId), .Devices.Select(d => d.GCMRegistrationId);
yaev var sregids = string.Join(",",regids);
); _logger.LogWarning($"ApiKey: {_googleSettings.ApiKey} {sregids}");
grep = await _GCMSender.NotifyAsync(_googleSettings,regids,yaev);
}
// TODO setup a profile choice to allow notifications // TODO setup a profile choice to allow notifications
// both on mailbox and mobile // both on mailbox and mobile
// if (grep==null || grep.success<=0 || grep.failure>0) // if (grep==null || grep.success<=0 || grep.failure>0)

46
Yavsc/Helpers/GoogleHelpers.cs
View file

@ -44,7 +44,8 @@ namespace Yavsc.Helpers
/// <returns>The event.</returns> /// <returns>The event.</returns>
/// <param name="evpub">Evpub.</param> /// <param name="evpub">Evpub.</param>
public static async Task<MessageWithPayloadResponse> NotifyEvent public static async Task<MessageWithPayloadResponse> NotifyEvent
(this HttpClient channel, GoogleAuthSettings googleSettings, CircleEvent evpub) { (this HttpClient channel, GoogleAuthSettings googleSettings, CircleEvent evpub)
{
// ASSERT ModelState.IsValid implies evpub.Circles != null // ASSERT ModelState.IsValid implies evpub.Circles != null
//send a MessageWithPayload<YaEvent> to circle members //send a MessageWithPayload<YaEvent> to circle members
// receive MessageWithPayloadResponse // receive MessageWithPayloadResponse
@ -52,37 +53,46 @@ namespace Yavsc.Helpers
var regids = new List<string>(); var regids = new List<string>();
foreach (var c in evpub.Circles) foreach (var c in evpub.Circles)
foreach (var u in c.Members) { foreach (var u in c.Members)
{
regids.AddRange(u.Member.Devices.Select(d => d.GCMRegistrationId)); regids.AddRange(u.Member.Devices.Select(d => d.GCMRegistrationId));
} }
if (regids.Count > 0) return null; if (regids.Count > 0) return null;
var request = new HttpRequestMessage(HttpMethod.Get, Constants.GCMNotificationUrl); var request = new HttpRequestMessage(HttpMethod.Get, Constants.GCMNotificationUrl);
request.Headers.Authorization = new AuthenticationHeaderValue("Key", googleSettings.ApiKey); request.Headers.Authorization = new AuthenticationHeaderValue("key", googleSettings.ApiKey);
var msg = new MessageWithPayload<YaEvent> () { var msg = new MessageWithPayload<YaEvent>()
{
notification = new Notification() { title = evpub.Title, body = evpub.Description, icon = "event" }, notification = new Notification() { title = evpub.Title, body = evpub.Description, icon = "event" },
data = evpub , registration_ids = regids.ToArray() }; data = evpub,
registration_ids = regids.ToArray()
};
var response = await channel.SendAsync(request); var response = await channel.SendAsync(request);
var payload = JObject.Parse(await response.Content.ReadAsStringAsync()); var payload = JObject.Parse(await response.Content.ReadAsStringAsync());
return payload.Value<MessageWithPayloadResponse>(); return payload.Value<MessageWithPayloadResponse>();
} }
public static async Task<MessageWithPayloadResponse> NotifyEvent<Event> public static MessageWithPayloadResponse NotifyEvent<Event>
(this HttpClient channel, GoogleAuthSettings googleSettings, IEnumerable<string> regids, Event ev) (this GoogleAuthSettings googleSettings, IEnumerable<string> regids, Event ev)
where Event : YaEvent where Event : YaEvent
{ {
var msg = new MessageWithPayload<Event>()
{
notification = new Notification()
{
title = ev.Title,
body = ev.Description + ev.Comment == null ?
"" : "(" + ev.Comment + ")",
icon = "icon"
},
data = ev,
registration_ids = regids.ToArray()
};
if (regids == null) if (regids == null)
throw new NotImplementedException("Notify & No GCM reg ids"); throw new NotImplementedException("Notify & No GCM reg ids");
var request = new HttpRequestMessage(HttpMethod.Get, Constants.GCMNotificationUrl); using (var m = new SimpleJsonPostMethod("https://gcm-http.googleapis.com/gcm/send",$"key={googleSettings.ApiKey}")) {
request.Headers.Authorization = new AuthenticationHeaderValue("Key", googleSettings.ApiKey); return m.Invoke<MessageWithPayloadResponse>(msg);
var msg = new MessageWithPayload<Event> () { }
notification = new Notification() { title = ev.Title,
body = ev.Description + ev.Comment==null?
"":"("+ev.Comment+")", icon = "icon" },
data = ev, registration_ids = regids.ToArray() };
var response = await channel.SendAsync(request);
var payload = JObject.Parse(await response.Content.ReadAsStringAsync());
return payload.Value<MessageWithPayloadResponse>();
} }
public static async Task<UserCredential> GetCredentialForGoogleApiAsync(this UserManager<ApplicationUser> userManager, ApplicationDbContext context, string uid) public static async Task<UserCredential> GetCredentialForGoogleApiAsync(this UserManager<ApplicationUser> userManager, ApplicationDbContext context, string uid)
{ {