<?php
require_once( "ringside/api/DefaultRest.php" );

class SuggestionAdd extends Api_DefaultRest
{

	/**
	 * String representing the topic of discussion.
	 */
	protected $m_topic;
	
	/**
	 * The UID of the user who created the topic.
	 */
	protected $m_owner;
	
	/**
	 * The actual suggestion. 
	 */
	protected $m_suggestion;
	
	/**
         * The API key of the application containing the topic.
         */
	protected $m_appApiKey;
	

	public function validateRequest( )
	{
		
		$this->m_topic = $this->getRequiredApiParam( 'topic' );
		$this->m_owner = $this->getRequiredApiParam( 'owner' );
		$this->m_suggestion = $this->getRequiredApiParam( 'suggestion' );
		$this->m_appApiKey = $this->getRequiredApiParam( 'app_api_key' );
	}
	
	public function execute()
	{
		//construct insertion SQL
		$sql = 'INSERT INTO suggestions SET ' .
    				 "topic='{$this->m_topic}'," .
    				 'uid=' . $this->getUserId() .
    				 ", suggestion='{$this->m_suggestion}', " .
    				 "api_key='{$this->m_appApiKey}', " .
    				 "owneruid={$this->m_owner}";
		
		//get DB connection
		if (!($db = $this->getDbCon())) {
			throw new Exception('Could not connect to DB: ' . mysql_error());
		}
		//execute query
		if (!mysql_query($sql, $db)) {
			throw new Exception('Error inserting into DB: ' . mysql_error() . "\nSQL='$sql'");
		} 
		
		//if made it this far, then return successfully
		return true;	
	}
}
?>

<?php
require_once( "ringside/api/DefaultRest.php" );

class SuggestionGetTopics extends Api_DefaultRest
{
	/**
	 * Array of friend IDs to query topics from.
	 */
	protected $m_friends;
	

	public function validateRequest()
	{
				
		$this->m_friends = explode(',', $this->getRequiredApiParam( 'friends' ) );		
	}
	
	public function execute()
	{
		//get DB connection
		if (!($db = $this->getDbCon())) {
			throw new Exception('Could not connect to DB: ' . mysql_error());
		}
		
		//construct query
		$sql = "SELECT DISTINCT topic, owneruid FROM suggestions WHERE " .
				 "owneruid IN ({$this->getUserId()}";
		if (count($this->m_friends) > 0) {
			$sql .= ',' . implode(',', $this->m_friends);
		}
		$sql .= ') ORDER BY topic';
		
		//execute query
		$results = mysql_query($sql, $db);
		if (!$results) {
			throw new Exception('Could not execute query: ' . mysql_error() . "\nSQL='$sql'");
		}
		$response = array();
		$response['topic'] = array();
		
		//create response
		while($row = mysql_fetch_assoc($results)) {
			$response['topic'][] = $row;
		}
		return $response;
	}
}
?>

<?php
require_once( "ringside/api/DefaultRest.php" );

class SuggestionGet extends Api_DefaultRest
{
	/**
    * The API key of the application containing the topic.
    */
	protected $m_appApiKey;
	
	/**
	 * Array of friend IDs to query topics from.
	 */
	protected $m_friends;
	
	function beginsWith( $str, $sub ) {
		return ( substr( $str, 0, strlen( $sub ) ) === $sub );
	}
	function endsWith( $str, $sub ) {
	   return ( substr( $str, strlen( $str ) - strlen( $sub ) ) === $sub );
	}


	public function validateRequest( )
	{

		$this->m_friends = $this->getRequiredApiParam( 'friends' );
		$this->m_appApiKey = $this->getRequiredApiParam( 'app_api_key' );
		
		if($this->endsWith($this->m_friends, ','))
		{
			$this->m_friends = substr($this->m_friends, 0, strlen($this->m_friends) - 1);
		}
	}
	
	public function execute()
	{
		//get DB connection
		if (!($db = $this->getDbCon())) {
			throw new Exception('Could not connect to DB: ' . mysql_error());
		}
		
		//construct query
		$sql = "SELECT * FROM suggestions WHERE api_key='{$this->m_appApiKey}' " .
				 " AND owneruid IN ({$this->getUserId()}";
		if (strlen($this->m_friends) > 0) {
			$sql .= ",$this->m_friends";
		}
		$sql .= ') ORDER BY topic, sid';

		//execute query
		$results = mysql_query( $sql, $db);
		if ( mysql_errno($db) > 0  && !$results) {
			throw new Exception('Could not execute query: ' . mysql_error() . "\nSQL='$sql'");
		}

		$suggestions = array();
  		//create response
  		while($row = mysql_fetch_assoc($results)) {
   			$suggestions[] = $row;
  		}
  		
  		$response = array();
  		if (!empty( $suggestions ) ) { 
     		$response['suggestions'] = $suggestions;
  		} 
  		else {
     		$response['result'] = '';
 		}
 		return $response;
	}
}
?>

<?php
require_once('ringside/api/clients/RingsideRestClient.php');

class SuggestionClient
{
   public $delegate;
    
   /**
    * Constructs a Ringside-specific REST client.
    */
   public function __construct($delegate) {
      $this->delegate = $delegate;
   }

   /**
    * Add a suggestion to a given topic.
    * @param $topic String name of the topic.
    * @param $owner Integer uid of topic owner.
    * @param $apiKey API key of app that owns topic.
    * @param $suggestion String representing suggestion to topic.
    */
   public function suggestion_add($topic, $owner, $apiKey, $suggestion)
   {
      //construct the parameters
      $params = array();
      $params['topic'] = $topic;
      $params['owner'] = $owner;
      $params['app_api_key'] = $apiKey;
      $params['suggestion'] = $suggestion;

      //make a call to the underlying REST client to add a suggestion
      return $this->delegate->call_method("ringside.suggestion.add", $params);
   }

   /**
    * Get all suggestions for a given API key and user.
    * @param $apiKey API key of app that owns topic.
    * @param $friends Array of friend UIDs (optional)
    */
   public function suggestion_get($apiKey, $friends = array())
   {
      //construct the parameters
      $params = array();
      $params['app_api_key'] = $apiKey;
      $params['friends'] = $friends;

      //make a call to the underlying REST client to add a suggestion
      $response =  $this->delegate->call_method("ringside.suggestion.get", $params);
      if ( empty ($response) ) { 
         $response = array();
      }
      return $response;
   }

   /**
    * Get all suggestions for a given API key and user.
    * @param $friends Array of friend UIDs (optional)
    */
   public function suggestion_getTopics($friends = array())
   {
      //construct the parameters
      $params = array();
      $params['friends'] = $friends;

      //make a call to the underlying REST client to add a suggestion
      $response = $this->delegate->call_method("ringside.suggestion.getTopics", $params);
      if ( empty ($response) ) { 
         $response = array();
      }
      return $response;
   }
}

?>

<?php
require_once('config.php');
require_once('ringside/api/clients/RingsideApiClients.php');
require_once('ringside/api/clients/SuggestionClient.php');

class SuggestionUtils
{
	static private function getSuggestionClient()
	{
	   	$client = new RingsideApiClients( Config::$api_key, Config::$secret );
	   	$uid = $client->require_login();
	   	
	   	$delegate = $client->api_client; 
		$obj = new ReflectionObject( $delegate );
	   	$suggestionClient = new SuggestionClient( $delegate );
	   	
	   	return $suggestionClient;
	}

	/**
	 * Saves a suggestion
	 */
	static public function createSuggestion($topic, $suggestion, $owner)
	{
		$client = self::getSuggestionClient();
		$client->suggestion_add($topic, $owner, Config::$api_key, $suggestion);
	}

	/**
	 * Returns suggestions for topics from this user or their friends
	 */
	static public function getSuggestions() 
	{
		$client = self::getSuggestionClient();
		$friends = $client->delegate->friends_get();
		
		$resp = $client->suggestion_get(Config::$api_key, $friends);
		
		if (!$resp)  return array();
		return $resp;
	}

	/**
	 * Returns all the topics for this user
	 */
	static public function getTopics()
	{
		$client = self::getSuggestionClient();		
		$friends = $client->delegate->friends_get();
		$resp = $client->suggestion_getTopics($friends);
		if (!$resp) return array(); 
		return $resp;
	}
}
?>