in core/provisioning-java/src/main/java/org/apache/syncope/core/provisioning/java/pushpull/PullJobDelegate.java [90:286]
protected String doExecute(final JobExecutionContext context) throws JobExecutionException {
LOG.debug("Executing pull on {}", task.getResource());
if (!profile.isDryRun()) {
for (InboundActions action : profile.getActions()) {
action.beforeAll(profile);
}
}
// First realms...
if (task.getResource().getOrgUnit() != null) {
setStatus("Pulling " + task.getResource().getOrgUnit().getObjectClass());
OrgUnit orgUnit = task.getResource().getOrgUnit();
Set<String> moreAttrsToGet = new HashSet<>();
profile.getActions().forEach(a -> moreAttrsToGet.addAll(a.moreAttrsToGet(profile, orgUnit)));
OperationOptions options = MappingUtils.buildOperationOptions(
MappingUtils.getInboundItems(orgUnit.getItems().stream()), moreAttrsToGet.toArray(String[]::new));
dispatcher.addHandlerSupplier(orgUnit.getObjectClass(), () -> {
RealmPullResultHandler handler = buildRealmHandler();
handler.setProfile(profile);
return handler;
});
try {
switch (task.getPullMode()) {
case INCREMENTAL:
if (!context.isDryRun()) {
setLatestSyncToken(
orgUnit.getObjectClass(),
ConnObjectUtils.toSyncToken(orgUnit.getSyncToken()));
}
connector.sync(new ObjectClass(orgUnit.getObjectClass()),
ConnObjectUtils.toSyncToken(orgUnit.getSyncToken()),
dispatcher,
options);
if (!context.isDryRun()) {
orgUnit.setSyncToken(
ConnObjectUtils.toString(latestSyncTokens.get(orgUnit.getObjectClass())));
resourceDAO.save(task.getResource());
}
break;
case FILTERED_RECONCILIATION:
connector.filteredReconciliation(new ObjectClass(orgUnit.getObjectClass()),
getReconFilterBuilder(task),
dispatcher,
options);
break;
case FULL_RECONCILIATION:
default:
connector.fullReconciliation(
new ObjectClass(orgUnit.getObjectClass()),
dispatcher,
options);
break;
}
} catch (Throwable t) {
throw new JobExecutionException("While pulling from connector", t);
}
}
// ...then provisions for any types
ghandler = buildGroupHandler();
for (Provision provision : task.getResource().getProvisions().stream().
filter(provision -> provision.getMapping() != null).sorted(provisionSorter).
toList()) {
setStatus("Pulling " + provision.getObjectClass());
AnyType anyType = anyTypeDAO.findById(provision.getAnyType()).
orElseThrow(() -> new NotFoundException("AnyType" + provision.getAnyType()));
dispatcher.addHandlerSupplier(provision.getObjectClass(), () -> {
SyncopePullResultHandler handler;
switch (anyType.getKind()) {
case USER:
handler = buildUserHandler();
break;
case GROUP:
handler = ghandler;
break;
case ANY_OBJECT:
default:
handler = buildAnyObjectHandler();
}
handler.setProfile(profile);
return handler;
});
boolean setSyncTokens = false;
try {
Set<String> moreAttrsToGet = new HashSet<>();
profile.getActions().forEach(a -> moreAttrsToGet.addAll(a.moreAttrsToGet(profile, provision)));
OperationOptions options = MappingUtils.buildOperationOptions(
MappingUtils.getInboundItems(provision.getMapping().getItems().stream()),
moreAttrsToGet.toArray(String[]::new));
switch (task.getPullMode()) {
case INCREMENTAL:
if (!context.isDryRun()) {
setLatestSyncToken(
provision.getObjectClass(),
ConnObjectUtils.toSyncToken(provision.getSyncToken()));
}
connector.sync(
new ObjectClass(provision.getObjectClass()),
ConnObjectUtils.toSyncToken(provision.getSyncToken()),
dispatcher,
options);
if (!context.isDryRun()) {
setSyncTokens = true;
}
break;
case FILTERED_RECONCILIATION:
connector.filteredReconciliation(new ObjectClass(provision.getObjectClass()),
getReconFilterBuilder(task),
dispatcher,
options);
break;
case FULL_RECONCILIATION:
default:
connector.fullReconciliation(
new ObjectClass(provision.getObjectClass()),
dispatcher,
options);
}
} catch (Throwable t) {
throw new JobExecutionException("While pulling from connector", t);
} finally {
if (setSyncTokens) {
latestSyncTokens.forEach((objectClass, syncToken) -> {
task.getResource().getProvisionByObjectClass(objectClass).
ifPresent(p -> p.setSyncToken(ConnObjectUtils.toString(syncToken)));
Optional.ofNullable(task.getResource().getOrgUnit()).
filter(ou -> objectClass.equals(ou.getObjectClass())).
ifPresent(ou -> ou.setSyncToken(ConnObjectUtils.toString(syncToken)));
});
resourceDAO.save(task.getResource());
}
}
}
dispatcher.shutdown();
for (Provision provision : task.getResource().getProvisions().stream().
filter(provision -> provision.getMapping() != null && provision.getUidOnCreate() != null).
sorted(provisionSorter).toList()) {
try {
AnyType anyType = anyTypeDAO.findById(provision.getAnyType()).
orElseThrow(() -> new NotFoundException("AnyType" + provision.getAnyType()));
AnyUtils anyUtils = anyUtilsFactory.getInstance(anyType.getKind());
profile.getResults().stream().
filter(result -> result.getUidValue() != null && result.getKey() != null
&& result.getOperation() == ResourceOperation.CREATE
&& result.getAnyType().equals(provision.getAnyType())).
forEach(result -> anyUtils.addAttr(
validator,
result.getKey(),
plainSchemaDAO.findById(provision.getUidOnCreate()).
orElseThrow(() -> new NotFoundException("PlainSchema " + provision.getUidOnCreate())),
result.getUidValue()));
} catch (Throwable t) {
LOG.error("While setting UID on create", t);
}
}
try {
setGroupOwners();
} catch (Exception e) {
LOG.error("While setting group owners", e);
}
if (!profile.isDryRun()) {
for (InboundActions action : profile.getActions()) {
action.afterAll(profile);
}
}
setStatus("Pull done");
String result = createReport(profile.getResults(), task.getResource(), context.isDryRun());
LOG.debug("Pull result: {}", result);
return result;
}