conformance_php.php 3.45 KB
Newer Older
1 2 3 4 5 6 7
<?php

require_once("Conformance/WireFormat.php");
require_once("Conformance/ConformanceResponse.php");
require_once("Conformance/ConformanceRequest.php");
require_once("Protobuf_test_messages/Proto3/ForeignMessage.php");
require_once("Protobuf_test_messages/Proto3/ForeignEnum.php");
8 9 10
require_once("Protobuf_test_messages/Proto3/TestAllTypesProto3.php");
require_once("Protobuf_test_messages/Proto3/TestAllTypesProto3_NestedMessage.php");
require_once("Protobuf_test_messages/Proto3/TestAllTypesProto3_NestedEnum.php");
11 12 13 14 15 16

require_once("GPBMetadata/Conformance.php");
require_once("GPBMetadata/Google/Protobuf/TestMessagesProto3.php");

use  \Conformance\WireFormat;

17 18 19 20
if (!ini_get("date.timezone")) {
  ini_set("date.timezone", "UTC");
}

21 22 23 24
$test_count = 0;

function doTest($request)
{
25
    $test_message = new \Protobuf_test_messages\Proto3\TestAllTypesProto3();
26 27
    $response = new \Conformance\ConformanceResponse();
    if ($request->getPayload() == "protobuf_payload") {
28
      if ($request->getMessageType() == "protobuf_test_messages.proto3.TestAllTypesProto3") {
29
        try {
30
          $test_message->mergeFromString($request->getProtobufPayload());
31
        } catch (Exception $e) {
32 33
          $response->setParseError($e->getMessage());
          return $response;
34
        }
35
      } elseif ($request->getMessageType() == "protobuf_test_messages.proto2.TestAllTypesProto2") {
36 37
        $response->setSkipped("PHP doesn't support proto2");
        return $response;
38
      } else {
39
        trigger_error("Protobuf request doesn't have specific payload type", E_USER_ERROR);
40
      }
41
    } elseif ($request->getPayload() == "json_payload") {
42
      try {
43
          $test_message->mergeFromJsonString($request->getJsonPayload());
44 45 46 47
      } catch (Exception $e) {
          $response->setParseError($e->getMessage());
          return $response;
      }
48 49 50 51 52 53 54
    } else {
      trigger_error("Request didn't have payload.", E_USER_ERROR);
    }

    if ($request->getRequestedOutputFormat() == WireFormat::UNSPECIFIED) {
      trigger_error("Unspecified output format.", E_USER_ERROR);
    } elseif ($request->getRequestedOutputFormat() == WireFormat::PROTOBUF) {
55
      $response->setProtobufPayload($test_message->serializeToString());
56
    } elseif ($request->getRequestedOutputFormat() == WireFormat::JSON) {
57 58 59 60 61 62
      try {
          $response->setJsonPayload($test_message->serializeToJsonString());
      } catch (Exception $e) {
          $response->setSerializeError($e->getMessage());
          return $response;
      }
63 64 65 66 67 68 69 70 71 72 73
    }

    return $response;
}

function doTestIO()
{
    $length_bytes = fread(STDIN, 4);
    if (strlen($length_bytes) == 0) {
      return false;   # EOF
    } elseif (strlen($length_bytes) != 4) {
74 75
      fwrite(STDERR, "I/O error\n");
      return false;
76 77 78 79 80 81 82 83 84
    }

    $length = unpack("V", $length_bytes)[1];
    $serialized_request = fread(STDIN, $length);
    if (strlen($serialized_request) != $length) {
      trigger_error("I/O error", E_USER_ERROR);
    }

    $request = new \Conformance\ConformanceRequest();
85
    $request->mergeFromString($serialized_request);
86 87 88

    $response = doTest($request);

89
    $serialized_response = $response->serializeToString();
90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105
    fwrite(STDOUT, pack("V", strlen($serialized_response)));
    fwrite(STDOUT, $serialized_response);

    $GLOBALS['test_count'] += 1;

    return true;
}

while(true){
  if (!doTestIO()) {
      fprintf(STDERR,
             "conformance_php: received EOF from test runner " +
             "after %d tests, exiting\n", $test_count);
      exit;
  }
}