Project

General

Profile

Statistics
| Revision:

root / src / peer / protocols / delete / Delete.java @ 2

History | View | Annotate | Download (776 Bytes)

1
package peer.protocols.delete;
2

    
3
import java.io.File;
4
import java.io.IOException;
5

    
6
import chunk.Chunk;
7
import message.Message;
8
import peer.Peer;
9

    
10
/**
11
 * Delete
12
 */
13
public class Delete implements Runnable {
14

    
15
        private Peer peer;
16
        private String fileId;
17

    
18
        public Delete(Peer peer, String fileId) {
19
                this.peer = peer;
20
                File originalFile = new File(fileId);
21
                this.fileId = Chunk.generateFileId(originalFile);
22
        }
23

    
24
        public void sendDelete() {
25
                Message message = Message.parseDeleteMessage(fileId, peer);
26
                try {
27
                        peer.sendToMc(message);
28
                } catch (IOException e) {
29
                        e.printStackTrace();
30
                }
31
        }
32

    
33
        public void delete() {
34
                peer.getDisk().deleteFileDirectory(fileId);
35
                sendDelete();
36
        }
37

    
38
        @Override
39
        public void run() {
40
                delete();
41
        }
42

    
43
}