src/main/java/de/thedevstack/conversationsplus/services/filetransfer/http/download/HttpFileDownloadCallback.java


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57

package de.thedevstack.conversationsplus.services.filetransfer.http.download;

import java.io.IOException;
import java.io.OutputStream;

import de.thedevstack.android.logcat.Logging;
import de.thedevstack.conversationsplus.entities.DownloadableFile;
import de.thedevstack.conversationsplus.enums.FileStatus;
import de.thedevstack.conversationsplus.persistance.FileBackend;
import de.thedevstack.conversationsplus.services.AbstractConnectionManager;
import de.thedevstack.conversationsplus.utils.MessageUtil;
import de.thedevstack.conversationsplus.utils.StreamUtil;
import de.thedevstack.conversationsplus.utils.XmppConnectionServiceAccessor;
import okhttp3.Call;
import okhttp3.Callback;
import okhttp3.Response;

/**
 *
 */
public class HttpFileDownloadCallback implements Callback {
    private HttpDownloadFileTransferEntity entity;

    public HttpFileDownloadCallback(HttpDownloadFileTransferEntity entity) {
        this.entity = entity;
    }


    @Override
    public void onFailure(Call call, IOException e) {
        changeStatus(FileStatus.DOWNLOAD_FAILED);
    }

    @Override
    public void onResponse(Call call, Response response) throws IOException {
        if (response.isSuccessful()) {
            Logging.d("http-download", "Receiving file from remote host");
            DownloadableFile file = this.entity.getFile();
            OutputStream os = AbstractConnectionManager.createOutputStream(file, true);
            os.write(response.body().bytes());
            StreamUtil.close(os);
            FileBackend.updateMediaScanner(file, XmppConnectionServiceAccessor.xmppConnectionService);
            this.entity.transferred();
            changeStatus(FileStatus.DOWNLOADED);
        } else {
            Logging.e("http-download", "Failed to retrieve file from remote host. HTTP response: " + response.code() + ", " + response.body().string());
            changeStatus(FileStatus.DOWNLOAD_FAILED);
        }
        if (entity.wakeLock.isHeld()) {
            entity.wakeLock.release();
        }
    }

    private void changeStatus(FileStatus status) {
        MessageUtil.setAndSaveFileStatus(this.entity.getMessage(), status);
    }
}