|
|
|
|
@ -0,0 +1,126 @@ |
|
|
|
|
#region Copyright notice and license |
|
|
|
|
// Protocol Buffers - Google's data interchange format |
|
|
|
|
// Copyright 2015 Google Inc. All rights reserved. |
|
|
|
|
// https://developers.google.com/protocol-buffers/ |
|
|
|
|
// |
|
|
|
|
// Redistribution and use in source and binary forms, with or without |
|
|
|
|
// modification, are permitted provided that the following conditions are |
|
|
|
|
// met: |
|
|
|
|
// |
|
|
|
|
// * Redistributions of source code must retain the above copyright |
|
|
|
|
// notice, this list of conditions and the following disclaimer. |
|
|
|
|
// * Redistributions in binary form must reproduce the above |
|
|
|
|
// copyright notice, this list of conditions and the following disclaimer |
|
|
|
|
// in the documentation and/or other materials provided with the |
|
|
|
|
// distribution. |
|
|
|
|
// * Neither the name of Google Inc. nor the names of its |
|
|
|
|
// contributors may be used to endorse or promote products derived from |
|
|
|
|
// this software without specific prior written permission. |
|
|
|
|
// |
|
|
|
|
// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS |
|
|
|
|
// "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT |
|
|
|
|
// LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR |
|
|
|
|
// A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT |
|
|
|
|
// OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, |
|
|
|
|
// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT |
|
|
|
|
// LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, |
|
|
|
|
// DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY |
|
|
|
|
// THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
|
|
|
|
// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE |
|
|
|
|
// OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
|
|
|
|
#endregion |
|
|
|
|
|
|
|
|
|
using Conformance; |
|
|
|
|
using System; |
|
|
|
|
using System.IO; |
|
|
|
|
|
|
|
|
|
namespace Google.Protobuf.Conformance |
|
|
|
|
{ |
|
|
|
|
/// <summary> |
|
|
|
|
/// Conformance tests. The test runner will provide JSON or proto data on stdin, |
|
|
|
|
/// and this program will produce its output on stdout. |
|
|
|
|
/// </summary> |
|
|
|
|
class Program |
|
|
|
|
{ |
|
|
|
|
private static void Main(string[] args) |
|
|
|
|
{ |
|
|
|
|
// This way we get the binary streams instead of readers/writers. |
|
|
|
|
var input = new BinaryReader(Console.OpenStandardInput()); |
|
|
|
|
var output = new BinaryWriter(Console.OpenStandardOutput()); |
|
|
|
|
|
|
|
|
|
int count = 0; |
|
|
|
|
while (RunTest(input, output)) |
|
|
|
|
{ |
|
|
|
|
count++; |
|
|
|
|
} |
|
|
|
|
Console.Error.WriteLine("Received EOF after {0} tests", count); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
private static bool RunTest(BinaryReader input, BinaryWriter output) |
|
|
|
|
{ |
|
|
|
|
int? size = ReadInt32(input); |
|
|
|
|
if (size == null) |
|
|
|
|
{ |
|
|
|
|
return false; |
|
|
|
|
} |
|
|
|
|
byte[] inputData = input.ReadBytes(size.Value); |
|
|
|
|
if (inputData.Length != size.Value) |
|
|
|
|
{ |
|
|
|
|
throw new EndOfStreamException("Read " + inputData.Length + " bytes of data when expecting " + size); |
|
|
|
|
} |
|
|
|
|
ConformanceRequest request = ConformanceRequest.Parser.ParseFrom(inputData); |
|
|
|
|
ConformanceResponse response = PerformRequest(request); |
|
|
|
|
byte[] outputData = response.ToByteArray(); |
|
|
|
|
output.Write(outputData.Length); |
|
|
|
|
output.Write(outputData); |
|
|
|
|
// Ready for another test... |
|
|
|
|
return true; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
private static ConformanceResponse PerformRequest(ConformanceRequest request) |
|
|
|
|
{ |
|
|
|
|
TestAllTypes message; |
|
|
|
|
switch (request.PayloadCase) |
|
|
|
|
{ |
|
|
|
|
case ConformanceRequest.PayloadOneofCase.JsonPayload: |
|
|
|
|
return new ConformanceResponse { Skipped = "JSON parsing not implemented in C# yet" }; |
|
|
|
|
case ConformanceRequest.PayloadOneofCase.ProtobufPayload: |
|
|
|
|
try |
|
|
|
|
{ |
|
|
|
|
message = TestAllTypes.Parser.ParseFrom(request.ProtobufPayload); |
|
|
|
|
} |
|
|
|
|
catch (InvalidProtocolBufferException e) |
|
|
|
|
{ |
|
|
|
|
return new ConformanceResponse { ParseError = e.Message }; |
|
|
|
|
} |
|
|
|
|
break; |
|
|
|
|
default: |
|
|
|
|
throw new Exception("Unsupported request payload: " + request.PayloadCase); |
|
|
|
|
} |
|
|
|
|
switch (request.RequestedOutputFormat) |
|
|
|
|
{ |
|
|
|
|
case global::Conformance.WireFormat.JSON: |
|
|
|
|
return new ConformanceResponse { JsonPayload = JsonFormatter.Default.Format(message) }; |
|
|
|
|
case global::Conformance.WireFormat.PROTOBUF: |
|
|
|
|
return new ConformanceResponse { ProtobufPayload = message.ToByteString() }; |
|
|
|
|
default: |
|
|
|
|
throw new Exception("Unsupported request output format: " + request.PayloadCase); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
private static int? ReadInt32(BinaryReader input) |
|
|
|
|
{ |
|
|
|
|
byte[] bytes = input.ReadBytes(4); |
|
|
|
|
if (bytes.Length == 0) |
|
|
|
|
{ |
|
|
|
|
// Cleanly reached the end of the stream |
|
|
|
|
return null; |
|
|
|
|
} |
|
|
|
|
if (bytes.Length != 4) |
|
|
|
|
{ |
|
|
|
|
throw new EndOfStreamException("Read " + bytes.Length + " bytes of size when expecting 4"); |
|
|
|
|
} |
|
|
|
|
return bytes[0] | (bytes[1] << 8) | (bytes[2] << 16) | (bytes[3] << 24); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
Jon Skeet
10 years ago