src/main/java/com/keuin/kbackupfabric/operation/DeleteOperation.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
58
59
60
61
62
63

package com.keuin.kbackupfabric.operation;

import com.keuin.kbackupfabric.backup.suggestion.BackupNameSuggestionProvider;
import com.keuin.kbackupfabric.operation.abstracts.InvokableAsyncBlockingOperation;
import com.keuin.kbackupfabric.util.PrintUtil;
import com.mojang.brigadier.context.CommandContext;
import net.minecraft.server.MinecraftServer;
import net.minecraft.server.command.ServerCommandSource;

import java.io.File;
import java.io.IOException;

import static com.keuin.kbackupfabric.backup.BackupFilesystemUtil.getBackupSaveDirectory;
import static com.keuin.kbackupfabric.util.PrintUtil.msgErr;
import static com.keuin.kbackupfabric.util.PrintUtil.msgInfo;
import static org.apache.commons.io.FileUtils.forceDelete;

public class DeleteOperation extends InvokableAsyncBlockingOperation {

    //private static final Logger LOGGER = LogManager.getLogger();
    private final String backupFileName;
    private final CommandContext<ServerCommandSource> context;

    public DeleteOperation(CommandContext<ServerCommandSource> context, String backupFileName) {
        super("BackupDeletingWorker");
        this.backupFileName = backupFileName;
        this.context = context;
    }

    @Override
    public String toString() {
        return String.format("deletion of %s", backupFileName);
    }

    @Override
    protected void async() {
        delete();
        BackupNameSuggestionProvider.updateCandidateList();
    }

    private void delete() {
        MinecraftServer server = context.getSource().getMinecraftServer();
        PrintUtil.info("Deleting backup file " + this.backupFileName);
        File backupFile = new File(getBackupSaveDirectory(server), backupFileName);
        int tryCounter = 0;
        do {
            if (tryCounter == 5) {
                String msg = "Failed to delete file " + backupFileName;
                PrintUtil.error(msg);
                msgErr(context, msg);
                return;
            }
            try {
                if (!backupFile.delete())
                    forceDelete(backupFile);
            } catch (SecurityException | NullPointerException | IOException ignored) {
            }
            ++tryCounter;
        } while (backupFile.exists());
        PrintUtil.info("Successfully deleted backup file " + this.backupFileName);
        msgInfo(context, "Successfully deleted backup file " + this.backupFileName);
    }
}