mirror of
git://xwords.git.sourceforge.net/gitroot/xwords/xwords
synced 2025-01-23 07:27:22 +01:00
test script taken from eehouse.org (it works)
This commit is contained in:
parent
1485d5944e
commit
3661041ce8
1 changed files with 73 additions and 0 deletions
73
xwords4/relay/scripts/fcm_msg.py
Executable file
73
xwords4/relay/scripts/fcm_msg.py
Executable file
|
@ -0,0 +1,73 @@
|
|||
#!/usr/bin/python
|
||||
|
||||
import sys, psycopg2, json, urllib, urllib2
|
||||
from oauth2client.service_account import ServiceAccountCredentials
|
||||
|
||||
# I'm not checking my key in...
|
||||
import mykey2
|
||||
|
||||
FCM_URL = 'https://fcm.googleapis.com/v1/projects/fcmtest-9fe99/messages:send'
|
||||
SCOPES = ["https://www.googleapis.com/auth/firebase.messaging"]
|
||||
|
||||
def usage():
|
||||
print 'usage:', sys.argv[0], '[--to <name>] msg'
|
||||
sys.exit()
|
||||
|
||||
def get_access_token():
|
||||
credentials = ServiceAccountCredentials.from_json_keyfile_name(
|
||||
'service-account.json', SCOPES)
|
||||
access_token_info = credentials.get_access_token()
|
||||
print 'token:', access_token_info.access_token
|
||||
return access_token_info.access_token
|
||||
|
||||
def sendMsg( devid, msg ):
|
||||
values = {
|
||||
'message' : {
|
||||
'token' : devid,
|
||||
'data' : { 'title' : 'Re: CrossWords',
|
||||
'teaser' : 'Please tap to read in the app',
|
||||
'msg' : msg,
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
params = json.dumps( values )
|
||||
print params
|
||||
for ignore in [True, True]:
|
||||
req = urllib2.Request( FCM_URL, params )
|
||||
# req.add_header( 'Content-Type' , 'application/x-www-form-urlencoded;charset=UTF-8' )
|
||||
req.add_header('Authorization', 'Bearer ' + get_access_token())
|
||||
req.add_header('Content-Type', 'application/json')
|
||||
print 'added headers'
|
||||
# req.add_header( 'Authorization' , 'key=' + mykey2.myKey )
|
||||
try:
|
||||
response = urllib2.urlopen( req )
|
||||
print 'urlopen done'
|
||||
response = response.read()
|
||||
print response
|
||||
except urllib2.URLError as e:
|
||||
print 'error from urlopen:', e.reason
|
||||
if e.reason == 'Unauthorized':
|
||||
g_accessToken = get_access_token()
|
||||
else:
|
||||
break
|
||||
|
||||
def main():
|
||||
to = None
|
||||
msg = sys.argv[1]
|
||||
if msg == '--to':
|
||||
to = sys.argv[2]
|
||||
msg = sys.argv[3]
|
||||
elif 2 < len(sys.argv):
|
||||
usage()
|
||||
if not to in mykey2.devids.keys():
|
||||
print 'Unknown --to param;', to, 'not in', ','.join(mykey2.devids.keys())
|
||||
usage()
|
||||
if not to: usage()
|
||||
devid = mykey2.devids[to]
|
||||
print 'sending: "%s" to' % msg, to
|
||||
sendMsg( devid, msg )
|
||||
|
||||
##############################################################################
|
||||
if __name__ == '__main__':
|
||||
main()
|
Loading…
Add table
Reference in a new issue