/*
    * Copyright 2012-2021 CodeLibs Project and the Others.
    *
    * Licensed under the Apache License, Version 2.0 (the "License");
    * you may not use this file except in compliance with the License.
    * You may obtain a copy of the License at
    *
    *     http://www.apache.org/licenses/LICENSE-2.0
    *
   * Unless required by applicable law or agreed to in writing, software
   * distributed under the License is distributed on an "AS IS" BASIS,
   * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
   * either express or implied. See the License for the specific language
   * governing permissions and limitations under the License.
   */
  package org.codelibs.fess.util;
  
  import java.io.BufferedReader;
  import java.io.InputStream;
  import java.io.InputStreamReader;
  import java.io.UnsupportedEncodingException;
  import java.util.LinkedList;
  import java.util.List;
  import java.util.function.Consumer;
  
  import org.apache.logging.log4j.LogManager;
  import org.apache.logging.log4j.Logger;
  import org.codelibs.fess.exception.FessSystemException;
  
  public class InputStreamThread extends Thread {
      private static final Logger logger = LogManager.getLogger(InputStreamThread.class);
  
      private BufferedReader br;
  
      public static final int MAX_BUFFER_SIZE = 1000;
  
      private final List<String> list = new LinkedList<>();
  
      private final int bufferSize;
  
      private final Consumer<String> outputCallback;
  
      public InputStreamThread(final InputStream is, final String charset) {
          this(is, charset, MAX_BUFFER_SIZE, null);
      }
  
      public InputStreamThread(final InputStream is, final String charset, final int bufferSize, final Consumer<String> outputCallback) {
          super("InputStreamThread");
          this.bufferSize = bufferSize;
          this.outputCallback = outputCallback;
  
          try {
              br = new BufferedReader(new InputStreamReader(is, charset));
          } catch (final UnsupportedEncodingException e) {
              throw new FessSystemException(e);
          }
      }
  
      @Override
      public void run() {
          boolean running = true;
          while (running) {
              try {
                  final String line = br.readLine();
                  if (line == null) {
                      running = false;
                  } else {
                      if (logger.isDebugEnabled()) {
                          logger.debug(line);
                      }
                      list.add(line);
                      if (outputCallback != null) {
                          outputCallback.accept(line);
                      }
                      if (list.size() > bufferSize) {
                          list.remove(0);
                      }
                  }
              } catch (final Exception e) {
                  running = false;
                  if (logger.isDebugEnabled()) {
                      logger.debug("Failed to process an input stream.", e);
                  }
              }
          }
      }
  
      public String getOutput() {
          final StringBuilder buf = new StringBuilder(100);
          for (final String value : list) {
              buf.append(value).append("\n");
          }
          return buf.toString();
      }
  
      public boolean contains(final String value) {
          for (final String line : list) {
              if (line.trim().equals(value)) {
                  return true;
             }
         }
         return false;
     }
 }