package io.vertx.micrometer.impl;

import io.micrometer.core.instrument.Timer;
import io.micrometer.core.instrument.*;
import io.micrometer.core.instrument.distribution.HistogramSnapshot;
import io.vertx.core.json.JsonObject;
import io.vertx.core.metrics.Measured;
import io.vertx.core.spi.metrics.Metrics;
import io.vertx.core.spi.metrics.MetricsProvider;
import io.vertx.micrometer.MetricsService;

import java.util.*;
import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors;
import java.util.stream.Stream;

Author:
Julien Viet, Joel Takvorian/**
 * @author <a href="mailto:julien@julienviet.com">Julien Viet</a>
 * @author Joel Takvorian
 */
public class MetricsServiceImpl implements MetricsService {

  private final MicrometerMetrics metrics;

  public MetricsServiceImpl(Measured measured) {
    MetricsProvider provider = (MetricsProvider) measured;
    Metrics baseMetrics = provider.getMetrics();
    if (baseMetrics instanceof MicrometerMetrics) {
      metrics = (MicrometerMetrics) baseMetrics;
    } else {
      metrics = null;
    }
  }

  @Override
  public String getBaseName() {
    return metrics != null ? metrics.baseName() : null;
  }

  @Override
  public JsonObject getMetricsSnapshot() {
    return metrics != null ? snapshot(metrics.registry(), metrics.baseName()) : null;
  }

  @Override
  public JsonObject getMetricsSnapshot(String baseName) {
    return metrics != null ? snapshot(metrics.registry(), baseName) : null;
  }

  @Override
  public Set<String> metricsNames() {
    if (metrics != null) {
      return metrics.registry().getMeters().stream()
        .map(m -> m.getId().getName())
        .collect(Collectors.toSet());
    }
    return Collections.emptySet();
  }

  
Returns:
the Micrometer registry used for these metrics, null if no metrics is available./**
   * @return the Micrometer registry used for these metrics, null if no metrics is available.
   */
  public MeterRegistry getRegistry() {
    return metrics != null ? metrics.registry() : null;
  }

  private JsonObject snapshot(MeterRegistry registry, String baseName) {
    Stream<Meter> filtered;
    if (baseName == null) {
      filtered = registry.getMeters().stream();
    } else {
      filtered = registry.getMeters().stream()
        .filter(m -> m.getId().getName().startsWith(baseName));
    }
    LinkedHashMap<String, List<JsonObject>> map = filtered
      .sorted(Comparator.comparing(m -> m.getId().getName()))
      .collect(
        Collectors.groupingBy(m -> m.getId().getName(),
          LinkedHashMap::new,
          Collectors.mapping(MetricsServiceImpl::metricToJson, Collectors.toList())));
    return new JsonObject((Map<String, Object>) (Object) map);
  }

  private static JsonObject metricToJson(Meter meter) {
    JsonObject tags = new JsonObject();
    meter.getId().getTags().forEach(tag -> tags.put(tag.getKey(), tag.getValue()));
    JsonObject obj = new JsonObject().put("tags", tags);
    return meter.match(gauge -> gaugeToJson(obj, gauge),
      counter -> counterToJson(obj, counter),
      timer -> timerToJson(obj, timer),
      summary -> summaryToJson(obj, summary),
      longTaskTimer -> longTaskTimerToJson(obj, longTaskTimer),
      timeGauge -> timeGaugeToJson(obj, timeGauge),
      functionCounter -> functionCounterToJson(obj, functionCounter),
      functionTimer -> functionTimerToJson(obj, functionTimer),
      m -> obj.put("type", "unknown"));
  }

  private static JsonObject summaryToJson(JsonObject obj, DistributionSummary summary) {
    HistogramSnapshot snapshot = summary.takeSnapshot(false);
    return obj.put("type", "summary")
      .put("count", snapshot.count())
      .put("total", snapshot.total())
      .put("mean", snapshot.mean())
      .put("max", snapshot.max());
  }

  private static JsonObject timerToJson(JsonObject obj, Timer timer) {
    return obj.put("type", "timer")
      .put("count", timer.count())
      .put("totalTimeMs", timer.totalTime(TimeUnit.MILLISECONDS))
      .put("meanMs", timer.mean(TimeUnit.MILLISECONDS))
      .put("maxMs", timer.max(TimeUnit.MILLISECONDS));
  }

  private static JsonObject gaugeToJson(JsonObject obj, Gauge gauge) {
    return obj.put("type", "gauge")
      .put("value", gauge.value());
  }

  private static JsonObject counterToJson(JsonObject obj, Counter counter) {
    return obj.put("type", "counter")
      .put("count", counter.count());
  }

  private static JsonObject longTaskTimerToJson(JsonObject obj, LongTaskTimer longTaskTimer) {
    return obj.put("type", "longTaskTimer")
      .put("activeTasks", longTaskTimer.activeTasks())
      .put("durationMs", longTaskTimer.duration(TimeUnit.MILLISECONDS));
  }

  private static JsonObject timeGaugeToJson(JsonObject obj, TimeGauge timeGauge) {
    return obj.put("type", "timeGauge")
      .put("valueMs", timeGauge.value(TimeUnit.MILLISECONDS));
  }

  private static JsonObject functionCounterToJson(JsonObject obj, FunctionCounter functionCounter) {
    return obj.put("type", "functionCounter")
      .put("count", functionCounter.count());
  }

  private static JsonObject functionTimerToJson(JsonObject obj, FunctionTimer functionTimer) {
    return obj.put("type", "functionTimer")
      .put("count", functionTimer.count())
      .put("totalTimeMs", functionTimer.totalTime(TimeUnit.MILLISECONDS))
      .put("meanMs", functionTimer.mean(TimeUnit.MILLISECONDS));
  }
}