Package org.apache.syncope.core.logic

Class TaskLogic

java.lang.Object

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

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

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 final TaskDataBinder	binder
protected final JobManager	jobManager
protected final JobStatusDAO	jobStatusDAO
protected final NotificationDAO	notificationDAO
protected final NotificationJobDelegate	notificationJobDelegate
protected final ExternalResourceDAO	resourceDAO
protected final SyncopeTaskScheduler	scheduler
protected final TaskDAO	taskDAO
protected final TaskExecDAO	taskExecDAO
protected final PropagationTaskExecutor	taskExecutor
protected final TaskUtilsFactory	taskUtilsFactory

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

LOG

Constructor Summary

Constructors

Constructor	Description
TaskLogic(JobManager jobManager, SyncopeTaskScheduler 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(String jobName, JobAction action)
protected ExecTO	doExecute(Task<?> task, OffsetDateTime startAt, boolean dryRun, Map<String,Object> additionalDataMap)
protected List<JobTO>	doListJobs(boolean includeCustom)
ExecTO	execute(ExecSpecs specs)
ExecTO	execute(ExecSpecs specs, SyncopeForm macroTaskForm)
JobTO	getJob(String key)
protected Optional<JobTO>	getJobTO(String jobName, boolean includeCustom)
SyncopeForm	getMacroTaskForm(String key, Locale locale)
protected Triple<JobType,String,String>	getReference(String jobName)
org.springframework.data.domain.Page<ExecTO>	listExecutions(String key, OffsetDateTime before, OffsetDateTime after, org.springframework.data.domain.Pageable pageable)
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> org.springframework.data.domain.Page<T>	search(TaskType type, String resource, String notification, AnyTypeKind anyTypeKind, String entityKey, org.springframework.data.domain.Pageable pageable, 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 Details

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 SyncopeTaskScheduler scheduler

jobStatusDAO

protected final JobStatusDAO jobStatusDAO

Constructor Details

TaskLogic

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

Method Details

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>
org.springframework.data.domain.Page<T> search(TaskType type,
 String resource,
 String notification,
 AnyTypeKind anyTypeKind,
 String entityKey,
 org.springframework.data.domain.Pageable pageable,
 boolean details)

read

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

getMacroTaskForm

@PreAuthorize("hasRole(\'TASK_READ\')")
@Transactional(readOnly=true)
public SyncopeForm getMacroTaskForm(String key,
 Locale locale)

doExecute

protected ExecTO doExecute(Task<?> task,
 OffsetDateTime startAt,
 boolean dryRun,
 Map<String,Object> additionalDataMap)

execute

@PreAuthorize("hasRole(\'TASK_EXECUTE\')")
public ExecTO execute(ExecSpecs specs)

Specified by:

execute in class AbstractExecutableLogic<TaskTO>

execute

@PreAuthorize("hasRole(\'TASK_EXECUTE\')")
public ExecTO execute(ExecSpecs specs,
 SyncopeForm macroTaskForm)

delete

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

listExecutions

@PreAuthorize("hasRole(\'TASK_READ\')")
public org.springframework.data.domain.Page<ExecTO> listExecutions(String key,
 OffsetDateTime before,
 OffsetDateTime after,
 org.springframework.data.domain.Pageable pageable)

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(String jobName)

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 Optional<JobTO> getJobTO(String jobName,
 boolean includeCustom)

doListJobs

protected List<JobTO> doListJobs(boolean includeCustom)

doActionJob

protected void doActionJob(String jobName,
 JobAction action)