# ====================================================================== # # Copyright (C) 2000-2001 Paul Kulchenko (paulclinger@yahoo.com) # SOAP::Lite is free software; you can redistribute it # and/or modify it under the same terms as Perl itself. # # $Id: Lite.pm,v 1.47 2002/04/15 16:17:38 paulk Exp $ # # ====================================================================== package SOAP::Lite; use 5.004; use strict; use vars qw($VERSION); $VERSION = sprintf("%d.%s", map {s/_//g; $_} q$Name: release-0_55-public $ =~ /-(\d+)_([\d_]+)/) or warn "warning: unspecified/non-released version of ", __PACKAGE__, "\n"; # ====================================================================== package SOAP::XMLSchemaSOAP1_1::Deserializer; sub anyTypeValue { 'ur-type' } sub as_boolean { shift; my $value = shift; $value eq '1' || $value eq 'true' ? 1 : $value eq '0' || $value eq 'false' ? 0 : die "Wrong boolean value '$value'\n" } sub as_base64 { shift; require MIME::Base64; MIME::Base64::decode_base64(shift) } sub as_ur_type { $_[1] } BEGIN { no strict 'refs'; for my $method (qw( string float double decimal timeDuration recurringDuration uriReference integer nonPositiveInteger negativeInteger long int short byte nonNegativeInteger unsignedLong unsignedInt unsignedShort unsignedByte positiveInteger timeInstant time timePeriod date month year century recurringDate recurringDay language )) { my $name = 'as_' . $method; *$name = sub { $_[1] } } } # ---------------------------------------------------------------------- package SOAP::XMLSchemaSOAP1_2::Deserializer; sub anyTypeValue { 'anyType' } sub as_boolean; *as_boolean = \&SOAP::XMLSchemaSOAP1_1::Deserializer::as_boolean; sub as_base64 { shift; require MIME::Base64; MIME::Base64::decode_base64(shift) } sub as_anyType { $_[1] } BEGIN { no strict 'refs'; for my $method (qw( string float double decimal dateTime timePeriod gMonth gYearMonth gYear century gMonthDay gDay duration recurringDuration anyURI language integer nonPositiveInteger negativeInteger long int short byte nonNegativeInteger unsignedLong unsignedInt unsignedShort unsignedByte positiveInteger date time dateTime )) { my $name = 'as_' . $method; *$name = sub { $_[1] } } } # ---------------------------------------------------------------------- package SOAP::XMLSchemaApacheSOAP::Deserializer; sub as_map { my $self = shift; +{ map { my $hash = ($self->decode_object($_))[1]; ($hash->{key} => $hash->{value}) } @{$_[3] || []} }; } sub as_Map; *as_Map = \&as_map; # ---------------------------------------------------------------------- package SOAP::XMLSchema::Serializer; use vars qw(@ISA); sub xmlschemaclass { my $self = shift; return $ISA[0] unless @_; @ISA = (shift); return $self; } # ---------------------------------------------------------------------- package SOAP::XMLSchema1999::Serializer; use vars qw(@EXPORT $AUTOLOAD); sub AUTOLOAD { local($1,$2); my($package, $method) = $AUTOLOAD =~ m/(?:(.+)::)([^:]+)$/; return if $method eq 'DESTROY'; no strict 'refs'; die "Type '$method' can't be found in a schema class '$package'\n" unless $method =~ s/^as_// && grep {$_ eq $method} @{"$package\::EXPORT"}; $method =~ s/_/-/; # fix ur-type *$AUTOLOAD = sub { my $self = shift; my($value, $name, $type, $attr) = @_; return [$name, {'xsi:type' => "xsd:$method", %$attr}, $value]; }; goto &$AUTOLOAD; } BEGIN { @EXPORT = qw(ur_type float double decimal timeDuration recurringDuration uriReference integer nonPositiveInteger negativeInteger long int short byte nonNegativeInteger unsignedLong unsignedInt unsignedShort unsignedByte positiveInteger timeInstant time timePeriod date month year century recurringDate recurringDay language base64 hex string boolean ); # predeclare subs, so ->can check will be positive foreach (@EXPORT) { eval "sub as_$_" } } sub nilValue { 'null' } sub anyTypeValue { 'ur-type' } sub as_base64 { my $self = shift; my($value, $name, $type, $attr) = @_; require MIME::Base64; return [$name, {'xsi:type' => SOAP::Utils::qualify($self->encprefix => 'base64'), %$attr}, MIME::Base64::encode_base64($value,'')]; } sub as_hex { my $self = shift; my($value, $name, $type, $attr) = @_; return [$name, {'xsi:type' => 'xsd:hex', %$attr}, join '', map {uc sprintf "%02x", ord} split '', $value]; } sub as_string { my $self = shift; my($value, $name, $type, $attr) = @_; die "String value expected instead of @{[ref $value]} reference\n" if ref $value; return [$name, {'xsi:type' => 'xsd:string', %$attr}, SOAP::Utils::encode_data($value)]; } sub as_undef { $_[1] ? '1' : '0' } sub as_boolean { my $self = shift; my($value, $name, $type, $attr) = @_; return [$name, {'xsi:type' => 'xsd:boolean', %$attr}, $value ? '1' : '0']; } # ---------------------------------------------------------------------- package SOAP::XMLSchema1999::Deserializer; sub anyTypeValue { 'ur-type' } sub as_string; *as_string = \&SOAP::XMLSchemaSOAP1_1::Deserializer::as_string; sub as_boolean; *as_boolean = \&SOAP::XMLSchemaSOAP1_1::Deserializer::as_boolean; sub as_hex { shift; my $value = shift; $value =~ s/([a-zA-Z0-9]{2})/chr oct '0x'.$1/ge; $value } sub as_ur_type { $_[1] } sub as_undef { shift; my $value = shift; $value eq '1' || $value eq 'true' ? 1 : $value eq '0' || $value eq 'false' ? 0 : die "Wrong null/nil value '$value'\n" } BEGIN { no strict 'refs'; for my $method (qw( float double decimal timeDuration recurringDuration uriReference integer nonPositiveInteger negativeInteger long int short byte nonNegativeInteger unsignedLong unsignedInt unsignedShort unsignedByte positiveInteger timeInstant time timePeriod date month year century recurringDate recurringDay language )) { my $name = 'as_' . $method; *$name = sub { $_[1] } } } # ---------------------------------------------------------------------- package SOAP::XMLSchema2001::Serializer; use vars qw(@EXPORT); # no more warnings about "used only once" *AUTOLOAD if 0; *AUTOLOAD = \&SOAP::XMLSchema1999::Serializer::AUTOLOAD; BEGIN { @EXPORT = qw(anyType anySimpleType float double decimal dateTime timePeriod gMonth gYearMonth gYear century gMonthDay gDay duration recurringDuration anyURI language integer nonPositiveInteger negativeInteger long int short byte nonNegativeInteger unsignedLong unsignedInt unsignedShort unsignedByte positiveInteger date time string hex base64 boolean ); # predeclare subs, so ->can check will be positive foreach (@EXPORT) { eval "sub as_$_" } } sub nilValue { 'nil' } sub anyTypeValue { 'anyType' } sub as_hexBinary { my $self = shift; my($value, $name, $type, $attr) = @_; return [$name, {'xsi:type' => 'xsd:hexBinary', %$attr}, join '', map {uc sprintf "%02x", ord} split '', $value]; } sub as_base64Binary { my $self = shift; my($value, $name, $type, $attr) = @_; require MIME::Base64; return [$name, {'xsi:type' => 'xsd:base64Binary', %$attr}, MIME::Base64::encode_base64($value,'')]; } sub as_string; *as_string = \&SOAP::XMLSchema1999::Serializer::as_string; sub as_hex; *as_hex = \&as_hexBinary; sub as_base64; *as_base64 = \&as_base64Binary; sub as_timeInstant; *as_timeInstant = \&as_dateTime; sub as_undef { $_[1] ? 'true' : 'false' } sub as_boolean { my $self = shift; my($value, $name, $type, $attr) = @_; return [$name, {'xsi:type' => 'xsd:boolean', %$attr}, $value ? 'true' : 'false']; } # ---------------------------------------------------------------------- package SOAP::XMLSchema2001::Deserializer; sub anyTypeValue { 'anyType' } sub as_string; *as_string = \&SOAP::XMLSchema1999::Deserializer::as_string; sub as_boolean; *as_boolean = \&SOAP::XMLSchemaSOAP1_2::Deserializer::as_boolean; sub as_base64Binary; *as_base64Binary = \&SOAP::XMLSchemaSOAP1_2::Deserializer::as_base64; sub as_hexBinary; *as_hexBinary = \&SOAP::XMLSchema1999::Deserializer::as_hex; sub as_undef; *as_undef = \&SOAP::XMLSchema1999::Deserializer::as_undef; BEGIN { no strict 'refs'; for my $method (qw( anyType anySimpleType float double decimal dateTime timePeriod gMonth gYearMonth gYear century gMonthDay gDay duration recurringDuration anyURI language integer nonPositiveInteger negativeInteger long int short byte nonNegativeInteger unsignedLong unsignedInt unsignedShort unsignedByte positiveInteger date time dateTime )) { my $name = 'as_' . $method; *$name = sub { $_[1] } } } # ====================================================================== package SOAP::Constants; BEGIN { use vars qw($NSMASK $ELMASK); $NSMASK = '[a-zA-Z_:][\w.\-:]*'; $ELMASK = '^(?![xX][mM][lL])[a-zA-Z_][\w.\-]*$'; use vars qw($NEXT_ACTOR $NS_ENV $NS_ENC $NS_APS $FAULT_CLIENT $FAULT_SERVER $FAULT_VERSION_MISMATCH $HTTP_ON_FAULT_CODE $HTTP_ON_SUCCESS_CODE $FAULT_MUST_UNDERSTAND $NS_XSI_ALL $NS_XSI_NILS %XML_SCHEMAS $DEFAULT_XML_SCHEMA $SOAP_VERSION %SOAP_VERSIONS $WRONG_VERSION $NS_SL_HEADER $NS_SL_PERLTYPE $PREFIX_ENV $PREFIX_ENC $DO_NOT_USE_XML_PARSER $DO_NOT_CHECK_MUSTUNDERSTAND $DO_NOT_USE_CHARSET $DO_NOT_PROCESS_XML_IN_MIME $DO_NOT_USE_LWP_LENGTH_HACK $DO_NOT_CHECK_CONTENT_TYPE $MAX_CONTENT_SIZE ); $FAULT_CLIENT = 'Client'; $FAULT_SERVER = 'Server'; $FAULT_VERSION_MISMATCH = 'VersionMismatch'; $FAULT_MUST_UNDERSTAND = 'MustUnderstand'; $HTTP_ON_SUCCESS_CODE = 200; # OK $HTTP_ON_FAULT_CODE = 500; # INTERNAL_SERVER_ERROR $WRONG_VERSION = 'Wrong SOAP version specified.'; %SOAP_VERSIONS = ( ($SOAP_VERSION = 1.1) => { NEXT_ACTOR => 'http://schemas.xmlsoap.org/soap/actor/next', NS_ENV => 'http://schemas.xmlsoap.org/soap/envelope/', NS_ENC => 'http://schemas.xmlsoap.org/soap/encoding/', DEFAULT_XML_SCHEMA => 'http://www.w3.org/1999/XMLSchema', }, 1.2 => { NEXT_ACTOR => 'http://www.w3.org/2001/06/soap-envelope/actor/next', NS_ENV => 'http://www.w3.org/2001/06/soap-envelope', NS_ENC => 'http://www.w3.org/2001/06/soap-encoding', DEFAULT_XML_SCHEMA => 'http://www.w3.org/2001/XMLSchema', }, ); # schema namespaces %XML_SCHEMAS = ( 'http://www.w3.org/1999/XMLSchema' => 'SOAP::XMLSchema1999', 'http://www.w3.org/2001/XMLSchema' => 'SOAP::XMLSchema2001', 'http://schemas.xmlsoap.org/soap/encoding/' => 'SOAP::XMLSchemaSOAP1_1', 'http://www.w3.org/2001/06/soap-encoding' => 'SOAP::XMLSchemaSOAP1_2', ); $NS_XSI_ALL = join join('|', map {"$_-instance"} grep {/XMLSchema/} keys %XML_SCHEMAS), '(?:', ')'; $NS_XSI_NILS = join join('|', map { my $class = $XML_SCHEMAS{$_} . '::Serializer'; "\{($_)-instance\}" . $class->nilValue } grep {/XMLSchema/} keys %XML_SCHEMAS), '(?:', ')'; # ApacheSOAP namespaces $NS_APS = 'http://xml.apache.org/xml-soap'; # SOAP::Lite namespace $NS_SL_HEADER = 'http://namespaces.soaplite.com/header'; $NS_SL_PERLTYPE = 'http://namespaces.soaplite.com/perl'; # default prefixes $PREFIX_ENV = 'SOAP-ENV'; $PREFIX_ENC = 'SOAP-ENC'; # others $DO_NOT_USE_XML_PARSER = 0; $DO_NOT_CHECK_MUSTUNDERSTAND = 0; $DO_NOT_USE_CHARSET = 0; $DO_NOT_PROCESS_XML_IN_MIME = 0; $DO_NOT_USE_LWP_LENGTH_HACK = 0; $DO_NOT_CHECK_CONTENT_TYPE = 0; } # ====================================================================== package SOAP::Utils; sub qualify { $_[1] ? $_[1] =~ /:/ ? $_[1] : join(':', $_[0] || (), $_[1]) : defined $_[1] ? $_[0] : '' } sub overqualify (&$) { for ($_[1]) { &{$_[0]}; s/^:|:$//g } } sub disqualify { (my $qname = shift) =~ s/^($SOAP::Constants::NSMASK?)://; $qname; } sub splitqname { local($1,$2); $_[0] =~ /^(?:([^:]+):)?(.+)$/; return ($1,$2) } sub longname { defined $_[0] ? sprintf('{%s}%s', $_[0], $_[1]) : $_[1] } sub splitlongname { local($1,$2); $_[0] =~ /^(?:\{(.*)\})?(.+)$/; return ($1,$2) } # Q: why only '&' and '<' are encoded, but not '>'? # A: because it is not required according to XML spec. # # [http://www.w3.org/TR/REC-xml#syntax] # The ampersand character (&) and the left angle bracket (<) may appear in # their literal form only when used as markup delimiters, or within a comment, # a processing instruction, or a CDATA section. If they are needed elsewhere, # they must be escaped using either numeric character references or the # strings "&" and "<" respectively. The right angle bracket (>) may be # represented using the string ">", and must, for compatibility, be # escaped using ">" or a character reference when it appears in the # string "]]>" in content, when that string is not marking the end of a # CDATA section. my %encode_attribute = ('&' => '&', '<' => '<', '"' => '"'); sub encode_attribute { (my $e = $_[0]) =~ s/([&<"])/$encode_attribute{$1}/g; $e } my %encode_data = ('&' => '&', '<' => '<', "\xd" => ' '); sub encode_data { (my $e = $_[0]) =~ s/([&<\015])/$encode_data{$1}/g; $e =~ s/\]\]>/\]\]>/g; $e } # methods for internal tree (SOAP::Deserializer, SOAP::SOM and SOAP::Serializer) sub o_qname { $_[0]->[0] } sub o_attr { $_[0]->[1] } sub o_child { ref $_[0]->[2] ? $_[0]->[2] : undef } sub o_chars { ref $_[0]->[2] ? undef : $_[0]->[2] } # $_[0]->[3] is not used. Serializer stores object ID there sub o_value { $_[0]->[4] } sub o_lname { $_[0]->[5] } sub o_lattr { $_[0]->[6] } # make bytelength that calculates length in bytes regardless of utf/byte settings # either we can do 'use bytes' or length will count bytes already BEGIN { sub bytelength; eval ( eval('use bytes; 1') # 5.6.0 and later? ? 'sub bytelength { use bytes; length(@_ ? $_[0] : $_) }; 1' : 'sub bytelength { length(@_ ? $_[0] : $_) }; 1' ) or die; } # ====================================================================== package SOAP::Cloneable; sub clone { my $self = shift; return unless ref $self && UNIVERSAL::isa($self => __PACKAGE__); my $clone = bless {} => ref($self) || $self; foreach (keys %$self) { my $value = $self->{$_}; $clone->{$_} = ref $value && UNIVERSAL::isa($value => __PACKAGE__) ? $value->clone : $value; } $clone; } # ====================================================================== package SOAP::Transport; use vars qw($AUTOLOAD @ISA); @ISA = qw(SOAP::Cloneable); sub DESTROY { SOAP::Trace::objects('()') } sub new { my $self = shift; my $class = ref($self) || $self; return $self if ref $self; SOAP::Trace::objects('()'); return bless {} => $class; } sub proxy { my $self = shift->new; my $class = ref $self; return $self->{_proxy} unless @_; $_[0] =~ /^(\w+):/ or die "proxy: transport protocol not specified\n"; my $protocol = uc "$1"; # untainted now # https: should be done through Transport::HTTP.pm for ($protocol) { s/^HTTPS$/HTTP/ } (my $protocol_class = "${class}::$protocol") =~ s/-/_/g; no strict 'refs'; unless (defined %{"$protocol_class\::Client::"} && UNIVERSAL::can("$protocol_class\::Client" => 'new')) { eval "require $protocol_class"; die "Unsupported protocol '$protocol'\n" if $@ =~ m!^Can't locate SOAP/Transport/!; die if $@; } $protocol_class .= "::Client"; return $self->{_proxy} = $protocol_class->new(endpoint => shift, @_); } sub AUTOLOAD { my $method = substr($AUTOLOAD, rindex($AUTOLOAD, '::') + 2); return if $method eq 'DESTROY'; no strict 'refs'; *$AUTOLOAD = sub { shift->proxy->$method(@_) }; goto &$AUTOLOAD; } # ====================================================================== package SOAP::Fault; use Carp (); use overload fallback => 1, '""' => "stringify"; sub DESTROY { SOAP::Trace::objects('()') } sub new { my $self = shift; unless (ref $self) { my $class = ref($self) || $self; $self = bless {} => $class; SOAP::Trace::objects('()'); } Carp::carp "Odd (wrong?) number of parameters in new()" if $^W && (@_ & 1); while (@_) { my $method = shift; $self->$method(shift) if $self->can($method) } return $self; } sub stringify { my $self = shift; return join ': ', $self->faultcode, $self->faultstring; } sub BEGIN { no strict 'refs'; for my $method (qw(faultcode faultstring faultactor faultdetail)) { my $field = '_' . $method; *$method = sub { my $self = UNIVERSAL::isa($_[0] => __PACKAGE__) ? shift->new : __PACKAGE__->new; if (@_) { $self->{$field} = shift; return $self } return $self->{$field}; } } *detail = \&faultdetail; } # ====================================================================== package SOAP::Data; use vars qw(@ISA @EXPORT_OK); use Exporter; use Carp (); @ISA = qw(Exporter); @EXPORT_OK = qw(name type attr value uri); sub DESTROY { SOAP::Trace::objects('()') } sub new { my $self = shift; unless (ref $self) { my $class = ref($self) || $self; $self = bless {_attr => {}, _value => [], _signature => []} => $class; SOAP::Trace::objects('()'); } Carp::carp "Odd (wrong?) number of parameters in new()" if $^W && (@_ & 1); while (@_) { my $method = shift; $self->$method(shift) if $self->can($method) } return $self; } sub name { my $self = UNIVERSAL::isa($_[0] => __PACKAGE__) ? shift->new : __PACKAGE__->new; if (@_) { my($name, $uri, $prefix) = shift; if ($name) { ($uri, $name) = SOAP::Utils::splitlongname($name); unless (defined $uri) { ($prefix, $name) = SOAP::Utils::splitqname($name); $self->prefix($prefix) if defined $prefix; } else { $self->uri($uri); } } $self->{_name} = $name; $self->value(@_) if @_; return $self; } return $self->{_name}; } sub attr { my $self = UNIVERSAL::isa($_[0] => __PACKAGE__) ? shift->new : __PACKAGE__->new; if (@_) { $self->{_attr} = shift; $self->value(@_) if @_; return $self } return $self->{_attr}; } sub type { my $self = UNIVERSAL::isa($_[0] => __PACKAGE__) ? shift->new : __PACKAGE__->new; if (@_) { $self->{_type} = shift; $self->value(@_) if @_; return $self; } if (!defined $self->{_type} && (my @types = grep {/^\{$SOAP::Constants::NS_XSI_ALL}type$/o} keys %{$self->{_attr}})) { $self->{_type} = (SOAP::Utils::splitlongname(delete $self->{_attr}->{shift(@types)}))[1]; } return $self->{_type}; } BEGIN { no strict 'refs'; for my $method (qw(root mustUnderstand)) { my $field = '_' . $method; *$method = sub { my $attr = $method eq 'root' ? "{$SOAP::Constants::NS_ENC}$method" : "{$SOAP::Constants::NS_ENV}$method"; my $self = UNIVERSAL::isa($_[0] => __PACKAGE__) ? shift->new : __PACKAGE__->new; if (@_) { $self->{_attr}->{$attr} = $self->{$field} = shift() ? 1 : 0; $self->value(@_) if @_; return $self; } $self->{$field} = SOAP::XMLSchemaSOAP1_2::Deserializer->as_boolean($self->{_attr}->{$attr}) if !defined $self->{$field} && defined $self->{_attr}->{$attr}; return $self->{$field}; } } for my $method (qw(actor encodingStyle)) { my $field = '_' . $method; *$method = sub { my $attr = "{$SOAP::Constants::NS_ENV}$method"; my $self = UNIVERSAL::isa($_[0] => __PACKAGE__) ? shift->new : __PACKAGE__->new; if (@_) { $self->{_attr}->{$attr} = $self->{$field} = shift; $self->value(@_) if @_; return $self; } $self->{$field} = $self->{_attr}->{$attr} if !defined $self->{$field} && defined $self->{_attr}->{$attr}; return $self->{$field}; } } } sub prefix { my $self = UNIVERSAL::isa($_[0] => __PACKAGE__) ? shift->new : __PACKAGE__->new; return $self->{_prefix} unless @_; $self->{_prefix} = shift; $self->value(@_) if @_; return $self; } sub uri { my $self = UNIVERSAL::isa($_[0] => __PACKAGE__) ? shift->new : __PACKAGE__->new; return $self->{_uri} unless @_; my $uri = $self->{_uri} = shift; warn "Usage of '::' in URI ($uri) deprecated. Use '/' instead\n" if defined $uri && $^W && $uri =~ /::/; $self->value(@_) if @_; return $self; } sub set_value { my $self = UNIVERSAL::isa($_[0] => __PACKAGE__) ? shift->new : __PACKAGE__->new; $self->{_value} = [@_]; return $self; } sub value { my $self = UNIVERSAL::isa($_[0] => __PACKAGE__) ? shift->new : __PACKAGE__->new; @_ ? ($self->set_value(@_), return $self) : wantarray ? return @{$self->{_value}} : return $self->{_value}->[0]; } sub signature { my $self = UNIVERSAL::isa($_[0] => __PACKAGE__) ? shift->new : __PACKAGE__->new; @_ ? ($self->{_signature} = shift, return $self) : (return $self->{_signature}); } # ====================================================================== package SOAP::Header; use vars qw(@ISA); @ISA = qw(SOAP::Data); # ====================================================================== package SOAP::Serializer; use Carp (); use vars qw(@ISA); @ISA = qw(SOAP::Cloneable SOAP::XMLSchema::Serializer); BEGIN { # namespaces and anonymous data structures my $ns = 0; my $name = 0; my $prefix = 'c-'; sub gen_ns { 'namesp' . ++$ns } sub gen_name { join '', $prefix, 'gensym', ++$name } sub prefix { $prefix =~ s/^[^\-]+-/$_[1]-/; $_[0]; } } sub DESTROY { SOAP::Trace::objects('()') } sub new { my $self = shift; unless (ref $self) { my $class = ref($self) || $self; $self = bless { _level => 0, _autotype => 1, _readable => 0, _multirefinplace => 0, _seen => {}, _typelookup => { base64 => [10, sub {$_[0] =~ /[^\x09\x0a\x0d\x20-\x7f]/}, 'as_base64'], 'int' => [20, sub {$_[0] =~ /^[+-]?\d+$/}, 'as_int'], float => [30, sub {$_[0] =~ /^(-?(?:\d+(?:\.\d*)?|\.\d+|NaN|INF)|([+-]?)(?=\d|\.\d)\d*(\.\d*)?([Ee]([+-]?\d+))?)$/}, 'as_float'], string => [40, sub {1}, 'as_string'], }, _encoding => 'UTF-8', _objectstack => {}, _signature => [], _maptype => {SOAPStruct => $SOAP::Constants::NS_APS}, _on_nonserialized => sub {Carp::carp "Cannot marshall @{[ref shift]} reference" if $^W; return}, _attr => { "{$SOAP::Constants::NS_ENV}encodingStyle" => $SOAP::Constants::NS_ENC, }, _namespaces => { $SOAP::Constants::NS_ENC => $SOAP::Constants::PREFIX_ENC, $SOAP::Constants::PREFIX_ENV ? ($SOAP::Constants::NS_ENV => $SOAP::Constants::PREFIX_ENV) : (), }, _soapversion => SOAP::Lite->soapversion, } => $class; $self->xmlschema($SOAP::Constants::DEFAULT_XML_SCHEMA); SOAP::Trace::objects('()'); } Carp::carp "Odd (wrong?) number of parameters in new()" if $^W && (@_ & 1); while (@_) { my $method = shift; $self->$method(shift) if $self->can($method) } return $self; } sub soapversion { my $self = shift; return $self->{_soapversion} unless @_; return $self if $self->{_soapversion} eq SOAP::Lite->soapversion; $self->{_soapversion} = shift; $self->attr({ "{$SOAP::Constants::NS_ENV}encodingStyle" => $SOAP::Constants::NS_ENC, }); $self->namespaces({ $SOAP::Constants::NS_ENC => $SOAP::Constants::PREFIX_ENC, $SOAP::Constants::PREFIX_ENV ? ($SOAP::Constants::NS_ENV => $SOAP::Constants::PREFIX_ENV) : (), }); $self->xmlschema($SOAP::Constants::DEFAULT_XML_SCHEMA); $self; } sub xmlschema { my $self = shift->new; return $self->{_xmlschema} unless @_; my @schema; if ($_[0]) { @schema = grep {/XMLSchema/ && /$_[0]/} keys %SOAP::Constants::XML_SCHEMAS; Carp::croak "More than one schema match parameter '$_[0]': @{[join ', ', @schema]}" if @schema > 1; Carp::croak "No schema match parameter '$_[0]'" if @schema != 1; } # do nothing if current schema is the same as new return $self if $self->{_xmlschema} && $self->{_xmlschema} eq $schema[0]; my $ns = $self->namespaces; # delete current schema from namespaces if (my $schema = $self->{_xmlschema}) { delete $ns->{$schema}; delete $ns->{"$schema-instance"}; } # add new schema into namespaces if (my $schema = $self->{_xmlschema} = shift @schema) { $ns->{$schema} = 'xsd'; $ns->{"$schema-instance"} = 'xsi'; } # and here is the class serializer should work with my $class = exists $SOAP::Constants::XML_SCHEMAS{$self->{_xmlschema}} ? $SOAP::Constants::XML_SCHEMAS{$self->{_xmlschema}} . '::Serializer' : $self; $self->xmlschemaclass($class); return $self; } sub namespace { Carp::carp "'SOAP::Serializer->namespace' method is deprecated. Instead use '->envprefix'" if $^W; shift->envprefix(@_); } sub encodingspace { Carp::carp "'SOAP::Serializer->encodingspace' method is deprecated. Instead use '->encprefix'" if $^W; shift->encprefix(@_); } sub envprefix { my $self = shift->new; return $self->namespaces->{$SOAP::Constants::NS_ENV} unless @_; $self->namespaces->{$SOAP::Constants::NS_ENV} = shift; return $self; } sub encprefix { my $self = shift->new; return $self->namespaces->{$SOAP::Constants::NS_ENC} unless @_; $self->namespaces->{$SOAP::Constants::NS_ENC} = shift; return $self; } sub BEGIN { no strict 'refs'; for my $method (qw(readable level seen autotype typelookup uri attr maptype namespaces multirefinplace encoding signature on_nonserialized)) { my $field = '_' . $method; *$method = sub { my $self = shift->new; @_ ? ($self->{$field} = shift, return $self) : return $self->{$field}; } } for my $method (qw(method fault freeform)) { # aliases for envelope *$method = sub { shift->envelope($method => @_) } } for my $method (qw(qualify overqualify disqualify)) { # import from SOAP::Utils *$method = \&{'SOAP::Utils::'.$method}; } } sub gen_id { sprintf "%U", $_[1] } sub multiref_object { my $self = shift; my $object = shift; my $id = $self->gen_id($object); my $seen = $self->seen; $seen->{$id}->{count}++; $seen->{$id}->{multiref} ||= $seen->{$id}->{count} > 1; $seen->{$id}->{value} = $object; $seen->{$id}->{recursive} ||= 0; return $id; } sub recursive_object { my $self = shift; $self->seen->{$self->gen_id(shift)}->{recursive} = 1; } sub is_href { my $self = shift; my $seen = $self->seen->{shift || return} or return; return 1 if $seen->{id}; return $seen->{multiref} && !($seen->{id} = (shift || $seen->{recursive} || $seen->{multiref} && $self->multirefinplace)); } sub multiref_anchor { my $seen = shift->seen->{my $id = shift || return undef}; return $seen->{multiref} ? "ref-$id" : undef; } sub encode_multirefs { my $self = shift; return if $self->multirefinplace; my $seen = $self->seen; map { $_->[1]->{_id} = 1; $_ } map { $self->encode_object($seen->{$_}->{value}) } grep { $seen->{$_}->{multiref} && !$seen->{$_}->{recursive} } keys %$seen; } # ---------------------------------------------------------------------- sub maptypetouri { my($self, $type, $simple) = @_; return $type unless defined $type; my($prefix, $name) = SOAP::Utils::splitqname($type); unless (defined $prefix) { $name =~ s/__|\./::/g; $self->maptype->{$name} = $simple ? die "Schema/namespace for type '$type' is not specified\n" : $SOAP::Constants::NS_SL_PERLTYPE unless exists $self->maptype->{$name}; $type = $self->maptype->{$name} ? qualify($self->namespaces->{$self->maptype->{$name}} ||= gen_ns, $type) : undef; } return $type; } sub encode_object { my($self, $object, $name, $type, $attr) = @_; $attr ||= {}; return $self->encode_scalar($object, $name, $type, $attr) unless ref $object; my $id = $self->multiref_object($object); use vars '%objectstack'; # we'll play with symbol table local %objectstack = %objectstack; # want to see objects ONLY in the current tree # did we see this object in current tree? Seems to be recursive refs $self->recursive_object($object) if ++$objectstack{$id} > 1; # return if we already saw it twice. It should be already properly serialized return if $objectstack{$id} > 2; if (UNIVERSAL::isa($object => 'SOAP::Data')) { # use $object->SOAP::Data:: to enable overriding name() and others in inherited classes $object->SOAP::Data::name($name) unless defined $object->SOAP::Data::name; # apply ->uri() and ->prefix() which can modify name and attributes of # element, but do not modify SOAP::Data itself my($name, $attr) = $self->fixattrs($object); $attr = $self->attrstoqname($attr); my @realvalues = $object->SOAP::Data::value; return [$name || gen_name, $attr] unless @realvalues; my $method = "as_" . ($object->SOAP::Data::type || '-'); # dummy type if not defined # try to call method specified for this type my @values = map { # store null/nil attribute if value is undef local $attr->{qualify(xsi => $self->xmlschemaclass->nilValue)} = $self->xmlschemaclass->as_undef(1) unless defined; $self->can($method) && $self->$method($_, $name || gen_name, $object->SOAP::Data::type, $attr) || $self->typecast($_, $name || gen_name, $object->SOAP::Data::type, $attr) || $self->encode_object($_, $name, $object->SOAP::Data::type, $attr) } @realvalues; $object->SOAP::Data::signature([map {join $;, $_->[0], disqualify($_->[1]->{'xsi:type'} || '')} @values]) if @values; return wantarray ? @values : $values[0]; } my $class = ref $object; if ($class !~ /^(?:SCALAR|ARRAY|HASH|REF)$/o) { # we could also check for CODE|GLOB|LVALUE, but we cannot serialize # them anyway, so they'll be cought by check below $class =~ s/::/__/g; $name = $class if !defined $name; $type = $class if !defined $type && $self->autotype; my $method = 'as_' . $class; if ($self->can($method)) { my $encoded = $self->$method($object, $name, $type, $attr); return $encoded if ref $encoded; # return only if handled, otherwise handle with default handlers } } return UNIVERSAL::isa($object => 'REF') || UNIVERSAL::isa($object => 'SCALAR') ? $self->encode_scalar($object, $name, $type, $attr) : UNIVERSAL::isa($object => 'ARRAY') ? $self->encode_array($object, $name, $type, $attr) : UNIVERSAL::isa($object => 'HASH') ? $self->encode_hash($object, $name, $type, $attr) : $self->on_nonserialized->($object); } sub encode_scalar { my($self, $value, $name, $type, $attr) = @_; $name ||= gen_name; my $schemaclass = $self->xmlschemaclass; # null reference return [$name, {%$attr, qualify(xsi => $schemaclass->nilValue) => $schemaclass->as_undef(1)}] unless defined $value; # object reference return [$name, {'xsi:type' => $self->maptypetouri($type), %$attr}, [$self->encode_object($$value)], $self->gen_id($value)] if ref $value; # autodefined type if ($self->autotype) { my $lookup = $self->typelookup; for (sort {$lookup->{$a}->[0] <=> $lookup->{$b}->[0]} keys %$lookup) { my $method = $lookup->{$_}->[2]; return $self->can($method) && $self->$method($value, $name, $type, $attr) || $method->($value, $name, $type, $attr) if $lookup->{$_}->[1]->($value); } } # invariant return [$name, $attr, $value]; } sub encode_array { my($self, $array, $name, $type, $attr) = @_; my $items = 'item'; # TD: add support for multidimensional, partially transmitted and sparse arrays my @items = map {$self->encode_object($_, $items)} @$array; my $num = @items; my($arraytype, %types) = '-'; for (@items) { $arraytype = $_->[1]->{'xsi:type'} || '-'; $types{$arraytype}++ } $arraytype = sprintf "%s\[$num]", keys %types > 1 || $arraytype eq '-' ? qualify(xsd => $self->xmlschemaclass->anyTypeValue) : $arraytype; $type = qualify($self->encprefix => 'Array') if $self->autotype && !defined $type; return [$name || qualify($self->encprefix => 'Array'), {qualify($self->encprefix => 'arrayType') => $arraytype, 'xsi:type' => $self->maptypetouri($type), %$attr}, [@items], $self->gen_id($array) ]; } sub encode_hash { my($self, $hash, $name, $type, $attr) = @_; if ($self->autotype && grep {!/$SOAP::Constants::ELMASK/o} keys %$hash) { warn qq!Cannot encode @{[$name ? "'$name'" : 'unnamed']} element as 'hash'. Will be encoded as 'map' instead\n! if $^W; return $self->as_map($hash, $name || gen_name, $type, $attr); } $type = 'SOAPStruct' if $self->autotype && !defined($type) && exists $self->maptype->{SOAPStruct}; return [$name || gen_name, {'xsi:type' => $self->maptypetouri($type), %$attr}, [map {$self->encode_object($hash->{$_}, $_)} keys %$hash], $self->gen_id($hash) ]; } # ---------------------------------------------------------------------- sub as_ordered_hash { my $self = shift; my($value, $name, $type, $attr) = @_; die "Not an ARRAY reference for 'ordered_hash' type" unless UNIVERSAL::isa($value => 'ARRAY'); return [$name, $attr, [map{$self->encode_object(@{$value}[2*$_+1,2*$_])} 0..$#$value/2], $self->gen_id($value) ]; } sub as_map { my $self = shift; my($value, $name, $type, $attr) = @_; die "Not a HASH reference for 'map' type" unless UNIVERSAL::isa($value => 'HASH'); my $prefix = ($self->namespaces->{$SOAP::Constants::NS_APS} ||= 'apachens'); my @items = map {$self->encode_object(SOAP::Data->type(ordered_hash => [key => $_, value => $value->{$_}]), 'item', '')} keys %$value; return [$name, {'xsi:type' => "$prefix:Map", %$attr}, [@items], $self->gen_id($value)]; } sub as_xml { my $self = shift; my($value, $name, $type, $attr) = @_; return [$name, {'_xml' => 1}, $value]; } sub typecast { my $self = shift; my($value, $name, $type, $attr) = @_; return if ref $value; # skip complex object, caller knows how to deal with it return if $self->autotype && !defined $type; # we don't know, autotype knows return [$name, {(defined $type && $type gt '' ? ('xsi:type' => $self->maptypetouri($type, 'simple type')) : ()), %$attr}, $value ]; } # ---------------------------------------------------------------------- sub fixattrs { my $self = shift; my $data = shift; my($name, $attr) = ($data->SOAP::Data::name, {%{$data->SOAP::Data::attr}}); my($xmlns, $prefix) = ($data->uri, $data->prefix); return ($name, $attr) unless defined($xmlns) || defined($prefix); $name ||= gen_name; # local name $prefix = gen_ns if !defined $prefix && $xmlns gt ''; $prefix = '' if defined $xmlns && $xmlns eq '' || defined $prefix && $prefix eq ''; $attr->{join ':', xmlns => $prefix || ()} = $xmlns if defined $xmlns; $name = join ':', $prefix, $name if $prefix; return ($name, $attr); } sub toqname { my $self = shift; my $long = shift; return $long unless $long =~ /^\{(.*)\}(.+)$/; return qualify $self->namespaces->{$1} ||= gen_ns, $2; } sub attrstoqname { my $self = shift; my $attrs = shift; return { map { /^\{(.*)\}(.+)$/ ? ($self->toqname($_) => $2 eq 'type' || $2 eq 'arrayType' ? $self->toqname($attrs->{$_}) : $attrs->{$_}) : ($_ => $attrs->{$_}) } keys %$attrs }; } sub tag { my $self = shift; my($tag, $attrs, @values) = @_; my $value = join '', @values; my $level = $self->level; my $indent = $self->readable ? "\n" . ' ' x (($level-1)*2) : ''; # check for special attribute return "$indent$value" if exists $attrs->{_xml} && delete $attrs->{_xml}; die "Element '$tag' can't be allowed in valid XML message. Died\n" if $tag !~ /^(?![xX][mM][lL])$SOAP::Constants::NSMASK$/o; my $prolog = ''; if ($level == 1) { my $namespaces = $self->namespaces; foreach (keys %$namespaces) { $attrs->{qualify(xmlns => $namespaces->{$_})} = $_ } $prolog = qq!encoding]}"?>! if defined $self->encoding; } my $tagattrs = join(' ', '', map { sprintf '%s="%s"', $_, SOAP::Utils::encode_attribute($attrs->{$_}) } grep { $_ && defined $attrs->{$_} && ($_ ne 'xsi:type' || $attrs->{$_} ne '') } keys %$attrs); $value gt '' ? sprintf("$prolog$indent<%s%s$indent>%s", $tag, $tagattrs, $value, $tag) : sprintf("$prolog$indent<%s%s/>", $tag, $tagattrs); } sub xmlize { my $self = shift; my($name, $attrs, $values, $id) = @{+shift}; $attrs ||= {}; local $self->{_level} = $self->{_level} + 1; return $self->tag($name, $attrs) unless defined $values; return $self->tag($name, $attrs, $values) unless UNIVERSAL::isa($values => 'ARRAY'); return $self->tag($name, {%$attrs, href => '#' . $self->multiref_anchor($id)}) if $self->is_href($id, delete($attrs->{_id})); return $self->tag($name, {%$attrs, id => $self->multiref_anchor($id)}, map {$self->xmlize($_)} @$values); } sub uriformethod { my $self = shift; my $method_is_data = ref $_[0] && UNIVERSAL::isa($_[0] => 'SOAP::Data'); # drop prefrix from method that could be string or SOAP::Data object my($prefix, $method) = $method_is_data ? ($_[0]->prefix, $_[0]->name) : SOAP::Utils::splitqname($_[0]); my $attr = {reverse %{$self->namespaces}}; # try to define namespace that could be stored as # a) method is SOAP::Data # ? attribute in method's element as xmlns= or xmlns:${prefix}= # : uri # b) attribute in Envelope element as xmlns= or xmlns:${prefix}= # c) no prefix or prefix equal serializer->envprefix # ? '', but see coment below # : die with error message my $uri = $method_is_data ? ref $_[0]->attr && ($_[0]->attr->{$prefix ? "xmlns:$prefix" : 'xmlns'} || $_[0]->uri) : $self->uri; defined $uri or $uri = $attr->{$prefix || ''}; defined $uri or $uri = !$prefix || $prefix eq $self->envprefix # still in doubts what should namespace be in this case # but will keep it like this for now and be compatible with our server ? ( $method_is_data && $^W && warn("URI is not provided as an attribute for method ($method)\n"), '' ) : die "Can't find namespace for method ($prefix:$method)\n"; return ($uri, $method); } sub serialize { SOAP::Trace::trace('()'); my $self = shift->new; @_ == 1 or Carp::croak "serialize() method accepts one parameter"; $self->seen({}); # reinitialize multiref table my($encoded) = $self->encode_object($_[0]); # now encode multirefs if any # v -------------- subelements of Envelope push(@{$encoded->[2]}, $self->encode_multirefs) if ref $encoded->[2]; return $self->xmlize($encoded); } sub envelope { SOAP::Trace::trace('()'); my $self = shift->new; my $type = shift; my(@parameters, @header); for (@_) { defined $_ && ref $_ && UNIVERSAL::isa($_ => 'SOAP::Header') ? push(@header, $_) : push(@parameters, $_); } my $header = @header ? SOAP::Data->set_value(@header) : undef; my($body,$parameters); if ($type eq 'method' || $type eq 'response') { SOAP::Trace::method(@parameters); my $method = shift(@parameters) or die "Unspecified method for SOAP call\n"; $parameters = @parameters ? SOAP::Data->set_value(@parameters) : undef; $body = UNIVERSAL::isa($method => 'SOAP::Data') ? $method : SOAP::Data->name($method)->uri($self->uri); $body->set_value($parameters ? \$parameters : ()); } elsif ($type eq 'fault') { SOAP::Trace::fault(@parameters); $body = SOAP::Data -> name(qualify($self->envprefix => 'Fault')) # commented on 2001/03/28 because of failing in ApacheSOAP # need to find out more about it # -> attr({'xmlns' => ''}) -> value(\SOAP::Data->set_value( SOAP::Data->name(faultcode => qualify($self->envprefix => $parameters[0])), SOAP::Data->name(faultstring => $parameters[1]), defined($parameters[2]) ? SOAP::Data->name(detail => do{my $detail = $parameters[2]; ref $detail ? \$detail : $detail}) : (), defined($parameters[3]) ? SOAP::Data->name(faultactor => $parameters[3]) : (), )); } elsif ($type eq 'freeform') { SOAP::Trace::freeform(@parameters); $body = SOAP::Data->set_value(@parameters); } else { die "Wrong type of envelope ($type) for SOAP call\n"; } $self->seen({}); # reinitialize multiref table my($encoded) = $self->encode_object( SOAP::Data->name(qualify($self->envprefix => 'Envelope') => \SOAP::Data->value( ($header ? SOAP::Data->name(qualify($self->envprefix => 'Header') => \$header) : ()), SOAP::Data->name(qualify($self->envprefix => 'Body') => \$body) ))->attr($self->attr) ); $self->signature($parameters->signature) if ref $parameters; # IMHO multirefs should be encoded after Body, but only some # toolkits understand this encoding, so we'll keep them for now (04/15/2001) # as the last element inside the Body # v -------------- subelements of Envelope # vv -------- last of them (Body) # v --- subelements push(@{$encoded->[2]->[-1]->[2]}, $self->encode_multirefs) if ref $encoded->[2]->[-1]->[2]; return $self->xmlize($encoded); } # ====================================================================== package SOAP::Parser; sub DESTROY { SOAP::Trace::objects('()') } sub xmlparser { my $self = shift; return eval { $SOAP::Constants::DO_NOT_USE_XML_PARSER ? undef : do {require XML::Parser; XML::Parser->new} } || eval { require XML::Parser::Lite; XML::Parser::Lite->new } || die "XML::Parser is not @{[$SOAP::Constants::DO_NOT_USE_XML_PARSER ? 'used' : 'available']} and ", $@; } sub parser { my $self = shift->new; @_ ? ($self->{'_parser'} = shift, return $self) : return ($self->{'_parser'} ||= $self->xmlparser); } sub new { my $self = shift; my $class = ref($self) || $self; return $self if ref $self; SOAP::Trace::objects('()'); return bless {_parser => shift} => $class; } sub decode { SOAP::Trace::trace('()'); my $self = shift; $self->parser->setHandlers( Final => sub { shift; $self->final(@_) }, Start => sub { shift; $self->start(@_) }, End => sub { shift; $self->end(@_) }, Char => sub { shift; $self->char(@_) }, ); $self->parser->parse($_[0]); } sub final { my $self = shift; # clean handlers, otherwise SOAP::Parser won't be deleted: # it refers to XML::Parser which refers to subs from SOAP::Parser # Thanks to Ryan Adams # and Craig Johnston # checked by number of tests in t/02-payload.t undef $self->{_values}; $self->parser->setHandlers( Final => undef, Start => undef, End => undef, Char => undef, ); $self->{_done}; } sub start { push @{shift->{_values}}, [shift, {@_}] } # string concatenation changed to arrays which should improve performance # for strings with many entity-encoded elements. # Thanks to Mathieu Longtin sub char { push @{shift->{_values}->[-1]->[3]}, shift } sub end { my $self = shift; my $done = pop @{$self->{_values}}; $done->[2] = defined $done->[3] ? join('',@{$done->[3]}) : '' unless ref $done->[2]; undef $done->[3]; @{$self->{_values}} ? (push @{$self->{_values}->[-1]->[2]}, $done) : ($self->{_done} = $done); } # ====================================================================== package SOAP::MIMEParser; use vars qw(@ISA); @ISA = qw(MIME::Parser); sub DESTROY { SOAP::Trace::objects('()') } sub new { local $^W; require MIME::Parser; Exporter::require_version('MIME::Parser' => 5.220); my $self = shift; unless (ref $self) { my $class = ref($self) || $self; $self = $class->SUPER::new(); unshift(@_, output_to_core => 'ALL', tmp_to_core => 1, ignore_errors => 1); SOAP::Trace::objects('()'); } while (@_) { my $method = shift; $self->$method(shift) if $self->can($method) } return $self; } sub get_multipart_id { (shift || '') =~ /^<(.+)>$/; $1 || '' } sub decode { my $self = shift; my $entity = eval { $self->parse_data(shift) } or die "Something wrong with MIME message: @{[$@ || $self->last_error]}\n"; my @result = $entity->head->mime_type eq 'multipart/form-data' ? $self->decode_form_data($entity) : $entity->head->mime_type eq 'multipart/related' ? $self->decode_related($entity) : $entity->head->mime_type eq 'text/xml' ? () : die "Can't handle MIME messsage with specified type (@{[$entity->head->mime_type]})\n"; @result ? @result : $entity->bodyhandle->as_string ? [undef, '', undef, $entity->bodyhandle->as_string] : die "No content in MIME message\n"; } sub decode_form_data { my($self, $entity) = @_; my @result; foreach my $part ($entity->parts) { my $name = $part->head->mime_attr('content-disposition.name'); my $type = $part->head->mime_type || ''; $name eq 'payload' ? unshift(@result, [$name, '', $type, $part->bodyhandle->as_string]) : push(@result, [$name, '', $type, $part->bodyhandle->as_string]); } @result; } sub decode_related { my($self, $entity) = @_; my $start = get_multipart_id($entity->head->mime_attr('content-type.start')); my $location = $entity->head->mime_attr('content-location') || 'thismessage:/'; my @result; foreach my $part ($entity->parts) { my $pid = get_multipart_id($part->head->get('content-id',0)); my $plocation = $part->head->get('content-location',0) || ''; my $type = $part->head->mime_type || ''; $start && $pid eq $start ? unshift(@result, [$start, $location, $type, $part->bodyhandle->as_string]) : push(@result, [$pid, $plocation, $type, $part->bodyhandle->as_string]); } die "Can't find 'start' parameter in multipart MIME message\n" if @result > 1 && !$start; @result; } # ====================================================================== package SOAP::SOM; use Carp (); sub BEGIN { no strict 'refs'; my %path = ( root => '/', envelope => '/Envelope', body => '/Envelope/Body', header => '/Envelope/Header', headers => '/Envelope/Header/[>0]', fault => '/Envelope/Body/Fault', faultcode => '/Envelope/Body/Fault/faultcode', faultstring => '/Envelope/Body/Fault/faultstring', faultactor => '/Envelope/Body/Fault/faultactor', faultdetail => '/Envelope/Body/Fault/detail', ); for my $method (keys %path) { *$method = sub { my $self = shift; ref $self or return $path{$method}; Carp::croak "Method '$method' is readonly and doesn't accept any parameters" if @_; return $self->valueof($path{$method}); }; } my %results = ( method => '/Envelope/Body/[1]', result => '/Envelope/Body/[1]/[1]', freeform => '/Envelope/Body/[>0]', paramsin => '/Envelope/Body/[1]/[>0]', paramsall => '/Envelope/Body/[1]/[>0]', paramsout => '/Envelope/Body/[1]/[>1]', ); for my $method (keys %results) { *$method = sub { my $self = shift; ref $self or return $results{$method}; Carp::croak "Method '$method' is readonly and doesn't accept any parameters" if @_; defined $self->fault ? return : return $self->valueof($results{$method}); }; } for my $method (qw(o_child o_value o_lname o_lattr o_qname)) { # import from SOAP::Utils *$method = \&{'SOAP::Utils::'.$method}; } } # use object in boolean context return true/false on last match # Ex.: $som->match('//Fault') ? 'SOAP call failed' : 'success'; use overload fallback => 1, 'bool' => sub { @{shift->{_current}} > 0 }; sub DESTROY { SOAP::Trace::objects('()') } sub new { my $self = shift; my $class = ref($self) || $self; my $content = shift; SOAP::Trace::objects('()'); return bless { _content => $content, _current => [$content] } => $class; } sub current { my $self = shift; $self->{_current} = [@_], return $self if @_; return wantarray ? @{$self->{_current}} : $self->{_current}->[0]; } sub valueof { my $self = shift; local $self->{_current} = $self->{_current}; $self->match(shift) if @_; return wantarray ? map {o_value($_)} @{$self->{_current}} : @{$self->{_current}} ? o_value($self->{_current}->[0]) : undef; } sub headerof { # SOAP::Header is the same as SOAP::Data, so just rebless it wantarray ? map { bless $_ => 'SOAP::Header' } shift->dataof(@_) : do { # header returned by ->dataof can be undef in scalar context my $header = shift->dataof(@_); ref $header ? bless($header => 'SOAP::Header') : undef; }; } sub dataof { my $self = shift; local $self->{_current} = $self->{_current}; $self->match(shift) if @_; return wantarray ? map {$self->_as_data($_)} @{$self->{_current}} : @{$self->{_current}} ? $self->_as_data($self->{_current}->[0]) : undef; } sub namespaceuriof { my $self = shift; local $self->{_current} = $self->{_current}; $self->match(shift) if @_; return wantarray ? map {(SOAP::Utils::splitlongname(o_lname($_)))[0]} @{$self->{_current}} : @{$self->{_current}} ? (SOAP::Utils::splitlongname(o_lname($self->{_current}->[0])))[0] : undef; } sub _as_data { my $self = shift; my $pointer = shift; SOAP::Data -> new(prefix => '', name => o_qname($pointer), name => o_lname($pointer), attr => o_lattr($pointer)) -> set_value(o_value($pointer)); } sub match { my $self = shift; my $path = shift; $self->{_current} = [ $path =~ s!^/!! || !@{$self->{_current}} ? $self->_traverse($self->{_content}, 1 => split '/' => $path) : map {$self->_traverse_tree(o_child($_), split '/' => $path)} @{$self->{_current}} ]; return $self; } sub _traverse { my $self = shift; my($pointer, $itself, $path, @path) = @_; die "Incorrect parameter" unless $itself =~ /^\d*$/; if ($path && substr($path, 0, 1) eq '{') { $path = join '/', $path, shift @path while @path && $path !~ /}/; } my($op, $num) = $path =~ /^\[(<=|<|>=|>|=|!=?)?(\d+)\]$/ if defined $path; return $pointer unless defined $path; $op = '==' unless $op; $op .= '=' if $op eq '=' || $op eq '!'; my $numok = defined $num && eval "$itself $op $num"; my $nameok = (o_lname($pointer) || '') =~ /(?:^|\})$path$/ if defined $path; # name can be with namespace my $anynode = $path eq ''; unless ($anynode) { if (@path) { return if defined $num && !$numok || !defined $num && !$nameok; } else { return $pointer if defined $num && $numok || !defined $num && $nameok; return; } } my @walk; push @walk, $self->_traverse_tree([$pointer], @path) if $anynode; push @walk, $self->_traverse_tree(o_child($pointer), $anynode ? ($path, @path) : @path); return @walk; } sub _traverse_tree { my $self = shift; my($pointer, @path) = @_; # can be list of children or value itself. Traverse only children return unless ref $pointer eq 'ARRAY'; my $itself = 1; grep {defined} map {$self->_traverse($_, $itself++, @path)} grep {!ref o_lattr($_) || !exists o_lattr($_)->{"{$SOAP::Constants::NS_ENC}root"} || o_lattr($_)->{"{$SOAP::Constants::NS_ENC}root"} ne '0'} @$pointer; } # ====================================================================== package SOAP::Deserializer; use vars qw(@ISA); @ISA = qw(SOAP::Cloneable); sub DESTROY { SOAP::Trace::objects('()') } sub BEGIN { no strict 'refs'; for my $method (qw(ids hrefs parser base xmlschemas xmlschema)) { my $field = '_' . $method; *$method = sub { my $self = shift->new; @_ ? ($self->{$field} = shift, return $self) : return $self->{$field}; } } } sub new { my $self = shift; my $class = ref($self) || $self; return $self if ref $self; SOAP::Trace::objects('()'); return bless { _ids => {}, _hrefs => {}, _parser => SOAP::Parser->new, _xmlschemas => { $SOAP::Constants::NS_APS => 'SOAP::XMLSchemaApacheSOAP::Deserializer', map { $_ => $SOAP::Constants::XML_SCHEMAS{$_} . '::Deserializer' } keys %SOAP::Constants::XML_SCHEMAS }, } => $class; } sub mimeparser { my $field = '_mimeparser'; my $self = shift->new; @_ ? ($self->{$field} = shift, return $self) : return $self->{$field} ||= new SOAP::MIMEParser; } sub is_xml { # Added check for envelope delivery. Fairly standard with MMDF and sendmail # Thanks to Chris Davies $_[1] =~ /^\s*new($location); # make absolute location if relative $location = $uri->abs($self->base)->as_string unless $uri->scheme; } $location; } sub mimedecode { my $self = shift->new; my $body; foreach ($self->mimeparser->decode($_[0])) { my($id, $location, $type, $value) = @$_; unless ($body) { # we are here for the first time, so it's a MAIN part $body = $self->parser->decode($value); $self->base($location); # store the base location } else { $location = $self->baselocation($location); my $part = $type eq 'text/xml' && !$SOAP::Constants::DO_NOT_PROCESS_XML_IN_MIME ? $self->parser->decode($value) : ['mimepart', {}, $value]; $self->ids->{$id} = $part if $id; $self->ids->{$location} = $part if $location; } } return $body; } sub decode { my $self = shift->new; return $self->is_xml($_[0]) ? $self->parser->decode($_[0]) : $self->mimedecode($_[0]); } sub deserialize { SOAP::Trace::trace('()'); my $self = shift->new; # initialize $self->hrefs({}); $self->ids({}); # TBD: find better way to signal parsing errors my $parsed = $self->decode($_[0]); # TBD: die on possible errors in Parser? # if there are some IDs (from mime processing), then process others # otherwise delay till we first meet IDs if (keys %{$self->ids()}) {$self->traverse_ids($parsed)} else {$self->ids($parsed)} $self->decode_object($parsed); return SOAP::SOM->new($parsed); } sub traverse_ids { my $self = shift; my $ref = shift; my($undef, $attrs, $children) = @$ref; # ^^^^^^ to fix nasty error on Mac platform (Carl K. Cunningham) $self->ids->{$attrs->{id}} = $ref if exists $attrs->{id}; return unless ref $children; for (@$children) {$self->traverse_ids($_)}; } sub decode_object { my $self = shift; my $ref = shift; my($name, $attrs, $children, $value) = @$ref; $ref->[6] = $attrs = {%$attrs}; # make a copy for long attributes use vars qw(%uris); local %uris = (%uris, map { do { (my $ns = $_) =~ s/^xmlns:?//; $ns } => delete $attrs->{$_} } grep {/^xmlns(:|$)/} keys %$attrs); foreach (keys %$attrs) { next unless m/^($SOAP::Constants::NSMASK?):($SOAP::Constants::NSMASK)$/; $1 =~ /^[xX][mM][lL]/ || $uris{$1} && do { $attrs->{SOAP::Utils::longname($uris{$1}, $2)} = do { my $value = $attrs->{$_}; $2 ne 'type' && $2 ne 'arrayType' ? $value : SOAP::Utils::longname($value =~ m/^($SOAP::Constants::NSMASK?):(${SOAP::Constants::NSMASK}(?:\[[\d,]*\])*)/ ? ($uris{$1} || die("Unresolved prefix '$1' for attribute value '$value'\n"), $2) : ($uris{''} || die("Unspecified namespace for type '$value'\n"), $value) ); }; 1; } || die "Unresolved prefix '$1' for attribute '$_'\n"; } # and now check the element my $ns = ($name =~ s/^($SOAP::Constants::NSMASK?):// ? $1 : ''); $ref->[5] = SOAP::Utils::longname( $ns ? ($uris{$ns} || die "Unresolved prefix '$ns' for element '$name'\n") : (defined $uris{''} ? $uris{''} : undef), $name ); ($children, $value) = (undef, $children) unless ref $children; return $name => ($ref->[4] = $self->decode_value( [$ref->[5], $attrs, $children, $value] )); } sub decode_value { my $self = shift; my $ref = shift; my($name, $attrs, $children, $value) = @$ref; # check SOAP version if applicable use vars '$level'; local $level = $level || 0; if (++$level == 1) { my($namespace, $envelope) = SOAP::Utils::splitlongname($name); SOAP::Lite->soapversion($namespace) if $envelope eq 'Envelope' && $namespace; } # check encodingStyle # future versions may bind deserializer to encodingStyle my $encodingStyle = $attrs->{"{$SOAP::Constants::NS_ENV}encodingStyle"}; die "Unrecognized/unsupported value of encodingStyle attribute '$encodingStyle'\n" if defined $encodingStyle && length($encodingStyle) != 0 && # encodingStyle="" $encodingStyle !~ /(?:^|\b)$SOAP::Constants::NS_ENC/; # ^^^^^^^^ \b causing problems (!?) on some systems # as reported by David Dyck # so use (?:^|\b) instead use vars '$arraytype'; # type of Array element specified on Array itself # either specified with xsi:type, or or array element my($type) = grep {defined} map($attrs->{$_}, sort grep {/^\{$SOAP::Constants::NS_XSI_ALL\}type$/o} keys %$attrs), $name =~ /^\{$SOAP::Constants::NS_ENC\}/ ? $name : $arraytype; local $arraytype; # it's used only for one level, we don't need it anymore # $name is not used here since type should be encoded as type, not as name my($schema, $class) = SOAP::Utils::splitlongname($type) if $type; my $schemaclass = $schema && $self->xmlschemas->{$schema} || $self; # store schema that is used in parsed message $self->xmlschema($schema) if $schema && $schema =~ /XMLSchema/; # don't use class/type if anyType/ur-type is specified on wire undef $class if $schemaclass->can('anyTypeValue') && $schemaclass->anyTypeValue eq $class; my $method = 'as_' . ($class || '-'); # dummy type if not defined $class =~ s/__|\./::/g if $class; my $id = $attrs->{id}; if (defined $id && exists $self->hrefs->{$id}) { return $self->hrefs->{$id}; } elsif (exists $attrs->{href}) { (my $id = delete $attrs->{href}) =~ s/^(#|cid:)?//; # convert to absolute if not internal '#' or 'cid:' $id = $self->baselocation($id) unless $1; return $self->hrefs->{$id} if exists $self->hrefs->{$id}; my $ids = $self->ids; # first time optimization. we don't traverse IDs unless asked for it if (ref $ids ne 'HASH') { $self->ids({}); $self->traverse_ids($ids); $ids = $self->ids } if (exists $ids->{$id}) { my $obj = ($self->decode_object(delete $ids->{$id}))[1]; return $self->hrefs->{$id} = $obj; } else { die "Unresolved (wrong?) href ($id) in element '$name'\n"; } } return undef if grep { /^$SOAP::Constants::NS_XSI_NILS$/ && $self->xmlschemas->{$1 || $2}->as_undef($attrs->{$_}) } keys %$attrs; # try to handle with typecasting my $res = $self->typecast($value, $name, $attrs, $children, $type); return $res if defined $res; # ok, continue with others if (exists $attrs->{"{$SOAP::Constants::NS_ENC}arrayType"}) { my $res = []; $self->hrefs->{$id} = $res if defined $id; # check for arrayType which could be [1], [,2][5] or [] # [,][1] will NOT be allowed right now (multidimensional sparse array) my($type, $multisize) = $attrs->{"{$SOAP::Constants::NS_ENC}arrayType"} =~ /^(.+)\[(\d*(?:,\d+)*)\](?:\[(?:\d+(?:,\d+)*)\])*$/ or die qq!Unrecognized/unsupported format of arrayType attribute '@{[$attrs->{"{$SOAP::Constants::NS_ENC}arrayType"}]}'\n!; my @dimensions = map { $_ || undef } split /,/, $multisize; my $size = 1; foreach (@dimensions) { $size *= $_ || 0 } local $arraytype = $type; # multidimensional if ($multisize =~ /,/) { @$res = splitarray( [@dimensions], [map { scalar(($self->decode_object($_))[1]) } @{$children || []}] ); # normal } else { @$res = map { scalar(($self->decode_object($_))[1]) } @{$children || []}; } # sparse (position) if (ref $children && exists SOAP::Utils::o_lattr($children->[0])->{"{$SOAP::Constants::NS_ENC}position"}) { my @new; for (my $pos = 0; $pos < @$children; $pos++) { # TBD implement position in multidimensional array my($position) = SOAP::Utils::o_lattr($children->[$pos])->{"{$SOAP::Constants::NS_ENC}position"} =~ /^\[(\d+)\]$/ or die "Position must be specified for all elements of sparse array\n"; $new[$position] = $res->[$pos]; } @$res = @new; } # partially transmitted (offset) # TBD implement offset in multidimensional array my($offset) = $attrs->{"{$SOAP::Constants::NS_ENC}offset"} =~ /^\[(\d+)\]$/ if exists $attrs->{"{$SOAP::Constants::NS_ENC}offset"}; unshift(@$res, (undef) x $offset) if $offset; die "Too many elements in array. @{[scalar@$res]} instead of claimed $multisize ($size)\n" if $multisize && $size < @$res; # extend the array if number of elements is specified $#$res = $dimensions[0]-1 if defined $dimensions[0] && @$res < $dimensions[0]; return defined $class && $class ne 'Array' ? bless($res => $class) : $res; } elsif ($name =~ /^\{$SOAP::Constants::NS_ENC\}Struct$/ || !$schemaclass->can($method) && (ref $children || defined $class && $value =~ /^\s*$/)) { my $res = {}; $self->hrefs->{$id} = $res if defined $id; %$res = map {$self->decode_object($_)} @{$children || []}; return defined $class && $class ne 'SOAPStruct' ? bless($res => $class) : $res; } else { my $res; if ($schemaclass->can($method)) { $method = "$schemaclass\::$method" unless ref $schemaclass; $res = $self->$method($value, $name, $attrs, $children, $type); } else { $res = $self->typecast($value, $name, $attrs, $children, $type); $res = $class ? die "Unrecognized type '$type'\n" : $value unless defined $res; } $self->hrefs->{$id} = $res if defined $id; return $res; } } sub splitarray { my @sizes = @{+shift}; my $size = shift @sizes; my $array = shift; return splice(@$array, 0, $size) unless @sizes; my @array = (); push @array, [splitarray([@sizes], $array)] while @$array && (!defined $size || $size--); return @array; } sub typecast { } # typecast is called for both objects AND scalar types # check ref of the second parameter (first is the object) # return undef if you don't want to handle it # ====================================================================== package SOAP::Client; sub BEGIN { no strict 'refs'; for my $method (qw(endpoint code message is_success status options)) { my $field = '_' . $method; *$method = sub { my $self = shift->new; @_ ? ($self->{$field} = shift, return $self) : return $self->{$field}; } } } # ====================================================================== package SOAP::Server::Object; sub gen_id; *gen_id = \&SOAP::Serializer::gen_id; my %alive; my %objects; sub objects_by_reference { shift; while (@_) { @alive{shift()} = ref $_[0] ? shift : sub { $_[1]-$_[$_[5] ? 5 : 4] > 600 } } keys %alive; } sub reference { my $self = shift; my $stamp = time; my $object = shift; my $id = $stamp . $self->gen_id($object); # this is code for garbage collection my $time = time; my $type = ref $object; my @objects = grep { $objects{$_}->[1] eq $type } keys %objects; for (grep { $alive{$type}->(scalar @objects, $time, @{$objects{$_}}) } @objects) { delete $objects{$_}; } $objects{$id} = [$object, $type, $stamp]; bless { id => $id } => ref $object; } sub references { my $self = shift; return @_ unless %alive; # small optimization map { ref($_) && exists $alive{ref $_} ? $self->reference($_) : $_ } @_; } sub object { my $self = shift; my $class = ref($self) || $self; my $object = shift; return $object unless ref($object) && $alive{ref $object} && exists $object->{id}; my $reference = $objects{$object->{id}}; die "Object with specified id couldn't be found\n" unless ref $reference->[0]; $reference->[3] = time; # last access time return $reference->[0]; # reference to actual object } sub objects { my $self = shift; return @_ unless %alive; # small optimization map { ref($_) && exists $alive{ref $_} && exists $_->{id} ? $self->object($_) : $_ } @_; } # ====================================================================== package SOAP::Server::Parameters; sub byNameOrOrder { unless (UNIVERSAL::isa($_[-1] => 'SOAP::SOM')) { warn "Last parameter is expected to be envelope\n" if $^W; pop; return @_; } my $params = pop->method; my @mandatory = ref $_[0] eq 'ARRAY' ? @{shift()} : die "list of parameters expected as the first parameter for byName"; my $byname = 0; my @res = map { $byname += exists $params->{$_}; $params->{$_} } @mandatory; return $byname ? @res : @_; } sub byName { unless (UNIVERSAL::isa($_[-1] => 'SOAP::SOM')) { warn "Last parameter is expected to be envelope\n" if $^W; pop; return @_; } return @{pop->method}{ref $_[0] eq 'ARRAY' ? @{shift()} : die "list of parameters expected as the first parameter for byName"}; } # ====================================================================== package SOAP::Server; use Carp (); sub DESTROY { SOAP::Trace::objects('()') } sub new { my $self = shift; unless (ref $self) { my $class = ref($self) || $self; my(@params, @methods); while (@_) { my($method, $params) = splice(@_,0,2); $class->can($method) ? push(@methods, $method, $params) : $^W && Carp::carp "Unrecognized parameter '$method' in new()"; } $self = bless { _dispatch_to => [], _dispatch_with => {}, _dispatched => [], _action => '', _options => {}, } => $class; unshift(@methods, $self->initialize); while (@methods) { my($method, $params) = splice(@methods,0,2); $self->$method(ref $params eq 'ARRAY' ? @$params : $params) } SOAP::Trace::objects('()'); } Carp::carp "Odd (wrong?) number of parameters in new()" if $^W && (@_ & 1); while (@_) { my($method, $params) = splice(@_,0,2); $self->can($method) ? $self->$method(ref $params eq 'ARRAY' ? @$params : $params) : $^W && Carp::carp "Unrecognized parameter '$method' in new()" } return $self; } sub initialize { return ( serializer => SOAP::Serializer->new, deserializer => SOAP::Deserializer->new, on_action => sub {}, on_dispatch => sub {return}, ); } sub BEGIN { no strict 'refs'; for my $method (qw(action myuri serializer deserializer options dispatch_with)) { my $field = '_' . $method; *$method = sub { my $self = shift->new; @_ ? ($self->{$field} = shift, return $self) : return $self->{$field}; } } for my $method (qw(on_action on_dispatch)) { my $field = '_' . $method; *$method = sub { my $self = shift->new; return $self->{$field} unless @_; local $@; # commented out because that 'eval' was unsecure # > ref $_[0] eq 'CODE' ? shift : eval shift; # Am I paranoid enough? $self->{$field} = shift; Carp::croak $@ if $@; Carp::croak "$method() expects subroutine (CODE) or string that evaluates into subroutine (CODE)" unless ref $self->{$field} eq 'CODE'; return $self; } } for my $method (qw(dispatch_to)) { my $field = '_' . $method; *$method = sub { my $self = shift->new; @_ ? ($self->{$field} = [@_], return $self) : return @{$self->{$field}}; } } } sub objects_by_reference { my $self = shift->new; @_ ? (SOAP::Server::Object->objects_by_reference(@_), return $self) : SOAP::Server::Object->objects_by_reference; } sub dispatched { my $self = shift->new; @_ ? (push(@{$self->{_dispatched}}, @_), return $self) : return @{$self->{_dispatched}}; } sub find_target { my $self = shift; my $request = shift; # try to find URI/method from on_dispatch call first my($method_uri, $method_name) = $self->on_dispatch->($request); # if nothing there, then get it from envelope itself $request->match((ref $request)->method); ($method_uri, $method_name) = ($request->namespaceuriof || '', $request->dataof->name) unless $method_name; $self->on_action->(my $action = $self->action, $method_uri, $method_name); # check to avoid security vulnerability: Protected->Unprotected::method(@parameters) # see for more details: http://www.phrack.org/phrack/58/p58-0x09 die "Denied access to method ($method_name)\n" unless $method_name =~ /^\w+$/; my($class, $static); # try to bind directly if (defined($class = $self->dispatch_with->{$method_uri} || $self->dispatch_with->{$action} || ($action =~ /^"(.+)"$/ ? $self->dispatch_with->{$1} : undef))) { # return object, nothing else to do here return ($class, $method_uri, $method_name) if ref $class; $static = 1; } else { die "URI path shall map to class" unless defined ($class = URI->new($method_uri)->path); for ($class) { s!^/|/$!!g; s!/!::!g; s/^$/main/; } die "Failed to access class ($class)" unless $class =~ /^(\w[\w:]*)$/; my $fullname = "$class\::$method_name"; foreach ($self->dispatch_to) { return ($_, $method_uri, $method_name) if ref eq $class; # $OBJECT next if ref; # skip other objects # will ignore errors, because it may complain on # d:\foo\bar, which is PATH and not regexp eval { $static ||= $class =~ /^$_$/ || # MODULE $fullname =~ /^$_$/ || # MODULE::method $method_name =~ /^$_$/ && ($class eq 'main') # method ('main' assumed) ; }; } } no strict 'refs'; unless (defined %{"${class}::"}) { # allow all for static and only specified path for dynamic bindings local @INC = (($static ? @INC : ()), grep {!ref && m![/\\.]!} $self->dispatch_to); eval 'local $^W; ' . "require $class"; die "Failed to access class ($class): $@" if $@; $self->dispatched($class) unless $static; } die "Denied access to method ($method_name) in class ($class)" unless $static || grep {/^$class$/} $self->dispatched; return ($class, $method_uri, $method_name); } sub handle { SOAP::Trace::trace('()'); my $self = shift; # we want to restore it when we are done local $SOAP::Constants::DEFAULT_XML_SCHEMA = $SOAP::Constants::DEFAULT_XML_SCHEMA; # SOAP version WILL NOT be restored when we are done. # is it problem? my $result = eval { local $SIG{__DIE__}; $self->serializer->soapversion(1.1); my $request = eval { $self->deserializer->deserialize($_[0]) }; die SOAP::Fault->faultcode($SOAP::Constants::FAULT_VERSION_MISMATCH) ->faultstring($@) if $@ && $@ =~ /^$SOAP::Constants::WRONG_VERSION/; die "Application failed during request deserialization: $@" if $@; my $som = ref $request; die "Can't find root element in the message" unless $request->match($som->envelope); $self->serializer->soapversion(SOAP::Lite->soapversion); $self->serializer->xmlschema($SOAP::Constants::DEFAULT_XML_SCHEMA = $self->deserializer->xmlschema) if $self->deserializer->xmlschema; die SOAP::Fault->faultcode($SOAP::Constants::FAULT_MUST_UNDERSTAND) ->faultstring("Unrecognized header has mustUnderstand attribute set to 'true'") if !$SOAP::Constants::DO_NOT_CHECK_MUSTUNDERSTAND && grep { $_->mustUnderstand && (!$_->actor || $_->actor eq $SOAP::Constants::NEXT_ACTOR) } $request->dataof($som->headers); die "Can't find method element in the message" unless $request->match($som->method); my($class, $method_uri, $method_name) = $self->find_target($request); my @results = eval { local $^W; my @parameters = $request->paramsin; # SOAP::Trace::dispatch($fullname); SOAP::Trace::parameters(@parameters); push @parameters, $request if UNIVERSAL::isa($class => 'SOAP::Server::Parameters'); SOAP::Server::Object->references( defined $parameters[0] && ref $parameters[0] && UNIVERSAL::isa($parameters[0] => $class) ? do { my $object = shift @parameters; SOAP::Server::Object->object(ref $class ? $class : $object)->$method_name( SOAP::Server::Object->objects(@parameters)), # send object back as a header # preserve name, specify URI SOAP::Header->uri($SOAP::Constants::NS_SL_HEADER => $object) ->name($request->dataof($som->method.'/[1]')->name) } : $class->$method_name(SOAP::Server::Object->objects(@parameters)) ); }; SOAP::Trace::result(@results); # let application errors pass through with 'Server' code die ref $@ ? $@ : $@ =~ /^Can't locate object method "$method_name"/ ? "Failed to locate method ($method_name) in class ($class)" : SOAP::Fault->faultcode($SOAP::Constants::FAULT_SERVER)->faultstring($@) if $@; return $self->serializer -> prefix('s') # distinguish generated element names between client and server -> uri($method_uri) -> envelope(response => $method_name . 'Response', @results); }; # void context return unless defined wantarray; # normal result return $result unless $@; # check fails, something wrong with message return $self->make_fault($SOAP::Constants::FAULT_CLIENT, $@) unless ref $@; # died with SOAP::Fault return $self->make_fault($@->faultcode || $SOAP::Constants::FAULT_SERVER, $@->faultstring || 'Application error', $@->faultdetail, $@->faultactor) if UNIVERSAL::isa($@ => 'SOAP::Fault'); # died with complex detail return $self->make_fault($SOAP::Constants::FAULT_SERVER, 'Application error' => $@); } sub make_fault { my $self = shift; my($code, $string, $detail, $actor) = @_; $self->serializer->fault($code, $string, $detail, $actor || $self->myuri); } # ====================================================================== package SOAP::Trace; use Carp (); my @list = qw(transport dispatch result parameters headers objects method fault freeform trace debug); { no strict 'refs'; for (@list) { *$_ = sub {} } } sub defaultlog { my $caller = (caller(1))[3]; $caller = (caller(2))[3] if $caller =~ /eval/; chomp(my $msg = join ' ', @_); printf STDERR "%s: %s\n", $caller, $msg; } sub import { no strict 'refs'; local $^W; my $pack = shift; my(@notrace, @symbols); for (@_) { if (ref eq 'CODE') { my $call = $_; foreach (@symbols) { *$_ = sub { $call->(@_) } } @symbols = (); } else { local $_ = $_; my $minus = s/^-//; my $all = $_ eq 'all'; Carp::carp "Illegal symbol for tracing ($_)" unless $all || $pack->can($_); $minus ? push(@notrace, $all ? @list : $_) : push(@symbols, $all ? @list : $_); } } foreach (@symbols) { *$_ = \&defaultlog } foreach (@notrace) { *$_ = sub {} } } # ====================================================================== package SOAP::Custom::XML::Data; use vars qw(@ISA $AUTOLOAD); @ISA = qw(SOAP::Data); use overload fallback => 1, '""' => sub { shift->value }; sub _compileit { no strict 'refs'; my $method = shift; *$method = sub { return __PACKAGE__->SUPER::name($method => $_[0]->attr->{$method}) if exists $_[0]->attr->{$method}; my @elems = grep { ref $_ && UNIVERSAL::isa($_ => __PACKAGE__) && $_->SUPER::name =~ /(^|:)$method$/ } $_[0]->value; return wantarray? @elems : $elems[0]; } } sub BEGIN { foreach (qw(name type import)) { _compileit($_) } } sub AUTOLOAD { my $method = substr($AUTOLOAD, rindex($AUTOLOAD, '::') + 2); return if $method eq 'DESTROY'; _compileit($method); goto &$AUTOLOAD; } # ====================================================================== package SOAP::Custom::XML::Deserializer; use vars qw(@ISA); @ISA = qw(SOAP::Deserializer); sub decode_value { my $self = shift; my $ref = shift; my($name, $attrs, $children, $value) = @$ref; # base class knows what to do with it return $self->SUPER::decode_value($ref) if exists $attrs->{href}; SOAP::Custom::XML::Data -> SOAP::Data::name($name) -> attr($attrs) -> set_value(ref $children && @$children ? map(scalar(($self->decode_object($_))[1]), @$children) : $value); } # ====================================================================== package SOAP::Schema::Deserializer; use vars qw(@ISA); @ISA = qw(SOAP::Custom::XML::Deserializer); # ====================================================================== package SOAP::Schema::WSDL; use vars qw(%imported); sub new { my $self = shift; unless (ref $self) { my $class = ref($self) || $self; $self = bless {} => $class; } return $self; } sub base { my $self = shift->new; @_ ? ($self->{_base} = shift, return $self) : return $self->{_base}; } sub import { my $self = shift->new; my $s = shift; my $base = shift || $self->base || die "Missing base argument for ", __PACKAGE__, "\n"; my $schema; my @a = $s->import; local %imported = %imported; foreach (@a) { next unless $_->location; my $location = URI->new_abs($_->location->value, $base)->as_string; if ($imported{$location}++) { warn "Recursion loop detected in service description from '$location'. Ignored\n" if $^W; return $s; } $schema ||= SOAP::Schema->new; my $root = $self->import($schema->deserializer->deserialize($schema->access($location))->root, $location); $root->SOAP::Data::name eq 'definitions' ? $s->set_value($s->value, $root->value) : $root->SOAP::Data::name eq 'schema' ? do { # add element if there is no one $s->set_value($s->value, SOAP::Schema::Deserializer->deserialize('')->root) unless $s->types; $s->types->set_value($s->types->value, $root) } : die "Don't know what to do with '@{[$root->SOAP::Data::name]}' in schema imported from '$location'\n"; } $s; } sub parse { my $self = shift->new; my($s, $service, $port) = @_; my @result; # handle imports $self->import($s); # handle descriptions without , aka tModel-type descriptions my @services = $s->service; # if there is no element we'll provide it @services = SOAP::Schema::Deserializer->deserialize(<<"FAKE")->root->service unless @services; FAKE foreach (@services) { my $name = $_->name; next if $service && $service ne $name; my %services; foreach ($_->port) { next if $port && $port ne $_->name; my $binding = SOAP::Utils::disqualify($_->binding); my $endpoint = ref $_->address ? $_->address->location : undef; foreach ($s->binding) { # is this a SOAP binding? next unless grep { $_->uri eq 'http://schemas.xmlsoap.org/wsdl/soap/' } $_->binding; next unless $_->name eq $binding; my $porttype = SOAP::Utils::disqualify($_->type); foreach ($_->operation) { my $opername = $_->name; my $soapaction = $_->operation->soapAction; my $namespace = $_->input->body->namespace; my @parts; foreach ($s->portType) { next unless $_->name eq $porttype; foreach ($_->operation) { next unless $_->name eq $opername; my $inputmessage = SOAP::Utils::disqualify($_->input->message); foreach ($s->message) { next unless $_->name eq $inputmessage; @parts = $_->part; } } } $services{$opername} = {}; # should be initialized in 5.7 and after for ($services{$opername}) { $_->{endpoint} = $endpoint; $_->{soapaction} = $soapaction; $_->{uri} = $namespace; $_->{parameters} = [@parts]; } } } } # fix nonallowed characters in package name, and add 's' if started with digit for ($name) { s/\W+/_/g; s/^(\d)/s$1/ } push @result, $name => \%services; } return @result; } # ====================================================================== package SOAP::Schema; use Carp (); sub DESTROY { SOAP::Trace::objects('()') } sub new { my $self = shift; unless (ref $self) { my $class = ref($self) || $self; $self = bless { _deserializer => SOAP::Schema::Deserializer->new, } => $class; SOAP::Trace::objects('()'); } Carp::carp "Odd (wrong?) number of parameters in new()" if $^W && (@_ & 1); while (@_) { my $method = shift; $self->$method(shift) if $self->can($method) } return $self; } sub BEGIN { no strict 'refs'; for my $method (qw(deserializer schema services)) { my $field = '_' . $method; *$method = sub { my $self = shift->new; @_ ? ($self->{$field} = shift, return $self) : return $self->{$field}; } } } sub parse { my $self = shift->new; my $s = $self->deserializer->deserialize($self->access)->root; # here should be something that defines what schema description we want to use $self->services({SOAP::Schema::WSDL->base($self->schema)->parse($s, @_)}); } sub load { my $self = shift->new; local $^W; # supress warnings about redefining foreach (keys %{$self->services || Carp::croak 'Nothing to load. Schema is not specified'}) { eval $self->stub($_) or Carp::croak "Bad stub: $@"; } $self; } sub access { require LWP::UserAgent; my $self = shift->new; my $url = shift || $self->schema || Carp::croak 'Nothing to access. URL is not specified'; my $ua = LWP::UserAgent->new; $ua->env_proxy if $ENV{'HTTP_proxy'}; my $req = HTTP::Request->new(GET => $url); $req->proxy_authorization_basic($ENV{'HTTP_proxy_user'}, $ENV{'HTTP_proxy_pass'}) if ($ENV{'HTTP_proxy_user'} && $ENV{'HTTP_proxy_pass'}); my $resp = $ua->request($req); $resp->is_success ? $resp->content : die "Service description '$url' can't be loaded: ", $resp->status_line, "\n"; } sub stub { my $self = shift->new; my $package = shift; my $services = $self->services->{$package}; my $schema = $self->schema; join("\n", "package $package;\n", "# -- generated by SOAP::Lite (v$SOAP::Lite::VERSION) for Perl -- soaplite.com -- Copyright (C) 2000-2001 Paul Kulchenko --", ($schema ? "# -- generated from $schema [@{[scalar localtime]}]\n" : "\n"), 'my %methods = (', (map { my $service = $_; join("\n", " $_ => {", map(" $_ => '$services->{$service}{$_}',", qw/endpoint soapaction uri/), " parameters => [", map(" SOAP::Data->new(name => '" . $_->name . "', type => '" . $_->type . "', attr => {" . do{ my %attr = %{$_->attr}; join ', ', map {"'$_' => '$attr{$_}'"} grep {/^xmlns:(?!-)/} keys %attr} . "}),", @{$services->{$service}{parameters}}), " ],\n },", ), } keys %$services), ");", <<'EOP'); use SOAP::Lite; use Exporter; use Carp (); use vars qw(@ISA $AUTOLOAD @EXPORT_OK %EXPORT_TAGS); @ISA = qw(Exporter SOAP::Lite); @EXPORT_OK = (keys %methods); %EXPORT_TAGS = ('all' => [@EXPORT_OK]); no strict 'refs'; for my $method (@EXPORT_OK) { my %method = %{$methods{$method}}; *$method = sub { my $self = UNIVERSAL::isa($_[0] => __PACKAGE__) ? ref $_[0] ? shift # OBJECT # CLASS, either get self or create new and assign to self : (shift->self || __PACKAGE__->self(__PACKAGE__->new)) # function call, either get self or create new and assign to self : (__PACKAGE__->self || __PACKAGE__->self(__PACKAGE__->new)); $self->proxy($method{endpoint} || Carp::croak "No server address (proxy) specified") unless $self->proxy; my @templates = @{$method{parameters}}; my $som = $self -> endpoint($method{endpoint}) -> uri($method{uri}) -> on_action(sub{qq!"$method{soapaction}"!}) -> call($method => map {@templates ? shift(@templates)->value($_) : $_} @_); UNIVERSAL::isa($som => 'SOAP::SOM') ? wantarray ? $som->paramsall : $som->result : $som; } } sub AUTOLOAD { my $method = substr($AUTOLOAD, rindex($AUTOLOAD, '::') + 2); return if $method eq 'DESTROY'; die "Unrecognized method '$method'. List of available method(s): @EXPORT_OK\n"; } 1; EOP } # ====================================================================== package SOAP; use vars qw($AUTOLOAD); use URI; my $soap; # shared between SOAP and SOAP::Lite packages { no strict 'refs'; *AUTOLOAD = sub { local($1,$2); my($package, $method) = $AUTOLOAD =~ m/(?:(.+)::)([^:]+)$/; return if $method eq 'DESTROY'; my $soap = ref $_[0] && UNIVERSAL::isa($_[0] => 'SOAP::Lite') ? $_[0] : $soap; my $uri = URI->new($soap->uri); my $currenturi = $uri->path; $package = ref $_[0] && UNIVERSAL::isa($_[0] => 'SOAP::Lite') ? $currenturi : $package eq 'SOAP' ? ref $_[0] || ($_[0] eq 'SOAP' ? $currenturi || Carp::croak "URI is not specified for method call" : $_[0]) : $package eq 'main' ? $currenturi || $package : $package; # drop first parameter if it's a class name { my $pack = $package; for ($pack) { s!^/!!; s!/!::!g; } shift @_ if !ref $_[0] && ($_[0] eq $pack || $_[0] eq 'SOAP') || ref $_[0] && UNIVERSAL::isa($_[0] => 'SOAP::Lite'); } for ($package) { s!::!/!g; s!^/?!/!; } $uri->path($package); my $som = $soap->uri($uri->as_string)->call($method => @_); UNIVERSAL::isa($som => 'SOAP::SOM') ? wantarray ? $som->paramsall : $som->result : $som; }; } # ====================================================================== package SOAP::Lite; use vars qw($AUTOLOAD @ISA); use Carp (); @ISA = qw(SOAP::Cloneable); # provide access to global/autodispatched object sub self { @_ > 1 ? $soap = $_[1] : $soap } # no more warnings about "used only once" *UNIVERSAL::AUTOLOAD if 0; sub autodispatched { \&{*UNIVERSAL::AUTOLOAD} eq \&{*SOAP::AUTOLOAD} }; sub soapversion { my $self = shift; my $version = shift or return $SOAP::Constants::SOAP_VERSION; ($version) = grep { $SOAP::Constants::SOAP_VERSIONS{$_}->{NS_ENV} eq $version } keys %SOAP::Constants::SOAP_VERSIONS unless exists $SOAP::Constants::SOAP_VERSIONS{$version}; die qq!$SOAP::Constants::WRONG_VERSION Supported versions:\n@{[ join "\n", map {" $_ ($SOAP::Constants::SOAP_VERSIONS{$_}->{NS_ENV})"} keys %SOAP::Constants::SOAP_VERSIONS ]}\n! unless defined($version) && defined(my $def = $SOAP::Constants::SOAP_VERSIONS{$version}); foreach (keys %$def) { eval "\$SOAP::Constants::$_ = '$SOAP::Constants::SOAP_VERSIONS{$version}->{$_}'"; } $SOAP::Constants::SOAP_VERSION = $version; $self; } BEGIN { SOAP::Lite->soapversion(1.1) } sub import { my $pkg = shift; my $caller = caller; no strict 'refs'; # emulate 'use SOAP::Lite 0.99' behavior $pkg->require_version(shift) if defined $_[0] && $_[0] =~ /^\d/; while (@_) { my $command = shift; my @parameters = UNIVERSAL::isa($_[0] => 'ARRAY') ? @{shift()} : shift if @_ && $command ne 'autodispatch'; if ($command eq 'autodispatch' || $command eq 'dispatch_from') { $soap = ($soap||$pkg)->new; no strict 'refs'; foreach ($command eq 'autodispatch' ? 'UNIVERSAL' : @parameters) { my $sub = "${_}::AUTOLOAD"; defined &{*$sub} ? (\&{*$sub} eq \&{*SOAP::AUTOLOAD} ? () : Carp::croak "$sub already assigned and won't work with DISPATCH. Died") : (*$sub = *SOAP::AUTOLOAD); } } elsif ($command eq 'service' || $command eq 'schema') { warn "'schema =>' interface is changed. Use 'service =>' instead\n" if $command eq 'schema' && $^W; foreach (keys %{SOAP::Schema->schema(shift(@parameters))->parse(@parameters)->load->services}) { $_->export_to_level(1, undef, ':all'); } } elsif ($command eq 'debug' || $command eq 'trace') { SOAP::Trace->import(@parameters ? @parameters : 'all'); } elsif ($command eq 'import') { local $^W; # supress warnings about redefining my $package = shift(@parameters); $package->export_to_level(1, undef, @parameters ? @parameters : ':all') if $package; } else { Carp::carp "Odd (wrong?) number of parameters in import(), still continue" if $^W && !(@parameters & 1); $soap = ($soap||$pkg)->$command(@parameters); } } } sub DESTROY { SOAP::Trace::objects('()') } sub new { my $self = shift; unless (ref $self) { my $class = ref($self) || $self; # check whether we can clone. Only the SAME class allowed, no inheritance $self = ref($soap) eq $class ? $soap->clone : { _transport => SOAP::Transport->new, _serializer => SOAP::Serializer->new, _deserializer => SOAP::Deserializer->new, _autoresult => 0, _on_action => sub { sprintf '"%s#%s"', shift || '', shift }, _on_fault => sub {ref $_[1] ? return $_[1] : Carp::croak $_[0]->transport->is_success ? $_[1] : $_[0]->transport->status}, }; bless $self => $class; $self->on_nonserialized($self->on_nonserialized || $self->serializer->on_nonserialized); SOAP::Trace::objects('()'); } Carp::carp "Odd (wrong?) number of parameters in new()" if $^W && (@_ & 1); while (@_) { my($method, $params) = splice(@_,0,2); $self->can($method) ? $self->$method(ref $params eq 'ARRAY' ? @$params : $params) : $^W && Carp::carp "Unrecognized parameter '$method' in new()" } return $self; } sub BEGIN { no strict 'refs'; for my $method (qw(endpoint transport serializer deserializer outputxml autoresult)) { my $field = '_' . $method; *$method = sub { my $self = shift->new; @_ ? ($self->{$field} = shift, return $self) : return $self->{$field}; } } for my $method (qw(on_action on_fault on_nonserialized)) { my $field = '_' . $method; *$method = sub { my $self = shift->new; return $self->{$field} unless @_; local $@; # commented out because that 'eval' was unsecure # > ref $_[0] eq 'CODE' ? shift : eval shift; # Am I paranoid enough? $self->{$field} = shift; Carp::croak $@ if $@; Carp::croak "$method() expects subroutine (CODE) or string that evaluates into subroutine (CODE)" unless ref $self->{$field} eq 'CODE'; return $self; } } for my $method (qw(proxy)) { *$method = sub { my $self = shift->new; @_ ? ($self->transport->$method(@_), return $self) : return $self->transport->$method(); } } for my $method (qw(autotype readable namespace encodingspace envprefix encprefix multirefinplace encoding typelookup uri header maptype xmlschema)) { *$method = sub { my $self = shift->new; @_ ? ($self->serializer->$method(@_), return $self) : return $self->serializer->$method(); } } } sub service { my $field = '_service'; my $self = shift->new; return $self->{$field} unless @_; my %services = %{SOAP::Schema->schema($self->{$field} = shift)->parse(@_)->load->services}; Carp::croak "More than one service in service description. Service and port names have to be specified\n" if keys %services > 1; return (keys %services)[0]->new; } sub schema { warn "SOAP::Lite->schema(...) interface is changed. Use ->service() instead\n" if $^W; shift->service(@_); } sub on_debug { my $self = shift; # comment this warning for now, till we redesign SOAP::Trace (2001/02/20) # Carp::carp "'SOAP::Lite->on_debug' method is deprecated. Instead use 'SOAP::Lite +debug ...'" if $^W; SOAP::Trace->import(debug => shift); $self; } sub AUTOLOAD { my $method = substr($AUTOLOAD, rindex($AUTOLOAD, '::') + 2); return if $method eq 'DESTROY'; ref $_[0] or Carp::croak qq!Can't locate class method "$method" via package "! . __PACKAGE__ .'"'; no strict 'refs'; *$AUTOLOAD = sub { my $self = shift; my $som = $self->call($method => @_); return $self->autoresult && UNIVERSAL::isa($som => 'SOAP::SOM') ? wantarray ? $som->paramsall : $som->result : $som; }; goto &$AUTOLOAD; } sub call { SOAP::Trace::trace('()'); my $self = shift; return $self->{_call} unless @_; my $serializer = $self->serializer; die "Transport is not specified (using proxy() method or service description)\n" unless defined $self->proxy && UNIVERSAL::isa($self->proxy => 'SOAP::Client'); $serializer->on_nonserialized($self->on_nonserialized); my $response = $self->transport->send_receive( endpoint => $self->endpoint, action => scalar($self->on_action->($serializer->uriformethod($_[0]))), # leave only parameters so we can later update them if required envelope => $serializer->envelope(method => shift, @_), encoding => $serializer->encoding, ); return $response if $self->outputxml; # deserialize and store result my $result = $self->{_call} = eval { $self->deserializer->deserialize($response) } if $response; if (!$self->transport->is_success || # transport fault $@ || # not deserializible # fault message even if transport OK # or no transport error (for example, fo TCP, POP3, IO implementations) UNIVERSAL::isa($result => 'SOAP::SOM') && $result->fault) { return $self->{_call} = ($self->on_fault->($self, $@ ? $@ . ($response || '') : $result) || $result); } return unless $response; # nothing to do for one-ways # little bit tricky part that binds in/out parameters if (UNIVERSAL::isa($result => 'SOAP::SOM') && ($result->paramsout || $result->headers) && $serializer->signature) { my $num = 0; my %signatures = map {$_ => $num++} @{$serializer->signature}; for ($result->dataof(SOAP::SOM::paramsout), $result->dataof(SOAP::SOM::headers)) { my $signature = join $;, $_->name, $_->type || ''; if (exists $signatures{$signature}) { my $param = $signatures{$signature}; my($value) = $_->value; # take first value UNIVERSAL::isa($_[$param] => 'SOAP::Data') ? $_[$param]->SOAP::Data::value($value) : UNIVERSAL::isa($_[$param] => 'ARRAY') ? (@{$_[$param]} = @$value) : UNIVERSAL::isa($_[$param] => 'HASH') ? (%{$_[$param]} = %$value) : UNIVERSAL::isa($_[$param] => 'SCALAR') ? (${$_[$param]} = $$value) : ($_[$param] = $value) } } } return $result; } # ====================================================================== package SOAP::Lite::COM; require SOAP::Lite; sub required { foreach (qw( URI::_foreign URI::http URI::https LWP::Protocol::http LWP::Protocol::https LWP::Authen::Basic LWP::Authen::Digest HTTP::Daemon Compress::Zlib SOAP::Transport::HTTP XMLRPC::Lite XMLRPC::Transport::HTTP )) { eval join ';', 'local $SIG{__DIE__}', "require $_"; } } sub new { required; SOAP::Lite->new(@_) } sub create; *create = \&new; # make alias. Somewhere 'new' is registered keyword sub soap; *soap = \&new; # also alias. Just to be consistent with .xmlrpc call sub xmlrpc { required; XMLRPC::Lite->new(@_) } sub server { required; shift->new(@_) } sub data { SOAP::Data->new(@_) } sub header { SOAP::Header->new(@_) } sub hash { +{@_} } sub instanceof { my $class = shift; die "Incorrect class name" unless $class =~ /^(\w[\w:]*)$/; eval "require $class"; $class->new(@_); } # ====================================================================== 1; __END__ =head1 NAME SOAP::Lite - Client and server side SOAP implementation =head1 SYNOPSIS use SOAP::Lite; print SOAP::Lite -> uri('http://www.soaplite.com/Temperatures') -> proxy('http://services.soaplite.com/temper.cgi') -> f2c(32) -> result; The same code with autodispatch: use SOAP::Lite +autodispatch => uri => 'http://www.soaplite.com/Temperatures', proxy => 'http://services.soaplite.com/temper.cgi'; print f2c(32); Code in OO-style: use SOAP::Lite +autodispatch => uri => 'http://www.soaplite.com/Temperatures', proxy => 'http://services.soaplite.com/temper.cgi'; my $temperatures = Temperatures->new(32); # get object print $temperatures->as_celsius; # invoke method Code with service description: use SOAP::Lite; print SOAP::Lite -> service('http://www.xmethods.net/sd/StockQuoteService.wsdl') -> getQuote('MSFT'); Code for SOAP server (CGI): use SOAP::Transport::HTTP; SOAP::Transport::HTTP::CGI -> dispatch_to('/Your/Path/To/Deployed/Modules', 'Module::Name', 'Module::method') -> handle; Visual Basic client (through COM interface): MsgBox CreateObject("SOAP.Lite").new( _ "proxy", "http://services.xmethods.net/soap", _ "uri", "urn:xmethods-delayed-quotes" _ ).getQuote("MSFT").result mod_soap enabled SOAP server: .htaccess SetHandler perl-script PerlHandler Apache::SOAP PerlSetVar dispatch_to "/Your/Path/To/Deployed/Modules, Module::Name" ASP/VB SOAP server: <% Response.ContentType = "text/xml" Response.Write(Server.CreateObject("SOAP.Lite") _ .server("SOAP::Server") _ .dispatch_to("/Your/Path/To/Deployed/Modules") _ .handle(Request.BinaryRead(Request.TotalBytes)) _ ) %> =head1 DESCRIPTION SOAP::Lite is a collection of Perl modules which provides a simple and lightweight interface to the Simple Object Access Protocol (SOAP) both on client and server side. This version of SOAP::Lite supports the SOAP 1.1 specification ( http://www.w3.org/TR/SOAP ). The main features of the library are: =over 3 =item * Supports SOAP 1.1 spec. =item * Interoperability tests with different implementations: Apache SOAP, Frontier, Microsoft SOAP, Microsoft .NET, DevelopMentor, XMethods, 4s4c, Phalanx, Kafka, SQLData, Lucin (in Java, Perl, C++, Python, VB, COM, XSLT). =item * Provides COM interface. Single dll (standalone [2.5MB] or minimal [32kB]). Works on Windows 9x/Me/NT/2K. Doesn't require ROPE or MSXML. Examples in VB, Excel/VBA, C#, ASP, JavaScript, PerlScript and Perl. =item * Provides transparent compression support for HTTP transport. =item * Provides mod_soap module. Make SOAP server with a few lines in .htaccess or .conf file. =item * Includes XML::Parser::Lite (regexp-based XML parser) which runs instead of XML::Parser where Perl 5.6 runs (even on WinCE) with some limitations. =item * Includes XMLRPC::Lite, implementation of XML-RPC protocol on client and server side. All transports and features of SOAP::Lite are available. =item * Supports multipart/form-data MIME attachments. =item * Supports circular linked lists and multiple references. =item * Supports Map datatype (encoding of maps/hashes with arbitrary keys). =item * Supports HTTPS protocol. =item * Provides proxy support. =item * Provides CGI/daemon/mod_perl/Apache::Registry server implementations. =item * Provides TCP server implementation. =item * Provides IO (STDIN/STDOUT/File) server implementation. =item * Provides FTP client implementation. =item * Supports single/multipart MIME attachment (parsing side only). =item * Supports SMTP protocol. =item * Provides POP3 server implementation. =item * Supports M-POST and redirects in HTTP transport. =item * Supports Basic/Digest server authentication. =item * Works with CGI accelerators, like VelociGen and PerlEx. =item * Supports UDDI interface on client side. See UDDI::Lite for details. =item * Supports UDDI publishing API. Examples and documentation provided. =item * Supports WSDL schema with stub and run-time access. =item * Supports blessed object references. =item * Supports arrays (both serialization and deserialization with autotyping). =item * Supports custom serialization. =item * Provides exception transport with custom exceptions =item * Supports Base64 encoding. =item * Supports XML entity encoding. =item * Supports header attributes. =item * Supports dynamic and static class/method binding. =item * Supports objects-by-reference with simple garbage collection and activation. =item * Provides shell for interactive SOAP sessions. =item * Supports out parameters binding. =item * Supports transparent SOAP calls with autodispatch feature. =item * Provides easy services deployment. Put module in specified directory and it'll be accessible. =item * Has tests, examples and documentation to let you be up and running in no time. =back =head2 WHERE TO FIND EXAMPLES See F, F and the module documentation for a client-side examples that demonstrate the serialization of a SOAP request, sending it via HTTP to the server and receiving the response, and the deserialization of the response. See F for server-side implementations. =head1 OVERVIEW OF CLASSES AND PACKAGES This table should give you a quick overview of the classes provided by the library. SOAP::Lite.pm -- SOAP::Lite -- Main class provides all logic -- SOAP::Transport -- Supports transport architecture -- SOAP::Data -- Provides extensions for serialization architecture -- SOAP::Header -- Provides extensions for header serialization -- SOAP::Parser -- Parses XML file into object tree -- SOAP::Serializer -- Serializes data structures to SOAP package -- SOAP::Deserializer -- Deserializes results of SOAP::Parser into objects -- SOAP::SOM -- Provides access to deserialized object tree -- SOAP::Constants -- Provides access to common constants -- SOAP::Trace -- Provides tracing facilities -- SOAP::Schema -- Provides access and stub(s) for schema(s) -- SOAP::Schema::WSDL -- WSDL implementation for SOAP::Schema -- SOAP::Server -- Handles requests on server side -- SOAP::Server::Object -- Handles objects-by-reference -- SOAP::Fault -- Provides support for Faults on server side SOAP::Transport::HTTP.pm -- SOAP::Transport::HTTP::Client -- Client interface to HTTP transport -- SOAP::Transport::HTTP::Server -- Server interface to HTTP transport -- SOAP::Transport::HTTP::CGI -- CGI implementation of server interface -- SOAP::Transport::HTTP::Daemon -- Daemon implementation of server interface -- SOAP::Transport::HTTP::Apache -- mod_perl implementation of server interface SOAP::Transport::POP3.pm -- SOAP::Transport::POP3::Server -- Server interface to POP3 protocol SOAP::Transport::MAILTO.pm -- SOAP::Transport::MAILTO::Client -- Client interface to SMTP/sendmail SOAP::Transport::LOCAL.pm -- SOAP::Transport::LOCAL::Client -- Client interface to local transport SOAP::Transport::TCP.pm -- SOAP::Transport::TCP::Server -- Server interface to TCP protocol -- SOAP::Transport::TCP::Client -- Client interface to TCP protocol SOAP::Transport::IO.pm -- SOAP::Transport::IO::Server -- Server interface to IO transport =head2 SOAP::Lite All methods that C provides can be used for both setting and retrieving values. If you provide no parameters, you will get current value, and if parameters are provided, a new value will be assigned to the object and the method in question will return the current object (if not stated otherwise). This is suitable for stacking these calls like: $lite = SOAP::Lite -> uri('http://simon.fell.com/calc') -> proxy('http://soap.4s4c.com/ssss4c/soap.asp') ; The order is insignificant and you may call the new() method first. If you don't do it, SOAP::Lite will do it for you. However, the new() method gives you an additional syntax: $lite = new SOAP::Lite uri => 'http://simon.fell.com/calc', proxy => 'http://soap.4s4c.com/ssss4c/soap.asp' ; =over 4 =item new() new() accepts a hash with method names as keys. It will call the appropriate methods together with the passed values. Since new() is optional it won't be mentioned anymore. =item transport() Provides access to the L object. The object will be created for you. You can reassign it (but generally you should not). =item serializer() Provides access to the L object. The object will be created for you. You can reassign it (but generally you should not). =item proxy() Shortcut for C<< transport->proxy() >>. This lets you specify an endpoint (service address) and also loads the required module at the same time. It is required for dispatching SOAP calls. The name of the module will be defined depending on the protocol specific for the endpoint. The prefix C will be prepended, the module will be loaded and object of class (with appended C<::Client>) will be created. For example, for F, the class for creating objects will look for C; In addition to endpoint parameter, proxy() can accept any transport specific parameters that could be passed as name => value pairs. For example, to specify proxy settings for HTTP protocol you may do: $soap->proxy('http://endpoint.server/', proxy => ['http' => 'http://my.proxy.server/']); Notice that since proxy (second one) expects to get more than one parameter you should wrap them in array. Another useful example can be the client that is sensitive to cookie-based authentication. You can provide this with: $soap->proxy('http://localhost/', cookie_jar => HTTP::Cookies->new(ignore_discard => 1)); You may specify timeout for HTTP transport with following code: $soap->proxy('http://localhost/', timeout => 5); =item endpoint() Lets you specify an endpoint B changing/loading the protocol module. This is useful for switching endpoints without switching protocols. You should call C first. No checks for protocol equivalence will be made. =item outputxml() Lets you specify the kind of output from all method calls. If C, all methods will return unprocessed, raw XML code. You can parse it with XML::Parser, SOAP::Deserializer or any other appropriate module. =item autotype() Shortcut for C<< serializer->autotype() >>. This lets you specify whether the serializer will try to make autotyping for you or not. Default setting is C. =item readable() Shortcut for C<< serializer->readable() >>. This lets you specify the format for the generated XML code. Carriage returns and indentation will be added for readability. Useful in the case you want to see the generated code in a debugger. By default, there are no additional characters in generated XML code. =item namespace() Shortcut for C<< serializer->namespace() >>. This lets you specify the default namespace for generated envelopes (C<'SOAP-ENV'> by default). =item encodingspace() Shortcut for C<< serializer->encodingspace() >>. This lets you specify the default encoding namespace for generated envelopes (C<'SOAP-ENC'> by default). =item encoding() Shortcut for C<< serializer->encoding() >>. This lets you specify the encoding for generated envelopes. It does not actually change envelope encoding, it will just modify the XML declaration (C<'UTF-8'> by default). Use C value to B generate XML declaration. =item typelookup() Shortcut for C<< serializer->typelookup() >>. This gives you access to the C table that is used for autotyping. For more information see L. =item uri() Shortcut for C<< serializer->uri() >>. This lets you specify the uri for SOAP methods. Nothing is specified by default and your call will definitely fail if you don't specify the required uri. B: URIs are just identifiers. They may B, but they are not guaranteed to point to anywhere and shouldn't be used as such pointers. URIs assume to be unique within the space of all XML documents, so consider them as unique identifiers and nothing else. =item multirefinplace() Shortcut for C<< serializer->multirefinplace() >>. If true, the serializer will put values for multireferences in the first occurrence of the reference. Otherwise it will be encoded as top independent element, right after C element inside C. Default value is C. =item header() B: Use SOAP::Header instead. Shortcut for C<< serializer->header() >>. This lets you specify the header for generated envelopes. You can specify C, C or any other header using L class: $serializer = SOAP::Serializer->envelope('method' => 'mymethod', 1, SOAP::Header->name(t1 => 5)->mustUnderstand(1), SOAP::Header->name(t2 => 7)->mustUnderstand(2), ); will be serialized into: 5 7 1 You can mix C parameters with other parameters and you can also return C parameters as a result of a remote call. They will be placed into the header. See C as an example. =item on_action() This lets you specify a handler for C. It is triggered when creating SOAPAction. The default handler will set SOAPAction to C<"uri#method">. You can change this behavior globally (see L) or locally, for a particular object. =item on_fault() This lets you specify a handler for C event. The default behavior is to B on an transport error and to B on other error conditions. You may change this behavior globally (see L) or locally, for a particular object. =item on_debug() This lets you specify a handler for C. Default behavior is to do nothing. Use C<+trace/+debug> option for SOAP::Lite instead. If you use if be warned that since this method is just interface to C<+trace/+debug> it has B effect, so if you install it for one object it'll be in effect for all subsequent calls (even for other objects). =item on_nonserialized() This lets you specify a handler for C. The default behavior is to produce a warning if warnings are on for everything that cannot be properly serialized (like CODE references or GLOBs). =item call() Provides alternative interface for remote method calls. You can always run C<< SOAP::Lite->new(...)->method(@parameters) >>, but call() gives you several additional options: =over 4 =item prefixed method If you want to specify prefix for generated method's element one of the available options is do it with call() interface: print SOAP::Lite -> new(....) -> call('myprefix:method' => @parameters) -> result; This example will work on client side only. If you want to change prefix on server side you should override default serializer. See F for examples. =item access to any method If for some reason you want to get access to remote procedures that have the same name as methods of SOAP::Lite object these calls (obviously) won't be dispatched. In that case you can originate your call trough call(): print SOAP::Lite -> new(....) -> call(new => @parameters) -> result; =item implementation of OO interface With L you can make CLASS/OBJECT calls like: my $obj = CLASS->new(@parameters); print $obj->method; However, because of side effects L has, it's not always possible to use this syntax. call() provides you with alternative: # you should specify uri() my $soap = SOAP::Lite -> uri('http://my.own.site/CLASS') # <<< CLASS goes here # ..... other parameters ; my $obj = $soap->call(new => @parameters)->result; print $soap->call(method => $obj)->result; # $obj object will be updated here if necessary, # as if you call $obj->method() and method() updates $obj # Update of modified object MAY not work if server on another side # is not SOAP::Lite =item ability to set method's attributes Additionally this syntax lets you specify attributes for method element: print SOAP::Lite -> new(....) -> call(SOAP::Data->name('method')->attr({xmlns => 'mynamespace'}) => @parameters) -> result; You can specify B attibutes and C of C element becomes name of method. Everything else except attributes is ignored and parameters should be provided as usual. Be warned, that though you have more control using this method, you B specify namespace attribute for method explicitely, even if you made uri() call earlier. So, if you have to have namespace on method element, instead of: print SOAP::Lite -> new(....) -> uri('mynamespace') # will be ignored -> call(SOAP::Data->name('method') => @parameters) -> result; do print SOAP::Lite -> new(....) -> call(SOAP::Data->name('method')->attr({xmlns => 'mynamespace'}) => @parameters) -> result; because in the former call uri() will be ignored and namespace won't be specified. If you run script with C<-w> option (as recommended) SOAP::Lite gives you a warning: URI is not provided as attribute for method (method) Moreover, it'll become fatal error if you try to call it with prefixed name: print SOAP::Lite -> new(....) -> uri('mynamespace') # will be ignored -> call(SOAP::Data->name('a:method') => @parameters) -> result; gives you: Can't find namespace for method (a:method) because nothing is associated with prefix C<'a'>. =back One more comment. One case when SOAP::Lite will change something that you specified is when you specified prefixed name and empty namespace name: print SOAP::Lite -> new(....) -> uri('') -> call('a:method' => @parameters) -> result; This code will generate: .... instead of .... because later is not allowed according to XML Namespace specification. In all other aspects C<< ->call(mymethod => @parameters) >> is just a synonim for C<< ->mymethod(@parameters) >>. =item self() Returns object reference to B defaul object specified with C interface. Both class method and object method return reference to B object, so: use SOAP::Lite proxy => 'http://my.global.server' ; my $soap = SOAP::Lite->proxy('http://my.local.server'); print $soap->self->proxy; prints C<'http://my.global.server'> (the same as C<< SOAP::Lite->self->proxy >>). See L for more information. =item dispatch_from() Does exactly the same as L does, but doesn't install UNIVERSAL::AUTOLOAD handler and only install AUTOLOAD handlers in specified classes. Can be used only with C clause and should be specified first: use SOAP::Lite dispatch_from => ['A', 'B'], # use "dispatch_from => 'A'" for one class uri => ...., proxy => ...., ; A->a; B->b; =back =head2 SOAP::Data You can use this class if you want to specify a value, a name, atype, a uri or attributes for SOAP elements (use C, C, C, C and C methods correspondingly). For example, C<< SOAP::Data->name('abc')->value(123) >> will be serialized into C<< 123 >>, as well as will C<< SOAP::Data->name(abc => 123) >>. Each of them (except the value() method) can accept a value as the second parameter. All methods return the current value if you call them without parameters. The return the object otherwise, so you can stack them. See tests for more examples. You can import these methods with: SOAP::Data->import('name'); or import SOAP::Data 'name'; and then use C<< name(abc => 123) >> for brevity. An interface for specific attributes is also provided. You can use the C, C, C and C methods to set/get values of the correspondent attributes. SOAP::Data ->name(c => 3) ->encodingStyle('http://xml.apache.org/xml-soap/literalxml') will be serialized into: 3 =head2 SOAP::Serializer Usually you don't need to interact directly with this module. The only case when you need it, it when using autotyping. This feature lets you specify types for your data according to your needs as well as to introduce new data types (like ordered hash for example). You can specify a type with C<< SOAP::Data->type(float => 123) >>. During the serialization stage the module will try to serialize your data with the C method. It then calls the C method (you can override it or inherit your own class from L) and only then it will try to serialize it according to data type (C, C or C). For example: SOAP::Data->type('ordered_hash' => [a => 1, b => 2]) will be serialized as an ordered hash, using the C method. If you do not specify a type directly, the serialization module will try to autodefine the type for you according to the C hash. It contains the type name as key and the following 3-element array as value: priority, check_function (CODE reference), typecast function (METHOD name or CODE reference) For example, if you want to add C to autodefined types, you should add something like this: $s->typelookup->{uriReference} = [11, sub { $_[0] =~ m!^http://! }, 'as_uriReference']; and add the C method to the L class: sub SOAP::Serializer::as_uriReference { my $self = shift; my($value, $name, $type, $attr) = @_; return [$name, {'xsi:type' => 'xsd:uriReference', %$attr}, $value]; } The specified methods will work for both autotyping and direct typing, so you can use either SOAP::Data->type(uriReference => 'http://yahoo.com')> or just 'http://yahoo.com' and it will be serialized into the same type. For more examples see C methods in L. The SOAP::Serializer provides you with C, C, C, C, C, C, C, C and C methods. All methods (except C) are described in the L section. =over 4 =item envelope() This method allows you to build three kind of envelopes depending on the first parameter: =over 4 =item method envelope(method => 'methodname', @parameters); or method('methodname', @parameters); Lets you build a request/response envelope. =item fault envelope(fault => 'faultcode', 'faultstring', $details); or fault('faultcode', 'faultstring', $details); Lets you build a fault envelope. Faultcode will be properly qualified and details could be string or object. =item freeform envelope(freeform => 'something that I want to serialize'); or freeform('something that I want to serialize'); Reserved for nonRPC calls. Lets you build your own payload inside a SOAP envelope. All SOAP 1.1 specification rules are enforced, except method specific ones. See UDDI::Lite as example. =back =back For more examples see tests and SOAP::Transport::HTTP.pm =head2 SOAP::SOM All calls you are making through object oriented interface will return SOAP::SOM object, and you can access actual values with it. Next example gives you brief overview of the class: my $soap = SOAP::Lite .....; my $som = $soap->method(@parameters); if ($som->fault) { # will be defined if Fault element is in the message print $som->faultdetail; # returns value of 'detail' element as # string or object $som->faultcode; # $som->faultstring; # also available $som->faultactor; # } else { $som->result; # gives you access to result of call # it could be any data structure, for example reference # to array if server didi something like: return [1,2]; $som->paramsout; # gives you access to out parameters if any # for example, you'll get array (1,2) if # server returns ([1,2], 1, 2); # [1,2] will be returned as $som->result # and $som->paramsall will return ([1,2], 1, 2) # see section IN/OUT, OUT PARAMETERS AND AUTOBINDING # for more information $som->paramsall; # gives access to result AND out parameters (if any) # and returns them as one array $som->valueof('//myelement'); # returns value(s) (as perl data) of # 'myelement' if any. All elements in array # context and only first one in scalar $h = $som->headerof('//myheader'); # returns element as SOAP::Header, so # you can access attributes and values # with $h->mustUnderstand, $h->actor # or $h->attr (for all attributes) } SOAP::SOM object gives you access to the deserialized envelope via several methods. All methods accept a node path (similar to XPath notations). SOM interprets '/' as the root node, '//' as relative location path ('//Body' will find all bodies in document, as well as '/Envelope//nums' will find all 'nums' nodes under Envelope node), '[num]' as node number and '[op num]' with C being a comparison operator ('<', '>', '<=', '>=', '!', '='). All nodes in nodeset will be returned in document order. =over 4 =item match() Accepts a path to a node and returns true/false in a boolean context and a SOM object otherwise. C and C can be used to get value(s) of matched node(s). =item valueof() Returns the value of a (previously) matched node. It accepts a node path. In this case, it returns the value of matched node, but does not change the current node. Suitable when you want to match a node and then navigate through node children: $som->match('/Envelope/Body/[1]'); # match method $som->valueof('[1]'); # result $som->valueof('[2]'); # first out parameter (if present) The returned value depends on the context. In a scalar context it will return the first element from matched nodeset. In an array context it will return all matched elements. =item dataof() Same as C, but it returns a L object, so you can get access to the name, the type and attributes of an element. =item headerof() Same as C, but it returns L object, so you can get access to the name, the type and attributes of an element. Can be used for modifying headers (if you want to see updated header inside Header element, it's better to use this method instead of C method). =item namespaceuriof() Returns the uri associated with the matched element. This uri can also be inherited, for example, if you have value this method will return same value for 'b' element as for 'a'. =back SOAP::SOM also provides methods for direct access to the envelope, the body, methods and parameters (both in and out). All these methods return real values (in most cases it will be a hash reference), if called as object method. Returned values also depend on context: in an array context it will return an array of values and in scalar context it will return the first element. So, if you want to access the first output parameter, you can call C<< $param = $som->paramsout >>; and you will get it regardless of the actual number of output parameters. If you call it as class function (for example, SOAP::SOM::method) it returns an XPath string that matches the current element ('/Envelope/Body/[1]' in case of 'method'). The method will return C if not present OR if you try to access an undefined element. To distinguish between these two cases you can first access the C method that will return true/false in a boolean context and then get the real value: if ($som->match('//myparameter')) { $value = $som->valueof; # can be undef too } else { # doesn't exist } =over 4 =item root() Returns the value (as hash) of the root element. Do exactly the same as C<< $som->valueof('/') >> does. =item envelope() Returns the value (as hash) of the C element. Keys in this hash will be 'Header' (if present), 'Body' and any other (optional) elements. Values will be the deserialized header, body, and elements, respectively. If called as function (C) it will return a Xpath string that matches the envelope content. Useful when you want just match it and then iterate over the content by yourself. Example: if ($som->match(SOAP::SOM::envelope)) { $som->valueof('Header'); # sho