| // Copyright (c) 2013, 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. | 
 |  | 
 | // Client for secure_socket_renegotiate_test, that runs in a subprocess. | 
 | // The test verifies that client certificates work, if the client and server | 
 | // are in separate processes, and that connection renegotiation can request | 
 | // a client certificate to be sent. | 
 |  | 
 | import "dart:async"; | 
 | import "dart:convert"; | 
 | import "dart:io"; | 
 |  | 
 | const HOST_NAME = "localhost"; | 
 | String localFile(path) => Platform.script.resolve(path).toFilePath(); | 
 |  | 
 | SecurityContext clientContext = new SecurityContext() | 
 |   ..setTrustedCertificates(localFile('certificates/trusted_certs.pem')); | 
 |  | 
 | class ExpectException implements Exception { | 
 |   ExpectException(this.message); | 
 |   String toString() => message; | 
 |   String message; | 
 | } | 
 |  | 
 | void expectEquals(expected, actual) { | 
 |   if (actual != expected) { | 
 |     throw new ExpectException('Expected $expected, found $actual'); | 
 |   } | 
 | } | 
 |  | 
 | void expect(condition) { | 
 |   if (!condition) { | 
 |     throw new ExpectException(''); | 
 |   } | 
 | } | 
 |  | 
 | void runClient(int port) { | 
 |   SecureSocket.connect(HOST_NAME, port, context: clientContext) | 
 |       .then((SecureSocket socket) { | 
 |     X509Certificate? certificate = socket.peerCertificate; | 
 |     expect(certificate != null); | 
 |     expectEquals('CN=localhost', certificate!.subject); | 
 |     expectEquals('CN=myauthority', certificate.issuer); | 
 |     StreamIterator<String> input = new StreamIterator( | 
 |         socket.transform(utf8.decoder).transform(new LineSplitter())); | 
 |     socket.writeln('first'); | 
 |     input.moveNext().then((success) { | 
 |       expect(success); | 
 |       expectEquals('first reply', input.current); | 
 |       socket.renegotiate(); | 
 |       socket.writeln('renegotiated'); | 
 |       return input.moveNext(); | 
 |     }).then((success) { | 
 |       expect(success); | 
 |       expectEquals('server renegotiated', input.current); | 
 |       X509Certificate? certificate = socket.peerCertificate; | 
 |       expect(certificate != null); | 
 |       expectEquals("CN=localhost", certificate!.subject); | 
 |       expectEquals("CN=myauthority", certificate.issuer); | 
 |       socket.writeln('second'); | 
 |       return input.moveNext(); | 
 |     }).then((success) { | 
 |       expect(success != true); | 
 |       socket.close(); | 
 |     }); | 
 |   }); | 
 | } | 
 |  | 
 | void main(List<String> args) { | 
 |   runClient(int.parse(args[0])); | 
 | } |