package Criptoconsola;

import Criptoconsola.Criptoconsola;
import static Criptoconsola.Criptoconsola.tamanyBlocDescarrega;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.MalformedURLException;
import java.net.URL;
import java.util.logging.Level;
import java.util.logging.Logger;

public class FilDescarrega extends Thread {

    private String urlEntrada;
    private String rutaFitxerSortida;

    private String parts[];
    private String directoriTreball;
    private String separadorDirectoris;

    private GestorDescarregas GestorDescarregas;

    private int bytesDescarregats;

    public FilDescarrega(GestorDescarregas GestorDescarregas, String urlEntrada, String rutaFitxerSortida) {

        this.urlEntrada = urlEntrada;
        this.rutaFitxerSortida = rutaFitxerSortida;

        this.GestorDescarregas = GestorDescarregas;

        bytesDescarregats = 0;

    }

    @Override
    public void run() {
        System.out.println("Run 1");

        String urlEntrada = parts[1];
        String nomFitxerSortida = parts[2];
        String rutaFitxerSortida = directoriTreball.toString() + separadorDirectoris + nomFitxerSortida;
        //// Obrim la url
        //
        try {
            URL url = new URL(urlEntrada);
            InputStream streamEntrada = url.openStream();
            //
            OutputStream streamSortida = new FileOutputStream(rutaFitxerSortida);
            //
            byte bloc[] = new byte[tamanyBlocDescarrega];
            //
            int llegits = streamEntrada.read(bloc);
            //
            while (llegits >= 0) {

                System.out.println("Run 2");

                streamSortida.write(bloc, 0, llegits);

                //Comptabilitzem els bytes descarregats
                bytesDescarregats += llegits;

                llegits = streamEntrada.read(bloc);
                if (llegits >= 0) {
                    GestorDescarregas.OnProgresDescarrega(llegits);
                    System.out.println("Run 3");
                }
            }

            GestorDescarregas.OnDescarregaFinalitzada(this);
            streamEntrada.close();
            streamSortida.close();

        } catch (NullPointerException NPE) {
            Logger.getLogger(FilDescarrega.class.getName()).log(Level.SEVERE, null, NPE);

        } catch (MalformedURLException ex) {
            Logger.getLogger(FilDescarrega.class.getName()).log(Level.SEVERE, null, ex);
        } catch (IOException ex) {
            Logger.getLogger(FilDescarrega.class.getName()).log(Level.SEVERE, null, ex);
        }
    }

    public String obtenirUrl() {
        return urlEntrada;
    }

    public int obtenirBytesDescarregats() {
        return bytesDescarregats;
    }

}