import std.process;
import std.stdio;
import std.range;
import std.string;
import std.algorithm.searching;
import std.format;
import std.conv;
import std.file;
import std.parallelism;
import core.thread;

//    pkexec dd if=/run/media/user1101/portable_drive/software/os/manjaro-kde-18.0-stable-x86_64.iso of=/dev/sdd bs=4M status=progress 2>&1 && sync
//    pkexec dd if=/home/user1101/Downloads/mini.iso of=/dev/sdd bs=4M status=progress 2>&1 && sync

int ddOp(in string logFileName, ref bool started) {
    started = true;
    immutable string fileName = "/run/media/user1101/portable_drive/software/os/archlinux-2018.11.01-x86_64.iso";
    immutable string device = "/dev/sdd";
    immutable string command = format("pkexec dd if=/%s of=%s bs=4M status=progress 2>%s && sync",
            fileName, device, logFileName);

    return executeShell(command).status;
}

uint parseLog(string logFileName) {
    try {
        if (!(logFileName.exists))
            return 0;
        auto text = logFileName.readText();
        if (text.splitLines().length == 0)
            return 0;
        if (text.text.splitLines().back.split.front.isNumeric)
            return text.splitLines().back.split.front.to!uint;
    }
    catch (Exception e) {
        return 0;
    }
    return 0;
}

void main() {
    auto logFileName = "/tmp/.dd_op.txt";
    bool ddStarted = false;
    auto invokedd = task!ddOp(logFileName, ddStarted);
    invokedd.executeInNewThread();
    while (!(invokedd.done)) {
        Thread.sleep(500.msecs);
        writeln(parseLog(logFileName));

    }
    if (logFileName.exists()) {
        logFileName.remove;
        ddStarted = false;
    }

}