import org.jivesoftware.util.LocaleUtils; //导入依赖的package包/类
public String getLastPresenceStatus(User user) {
    String username = user.getUsername();
    String presenceStatus = null;
    String presenceXML = offlinePresenceCache.get(username);
    if (presenceXML == null) {
        loadOfflinePresence(username);
    }
    presenceXML = offlinePresenceCache.get(username);
    if (presenceXML != null) {
        // If the cached answer is no data, return null.
        if (presenceXML.equals(NULL_STRING)) {
            return null;
        }
        // Otherwise, parse out the status from the XML.
        try {
            // Parse the element
            Document element = DocumentHelper.parseText(presenceXML);
            presenceStatus = element.getRootElement().elementTextTrim("status");
        }
        catch (DocumentException e) {
            Log.error(LocaleUtils.getLocalizedString("admin.error"), e);
        }
    }
    return presenceStatus;
}
 

import org.jivesoftware.util.LocaleUtils; //导入依赖的package包/类
/**
 * @see org.openymsg.network.event.SessionAdapter#newMailReceived(org.openymsg.network.event.SessionNewMailEvent)
 */
public void newMailReceived(SessionNewMailEvent event) {
    if (JiveGlobals.getBooleanProperty("plugin.gateway.yahoo.mailnotifications", true) && (emailInitialized || event.getMailCount() > 0)) {
        if (!emailInitialized) {
            getSession().getTransport().sendMessage(
                    getSession().getJID(),
                    getSession().getTransport().getJID(),
                    LocaleUtils.getLocalizedString("gateway.yahoo.mail", "kraken", Arrays.asList(Integer.toString(event.getMailCount()))),
                    Message.Type.headline
            );
        }
        else {
            getSession().getTransport().sendMessage(
                    getSession().getJID(),
                    getSession().getTransport().getJID(),
                    LocaleUtils.getLocalizedString("gateway.yahoo.newmail", "kraken"),
                    Message.Type.headline
            );
        }
    }
    emailInitialized = true;
}
 

import org.jivesoftware.util.LocaleUtils; //导入依赖的package包/类
@Override
    protected void handleFlapPacket(FlapPacketEvent e) {
//        Log.debug("OSCAR bos flap packet received: "+e);
        FlapCommand cmd = e.getFlapCommand();

        if (cmd instanceof CloseFlapCmd) {
            CloseFlapCmd cfc = (CloseFlapCmd)cmd;
            if (cfc.getCode() == CloseFlapCmd.CODE_LOGGED_IN_ELSEWHERE) {
                getMainSession().setFailureStatus(ConnectionFailureReason.LOCKED_OUT);
                getMainSession().sessionDisconnectedNoReconnect(LocaleUtils.getLocalizedString("gateway.oscar.multilogin", "kraken"));
            }
            else {
                getMainSession().setFailureStatus(ConnectionFailureReason.UNKNOWN);                
                getMainSession().sessionDisconnected(LocaleUtils.getLocalizedString("gateway.oscar.disconnected", "kraken"));
            }
        }
        super.handleFlapPacket(e);
    }
 

import org.jivesoftware.util.LocaleUtils; //导入依赖的package包/类
/**
 * <p>Following the loading and initialization of all the modules
 * this method is called to iterate through the known modules and
 * start them.</p>
 */
private void startModules() {
    for (Module module : modules.values()) {
        boolean started = false;
        try {
            module.start();
        }
        catch (Exception e) {
            if (started && module != null) {
                module.stop();
                module.destroy();
            }
            Log.error(LocaleUtils.getLocalizedString("admin.error"), e);
        }
    }
}
 

import org.jivesoftware.util.LocaleUtils; //导入依赖的package包/类
@Override
public void start() {
    // Check that the service is enabled
    if (!isServiceEnabled()) {
        return;
    }
    super.start();
    // Add the route to this service
    routingTable.addComponentRoute(getAddress(), this);
    // Start the pubsub engine
    engine.start(this);
    ArrayList<String> params = new ArrayList<>();
    params.clear();
    params.add(getServiceDomain());
    Log.info(LocaleUtils.getLocalizedString("startup.starting.pubsub", params));
}
 

import org.jivesoftware.util.LocaleUtils; //导入依赖的package包/类
@Override
protected void addStageInformation(SessionData data, Element command) {
    DataForm form = new DataForm(DataForm.Type.form);
    form.setTitle(LocaleUtils.getLocalizedString("pubsub.command.pending-subscriptions.title"));
    form.addInstruction(
            LocaleUtils.getLocalizedString("pubsub.command.pending-subscriptions.instruction"));

    FormField formField = form.addField();
    formField.setVariable("pubsub#node");
    formField.setType(FormField.Type.list_single);
    formField.setLabel(
            LocaleUtils.getLocalizedString("pubsub.command.pending-subscriptions.node"));
    for (Node node : service.getNodes()) {
        if (!node.isCollectionNode() && node.isAdmin(data.getOwner())) {
            formField.addOption(null, node.getNodeID());
        }
    }
    // Add the form to the command
    command.add(form.getElement());
}
 

import org.jivesoftware.util.LocaleUtils; //导入依赖的package包/类
/**
 * Updates a registration via the web interface.
 *
 *
 * @param registrationID ID number associated with registration to modify.
 * @param legacyUsername User's updated username on the legacy service.
 * @param legacyPassword User's updated password on the legacy service, null if no change.
 * @param legacyNickname User's updated nickname on the legacy service.
 * @return Error message or null on success.
 */
public String updateRegistration(Integer registrationID, String legacyUsername, String legacyPassword, String legacyNickname) {
    PluginManager pluginManager = XMPPServer.getInstance().getPluginManager();
    KrakenPlugin plugin = (KrakenPlugin)pluginManager.getPlugin("kraken");
    try {
        Registration reg = new Registration(registrationID);
        if (!plugin.getTransportInstance(reg.getTransportType().toString()).isEnabled()) {
            return LocaleUtils.getLocalizedString("gateway.web.registrations.notenabled", "kraken");
        }
        reg.setUsername(legacyUsername);
        if (legacyPassword != null) {
            reg.setPassword(legacyPassword);
        }
        reg.setNickname(legacyNickname);
        return null;
    }
    catch (NotFoundException e) {
        // Ok, nevermind.
        Log.error("Not found while editing id "+registrationID, e);
        return LocaleUtils.getLocalizedString("gateway.web.registrations.regnotfound", "kraken");
    }
}
 

import org.jivesoftware.util.LocaleUtils; //导入依赖的package包/类
/**
 * Create a MSN Session instance.
 *
 * @param registration Registration information used for logging in.
 * @param jid JID associated with this session.
 * @param transport Transport instance associated with this session.
 * @param priority Priority of this session.
 */
public MSNSession(Registration registration, JID jid, MSNTransport transport, Integer priority) {
    super(registration, jid, transport, priority);
    setSupportedFeature(SupportedFeature.chatstates);
    setSupportedFeature(SupportedFeature.attention);

    if (Email.parseStr(registration.getUsername()) == null) {
        Message m = new Message();
        m.setType(Message.Type.error);
        m.setTo(getJID());
        m.setFrom(getTransport().getJID());
        m.setBody(LocaleUtils.getLocalizedString("gateway.msn.illegalaccount", "kraken")+" "+registration.getUsername());
        getTransport().sendPacket(m);
        // TODO: this should probably be generic and done within base transport for -all- transports
        // TODO: Also, this Email.parseStr could be used in the "is this a valid username" check
    }
}
 

import org.jivesoftware.util.LocaleUtils; //导入依赖的package包/类
public long getLastActivity(User user) {
    String username = user.getUsername();
    long lastActivity = NULL_LONG;
    Long offlineDate = lastActivityCache.get(username);
    if (offlineDate == null) {
        loadOfflinePresence(username);
    }
    offlineDate = lastActivityCache.get(username);
    if (offlineDate != null) {
        // If the cached answer is no data, return -1.
        if (offlineDate == NULL_LONG) {
            return NULL_LONG;
        }
        else {
            try {
                lastActivity = (System.currentTimeMillis() - offlineDate);
            }
            catch (NumberFormatException e) {
                Log.error(LocaleUtils.getLocalizedString("admin.error"), e);
            }
        }
    }
    return lastActivity;
}
 

import org.jivesoftware.util.LocaleUtils; //导入依赖的package包/类
public int getItemCount(String username) {
    int count = 0;
    Connection con = null;
    PreparedStatement pstmt = null;
    ResultSet rs = null;
    try {
        con = DbConnectionManager.getConnection();
        pstmt = con.prepareStatement(COUNT_ROSTER_ITEMS);
        pstmt.setString(1, username);
        rs = pstmt.executeQuery();
        if (rs.next()) {
            count = rs.getInt(1);
        }
    }
    catch (SQLException e) {
        Log.error(LocaleUtils.getLocalizedString("admin.error"), e);
    }
    finally {
        DbConnectionManager.closeConnection(rs, pstmt, con);
    }
    return count;
}
 

import org.jivesoftware.util.LocaleUtils; //导入依赖的package包/类
/**
 * Deletes the DispatcherInfo Object from the given RequestQueue.
 * @param queueID the id of the RequestQueue.
 * @throws UnauthorizedException thrown if the user is not allowed to delete from the db.
 */
public void deleteDispatcherInfo(long queueID) throws UnauthorizedException {
    Connection con = null;
    PreparedStatement pstmt = null;
    try {
        con = DbConnectionManager.getConnection();
        pstmt = con.prepareStatement(DELETE_DISPATCHER);
        pstmt.setLong(1, queueID);
        pstmt.executeUpdate();
    }
    catch (SQLException e) {
        Log.error(LocaleUtils.getLocalizedString("admin.error"), e);
        throw new UnauthorizedException();
    }
    finally {
        DbConnectionManager.closeConnection(pstmt, con);
    }
}
 

import org.jivesoftware.util.LocaleUtils; //导入依赖的package包/类
@Override
public void start() {
       // Check that the service is enabled
       if (!isServiceEnabled()) {
           return;
       }
       super.start();
       // Add the route to this service
       routingTable.addComponentRoute(getAddress(), this);
       // Start the pubsub engine
       engine.start(this);
       ArrayList<String> params = new ArrayList<String>();
       params.clear();
       params.add(getServiceDomain());
       Log.info(LocaleUtils.getLocalizedString("startup.starting.pubsub", params));
   }
 

import org.jivesoftware.util.LocaleUtils; //导入依赖的package包/类
@Override
public long getLastActivity(User user) {
    String username = user.getUsername();
    long lastActivity = NULL_LONG;
    Long offlineDate = lastActivityCache.get(username);
    if (offlineDate == null) {
        loadOfflinePresence(username);
    }
    offlineDate = lastActivityCache.get(username);
    if (offlineDate != null) {
        // If the cached answer is no data, return -1.
        if (offlineDate == NULL_LONG) {
            return NULL_LONG;
        }
        else {
            try {
                lastActivity = (System.currentTimeMillis() - offlineDate);
            }
            catch (NumberFormatException e) {
                Log.error(LocaleUtils.getLocalizedString("admin.error"), e);
            }
        }
    }
    return lastActivity;
}
 

import org.jivesoftware.util.LocaleUtils; //导入依赖的package包/类
/**
 * Close outgoing server sessions that have been idle for a long time.
 */
@Override
public void run() {
    // Do nothing if this feature is disabled
    int idleTime = SessionManager.getInstance().getServerSessionIdleTime();
    if (idleTime == -1) {
        return;
    }
    final long deadline = System.currentTimeMillis() - idleTime;
    for (RoutableChannelHandler route : routes.values()) {
        // Check outgoing server sessions
        if (route instanceof OutgoingServerSession) {
            Session session = (Session) route;
            try {
                if (session.getLastActiveDate().getTime() < deadline) {
                    session.close();
                }
            }
            catch (Throwable e) {
                Log.error(LocaleUtils.getLocalizedString("admin.error"), e);
            }
        }
    }
}
 

import org.jivesoftware.util.LocaleUtils; //导入依赖的package包/类
/**
       * Close outgoing server sessions that have been idle for a long time.
       */
      @Override
public void run() {
          // Do nothing if this feature is disabled
          int idleTime = SessionManager.getInstance().getServerSessionIdleTime();
          if (idleTime == -1) {
              return;
          }
          final long deadline = System.currentTimeMillis() - idleTime;
          for (RoutableChannelHandler route : routes.values()) {
              // Check outgoing server sessions
              if (route instanceof OutgoingServerSession) {
                  Session session = (Session) route;
                  try {
                      if (session.getLastActiveDate().getTime() < deadline) {
                          session.close();
                      }
                  }
                  catch (Throwable e) {
                      Log.error(LocaleUtils.getLocalizedString("admin.error"), e);
                  }
              }
          }
      }
 

import org.jivesoftware.util.LocaleUtils; //导入依赖的package包/类
@Override
public Iterator<String> getUsernames(String jid) {
    List<String> answer = new ArrayList<>();
    Connection con = null;
    PreparedStatement pstmt = null;
    ResultSet rs = null;
    try {
        con = DbConnectionManager.getConnection();
        pstmt = con.prepareStatement(LOAD_USERNAMES);
        pstmt.setString(1, jid);
        rs = pstmt.executeQuery();
        while (rs.next()) {
            answer.add(rs.getString(1));
        }
    }
    catch (SQLException e) {
        Log.error(LocaleUtils.getLocalizedString("admin.error"), e);
    }
    finally {
        DbConnectionManager.closeConnection(rs, pstmt, con);
    }
    return answer.iterator();
}
 

import org.jivesoftware.util.LocaleUtils; //导入依赖的package包/类
/**
 * Handle presence updates that affect roster subscriptions.
 *
 * @param presence The presence presence to handle
 * @throws PacketException if the packet is null or the packet could not be routed.
 */
public void process(Presence presence) throws PacketException {
    try {
        process((Packet)presence);
    }
    catch (UnauthorizedException e) {
        try {
            LocalSession session = (LocalSession) sessionManager.getSession(presence.getFrom());
            presence = presence.createCopy();
            if (session != null) {
                presence.setFrom(new JID(null, session.getServerName(), null, true));
                presence.setTo(session.getAddress());
            }
            else {
                JID sender = presence.getFrom();
                presence.setFrom(presence.getTo());
                presence.setTo(sender);
            }
            presence.setError(PacketError.Condition.not_authorized);
            deliverer.deliver(presence);
        }
        catch (Exception err) {
            Log.error(LocaleUtils.getLocalizedString("admin.error"), err);
        }
    }
}
 

import org.jivesoftware.util.LocaleUtils; //导入依赖的package包/类
public void processPacket(Packet packet) {
    if (!isServiceEnabled()) {
        return;
    }
    // The MUC service will receive all the packets whose domain matches the domain of the MUC
    // service. This means that, for instance, a disco request should be responded by the
    // service itself instead of relying on the server to handle the request.
    try {
        // Check if the packet is a disco request or a packet with namespace iq:register
        if (packet instanceof IQ) {
            if (process((IQ)packet)) {
                return;
            }
        }
        // The packet is a normal packet that should possibly be sent to the room
        JID receipient = packet.getTo();
        String roomName = receipient != null ? receipient.getNode() : null;
        getChatUser(packet.getFrom(), roomName).process(packet);
    }
    catch (Exception e) {
        Log.error(LocaleUtils.getLocalizedString("admin.error"), e);
    }
}
 

import org.jivesoftware.util.LocaleUtils; //导入依赖的package包/类
private IQ passwordReset(String password, IQ packet, String username, Session session)
        throws UnauthorizedException
{
    IQ response;
    // Check if users can change their passwords and a password was specified
    if (!registerHandler.canChangePassword() || password == null || password.length() == 0) {
        throw new UnauthorizedException();
    }
    else {
        try {
            userManager.getUser(username).setPassword(password);
            response = IQ.createResultIQ(packet);
            List<String> params = new ArrayList<String>();
            params.add(username);
            params.add(session.toString());
            Log.info(LocaleUtils.getLocalizedString("admin.password.update", params));
        }
        catch (UserNotFoundException e) {
            throw new UnauthorizedException();
        }
    }
    return response;
}
 

import org.jivesoftware.util.LocaleUtils; //导入依赖的package包/类
private void closeConnection() {
    release();
    try {
        if (tlsStreamHandler == null) {
            socket.close();
        }
        else {
            // Close the channels since we are using TLS (i.e. NIO). If the channels implement
            // the InterruptibleChannel interface then any other thread that was blocked in
            // an I/O operation will be interrupted and an exception thrown
            tlsStreamHandler.close();
        }
    }
    catch (Exception e) {
        Log.error(LocaleUtils.getLocalizedString("admin.error.close")
                + "\n" + this.toString(), e);
    }
}