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 chatEndpoint, ServerTextFilter.MessageEncoder chatEncoder, ServerTextFilter.IgnoreStrategy chatIgnoreStrategy, ExecutorService workerPool)

Method Summary

Modifier and Type	Method	Description
void	close()
protected int	connectionReadTimeout()
TextFilter	createContext(com.mojang.authlib.GameProfile profile)
static @Nullable ServerTextFilter	createFromConfig(DedicatedServerProperties config)
protected static ExecutorService	createWorkerPool(int size)
protected void	drainStream(InputStream stream)
protected abstract FilteredText	filterText(String text, ServerTextFilter.IgnoreStrategy ignoreStrategy, JsonObject response)
protected static URL	getEndpoint(URI apiServer, @Nullable JsonObject json, String key, String fallback)
protected static String	getEndpointFromConfig(@Nullable JsonObject json, String key, String fallback)
protected HttpURLConnection	getURLConnection(URL url)
protected HttpURLConnection	makeRequest(JsonObject request, URL endpoint)
protected FilterMask	parseMask(String text, JsonArray hashes, ServerTextFilter.IgnoreStrategy ignoreStrategy)
private JsonObject	processRequestResponse(JsonObject request, URL endpoint)
protected CompletableFuture<FilteredText>	requestMessageProcessing(com.mojang.authlib.GameProfile profile, String filter, ServerTextFilter.IgnoreStrategy chatIgnoreStrategy, Executor streamExecutor)
protected abstract void	setAuthorizationProperty(HttpURLConnection connection)

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 chatEndpoint,
 ServerTextFilter.MessageEncoder chatEncoder,
 ServerTextFilter.IgnoreStrategy chatIgnoreStrategy,
 ExecutorService workerPool)

Method Details

createWorkerPool

protected static ExecutorService createWorkerPool(int size)

getEndpoint

protected static URL getEndpoint(URI apiServer,
 @Nullable JsonObject json,
 String key,
 String fallback)
                          throws MalformedURLException

Throws:

MalformedURLException

getEndpointFromConfig

protected static String getEndpointFromConfig(@Nullable JsonObject json,
 String key,
 String fallback)

createFromConfig

public static @Nullable ServerTextFilter createFromConfig(DedicatedServerProperties config)

requestMessageProcessing

protected CompletableFuture<FilteredText> requestMessageProcessing(com.mojang.authlib.GameProfile profile,
 String filter,
 ServerTextFilter.IgnoreStrategy chatIgnoreStrategy,
 Executor streamExecutor)

filterText

protected abstract FilteredText filterText(String text,
 ServerTextFilter.IgnoreStrategy ignoreStrategy,
 JsonObject response)

parseMask

protected FilterMask parseMask(String text,
 JsonArray hashes,
 ServerTextFilter.IgnoreStrategy ignoreStrategy)

close

public void close()

Specified by:

close in interface AutoCloseable

drainStream

protected void drainStream(InputStream stream)
                    throws IOException

Throws:

IOException

processRequestResponse

private JsonObject processRequestResponse(JsonObject request,
 URL endpoint)
                                   throws IOException

Throws:

IOException

makeRequest

protected HttpURLConnection makeRequest(JsonObject request,
 URL endpoint)
                                 throws IOException

Throws:

IOException

setAuthorizationProperty

protected abstract void setAuthorizationProperty(HttpURLConnection connection)

connectionReadTimeout

protected int connectionReadTimeout()

getURLConnection

protected HttpURLConnection getURLConnection(URL url)
                                      throws IOException

Throws:

IOException

createContext

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