Package ch.rswk.meta.engine

Class UserService

java.lang.Object

com.google.common.util.concurrent.AbstractIdleService

ch.rswk.meta.engine.AbstractEngineIdleService<UserService.UserServiceConfig>

ch.rswk.meta.engine.UserService

All Implemented Interfaces:

EngineServices.ConfigurableService<UserService.UserServiceConfig>, EngineServices.InfoProvidingService, com.google.common.util.concurrent.Service, com.yubico.webauthn.CredentialRepository

@Singleton
public class UserService
extends AbstractEngineIdleService<UserService.UserServiceConfig>
implements com.yubico.webauthn.CredentialRepository

UserService provides CRUD functionality for all user entities. Uses a LuceneService to store the user entities.

Provides authentication, authorization, verification and other access control functionality.

Passwords are stored using SCrypt (implemented by wg/scrypt). Passwords are optional, since it's possible to use OTP or WebAuthn. OTPs are 6 digit strings like 123 456 and can use SMS, e-mail, webhook or TOTP. OTPs can also be used as a second factor.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	UserService.ConfigCacheLoader
static final record	UserService.GeneratedOtp
private class	UserService.GroupCacheLoader
static final record	UserService.GroupWriteNotification
private static final record	UserService.OtpChallenge
private static enum	UserService.OtpChallengeType
private static final record	UserService.OtpValidation
private static final record	UserService.PasswordValidation
private static final record	UserService.PendingUserValidation
static final record	UserService.TokenRequest
static final record	UserService.UserCacheEntry
private class	UserService.UserCacheLoader
private static final record	UserService.UserConfigResult
static final record	UserService.UserConfigWriteNotification
static final record	UserService.UserServiceConfig
static final record	UserService.UserServiceContactConfig
static final record	UserService.UserServiceEnforceConfig
static final record	UserService.UserServiceTokenConfig
static final record	UserService.UserServiceWebAuthnConfig
static final record	UserService.UserTokenReply
static final record	UserService.UserTokenRequest
static final record	UserService.UserWriteNotification
private static final record	UserService.UserWriteValidationResult
static final record	UserService.VerifyTokenReply
static final record	UserService.VerifyTokenRequest
static enum	UserService.VerifyTokenState

Nested classes/interfaces inherited from interface com.google.common.util.concurrent.Service

com.google.common.util.concurrent.Service.Listener, com.google.common.util.concurrent.Service.State

Field Summary

Fields

Modifier and Type	Field	Description
private static final Protocol.ErrorReplyFactory	ATTEMPTS_EXCEEDED_ERROR
private static final Protocol.ErrorReplyFactory	AUTH_ERROR
private static final int	AUTH_TOKEN_EXPIRATION
private UserService.UserServiceContactConfig	authContact
private com.codahale.metrics.Meter	authErrorMeter
private com.codahale.metrics.Meter	authMeter
private SecretKey	authTokenKey
private com.codahale.metrics.Meter	authTokenMeter
private final BackupService	backupService
private static final Duration	CLEANUP_SCHEDULE
private ScheduledFuture<?>	cleanupHandle
private static final com.google.common.base.CharMatcher	CLIENT_NAME_OR_VERSION_MATCHER
private com.codahale.metrics.Meter	clientListMeter
private final Map<String,ClientListEntry>	clients
private static final Protocol.ErrorReplyFactory	CONFIG_ALREADY_EXISTS_ERROR
private static final com.fasterxml.jackson.databind.ObjectReader	CONFIG_READER
private com.github.benmanes.caffeine.cache.AsyncLoadingCache<String,Optional<MetaUserConfig>>	configCache
private com.codahale.metrics.Meter	configSearchMeter
private com.codahale.metrics.Meter	configWriteMeter
private static final Protocol.ErrorReplyFactory	DELETE_ADMIN_GROUP_ERROR
private final List<String>	disconnectedClientIds
private com.codahale.metrics.Meter	failedAttemptMeter
private final com.google.common.collect.Multiset<String>	failedAttempts
private com.codahale.metrics.Meter	failedTokenMeter
private final GatewayService	gatewayService
private static final Protocol.ErrorReplyFactory	GROUP_ALREADY_EXISTS_ERROR
private static final com.fasterxml.jackson.databind.ObjectReader	GROUP_READER
private com.github.benmanes.caffeine.cache.AsyncLoadingCache<String,Optional<MetaUserGroup>>	groupCache
private com.codahale.metrics.Meter	groupSearchMeter
private com.codahale.metrics.Meter	groupUpdateMeter
private com.codahale.metrics.Meter	groupWriteMeter
private static final Protocol.ErrorReplyFactory	INVALID_CONFIG_ERROR
private static final Protocol.ErrorReplyFactory	INVALID_GROUP_ERROR
private static final Protocol.ErrorReplyFactory	INVALID_OTP_ERROR
private static final Protocol.ErrorReplyFactory	INVALID_PASSWORD_ERROR
private static final Protocol.ErrorReplyFactory	INVALID_USER_ERROR
private static final org.slf4j.Logger	LOG
private com.codahale.metrics.Meter	loginMeter
private com.codahale.metrics.Meter	logoutMeter
private final LuceneService	luceneService
private static final Protocol.ErrorReplyFactory	MISSING_SUBJECT_ERROR
private static final Protocol.ErrorReplyFactory	NO_GROUP_FOR_UPDATE_ERROR
private static final Protocol.ErrorReplyFactory	NO_USER_FOR_UPDATE_ERROR
private static final Protocol.ErrorReplyFactory	NO_VERIFY_REQUEST_ERROR
private static final int	OTP_BOUND
private static final Protocol.ErrorReplyFactory	OTP_DELIVERY_FAILED_ERROR
private static final String	OTP_SEPARATOR
private static final Protocol.ErrorReplyFactory	OTP_VERIFICATION_ERROR
private com.github.benmanes.caffeine.cache.Cache<String,UserService.OtpChallenge>	otpCache
private com.codahale.metrics.Meter	otpExpiredMeter
private com.codahale.metrics.Timer	otpTimer
private Pattern	passwordRegex
private static final SecureRandom	RANDOM
private UserService.UserServiceContactConfig	recoverContact
private com.codahale.metrics.Meter	recoverErrorMeter
private com.codahale.metrics.Meter	recoverMeter
private UserService.UserServiceContactConfig	resetContact
private com.codahale.metrics.Meter	resetPasswordErrorMeter
private com.codahale.metrics.Meter	resetPasswordMeter
private com.codahale.metrics.Meter	scryptMeter
private static final Protocol.ErrorReplyFactory	SEARCH_ERROR
private static final io.jsonwebtoken.jackson.io.JacksonDeserializer<Map<String,?>>	TOKEN_DESERIALIZER
private static final String	TOKEN_ISSUER
private static final io.jsonwebtoken.jackson.io.JacksonSerializer<Map<String,?>>	TOKEN_SERIALIZER
private com.github.benmanes.caffeine.cache.Cache<String,OffsetDateTime>	tokenInvalidationCache
private SecretKey	tokenKey
private com.codahale.metrics.Meter	tokenMeter
private static final int	TOTP_ACCEPTED_CODES
private static final String	TOTP_RETURN_DIGITS
static final long	TOTP_VALIDITY
private com.codahale.metrics.Meter	totpMeter
private static final Protocol.ErrorReplyFactory	UPDATE_ERROR
private static final Protocol.ErrorReplyFactory	USER_ALREADY_EXISTS_ERROR
static final String	USER_CONFIG_EMAIL
private static final String	USER_CONFIG_GROUP_QUERY_FORMAT
static final String	USER_CONFIG_PHONE
private static final String	USER_CONFIG_QUERY_FORMAT
private static final String	USER_GROUP_MEMBER_QUERY_FORMAT
private static final com.fasterxml.jackson.databind.ObjectReader	USER_READER
private com.github.benmanes.caffeine.cache.AsyncLoadingCache<String,Optional<UserService.UserCacheEntry>>	userCache
private com.codahale.metrics.Meter	userSearchMeter
private com.codahale.metrics.Meter	userUpdateMeter
private com.github.benmanes.caffeine.cache.Cache<String,UserService.PendingUserValidation>	userValidationCache
private com.codahale.metrics.Meter	userWriteMeter
private UserService.UserServiceContactConfig	verifyContact
private com.github.benmanes.caffeine.cache.Cache<String,com.google.common.util.concurrent.SettableFuture<Void>>	verifyOtpCache
private com.codahale.metrics.Meter	verifyOtpErrorMeter
private com.codahale.metrics.Meter	verifyOtpMeter
private com.codahale.metrics.Meter	verifyTokenErrorMeter
private com.codahale.metrics.Meter	verifyTokenMeter
private static final Protocol.ErrorReplyFactory	WEBAUTHN_ASSERTION_ERROR
private static final com.fasterxml.jackson.core.type.TypeReference<com.yubico.webauthn.data.PublicKeyCredential<com.yubico.webauthn.data.AuthenticatorAssertionResponse,com.yubico.webauthn.data.ClientAssertionExtensionOutputs>>	WEBAUTHN_ASSERTION_TYPE
private static final String	WEBAUTHN_CREDENTIAL_QUERY_FORMAT
private static final com.google.common.base.CharMatcher	WEBAUTHN_DISPLAY_NAME_MATCHER
private static final com.fasterxml.jackson.databind.ObjectMapper	WEBAUTHN_MAPPER
private static final Protocol.ErrorReplyFactory	WEBAUTHN_REGISTRATION_ERROR
private static final com.fasterxml.jackson.core.type.TypeReference<com.yubico.webauthn.data.PublicKeyCredential<com.yubico.webauthn.data.AuthenticatorAttestationResponse,com.yubico.webauthn.data.ClientRegistrationExtensionOutputs>>	WEBAUTHN_REGISTRATION_TYPE
private static final String	WEBAUTHN_USER_HANDLE_QUERY_FORMAT
private com.github.benmanes.caffeine.cache.Cache<String,com.yubico.webauthn.AssertionRequest>	webAuthnAssertionCache
private com.github.benmanes.caffeine.cache.Cache<String,com.yubico.webauthn.data.PublicKeyCredentialCreationOptions>	webAuthnRegistrationCache
private com.yubico.webauthn.RelyingParty	webAuthnRelyingParty
private static final Protocol.ErrorReplyFactory	WEBHOOK_ERROR
private final Map<String,com.google.common.util.concurrent.SettableFuture<String>>	webhookAuthFutures
private final com.google.common.util.concurrent.Monitor	webhookAuthMonitor
private com.github.benmanes.caffeine.cache.Cache<String,String>	webhookAuthReceived
private com.codahale.metrics.Meter	webhookMeter
private static final Protocol.ErrorReplyFactory	WRITE_ERROR
private com.codahale.metrics.Meter	writeErrorMeter

Fields inherited from class ch.rswk.meta.engine.AbstractEngineIdleService

runtime

Constructor Summary

Constructors

Constructor	Description
UserService(BackupService backupService, UserService.UserServiceConfig config, GatewayService gatewayService, LuceneService luceneService, EngineRuntime runtime)

Method Summary

Modifier and Type	Method	Description
com.google.common.util.concurrent.ListenableFuture<AuthReply>	auth(String clientId, String ipAddress, AuthRequest request, String user)
com.google.common.util.concurrent.ListenableFuture<AuthTokenReply>	authToken(String clientId, String ipAddress, AuthTokenRequest request, String user)
private Optional<ErrorReplyException>	checkAttempts(int attempts, String identifier)
Optional<ErrorReplyException>	checkAttempts(String... identifiers)
com.google.common.util.concurrent.ListenableFuture<UserConfigSearchReply>	configSearch(UserConfigSearchRequest request)
static com.google.common.util.concurrent.ListenableFuture<Void>	configSearchRecursive(Executor executor, Function<UserConfigSearchReply,com.google.common.util.concurrent.ListenableFuture<?>> replyConsumer, UserConfigSearchRequest request, Function<UserConfigSearchRequest,com.google.common.util.concurrent.ListenableFuture<UserConfigSearchReply>> service)
com.google.common.util.concurrent.ListenableFuture<UserConfigWriteReply>	configWrite(UserConfigWriteRequest request)
private void	decrementFailedAttempts()
private com.google.common.util.concurrent.ListenableFuture<Void>	deleteConfigs(String query)
private void	deleteDisconnectedClientIds()
private LuceneService.SearchResult	executeLuceneGroupSearch(LuceneService.LuceneContext context, UserGroupSearchRequest request)
private LuceneService.SearchResult	executeLuceneUserSearch(LuceneService.LuceneContext context, UserSearchRequest request)
private Optional<MetaUser>	findUserForHandle(com.yubico.webauthn.data.ByteArray userHandle)
private Optional<ErrorReply>	finishWebAuthnAssertion(AuthRequest.AuthRequestWebAuthnAssertionReply assertionReply, String clientId, @Nullable String ipAddress, String user)
private Optional<MetaUser.MetaUserWebAuthn>	finishWebAuthnRegistration(UserWriteRequest.UserWriteRequestWebAuthnReply createReply, String user)
private String	forgeEmailAndPhoneQuery(@Nullable String email, String emailField, @Nullable String phone, String phoneField)
static String	generateScryptHash(int cpu, int memory, String secret)
static UserService.GeneratedOtp	generateScryptOtp(int scryptCpu, int scryptMemory)
String	generateToken(UserService.TokenRequest request)
static String	generateTotp(long offset, String totpKey)	generateTotp generates a totp from the given key based on the current time plus offset.
static String	generateTotpKey()
com.google.common.util.concurrent.ListenableFuture<UserService.UserTokenReply>	generateUserToken(@Nullable String clientId, String ipAddress, UserService.UserTokenRequest request)	generateUserToken authenticates the given user/password and generates a token containing all grants for user and its groups.
com.google.common.util.concurrent.ListenableFuture<Optional<MetaUserConfig>>	getCachedConfig(String configId)
com.google.common.util.concurrent.ListenableFuture<Optional<MetaUserGroup>>	getCachedGroup(String group)
com.google.common.util.concurrent.ListenableFuture<Optional<UserService.UserCacheEntry>>	getCachedUser(String user)
com.google.common.util.concurrent.ListenableFuture<ClientListReply>	getClientList(ClientListRequest request)
Set<com.yubico.webauthn.data.PublicKeyCredentialDescriptor>	getCredentialIdsForUsername(String username)
Optional<com.yubico.webauthn.data.ByteArray>	getUserHandleForUsername(String username)
Optional<String>	getUsernameForUserHandle(com.yubico.webauthn.data.ByteArray userHandle)
com.google.common.util.concurrent.ListenableFuture<UserGroupSearchReply>	groupSearch(UserGroupSearchRequest request)
static com.google.common.util.concurrent.ListenableFuture<Void>	groupSearchRecursive(Executor executor, Function<UserGroupSearchReply,com.google.common.util.concurrent.ListenableFuture<?>> replyConsumer, UserGroupSearchRequest request, Function<UserGroupSearchRequest,com.google.common.util.concurrent.ListenableFuture<UserGroupSearchReply>> service)
com.google.common.util.concurrent.ListenableFuture<UserGroupWriteReply>	groupWrite(UserGroupWriteRequest request)
com.google.common.util.concurrent.ListenableFuture<UserGroupWriteUpdateReply>	groupWriteUpdate(UserGroupWriteUpdateRequest request)
private static boolean	hasRequiredGrants(io.jsonwebtoken.Claims claims, @Nullable Map<String,Integer> requiredGrants)
com.google.common.util.concurrent.ListenableFuture<Boolean>	hasUserPermission(int permission, String userName, String... keys)	hasUserPermission checks if user has required permission for at least onf of keys.
com.google.common.util.concurrent.ListenableFuture<Boolean>	isMember(String groupName, String userName)
private com.google.common.util.concurrent.ListenableFuture<UserService.UserConfigResult>	loadUserConfigs(Set<String> groups, String user)
com.google.common.util.concurrent.ListenableFuture<LoginReply>	login(String clientId, String ipAddress, LoginRequest request)
private com.google.common.util.concurrent.ListenableFuture<LoginReply>	loginWithPassword(String clientId, String ipAddress, @Nullable String locale, @Nullable String password, @Nullable String login)
private com.google.common.util.concurrent.ListenableFuture<LoginReply>	loginWithToken(String clientId, String ipAddress, String token)
com.google.common.util.concurrent.ListenableFuture<LogoutReply>	logout(String clientId, LogoutRequest request)
Optional<com.yubico.webauthn.RegisteredCredential>	lookup(com.yubico.webauthn.data.ByteArray credentialId, com.yubico.webauthn.data.ByteArray userHandle)
Set<com.yubico.webauthn.RegisteredCredential>	lookupAll(com.yubico.webauthn.data.ByteArray credentialId)
private com.google.common.util.concurrent.ListenableFuture<Set<String>>	lookupUserByPhoneAndEmail(String email, String phone)
private UserGroupSearchReply	newGroupSearchReply(LuceneService.SearchResult result)
private static @Nullable MetaUser	newMaskedUser(@Nullable MetaUser user)
private static @Nullable MetaUser.MetaUserWebAuthn	newMaskedWebAuthn(@Nullable MetaUser.MetaUserWebAuthn webAuthn)
private UserSearchReply	newUserSearchReply(boolean mask, LuceneService.SearchResult result)
private com.google.common.util.concurrent.ListenableFuture<UserConfigWriteReply>	processConfigWrite(UserConfigWriteRequest request)
private com.google.common.util.concurrent.ListenableFuture<UserGroupWriteReply>	processGroupWrite(UserGroupWriteRequest request)
private com.google.common.util.concurrent.ListenableFuture<UserGroupWriteUpdateReply>	processGroupWriteUpdate(UserGroupWriteUpdateRequest request)
private com.google.common.util.concurrent.ListenableFuture<UserWriteReply>	processUserWrite(UserWriteRequest request)
private com.google.common.util.concurrent.ListenableFuture<UserWriteUpdateReply>	processUserWriteUpdate(UserWriteUpdateRequest request)
void	recordFailedAttempt(@Nullable String clientId, @Nullable String ipAddress, String source, @Nullable String user)
com.google.common.util.concurrent.ListenableFuture<RecoverUserReply>	recoverUser(String clientId, String ipAddress, RecoverUserRequest request)
com.google.common.util.concurrent.ListenableFuture<ResetPasswordReply>	resetPassword(String clientId, String ipAddress, ResetPasswordRequest request)
private static String	sanitizeClientNameOrVersion(String s)
private static String	sanitizeOtp(String otp)
private static @Nullable String	sanitizeWebAuthnDisplayName(String displayName)
protected void	shutDown()
private com.google.common.util.concurrent.ListenableFuture<Void>	startOtpChallenge(String clientId, UserService.UserServiceContactConfig contact, String ipAddress, @Nullable String locale, UserService.OtpChallengeType type, String user, MetaUser.MetaUserOtp userOtp)
protected void	startUp()
com.google.common.util.concurrent.ListenableFuture<Void>	startVerifyOtp(String clientId, @Nullable UserService.UserServiceContactConfig contact, String ipAddress, @Nullable String locale, String user, MetaUser.MetaUserOtp userOtp)
private LoginReply.LoginReplyWebAuthnAssertionRequest	startWebAuthnAssertion(String clientId, String user)
private UserWriteReply.UserWriteReplyWebAuthnRequest	startWebAuthnRegistration(String displayName, @Nullable String existingUserHandle, String user)
com.google.common.util.concurrent.ListenableFuture<String>	startWebhookAuth(String authRef)
void	updateClientList(ClientListEntry entry)
private void	updateUserCache(String user)
com.google.common.util.concurrent.ListenableFuture<UserSearchReply>	userSearch(UserSearchRequest request)
protected com.google.common.util.concurrent.ListenableFuture<UserSearchReply>	userSearchInternal(boolean mask, UserSearchRequest request)
static com.google.common.util.concurrent.ListenableFuture<Void>	userSearchRecursive(Executor executor, Function<UserSearchReply,com.google.common.util.concurrent.ListenableFuture<?>> replyConsumer, UserSearchRequest request, Function<UserSearchRequest,com.google.common.util.concurrent.ListenableFuture<UserSearchReply>> service)
com.google.common.util.concurrent.ListenableFuture<UserWriteReply>	userWrite(@Nullable String clientId, boolean enforce, @Nullable String ipAddress, UserWriteRequest request)	userWrite processes UserWriteRequest.
protected com.google.common.util.concurrent.ListenableFuture<UserWriteReply>	userWriteInternal(@Nullable String clientId, boolean enforce, boolean hashed, @Nullable String ipAddress, boolean mask, UserWriteRequest request)
com.google.common.util.concurrent.ListenableFuture<UserWriteUpdateReply>	userWriteUpdate(UserWriteUpdateRequest request)
private static UserService.PasswordValidation	validatePassword(String existingPassword, boolean hashed, String password, @Nullable Pattern passwordRegex, int scryptCpu, int scryptMemory)
private static UserService.OtpValidation	validateUserOtp(@Nullable UserService.UserServiceEnforceConfig enforceConfig, @Nullable MetaUser.MetaUserOtp existingUserOtp, boolean hashed, @Nullable UserService.PendingUserValidation pendingUserValidation, @Nullable MetaUser.MetaUserOtp userOtp)
private UserService.UserWriteValidationResult	validateUserWrite(@Nullable String clientId, boolean enforce, boolean hashed, @Nullable String ipAddress, UserWriteRequest request, MetaUser user, @Nullable UserService.UserCacheEntry cacheEntry, String userName)
Optional<ErrorReply>	verifyOtp(String clientId, String ipAddress, String otp, String user)
private Optional<ErrorReply>	verifyOtpChallenge(String clientId, String ipAddress, String otp, UserService.OtpChallengeType type, String user)
private boolean	verifyPassword(@Nullable String password, MetaUser user)
boolean	verifyScryptHash(@Nullable String hash, @Nullable String secret)
boolean	verifyScryptOtp(@Nullable String hash, @Nullable String otp)
UserService.VerifyTokenReply	verifyToken(@Nullable String clientId, String ipAddress, UserService.VerifyTokenRequest request)
static boolean	verifyTotp(int acceptedCodes, String totpKey, @Nullable String totp)	verifyTotp generates codes from the given key and compares them to the given totp.
boolean	verifyTotp(String totpKey, @Nullable String totp)
void	verifyWebhookAuth(String authRef, String otp)
private void	writeGroup(WriteAction action, @Nullable MetaUserGroup existingGroup, MetaUserGroup group, org.apache.lucene.index.IndexWriter writer)
private void	writeUser(WriteAction action, @Nullable org.apache.lucene.document.Document document, String userName, org.apache.lucene.index.IndexWriter writer)

Methods inherited from class ch.rswk.meta.engine.AbstractEngineIdleService

configClass, configReference, serviceName

Methods inherited from class com.google.common.util.concurrent.AbstractIdleService

addListener, awaitRunning, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, awaitTerminated, executor, failureCause, isRunning, startAsync, state, stopAsync, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface ch.rswk.meta.engine.EngineServices.ConfigurableService

config, onConfigChanged

Methods inherited from interface ch.rswk.meta.engine.EngineServices.InfoProvidingService

getServiceInfo

Field Details

LOG

private static final org.slf4j.Logger LOG

TOTP_VALIDITY

public static final long TOTP_VALIDITY

See Also:

• Constant Field Values

USER_CONFIG_EMAIL

public static final String USER_CONFIG_EMAIL

See Also:

• Constant Field Values

USER_CONFIG_PHONE

public static final String USER_CONFIG_PHONE

See Also:

• Constant Field Values

ATTEMPTS_EXCEEDED_ERROR

private static final Protocol.ErrorReplyFactory ATTEMPTS_EXCEEDED_ERROR

AUTH_ERROR

private static final Protocol.ErrorReplyFactory AUTH_ERROR

AUTH_TOKEN_EXPIRATION

private static final int AUTH_TOKEN_EXPIRATION

See Also:

• Constant Field Values

CLEANUP_SCHEDULE

private static final Duration CLEANUP_SCHEDULE

CLIENT_NAME_OR_VERSION_MATCHER

private static final com.google.common.base.CharMatcher CLIENT_NAME_OR_VERSION_MATCHER

CONFIG_ALREADY_EXISTS_ERROR

private static final Protocol.ErrorReplyFactory CONFIG_ALREADY_EXISTS_ERROR

CONFIG_READER

private static final com.fasterxml.jackson.databind.ObjectReader CONFIG_READER

DELETE_ADMIN_GROUP_ERROR

private static final Protocol.ErrorReplyFactory DELETE_ADMIN_GROUP_ERROR

GROUP_ALREADY_EXISTS_ERROR

private static final Protocol.ErrorReplyFactory GROUP_ALREADY_EXISTS_ERROR

GROUP_READER

private static final com.fasterxml.jackson.databind.ObjectReader GROUP_READER

INVALID_CONFIG_ERROR

private static final Protocol.ErrorReplyFactory INVALID_CONFIG_ERROR

INVALID_GROUP_ERROR

private static final Protocol.ErrorReplyFactory INVALID_GROUP_ERROR

INVALID_OTP_ERROR

private static final Protocol.ErrorReplyFactory INVALID_OTP_ERROR

INVALID_PASSWORD_ERROR

private static final Protocol.ErrorReplyFactory INVALID_PASSWORD_ERROR

INVALID_USER_ERROR

private static final Protocol.ErrorReplyFactory INVALID_USER_ERROR

MISSING_SUBJECT_ERROR

private static final Protocol.ErrorReplyFactory MISSING_SUBJECT_ERROR

NO_GROUP_FOR_UPDATE_ERROR

private static final Protocol.ErrorReplyFactory NO_GROUP_FOR_UPDATE_ERROR

NO_USER_FOR_UPDATE_ERROR

private static final Protocol.ErrorReplyFactory NO_USER_FOR_UPDATE_ERROR

NO_VERIFY_REQUEST_ERROR

private static final Protocol.ErrorReplyFactory NO_VERIFY_REQUEST_ERROR

OTP_BOUND

private static final int OTP_BOUND

See Also:

• Constant Field Values

OTP_DELIVERY_FAILED_ERROR

private static final Protocol.ErrorReplyFactory OTP_DELIVERY_FAILED_ERROR

OTP_SEPARATOR

private static final String OTP_SEPARATOR

See Also:

• Constant Field Values

OTP_VERIFICATION_ERROR

private static final Protocol.ErrorReplyFactory OTP_VERIFICATION_ERROR

RANDOM

private static final SecureRandom RANDOM

SEARCH_ERROR

private static final Protocol.ErrorReplyFactory SEARCH_ERROR

TOKEN_DESERIALIZER

private static final io.jsonwebtoken.jackson.io.JacksonDeserializer<Map<String,?>> TOKEN_DESERIALIZER

TOKEN_ISSUER

private static final String TOKEN_ISSUER

TOKEN_SERIALIZER

private static final io.jsonwebtoken.jackson.io.JacksonSerializer<Map<String,?>> TOKEN_SERIALIZER

TOTP_ACCEPTED_CODES

private static final int TOTP_ACCEPTED_CODES

See Also:

• Constant Field Values

TOTP_RETURN_DIGITS

private static final String TOTP_RETURN_DIGITS

See Also:

• Constant Field Values

UPDATE_ERROR

private static final Protocol.ErrorReplyFactory UPDATE_ERROR

USER_ALREADY_EXISTS_ERROR

private static final Protocol.ErrorReplyFactory USER_ALREADY_EXISTS_ERROR

USER_CONFIG_GROUP_QUERY_FORMAT

private static final String USER_CONFIG_GROUP_QUERY_FORMAT

See Also:

• Constant Field Values

USER_CONFIG_QUERY_FORMAT

private static final String USER_CONFIG_QUERY_FORMAT

See Also:

• Constant Field Values

USER_GROUP_MEMBER_QUERY_FORMAT

private static final String USER_GROUP_MEMBER_QUERY_FORMAT

See Also:

• Constant Field Values

USER_READER

private static final com.fasterxml.jackson.databind.ObjectReader USER_READER

WEBAUTHN_ASSERTION_ERROR

private static final Protocol.ErrorReplyFactory WEBAUTHN_ASSERTION_ERROR

WEBAUTHN_ASSERTION_TYPE

private static final com.fasterxml.jackson.core.type.TypeReference<com.yubico.webauthn.data.PublicKeyCredential<com.yubico.webauthn.data.AuthenticatorAssertionResponse,com.yubico.webauthn.data.ClientAssertionExtensionOutputs>> WEBAUTHN_ASSERTION_TYPE

WEBAUTHN_CREDENTIAL_QUERY_FORMAT

private static final String WEBAUTHN_CREDENTIAL_QUERY_FORMAT

See Also:

• Constant Field Values

WEBAUTHN_DISPLAY_NAME_MATCHER

private static final com.google.common.base.CharMatcher WEBAUTHN_DISPLAY_NAME_MATCHER

WEBAUTHN_MAPPER

private static final com.fasterxml.jackson.databind.ObjectMapper WEBAUTHN_MAPPER

WEBAUTHN_REGISTRATION_ERROR

private static final Protocol.ErrorReplyFactory WEBAUTHN_REGISTRATION_ERROR

WEBAUTHN_REGISTRATION_TYPE

private static final com.fasterxml.jackson.core.type.TypeReference<com.yubico.webauthn.data.PublicKeyCredential<com.yubico.webauthn.data.AuthenticatorAttestationResponse,com.yubico.webauthn.data.ClientRegistrationExtensionOutputs>> WEBAUTHN_REGISTRATION_TYPE

WEBAUTHN_USER_HANDLE_QUERY_FORMAT

private static final String WEBAUTHN_USER_HANDLE_QUERY_FORMAT

See Also:

• Constant Field Values

WEBHOOK_ERROR

private static final Protocol.ErrorReplyFactory WEBHOOK_ERROR

WRITE_ERROR

private static final Protocol.ErrorReplyFactory WRITE_ERROR

backupService

private final BackupService backupService

clients

private final Map<String,ClientListEntry> clients

disconnectedClientIds

private final List<String> disconnectedClientIds

failedAttempts

private final com.google.common.collect.Multiset<String> failedAttempts

gatewayService

private final GatewayService gatewayService

luceneService

private final LuceneService luceneService

webhookAuthFutures

private final Map<String,com.google.common.util.concurrent.SettableFuture<String>> webhookAuthFutures

webhookAuthMonitor

private final com.google.common.util.concurrent.Monitor webhookAuthMonitor

authContact

private UserService.UserServiceContactConfig authContact

authErrorMeter

private com.codahale.metrics.Meter authErrorMeter

authMeter

private com.codahale.metrics.Meter authMeter

authTokenKey

private SecretKey authTokenKey

authTokenMeter

private com.codahale.metrics.Meter authTokenMeter

cleanupHandle

private ScheduledFuture<?> cleanupHandle

clientListMeter

private com.codahale.metrics.Meter clientListMeter

configCache

private com.github.benmanes.caffeine.cache.AsyncLoadingCache<String,Optional<MetaUserConfig>> configCache

configSearchMeter

private com.codahale.metrics.Meter configSearchMeter

configWriteMeter

private com.codahale.metrics.Meter configWriteMeter

failedAttemptMeter

private com.codahale.metrics.Meter failedAttemptMeter

failedTokenMeter

private com.codahale.metrics.Meter failedTokenMeter

groupCache

private com.github.benmanes.caffeine.cache.AsyncLoadingCache<String,Optional<MetaUserGroup>> groupCache

groupSearchMeter

private com.codahale.metrics.Meter groupSearchMeter

groupUpdateMeter

private com.codahale.metrics.Meter groupUpdateMeter

groupWriteMeter

private com.codahale.metrics.Meter groupWriteMeter

loginMeter

private com.codahale.metrics.Meter loginMeter

logoutMeter

private com.codahale.metrics.Meter logoutMeter

otpCache

private com.github.benmanes.caffeine.cache.Cache<String,UserService.OtpChallenge> otpCache

otpExpiredMeter

private com.codahale.metrics.Meter otpExpiredMeter

otpTimer

private com.codahale.metrics.Timer otpTimer

passwordRegex

private Pattern passwordRegex

recoverContact

private UserService.UserServiceContactConfig recoverContact

recoverErrorMeter

private com.codahale.metrics.Meter recoverErrorMeter

recoverMeter

private com.codahale.metrics.Meter recoverMeter

resetContact

private UserService.UserServiceContactConfig resetContact

resetPasswordErrorMeter

private com.codahale.metrics.Meter resetPasswordErrorMeter

resetPasswordMeter

private com.codahale.metrics.Meter resetPasswordMeter

scryptMeter

private com.codahale.metrics.Meter scryptMeter

tokenInvalidationCache

private com.github.benmanes.caffeine.cache.Cache<String,OffsetDateTime> tokenInvalidationCache

tokenKey

private SecretKey tokenKey

tokenMeter

private com.codahale.metrics.Meter tokenMeter

totpMeter

private com.codahale.metrics.Meter totpMeter

userCache

private com.github.benmanes.caffeine.cache.AsyncLoadingCache<String,Optional<UserService.UserCacheEntry>> userCache

userSearchMeter

private com.codahale.metrics.Meter userSearchMeter

userUpdateMeter

private com.codahale.metrics.Meter userUpdateMeter

userValidationCache

private com.github.benmanes.caffeine.cache.Cache<String,UserService.PendingUserValidation> userValidationCache

userWriteMeter

private com.codahale.metrics.Meter userWriteMeter

verifyContact

private UserService.UserServiceContactConfig verifyContact

verifyOtpCache

private com.github.benmanes.caffeine.cache.Cache<String,com.google.common.util.concurrent.SettableFuture<Void>> verifyOtpCache

verifyOtpErrorMeter

private com.codahale.metrics.Meter verifyOtpErrorMeter

verifyOtpMeter

private com.codahale.metrics.Meter verifyOtpMeter

verifyTokenErrorMeter

private com.codahale.metrics.Meter verifyTokenErrorMeter

verifyTokenMeter

private com.codahale.metrics.Meter verifyTokenMeter

webAuthnAssertionCache

private com.github.benmanes.caffeine.cache.Cache<String,com.yubico.webauthn.AssertionRequest> webAuthnAssertionCache

webAuthnRegistrationCache

private com.github.benmanes.caffeine.cache.Cache<String,com.yubico.webauthn.data.PublicKeyCredentialCreationOptions> webAuthnRegistrationCache

webAuthnRelyingParty

private com.yubico.webauthn.RelyingParty webAuthnRelyingParty

webhookAuthReceived

private com.github.benmanes.caffeine.cache.Cache<String,String> webhookAuthReceived

webhookMeter

private com.codahale.metrics.Meter webhookMeter

writeErrorMeter

private com.codahale.metrics.Meter writeErrorMeter

Constructor Details

UserService

@Inject
public UserService(BackupService backupService,
 UserService.UserServiceConfig config,
 GatewayService gatewayService,
 @Named("User")
 LuceneService luceneService,
 EngineRuntime runtime)

Method Details

startUp

protected void startUp()
                throws Exception

Overrides:

startUp in class AbstractEngineIdleService<UserService.UserServiceConfig>

Throws:

Exception

deleteDisconnectedClientIds

private void deleteDisconnectedClientIds()

decrementFailedAttempts

private void decrementFailedAttempts()

shutDown

protected void shutDown()
                 throws Exception

Overrides:

shutDown in class AbstractEngineIdleService<UserService.UserServiceConfig>

Throws:

Exception

login

public com.google.common.util.concurrent.ListenableFuture<LoginReply> login(String clientId,
 String ipAddress,
 LoginRequest request)

sanitizeClientNameOrVersion

private static String sanitizeClientNameOrVersion(String s)

loginWithPassword

private com.google.common.util.concurrent.ListenableFuture<LoginReply> loginWithPassword(String clientId,
 String ipAddress,
 @Nullable String locale,
 @Nullable String password,
 @Nullable String login)

verifyPassword

private boolean verifyPassword(@Nullable String password,
 MetaUser user)

startWebAuthnAssertion

private LoginReply.LoginReplyWebAuthnAssertionRequest startWebAuthnAssertion(String clientId,
 String user)

loginWithToken

private com.google.common.util.concurrent.ListenableFuture<LoginReply> loginWithToken(String clientId,
 String ipAddress,
 String token)

auth

public com.google.common.util.concurrent.ListenableFuture<AuthReply> auth(String clientId,
 String ipAddress,
 AuthRequest request,
 String user)

finishWebAuthnAssertion

private Optional<ErrorReply> finishWebAuthnAssertion(AuthRequest.AuthRequestWebAuthnAssertionReply assertionReply,
 String clientId,
 @Nullable String ipAddress,
 String user)

loadUserConfigs

private com.google.common.util.concurrent.ListenableFuture<UserService.UserConfigResult> loadUserConfigs(Set<String> groups,
 String user)

startWebhookAuth

public com.google.common.util.concurrent.ListenableFuture<String> startWebhookAuth(String authRef)
                                                                            throws ErrorReplyException

Throws:

ErrorReplyException

verifyWebhookAuth

public void verifyWebhookAuth(String authRef,
 String otp)
                       throws ErrorReplyException

Throws:

ErrorReplyException

authToken

public com.google.common.util.concurrent.ListenableFuture<AuthTokenReply> authToken(String clientId,
 String ipAddress,
 AuthTokenRequest request,
 String user)
                                                                             throws ErrorReplyException

Throws:

ErrorReplyException

generateUserToken

public com.google.common.util.concurrent.ListenableFuture<UserService.UserTokenReply> generateUserToken(@Nullable String clientId,
 String ipAddress,
 UserService.UserTokenRequest request)
                                                                                                 throws ErrorReplyException

generateUserToken authenticates the given user/password and generates a token containing all grants for user and its groups. Use this for system/technical users with limited permissions.

Throws:

ErrorReplyException - missing user name, user has OTP/WebAuthn or authentication fails

generateToken

public String generateToken(UserService.TokenRequest request)
                     throws ErrorReplyException

Throws:

ErrorReplyException

verifyToken

public UserService.VerifyTokenReply verifyToken(@Nullable String clientId,
 String ipAddress,
 UserService.VerifyTokenRequest request)

hasRequiredGrants

private static boolean hasRequiredGrants(io.jsonwebtoken.Claims claims,
 @Nullable Map<String,Integer> requiredGrants)

startVerifyOtp

public com.google.common.util.concurrent.ListenableFuture<Void> startVerifyOtp(String clientId,
 @Nullable UserService.UserServiceContactConfig contact,
 String ipAddress,
 @Nullable String locale,
 String user,
 MetaUser.MetaUserOtp userOtp)

startOtpChallenge

private com.google.common.util.concurrent.ListenableFuture<Void> startOtpChallenge(String clientId,
 UserService.UserServiceContactConfig contact,
 String ipAddress,
 @Nullable String locale,
 UserService.OtpChallengeType type,
 String user,
 MetaUser.MetaUserOtp userOtp)

verifyOtp

public Optional<ErrorReply> verifyOtp(String clientId,
 String ipAddress,
 String otp,
 String user)

verifyOtpChallenge

private Optional<ErrorReply> verifyOtpChallenge(String clientId,
 String ipAddress,
 String otp,
 UserService.OtpChallengeType type,
 String user)

recordFailedAttempt

public void recordFailedAttempt(@Nullable String clientId,
 @Nullable String ipAddress,
 String source,
 @Nullable String user)

checkAttempts

public Optional<ErrorReplyException> checkAttempts(String... identifiers)

checkAttempts

private Optional<ErrorReplyException> checkAttempts(int attempts,
 String identifier)

generateScryptOtp

public static UserService.GeneratedOtp generateScryptOtp(int scryptCpu,
 int scryptMemory)

sanitizeOtp

private static String sanitizeOtp(String otp)

verifyScryptOtp

public boolean verifyScryptOtp(@Nullable String hash,
 @Nullable String otp)

verifyTotp

public boolean verifyTotp(String totpKey,
 @Nullable String totp)

generateTotpKey

public static String generateTotpKey()

verifyTotp

public static boolean verifyTotp(int acceptedCodes,
 String totpKey,
 @Nullable String totp)

verifyTotp generates codes from the given key and compares them to the given totp.

Parameters:

acceptedCodes - number of accepted codes. 1 = only the current code is accepted, 2 = current and one past code is accepted, and so on. One future code is always accepted

generateTotp

public static String generateTotp(long offset,
 String totpKey)

generateTotp generates a totp from the given key based on the current time plus offset.

Parameters:

offset - positive or negative time step offset. 0 = current time step, 1 = future time step, and so on. Time step is based on TOTP_VALIDITY

See Also:

• TOTP.generateTOTP(String, String, String)

generateScryptHash

public static String generateScryptHash(int cpu,
 int memory,
 String secret)

verifyScryptHash

public boolean verifyScryptHash(@Nullable String hash,
 @Nullable String secret)

logout

public com.google.common.util.concurrent.ListenableFuture<LogoutReply> logout(String clientId,
 LogoutRequest request)

recoverUser

public com.google.common.util.concurrent.ListenableFuture<RecoverUserReply> recoverUser(String clientId,
 String ipAddress,
 RecoverUserRequest request)

lookupUserByPhoneAndEmail

private com.google.common.util.concurrent.ListenableFuture<Set<String>> lookupUserByPhoneAndEmail(String email,
 String phone)

forgeEmailAndPhoneQuery

private String forgeEmailAndPhoneQuery(@Nullable String email,
 String emailField,
 @Nullable String phone,
 String phoneField)

resetPassword

public com.google.common.util.concurrent.ListenableFuture<ResetPasswordReply> resetPassword(String clientId,
 String ipAddress,
 ResetPasswordRequest request)

getClientList

public com.google.common.util.concurrent.ListenableFuture<ClientListReply> getClientList(ClientListRequest request)

updateClientList

public void updateClientList(ClientListEntry entry)

userSearch

public com.google.common.util.concurrent.ListenableFuture<UserSearchReply> userSearch(UserSearchRequest request)

userSearchInternal

protected com.google.common.util.concurrent.ListenableFuture<UserSearchReply> userSearchInternal(boolean mask,
 UserSearchRequest request)

executeLuceneUserSearch

private LuceneService.SearchResult executeLuceneUserSearch(LuceneService.LuceneContext context,
 UserSearchRequest request)
                                                    throws org.apache.lucene.queryparser.flexible.core.QueryNodeException,
IOException

Throws:

org.apache.lucene.queryparser.flexible.core.QueryNodeException

IOException

newUserSearchReply

private UserSearchReply newUserSearchReply(boolean mask,
 LuceneService.SearchResult result)

getCredentialIdsForUsername

public Set<com.yubico.webauthn.data.PublicKeyCredentialDescriptor> getCredentialIdsForUsername(String username)

Specified by:

getCredentialIdsForUsername in interface com.yubico.webauthn.CredentialRepository

getUserHandleForUsername

public Optional<com.yubico.webauthn.data.ByteArray> getUserHandleForUsername(String username)

Specified by:

getUserHandleForUsername in interface com.yubico.webauthn.CredentialRepository

getUsernameForUserHandle

public Optional<String> getUsernameForUserHandle(com.yubico.webauthn.data.ByteArray userHandle)

Specified by:

getUsernameForUserHandle in interface com.yubico.webauthn.CredentialRepository

lookup

public Optional<com.yubico.webauthn.RegisteredCredential> lookup(com.yubico.webauthn.data.ByteArray credentialId,
 com.yubico.webauthn.data.ByteArray userHandle)

Specified by:

lookup in interface com.yubico.webauthn.CredentialRepository

findUserForHandle

private Optional<MetaUser> findUserForHandle(com.yubico.webauthn.data.ByteArray userHandle)

lookupAll

public Set<com.yubico.webauthn.RegisteredCredential> lookupAll(com.yubico.webauthn.data.ByteArray credentialId)

Specified by:

lookupAll in interface com.yubico.webauthn.CredentialRepository

userWrite

public com.google.common.util.concurrent.ListenableFuture<UserWriteReply> userWrite(@Nullable String clientId,
 boolean enforce,
 @Nullable String ipAddress,
 UserWriteRequest request)

userWrite processes UserWriteRequest. Some write operations require a second call to userWrite with additional parameters.

For WebAuthn, a second request is required with a valid UserWriteRequest.UserWriteRequestWebAuthnReply.

Parameters:

clientId - optional, if provided and MetaUser.MetaUserOtp has changed, a second request for OTP verification is required

enforce - if true, then any UserService.UserServiceEnforceConfig options are going to be enforced

ipAddress - optional, must be provied together with clientId for OTP verification

userWriteInternal

protected com.google.common.util.concurrent.ListenableFuture<UserWriteReply> userWriteInternal(@Nullable String clientId,
 boolean enforce,
 boolean hashed,
 @Nullable String ipAddress,
 boolean mask,
 UserWriteRequest request)

validateUserWrite

private UserService.UserWriteValidationResult validateUserWrite(@Nullable String clientId,
 boolean enforce,
 boolean hashed,
 @Nullable String ipAddress,
 UserWriteRequest request,
 MetaUser user,
 @Nullable UserService.UserCacheEntry cacheEntry,
 String userName)

validatePassword

private static UserService.PasswordValidation validatePassword(String existingPassword,
 boolean hashed,
 String password,
 @Nullable Pattern passwordRegex,
 int scryptCpu,
 int scryptMemory)

validateUserOtp

private static UserService.OtpValidation validateUserOtp(@Nullable UserService.UserServiceEnforceConfig enforceConfig,
 @Nullable MetaUser.MetaUserOtp existingUserOtp,
 boolean hashed,
 @Nullable UserService.PendingUserValidation pendingUserValidation,
 @Nullable MetaUser.MetaUserOtp userOtp)

sanitizeWebAuthnDisplayName

private static @Nullable String sanitizeWebAuthnDisplayName(String displayName)

newMaskedUser

private static @Nullable MetaUser newMaskedUser(@Nullable MetaUser user)

newMaskedWebAuthn

private static @Nullable MetaUser.MetaUserWebAuthn newMaskedWebAuthn(@Nullable MetaUser.MetaUserWebAuthn webAuthn)

processUserWrite

private com.google.common.util.concurrent.ListenableFuture<UserWriteReply> processUserWrite(UserWriteRequest request)

startWebAuthnRegistration

private UserWriteReply.UserWriteReplyWebAuthnRequest startWebAuthnRegistration(String displayName,
 @Nullable String existingUserHandle,
 String user)

finishWebAuthnRegistration

private Optional<MetaUser.MetaUserWebAuthn> finishWebAuthnRegistration(UserWriteRequest.UserWriteRequestWebAuthnReply createReply,
 String user)

deleteConfigs

private com.google.common.util.concurrent.ListenableFuture<Void> deleteConfigs(String query)

userWriteUpdate

public com.google.common.util.concurrent.ListenableFuture<UserWriteUpdateReply> userWriteUpdate(UserWriteUpdateRequest request)

processUserWriteUpdate

private com.google.common.util.concurrent.ListenableFuture<UserWriteUpdateReply> processUserWriteUpdate(UserWriteUpdateRequest request)

writeUser

private void writeUser(WriteAction action,
 @Nullable org.apache.lucene.document.Document document,
 String userName,
 org.apache.lucene.index.IndexWriter writer)

updateUserCache

private void updateUserCache(String user)

groupSearch

public com.google.common.util.concurrent.ListenableFuture<UserGroupSearchReply> groupSearch(UserGroupSearchRequest request)

executeLuceneGroupSearch

private LuceneService.SearchResult executeLuceneGroupSearch(LuceneService.LuceneContext context,
 UserGroupSearchRequest request)
                                                     throws org.apache.lucene.queryparser.flexible.core.QueryNodeException,
IOException

Throws:

org.apache.lucene.queryparser.flexible.core.QueryNodeException

IOException

newGroupSearchReply

private UserGroupSearchReply newGroupSearchReply(LuceneService.SearchResult result)

groupWrite

public com.google.common.util.concurrent.ListenableFuture<UserGroupWriteReply> groupWrite(UserGroupWriteRequest request)

processGroupWrite

private com.google.common.util.concurrent.ListenableFuture<UserGroupWriteReply> processGroupWrite(UserGroupWriteRequest request)

groupWriteUpdate

public com.google.common.util.concurrent.ListenableFuture<UserGroupWriteUpdateReply> groupWriteUpdate(UserGroupWriteUpdateRequest request)

processGroupWriteUpdate

private com.google.common.util.concurrent.ListenableFuture<UserGroupWriteUpdateReply> processGroupWriteUpdate(UserGroupWriteUpdateRequest request)

writeGroup

private void writeGroup(WriteAction action,
 @Nullable MetaUserGroup existingGroup,
 MetaUserGroup group,
 org.apache.lucene.index.IndexWriter writer)

configSearch

public com.google.common.util.concurrent.ListenableFuture<UserConfigSearchReply> configSearch(UserConfigSearchRequest request)

configWrite

public com.google.common.util.concurrent.ListenableFuture<UserConfigWriteReply> configWrite(UserConfigWriteRequest request)

processConfigWrite

private com.google.common.util.concurrent.ListenableFuture<UserConfigWriteReply> processConfigWrite(UserConfigWriteRequest request)

hasUserPermission

public com.google.common.util.concurrent.ListenableFuture<Boolean> hasUserPermission(int permission,
 String userName,
 String... keys)

hasUserPermission checks if user has required permission for at least onf of keys.

isMember

public com.google.common.util.concurrent.ListenableFuture<Boolean> isMember(String groupName,
 String userName)

getCachedConfig

public com.google.common.util.concurrent.ListenableFuture<Optional<MetaUserConfig>> getCachedConfig(String configId)

getCachedGroup

public com.google.common.util.concurrent.ListenableFuture<Optional<MetaUserGroup>> getCachedGroup(String group)

getCachedUser

public com.google.common.util.concurrent.ListenableFuture<Optional<UserService.UserCacheEntry>> getCachedUser(String user)

configSearchRecursive

public static com.google.common.util.concurrent.ListenableFuture<Void> configSearchRecursive(Executor executor,
 Function<UserConfigSearchReply,com.google.common.util.concurrent.ListenableFuture<?>> replyConsumer,
 UserConfigSearchRequest request,
 Function<UserConfigSearchRequest,com.google.common.util.concurrent.ListenableFuture<UserConfigSearchReply>> service)

groupSearchRecursive

public static com.google.common.util.concurrent.ListenableFuture<Void> groupSearchRecursive(Executor executor,
 Function<UserGroupSearchReply,com.google.common.util.concurrent.ListenableFuture<?>> replyConsumer,
 UserGroupSearchRequest request,
 Function<UserGroupSearchRequest,com.google.common.util.concurrent.ListenableFuture<UserGroupSearchReply>> service)

userSearchRecursive

public static com.google.common.util.concurrent.ListenableFuture<Void> userSearchRecursive(Executor executor,
 Function<UserSearchReply,com.google.common.util.concurrent.ListenableFuture<?>> replyConsumer,
 UserSearchRequest request,
 Function<UserSearchRequest,com.google.common.util.concurrent.ListenableFuture<UserSearchReply>> service)