sdis1819-t7g06

package Storage;

import java.io.FileInputStream;

import java.io.IOException;

import java.util.ArrayList;

import static Global.Globals.MAX_CHUNK_SIZE;

public class ChunksManager {

    ArrayList<Chunk> chunks;

    int peerId;

    int replicationDegree;

    public ChunksManager(String filepath, int rep, int peerId) throws IOException {

        this.peerId = peerId;

        replicationDegree = rep;

        FileInputStream file = new FileInputStream(filepath);

        String[] b = filepath.split("/");

        this.chunks = new ArrayList<>();

        split(file, b[b.length - 1]);

    }

    private void split(FileInputStream fileInfo, String fileID) {

        int x = 0;

        int chunkNo = 0;

        try {

            while (x != -1) {

                byte[] a = new byte[MAX_CHUNK_SIZE];

                byte[] temp;

                x = fileInfo.read(a);

                if (x == -1) {

                    temp = new byte[0];

                    Chunk chunk = new Chunk(chunkNo, temp, peerId, fileID, replicationDegree);

                    chunks.add(chunkNo, chunk);

                    break;

                } else if (x < MAX_CHUNK_SIZE) {

                    temp = new byte[x];

                    System.arraycopy(a, 0, temp, 0, x);

                    Chunk chunk = new Chunk(chunkNo, temp, peerId, fileID, replicationDegree);

                    chunks.add(chunkNo, chunk);

                    break;

                }

                Chunk chunk = new Chunk(chunkNo, a, peerId, fileID, replicationDegree);

                chunks.add(chunkNo, chunk);

                chunkNo++;

            }

            /*if(chunks.get(chunkNo).getInfo().length == MAX_CHUNK_SIZE){

                chunkNo++;

                chunks.add(chunkNo,new Chunk(chunkNo, new byte[0], peerId));

            }*/

            fileInfo.close();

        } catch (IOException e) {

            //e.printStackTrace();

        }

    }

    public ArrayList<Chunk> getChunks() {

        return chunks;

    }

    public int getPeerId() {

        return peerId;

    }

}