sdis1819-t2g03

package protocols;

import server.Peer;

import java.util.Set;

import java.io.IOException;

import java.nio.file.Files;

import java.nio.file.Paths;

import chunk.FileManager;

import handlers.Message;

public class Delete implements Runnable {

    private Peer peer;

    private Message req;

    private FileManager fileManager;

    public Delete(Peer peer, Message req) {

        this.peer = peer;

        this.req = req;

        this.fileManager = peer.getDatabase();

        System.out.println("DELETE begins!");

    }

    @Override

    public void run() {

        String fileID;

        String path;

        Set<Integer> chunks;

        fileID = req.getFileID();

        if (!fileManager.chunkExists(fileID)) {

                System.out.println("Can not find chunks!");

            System.exit(-1);;

        }

        chunks = fileManager.getFileChunksKey(fileID);

        path = peer.getPath("chunks");

        for (Integer chunk : chunks) {

            try {

                Files.delete(Paths.get(path + "/" + fileID + "/" + chunk));

            } catch (IOException e) {

                e.printStackTrace();

            }

        }

        try {

            Files.delete(Paths.get(path + "/" + fileID));

        } catch (IOException e) {

            e.printStackTrace();

        }

        fileManager.deleteFileBackedUp(fileID);

        System.out.println("Delete successful.");

    }

}