ingest.php

<?php

/*
 *name: Carter Currin
 *file: ingest.php
 *description: receives http requests with raw POST data in the following form:
 *  {  
 *    "endpoint":
 *    {  
 *      "method":"GET",
 *      "url":"http://sample-domain-endpoint.com/data?key={key}&value={value}&foo={bar}"
 *    },
 *    "data":
 *    [  
 *      {  
 *        "key":"Azureus",
 *        "value":"Dendrobates"
 *      },
 *      {  
 *        "key":"Phyllobates",
 *        "value":"Terribilis"
 *      }
 *    ]
 *  }
 *  
 *  for each "data" object in the accepted request, a "postback" object will be
 *  appended to the "request" list in a local redis database as such:
 *  KEY      VALUES
 *  request  {  
 *              "method":"GET",
 *              "url":"http://sample-domain-endpoint.com/data?key={key}&value={value}&foo={bar}"
 *              "data":
 *              {  
 *                 "key":"Azureus",
 *                 "value":"Dendrobates"
 *              }
 *           },
 *           {  
 *              "method":"GET",
 *              "url":"http://sample-domain-endpoint.com/data?key={key}&value={value}&foo={bar}"
 *              "data":
 *              {  
 *                 "key":"Phyllobates",
 *                 "value":"Terribilis"
 *              }
 *           }
 */

require 'Predis/Autoloader.php';
Predis\Autoloader::register();

$REDIS_LIST_NAME = 'request';

//tries to decode JSON from the raw post data. If it can not, echos an error
if($content = json_decode(file_get_contents('php://input'), true))
{	
	//varifies that the provided endpoint url is in valid form. Else echos an error
	if(filter_var($content['endpoint']['url'], FILTER_VALIDATE_URL))
	{
		//varifies the endpoint method is supported. Else echos an error
		if(strtoupper($content['endpoint']['method']) == 'GET' ||
		   strtoupper($content['endpoint']['method']) == 'POST')
		{
			try
			{   //makes a coonection to the local redis database
				$redis = new Predis\Client();
				//makes separate "postback" objects for each received "data" object
				foreach($content['data'] as $data)
				{
					$redis->rpush($REDIS_LIST_NAME, json_encode($content['endpoint'] + array('data' => $data)));
				}
				echo "Success!<br>";
			}
			catch (Exception $e)
			{
				echo "Could not connect to Redis.<br>";
				echo $e->getMessage();
			}
		}
		else
		{
			echo 'Expected "method" to be GET or POST.<br>';
		}
	}
	else
	{
		echo 'Expected valid "url".<br>';
	}
}
else
{
	echo 'Raw POST Request not in JSON form.<br>';
}
?>