<?php 	 
	require 'bean.php';
	
	class DSResponse extends Bean
	{
		// variables
		/* Read/Write property*/
		var $data;		
		/* Read/Write property*/
		var $startRow;
		/* Read/Write property*/
		var $endRow;
		/* Read/Write property*/
		var $totalRows;
		/* Read/Write property*/
		var $status;
				 
		public function setData($value) {			 
			$this->data = empty($value) ? null : (Array)$value;
			return $this;
		}
		public function getData( )
		{
			return $this->data;
		}
		
		public function setStartRow($value) {			
			$this->startRow = (int)$value;
			return $this;
		}
		public function getStartRow(  )
		{
			return $this->startRow;
		}
		
		public function setEndRow($value) {			
			$this->endRow = (int)$value;
			return $this;
		}
		public function getEndRow(  )
		{
			return $this->endRow;
		}
		
		public function setTotalRows($value) {			
			$this->totalRows = (int)$value;
			return $this;
		}
		public function getTotalRows(  )
		{
			return $this->totalRows;
		}
		
		public function setStatus($value) {			
			$this->status = (int)$value;
			return $this;
		}
		public function getStatus(  )
		{
			return $this->status;
		}
		
	}

<?php
	require 'DSResponse.php';	 	
    require 'DSRequest.php';
       	
	class RPCManager
	{
		var $_request;
		var $_response;
		
		function __construct($request)
		{
			$this->_request = $request;			
		}

/// <summary>
/// Process the request for which this RPCManager was created for
/// </summary>
/// <returns></returns>
public function processRequest()
{
	// retrieve the requests with data
	$request = new DSRequest($this->_request);
	// set the response variable									
	$response = $request->execute();
	// safeguard, if was null, create an empty response with failed status
	if (empty($response))
	{
		$response = new DSResponse();
		$response->setStatus(-1);
	}
	$this->_response = $response;
	return $this->buildResult();
} 

/// <summary>
/// Transforms a object object into a JsonNetResult. Will setup the serializer with the 
/// appropriate converters, attributes,etc.
/// </summary>
/// <param name="dsresponse">the object object to be transformed to JsonNetResult</param>
/// <returns>the created JsonNetResult object</returns>
private function buildResult()
{
	$data = array();
	$data['response'] = (Array)$this->_response;
	echo json_encode($data);	 
}  

require_once 'RPCManager.php';   
$rpc_manager = new RPCManager($HTTP_RAW_POST_DATA);
return $rpc_manager->processRequest();		

In order to get the parameters from the user, we should parse $HTTP_RAW_POST_DATA and then we can parse it to the JSON format.

The code that has been removed is no longer required here, as the functionality for processing the requests has been moved inside the DataSource class. As discussed earlier, the functionality from the controller is now resident in the DataSource class itself:

public function execute($request)
{
	 switch($request->operationType)
	 {
		 case 'fetch':  	return $this->fetch($request);
		 case 'add':
			return $this->add($request);
		 case 'update':                                    
			return $this->update($request);
		 case 'remove':                                       
			return $this->remove($request);
	 }
}
private function add($request)
{            
	$ds = $this->data_source;
	// get the table name from data source
	$tbl_name = $ds['ID'];
	$new_data = $request->data;
	$insert_values = array();
	// make the query            
	$columns = '';
	$values = '';
	foreach($new_data as $key => $value)
	{            
	   $columns .=  $key.',';
	   $values .=  "?,";   
	   array_push($insert_values, $value);             
	}         
	// remove the last comma
	$columns = substr($columns, 0, strlen($columns) - 1);
	$values = substr($values, 0, strlen($values) - 1);
	// result insert query
	$insert_query = 'INSERT INTO '.$tbl_name.' ('.$columns.') VALUES ('.$values.')';
	
	// Run the insert query
	R::exec($insert_query, $insert_values);
	//DSResponse
	$response = new DSResponse();      
	$response->setData($new_data);            
	$response->setStatus(0);  
	return $response;
}
private function update($request)
{
	$old_data = $request->oldValues;
	$update_data = $request->data;
	$ds = $this->data_source;
	
	// update all fields which have changed. they are defined in the data property
	if ( count($request->getDataKeys()) != 0 )
	{
		 foreach($request->data as $key => $value)
		 {
			$old_data[$key] = $value;
		 }
	}     
	
	// get the id  by primary key
	$values = array();
	
	
	// get the table name from data source
	$tbl_name = $ds['ID'];            
	$set_value = '';
	// make the update query
	foreach($old_data as $key => $value)
	{          
		
		
			$set_value .= "$key = ?,"; 
			array_push($values, $value);                  
		 
	}
	array_push($values, $old_data['itemID']);
	
	// remove the last comma
	$set_value = substr($set_value, 0, strlen($set_value) - 1);
	// result insert query
	$update_query = 'UPDATE '.$tbl_name.' SET '.$set_value.' WHERE itemID = ?';
	 R::exec($update_query, $values);
	
	// build the criteria
	//DSResponse
	$response = new DSResponse();      
	$response->setData($old_data);            
	$response->setStatus(0);  
	return $response;
}
private function remove($request)
{
	$ds = $this->data_source;            
	// get the table name from 			return $this->fetch($request);
		 case 'add':
			return $this->add($request);
		 case 'update':data source
	$tbl_name = $ds['ID'];            
	$new_data = $request->data;
	// make the delete query
	$itemID = $new_data['itemID'];
	$delete_query = "DELETE FROM $tbl_name WHERE itemID = ?";
	// Run the insert query
 
			return $this->update($request	R::exec($delete_query, array($itemID));
		 case 'remove':                  								 
	//DSResponse
	$response = new DSResponse();      
 	$response->setData($new_data);            

			return $this->remove($request$response->setStatus(0);  
	return }$response;
}
private function addfetch($request)
{   
	// get the   DataSource
  
	$ds = $this->data_source;   
	$new$tbl_dataname = $request->data;
				$ds['ID'];   
	//DSResponse
	$response = new DSResponse(); check the advanced cretira             
   $query_result = 	$response$this->setData>buildStandardCriteria($new_data$request); 
	
	$query = "select * from $tbl_name ";
	
	$query 
	$response->setStatus(0).= $query_result['query'];
   
	return// $response;sort }by
private function update	if( !empty($request->sortBy) )
	{
	$old_data = $request->oldValues;
	$update_data = $request->data;
	$ds = $this->data_source;
	
	// update all fields which have changed. they are defined in the data property
	if ( count($request->getDataKeys()) != 0 )
	{
		 foreach($request->data as $key => $value)
		 {
			$old_data[$key] = $value;
		 }
	}     
	 
	// build the criteria
	//DSResponse
	$response = new DSResponse();      
	$response->setData($old_data);            
	$response->setStatus(0);  
	return $response;
}
private function remove($request)
{
	$ds = $this->data_source;
	$new_data = $request->data;
				// set the orderBy
		$query .= " order by ";
		
		// we start to build a coma separated list of items. First item won't have coma
		// but every possible next will do
		$seperator = "";
		foreach($request->sortBy as $index => $sort)
		{ 
			
			// if column name is with -, then ordering is descending, otherwise ascending
			if ( strpos($index, '-') === 0 )
			{
				$query .= $seperator . $sort . " ASC";
			} else
			{
				$query .= $seperator . substr($sort, 1) . " DESC";
			}
			$separator  = ',';
		}
	}
	
	//DSResponse
	$response = new DSResponse();       	$response->setData($new_data);          
	$products 
	$response->setStatus(0= R::getAll($query, $query_result['value']);   	return $response;
}
private function fetch($request)
{
	// get the count                 	// get the DataSource
	$ds$count = $this->data_sourcecount($products); 	$tbl_name = $ds['ID']; 	  	$query = "select * from $tbl_name s ";
	$query_count = "select count(*) from $tbl_name s";

	$response->setData($products);
	$response->setStartRow($request->startRow);
	$response->setEndRow($request->endRow);
	$response->setTotalRows($count);
	$response->setStatus(0);  
	
	// build up the query sanity check, if no rows, return 0
	if ( count($request->getDataKeys$response->getEndRow()) !=< 0 ) 
	{  

		$query .= ' where '$response->setEndRow(0);
	}
	$query_count .= ' where ';
		 
		foreach($request->data as $key => $value)
		{  
	return $response;
}