Mercurial > hg > orthanc
view OrthancServer/ServerContext.cpp @ 408:5a3a4a25e568 lua-scripting
reintegration from mainline
author | Sebastien Jodogne <s.jodogne@gmail.com> |
---|---|
date | Thu, 02 May 2013 16:51:40 +0200 |
parents | 2d269089078f |
children | 63f707278fc8 |
line wrap: on
line source
/** * Orthanc - A Lightweight, RESTful DICOM Store * Copyright (C) 2012-2013 Medical Physics Department, CHU of Liege, * 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 "ServerContext.h" #include "../Core/HttpServer/FilesystemHttpSender.h" #include "../Core/Lua/LuaFunctionCall.h" #include "ServerToolbox.h" #include <glog/logging.h> #include <EmbeddedResources.h> #define ENABLE_DICOM_CACHE 1 static const char* RECEIVED_INSTANCE_FILTER = "ReceivedInstanceFilter"; static const size_t DICOM_CACHE_SIZE = 2; /** * IMPORTANT: We make the assumption that the same instance of * FileStorage can be accessed from multiple threads. This seems OK * since the filesystem implements the required locking mechanisms, * but maybe a read-writer lock on the "FileStorage" could be * useful. Conversely, "ServerIndex" already implements mutex-based * locking. **/ namespace Orthanc { ServerContext::ServerContext(const boost::filesystem::path& storagePath, const boost::filesystem::path& indexPath) : storage_(storagePath.string()), index_(*this, indexPath.string()), accessor_(storage_), provider_(*this), dicomCache_(provider_, DICOM_CACHE_SIZE) { lua_.Execute(Orthanc::EmbeddedResources::LUA_TOOLBOX); } void ServerContext::SetCompressionEnabled(bool enabled) { if (enabled) LOG(WARNING) << "Disk compression is enabled"; else LOG(WARNING) << "Disk compression is disabled"; compressionEnabled_ = enabled; } void ServerContext::RemoveFile(const std::string& fileUuid) { storage_.Remove(fileUuid); } StoreStatus ServerContext::Store(const char* dicomInstance, size_t dicomSize, const DicomMap& dicomSummary, const Json::Value& dicomJson, const std::string& remoteAet) { // Test if the instance must be filtered out if (lua_.IsExistingFunction(RECEIVED_INSTANCE_FILTER)) { Json::Value simplified; SimplifyTags(simplified, dicomJson); LuaFunctionCall call(lua_, RECEIVED_INSTANCE_FILTER); call.PushJSON(simplified); call.PushString(remoteAet); if (!call.ExecutePredicate()) { LOG(INFO) << "An incoming instance has been discarded by a filter"; return StoreStatus_FilteredOut; } } if (compressionEnabled_) { accessor_.SetCompressionForNextOperations(CompressionType_Zlib); } else { accessor_.SetCompressionForNextOperations(CompressionType_None); } FileInfo dicomInfo = accessor_.Write(dicomInstance, dicomSize, FileContentType_Dicom); FileInfo jsonInfo = accessor_.Write(dicomJson.toStyledString(), FileContentType_Json); ServerIndex::Attachments attachments; attachments.push_back(dicomInfo); attachments.push_back(jsonInfo); StoreStatus status = index_.Store(dicomSummary, attachments, remoteAet); if (status != StoreStatus_Success) { storage_.Remove(dicomInfo.GetUuid()); storage_.Remove(jsonInfo.GetUuid()); } switch (status) { case StoreStatus_Success: LOG(INFO) << "New instance stored"; break; case StoreStatus_AlreadyStored: LOG(INFO) << "Already stored"; break; case StoreStatus_Failure: LOG(ERROR) << "Store failure"; break; default: // This should never happen break; } return status; } void ServerContext::AnswerFile(RestApiOutput& output, const std::string& instancePublicId, FileContentType content) { FileInfo attachment; if (!index_.LookupAttachment(attachment, instancePublicId, content)) { throw OrthancException(ErrorCode_InternalError); } accessor_.SetCompressionForNextOperations(attachment.GetCompressionType()); std::auto_ptr<HttpFileSender> sender(accessor_.ConstructHttpFileSender(attachment.GetUuid())); sender->SetContentType("application/dicom"); sender->SetDownloadFilename(instancePublicId + ".dcm"); output.AnswerFile(*sender); } void ServerContext::ReadJson(Json::Value& result, const std::string& instancePublicId) { std::string s; ReadFile(s, instancePublicId, FileContentType_Json); Json::Reader reader; if (!reader.parse(s, result)) { throw OrthancException("Corrupted JSON file"); } } void ServerContext::ReadFile(std::string& result, const std::string& instancePublicId, FileContentType content) { FileInfo attachment; if (!index_.LookupAttachment(attachment, instancePublicId, content)) { throw OrthancException(ErrorCode_InternalError); } accessor_.SetCompressionForNextOperations(attachment.GetCompressionType()); accessor_.Read(result, attachment.GetUuid()); } IDynamicObject* ServerContext::DicomCacheProvider::Provide(const std::string& instancePublicId) { std::string content; context_.ReadFile(content, instancePublicId, FileContentType_Dicom); return new ParsedDicomFile(content); } ParsedDicomFile& ServerContext::GetDicomFile(const std::string& instancePublicId) { #if ENABLE_DICOM_CACHE == 0 static std::auto_ptr<IDynamicObject> p; p.reset(provider_.Provide(instancePublicId)); return dynamic_cast<ParsedDicomFile&>(*p); #else return dynamic_cast<ParsedDicomFile&>(dicomCache_.Access(instancePublicId)); #endif } StoreStatus ServerContext::Store(std::string& resultPublicId, DcmFileFormat& dicomInstance, const char* dicomBuffer, size_t dicomSize) { DicomMap dicomSummary; FromDcmtkBridge::Convert(dicomSummary, *dicomInstance.getDataset()); DicomInstanceHasher hasher(dicomSummary); resultPublicId = hasher.HashInstance(); Json::Value dicomJson; FromDcmtkBridge::ToJson(dicomJson, *dicomInstance.getDataset()); StoreStatus status = StoreStatus_Failure; if (dicomSize > 0) { status = Store(dicomBuffer, dicomSize, dicomSummary, dicomJson, ""); } return status; } StoreStatus ServerContext::Store(std::string& resultPublicId, DcmFileFormat& dicomInstance) { std::string buffer; if (!FromDcmtkBridge::SaveToMemoryBuffer(buffer, dicomInstance.getDataset())) { throw OrthancException(ErrorCode_InternalError); } if (buffer.size() == 0) return Store(resultPublicId, dicomInstance, NULL, 0); else return Store(resultPublicId, dicomInstance, &buffer[0], buffer.size()); } StoreStatus ServerContext::Store(std::string& resultPublicId, const char* dicomBuffer, size_t dicomSize) { ParsedDicomFile dicom(dicomBuffer, dicomSize); return Store(resultPublicId, dicom.GetDicom(), dicomBuffer, dicomSize); } }