public final class TypeServiceImpl extends java.lang.Object implements TypeService
Modifier and Type | Field and Description |
---|---|
protected com.github.benmanes.caffeine.cache.Cache<java.lang.String,java.lang.String> |
keyToIdCache |
protected static int |
MAXIMUM_ALLOWED_UPDATE_ACTIONS |
Constructor and Description |
---|
TypeServiceImpl(BaseSyncOptions syncOptions) |
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.CompletionStage<java.util.Map<java.lang.String,java.lang.String>> |
cacheKeysToIds(java.util.Set<java.lang.String> typeKeys)
Filters out the keys which are already cached and fetches only the not-cached type keys from
the CTP project defined in an injected
SphereClient and stores a mapping for every type
to id in the cached map of keys -> ids and returns this cached map. |
java.util.concurrent.CompletionStage<java.util.Optional<io.sphere.sdk.types.Type>> |
createType(io.sphere.sdk.types.TypeDraft typeDraft)
Given a resource draft of type
TypeDraft , this method attempts to create a resource
Type based on it in the CTP project defined by the sync options. |
java.util.concurrent.CompletionStage<java.util.Optional<java.lang.String>> |
fetchCachedTypeId(java.lang.String key)
Given a
key , this method first checks if a cached map of Type keys -> ids contains
the key. |
java.util.concurrent.CompletionStage<java.util.Set<io.sphere.sdk.types.Type>> |
fetchMatchingTypesByKeys(java.util.Set<java.lang.String> keys)
Given a
Set of Type keys, this method fetches a set of all the Types, matching this
given set of keys in the CTP project, defined in an injected SphereClient . |
java.util.concurrent.CompletionStage<java.util.Optional<io.sphere.sdk.types.Type>> |
fetchType(java.lang.String key)
Given a type key, this method fetches a type that matches this given key in the CTP project
defined in an injected
SphereClient . |
java.util.concurrent.CompletionStage<io.sphere.sdk.types.Type> |
updateType(io.sphere.sdk.types.Type type,
java.util.List<io.sphere.sdk.commands.UpdateAction<io.sphere.sdk.types.Type>> updateActions)
Given a
Type and a List <UpdateAction <Type >>, this
method issues an update request with these update actions on this Type in the CTP
project defined in an injected SphereClient . |
protected final com.github.benmanes.caffeine.cache.Cache<java.lang.String,java.lang.String> keyToIdCache
protected static final int MAXIMUM_ALLOWED_UPDATE_ACTIONS
public TypeServiceImpl(@Nonnull BaseSyncOptions syncOptions)
@Nonnull public java.util.concurrent.CompletionStage<java.util.Map<java.lang.String,java.lang.String>> cacheKeysToIds(@Nonnull java.util.Set<java.lang.String> typeKeys)
TypeService
SphereClient
and stores a mapping for every type
to id in the cached map of keys -> ids and returns this cached map.cacheKeysToIds
in interface TypeService
typeKeys
- - a set type keys to fetch and cache the ids forCompletionStage
<Map
> in which the result of it's completion
contains a map of requested type keys -> ids@Nonnull public java.util.concurrent.CompletionStage<java.util.Optional<java.lang.String>> fetchCachedTypeId(@Nonnull java.lang.String key)
TypeService
key
, this method first checks if a cached map of Type keys -> ids contains
the key. If not, it returns a completed future that contains an Optional
that contains
what this key maps to in the cache. 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
with the id inside of it or an empty Optional
if no Type
was found in the CTP project with this key.fetchCachedTypeId
in interface TypeService
key
- the key by which a Type
id should be fetched from the
CTP project.CompletionStage
<Optional
<String
>> in which the
result of its completion could contain an Optional
with the id inside of it or an
empty Optional
if no Type
was found in the CTP project with this key.@Nonnull public java.util.concurrent.CompletionStage<java.util.Set<io.sphere.sdk.types.Type>> fetchMatchingTypesByKeys(@Nonnull java.util.Set<java.lang.String> keys)
TypeService
Set
of Type keys, this method fetches a set of all the Types, matching this
given set of keys in the CTP project, defined in an injected SphereClient
. A mapping of the key to the id of the fetched Type is
persisted in an in-memory map.fetchMatchingTypesByKeys
in interface TypeService
keys
- set of Type keys to fetch matching Type by.CompletionStage
<Map
> in which the result of its completion
contains a Set
of all matching Types.@Nonnull public java.util.concurrent.CompletionStage<java.util.Optional<io.sphere.sdk.types.Type>> fetchType(@Nullable java.lang.String key)
TypeService
SphereClient
. If there is no matching type an empty Optional
will be returned in the returned future.fetchType
in interface TypeService
key
- the key of the type to fetch.CompletionStage
<Optional
> in which the result of its completion
contains an Optional
that contains the matching Type
if exists, otherwise
empty.@Nonnull public java.util.concurrent.CompletionStage<java.util.Optional<io.sphere.sdk.types.Type>> createType(@Nonnull io.sphere.sdk.types.TypeDraft typeDraft)
TypeService
TypeDraft
, this method attempts to create a resource
Type
based on it in the CTP project defined by the sync options.
A completion stage containing an empty optional and the error callback will be triggered in those cases:
On the other hand, if the resource gets created successfully on CTP, then the created
resource's id and key are cached and the method returns a CompletionStage
in which the
result of its completion contains an instance Optional
of the resource which was
created.
createType
in interface TypeService
typeDraft
- the resource draft to create a resource based off of.CompletionStage
containing an optional with the created resource if
successful otherwise an empty optional.@Nonnull public java.util.concurrent.CompletionStage<io.sphere.sdk.types.Type> updateType(@Nonnull io.sphere.sdk.types.Type type, @Nonnull java.util.List<io.sphere.sdk.commands.UpdateAction<io.sphere.sdk.types.Type>> updateActions)
TypeService
Type
and a List
<UpdateAction
<Type
>>, this
method issues an update request with these update actions on this Type
in the CTP
project defined in an injected SphereClient
. This method returns
CompletionStage
<Type
> in which the result of its completion contains an
instance of the Type
which was updated in the CTP project.updateType
in interface TypeService
type
- the Type
to update.updateActions
- the update actions to update the Type
with.CompletionStage
<Type
> containing as a result of it's completion
an instance of the Type
which was updated in the CTP project or a SphereException
.