Package dev.unnm3d.redischat.datamanagers

Class RedisDataManager

java.lang.Object

dev.unnm3d.redischat.datamanagers.redistools.RedisAbstract

dev.unnm3d.redischat.datamanagers.RedisDataManager

All Implemented Interfaces:

DataManager

public class RedisDataManager
extends RedisAbstract
implements DataManager

Field Summary

Fields

Modifier and Type	Field	Description
static int	pubSubIndex

Fields inherited from class dev.unnm3d.redischat.datamanagers.redistools.RedisAbstract

lettuceRedisClient

Constructor Summary

Constructors

Constructor	Description
RedisDataManager(io.lettuce.core.RedisClient redisClient, RedisChat redisChat)

Method Summary

Modifier and Type	Method	Description
void	addEnderchest(@NotNull String name, org.bukkit.inventory.ItemStack[] inv)
void	addInventory(@NotNull String name, org.bukkit.inventory.ItemStack[] inv)
void	addItem(@NotNull String name, org.bukkit.inventory.ItemStack item)
void	clearInvShareCache()
void	close()
CompletionStage<Boolean>	deleteMail(@NotNull Mail mail)
CompletionStage<String>	getActivePlayerChannel(@NotNull String playerName, Map<String,Channel> registeredChannels)
CompletionStage<Map<String,Set<String>>>	getAllMutedEntities()
CompletionStage<List<Channel>>	getChannels()
CompletionStage<org.bukkit.inventory.ItemStack[]>	getPlayerEnderchest(@NotNull String playerName)
CompletionStage<org.bukkit.inventory.ItemStack[]>	getPlayerInventory(@NotNull String playerName)
CompletionStage<org.bukkit.inventory.ItemStack>	getPlayerItem(@NotNull String playerName)
CompletionStage<Map<String,String>>	getPlayerPlaceholders(@NotNull String playerName)
CompletionStage<List<Mail>>	getPlayerPrivateMail(@NotNull String playerName)
CompletableFuture<List<Mail>>	getPublicMails(@NotNull String playerName)
CompletionStage<Optional<String>>	getReplyName(@NotNull String requesterName)
CompletionStage<Set<String>>	getWhitelistEnabledPlayers()
boolean	isRateLimited(@NotNull String playerName, @NotNull Channel channel)
CompletionStage<Boolean>	isSpying(@NotNull String playerName)
void	publishPlayerList(@NotNull List<String> playerNames)
void	receiveMessage(String channel, String message)
void	registerChannel(@NotNull Channel channel)
void	sendChatMessage(@NotNull ChatMessage packet)
void	sendRejoin(@NotNull String playerName)
void	setActivePlayerChannel(String playerName, String channelName)
CompletionStage<Boolean>	setMailRead(@NotNull String playerName, @NotNull Mail mail)
void	setMutedEntities(@NotNull String keyEntity, @NotNull Set<String> valueEntities)
void	setPlayerPlaceholders(@NotNull String playerName, @NotNull Map<String,String> placeholders)
CompletionStage<Boolean>	setPlayerPrivateMail(@NotNull Mail mail)
CompletionStage<Boolean>	setPublicMail(@NotNull Mail mail)
void	setReplyName(@NotNull String nameReceiver, @NotNull String requesterName)
void	setSpying(@NotNull String playerName, boolean spy)
void	setWhitelistEnabledPlayer(@NotNull String playerName, boolean enabled)
static RedisDataManager	startup(RedisChat redisChat)
void	unregisterChannel(@NotNull String channelName)

Methods inherited from class dev.unnm3d.redischat.datamanagers.redistools.RedisAbstract

executeTransaction, getConnectionAsync, getConnectionPipeline, registerSub

Methods inherited from class java.lang.Object

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

Methods inherited from interface dev.unnm3d.redischat.api.DataManager

deserialize, deserializePlayerPlaceholders, serialize, serializePlayerPlaceholders

Field Details

pubSubIndex

public static int pubSubIndex

Constructor Details

RedisDataManager

public RedisDataManager(io.lettuce.core.RedisClient redisClient,
 RedisChat redisChat)

Method Details

startup

public static RedisDataManager startup(RedisChat redisChat)

receiveMessage

public void receiveMessage(String channel,
 String message)

Specified by:

receiveMessage in class RedisAbstract

getReplyName

public CompletionStage<Optional<String>> getReplyName(@NotNull
 @NotNull String requesterName)

Specified by:

getReplyName in interface DataManager

setReplyName

public void setReplyName(@NotNull
 @NotNull String nameReceiver,
 @NotNull
 @NotNull String requesterName)

Specified by:

setReplyName in interface DataManager

getPlayerPlaceholders

public CompletionStage<Map<String,String>> getPlayerPlaceholders(@NotNull
 @NotNull String playerName)

Specified by:

getPlayerPlaceholders in interface DataManager

setPlayerPlaceholders

public void setPlayerPlaceholders(@NotNull
 @NotNull String playerName,
 @NotNull
 @NotNull Map<String,String> placeholders)

Specified by:

setPlayerPlaceholders in interface DataManager

isRateLimited

public boolean isRateLimited(@NotNull
 @NotNull String playerName,
 @NotNull
 @NotNull Channel channel)

Specified by:

isRateLimited in interface DataManager

isSpying

public CompletionStage<Boolean> isSpying(@NotNull
 @NotNull String playerName)

Specified by:

isSpying in interface DataManager

setSpying

public void setSpying(@NotNull
 @NotNull String playerName,
 boolean spy)

Specified by:

setSpying in interface DataManager

addInventory

public void addInventory(@NotNull
 @NotNull String name,
 org.bukkit.inventory.ItemStack[] inv)

Specified by:

addInventory in interface DataManager

addItem

public void addItem(@NotNull
 @NotNull String name,
 org.bukkit.inventory.ItemStack item)

Specified by:

addItem in interface DataManager

addEnderchest

public void addEnderchest(@NotNull
 @NotNull String name,
 org.bukkit.inventory.ItemStack[] inv)

Specified by:

addEnderchest in interface DataManager

clearInvShareCache

public void clearInvShareCache()

Specified by:

clearInvShareCache in interface DataManager

getPlayerItem

public CompletionStage<org.bukkit.inventory.ItemStack> getPlayerItem(@NotNull
 @NotNull String playerName)

Specified by:

getPlayerItem in interface DataManager

getPlayerInventory

public CompletionStage<org.bukkit.inventory.ItemStack[]> getPlayerInventory(@NotNull
 @NotNull String playerName)

Specified by:

getPlayerInventory in interface DataManager

getPlayerEnderchest

public CompletionStage<org.bukkit.inventory.ItemStack[]> getPlayerEnderchest(@NotNull
 @NotNull String playerName)

Specified by:

getPlayerEnderchest in interface DataManager

getPlayerPrivateMail

public CompletionStage<List<Mail>> getPlayerPrivateMail(@NotNull
 @NotNull String playerName)

Specified by:

getPlayerPrivateMail in interface DataManager

setPlayerPrivateMail

public CompletionStage<Boolean> setPlayerPrivateMail(@NotNull
 @NotNull Mail mail)

Specified by:

setPlayerPrivateMail in interface DataManager

setPublicMail

public CompletionStage<Boolean> setPublicMail(@NotNull
 @NotNull Mail mail)

Specified by:

setPublicMail in interface DataManager

getPublicMails

public CompletableFuture<List<Mail>> getPublicMails(@NotNull
 @NotNull String playerName)

Specified by:

getPublicMails in interface DataManager

setMailRead

public CompletionStage<Boolean> setMailRead(@NotNull
 @NotNull String playerName,
 @NotNull
 @NotNull Mail mail)

Specified by:

setMailRead in interface DataManager

deleteMail

public CompletionStage<Boolean> deleteMail(@NotNull
 @NotNull Mail mail)

Specified by:

deleteMail in interface DataManager

registerChannel

public void registerChannel(@NotNull
 @NotNull Channel channel)

Specified by:

registerChannel in interface DataManager

unregisterChannel

public void unregisterChannel(@NotNull
 @NotNull String channelName)

Specified by:

unregisterChannel in interface DataManager

getChannels

public CompletionStage<List<Channel>> getChannels()

Specified by:

getChannels in interface DataManager

getActivePlayerChannel

public CompletionStage<String> getActivePlayerChannel(@NotNull
 @NotNull String playerName,
 Map<String,Channel> registeredChannels)

Specified by:

getActivePlayerChannel in interface DataManager

setActivePlayerChannel

public void setActivePlayerChannel(String playerName,
 String channelName)

Specified by:

setActivePlayerChannel in interface DataManager

setMutedEntities

public void setMutedEntities(@NotNull
 @NotNull String keyEntity,
 @NotNull
 @NotNull Set<String> valueEntities)

Specified by:

setMutedEntities in interface DataManager

getAllMutedEntities

public CompletionStage<Map<String,Set<String>>> getAllMutedEntities()

Specified by:

getAllMutedEntities in interface DataManager

getWhitelistEnabledPlayers

public CompletionStage<Set<String>> getWhitelistEnabledPlayers()

Specified by:

getWhitelistEnabledPlayers in interface DataManager

setWhitelistEnabledPlayer

public void setWhitelistEnabledPlayer(@NotNull
 @NotNull String playerName,
 boolean enabled)

Specified by:

setWhitelistEnabledPlayer in interface DataManager

sendChatMessage

public void sendChatMessage(@NotNull
 @NotNull ChatMessage packet)

Specified by:

sendChatMessage in interface DataManager

sendRejoin

public void sendRejoin(@NotNull
 @NotNull String playerName)

Specified by:

sendRejoin in interface DataManager

publishPlayerList

public void publishPlayerList(@NotNull
 @NotNull List<String> playerNames)

Specified by:

publishPlayerList in interface DataManager

close

public void close()

Specified by:

close in interface DataManager

Overrides:

close in class RedisAbstract