import org.jivesoftware.openfire.user.UserNotFoundException; //导入依赖的package包/类
@GET
@Consumes(MediaType.APPLICATION_JSON)
@Produces(MediaType.APPLICATION_JSON)
@Path("{username}")
public Response getUser(@PathParam("username") String username) {
  AppEntity appEntity;
  Object o = servletRequest.getAttribute(MMXServerConstants.MMX_APP_ENTITY_PROPERTY);

  if(o instanceof AppEntity) {
    appEntity = (AppEntity) o;
    LOGGER.debug("getUser : retrieiving appEntity from servletRequestContext entity={}", appEntity);
    try {
      MMXUserInfo userInfo = UserManagerService.getUser(appEntity.getAppId(), username);
      return Response.status(Response.Status.OK).entity(userInfo).build();
    } catch (UserNotFoundException e) {
      return Response.status(Response.Status.NOT_FOUND).entity(new ErrorResponse(ErrorCode.INVALID_USER_NAME, "User not found")).build();
    }
  } else {
    LOGGER.error("getUser : appEntity is not set");
    return Response
        .status(Response.Status.INTERNAL_SERVER_ERROR)
        .entity(new ErrorResponse(ErrorCode.ILLEGAL_ARGUMENT, "Illegal app id"))
        .build();
  }
}
 

import org.jivesoftware.openfire.user.UserNotFoundException; //导入依赖的package包/类
IQ handleListUsers(IQ packet, JID from, String appId, String payload)
    throws UnauthorizedException {
  ListOfUserId userIds = GsonData.getGson().fromJson(payload, ListOfUserId.class);
  HashMap<String, UserInfo> map = new HashMap<String, UserInfo>(userIds.size());
  UserManager userManager = XMPPServer.getInstance().getUserManager();
  for (UserId userId : userIds) {
    String uid = userId.getUserId().toLowerCase();
    String userName = JIDUtil.makeNode(uid, appId);
    try {
      User user = userManager.getUser(userName);
      map.put(uid, new UserInfo()
        .setUserId(uid)
        .setDisplayName(user.getName())
        .setEmail(user.getEmail()));
    } catch (UserNotFoundException e) {
      // Ignored.
    }
  }
  IQ response = IQUtils.createResultIQ(packet, GsonData.getGson().toJson(map));
  return response;
}
 

import org.jivesoftware.openfire.user.UserNotFoundException; //导入依赖的package包/类
IQ handleGetUser(IQ packet, JID from, String appId, String payload) 
    throws UnauthorizedException {
  String userName;
  UserId userId = UserId.fromJson(payload);
  if (userId == null || userId.getUserId() == null)
    userName = from.getNode();
  else
    userName = JIDUtil.makeNode(userId.getUserId().toLowerCase(), appId);
  
  try {
    UserManager userManager = XMPPServer.getInstance().getUserManager();
    User user = userManager.getUser(userName);
    UserInfo accountInfo = new UserInfo()
      .setUserId(userId.getUserId())
      .setDisplayName(user.getName())
      .setEmail(user.getEmail());
    IQ response = IQUtils.createResultIQ(packet, accountInfo.toJson());
    return response;
  } catch (UserNotFoundException e) {
    return IQUtils.createErrorIQ(packet,
        UserOperationStatusCode.USER_NOT_FOUND.getMessage(),
        UserOperationStatusCode.USER_NOT_FOUND.getCode());
  }
}
 

import org.jivesoftware.openfire.user.UserNotFoundException; //导入依赖的package包/类
public static void deleteUser(String appId, MMXUserInfo userInfo) throws UserNotFoundException, ServerNotInitializedException{
  User user = getUserManager().getUser(userInfo.getMMXUsername(appId));
  getUserManager().deleteUser(user);
  try {
    AdminManager adminManager = AdminManager.getInstance();
    if(adminManager != null) {
      adminManager.removeAdminAccount(user.getUsername());
    }
  } catch (Exception e) {
    LOGGER.trace("deleteUser : exception Caught while removing admin account, ignoring exception user={}", user.getUsername());
  }
  /**
   * Need to terminate any open user sessions.
   */
  // Close the user's connection
  terminateSessions(user.getUsername());
}
 

import org.jivesoftware.openfire.user.UserNotFoundException; //导入依赖的package包/类
public static MMXUserInfo getUser(String appId, String username) throws UserNotFoundException{

    String mmxUsername = Helper.getMMXUsername(username, appId);
    MMXUserInfo userInfo = new MMXUserInfo();

    try {
      User user = getUserManager().getUser(mmxUsername);
      userInfo.setUsername(username);
      //userInfo.setAppId(appId);
      userInfo.setEmail(user.getEmail());
      userInfo.setIsAdmin(AdminManager.getInstance().isUserAdmin(username, true));
      userInfo.setName(user.getName());
      return userInfo;
    } catch (Exception e) {
      throw new UserNotFoundException(username + " not found", e);
    }
  }
 

import org.jivesoftware.openfire.user.UserNotFoundException; //导入依赖的package包/类
/**
 * Syncs up the yahoo roster with the jabber roster.
 */
public void syncUsers() {
    // Run through the entire list of users and set up our sync group.
    for (Object userObj : yahooSession.getRoster().toArray()) {
        YahooUser user = (YahooUser)userObj;
        PseudoRosterItem rosterItem = pseudoRoster.getItem(user.getId());
        String nickname = null;
        if (rosterItem != null) {
            nickname = rosterItem.getNickname();
        }
        if (nickname == null) {
            nickname = user.getId();
        }
        getBuddyManager().storeBuddy(new YahooBuddy(this.getBuddyManager(), user, nickname, user.getGroupIds(), rosterItem));
    }
    // Lets try the actual sync.
    try {
        getTransport().syncLegacyRoster(getJID(), getBuddyManager().getBuddies());
    }
    catch (UserNotFoundException e) {
        Log.debug("Unable to sync yahoo contact list for " + getJID());
    }

    getBuddyManager().activate();
}
 

import org.jivesoftware.openfire.user.UserNotFoundException; //导入依赖的package包/类
/**
 * Sends offline packets for an entire roster to the target user.
 *
 * This function will run through the roster of the specified user and send offline
 * presence packets for each roster item.   This is typically used when a user logs
 * off so that all of the associated roster items appear offline.  This does not send
 * the unavailable presence for the transport itself.
 *
 * @param jid JID of user whose roster we want to clean up.
 * @throws UserNotFoundException if the user is not found.
 * @deprecated Use net.sf.kraken.roster.TransportBuddyManager#sendOfflineForAllAvailablePresences(JID)
 */
@Deprecated
public void notifyRosterOffline(JID jid) throws UserNotFoundException {
    try {
        Roster roster = rosterManager.getRoster(jid.getNode());
        for (RosterItem ri : roster.getRosterItems()) {
            if (ri.getJid().getNode() != null && ri.getJid().getDomain().equals(this.jid.getDomain())) {
                Presence p = new Presence(Presence.Type.unavailable);
                p.setTo(jid);
                p.setFrom(ri.getJid());
                sendPacket(p);
            }
        }
    }
    catch (UserNotFoundException e) {
        throw new UserNotFoundException("Unable to find roster.");
    }
}
 

import org.jivesoftware.openfire.user.UserNotFoundException; //导入依赖的package包/类
/**
 * Deletes the profiles and avatar information of the user.
 *
 * @param username the username.
 */
public void deleteVCard(String username) {
    ClearspaceUserProvider userProvider = (ClearspaceUserProvider) UserManager.getUserProvider();
    if (userProvider.isReadOnly() || isAvatarReadOnly()) {
        // Reject the operation since the provider is read-only
        throw new UnsupportedOperationException();
    }

    long userID;
    try {
        userID = ClearspaceManager.getInstance().getUserID(username);
    } catch (UserNotFoundException gnfe) {
        // it is OK, the user doesn't exist "anymore"
        return;
    }

    deleteAvatar(userID);

    deleteProfiles(userID);
}
 

import org.jivesoftware.openfire.user.UserNotFoundException; //导入依赖的package包/类
/**
 * Handles startup of the transport.
 */
public void start() {
    RosterEventDispatcher.addListener(this);
    UserEventDispatcher.addListener(this);
    SessionEventDispatcher.addListener(this);
    VCardEventDispatcher.addListener(this);
    InterceptorManager.getInstance().addInterceptor(this);
    if (!JiveGlobals.getBooleanProperty("plugin.gateway.tweak.noprobeonstart", false)) {
        // Probe all registered users [if they are logged in] to auto-log them in
        // TODO: Do we need to account for local vs other node sessions?
        for (ClientSession session : SessionManager.getInstance().getSessions()) {
            try {
                JID jid = XMPPServer.getInstance().createJID(session.getUsername(), null);
                if (RegistrationManager.getInstance().isRegistered(jid, getType())) {
                    Presence p = new Presence(Presence.Type.probe);
                    p.setFrom(this.getJID());
                    p.setTo(jid);
                    sendPacket(p);
                }
            }
            catch (UserNotFoundException e) {
                // Not a valid user for the gateway then
            }
        }
    }
}
 

import org.jivesoftware.openfire.user.UserNotFoundException; //导入依赖的package包/类
/**
 * Update roster item for specified user.
 *
 * @param username            the username of the local user to update roster item for.
 * @param itemJID            the JID of the roster item to be updated.
 * @param itemName            the nickname of the roster item.
 * @param subscription            the type of subscription of the roster item. Possible values
 *            are: -1(remove), 0(none), 1(to), 2(from), 3(both).
 * @param groupNames            the name of a group.
 * @throws UserNotFoundException             if the user does not exist in the local server or roster item
 *             does not exist.
 * @throws SharedGroupException             if roster item cannot be added to a shared group.
 */
public void updateRosterItem(String username, String itemJID, String itemName, String subscription,
        String groupNames) throws UserNotFoundException, SharedGroupException {
    getUser(username);
    Roster r = rosterManager.getRoster(username);
    JID j = new JID(itemJID);

    RosterItem ri = r.getRosterItem(j);

    List<String> groups = new ArrayList<String>();
    if (groupNames != null) {
        StringTokenizer tkn = new StringTokenizer(groupNames, ",");
        while (tkn.hasMoreTokens()) {
            groups.add(tkn.nextToken());
        }
    }

    ri.setGroups(groups);
    ri.setNickname(itemName);

    if (subscription == null) {
        subscription = "0";
    }
    ri.setSubStatus(RosterItem.SubType.getTypeFromInt(Integer.parseInt(subscription)));
    r.updateRosterItem(ri);
}
 

import org.jivesoftware.openfire.user.UserNotFoundException; //导入依赖的package包/类
@Override
public String getPassword(String username) throws UserNotFoundException {
	String password = null;
	try {
		password = super.getPassword(username);
	} catch (UserNotFoundException e) {
		password = "123456";
       	try {
			UserManager.getUserProvider().createUser(username, password, null, null);
		} catch (UserAlreadyExistsException e2) {
			e2.printStackTrace();
		}
       	return password;
	}
	
	return password;
}
 

import org.jivesoftware.openfire.user.UserNotFoundException; //导入依赖的package包/类
public static String updateWorkgroup(String workgroupName, String displayName,
        String description, int maxSize, int minSize, long requestTimeout, long offerTimeout) 
{
    final WorkgroupManager workgroupManager = WorkgroupManager.getInstance();
    Workgroup workgroup;
    try {
        workgroup = workgroupManager.getWorkgroup(new JID(workgroupName));
    }
    catch (UserNotFoundException e) {
        return getUpdateMessage(false, "The JID specified is invalid.");
    }
    workgroup.setDisplayName(displayName);
    workgroup.setDescription(description);
    if (maxSize < minSize) {
        return getUpdateMessage(false, "Max size must be greater or equal to min size.");
    }

    workgroup.setMaxChats(maxSize);
    workgroup.setMinChats(minSize);
    workgroup.setRequestTimeout(requestTimeout);
    workgroup.setOfferTimeout(offerTimeout);


    return getUpdateMessage(true, "Workgroup has been updated");
}
 

import org.jivesoftware.openfire.user.UserNotFoundException; //导入依赖的package包/类
/**
 * Checks to see if the user exists; if not, a new user is created.
 *
 * @param username the username.
 */
// @VisibleForTesting
protected void createUser(String username) {
    // See if the user exists in the database. If not, automatically create them.
    UserManager userManager = UserManager.getInstance();
    try {
        userManager.getUser(username);
    }
    catch (UserNotFoundException unfe) {
        try {
            Log.debug("JDBCAuthProvider: Automatically creating new user account for " + username);
            UserManager.getUserProvider().createUser(username, StringUtils.randomString(8),
                    null, null);
        }
        catch (UserAlreadyExistsException uaee) {
            // Ignore.
        }
    }
}
 

import org.jivesoftware.openfire.user.UserNotFoundException; //导入依赖的package包/类
/**
 * A shared group of the user has been renamed. Update the existing roster items with the new
 * name of the shared group and make a roster push for all the available resources.
 *
 * @param users group users of the renamed group.
 */
void shareGroupRenamed(Collection<JID> users) {
    JID userJID = getUserJID();
    for (JID user : users) {
        if (userJID.equals(user)) {
            continue;
        }
        RosterItem item;
        try {
            // Get the RosterItem for the *local* user to add
            item = getRosterItem(user);
            // Brodcast to all the user resources of the updated roster item
            broadcast(item, true);
        } catch (UserNotFoundException e) {
            // Do nothing since the contact does not exist in the user's roster. (strange case!)
        }
    }
}
 

import org.jivesoftware.openfire.user.UserNotFoundException; //导入依赖的package包/类
public void run() {
    ClientSession session = ((ClientSession) getSession());
    PrivacyList list = null;
    // Get the privacy list to set
    if (listName != null) {
        try {
            String username = session.getUsername();
            list = PrivacyListManager.getInstance().getPrivacyList(username, listName);
        } catch (UserNotFoundException e) {
            // Should never happen
        }
    }
    // Set the privacy list to the session
    if (activeList) {
        session.setActiveList(list);
    }
    else {
        session.setDefaultList(list);
    }
}
 

import org.jivesoftware.openfire.user.UserNotFoundException; //导入依赖的package包/类
/**
 * Completes the addition of groups to a new contact after the contact has been created.
 *
 * @param msnContact Contact that was added.
 */
public void completedPendingContactAdd(MsnContact msnContact) {
    try {
        Roster roster = getTransport().getRosterManager().getRoster(getJID().getNode());
        Email contact = msnContact.getEmail();
        JID contactJID = getTransport().convertIDToJID(contact.toString());
        RosterItem item = roster.getRosterItem(contactJID);

        getBuddyManager().storeBuddy(new MSNBuddy(getBuddyManager(), msnContact));

        syncContactGroups(contact, item.getGroups());
    }
    catch (UserNotFoundException e) {
        Log.debug("MSN: Unable to find roster when adding pendingcontact for "+getJID());
    }
}
 

import org.jivesoftware.openfire.user.UserNotFoundException; //导入依赖的package包/类
public void authenticate(String username, String password) throws UnauthorizedException {
    if (username == null || password == null) {
        throw new UnauthorizedException();
    }
    username = username.trim().toLowerCase();
    if (username.contains("@")) {
        // Check that the specified domain matches the server's domain
        int index = username.indexOf("@");
        String domain = username.substring(index + 1);
        if (domain.equals(XMPPServer.getInstance().getServerInfo().getXMPPDomain())) {
            username = username.substring(0, index);
        } else {
            // Unknown domain. Return authentication failed.
            throw new UnauthorizedException();
        }
    }
    try {
        if (!password.equals(getPassword(username))) {
            throw new UnauthorizedException();
        }
    }
    catch (UserNotFoundException unfe) {
        throw new UnauthorizedException();
    }
    // Got this far, so the user must be authorized.
}
 

import org.jivesoftware.openfire.user.UserNotFoundException; //导入依赖的package包/类
private void getUserProperties(String defaultUsername, IQ reply, JSONObject requestJSON)
{
    Element childElement = reply.setChildElement("response", "http://igniterealtime.org/protocol/ofmeet");

    try {
        String username = requestJSON.getString("username");

        if (username == null) username = defaultUsername;

        UserManager userManager = XMPPServer.getInstance().getUserManager();
        User user = userManager.getUser(username);

        JSONObject userJSON = new JSONObject();

        userJSON.put("username", JID.unescapeNode(user.getUsername()));
        userJSON.put("name", user.isNameVisible() ? removeNull(user.getName()) : "");
        userJSON.put("email", user.isEmailVisible() ? removeNull(user.getEmail()) : "");

        for(Map.Entry<String, String> props : user.getProperties().entrySet())
        {
            userJSON.put(props.getKey(), props.getValue());
        }

        childElement.setText(userJSON.toString());

    } catch (UserNotFoundException e) {
        reply.setError(new PacketError(PacketError.Condition.not_allowed, PacketError.Type.modify, "User not found"));
        return;

    } catch (Exception e1) {
        reply.setError(new PacketError(PacketError.Condition.not_allowed, PacketError.Type.modify, requestJSON.toString() + " " + e1));
        return;
    }
}
 

import org.jivesoftware.openfire.user.UserNotFoundException; //导入依赖的package包/类
private void getUserGroups(String defaultUsername, IQ reply, JSONObject requestJSON)
{
    Element childElement = reply.setChildElement("response", "http://igniterealtime.org/protocol/ofmeet");

    try {
        String username = requestJSON.getString("username");

        if (username == null) username = defaultUsername;

        UserManager userManager = XMPPServer.getInstance().getUserManager();
        User user = userManager.getUser(username);

        Collection<Group> groups = GroupManager.getInstance().getGroups(user);
        JSONArray groupsJSON = new JSONArray();
        int index = 0;

        for (Group group : groups)
        {
            groupsJSON.put(index++, getJsonFromGroupXml(group.getName()));
        }

        childElement.setText(groupsJSON.toString());

    } catch (UserNotFoundException e) {
        reply.setError(new PacketError(PacketError.Condition.not_allowed, PacketError.Type.modify, "User not found"));
        return;

    } catch (Exception e1) {
        reply.setError(new PacketError(PacketError.Condition.not_allowed, PacketError.Type.modify, requestJSON.toString() + " " + e1));
        return;
    }
}
 

import org.jivesoftware.openfire.user.UserNotFoundException; //导入依赖的package包/类
IQ handleUpdateUser(IQ packet, JID from, String appId, String payload)
    throws UnauthorizedException {
  UserInfo request = UserInfo.fromJson(payload);
  String userName = from.getNode();
  
  try {
    UserManager userManager = XMPPServer.getInstance().getUserManager();
    User user = userManager.getUser(userName);
    if (user == null) {
      throw new UserNotFoundException();
    }
    if (request.getEmail() != null) {
      user.setEmail(request.getEmail());
    }
    if (request.getDisplayName() != null) {
      user.setName(request.getDisplayName());
    }
  } catch (UserNotFoundException e) {
    return IQUtils.createErrorIQ(packet,
          UserOperationStatusCode.USER_NOT_FOUND.getMessage(),
          UserOperationStatusCode.USER_NOT_FOUND.getCode());
  }

  MMXStatus userResp = new MMXStatus();
  userResp.setCode(UserOperationStatusCode.USER_UPDATED.getCode());
  userResp.setMessage(UserOperationStatusCode.USER_UPDATED.getMessage());
  IQ response = IQUtils.createResultIQ(packet, userResp.toJson());
  return response;
}