/*
  http-cm - File management extensions to jdk.httpserver
  Copyright (C) 2021  Ulrich Hilger

  This program is free software: you can redistribute it and/or modify
  it under the terms of the GNU Affero General Public License as
  published by the Free Software Foundation, either version 3 of the
  License, or (at your option) any later version.

  This program is distributed in the hope that it will be useful,
  but WITHOUT ANY WARRANTY; without even the implied warranty of
  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  GNU Affero General Public License for more details.

  You should have received a copy of the GNU Affero General Public License
  along with this program.  If not, see <https://www.gnu.org/licenses/>.
 */
package de.uhilger.httpserver.cm.actor;

import com.google.gson.Gson;
import de.uhilger.httpserver.cm.DirList;
import de.uhilger.httpserver.cm.FileManager;
import static de.uhilger.httpserver.cm.FileManager.STR_DOT;
import de.uhilger.httpserver.cm.ImageFileFilter;
import de.uhilger.httpserver.image.Datei;
import de.uhilger.httpserver.image.ImageActor;
import de.uhilger.httpserver.image.ImageThread;
import de.uhilger.httpserver.image.ImageThread.ThreadListener;
import java.io.File;
import java.io.IOException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.logging.Level;
import java.util.logging.Logger;

/**
 * Klasse zum Erzeugen von Dateilisten
 * 
 * @author Ulrich Hilger, 15. Januar 2024
 */
public class Lister implements ThreadListener {
  
  private final List waitingThreads;
  private final int maxThreads;
  private int threadCount;
  
  public Lister() {
    waitingThreads = new ArrayList();
    maxThreads = 4;
    threadCount = 0;    
  }
  
  public String liste(String fName, String ctxPath, String base, String path) throws IOException {
    String dirListPath = ctxPath + fName;
    //if (path.endsWith(STR_SLASH)) {      
      //logger.fine("fName: " + fName);
      File dir = new File(base, fName);
      //logger.fine("absPath: " + dir.getAbsolutePath());
      File[] files = dir.listFiles(new ImageFileFilter());
      if(files != null && files.length > 0) {
        Arrays.sort(files);
        ArrayList liste = new ArrayList();
        for (File file : files) {
          Datei datei = new Datei();
          String dateiName = file.getName();
          datei.setName(dateiName);
          if (file.isDirectory()) {
            datei.setTyp(Datei.TYP_ORDNER);
          } else {
            datei.setTyp(Datei.TYP_DATEI);
          }
          //datei.setPfad(e.getHttpContext().getPath() + fName);
          String lowerName = dateiName.toLowerCase();
          if (lowerName.endsWith(ImageActor.JPEG)
                  || lowerName.endsWith(ImageActor.JPG)
                  || lowerName.endsWith(ImageActor.PNG)) {
            datei.setBild(true);
            String ext = dateiName.substring(dateiName.lastIndexOf(STR_DOT));
            String ohneExt = dateiName.substring(0, dateiName.lastIndexOf(STR_DOT));
            datei.setMiniurl(ohneExt + ImageActor.TN + ext);
            buildImgSrc(file, datei, ohneExt, ext);
          }
          liste.add(datei);
        }
        while(threadCount > 0) {
          try {
            Thread.sleep(50);
          } catch (InterruptedException ex) {
            Logger.getLogger(FileManager.class.getName()).log(Level.SEVERE, null, ex);
          }
        }
        if(liste.size() > 0) {
          DirList list = new DirList();
          list.setPfad(dirListPath);
          list.setDateien(liste);
          Gson gson = new Gson();
          //String json = gson.toJson(liste);
          String json = gson.toJson(list);
          //byte[] bytes = json.getBytes();
          //logger.fine("json: '" + json + "'");
          return json;
        } else {
          return null;
        }
      } else {
        return null;
      }
    //} else {
    //}
  }
  
  public void b64Action(String fName, String base) throws IOException {
      String lowerName = fName.toLowerCase();
      if(lowerName.contains(ImageActor.B64)) {
        ImageActor actor = new ImageActor();
        String fromName = fName.replace(ImageActor.B64, "");
        File fromFile = new File(base, fromName);
        File toFile = new File(base, fName);
        //logger.fine("from " + fromFile.getAbsolutePath() + ", to " + toFile.getAbsolutePath());
        if(!toFile.exists()) {
          actor.b64Image(fromFile, toFile);
        }
      }
  }

  //  data:[<mime type>][;charset=<Zeichensatz>][;base64],<Daten>
  /*
  [So. Juni 13 13:23:32 MESZ 2021] FEIN: 
  file: /home/ulrich/helix-files/bild-test/10419903-14-2-1920-r.jpg, 
  relname: bild-test/10419903-14-2-1920-r.jpg, ohneExt: 10419903-14-2-1920-r, ext: .jpg (de.uhilger.helix.FileManager buildImgSrc)

  */
  private void buildImgSrc(File file, Datei datei, String ohneExt, String ext) throws IOException {
    //logger.fine("file: " + file.getAbsolutePath() + ", ohneExt: " + ohneExt + ", ext: " + ext);
    File dir = file.getParentFile();
    String newRelName = ohneExt + ImageActor.TN + ImageActor.B64 + ext;
    File b64File = new File(dir, newRelName);
    //logger.fine("b64File: " + b64File.getAbsolutePath());
    if(!b64File.exists()) {
      //BildErzeuger be = new BildErzeuger();
      //be.bildErzeugen(dir, newRelName, BildErzeuger.TN, 120, b64File);
      ImageThread it = new ImageThread(dir, newRelName, ImageActor.TN, 120, b64File, datei, ext);
      it.addListener(this);
      if(threadCount < maxThreads) {
        ++threadCount;
        //logger.fine("Thread started, threadCount: " + threadCount);
        it.start();
      } else {
        waitingThreads.add(it);
        //logger.fine("Thread added to wait queue.");
      }
    } else {
      ImageActor be = new ImageActor();
      be.setImgSrc(datei, ext, b64File);
    }
  }
  
  @Override
  public void finished() {
    --threadCount;
    //logger.fine("Thread finished, threadCound now: " + threadCount);
    if (threadCount < maxThreads) {
      if (waitingThreads.size() > 0) {
        Object o = waitingThreads.get(0);
        if (o instanceof ImageThread) {
          waitingThreads.remove(o);
          ImageThread it = (ImageThread) o;
          ++threadCount;
          //logger.fine("Thread started from wait queue, threadCount now: " + threadCount);
          it.start();
        }
      }
    }
  }  
  
  
}