sdis1819-t4g03

package threads;

import java.io.File;

import java.io.FileOutputStream;

import java.io.IOException;

import chunk.*;

import server.*;

public class ReceivePutchunk implements Runnable {

        private Double version;

        private String fileId;

        private int chunkNr;

        private int replicationDegree;

        private byte[] content;

        public ReceivePutchunk(double version, String fileId, int chunkNr, int replicationDegree, byte[] content) {

                this.version = version;

                this.fileId = fileId;

                this.chunkNr = chunkNr;

                this.replicationDegree = replicationDegree;

                this.content = content;

        }

        @Override

        public void run() {

                String key = fileId + "." + chunkNr;

                for (int i = 0; i < Server.getStorage().getFiles().size(); i++) {

                        if (Server.getStorage().getFiles().get(i).getFileId().equals(fileId))

                                return;

                }

                if (version == 2.0) {

                        if (Server.getStorage().getStoredTimes().get(key) >= replicationDegree)

                                return;

                        if (Server.getStorage().getSpaceAvailable() >= content.length) {

                                Chunk chunk = null;

                                try {

                                        chunk = new Chunk(chunkNr, fileId, replicationDegree, content.length);

                                } catch (IOException e1) {

                                        e1.printStackTrace();

                                }

                                if (!Server.getStorage().addSavedChunk(chunk)) {

                                        return;

                                }

                                Server.getStorage().decSpaceAvailable(content.length);

            //creates the file and saves the chunk

            try {

                String filename = Server.getServerId() + "/" + fileId + "." + chunkNr;

                                        File file = new File(filename);

                                        if (!file.exists()) {

                                                file.getParentFile().mkdirs();

                                                file.createNewFile();

                                        }

                                        try (FileOutputStream fos = new FileOutputStream(filename)) {

                                                fos.write(content);

                                        }

                                } catch (IOException e) {

                                        e.printStackTrace();

                                }

                                Server.getStorage().incStoredOccurrences(fileId, chunkNr);

                                String header = "STORED " + "1.0" + " " + Server.getServerId() + " " + fileId + " " + chunkNr

                                                + "\r\n\r\n";

                                System.out.println(

                                                "Sent " + "STORED " + "1.0" + " " + Server.getServerId() + " " + fileId + " " + chunkNr);

                                try {

                                        Server.getmc().sendMessage(header.getBytes());

                                } catch (IOException e) {

                                        e.printStackTrace();

                                }

                        } else {

                                System.out.println("Not enough space in this peer " + fileId + "_" + chunkNr);

                        }

                }

        }

}