Class DefaultUserService<P extends User,D extends com.broadleafcommerce.data.tracking.core.mapping.BusinessTypeAware & com.broadleafcommerce.data.tracking.core.mapping.ModelMapperMappable>
- java.lang.Object
-
- com.broadleafcommerce.auth.user.service.DefaultUserService<P,D>
-
- All Implemented Interfaces:
UserService<P>
public class DefaultUserService<P extends User,D extends com.broadleafcommerce.data.tracking.core.mapping.BusinessTypeAware & com.broadleafcommerce.data.tracking.core.mapping.ModelMapperMappable> extends Object implements UserService<P>
- Author:
- Nathan Moore (nathanmoore)., Samarth Dhruva (samarthd)., Nick Crum (ncrum)
-
-
Constructor Summary
Constructors Constructor Description DefaultUserService(AuthorizedClientService<AuthorizedClient> clientService, UserRepository<D> userRepository, SimplePayloadMapper mapper, com.broadleafcommerce.data.tracking.core.mapping.validation.EntityValidatorManager validator, UserUpdateProducer userUpdateProducer)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected voidapplyChangesForArchive(P user)Modifies the given instance for archival.voidarchive(@NonNull String id)protected booleanauthServerMatches(P firstUser, P secondUser)Verifies that two user instances have the same authorization server.Pcreate(P user)Creates a new user in the data store.PcreateServiceUserOnlyIfDoesNotExist(P user)A create operation that will only create the givenuserif one does not already exist matching the givenUser.serviceIdandUser.type.voiddelete(@NonNull String id)Hard-deletes the given record.org.springframework.data.domain.Page<P>findAllNotArchived(org.springframework.data.domain.Pageable page)Finds and returns all entities that are notUser.archived.Optional<P>findByClientIdAndUsernameAndNotArchived(String clientId, String username)Finds the entity with the given username under the givenclientIdif notUser.archived.Optional<P>findByEmailAndAuthorizationServer(String email, String serverId)Find a user by email and authorization server id.Optional<P>findById(String id)Finds and returns the entity with the given ID.Optional<P>findByIdAndNotArchived(String id)Finds and returns the entity with the given ID if notUser.archived.List<P>findByIdIn(List<String> ids)Finds and returns all entities matching the givenids.Optional<P>findByServiceIdAndType(@NonNull String serviceId, @NonNull String type)Finds the unique record whoseUser.serviceIdandUser.typematch the given values.Optional<P>findByUsernameAndAuthorizationServer(String username, String serverId)Find a user by email and authorization server id.protected List<P>fromRepositoryDomain(Iterable<D> users)protected com.broadleafcommerce.data.tracking.core.mapping.validation.EntityValidatorManagergetValidator()booleanisEmailAlreadyInUse(String email, String authServerId)Check to determine if an email address for the given authorization server ID already exists.booleanisUsernameAlreadyInUse(String username, String serverId)Check to determine if a username for the given authorization server ID already exists.Preplace(String id, P user)Replaces the user in the data store with the givenidwithuser.PreplaceOnlyIfLastUpdatedBefore(@NonNull String entityId, P user, @NonNull Instant lastUpdated)A specialized replace operation that does not invoke the "save" create-or-update behavior.Psave(P user)List<P>saveAll(List<P> users)protected voidsendUserUpdateEvent(P updatedUser)protected voidvalidateCreate(P user)protected voidvalidateEmailAvailable(P user, org.springframework.validation.Errors errors)protected voidvalidateReplace(P originalUser, P replaceUser)protected voidvalidateServiceIdAndTypeAvailable(P user, org.springframework.validation.Errors errors)Validates that, if both are supplied, the combination ofUser.serviceIdandUser.typedo not currently exist in the data store.protected voidvalidateUsernameAvailable(P user, org.springframework.validation.Errors errors)
-
-
-
Constructor Detail
-
DefaultUserService
public DefaultUserService(AuthorizedClientService<AuthorizedClient> clientService, UserRepository<D> userRepository, SimplePayloadMapper mapper, com.broadleafcommerce.data.tracking.core.mapping.validation.EntityValidatorManager validator, UserUpdateProducer userUpdateProducer)
-
-
Method Detail
-
findById
public Optional<P> findById(String id)
Description copied from interface:UserServiceFinds and returns the entity with the given ID.- Specified by:
findByIdin interfaceUserService<P extends User>- Parameters:
id- the id of the entity to find- Returns:
- an
Optionalcontaining the entity if found,Optional.empty()otherwise
-
findByIdAndNotArchived
public Optional<P> findByIdAndNotArchived(String id)
Description copied from interface:UserServiceFinds and returns the entity with the given ID if notUser.archived.- Specified by:
findByIdAndNotArchivedin interfaceUserService<P extends User>- Parameters:
id- the id of the entity to find- Returns:
- an
Optionalcontaining the entity if found,Optional.empty()otherwise
-
findByClientIdAndUsernameAndNotArchived
public Optional<P> findByClientIdAndUsernameAndNotArchived(String clientId, String username)
Description copied from interface:UserServiceFinds the entity with the given username under the givenclientIdif notUser.archived.NOTE: By default this performs a case insensitive search on
username.- Specified by:
findByClientIdAndUsernameAndNotArchivedin interfaceUserService<P extends User>- Parameters:
clientId- the client id to match againstusername- the username to match against- Returns:
- an
Optionalcontaining the entity if found,Optional.empty()otherwise
-
findAllNotArchived
public org.springframework.data.domain.Page<P> findAllNotArchived(org.springframework.data.domain.Pageable page)
Description copied from interface:UserServiceFinds and returns all entities that are notUser.archived.- Specified by:
findAllNotArchivedin interfaceUserService<P extends User>- Parameters:
page- information about which page of results to return from the database- Returns:
- all entities that are not archived
-
findByIdIn
public List<P> findByIdIn(List<String> ids)
Description copied from interface:UserServiceFinds and returns all entities matching the givenids.- Specified by:
findByIdInin interfaceUserService<P extends User>- Parameters:
ids- the ids of entities to find. Must not be null nor contain any null values.- Returns:
- a non-null
Iterablecontaining the found entities (may be empty)
-
findByServiceIdAndType
public Optional<P> findByServiceIdAndType(@NonNull @NonNull String serviceId, @NonNull @NonNull String type)
Description copied from interface:UserServiceFinds the unique record whoseUser.serviceIdandUser.typematch the given values. Since records are only guaranteed unique if bothUser.serviceIdandUser.typeare present, this method does not accept null values for either argument.- Specified by:
findByServiceIdAndTypein interfaceUserService<P extends User>- Parameters:
serviceId- the service id to match against. Must not be null.type- the type to match against. Must not be null.- Returns:
- the record whose
User.serviceIdandUser.typematch the given values
-
create
public P create(P user)
Description copied from interface:UserServiceCreates a new user in the data store.- Specified by:
createin interfaceUserService<P extends User>- Parameters:
user- the user to create- Returns:
- the user after creation
-
validateCreate
protected void validateCreate(P user)
-
validateEmailAvailable
protected void validateEmailAvailable(P user, org.springframework.validation.Errors errors)
-
validateUsernameAvailable
protected void validateUsernameAvailable(P user, org.springframework.validation.Errors errors)
-
validateServiceIdAndTypeAvailable
protected void validateServiceIdAndTypeAvailable(P user, org.springframework.validation.Errors errors)
Validates that, if both are supplied, the combination ofUser.serviceIdandUser.typedo not currently exist in the data store. Intended to be used on standard create operations, notcreateServiceUserOnlyIfDoesNotExist(User).- Parameters:
user- the user whose service id and type should be validatederrors- the errors object bound to theuseron which errors can be registered
-
replace
public P replace(String id, P user)
Description copied from interface:UserServiceReplaces the user in the data store with the givenidwithuser.- Specified by:
replacein interfaceUserService<P extends User>- Parameters:
id- the ID of the user to replaceuser- the replacement user- Returns:
- the user after replacement
-
sendUserUpdateEvent
protected void sendUserUpdateEvent(@Nullable P updatedUser)
-
authServerMatches
protected boolean authServerMatches(P firstUser, P secondUser)
Verifies that two user instances have the same authorization server.User.getServerId()()} is a required field and must not be null.- Parameters:
firstUser- The first user to comparesecondUser- The second user to compare- Returns:
- true if auth servers match, else false
- Throws:
NullPointerException- If either user's AuthorizationServer is null
-
saveAll
public List<P> saveAll(List<P> users)
- Specified by:
saveAllin interfaceUserService<P extends User>
-
delete
public void delete(@NonNull @NonNull String id)Description copied from interface:UserServiceHard-deletes the given record.In all but exceptional cases,
UserService.archive(String)should be preferred to this operation.- Specified by:
deletein interfaceUserService<P extends User>- Parameters:
id- the id of the entity to delete- See Also:
UserService.archive(String)
-
archive
public void archive(@NonNull @NonNull String id)Description copied from interface:UserServiceSoft-deletes a record by setting itsUser.archivedtotrueandUser.activetofalse.As part of this operation, the
User.rolesandUser.permissionscollections should be cleared such that those relationships are deleted.- Specified by:
archivein interfaceUserService<P extends User>- Parameters:
id- the id of the entity to archive- See Also:
UserService.delete(String)
-
applyChangesForArchive
protected void applyChangesForArchive(P user)
Modifies the given instance for archival.- Parameters:
user- the instance to modify
-
isUsernameAlreadyInUse
public boolean isUsernameAlreadyInUse(String username, String serverId)
Description copied from interface:UserServiceCheck to determine if a username for the given authorization server ID already exists.NOTE: By default this performs a case insensitive search on
username.- Specified by:
isUsernameAlreadyInUsein interfaceUserService<P extends User>- Parameters:
username- The username to validateserverId- TheAuthorizationServerid- Returns:
- true if the username is in use, else false
-
isEmailAlreadyInUse
public boolean isEmailAlreadyInUse(String email, String authServerId)
Description copied from interface:UserServiceCheck to determine if an email address for the given authorization server ID already exists.NOTE: By default this performs a case insensitive search on
email.- Specified by:
isEmailAlreadyInUsein interfaceUserService<P extends User>- Parameters:
email- The username to validateauthServerId- TheAuthorizationServerid.- Returns:
- true if the email is in use, else false
-
findByEmailAndAuthorizationServer
public Optional<P> findByEmailAndAuthorizationServer(String email, String serverId)
Description copied from interface:UserServiceFind a user by email and authorization server id.NOTE: By default this performs a case insensitive search on
email.- Specified by:
findByEmailAndAuthorizationServerin interfaceUserService<P extends User>- Parameters:
email- The user e-mail addressserverId- TheAuthorizationServerid- Returns:
- The user found or
Optional.empty()
-
findByUsernameAndAuthorizationServer
public Optional<P> findByUsernameAndAuthorizationServer(String username, String serverId)
Description copied from interface:UserServiceFind a user by email and authorization server id.NOTE: By default this performs a case insensitive search on
username.- Specified by:
findByUsernameAndAuthorizationServerin interfaceUserService<P extends User>- Parameters:
username- The user's usernameserverId- TheAuthorizationServerid- Returns:
- The user found or
Optional.empty()
-
createServiceUserOnlyIfDoesNotExist
@Nullable public P createServiceUserOnlyIfDoesNotExist(@NonNull P user)
Description copied from interface:UserServiceA create operation that will only create the givenuserif one does not already exist matching the givenUser.serviceIdandUser.type.This is intended to be used in concurrent scenarios such as a message handler where only one operation should succeed.
Due to its specialized nature, this method does not perform the eager validations done by the standard
UserService.create(User)operation. It will rely on data-store mechanisms to protect against duplicates, and trust that the input is otherwise valid.This method should create the record with the provided
User.archivedvalue, even if it istrue.This method should create the record with the provided
User.lastUpdatedvalue.- Specified by:
createServiceUserOnlyIfDoesNotExistin interfaceUserService<P extends User>- Parameters:
user- the user to create. Must have a non-nullUser.serviceId,User.type, andUser.lastUpdatedpresent.- Returns:
- the user if successfully created, or
nullif the data store rejected it as a duplicate
-
replaceOnlyIfLastUpdatedBefore
@Nullable public P replaceOnlyIfLastUpdatedBefore(@NonNull @NonNull String entityId, @NonNull P user, @NonNull @NonNull Instant lastUpdated)
Description copied from interface:UserServiceA specialized replace operation that does not invoke the "save" create-or-update behavior. This operation should directly attempt an atomic update that the data store will reject if the entity is not found or has a lastUpdated ahead of the current change.This is intended to be used in concurrent scenarios where only one operation should succeed.
Note that this update should succeed even if the existing record is
User.archived.Note that this method should also set the provided
User.archivedvalue, even if it istrue.- Specified by:
replaceOnlyIfLastUpdatedBeforein interfaceUserService<P extends User>- Parameters:
entityId- the id of the entity to replaceuser- the replacement entitylastUpdated- the timestamp of the current change. This will be compared to the lastUpdated on the existing entity for determination of whether the replacement should occur. Furthermore, the replacement will have itsUser.lastUpdatedset to this value.- Returns:
- the user after replacement if successfully replaced, or
nullif the entity was not found or could not be updated due to its lastUpdated value.
-
getValidator
@NonNull protected com.broadleafcommerce.data.tracking.core.mapping.validation.EntityValidatorManager getValidator()
-
-