Mock Azure Blob client for testing without Azure SDK dependency. More...

Inheritance diagram for kcenon::pacs::storage::mock_azure_client:

Collaboration diagram for kcenon::pacs::storage::mock_azure_client:

Classes
struct	blob_data

Public Member Functions
	mock_azure_client (const azure_storage_config &)

auto	put_blob (const std::string &blob_name, const std::vector< std::uint8_t > &data) -> VoidResult override

auto	get_blob (const std::string &blob_name) -> Result< std::vector< std::uint8_t > > override

auto	delete_blob (const std::string &blob_name) -> VoidResult override

auto	head_blob (const std::string &blob_name) const -> bool override

auto	get_blob_size (const std::string &blob_name) const -> std::size_t override

auto	get_blob_etag (const std::string &blob_name) const -> std::string override

auto	get_blob_md5 (const std::string &blob_name) const -> std::string override

auto	list_blobs () const -> std::vector< std::string > override

auto	is_connected () const -> bool override

auto	stage_block (const std::string &blob_name, const std::string &block_id, const std::vector< std::uint8_t > &data) -> VoidResult override

auto	commit_blocks (const std::string &blob_name, const std::vector< std::string > &block_ids) -> VoidResult override

auto	set_tier (const std::string &blob_name, const std::string &tier) -> VoidResult override

Public Member Functions inherited from kcenon::pacs::storage::azure_blob_storage::azure_client_interface
virtual	~azure_client_interface ()=default

Private Attributes
std::unordered_map< std::string, blob_data >	blobs_

std::unordered_map< std::string, std::unordered_map< std::string, std::vector< std::uint8_t > > >	staged_blocks_

bool	connected_

Detailed Description

Mock Azure Blob client for testing without Azure SDK dependency.

Simulates Azure Blob operations using in-memory storage. Always used when PACS_USE_MOCK_AZURE is defined or PACS_WITH_AZURE_SDK is not set.

Definition at line 143 of file azure_blob_storage.cpp.

Constructor & Destructor Documentation

◆ mock_azure_client()

kcenon::pacs::storage::mock_azure_client::mock_azure_client ( const azure_storage_config & )

inlineexplicit

Definition at line 146 of file azure_blob_storage.cpp.

147 : connected_(true) {}

kcenon::pacs::storage::mock_azure_client::connected_

bool connected_

Definition azure_blob_storage.cpp:324

Member Function Documentation

◆ commit_blocks()

auto kcenon::pacs::storage::mock_azure_client::commit_blocks	(	const std::string &	blob_name,
		const std::vector< std::string > &	block_ids ) -> VoidResult

inlinenodiscardoverridevirtual

Implements kcenon::pacs::storage::azure_blob_storage::azure_client_interface.

Definition at line 255 of file azure_blob_storage.cpp.

                             {
    if (!connected_) {
      return make_error<std::monostate>(
          kConnectionError, "Azure client not connected",
          "azure_blob_storage");
    }
 
    auto it = staged_blocks_.find(blob_name);
    if (it == staged_blocks_.end()) {
      return make_error<std::monostate>(
          kUploadError, "No staged blocks found for: " + blob_name,
          "azure_blob_storage");
    }
 
    std::vector<std::uint8_t> combined_data;
    for (const auto &block_id : block_ids) {
      auto block_it = it->second.find(block_id);
      if (block_it == it->second.end()) {
        return make_error<std::monostate>(
            kUploadError, "Block not found: " + block_id,
            "azure_blob_storage");
      }
      combined_data.insert(combined_data.end(), block_it->second.begin(),
                           block_it->second.end());
    }
 
    blob_data blob;
    blob.data = std::move(combined_data);
    blob.etag = "\"" + compute_content_hash(blob.data) + "\"";
    blob.content_md5 = compute_content_hash(blob.data);
    blob.tier = "Hot";
    blobs_[blob_name] = std::move(blob);
 
    staged_blocks_.erase(blob_name);
    return ok();
  }

References kcenon::pacs::storage::mock_azure_client::blob_data::content_md5, kcenon::pacs::storage::mock_azure_client::blob_data::data, kcenon::pacs::storage::mock_azure_client::blob_data::etag, and kcenon::pacs::storage::mock_azure_client::blob_data::tier.

◆ delete_blob()

auto kcenon::pacs::storage::mock_azure_client::delete_blob ( const std::string & blob_name ) -> VoidResult

inlinenodiscardoverridevirtual

Implements kcenon::pacs::storage::azure_blob_storage::azure_client_interface.

Definition at line 182 of file azure_blob_storage.cpp.

                             {
    if (!connected_) {
      return make_error<std::monostate>(
          kConnectionError, "Azure client not connected",
          "azure_blob_storage");
    }
    blobs_.erase(blob_name);
    return ok();
  }

◆ get_blob()

auto kcenon::pacs::storage::mock_azure_client::get_blob ( const std::string & blob_name ) -> Result<std::vector<std::uint8_t>>

inlinenodiscardoverridevirtual

Implements kcenon::pacs::storage::azure_blob_storage::azure_client_interface.

Definition at line 166 of file azure_blob_storage.cpp.

                                                {
    if (!connected_) {
      return make_error<std::vector<std::uint8_t>>(
          kConnectionError, "Azure client not connected",
          "azure_blob_storage");
    }
    auto it = blobs_.find(blob_name);
    if (it == blobs_.end()) {
      return make_error<std::vector<std::uint8_t>>(
          kBlobNotFound, "Blob not found: " + blob_name,
          "azure_blob_storage");
    }
    return it->second.data;
  }

◆ get_blob_etag()

auto kcenon::pacs::storage::mock_azure_client::get_blob_etag ( const std::string & blob_name ) const -> std::string

inlinenodiscardoverridevirtual

Implements kcenon::pacs::storage::azure_blob_storage::azure_client_interface.

Definition at line 210 of file azure_blob_storage.cpp.

                            {
    auto it = blobs_.find(blob_name);
    if (it != blobs_.end()) {
      return it->second.etag;
    }
    return {};
  }

◆ get_blob_md5()

auto kcenon::pacs::storage::mock_azure_client::get_blob_md5 ( const std::string & blob_name ) const -> std::string

inlinenodiscardoverridevirtual

Implements kcenon::pacs::storage::azure_blob_storage::azure_client_interface.

Definition at line 219 of file azure_blob_storage.cpp.

                            {
    auto it = blobs_.find(blob_name);
    if (it != blobs_.end()) {
      return it->second.content_md5;
    }
    return {};
  }

◆ get_blob_size()

auto kcenon::pacs::storage::mock_azure_client::get_blob_size ( const std::string & blob_name ) const -> std::size_t

inlinenodiscardoverridevirtual

Implements kcenon::pacs::storage::azure_blob_storage::azure_client_interface.

Definition at line 201 of file azure_blob_storage.cpp.

                            {
    auto it = blobs_.find(blob_name);
    if (it != blobs_.end()) {
      return it->second.data.size();
    }
    return 0;
  }

◆ head_blob()

auto kcenon::pacs::storage::mock_azure_client::head_blob ( const std::string & blob_name ) const -> bool

inlinenodiscardoverridevirtual

Implements kcenon::pacs::storage::azure_blob_storage::azure_client_interface.

Definition at line 193 of file azure_blob_storage.cpp.

                       {
    if (!connected_) {
      return false;
    }
    return blobs_.contains(blob_name);
  }

◆ is_connected()

auto kcenon::pacs::storage::mock_azure_client::is_connected ( ) const -> bool

inlinenodiscardoverridevirtual

Implements kcenon::pacs::storage::azure_blob_storage::azure_client_interface.

Definition at line 238 of file azure_blob_storage.cpp.

                                                           {
    return connected_;
  }

◆ list_blobs()

auto kcenon::pacs::storage::mock_azure_client::list_blobs ( ) const -> std::vector<std::string>

inlinenodiscardoverridevirtual

Implements kcenon::pacs::storage::azure_blob_storage::azure_client_interface.

Definition at line 228 of file azure_blob_storage.cpp.

                                       {
    std::vector<std::string> names;
    names.reserve(blobs_.size());
    for (const auto &[name, data] : blobs_) {
      names.push_back(name);
    }
    return names;
  }

References name.

◆ put_blob()

auto kcenon::pacs::storage::mock_azure_client::put_blob	(	const std::string &	blob_name,
		const std::vector< std::uint8_t > &	data ) -> VoidResult

inlinenodiscardoverridevirtual

Implements kcenon::pacs::storage::azure_blob_storage::azure_client_interface.

Definition at line 149 of file azure_blob_storage.cpp.

                             {
    if (!connected_) {
      return make_error<std::monostate>(
          kConnectionError, "Azure client not connected",
          "azure_blob_storage");
    }
    blob_data blob;
    blob.data = data;
    blob.etag = "\"" + compute_content_hash(data) + "\"";
    blob.content_md5 = compute_content_hash(data);
    blob.tier = "Hot";
    blobs_[blob_name] = std::move(blob);
    return ok();
  }

References kcenon::pacs::storage::mock_azure_client::blob_data::content_md5, kcenon::pacs::storage::mock_azure_client::blob_data::data, kcenon::pacs::storage::mock_azure_client::blob_data::etag, and kcenon::pacs::storage::mock_azure_client::blob_data::tier.

◆ set_tier()

auto kcenon::pacs::storage::mock_azure_client::set_tier	(	const std::string &	blob_name,
		const std::string &	tier ) -> VoidResult

inlinenodiscardoverridevirtual

Implements kcenon::pacs::storage::azure_blob_storage::azure_client_interface.

Definition at line 294 of file azure_blob_storage.cpp.

                             {
    if (!connected_) {
      return make_error<std::monostate>(
          kConnectionError, "Azure client not connected",
          "azure_blob_storage");
    }
    auto it = blobs_.find(blob_name);
    if (it == blobs_.end()) {
      return make_error<std::monostate>(
          kBlobNotFound, "Blob not found: " + blob_name,
          "azure_blob_storage");
    }
    it->second.tier = tier;
    return ok();
  }

◆ stage_block()

auto kcenon::pacs::storage::mock_azure_client::stage_block	(	const std::string &	blob_name,
		const std::string &	block_id,
		const std::vector< std::uint8_t > &	data ) -> VoidResult

inlinenodiscardoverridevirtual

Implements kcenon::pacs::storage::azure_blob_storage::azure_client_interface.

Definition at line 242 of file azure_blob_storage.cpp.

                             {
    if (!connected_) {
      return make_error<std::monostate>(
          kConnectionError, "Azure client not connected",
          "azure_blob_storage");
    }
    staged_blocks_[blob_name][block_id] = data;
    return ok();
  }

Member Data Documentation

◆ blobs_

std::unordered_map<std::string, blob_data> kcenon::pacs::storage::mock_azure_client::blobs_

private

Definition at line 320 of file azure_blob_storage.cpp.

◆ connected_

bool kcenon::pacs::storage::mock_azure_client::connected_

private

Definition at line 324 of file azure_blob_storage.cpp.

◆ staged_blocks_

std::unordered_map<std::string, std::unordered_map<std::string, std::vector<std::uint8_t> > > kcenon::pacs::storage::mock_azure_client::staged_blocks_

private

Definition at line 323 of file azure_blob_storage.cpp.

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

src/storage/azure_blob_storage.cpp

Classes

Public Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

◆ mock_azure_client()

Member Function Documentation

◆ commit_blocks()

◆ delete_blob()

◆ get_blob()

◆ get_blob_etag()

◆ get_blob_md5()

◆ get_blob_size()

◆ head_blob()

◆ is_connected()

◆ list_blobs()

◆ put_blob()

◆ set_tier()

◆ stage_block()

Member Data Documentation

◆ blobs_

◆ connected_

◆ staged_blocks_