kcenon::pacs::ihe::xds::document_consumer::impl Class Reference

Collaboration diagram for kcenon::pacs::ihe::xds::document_consumer::impl:

Public Member Functions
	impl (http_options opts, signing_material signing)
void	set_audit_sink (std::shared_ptr< kcenon::pacs::security::xds_audit_sink > sink)
kcenon::common::Result< document_response >	retrieve (const std::string &document_unique_id, const std::string &repository_unique_id)

Private Member Functions
void	audit (const std::string &document_unique_id, const std::string &repository_unique_id, const kcenon::common::Result< document_response > &r)

Private Attributes
http_options	opts_
signing_material	signing_
std::shared_ptr< kcenon::pacs::security::xds_audit_sink >	audit_sink_

Detailed Description

Definition at line 44 of file document_consumer.cpp.

Constructor & Destructor Documentation

impl()

kcenon::pacs::ihe::xds::document_consumer::impl::impl ( http_options opts, signing_material signing )

inline

Definition at line 46 of file document_consumer.cpp.

        : opts_(std::move(opts)), signing_(std::move(signing)) {}

Member Function Documentation

audit()

void kcenon::pacs::ihe::xds::document_consumer::impl::audit ( const std::string & document_unique_id, const std::string & repository_unique_id, const kcenon::common::Result< document_response > & r )

inlineprivate

Definition at line 132 of file document_consumer.cpp.

                                                               {
        if (!audit_sink_) return;
        kcenon::pacs::security::xds_iti43_event e;
        e.source_endpoint = opts_.endpoint;
        e.document_unique_id = document_unique_id;
        e.repository_unique_id = repository_unique_id;
        if (r.is_ok()) {
            e.outcome = kcenon::pacs::security::atna_event_outcome::success;
        } else {
            e.outcome =
                kcenon::pacs::security::atna_event_outcome::serious_failure;
            e.failure_description = r.error().message;
        }
        audit_sink_->on_iti43_retrieve(e);
    }

References audit_sink_, kcenon::pacs::ihe::xds::http_options::endpoint, opts_, kcenon::pacs::security::serious_failure, and kcenon::pacs::security::success.

Referenced by retrieve().

Here is the caller graph for this function:

retrieve()

kcenon::common::Result< document_response > kcenon::pacs::ihe::xds::document_consumer::impl::retrieve ( const std::string & document_unique_id, const std::string & repository_unique_id )

inline

Definition at line 54 of file document_consumer.cpp.

                                               {
        auto do_audit =
            [&](const kcenon::common::Result<document_response>& r) {
                audit(document_unique_id, repository_unique_id, r);
                return r;
            };
 
        if (document_unique_id.empty()) {
            return do_audit(kcenon::common::make_error<document_response>(
                static_cast<int>(
                    error_code::consumer_retrieve_missing_document_id),
                "retrieve: document_unique_id is empty",
                std::string(error_source)));
        }
        if (repository_unique_id.empty()) {
            return do_audit(kcenon::common::make_error<document_response>(
                static_cast<int>(
                    error_code::consumer_retrieve_missing_repository_id),
                "retrieve: repository_unique_id is empty",
                std::string(error_source)));
        }
 
        retrieve_request req;
        req.document_unique_id = document_unique_id;
        req.repository_unique_id = repository_unique_id;
 
        auto env_result = detail::build_iti43_envelope(req);
        if (env_result.is_err()) {
            return do_audit(kcenon::common::make_error<document_response>(
                env_result.error()));
        }
        auto env = env_result.value();
 
        auto sign_result = detail::sign_envelope(
            env, signing_.certificate_pem, signing_.private_key_pem,
            signing_.private_key_password);
        if (sign_result.is_err()) {
            return do_audit(kcenon::common::make_error<document_response>(
                sign_result.error()));
        }
 
        // Per-call copy: the ITI-43 SOAP action is specific to this
        // transaction and must not mutate the shared opts_ member, so
        // other transaction types - if this Consumer later grows more
        // retrieve variants - cannot pick up a stale action from a
        // previous call. This also preserves whatever the caller set.
        http_options call_opts = opts_;
        call_opts.soap_action = kIti43SoapAction;
 
        auto http_result =
            detail::http_post(call_opts, kSoapContentType, env.xml);
        if (http_result.is_err()) {
            return do_audit(kcenon::common::make_error<document_response>(
                http_result.error()));
        }
        auto response = http_result.value();
 
        auto parsed =
            detail::parse_mtom_response(response.content_type, response.body);
        if (parsed.is_err()) {
            return do_audit(kcenon::common::make_error<document_response>(
                parsed.error()));
        }
        auto mtom = parsed.value();
 
        auto verify = detail::verify_envelope_integrity(mtom.root_xml);
        if (verify.is_err()) {
            return do_audit(kcenon::common::make_error<document_response>(
                verify.error()));
        }
 
        return do_audit(detail::parse_retrieve_response(
            mtom.root_xml, mtom.parts, req));
    }

References audit(), kcenon::pacs::ihe::xds::detail::build_iti43_envelope(), kcenon::pacs::ihe::xds::signing_material::certificate_pem, kcenon::pacs::ihe::xds::consumer_retrieve_missing_document_id, kcenon::pacs::ihe::xds::consumer_retrieve_missing_repository_id, kcenon::pacs::ihe::xds::retrieve_request::document_unique_id, kcenon::pacs::ihe::xds::error_source, kcenon::pacs::ihe::xds::detail::http_post(), opts_, kcenon::pacs::ihe::xds::detail::parse_mtom_response(), kcenon::pacs::ihe::xds::detail::parse_retrieve_response(), kcenon::pacs::ihe::xds::signing_material::private_key_password, kcenon::pacs::ihe::xds::signing_material::private_key_pem, kcenon::pacs::ihe::xds::retrieve_request::repository_unique_id, kcenon::pacs::ihe::xds::detail::sign_envelope(), signing_, kcenon::pacs::ihe::xds::http_options::soap_action, and kcenon::pacs::ihe::xds::detail::verify_envelope_integrity().

Here is the call graph for this function:

set_audit_sink()

void kcenon::pacs::ihe::xds::document_consumer::impl::set_audit_sink ( std::shared_ptr< kcenon::pacs::security::xds_audit_sink > sink )

inline

Definition at line 49 of file document_consumer.cpp.

                                                              {
        audit_sink_ = std::move(sink);
    }

References audit_sink_.

Referenced by kcenon::pacs::ihe::xds::document_consumer::set_audit_sink().

Here is the caller graph for this function:

Member Data Documentation

audit_sink_

std::shared_ptr<kcenon::pacs::security::xds_audit_sink> kcenon::pacs::ihe::xds::document_consumer::impl::audit_sink_

private

Definition at line 152 of file document_consumer.cpp.

Referenced by audit(), and set_audit_sink().

opts_

http_options kcenon::pacs::ihe::xds::document_consumer::impl::opts_

private

Definition at line 150 of file document_consumer.cpp.

Referenced by audit(), and retrieve().

signing_

signing_material kcenon::pacs::ihe::xds::document_consumer::impl::signing_

private

Definition at line 151 of file document_consumer.cpp.

Referenced by retrieve().

---

The documentation for this class was generated from the following file:

• src/ihe/xds/document_consumer.cpp