Package org.apache.syncope.core.logic

Class TaskLogic

java.lang.Object

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

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

org.apache.syncope.core.logic.AbstractExecutableLogic<TaskTO>

org.apache.syncope.core.logic.TaskLogic

public class TaskLogic
extends AbstractExecutableLogic<TaskTO>

Field Summary

Fields

Modifier and Type	Field	Description
protected TaskDataBinder	binder
protected JobManager	jobManager
protected JobStatusDAO	jobStatusDAO
protected NotificationDAO	notificationDAO
protected NotificationJobDelegate	notificationJobDelegate
protected ExternalResourceDAO	resourceDAO
protected SchedulerFactoryBean	scheduler
protected TaskDAO	taskDAO
protected TaskExecDAO	taskExecDAO
protected PropagationTaskExecutor	taskExecutor
protected TaskUtilsFactory	taskUtilsFactory

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

LOG

Constructor Summary

Constructors

Constructor	Description
TaskLogic(JobManager jobManager, SchedulerFactoryBean scheduler, JobStatusDAO jobStatusDAO, TaskDAO taskDAO, TaskExecDAO taskExecDAO, ExternalResourceDAO resourceDAO, NotificationDAO notificationDAO, TaskDataBinder binder, PropagationTaskExecutor taskExecutor, NotificationJobDelegate notificationJobDelegate, TaskUtilsFactory taskUtilsFactory)

Method Summary

Modifier and Type	Method	Description
void	actionJob(String key, JobAction action)
<T extends SchedTaskTO> T	createSchedTask(TaskType type, T taskTO)
<T extends TaskTO> T	delete(TaskType type, String key)
ExecTO	deleteExecution(String execKey)
List<BatchResponseItem>	deleteExecutions(String key, OffsetDateTime before, OffsetDateTime after)
protected void	doActionJob(org.quartz.JobKey jobKey, JobAction action)
protected List<JobTO>	doListJobs(boolean includeCustom)
ExecTO	execute(String key, OffsetDateTime startAt, boolean dryRun)
JobTO	getJob(String key)
protected JobTO	getJobTO(org.quartz.JobKey jobKey, boolean includeCustom)
protected Triple<JobType,String,String>	getReference(org.quartz.JobKey jobKey)
Pair<Integer,List<ExecTO>>	listExecutions(String key, OffsetDateTime before, OffsetDateTime after, int page, int size, List<OrderByClause> orderByClauses)
List<JobTO>	listJobs()
List<ExecTO>	listRecentExecutions(int max)
List<PropagationTaskTO>	purgePropagations(OffsetDateTime since, List<ExecStatus> statuses, List<String> resources)
<T extends TaskTO> T	read(TaskType type, String key, boolean details)
protected TaskTO	resolveReference(Method method, Object... args)
<T extends TaskTO> Pair<Integer,List<T>>	search(TaskType type, String resource, String notification, AnyTypeKind anyTypeKind, String entityKey, int page, int size, List<OrderByClause> orderByClauses, boolean details)
protected void	securityChecks(String entitlement, String realm)
<T extends SchedTaskTO> T	updateSchedTask(TaskType type, SchedTaskTO taskTO)

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

taskDAO

protected final TaskDAO taskDAO

taskExecDAO

protected final TaskExecDAO taskExecDAO

resourceDAO

protected final ExternalResourceDAO resourceDAO

notificationDAO

protected final NotificationDAO notificationDAO

binder

protected final TaskDataBinder binder

taskExecutor

protected final PropagationTaskExecutor taskExecutor

notificationJobDelegate

protected final NotificationJobDelegate notificationJobDelegate

taskUtilsFactory

protected final TaskUtilsFactory taskUtilsFactory

jobManager

protected final JobManager jobManager

scheduler

protected final SchedulerFactoryBean scheduler

jobStatusDAO

protected final JobStatusDAO jobStatusDAO

Constructor Detail

TaskLogic

public TaskLogic(JobManager jobManager,
                 SchedulerFactoryBean scheduler,
                 JobStatusDAO jobStatusDAO,
                 TaskDAO taskDAO,
                 TaskExecDAO taskExecDAO,
                 ExternalResourceDAO resourceDAO,
                 NotificationDAO notificationDAO,
                 TaskDataBinder binder,
                 PropagationTaskExecutor taskExecutor,
                 NotificationJobDelegate notificationJobDelegate,
                 TaskUtilsFactory taskUtilsFactory)

Method Detail

securityChecks

protected void securityChecks(String entitlement,
                              String realm)

createSchedTask

@PreAuthorize("hasRole(\'TASK_CREATE\')")
public <T extends SchedTaskTO> T createSchedTask(TaskType type,
                                                 T taskTO)

updateSchedTask

@PreAuthorize("hasRole(\'TASK_UPDATE\')")
public <T extends SchedTaskTO> T updateSchedTask(TaskType type,
                                                 SchedTaskTO taskTO)

search

@PreAuthorize("hasRole(\'TASK_LIST\')")
@Transactional(readOnly=true)
public <T extends TaskTO> Pair<Integer,List<T>> search(TaskType type,
                                                             String resource,
                                                             String notification,
                                                             AnyTypeKind anyTypeKind,
                                                             String entityKey,
                                                             int page,
                                                             int size,
                                                             List<OrderByClause> orderByClauses,
                                                             boolean details)

read

@PreAuthorize("hasRole(\'TASK_READ\')")
@Transactional(readOnly=true)
public <T extends TaskTO> T read(TaskType type,
                                 String key,
                                 boolean details)

execute

@PreAuthorize("hasRole(\'TASK_EXECUTE\')")
public ExecTO execute(String key,
                      OffsetDateTime startAt,
                      boolean dryRun)

Specified by:

execute in class AbstractExecutableLogic<TaskTO>

delete

@PreAuthorize("hasRole(\'TASK_DELETE\')")
public <T extends TaskTO> T delete(TaskType type,
                                   String key)

listExecutions

@PreAuthorize("hasRole(\'TASK_READ\')")
public Pair<Integer,List<ExecTO>> listExecutions(String key,
                                                       OffsetDateTime before,
                                                       OffsetDateTime after,
                                                       int page,
                                                       int size,
                                                       List<OrderByClause> orderByClauses)

Specified by:

listExecutions in class AbstractExecutableLogic<TaskTO>

listRecentExecutions

@PreAuthorize("hasRole(\'TASK_LIST\')")
public List<ExecTO> listRecentExecutions(int max)

Specified by:

listRecentExecutions in class AbstractExecutableLogic<TaskTO>

deleteExecution

@PreAuthorize("hasRole(\'TASK_DELETE\')")
public ExecTO deleteExecution(String execKey)

Specified by:

deleteExecution in class AbstractExecutableLogic<TaskTO>

deleteExecutions

@PreAuthorize("hasRole(\'TASK_DELETE\')")
public List<BatchResponseItem> deleteExecutions(String key,
                                                OffsetDateTime before,
                                                OffsetDateTime after)

Specified by:

deleteExecutions in class AbstractExecutableLogic<TaskTO>

getReference

protected Triple<JobType,String,String> getReference(org.quartz.JobKey jobKey)

listJobs

@PreAuthorize("hasRole(\'TASK_LIST\')")
public List<JobTO> listJobs()

Specified by:

listJobs in class AbstractExecutableLogic<TaskTO>

getJob

@PreAuthorize("hasRole(\'TASK_READ\')")
public JobTO getJob(String key)

Specified by:

getJob in class AbstractExecutableLogic<TaskTO>

actionJob

@PreAuthorize("hasRole(\'TASK_EXECUTE\')")
public void actionJob(String key,
                      JobAction action)

Specified by:

actionJob in class AbstractExecutableLogic<TaskTO>

purgePropagations

@PreAuthorize("hasRole(\'TASK_DELETE\')")
public List<PropagationTaskTO> purgePropagations(OffsetDateTime since,
                                                 List<ExecStatus> statuses,
                                                 List<String> resources)

resolveReference

protected TaskTO resolveReference(Method method,
                                  Object... args)
                           throws UnresolvedReferenceException

Specified by:

resolveReference in class AbstractLogic<TaskTO>

Throws:

UnresolvedReferenceException

getJobTO

protected JobTO getJobTO(org.quartz.JobKey jobKey,
                         boolean includeCustom)
                  throws org.quartz.SchedulerException

Throws:

org.quartz.SchedulerException

doListJobs

protected List<JobTO> doListJobs(boolean includeCustom)

doActionJob

protected void doActionJob(org.quartz.JobKey jobKey,
                           JobAction action)