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 UserMappingProperties	getUserMappingProperties()
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	setUserMappingProperties(UserMappingProperties userMappingProperties)
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()

getUserMappingProperties

protected UserMappingProperties getUserMappingProperties()

setUserMappingProperties

@Autowired
public void setUserMappingProperties(UserMappingProperties userMappingProperties)