| | |
| | |
|
| | | import com.gitblit.models.TeamModel;
|
| | | import com.gitblit.models.UserModel;
|
| | | import com.gitblit.utils.ArrayUtils;
|
| | | import com.gitblit.utils.DeepCopier;
|
| | | import com.gitblit.utils.StringUtils;
|
| | |
|
| | |
| | | private final Map<String, TeamModel> teams = new ConcurrentHashMap<String, TeamModel>();
|
| | |
|
| | | private volatile long lastModified;
|
| | | |
| | | private volatile boolean forceReload;
|
| | |
|
| | | public ConfigUserService(File realmFile) {
|
| | | this.realmFile = realmFile;
|
| | |
| | | }
|
| | |
|
| | | /**
|
| | | * 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() {
|
| | | read();
|
| | | List<TeamModel> list = new ArrayList<TeamModel>(teams.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.
|
| | | *
|
| | |
| | | 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() {
|
| | | 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
|
| | |
| | | // repository memberships
|
| | | // null check on "final" repositories because JSON-sourced UserModel
|
| | | // can have a null repositories object
|
| | | if (model.repositories != null) {
|
| | | if (!ArrayUtils.isEmpty(model.repositories)) {
|
| | | config.setStringList(USER, model.username, REPOSITORY, new ArrayList<String>(
|
| | | model.repositories));
|
| | | }
|
| | |
| | | for (TeamModel model : teams.values()) {
|
| | | // null check on "final" repositories because JSON-sourced TeamModel
|
| | | // can have a null repositories object
|
| | | if (model.repositories != null) {
|
| | | if (!ArrayUtils.isEmpty(model.repositories)) {
|
| | | config.setStringList(TEAM, model.name, REPOSITORY, new ArrayList<String>(
|
| | | model.repositories));
|
| | | }
|
| | |
|
| | | // null check on "final" users because JSON-sourced TeamModel
|
| | | // can have a null users object
|
| | | if (model.users != null) {
|
| | | if (!ArrayUtils.isEmpty(model.users)) {
|
| | | config.setStringList(TEAM, model.name, USER, new ArrayList<String>(model.users));
|
| | | }
|
| | |
|
| | | // null check on "final" mailing lists because JSON-sourced
|
| | | // TeamModel can have a null users object
|
| | | if (model.mailingLists != null) {
|
| | | if (!ArrayUtils.isEmpty(model.mailingLists)) {
|
| | | config.setStringList(TEAM, model.name, MAILINGLIST, new ArrayList<String>(
|
| | | model.mailingLists));
|
| | | }
|
| | |
|
| | | // null check on "final" preReceiveScripts because JSON-sourced
|
| | | // TeamModel can have a null preReceiveScripts object
|
| | | if (model.preReceiveScripts != null) {
|
| | | if (!ArrayUtils.isEmpty(model.preReceiveScripts)) {
|
| | | config.setStringList(TEAM, model.name, PRERECEIVE, model.preReceiveScripts);
|
| | | }
|
| | |
|
| | | // null check on "final" postReceiveScripts because JSON-sourced
|
| | | // TeamModel can have a null postReceiveScripts object
|
| | | if (model.postReceiveScripts != null) {
|
| | | if (!ArrayUtils.isEmpty(model.postReceiveScripts)) {
|
| | | config.setStringList(TEAM, model.name, POSTRECEIVE, model.postReceiveScripts);
|
| | | }
|
| | | }
|
| | |
|
| | | config.save();
|
| | | // manually set the forceReload flag because not all JVMs support real
|
| | | // millisecond resolution of lastModified. (issue-55)
|
| | | forceReload = true;
|
| | |
|
| | | // If the write is successful, delete the current file and rename
|
| | | // the temporary copy to the original filename.
|
| | |
| | | * Reads the realm file and rebuilds the in-memory lookup tables.
|
| | | */
|
| | | protected synchronized void read() {
|
| | | if (realmFile.exists() && (realmFile.lastModified() > lastModified)) {
|
| | | if (realmFile.exists() && (forceReload || (realmFile.lastModified() != lastModified))) {
|
| | | forceReload = false;
|
| | | lastModified = realmFile.lastModified();
|
| | | users.clear();
|
| | | cookies.clear();
|
| | |
| | | config.load();
|
| | | Set<String> usernames = config.getSubsections(USER);
|
| | | for (String username : usernames) {
|
| | | UserModel user = new UserModel(username);
|
| | | UserModel user = new UserModel(username.toLowerCase());
|
| | | user.password = config.getString(USER, username, PASSWORD);
|
| | |
|
| | | // user roles
|
| | |
| | | }
|
| | |
|
| | | // update cache
|
| | | users.put(username, user);
|
| | | cookies.put(StringUtils.getSHA1(username + user.password), user);
|
| | | users.put(user.username, user);
|
| | | cookies.put(StringUtils.getSHA1(user.username + user.password), user);
|
| | | }
|
| | |
|
| | | // load the teams
|