Package net.minecraft.server.jsonrpc

Class Connection

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

io.netty.channel.SimpleChannelInboundHandler<JsonElement>

net.minecraft.server.jsonrpc.Connection

All Implemented Interfaces:

io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler

public class Connection
extends io.netty.channel.SimpleChannelInboundHandler<JsonElement>

Nested Class Summary

Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler

io.netty.channel.ChannelHandler.Sharable

Field Summary

Fields

Modifier and Type	Field	Description
private final io.netty.channel.Channel	channel
private final ClientInfo	clientInfo
private static final AtomicInteger	CONNECTION_ID_COUNTER
private final JsonRpcLogger	jsonRpcLogger
private static final org.slf4j.Logger	LOGGER
private final ManagementServer	managementServer
private final MinecraftApi	minecraftApi
private final it.unimi.dsi.fastutil.ints.Int2ObjectMap<PendingRpcRequest<?>>	pendingRequests
private final AtomicInteger	transactionId

Constructor Summary

Constructors

Constructor	Description
Connection(io.netty.channel.Channel pChannel, ManagementServer pManagementServer, MinecraftApi pMinecraftApi, JsonRpcLogger pJsonRpcLogger)

Method Summary

Modifier and Type	Method	Description
void	channelActive(io.netty.channel.ChannelHandlerContext pContext)
void	channelInactive(io.netty.channel.ChannelHandlerContext pContext)
protected void	channelRead0(io.netty.channel.ChannelHandlerContext pContext, JsonElement pJson)
JsonElement	dispatchIncomingRequest(String pMethodName, JsonElement pParams)
void	exceptionCaught(io.netty.channel.ChannelHandlerContext pContext, Throwable pException)
private JsonArray	handleBatchRequest(List<JsonElement> pRequests)
private JsonObject	handleError(JsonElement pRequestId, JsonObject pError)
private JsonObject	handleIncomingRequest(JsonElement pRequestId, String pMethodName, JsonElement pParams)
(package private) JsonObject	handleJsonObject(JsonObject pJson)
private void	handleRequestResponse(int pRequestId, JsonElement pResult)
private static boolean	isValidRequestId(JsonElement pJson)
private static boolean	isValidResponseId(JsonElement pJson)
void	sendNotification(Holder.Reference<? extends OutgoingRpcMethod<Void,?>> pMethod)
<Params> void	sendNotification(Holder.Reference<? extends OutgoingRpcMethod<Params,?>> pMethod, Params pParams)
<Result> CompletableFuture<Result>	sendRequest(Holder.Reference<? extends OutgoingRpcMethod<Void,Result>> pMethod)
private <Params, Result> CompletableFuture<Result>	sendRequest(Holder.Reference<? extends OutgoingRpcMethod<Params,? extends Result>> pMethod, Params pParams, boolean pExpectResponse)
<Params, Result> CompletableFuture<Result>	sendRequest(Holder.Reference<? extends OutgoingRpcMethod<Params,Result>> pMethod, Params pParams)
void	tick()

Methods inherited from class io.netty.channel.SimpleChannelInboundHandler

acceptInboundMessage, channelRead

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, userEventTriggered

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, handlerAdded, handlerRemoved, isSharable

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.netty.channel.ChannelHandler

handlerAdded, handlerRemoved

Field Details

LOGGER

private static final org.slf4j.Logger LOGGER

CONNECTION_ID_COUNTER

private static final AtomicInteger CONNECTION_ID_COUNTER

jsonRpcLogger

private final JsonRpcLogger jsonRpcLogger

clientInfo

private final ClientInfo clientInfo

managementServer

private final ManagementServer managementServer

channel

private final io.netty.channel.Channel channel

minecraftApi

private final MinecraftApi minecraftApi

transactionId

private final AtomicInteger transactionId

pendingRequests

private final it.unimi.dsi.fastutil.ints.Int2ObjectMap<PendingRpcRequest<?>> pendingRequests

Constructor Details

Connection

public Connection(io.netty.channel.Channel pChannel,
 ManagementServer pManagementServer,
 MinecraftApi pMinecraftApi,
 JsonRpcLogger pJsonRpcLogger)

Method Details

tick

public void tick()

channelActive

public void channelActive(io.netty.channel.ChannelHandlerContext pContext)
                   throws Exception

Specified by:

channelActive in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelActive in class io.netty.channel.ChannelInboundHandlerAdapter

Throws:

Exception

channelInactive

public void channelInactive(io.netty.channel.ChannelHandlerContext pContext)
                     throws Exception

Specified by:

channelInactive in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelInactive in class io.netty.channel.ChannelInboundHandlerAdapter

Throws:

Exception

exceptionCaught

public void exceptionCaught(io.netty.channel.ChannelHandlerContext pContext,
 Throwable pException)
                     throws Exception

Specified by:

exceptionCaught in interface io.netty.channel.ChannelHandler

Specified by:

exceptionCaught in interface io.netty.channel.ChannelInboundHandler

Overrides:

exceptionCaught in class io.netty.channel.ChannelInboundHandlerAdapter

Throws:

Exception

channelRead0

protected void channelRead0(io.netty.channel.ChannelHandlerContext pContext,
 JsonElement pJson)

Specified by:

channelRead0 in class io.netty.channel.SimpleChannelInboundHandler<JsonElement>

handleBatchRequest

private JsonArray handleBatchRequest(List<JsonElement> pRequests)

sendNotification

public void sendNotification(Holder.Reference<? extends OutgoingRpcMethod<Void,?>> pMethod)

sendNotification

public <Params> void sendNotification(Holder.Reference<? extends OutgoingRpcMethod<Params,?>> pMethod,
 Params pParams)

sendRequest

public <Result> CompletableFuture<Result> sendRequest(Holder.Reference<? extends OutgoingRpcMethod<Void,Result>> pMethod)

sendRequest

public <Params,
Result> CompletableFuture<Result> sendRequest(Holder.Reference<? extends OutgoingRpcMethod<Params,Result>> pMethod,
 Params pParams)

sendRequest

@Nullable
@Contract("_,_,false->null;_,_,true->!null")
private <Params,
Result> CompletableFuture<Result> sendRequest(Holder.Reference<? extends OutgoingRpcMethod<Params,? extends Result>> pMethod,
 @Nullable
 Params pParams,
 boolean pExpectResponse)

handleJsonObject

@Nullable
JsonObject handleJsonObject(JsonObject pJson)

isValidRequestId

private static boolean isValidRequestId(JsonElement pJson)

isValidResponseId

private static boolean isValidResponseId(JsonElement pJson)

handleIncomingRequest

@Nullable
private JsonObject handleIncomingRequest(@Nullable
 JsonElement pRequestId,
 String pMethodName,
 @Nullable
 JsonElement pParams)

dispatchIncomingRequest

@Nullable
public JsonElement dispatchIncomingRequest(String pMethodName,
 @Nullable
 JsonElement pParams)

handleRequestResponse

private void handleRequestResponse(int pRequestId,
 JsonElement pResult)

handleError

@Nullable
private JsonObject handleError(@Nullable
 JsonElement pRequestId,
 JsonObject pError)