Class NodePlayerManager

java.lang.Object

eu.cloudnetservice.modules.bridge.node.player.NodePlayerManager

All Implemented Interfaces:

PlayerManager

@Singleton
@Provides(PlayerManager.class)
public class NodePlayerManager
extends Object
implements PlayerManager

Field Summary

Fields

Modifier and Type	Field	Description
protected final PlayerProvider	allPlayerProvider
protected final eu.cloudnetservice.node.command.CommandProvider	commandProvider
protected final String	databaseName
protected final eu.cloudnetservice.driver.event.EventManager	eventManager
protected final eu.cloudnetservice.node.database.NodeDatabaseProvider	nodeDatabaseProvider
protected final com.github.benmanes.caffeine.cache.LoadingCache<UUID,Optional<CloudOfflinePlayer>>	offlinePlayerCache
protected final Map<UUID,CloudPlayer>	onlinePlayers
protected final com.google.common.util.concurrent.Striped<Lock>	playerReadWriteLocks

Constructor Summary

Constructors

Constructor

Description

NodePlayerManager(@NonNull eu.cloudnetservice.driver.event.EventManager eventManager, @NonNull eu.cloudnetservice.driver.network.rpc.factory.RPCFactory providerFactory, @NonNull eu.cloudnetservice.node.command.CommandProvider commandProvider, @NonNull eu.cloudnetservice.node.cluster.sync.DataSyncRegistry dataSyncRegistry, @NonNull eu.cloudnetservice.driver.network.rpc.handler.RPCHandlerRegistry handlerRegistry, @NonNull eu.cloudnetservice.node.database.NodeDatabaseProvider nodeDatabaseProvider)

Method Summary

Modifier and Type	Method	Description
protected @NonNull eu.cloudnetservice.node.database.LocalDatabase	database()
void	deleteCloudOfflinePlayer(@NonNull CloudOfflinePlayer cloudOfflinePlayer)	Deletes the given offline player from the database, the local cache of the node and calls the deletion in the cluster.
@NonNull List<CloudPlayer>	environmentOnlinePlayers(@NonNull eu.cloudnetservice.driver.service.ServiceEnvironmentType environment)	Gets all online cloud players that are connected to a service of given service environment.
@Nullable CloudOfflinePlayer	firstOfflinePlayer(@NonNull String name)	Gets the first registered offline player that has the given name.
@Nullable CloudPlayer	firstOnlinePlayer(@NonNull String name)	Gets the first cloud player that is online and has the given case-insensitive name.
@NonNull CloudOfflinePlayer	getOrRegisterOfflinePlayer(@NonNull NetworkPlayerProxyInfo proxyInfo)
@NonNull PlayerExecutor	globalPlayerExecutor()	Gets the jvm static player executor for all players that are connected to the network.
@NonNull PlayerProvider	groupOnlinePlayers(@NonNull String group)	Gets a player provider that provides access to all players that are connected to a service with the group with the given name.
void	loginPlayer(@NonNull NetworkPlayerProxyInfo networkPlayerProxyInfo, @Nullable NetworkServiceInfo joinedServiceInfo)
protected void	loginPlayer0(@NonNull NetworkPlayerProxyInfo networkPlayerProxyInfo, @Nullable NetworkServiceInfo joinedServiceInfo)
void	logoutPlayer(@NonNull CloudPlayer cloudPlayer)
void	logoutPlayer(@Nullable UUID uniqueId, @Nullable String name, @Nullable Predicate<CloudPlayer> tester)
private void	logoutPlayer0(@NonNull CloudPlayer cloudPlayer)
@Nullable CloudOfflinePlayer	offlinePlayer(@NonNull UUID uniqueId)	Gets the offline player associated with the given unique id.
@NonNull List<CloudOfflinePlayer>	offlinePlayers(@NonNull String name)	Gets all registered cloud players that have the given case-sensitive name.
int	onlineCount()	Gets the amount of online players connected to the cloudnet network.
@Nullable CloudPlayer	onlinePlayer(@NonNull UUID uniqueId)	Gets an online cloud player by its unique id from the cache on the node.
@NonNull PlayerProvider	onlinePlayers()	Gets a player provider that provides access to all players that are connected to the cloudnet network.
@NonNull List<CloudPlayer>	onlinePlayers(@NonNull String name)	Gets all online cloud players that have the given case-insensitive name.
@NonNull PlayerExecutor	playerExecutor(@NonNull UUID uniqueId)	Creates a new player executor for the player associated with the given unique id.
@NonNull Map<UUID,CloudPlayer>	players()
protected void	processLogin(@NonNull CloudPlayer cloudPlayer)
void	processLoginMessage(@NonNull CloudPlayer cloudPlayer)
void	pushOfflinePlayerCache(@NonNull UUID uniqueId, @Nullable CloudOfflinePlayer cloudOfflinePlayer)
void	pushOnlinePlayerCache(@NonNull CloudPlayer cloudPlayer)
long	registeredCount()	Gets the amount of registered players in the database.
@NonNull List<CloudOfflinePlayer>	registeredPlayers()	Gets a list with all registered players from the database.
private void	registerListeners()
private void	registerPlayerCommand()
protected @NonNull CloudPlayer	selectPlayerForLogin(@NonNull NetworkPlayerProxyInfo connectionInfo, @Nullable NetworkServiceInfo joinedServiceInfo)
@NonNull PlayerProvider	taskOnlinePlayers(@NonNull String task)	Gets a player provider that provides access to all players that are connected to a service of the task with the given name.
void	updateOfflinePlayer(@NonNull CloudOfflinePlayer player)	Updates the given cloud offline player in the database, in the local cache of the node and calls the update in the cluster.
void	updateOnlinePlayer(@NonNull CloudPlayer cloudPlayer)	Updates the given cloud online player in the cache and calls the update in the cluster.

Methods inherited from class java.lang.Object

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

Methods inherited from interface eu.cloudnetservice.modules.bridge.player.PlayerManager

deleteCloudOfflinePlayerAsync, firstOfflinePlayerAsync, firstOnlinePlayerAsync, offlinePlayerAsync, offlinePlayerAsync, onlineCountAsync, onlinePlayerAsync, onlinePlayerAsync, onlinePlayerAsync, registeredCountAsync, updateOfflinePlayerAsync, updateOnlinePlayerAsync

Field Details

databaseName

protected final String databaseName

eventManager

protected final eu.cloudnetservice.driver.event.EventManager eventManager

commandProvider

protected final eu.cloudnetservice.node.command.CommandProvider commandProvider

nodeDatabaseProvider

protected final eu.cloudnetservice.node.database.NodeDatabaseProvider nodeDatabaseProvider

onlinePlayers

protected final Map<UUID,CloudPlayer> onlinePlayers

allPlayerProvider

protected final PlayerProvider allPlayerProvider

playerReadWriteLocks

protected final com.google.common.util.concurrent.Striped<Lock> playerReadWriteLocks

offlinePlayerCache

protected final com.github.benmanes.caffeine.cache.LoadingCache<UUID,Optional<CloudOfflinePlayer>> offlinePlayerCache

Constructor Details

NodePlayerManager

@Inject
public NodePlayerManager(@NonNull
 @NonNull eu.cloudnetservice.driver.event.EventManager eventManager,
 @NonNull
 @NonNull eu.cloudnetservice.driver.network.rpc.factory.RPCFactory providerFactory,
 @NonNull
 @NonNull eu.cloudnetservice.node.command.CommandProvider commandProvider,
 @NonNull
 @NonNull eu.cloudnetservice.node.cluster.sync.DataSyncRegistry dataSyncRegistry,
 @NonNull
 @NonNull eu.cloudnetservice.driver.network.rpc.handler.RPCHandlerRegistry handlerRegistry,
 @NonNull
 @NonNull eu.cloudnetservice.node.database.NodeDatabaseProvider nodeDatabaseProvider)

Method Details

registerPlayerCommand

@PostConstruct
private void registerPlayerCommand()

registerListeners

@PostConstruct
private void registerListeners()

onlineCount

public int onlineCount()

Description copied from interface: PlayerManager

Gets the amount of online players connected to the cloudnet network.

Specified by:

onlineCount in interface PlayerManager

Returns:

the online player count.

registeredCount

public long registeredCount()

Description copied from interface: PlayerManager

Gets the amount of registered players in the database.

Specified by:

registeredCount in interface PlayerManager

Returns:

the registered player count.

onlinePlayer

@Nullable
public @Nullable CloudPlayer onlinePlayer(@NonNull
 @NonNull UUID uniqueId)

Description copied from interface: PlayerManager

Gets an online cloud player by its unique id from the cache on the node.

The online player is cached on the node until the player disconnects.

Specified by:

onlinePlayer in interface PlayerManager

Parameters:

uniqueId - the unique id of the player.

Returns:

the online cloud player or null if the player is not online.

firstOnlinePlayer

@Nullable
public @Nullable CloudPlayer firstOnlinePlayer(@NonNull
 @NonNull String name)

Description copied from interface: PlayerManager

Gets the first cloud player that is online and has the given case-insensitive name.

All online players are cached on the node while they are online.

Specified by:

firstOnlinePlayer in interface PlayerManager

Parameters:

name - the name of the cloud player.

Returns:

the first cloud player with the given name, null if no player was found.

onlinePlayers

@NonNull
public @NonNull List<CloudPlayer> onlinePlayers(@NonNull
 @NonNull String name)

Description copied from interface: PlayerManager

Gets all online cloud players that have the given case-insensitive name.

All online players are cached on the node while they are online.

Specified by:

onlinePlayers in interface PlayerManager

Parameters:

name - the name of the cloud players.

Returns:

a list of all online players with the given name.

environmentOnlinePlayers

@NonNull
public @NonNull List<CloudPlayer> environmentOnlinePlayers(@NonNull
 @NonNull eu.cloudnetservice.driver.service.ServiceEnvironmentType environment)

Description copied from interface: PlayerManager

Gets all online cloud players that are connected to a service of given service environment.

All online players are cached on the node while they are online.

Specified by:

environmentOnlinePlayers in interface PlayerManager

Parameters:

environment - the environment to get all players for.

Returns:

a list of all cloud players connected to a service of the given service environment.

onlinePlayers

@NonNull
public @NonNull PlayerProvider onlinePlayers()

Description copied from interface: PlayerManager

Gets a player provider that provides access to all players that are connected to the cloudnet network.

Specified by:

onlinePlayers in interface PlayerManager

Returns:

the player provider for all online players.

taskOnlinePlayers

@NonNull
public @NonNull PlayerProvider taskOnlinePlayers(@NonNull
 @NonNull String task)

Description copied from interface: PlayerManager

Gets a player provider that provides access to all players that are connected to a service of the task with the given name.

Specified by:

taskOnlinePlayers in interface PlayerManager

Parameters:

task - the task of the service the player has to be connected to.

Returns:

the player provider for the given task.

groupOnlinePlayers

@NonNull
public @NonNull PlayerProvider groupOnlinePlayers(@NonNull
 @NonNull String group)

Description copied from interface: PlayerManager

Gets a player provider that provides access to all players that are connected to a service with the group with the given name.

Specified by:

groupOnlinePlayers in interface PlayerManager

Parameters:

group - the group of the service the player has to be connected to.

Returns:

the player provider for the given group.

offlinePlayer

@Nullable
public @Nullable CloudOfflinePlayer offlinePlayer(@NonNull
 @NonNull UUID uniqueId)

Description copied from interface: PlayerManager

Gets the offline player associated with the given unique id. The player must have been previously connected.

The cloud offline player is cached on the node and retrieved from the cache if present otherwise loaded from the database.

Specified by:

offlinePlayer in interface PlayerManager

Parameters:

uniqueId - the unique id of the offline player.

Returns:

the offline player with the given unique id or null if there is no player.

firstOfflinePlayer

@Nullable
public @Nullable CloudOfflinePlayer firstOfflinePlayer(@NonNull
 @NonNull String name)

Description copied from interface: PlayerManager

Gets the first registered offline player that has the given name. The player must have been previously connected. If the player is cached on the corresponding node which is handling the method call, then the given name check will be done case-insensitive against the underlying cache, if the player data must be queried from the database then this check is case-sensitive.

Specified by:

firstOfflinePlayer in interface PlayerManager

Parameters:

name - the name of the registered player.

Returns:

the first offline player with the given name or null if there is no player with the name.

offlinePlayers

@NonNull
public @NonNull List<CloudOfflinePlayer> offlinePlayers(@NonNull
 @NonNull String name)

Description copied from interface: PlayerManager

Gets all registered cloud players that have the given case-sensitive name. The player must have been previously connected.

Specified by:

offlinePlayers in interface PlayerManager

Parameters:

name - the name of the registered cloud players.

Returns:

a list of all registered players with the given name.

registeredPlayers

@NonNull
public @NonNull List<CloudOfflinePlayer> registeredPlayers()

Description copied from interface: PlayerManager

Gets a list with all registered players from the database.

This method should not be used if the database contains a lot of registered players. It can happen that the entire heap of the cloud is used up by this method and therefore errors occur.

Specified by:

registeredPlayers in interface PlayerManager

Returns:

a list of all registered players.

updateOfflinePlayer

public void updateOfflinePlayer(@NonNull
 @NonNull CloudOfflinePlayer player)

Description copied from interface: PlayerManager

Updates the given cloud offline player in the database, in the local cache of the node and calls the update in the cluster.

Specified by:

updateOfflinePlayer in interface PlayerManager

Parameters:

player - the offline player to update.

updateOnlinePlayer

public void updateOnlinePlayer(@NonNull
 @NonNull CloudPlayer cloudPlayer)

Description copied from interface: PlayerManager

Updates the given cloud online player in the cache and calls the update in the cluster.

Specified by:

updateOnlinePlayer in interface PlayerManager

Parameters:

cloudPlayer - the cloud player to update.

deleteCloudOfflinePlayer

public void deleteCloudOfflinePlayer(@NonNull
 @NonNull CloudOfflinePlayer cloudOfflinePlayer)

Description copied from interface: PlayerManager

Deletes the given offline player from the database, the local cache of the node and calls the deletion in the cluster.

Specified by:

deleteCloudOfflinePlayer in interface PlayerManager

Parameters:

cloudOfflinePlayer - the offline player to delete.

globalPlayerExecutor

@NonNull
public @NonNull PlayerExecutor globalPlayerExecutor()

Description copied from interface: PlayerManager

Gets the jvm static player executor for all players that are connected to the network. All methods account for all connected players.

Specified by:

globalPlayerExecutor in interface PlayerManager

Returns:

the global player executor for all players.

playerExecutor

@NonNull
public @NonNull PlayerExecutor playerExecutor(@NonNull
 @NonNull UUID uniqueId)

Description copied from interface: PlayerManager

Creates a new player executor for the player associated with the given unique id. The player executor is created even if there is no online player with the given unique id.

Specified by:

playerExecutor in interface PlayerManager

Parameters:

uniqueId - the unique id of the player for the new player executor.

Returns:

the player executor for the given player.

pushOfflinePlayerCache

public void pushOfflinePlayerCache(@NonNull
 @NonNull UUID uniqueId,
 @Nullable
 @Nullable CloudOfflinePlayer cloudOfflinePlayer)

pushOnlinePlayerCache

public void pushOnlinePlayerCache(@NonNull
 @NonNull CloudPlayer cloudPlayer)

database

@NonNull
protected @NonNull eu.cloudnetservice.node.database.LocalDatabase database()

players

@NonNull
public @NonNull Map<UUID,CloudPlayer> players()

loginPlayer

public void loginPlayer(@NonNull
 @NonNull NetworkPlayerProxyInfo networkPlayerProxyInfo,
 @Nullable
 @Nullable NetworkServiceInfo joinedServiceInfo)

loginPlayer0

protected void loginPlayer0(@NonNull
 @NonNull NetworkPlayerProxyInfo networkPlayerProxyInfo,
 @Nullable
 @Nullable NetworkServiceInfo joinedServiceInfo)

selectPlayerForLogin

@NonNull
protected @NonNull CloudPlayer selectPlayerForLogin(@NonNull
 @NonNull NetworkPlayerProxyInfo connectionInfo,
 @Nullable
 @Nullable NetworkServiceInfo joinedServiceInfo)

processLogin

protected void processLogin(@NonNull
 @NonNull CloudPlayer cloudPlayer)

processLoginMessage

public void processLoginMessage(@NonNull
 @NonNull CloudPlayer cloudPlayer)

getOrRegisterOfflinePlayer

@NonNull
public @NonNull CloudOfflinePlayer getOrRegisterOfflinePlayer(@NonNull
 @NonNull NetworkPlayerProxyInfo proxyInfo)

logoutPlayer

public void logoutPlayer(@NonNull
 @NonNull CloudPlayer cloudPlayer)

logoutPlayer0

private void logoutPlayer0(@NonNull
 @NonNull CloudPlayer cloudPlayer)

logoutPlayer

@Contract("!null, !null, _ -> _; !null, null, _ -> _; null, !null, _ -> _; null, null, _ -> fail")
public void logoutPlayer(@Nullable
 @Nullable UUID uniqueId,
 @Nullable
 @Nullable String name,
 @Nullable
 @Nullable Predicate<CloudPlayer> tester)