LdapIncrementalPullCorrelationRule

LdapIncrementalPullCorrelationRule.java

import org.apache.commons.lang3.StringUtils;
import org.apache.syncope.core.persistence.api.dao.PullCorrelationRule;
import org.apache.syncope.core.persistence.api.dao.search.AttributeCond;
import org.apache.syncope.core.persistence.api.dao.search.SearchCond;
import org.apache.syncope.core.persistence.api.entity.resource.Provision;
import org.identityconnectors.framework.common.objects.SyncDelta;

public class GFSLdapPullRule implements PullCorrelationRule {

    @Override
    public SearchCond getSearchCond(SyncDelta syncDelta, Provision provision) {
        AttributeCond cond = new AttributeCond();
        cond.setSchema("_schema_in_Syncope_che_mappa_uid");
        cond.setType(AttributeCond.Type.EQ);

        String dn = syncDelta.getObject().getName().getNameValue();
        String uid = StringUtils.substringAfter(StringUtils.substringBefore(dn, ",ou=People"), "uid=");
        cond.setExpression(uid);

        return SearchCond.getLeafCond(cond);
    }
}