Package org.apache.syncope.core.logic

Class ReconciliationLogic

java.lang.Object

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

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 AnySearchDAO	anySearchDAO
protected AnyTypeDAO	anyTypeDAO
protected AnyUtilsFactory	anyUtilsFactory
protected ConnectorManager	connectorManager
protected DerSchemaDAO	derSchemaDAO
protected InboundMatcher	inboundMatcher
protected MappingManager	mappingManager
protected OutboundMatcher	outboundMatcher
protected PlainSchemaDAO	plainSchemaDAO
protected RealmDAO	realmDAO
protected ExternalResourceDAO	resourceDAO
protected VirAttrHandler	virAttrHandler
protected VirSchemaDAO	virSchemaDAO

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

LOG

Constructor Summary

Constructors

Constructor

Description

ReconciliationLogic(AnyUtilsFactory anyUtilsFactory, AnyTypeDAO anyTypeDAO, ExternalResourceDAO resourceDAO, RealmDAO realmDAO, PlainSchemaDAO plainSchemaDAO, DerSchemaDAO derSchemaDAO, VirSchemaDAO virSchemaDAO, AnySearchDAO anySearchDAO, VirAttrHandler virAttrHandler, MappingManager mappingManager, InboundMatcher inboundMatcher, OutboundMatcher outboundMatcher, ConnectorManager connectorManager)

Method Summary

Modifier and Type	Method	Description
protected 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, int page, int size, List<OrderByClause> orderBy, 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(AnyType anyType, 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 Detail

anyUtilsFactory

protected final AnyUtilsFactory anyUtilsFactory

anyTypeDAO

protected final AnyTypeDAO anyTypeDAO

resourceDAO

protected final ExternalResourceDAO resourceDAO

realmDAO

protected final RealmDAO realmDAO

plainSchemaDAO

protected final PlainSchemaDAO plainSchemaDAO

derSchemaDAO

protected final DerSchemaDAO derSchemaDAO

virSchemaDAO

protected final VirSchemaDAO virSchemaDAO

anySearchDAO

protected final AnySearchDAO anySearchDAO

virAttrHandler

protected final VirAttrHandler virAttrHandler

mappingManager

protected final MappingManager mappingManager

inboundMatcher

protected final InboundMatcher inboundMatcher

outboundMatcher

protected final OutboundMatcher outboundMatcher

connectorManager

protected final ConnectorManager connectorManager

Constructor Detail

ReconciliationLogic

public ReconciliationLogic(AnyUtilsFactory anyUtilsFactory,
                           AnyTypeDAO anyTypeDAO,
                           ExternalResourceDAO resourceDAO,
                           RealmDAO realmDAO,
                           PlainSchemaDAO plainSchemaDAO,
                           DerSchemaDAO derSchemaDAO,
                           VirSchemaDAO virSchemaDAO,
                           AnySearchDAO anySearchDAO,
                           VirAttrHandler virAttrHandler,
                           MappingManager mappingManager,
                           InboundMatcher inboundMatcher,
                           OutboundMatcher outboundMatcher,
                           ConnectorManager connectorManager)

Method Detail

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(AnyType anyType,
                                            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 CsvSchema.Builder csvSchema(AbstractCSVSpec spec)

push

@PreAuthorize("hasRole(\'TASK_EXECUTE\')")
public List<ProvisioningReport> push(SearchCond searchCond,
                                     int page,
                                     int size,
                                     List<OrderByClause> orderBy,
                                     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