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 ctx)
void	channelInactive(io.netty.channel.ChannelHandlerContext ctx)
protected void	channelRead0(io.netty.channel.ChannelHandlerContext channelHandlerContext, JsonElement jsonElement)
@Nullable JsonElement	dispatchIncomingRequest(String method, @Nullable JsonElement params)
void	exceptionCaught(io.netty.channel.ChannelHandlerContext ctx, Throwable cause)
private JsonArray	handleBatchRequest(List<JsonElement> batchRequests)
private @Nullable JsonObject	handleError(@Nullable JsonElement id, JsonObject error)
private @Nullable JsonObject	handleIncomingRequest(@Nullable JsonElement id, String method, @Nullable JsonElement params)
(package private) @Nullable JsonObject	handleJsonObject(JsonObject jsonObject)
private void	handleRequestResponse(int id, JsonElement result)
private static boolean	isValidRequestId(JsonElement id)
private static boolean	isValidResponseId(JsonElement id)
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> @Nullable CompletableFuture<Result>	sendRequest(Holder.Reference<? extends OutgoingRpcMethod<Params, ? extends Result>> method, @Nullable Params params, boolean expectReply)
<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 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 ctx)
                   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 ctx)
                     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 ctx,
 Throwable cause)
                     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 channelHandlerContext,
 JsonElement jsonElement)

Specified by:

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

handleBatchRequest

private JsonArray handleBatchRequest(List<JsonElement> batchRequests)

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

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

handleJsonObject

@Nullable JsonObject handleJsonObject(JsonObject jsonObject)

isValidRequestId

private static boolean isValidRequestId(JsonElement id)

isValidResponseId

private static boolean isValidResponseId(JsonElement id)

handleIncomingRequest

private @Nullable JsonObject handleIncomingRequest(@Nullable JsonElement id,
 String method,
 @Nullable JsonElement params)

dispatchIncomingRequest

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

handleRequestResponse

private void handleRequestResponse(int id,
 JsonElement result)

handleError

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