Package com.commercetools.sync.inventories

Class InventorySync

java.lang.Object

com.commercetools.sync.commons.BaseSync<io.sphere.sdk.inventory.InventoryEntryDraft,io.sphere.sdk.inventory.InventoryEntry,InventorySyncStatistics,InventorySyncOptions>

com.commercetools.sync.inventories.InventorySync

public final class InventorySync
extends BaseSync<io.sphere.sdk.inventory.InventoryEntryDraft,io.sphere.sdk.inventory.InventoryEntry,InventorySyncStatistics,InventorySyncOptions>

Default implementation of inventories sync process.

Field Summary

Fields inherited from class com.commercetools.sync.commons.BaseSync

statistics, syncOptions

Constructor Summary

Constructors

Constructor	Description
InventorySync(InventorySyncOptions syncOptions)	Takes a InventorySyncOptions instance to instantiate a new InventorySync instance that could be used to sync inventory drafts with the given inventory entries in the CTP project specified in the injected InventorySyncOptions instance.

Method Summary

Modifier and Type	Method	Description
protected java.util.concurrent.CompletionStage<InventorySyncStatistics>	process(java.util.List<io.sphere.sdk.inventory.InventoryEntryDraft> inventoryEntryDrafts)	Iterates through the whole inventories list and accumulates its valid drafts to batches.
protected java.util.concurrent.CompletionStage<InventorySyncStatistics>	processBatch(java.util.List<io.sphere.sdk.inventory.InventoryEntryDraft> batch)	Fetches existing InventoryEntry objects from CTP project that correspond to passed batchOfDrafts.

Methods inherited from class com.commercetools.sync.commons.BaseSync

executeSupplierIfConcurrentModificationException, getStatistics, getSyncOptions, handleError, sync, syncBatches

Methods inherited from class java.lang.Object

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

Constructor Detail

InventorySync

public InventorySync(@Nonnull
                     InventorySyncOptions syncOptions)

Takes a InventorySyncOptions instance to instantiate a new InventorySync instance that could be used to sync inventory drafts with the given inventory entries in the CTP project specified in the injected InventorySyncOptions instance.

Parameters:

syncOptions - the container of all the options of the sync process including the CTP project client and/or configuration and other sync-specific options.

Method Detail

process

@Nonnull
protected java.util.concurrent.CompletionStage<InventorySyncStatistics> process(@Nonnull
                                                                                java.util.List<io.sphere.sdk.inventory.InventoryEntryDraft> inventoryEntryDrafts)

Iterates through the whole inventories list and accumulates its valid drafts to batches. Every batch is then processed by processBatch(List).

Inherited doc: Given a list of resource (e.g. categories, products, etc..) drafts. This method compares each new resource in this list with it's corresponding old resource in a given CTP project, and in turn it either issues update actions on the existing resource if it exists or create it if it doesn't.

Specified by:

process in class BaseSync<io.sphere.sdk.inventory.InventoryEntryDraft,io.sphere.sdk.inventory.InventoryEntry,InventorySyncStatistics,InventorySyncOptions>

Parameters:

inventoryEntryDrafts - List of InventoryEntryDraft resources that would be synced into CTP project.

Returns:

CompletionStage with InventorySyncStatistics holding statistics of all sync processes performed by this sync instance

processBatch

protected java.util.concurrent.CompletionStage<InventorySyncStatistics> processBatch(@Nonnull
                                                                                     java.util.List<io.sphere.sdk.inventory.InventoryEntryDraft> batch)

Fetches existing InventoryEntry objects from CTP project that correspond to passed batchOfDrafts. Having existing inventory entries fetched, batchOfDrafts is compared and synced with fetched objects by syncBatch(Set, Set) function. When fetching existing inventory entries results in an empty optional then batchOfDrafts isn't processed.

Specified by:

processBatch in class BaseSync<io.sphere.sdk.inventory.InventoryEntryDraft,io.sphere.sdk.inventory.InventoryEntry,InventorySyncStatistics,InventorySyncOptions>

Parameters:

batch - batch of drafts that need to be synced

Returns:

CompletionStage of Void that indicates method progress.