sdis1819-t4g03

package threads;

import java.util.ArrayList;

import server.Server;

import java.util.Arrays;

import java.util.List;

import java.util.Random;

import java.util.concurrent.TimeUnit;

public class messageManagement implements Runnable{

        private byte[] msg;

        public messageManagement(byte[] msg) {

                this.msg = msg;

        }

        @Override

        public void run() {

                List<byte[]> HB = getHeaderNBody();

                byte[] header = HB.get(0);

                byte[] body = HB.get(1);

                String message = new String(this.msg, 0, this.msg.length);

                String[] newMessage = message.split(" ");

                String messageType = newMessage[0];

                Double version = Double.parseDouble(newMessage[1]);

                int senderID = Integer.parseInt(newMessage[2]);

                String fileID = newMessage[3];

                int chunkNr = Integer.parseInt(newMessage[4]);

                int replicationDegree = Integer.parseInt(newMessage[5]);

                //removeBlanks(newMessage);        

                switch (newMessage[0]) {

        case "PUTCHUNK":

            putchunkOperation(version, fileID, chunkNr, replicationDegree, body);

            break;

        case "GETCHUNK":

            getchunkOperation(version, senderID, fileID, chunkNr);

            break;

        case "DELETE":

            deleteOperation(version, senderID, fileID);

            break;

        case "REMOVED":

            removedOperation(version, senderID, fileID, chunkNr);

            break;

        case "STORED":

            storedOperation(version, senderID, fileID, chunkNr);

            break;

        }

}

        private void deleteOperation(Double version, int senderID, String fileID) {

                if (Integer.parseInt(fileID) != senderID) { 

            Server.getStorage().deleteStoredChunks(fileID);

            System.out.println("Received DELETE " + version + " " + senderID + " " + fileID);

        }                

        }

        private void removedOperation(Double version, int senderID, String fileID, int chunkNr) {

        }

        private void getchunkOperation(Double version, int senderID, String fileID, int chunkNr) {

                if (Integer.parseInt(fileID) != senderID) {           

                        Random random = new Random();

            System.out.println("Received GETCHUNK " + version + " " + senderID + " " + fileID + " " + chunkNr);

            Server.getThreadLauncher().schedule(new ReceiveGetChunk(fileID, chunkNr), random.nextInt(401), TimeUnit.MILLISECONDS);

                }

        }

        private void storedOperation(Double version, int senderID, String fileID, int chunkNr) {

                if (Integer.parseInt(fileID) != senderID) {           

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

            System.out.println("Received STORED " + version + " " + senderID + " " + fileID + " " + chunkNr);

        }

        }

        private void putchunkOperation(Double version, String fileID, int chunkNr, int replicationDegree, byte[] body) {

                Random r = new Random();

                System.out.println("Received PUTCHUNK " + version + " " + fileID + " " + chunkNr);

                Server.getThreadLauncher().schedule(new ReceivePutchunk(version, fileID, chunkNr, replicationDegree, body), r.nextInt(401), TimeUnit.MILLISECONDS);

        }

        private void removeBlanks(String[] newMessage) {

                for(int i=0; i<newMessage.length; i++) {

                        newMessage[i] = newMessage[i].replaceAll("\\s","" );

                }

        }

        private List<byte[]> getHeaderNBody(){

                int h = this.msg.length -4;

                byte[] header = Arrays.copyOfRange(this.msg, 0 ,h);

                byte[] body = Arrays.copyOfRange(this.msg, h, this.msg.length);

                List<byte[]> headerNBody = new ArrayList<>();

        headerNBody.add(header);

        headerNBody.add(body);

        return headerNBody;

        }

}