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 channel, ManagementServer managementServer, MinecraftApi minecraftApi, JsonRpcLogger jsonRpcLogger)

Method Summary

Modifier and Type	Method	Description
void	channelActive(io.netty.channel.ChannelHandlerContext context)
void	channelInactive(io.netty.channel.ChannelHandlerContext context)
protected void	channelRead0(io.netty.channel.ChannelHandlerContext context, JsonElement json)
JsonElement	dispatchIncomingRequest(String methodName, JsonElement params)
void	exceptionCaught(io.netty.channel.ChannelHandlerContext context, Throwable exception)
private JsonArray	handleBatchRequest(List<JsonElement> requests)
private JsonObject	handleError(JsonElement requestId, JsonObject error)
private JsonObject	handleIncomingRequest(JsonElement requestId, String methodName, JsonElement params)
(package private) JsonObject	handleJsonObject(JsonObject json)
private void	handleRequestResponse(int requestId, JsonElement result)
private static boolean	isValidRequestId(JsonElement json)
private static boolean	isValidResponseId(JsonElement json)
void	sendNotification(Holder.Reference<? extends OutgoingRpcMethod<Void,?>> method)
<Params> void	sendNotification(Holder.Reference<? extends OutgoingRpcMethod<Params,?>> method, Params params)
<Result> CompletableFuture<Result>	sendRequest(Holder.Reference<? extends OutgoingRpcMethod<Void,Result>> method)
private <Params, Result> CompletableFuture<Result>	sendRequest(Holder.Reference<? extends OutgoingRpcMethod<Params,? extends Result>> method, Params params, boolean expectResponse)
<Params, Result> CompletableFuture<Result>	sendRequest(Holder.Reference<? extends OutgoingRpcMethod<Params,Result>> method, Params params)
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 channel,
 ManagementServer managementServer,
 MinecraftApi minecraftApi,
 JsonRpcLogger jsonRpcLogger)

Method Details

tick

public void tick()

channelActive

public void channelActive(io.netty.channel.ChannelHandlerContext context)
                   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 context)
                     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 context,
 Throwable exception)
                     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 context,
 JsonElement json)

Specified by:

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

handleBatchRequest

private JsonArray handleBatchRequest(List<JsonElement> requests)

sendNotification

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

sendNotification

public <Params> void sendNotification(Holder.Reference<? extends OutgoingRpcMethod<Params,?>> method,
 Params params)

sendRequest

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

sendRequest

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

sendRequest

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

handleJsonObject

@Nullable
JsonObject handleJsonObject(JsonObject json)

isValidRequestId

private static boolean isValidRequestId(JsonElement json)

isValidResponseId

private static boolean isValidResponseId(JsonElement json)

handleIncomingRequest

@Nullable
private JsonObject handleIncomingRequest(@Nullable
 JsonElement requestId,
 String methodName,
 @Nullable
 JsonElement params)

dispatchIncomingRequest

@Nullable
public JsonElement dispatchIncomingRequest(String methodName,
 @Nullable
 JsonElement params)

handleRequestResponse

private void handleRequestResponse(int requestId,
 JsonElement result)

handleError

@Nullable
private JsonObject handleError(@Nullable
 JsonElement requestId,
 JsonObject error)