Package org.apache.syncope.core.persistence.neo4j.dao.repo

Class UserRepoExtImpl

java.lang.Object

org.apache.syncope.core.persistence.neo4j.dao.AbstractDAO

org.apache.syncope.core.persistence.neo4j.dao.repo.AbstractAnyRepoExt<User,Neo4jUser>

org.apache.syncope.core.persistence.neo4j.dao.repo.UserRepoExtImpl

All Implemented Interfaces:

AnyRepoExt<User>, UserRepoExt

public class UserRepoExtImpl
extends AbstractAnyRepoExt<User,Neo4jUser>
implements UserRepoExt

Field Summary

Fields

Modifier and Type	Field	Description
protected final AccessTokenDAO	accessTokenDAO
protected final DelegationDAO	delegationDAO
protected final FIQLQueryDAO	fiqlQueryDAO
protected final GroupDAO	groupDAO
protected final NodeValidator	nodeValidator
protected final RoleDAO	roleDAO
protected final SecurityProperties	securityProperties
protected final javax.cache.Cache<EntityCacheKey,Neo4jUser>	userCache

Fields inherited from class org.apache.syncope.core.persistence.neo4j.dao.repo.AbstractAnyRepoExt

anyTypeClassDAO, anyTypeDAO, anyUtils, derSchemaDAO, dynRealmDAO, plainSchemaDAO

Fields inherited from class org.apache.syncope.core.persistence.neo4j.dao.AbstractDAO

LOG, neo4jClient, neo4jTemplate

Fields inherited from interface org.apache.syncope.core.persistence.neo4j.dao.repo.AnyRepoExt

REGEX_CHARS

Fields inherited from interface org.apache.syncope.core.persistence.neo4j.dao.repo.UserRepoExt

CACHE

Constructor Summary

Constructors

Constructor

Description

UserRepoExtImpl(AnyUtilsFactory anyUtilsFactory, AnyTypeDAO anyTypeDAO, AnyTypeClassDAO anyTypeClassDAO, PlainSchemaDAO plainSchemaDAO, DerSchemaDAO derSchemaDAO, DynRealmDAO dynRealmDAO, RoleDAO roleDAO, AccessTokenDAO accessTokenDAO, GroupDAO groupDAO, DelegationDAO delegationDAO, FIQLQueryDAO fiqlQueryDAO, SecurityProperties securityProperties, org.springframework.data.neo4j.core.Neo4jTemplate neo4jTemplate, org.springframework.data.neo4j.core.Neo4jClient neo4jClient, NodeValidator nodeValidator, javax.cache.Cache<EntityCacheKey,Neo4jUser> userCache)

Method Summary

Modifier and Type	Method	Description
protected javax.cache.Cache<EntityCacheKey,Neo4jUser>	cache()
protected <T extends Attributable> void	checkBeforeSave(T user)
Map<String,Long>	countByRealm()
Map<String,Long>	countByStatus()
void	delete(User user)
void	deleteMembership(UMembership membership)
protected Pair<User,GroupDAO.DynMembershipInfo>	doSave(User user)
Collection<String>	findAllGroupKeys(User user)
Collection<String>	findAllGroupNames(User user)
Collection<Group>	findAllGroups(User user)
Collection<String>	findAllResourceKeys(String key)
Collection<ExternalResource>	findAllResources(User user)
Collection<Role>	findAllRoles(User user)
List<User>	findBySecurityQuestion(SecurityQuestion securityQuestion)
Optional<? extends User>	findByToken(String token)
List<Group>	findDynGroups(String key)
List<Role>	findDynRoles(String key)
Optional<OffsetDateTime>	findLastChange(String key)
Optional<? extends LinkedAccount>	findLinkedAccount(ExternalResource resource, String connObjectKeyValue)
List<LinkedAccount>	findLinkedAccounts(String userKey)
List<LinkedAccount>	findLinkedAccountsByResource(ExternalResource resource)
UMembership	findMembership(String key)
boolean	linkedAccountExists(String userKey, String connObjectKeyValue)
<S extends User> S	save(S user)
GroupDAO.DynMembershipInfo	saveAndGetDynGroupMembs(User user)
void	securityChecks(Set<String> authRealms, String key, String realm, Collection<String> groups)
protected void	securityChecks(User user)

Methods inherited from class org.apache.syncope.core.persistence.neo4j.dao.repo.AbstractAnyRepoExt

authFind, deleteById, findAllowedSchemas, findById, findByKeys, findByResourcesContaining, findDynRealms, findLastChange, split

Methods inherited from class org.apache.syncope.core.persistence.neo4j.dao.AbstractDAO

cascadeDelete, deleteRelationship, findById, findByRelationship, findByRelationship, toList, toOptional

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.syncope.core.persistence.neo4j.dao.repo.AnyRepoExt

authFind, deleteById, findAllowedSchemas, findByKeys, findByResourcesContaining, findDynRealms

Field Details

roleDAO

protected final RoleDAO roleDAO

accessTokenDAO

protected final AccessTokenDAO accessTokenDAO

groupDAO

protected final GroupDAO groupDAO

delegationDAO

protected final DelegationDAO delegationDAO

fiqlQueryDAO

protected final FIQLQueryDAO fiqlQueryDAO

securityProperties

protected final SecurityProperties securityProperties

nodeValidator

protected final NodeValidator nodeValidator

userCache

protected final javax.cache.Cache<EntityCacheKey,Neo4jUser> userCache

Constructor Details

UserRepoExtImpl

public UserRepoExtImpl(AnyUtilsFactory anyUtilsFactory,
 AnyTypeDAO anyTypeDAO,
 AnyTypeClassDAO anyTypeClassDAO,
 PlainSchemaDAO plainSchemaDAO,
 DerSchemaDAO derSchemaDAO,
 DynRealmDAO dynRealmDAO,
 RoleDAO roleDAO,
 AccessTokenDAO accessTokenDAO,
 GroupDAO groupDAO,
 DelegationDAO delegationDAO,
 FIQLQueryDAO fiqlQueryDAO,
 SecurityProperties securityProperties,
 org.springframework.data.neo4j.core.Neo4jTemplate neo4jTemplate,
 org.springframework.data.neo4j.core.Neo4jClient neo4jClient,
 NodeValidator nodeValidator,
 javax.cache.Cache<EntityCacheKey,Neo4jUser> userCache)

Method Details

cache

protected javax.cache.Cache<EntityCacheKey,Neo4jUser> cache()

Specified by:

cache in class AbstractAnyRepoExt<User,Neo4jUser>

findByToken

public Optional<? extends User> findByToken(String token)

Specified by:

findByToken in interface UserRepoExt

findBySecurityQuestion

public List<User> findBySecurityQuestion(SecurityQuestion securityQuestion)

Specified by:

findBySecurityQuestion in interface UserRepoExt

findLastChange

@Transactional(readOnly=true)
public Optional<OffsetDateTime> findLastChange(String key)

Specified by:

findLastChange in interface AnyRepoExt<User>

securityChecks

@Transactional(readOnly=true)
public void securityChecks(Set<String> authRealms,
 String key,
 String realm,
 Collection<String> groups)

Specified by:

securityChecks in interface UserRepoExt

securityChecks

protected void securityChecks(User user)

Specified by:

securityChecks in class AbstractAnyRepoExt<User,Neo4jUser>

countByRealm

public Map<String,Long> countByRealm()

Specified by:

countByRealm in interface UserRepoExt

countByStatus

public Map<String,Long> countByStatus()

Specified by:

countByStatus in interface UserRepoExt

findMembership

public UMembership findMembership(String key)

Specified by:

findMembership in interface UserRepoExt

deleteMembership

public void deleteMembership(UMembership membership)

Specified by:

deleteMembership in interface UserRepoExt

checkBeforeSave

protected <T extends Attributable> void checkBeforeSave(T user)

Overrides:

checkBeforeSave in class AbstractAnyRepoExt<User,Neo4jUser>

doSave

protected Pair<User,GroupDAO.DynMembershipInfo> doSave(User user)

save

public <S extends User> S save(S user)

Specified by:

save in interface AnyRepoExt<User>

Specified by:

save in interface UserRepoExt

saveAndGetDynGroupMembs

public GroupDAO.DynMembershipInfo saveAndGetDynGroupMembs(User user)

Specified by:

saveAndGetDynGroupMembs in interface UserRepoExt

delete

public void delete(User user)

Specified by:

delete in interface AnyRepoExt<User>

Specified by:

delete in interface UserRepoExt

findAllRoles

@Transactional(propagation=REQUIRES_NEW,
               readOnly=true)
public Collection<Role> findAllRoles(User user)

Specified by:

findAllRoles in interface UserRepoExt

findDynRoles

@Transactional(propagation=REQUIRES_NEW,
               readOnly=true)
public List<Role> findDynRoles(String key)

Specified by:

findDynRoles in interface UserRepoExt

findDynGroups

@Transactional(propagation=REQUIRES_NEW,
               readOnly=true)
public List<Group> findDynGroups(String key)

Specified by:

findDynGroups in interface UserRepoExt

findAllGroups

@Transactional(propagation=REQUIRES_NEW,
               readOnly=true)
public Collection<Group> findAllGroups(User user)

Specified by:

findAllGroups in interface UserRepoExt

findAllGroupKeys

@Transactional(propagation=REQUIRES_NEW,
               readOnly=true)
public Collection<String> findAllGroupKeys(User user)

Specified by:

findAllGroupKeys in interface UserRepoExt

findAllGroupNames

@Transactional(propagation=REQUIRES_NEW,
               readOnly=true)
public Collection<String> findAllGroupNames(User user)

Specified by:

findAllGroupNames in interface UserRepoExt

findAllResources

@Transactional(propagation=REQUIRES_NEW,
               readOnly=true)
public Collection<ExternalResource> findAllResources(User user)

Specified by:

findAllResources in interface UserRepoExt

findAllResourceKeys

@Transactional(readOnly=true)
public Collection<String> findAllResourceKeys(String key)

Specified by:

findAllResourceKeys in interface AnyRepoExt<User>

linkedAccountExists

@Transactional(readOnly=true)
public boolean linkedAccountExists(String userKey,
 String connObjectKeyValue)

Specified by:

linkedAccountExists in interface UserRepoExt

findLinkedAccount

public Optional<? extends LinkedAccount> findLinkedAccount(ExternalResource resource,
 String connObjectKeyValue)

Specified by:

findLinkedAccount in interface UserRepoExt

findLinkedAccounts

public List<LinkedAccount> findLinkedAccounts(String userKey)

Specified by:

findLinkedAccounts in interface UserRepoExt

findLinkedAccountsByResource

public List<LinkedAccount> findLinkedAccountsByResource(ExternalResource resource)

Specified by:

findLinkedAccountsByResource in interface UserRepoExt