<?php
/*!
* HybridAuth
* http://hybridauth.sourceforge.net | http://github.com/hybridauth/hybridauth
* (c) 2009-2012, HybridAuth authors | http://hybridauth.sourceforge.net/licenses.html 
*/

/** 
 * Yahoo OAuth Class
 * 
 * @package             HybridAuth providers package 
 * @author              Lukasz Koprowski <azram19@gmail.com>
 * @version             0.2
 * @license             BSD License
 */ 

/**
 * Hybrid_Providers_Yahoo - Yahoo provider adapter based on OAuth1 protocol
 */
class Hybrid_Providers_Yahoo extends Hybrid_Provider_Model_OAuth1
{
	function initialize() 
	{
		parent::initialize();

		// Provider api end-points
		$this->api->api_base_url      = 'http://social.yahooapis.com/v1/';
		$this->api->authorize_url     = 'https://api.login.yahoo.com/oauth/v2/request_auth';
		$this->api->request_token_url = 'https://api.login.yahoo.com/oauth/v2/get_request_token';
		$this->api->access_token_url  = 'https://api.login.yahoo.com/oauth/v2/get_token';
	}

	function getUserProfile()
	{
		$userId = $this->getCurrentUserId();

		$parameters = array();
		$parameters['format']	= 'json';

		$response = $this->api->get( 'user/' . $userId . '/profile', $parameters ); 

		if ( ! isset( $response->profile ) ){
			throw new Exception( "User profile request failed! {$this->providerId} returned an invalid response.", 6 );
		}

		$data = $response->profile;

		$this->user->profile->identifier    = (property_exists($data,'guid'))?$data->guid:"";
		$this->user->profile->firstName     = (property_exists($data,'givenName'))?$data->givenName:"";
		$this->user->profile->lastName      = (property_exists($data,'familyName'))?$data->familyName:"";
		$this->user->profile->displayName   = (property_exists($data,'nickname'))?trim( $data->nickname ):"";
		$this->user->profile->profileURL    = (property_exists($data,'profileUrl'))?$data->profileUrl:"";
		$this->user->profile->gender        = (property_exists($data,'gender'))?$data->gender:"";

		if( $this->user->profile->gender == "F" ){
			$this->user->profile->gender = "female";
		}

		if( $this->user->profile->gender == "M" ){
			$this->user->profile->gender = "male";
		} 

		if( isset($data->emails) ){
			$email = "";
			foreach( $data->emails as $v ){
				if( isset($v->primary) && $v->primary ) {
					$email = (property_exists($v,'handle'))?$v->handle:"";

					break;
				}
			}

			$this->user->profile->email         = $email;
			$this->user->profile->emailVerified = $email;
		}
		
		$this->user->profile->age           = (property_exists($data,'displayAge'))?$data->displayAge:"";
		$this->user->profile->photoURL      = (property_exists($data,'image'))?$data->image->imageUrl:"";

		$this->user->profile->address       = (property_exists($data,'location'))?$data->location:"";
		$this->user->profile->language      = (property_exists($data,'lang'))?$data->lang:"";

		return $this->user->profile;
	}

	/**
	 * load the user contacts
	 */
	function getUserContacts()
	{
		$userId = $this->getCurrentUserId();

		$parameters = array();
		$parameters['format']	= 'json';
		$parameters['count'] = 'max';
		
		$response = $this->api->get('user/' . $userId . '/contacts', $parameters);

		if ( $this->api->http_code != 200 )
		{
			throw new Exception( 'User contacts request failed! ' . $this->providerId . ' returned an error: ' . $this->errorMessageByStatus( $this->api->http_code ) );
		}

		if ( !$response->contacts->contact && ( $response->errcode != 0 ) )
		{
			return array();
		}

		$contacts = array();

		foreach( $response->contacts->contact as $item ) {
			$uc = new Hybrid_User_Contact();

			$uc->identifier   = $this->selectGUID( $item );
			$uc->email        = $this->selectEmail( $item->fields );
			$uc->displayName  = $this->selectName( $item->fields );
			$uc->photoURL     = $this->selectPhoto( $item->fields );

			$contacts[] = $uc;
		}
		
		return $contacts;
	}

	/**
	* return the user activity stream  
	*/
	function getUserActivity( $stream ) 
	{
		$userId = $this->getCurrentUserId();

		$parameters = array();
		$parameters['format']	= 'json';
		$parameters['count']	= 'max';
		
		$response = $this->api->get('user/' . $userId . '/updates', $parameters);

		if( ! $response->updates || $this->api->http_code != 200 )
		{
			throw new Exception( 'User activity request failed! ' . $this->providerId . ' returned an error: ' . $this->errorMessageByStatus( $this->api->http_code ) );
		}

		$activities = array();

		foreach( $response->updates as $item ){
			$ua = new Hybrid_User_Activity();

			$ua->id = (property_exists($item,'collectionID'))?$item->collectionID:"";
			$ua->date = (property_exists($item,'lastUpdated'))?$item->lastUpdated:"";
			$ua->text = (property_exists($item,'loc_longForm'))?$item->loc_longForm:"";

			$ua->user->identifier  = (property_exists($item,'profile_guid'))?$item->profile_guid:"";
			$ua->user->displayName = (property_exists($item,'profile_nickname'))?$item->profile_nickname:"";
			$ua->user->profileURL  = (property_exists($item,'profile_profileUrl'))?$item->profile_profileUrl:"";
			$ua->user->photoURL    = (property_exists($item,'profile_displayImage'))?$item->profile_displayImage:""; 

			$activities[] = $ua;
		}

		if( $stream == "me" ){
			$userId = $this->getCurrentUserId();
			$my_activities = array();

			foreach( $activities as $a ){
				if( $a->user->identifier == $userId ){
					$my_activities[] = $a;
				}
			}

			return $my_activities;
		}

		return $activities;
	}

	//--

	function select($vs, $t)
	{
		foreach( $vs as $v ){
			if( $v->type == $t ) {
				return $v;
			}
		}

		return NULL;
	}

	function selectGUID( $v )
	{
		return (property_exists($v,'id'))?$v->id:"";
	}

	function selectName( $v )
	{
		$s = $this->select($v, 'name');
		
		if( ! $s ){
			$s = $this->select($v, 'nickname');
			return ($s)?$s->value:"";
		} else {
			return ($s)?$s->value->givenName . " " . $s->value->familyName:"";
		}
	}

	function selectNickame( $v )
	{
		$s = $this->select($v, 'nickname');
		return ($s)?$s:"";
	}

	function selectPhoto( $v )
	{
		$s = $this->select($v, 'guid');
		return ($s)?(property_exists($s,'image')):"";
	}

	function selectEmail( $v )
	{
		$s = $this->select($v, 'email');
		return ($s)?$s->value:"";
	}

	public function getCurrentUserId()
	{
		$parameters = array();
		$parameters['format']	= 'json';

		$response = $this->api->get( 'me/guid', $parameters );

		if ( ! isset( $response->guid->value ) ){
			throw new Exception( "User id request failed! {$this->providerId} returned an invalid response." );
		}

		return $response->guid->value;
	}
}