import org.osiam.resources.scim.Email; //导入依赖的package包/类
/**
 * updates (adds new, delete, updates) the {@link EmailEntity}'s of the given {@link UserEntity} based on the given
 * List of Email's
 *
 * @param emails     list of Email's to be deleted, updated or added
 * @param userEntity user who needs to be updated
 * @param attributes all {@link EmailEntity}'s will be deleted if this Set contains 'emails'
 */
void update(List<Email> emails, UserEntity userEntity, Set<String> attributes) {

    if (attributes.contains("emails")) {
        userEntity.removeAllEmails();
    }

    if (emails != null) {
        for (Email scimEmail : emails) {
            EmailEntity emailEntity = emailConverter.fromScim(scimEmail);
            userEntity.removeEmail(emailEntity); // we always have to remove the email in case
            // the primary attribute has changed
            if (Strings.isNullOrEmpty(scimEmail.getOperation())
                    || !scimEmail.getOperation().equalsIgnoreCase("delete")) {

                ensureOnlyOnePrimaryEmailExists(emailEntity, userEntity.getEmails());
                userEntity.addEmail(emailEntity);
            }
        }
    }
}
 

import org.osiam.resources.scim.Email; //导入依赖的package包/类
@Command(description = "Update an email from the user.", startsSubshell = true)
public void updateEmail(
		@Param(value = "searchKey", description = "Which key should be used to identify the email.")
		String key,
		@Param(value = "expr", description = "If the value matches this regular expression, the email will updated.")
		String valueExp) throws IOException{

	Set<Email> emails = builderCommand.showAllEmails();
	for(Email current : emails){
		if(match(current, key, valueExp)){
			final Email email = builderCommand.builderShellFactory.enterEmailShell(current);
			if(email != null){
				builderCommand.builder.updateEmail(current, email);
			}
		}
	}
}
 

import org.osiam.resources.scim.Email; //导入依赖的package包/类
/**
 * Enter a new subshell for creating an {@link Email}.
 *
 * @param current The current persisted {@link Email}.
 * @return The {@link Email}. Or null if the user interrupt the process.
 * @throws IOException
 */
public Email enterEmailShell(Email current) throws IOException {
	final EmailBuilder emailBuilder = new EmailBuilder(current);

	final Shell subShell = ShellBuilder.subshell((current == null ? "create" : "replace") + "-email", shell)
		.behavior()
			.disableExitCommand()
			.addHandler(emailBuilder)
		.build();

	output.out()
		.normal("In this subshell you can create an email. Leave this sub shell via \"commit\" to persist the changes.")
	.println();

	subShell.commandLoop();

	return emailBuilder.build();
}
 

import org.osiam.resources.scim.Email; //导入依赖的package包/类
@Test
public void can_replace_own_user() {
    AccessToken accessToken = OSIAM_CONNECTOR.retrieveAccessToken("marissa", "koala", Scope.ME);
    User originalUser = OSIAM_CONNECTOR.getUser(OWN_USER_ID, accessToken);
    Email email = new Email.Builder()
            .setValue("[email protected]")
            .setType(Email.Type.HOME)
            .build();
    User replaceUser = new User.Builder(originalUser)
            .setDisplayName("Marissa")
            .setActive(false)
            .addEmail(email)
            .build();

    User user = OSIAM_CONNECTOR.replaceUser(OWN_USER_ID, replaceUser, accessToken);

    assertThat(user.getDisplayName(), is(equalTo("Marissa")));
    assertThat(user.getEmails().get(0).getValue(), is(equalTo("[email protected]")));
    assertThat(user.getEmails().get(0).getType(), is(equalTo(Email.Type.HOME)));
}
 

import org.osiam.resources.scim.Email; //导入依赖的package包/类
@Test
public void can_replace_own_user() {
    AccessToken accessToken = OSIAM_CONNECTOR.retrieveAccessToken("marissa", "koala", Scope.ADMIN);
    User originalUser = OSIAM_CONNECTOR.getUser(OWN_USER_ID, accessToken);
    Email email = new Email.Builder()
            .setValue("[email protected]")
            .setType(Email.Type.HOME)
            .build();
    User replaceUser = new User.Builder(originalUser)
            .setDisplayName("Marissa")
            .setActive(false)
            .addEmail(email)
            .build();

    User user = OSIAM_CONNECTOR.replaceUser(OWN_USER_ID, replaceUser, accessToken);

    assertThat(user.getDisplayName(), is(equalTo("Marissa")));
    assertThat(user.isActive(), is(equalTo(false)));
    assertThat(user.getEmails().get(0).getValue(), is(equalTo("[email protected]")));
    assertThat(user.getEmails().get(0).getType(), is(equalTo(Email.Type.HOME)));
}
 

import org.osiam.resources.scim.Email; //导入依赖的package包/类
@Test
public void can_replace_other_user() {
    AccessToken accessToken = OSIAM_CONNECTOR.retrieveAccessToken("marissa", "koala", Scope.ADMIN);
    User originalUser = OSIAM_CONNECTOR.getUser(OTHER_USER_ID, accessToken);
    Email email = new Email.Builder()
            .setValue("[email protected]")
            .setType(Email.Type.HOME)
            .build();
    User replaceUser = new User.Builder(originalUser)
            .setDisplayName("Barbara")
            .setActive(false)
            .addEmail(email)
            .build();

    User user = OSIAM_CONNECTOR.replaceUser(OTHER_USER_ID, replaceUser, accessToken);

    assertThat(user.getDisplayName(), is(equalTo("Barbara")));
    assertThat(user.isActive(), is(equalTo(false)));
    assertThat(user.getEmails().get(0).getValue(), is(equalTo("[email protected]")));
    assertThat(user.getEmails().get(0).getType(), is(equalTo(Email.Type.HOME)));
}
 

import org.osiam.resources.scim.Email; //导入依赖的package包/类
private void updateEmail(UpdateUser.Builder updateBuilder, List<Email> emails, String emailValue) {
    Email newEmail = new Email.Builder().setValue(emailValue)
            .setType(new Email.Type(LdapAuthentication.LDAP_PROVIDER)).build();
    for (Email email : emails) {
        if (email.getType() != null && email.getType().toString().equals(LdapAuthentication.LDAP_PROVIDER)) {
            updateBuilder.deleteEmail(email);
        }
    }
    updateBuilder.addEmail(newEmail);
}
 

import org.osiam.resources.scim.Email; //导入依赖的package包/类
@Override
public EmailEntity fromScim(Email scim) {
    EmailEntity emailEntity = new EmailEntity();
    emailEntity.setValue(scim.getValue());
    emailEntity.setPrimary(scim.isPrimary());
    emailEntity.setType(scim.getType());
    emailEntity.setDisplay(scim.getDisplay());
    return emailEntity;
}
 

import org.osiam.resources.scim.Email; //导入依赖的package包/类
@Override
public Email toScim(EmailEntity entity) {
    return new Email.Builder()
            .setPrimary(entity.isPrimary())
            .setType(entity.getType())
            .setValue(entity.getValue())
            .setDisplay(entity.getDisplay())
            .build();
}
 

import org.osiam.resources.scim.Email; //导入依赖的package包/类
@Override
public String convertToDatabaseColumn(Email.Type attribute) {
    if (attribute == null || Strings.isNullOrEmpty(attribute.getValue())) {
        return null;
    }

    return attribute.getValue();
}
 

import org.osiam.resources.scim.Email; //导入依赖的package包/类
@Override
public Email.Type convertToEntityAttribute(String dbData) {
    if (Strings.isNullOrEmpty(dbData)) {
        return null;
    }

    return new Email.Type(dbData);
}
 

import org.osiam.resources.scim.Email; //导入依赖的package包/类
@Override
public EmailEntity fromScim(Email scim) {
    EmailEntity emailEntity = new EmailEntity();
    emailEntity.setValue(scim.getValue());
    emailEntity.setPrimary(scim.isPrimary());
    emailEntity.setType(scim.getType());

    return emailEntity;
}
 

import org.osiam.resources.scim.Email; //导入依赖的package包/类
@Override
public Email toScim(EmailEntity entity) {
    return new Email.Builder()
            .setPrimary(entity.isPrimary())
            .setType(entity.getType())
            .setValue(entity.getValue())
            .build();
}
 

import org.osiam.resources.scim.Email; //导入依赖的package包/类
public void sendDeactivateMail(User user, Locale locale) {
    Map<String, Object> variables = new HashMap<>();
    variables.put("user", user);

    String mailContent = renderer.renderEmailBody("user/deactivate", locale, variables);
    String mailSubject = renderer.renderEmailSubject("user/deactivate", locale, variables);
    Optional<Email> email = user.getPrimaryOrFirstEmail();
    if (!email.isPresent()) {
        throw new SendEmailException("The user has no email!", "user.no.email");
    }

    sendHTMLMail(fromAddress, email.get().getValue(), mailSubject, mailContent);
}
 

import org.osiam.resources.scim.Email; //导入依赖的package包/类
public void sendActivateMail(User user, Locale locale) {
    Map<String, Object> variables = new HashMap<>();
    variables.put("user", user);

    String mailContent = renderer.renderEmailBody("user/activate", locale, variables);
    String mailSubject = renderer.renderEmailSubject("user/activate", locale, variables);
    Optional<Email> email = user.getPrimaryOrFirstEmail();
    if (!email.isPresent()) {
        throw new SendEmailException("The user has no email!", "user.no.email");
    }

    sendHTMLMail(fromAddress, email.get().getValue(), mailSubject, mailContent);
}
 

import org.osiam.resources.scim.Email; //导入依赖的package包/类
public EmailCommand(Email email) {
    display = email.getDisplay();
    primary = email.isPrimary();
    value = email.getValue();

    if (email.getType() != null) {
        type = email.getType().getValue();
    }
}
 

import org.osiam.resources.scim.Email; //导入依赖的package包/类
public Email getAsEmail() {
    Email.Builder email = new Email.Builder()
            .setDisplay(display)
            .setPrimary(primary)
            .setValue(value);

    if (!Strings.isNullOrEmpty(type)) {
        email.setType(new Email.Type(type));
    }

    return email.build();
}
 

import org.osiam.resources.scim.Email; //导入依赖的package包/类
@Command(description = "Delete an email from the user.")
public void deleteEmail(
		@Param(value = "searchKey", description = "Which key should be used to identify the email.")
		String key,
		@Param(value = "expr", description = "If the value matches this regular expression, the email will deleted.")
		String valueExp){
	
	Set<Email> emails = builderCommand.showAllEmails();
	for(Email current : emails){
		if(match(current, key, valueExp)){
			builderCommand.builder.deleteEmail(current);
		}
	}
}
 

import org.osiam.resources.scim.Email; //导入依赖的package包/类
@Command(description = "Add an email for this user.", startsSubshell = true)
public void addEmail() throws IOException {
	final Email email = builderCommand.builderShellFactory.enterEmailShell();
	if(email != null){
		builderCommand.builder.addEmail(email);
	}
}
 

import org.osiam.resources.scim.Email; //导入依赖的package包/类
@Command(description = "Show all emails (persited and non persisted) for the user.")
public Set<Email> showAllEmails(){
	Set<Email> all = new HashSet<>(user.getEmails());
	all.addAll(_build().getScimConformUpdateUser().getEmails());
	
	return all;
}