package com.wavefront.agent.preprocessor;

import com.yammer.metrics.Metrics;
import com.yammer.metrics.core.Counter;
import com.yammer.metrics.core.MetricName;

import org.apache.commons.lang.time.DateUtils;

import javax.annotation.Nullable;
import javax.validation.constraints.NotNull;

import sunnylabs.report.ReportPoint;

/**
 * Filter condition for valid timestamp - should be no more than 1 day in the future
 * and no more than X hours (usually 8760, or 1 year) in the past
 *
 * Created by Vasily on 9/16/16.
 */
public class ReportPointTimestampInRangeFilter extends AnnotatedPredicate<ReportPoint> {

  private final int cutoffHours;
  private final Counter outOfRangePointTimes;
  @Nullable
  private String message = null;

  public ReportPointTimestampInRangeFilter(final int cutoffHours) {
    this.cutoffHours = cutoffHours;
    this.outOfRangePointTimes = Metrics.newCounter(new MetricName("point", "", "badtime"));
  }

  @Override
  public boolean apply(@NotNull ReportPoint point) {
    this.message = null;
    long pointTime = point.getTimestamp();
    long rightNow = System.currentTimeMillis();

    // within <cutoffHours> ago and 1 day ahead
    boolean pointInRange = (pointTime > (rightNow - this.cutoffHours * DateUtils.MILLIS_PER_HOUR)) &&
        (pointTime < (rightNow + DateUtils.MILLIS_PER_DAY));
    if (!pointInRange) {
      outOfRangePointTimes.inc();
      this.message = "WF-402: Point outside of reasonable timeframe (" + point.toString() + ")";
    }
    return pointInRange;
  }

  @Override
  public String getMessage(ReportPoint point) {
    return this.message;
  }
}

@@ -36,16 +36,51 @@
 essor;%0A%0A
+import com.wavefront.common.Clock;%0A
 import c
@@ -1124,32 +1124,17 @@
 w = 
-System.currentTimeMillis
+Clock.now
 ();%0A

Validate point timestamp against drift-corrected clock, not machine time