sdis1819-t2g03

package protocols;

import server.Peer;

import sockets.Socket;

import utils.Utils;

import java.io.IOException;

import java.nio.file.Files;

import java.nio.file.Paths;

import chunk.FileManager;

import handlers.Message;

public class DeleteChunk implements Runnable {

    private String version;

    private String pathName;

    private Peer peer;

    public DeleteChunk(String version, String pathName, Peer parentPeer) {

        this.version = version;

        this.pathName = pathName;

        this.peer = parentPeer;

    }

    @Override

    public void run() {

        FileManager fileInformation;

        fileInformation = peer.getFile(pathName);

        if (fileInformation == null) {

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

            System.exit(-1);;

        }

        sendMsgToMC(fileInformation);

        try {

            Files.delete(Paths.get(pathName));

        } catch (IOException e) {

            e.printStackTrace();

        }

        peer.deleteFileFromFileManager(pathName);

    }

    private boolean sendMsgToMC(FileManager fileInformation) {

            String idString = Integer.toString(peer.getID());

        String[] args = { version, idString,fileInformation.getFileID() };

        Message msg = new Message(Utils.MessageType.DELETE, args);

        try {

            peer.sendMsg(Socket.SocketType.MC, msg);

        } catch (IOException e) {

            e.printStackTrace();

            return false;

        }

        return true;

    }

}