E  java/lang/Object()V   )com/mojang/realmsclient/client/FileUploadfileLjava/io/File;  realmIdJ  slotIdI   uploadInfo(Lcom/mojang/realmsclient/dto/UploadInfo;  net/minecraft/client/User getSessionId()Ljava/lang/String;  !" sessionIdLjava/lang/String; $ %getName ' ("username * +" clientVersion - ." worldVersion 0 12 uploadStatus-Lcom/mojang/realmsclient/client/UploadStatus; 456 78java/net/http/HttpClient newBuilder$()Ljava/net/http/HttpClient$Builder; :;< =>net/minecraft/util/UtilnonCriticalIoPool!()Lnet/minecraft/TracingExecutor; @AB CD java/net/http/HttpClient$BuilderexecutorC(Ljava/util/concurrent/Executor;)Ljava/net/http/HttpClient$Builder; HIJ KLjava/time/Duration ofSeconds(J)Ljava/time/Duration; @N OPconnectTimeout8(Ljava/time/Duration;)Ljava/net/http/HttpClient$Builder; @R STbuild()Ljava/net/http/HttpClient; V WXclientLjava/net/http/HttpClient; 4Z [close ]^_ `a java/io/Filelength()J cde fg+com/mojang/realmsclient/client/UploadStatus setTotalBytes(J)V i jk requestUpload,(IJ)Ljava/util/concurrent/CompletableFuture;m nogetJ(Lcom/mojang/realmsclient/client/FileUpload;)Ljava/util/function/Supplier; q rsinputStreamPublisherWithSizeI(Ljava/util/function/Supplier;J)Ljava/net/http/HttpRequest$BodyPublisher; uvw xy&com/mojang/realmsclient/dto/UploadInfouploadEndpoint()Ljava/net/URI;{ |}makeConcatWithConstants(JI)Ljava/lang/String;   java/net/URIresolve"(Ljava/lang/String;)Ljava/net/URI;  7java/net/http/HttpRequest3(Ljava/net/URI;)Ljava/net/http/HttpRequest$Builder; H L ofMinutes  !java/net/http/HttpRequest$Buildertimeout9(Ljava/time/Duration;)Ljava/net/http/HttpRequest$Builder;Cookie   uploadCookie  setHeaderI(Ljava/lang/String;Ljava/lang/String;)Ljava/net/http/HttpRequest$Builder; Content-Typeapplication/octet-stream POSTN(Ljava/net/http/HttpRequest$BodyPublisher;)Ljava/net/http/HttpRequest$Builder; S()Ljava/net/http/HttpRequest;  !java/nio/charset/StandardCharsetsUTF_8Ljava/nio/charset/Charset;  'java/net/http/HttpResponse$BodyHandlersofStringD(Ljava/nio/charset/Charset;)Ljava/net/http/HttpResponse$BodyHandler; 4  sendAsyncm(Ljava/net/http/HttpRequest;Ljava/net/http/HttpResponse$BodyHandler;)Ljava/util/concurrent/CompletableFuture; applyL(Lcom/mojang/realmsclient/client/FileUpload;IJ)Ljava/util/function/Function;  &java/util/concurrent/CompletableFuture thenComposeG(Ljava/util/function/Function;)Ljava/util/concurrent/CompletableFuture;  (java/net/http/HttpRequest$BodyPublishers ofInputStreamH(Ljava/util/function/Supplier;)Ljava/net/http/HttpRequest$BodyPublisher;  fromPublisherQ(Ljava/util/concurrent/Flow$Publisher;J)Ljava/net/http/HttpRequest$BodyPublisher; u token |n(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;  java/net/http/HttpResponse statusCode()I  LOGGERLorg/slf4j/Logger;Realms server returned 401: {} headers()Ljava/net/http/HttpHeaders;WWW-Authenticate  java/net/http/HttpHeaders firstValue((Ljava/lang/String;)Ljava/util/Optional;  org/slf4j/Loggerdebug'(Ljava/lang/String;Ljava/lang/Object;)V body()Ljava/lang/Object;java/lang/String isBlank()Z  $net/minecraft/util/LenientJsonParserparse1(Ljava/lang/String;)Lcom/google/gson/JsonElement;  com/google/gson/JsonElementgetAsJsonObject()Lcom/google/gson/JsonObject;errorMsg    ncom/google/gson/JsonObject   getAsStringjava/lang/ExceptionFailed to parse response {}  warn9(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V0com/mojang/realmsclient/gui/screens/UploadResult  (ILjava/lang/String;)V Retry-After   !firstValueAsLong,(Ljava/lang/String;)Ljava/util/OptionalLong; #$% &'java/util/OptionalLongorElse(J)J ) *+getRetryDelaySeconds(Ljava/net/http/HttpResponse;)J - ./ shouldRetry(JI)Z c1 2restart 456 78java/lang/Threadsleep(Ljava/time/Duration;)V:java/lang/InterruptedException < =>handleResponseP(Ljava/net/http/HttpResponse;)Lcom/mojang/realmsclient/gui/screens/UploadResult; @ ABcompletedFuture<(Ljava/lang/Object;)Ljava/util/concurrent/CompletableFuture;DCcom/mojang/realmsclient/client/FileUpload$UploadCountingInputStreamFjava/io/FileInputStream EH I(Ljava/io/File;)V CK LE(Ljava/io/InputStream;Lcom/mojang/realmsclient/client/UploadStatus;)VNjava/io/IOExceptionPFailed to open file {} RST UVcom/mojang/logging/LogUtils getLogger()Lorg/slf4j/Logger;Xjava/lang/AutoCloseable MAX_RETRIES ConstantValue UPLOAD_PATH^/upload(Ljava/io/File;JILcom/mojang/realmsclient/dto/UploadInfo;Lnet/minecraft/client/User;Ljava/lang/String;Ljava/lang/String;Lcom/mojang/realmsclient/client/UploadStatus;)VCodeLineNumberTableLocalVariableTablethis+Lcom/mojang/realmsclient/client/FileUpload;userLnet/minecraft/client/User;MethodParameters startUpload*()Ljava/util/concurrent/CompletableFuture;fileSize Signature^()Ljava/util/concurrent/CompletableFuture;currentAttempt publisher)Ljava/net/http/HttpRequest$BodyPublisher;requestLjava/net/http/HttpRequest;`(IJ)Ljava/util/concurrent/CompletableFuture;inputStreamSupplierLjava/util/function/Supplier;LocalVariableTypeTable4Ljava/util/function/Supplier;`(Ljava/util/function/Supplier;J)Ljava/net/http/HttpRequest$BodyPublisher;RuntimeVisibleTypeAnnotations#Lorg/jspecify/annotations/Nullable;errorMsgElementLcom/google/gson/JsonElement;eLjava/lang/Exception;responseLjava/net/http/HttpResponse; errorMessage0Ljava/net/http/HttpResponse; StackMapTabled(Ljava/net/http/HttpResponse;)Lcom/mojang/realmsclient/gui/screens/UploadResult;retryDelaySecondsLjava/net/http/HttpResponse<*>;"(Ljava/net/http/HttpResponse<*>;)Jlambda$requestUpload$1F(IJLjava/net/http/HttpResponse;)Ljava/util/concurrent/CompletionStage;lambda$requestUpload$0()Ljava/io/InputStream;Ljava/io/IOException; SourceFileFileUpload.java NestMembersBootstrapMethods   /upload//&(Ljava/lang/Object;)Ljava/lang/Object;  D(Ljava/net/http/HttpResponse;)Ljava/util/concurrent/CompletionStage;-sid=;token=;user=;version=;worldVersion=  "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; InnerClassesBuilder'java/net/http/HttpRequest$BodyPublisher BodyPublisher BodyHandlers&java/net/http/HttpResponse$BodyHandler BodyHandlerBodyPublishers#java/util/concurrent/Flow$Publisherjava/util/concurrent/Flow PublisherUploadCountingInputStream%java/lang/invoke/MethodHandles$Lookupjava/lang/invoke/MethodHandlesLookup!W YZ[\"Z] !"("+"."12WX _` ^**+* ****#&*)*,* /*39?EGMQUa2 ,- ./01#2,32485>7]8b\ ^cd^ ^^^^ef^+"^."^12 g! e+.1[`6*UYa <=b cdhi`S*\@*/b*ha@ABbcdjkljk`n*l p:*t* *z~*:*U* a"G P)Q4R@SGTLUSWb4ncdnmnj bnoSpqg mjkr rs`W *Ȱafgfb st ju  svg sjkwx y`G***&*)*,amb cd=>`@v+=+N+::2:  N:Y-=X[a6 qrs#u%v0w=yMzR{X[}]~lbHM z{]|}vcdv~o%Q"0F"u v~#4Bg~k./`\ `ab cdm@g m*+`W+ "abcd~u ~g~k`9*(7*, */0G3:*` h*;?!$9a"XYZ\!^$]&_/ab49cd9m9j9~1$9`~*CYEY*G*/JLO*+MaIJK(Lb|*cdWM`QرaC"J @4       C