Index: mojo/dart/packages/mojo_services/lib/mojo/http_message.mojom.dart |
diff --git a/mojo/dart/packages/mojo_services/lib/mojo/http_message.mojom.dart b/mojo/dart/packages/mojo_services/lib/mojo/http_message.mojom.dart |
new file mode 100644 |
index 0000000000000000000000000000000000000000..959db5ca83641efd360e66a696d5a3aa400a0cf6 |
--- /dev/null |
+++ b/mojo/dart/packages/mojo_services/lib/mojo/http_message.mojom.dart |
@@ -0,0 +1,224 @@ |
+// Copyright 2014 The Chromium Authors. All rights reserved. |
+// Use of this source code is governed by a BSD-style license that can be |
+// found in the LICENSE file. |
+ |
+library http_message_mojom; |
+ |
+import 'dart:async'; |
+ |
+import 'package:mojo/bindings.dart' as bindings; |
+import 'package:mojo/core.dart' as core; |
+import 'package:mojo/mojo/http_header.mojom.dart' as http_header_mojom; |
+ |
+ |
+ |
+class HttpRequest extends bindings.Struct { |
+ static const List<bindings.StructDataHeader> kVersions = const [ |
+ const bindings.StructDataHeader(40, 0) |
+ ]; |
+ String method = "GET"; |
+ String url = null; |
+ List<http_header_mojom.HttpHeader> headers = null; |
+ core.MojoDataPipeConsumer body = null; |
+ |
+ HttpRequest() : super(kVersions.last.size); |
+ |
+ static HttpRequest deserialize(bindings.Message message) { |
+ var decoder = new bindings.Decoder(message); |
+ var result = decode(decoder); |
+ if (decoder.excessHandles != null) { |
+ decoder.excessHandles.forEach((h) => h.close()); |
+ } |
+ return result; |
+ } |
+ |
+ static HttpRequest decode(bindings.Decoder decoder0) { |
+ if (decoder0 == null) { |
+ return null; |
+ } |
+ HttpRequest result = new HttpRequest(); |
+ |
+ var mainDataHeader = decoder0.decodeStructDataHeader(); |
+ if (mainDataHeader.version <= kVersions.last.version) { |
+ // Scan in reverse order to optimize for more recent versions. |
+ for (int i = kVersions.length - 1; i >= 0; --i) { |
+ if (mainDataHeader.version >= kVersions[i].version) { |
+ if (mainDataHeader.size == kVersions[i].size) { |
+ // Found a match. |
+ break; |
+ } |
+ throw new bindings.MojoCodecError( |
+ 'Header size doesn\'t correspond to known version size.'); |
+ } |
+ } |
+ } else if (mainDataHeader.size < kVersions.last.size) { |
+ throw new bindings.MojoCodecError( |
+ 'Message newer than the last known version cannot be shorter than ' |
+ 'required by the last known version.'); |
+ } |
+ if (mainDataHeader.version >= 0) { |
+ |
+ result.method = decoder0.decodeString(8, false); |
+ } |
+ if (mainDataHeader.version >= 0) { |
+ |
+ result.url = decoder0.decodeString(16, false); |
+ } |
+ if (mainDataHeader.version >= 0) { |
+ |
+ var decoder1 = decoder0.decodePointer(24, true); |
+ if (decoder1 == null) { |
+ result.headers = null; |
+ } else { |
+ var si1 = decoder1.decodeDataHeaderForPointerArray(bindings.kUnspecifiedArrayLength); |
+ result.headers = new List<http_header_mojom.HttpHeader>(si1.numElements); |
+ for (int i1 = 0; i1 < si1.numElements; ++i1) { |
+ |
+ var decoder2 = decoder1.decodePointer(bindings.ArrayDataHeader.kHeaderSize + bindings.kPointerSize * i1, false); |
+ result.headers[i1] = http_header_mojom.HttpHeader.decode(decoder2); |
+ } |
+ } |
+ } |
+ if (mainDataHeader.version >= 0) { |
+ |
+ result.body = decoder0.decodeConsumerHandle(32, true); |
+ } |
+ return result; |
+ } |
+ |
+ void encode(bindings.Encoder encoder) { |
+ var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last); |
+ |
+ encoder0.encodeString(method, 8, false); |
+ |
+ encoder0.encodeString(url, 16, false); |
+ |
+ if (headers == null) { |
+ encoder0.encodeNullPointer(24, true); |
+ } else { |
+ var encoder1 = encoder0.encodePointerArray(headers.length, 24, bindings.kUnspecifiedArrayLength); |
+ for (int i0 = 0; i0 < headers.length; ++i0) { |
+ |
+ encoder1.encodeStruct(headers[i0], bindings.ArrayDataHeader.kHeaderSize + bindings.kPointerSize * i0, false); |
+ } |
+ } |
+ |
+ encoder0.encodeConsumerHandle(body, 32, true); |
+ } |
+ |
+ String toString() { |
+ return "HttpRequest(" |
+ "method: $method" ", " |
+ "url: $url" ", " |
+ "headers: $headers" ", " |
+ "body: $body" ")"; |
+ } |
+ |
+ Map toJson() { |
+ throw new bindings.MojoCodecError( |
+ 'Object containing handles cannot be encoded to JSON.'); |
+ } |
+} |
+ |
+ |
+class HttpResponse extends bindings.Struct { |
+ static const List<bindings.StructDataHeader> kVersions = const [ |
+ const bindings.StructDataHeader(24, 0) |
+ ]; |
+ int statusCode = 200; |
+ core.MojoDataPipeConsumer body = null; |
+ List<http_header_mojom.HttpHeader> headers = null; |
+ |
+ HttpResponse() : super(kVersions.last.size); |
+ |
+ static HttpResponse deserialize(bindings.Message message) { |
+ var decoder = new bindings.Decoder(message); |
+ var result = decode(decoder); |
+ if (decoder.excessHandles != null) { |
+ decoder.excessHandles.forEach((h) => h.close()); |
+ } |
+ return result; |
+ } |
+ |
+ static HttpResponse decode(bindings.Decoder decoder0) { |
+ if (decoder0 == null) { |
+ return null; |
+ } |
+ HttpResponse result = new HttpResponse(); |
+ |
+ var mainDataHeader = decoder0.decodeStructDataHeader(); |
+ if (mainDataHeader.version <= kVersions.last.version) { |
+ // Scan in reverse order to optimize for more recent versions. |
+ for (int i = kVersions.length - 1; i >= 0; --i) { |
+ if (mainDataHeader.version >= kVersions[i].version) { |
+ if (mainDataHeader.size == kVersions[i].size) { |
+ // Found a match. |
+ break; |
+ } |
+ throw new bindings.MojoCodecError( |
+ 'Header size doesn\'t correspond to known version size.'); |
+ } |
+ } |
+ } else if (mainDataHeader.size < kVersions.last.size) { |
+ throw new bindings.MojoCodecError( |
+ 'Message newer than the last known version cannot be shorter than ' |
+ 'required by the last known version.'); |
+ } |
+ if (mainDataHeader.version >= 0) { |
+ |
+ result.statusCode = decoder0.decodeUint32(8); |
+ } |
+ if (mainDataHeader.version >= 0) { |
+ |
+ result.body = decoder0.decodeConsumerHandle(12, true); |
+ } |
+ if (mainDataHeader.version >= 0) { |
+ |
+ var decoder1 = decoder0.decodePointer(16, true); |
+ if (decoder1 == null) { |
+ result.headers = null; |
+ } else { |
+ var si1 = decoder1.decodeDataHeaderForPointerArray(bindings.kUnspecifiedArrayLength); |
+ result.headers = new List<http_header_mojom.HttpHeader>(si1.numElements); |
+ for (int i1 = 0; i1 < si1.numElements; ++i1) { |
+ |
+ var decoder2 = decoder1.decodePointer(bindings.ArrayDataHeader.kHeaderSize + bindings.kPointerSize * i1, false); |
+ result.headers[i1] = http_header_mojom.HttpHeader.decode(decoder2); |
+ } |
+ } |
+ } |
+ return result; |
+ } |
+ |
+ void encode(bindings.Encoder encoder) { |
+ var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last); |
+ |
+ encoder0.encodeUint32(statusCode, 8); |
+ |
+ encoder0.encodeConsumerHandle(body, 12, true); |
+ |
+ if (headers == null) { |
+ encoder0.encodeNullPointer(16, true); |
+ } else { |
+ var encoder1 = encoder0.encodePointerArray(headers.length, 16, bindings.kUnspecifiedArrayLength); |
+ for (int i0 = 0; i0 < headers.length; ++i0) { |
+ |
+ encoder1.encodeStruct(headers[i0], bindings.ArrayDataHeader.kHeaderSize + bindings.kPointerSize * i0, false); |
+ } |
+ } |
+ } |
+ |
+ String toString() { |
+ return "HttpResponse(" |
+ "statusCode: $statusCode" ", " |
+ "body: $body" ", " |
+ "headers: $headers" ")"; |
+ } |
+ |
+ Map toJson() { |
+ throw new bindings.MojoCodecError( |
+ 'Object containing handles cannot be encoded to JSON.'); |
+ } |
+} |
+ |
+ |