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

Collaboration diagram for kcenon::pacs::ihe::xds::registry_query::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< registry_query_result >	find_documents (const std::string &patient_id, const registry_query_options &options)
kcenon::common::Result< registry_query_result >	get_documents (const std::vector< std::string > &uuids)

Private Member Functions
kcenon::common::Result< registry_query_result >	execute (const registry_query_request &req, detail::stored_query_kind kind)
void	audit_find (const std::string &patient_id, const kcenon::common::Result< registry_query_result > &r)
void	audit_get (const std::vector< std::string > &uuids, const kcenon::common::Result< registry_query_result > &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 76 of file registry_query.cpp.

Constructor & Destructor Documentation

impl()

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

inline

Definition at line 78 of file registry_query.cpp.

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

Member Function Documentation

audit_find()

void kcenon::pacs::ihe::xds::registry_query::impl::audit_find ( const std::string & patient_id, const kcenon::common::Result< registry_query_result > & r )

inlineprivate

Definition at line 231 of file registry_query.cpp.

                                                                        {
        if (!audit_sink_) return;
        kcenon::pacs::security::xds_iti18_event e;
        e.registry_endpoint = opts_.endpoint;
        e.query_kind =
            kcenon::pacs::security::xds_iti18_event::kind::find_documents;
        e.patient_id = patient_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_iti18_query(e);
    }

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

Referenced by find_documents().

Here is the caller graph for this function:

audit_get()

void kcenon::pacs::ihe::xds::registry_query::impl::audit_get ( const std::vector< std::string > & uuids, const kcenon::common::Result< registry_query_result > & r )

inlineprivate

Definition at line 249 of file registry_query.cpp.

                                                                       {
        if (!audit_sink_) return;
        kcenon::pacs::security::xds_iti18_event e;
        e.registry_endpoint = opts_.endpoint;
        e.query_kind =
            kcenon::pacs::security::xds_iti18_event::kind::get_documents;
        e.document_uuids = uuids;
        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_iti18_query(e);
    }

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

Referenced by get_documents().

Here is the caller graph for this function:

execute()

kcenon::common::Result< registry_query_result > kcenon::pacs::ihe::xds::registry_query::impl::execute ( const registry_query_request & req, detail::stored_query_kind kind )

inlineprivate

Definition at line 183 of file registry_query.cpp.

                                      {
        auto env_result = detail::build_iti18_envelope(req, kind);
        if (env_result.is_err()) {
            return kcenon::common::make_error<registry_query_result>(
                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 kcenon::common::make_error<registry_query_result>(
                sign_result.error());
        }
 
        // Per-call copy: the ITI-18 action is specific to this transaction
        // and must not mutate the shared opts_ member, so other transaction
        // types sharing the same http_options template do not pick up a
        // stale action from a previous call.
        http_options call_opts = opts_;
        call_opts.soap_action = kIti18SoapAction;
 
        auto http_result =
            detail::http_post(call_opts, kSoapContentType, env.xml);
        if (http_result.is_err()) {
            return kcenon::common::make_error<registry_query_result>(
                http_result.error());
        }
        auto response = http_result.value();
 
        // Verify the signature on the response envelope before trusting
        // its status attribute or any entry it carries. An unsigned
        // "Failure" response could otherwise be used to deny service or
        // mask real successful queries; this check short-circuits before
        // parse_query_response sees the body.
        auto verify = detail::verify_envelope_integrity(response.body);
        if (verify.is_err()) {
            auto err = verify.error();
            err.code = map_signature_error(err.code);
            return kcenon::common::make_error<registry_query_result>(err);
        }
 
        return detail::parse_query_response(response.body);
    }

References kcenon::pacs::ihe::xds::detail::build_iti18_envelope(), kcenon::pacs::ihe::xds::signing_material::certificate_pem, kcenon::pacs::ihe::xds::detail::http_post(), opts_, kcenon::pacs::ihe::xds::detail::parse_query_response(), kcenon::pacs::ihe::xds::signing_material::private_key_password, kcenon::pacs::ihe::xds::signing_material::private_key_pem, 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().

Referenced by find_documents(), and get_documents().

Here is the call graph for this function:

Here is the caller graph for this function:

find_documents()

kcenon::common::Result< registry_query_result > kcenon::pacs::ihe::xds::registry_query::impl::find_documents ( const std::string & patient_id, const registry_query_options & options )

inline

Definition at line 86 of file registry_query.cpp.

                                               {
        auto do_audit =
            [&](const kcenon::common::Result<registry_query_result>& r) {
                audit_find(patient_id, r);
                return r;
            };
 
        if (patient_id.empty()) {
            return do_audit(kcenon::common::make_error<registry_query_result>(
                static_cast<int>(
                    error_code::registry_query_missing_patient_id),
                "find_documents: patient_id is empty",
                std::string(error_source)));
        }
        if (contains_slot_literal_metachar(patient_id)) {
            return do_audit(kcenon::common::make_error<registry_query_result>(
                static_cast<int>(
                    error_code::registry_query_invalid_patient_id),
                "find_documents: patient_id contains a character that is "
                "not legal inside an ebRIM StoredQuery slot literal "
                "('(),\\' or control character)",
                std::string(error_source)));
        }
        for (const auto& s : options.status_values) {
            if (contains_slot_literal_metachar(s)) {
                return do_audit(
                    kcenon::common::make_error<registry_query_result>(
                        static_cast<int>(
                            error_code::registry_query_invalid_patient_id),
                        "find_documents: options.status_values contains a "
                        "slot-literal metacharacter",
                        std::string(error_source)));
            }
        }
        if (contains_slot_literal_metachar(options.creation_time_from) ||
            contains_slot_literal_metachar(options.creation_time_to)) {
            return do_audit(kcenon::common::make_error<registry_query_result>(
                static_cast<int>(
                    error_code::registry_query_invalid_patient_id),
                "find_documents: options.creation_time_* contains a "
                "slot-literal metacharacter",
                std::string(error_source)));
        }
 
        registry_query_request req;
        req.patient_id = patient_id;
        req.options = options;
 
        return do_audit(
            execute(req, detail::stored_query_kind::find_documents));
    }

References audit_find(), kcenon::pacs::ihe::xds::registry_query_options::creation_time_from, kcenon::pacs::ihe::xds::registry_query_options::creation_time_to, kcenon::pacs::ihe::xds::error_source, execute(), kcenon::pacs::ihe::xds::detail::find_documents, kcenon::pacs::ihe::xds::registry_query_request::options, kcenon::pacs::ihe::xds::registry_query_request::patient_id, kcenon::pacs::ihe::xds::registry_query_invalid_patient_id, kcenon::pacs::ihe::xds::registry_query_missing_patient_id, and kcenon::pacs::ihe::xds::registry_query_options::status_values.

Here is the call graph for this function:

get_documents()

kcenon::common::Result< registry_query_result > kcenon::pacs::ihe::xds::registry_query::impl::get_documents ( const std::vector< std::string > & uuids )

inline

Definition at line 140 of file registry_query.cpp.

                                           {
        auto do_audit =
            [&](const kcenon::common::Result<registry_query_result>& r) {
                audit_get(uuids, r);
                return r;
            };
 
        if (uuids.empty()) {
            return do_audit(kcenon::common::make_error<registry_query_result>(
                static_cast<int>(
                    error_code::registry_query_empty_uuid_list),
                "get_documents: uuids is empty",
                std::string(error_source)));
        }
        for (const auto& u : uuids) {
            if (u.empty()) {
                return do_audit(
                    kcenon::common::make_error<registry_query_result>(
                        static_cast<int>(
                            error_code::registry_query_missing_document_uuid),
                        "get_documents: uuids contains an empty element",
                        std::string(error_source)));
            }
            if (contains_slot_literal_metachar(u)) {
                return do_audit(
                    kcenon::common::make_error<registry_query_result>(
                        static_cast<int>(
                            error_code::registry_query_missing_document_uuid),
                        "get_documents: uuids contains an element with a "
                        "slot-literal metacharacter",
                        std::string(error_source)));
            }
        }
 
        registry_query_request req;
        req.document_uuids = uuids;
 
        return do_audit(
            execute(req, detail::stored_query_kind::get_documents));
    }

References audit_get(), kcenon::pacs::ihe::xds::registry_query_request::document_uuids, kcenon::pacs::ihe::xds::error_source, execute(), kcenon::pacs::ihe::xds::detail::get_documents, kcenon::pacs::ihe::xds::registry_query_empty_uuid_list, and kcenon::pacs::ihe::xds::registry_query_missing_document_uuid.

Referenced by kcenon::pacs::ihe::xds::registry_query::get_documents().

Here is the call graph for this function:

Here is the caller graph for this function:

set_audit_sink()

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

inline

Definition at line 81 of file registry_query.cpp.

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

References audit_sink_.

Referenced by kcenon::pacs::ihe::xds::registry_query::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::registry_query::impl::audit_sink_

private

Definition at line 269 of file registry_query.cpp.

Referenced by audit_find(), audit_get(), and set_audit_sink().

opts_

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

private

Definition at line 267 of file registry_query.cpp.

Referenced by audit_find(), audit_get(), and execute().

signing_

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

private

Definition at line 268 of file registry_query.cpp.

Referenced by execute().

---

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

• src/ihe/xds/registry_query.cpp