X-Git-Url: http://www.project-moonshot.org/gitweb/?a=blobdiff_plain;f=saml%2Fsaml1%2Fbinding%2Fimpl%2FSAML1ArtifactDecoder.cpp;h=12552ad4b8a08b0477465a05eb82f962177ce85d;hb=40fdf576ed07e3cf8f88d9bf0441e55ea4fc3d05;hp=70cee0faa44de1dffd97ee735a11491e0a4c52f2;hpb=8a21bb42163a78e9c324f840004fd9e9821ad745;p=shibboleth%2Fcpp-opensaml.git diff --git a/saml/saml1/binding/impl/SAML1ArtifactDecoder.cpp b/saml/saml1/binding/impl/SAML1ArtifactDecoder.cpp index 70cee0f..12552ad 100644 --- a/saml/saml1/binding/impl/SAML1ArtifactDecoder.cpp +++ b/saml/saml1/binding/impl/SAML1ArtifactDecoder.cpp @@ -1,6 +1,6 @@ /* - * Copyright 2001-2006 Internet2 - * + * Copyright 2001-2010 Internet2 + * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at @@ -16,41 +16,59 @@ /** * SAML1ArtifactDecoder.cpp - * + * * SAML 1.x Artifact binding/profile message decoder */ #include "internal.h" #include "exceptions.h" -#include "binding/HTTPRequest.h" -#include "saml/binding/SAMLArtifact.h" -#include "saml1/binding/SAML1ArtifactDecoder.h" +#include "binding/SAMLArtifact.h" +#include "binding/SecurityPolicy.h" +#include "saml1/binding/SAML1MessageDecoder.h" +#include "saml1/core/Protocols.h" #include "saml2/metadata/Metadata.h" #include "saml2/metadata/MetadataProvider.h" -#include +#include +#include +#include #include #include using namespace opensaml::saml2md; using namespace opensaml::saml1p; using namespace opensaml; +using namespace xmltooling::logging; using namespace xmltooling; -using namespace log4cpp; using namespace std; namespace opensaml { - namespace saml1p { - MessageDecoder* SAML_DLLLOCAL SAML1ArtifactDecoderFactory(const DOMElement* const & e) + namespace saml1p { + class SAML_DLLLOCAL SAML1ArtifactDecoder : public SAML1MessageDecoder + { + public: + SAML1ArtifactDecoder() {} + virtual ~SAML1ArtifactDecoder() {} + + const char* getShortName() const { + return "Artifact"; + } + + xmltooling::XMLObject* decode( + std::string& relayState, + const GenericRequest& genericRequest, + SecurityPolicy& policy + ) const; + }; + + MessageDecoder* SAML_DLLLOCAL SAML1ArtifactDecoderFactory(const pair& p) { - return new SAML1ArtifactDecoder(e); + return new SAML1ArtifactDecoder(); } }; }; -SAML1ArtifactDecoder::SAML1ArtifactDecoder(const DOMElement* e) {} - -Response* SAML1ArtifactDecoder::decode( +XMLObject* SAML1ArtifactDecoder::decode( string& relayState, const GenericRequest& genericRequest, SecurityPolicy& policy @@ -63,16 +81,12 @@ Response* SAML1ArtifactDecoder::decode( log.debug("validating input"); const HTTPRequest* httpRequest=dynamic_cast(&genericRequest); - if (!httpRequest) { - log.error("unable to cast request to HTTPRequest type"); - return NULL; - } - if (strcmp(httpRequest->getMethod(),"GET")) - return NULL; + if (!httpRequest) + throw BindingException("Unable to cast request object to HTTPRequest type."); vector SAMLart; const char* TARGET = httpRequest->getParameter("TARGET"); if (httpRequest->getParameters("SAMLart", SAMLart)==0 || !TARGET) - return NULL; + throw BindingException("Request missing SAMLart or TARGET query string parameters."); relayState = TARGET; if (!m_artifactResolver || !policy.getMetadataProvider() || !policy.getRole()) @@ -83,11 +97,11 @@ Response* SAML1ArtifactDecoder::decode( for (vector::const_iterator raw=SAMLart.begin(); raw!=SAMLart.end(); ++raw) { try { log.debug("processing encoded artifact (%s)", *raw); - + // Check replay. ReplayCache* replayCache = XMLToolingConfig::getConfig().getReplayCache(); if (replayCache) { - if (!replayCache->check("SAML1Artifact", *raw, time(NULL) + (2*XMLToolingConfig::getConfig().clock_skew_secs))) { + if (!replayCache->check("SAML1Artifact", *raw, time(nullptr) + (2*XMLToolingConfig::getConfig().clock_skew_secs))) { log.error("replay detected of artifact (%s)", *raw); throw BindingException("Rejecting replayed artifact ($1).", params(1,*raw)); } @@ -107,10 +121,15 @@ Response* SAML1ArtifactDecoder::decode( throw; } } - + log.debug("attempting to determine source of artifact(s)..."); - const EntityDescriptor* provider=policy.getMetadataProvider()->getEntityDescriptor(artifacts.front()); - if (!provider) { + MetadataProvider::Criteria& mc = policy.getMetadataProviderCriteria(); + mc.artifact = artifacts.front(); + mc.role = policy.getRole(); + mc.protocol = samlconstants::SAML11_PROTOCOL_ENUM; + mc.protocol2 = samlconstants::SAML10_PROTOCOL_ENUM; + pair provider=policy.getMetadataProvider()->getEntityDescriptor(mc); + if (!provider.first) { log.error( "metadata lookup failed, unable to determine issuer of artifact (0x%s)", SAMLArtifact::toHex(artifacts.front()->getBytes()).c_str() @@ -118,36 +137,34 @@ Response* SAML1ArtifactDecoder::decode( for_each(artifacts.begin(), artifacts.end(), xmltooling::cleanup()); throw BindingException("Metadata lookup failed, unable to determine artifact issuer"); } - + if (log.isDebugEnabled()) { - auto_ptr_char issuer(provider->getEntityID()); - log.debug("lookup succeeded, artifact issued by (%s)", issuer.get()); + auto_ptr_char issuer(provider.first->getEntityID()); + log.debug("artifact issued by (%s)", issuer.get()); } - - log.debug("attempting to find artifact issuing role..."); - const RoleDescriptor* roledesc=provider->getRoleDescriptor(*(policy.getRole()), samlconstants::SAML11_PROTOCOL_ENUM); - if (!roledesc) - roledesc=provider->getRoleDescriptor(*(policy.getRole()), samlconstants::SAML10_PROTOCOL_ENUM); - if (!roledesc || !dynamic_cast(roledesc)) { - log.error("unable to find compatible SAML role (%s) in metadata", policy.getRole()->toString().c_str()); + + if (!provider.second || !dynamic_cast(provider.second)) { + log.error("unable to find compatible SAML 1.x role (%s) in metadata", policy.getRole()->toString().c_str()); for_each(artifacts.begin(), artifacts.end(), xmltooling::cleanup()); - BindingException ex("Unable to find compatible metadata role for artifact issuer."); - annotateException(&ex,provider); // throws it + throw BindingException("Unable to find compatible metadata role for artifact issuer."); } - + // Set Issuer for the policy. + policy.setIssuer(provider.first->getEntityID()); + policy.setIssuerMetadata(provider.second); + try { + log.debug("calling ArtifactResolver..."); auto_ptr response( - m_artifactResolver->resolve(artifacts, dynamic_cast(*roledesc), policy) + m_artifactResolver->resolve(artifacts, dynamic_cast(*provider.second), policy) ); - - policy.evaluate(genericRequest, *(response.get())); - + + // The policy should be enforced against the Response by the resolve step. + for_each(artifacts.begin(), artifacts.end(), xmltooling::cleanup()); return response.release(); } - catch (XMLToolingException& ex) { + catch (XMLToolingException&) { for_each(artifacts.begin(), artifacts.end(), xmltooling::cleanup()); - annotateException(&ex,roledesc,false); throw; } }