sdis1819-t7g07

package protocols;

import channels.MdbChannel;

import peer.Peer;

import utils.Chunk;

import utils.FileController;

import utils.Utils;

import java.io.IOException;

import java.security.NoSuchAlgorithmException;

import java.util.ArrayList;

public class BackupProtocol {

    FileController file;

    private int[] peers;

    private String fileId;

    private int chunkNo;

    public BackupProtocol(String[] requestArgs) throws IOException, NoSuchAlgorithmException {

        file = new FileController(requestArgs[0], Utils.version, Peer.getSenderId(),requestArgs[1],requestArgs[2]);

        backUpFile();

    }

    private void backUpFile() throws IOException, NoSuchAlgorithmException {

        file.openStream();

        file.hashFileId();

        int size = file.getSize();

        this.fileId=file.getHashedFileId();

        sendToPeers(size);

    }

    private void sendToPeers(int size) throws IOException, NoSuchAlgorithmException {

        for(int i=0; (i==0 || size > 0);i++){

            this.peers = new int[0];

            boolean done = false;

            int attempts = 0;

            int delay = 1000;

            size -= 64000;

            byte[] header = file.header(i);

            Chunk chunk = new Chunk(header,file);

            while(!done && attempts<5){

                System.out.println("BACKUP: Sending chunk of: " + file.getFileName() + "  ||  Size Remaining:" + size + " ||  Header: " + new String(header,0,header.length));

                this.chunkNo = i;

                MdbChannel.sendMessage(chunk.getBuffer());

                try{

                    Thread.sleep(delay);

                } catch(InterruptedException e){

                    e.getCause();

                }

                if(Integer.parseInt(file.getReplicationDeg()) <= this.peers.length){

                    done = true;

                }

                else{

                    attempts++;

                    delay=2*delay;

                }

            }

        }

        System.out.println(("DONE"));

    }

}