Mercurial > hg > orthanc
view OrthancServer/Sources/DicomInstanceToStore.cpp @ 4454:f20a7655fb1c
Fix upload of multiple DICOM files using one single POST call to "multipart/form-data"
author | Sebastien Jodogne <s.jodogne@gmail.com> |
---|---|
date | Tue, 19 Jan 2021 12:03:49 +0100 |
parents | d9473bd5ed43 |
children | 7d1eabfac6e0 |
line wrap: on
line source
/** * Orthanc - A Lightweight, RESTful DICOM Store * Copyright (C) 2012-2016 Sebastien Jodogne, Medical Physics * Department, University Hospital of Liege, Belgium * Copyright (C) 2017-2021 Osimis S.A., Belgium * * This program is free software: you can redistribute it and/or * modify it under the terms of the GNU General Public License as * published by the Free Software Foundation, either version 3 of the * License, or (at your option) any later version. * * In addition, as a special exception, the copyright holders of this * program give permission to link the code of its release with the * OpenSSL project's "OpenSSL" library (or with modified versions of it * that use the same license as the "OpenSSL" library), and distribute * the linked executables. You must obey the GNU General Public License * in all respects for all of the code used other than "OpenSSL". If you * modify file(s) with this exception, you may extend this exception to * your version of the file(s), but you are not obligated to do so. If * you do not wish to do so, delete this exception statement from your * version. If you delete this exception statement from all source files * in the program, then also delete it here. * * This program is distributed in the hope that it will be useful, but * WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU * General Public License for more details. * * You should have received a copy of the GNU General Public License * along with this program. If not, see <http://www.gnu.org/licenses/>. **/ #include "PrecompiledHeadersServer.h" #include "DicomInstanceToStore.h" #include "OrthancConfiguration.h" #include "../../OrthancFramework/Sources/DicomParsing/FromDcmtkBridge.h" #include "../../OrthancFramework/Sources/DicomParsing/ParsedDicomFile.h" #include "../../OrthancFramework/Sources/Logging.h" #include "../../OrthancFramework/Sources/OrthancException.h" #include <dcmtk/dcmdata/dcfilefo.h> #include <dcmtk/dcmdata/dcdeftag.h> namespace Orthanc { // Anonymous namespace to avoid clashes between compilation modules namespace { template <typename T> class SmartContainer { private: T* content_; bool toDelete_; bool isReadOnly_; void Deallocate() { if (content_ && toDelete_) { delete content_; toDelete_ = false; content_ = NULL; } } public: SmartContainer() : content_(NULL), toDelete_(false), isReadOnly_(true) { } ~SmartContainer() { Deallocate(); } void Allocate() { Deallocate(); content_ = new T; toDelete_ = true; isReadOnly_ = false; } void TakeOwnership(T* content) { if (content == NULL) { throw OrthancException(ErrorCode_ParameterOutOfRange); } Deallocate(); content_ = content; toDelete_ = true; isReadOnly_ = false; } void SetReference(T& content) // Read and write assign, without transfering ownership { Deallocate(); content_ = &content; toDelete_ = false; isReadOnly_ = false; } void SetConstReference(const T& content) // Read-only assign, without transfering ownership { Deallocate(); content_ = &const_cast<T&>(content); toDelete_ = false; isReadOnly_ = true; } bool HasContent() const { return content_ != NULL; } T& GetContent() { if (content_ == NULL) { throw OrthancException(ErrorCode_BadSequenceOfCalls); } if (isReadOnly_) { throw OrthancException(ErrorCode_ReadOnly); } return *content_; } const T& GetConstContent() const { if (content_ == NULL) { throw OrthancException(ErrorCode_BadSequenceOfCalls); } return *content_; } }; } class DicomInstanceToStore::PImpl { public: DicomInstanceOrigin origin_; bool hasBuffer_; std::unique_ptr<std::string> ownBuffer_; const void* bufferData_; size_t bufferSize_; SmartContainer<ParsedDicomFile> parsed_; SmartContainer<DicomMap> summary_; SmartContainer<Json::Value> json_; MetadataMap metadata_; PImpl() : hasBuffer_(false), bufferData_(NULL), bufferSize_(0) { } private: std::unique_ptr<DicomInstanceHasher> hasher_; void ParseDicomFile() { if (!parsed_.HasContent()) { if (!hasBuffer_) { throw OrthancException(ErrorCode_InternalError); } if (ownBuffer_.get() != NULL) { parsed_.TakeOwnership(new ParsedDicomFile(*ownBuffer_)); } else { parsed_.TakeOwnership(new ParsedDicomFile(bufferData_, bufferSize_)); } } } void ComputeMissingInformation() { if (hasBuffer_ && summary_.HasContent() && json_.HasContent()) { // Fine, everything is available return; } if (!hasBuffer_) { if (!parsed_.HasContent()) { if (!summary_.HasContent()) { throw OrthancException(ErrorCode_NotImplemented); } else { parsed_.TakeOwnership(new ParsedDicomFile(summary_.GetConstContent(), GetDefaultDicomEncoding(), false /* be strict */)); } } // Serialize the parsed DICOM file ownBuffer_.reset(new std::string); if (!FromDcmtkBridge::SaveToMemoryBuffer(*ownBuffer_, *parsed_.GetContent().GetDcmtkObject().getDataset())) { throw OrthancException(ErrorCode_InternalError, "Unable to serialize a DICOM file to a memory buffer"); } hasBuffer_ = true; } if (summary_.HasContent() && json_.HasContent()) { return; } // At this point, we know that the DICOM file is available as a // memory buffer, but that its summary or its JSON version is // missing ParseDicomFile(); assert(parsed_.HasContent()); // At this point, we have parsed the DICOM file if (!summary_.HasContent()) { summary_.Allocate(); OrthancConfiguration::DefaultExtractDicomSummary(summary_.GetContent(), parsed_.GetContent()); } if (!json_.HasContent()) { json_.Allocate(); OrthancConfiguration::DefaultDicomDatasetToJson(json_.GetContent(), parsed_.GetContent()); } } public: void SetBuffer(const void* data, size_t size) { ownBuffer_.reset(NULL); bufferData_ = data; bufferSize_ = size; hasBuffer_ = true; } const void* GetBufferData() { ComputeMissingInformation(); if (!hasBuffer_) { throw OrthancException(ErrorCode_InternalError); } if (ownBuffer_.get() != NULL) { if (ownBuffer_->empty()) { return NULL; } else { return ownBuffer_->c_str(); } } else { return bufferData_; } } size_t GetBufferSize() { ComputeMissingInformation(); if (!hasBuffer_) { throw OrthancException(ErrorCode_InternalError); } if (ownBuffer_.get() != NULL) { return ownBuffer_->size(); } else { return bufferSize_; } } const DicomMap& GetSummary() { ComputeMissingInformation(); if (!summary_.HasContent()) { throw OrthancException(ErrorCode_InternalError); } return summary_.GetConstContent(); } const Json::Value& GetJson() { ComputeMissingInformation(); if (!json_.HasContent()) { throw OrthancException(ErrorCode_InternalError); } return json_.GetConstContent(); } DicomInstanceHasher& GetHasher() { if (hasher_.get() == NULL) { hasher_.reset(new DicomInstanceHasher(GetSummary())); } if (hasher_.get() == NULL) { throw OrthancException(ErrorCode_InternalError); } return *hasher_; } bool LookupTransferSyntax(std::string& result) { ComputeMissingInformation(); DicomMap header; if (DicomMap::ParseDicomMetaInformation(header, GetBufferData(), GetBufferSize())) { const DicomValue* value = header.TestAndGetValue(DICOM_TAG_TRANSFER_SYNTAX_UID); if (value != NULL && !value->IsBinary() && !value->IsNull()) { result = Toolbox::StripSpaces(value->GetContent()); return true; } } else { // This is a DICOM file without a proper meta-header. Fallback // to DCMTK, which will fully parse the dataset to retrieve // the transfer syntax. Added in Orthanc 1.8.2. std::string transferSyntax; if (GetParsedDicomFile().LookupTransferSyntax(transferSyntax)) { result = Toolbox::StripSpaces(transferSyntax); return true; } } return false; } ParsedDicomFile& GetParsedDicomFile() { ComputeMissingInformation(); ParseDicomFile(); if (parsed_.HasContent()) { return parsed_.GetContent(); } else { throw OrthancException(ErrorCode_InternalError); } } }; DicomInstanceToStore::DicomInstanceToStore() : pimpl_(new PImpl) { } void DicomInstanceToStore::SetOrigin(const DicomInstanceOrigin& origin) { pimpl_->origin_ = origin; } const DicomInstanceOrigin& DicomInstanceToStore::GetOrigin() const { return pimpl_->origin_; } void DicomInstanceToStore::SetBuffer(const void* dicom, size_t size) { pimpl_->SetBuffer(dicom, size); } void DicomInstanceToStore::SetParsedDicomFile(ParsedDicomFile& parsed) { pimpl_->parsed_.SetReference(parsed); } void DicomInstanceToStore::SetSummary(const DicomMap& summary) { pimpl_->summary_.SetConstReference(summary); } void DicomInstanceToStore::SetJson(const Json::Value& json) { pimpl_->json_.SetConstReference(json); } const DicomInstanceToStore::MetadataMap& DicomInstanceToStore::GetMetadata() const { return pimpl_->metadata_; } DicomInstanceToStore::MetadataMap& DicomInstanceToStore::GetMetadata() { return pimpl_->metadata_; } void DicomInstanceToStore::AddMetadata(ResourceType level, MetadataType metadata, const std::string& value) { pimpl_->metadata_[std::make_pair(level, metadata)] = value; } const void* DicomInstanceToStore::GetBufferData() const { return const_cast<PImpl&>(*pimpl_).GetBufferData(); } size_t DicomInstanceToStore::GetBufferSize() const { return const_cast<PImpl&>(*pimpl_).GetBufferSize(); } const DicomMap& DicomInstanceToStore::GetSummary() { return pimpl_->GetSummary(); } const Json::Value& DicomInstanceToStore::GetJson() const { return const_cast<PImpl&>(*pimpl_).GetJson(); } bool DicomInstanceToStore::LookupTransferSyntax(std::string& result) const { return const_cast<PImpl&>(*pimpl_).LookupTransferSyntax(result); } DicomInstanceHasher& DicomInstanceToStore::GetHasher() { return pimpl_->GetHasher(); } bool DicomInstanceToStore::HasPixelData() const { return const_cast<PImpl&>(*pimpl_).GetParsedDicomFile().HasTag(DICOM_TAG_PIXEL_DATA); } ParsedDicomFile& DicomInstanceToStore::GetParsedDicomFile() const { return const_cast<PImpl&>(*pimpl_).GetParsedDicomFile(); } }