Brian Wilkerson
3e1bad6e7a
In order to avoid passing several pieces of data through several layers of the API, this change passes the analytics manager down. This means that we're creating the manager earlier, but I think it keeps the code cleaner. Change-Id: I096e416c1aa445f5f7382ae666b3d02d0abf0a0f Reviewed-on: https://dart-review.googlesource.com/c/sdk/+/246320 Reviewed-by: Konstantin Shcheglov <scheglov@google.com> Commit-Queue: Brian Wilkerson <brianwilkerson@google.com>
85 lines
3.2 KiB
Dart
85 lines
3.2 KiB
Dart
// 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 'package:analysis_server/protocol/protocol.dart';
|
|
import 'package:analysis_server/protocol/protocol_constants.dart';
|
|
import 'package:analysis_server/protocol/protocol_generated.dart';
|
|
import 'package:analysis_server/src/analysis_server.dart';
|
|
import 'package:analysis_server/src/analytics/noop_analytics_manager.dart';
|
|
import 'package:analysis_server/src/server/crash_reporting_attachments.dart';
|
|
import 'package:analysis_server/src/server/error_notifier.dart';
|
|
import 'package:analysis_server/src/socket_server.dart';
|
|
import 'package:analysis_server/src/utilities/mocks.dart';
|
|
import 'package:analyzer/src/generated/engine.dart';
|
|
import 'package:analyzer/src/generated/sdk.dart';
|
|
import 'package:test/test.dart';
|
|
|
|
void main() {
|
|
group('SocketServer', () {
|
|
test('createAnalysisServer_successful',
|
|
SocketServerTest.createAnalysisServer_successful);
|
|
test('createAnalysisServer_alreadyStarted',
|
|
SocketServerTest.createAnalysisServer_alreadyStarted);
|
|
});
|
|
}
|
|
|
|
class SocketServerTest {
|
|
static void createAnalysisServer_alreadyStarted() {
|
|
var channel1 = MockServerChannel();
|
|
var channel2 = MockServerChannel();
|
|
var server = _createSocketServer(channel1);
|
|
expect(
|
|
channel1.notificationsReceived[0].event, SERVER_NOTIFICATION_CONNECTED);
|
|
server.createAnalysisServer(channel2);
|
|
channel1.expectMsgCount(notificationCount: 1);
|
|
channel2.expectMsgCount(responseCount: 1);
|
|
expect(channel2.responsesReceived[0].id, equals(''));
|
|
expect(channel2.responsesReceived[0].error, isNotNull);
|
|
expect(channel2.responsesReceived[0].error!.code,
|
|
equals(RequestErrorCode.SERVER_ALREADY_STARTED));
|
|
channel2
|
|
.sendRequest(ServerShutdownParams().toRequest('0'))
|
|
.then((Response response) {
|
|
expect(response.id, equals('0'));
|
|
var error = response.error!;
|
|
expect(error.code, equals(RequestErrorCode.SERVER_ALREADY_STARTED));
|
|
channel2.expectMsgCount(responseCount: 2);
|
|
});
|
|
}
|
|
|
|
static Future createAnalysisServer_successful() {
|
|
var channel = MockServerChannel();
|
|
_createSocketServer(channel);
|
|
channel.expectMsgCount(notificationCount: 1);
|
|
expect(
|
|
channel.notificationsReceived[0].event, SERVER_NOTIFICATION_CONNECTED);
|
|
return channel
|
|
.sendRequest(ServerShutdownParams().toRequest('0'))
|
|
.then((Response response) {
|
|
expect(response.id, equals('0'));
|
|
expect(response.error, isNull);
|
|
channel.expectMsgCount(responseCount: 1, notificationCount: 1);
|
|
});
|
|
}
|
|
|
|
static SocketServer _createSocketServer(MockServerChannel channel) {
|
|
final errorNotifier = ErrorNotifier();
|
|
final server = SocketServer(
|
|
AnalysisServerOptions(),
|
|
DartSdkManager(''),
|
|
CrashReportingAttachmentsBuilder.empty,
|
|
errorNotifier,
|
|
null,
|
|
null,
|
|
NoopAnalyticsManager(),
|
|
null);
|
|
|
|
server.createAnalysisServer(channel);
|
|
errorNotifier.server = server.analysisServer;
|
|
AnalysisEngine.instance.instrumentationService = errorNotifier;
|
|
|
|
return server;
|
|
}
|
|
}
|