Initial support for execution domain

pkg/analysis_server/test/domain_execution_test.dart

Index: pkg/analysis_server/test/domain_execution_test.dart
diff --git a/pkg/analysis_server/test/domain_execution_test.dart b/pkg/analysis_server/test/domain_execution_test.dart
new file mode 100644
index 0000000000000000000000000000000000000000..9fee3fcf57a48fefbd43f0160d6a0aa09845dc92
--- /dev/null
+++ b/pkg/analysis_server/test/domain_execution_test.dart
@@ -0,0 +1,274 @@
+// 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.
+
+library test.domain.execution;
+
+import 'package:analyzer/file_system/physical_file_system.dart';
+import 'package:analysis_server/src/analysis_server.dart';
+import 'package:analysis_server/src/constants.dart';
+import 'package:analysis_server/src/domain_execution.dart';
+import 'package:analysis_server/src/protocol.dart';
+import 'mock_sdk.dart';
+import 'package:unittest/unittest.dart';
+
+import 'mocks.dart';
+import 'operation/operation_queue_test.dart';
+import 'package:typed_mock/typed_mock.dart';
+import 'package:analyzer/src/generated/engine.dart';
+import 'package:analyzer/src/generated/source.dart';
+
+main() {
+  group('ExecutionDomainHandler', () {
+    AnalysisServer server;
+    ExecutionDomainHandler handler;
+
+    setUp(() {
+      server = new AnalysisServer(
+          new MockServerChannel(),
+          PhysicalResourceProvider.INSTANCE,
+          new MockPackageMapProvider(),
+          null,
+          new MockSdk());
+      handler = new ExecutionDomainHandler(server);
+    });
+
+    group('createContext/deleteContext', () {
+      test('create/delete multiple contexts', () {
+        Request request =
+            new ExecutionCreateContextParams('/a/b.dart').toRequest('0');
+        Response response = handler.handleRequest(request);
+        expect(response, isResponseSuccess('0'));
+        ExecutionCreateContextResult result =
+            new ExecutionCreateContextResult.fromResponse(response);
+        String id0 = result.id;
+
+        request = new ExecutionCreateContextParams('/c/d.dart').toRequest('1');
+        response = handler.handleRequest(request);
+        expect(response, isResponseSuccess('1'));
+        result = new ExecutionCreateContextResult.fromResponse(response);
+        String id1 = result.id;
+
+        expect(id0 == id1, isFalse);
+
+        request = new ExecutionDeleteContextParams(id0).toRequest('2');
+        response = handler.handleRequest(request);
+        expect(response, isResponseSuccess('2'));
+
+        request = new ExecutionDeleteContextParams(id1).toRequest('3');
+        response = handler.handleRequest(request);
+        expect(response, isResponseSuccess('3'));
+      });
+
+      test('delete non-existent context', () {
+        Request request = new ExecutionDeleteContextParams('13').toRequest('0');
+        Response response = handler.handleRequest(request);
+        // TODO(brianwilkerson) It isn't currently specified to be an error if a
+        // client attempts to delete a context that doesn't exist. Should it be?
+//        expect(response, isResponseFailure('0'));
+        expect(response, isResponseSuccess('0'));
+      });
+    });
+
+    group('mapUri', () {
+      String contextId;
+
+      setUp(() {
+        Request request =
+            new ExecutionCreateContextParams('/a/b.dart').toRequest('0');
+        Response response = handler.handleRequest(request);
+        expect(response, isResponseSuccess('0'));
+        ExecutionCreateContextResult result =
+            new ExecutionCreateContextResult.fromResponse(response);
+        contextId = result.id;
+      });
+
+      tearDown(() {
+        Request request =
+            new ExecutionDeleteContextParams(contextId).toRequest('1');
+        Response response = handler.handleRequest(request);
+        expect(response, isResponseSuccess('1'));
+      });
+
+      test('file to URI', () {
+        Request request =
+            new ExecutionMapUriParams(contextId, file: '/a/b.dart').toRequest('2');
+        Response response = handler.handleRequest(request);
+        expect(response, isResponseSuccess('2'));
+        ExecutionMapUriResult result =
+            new ExecutionMapUriResult.fromResponse(response);
+        expect(result.file, isNull);
+        expect(result.uri, isNotNull);
+        // TODO(brianwilkerson) Test for the correct result.
+      });
+
+      test('URI to file', () {
+        Request request =
+            new ExecutionMapUriParams(contextId, uri: '/a/b.dart').toRequest('3');
+        Response response = handler.handleRequest(request);
+        expect(response, isResponseSuccess('3'));
+        ExecutionMapUriResult result =
+            new ExecutionMapUriResult.fromResponse(response);
+        expect(result.file, isNotNull);
+        expect(result.uri, isNull);
+        // TODO(brianwilkerson) Test for the correct result.
+      });
+
+      test('invalid context id', () {
+        Request request =
+            new ExecutionMapUriParams('xxx', uri: '').toRequest('4');
+        Response response = handler.handleRequest(request);
+        expect(response, isResponseFailure('4'));
+      });
+
+      test('both file and uri', () {
+        Request request =
+            new ExecutionMapUriParams('xxx', file: '', uri: '').toRequest('5');
+        Response response = handler.handleRequest(request);
+        expect(response, isResponseFailure('5'));
+      });
+    });
+
+    group('setSubscriptions', () {
+      test('failure - invalid service name', () {
+        expect(handler.launchDataListener, isNull);
+
+        Request request = new Request('0', EXECUTION_SET_SUBSCRIPTIONS, {
+          SUBSCRIPTIONS: ['noSuchService']
+        });
+        Response response = handler.handleRequest(request);
+        expect(response, isResponseFailure('0'));
+        expect(handler.launchDataListener, isNull);
+      });
+
+      test('success - setting and clearing', () {
+        expect(handler.launchDataListener, isNull);
+
+        Request request = new ExecutionSetSubscriptionsParams(
+            [ExecutionService.LAUNCH_DATA]).toRequest('0');
+        Response response = handler.handleRequest(request);
+        expect(response, isResponseSuccess('0'));
+        expect(handler.launchDataListener, isNotNull);
+
+        request = new ExecutionSetSubscriptionsParams([]).toRequest('0');
+        response = handler.handleRequest(request);
+        expect(response, isResponseSuccess('0'));
+        expect(handler.launchDataListener, isNull);
+      });
+    });
+  });
+
+  group('LaunchDataNotificationListener', () {
+    test('success - setting and clearing', () {
+      Source source1 = new TestSource('/a.dart');
+      Source source2 = new TestSource('/b.dart');
+      Source source3 = new TestSource('/c.dart');
+      Source source4 = new TestSource('/d.dart');
+      Source source5 = new TestSource('/e.html');
+      Source source6 = new TestSource('/f.html');
+      Source source7 = new TestSource('/g.html');
+      Source source8 = new TestSource('/h.dart');
+      Source source9 = new TestSource('/i.dart');
+
+      AnalysisContext context = new AnalysisContextMock();
+      when(context.launchableClientLibrarySources)
+          .thenReturn([source1, source2]);
+      when(context.launchableServerLibrarySources)
+          .thenReturn([source2, source3]);
+      when(context.librarySources).thenReturn([source4]);
+      when(context.getHtmlFilesReferencing(anyObject))
+          .thenReturn([source5, source6]);
+      when(context.htmlSources).thenReturn([source7]);
+      when(context.getLibrariesReferencedFromHtml(anyObject))
+          .thenReturn([source8, source9]);
+
+      AnalysisServer server = new AnalysisServerMock();
+      when(server.getAnalysisContexts()).thenReturn([context]);
+      bool notificationSent = false;
+      when(server.sendNotification(anyObject))
+          .thenInvoke((Notification notification) {
+        ExecutionLaunchDataParams params =
+            new ExecutionLaunchDataParams.fromNotification(notification);
+
+        List<ExecutableFile> executables = params.executables;
+        expect(executables.length, equals(3));
+        expect(
+            executables[0],
+            isExecutableFile(source1, ExecutableKind.CLIENT));
+        expect(
+            executables[1],
+            isExecutableFile(source2, ExecutableKind.EITHER));
+        expect(
+            executables[2],
+            isExecutableFile(source3, ExecutableKind.SERVER));
+
+        Map<String, List<String>> dartToHtml = params.dartToHtml;
+        expect(dartToHtml.length, equals(1));
+        List<String> htmlFiles = dartToHtml[source4.fullName];
+        expect(htmlFiles, isNotNull);
+        expect(htmlFiles.length, equals(2));
+        expect(htmlFiles[0], equals(source5.fullName));
+        expect(htmlFiles[1], equals(source6.fullName));
+
+        Map<String, List<String>> htmlToDart = params.htmlToDart;
+        expect(htmlToDart.length, equals(1));
+        List<String> dartFiles = htmlToDart[source7.fullName];
+        expect(dartFiles, isNotNull);
+        expect(dartFiles.length, equals(2));
+        expect(dartFiles[0], equals(source8.fullName));
+        expect(dartFiles[1], equals(source9.fullName));
+
+        notificationSent = true;
+      });
+      LaunchDataNotificationListener listener =
+          new LaunchDataNotificationListener(server);
+      listener.analysisComplete();
+      expect(notificationSent, isTrue);
+    });
+  });
+}
+
+/**
+ * A [Source] that knows it's [fullName].
+ */
+class TestSource implements Source {
+  String fullName;
+
+  TestSource(this.fullName);
+
+  @override
+  noSuchMethod(Invocation invocation) => super.noSuchMethod(invocation);
+}
+
+/**
+ * Return a matcher that will match an [ExecutableFile] if it has the given
+ * [source] and [kind].
+ */
+Matcher isExecutableFile(Source source, ExecutableKind kind) {
+  return new IsExecutableFile(source.fullName, kind);
+}
+
+/**
+ * A matcher that will match an [ExecutableFile] if it has a specified [source]
+ * and [kind].
+ */
+class IsExecutableFile extends Matcher {
+  String expectedFile;
+  ExecutableKind expectedKind;
+
+  IsExecutableFile(this.expectedFile, this.expectedKind);
+
+  @override
+  Description describe(Description description) {
+    return description.add('ExecutableFile($expectedFile, $expectedKind)');
+  }
+
+  @override
+  bool matches(item, Map matchState) {
+    if (item is! ExecutableFile) {
+      return false;
+    }
+    ExecutableFile file = item;
+    return item.file == expectedFile && item.kind == expectedKind;
+  }
+}