Package com.commercetools.sync.services.impl

Class CustomerServiceImpl

    • Field Summary

      Fields 
      Modifier and Type Field Description
      protected com.github.benmanes.caffeine.cache.Cache<java.lang.String,​java.lang.String> keyToIdCache  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      java.util.concurrent.CompletionStage<java.util.Map<java.lang.String,​java.lang.String>> cacheKeysToIds​(java.util.Set<java.lang.String> keysToCache)
      Given a set of keys this method caches in-memory a mapping of key -> id only for those keys which are not already cached.
      java.util.concurrent.CompletionStage<java.util.Optional<io.sphere.sdk.customers.Customer>> createCustomer​(io.sphere.sdk.customers.CustomerDraft customerDraft)
      Given a resource draft of type CustomerDraft, this method attempts to create a resource Customer based on the draft, in the CTP project defined by the sync options.
      java.util.concurrent.CompletionStage<java.util.Optional<java.lang.String>> fetchCachedCustomerId​(java.lang.String key)
      Given a key, if it is blank (null/empty), a completed future with an empty optional is returned.
      java.util.concurrent.CompletionStage<java.util.Optional<io.sphere.sdk.customers.Customer>> fetchCustomerByKey​(java.lang.String key)
      Given a customer key, this method fetches a customer that matches this given key in the CTP project defined in a potentially injected SphereClient.
      java.util.concurrent.CompletionStage<java.util.Set<io.sphere.sdk.customers.Customer>> fetchMatchingCustomersByKeys​(java.util.Set<java.lang.String> customerKeys)
      Given a Set of customer keys, this method fetches a set of all the customers, matching the given set of keys in the CTP project, defined in an injected SphereClient.
      java.util.concurrent.CompletionStage<io.sphere.sdk.customers.Customer> updateCustomer​(io.sphere.sdk.customers.Customer customer, java.util.List<io.sphere.sdk.commands.UpdateAction<io.sphere.sdk.customers.Customer>> updateActions)
      Given a Customer and a List<UpdateAction<Customer>>, this method issues an update request with these update actions on this Customer in the CTP project defined in a potentially injected SphereClient.

      • Methods inherited from class java.lang.Object

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

    • Field Detail

      • keyToIdCache

        protected final com.github.benmanes.caffeine.cache.Cache<java.lang.String,​java.lang.String> keyToIdCache

    • Constructor Detail

      • CustomerServiceImpl

        public CustomerServiceImpl​(@Nonnull
                           CustomerSyncOptions syncOptions)

    • Method Detail

      • cacheKeysToIds

        @Nonnull
public java.util.concurrent.CompletionStage<java.util.Map<java.lang.String,​java.lang.String>> cacheKeysToIds​(@Nonnull
                                                                                                                   java.util.Set<java.lang.String> keysToCache)
        Description copied from interface: CustomerService
        Given a set of keys this method caches in-memory a mapping of key -> id only for those keys which are not already cached.
        Specified by:
        cacheKeysToIds in interface CustomerService
        Parameters:
        keysToCache - a set of keys to cache.
        Returns:
        a map of key to ids of the requested keys.

      • fetchMatchingCustomersByKeys

        @Nonnull
public java.util.concurrent.CompletionStage<java.util.Set<io.sphere.sdk.customers.Customer>> fetchMatchingCustomersByKeys​(@Nonnull
                                                                                                                          java.util.Set<java.lang.String> customerKeys)
        Description copied from interface: CustomerService
        Given a Set of customer keys, this method fetches a set of all the customers, matching the given set of keys in the CTP project, defined in an injected SphereClient. A mapping of the key to the id of the fetched customers is persisted in an in-memory map.
        Specified by:
        fetchMatchingCustomersByKeys in interface CustomerService
        Parameters:
        customerKeys - set of customer keys to fetch matching resources by.
        Returns:
        CompletionStage<Set<Customer>> in which the result of it's completion contains a Set of all matching customers.

      • fetchCustomerByKey

        @Nonnull
public java.util.concurrent.CompletionStage<java.util.Optional<io.sphere.sdk.customers.Customer>> fetchCustomerByKey​(@Nullable
                                                                                                                     java.lang.String key)
        Description copied from interface: CustomerService
        Given a customer key, this method fetches a customer that matches this given key in the CTP project defined in a potentially injected SphereClient. If there is no matching resource an empty Optional will be returned in the returned future. A mapping of the key to the id of the fetched customer is persisted in an in -memory map.
        Specified by:
        fetchCustomerByKey in interface CustomerService
        Parameters:
        key - the key of the resource to fetch
        Returns:
        CompletionStage<Optional> in which the result of it's completion contains an Optional that contains the matching Customer if exists, otherwise empty.

      • fetchCachedCustomerId

        @Nonnull
public java.util.concurrent.CompletionStage<java.util.Optional<java.lang.String>> fetchCachedCustomerId​(@Nonnull
                                                                                                        java.lang.String key)
        Description copied from interface: CustomerService
        Given a key, if it is blank (null/empty), a completed future with an empty optional is returned. Otherwise this method checks if the cached map of resource keys -> ids contains the given key. If it does, an optional containing the matching id is returned. If the cache doesn't contain the key; this method attempts to fetch the id of the key from the CTP project, caches it and returns a CompletionStage< Optional<String>> in which the result of it's completion could contain an Optional holding the id or an empty Optional if no customer was found in the CTP project with this key.
        Specified by:
        fetchCachedCustomerId in interface CustomerService
        Parameters:
        key - the key by which a customer id should be fetched from the CTP project.
        Returns:
        CompletionStage<Optional<String>> in which the result of it's completion could contain an Optional holding the id or an empty Optional if no customer was found in the CTP project with this key.

      • createCustomer

        @Nonnull
public java.util.concurrent.CompletionStage<java.util.Optional<io.sphere.sdk.customers.Customer>> createCustomer​(@Nonnull
                                                                                                                 io.sphere.sdk.customers.CustomerDraft customerDraft)
        Description copied from interface: CustomerService
        Given a resource draft of type CustomerDraft, this method attempts to create a resource Customer based on the draft, in the CTP project defined by the sync options.

        A completion stage containing an empty option and the error callback will be triggered in those cases:

        • the draft has a blank key
        • the create request fails on CTP

        On the other hand, if the resource gets created successfully on CTP, the created resource's id and key are cached and the method returns a CompletionStage in which the result of it's completion contains an instance Optional of the resource which was created.

        Specified by:
        createCustomer in interface CustomerService
        Parameters:
        customerDraft - the resource draft to create a resource based off of.
        Returns:
        a CompletionStage containing an optional with the created resource if successful otherwise an empty optional.

      • updateCustomer

        @Nonnull
public java.util.concurrent.CompletionStage<io.sphere.sdk.customers.Customer> updateCustomer​(@Nonnull
                                                                                             io.sphere.sdk.customers.Customer customer,
                                                                                             @Nonnull
                                                                                             java.util.List<io.sphere.sdk.commands.UpdateAction<io.sphere.sdk.customers.Customer>> updateActions)
        Description copied from interface: CustomerService
        Given a Customer and a List<UpdateAction<Customer>>, this method issues an update request with these update actions on this Customer in the CTP project defined in a potentially injected SphereClient. This method returns CompletionStage<Customer> in which the result of it's completion contains an instance of the Customer which was updated in the CTP project.
        Specified by:
        updateCustomer in interface CustomerService
        Parameters:
        customer - the Customer to update.
        updateActions - the update actions to update the Customer with.
        Returns:
        CompletionStage<Customer> containing as a result of it's completion an instance of the Customer which was updated in the CTP project or a SphereException.