曹妃甸核酸检测平台.apk(点击下载) / PEPManager.java

package asmack.org.jivesoftware.smackx;

import androidx.core.app.NotificationCompat;
import asmack.org.jivesoftware.smack.Connection;
import asmack.org.jivesoftware.smack.PacketListener;
import asmack.org.jivesoftware.smack.filter.PacketExtensionFilter;
import asmack.org.jivesoftware.smack.filter.PacketFilter;
import asmack.org.jivesoftware.smack.packet.IQ;
import asmack.org.jivesoftware.smack.packet.Message;
import asmack.org.jivesoftware.smack.packet.Packet;
import asmack.org.jivesoftware.smackx.packet.PEPEvent;
import asmack.org.jivesoftware.smackx.packet.PEPItem;
import asmack.org.jivesoftware.smackx.packet.PEPPubSub;
import java.util.ArrayList;
import java.util.List;

public class PEPManager {
    private Connection connection;
    private PacketFilter packetFilter = new PacketExtensionFilter(NotificationCompat.CATEGORY_EVENT, "http://jabber.org/protocol/pubsub#event");
    private PacketListener packetListener;
    private List<PEPListener> pepListeners = new ArrayList();

    public PEPManager(Connection connection2) {
        this.connection = connection2;
        init();
    }

    /* access modifiers changed from: private */
    /* access modifiers changed from: public */
    private void firePEPListeners(String str, PEPEvent pEPEvent) {
        PEPListener[] pEPListenerArr;
        synchronized (this.pepListeners) {
            pEPListenerArr = new PEPListener[this.pepListeners.size()];
            this.pepListeners.toArray(pEPListenerArr);
        }
        for (PEPListener pEPListener : pEPListenerArr) {
            pEPListener.eventReceived(str, pEPEvent);
        }
    }

    private void init() {
        this.packetListener = new PacketListener() {
            /* class asmack.org.jivesoftware.smackx.PEPManager.AnonymousClass1 */

            @Override // asmack.org.jivesoftware.smack.PacketListener
            public void processPacket(Packet packet) {
                Message message = (Message) packet;
                PEPManager.this.firePEPListeners(message.getFrom(), (PEPEvent) message.getExtension(NotificationCompat.CATEGORY_EVENT, "http://jabber.org/protocol/pubsub#event"));
            }
        };
        this.connection.addPacketListener(this.packetListener, this.packetFilter);
    }

    public void addPEPListener(PEPListener pEPListener) {
        synchronized (this.pepListeners) {
            if (!this.pepListeners.contains(pEPListener)) {
                this.pepListeners.add(pEPListener);
            }
        }
    }

    public void destroy() {
        Connection connection2 = this.connection;
        if (connection2 != null) {
            connection2.removePacketListener(this.packetListener);
        }
    }

    /* access modifiers changed from: protected */
    public void finalize() throws Throwable {
        destroy();
        super.finalize();
    }

    public void publish(PEPItem pEPItem) {
        PEPPubSub pEPPubSub = new PEPPubSub(pEPItem);
        pEPPubSub.setType(IQ.Type.SET);
        this.connection.sendPacket(pEPPubSub);
    }

    public void removePEPListener(PEPListener pEPListener) {
        synchronized (this.pepListeners) {
            this.pepListeners.remove(pEPListener);
        }
    }
}