File Coverage

blib/lib/WebService/GData/YouTube/Feed/Video.pm

Criterion	Covered	Total	%
statement	146	240	60.8
branch	36	88	40.9
condition	7	15	46.6
subroutine	41	55	74.5
pod	29	34	85.2
total	259	432	59.9

package WebService::GData::YouTube::Feed::Video;

use WebService::GData;
use base 'WebService::GData::Feed::Entry';
use WebService::GData::Constants qw(:all);
use WebService::GData::YouTube::Constants qw(:all);
use WebService::GData::YouTube::StagingServer ();
use WebService::GData::Error;
use WebService::GData::Node::PointEntity();
use WebService::GData::YouTube::YT::GroupEntity();
use WebService::GData::YouTube::YT::AccessControl();
use WebService::GData::YouTube::YT::Rating();
use WebService::GData::YouTube::YT::Recorded();
use WebService::GData::Node::Media::Category();
use WebService::GData::Collection;

our $VERSION         = 0.02_01;
our $ROOT_URI        = BASE_URI;
our $UPLOAD_BASE_URI = UPLOAD_BASE_URI . PROJECTION . '/users/default/uploads/';
our $BASE_URI        = BASE_URI . PROJECTION . '/users/default/uploads/';
our $API_DOMAIN_URI  = API_DOMAIN_URI;

if ( WebService::GData::YouTube::StagingServer->is_on ) {
	$ROOT_URI = STAGING_BASE_URI;
	$UPLOAD_BASE_URI =
	  STAGING_UPLOAD_BASE_URI . PROJECTION . '/users/default/uploads/';
	$BASE_URI       = STAGING_BASE_URI . PROJECTION . '/users/default/uploads/';
	$API_DOMAIN_URI = STAGING_API_DOMAIN_URI;

}

use constant {
	DIRECT_UPLOAD  => 'DIRECT_UPLOAD',
	BROWSER_UPLOAD => 'BROWSER_UPLOAD'
};

sub __init {
	my ( $this, $feed, $req ) = @_;

	$feed ||= {};
	if ( ref($feed) ne 'HASH' ) {
		$req  = $feed;
		$feed = {};
	}

	$this->SUPER::__init( $feed, $req );
	$this->_media(
		new WebService::GData::YouTube::YT::GroupEntity(
			$feed->{'media$group'} || {}
		)
	);
	$this->{_rating} =
	  new WebService::GData::YouTube::YT::Rating( $feed->{'yt$rating'} );
	$this->{_recorded} =
	  new WebService::GData::YouTube::YT::Recorded( $feed->{'yt$recorded'} );
	$this->_entity->child( $this->_media )->child( $this->{_rating} )
	  ->child( $this->{_recorded} );
}

sub next_url {
	my $this = shift;
	if ( @_ == 1 ) {
		$this->{next_url} = _urlencode( shift() );
	}
	return $this->{next_url};
}

sub location {
	my ( $this, $pos ) = @_;
	my $where = $this->{_feed}->{'georss$where'};
	if ( ref($where) eq 'HASH' && !$this->{_where} ) {
		$this->_location(
			new WebService::GData::Node::PointEntity(
				$where->{'gml$Point'}->{'gml$pos'}
			)
		);
	}
	else {
		$this->{_feed}->{'georss$where'} = {};
		$this->_location( new WebService::GData::Node::PointEntity() );
	}
	if ($pos) {
		$this->_location->pos($pos);
	}
	return ref $this->_location->pos ? '' : $this->_location->pos;

}

sub _location {
	my ( $this, $instance ) = @_;
	if ($instance) {
		$this->{_where} = $instance;
		$this->_entity->child($instance);
	}
	$this->{_where};
}

sub view_count {
	my $this = shift;
	$this->{_feed}->{'yt$statistics'}->{'viewCount'};
}

sub favorite_count {
	my $this = shift;
	$this->{_feed}->{'yt$statistics'}->{'favoriteCount'};
}

sub _media {
	my ( $this, $instance ) = @_;
	if ($instance) {
		$this->{_media} = $instance;
	}
	$this->{_media};
}

sub media_player {
	my $this = shift;
	$this->_media->player( {} )->url;
}

sub restriction {
	my $this = shift;
	$this->_media->restriction;
}

sub denied_countries {
	my $this   = shift;
	my $denied = $this->_media->restriction->relationship('deny');
	return if !ref $denied;
	my @countries;
	foreach my $d (@$denied) {
		push @countries, $d->text if ( $d->type eq 'country' );
	}
	return join ' ', @countries;
}

sub aspect_ratio {
	my $this = shift;
	$this->_media->aspect_ratio;
}

sub video_id {
	my ( $this, $id ) = @_;
	$this->_media->videoid($id) if $id;
	ref $this->_media->videoid ? '' : $this->_media->videoid;
}

sub duration {
	my $this = shift;
	$this->_media->duration( {} )->seconds;
}

sub content {
	my $this = shift;
	$this->_media->content;
}

sub thumbnails {
	my $this = shift;
	$this->_media->thumbnail;
}

sub uploaded {
	my $this = shift;
	$this->_media->uploaded;
}

sub uploader {
	my $this = shift;
	if ( @{ $this->_media->credit->role('uploader') } > 0 ) {
		$this->_media->credit->role('uploader')->[0]->text;
	}
}

sub category {
	my $this = shift;

	if ( @_ == 1 ) {
		if ( !$this->_media->category->isa('WebService::GData::Collection') ) {
			$this->_media->swap( $this->_media->category,
				new WebService::GData::Collection() );
		}
		push @{ $this->_media->category },
		  new WebService::GData::Node::Media::Category(
			{
				'$t'    => $_[0],
				'label' => $_[0],
				'scheme' =>
				  'http://gdata.youtube.com/schemas/2007/categories.cat'
			}
		  );
	}
	$this->_media->category;
}

sub genre {
	my $this = shift;
	if ( @{ $this->_media->category } > 0 ) {
		$this->_media->category->[0]->text;
	}
}

sub is_read_only {
	my $this = shift;
	return 1 if ( @{ $this->links->rel('edit') } > 0 );
}

sub description {
	my $this = shift;
	if ( @_ == 1 ) {
		$this->_media->description( $_[0] );
		$this->_media->description( {} )->type("plain");
	}
	$this->_media->description || '';
}

sub title {
	my $this = shift;
	if ( @_ == 1 ) {
		$this->_media->title( $_[0] );

		$this->_media->title( {} )->type("plain");
	}
	$this->_media->title || '';
}

sub keywords {
	my $this = shift;
	if ( @_ >= 1 ) {
		return $this->_media->keywords( join( ',', @_ ) );
	}
	$this->_media->keywords || '';
}

sub is_private {
	my $this = shift;
	if ( @_ == 1 ) {
		$this->_media->{'_private'} =
		  new WebService::GData::YouTube::YT::Private();
		$this->_media->_entity->child( $this->_media->{'_private'} );
	}
	return ( $this->_media->private ) ? 1 : 0;
}

sub comments {
	my $this = shift;
	$this->{_feed}->{'gd$comments'}->{'gd$feedLink'}->{'href'};
}

sub appcontrol_state {
	my $this = shift;
	return $this->{_feed}->{'app$control'}->{'yt$state'}->{reasonCode};
}

#####WRITE FUNCTIONS########################

sub _access_control {
	my ( $this, $instance ) = @_;
	if ($instance) {
		$this->{_access_control} = $instance;
		$this->_entity->child($instance);
	}
	$this->{_access_control};
}

sub access_control {
	my $this = shift;
	if ( !$this->_access_control ) {
		$this->_access_control( new WebService::GData::Collection() );
		my $access = $this->{_feed}->{'yt$accessControl'} || [];
		foreach my $control (@$access) {
			push @{ $this->_access_control },
			  new WebService::GData::YouTube::YT::AccessControl($control);
		}
	}
	if ( @_ == 2 ) {

		#first check if the action is already set and if so update
		my $ret = $this->_access_control->action( $_[0] );
		if ( @$ret > 0 ) {
			$ret->[0]->permission( $_[1] );
		}

		#if not, just push a new entry;
		else {
			push @{ $this->_access_control },
			  new WebService::GData::YouTube::YT::AccessControl(
				{ action => $_[0], permission => $_[1] } );
		}
	}
	if ( @_ == 1 ) {

		return $this->_access_control->action( $_[0] )->[0];

	}
	$this->_access_control;
}

sub delete {
	my $this = shift;

	my $uri =
	  @{ $this->links->rel('edit') } > 0
	  ? $this->links->rel('edit')->[0]->href
	  : $BASE_URI . $this->video_id;
	$this->{_request}->delete( $uri, 0 );
}

sub rate {
	my ( $this, $val ) = @_;
	$this->rating->value($val) if $val;
	my $uri =
	  $ROOT_URI . PROJECTION . '/videos/' . $this->video_id . '/ratings';
	$this->{_request}->insert( $uri, XML_HEADER . $this->serialize() );
}

sub add_video_response {
	my ( $this, $response ) = @_;
	my $uri =
	  $ROOT_URI . PROJECTION . '/videos/' . $this->video_id . '/responses';
	$this->{_request}->insert( $uri, XML_HEADER . $response->serialize() );
}

sub delete_video_response {
	my ( $this, $response_id ) = @_;
	my $uri =
	    $ROOT_URI. PROJECTION
	  . '/videos/'. $this->video_id
	  . '/responses/' . $response_id;
	$this->{_request}->delete($uri);
}

sub add_favorite_video {
    my ( $this,$id) = @_;

    $this->id($id) if $id;

    if($this->id){
        my $uri =
            $ROOT_URI . PROJECTION . '/users/default/favorites';
            $this->{_request}->insert( $uri, XML_HEADER . $this->serialize() );
    }
}

sub save {
	my ($this) = @_;
	my $content = XML_HEADER . $this->serialize();

	if ( $this->video_id ) {

		my $ret =
		  $this->{_request}->update( $BASE_URI . $this->video_id, $content );
	}
	else {

		if ( $this->upload_mode eq DIRECT_UPLOAD ) {
			$this->direct_uploading( $UPLOAD_BASE_URI, $content );
		}
		else {
			return $this->browser_uploading( $UPLOAD_BASE_URI, $content );
		}
	}
}

#video upload

sub filename {
	my $this = shift;
	return $this->{_filename} = $_[0] if ( @_ == 1 );
	$this->{_filename};
}

#TODO: stream
sub _binary_data {
	my $this = shift;

	if ( @_ == 1 ) {
		my $fh = $_[0];
		binmode($fh);
		my $data = '';
		while ( read $fh, my $buf, 1024 ) {
			$data .= $buf;
		}
		close $fh;
		return $this->{_binary_data} = $data;
	}
	$this->{_binary_data};
}

sub upload_mode {
	my $this = shift;
	if ( @_ == 1 ) {
		$this->{_UPLOAD_MODE} = shift;
		$this->{_UPLOAD_MODE} = undef
		  if ( $this->{_UPLOAD_MODE} ne DIRECT_UPLOAD
			|| $this->{_UPLOAD_MODE} ne BROWSER_UPLOAD );
	}
	$this->{_UPLOAD_MODE} = BROWSER_UPLOAD if ( !$this->{_UPLOAD_MODE} );
	$this->{_UPLOAD_MODE};
}

sub browser_uploading {
	my ( $this, $uri, $content ) = @_;
	my $response =
	  $this->{_request}
	  ->insert( $API_DOMAIN_URI . 'action/GetUploadToken', $content );

	my ( $url, $token ) =
	  $response =~ m/(.+?)<\/url>(.+?)<\/token>/;
	if ( $this->next_url ) {
		$url .= '?' . $this->next_url;
	}
	return ( $url, $token, $response );
}

#TODO:move this and rewrite from scratch!
sub direct_uploading {
	my ( $this, $uri, $content ) = @_;

	my $binary = $this->_binary_data;

	my $content2 = <

--f93dcbA3
Content-Type: application/atom+xml; charset=UTF-8



  xmlns:media="http://search.yahoo.com/mrss/"
  xmlns:yt="http://gdata.youtube.com/schemas/2007">
XML

	$content2 .= $content . '';

	$content2 .= <

--f93dcbA3
Content-Type: video/quicktime
Content-Transfer-Encoding: binary

$binary

--f93dcbA3--
XML

	my $req = HTTP::Request->new( POST => $uri );

	if ( $this->{_request}->auth ) {
		$this->{_request}->auth->set_authorization_headers( $this, $req );
		$this->{_request}->auth->set_service_headers( $this, $req );
	}
	$req->header( 'GData-Version' => $this->{_request}->query->get('v') );
	$req->header( 'Slug'          => $this->filename );
	$req->content_type('multipart/related; boundary="f93dcbA3"');
	$req->header( 'Content-Length' => length($content2) );
	$req->header( 'Connection'     => 'close' );
	$req->content($content2);

	my $res = $this->{_request}->{__UA__}->request($req);
	if ( $res->is_success ) {
		return $this;
	}
	else {
		die new WebService::GData::Error( $res->code, $res->content );
	}

}

{
	no strict 'refs';

	my %controlList = (
		videoRespond => 'video_response',
		rate         => 'rating',
		embed        => 'embedding',
		list         => 'listing',
		syndicate    => 'syndication'
	);
	my @ytControls = ( keys %controlList, 'comment', 'comment_vote' );

	foreach my $access (@ytControls) {
		my $name = $access;
		$name =~ s/_([a-z])/\U$1/g;
		my $func = $controlList{$access} || $access;
		*{ __PACKAGE__ . '::is_' . $func . '_allowed' } = sub {
			my $this = shift;
			my $ret  = $this->_access_control->action($name)->[0];
			return ( $ret && $ret->permission eq 'allowed' ) ? 1 : 0;
		  }
	}
}

private _urlencode => sub {
	my ($string) = shift;
	$string =~ s/(\W)/"%" . unpack("H2", $1)/ge;
	return $string;
};

"The earth is blue like an orange.";

__END__