svn commit: r1021521 - in /incubator/thrift/trunk/lib/php: Makefile.am src/protocol/TBinarySerializer.php

[mc...@apache.org]

Author: mcslee
Date: Mon Oct 11 21:45:13 2010
New Revision: 1021521

URL: http://svn.apache.org/viewvc?rev=1021521&view=rev
Log:
THRIFT-952. TBinarySerializer utility class for converting between byte strings and PHP objects

Adds a nice TBinarySerializer class to make it simple to convert between PHP objects and serialized strings using the Binary protocol.

Patch: Radu Marin

Added:
    incubator/thrift/trunk/lib/php/src/protocol/TBinarySerializer.php
Modified:
    incubator/thrift/trunk/lib/php/Makefile.am

Modified: incubator/thrift/trunk/lib/php/Makefile.am
URL: http://svn.apache.org/viewvc/incubator/thrift/trunk/lib/php/Makefile.am?rev=1021521&r1=1021520&r2=1021521&view=diff
==============================================================================
--- incubator/thrift/trunk/lib/php/Makefile.am (original)
+++ incubator/thrift/trunk/lib/php/Makefile.am Mon Oct 11 21:45:13 2010
@@ -37,6 +37,7 @@ php_DATA =  \
 phpprotocoldir = $(phpdir)/protocol
 phpprotocol_DATA = \
   src/protocol/TBinaryProtocol.php \
+  src/protocol/TBinarySerializer.php \
   src/protocol/TProtocol.php
 
 phptransportdir = $(phpdir)/transport

Added: incubator/thrift/trunk/lib/php/src/protocol/TBinarySerializer.php
URL: http://svn.apache.org/viewvc/incubator/thrift/trunk/lib/php/src/protocol/TBinarySerializer.php?rev=1021521&view=auto
==============================================================================
--- incubator/thrift/trunk/lib/php/src/protocol/TBinarySerializer.php (added)
+++ incubator/thrift/trunk/lib/php/src/protocol/TBinarySerializer.php Mon Oct 11 21:45:13 2010
@@ -0,0 +1,69 @@
+<?php
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ * @package thrift.protocol
+ * @author: rmarin (marin.radu@facebook.com)
+ */
+
+require_once $GLOBALS['THRIFT_ROOT'].'/transport/TMemoryBuffer.php';
+require_once $GLOBALS['THRIFT_ROOT'].'/protocol/TBinaryProtocol.php';
+
+/**
+ * Utility class for serializing and deserializing
+ * a thrift object using TBinaryProtocolAccelerated.
+ */
+class TBinarySerializer {
+
+  // NOTE(rmarin): Because thrift_protocol_write_binary
+  // adds a begin message prefix, you cannot specify
+  // a transport in which to serialize an object. It has to
+  // be a string. Otherwise we will break the compatibility with
+  // normal deserialization.
+  public static function serialize($object) {
+    $transport = new TMemoryBuffer();
+    $protocol = new TBinaryProtocolAccelerated($transport);
+    if (function_exists('thrift_protocol_write_binary')) {
+      thrift_protocol_write_binary($protocol, $object->getName(),
+                                   TMessageType::REPLY, $object,
+                                   0, $protocol->isStrictWrite());
+
+      $protocol->readMessageBegin($unused_name, $unused_type,
+                                  $unused_seqid);
+    } else {
+      $object->write($protocol);
+    }
+    return $transport->getBuffer();
+  }
+
+  public static function deserialize($string_object, $class_name) {
+     $transport = new TMemoryBuffer();
+     $protocol = new TBinaryProtocolAccelerated($transport);
+     if (function_exists('thrift_protocol_read_binary')) {
+       $protocol->writeMessageBegin('', TMessageType::REPLY, 0);
+       $transport->write($string_object);
+       return thrift_protocol_read_binary($protocol, $class_name,
+                                          $protocol->isStrictRead());
+     } else {
+       $transport->write($string_object);
+       $object = new $class_name();
+       $object->read($protocol);
+       return $object;
+     }
+  }
+}