php/test/social/MessageRestTest.php - shindig - Git at Google

 <?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.
  */

 require_once 'RestBase.php';

 /**
  * It is an integration test. Since it's may be used by the specified container implementation.
  * It'd better not to depends on the data in the json DB sample.
  */
 class MessageRestTest extends RestBase {

   private function getAllEntities($url) {
     $sep = strpos($url, '?') !== false ? '&' : '?';
     $ret = $this->curlRest($url . $sep . 'startIndex=0&count=1000000', '', 'application/json', 'GET');
     $retDecoded = json_decode($ret, true);
     $this->assertTrue($ret != $retDecoded && $ret != null, "Invalid json response: $retDecoded");
     return $retDecoded['entry'];
   }

   /**
    * NOTE: If there are lots of messages in the storage this test may take a long time as
    * it retrieves all the message.
    */
   private function verifyLifeCycle($postData, $postDataFormat, $randomTitle) {
     $url = '/messages/1/@outbox';

     $cnt = count($this->getAllEntities($url));

     // Creates the message.
     $ret = $this->curlRest($url, $postData, $postDataFormat, 'POST');
     $this->assertTrue(empty($ret), "Create message failed. Response: $ret");

     // Gets the message.
     $messages = $this->getAllEntities($url);
     $this->assertEquals($cnt + 1, count($messages), "Size of the messages is not right.");
     $fetchedMessage = null;
     foreach ($messages as $m) {
       if ($m['title'] == $randomTitle) {
         $fetchedMessage = $m;
       }
     }
     $this->assertNotNull($fetchedMessage, "Couldn't find the created message with title $randomTitle");

     // Deletes the message.
     $ret = $this->curlRest($url . '/' . urlencode($fetchedMessage['id']), '', 'application/json', 'DELETE');
     $this->assertTrue(empty($ret), "Delete the created message failed. Response: $ret");

     $messages = $this->getAllEntities($url, $randomTitle);
     $this->assertEquals($cnt, count($messages), "Size of the messages is not right after deletion.");
   }

   public function testLifeCycleInJson() {
     $randomTitle = "[" . rand(0, 2048) . "] message test title.";
     $postData = '{
       "id" : "msgid",
       "recipients" : [2,3],
       "title" : "' . $randomTitle . '",
       "titleId" : "541141091700",
       "body" : "Short message from Joe to some friends",
       "bodyId" : "5491155811231",
       "type" : "privateMessage",
       "status" : "unread"
     }';
     $this->verifyLifeCycle($postData, 'application/json', $randomTitle);
   }

   public function testLifeCycleInXml() {
     $randomTitle = "[" . rand(0, 2048) . "] message test title.";
     $postData = '<message xmlns="http://ns.opensocial.org/2008/opensocial">
       <recipient>2</recipient>
       <recipient>3</recipient>
       <title>' . $randomTitle . '</title>
       <id>msgid</id>
       <body>Click <a href="http://app.example.org/invites/{msgid}">here</a> to review your invitation.</body>
     </message>';
     $this->verifyLifeCycle($postData, 'application/xml', $randomTitle);
   }

   public function testLifeCycleInAtom() {
     $randomTitle = "[" . rand(0, 2048) . "] message test title.";
     $postData = '<entry xmlns="http://www.w3.org/2005/Atom"
              xmlns:osapi="http://opensocial.org/2008/opensocialapi">
       <osapi:recipient>2</osapi:recipient>
       <osapi:recipient>3</osapi:recipient>
       <title>' . $randomTitle . '</title>
       <id>{msgid}</id>
       <link rel="alternate" href="http://app.example.org/invites/{msgid}"/>
       <content>Click <a href="http://app.example.org/invites/{msgid}">here</a> to review your invitation.</content>
     </entry>';
     $this->verifyLifeCycle($postData, 'application/atom+xml', $randomTitle);
   }

   public function testMessageCollectionLifeCycle() {
     $url = '/messages/1';
     // Gets number of message collections in the repository.
     $cnt = count($this->getAllEntities($url));

     // Creates a message collection.
     $createData = array();
     $createData['title'] = "[" . rand(0, 2048) . "] message collection test title.";
     $createData['urls'] = array("http://abc.com/abc", "http://xyz.com/xyz");
     $ret = $this->curlRest($url, json_encode($createData), 'application/json', 'POST');

     // Verifies that whether the message collection is created.
     $retDecoded = json_decode($ret, true);
     $id = $retDecoded['entry']['id'];
     $this->assertEquals($cnt + 1, count($this->getAllEntities($url)), "Wrong size of the collections. $ret");

     // Updates the created message collection.
     $newUrls = array("http://123.com/123");
     $newTitle = 'new title';
     $updateData = array();
     $updateData['id'] = $id;
     $updateData['title'] = $newTitle;
     $updateData['urls'] = $newUrls;

     $ret = $this->curlRest($url . "/$id", json_encode($updateData), 'application/json', 'PUT');
     $this->assertTrue(empty($ret), "Update should return empty. $ret <$id>");

     $collections = $this->getAllEntities($url);
     $this->assertEquals($cnt + 1, count($collections), "Wrong size of the collections.");
     $found = false;
     foreach ($collections as $collection) {
       if ($collection['id'] == $id) {
         $this->assertEquals($newTitle, $collection['title']);
         $this->assertEquals($newUrls, $collection['urls']);
         $found = true;
       }
     }
     $this->assertTrue($found, "Created message not found.");

     // Deletes the message collection.
     $ret = $this->curlRest($url . "/$id", '', 'application/json', 'DELETE');

     // Verifies that the message collection is deleted.
     $this->assertEquals($cnt, count($this->getAllEntities($url)), "Wrong size of the collections. $ret");
   }
 }
	<?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.
	*/

	require_once 'RestBase.php';

	/**
	* It is an integration test. Since it's may be used by the specified container implementation.
	* It'd better not to depends on the data in the json DB sample.
	*/
	class MessageRestTest extends RestBase {

	private function getAllEntities($url) {
	$sep = strpos($url, '?') !== false ? '&' : '?';
	$ret = $this->curlRest($url . $sep . 'startIndex=0&count=1000000', '', 'application/json', 'GET');
	$retDecoded = json_decode($ret, true);
	$this->assertTrue($ret != $retDecoded && $ret != null, "Invalid json response: $retDecoded");
	return $retDecoded['entry'];
	}

	/**
	* NOTE: If there are lots of messages in the storage this test may take a long time as
	* it retrieves all the message.
	*/
	private function verifyLifeCycle($postData, $postDataFormat, $randomTitle) {
	$url = '/messages/1/@outbox';

	$cnt = count($this->getAllEntities($url));

	// Creates the message.
	$ret = $this->curlRest($url, $postData, $postDataFormat, 'POST');
	$this->assertTrue(empty($ret), "Create message failed. Response: $ret");

	// Gets the message.
	$messages = $this->getAllEntities($url);
	$this->assertEquals($cnt + 1, count($messages), "Size of the messages is not right.");
	$fetchedMessage = null;
	foreach ($messages as $m) {
	if ($m['title'] == $randomTitle) {
	$fetchedMessage = $m;
	}
	}
	$this->assertNotNull($fetchedMessage, "Couldn't find the created message with title $randomTitle");

	// Deletes the message.
	$ret = $this->curlRest($url . '/' . urlencode($fetchedMessage['id']), '', 'application/json', 'DELETE');
	$this->assertTrue(empty($ret), "Delete the created message failed. Response: $ret");

	$messages = $this->getAllEntities($url, $randomTitle);
	$this->assertEquals($cnt, count($messages), "Size of the messages is not right after deletion.");
	}

	public function testLifeCycleInJson() {
	$randomTitle = "[" . rand(0, 2048) . "] message test title.";
	$postData = '{
	"id" : "msgid",
	"recipients" : [2,3],
	"title" : "' . $randomTitle . '",
	"titleId" : "541141091700",
	"body" : "Short message from Joe to some friends",
	"bodyId" : "5491155811231",
	"type" : "privateMessage",
	"status" : "unread"
	}';
	$this->verifyLifeCycle($postData, 'application/json', $randomTitle);
	}

	public function testLifeCycleInXml() {
	$randomTitle = "[" . rand(0, 2048) . "] message test title.";
	$postData = '<message xmlns="http://ns.opensocial.org/2008/opensocial">
	<recipient>2</recipient>
	<recipient>3</recipient>
	<title>' . $randomTitle . '</title>
	<id>msgid</id>
	<body>Click <a href="http://app.example.org/invites/{msgid}">here</a> to review your invitation.</body>
	</message>';
	$this->verifyLifeCycle($postData, 'application/xml', $randomTitle);
	}

	public function testLifeCycleInAtom() {
	$randomTitle = "[" . rand(0, 2048) . "] message test title.";
	$postData = '<entry xmlns="http://www.w3.org/2005/Atom"
	xmlns:osapi="http://opensocial.org/2008/opensocialapi">
	<osapi:recipient>2</osapi:recipient>
	<osapi:recipient>3</osapi:recipient>
	<title>' . $randomTitle . '</title>
	<id>{msgid}</id>
	<link rel="alternate" href="http://app.example.org/invites/{msgid}"/>
	<content>Click <a href="http://app.example.org/invites/{msgid}">here</a> to review your invitation.</content>
	</entry>';
	$this->verifyLifeCycle($postData, 'application/atom+xml', $randomTitle);
	}

	public function testMessageCollectionLifeCycle() {
	$url = '/messages/1';
	// Gets number of message collections in the repository.
	$cnt = count($this->getAllEntities($url));

	// Creates a message collection.
	$createData = array();
	$createData['title'] = "[" . rand(0, 2048) . "] message collection test title.";
	$createData['urls'] = array("http://abc.com/abc", "http://xyz.com/xyz");
	$ret = $this->curlRest($url, json_encode($createData), 'application/json', 'POST');

	// Verifies that whether the message collection is created.
	$retDecoded = json_decode($ret, true);
	$id = $retDecoded['entry']['id'];
	$this->assertEquals($cnt + 1, count($this->getAllEntities($url)), "Wrong size of the collections. $ret");

	// Updates the created message collection.
	$newUrls = array("http://123.com/123");
	$newTitle = 'new title';
	$updateData = array();
	$updateData['id'] = $id;
	$updateData['title'] = $newTitle;
	$updateData['urls'] = $newUrls;

	$ret = $this->curlRest($url . "/$id", json_encode($updateData), 'application/json', 'PUT');
	$this->assertTrue(empty($ret), "Update should return empty. $ret <$id>");

	$collections = $this->getAllEntities($url);
	$this->assertEquals($cnt + 1, count($collections), "Wrong size of the collections.");
	$found = false;
	foreach ($collections as $collection) {
	if ($collection['id'] == $id) {
	$this->assertEquals($newTitle, $collection['title']);
	$this->assertEquals($newUrls, $collection['urls']);
	$found = true;
	}
	}
	$this->assertTrue($found, "Created message not found.");

	// Deletes the message collection.
	$ret = $this->curlRest($url . "/$id", '', 'application/json', 'DELETE');

	// Verifies that the message collection is deleted.
	$this->assertEquals($cnt, count($this->getAllEntities($url)), "Wrong size of the collections. $ret");
	}
	}