Page MenuHomePhabricator
Files F7312169

No OneTemporary
Actions

View Options

diff --git a/sylk/applications/webrtcgateway/push.py b/sylk/applications/webrtcgateway/push.py
index 35e94c2..3c8c621 100644
--- a/sylk/applications/webrtcgateway/push.py
+++ b/sylk/applications/webrtcgateway/push.py
@@ -1,75 +1,78 @@
import json
from twisted.internet import defer, reactor
from twisted.web.client import Agent
from twisted.web.iweb import IBodyProducer
from twisted.web.http_headers import Headers
from zope.interface import implementer
from .configuration import GeneralConfig
from .logger import log
from .models import firebase
from .storage import TokenStorage
__all__ = 'incoming_call', 'missed_call', 'conference_invite'
agent = Agent(reactor)
headers = Headers({'User-Agent': ['SylkServer'],
'Content-Type': ['application/json'],
'Authorization': ['key=%s' % GeneralConfig.firebase_server_key]})
FIREBASE_API_URL = 'https://fcm.googleapis.com/fcm/send'
@implementer(IBodyProducer)
class StringProducer(object):
def __init__(self, data):
self.body = data
self.length = len(data)
def startProducing(self, consumer):
consumer.write(self.body)
return defer.succeed(None)
def pauseProducing(self):
pass
def stopProducing(self):
pass
def incoming_call(originator, destination):
tokens = TokenStorage()
+ request = firebase.FirebaseRequest(token='dummy', event=firebase.IncomingCallEvent(originator=originator, destination=destination), time_to_live=60)
for token in tokens[destination]:
- request = firebase.FirebaseRequest(token, event=firebase.IncomingCallEvent(originator=originator, destination=destination), time_to_live=60)
+ request.to = token
_send_push_notification(json.dumps(request.__data__))
def missed_call(originator, destination):
tokens = TokenStorage()
+ request = firebase.FirebaseRequest(token='dummy', event=firebase.MissedCallEvent(originator=originator, destination=destination))
for token in tokens[destination]:
- request = firebase.FirebaseRequest(token, event=firebase.MissedCallEvent(originator=originator, destination=destination))
+ request.to = token
_send_push_notification(json.dumps(request.__data__))
def conference_invite(originator, destination, room):
tokens = TokenStorage()
+ request = firebase.FirebaseRequest(token='dummy', event=firebase.ConferenceInviteEvent(originator=originator, destination=destination, room=room), time_to_live=3600)
for token in tokens[destination]:
- request = firebase.FirebaseRequest(token, event=firebase.ConferenceInviteEvent(originator=originator, destination=destination, room=room), time_to_live=3600)
+ request.to = token
_send_push_notification(json.dumps(request.__data__))
@defer.inlineCallbacks
def _send_push_notification(payload):
if GeneralConfig.firebase_server_key:
try:
r = yield agent.request('POST', FIREBASE_API_URL, headers, StringProducer(payload))
except Exception as e:
log.info('Error sending Firebase message: %s', e)
else:
if r.code != 200:
log.warn('Error sending Firebase message: %s' % r.phrase)
else:
log.warn('Cannot send push notification: no Firebase server key configured')

File Metadata

Mime Type
text/x-diff
Expires
Sat, Feb 1, 5:17 AM (22 h, 15 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
3488295
Default Alt Text
(3 KB)

Event Timeline