Initial Implementation of the vm-service protocol

pkg/dartino_compiler/lib/src/worker/developer.dart

 // Copyright (c) 2015, the Dartino 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.md file.
 
 library dartino_compiler.worker.developer;
 
 import 'dart:async' show
     Future,
     TimeoutException;
 
 import 'dart:convert' show
     JSON,
     JsonEncoder,
     LineSplitter,
     UTF8;
 
 import 'dart:io' show
     Directory,
     File,
     FileSystemEntity,
     InternetAddress,
     Platform,
     Process,
     ProcessResult,
     SocketException;
 
+import 'dart:typed_data' show
+    Uint8List;
+
 import 'package:sdk_services/sdk_services.dart' show
     OutputService,
     SDKServices,
     DownloadException;
 
 import 'package:dartino_agent/agent_connection.dart' show
     AgentConnection,
     AgentException,
     VmData;
 
@@ skipping 39 matching lines @@
     DartinoCompiler,
     DartinoDelta,
     IncrementalCompiler,
     WorkerConnection,
     IsolatePool,
     SharedTask,
     StreamIterator,
     throwFatalError;
 
 import '../../vm_context.dart' show
-    DartinoVmContext,
-    SinkDebugListener;
+    DartinoVmContext;
 
 import '../../incremental/dartino_compiler_incremental.dart' show
     IncrementalCompilationFailed;
 
 import '../dartino_compiler_options.dart' show
     IncrementalMode,
     parseIncrementalMode,
     unparseIncrementalMode;
 
 export '../dartino_compiler_options.dart' show
@@ skipping 26 matching lines @@
     BackTrace;
 
 import '../vm_connection.dart' show
     TcpConnection,
     VmConnection,
     connectToTty;
 
 import '../dartino_compiler_options.dart' show
     DartinoCompilerOptions;
 
+import '../../vm_context.dart' show DebugListener;
+
 import '../hub/exit_codes.dart' show
     INPUT_ERROR;
 
 import '../diagnostic.dart' show
     InputError;
 
 typedef Future<Null> ClientEventHandler(DartinoVmContext vmContext);
 
 Uri configFileUri;
 
@@ skipping 108 matching lines @@
       ttyDevice, "vmTty", state.log);
   await attachToVm(connection, state, maxTimeSpent: new Duration(seconds: 20));
 }
 
 Future<Null> attachToVmTcp(String host, int port, SessionState state) async {
   TcpConnection connection = await TcpConnection.connect(
       host, port, "vmSocket", state.log);
   await attachToVm(connection, state);
 }
 
+class SinkDebugListener extends DebugListener {
+  final Sink stdoutSink;
+  final Sink stderrSink;
+  SinkDebugListener(this.stdoutSink, this.stderrSink);
+
+  // Notification of bytes written to stdout.
+  writeStdOut(int processId, Uint8List data) {
+    stdoutSink.add(data);
+  }
+
+  // Notification of bytes written stderr.
+  writeStdErr(int processId, Uint8List data) {
+    stderrSink.add(data);
+  }
+}
+
 Future<Null> attachToVm(
     VmConnection connection,
     SessionState state,
     {Duration maxTimeSpent}) async {
   DartinoVmContext vmContext = new DartinoVmContext(
       connection,
       state.compiler,
       null);
 
   vmContext.listeners.add(
@@ skipping 1862 matching lines @@
     addIfNotNull("open_ocd_board", open_ocd_board);
     return result;
   }
 }
 
 Uri defaultSnapshotLocation(Uri script) {
   // TODO(sgjesse): Use a temp directory for the snapshot.
   String snapshotName = basenameWithoutExtension(script.path) + '.snapshot';
   return script.resolve(snapshotName);
 }