001/** 002 * 003 * Copyright © 2016 Fernando Ramirez 004 * 005 * Licensed under the Apache License, Version 2.0 (the "License"); 006 * you may not use this file except in compliance with the License. 007 * You may obtain a copy of the License at 008 * 009 * http://www.apache.org/licenses/LICENSE-2.0 010 * 011 * Unless required by applicable law or agreed to in writing, software 012 * distributed under the License is distributed on an "AS IS" BASIS, 013 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 014 * See the License for the specific language governing permissions and 015 * limitations under the License. 016 */ 017package org.jivesoftware.smackx.push_notifications; 018 019import java.util.HashMap; 020import java.util.Map; 021import java.util.WeakHashMap; 022 023import org.jivesoftware.smack.ConnectionCreationListener; 024import org.jivesoftware.smack.Manager; 025import org.jivesoftware.smack.SmackException.NoResponseException; 026import org.jivesoftware.smack.SmackException.NotConnectedException; 027import org.jivesoftware.smack.XMPPConnection; 028import org.jivesoftware.smack.XMPPConnectionRegistry; 029import org.jivesoftware.smack.XMPPException.XMPPErrorException; 030import org.jivesoftware.smack.packet.IQ; 031import org.jivesoftware.smack.packet.IQ.Type; 032 033import org.jivesoftware.smackx.disco.ServiceDiscoveryManager; 034import org.jivesoftware.smackx.push_notifications.element.DisablePushNotificationsIQ; 035import org.jivesoftware.smackx.push_notifications.element.EnablePushNotificationsIQ; 036import org.jivesoftware.smackx.push_notifications.element.PushNotificationsElements; 037 038import org.jxmpp.jid.Jid; 039 040/** 041 * Push Notifications manager class. 042 * 043 * @see <a href="http://xmpp.org/extensions/xep-0357.html">XEP-0357: Push 044 * Notifications</a> 045 * @author Fernando Ramirez 046 * 047 */ 048public final class PushNotificationsManager extends Manager { 049 050 static { 051 XMPPConnectionRegistry.addConnectionCreationListener(new ConnectionCreationListener() { 052 @Override 053 public void connectionCreated(XMPPConnection connection) { 054 getInstanceFor(connection); 055 } 056 }); 057 } 058 059 private static final Map<XMPPConnection, PushNotificationsManager> INSTANCES = new WeakHashMap<>(); 060 061 /** 062 * Get the singleton instance of PushNotificationsManager. 063 * 064 * @param connection 065 * @return the instance of PushNotificationsManager 066 */ 067 public static synchronized PushNotificationsManager getInstanceFor(XMPPConnection connection) { 068 PushNotificationsManager pushNotificationsManager = INSTANCES.get(connection); 069 070 if (pushNotificationsManager == null) { 071 pushNotificationsManager = new PushNotificationsManager(connection); 072 INSTANCES.put(connection, pushNotificationsManager); 073 } 074 075 return pushNotificationsManager; 076 } 077 078 private PushNotificationsManager(XMPPConnection connection) { 079 super(connection); 080 } 081 082 /** 083 * Returns true if Push Notifications are supported by this account. 084 * 085 * @return true if Push Notifications are supported by this account. 086 * @throws NoResponseException 087 * @throws XMPPErrorException 088 * @throws NotConnectedException 089 * @throws InterruptedException 090 * @since 4.2.2 091 */ 092 public boolean isSupported() 093 throws NoResponseException, XMPPErrorException, NotConnectedException, InterruptedException { 094 return ServiceDiscoveryManager.getInstanceFor(connection()).accountSupportsFeatures( 095 PushNotificationsElements.NAMESPACE); 096 } 097 098 /** 099 * Enable push notifications. 100 * 101 * @param pushJid 102 * @param node 103 * @return true if it was successfully enabled, false if not 104 * @throws NoResponseException 105 * @throws XMPPErrorException 106 * @throws NotConnectedException 107 * @throws InterruptedException 108 */ 109 public boolean enable(Jid pushJid, String node) 110 throws NoResponseException, XMPPErrorException, NotConnectedException, InterruptedException { 111 return enable(pushJid, node, null); 112 } 113 114 /** 115 * Enable push notifications. 116 * 117 * @param pushJid 118 * @param node 119 * @param publishOptions 120 * @return true if it was successfully enabled, false if not 121 * @throws NoResponseException 122 * @throws XMPPErrorException 123 * @throws NotConnectedException 124 * @throws InterruptedException 125 */ 126 public boolean enable(Jid pushJid, String node, HashMap<String, String> publishOptions) 127 throws NoResponseException, XMPPErrorException, NotConnectedException, InterruptedException { 128 EnablePushNotificationsIQ enablePushNotificationsIQ = new EnablePushNotificationsIQ(pushJid, node, 129 publishOptions); 130 return changePushNotificationsStatus(enablePushNotificationsIQ); 131 } 132 133 /** 134 * Disable all push notifications. 135 * 136 * @param pushJid 137 * @return true if it was successfully disabled, false if not 138 * @throws NoResponseException 139 * @throws XMPPErrorException 140 * @throws NotConnectedException 141 * @throws InterruptedException 142 */ 143 public boolean disableAll(Jid pushJid) 144 throws NoResponseException, XMPPErrorException, NotConnectedException, InterruptedException { 145 return disable(pushJid, null); 146 } 147 148 /** 149 * Disable push notifications of an specific node. 150 * 151 * @param pushJid 152 * @param node 153 * @return true if it was successfully disabled, false if not 154 * @throws NoResponseException 155 * @throws XMPPErrorException 156 * @throws NotConnectedException 157 * @throws InterruptedException 158 */ 159 public boolean disable(Jid pushJid, String node) 160 throws NoResponseException, XMPPErrorException, NotConnectedException, InterruptedException { 161 DisablePushNotificationsIQ disablePushNotificationsIQ = new DisablePushNotificationsIQ(pushJid, node); 162 return changePushNotificationsStatus(disablePushNotificationsIQ); 163 } 164 165 private boolean changePushNotificationsStatus(IQ iq) 166 throws NotConnectedException, InterruptedException, NoResponseException, XMPPErrorException { 167 final XMPPConnection connection = connection(); 168 IQ responseIQ = connection.createStanzaCollectorAndSend(iq).nextResultOrThrow(); 169 return responseIQ.getType() != Type.error; 170 } 171 172}