/*
    * #%L
    * IsisFish
    * 
    * $Id: LoggerHelper.java 4301 2015-09-29 16:46:43Z echatellier $
    * $HeadURL: https://svn.codelutin.com/isis-fish/tags/isis-fish-4.4.0.2/src/test/java/fr/ifremer/isisfish/logging/LoggerHelper.java $
    * %%
    * Copyright (C) 2006 - 2010 Ifremer, Code Lutin
    * %%
   * This program is free software: you can redistribute it and/or modify
   * it under the terms of the GNU 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 General Public License for more details.
   * 
   * You should have received a copy of the GNU General Public 
   * License along with this program.  If not, see
   * <http://www.gnu.org/licenses/gpl-3.0.html>.
   * #L%
   */
  
  package fr.ifremer.isisfish.logging;
  
  import java.io.BufferedWriter;
  import java.io.File;
  import java.io.FileWriter;
  import java.io.IOException;
  import java.io.UnsupportedEncodingException;
  
  import org.apache.commons.logging.Log;
  import org.apache.commons.logging.LogFactory;
  import org.nuiton.util.StringUtil;
  
  /**
   * Usefull methods for tests.
   *
   * @author chemit
   */
  public abstract class LoggerHelper {
  
      public static String filename;
      public static long MEGA_STREAM_SIZE = 6 * 100000;
      private static long totalPause;
  
      protected static final Log log = LogFactory.getLog(LoggerHelper.class);
  
      public static void createMock(File testDir, String filename, int i) throws IOException, InterruptedException {
          LoggerHelper.MEGA_STREAM_SIZE = 6 * i;
          LoggerHelper.filename = new File(testDir, filename).getAbsolutePath();
          File file = new File(testDir, filename);
          long t0 = System.nanoTime();
          mockLogFile();
          long t1;
  
          t1 = System.nanoTime();
          log.info("create [" + LoggerHelper.MEGA_STREAM_SIZE + "] in " + StringUtil.convertTime(t1 - t0) + " [file: " + file + ", length: " + StringUtil.convertMemory(file.length()) + "]");
          System.gc();
      }
  
      static void pause(long time) throws InterruptedException {
          Thread.sleep(time);
          totalPause += time;
          System.gc();
      }
  
      /**
       * create a mock of logEvents
       *
       * @throws java.io.IOException  todo
       * @throws InterruptedException todo
       */
      public static void mockLogFile() throws IOException, InterruptedException {
          File f = new File(filename);
          if (f.exists()) {
              f.delete();
          }
          BufferedWriter s = new BufferedWriter(new FileWriter(f));
          int MAX_0 = (int) (MEGA_STREAM_SIZE / 6);
          int i = 0;
          long t0, t00;
          long t1;
          totalPause = 0;
          t00 = System.currentTimeMillis();
          t0 = System.currentTimeMillis();
          try {
  
              for (i = 0; i < MAX_0; i++) {
                  LogRecord record = LogRecord.newInstance(LogLevel.FATAL, 0, i + "debug ", "ioreiovrio veuio vreupo xz xe opiu tep uxr u ", "xeoiujoiz xpo puoi rui hp", i, new String[0]);
                  s.write(record.toString() + '\n');
                  s.flush();
              }
  
              t1 = System.currentTimeMillis();
              log.debug("create next [" + MAX_0 + "] in " + StringUtil.convertTime(t1 - t0) + " | total " + i + " in " + StringUtil.convertTime(t1 - totalPause - t00));
              //pause(500);
             t0 = System.currentTimeMillis();
 
             for (i = MAX_0; i < 2 * MAX_0; i++) {
                 LogRecord record = LogRecord.newInstance(LogLevel.WARN, 0, i + " warn", "jkljfdjkl fdkjlkj lkjdlkfjl dfkljl dflkfdj lfdjlk fjdlkj fdl", "vmfof o rieipk?prj,anklvndfkljn gmlrtsoijrmoig", i, new String[0]);
                 s.write(record.toString() + '\n');
             }
             t1 = System.currentTimeMillis();
             log.debug("create next [" + MAX_0 + "] in " + StringUtil.convertTime(t1 - t0) + " | total " + i + " in " + StringUtil.convertTime(t1 - totalPause - t00));
             //pause(500);
             t0 = System.currentTimeMillis();
             for (i = 2 * MAX_0; i < 3 * MAX_0; i++) {
                 LogRecord record = LogRecord.newInstance(LogLevel.INFO, 0, i + " info", "grlgjlrmgr  jglerj mgrjm  gre pjkogremoiqp   jgpo rejopigjrej,m", "grkgherjfezoprjgbpdofajhlbnb;k nfkfjgmjmsg", i, new String[0]);
                 s.write(record.toString() + '\n');
             }
             t1 = System.currentTimeMillis();
             log.debug("create next [" + MAX_0 + "] in " + StringUtil.convertTime(t1 - t0) + " | total " + i + " in " + StringUtil.convertTime(t1 - totalPause - t00));
             //pause(500);
             t0 = System.currentTimeMillis();
             for (i = 3 * MAX_0; i < 4 * MAX_0; i++) {
                 LogRecord record = LogRecord.newInstance(LogLevel.DEBUG, 0, i + " debug", "grmgjueroijiorehjnjodj j gn mbr,nhltrhjjdo jp joi   jreio j", "gezoeteroiyerphehkzb,fgbd bcmsherkgheiusbcjkdvberb ", i, new String[0]);
                 s.write(record.toString() + '\n');
                 s.flush();
             }
             t1 = System.currentTimeMillis();
             log.debug("create next [" + MAX_0 + "] in " + StringUtil.convertTime(t1 - t0) + " | total " + i + " in " + StringUtil.convertTime(t1 - totalPause - t00));
             //pause(500);
             t0 = System.currentTimeMillis();
             for (i = 4 * MAX_0; i < 5 * MAX_0; i++) {
                 LogRecord record = LogRecord.newInstance(LogLevel.TRACE, 0, i + " trace", "ffgkdhvlsdknjk   eriopgejo ipjiropj i io poi opijgr pe jupoieruj ga geigerihpi oeop erp ", "griofeioteogbbekjbnrjemk prejrlmekhgrehivbn   rekhgrhi ", i, new String[0]);
                 s.write(record.toString() + '\n');
             }
             t1 = System.currentTimeMillis();
             log.debug("create next [" + MAX_0 + "] in " + StringUtil.convertTime(t1 - t0) + " | total " + i + " in " + StringUtil.convertTime(t1 - totalPause - t00));
             //pause(500);
             t0 = System.currentTimeMillis();
             for (i = 5 * MAX_0; i < 6 * MAX_0; i++) {
                 LogRecord record = LogRecord.newInstance(LogLevel.TRACE, 0, i + " user", "grekgrhze t  e re klgre ge rgre gre gfer g rjyukj yujty reez ze fz", "gekfhezh zhrze hgerhglkrej ljbvkxdfn df,ekgrrnvkmn", i, new String[0]);
                 s.write(record.toString() + '\n');
                 s.flush();
             }
             t1 = System.currentTimeMillis();
             log.debug("create next [" + MAX_0 + "] in " + StringUtil.convertTime(t1 - t0) + " | total " + i + " in " + StringUtil.convertTime(t1 - totalPause - t00));
         } catch (OutOfMemoryError e) {
             t1 = System.currentTimeMillis();
             log.info("failed after | total " + i + " in " + StringUtil.convertTime(t1 - totalPause - t00));
             e.printStackTrace();
         } finally {
             if (s != null) {
                 s.flush();
                 s.close();
             }
         }
     }
 
     /**
      * create a mock of logEvents
      *
      * @throws java.io.IOException  todo
      * @throws InterruptedException todo
      */
     public static void mockLogFile2() throws IOException, InterruptedException {
         File f = new File(filename);
         if (f.exists()) {
             f.delete();
         }
         BufferedWriter s = new BufferedWriter(new FileWriter(f));
         int MAX_0 = (int) (MEGA_STREAM_SIZE / 6);
         int i = 0;
         long t0, t00;
         long t1;
         totalPause = 0;
         t00 = System.currentTimeMillis();
         t0 = System.currentTimeMillis();
         try {
 
             for (i = 0; i < MAX_0; i++) {
                 LogRecord record = LogRecord.newInstance(LogLevel.FATAL, 0, i + "debug ", "ioreiovrio veuio vreupo xz xe opiu tep uxr u ", "xeoiujoiz xpo puoi rui hp", i, new String[0]);
                 s.write(record.toString() + '\n');
                 s.flush();
             }
 
             t1 = System.currentTimeMillis();
             log.debug("create next [" + MAX_0 + "] in " + StringUtil.convertTime(t1 - t0) + " | total " + i + " in " + StringUtil.convertTime(t1 - totalPause - t00));
             //pause(500);
             t0 = System.currentTimeMillis();
 
             for (i = MAX_0; i < 2 * MAX_0; i++) {
                 LogRecord record = LogRecord.newInstance(LogLevel.WARN, 0, i + " warn", "jkljfdjkl fdkjlkj lkjdlkfjl dfkljl dflkfdj lfdjlk fjdlkj fdl", "vmfof o rieipk?prj,ùnklvndfkljn gmlrtsoîjrmoig", i, new String[0]);
                 s.write(record.toString() + '\n');
             }
             t1 = System.currentTimeMillis();
             log.debug("create next [" + MAX_0 + "] in " + StringUtil.convertTime(t1 - t0) + " | total " + i + " in " + StringUtil.convertTime(t1 - totalPause - t00));
             //pause(500);
             t0 = System.currentTimeMillis();
             for (i = 2 * MAX_0; i < 3 * MAX_0; i++) {
                 LogRecord record = LogRecord.newInstance(LogLevel.INFO, 0, i + " info", "grlgjlrmgr  jglerj mgrjm  gre pjkogremoiqp   jgpo rejopigjrej,m", "grkgherjfezoprjgbpdofùjhlbnb;k nfkfjgmjmsg", i, new String[0]);
                 s.write(record.toString() + '\n');
             }
             t1 = System.currentTimeMillis();
             log.debug("create next [" + MAX_0 + "] in " + StringUtil.convertTime(t1 - t0) + " | total " + i + " in " + StringUtil.convertTime(t1 - totalPause - t00));
             //pause(500);
             t0 = System.currentTimeMillis();
             for (i = 3 * MAX_0; i < 4 * MAX_0; i++) {
                 LogRecord record = LogRecord.newInstance(LogLevel.DEBUG, 0, i + " debug", "grmgjueroijiorehjnjodj j gn mbr,nhltrhjjdo jp joi   jreio j", "gezoeteroiyerphehkzb,fgbd bcmsherkgheiusbcjkdvberb ", i, new String[0]);
                 s.write(record.toString() + '\n');
                 s.flush();
             }
             t1 = System.currentTimeMillis();
             log.debug("create next [" + MAX_0 + "] in " + StringUtil.convertTime(t1 - t0) + " | total " + i + " in " + StringUtil.convertTime(t1 - totalPause - t00));
             //pause(500);
             t0 = System.currentTimeMillis();
             for (i = 4 * MAX_0; i < 5 * MAX_0; i++) {
                 LogRecord record = LogRecord.newInstance(LogLevel.TRACE, 0, i + " trace", "ffgkdhvlsdknjk   eriopgejo ipjiropj i io poi opijgr pe jupoieruj g'^ geigerihpi oeop erp ", "griofeioteogbbekjbnrjemk çprejrlmekhgrehivbn   rekhgrhi ", i, new String[0]);
                 s.write(record.toString() + '\n');
             }
             t1 = System.currentTimeMillis();
             log.debug("create next [" + MAX_0 + "] in " + StringUtil.convertTime(t1 - t0) + " | total " + i + " in " + StringUtil.convertTime(t1 - totalPause - t00));
             //pause(500);
             t0 = System.currentTimeMillis();
             for (i = 5 * MAX_0; i < 6 * MAX_0; i++) {
                 LogRecord record = LogRecord.newInstance(LogLevel.TRACE, 0, i + " user", "grekgrhze t  e re klgre ge rgre gre gfer g rjyukj yujty reez ze fz", "gekfhezh zhrze hgerhglkrej ljbvkxdfn df,ekgrrnvkmn", i, new String[0]);
                 s.write(record.toString() + '\n');
                 s.flush();
             }
             t1 = System.currentTimeMillis();
             log.debug("create next [" + MAX_0 + "] in " + StringUtil.convertTime(t1 - t0) + " | total " + i + " in " + StringUtil.convertTime(t1 - totalPause - t00));
         } catch (OutOfMemoryError e) {
             t1 = System.currentTimeMillis();
             log.info("failed after | total " + i + " in " + StringUtil.convertTime(t1 - totalPause - t00));
             e.printStackTrace();
         } finally {
             if (s != null) {
                 s.flush();
                 s.close();
             }
         }
     }
 
     /**
      * This is a log record (says an entry of a log file). This is abstracted from any
      * logging implementation.
      * 
      * To deal with log, we don't use string version stored in original log file,
      * prefer use serialized form of a LogRecord : we keep a lot of time when using
      * them to display them in ui, and for filtering process too.
      * 
      * The LogRecord unicity is base on two properties :
      * <ul>
      * <li>timestamp</li>
      * <li>message</li>
      * </ul>
      * 
      * We can not use only timestamp, more than one event could appear in a same
      * timestamp.
      * 
      * TODO Put this code in lutinLog ?
      *
      * @author chemit
      */
     public static class LogRecord implements java.io.Serializable {
 
         /** the time of the event */
         protected long timeStamp;
 
         /** the msg for the event */
         protected String message;
 
         /** the severity of the event */
         protected int level;
 
         /** the throwable details the event */
         protected String[] throwableStrRep;
 
         /** origin filename of the event */
         //protected transient String filename;
 
         /** origin method name of the event */
         //protected transient String methodName;
 
         /** origin line number of the event */
         //protected transient int lineNumber;
 
         /**
          * the string represention of logEvent, transient since we use a lazy getter
          * we don't need to store it.
          * 
          * <b>(if not transient : double the size of serialized form...)</b>
          */
         protected transient String text;
 
         /**
          * the offset of logRecord in stream.
          * 
          * This is a transient property, since we compute this value when getting
          * the LogRecord from stream
          */
         protected transient long offset;
 
         private static final long serialVersionUID = 1335077740059488080L;
 
         public static LogRecord newInstance(LogLevel level,
                                             long timestamp,
                                             String message,
                                             String fileName,
                                             String methodName,
                                             int lineNumber,
                                             String[] errors) throws UnsupportedEncodingException {
             return new LogRecord(
                     level == null ? LogLevel.DEBUG.ordinal() : level.ordinal(),
                     timestamp,
                     message,
                     fileName,
                     methodName,
                     lineNumber,
                     errors
             );
         }
 
         protected LogRecord(int level,
                             long timestamp,
                             String message,
                             String filename,
                             String methodName,
                             int lineNumber,
                             String[] throwableStrRep) throws UnsupportedEncodingException {
             this.level = level;
             this.timeStamp = timestamp;
             //this.message = message;
             this.message = new String((filename + ":" + lineNumber + " - " + methodName + " - " + message).getBytes("utf-8"));
             //this.filename = filename;
             //this.methodName = methodName;
             //this.lineNumber = lineNumber;
             this.throwableStrRep = throwableStrRep;
         }
 
         public String getMessage() {
             return message;
         }
 
         public int getLevel() {
             return level;
         }
 
         public String[] getThrowableStrRep() {
             return throwableStrRep;
         }
 
         public long getTimeStamp() {
             return timeStamp;
         }
 
         public int getLineNumber() {
             return 0;
             //return lineNumber;
         }
 
         public String getMethodName() {
             return "";
             //return methodName;
         }
 
         public long getOffset() {
             return offset;
         }
 
         public void setOffset(long offset) {
             this.offset = offset;
         }
 
         /**
          * We use a cache for the representation since we will use a lots of time.
          *
          * @return the String representation used to display logEvent in ui.
          */
         @Override
         public String toString() {
             if (text == null) {
                 text = new StringBuilder(LogLevel.getLogLevel(level).toString()).
                         append(' ').append(message).toString();
             }
             /*if (text == null) {
                 text = new StringBuilder().append(LogLevel.getSimulLogLevel(level)).
                         append(' ').append(filename).append(':').
                         append(lineNumber).append(" - ").
                         append(methodName).append(" - ").append(message).toString();
             }*/
             return text;
         }
 
         /**
          * We base the identiy of a LogEvent on the message, level and timestamp
          *
          * @param o object to compare
          * @return <code>true</code> if same object
          */
 
         @Override
         public boolean equals(Object o) {
             if (this == o) {
                 return true;
             }
             if (o == null || getClass() != o.getClass()) {
                 return false;
             }
 
             LogRecord event = (LogRecord) o;
             return timeStamp == event.timeStamp &&
                     !(message != null ? !message.equals(event.message) :
                             event.message != null);
         }
 
         @Override
         public int hashCode() {
             int result;
             result = (int) (timeStamp ^ (timeStamp >>> 32));
             result = 31 * result + (message != null ? message.hashCode() : 0);
             return result;
         }
 
     }
 }