Mastodon
/
fedilab-Android-App
mirror of https://codeberg.org/tom79/Fedilab
1
0
Fork 0
Code Issues Releases Wiki Activity

Finish upload part

This commit is contained in:
stom79 2017-11-18 09:44:54 +01:00
parent 532e4cbba0
commit 251f3d3803
1 changed files with 27 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
app/src/main/java/fr/gouv/etalab/mastodon/client/HttpsConnection.java
View File

@ -16,6 +16,8 @@ package fr.gouv.etalab.mastodon.client;
import android.content.Context;
import android.os.Build;
import org.json.JSONObject;
import java.io.BufferedInputStream;
import java.io.BufferedReader;
import java.io.ByteArrayOutputStream;
@ -42,6 +44,7 @@ import java.util.regex.Pattern;
import javax.net.ssl.HttpsURLConnection;
import fr.gouv.etalab.mastodon.client.Entities.Attachment;
import fr.gouv.etalab.mastodon.interfaces.OnRetrieveAttachmentInterface;
@ -213,6 +216,23 @@ public class HttpsConnection {
request.write(pixels);
int totalSize = pixels.length;
int bytesTransferred = 0;
int chunkSize = 2000;
while (bytesTransferred < totalSize) {
int nextChunkSize = totalSize - bytesTransferred;
if (nextChunkSize > chunkSize) {
nextChunkSize = chunkSize;
}
request.write(pixels, bytesTransferred, nextChunkSize);
bytesTransferred += nextChunkSize;
int progress = 100 * bytesTransferred / totalSize;
listener.onUpdateProgress(progress);
}
request.writeBytes("\r\n");
request.writeBytes("--*****\r\n");
request.flush();
@ -229,12 +249,17 @@ public class HttpsConnection {
while ((line = responseStreamReader.readLine()) != null) {
stringBuilder.append(line).append("\n");
}
listener.onUpdateProgress(101);
responseStreamReader.close();
String response = stringBuilder.toString();
Attachment attachment = API.parseAttachmentResponse(new JSONObject(response));
listener.onRetrieveAttachment(attachment, null);
}catch (Exception e) {
e.printStackTrace();
listener.onUpdateProgress(101);
fr.gouv.etalab.mastodon.client.Entities.Error error = new fr.gouv.etalab.mastodon.client.Entities.Error();
error.setError(e.getMessage());
listener.onRetrieveAttachment(null, error);
}
}
}).start();