aboutsummaryrefslogtreecommitdiffstats
path: root/src/standardPush/java/de/pixart/messenger/services/PushManagementService.java
diff options
context:
space:
mode:
authorChristian Schneppe <christian.schneppe@pix-art.de>2019-11-02 15:44:31 +0100
committerChristian Schneppe <christian.schneppe@pix-art.de>2019-11-02 15:44:31 +0100
commit7bb48465e21a8468a5a9ed61b81989903c8b36a4 (patch)
treee2c3819e36c108f55722c4d62300a3fded6fdfdd /src/standardPush/java/de/pixart/messenger/services/PushManagementService.java
parent6e386a8701190aad9e5adfa83c48ef9ea1582f1e (diff)
rename build flavors
Diffstat (limited to 'src/standardPush/java/de/pixart/messenger/services/PushManagementService.java')
-rw-r--r--src/standardPush/java/de/pixart/messenger/services/PushManagementService.java194
1 files changed, 0 insertions, 194 deletions
diff --git a/src/standardPush/java/de/pixart/messenger/services/PushManagementService.java b/src/standardPush/java/de/pixart/messenger/services/PushManagementService.java
deleted file mode 100644
index a7054cf2f..000000000
--- a/src/standardPush/java/de/pixart/messenger/services/PushManagementService.java
+++ /dev/null
@@ -1,194 +0,0 @@
-package de.pixart.messenger.services;
-
-import android.util.Log;
-
-import com.google.android.gms.common.ConnectionResult;
-import com.google.android.gms.common.GoogleApiAvailability;
-import com.google.firebase.iid.FirebaseInstanceId;
-import com.google.firebase.iid.InstanceIdResult;
-
-import de.pixart.messenger.Config;
-import de.pixart.messenger.R;
-import de.pixart.messenger.entities.Account;
-import de.pixart.messenger.entities.Conversation;
-import de.pixart.messenger.utils.Namespace;
-import de.pixart.messenger.utils.PhoneHelper;
-import de.pixart.messenger.xml.Element;
-import de.pixart.messenger.xmpp.XmppConnection;
-import de.pixart.messenger.xmpp.forms.Data;
-import de.pixart.messenger.xmpp.stanzas.IqPacket;
-import rocks.xmpp.addr.Jid;
-
-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() + ": invalid response from app server");
- }
- });
- });
- }
-
- public void unregisterChannel(final Account account, final String channel) {
- final String androidId = PhoneHelper.getAndroidId(mXmppConnectionService);
- final Jid appServer = getAppServer();
- final IqPacket packet = mXmppConnectionService.getIqGenerator().unregisterChannelOnAppServer(appServer, androidId, channel);
- mXmppConnectionService.sendIqPacket(account, packet, (a, response) -> {
- if (response.getType() == IqPacket.TYPE.RESULT) {
- Log.d(Config.LOGTAG, a.getJid().asBareJid() + ": successfully unregistered channel");
- } else if (response.getType() == IqPacket.TYPE.ERROR) {
- Log.d(Config.LOGTAG, a.getJid().asBareJid() + ": unable to unregister channel with hash " + channel);
- }
- });
- }
-
- void registerPushTokenOnServer(final Conversation conversation) {
- Log.d(Config.LOGTAG, conversation.getAccount().getJid().asBareJid() + ": room " + conversation.getJid().asBareJid() + " has push support");
- retrieveFcmInstanceToken(token -> {
- final Jid muc = conversation.getJid().asBareJid();
- final String androidId = PhoneHelper.getAndroidId(mXmppConnectionService);
- final IqPacket packet = mXmppConnectionService.getIqGenerator().pushTokenToAppServer(getAppServer(), token, androidId, muc);
- packet.setTo(muc);
- mXmppConnectionService.sendIqPacket(conversation.getAccount(), packet, (a, response) -> {
- final Data data = findResponseData(response);
- if (response.getType() == IqPacket.TYPE.RESULT && data != null) {
- try {
- final String node = data.getValue("node");
- final String secret = data.getValue("secret");
- final Jid jid = Jid.of(data.getValue("jid"));
- if (node != null && secret != null) {
- enablePushOnServer(conversation, jid, node, secret);
- }
- } catch (IllegalArgumentException e) {
- e.printStackTrace();
- }
- } else {
- Log.d(Config.LOGTAG, a.getJid().asBareJid() + ": invalid response from app server");
- }
- });
- });
- }
-
- 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 enablePushOnServer(final Conversation conversation, final Jid appServer, final String node, final String secret) {
- final Jid muc = conversation.getJid().asBareJid();
- final IqPacket enable = mXmppConnectionService.getIqGenerator().enablePush(appServer, node, secret);
- enable.setTo(muc);
- mXmppConnectionService.sendIqPacket(conversation.getAccount(), enable, (a, p) -> {
- if (p.getType() == IqPacket.TYPE.RESULT) {
- Log.d(Config.LOGTAG, a.getJid().asBareJid() + ": successfully enabled push on " + muc);
- if (conversation.setAttribute(Conversation.ATTRIBUTE_ALWAYS_NOTIFY, node)) {
- mXmppConnectionService.updateConversation(conversation);
- }
- } else if (p.getType() == IqPacket.TYPE.ERROR) {
- Log.d(Config.LOGTAG, a.getJid().asBareJid() + ": enabling push on " + muc + " failed");
- }
- });
- }
-
- public void disablePushOnServer(final Conversation conversation) {
- final Jid muc = conversation.getJid().asBareJid();
- final String node = conversation.getAttribute(Conversation.ATTRIBUTE_PUSH_NODE);
- if (node != null) {
- final IqPacket disable = mXmppConnectionService.getIqGenerator().disablePush(getAppServer(), node);
- disable.setTo(muc);
- mXmppConnectionService.sendIqPacket(conversation.getAccount(), disable, (account, response) -> {
- if (response.getType() == IqPacket.TYPE.ERROR) {
- Log.d(Config.LOGTAG, account.getJid().asBareJid() + ": unable to disable push for room " + muc);
- }
- });
- } else {
- Log.d(Config.LOGTAG, conversation.getAccount().getJid().asBareJid() + ": room " + muc + " has no stored node. unable to disable push");
- }
- }
-
- private void retrieveFcmInstanceToken(final OnGcmInstanceTokenRetrieved instanceTokenRetrieved) {
- final FirebaseInstanceId firebaseInstanceId;
- try {
- firebaseInstanceId = FirebaseInstanceId.getInstance();
- } catch (IllegalStateException e) {
- Log.d(Config.LOGTAG, "unable to get firebase instance token ", e);
- return;
- }
- firebaseInstanceId.getInstanceId().addOnCompleteListener(task -> {
- if (!task.isSuccessful()) {
- Log.d(Config.LOGTAG, "unable to get Firebase instance token", task.getException());
- }
- final InstanceIdResult 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.getToken());
- }
- });
-
- }
-
-
- public boolean available(Account account) {
- final XmppConnection connection = account.getXmppConnection();
- return connection != null
- && connection.getFeatures().sm()
- && connection.getFeatures().push()
- && playServicesAvailable();
- }
-
- private boolean playServicesAvailable() {
- return GoogleApiAvailability.getInstance().isGooglePlayServicesAvailable(mXmppConnectionService) == ConnectionResult.SUCCESS;
- }
-
- public boolean isStub() {
- return false;
- }
-
- interface OnGcmInstanceTokenRetrieved {
- void onGcmInstanceTokenRetrieved(String token);
- }
-} \ No newline at end of file