com.broadleafcommerce.auth.user.listener

Class AdminRolePersistenceHandler

java.lang.Object

com.broadleafcommerce.auth.user.listener.AuthDataUpdatePersistenceHandler

com.broadleafcommerce.auth.user.listener.OperationAwarePersistenceHandler

com.broadleafcommerce.auth.user.listener.AdminRolePersistenceHandler

All Implemented Interfaces:

com.broadleafcommerce.common.messaging.PersistenceHandler

public class AdminRolePersistenceHandler
extends OperationAwarePersistenceHandler

Handles messages from the Persistence channel for AdminRole data to update UserRole. This is designed to perform a replacement of existing data within this service from the admin user service.

Author:

Samarth Dhruva (samarthd)

Constructor Summary

Constructors

Constructor and Description
AdminRolePersistenceHandler(UserRoleService<UserRole> userRoleService, com.fasterxml.jackson.databind.ObjectMapper mapper, com.broadleafcommerce.common.extension.TypeFactory typeFactory)

Method Summary

Modifier and Type	Method and Description
protected UserRole	buildUserRoleForCreate(String id, AdminRole request, Instant lastUpdated)
protected AdminRole	deserialize(com.fasterxml.jackson.databind.JsonNode jsonNode)
String[]	getSupportedSimpleTypeNames()
protected com.broadleafcommerce.common.extension.TypeFactory	getTypeFactory()
protected UserRoleService<UserRole>	getUserRoleService()
void	hook(String entityJson)
protected void	mapUpdatesFromRequest(AdminRole request, UserRole target)
protected void	modifyForArchival(UserRole target) Mimic what UserRoleService.archive(String) would do to mark this record as archived.
protected void	performArchivalReplacementIfEligible(@NonNull String entityId, @NonNull UserRole existing, @NonNull Instant changeTimestamp)
protected void	performReplacementIfEligible(@NonNull String entityId, @NonNull UserRole existing, @NonNull AdminRole request, @NonNull Instant changeTimestamp)
protected void	processCreateOperation(@NonNull String entityId, @NonNull Instant changeTimestamp, @NonNull com.fasterxml.jackson.databind.JsonNode entityJson) Invoked if the persistence message had an OperationType of OperationType.CREATE.
protected void	processDeleteOperation(@NonNull String entityId, @NonNull Instant changeTimestamp, @NonNull com.fasterxml.jackson.databind.JsonNode entityJson) Archives the given entity.
protected void	processUpdateOperation(@NonNull String entityId, @NonNull Instant changeTimestamp, @NonNull com.fasterxml.jackson.databind.JsonNode entityJson) Invoked if the persistence message had an OperationType of OperationType.UPDATE.
protected void	updateBasicRoleInfo(AdminRole request, UserRole role)
protected void	updateParent(AdminRole request, UserRole role) Don't validate parent or ancestry here, since we expect the admin user service to have pre-validated it against cycles or broken references.
protected void	updatePermissions(AdminRole request, UserRole role) We will not validate these references by querying for them, as the associated permissions may not yet be synchronized to the authentication service.
protected void	updateRoleTenantRestrictions(AdminRole request, UserRole role)

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

getChangeTimestamp, getEntityIdOrThrow, getNonNullField, getValidOperationTypeOrThrow, processStateChange, processStateChange

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 Detail

AdminRolePersistenceHandler

public AdminRolePersistenceHandler(UserRoleService<UserRole> userRoleService,
                                   com.fasterxml.jackson.databind.ObjectMapper mapper,
                                   com.broadleafcommerce.common.extension.TypeFactory typeFactory)

Method Detail

hook

@StreamListener(value="persistenceInputAdminRole")
public void hook(String entityJson)

processCreateOperation

protected void processCreateOperation(@NonNull
                                      @NonNull String entityId,
                                      @NonNull
                                      @NonNull Instant changeTimestamp,
                                      @NonNull
                                      @NonNull com.fasterxml.jackson.databind.JsonNode entityJson)
                               throws IOException

Description copied from class: OperationAwarePersistenceHandler

Invoked if the persistence message had an OperationType of OperationType.CREATE.

Specified by:

processCreateOperation in class OperationAwarePersistenceHandler

Parameters:

entityId - the ID found on the persistence message. Guaranteed non-empty.

changeTimestamp - the timestamp found on the persistence message. Guaranteed non-null.

entityJson - the persistence message json itself. Guaranteed non-null.

Throws:

IOException

buildUserRoleForCreate

protected UserRole buildUserRoleForCreate(String id,
                                          AdminRole request,
                                          Instant lastUpdated)

mapUpdatesFromRequest

protected void mapUpdatesFromRequest(AdminRole request,
                                     UserRole target)

deserialize

protected AdminRole deserialize(com.fasterxml.jackson.databind.JsonNode jsonNode)
                         throws IOException

Throws:

IOException

processUpdateOperation

protected void processUpdateOperation(@NonNull
                                      @NonNull String entityId,
                                      @NonNull
                                      @NonNull Instant changeTimestamp,
                                      @NonNull
                                      @NonNull com.fasterxml.jackson.databind.JsonNode entityJson)
                               throws IOException

Description copied from class: OperationAwarePersistenceHandler

Invoked if the persistence message had an OperationType of OperationType.UPDATE.

Specified by:

processUpdateOperation in class OperationAwarePersistenceHandler

Parameters:

entityId - the entity ID found on the persistence message. Guaranteed non-empty.

changeTimestamp - the timestamp found on the persistence message. Guaranteed non-null.

entityJson - the persistence message json itself. Guaranteed non-null.

Throws:

IOException

performReplacementIfEligible

protected void performReplacementIfEligible(@NonNull
                                            @NonNull String entityId,
                                            @NonNull
                                            @NonNull UserRole existing,
                                            @NonNull
                                            @NonNull AdminRole request,
                                            @NonNull
                                            @NonNull Instant changeTimestamp)

processDeleteOperation

protected void processDeleteOperation(@NonNull
                                      @NonNull String entityId,
                                      @NonNull
                                      @NonNull Instant changeTimestamp,
                                      @NonNull
                                      @NonNull com.fasterxml.jackson.databind.JsonNode entityJson)
                               throws IOException

Archives the given entity.

Note that if an existing record is not found, one will be created in an archived state. The motivation for this is to protect against out-of-order messages (ex: "Delete" message on an entity arrives before the "Create"). By establishing a pre-existing record in an archived state with a timestamp, any subsequent persistence message received can be compared against this record's timestamp and appropriately discarded as outdated rather than triggering creation of a new record.

Specified by:

processDeleteOperation in class OperationAwarePersistenceHandler

Parameters:

entityId - the entity ID found on the persistence message. Guaranteed non-empty.

changeTimestamp - the timestamp found on the persistence message. Guaranteed non-null.

entityJson - the persistence message json itself. Guaranteed non-null.

Throws:

IOException

performArchivalReplacementIfEligible

protected void performArchivalReplacementIfEligible(@NonNull
                                                    @NonNull String entityId,
                                                    @NonNull
                                                    @NonNull UserRole existing,
                                                    @NonNull
                                                    @NonNull Instant changeTimestamp)

modifyForArchival

protected void modifyForArchival(UserRole target)

Mimic what UserRoleService.archive(String) would do to mark this record as archived.

Parameters:

target - the instance to modify

updatePermissions

protected void updatePermissions(AdminRole request,
                                 UserRole role)

We will not validate these references by querying for them, as the associated permissions may not yet be synchronized to the authentication service. We trust the admin user service to have pre-validated these associations, and thus eventually no references will be broken.

TODO https://github.com/BroadleafCommerce/AuthenticationServices/issues/182

Parameters:

request - the request whose permissions should be used to replace the existing data

role - the target on which the permissions will be replaced

updateBasicRoleInfo

protected void updateBasicRoleInfo(AdminRole request,
                                   UserRole role)

updateParent

protected void updateParent(AdminRole request,
                            UserRole role)

Don't validate parent or ancestry here, since we expect the admin user service to have pre-validated it against cycles or broken references. Thus if this reference is currently broken or causes a problem, it's probably due to out-of-order message delivery and we expect it to be resolved shortly via another persistence message.

Parameters:

request - the payload received in the persistence message

role - the target instance to update

See Also:

UserRoleService.createOnlyIfDoesNotExist(UserRole, Instant), UserRoleService.replaceOnlyIfLastUpdatedBefore(String, UserRole, Instant)

updateRoleTenantRestrictions

protected void updateRoleTenantRestrictions(AdminRole request,
                                            UserRole role)

getSupportedSimpleTypeNames

public String[] getSupportedSimpleTypeNames()

getUserRoleService

protected UserRoleService<UserRole> getUserRoleService()

getTypeFactory

protected com.broadleafcommerce.common.extension.TypeFactory getTypeFactory()