/**

  * 

  */

 package com.buckosoft.PicMan.business.util;

 import java.awt.image.BufferedImage;

 import java.io.ByteArrayOutputStream;

 import java.util.Date;

 import java.util.Iterator;

 import java.util.List;

 import javax.imageio.ImageIO;

 import javax.imageio.ImageWriter;

 import javax.imageio.stream.ImageOutputStream;

 import org.apache.commons.logging.Log;

 import org.apache.commons.logging.LogFactory;

 import com.buckosoft.PicMan.business.PicManFacade;

 import com.buckosoft.PicMan.domain.JobLogEntry;

 import com.buckosoft.PicMan.domain.Pic;

 import com.buckosoft.PicMan.image.PicReader;

 /**

  * @author dick

  *

  */

 public class MD5SumUpdater {

         protected final static Log log = LogFactory.getLog(MD5SumUpdater.class);

         private        int picProcessing = 0;

         private        PicManFacade        pmf;

         /** Set the reference to the PicMan API.

          * @param pmf The PicManFacade

          */

         public        void setPicMan(PicManFacade pmf) {

                 this.pmf = pmf;

         }

         /** Which ordinal picture are we working on?

          * This is just a status indicator

          * @return the picProcessing

          */

         public int getPicProcessing() {

                 return picProcessing;

         }

         /** Entry point from BatchManager to run the job

          */

         public void run() {

                 List<Pic> pics = pmf.getDB().getPics();

                 Iterator<Pic> iter = pics.iterator();

                 int        picCount = pics.size();

                 picProcessing = 0;

                 JobLogEntry jle = new JobLogEntry();

                 jle.setType(JobLogEntry.MD5SUM);

                 pmf.addJobToLog(jle);

                 Pic pic;

                 while (iter.hasNext()) {

                         picProcessing++;

                         int cp = picProcessing * 100 / picCount;

                         jle.setName("" + cp + "%");

                         pic = iter.next();

                         calculateMD5Sum(pmf, pic);

                         //log.info("md5sum for " + pic.getName() + " = " + pic.getMd5());

                         pmf.getDB().updatePic(pic);

                 }

                 jle.setEndTime(new Date());

         }

         public static void calculateMD5Sum(PicManFacade pmf, Pic pic) {

                 //FileInputStream fis;

                 String md5;

                 //String fullPath = null;

                 try {

                         BufferedImage bi = pmf.getPicReader().readPic(pic);

                         ByteArrayOutputStream out = new ByteArrayOutputStream();

                         ImageOutputStream ios = ImageIO.createImageOutputStream(out);

                         Iterator<ImageWriter> writers = ImageIO.getImageWritersByFormatName("jpg");

                         ImageWriter writer = (ImageWriter)writers.next();

                         writer.setOutput(ios);

                         writer.write(bi);

                         byte[] data = out.toByteArray();

                         md5 = org.apache.commons.codec.digest.DigestUtils.md5Hex(data);

                         //fullPath = PicReader.getFullPath(pmf, pic);

 //                        fis = new FileInputStream(new File(fullPath));

 //                        md5 = org.apache.commons.codec.digest.DigestUtils.md5Hex(fis);

 //                        fis.close();

                 } catch (Exception e) {

                         // TODO Auto-generated catch block

                         //e.printStackTrace();

                         log.warn("md5 file error on " + PicReader.getFullPath(pmf, pic));

                         pic.setMd5(0);

                         return;

                 }

                 long l = Long.parseLong(md5.substring(0, 8), 16);

                 pic.setMd5(l);

                 //byte[] m = org.apache.commons.codec.digest.DigestUtils.md5(fis);

                 //long l = m[0] + m[1]<<8 + m[2]<<16 + m[3]<<24 + m[4]<<32 + m[5]<<40 + m[6]<<48 + m[7]<<56;

 /*                MessageDigest md = null;

                 try {

                         md = MessageDigest.getInstance("MD5");

                 } catch (NoSuchAlgorithmException e) {

                         log.error(e);

                         return;

                 }

                 InputStream is = null;

                 try {

                         is = Files.newInputStream(Paths.get("file.txt"));

                 } catch (IOException e) {

                         log.error(e);

                         return;

                 }

                 DigestInputStream dis = new DigestInputStream(is, md);

                  Read stream to EOF as normal... 

                 byte[] digest = md.digest();                

 */        }

 }