Êþº¾Eá  ,io/netty/channel/SimpleChannelInboundHandler()V)java/util/concurrent/atomic/AtomicInteger   'net/minecraft/server/jsonrpc/Connection transactionId+Ljava/util/concurrent/atomic/AtomicInteger;0it/unimi/dsi/fastutil/ints/Int2ObjectOpenHashMap   )it/unimi/dsi/fastutil/ints/Int2ObjectMaps synchronizeV(Lit/unimi/dsi/fastutil/ints/Int2ObjectMap;)Lit/unimi/dsi/fastutil/ints/Int2ObjectMap;  pendingRequests*Lit/unimi/dsi/fastutil/ints/Int2ObjectMap;  CONNECTION_ID_COUNTER ! "#incrementAndGet()I %&' ()java/lang/IntegervalueOf(I)Ljava/lang/Integer; +,- .//net/minecraft/server/jsonrpc/methods/ClientInfoofF(Ljava/lang/Integer;)Lnet/minecraft/server/jsonrpc/methods/ClientInfo; 1 23 clientInfo1Lnet/minecraft/server/jsonrpc/methods/ClientInfo; 5 67managementServer/Lnet/minecraft/server/jsonrpc/ManagementServer; 9 :; minecraftApi7Lnet/minecraft/server/jsonrpc/internalapi/MinecraftApi; = >?channelLio/netty/channel/Channel; A BC jsonRpcLogger,Lnet/minecraft/server/jsonrpc/JsonRpcLogger; EFG HInet/minecraft/util/Util getMillis()J KLM NO(it/unimi/dsi/fastutil/ints/Int2ObjectMapint2ObjectEntrySet+()Lit/unimi/dsi/fastutil/objects/ObjectSet;Q RStest!(J)Ljava/util/function/Predicate; UVW XY'it/unimi/dsi/fastutil/objects/ObjectSetremoveIf!(Ljava/util/function/Predicate;)Z[#Management connection opened for {}]java/lang/Object _`a bcio/netty/channel/Channel remoteAddress()Ljava/net/SocketAddress; efg hi*net/minecraft/server/jsonrpc/JsonRpcLoggerlogY(Lnet/minecraft/server/jsonrpc/methods/ClientInfo;Ljava/lang/String;[Ljava/lang/Object;)V k lm channelActive+(Lio/netty/channel/ChannelHandlerContext;)V opq rs-net/minecraft/server/jsonrpc/ManagementServer onConnected,(Lnet/minecraft/server/jsonrpc/Connection;)Vu#Management connection closed for {} w xmchannelInactive oz {sonDisconnected }~ €�java/lang/ThrowablegetCause()Ljava/lang/Throwable;ƒ"com/google/gson/JsonParseException …†‡ ˆ‰*net/minecraft/server/jsonrpc/JsonRPCErrors PARSE_ERROR,Lnet/minecraft/server/jsonrpc/JsonRPCErrors; }‹ Œ� getMessage()Ljava/lang/String; …� �‘createWithUnknownId0(Ljava/lang/String;)Lcom/google/gson/JsonObject; _“ ”• writeAndFlush4(Ljava/lang/Object;)Lio/netty/channel/ChannelFuture; — ˜™exceptionCaught@(Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Throwable;)V _› œ�close"()Lio/netty/channel/ChannelFuture; Ÿ ¡ ¢�io/netty/channel/ChannelFutureawaitUninterruptibly ¤¥¦ §¨com/google/gson/JsonElement isJsonObject()Z ¤ª «¬getAsJsonObject()Lcom/google/gson/JsonObject; ® ¯°handleJsonObject:(Lcom/google/gson/JsonObject;)Lcom/google/gson/JsonObject; ¤² ³¨ isJsonArray ¤µ ¶·getAsJsonArray()Lcom/google/gson/JsonArray; ¹º» ¼½com/google/gson/JsonArrayasList()Ljava/util/List; ¿ ÀÁhandleBatchRequest-(Ljava/util/List;)Lcom/google/gson/JsonArray; …à ĉINVALID_REQUEST ¹ ÇÈÉ ÊËjava/util/Liststream()Ljava/util/stream/Stream;Í ÎÏapplyH(Lnet/minecraft/server/jsonrpc/Connection;)Ljava/util/function/Function; ÑÒÓ ÔÕjava/util/stream/Streammap8(Ljava/util/function/Function;)Ljava/util/stream/Stream;× RØ ()Ljava/util/function/Predicate; ÑÚ ÛÜfilter9(Ljava/util/function/Predicate;)Ljava/util/stream/Stream; Þßà áâjava/util/ObjectsrequireNonNull&(Ljava/lang/Object;)Ljava/lang/Object;ä åæaccept:(Lcom/google/gson/JsonArray;)Ljava/util/function/Consumer; Ñè éêforEach (Ljava/util/function/Consumer;)V ì íî sendRequestb(Lnet/minecraft/core/Holder$Reference;Ljava/lang/Object;Z)Ljava/util/concurrent/CompletableFuture; ðñò óô#net/minecraft/core/Holder$Referencevalue()Ljava/lang/Object;ö.net/minecraft/server/jsonrpc/OutgoingRpcMethod øùú ûü5net/minecraft/server/jsonrpc/internalapi/MinecraftApinotificationManager:()Lnet/minecraft/server/notifications/NotificationManager; þÿ 6net/minecraft/server/notifications/NotificationManagerserver2()Lnet/minecraft/server/dedicated/DedicatedServer; õ  attributes=()Lnet/minecraft/server/jsonrpc/OutgoingRpcMethod$Attributes;    ¨9net/minecraft/server/jsonrpc/OutgoingRpcMethod$AttributesallowPreServerInit Cnet/minecraft/server/jsonrpc/methods/InvalidRequestJsonRpcException  (java/lang/String&(Ljava/lang/Object;)Ljava/lang/String; makeConcatWithConstants&(Ljava/lang/String;)Ljava/lang/String;   (Ljava/lang/String;)V  &java/util/concurrent/CompletableFuture failedFuture?(Ljava/lang/Throwable;)Ljava/util/concurrent/CompletableFuture; õ! "# encodeParams1(Ljava/lang/Object;)Lcom/google/gson/JsonElement; Ç% .&$(Ljava/lang/Object;)Ljava/util/List; Ç( .½ +.net/minecraft/server/jsonrpc/PendingRpcRequestˆ */ 0Q(Lnet/minecraft/core/Holder$Reference;Ljava/util/concurrent/CompletableFuture;J)V K2 34put'(ILjava/lang/Object;)Ljava/lang/Object; ð6 78key'()Lnet/minecraft/resources/ResourceKey; :;< =>#net/minecraft/resources/ResourceKey identifier&()Lnet/minecraft/resources/Identifier; @AB CD)net/minecraft/server/jsonrpc/JsonRPCUtils createRequeste(Ljava/lang/Integer;Lnet/minecraft/resources/Identifier;Ljava/util/List;)Lcom/google/gson/JsonObject; @F GH getRequestId;(Lcom/google/gson/JsonObject;)Lcom/google/gson/JsonElement; @J KL getMethodName0(Lcom/google/gson/JsonObject;)Ljava/lang/String; @N OH getResult @Q RH getParams @T U°getError W XYisValidRequestId (Lcom/google/gson/JsonElement;)Z[;Invalid request id - only String, Number and NULL supported ] ^_handleIncomingRequestj(Lcom/google/gson/JsonElement;Ljava/lang/String;Lcom/google/gson/JsonElement;)Lcom/google/gson/JsonObject; a bYisValidResponseId ¤d e#getAsInt g hihandleRequestResponse!(ILcom/google/gson/JsonElement;)V k lmLOGGERLorg/slf4j/Logger;o1Received respose {} with id {} we did not request qrs tuorg/slf4j/Loggerwarn9(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V w xy handleErrorW(Lcom/google/gson/JsonElement;Lcom/google/gson/JsonObject;)Lcom/google/gson/JsonObject; {|} ~com/google/gson/JsonNullINSTANCELcom/google/gson/JsonNull; Þ� ‚ƒrequireNonNullElse8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; …… †‡createWithoutData;(Lcom/google/gson/JsonElement;)Lcom/google/gson/JsonObject;‰java/lang/Exception‹ Error while handling rpc request q� Ž�error*(Ljava/lang/String;Ljava/lang/Throwable;)V …‘ ’‰INTERNAL_ERROR”BUnknown error handling request - check server logs for stack trace ¤– —¨ isJsonNull ™š› œYnet/minecraft/util/GsonHelper isNumberValue ™ž ŸY isStringValue ¡ ¢£dispatchIncomingRequestN(Ljava/lang/String;Lcom/google/gson/JsonElement;)Lcom/google/gson/JsonElement; @¥ ¦§createSuccessResultX(Lcom/google/gson/JsonElement;Lcom/google/gson/JsonElement;)Lcom/google/gson/JsonObject;©Enet/minecraft/server/jsonrpc/methods/InvalidParameterJsonRpcException«#Invalid parameter invocation {}: {} q­ ®¯debug((Ljava/lang/String;[Ljava/lang/Object;)V …± ²‰INVALID_PARAMS ¨‹ …µ ¶·createM(Lcom/google/gson/JsonElement;Ljava/lang/String;)Lcom/google/gson/JsonObject;¹;net/minecraft/server/jsonrpc/methods/EncodeJsonRpcException»%Failed to encode json rpc response {} q½ Žu ¸‹  ‹ÁCnet/minecraft/server/jsonrpc/methods/MethodNotFoundJsonRpcException …à ĉMETHOD_NOT_FOUND À‹Ç%Error while dispatching rpc method {} ÉÊË ÌÍ"net/minecraft/resources/IdentifiertryParse8(Ljava/lang/String;)Lnet/minecraft/resources/Identifier; ÐÑÒ ÓÔ/net/minecraft/core/registries/BuiltInRegistriesINCOMING_RPC_METHODLnet/minecraft/core/Registry; Öר ÙÚnet/minecraft/core/Registry getOptional:(Lnet/minecraft/resources/Identifier;)Ljava/util/Optional; ÜÝÞ ߨjava/util/OptionalisEmpty À Üã äôgetæ.net/minecraft/server/jsonrpc/IncomingRpcMethod åè é=()Lnet/minecraft/server/jsonrpc/IncomingRpcMethod$Attributes; ë ì9net/minecraft/server/jsonrpc/IncomingRpcMethod$Attributes ëî ï¨runOnMainThreadñ äòy(Lnet/minecraft/server/jsonrpc/Connection;Ljava/util/Optional;Lcom/google/gson/JsonElement;)Ljava/util/function/Supplier; øô õösubmitG(Ljava/util/function/Supplier;)Ljava/util/concurrent/CompletableFuture; ø ùôjoinû(java/util/concurrent/CompletionException ú~þjava/lang/RuntimeException å Τ(Lnet/minecraft/server/jsonrpc/internalapi/MinecraftApi;Lcom/google/gson/JsonElement;Lnet/minecraft/server/jsonrpc/methods/ClientInfo;)Lcom/google/gson/JsonElement; K remove(I)Ljava/lang/Object;&Received unknown response (id: {}): {} * å  (Lcom/google/gson/JsonElement;)V *   resultFuture*()Ljava/util/concurrent/CompletableFuture;;>;¯(Lio/netty/channel/Channel;Lnet/minecraft/server/jsonrpc/ManagementServer;Lnet/minecraft/server/jsonrpc/internalapi/MinecraftApi;Lnet/minecraft/server/jsonrpc/JsonRpcLogger;)VCodeLineNumberTableLocalVariableTablethis)Lnet/minecraft/server/jsonrpc/Connection; jsonrpcLoggerMethodParametersticktimeJctx(Lio/netty/channel/ChannelHandlerContext; ExceptionscauseLjava/lang/Throwable; StackMapTableresponseLcom/google/gson/JsonObject;channelHandlerContext jsonElementLcom/google/gson/JsonElement; batchRequestsLjava/util/List;batchResponsesLcom/google/gson/JsonArray;LocalVariableTypeTable/Ljava/util/List;L(Ljava/util/List;)Lcom/google/gson/JsonArray;sendNotification((Lnet/minecraft/core/Holder$Reference;)V%Lnet/minecraft/core/Holder$Reference;kLnet/minecraft/core/Holder$Reference<+Lnet/minecraft/server/jsonrpc/OutgoingRpcMethod;>;n(Lnet/minecraft/core/Holder$Reference<+Lnet/minecraft/server/jsonrpc/OutgoingRpcMethod;>;)V:(Lnet/minecraft/core/Holder$Reference;Ljava/lang/Object;)VparamsLjava/lang/Object;cLnet/minecraft/core/Holder$Reference<+Lnet/minecraft/server/jsonrpc/OutgoingRpcMethod;>;TParams;‰(Lnet/minecraft/core/Holder$Reference<+Lnet/minecraft/server/jsonrpc/OutgoingRpcMethod;>;TParams;)VO(Lnet/minecraft/core/Holder$Reference;)Ljava/util/concurrent/CompletableFuture;rLnet/minecraft/core/Holder$Reference<+Lnet/minecraft/server/jsonrpc/OutgoingRpcMethod;>;Á(Lnet/minecraft/core/Holder$Reference<+Lnet/minecraft/server/jsonrpc/OutgoingRpcMethod;>;)Ljava/util/concurrent/CompletableFuture;a(Lnet/minecraft/core/Holder$Reference;Ljava/lang/Object;)Ljava/util/concurrent/CompletableFuture;jLnet/minecraft/core/Holder$Reference<+Lnet/minecraft/server/jsonrpc/OutgoingRpcMethod;>;Ú(Lnet/minecraft/core/Holder$Reference<+Lnet/minecraft/server/jsonrpc/OutgoingRpcMethod;>;TParams;)Ljava/util/concurrent/CompletableFuture;future(Ljava/util/concurrent/CompletableFuture;idI methodHolder expectReplyZ0Lnet/minecraft/server/jsonrpc/OutgoingRpcMethod; jsonParams2Ljava/util/concurrent/CompletableFuture;kLnet/minecraft/core/Holder$Reference<+Lnet/minecraft/server/jsonrpc/OutgoingRpcMethod;>;CLnet/minecraft/server/jsonrpc/OutgoingRpcMethod;Ü(Lnet/minecraft/core/Holder$Reference<+Lnet/minecraft/server/jsonrpc/OutgoingRpcMethod;>;TParams;Z)Ljava/util/concurrent/CompletableFuture;RuntimeInvisibleAnnotations$Lorg/jetbrains/annotations/Contract;_,_,false->null;_,_,true->!nullRuntimeVisibleTypeAnnotations#Lorg/jspecify/annotations/Nullable;Ljava/lang/String;resulteLjava/lang/Exception; jsonObject€com/google/gson/JsonObject1Lcom/google/common/annotations/VisibleForTesting;GLnet/minecraft/server/jsonrpc/methods/InvalidParameterJsonRpcException;=Lnet/minecraft/server/jsonrpc/methods/EncodeJsonRpcException;ELnet/minecraft/server/jsonrpc/methods/InvalidRequestJsonRpcException;ELnet/minecraft/server/jsonrpc/methods/MethodNotFoundJsonRpcException; sendResponsereLjava/lang/RuntimeException;*Ljava/util/concurrent/CompletionException;$Lnet/minecraft/resources/Identifier;incomingRpcMethodLjava/util/Optional;;Lnet/minecraft/server/jsonrpc/IncomingRpcMethod$Attributes;8Lnet/minecraft/server/notifications/NotificationManager;JLjava/util/Optional;>;request0Lnet/minecraft/server/jsonrpc/PendingRpcRequest;3Lnet/minecraft/server/jsonrpc/PendingRpcRequest<*>;=(Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Object;)V lambda$dispatchIncomingRequest$0P(Ljava/util/Optional;Lcom/google/gson/JsonElement;)Lcom/google/gson/JsonElement;lambda$handleBatchRequest$0 batchEntry lambda$tick$04(JLit/unimi/dsi/fastutil/ints/Int2ObjectMap$Entry;)Zentry0Lit/unimi/dsi/fastutil/ints/Int2ObjectMap$Entry;MLio/netty/channel/SimpleChannelInboundHandler; SourceFileConnection.javaBootstrapMethods¢(Ljava/lang/Object;)Z¤ ¥ ˜™§3(Lit/unimi/dsi/fastutil/ints/Int2ObjectMap$Entry;)Z⪠« –‡‡® Þ¯ °¢nonNull²(Lcom/google/gson/JsonObject;)Z´(Ljava/lang/Object;)V¶ ¹· ¸ addº(Lcom/google/gson/JsonObject;)V¼8Method cannot be dispatched pre server initialization: ¾Failed to parse method value: ÀMethod not found: ôà Ä ”•Æ()Lcom/google/gson/JsonElement;È+RPC method  timed out waiting for responseÊ ËÌÍ ÎÏ"java/lang/invoke/LambdaMetafactory metafactoryÌ(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;Ñ ÒÓÔ Õ$java/lang/invoke/StringConcatFactory˜(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/invoke/CallSite; InnerClassesØnet/minecraft/core/Holder Reference AttributesEntryÝ%java/lang/invoke/MethodHandles$Lookupßjava/lang/invoke/MethodHandlesLookup!  lmBC2367>?:;89:;µC*·*»Y· µ *»Y·¸µ*²¶ ¸$¸*µ0*,µ4*-µ8*+µ<*µ@±<& 7458-92:7;<<B==4C>?C>?C67C:;C@CA>6:@B;V¸D@*´¹JºP¹TW±<@AH=>?CDlm;k+*´@*´0Z½\Y*´<¹^S¶d*+·j*´4*¶n±<LM"N*O=+>?+EFGˆAExm;k+*´@*´0t½\Y*´<¹^S¶d*+·v*´4*¶y±<ST"U*V=+>?+EFGˆAE˜™;�5,¶|Á‚™*´<²„,¶Š¶Ž¹’W±*+,·–*´<¹š¹žW±<Z [\^%_4`= 5>?5EF5HIJGˆA EH;ÃS,¶£™*,¶©¶­N-Æ*´<-¹’W§3,¶±™*´<*,¶´¶¸¶¾¹’W§*´<²Â¶Ž¹’W±<"defgi)jAlRn=*KLS>?SMFSNOJA MNÀÁ;�5»¹Y·ÅM+¹Æ*ºÌ¹ÐºÖ¹Ù,Y¸ÝWºã¹ç,°<qr stu%v3w= 5>?5PQ-RST 5PUAP8VWX;S *+¶ëW±< {|= >? +YT  +ZA+8[W\;g *+,¶ëW±< €=  >? +Y ]^T +_ ]`A +]8aíb;N*+¶ë°<ƒ=>?+YT +cA+8díe;b*+,¶ë°<‡= >?+Y]^T+f]`A +]8gíî;À Ã+¶ïÀõ:*´8¶÷¶ýÇ%¹¶š» Y¸º·¸°,Æ,¹ ¸ÝÀ¤¸$§¸':™T»Y·):*´ ¶ 6¸D7*´»*Y+,a·.¹1W*´<¸$+¶5¶9¸?¹’W°*´<+¶5¶9¸?¹’W°<6 Œ �#Ž8�U‘Y’b“k”p•Œ–§—ª™Áš=\ bHhik?jkp:CDÃ>?ÃlYÃ]^Ãmn º+oUnpQT4bHhqÃlrÃ]` º+sUnpUJü8õBÇüVÇA l]m8tu vóswxyy¯°;Ù¼+¸EM+¸IN+¸M:+¸P:+¸S:-Æ+Ç&Ç!,Æ,¸Vš ²ÂZ¶Ž°*,-¶\°-Ç5Æ0Ç+,Æ',¸`™*,¶c¶f§²jn,¹p°-ÇÇÆ *,¶v°²Â,²z¸€À¤¶„°M²jŠ,¹Œ²�“¶Ž°>¥ˆ?G¥ˆH}¥ˆ~“¥ˆ”¤¥ˆ<R¨© ª«¬­*®5¯?±H²Z´aµn·|º~»Œ¼”¾¥À¦Á²Â=R jO ›+z•{O�]O‰ŽL¦|}¼>?¼~LJ3ÿ? ¤¤¤% ÿ ˆA~u�xy XY;Q*¶•š*¸˜š *¸�™§¬<È= jOJ@Aj bY;/*¸˜¬<Í= jOAj^_;«Ñ+Ƨ6*,-¶ :Æš°+¸¤°:²jª½\Y,SY-SYS¹¬™²°+¶³¶´§°:²jº,¹¼™²�+¶¾¶´§°:™²Â+¶¿¶´§°:™²Â+¶Ŷ´§°:²jÆ,¹¼™ ²�+¶„§° &¨%&¨ Z¸%Z¸ € %€ ˜À%˜À °ˆ%°ˆ<JÓ ÕÖ×Ù&Ú(ÛDÜZÝ\Þj߀à‚á˜âšã°ä²åÀæ=p {O(2|‚\$|ƒ‚|„š|…²|}Ñ>?ÑjOÑ+zÑ]O ƆnJ²@ý¤ÿ ¤¤¨ü1¨@ÿ ¤¤¸ü#¸@ÿ ¤¤ ü @ÿ ¤¤ÀüÀ@ÿ ¤¤ˆüˆ@A j+]xyyy¢£;Å Ç+¸ÈN-Ç» Y+ºη¿²Ï-¹Õ:¶Û™»ÀY+ºà·á¿¶âÀå¹ç:*´8¶÷:Æ!¶ýǶꚻ Y+º·¿¶í™8*´8*,ºð¶ó¶÷À¤°:¶ü:  Áý™  Àý:¿¿¶âÀå*´8,*´0¹ÿ°{‘’ú<Fëì íð"ñ*ò8õGöPùeúsý{’”ª­°=\ ª‡ˆ”|‰Ç>?Ç+zÇ]OÂ=Š"¥‹ŒG€�PwûŽT "¥‹�J$üÉü Üý:ëþ^úüúúA +]xyyhi;¤+*´¹À*N-Dzj¸$,¹p§-,¶±< %*=*+>?+jk+{O�‘T �’J ü%*A j{xy;·@+Æ0+¸`™)*´+¶c¹À*N-Æ-¶ »Y+,·¶W²j+,¹¼°<  1>=*�‘@>?@jO@ŽLT �’J1A jŽxyyD“;4 *+,À¤¶±<*=  >?GˆA MN”•;T+¶âÀå*´8,*´0¹ÿ°<= >?‹Œ]O–‡;= *+¶©¶­°<t= >? —O ˜™;›E,¹À*¶#>™4,¹À*¶ »'Y,¹À*¶)¶5¶9¸º-·.¶W¬<BCDCF= ECDEš›7%nJüCœ;.¸/³j»Y·5³±< +,8�žŸ L É¡£¦É¨©¬É¡­±É³µ¹Ð»Ð½Ð¿ÉÁÂÅÐÇÖ*ð×Ù õÚëåÚKÛ ÜÞà