# Copyright 2023 The Chromium Authors
# Use of this source code is governed by a BSD-style license that can be
# found in the LICENSE file.

from __future__ import annotations

import abc
from typing import TYPE_CHECKING, Iterable

from crossbench import exception
from crossbench.path import AnyPath
from crossbench.probes.results import ProbeResult, ProbeResultDict

if TYPE_CHECKING:
  from crossbench.path import LocalPath
  from crossbench.probes.probe import Probe
  from crossbench.runner.run import Run
  from crossbench.types import JsonMapping


class RunGroup(abc.ABC):

  def __init__(self, throw: bool = False) -> None:
    self._exceptions = exception.Annotator(throw)
    self._path: LocalPath | None = None
    self._merged_probe_results: ProbeResultDict = ProbeResultDict(AnyPath())

  def _set_path(self, path: LocalPath) -> None:
    assert self._path is None
    self._path = path
    self._merged_probe_results = ProbeResultDict(path)

  @property
  def results(self) -> ProbeResultDict:
    assert self._path, "uninitialized probe results"
    return self._merged_probe_results

  @property
  def path(self) -> LocalPath:
    assert self._path
    return self._path

  @property
  def throw(self) -> bool:
    return self._exceptions.throw

  @property
  def exceptions(self) -> exception.Annotator:
    return self._exceptions

  @property
  def is_success(self) -> bool:
    return self._exceptions.is_success

  @property
  @abc.abstractmethod
  def info_stack(self) -> exception.TInfoStack:
    pass

  @property
  @abc.abstractmethod
  def runs(self) -> Iterable[Run]:
    pass

  @property
  def failed_runs(self) -> Iterable[Run]:
    for run in self.runs:
      if not run.is_success:
        yield run

  @property
  def info(self) -> JsonMapping:
    return {
        "runs": len(tuple(self.runs)),
        "failed runs": len(tuple(self.failed_runs))
    }

  def get_local_probe_result_path(self,
                                  probe: Probe,
                                  exists_ok: bool = False) -> LocalPath:
    new_file = self.path / probe.result_path_name
    if not exists_ok:
      assert not new_file.exists(), (
          f"Merged file {new_file} for {self.__class__} exists already.")
    return new_file

  def get_local_probe_result_dir(self,
                                 probe: Probe,
                                 exists_ok: bool = True) -> LocalPath:
    path = self.get_local_probe_result_path(probe, exists_ok)
    path.mkdir(parents=True, exist_ok=exists_ok)
    return path

  def merge(self, probes: Iterable[Probe]) -> None:
    with self._exceptions.info(*self.info_stack):
      for probe in reversed(tuple(probes)):
        with self._exceptions.capture(f"Probe {probe.name} merge results"):
          results = self._merge_probe_results(probe)
          if results is None:
            continue
          self._merged_probe_results[probe] = results

  @abc.abstractmethod
  def _merge_probe_results(self, probe: Probe) -> ProbeResult:
    pass