Package me.confuser.banmanager.common.storage

Class PlayerMuteStorage

java.lang.Object

me.confuser.banmanager.common.ormlite.dao.BaseDaoImpl<PlayerMuteData,Integer>

me.confuser.banmanager.common.storage.BaseStorage<PlayerMuteData,Integer>

me.confuser.banmanager.common.storage.PlayerMuteStorage

All Implemented Interfaces:

Iterable<PlayerMuteData>, me.confuser.banmanager.common.ormlite.dao.CloseableIterable<PlayerMuteData>, me.confuser.banmanager.common.ormlite.dao.Dao<PlayerMuteData,Integer>

public class PlayerMuteStorage
extends BaseStorage<PlayerMuteData,Integer>

Nested Class Summary

Nested classes/interfaces inherited from interface me.confuser.banmanager.common.ormlite.dao.Dao

me.confuser.banmanager.common.ormlite.dao.Dao.CreateOrUpdateStatus, me.confuser.banmanager.common.ormlite.dao.Dao.DaoObserver

Field Summary

Fields inherited from class me.confuser.banmanager.common.storage.BaseStorage

plugin

Fields inherited from class me.confuser.banmanager.common.ormlite.dao.BaseDaoImpl

connectionSource, databaseType, dataClass, lastIterator, objectFactory, statementExecutor, tableConfig, tableInfo

Constructor Summary

Constructors

Constructor	Description
PlayerMuteStorage(BanManagerPlugin plugin)
PlayerMuteStorage(BanManagerPlugin plugin, me.confuser.banmanager.common.ormlite.support.ConnectionSource connection, me.confuser.banmanager.common.ormlite.table.DatabaseTableConfig<?> table)

Method Summary

Modifier and Type	Method	Description
void	addMute(PlayerMuteData mute)
me.confuser.banmanager.common.ormlite.dao.CloseableIterator<PlayerMuteData>	findMutes(long fromTime)
PlayerMuteData	getMute(String playerName)
PlayerMuteData	getMute(UUID uuid)
ConcurrentHashMap<UUID,PlayerMuteData>	getMutes()
boolean	isMuted(String playerName)
boolean	isMuted(UUID uuid)
boolean	isRecentlyMuted(PlayerData player, long cooldown)
boolean	mute(PlayerMuteData mute)
boolean	mute(PlayerMuteData mute, boolean fromSync)
boolean	pauseMute(PlayerMuteData mute, long remaining)	Pauses an online-only mute when the player goes offline.
void	removeMute(UUID uuid)
void	removeMute(PlayerMuteData mute)
boolean	resumeMute(PlayerMuteData mute)	Resumes an online-only mute when the player comes online.
PlayerMuteData	retrieveMute(UUID uuid)
boolean	unmute(PlayerMuteData mute, PlayerData actor)
boolean	unmute(PlayerMuteData mute, PlayerData actor, String reason)
boolean	unmute(PlayerMuteData mute, PlayerData actor, String reason, boolean skipRecord)
boolean	unmute(PlayerMuteData mute, PlayerData actor, String reason, boolean skipRecord, boolean silent)
boolean	unmuteIfExpired(PlayerMuteData mute, PlayerData actor)	Conditionally unmutes a mute only if it has truly expired (expires > 0 AND expires invalid input: '<'= now).
void	updateMuteState(PlayerMuteData mute)	Updates the in-memory mute state without firing PlayerMutedEvent.

Methods inherited from class me.confuser.banmanager.common.storage.BaseStorage

create, createPreservingTimestamps, getBmTableName, getDatabaseConfig, hasUpdatedColumn, update, updatePreservingTimestamps

Methods inherited from class me.confuser.banmanager.common.ormlite.dao.BaseDaoImpl

assignEmptyForeignCollection, callBatchTasks, checkForInitialized, clearAllInternalObjectCaches, clearObjectCache, closeableIterator, closeLastIterator, commit, countOf, countOf, create, createIfNotExists, createOrUpdate, delete, delete, delete, deleteBuilder, deleteById, deleteIds, endThreadConnection, executeRaw, executeRawNoArgs, extractId, findForeignFieldType, getConnectionSource, getDataClass, getEmptyForeignCollection, getObjectCache, getObjectFactory, getRawRowMapper, getSelectStarRowMapper, getTableConfig, getTableInfo, getTableName, getWrappedIterable, getWrappedIterable, idExists, initialize, isAutoCommit, isTableExists, isUpdatable, iterator, iterator, iterator, iterator, mapSelectStarRow, notifyChanges, objectsEqual, objectToString, query, queryBuilder, queryForAll, queryForEq, queryForFieldValues, queryForFieldValuesArgs, queryForFirst, queryForId, queryForMatching, queryForMatchingArgs, queryForSameId, queryRaw, queryRaw, queryRaw, queryRaw, queryRaw, queryRawValue, refresh, registerObserver, rollBack, setAutoCommit, setConnectionSource, setObjectCache, setObjectCache, setObjectFactory, setTableConfig, startThreadConnection, unregisterObserver, update, updateBuilder, updateId, updateRaw

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Details

PlayerMuteStorage

public PlayerMuteStorage(BanManagerPlugin plugin)
                  throws SQLException

Throws:

SQLException

PlayerMuteStorage

public PlayerMuteStorage(BanManagerPlugin plugin,
 me.confuser.banmanager.common.ormlite.support.ConnectionSource connection,
 me.confuser.banmanager.common.ormlite.table.DatabaseTableConfig<?> table)
                  throws SQLException

Throws:

SQLException

Method Details

getMutes

public ConcurrentHashMap<UUID,PlayerMuteData> getMutes()

isMuted

public boolean isMuted(UUID uuid)

retrieveMute

public PlayerMuteData retrieveMute(UUID uuid)
                            throws SQLException

Throws:

SQLException

isMuted

public boolean isMuted(String playerName)

getMute

public PlayerMuteData getMute(UUID uuid)

getMute

public PlayerMuteData getMute(String playerName)

addMute

public void addMute(PlayerMuteData mute)

updateMuteState

public void updateMuteState(PlayerMuteData mute)

Updates the in-memory mute state without firing PlayerMutedEvent. Used for syncing pause/resume state changes from other servers.

Parameters:

mute - the mute with updated state

mute

public boolean mute(PlayerMuteData mute)
             throws SQLException

Throws:

SQLException

mute

public boolean mute(PlayerMuteData mute,
 boolean fromSync)
             throws SQLException

Throws:

SQLException

removeMute

public void removeMute(UUID uuid)

removeMute

public void removeMute(PlayerMuteData mute)

unmute

public boolean unmute(PlayerMuteData mute,
 PlayerData actor)
               throws SQLException

Throws:

SQLException

unmute

public boolean unmute(PlayerMuteData mute,
 PlayerData actor,
 String reason)
               throws SQLException

Throws:

SQLException

unmute

public boolean unmute(PlayerMuteData mute,
 PlayerData actor,
 String reason,
 boolean skipRecord)
               throws SQLException

Throws:

SQLException

unmute

public boolean unmute(PlayerMuteData mute,
 PlayerData actor,
 String reason,
 boolean skipRecord,
 boolean silent)
               throws SQLException

Throws:

SQLException

unmuteIfExpired

public boolean unmuteIfExpired(PlayerMuteData mute,
 PlayerData actor)
                        throws SQLException

Conditionally unmutes a mute only if it has truly expired (expires > 0 AND expires invalid input: '<'= now). This prevents race conditions where a mute is paused (expires set to 0) between the ExpiresSync query and the delete operation. The delete and record creation are performed atomically in a transaction.

Parameters:

mute - the mute to expire

actor - the actor performing the unmute

Returns:

true if the mute was deleted, false if it was already paused/modified or event was cancelled

Throws:

SQLException

findMutes

public me.confuser.banmanager.common.ormlite.dao.CloseableIterator<PlayerMuteData> findMutes(long fromTime)
                                                                                      throws SQLException

Throws:

SQLException

isRecentlyMuted

public boolean isRecentlyMuted(PlayerData player,
 long cooldown)
                        throws SQLException

Throws:

SQLException

pauseMute

public boolean pauseMute(PlayerMuteData mute,
 long remaining)
                  throws SQLException

Pauses an online-only mute when the player goes offline. Uses conditional update with optimistic concurrency (updated timestamp) to prevent race conditions during fast server transfers.

Parameters:

mute - the mute to pause (must have current updated timestamp)

remaining - the remaining seconds to store

Returns:

true if the mute was paused, false if it was already paused, modified, or conditions not met

Throws:

SQLException

resumeMute

public boolean resumeMute(PlayerMuteData mute)
                   throws SQLException

Resumes an online-only mute when the player comes online. Uses conditional update with optimistic concurrency (updated timestamp) to prevent race conditions during fast server transfers. Uses database time (UNIX_TIMESTAMP()) to avoid JVM clock drift issues.

Parameters:

mute - the mute to resume (must have current updated timestamp)

Returns:

true if the mute was resumed, false if it was already active, modified, or conditions not met

Throws:

SQLException