Package com.broadleafcommerce.auth.user.listener

Class CustomerPersistenceHandler

java.lang.Object

com.broadleafcommerce.auth.user.listener.AuthDataUpdatePersistenceHandler

com.broadleafcommerce.auth.user.listener.CustomerPersistenceHandler

All Implemented Interfaces:

com.broadleafcommerce.common.messaging.PersistenceHandler

public class CustomerPersistenceHandler
extends AuthDataUpdatePersistenceHandler

Constructor Summary

Constructors

Constructor	Description
CustomerPersistenceHandler(UserService<User> userService, AuthorizedClientService<AuthorizedClient> clientService, ApplicationService<Application> applicationService, UserCreationProducer userCreationProducer, com.fasterxml.jackson.databind.ObjectMapper objectMapper, UserLockoutService userLockoutService)

Method Summary

Modifier and Type	Method	Description
protected void	createNewUser(Customer customer)
protected ApplicationService<Application>	getApplicationService()
protected Instant	getChangeTimestamp(com.fasterxml.jackson.databind.JsonNode persistenceMessage)
protected AuthorizedClientService<AuthorizedClient>	getClientService()
String[]	getSupportedSimpleTypeNames()
protected UserCreationProducer	getUserCreationProducer()
protected String	getUserId(Customer customer)
protected UserLockoutService	getUserLockoutService()
protected UserMappingPropertiesService	getUserMappingPropertiesService()
protected UserResourceLockService<User>	getUserResourceLockService()
protected UserService<User>	getUserService()
protected @NotNull User	handleUserLockoutIfNecessary(Customer customer, User user)
void	hook(String entityJson)
protected boolean	mapAdditionalAttributes(@NonNull Customer customer, @NonNull User user)	Maps additional attributes from a Customer to its User.
protected IllegalArgumentException	missingTimestampError()
protected void	notifyNewCustomerUserCreated(User user, Customer customer)
protected Customer	parseCustomer(com.fasterxml.jackson.databind.JsonNode entityJson)
void	processStateChange(com.fasterxml.jackson.databind.JsonNode entityJson)
protected List<Application>	readApplicationsForCustomer(Customer customer)	Finds all applications in the data store for the given Customer.getCustomerContextId().
protected String	readAuthServerId(String applicationId)
void	setUserMappingPropertiesService(UserMappingPropertiesService userMappingPropertiesService)
void	setUserResourceLockService(UserResourceLockService<User> userResourceLockService)
protected void	updateExistingUser(Customer customer, Instant timestamp)
protected void	updateOrCreateUser(Customer customer, com.fasterxml.jackson.databind.JsonNode entityJson)
protected boolean	updateUserFields(Customer customer, User user)	Updates user fields that auth is concerned with.
protected Supplier<IllegalArgumentException>	userNotFound(Customer customer, String userId)

Methods inherited from class com.broadleafcommerce.auth.user.listener.AuthDataUpdatePersistenceHandler

getObjectMapper, handle, isNodeNull, isValidType

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.broadleafcommerce.common.messaging.PersistenceHandler

validate

Constructor Details

CustomerPersistenceHandler

public CustomerPersistenceHandler(UserService<User> userService,
 AuthorizedClientService<AuthorizedClient> clientService,
 ApplicationService<Application> applicationService,
 UserCreationProducer userCreationProducer,
 com.fasterxml.jackson.databind.ObjectMapper objectMapper,
 UserLockoutService userLockoutService)

Method Details

hook

@StreamListener("persistenceInputAuthCustomer")
public void hook(String entityJson)

processStateChange

public void processStateChange(com.fasterxml.jackson.databind.JsonNode entityJson)

updateOrCreateUser

protected void updateOrCreateUser(Customer customer,
 com.fasterxml.jackson.databind.JsonNode entityJson)

createNewUser

protected void createNewUser(Customer customer)

mapAdditionalAttributes

protected boolean mapAdditionalAttributes(@NonNull
 @NonNull Customer customer,
 @NonNull
 @NonNull User user)

Maps additional attributes from a Customer to its User.

Parameters:

customer - The customer spawning the event.

user - The user to update.

Returns:

Whether any updates occurred.

See Also:

• UserMappingProperties.getCustomerMappings()

notifyNewCustomerUserCreated

protected void notifyNewCustomerUserCreated(User user,
 Customer customer)

updateExistingUser

protected void updateExistingUser(Customer customer,
 Instant timestamp)

updateUserFields

protected boolean updateUserFields(Customer customer,
 User user)

Updates user fields that auth is concerned with.

Parameters:

customer - The customer from

user - The user to set fields on.

Returns:

true if a value was updated, else false.

getUserId

protected String getUserId(Customer customer)

userNotFound

protected Supplier<IllegalArgumentException> userNotFound(Customer customer,
 String userId)

parseCustomer

protected Customer parseCustomer(com.fasterxml.jackson.databind.JsonNode entityJson)

readAuthServerId

protected String readAuthServerId(String applicationId)

readApplicationsForCustomer

protected List<Application> readApplicationsForCustomer(Customer customer)

Finds all applications in the data store for the given Customer.getCustomerContextId().

Parameters:

customer - the customer for which to find applications in the data store

Returns:

the applications in the data store for the Customer.getCustomerContextId(). Never empty.

Throws:

IllegalArgumentException - if no applications were found

getChangeTimestamp

protected Instant getChangeTimestamp(com.fasterxml.jackson.databind.JsonNode persistenceMessage)

handleUserLockoutIfNecessary

@NotNull
protected @NotNull User handleUserLockoutIfNecessary(Customer customer,
 User user)

missingTimestampError

protected IllegalArgumentException missingTimestampError()

getSupportedSimpleTypeNames

public String[] getSupportedSimpleTypeNames()

getClientService

protected AuthorizedClientService<AuthorizedClient> getClientService()

getApplicationService

protected ApplicationService<Application> getApplicationService()

getUserCreationProducer

protected UserCreationProducer getUserCreationProducer()

getUserService

protected UserService<User> getUserService()

getUserLockoutService

protected UserLockoutService getUserLockoutService()

getUserMappingPropertiesService

protected UserMappingPropertiesService getUserMappingPropertiesService()

setUserMappingPropertiesService

@Autowired
public void setUserMappingPropertiesService(UserMappingPropertiesService userMappingPropertiesService)

getUserResourceLockService

protected UserResourceLockService<User> getUserResourceLockService()

setUserResourceLockService

@Autowired
public void setUserResourceLockService(UserResourceLockService<User> userResourceLockService)