AttributesEnrichingPropagationActions

AttributesEnrichingPropagationActions.java

public class AttributesEnrichingPropagationAction implements PropagationActions {

    @Autowired
    private UserDAO userDAO;

    @Transactional(readonly = true)
    @Override
    public void before(final PropagationTask task, final ConnectorObject beforeObj) {
        // do something only if propagating users
        if (AnyTypeKind.USER == task.getAnyTypeKind()) {
          // read the user being propagated
          User user = userDAO.find(task.getEntityKey());
          if (user != null) {
            // get the propagation attributes preparared according to the mapping provided
            Set<Attribute> attributes = new HashSet<>(task.getAttributes());
            
            // add, replace of remove attributes
            Set<String> groups = user.getMemberships().stream().
              map(memb -> memb.getRightEnd().getName()).collect(Collectors.toSet());
            attributes.add(AttributeBuilder.build("new_attribute_name", groups));
            
            // store the updated attributes for actual propagation
            task.setAttributes(attributes);
          }
        }
    }
}