Package com.mojang.realmsclient.client

Class FileUpload

java.lang.Object

com.mojang.realmsclient.client.FileUpload

public class FileUpload
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	FileUpload.CustomInputStreamEntity

Field Summary

Fields

Modifier and Type	Field	Description
private final AtomicBoolean	cancelled
private final String	clientVersion
private final File	file
private static final org.slf4j.Logger	LOGGER
private static final int	MAX_RETRIES
private final long	realmId
private final org.apache.http.client.config.RequestConfig	requestConfig
private final String	sessionId
private final int	slotId
private static final String	UPLOAD_PATH
private final UploadInfo	uploadInfo
private final UploadStatus	uploadStatus
private CompletableFuture<UploadResult>	uploadTask
private final String	username
private final String	worldVersion

Constructor Summary

Constructors

Constructor	Description
FileUpload(File pFile, long pRealmId, int pSlotId, UploadInfo pUploadInfo, User pUser, String pClientVersiob, String pWorldVersion, UploadStatus pUploadStatus)

Method Summary

Modifier and Type	Method	Description
void	cancel()
private void	cleanup(org.apache.http.client.methods.HttpPost pPost, org.apache.http.impl.client.CloseableHttpClient pHttpClient)
private long	getRetryDelaySeconds(org.apache.http.HttpResponse pHttpResponse)
private void	handleResponse(org.apache.http.HttpResponse pResponse, UploadResult.Builder pUploadResult)
boolean	isFinished()
private UploadResult	requestUpload(int pRetries)
private UploadResult	retryUploadAfter(long pSeconds, int pRetries)
private void	setupRequest(org.apache.http.client.methods.HttpPost pPost)
private boolean	shouldRetry(long pRetryDelaySeconds, int pRetries)
void	upload(Consumer<UploadResult> pResultConsumer)

Methods inherited from class java.lang.Object

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

Field Details

LOGGER

private static final org.slf4j.Logger LOGGER

MAX_RETRIES

private static final int MAX_RETRIES

See Also:

• Constant Field Values

UPLOAD_PATH

private static final String UPLOAD_PATH

See Also:

• Constant Field Values

file

private final File file

realmId

private final long realmId

slotId

private final int slotId

uploadInfo

private final UploadInfo uploadInfo

sessionId

private final String sessionId

username

private final String username

clientVersion

private final String clientVersion

worldVersion

private final String worldVersion

uploadStatus

private final UploadStatus uploadStatus

cancelled

private final AtomicBoolean cancelled

uploadTask

@Nullable
private CompletableFuture<UploadResult> uploadTask

requestConfig

private final org.apache.http.client.config.RequestConfig requestConfig

Constructor Details

FileUpload

public FileUpload(File pFile,
 long pRealmId,
 int pSlotId,
 UploadInfo pUploadInfo,
 User pUser,
 String pClientVersiob,
 String pWorldVersion,
 UploadStatus pUploadStatus)

Method Details

upload

public void upload(Consumer<UploadResult> pResultConsumer)

cancel

public void cancel()

requestUpload

private UploadResult requestUpload(int pRetries)

Parameters:

pRetries - The number of times this upload has already been attempted

cleanup

private void cleanup(org.apache.http.client.methods.HttpPost pPost,
 @Nullable
 org.apache.http.impl.client.CloseableHttpClient pHttpClient)

setupRequest

private void setupRequest(org.apache.http.client.methods.HttpPost pPost)
                   throws FileNotFoundException

Throws:

FileNotFoundException

handleResponse

private void handleResponse(org.apache.http.HttpResponse pResponse,
 UploadResult.Builder pUploadResult)
                     throws IOException

Throws:

IOException

shouldRetry

private boolean shouldRetry(long pRetryDelaySeconds,
 int pRetries)

retryUploadAfter

private UploadResult retryUploadAfter(long pSeconds,
 int pRetries)
                               throws InterruptedException

Throws:

InterruptedException

getRetryDelaySeconds

private long getRetryDelaySeconds(org.apache.http.HttpResponse pHttpResponse)

isFinished

public boolean isFinished()