/*
 * Copyright (C) 2015 Pedro Vicente Gomez Sanchez.
 *
 * 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 com.github.pedrovgs.lynx.model;

import com.github.pedrovgs.lynx.LynxConfig;
import com.github.pedrovgs.lynx.exception.IllegalTraceException;
import java.util.LinkedList;
import java.util.List;

/**
 * Main business logic class for this project. Lynx responsibility is related to listen Logcat
 * events and notify it to the Lynx listeners transforming all the information from a plain String
 * to a Trace with all the information needed.
 *
 * @author Pedro Vicente Gómez Sánchez.
 */
public class Lynx {

  private static final int MIN_NOTIFICATION_TIME_FREQUENCY = 10;

  private final Logcat logcat;
  private final MainThread mainThread;
  private final TimeProvider timeProvider;

  private final List<Listener> listeners;
  private final List<Trace> tracesToNotify;
  private long lastNotificationTime;
  private LynxConfig lynxConfig = new LynxConfig();

  public Lynx(Logcat logcat, MainThread mainThread, TimeProvider timeProvider) {
    this.listeners = new LinkedList<Listener>();
    this.tracesToNotify = new LinkedList<Trace>();
    this.logcat = logcat;
    this.mainThread = mainThread;
    this.timeProvider = timeProvider;
  }

  public synchronized void setConfig(LynxConfig lynxConfig) {
    this.lynxConfig = lynxConfig;
  }

  public void startReading() {
    logcat.setListener(new Logcat.Listener() {
      @Override public void onTraceRead(String logcatTrace) {
        try {
          addTraceToTheBuffer(logcatTrace);
        } catch (IllegalTraceException e) {
          return;
        }
        notifyNewTraces();
      }
    });
    logcat.start();
  }

  public void stopReading() {
    logcat.stopReading();
  }

  public void registerListener(Listener lynxPresenter) {
    listeners.add(lynxPresenter);
  }

  public void unregisterListener(Listener lynxPresenter) {
    listeners.remove(lynxPresenter);
  }

  private synchronized void addTraceToTheBuffer(String logcatTrace) throws IllegalTraceException {
    if (shouldAddTrace(logcatTrace)) {
      Trace trace = Trace.fromString(logcatTrace);
      tracesToNotify.add(trace);
    }
  }

  private boolean shouldAddTrace(String logcatTrace) {
    boolean hasFilterConfigured = lynxConfig.hasFilter();
    return !hasFilterConfigured || traceMatchesFilter(logcatTrace);
  }

  private boolean traceMatchesFilter(String logcatTrace) {
    String filter = lynxConfig.getFilter().toLowerCase();
    String logcatTraceLowercase = logcatTrace.toLowerCase();
    return logcatTraceLowercase.contains(filter);
  }

  private void notifyNewTraces() {
    if (shouldNotifyListeners()) {
      final List<Trace> traces = new LinkedList<Trace>(tracesToNotify);
      tracesToNotify.clear();
      notifyListeners(traces);
    }
  }

  private boolean shouldNotifyListeners() {
    long now = timeProvider.getCurrentTimeMillis();
    long timeFromLastNotification = now - lastNotificationTime;
    boolean hasTracesToNotify = tracesToNotify.size() > 0;
    return timeFromLastNotification > MIN_NOTIFICATION_TIME_FREQUENCY && hasTracesToNotify;
  }

  private void notifyListeners(final List<Trace> traces) {
    mainThread.post(new Runnable() {
      @Override public void run() {
        for (Listener listener : listeners) {
          listener.onNewTraces(traces);
        }
      }
    });
    lastNotificationTime = timeProvider.getCurrentTimeMillis();
  }

  public interface Listener {

    void onNewTraces(List<Trace> traces);
  }
}

@@ -1198,22 +1198,16 @@
 private 
-final 
 Logcat l
@@ -1213,16 +1213,16 @@
 logcat;%0A
+
   privat
@@ -1298,51 +1298,8 @@
 der;
-%0A%0A  private final List%3CListener%3E listeners;
 %0A  p
@@ -1353,34 +1353,40 @@
 ate 
-long lastNotificationTime;
+final List%3CListener%3E listeners;%0A
 %0A  p
@@ -1433,16 +1433,53 @@
 onfig();
+%0A  private long lastNotificationTime;
 %0A%0A  publ
@@ -2247,24 +2247,290 @@
 pReading();%0A
+    logcat.interrupt();%0A  %7D%0A%0A  public void restart() %7B%0A    Logcat.Listener previousListener = logcat.getListener();%0A    logcat.stopReading();%0A    logcat.interrupt();%0A    logcat = (Logcat) logcat.clone();%0A    logcat.setListener(previousListener);%0A    logcat.start();%0A
   %7D%0A%0A  publi
@@ -4206,32 +4206,115 @@
 eMillis();%0A  %7D%0A%0A
+  public LynxConfig getConfig() %7B%0A    return (LynxConfig) lynxConfig.clone();%0A  %7D%0A%0A
   public interfa

Add restart method to Lynx