in core/provisioning-java/src/main/java/org/apache/syncope/core/provisioning/java/data/PolicyDataBinderImpl.java [85:233]
protected <T extends Policy> T getPolicy(final T policy, final PolicyTO policyTO) {
T result = policy;
if (policyTO instanceof PasswordPolicyTO passwordPolicyTO) {
if (result == null) {
result = (T) entityFactory.newEntity(PasswordPolicy.class);
}
PasswordPolicy passwordPolicy = PasswordPolicy.class.cast(result);
passwordPolicy.setAllowNullPassword(passwordPolicyTO.isAllowNullPassword());
passwordPolicy.setHistoryLength(passwordPolicyTO.getHistoryLength());
passwordPolicyTO.getRules().forEach(ruleKey -> implementationDAO.findById(ruleKey).ifPresentOrElse(
passwordPolicy::add,
() -> LOG.debug("Invalid {} {}, ignoring...", Implementation.class.getSimpleName(), ruleKey)));
// remove all implementations not contained in the TO
passwordPolicy.getRules().
removeIf(implementation -> !passwordPolicyTO.getRules().contains(implementation.getKey()));
} else if (policyTO instanceof AccountPolicyTO accountPolicyTO) {
if (result == null) {
result = (T) entityFactory.newEntity(AccountPolicy.class);
}
AccountPolicy accountPolicy = AccountPolicy.class.cast(result);
accountPolicy.setMaxAuthenticationAttempts(accountPolicyTO.getMaxAuthenticationAttempts());
accountPolicy.setPropagateSuspension(accountPolicyTO.isPropagateSuspension());
accountPolicyTO.getRules().forEach(ruleKey -> implementationDAO.findById(ruleKey).ifPresentOrElse(
accountPolicy::add,
() -> LOG.debug("Invalid {} {}, ignoring...", Implementation.class.getSimpleName(), ruleKey)));
// remove all implementations not contained in the TO
accountPolicy.getRules().
removeIf(implementation -> !accountPolicyTO.getRules().contains(implementation.getKey()));
} else if (policyTO instanceof PropagationPolicyTO propagationPolicyTO) {
if (result == null) {
result = (T) entityFactory.newEntity(PropagationPolicy.class);
}
PropagationPolicy propagationPolicy = PropagationPolicy.class.cast(result);
propagationPolicy.setFetchAroundProvisioning(propagationPolicyTO.isFetchAroundProvisioning());
propagationPolicy.setUpdateDelta(propagationPolicyTO.isUpdateDelta());
propagationPolicy.setBackOffStrategy(propagationPolicyTO.getBackOffStrategy());
propagationPolicy.setBackOffParams(propagationPolicyTO.getBackOffParams());
propagationPolicy.setMaxAttempts(propagationPolicyTO.getMaxAttempts());
} else if (policyTO instanceof InboundPolicyTO inboundPolicyTO) {
if (result == null) {
result = (T) entityFactory.newEntity(InboundPolicy.class);
}
InboundPolicy inboundPolicy = InboundPolicy.class.cast(result);
inboundPolicy.setConflictResolutionAction(inboundPolicyTO.getConflictResolutionAction());
inboundPolicyTO.getCorrelationRules().forEach((type, impl) -> anyTypeDAO.findById(type).ifPresentOrElse(
anyType -> {
InboundCorrelationRuleEntity correlationRule = inboundPolicy.
getCorrelationRule(anyType.getKey()).orElse(null);
if (correlationRule == null) {
correlationRule = entityFactory.newEntity(InboundCorrelationRuleEntity.class);
correlationRule.setAnyType(anyType);
correlationRule.setInboundPolicy(inboundPolicy);
inboundPolicy.add(correlationRule);
}
Implementation rule = implementationDAO.findById(impl).
orElseThrow(() -> new NotFoundException("Implementation " + type + ' ' + impl));
correlationRule.setImplementation(rule);
},
() -> LOG.debug("Invalid AnyType {} specified, ignoring...", type)));
// remove all rules not contained in the TO
inboundPolicy.getCorrelationRules().removeIf(anyFilter -> !inboundPolicyTO.getCorrelationRules().
containsKey(anyFilter.getAnyType().getKey()));
} else if (policyTO instanceof PushPolicyTO pushPolicyTO) {
if (result == null) {
result = (T) entityFactory.newEntity(PushPolicy.class);
}
PushPolicy pushPolicy = PushPolicy.class.cast(result);
pushPolicy.setConflictResolutionAction(pushPolicyTO.getConflictResolutionAction());
pushPolicyTO.getCorrelationRules().forEach((type, impl) -> anyTypeDAO.findById(type).ifPresentOrElse(
anyType -> {
PushCorrelationRuleEntity correlationRule = pushPolicy.
getCorrelationRule(anyType.getKey()).orElse(null);
if (correlationRule == null) {
correlationRule = entityFactory.newEntity(PushCorrelationRuleEntity.class);
correlationRule.setAnyType(anyType);
correlationRule.setPushPolicy(pushPolicy);
pushPolicy.add(correlationRule);
}
Implementation rule = implementationDAO.findById(impl).
orElseThrow(() -> new NotFoundException("Implementation " + type + ' ' + impl));
correlationRule.setImplementation(rule);
},
() -> LOG.debug("Invalid AnyType {} specified, ignoring...", type)));
// remove all rules not contained in the TO
pushPolicy.getCorrelationRules().
removeIf(anyFilter -> !pushPolicyTO.getCorrelationRules().
containsKey(anyFilter.getAnyType().getKey()));
} else if (policyTO instanceof AuthPolicyTO authPolicyTO) {
if (result == null) {
result = (T) entityFactory.newEntity(AuthPolicy.class);
}
AuthPolicy authPolicy = AuthPolicy.class.cast(result);
authPolicy.setName(authPolicyTO.getKey());
authPolicy.setConf(authPolicyTO.getConf());
} else if (policyTO instanceof AccessPolicyTO accessPolicyTO) {
if (result == null) {
result = (T) entityFactory.newEntity(AccessPolicy.class);
}
AccessPolicy accessPolicy = AccessPolicy.class.cast(result);
accessPolicy.setName(accessPolicyTO.getKey());
accessPolicy.setConf(accessPolicyTO.getConf());
} else if (policyTO instanceof AttrReleasePolicyTO attrReleasePolicyTO) {
if (result == null) {
result = (T) entityFactory.newEntity(AttrReleasePolicy.class);
}
AttrReleasePolicy attrReleasePolicy = AttrReleasePolicy.class.cast(result);
attrReleasePolicy.setName(attrReleasePolicyTO.getKey());
attrReleasePolicy.setOrder(attrReleasePolicyTO.getOrder());
attrReleasePolicy.setStatus(attrReleasePolicyTO.getStatus());
attrReleasePolicy.setConf(attrReleasePolicyTO.getConf());
} else if (policyTO instanceof TicketExpirationPolicyTO ticketExpirationPolicyTO) {
if (result == null) {
result = (T) entityFactory.newEntity(TicketExpirationPolicy.class);
}
TicketExpirationPolicy ticketExpirationPolicy = TicketExpirationPolicy.class.cast(result);
ticketExpirationPolicy.setConf(ticketExpirationPolicyTO.getConf());
}
if (result != null) {
result.setName(policyTO.getName());
}
return result;
}