Package net.minecraft.server.network

Class ServerTextFilter

java.lang.Object

net.minecraft.server.network.ServerTextFilter

All Implemented Interfaces:

AutoCloseable

Direct Known Subclasses:

LegacyTextFilter, PlayerSafetyServiceTextFilter

public abstract class ServerTextFilter
extends Object
implements AutoCloseable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	ServerTextFilter.IgnoreStrategy
protected static interface	ServerTextFilter.MessageEncoder
protected class	ServerTextFilter.PlayerContext
protected static class	ServerTextFilter.RequestFailedException

Field Summary

Fields

Modifier and Type	Field	Description
private final ServerTextFilter.MessageEncoder	chatEncoder
private final URL	chatEndpoint
(package private) final ServerTextFilter.IgnoreStrategy	chatIgnoreStrategy
protected static final org.slf4j.Logger	LOGGER
private static final ThreadFactory	THREAD_FACTORY
private static final AtomicInteger	WORKER_COUNT
(package private) final ExecutorService	workerPool

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ServerTextFilter(URL pChatEndpoint, ServerTextFilter.MessageEncoder pChatEncoder, ServerTextFilter.IgnoreStrategy pChatIgnoreStrategy, ExecutorService pWorkerPool)

Method Summary

Modifier and Type	Method	Description
void	close()
protected int	connectionReadTimeout()
TextFilter	createContext(com.mojang.authlib.GameProfile pProfile)
static @Nullable ServerTextFilter	createFromConfig(DedicatedServerProperties pConfig)
protected static ExecutorService	createWorkerPool(int pSize)
protected void	drainStream(InputStream pStream)
protected abstract FilteredText	filterText(String pText, ServerTextFilter.IgnoreStrategy pIgnoreStrategy, JsonObject pResponse)
protected static URL	getEndpoint(URI pApiServer, @Nullable JsonObject pJson, String pKey, String pFallback)
protected static String	getEndpointFromConfig(@Nullable JsonObject pJson, String pKey, String pFallback)
protected HttpURLConnection	getURLConnection(URL pUrl)
protected HttpURLConnection	makeRequest(JsonObject pRequest, URL pEndpoint)
protected FilterMask	parseMask(String pText, JsonArray pHashes, ServerTextFilter.IgnoreStrategy pIgnoreStrategy)
private JsonObject	processRequestResponse(JsonObject pRequest, URL pEndpoint)
protected CompletableFuture<FilteredText>	requestMessageProcessing(com.mojang.authlib.GameProfile pProfile, String pFilter, ServerTextFilter.IgnoreStrategy pChatIgnoreStrategy, Executor pStreamExecutor)
protected abstract void	setAuthorizationProperty(HttpURLConnection pConnection)

Methods inherited from class java.lang.Object

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

Field Details

LOGGER

protected static final org.slf4j.Logger LOGGER

WORKER_COUNT

private static final AtomicInteger WORKER_COUNT

THREAD_FACTORY

private static final ThreadFactory THREAD_FACTORY

chatEndpoint

private final URL chatEndpoint

chatEncoder

private final ServerTextFilter.MessageEncoder chatEncoder

chatIgnoreStrategy

final ServerTextFilter.IgnoreStrategy chatIgnoreStrategy

workerPool

final ExecutorService workerPool

Constructor Details

ServerTextFilter

protected ServerTextFilter(URL pChatEndpoint,
 ServerTextFilter.MessageEncoder pChatEncoder,
 ServerTextFilter.IgnoreStrategy pChatIgnoreStrategy,
 ExecutorService pWorkerPool)

Method Details

createWorkerPool

protected static ExecutorService createWorkerPool(int pSize)

getEndpoint

protected static URL getEndpoint(URI pApiServer,
 @Nullable JsonObject pJson,
 String pKey,
 String pFallback)
                          throws MalformedURLException

Throws:

MalformedURLException

getEndpointFromConfig

protected static String getEndpointFromConfig(@Nullable JsonObject pJson,
 String pKey,
 String pFallback)

createFromConfig

public static @Nullable ServerTextFilter createFromConfig(DedicatedServerProperties pConfig)

requestMessageProcessing

protected CompletableFuture<FilteredText> requestMessageProcessing(com.mojang.authlib.GameProfile pProfile,
 String pFilter,
 ServerTextFilter.IgnoreStrategy pChatIgnoreStrategy,
 Executor pStreamExecutor)

filterText

protected abstract FilteredText filterText(String pText,
 ServerTextFilter.IgnoreStrategy pIgnoreStrategy,
 JsonObject pResponse)

parseMask

protected FilterMask parseMask(String pText,
 JsonArray pHashes,
 ServerTextFilter.IgnoreStrategy pIgnoreStrategy)

close

public void close()

Specified by:

close in interface AutoCloseable

drainStream

protected void drainStream(InputStream pStream)
                    throws IOException

Throws:

IOException

processRequestResponse

private JsonObject processRequestResponse(JsonObject pRequest,
 URL pEndpoint)
                                   throws IOException

Throws:

IOException

makeRequest

protected HttpURLConnection makeRequest(JsonObject pRequest,
 URL pEndpoint)
                                 throws IOException

Throws:

IOException

setAuthorizationProperty

protected abstract void setAuthorizationProperty(HttpURLConnection pConnection)

connectionReadTimeout

protected int connectionReadTimeout()

getURLConnection

protected HttpURLConnection getURLConnection(URL pUrl)
                                      throws IOException

Throws:

IOException

createContext

public TextFilter createContext(com.mojang.authlib.GameProfile pProfile)