/*
    * Licensed to The Apereo Foundation under one or more contributor license
    * agreements. See the NOTICE file distributed with this work for additional
    * information regarding copyright ownership.
    *
    *
    * The Apereo Foundation licenses this file to you under the Educational
    * Community 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://opensource.org/licenses/ecl2.txt
   *
   * 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.opencastproject.silencedetection.ffmpeg;
  
  import org.opencastproject.mediapackage.MediaPackageException;
  import org.opencastproject.mediapackage.Track;
  import org.opencastproject.silencedetection.api.MediaSegment;
  import org.opencastproject.silencedetection.api.MediaSegments;
  import org.opencastproject.silencedetection.api.SilenceDetectionFailedException;
  import org.opencastproject.silencedetection.impl.SilenceDetectionProperties;
  import org.opencastproject.util.NotFoundException;
  import org.opencastproject.workspace.api.Workspace;
  
  import org.apache.commons.lang3.StringUtils;
  import org.osgi.framework.BundleContext;
  import org.slf4j.Logger;
  import org.slf4j.LoggerFactory;
  
  import java.io.BufferedReader;
  import java.io.File;
  import java.io.IOException;
  import java.io.InputStreamReader;
  import java.text.DecimalFormat;
  import java.text.DecimalFormatSymbols;
  import java.util.LinkedList;
  import java.util.List;
  import java.util.Locale;
  import java.util.Properties;
  import java.util.regex.Matcher;
  import java.util.regex.Pattern;
  
  /**
   * Find silent sequences in audio stream using Gstreamer.
   */
  public class FFmpegSilenceDetector {
  
    private static final Logger logger = LoggerFactory.getLogger(FFmpegSilenceDetector.class);
  
    public static final String FFMPEG_BINARY_CONFIG = "org.opencastproject.composer.ffmpeg.path";
    public static final String FFMPEG_BINARY_DEFAULT = "ffmpeg";
  
    private static final Long DEFAULT_SILENCE_MIN_LENGTH = 5000L;
    private static final Long DEFAULT_SILENCE_PRE_LENGTH = 2000L;
    private static final String DEFAULT_THRESHOLD_DB = "-40dB";
    private static final Long DEFAULT_VOICE_MIN_LENGTH = 60000L;
  
    private static String binary = FFMPEG_BINARY_DEFAULT;
    private String filePath;
    private String trackId;
  
    private List<MediaSegment> segments = null;
  
    /**
     * Update FFMPEG binary path if set in configuration.
     *
     * @param bundleContext
     */
    public static void init(BundleContext bundleContext) {
      String binaryPath = bundleContext.getProperty(FFMPEG_BINARY_CONFIG);
      try {
        if (StringUtils.isNotBlank(binaryPath)) {
          File binaryFile = new File(StringUtils.trim(binaryPath));
          if (binaryFile.exists()) {
            binary = binaryFile.getAbsolutePath();
          } else {
            logger.warn("FFmpeg binary file {} does not exist", StringUtils.trim(binaryPath));
          }
        }
      } catch (Exception ex) {
        logger.error("Failed to set ffmpeg binary path", ex);
      }
    }
  
  
    /**
     * Create nonsilent sequences detection pipeline.
     * Parse audio stream and store all positions, where the volume level fall under the threshold.
     *
     * @param properties
     * @param track source track
    */
   public FFmpegSilenceDetector(Properties properties, Track track, Workspace workspace)
           throws SilenceDetectionFailedException, MediaPackageException, IOException {
 
     long minSilenceLength;
     long minVoiceLength;
     long preSilenceLength;
     String thresholdDB;
 
     //Ensure properties is not null, avoids null checks later
     if (null == properties) {
       properties = new Properties();
     }
 
     minSilenceLength = parseLong(properties, SilenceDetectionProperties.SILENCE_MIN_LENGTH, DEFAULT_SILENCE_MIN_LENGTH);
     minVoiceLength = parseLong(properties, SilenceDetectionProperties.VOICE_MIN_LENGTH, DEFAULT_VOICE_MIN_LENGTH);
     preSilenceLength = parseLong(properties, SilenceDetectionProperties.SILENCE_PRE_LENGTH, DEFAULT_SILENCE_PRE_LENGTH);
     thresholdDB = properties.getProperty(SilenceDetectionProperties.SILENCE_THRESHOLD_DB, DEFAULT_THRESHOLD_DB);
 
     trackId = track.getIdentifier();
 
     /* Make sure the element can be analyzed using this analysis implementation */
     if (!track.hasAudio()) {
       logger.warn("Track {} has no audio stream to run a silece detection on", trackId);
       throw new SilenceDetectionFailedException("Element has no audio stream");
     }
 
     /* Make sure we are not allowed to move the beginning of a segment into the last segment */
     if (preSilenceLength > minSilenceLength) {
       logger.error("Pre silence length ({}) is configured to be greater than minimun silence length ({})",
           preSilenceLength, minSilenceLength);
       throw new SilenceDetectionFailedException("preSilenceLength > minSilenceLength");
     }
 
     try {
       File mediaFile = workspace.get(track.getURI());
       filePath = mediaFile.getAbsolutePath();
     } catch (NotFoundException e) {
       throw new SilenceDetectionFailedException("Error finding the media file in workspace", e);
     } catch (IOException e) {
       throw new SilenceDetectionFailedException("Error reading media file in workspace", e);
     }
 
     if (track.getDuration() == null) {
       throw new MediaPackageException("Track " + trackId + " does not have a duration");
     }
     logger.debug("Track {} loaded, duration is {} s", filePath, track.getDuration() / 1000);
     logger.info("Starting silence detection of {}", filePath);
     DecimalFormat decimalFmt = new DecimalFormat("0.000", new DecimalFormatSymbols(Locale.US));
     String minSilenceLengthInSeconds = decimalFmt.format((double) minSilenceLength / 1000.0);
     String filter = "silencedetect=noise=" + thresholdDB + ":duration=" + minSilenceLengthInSeconds;
     String[] command = new String[] {
         binary, "-nostats", "-nostdin", "-i", filePath, "-vn", "-filter:a", filter, "-f", "null", "-"};
 
     logger.info("Running {}", (Object) command);
 
     ProcessBuilder pbuilder = new ProcessBuilder(command);
     List<String> segmentsStrings = new LinkedList<String>();
     Process process = pbuilder.start();
     try (BufferedReader reader = new BufferedReader(new InputStreamReader(process.getErrorStream()))) {
       String line = reader.readLine();
       while (null != line) {
         /* We want only lines from the silence detection filter */
         logger.debug("FFmpeg output: {}", line);
         if (line.startsWith("[silencedetect ") // FFmpeg <= 8.0
             || line.startsWith("[Parsed_silencedetect_")) { // FFmpeg > 8.0
           segmentsStrings.add(line);
         }
         line = reader.readLine();
       }
     } catch (IOException e) {
       logger.error("Error executing ffmpeg", e);
     }
 
     /*
      * Example output:
      * [silencedetect @ 0x2968e40] silence_start: 466.486
      * [silencedetect @ 0x2968e40] silence_end: 469.322 | silence_duration: 2.83592
      */
 
     LinkedList<MediaSegment> segmentsTmp = new LinkedList<>();
     if (!segmentsStrings.isEmpty()) {
       long lastSilenceEnd = 0;
       long lastSilenceStart = 0;
       Pattern patternStart = Pattern.compile("silence_start\\:\\ \\d+\\.\\d+");
       Pattern patternEnd = Pattern.compile("silence_end\\:\\ \\d+\\.\\d+");
       for (String seginfo : segmentsStrings) {
         /* Match silence ends */
         Matcher matcher = patternEnd.matcher(seginfo);
         String time = "";
         while (matcher.find()) {
           time = matcher.group().substring(13);
         }
         if (!"".equals(time)) {
           long silenceEnd = (long) (Double.parseDouble(time) * 1000);
           if (silenceEnd > lastSilenceEnd) {
             logger.debug("Found silence end at {}", silenceEnd);
             lastSilenceEnd = silenceEnd;
           }
           continue;
         }
 
         /* Match silence start -> End of segments */
         matcher = patternStart.matcher(seginfo);
         time = "";
         while (matcher.find()) {
           time = matcher.group().substring(15);
         }
         if (!"".equals(time)) {
           lastSilenceStart = (long) (Double.parseDouble(time) * 1000);
           logger.debug("Found silence start at {}", lastSilenceStart);
           if (lastSilenceStart - lastSilenceEnd > minVoiceLength) {
             /* Found a valid segment */
             long segmentStart = java.lang.Math.max(0, lastSilenceEnd - preSilenceLength);
             logger.info("Adding segment from {} to {}", segmentStart, lastSilenceStart);
             segmentsTmp.add(new MediaSegment(segmentStart, lastSilenceStart));
           }
         }
       }
       /* Add last segment if it is no silence and the segment is long enough */
       if (lastSilenceStart < lastSilenceEnd && track.getDuration() - lastSilenceEnd > minVoiceLength) {
         long segmentStart = java.lang.Math.max(0, lastSilenceEnd - preSilenceLength);
         logger.info("Adding final segment from {} to {}", segmentStart, track.getDuration());
         segmentsTmp.add(new MediaSegment(segmentStart, track.getDuration()));
       }
     }
 
     logger.info("Segmentation of track {} yielded {} segments", trackId, segmentsTmp.size());
     segments = segmentsTmp;
 
   }
 
   private Long parseLong(Properties properties, String key, Long defaultValue) {
     try {
       return Long.parseLong(properties.getProperty(key, defaultValue.toString()));
     } catch (NumberFormatException e) {
       logger.warn("Configuration value for {} is invalid, using default value of {} instead", key, defaultValue);
       return defaultValue;
     }
   }
 
   /**
    * Returns found media segments.
    * @return nonsilent media segments
    */
   public MediaSegments getMediaSegments() {
     if (segments == null) {
       return null;
     }
 
     return new MediaSegments(trackId, filePath, segments);
   }
 }