Package org.apache.syncope.core.logic

Class ReconciliationLogic

java.lang.Object

org.apache.syncope.core.logic.AbstractLogic<EntityTO>

org.apache.syncope.core.logic.AbstractTransactionalLogic<EntityTO>

org.apache.syncope.core.logic.ReconciliationLogic

public class ReconciliationLogic
extends AbstractTransactionalLogic<EntityTO>

Field Summary

Fields

Modifier and Type	Field	Description
protected final AnySearchDAO	anySearchDAO
protected final AnyTypeDAO	anyTypeDAO
protected final AnyUtilsFactory	anyUtilsFactory
protected final ConnectorManager	connectorManager
protected final DerSchemaDAO	derSchemaDAO
protected final InboundMatcher	inboundMatcher
protected final MappingManager	mappingManager
protected final OutboundMatcher	outboundMatcher
protected final PlainSchemaDAO	plainSchemaDAO
protected final RealmSearchDAO	realmSearchDAO
protected final ExternalResourceDAO	resourceDAO

Fields inherited from class org.apache.syncope.core.logic.AbstractLogic

LOG

Constructor Summary

Constructors

Constructor	Description
ReconciliationLogic(AnyUtilsFactory anyUtilsFactory, AnyTypeDAO anyTypeDAO, ExternalResourceDAO resourceDAO, RealmSearchDAO realmSearchDAO, PlainSchemaDAO plainSchemaDAO, DerSchemaDAO derSchemaDAO, AnySearchDAO anySearchDAO, MappingManager mappingManager, InboundMatcher inboundMatcher, OutboundMatcher outboundMatcher, ConnectorManager connectorManager)

Method Summary

Modifier and Type	Method	Description
protected com.fasterxml.jackson.dataformat.csv.CsvSchema.Builder	csvSchema(AbstractCSVSpec spec)
protected Any	getAny(Provision provision, AnyTypeKind anyTypeKind, String anyKey)
protected ConnObject	getOnSyncope(Item connObjectKeyItem, String connObjectKeyValue, Boolean suspended, Set<Attribute> attrs)
protected ConnObject	getOnSyncope(Any any, Item connObjectKeyItem, ExternalResource resource, Provision provision)
protected ConnObject	getOnSyncope(LinkedAccount account, Item connObjectKeyItem, Provision provision)
protected Triple<AnyType,ExternalResource,Provision>	getProvision(String anyTypeKey, String resourceKey)
List<ProvisioningReport>	pull(String anyTypeKey, String resourceKey, String anyKey, Set<String> moreAttrsToGet, PullTaskTO pullTask)
List<ProvisioningReport>	pull(String anyTypeKey, String resourceKey, Filter filter, Set<String> moreAttrsToGet, PullTaskTO pullTask)
List<ProvisioningReport>	pull(CSVPullSpec spec, InputStream csv)
protected List<ProvisioningReport>	pull(ExternalResource resource, Provision provision, ReconFilterBuilder reconFilterBuilder, Set<String> moreAttrsToGet, PullTaskTO pullTask)
List<ProvisioningReport>	push(String anyTypeKey, String resourceKey, String anyKey, PushTaskTO pushTask)
List<ProvisioningReport>	push(String anyTypeKey, String resourceKey, Filter filter, Set<String> moreAttrsToGet, PushTaskTO pushTask)
List<ProvisioningReport>	push(SearchCond searchCond, org.springframework.data.domain.Pageable pageable, String realm, CSVPushSpec spec, OutputStream os)
protected EntityTO	resolveReference(Method method, Object... os)
protected SyncopeSinglePushExecutor	singlePushExecutor()
ReconStatus	status(String anyTypeKey, String resourceKey, String anyKey, Set<String> moreAttrsToGet)
ReconStatus	status(String anyTypeKey, String resourceKey, Filter filter, Set<String> moreAttrsToGet)
protected SyncDeltaBuilder	syncDeltaBuilder(ExternalResource resource, Provision provision, Filter filter, Set<String> moreAttrsToGet)

Methods inherited from class org.apache.syncope.core.logic.AbstractLogic

resolveBeanReference

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

anyUtilsFactory

protected final AnyUtilsFactory anyUtilsFactory

anyTypeDAO

protected final AnyTypeDAO anyTypeDAO

resourceDAO

protected final ExternalResourceDAO resourceDAO

realmSearchDAO

protected final RealmSearchDAO realmSearchDAO

plainSchemaDAO

protected final PlainSchemaDAO plainSchemaDAO

derSchemaDAO

protected final DerSchemaDAO derSchemaDAO

anySearchDAO

protected final AnySearchDAO anySearchDAO

mappingManager

protected final MappingManager mappingManager

inboundMatcher

protected final InboundMatcher inboundMatcher

outboundMatcher

protected final OutboundMatcher outboundMatcher

connectorManager

protected final ConnectorManager connectorManager

Constructor Details

ReconciliationLogic

public ReconciliationLogic(AnyUtilsFactory anyUtilsFactory,
 AnyTypeDAO anyTypeDAO,
 ExternalResourceDAO resourceDAO,
 RealmSearchDAO realmSearchDAO,
 PlainSchemaDAO plainSchemaDAO,
 DerSchemaDAO derSchemaDAO,
 AnySearchDAO anySearchDAO,
 MappingManager mappingManager,
 InboundMatcher inboundMatcher,
 OutboundMatcher outboundMatcher,
 ConnectorManager connectorManager)

Method Details

getProvision

protected Triple<AnyType,ExternalResource,Provision> getProvision(String anyTypeKey,
 String resourceKey)

getOnSyncope

protected ConnObject getOnSyncope(Item connObjectKeyItem,
 String connObjectKeyValue,
 Boolean suspended,
 Set<Attribute> attrs)

getOnSyncope

protected ConnObject getOnSyncope(Any any,
 Item connObjectKeyItem,
 ExternalResource resource,
 Provision provision)

getOnSyncope

protected ConnObject getOnSyncope(LinkedAccount account,
 Item connObjectKeyItem,
 Provision provision)

getAny

protected Any getAny(Provision provision,
 AnyTypeKind anyTypeKind,
 String anyKey)

status

@PreAuthorize("hasRole(\'RESOURCE_GET_CONNOBJECT\')")
public ReconStatus status(String anyTypeKey,
 String resourceKey,
 String anyKey,
 Set<String> moreAttrsToGet)

syncDeltaBuilder

protected SyncDeltaBuilder syncDeltaBuilder(ExternalResource resource,
 Provision provision,
 Filter filter,
 Set<String> moreAttrsToGet)

status

@PreAuthorize("hasRole(\'RESOURCE_GET_CONNOBJECT\')")
public ReconStatus status(String anyTypeKey,
 String resourceKey,
 Filter filter,
 Set<String> moreAttrsToGet)

singlePushExecutor

protected SyncopeSinglePushExecutor singlePushExecutor()

push

@PreAuthorize("hasRole(\'TASK_EXECUTE\')")
public List<ProvisioningReport> push(String anyTypeKey,
 String resourceKey,
 String anyKey,
 PushTaskTO pushTask)

push

@PreAuthorize("hasRole(\'TASK_EXECUTE\')")
public List<ProvisioningReport> push(String anyTypeKey,
 String resourceKey,
 Filter filter,
 Set<String> moreAttrsToGet,
 PushTaskTO pushTask)

pull

protected List<ProvisioningReport> pull(ExternalResource resource,
 Provision provision,
 ReconFilterBuilder reconFilterBuilder,
 Set<String> moreAttrsToGet,
 PullTaskTO pullTask)

pull

@PreAuthorize("hasRole(\'TASK_EXECUTE\')")
@Transactional(noRollbackFor=SyncopeClientException.class)
public List<ProvisioningReport> pull(String anyTypeKey,
 String resourceKey,
 String anyKey,
 Set<String> moreAttrsToGet,
 PullTaskTO pullTask)

pull

@PreAuthorize("hasRole(\'TASK_EXECUTE\')")
@Transactional(noRollbackFor=SyncopeClientException.class)
public List<ProvisioningReport> pull(String anyTypeKey,
 String resourceKey,
 Filter filter,
 Set<String> moreAttrsToGet,
 PullTaskTO pullTask)

csvSchema

protected com.fasterxml.jackson.dataformat.csv.CsvSchema.Builder csvSchema(AbstractCSVSpec spec)

push

@PreAuthorize("hasRole(\'TASK_EXECUTE\')")
public List<ProvisioningReport> push(SearchCond searchCond,
 org.springframework.data.domain.Pageable pageable,
 String realm,
 CSVPushSpec spec,
 OutputStream os)

pull

@PreAuthorize("hasRole(\'TASK_EXECUTE\')")
@Transactional(noRollbackFor=SyncopeClientException.class)
public List<ProvisioningReport> pull(CSVPullSpec spec,
 InputStream csv)

resolveReference

protected EntityTO resolveReference(Method method,
 Object... os)
                             throws UnresolvedReferenceException

Specified by:

resolveReference in class AbstractLogic<EntityTO>

Throws:

UnresolvedReferenceException