sdis1819-t7g05

import java.io.File;

import java.io.IOException;

import java.net.DatagramPacket;

import java.net.DatagramSocket;

import java.net.InetAddress;

import java.security.NoSuchAlgorithmException;

/**

 * DeleteTask

 */

public class DeleteTask implements Runnable {

    private static final String CRLF = Integer.toHexString(0xD) + Integer.toHexString(0xA);

    private String filePath;

    private InetAddress MCaddress;

    private int MCport;

    private Peer peer;

    private String version;

    DeleteTask(String pathname, String version, Peer peer) {

        this.filePath = pathname;

        this.MCaddress = peer.getMCaddress();

        this.MCport = peer.getMCport();

        this.version = version;

        this.peer = peer;

    }

    @Override

    public void run() {

        File file = new File(this.filePath);

        try {

            String fileId = BackupFile.generateFileId(this.filePath, file.lastModified());

            DeleteFile deleteFile = new DeleteFile(fileId);

            this.peer.deleteMap.put(fileId, deleteFile);

            DatagramSocket socket = new DatagramSocket();

            //DELETE <Version> <SenderId> <FileId> <CRLF><CRLF>

            String message = "DELETE " + this.version + " " + peer.getSenderId() + " " + fileId + " " + CRLF + CRLF;

            DatagramPacket packet = new DatagramPacket(message.getBytes(), message.length(), this.MCaddress, this.MCport);

            this.peer.print("sending DELETE message");

            socket.send(packet);

            socket.close();

            this.peer.print("DELETE protocol finished");

        } catch (IOException | NoSuchAlgorithmException e) {

            e.printStackTrace();

        }

    }

}