de.hybris.platform.cmswebservices.synchronization.facade.impl

Class DefaultSynchronizationFacade

java.lang.Object

de.hybris.platform.cmswebservices.synchronization.facade.impl.DefaultSynchronizationFacade

All Implemented Interfaces:

SynchronizationFacade

public class DefaultSynchronizationFacade
extends Object
implements SynchronizationFacade

Default implementation of the synchronization facade.

Constructor Summary

Constructors

Constructor and Description
DefaultSynchronizationFacade()

Method Summary

Modifier and Type	Method and Description
SyncJobData	createCatalogSynchronization(SyncJobRequestData syncJobRequest) Attempts to create a synchronization job.
protected SyncItemCronJobModel	createSyncCronJob(SyncItemJobModel job) Creates a new SyncItemCronJobModel for the same SyncItemJobModel
protected SyncItemJobModel	createSyncJobModel(CatalogVersionModel source, CatalogVersionModel target) Create a sync job
protected Optional<SyncItemJobModel>	findLatestSyncItemJobModel(String catalogId, String sourceCatalogVersionName, String targetTatalogVersionName) Find the latest SyncItemJobModel
protected Optional<CronJobModel>	findTheCronJob(Optional<SyncItemJobModel> syncItemJobModel) Return the latest cron job of a syncItemJobModel
protected Optional<CronJobModel>	findTheCronJob(String catalogId, String sourceCatalogVersionName, String targetCatalogVersionName) Find a cron job based a catalog and version.
protected CatalogVersionService	getCatalogVersionService()
protected Validator	getCreateCatalogSynchronizationCompositeValidator()
protected CronJobService	getCronJobService()
protected Optional<CronJobStatus>	getCronJobStatus(Optional<CronJobModel> cronJobModel) Get a cron job status
protected FacadeValidationService	getFacadeValidationService()
protected ModelService	getModelService()
SyncJobData	getSynchronizationByCatalogSourceTarget(SyncJobRequestData syncJobRequest) Get a synchronization status by SyncJobRequestData.
protected Converter<Optional<CronJobModel>,SyncJobData>	getSyncJobConverter()
protected Validator	getSyncJobRequestCompositeValidator()
void	setCatalogVersionService(CatalogVersionService catalogVersionService)
void	setCreateCatalogSynchronizationCompositeValidator(Validator createCatalogSynchronizationCompositeValidator)
void	setCronJobService(CronJobService cronJobService)
void	setFacadeValidationService(FacadeValidationService facadeValidationService)
void	setModelService(ModelService modelService)
void	setSyncJobConverter(Converter<Optional<CronJobModel>,SyncJobData> syncJobConverter)
void	setSyncJobRequestCompositeValidator(Validator syncJobRequestCompositeValidator)
protected void	validateIfJobIsRunning(Optional<CronJobStatus> cronJobStatus) Check if the a cron job is running

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultSynchronizationFacade

public DefaultSynchronizationFacade()

Method Detail

getSynchronizationByCatalogSourceTarget

public SyncJobData getSynchronizationByCatalogSourceTarget(SyncJobRequestData syncJobRequest)
                                                    throws ValidationException

Description copied from interface: SynchronizationFacade

Get a synchronization status by SyncJobRequestData.

Specified by:

getSynchronizationByCatalogSourceTarget in interface SynchronizationFacade

Parameters:

syncJobRequest - the synchronization request data

Returns:

the SyncJobData

Throws:

ValidationException - if there any validation errors.

createCatalogSynchronization

public SyncJobData createCatalogSynchronization(SyncJobRequestData syncJobRequest)

Description copied from interface: SynchronizationFacade

Attempts to create a synchronization job. It may not succeed due to internal constraints, and in this case it will throw an exception.

Specified by:

createCatalogSynchronization in interface SynchronizationFacade

Parameters:

syncJobRequest - the synchronization request data

Returns:

the synchronization job status

validateIfJobIsRunning

protected void validateIfJobIsRunning(Optional<CronJobStatus> cronJobStatus)

Check if the a cron job is running

Parameters:

cronJobStatus - an Optional of CronJobStatus

createSyncJobModel

protected SyncItemJobModel createSyncJobModel(CatalogVersionModel source,
                                              CatalogVersionModel target)

Create a sync job

Parameters:

source - the catalog source version

target - the catalog target version.

Returns:

a SyncItemJobModel

findLatestSyncItemJobModel

protected Optional<SyncItemJobModel> findLatestSyncItemJobModel(String catalogId,
                                                                String sourceCatalogVersionName,
                                                                String targetTatalogVersionName)

Find the latest SyncItemJobModel

Parameters:

catalogId -

sourceCatalogVersionName -

targetTatalogVersionName -

Returns:

Optional

findTheCronJob

protected Optional<CronJobModel> findTheCronJob(String catalogId,
                                                String sourceCatalogVersionName,
                                                String targetCatalogVersionName)

Find a cron job based a catalog and version.

Parameters:

catalogId - a catalog id

sourceCatalogVersionName - the source catalog version

targetCatalogVersionName - the target catalog version

Returns:

Optional a Optional of CronJobModel

findTheCronJob

protected Optional<CronJobModel> findTheCronJob(Optional<SyncItemJobModel> syncItemJobModel)

Return the latest cron job of a syncItemJobModel

Parameters:

syncItemJobModel - an Optional of SyncItemJobModel

Returns:

a Optional of CronJobModel

getCronJobStatus

protected Optional<CronJobStatus> getCronJobStatus(Optional<CronJobModel> cronJobModel)

Get a cron job status

Parameters:

cronJobModel - Optional of CronJobModel

Returns:

Optional of CronJobStatus

createSyncCronJob

protected SyncItemCronJobModel createSyncCronJob(SyncItemJobModel job)

Creates a new SyncItemCronJobModel for the same SyncItemJobModel

Parameters:

job - the SyncItemJobModel that will hold the new instance of the cron Job

Returns:

a new SyncItemCronJobModel

getCatalogVersionService

protected CatalogVersionService getCatalogVersionService()

setCatalogVersionService

public void setCatalogVersionService(CatalogVersionService catalogVersionService)

getSyncJobConverter

protected Converter<Optional<CronJobModel>,SyncJobData> getSyncJobConverter()

setSyncJobConverter

public void setSyncJobConverter(Converter<Optional<CronJobModel>,SyncJobData> syncJobConverter)

getFacadeValidationService

protected FacadeValidationService getFacadeValidationService()

setFacadeValidationService

public void setFacadeValidationService(FacadeValidationService facadeValidationService)

getModelService

protected ModelService getModelService()

setModelService

public void setModelService(ModelService modelService)

getCreateCatalogSynchronizationCompositeValidator

protected Validator getCreateCatalogSynchronizationCompositeValidator()

setCreateCatalogSynchronizationCompositeValidator

public void setCreateCatalogSynchronizationCompositeValidator(Validator createCatalogSynchronizationCompositeValidator)

getSyncJobRequestCompositeValidator

protected Validator getSyncJobRequestCompositeValidator()

setSyncJobRequestCompositeValidator

public void setSyncJobRequestCompositeValidator(Validator syncJobRequestCompositeValidator)

getCronJobService

protected CronJobService getCronJobService()

setCronJobService

public void setCronJobService(CronJobService cronJobService)