// Copyright (c) 2016, the Dart project authors.  Please see the AUTHORS file
// for details. All rights reserved. Use of this source code is governed by a
// BSD-style license that can be found in the LICENSE file.

// @dart = 2.9

import 'dart:async';
import 'dart:io';

import "package:expect/expect.dart";

int lastRetryId = 0;

Future retry(Future fun(), {int maxCount: 10}) async {
  final int id = lastRetryId++;
  for (int i = 0; i < maxCount; i++) {
    try {
      // If there is no exception this will simply return, otherwise we keep
      // trying.
      return await fun();
    } catch (e, stack) {
      print("Failed to execute test closure (retry id: ${id}) in attempt $i "
          "(${maxCount - i} retries left).");
      print("Exception: ${e}");
      print("Stacktrace: ${stack}");
    }
  }
  return await fun();
}

Future throws(Function f, bool check(Object exception)) async {
  try {
    await f();
  } catch (e) {
    if (!check(e)) {
      Expect.fail('Unexpected: $e');
    }
    return;
  }
  Expect.fail('Did not throw');
}

// Create a temporary directory and delete it when the test function exits.
Future withTempDir(String prefix, Future<void> test(Directory dir)) async {
  final tempDir = Directory.systemTemp.createTempSync(prefix);
  try {
    await runZonedGuarded(() => test(tempDir), (e, st) {
      try {
        tempDir.deleteSync(recursive: true);
      } catch (_) {
        // ignore errors
      }
      throw e;
    });
  } finally {
    try {
      tempDir.deleteSync(recursive: true);
    } catch (_) {
      // ignore errors
    }
  }
}