import com.atlassian.confluence.user.ConfluenceUser; //导入依赖的package包/类
private String getTemplate(String apiUrl, String callbackUrl, String fileUrl, String key, String fileName, ConfluenceUser user, String errorMessage)
		throws UnsupportedEncodingException
{
	Map<String, Object> contextMap = MacroUtils.defaultVelocityContext();

	contextMap.put("docserviceApiUrl", apiUrl + properties.getProperty("files.docservice.url.api"));
	contextMap.put("callbackUrl", callbackUrl);
	contextMap.put("fileUrl", fileUrl);
	contextMap.put("key", key);
	contextMap.put("fileName", fileName);
	contextMap.put("errorMessage", errorMessage);
	if (user != null)
	{
		contextMap.put("userId", user.getName());
		contextMap.put("userName", user.getFullName());
	}

	return VelocityUtils.getRenderedTemplate("templates/editor.vm", contextMap);
}
 

import com.atlassian.confluence.user.ConfluenceUser; //导入依赖的package包/类
@GET
@Path("/{username}")
@AnonymousAllowed
@Produces({"application/json"})
public Response getProfile(@PathParam("username") String username) {
    final Response response;
    final ConfluenceUser user = _userAccessor.getUserByName(username);
    final ConfluenceUser currentUser = AuthenticatedUserThreadLocal.get();
    final Locale locale = currentUser != null ? _localeManager.getLocale(currentUser) : null;
    if (user == null || !_userHelper.isProfileViewPermitted()) {
        response = getNotFoundResponse();
    } else {
        final UserDto original = _userDtoFactory.getUserDto(user);
        final ExtendedUserDto dto = new ExtendedUserDto(original, createGroupsFor(currentUser, user, locale));
        response = ok(dto).build();
    }
    return response;
}
 

import com.atlassian.confluence.user.ConfluenceUser; //导入依赖的package包/类
@Nonnull
protected List<Profile> searchFor(@Nullable Report report, @Nullable Iterable<Column> columns) {
    final List<Profile> profiles = new ArrayList<>();
    if (report != null && columns != null) {
        final SearchResults results = performSearch(report, makeSearchQuery(columns), makeSearchFilterFor(report));
        final List<Searchable> resultObjects = _searchManager.convertToEntities(results, EntityVersionPolicy.LATEST_VERSION);
        final ManualTotalPaginationSupport<Searchable> paginationSupport = (ManualTotalPaginationSupport<Searchable>) getPaginationSupport();
        paginationSupport.setPageSize(report.getResultsPerPage());
        paginationSupport.setStartIndex(getStartIndex());
        paginationSupport.setTotal(results.getUnfilteredResultsCount());
        paginationSupport.setItems(resultObjects);
        for (final Searchable resultObject : resultObjects) {
            final PersonalInformation personalInformation = (PersonalInformation) resultObject;
            final ConfluenceUser user = personalInformation.getUser();
            final Profile profile = profileProvider().provideFor(user);
            profiles.add(profile);
        }
    }
    if (isShowingAllPeople()) {
        determineBlankExperience();
    }
    return profiles;
}
 

import com.atlassian.confluence.user.ConfluenceUser; //导入依赖的package包/类
@Nonnull
protected String getTemplateNameFor(@Nonnull Map<String, Object> context, @Nullable User user) {
    final ConfluenceUser currentUser = AuthenticatedUserThreadLocal.get();
    final String variant;
    if ((user == null || !user.equals(currentUser)) && !_permissionManager.hasPermission(currentUser, VIEW, TARGET_PEOPLE_DIRECTORY)) {
        variant = ".accessDenied";
    } else {
        final Object username = context.get("username");
        if (username == null || username.toString().isEmpty()) {
            variant = ".missingUsername";
        } else if (context.get("user") == null) {
            variant = ".unknownUser";
        } else {
            variant = "";
        }
    }
    return TEMPLATE_NAME_PREFIX + variant + TEMPLATE_NAME_SUFFIX;
}
 

import com.atlassian.confluence.user.ConfluenceUser; //导入依赖的package包/类
protected void authenticateUserAndLogin(HttpServletRequest request,
		HttpServletResponse response, String username)
		throws Exception {

	Authenticator authenticator = SecurityConfigFactory.getInstance().getAuthenticator();

       if (authenticator instanceof ConfluenceAuthenticator) {
           UserAccessor userAccessor = (UserAccessor) ContainerManager.getComponent("userAccessor");
           ConfluenceUser confluenceUser = userAccessor.getUserByName(username);

           if (confluenceUser == null) {
               confluenceUser = tryCreateOrUpdateUser(username);
           }

           if (confluenceUser != null) {
               Boolean result = authoriseUserAndEstablishSession((DefaultAuthenticator) authenticator, confluenceUser, request, response);

               if (result) {
                   redirectToSuccessfulAuthLandingPage(request, response);
                   return;
               }
           }
       }

       redirectToLoginWithSAMLError(response, null, "user_not_found");
}
 

import com.atlassian.confluence.user.ConfluenceUser; //导入依赖的package包/类
public boolean shouldDisplay(Map<String, Object> context)
{
	Attachment attachment = (Attachment) context.get("attachment");
	if (attachment == null)
	{
		return false;
	}
	if (!isXExtension(attachment.getFileExtension()))
	{
		return false;
	}
	if (attachment.getFileSize() > DocumentManager.GetMaxFileSize())
	{
		return false;
	}

	ConfluenceUser user = AuthenticatedUserThreadLocal.get();
	boolean accessEdit = AttachmentUtil.checkAccess(attachment, user, true);
	boolean accessView = AttachmentUtil.checkAccess(attachment, user, false);
	if (!forEdit && (!accessView || accessEdit))
	{
		return false;
	}
	if (forEdit && !accessEdit)
	{
		return false;
	}

	return true;
}
 

import com.atlassian.confluence.user.ConfluenceUser; //导入依赖的package包/类
public static void saveAttachment(Long attachmentId, InputStream attachmentData, int size, ConfluenceUser user)
		throws IOException, IllegalArgumentException
{
	AttachmentManager attachmentManager = (AttachmentManager) ContainerManager.getComponent("attachmentManager");
	Attachment attachment = attachmentManager.getAttachment(attachmentId);
	
	Attachment oldAttachment = attachment.copy();
	attachment.setFileSize(size);

	AuthenticatedUserThreadLocal.set(user);

	attachmentManager.saveAttachment(attachment, oldAttachment, attachmentData);
}
 

import com.atlassian.confluence.user.ConfluenceUser; //导入依赖的package包/类
private void checkPermissions(Space space, ConfluenceUser user) throws NotPermittedException {
    List<String> permTypes = new ArrayList<>();
    permTypes.add(SpacePermission.VIEWSPACE_PERMISSION);
    if (!ldUtil.getSpacePermissionManager().hasPermissionForSpace(user, permTypes, space)) {
        throw new NotPermittedException();
    }
}
 

import com.atlassian.confluence.user.ConfluenceUser; //导入依赖的package包/类
private ConfluenceUser login(String username, String password) throws EntityException {

        if (StringUtils.isNotEmpty(username) && ldUtil.isCredentialsValid(username, password)) {
            return (ConfluenceUser) ldUtil.getConfluenceUserManager().getUser(username);
        }
        return null;

    }
 

import com.atlassian.confluence.user.ConfluenceUser; //导入依赖的package包/类
private ForumAO createNewForum(Map parameters) {
    ForumAO newForum = ao.create(ForumAO.class, new DBParam("TITLE", "title"));
    newForum.setTitle((String) parameters.get(forumTitel));
    newForum.setDescription((String) parameters.get("forum_description"));
    newForum.save();
    // Initialize permissions if not yet done and add current user as
    // admin
    if (ao.find(PermissionAO.class).length == 0) {
        rightsManagement.initPermissions();
    }
    ConfluenceUser currentUser = AuthenticatedUserThreadLocal.get();
    rightsManagement.initAdmin(currentUser.getKey().getStringValue(), newForum.getID());
    rightsManagement.initDeletedUserRole(newForum.getID());
    return newForum;
}
 

import com.atlassian.confluence.user.ConfluenceUser; //导入依赖的package包/类
@GET
@Path("{forumID}/getProfileInfo/{userKey}")
public Response getUserProfileInfo(@PathParam("userKey") String userKey,
                                   @PathParam("forumID") int forumID) {
    ConfluenceUser user = userAccessor.getExistingUserByKey(new UserKey(userKey));
    String name = user.getFullName();
    String role = rightsManagement.getUser(userKey, forumID).getRole().getName();
    String profilePicture = settingsManager.getGlobalSettings().getBaseUrl() + userAccessor.getUserProfilePicture(user).getDownloadPath();
    return Response.ok(SerializableProfile.build(name, role, profilePicture)).build();
}
 

import com.atlassian.confluence.user.ConfluenceUser; //导入依赖的package包/类
/**
 * Returns all existing ConfluenceUsers
 *
 * @return a Response containing information about all Confluence Users
 */
@GET
@Path("confluenceusers")
public Response confluenceUsers() {
    List<String> confUsernames = userAccessor.getUserNamesWithConfluenceAccess();
    List<ConfluenceUser> users = new ArrayList<ConfluenceUser>();
    for (String username : confUsernames) {
        users.add(userAccessor.getUserByName(username));
    }
    return Response.ok(SerializableConfluenceUser.build(users)).build();
}
 

import com.atlassian.confluence.user.ConfluenceUser; //导入依赖的package包/类
private SerializableUserImplement(String userKey, SerializableRole role) {
    this.userKey = userKey;
    this.role = role;
    UserAccessor userAccessor = (UserAccessor) ContainerManager.getInstance().getContainerContext().getComponent("userAccessor");
    ConfluenceUser user = userAccessor.getExistingUserByKey(new UserKey(userKey));
    this.name = user.getFullName();
}
 

import com.atlassian.confluence.user.ConfluenceUser; //导入依赖的package包/类
public static SerializableConfluenceUser[] build(List<ConfluenceUser> users) {
    List<SerializableConfluenceUser> serializableConfluenceUsers = new ArrayList<SerializableConfluenceUser>();
    for (ConfluenceUser user : users) {
        serializableConfluenceUsers.add(new SerializableConfluenceUser(user.getName(), user.getFullName(), user.getKey().getStringValue()));
    }
    return serializableConfluenceUsers.toArray(new SerializableConfluenceUser[]{});
}
 

import com.atlassian.confluence.user.ConfluenceUser; //导入依赖的package包/类
public static ConfluenceUser mockUser(final String userKey, final String username, final String displayName, final String email) {
    ConfluenceUser user = mock(ConfluenceUser.class);
    when(user.getKey()).thenReturn(new UserKey(userKey));
    when(user.getEmail()).thenReturn(email);
    when(user.getName()).thenReturn(username);
    when(user.getFullName()).thenReturn(displayName);
    return user;
}
 

import com.atlassian.confluence.user.ConfluenceUser; //导入依赖的package包/类
@GET
@Path("confluenceusers")
public Response confluenceUsers() {
    List<String> confUsernames = userAccessor.getUserNamesWithConfluenceAccess();
    List<ConfluenceUser> users = new ArrayList<ConfluenceUser>();
    for (String username : confUsernames) {
        System.out.println(username);
        users.add(userAccessor.getUserByName(username));
        System.out.println(userAccessor.getUserByName(username));
    }
    return Response.ok(SerializableConfluenceUser.build(users)).build();
}
 

import com.atlassian.confluence.user.ConfluenceUser; //导入依赖的package包/类
@Override
public String doEdit() throws Exception {
    final String result = super.doEdit();
    final ConfluenceUser user = getUser();
    final Profile profile = user != null ? profileProvider().provideFor(user) : null;
    if (profile != null && "success".equals(result)) {
        updateFields(profile);
        profile.reIndex();
    }
    return result;
}
 

import com.atlassian.confluence.user.ConfluenceUser; //导入依赖的package包/类
@GET
@Path("/")
@AnonymousAllowed
@Produces({"application/json"})
public Response getViews() {
    final ConfluenceUser currentUser = AuthenticatedUserThreadLocal.get();
    final Locale locale = currentUser != null ? _localeManager.getLocale(currentUser) : null;
    final List<View> views = new ArrayList<>();
    for (final org.echocat.adam.view.View view : _viewProvider) {
        views.add(new View(_localizationHelper, view, locale, currentUser));
    }
    return ok(views).build();
}
 

import com.atlassian.confluence.user.ConfluenceUser; //导入依赖的package包/类
@GET
@Path("/profile")
@AnonymousAllowed
@Produces({"application/json"})
public Response getProfile() {
    final ConfluenceUser currentUser = AuthenticatedUserThreadLocal.get();
    final Locale locale = currentUser != null ? _localeManager.getLocale(currentUser) : null;
    return ok(new ProfileModel(_localizationHelper, _groupProvider, locale, currentUser)).build();
}
 

import com.atlassian.confluence.user.ConfluenceUser; //导入依赖的package包/类
protected ConfluenceUser tryCreateOrUpdateUser(String username) {
    if (saml2Config.getAutoCreateUserFlag()){
        UserAccessor userAccessor = (UserAccessor) ContainerManager.getComponent("userAccessor");

        String fullName = credential.getAttributeAsString("cn");
        String email = credential.getAttributeAsString("mail");

        log.warn("Creating user account for " + username );
        ConfluenceUser createdUser = userAccessor.createUser(new DefaultUser(username, fullName, email), Credential.NONE);

        // Find the first administrator user and use it to add the user to the confluence-users group if it exists
        ConfluenceUser administratorUser = getAdministratorUser();

        String defaultGroup = saml2Config.getAutoCreateUserDefaultGroup();
        if (defaultGroup.isEmpty()) {
            defaultGroup = SAMLConfluenceConfig.DEFAULT_AUTOCREATE_USER_GROUP;
        }

        Group confluenceUsersGroup = userAccessor.getGroup(defaultGroup);
        if (administratorUser != null && confluenceUsersGroup != null) {
            AuthenticatedUserThreadLocal.set(administratorUser);
            userAccessor.addMembership(confluenceUsersGroup, createdUser);
        }
        return createdUser;
    } else {
        // not allowed to auto-create user
        log.error("User not found and auto-create disabled: " + username);
    }
    return null;
}