AMF-Connection
view release on metacpan or search on metacpan
0.21- Fixed check on Storable versionforparse_option()0.30 Wed May 11 18:07:11 BST 2011- Added callBatch () to make AMF batch RPC possible0.31 Fri May 4 17:33:56 2012 +0100- Support different source and destination in AMF remotingpackage(patch by Aleksey Komarov)0.32 Fri May 4 18:59:18 BST 2012- Fixed bug to correctly decode the HTTP response using decoded_content()whenthe AMFgateway supports HTTP Accept-Encoding request headers (bug report by Markus Ortner)
},"name":"AMF-Connection","no_index": {"directory": ["t","inc"]},"prereqs": {"build": {"requires": {"ExtUtils::MakeMaker": 0}},"configure": {"requires": {"ExtUtils::MakeMaker": 0}},"runtime": {"requires": {"LWP::UserAgent":"5.829","Storable::AMF":"0.71"}}},"release_status":"stable","version":"0.32"}
---abstract:'A simple library to write AMF clients.'author:-'Alberto Attilio Reggiori, <areggiori@cpan.org>'build_requires:ExtUtils::MakeMaker: 0configure_requires:ExtUtils::MakeMaker: 0dynamic_config: 1generated_by:'ExtUtils::MakeMaker version 6.59, CPAN::Meta::Converter version 2.112150'license: unknownmeta-spec:version: 1.4name: AMF-Connectionno_index:directory:- t- increquires:LWP::UserAgent: 5.829Storable::AMF: 0.71version: 0.32
AMF-Connection==============A simple module towriteAMF [1] clients to invoke remote services as used by Flex/AIR RIAs.The module includes basic supportforsynchronous HTTP/S based RPC request-response access, wherethe client sends a request to the server to be processed and the server returns a response to the clientcontaining the processing outcome. Data is sent back and forth in AMF binaryformat(AMFChannel). Other access patternssuch as pub/suband channels transport are out of scope of this inital release.See public github repo http://github.com/areggiori/AMF-ConnectionINSTALLATIONTo install this module type the following:perl Makefile.PLmakemake testmake installDEPENDENCIESThis module requires these other modules and libraries:Storable::AMF (forserialisation/deserialisation of AMF )LWP::UserAgent (forRPC services over HTTP/S POST )COPYRIGHT AND LICENCEPut the correct copyright and licence information here.Copyright (C) 2010 by Alberto Attilio Reggiori
- tests- more documentation- more testing- look into results/class mapping
examples/amfclient.pl view on Meta::CPAN
my$method='search';my$client= new AMF::Connection($endpoint);$client->setEncoding(3);#$client->setHTTPProxy('http://127.0.0.1:8888');#$client->addHeader( 'serviceBrowser', 'true' );$client->setHTTPCookieJar( HTTP::Cookies->new(file=>"/tmp/lwpcookies.txt",autosave=> 1,ignore_discard=> 1 ) );my$params= ["italy"];my($response) =$client->call($service.'.'.$method,$params);my$json= JSON->new;$json->ascii(1);$json->utf8(1);$json->pretty(1);$json->allow_blessed(1);$json->convert_blessed(1);my$json_data=$json->encode($response->getData );if($response->is_success ) {$json_data;}else{die"Can not send remote request for $service.$method method with params on $endpoint using AMF".$client->getEncoding()." encoding:\n".$json_data."\n";};
examples/get-brightcove-videos-metadata.pl view on Meta::CPAN
'videoRefId'=>undef,'videoId'=>$videoId,# param 2 - videoId'featuredLineupFetchInfo'=> {'fetchLevelEnum'=>'4','contentType'=>'VideoLineup','childLimit'=>'100'}}];my$response=$client->call($service.'.'.$method,$params);my$json= JSON->new;$json->ascii(1);$json->utf8(1);$json->pretty(1);$json->allow_blessed(1);$json->convert_blessed(1);my$json_data=$json->encode($response->getData );if($response->is_success ) {$json_data;}else{die"Can not send remote request for $service.$method method with params on $endpoint using AMF".$client->getEncoding()." encoding:\n".$json_data."\n";};
lib/AMF/Connection.pm view on Meta::CPAN
subnew {my($proto,$endpoint) =@_;my$class=ref($proto) ||$proto;my$self= {'endpoint'=>$endpoint,'headers'=> [],'http_headers'=> {},'http_cookie_jar'=> new HTTP::Cookies(),'response_counter'=> 0,'encoding'=> 0,# default is AMF0 encoding'ua'=> new LWP::UserAgent(),'append_to_endpoint'=>''};$self->{'ua'}->cookie_jar($self->{'http_cookie_jar'} );returnbless($self,$class);};
lib/AMF/Connection.pm view on Meta::CPAN
foreachmy$call(@batch){nextunless(defined$call&&ref($call) =~ m/HASH/&&defined$call->{'operation'} &&defined$call->{'arguments'});my$operation=$call->{'operation'};my$arguments=$call->{'arguments'};my$body= new AMF::Connection::MessageBody;$class->{'response_counter'}++;$body->setResponse("/".$class->{'response_counter'} );if($class->{'encoding'} == 3 ) {# AMF3$body->setTarget('null');my(@operation) =split('\.',$operation);my$method=pop@operation;my$service=join('.',@operation);my$destination= (defined$call->{'destination'}) ?$call->{'destination'} :$service;my$remoting_message=$class->_brew_flex_remoting_message($service,$method, {},$arguments,$destination);
lib/AMF/Connection.pm view on Meta::CPAN
# serialize request$request->serialize($request_stream);#use Data::Dumper;#print STDERR Dumper( $request );# set any extra HTTP headermap{$class->{'ua'}->default_header($_=>$class->{'http_headers'}->{$_} ); }keys%{$class->{'http_headers'} };my$http_response=$class->{'ua'}->post($class->{'endpoint'}.$class->{'append_to_endpoint'},# TODO - check if append to URL this really work for HTTP POSTContent_Type=>"application/x-amf",Content=>$request_stream->getStreamData());croak"HTTP POST error: ".$http_response->status_line."\n"unless($http_response->is_success);my$response_stream= new AMF::Connection::InputStream($http_response->decoded_content,$class->{'input_amf_options'});my$response= new AMF::Connection::Message;$response->deserialize($response_stream);#print STDERR Dumper( $response )."\n";# process AMF response headers$class->_process_response_headers($response);my@all= @{$response->getBodies() };# we make sure the main response is always returned firstreturn(wantarray) ?@all:$all[0];};# TODO## sub command { } - to send "flex.messaging.messages.CommandMessage" instead#subsetCredentials {my($class,$username,$password) =@_;$class->addHeader('Credentials', {'userid'=>$username,'password'=>$password}, 0 );};sub_process_response_headers {my($class,$message) =@_;foreachmy$header(@{$message->getHeaders()}) {if($header->getName eq'ReplaceGatewayUrl') {# another way used by server to keep cookies-less sessions$class->setEndpoint($header->getValue )unless(ref($header->getValue) );}elsif($header->getName eq'AppendToGatewayUrl') {# generally used for cokies-less sessions E.g. ';jsessionid=99226346ED3FF5296D08146B02ECCA28'$class->{'append_to_endpoint'} =$header->getValueunless(ref($header->getValue) );};
lib/AMF/Connection.pm view on Meta::CPAN
my$service='myService';my$method='myMethod';my$client= new AMF::Connection($endpoint);$client->setEncoding(3);# use AMF3 default AMF0$client->setHTTPCookieJar( HTTP::Cookies->new(file=>"/tmp/mycookies.txt",autosave=> 1,ignore_discard=> 1 ) );my@params= ('param1', {'param2'=>'value2'} );my$response=$client->call("$service.$method", \@params);if($response->is_success ) {my$result_object=$response->getData();# ...}else{die"Can not send remote request for $service.$method method on $endpoint\n";};my@response=$client->callBatch ( {"operation"=>$service.$method", "arguments" => \@params}, ... );=head1 DESCRIPTIONI was looking for a simple Perl module to automate data extraction from an existing Flash+Flex/AMS application, and I could not find a decent client implementation. So, this module was born based on available online documentation.This module has been inspired to SabreAMF PHP implementation of AMF client libraries.AMF::Connection is meant to provide a simple AMF library to write client applications for invocation of remote services as used by most flex/AIR RIAs.The module includes basic support for synchronous HTTP/S based RPC request-response access, where the client sends a request to the server to be processed and the server returns a response to the client containing the processing outcome. Data is sent...AMF0 and AMF3 support is provided using the Storable::AMF module. While HTTP/S requestes to the AMF endpoint are carried out using the LWP::UserAgent module. The requests are sent using the HTTP POST method as AMF0 encoded data by default. AMF3 encod...If encoding is set to AMF3 the Flex Messaging framework is used on returned responses content (I.e. objects casted to "flex.messaging.messages.AcknowledgeMessage" and "flex.messaging.messages.ErrorMessage" are returned).Simple batch requests and responses is provided also.See the sample usage synopsis above to start using the module.=head1 DATE TYPE SUPPORTThe latest 0.79 version of Storable::AMF added basic date support with the new_date() and perl_date() utilitiy functions. This is just great. Internally an AMF Date Type represents a timestamp in milliseconds since the epoch in UTC ("neutral") timezo...use Storable::AMF qw(new_date perl_date);and make sure any date passed to an AMF::Connection as parameter is encoded with new_date().=head2 OPEN ISSUES AND SHORTCOMINGSThere is still an issue when arbitrary Date structures are returned from an AMF server to an AMF::Connection (E.g. as part of values of structured AMF Objects). In this case, the AMF::Connection does not try to reparse the Perl object structure retur...All this means that an AMF::Connection client application can not rely on those Date returned by the server as being Perl timestamps (seconds since the epoch) and will need explicitly call perl_date() or divide the timestamp by 1000 *explicitly*.=head2 USING OLD Storable::AMF VERSIONSIn older versions (pre 0.79) of Storable::AMF there was no support for the AMF0/AFM3 Date Type, and everything was being passed as string to the server (E.g. "2010-09-22T02:34:00"). Or as double (number) if the date was in timestamp seconds since the...=head1 MAPPING OBJECTSBy combining the power of Perl bless {}, $package_name syntax and the Storable::AMF freeze()/thaw() interface, it is possible to pass arbitrary structured AMF Objects the corresponding AMF server can interpret. This is possible due a simple Perl obje...This means that an AMF::Connection application can wrap all ActionScript / Flex AMF Objects around Perl Objects and get them sent; and returned into a Perl object BLOB using the power of Storable::AMF freeze()/thaw().AFor example to send a SearchQueryFx AMF Object to the server an AMF::Connection advanced search call(), the following code could be used:my $client = new AMF::Connection ( ... );# ... prepare parameters...my $searchAMFObject = bless( {'searchId' => $searchId,'startHit' => int($startHit),'searchString' => $searchString,'hitsPerPage' => ($hitsPerPage) ? int($hitsPerPage) : 20,'sortId' => $sortId,}, 'com.mycompany.application.flex.data.SearchQueryFx');my $response = $client->call( "MySearchSevice.searchAdvanced", [ $searchAMFObject ] );#....For other Java to ActionScript type mappings possibilities see http://livedocs.adobe.com/blazeds/1/javadoc/flex/messaging/io/amf/ActionMessageOutput.html#writeObject(java.lang.Object)For PHP gateways at the moment there is not a known/documented way to map client to server objects.Future versions of AMF::Connection may add a proper configurable factory for application specific ActionScript/Flex object mappings.=head1 METHODS=head2 new ($endpoint)Create new AMF::Connection object. An endpoint can be specified as the only parameter. Or set in a second moment with the setEndpoint() method.=head2 call ($operation, $arguments)Call the remote service method with given parameters/arguments on the set endpoint and return an AMF::Connection::MessageBody response. Or an array of responses if requsted (wantarray call scope). The $arguments is generally an array reference, but t...=head2 callBatch (@batch)Call the remote service once in batch. Each element of @batch must be an hash like { "operation" => $operation, "arguments" => $arguments }, where $operation and $arguments are as specified in C<call>. The commands are called and responses returned i...=head2 setEndpoint ($endpoint)Set the AMF service endpoint.=head2 getEndpoint ()Return the AMF service endpoint.=head2 setEncoding ($encoding)
lib/AMF/Connection.pm view on Meta::CPAN
=head2 addHTTPHeader ($name, $value)Add an HTTP header to sub-sequent HTTP requests.=head2 setUserAgent ($ua)Allow to specify an alternative LWP::UserAgent. The $ua must support the post() method, proxy() and cookie_jar() if necessary.=head2 setHTTPCookieJar ($cookie_jar)Allow to specify an alternative HTTP::Cookies jar. By default AMF::Connection keeps cookies into main-memory and the cookie jar is reset when a new connection is created. When a new cookies jar is set, any existing AMF::Connection cookie is copied ov...=head2 getHTTPCookieJar ()Return the current HTTP::Cookies jar in use.=head2 setCredentials ($username,$password)Minimal support for AMF authentication. Password seems to be wanted in clear.=head2 setInputAMFOptions ($options)
lib/AMF/Connection/InputStream.pm view on Meta::CPAN
subreadLong {my($class) =@_;my$block=$class->readBuffer(4);my@long=unpack("N",$block);return$long[0];};# deparse out the next avail AMF entity# TODO - make sure ref counts are reset/preserved between calls in the scope of the same InputStream - study Storable::AMF APIsubreadAMFData {my($class) =@_;my$type=$class->readByte();# Storable::AMF will take care of deparsing the right AMF format$class->{'cursor'}--;local$@ =undef;
lib/AMF/Connection/Message.pm view on Meta::CPAN
# TODO - make sure Storable::AMF does not store string "true" as boolean - or make sure value is right typed$stream->writeAMFData($class->getEncoding(),$header->getValue() );};$stream->writeInt(scalar(@{$class->{'bodies'}}));foreachmy$body(@{$class->{'bodies'}}) {my$target=$body->getTarget();$stream->writeInt(length($target));$stream->writeBuffer($target);my$response=$body->getResponse();$stream->writeInt(length($response));$stream->writeBuffer($response);$stream->writeLong(-1);$stream->writeAMFData($class->getEncoding(),$body->getData() );};};subdeserialize {my($class,$stream) =@_;
lib/AMF/Connection/Message.pm view on Meta::CPAN
return$class->{'encoding'};};1;__END__=head1 NAMEAMF::Connection::Message - Encapsulates a request or response protocol packet/message=head1 SYNOPSIS# ...my $request = new AMF::Connection::Message;$request->setBody( $body );# ..=head1 DESCRIPTIONThe AMF::Connection::Message class encapsulates a request or response protocol packet/message.=head1 SEE ALSOStorable::AMF0, Storable::AMF3, AMF::Connection::MessageHeader, AMF::Connection::MessageBody=head1 AUTHORAlberto Attilio Reggiori, <areggiori at cpan dot org>=head1 COPYRIGHT AND LICENSE
lib/AMF/Connection/MessageBody.pm view on Meta::CPAN
packageAMF::Connection::MessageBody;usestrict;useCarp;subnew {my$proto=shift;my$class=ref($proto) ||$proto;my($target,$response,$data) =@_;my$self= {'target'=>$target,'response'=>$response,'data'=>$data# we might want to have some kind of mapper between remote objects and local / user registered ones};returnbless($self,$class);};subsetTarget {my($class,$target) =@_;$class->{'target'} =$target;};subgetTarget {my($class) =@_;return$class->{'target'};};subsetResponse {my($class,$response) =@_;$class->{'response'} =$response;};subgetResponse {my($class) =@_;return$class->{'response'};};subsetData {my($class,$data) =@_;$class->{'data'} =$data;};subgetData {my($class) =@_;
lib/AMF/Connection/MessageBody.pm view on Meta::CPAN
my($class) =@_;return($class->{'target'} =~ m|onDebug|) ? 1 : 0 ;};1;__END__=head1 NAMEAMF::Connection::MessageBody - Encapsulates a request or response protocol packet/message body.=head1 SYNOPSIS# ...my $request = new AMF::Connection::Message;my $body = new AMF::Connection::MessageBody;$body->setTarget('myService.myOperation);$body->setResponse('/1');$body->setData( { 'param1' => 'value1', 'param2' => 'value2' } );$request->setBody( $body );# ..=head1 DESCRIPTIONThe AMF::Connection::MessageBody class encapsulates a request or response protocol packet/message body.=head1 SEE ALSOAMF::Connection::Message=head1 AUTHORAlberto Attilio Reggiori, <areggiori at cpan dot org>=head1 COPYRIGHT AND LICENSE
lib/AMF/Connection/MessageHeader.pm view on Meta::CPAN
$class->{'required'} = ($required) ? 1 : 0 ;};1;__END__=head1 NAMEAMF::Connection::MessageHeader - Encapsulates a request or response protocol packet/message header.=head1 SYNOPSIS# ...my $header = new AMF::Connection::MessageHeader;$header->setName( 'Foo' );$header->setValue( 'Bar' );$header->setRequired( 1 );# ...
lib/AMF/Connection/MessageHeader.pm view on Meta::CPAN
}else{# 2...};# ..my$header2= new AMF::Connection::MessageHeader($name,$value,0);=head1 DESCRIPTIONThe AMF::Connection::MessageHeader class encapsulates a request or response protocol packet/message header.=head1 SEE ALSOAMF::Connection::Message=head1 AUTHORAlberto Attilio Reggiori, <areggiori at cpan dot org>=head1 COPYRIGHT AND LICENSE
( run in 1.115 second using v1.01-cache-2.11-cpan-3cd7ad12f66 )