James Moger
2013-09-30 699e71e76b15081baf746c6ce9c9144f7e5f1ff9
src/main/java/com/gitblit/ConfigUserService.java
@@ -45,16 +45,16 @@
/**
 * ConfigUserService is Gitblit's default user service implementation since
 * version 0.8.0.
 *
 *
 * Users and their repository memberships are stored in a git-style config file
 * which is cached and dynamically reloaded when modified. This file is
 * plain-text, human-readable, and may be edited with a text editor.
 *
 *
 * Additionally, this format allows for expansion of the user model without
 * bringing in the complexity of a database.
 *
 *
 * @author James Moger
 *
 *
 */
public class ConfigUserService implements IUserService {
@@ -63,21 +63,21 @@
   private static final String USER = "user";
   private static final String PASSWORD = "password";
   private static final String DISPLAYNAME = "displayName";
   private static final String EMAILADDRESS = "emailAddress";
   private static final String ORGANIZATIONALUNIT = "organizationalUnit";
   private static final String ORGANIZATION = "organization";
   private static final String LOCALITY = "locality";
   private static final String STATEPROVINCE = "stateProvince";
   private static final String COUNTRYCODE = "countryCode";
   private static final String COOKIE = "cookie";
   private static final String REPOSITORY = "repository";
@@ -89,9 +89,9 @@
   private static final String PRERECEIVE = "preReceiveScript";
   private static final String POSTRECEIVE = "postReceiveScript";
   private static final String STARRED = "starred";
   private static final String LOCALE = "locale";
   private final File realmFile;
@@ -105,7 +105,7 @@
   private final Map<String, TeamModel> teams = new ConcurrentHashMap<String, TeamModel>();
   private volatile long lastModified;
   private volatile boolean forceReload;
   public ConfigUserService(File realmFile) {
@@ -114,7 +114,7 @@
   /**
    * Setup the user service.
    *
    *
    * @param settings
    * @since 0.7.0
    */
@@ -124,7 +124,7 @@
   /**
    * Does the user service support changes to credentials?
    *
    *
    * @return true or false
    * @since 1.0.0
    */
@@ -135,7 +135,7 @@
   /**
    * Does the user service support changes to user display name?
    *
    *
    * @return true or false
    * @since 1.0.0
    */
@@ -146,7 +146,7 @@
   /**
    * Does the user service support changes to user email address?
    *
    *
    * @return true or false
    * @since 1.0.0
    */
@@ -157,17 +157,18 @@
   /**
    * Does the user service support changes to team memberships?
    *
    *
    * @return true or false
    * @since 1.0.0
    */
    */
   @Override
   public boolean supportsTeamMembershipChanges() {
      return true;
   }
   /**
    * Does the user service support cookie authentication?
    *
    *
    * @return true or false
    */
   @Override
@@ -177,7 +178,7 @@
   /**
    * Returns the cookie value for the specified user.
    *
    *
    * @param model
    * @return cookie value
    */
@@ -186,19 +187,21 @@
      if (!StringUtils.isEmpty(model.cookie)) {
         return model.cookie;
      }
      read();
      UserModel storedModel = users.get(model.username.toLowerCase());
      UserModel storedModel = getUserModel(model.username);
      if (storedModel == null) {
         return null;
      }
      return storedModel.cookie;
   }
   /**
    * Authenticate a user based on their cookie.
    *
    *
    * @param cookie
    * @return a user object or null
    */
   @Override
   public UserModel authenticate(char[] cookie) {
   public synchronized UserModel authenticate(char[] cookie) {
      String hash = new String(cookie);
      if (StringUtils.isEmpty(hash)) {
         return null;
@@ -208,7 +211,7 @@
      if (cookies.containsKey(hash)) {
         model = cookies.get(hash);
      }
      if (model != null) {
         // clone the model, otherwise all changes to this object are
         // live and unpersisted
@@ -219,14 +222,13 @@
   /**
    * Authenticate a user based on a username and password.
    *
    *
    * @param username
    * @param password
    * @return a user object or null
    */
   @Override
   public UserModel authenticate(String username, char[] password) {
      read();
      UserModel returnedUser = null;
      UserModel user = getUserModel(username);
      if (user == null) {
@@ -254,21 +256,21 @@
   /**
    * Logout a user.
    *
    *
    * @param user
    */
   @Override
   public void logout(UserModel user) {
   public void logout(UserModel user) {
   }
   /**
    * Retrieve the user object for the specified username.
    *
    *
    * @param username
    * @return a user object or null
    */
   @Override
   public UserModel getUserModel(String username) {
   public synchronized UserModel getUserModel(String username) {
      read();
      UserModel model = users.get(username.toLowerCase());
      if (model != null) {
@@ -281,7 +283,7 @@
   /**
    * Updates/writes a complete user object.
    *
    *
    * @param model
    * @return true if update is successful
    */
@@ -292,13 +294,13 @@
   /**
    * Updates/writes all specified user objects.
    *
    *
    * @param models a list of user models
    * @return true if update is successful
    * @since 1.2.0
    */
   @Override
   public boolean updateUserModels(Collection<UserModel> models) {
   public synchronized boolean updateUserModels(Collection<UserModel> models) {
      try {
         read();
         for (UserModel model : models) {
@@ -316,7 +318,7 @@
                  } else {
                     // do not clobber existing team definition
                     // maybe because this is a federated user
                     t.addUser(model.username);
                     t.addUser(model.username);
                  }
               }
@@ -342,7 +344,7 @@
   /**
    * Updates/writes and replaces a complete user object keyed by username.
    * This method allows for renaming a user.
    *
    *
    * @param username
    *            the old username
    * @param model
@@ -350,7 +352,7 @@
    * @return true if update is successful
    */
   @Override
   public boolean updateUserModel(String username, UserModel model) {
   public synchronized boolean updateUserModel(String username, UserModel model) {
      UserModel originalUser = null;
      try {
         read();
@@ -400,7 +402,7 @@
   /**
    * Deletes the user object from the user service.
    *
    *
    * @param model
    * @return true if successful
    */
@@ -411,12 +413,12 @@
   /**
    * Delete the user object with the specified username
    *
    *
    * @param username
    * @return true if successful
    */
   @Override
   public boolean deleteUser(String username) {
   public synchronized boolean deleteUser(String username) {
      try {
         // Read realm file
         read();
@@ -447,7 +449,7 @@
   /**
    * Returns the list of all teams available to the login service.
    *
    *
    * @return list of all teams
    * @since 0.8.0
    */
@@ -461,12 +463,12 @@
   /**
    * Returns the list of all teams available to the login service.
    *
    *
    * @return list of all teams
    * @since 0.8.0
    */
   @Override
   public List<TeamModel> getAllTeams() {
   public synchronized List<TeamModel> getAllTeams() {
      read();
      List<TeamModel> list = new ArrayList<TeamModel>(teams.values());
      list = DeepCopier.copy(list);
@@ -477,13 +479,13 @@
   /**
    * Returns the list of all users who are allowed to bypass the access
    * restriction placed on the specified repository.
    *
    *
    * @param role
    *            the repository name
    * @return list of all usernames that can bypass the access restriction
    */
   @Override
   public List<String> getTeamnamesForRepositoryRole(String role) {
   public synchronized List<String> getTeamnamesForRepositoryRole(String role) {
      List<String> list = new ArrayList<String>();
      try {
         read();
@@ -503,14 +505,14 @@
   /**
    * Sets the list of all teams who are allowed to bypass the access
    * restriction placed on the specified repository.
    *
    *
    * @param role
    *            the repository name
    * @param teamnames
    * @return true if successful
    */
   @Override
   public boolean setTeamnamesForRepositoryRole(String role, List<String> teamnames) {
   public synchronized boolean setTeamnamesForRepositoryRole(String role, List<String> teamnames) {
      try {
         Set<String> specifiedTeams = new HashSet<String>();
         for (String teamname : teamnames) {
@@ -541,13 +543,13 @@
   /**
    * Retrieve the team object for the specified team name.
    *
    *
    * @param teamname
    * @return a team object or null
    * @since 0.8.0
    */
   @Override
   public TeamModel getTeamModel(String teamname) {
   public synchronized TeamModel getTeamModel(String teamname) {
      read();
      TeamModel model = teams.get(teamname.toLowerCase());
      if (model != null) {
@@ -560,7 +562,7 @@
   /**
    * Updates/writes a complete team object.
    *
    *
    * @param model
    * @return true if update is successful
    * @since 0.8.0
@@ -572,7 +574,7 @@
   /**
    * Updates/writes all specified team objects.
    *
    *
    * @param models a list of team models
    * @return true if update is successful
    * @since 1.2.0
@@ -595,7 +597,7 @@
   /**
    * Updates/writes and replaces a complete team object keyed by teamname.
    * This method allows for renaming a team.
    *
    *
    * @param teamname
    *            the old teamname
    * @param model
@@ -627,7 +629,7 @@
   /**
    * Deletes the team object from the user service.
    *
    *
    * @param model
    * @return true if successful
    * @since 0.8.0
@@ -639,7 +641,7 @@
   /**
    * Delete the team object with the specified teamname
    *
    *
    * @param teamname
    * @return true if successful
    * @since 0.8.0
@@ -660,7 +662,7 @@
   /**
    * Returns the list of all users available to the login service.
    *
    *
    * @return list of all usernames
    */
   @Override
@@ -670,31 +672,31 @@
      Collections.sort(list);
      return list;
   }
   /**
    * Returns the list of all users available to the login service.
    *
    *
    * @return list of all usernames
    */
   @Override
   public List<UserModel> getAllUsers() {
   public synchronized List<UserModel> getAllUsers() {
      read();
      List<UserModel> list = new ArrayList<UserModel>(users.values());
      list = DeepCopier.copy(list);
      Collections.sort(list);
      return list;
   }
   }
   /**
    * Returns the list of all users who are allowed to bypass the access
    * restriction placed on the specified repository.
    *
    *
    * @param role
    *            the repository name
    * @return list of all usernames that can bypass the access restriction
    */
   @Override
   public List<String> getUsernamesForRepositoryRole(String role) {
   public synchronized List<String> getUsernamesForRepositoryRole(String role) {
      List<String> list = new ArrayList<String>();
      try {
         read();
@@ -714,7 +716,7 @@
   /**
    * Sets the list of all uses who are allowed to bypass the access
    * restriction placed on the specified repository.
    *
    *
    * @param role
    *            the repository name
    * @param usernames
@@ -722,7 +724,7 @@
    */
   @Override
   @Deprecated
   public boolean setUsernamesForRepositoryRole(String role, List<String> usernames) {
   public synchronized boolean setUsernamesForRepositoryRole(String role, List<String> usernames) {
      try {
         Set<String> specifiedUsers = new HashSet<String>();
         for (String username : usernames) {
@@ -753,13 +755,13 @@
   /**
    * Renames a repository role.
    *
    *
    * @param oldRole
    * @param newRole
    * @return true if successful
    */
   @Override
   public boolean renameRepositoryRole(String oldRole, String newRole) {
   public synchronized boolean renameRepositoryRole(String oldRole, String newRole) {
      try {
         read();
         // identify users which require role rename
@@ -789,12 +791,12 @@
   /**
    * Removes a repository role from all users.
    *
    *
    * @param role
    * @return true if successful
    */
   @Override
   public boolean deleteRepositoryRole(String role) {
   public synchronized boolean deleteRepositoryRole(String role) {
      try {
         read();
@@ -819,7 +821,7 @@
   /**
    * Writes the properties file.
    *
    *
    * @throws IOException
    */
   private synchronized void write() throws IOException {
@@ -895,7 +897,7 @@
            }
            config.setStringList(USER, model.username, REPOSITORY, permissions);
         }
         // user preferences
         if (model.getPreferences() != null) {
            List<String> starred =  model.getPreferences().getStarredRepositories();
@@ -924,7 +926,7 @@
            roles.add(Constants.NO_ROLE);
         }
         config.setStringList(TEAM, model.name, ROLE, roles);
         if (!model.canAdmin) {
            // write team permission for non-admin teams
            if (model.permissions == null) {
@@ -1014,7 +1016,7 @@
            Set<String> usernames = config.getSubsections(USER);
            for (String username : usernames) {
               UserModel user = new UserModel(username.toLowerCase());
               user.password = config.getString(USER, username, PASSWORD);
               user.password = config.getString(USER, username, PASSWORD);
               user.displayName = config.getString(USER, username, DISPLAYNAME);
               user.emailAddress = config.getString(USER, username, EMAILADDRESS);
               user.organizationalUnit = config.getString(USER, username, ORGANIZATIONALUNIT);
@@ -1023,7 +1025,7 @@
               user.stateProvince = config.getString(USER, username, STATEPROVINCE);
               user.countryCode = config.getString(USER, username, COUNTRYCODE);
               user.cookie = config.getString(USER, username, COOKIE);
               user.getPreferences().locale = config.getString(USER, username, LOCALE);
               user.getPreferences().locale = config.getString(USER, username, LOCALE);
               if (StringUtils.isEmpty(user.cookie) && !StringUtils.isEmpty(user.password)) {
                  user.cookie = StringUtils.getSHA1(user.username + user.password);
               }
@@ -1070,7 +1072,7 @@
               team.canAdmin = roles.contains(Constants.ADMIN_ROLE);
               team.canFork = roles.contains(Constants.FORK_ROLE);
               team.canCreate = roles.contains(Constants.CREATE_ROLE);
               if (!team.canAdmin) {
                  // non-admin team, read permissions
                  team.addRepositoryPermissions(Arrays.asList(config.getStringList(TEAM, teamname,