/** | |
* All rights reserved. Licensed under the Apache License, Version 2.0 (the "License"); | |
* you may not use this file except in compliance with the License. | |
* You may obtain a copy of the License at | |
* | |
* http://www.apache.org/licenses/LICENSE-2.0 | |
* | |
* Unless required by applicable law or agreed to in writing, software | |
* distributed under the License is distributed on an "AS IS" BASIS, | |
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | |
* See the License for the specific language governing permissions and | |
* limitations under the License. | |
*/ | |
package org.jivesoftware.smackx.bytestreams.ibb; | |
import org.jivesoftware.smack.PacketListener; | |
import org.jivesoftware.smack.filter.AndFilter; | |
import org.jivesoftware.smack.filter.PacketFilter; | |
import org.jivesoftware.smack.filter.PacketTypeFilter; | |
import org.jivesoftware.smack.packet.Packet; | |
import org.jivesoftware.smackx.bytestreams.ibb.packet.Data; | |
/** | |
* DataListener handles all In-Band Bytestream IQ stanzas containing a data | |
* packet extension that don't belong to an existing session. | |
* <p> | |
* If a data packet is received it looks if a stored In-Band Bytestream session | |
* exists. If no session with the given session ID exists an | |
* <item-not-found/> error is returned to the sender. | |
* <p> | |
* Data packets belonging to a running In-Band Bytestream session are processed | |
* by more specific listeners registered when an {@link InBandBytestreamSession} | |
* is created. | |
* | |
* @author Henning Staib | |
*/ | |
class DataListener implements PacketListener { | |
/* manager containing the listeners and the XMPP connection */ | |
private final InBandBytestreamManager manager; | |
/* packet filter for all In-Band Bytestream data packets */ | |
private final PacketFilter dataFilter = new AndFilter( | |
new PacketTypeFilter(Data.class)); | |
/** | |
* Constructor. | |
* | |
* @param manager the In-Band Bytestream manager | |
*/ | |
public DataListener(InBandBytestreamManager manager) { | |
this.manager = manager; | |
} | |
public void processPacket(Packet packet) { | |
Data data = (Data) packet; | |
InBandBytestreamSession ibbSession = this.manager.getSessions().get( | |
data.getDataPacketExtension().getSessionID()); | |
if (ibbSession == null) { | |
this.manager.replyItemNotFoundPacket(data); | |
} | |
} | |
/** | |
* Returns the packet filter for In-Band Bytestream data packets. | |
* | |
* @return the packet filter for In-Band Bytestream data packets | |
*/ | |
protected PacketFilter getFilter() { | |
return this.dataFilter; | |
} | |
} |