1package eu.siacs.conversations.services;
2
3import android.provider.Settings;
4import android.util.Log;
5
6import com.google.android.gms.common.ConnectionResult;
7import com.google.android.gms.common.GoogleApiAvailability;
8import com.google.android.gms.gcm.GoogleCloudMessaging;
9import com.google.android.gms.iid.InstanceID;
10
11import java.io.IOException;
12
13import eu.siacs.conversations.Config;
14import eu.siacs.conversations.R;
15import eu.siacs.conversations.entities.Account;
16import eu.siacs.conversations.xml.Element;
17import eu.siacs.conversations.xmpp.OnIqPacketReceived;
18import eu.siacs.conversations.xmpp.XmppConnection;
19import eu.siacs.conversations.xmpp.forms.Data;
20import eu.siacs.conversations.xmpp.jid.InvalidJidException;
21import eu.siacs.conversations.xmpp.jid.Jid;
22import eu.siacs.conversations.xmpp.stanzas.IqPacket;
23
24public class PushManagementService {
25
26 private static final String APP_SERVER = "push.siacs.eu";
27
28 protected final XmppConnectionService mXmppConnectionService;
29
30 public PushManagementService(XmppConnectionService service) {
31 this.mXmppConnectionService = service;
32 }
33
34 public void registerPushTokenOnServer(final Account account) {
35 Log.d(Config.LOGTAG, account.getJid().toBareJid() + ": has push support");
36 retrieveGcmInstanceToken(new OnGcmInstanceTokenRetrieved() {
37 @Override
38 public void onGcmInstanceTokenRetrieved(String token) {
39 try {
40 final String deviceId = Settings.Secure.getString(mXmppConnectionService.getContentResolver(), Settings.Secure.ANDROID_ID);
41 IqPacket packet = mXmppConnectionService.getIqGenerator().pushTokenToAppServer(Jid.fromString(APP_SERVER), token, deviceId);
42 mXmppConnectionService.sendIqPacket(account, packet, new OnIqPacketReceived() {
43 @Override
44 public void onIqPacketReceived(Account account, IqPacket packet) {
45 Element command = packet.findChild("command","http://jabber.org/protocol/commands");
46 if (packet.getType() == IqPacket.TYPE.RESULT && command != null) {
47 Element x = command.findChild("x","jabber:x:data");
48 if (x != null) {
49 Data data = Data.parse(x);
50 try {
51 String node = data.getValue("node");
52 String secret = data.getValue("secret");
53 Jid jid = Jid.fromString(data.getValue("jid"));
54 if (node != null && secret != null) {
55 enablePushOnServer(account, jid, node, secret);
56 }
57 } catch (InvalidJidException e) {
58 e.printStackTrace();
59 }
60 }
61 } else {
62 Log.d(Config.LOGTAG,account.getJid().toBareJid()+": invalid response from app server");
63 }
64 }
65 });
66 } catch (InvalidJidException ignored) {
67
68 }
69 }
70 });
71 }
72
73 private void enablePushOnServer(final Account account, final Jid jid, final String node, final String secret) {
74 IqPacket enable = mXmppConnectionService.getIqGenerator().enablePush(jid, node, secret);
75 mXmppConnectionService.sendIqPacket(account, enable, new OnIqPacketReceived() {
76 @Override
77 public void onIqPacketReceived(Account account, IqPacket packet) {
78 if (packet.getType() == IqPacket.TYPE.RESULT) {
79 Log.d(Config.LOGTAG, account.getJid().toBareJid() + ": successfully enabled push on server");
80 } else if (packet.getType() == IqPacket.TYPE.ERROR) {
81 Log.d(Config.LOGTAG, account.getJid().toBareJid() + ": enabling push on server failed");
82 }
83 }
84 });
85 }
86
87 private void retrieveGcmInstanceToken(final OnGcmInstanceTokenRetrieved instanceTokenRetrieved) {
88 new Thread(new Runnable() {
89 @Override
90 public void run() {
91 InstanceID instanceID = InstanceID.getInstance(mXmppConnectionService);
92 try {
93 String token = instanceID.getToken(mXmppConnectionService.getString(R.string.gcm_defaultSenderId), GoogleCloudMessaging.INSTANCE_ID_SCOPE, null);
94 instanceTokenRetrieved.onGcmInstanceTokenRetrieved(token);
95 } catch (Exception e) {
96 Log.d(Config.LOGTAG,"unable to get push token");
97 }
98 }
99 }).start();
100
101 }
102
103
104 public boolean available(Account account) {
105 final XmppConnection connection = account.getXmppConnection();
106 return connection != null && connection.getFeatures().push() && playServicesAvailable();
107 }
108
109 public boolean availableAndUseful(Account account) {
110 return account.getServerIdentity() == XmppConnection.Identity.EJABBERD && available(account);
111 }
112
113 private boolean playServicesAvailable() {
114 return GoogleApiAvailability.getInstance().isGooglePlayServicesAvailable(mXmppConnectionService) == ConnectionResult.SUCCESS;
115 }
116
117 public boolean isStub() {
118 return false;
119 }
120
121 interface OnGcmInstanceTokenRetrieved {
122 void onGcmInstanceTokenRetrieved(String token);
123 }
124}