Class SetupThread

app/src/main/java/io/neoterm/setup/SetupThread.java:26–165

@author kiva

 */

final class SetupThread extends Thread {
    private final SourceConnection sourceConnection;
    private final File prefixPath;
    private final AppCompatActivity activity;
    private final ResultListener resultListener;
    private final ProgressDialog progressDialog;

    public SetupThread(AppCompatActivity activity, SourceConnection sourceConnection,
                       File prefixPath, ResultListener resultListener,
                       ProgressDialog progressDialog) {
        this.activity = activity;
        this.sourceConnection = sourceConnection;
        this.prefixPath = prefixPath;
        this.resultListener = resultListener;
        this.progressDialog = progressDialog;
    }

    @Override
    public void run() {
        try {
            final String stagingPrefixPath = NeoTermPath.ROOT_PATH + "/usr-staging";
            final File stagingPrefixFile = new File(stagingPrefixPath);

            if (stagingPrefixFile.exists()) {
                deleteFolder(stagingPrefixFile);
            }

            int totalReadBytes = 0;
            final byte[] buffer = new byte[8096];
            final List<Pair<String, String>> symlinks = new ArrayList<>(50);


            try (ZipInputStream zipInput = new ZipInputStream(sourceConnection.getInputStream())) {
                ZipEntry zipEntry;

                int totalBytes = sourceConnection.getSize();

                while ((zipEntry = zipInput.getNextEntry()) != null) {
                    totalReadBytes += zipEntry.getCompressedSize();

                    final int totalReadBytesFinal = totalReadBytes;
                    final int totalBytesFinal = totalBytes;

                    activity.runOnUiThread(() -> {
                        try {
                            double progressFloat = ((double) totalReadBytesFinal) / ((double) totalBytesFinal) * 100.0;
                            progressDialog.setProgress((int) progressFloat);
                        } catch (RuntimeException ignore) {
                            // activity dismissed
                        }
                    });

                    if (zipEntry.getName().contains("SYMLINKS.txt")) {
                        BufferedReader symlinksReader = new BufferedReader(new InputStreamReader(zipInput));
                        String line;
                        while ((line = symlinksReader.readLine()) != null) {
                            if (line.isEmpty()) {
                                continue;