import org.jivesoftware.openfire.interceptor.PacketRejectedException; //导入依赖的package包/类
public void interceptPacket(Packet packet, Session session,
		boolean incoming, boolean processed) throws PacketRejectedException {

	if (processed) {
		return;
	}
	if (!incoming) {
		return;
	}

	if (packet instanceof Message) {
		Message msg = (Message) packet;
		process(msg);
	}

}
 

import org.jivesoftware.openfire.interceptor.PacketRejectedException; //导入依赖的package包/类
/**
 * Keeps a log of the XMPP traffic, releasing the wait lock on response received.
 */
@Override
public void interceptPacket(Packet packet, Session session, boolean incoming, boolean processed)
        throws PacketRejectedException {
    if (!processed
            && (ping.getTo().getDomain().equals(packet.getFrom().getDomain()) || ping.getTo().getDomain().equals(packet.getTo().getDomain()))) {

        // Log all traffic to and from the domain.
        xml.append(packet.toXML());
        xml.append('\n');

        // If we've received our IQ response, stop the test.
        if ( packet instanceof IQ )
        {
            final IQ iq = (IQ) packet;
            if ( iq.isResponse() && ping.getID().equals( iq.getID() ) && ping.getTo().equals( iq.getFrom() ) ) {
                Log.info("Successful server to server response received.");
                waitUntil.release();
            }
        }
    }
}
 

import org.jivesoftware.openfire.interceptor.PacketRejectedException; //导入依赖的package包/类
private void acceptSubscription(JID toJID, JID fromJID) throws PacketRejectedException {
    if (getSubscriptionLevel().equals(LOCAL)) {
        String toDomain = toJID.getDomain();
        String fromDomain = fromJID.getDomain();

        if (!toDomain.equals(serverName) || !fromDomain.equals(serverName)) {
            return;
        }
    }

    // Simulate that the target user has accepted the presence subscription request
    Presence presence = new Presence();
    presence.setType(Presence.Type.subscribed);

    presence.setTo(fromJID);
    presence.setFrom(toJID);
    router.route(presence);

    throw new PacketRejectedException();
}
 

import org.jivesoftware.openfire.interceptor.PacketRejectedException; //导入依赖的package包/类
/**
 * At this Point we know: MucBlock = true, !incoming, !processed Package is
 * IQ with Namespace disco#info, from equals the watched subdomain given
 * through subdomain
 */
@Override
public void process(Packet packet, String subdomain, String to, String from) throws PacketRejectedException {
    IQ iqPacket = (IQ) packet;

    if (iqPacket.getType().equals(IQ.Type.result) && to.length() > 0) {
        Element root = iqPacket.getChildElement();

        List<Node> nodes = XpathHelper.findNodesInDocument(root.getDocument(), "//disco:feature");
        for (Node node : nodes) {
            String var = node.valueOf("@var");
            if (var.equals("http://jabber.org/protocol/muc"))
                root.remove(node);
        }

    }
}
 

import org.jivesoftware.openfire.interceptor.PacketRejectedException; //导入依赖的package包/类
/**
 * Here we process the response of the remote command sent to Spectrum. We have to identify what kind of response it
 * is, as no tag for the command being responded is being sent. Currently these commands are used in Gojara
 * TransportSessionManager: online_users ( Chatmsg of online users for specific transport), usernames seperated by
 * newlines
 */
@Override
public void process(Packet packet, String subdomain, String to, String from) throws PacketRejectedException {
    Message message = (Message) packet;

    // handle different commands
    Log.debug("Intercepted spectrum message: " + message.toString());
    String command = packet.getID();
    if (command.equals("online_users")) {
        handleOnlineUsers(message, subdomain);
    } else if (command.equals("unregister")) {
        handleUnregister(message, subdomain);
    } else if (command.equals("config_check")) {
        handleConfigCheck(subdomain);
    } else if (command.equals("uptime")) {
        handleStatistic(message, subdomain, "uptime");
    } else if (command.equals("messages_from_xmpp")) {
        handleStatistic(message, subdomain, "messages_from_xmpp");
    } else if (command.equals("messages_to_xmpp")) {
        handleStatistic(message, subdomain, "messages_to_xmpp");
    } else if (command.equals("used_memory")) {
        handleStatistic(message, subdomain, "used_memory");
    } else if (command.equals("average_memory_per_user")) {
        handleStatistic(message, subdomain, "average_memory_per_user");
    }
}
 

import org.jivesoftware.openfire.interceptor.PacketRejectedException; //导入依赖的package包/类
/**
 * If this is valid disco#items package for this Use-Case we iterate through
 * the nodes and check if we have to remove nodes, this way they are not
 * shown to the user receiving this disco#items.
 * 
 * @param subdomain
 *            not the actual Subdomain here, as we have to use our set.
 */
@Override
public void process(Packet packet, String subdomain, String to, String from) throws PacketRejectedException {
    IQ myPacket = (IQ) packet;
    if (myPacket.getType().equals(IQ.Type.result) && (from.length() == 0 || from.equals(_server.getServerInfo().getXMPPDomain()))) {

        Log.debug("Processing packet in Whitelistprocessor for " + to + "Packet: " + packet.toString());
        Element root = myPacket.getChildElement();

        List<Node> nodes = XpathHelper.findNodesInDocument(root.getDocument(), "//discoitems:item");
        for (Node node : nodes) {
            String node_domain = node.valueOf("@jid");
            if (watchedSubdomains.contains(node_domain)) {
                if (_permissions.isGatewayLimited(node_domain) && !_permissions.allowedForUser(node_domain, myPacket.getTo()))
                    root.remove(node);
            }
        }
    }
}
 

import org.jivesoftware.openfire.interceptor.PacketRejectedException; //导入依赖的package包/类
@Override
public void process(Packet packet, String subdomain, String to, String from) throws PacketRejectedException {
    Log.debug("Processing packet in ClientToComponentUpdateProcessor: " + packet.toString());

    Element query = ((IQ) packet).getChildElement();
    List<Node> nodes = findNodesInDocument(query.getDocument(), "//roster:item");
    if (nodes.size() > 0) {
        // We now know we have to check the JID of the to be added User
        // against our valid subdomains.
        for (Node n : nodes) {
            String jid = n.valueOf("@jid");
            // TODO: We ignore remove iq packets for now. There might be
            // conflicts
            // when we remove our legacy network registration.
            String found_subdomain = searchJIDforSubdomain(jid);
            if (found_subdomain.length() > 0 && !n.valueOf("@subscription").equals("remove")) {

                Log.debug("Mirroring packet from local network to legacy component " + found_subdomain);
                IQ forward = (IQ) packet.createCopy();
                forward.setTo(found_subdomain);
                dispatchPacket(forward);
            }
        }
    }
}
 

import org.jivesoftware.openfire.interceptor.PacketRejectedException; //导入依赖的package包/类
/**
 * At this Point we know: MucBlock = true, !incoming, !processed Package is
 * IQ with Namespace disco#info, from equals the watched subdomain given
 * through subdomain
 */
@Override
public void process(Packet packet, String subdomain, String to, String from) throws PacketRejectedException {
	IQ iqPacket = (IQ) packet;

	if (iqPacket.getType().equals(IQ.Type.result) && to.length() > 0) {
		Element root = iqPacket.getChildElement();

		List<Node> nodes = XpathHelper.findNodesInDocument(root.getDocument(), "//disco:feature");
		for (Node node : nodes) {
			String var = node.valueOf("@var");
			if (var.equals("http://jabber.org/protocol/muc"))
				root.remove(node);
		}

	}
}
 

import org.jivesoftware.openfire.interceptor.PacketRejectedException; //导入依赖的package包/类
/**
 * Here we process the response of the remote command sent to Spectrum. We have to identify what kind of response it
 * is, as no tag for the command being responded is being sent. Currently these commands are used in Gojara
 * TransportSessionManager: online_users ( Chatmsg of online users for specific transport), usernames seperated by
 * newlines
 */
@Override
public void process(Packet packet, String subdomain, String to, String from) throws PacketRejectedException {
	Message message = (Message) packet;

	// handle different commands
	Log.debug("Intercepted spectrum message: " + message.toString());
	String command = packet.getID();
	if (command.equals("online_users")) {
		handleOnlineUsers(message, subdomain);
	} else if (command.equals("unregister")) {
		handleUnregister(message, subdomain);
	} else if (command.equals("config_check")) {
		handleConfigCheck(subdomain);
	} else if (command.equals("uptime")) {
		handleStatistic(message, subdomain, "uptime");
	} else if (command.equals("messages_from_xmpp")) {
		handleStatistic(message, subdomain, "messages_from_xmpp");
	} else if (command.equals("messages_to_xmpp")) {
		handleStatistic(message, subdomain, "messages_to_xmpp");
	} else if (command.equals("used_memory")) {
		handleStatistic(message, subdomain, "used_memory");
	} else if (command.equals("average_memory_per_user")) {
		handleStatistic(message, subdomain, "average_memory_per_user");
	}
}
 

import org.jivesoftware.openfire.interceptor.PacketRejectedException; //导入依赖的package包/类
/**
 * If this is valid disco#items package for this Use-Case we iterate through
 * the nodes and check if we have to remove nodes, this way they are not
 * shown to the user receiving this disco#items.
 * 
 * @param subdomain
 *            not the actual Subdomain here, as we have to use our set.
 */
@Override
public void process(Packet packet, String subdomain, String to, String from) throws PacketRejectedException {
	IQ myPacket = (IQ) packet;
	if (myPacket.getType().equals(IQ.Type.result) && (from.length() == 0 || from.equals(_server.getServerInfo().getXMPPDomain()))) {

		Log.debug("Processing packet in Whitelistprocessor for " + to + "Packet: " + packet.toString());
		Element root = myPacket.getChildElement();

		List<Node> nodes = XpathHelper.findNodesInDocument(root.getDocument(), "//discoitems:item");
		for (Node node : nodes) {
			String node_domain = node.valueOf("@jid");
			if (watchedSubdomains.contains(node_domain)) {
				if (_permissions.isGatewayLimited(node_domain) && !_permissions.allowedForUser(node_domain, myPacket.getTo()))
					root.remove(node);
			}
		}
	}
}
 

import org.jivesoftware.openfire.interceptor.PacketRejectedException; //导入依赖的package包/类
@Override
public void process(Packet packet, String subdomain, String to, String from) throws PacketRejectedException {
	Log.debug("Processing packet in ClientToComponentUpdateProcessor: " + packet.toString());

	Element query = ((IQ) packet).getChildElement();
	List<Node> nodes = findNodesInDocument(query.getDocument(), "//roster:item");
	if (nodes.size() > 0) {
		// We now know we have to check the JID of the to be added User
		// against our valid subdomains.
		for (Node n : nodes) {
			String jid = n.valueOf("@jid");
			// TODO: We ignore remove iq packets for now. There might be
			// conflicts
			// when we remove our legacy network registration.
			String found_subdomain = searchJIDforSubdomain(jid);
			if (found_subdomain.length() > 0 && !n.valueOf("@subscription").equals("remove")) {

				Log.debug("Mirroring packet from local network to legacy component " + found_subdomain);
				IQ forward = (IQ) packet.createCopy();
				forward.setTo(found_subdomain);
				dispatchPacket(forward);
			}
		}
	}
}
 

import org.jivesoftware.openfire.interceptor.PacketRejectedException; //导入依赖的package包/类
@Override
public void interceptPacket(Packet packet, Session session, boolean incoming, boolean processed)
		throws PacketRejectedException {
	JID from = packet.getFrom();
	JID to = packet.getTo();

	if (from != null && to != null && processed && incoming) {
		if (from.toString().contains(_subdomain) || to.toString().contains(_subdomain)) {
			/*
			 * Spectrum sends a Ping to itself through the server to check
			 * if the server is alive. We ignore that for statistics
			 */
			if (to.toString().equals(from.toString()) && to.toString().equals(_subdomain))
				return;
			String type = packet.getClass().getName();
			_db.addNewLogEntry(_subdomain, type, from.toString(), to.toString());
		}
	}
}
 

import org.jivesoftware.openfire.interceptor.PacketRejectedException; //导入依赖的package包/类
@Override
public void interceptPacket(Packet packet, Session session, boolean incoming, boolean processed)
		throws PacketRejectedException {
	if (_permissions.isGatewayLimited(_subDomain)) {
		if (packet instanceof IQ) {
			IQ iqpacket = (IQ) packet;
			Element root = iqpacket.getChildElement();
			if (root == null)
				return; 
			
			String ns = root.getNamespaceURI();
			if (ns.equals("http://jabber.org/protocol/disco#items") && iqpacket.getType().equals(IQ.Type.result)) {
				if (!_permissions.allowedForUser(_subDomain, iqpacket.getTo())) {
					if (iqpacket.getFrom().toString().equals(_host)) {
						List<Node> nodes = XpathHelper.findNodesInDocument(root.getDocument(), "//discoitems:item");
						for (Node node : nodes) {
							if (node.valueOf("@jid").equals(_subDomain)) {
								root.remove(node);
							}
						}
					}
				}
			}
		}
	}
}
 

import org.jivesoftware.openfire.interceptor.PacketRejectedException; //导入依赖的package包/类
@Override
public void process(Packet packet) throws PacketRejectedException {
	Log.debug("Processing packet in NonPersistantRosterProcessor for " + _subDomain);
	Presence myPacket = (Presence) packet;
	String to = myPacket.getTo().toString();
	String username = getUsernameFromJid(to);
	if (myPacket.getType() != null && myPacket.getType().equals(Presence.Type.unavailable)) {
		try {
			Roster roster = _rosterManager.getRoster(username);
			Collection<RosterItem> items = roster.getRosterItems();
			for (RosterItem item : items) {
				String itemName = item.getJid().toString();
				if (itemName.contains(_subDomain) && !itemName.equals(_subDomain)) {
					Log.debug("Removing contact " + item.getJid().toString() + " from contact list.");
					roster.deleteRosterItem(item.getJid(), false);
				}
			}
			
		} catch (Exception e) {
			Log.debug("Execption occured when cleaning up the Roster.", e);
			e.printStackTrace();
		} 

	}
}
 

import org.jivesoftware.openfire.interceptor.PacketRejectedException; //导入依赖的package包/类
@Override
public void process(Packet packet) throws PacketRejectedException {
	Log.debug("Processing packet in SendRosterProcessor for " + _componentName);
	IQ myPacket = (IQ) packet;

	String user = myPacket.getTo().toString();
	String username = getUsernameFromJid(user);

	Roster roster;
	if(JiveGlobals.getBooleanProperty("plugin.remoteroster.persistent", false)){
		try {
			roster = _rosterManager.getRoster(username);
			Collection<RosterItem> items = roster.getRosterItems();
			sendRosterToComponent(myPacket, items);
		} catch (UserNotFoundException e) {
			e.printStackTrace();
		}
	} else {
		sendEmptyRoster(myPacket);
	}
}
 

import org.jivesoftware.openfire.interceptor.PacketRejectedException; //导入依赖的package包/类
@Override
public void process(Packet packet) throws PacketRejectedException {
	Log.debug("Processing packet in ClientToComponentUpdateProcessor for " + _myDomain);
	Element query = ((IQ) packet).getChildElement();
	if (query != null && query.getNamespaceURI().equals("jabber:iq:roster")) {
		if (findNodesInDocument(query.getDocument(), "//roster:item").size() > 0) {
			for (Node n : findNodesInDocument(query.getDocument(), "//roster:item")) {
				String jid = n.valueOf("@jid");
				// TODO: We ignore remove iq packets for now. There might be
				// conflicts
				// when we remove our legacy network registration.
				if (jid.contains("@" + _myDomain) && !n.valueOf("@subscription").equals("remove")) {
					Log.debug("Mirroring packet from local network to legacy component " + _myDomain);
					IQ forward = (IQ) packet.createCopy();
					forward.setTo(_myDomain);
					dispatchPacket(forward);
				}
			}
		}
	}
}
 

import org.jivesoftware.openfire.interceptor.PacketRejectedException; //导入依赖的package包/类
@Override
public void interceptPacket(Packet packet, Session session, boolean incoming,
                            boolean processed)
        throws PacketRejectedException
{
    // We only want packets received by the server
    if (!processed && incoming && packet instanceof IQ) {
        IQ iq = (IQ) packet;
        Element childElement = iq.getChildElement();
        if(childElement == null) {
            return;
        }

        String namespace = childElement.getNamespaceURI();
        String profile = childElement.attributeValue("profile");
        // Check that the SI is about file transfer and try creating a file transfer
        if (NAMESPACE_SI.equals(namespace) && NAMESPACE_SI_FILETRANSFER.equals(profile)) {
            // If this is a set, check the feature offer
            if (iq.getType().equals(IQ.Type.set)) {
                JID from = iq.getFrom();
                JID to = iq.getTo();

                FileTransfer transfer = createFileTransfer(from, to, childElement);

                try {
                    if (transfer == null || !acceptIncomingFileTransferRequest(transfer)) {
                        throw new PacketRejectedException();
                    }
                }
                catch (FileTransferRejectedException e) {
                    throw new PacketRejectedException(e);
                }
            }
        }
    }
}
 

import org.jivesoftware.openfire.interceptor.PacketRejectedException; //导入依赖的package包/类
public void interceptPacket(Packet packet, Session session, boolean incoming, boolean processed) throws PacketRejectedException {
    String type = getSubscriptionType();

    if (type.equals(DISABLED)) {
        return;
    }

    if ((packet instanceof Presence) && !incoming && !processed) {
        Presence presencePacket = (Presence) packet;

        Type presenceType = presencePacket.getType();
        if (presenceType != null && presenceType.equals(Presence.Type.subscribe)) {
            JID toJID = presencePacket.getTo();
            JID fromJID = presencePacket.getFrom();

            String toNode = toJID.getNode();
            if (whiteList.contains(toNode)) {
                return;
            }

            if (type.equals(ACCEPT)) {
                acceptSubscription(toJID, fromJID);
            }

            if (type.equals(REJECT)) {
                rejectSubscription(toJID, fromJID);
            }
        }
    }
}
 

import org.jivesoftware.openfire.interceptor.PacketRejectedException; //导入依赖的package包/类
private void rejectSubscription(JID toJID, JID fromJID) throws PacketRejectedException {
    if (getSubscriptionLevel().equals(LOCAL)) {
        String toDomain = toJID.getDomain();
        String fromDomain = fromJID.getDomain();

        if (toDomain.equals(serverName) && fromDomain.equals(serverName)) {
            return;
        }
    }

    // Simulate that the target user has rejected the presence subscription request
    Presence presence = new Presence();
    presence.setType(Presence.Type.unsubscribed);

    // This is to get around an issue in Spark
    // (http://www.igniterealtime.org/issues/browse/SPARK-300).
    // Unfortunately, this is a bit of a hack and can easily be defeated
    // if a user changes their resource when using Spark.
    if (JiveGlobals.getBooleanProperty("plugin.subscription.sparkCheck", false)) {
        String resource = fromJID.getResource();
        if (resource != null && resource.equalsIgnoreCase("Spark")) {
            presence.setType(Presence.Type.unsubscribed);
        }
    }

    presence.setTo(fromJID);
    presence.setFrom(toJID);
    router.route(presence);

    throw new PacketRejectedException();
}
 

import org.jivesoftware.openfire.interceptor.PacketRejectedException; //导入依赖的package包/类
public void interceptPacket(Packet packet, Session session, boolean incoming, boolean processed) throws PacketRejectedException {
    if (!processed && packet instanceof IQ && !incoming) {

        // Check for the Bookmark Storage element and hand off to the Bookmark engine.
        IQ iq = (IQ)packet;
        Element childElement = iq.getChildElement();
        if (childElement == null || iq.getType() != IQ.Type.result) {
            return;
        }

        String namespace = childElement.getNamespaceURI();
        if ("jabber:iq:private".equals(namespace)) {
            // In private data, when a user is attempting to retrieve bookmark
            // information, there will be a storage:bookmarks namespace.
            Element storageElement = childElement.element("storage");
            if (storageElement == null) {
                return;
            }

            namespace = storageElement.getNamespaceURI();
            if ("storage:bookmarks".equals(namespace)) {
                // Append Server defined bookmarks for user.
                JID toJID = iq.getTo();
                addBookmarks(toJID, storageElement);
            }
        }
    }
}