// Copyright (c) 2014, 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.

import 'dart:async';

import 'package:analysis_server/protocol/protocol.dart';
import 'package:analysis_server/protocol/protocol_constants.dart';
import 'package:analysis_server/protocol/protocol_generated.dart';
import 'package:analyzer_plugin/protocol/protocol_common.dart';
import 'package:test/test.dart';
import 'package:test_reflective_loader/test_reflective_loader.dart';

import '../analysis_abstract.dart';

main() {
  defineReflectiveSuite(() {
    defineReflectiveTests(ReanalyzeTest);
    defineReflectiveTests(ReanalyzeTest_UseCFE);
  });
}

@reflectiveTest
class ReanalyzeTest extends AbstractAnalysisTest {
  Map<String, List<AnalysisError>> filesErrors = {};

  Completer _resultsAvailable = new Completer();

  @override
  void processNotification(Notification notification) {
    if (notification.event == ANALYSIS_NOTIFICATION_ERRORS) {
      var decoded = new AnalysisErrorsParams.fromNotification(notification);
      filesErrors[decoded.file] = decoded.errors;
      _resultsAvailable.complete(null);
    }
  }

  test_reanalyze() {
    createProject();
    Map drivers = server.driverMap;
    expect(drivers, hasLength(1));
    Request request = new Request("0", ANALYSIS_REQUEST_REANALYZE);
    handleSuccessfulRequest(request);
    drivers = server.driverMap;
    expect(drivers, hasLength(1));
  }

  test_reanalyze_with_overlay() async {
    createProject();
    newFolder(testFolder);
    newFile(testFile, content: 'main() {}');
    // Update the content with an overlay that contains a syntax error.
    server.updateContent('1', {testFile: new AddContentOverlay('main() {')});
    await _resultsAvailable.future;
    // Verify that the syntax error was detected.
    {
      List<AnalysisError> errors = filesErrors[testFile];
      expect(errors, hasLength(1));
    }
    // Remove testFile from filesErrors so that we'll notice when the file is
    // re-analyzed.
    filesErrors.remove(testFile);
    // Reanalyze.
    _resultsAvailable = new Completer();
    server.reanalyze(null);
    await _resultsAvailable.future;
    // The file should have been reanalyzed.
    expect(filesErrors, contains(testFile));
    // Verify that the syntax error is present (this indicates that the
    // content introduced by the call to updateContent is still in effect).
    {
      List<AnalysisError> errors = filesErrors[testFile];
      expect(errors, hasLength(1));
    }
  }
}

@reflectiveTest
class ReanalyzeTest_UseCFE extends ReanalyzeTest {
  @override
  bool get useCFE => true;
}