121 lines
4.9 KiB
Java
121 lines
4.9 KiB
Java
package eu.siacs.conversations.services;
|
|
|
|
import android.util.Log;
|
|
|
|
import com.google.android.gms.common.ConnectionResult;
|
|
import com.google.android.gms.common.GoogleApiAvailabilityLight;
|
|
import com.google.firebase.messaging.FirebaseMessaging;
|
|
|
|
import eu.siacs.conversations.Config;
|
|
import eu.siacs.conversations.R;
|
|
import eu.siacs.conversations.entities.Account;
|
|
import eu.siacs.conversations.utils.PhoneHelper;
|
|
import eu.siacs.conversations.xml.Element;
|
|
import eu.siacs.conversations.xml.Namespace;
|
|
import eu.siacs.conversations.xmpp.Jid;
|
|
import eu.siacs.conversations.xmpp.XmppConnection;
|
|
import eu.siacs.conversations.xmpp.forms.Data;
|
|
import eu.siacs.conversations.xmpp.stanzas.IqPacket;
|
|
|
|
public class PushManagementService {
|
|
|
|
protected final XmppConnectionService mXmppConnectionService;
|
|
|
|
PushManagementService(XmppConnectionService service) {
|
|
this.mXmppConnectionService = service;
|
|
}
|
|
|
|
private static Data findResponseData(IqPacket response) {
|
|
final Element command = response.findChild("command", Namespace.COMMANDS);
|
|
final Element x = command == null ? null : command.findChild("x", Namespace.DATA);
|
|
return x == null ? null : Data.parse(x);
|
|
}
|
|
|
|
private Jid getAppServer() {
|
|
return Jid.of(mXmppConnectionService.getString(R.string.app_server));
|
|
}
|
|
|
|
void registerPushTokenOnServer(final Account account) {
|
|
Log.d(Config.LOGTAG, account.getJid().asBareJid() + ": has push support");
|
|
retrieveFcmInstanceToken(token -> {
|
|
final String androidId = PhoneHelper.getAndroidId(mXmppConnectionService);
|
|
final IqPacket packet = mXmppConnectionService.getIqGenerator().pushTokenToAppServer(getAppServer(), token, androidId);
|
|
mXmppConnectionService.sendIqPacket(account, packet, (a, response) -> {
|
|
final Data data = findResponseData(response);
|
|
if (response.getType() == IqPacket.TYPE.RESULT && data != null) {
|
|
try {
|
|
String node = data.getValue("node");
|
|
String secret = data.getValue("secret");
|
|
Jid jid = Jid.of(data.getValue("jid"));
|
|
if (node != null && secret != null) {
|
|
enablePushOnServer(a, jid, node, secret);
|
|
}
|
|
} catch (IllegalArgumentException e) {
|
|
e.printStackTrace();
|
|
}
|
|
} else {
|
|
Log.d(Config.LOGTAG, a.getJid().asBareJid() + ": failed to enable push. invalid response from app server " + response);
|
|
}
|
|
});
|
|
});
|
|
}
|
|
|
|
private void enablePushOnServer(final Account account, final Jid appServer, final String node, final String secret) {
|
|
final IqPacket enable = mXmppConnectionService.getIqGenerator().enablePush(appServer, node, secret);
|
|
mXmppConnectionService.sendIqPacket(account, enable, (a, p) -> {
|
|
if (p.getType() == IqPacket.TYPE.RESULT) {
|
|
Log.d(Config.LOGTAG, a.getJid().asBareJid() + ": successfully enabled push on server");
|
|
} else if (p.getType() == IqPacket.TYPE.ERROR) {
|
|
Log.d(Config.LOGTAG, a.getJid().asBareJid() + ": enabling push on server failed");
|
|
}
|
|
});
|
|
}
|
|
|
|
private void retrieveFcmInstanceToken(final OnGcmInstanceTokenRetrieved instanceTokenRetrieved) {
|
|
final FirebaseMessaging firebaseMessaging;
|
|
try {
|
|
firebaseMessaging = FirebaseMessaging.getInstance();
|
|
} catch (IllegalStateException e) {
|
|
Log.d(Config.LOGTAG, "unable to get firebase instance token ", e);
|
|
return;
|
|
}
|
|
firebaseMessaging.getToken().addOnCompleteListener(task -> {
|
|
if (!task.isSuccessful()) {
|
|
Log.d(Config.LOGTAG, "unable to get Firebase instance token", task.getException());
|
|
}
|
|
final String result;
|
|
try {
|
|
result = task.getResult();
|
|
} catch (Exception e) {
|
|
Log.d(Config.LOGTAG, "unable to get Firebase instance token due to bug in library ", e);
|
|
return;
|
|
}
|
|
if (result != null) {
|
|
instanceTokenRetrieved.onGcmInstanceTokenRetrieved(result);
|
|
}
|
|
});
|
|
|
|
}
|
|
|
|
|
|
public boolean available(Account account) {
|
|
final XmppConnection connection = account.getXmppConnection();
|
|
return connection != null
|
|
&& connection.getFeatures().sm()
|
|
&& connection.getFeatures().push()
|
|
&& playServicesAvailable();
|
|
}
|
|
|
|
private boolean playServicesAvailable() {
|
|
return GoogleApiAvailabilityLight.getInstance().isGooglePlayServicesAvailable(mXmppConnectionService) == ConnectionResult.SUCCESS;
|
|
}
|
|
|
|
public boolean isStub() {
|
|
return false;
|
|
}
|
|
|
|
interface OnGcmInstanceTokenRetrieved {
|
|
void onGcmInstanceTokenRetrieved(String token);
|
|
}
|
|
}
|