import 'dart:io';

import 'package:gherkin/gherkin.dart';

class ResetCwtchEnvironment extends Hook {
  @override
  int get priority => 10;

  @override
  Future<void> onBeforeRun(TestConfiguration config) async {
    // initialize @env:persist
    await Process.run("rm", ["-rf", "integration_test/env/temp-persist"]);
    await Process.run("rm", ["-rf", "integration_test/env/temp"]);
    await Process.run("cp", ["-R", "integration_test/env/persist", "integration_test/env/temp-persist"]);

    return super.onBeforeRun(config);
  }

  @override
  Future<void> onAfterRun(TestConfiguration config) async {
    // Clean up After a Test Run...
    print("clean up environments after run...");
    await Process.run("rm", ["-rf", "integration_test/env/temp-persist"]);
    await Process.run("rm", ["-rf", "integration_test/env/temp"]);
    return super.onAfterRun(config);
  }

  @override
  Future<void> onBeforeScenario(TestConfiguration config, String scenario, Iterable<Tag> tags) async {
    if (tags.any((t) => t.name == "@env:persist")) {
      return Process.run("rm", ["-rf", "integration_test/env/temp"]).then((value) {
        return Process.run("mv",
            ["integration_test/env/temp-persist", "integration_test/env/temp"])
            .then((value) {
          print("copied persist!");
          return super.onBeforeScenario(config, scenario, tags);
        });
      });
    } else if (tags.any((t) => t.name == "@env:aliceandbob1")) {
      return Process.run("rm", ["-rf", "integration_test/env/temp"]).then((value) {
        return Process.run("cp", [
          "-R",
          "integration_test/env/aliceandbob1",
          "integration_test/env/temp"
        ]).then((value) {
          print("copied aliceandbob!");
          return super.onBeforeScenario(config, scenario, tags);
        });
      });
    } else if (!(tags.any((t) => t.name == "@env:clean"))) {
      // use the default environment if no @env: tag specified
      return Process.run("rm", ["-rf", "integration_test/env/temp"]).then((value) {
        return Process.run("cp",
            ["-R", "integration_test/env/default", "integration_test/env/temp"])
            .then((value) {
          print("copied clean!");
          return super.onBeforeScenario(config, scenario, tags);
        });
      });
    }
    print("potentially dirty environment initialized - clean not specified");
    return super.onBeforeScenario(config, scenario, tags);
  }

  @override
  Future<void> onAfterScenario(TestConfiguration config, String scenario, Iterable<Tag> tags, {bool passed = true}) async {
    if (tags.any((t) => t.name == "@env:persist")) {
      await Process.run("mv", ["integration_test/env/temp", "integration_test/env/temp-persist"]);
    }
    return super.onAfterScenario(config, scenario, tags);
  }
}