orthanc-object-storage: Azure/AzureBlobStoragePlugin.cpp annotate

annotate Azure/AzureBlobStoragePlugin.cpp @ 99:f4e05641c108

rewrote using the latest azure C++ sdk

author	Alain Mazy <am@osimis.io>
date	Thu, 20 Jul 2023 15:09:57 +0200
parents	1bc055199cd2
children	407bd022b0cf

rev	line source
1 fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	1 /**
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	2 * Cloud storage plugins for Orthanc
37 f55b2afdf53d upgrade to year 2021 Sebastien Jodogne <s.jodogne@gmail.com> parents: 34 diff changeset	3 * Copyright (C) 2020-2021 Osimis S.A., Belgium
1 fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	4 *
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	5 * This program is free software: you can redistribute it and/or
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	6 * modify it under the terms of the GNU Affero General Public License
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	7 * as published by the Free Software Foundation, either version 3 of
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	8 * the License, or (at your option) any later version.
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	9 *
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	10 * This program is distributed in the hope that it will be useful, but
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	11 * WITHOUT ANY WARRANTY; without even the implied warranty of
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	13 * Affero General Public License for more details.
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	14 *
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	15 * You should have received a copy of the GNU Affero General Public License
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	16 * along with this program. If not, see <http://www.gnu.org/licenses/>.
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	17 **/
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	18
56 b922ae86bbe1 full static linking against AWS SDK Sebastien Jodogne <s.jodogne@gmail.com> parents: 48 diff changeset	19
1 fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	20 #include "AzureBlobStoragePlugin.h"
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	21
99 f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	22 #include <azure/storage/blobs.hpp>
1 fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	23 #include <boost/lexical_cast.hpp>
12 a203d0a4fd8f Azure: now removing spaces and CR at the end of the connectionString since it prevented the plugin to initialize. Alain Mazy parents: 11 diff changeset	24 #include <boost/algorithm/string.hpp>
99 f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	25 // #include "cpprest/rawptrstream.h"
f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	26 // #include "cpprest/details/basic_types.h"
1 fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	27
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	28 // Create aliases to make the code easier to read.
99 f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	29 namespace as = Azure::Storage::Blobs;
1 fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	30
78 d7295e8678d7 renames Alain Mazy <am@osimis.io> parents: 71 diff changeset	31 class AzureBlobStoragePlugin : public BaseStorage
1 fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	32 {
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	33 public:
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	34
99 f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	35 as::BlobContainerClient blobClient_;
70 16e419fe80c5 Google & Azure: Added the "EnableLegacyUnknownFiles" configuration option Alain Mazy <am@osimis.io> parents: 56 diff changeset	36 bool storageContainsUnknownFiles_;
16e419fe80c5 Google & Azure: Added the "EnableLegacyUnknownFiles" configuration option Alain Mazy <am@osimis.io> parents: 56 diff changeset	37
1 fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	38 public:
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	39
79 16514270d9ca fix Alain Mazy <am@osimis.io> parents: 78 diff changeset	40 AzureBlobStoragePlugin(const std::string& nameForLogs,
99 f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	41 const as::BlobContainerClient& blobClient,
70 16e419fe80c5 Google & Azure: Added the "EnableLegacyUnknownFiles" configuration option Alain Mazy <am@osimis.io> parents: 56 diff changeset	42 bool enableLegacyStorageStructure,
16e419fe80c5 Google & Azure: Added the "EnableLegacyUnknownFiles" configuration option Alain Mazy <am@osimis.io> parents: 56 diff changeset	43 bool storageContainsUnknownFiles
16e419fe80c5 Google & Azure: Added the "EnableLegacyUnknownFiles" configuration option Alain Mazy <am@osimis.io> parents: 56 diff changeset	44 );
1 fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	45
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	46 virtual IWriter* GetWriterForObject(const char* uuid, OrthancPluginContentType type, bool encryptionEnabled);
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	47 virtual IReader* GetReaderForObject(const char* uuid, OrthancPluginContentType type, bool encryptionEnabled);
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	48 virtual void DeleteObject(const char* uuid, OrthancPluginContentType type, bool encryptionEnabled);
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	49 };
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	50
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	51
78 d7295e8678d7 renames Alain Mazy <am@osimis.io> parents: 71 diff changeset	52 class Writer : public IStorage::IWriter
1 fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	53 {
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	54 std::string path_;
99 f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	55 as::BlobContainerClient client_;
1 fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	56
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	57 public:
99 f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	58 Writer(const std::string& path, const as::BlobContainerClient& client)
1 fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	59 : path_(path),
99 f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	60 client_(client)
1 fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	61 {
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	62 }
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	63
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	64 virtual ~Writer()
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	65 {
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	66 }
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	67
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	68 virtual void Write(const char* data, size_t size)
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	69 {
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	70 try
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	71 {
99 f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	72 as::BlockBlobClient blobClient = client_.GetBlockBlobClient(path_);
f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	73 blobClient.UploadFrom(reinterpret_cast<const uint8_t*>(data), size);
1 fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	74 }
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	75 catch (std::exception& ex)
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	76 {
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	77 throw StoragePluginException("AzureBlobStorage: error writing file " + std::string(path_) + ": " + ex.what());
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	78 }
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	79 }
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	80 };
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	81
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	82
78 d7295e8678d7 renames Alain Mazy <am@osimis.io> parents: 71 diff changeset	83 class Reader : public IStorage::IReader
1 fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	84 {
70 16e419fe80c5 Google & Azure: Added the "EnableLegacyUnknownFiles" configuration option Alain Mazy <am@osimis.io> parents: 56 diff changeset	85 std::string path_;
99 f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	86 as::BlobContainerClient client_;
f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	87 int64_t size_;
1 fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	88
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	89 public:
99 f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	90 Reader(const std::list<std::string>& paths, const as::BlobContainerClient& client)
f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	91 : client_(client)
1 fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	92 {
70 16e419fe80c5 Google & Azure: Added the "EnableLegacyUnknownFiles" configuration option Alain Mazy <am@osimis.io> parents: 56 diff changeset	93 std::string firstExceptionMessage;
16e419fe80c5 Google & Azure: Added the "EnableLegacyUnknownFiles" configuration option Alain Mazy <am@osimis.io> parents: 56 diff changeset	94
16e419fe80c5 Google & Azure: Added the "EnableLegacyUnknownFiles" configuration option Alain Mazy <am@osimis.io> parents: 56 diff changeset	95 for (auto& path: paths)
1 fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	96 {
70 16e419fe80c5 Google & Azure: Added the "EnableLegacyUnknownFiles" configuration option Alain Mazy <am@osimis.io> parents: 56 diff changeset	97 try
16e419fe80c5 Google & Azure: Added the "EnableLegacyUnknownFiles" configuration option Alain Mazy <am@osimis.io> parents: 56 diff changeset	98 {
99 f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	99 as::BlockBlobClient blobClient = client_.GetBlockBlobClient(path);
f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	100 auto properties = blobClient.GetProperties().Value;
f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	101 size_ = properties.BlobSize;
70 16e419fe80c5 Google & Azure: Added the "EnableLegacyUnknownFiles" configuration option Alain Mazy <am@osimis.io> parents: 56 diff changeset	102 path_ = path;
71 a2bb9acdc5e6 fix Alain Mazy <am@osimis.io> parents: 70 diff changeset	103 return;
70 16e419fe80c5 Google & Azure: Added the "EnableLegacyUnknownFiles" configuration option Alain Mazy <am@osimis.io> parents: 56 diff changeset	104 }
16e419fe80c5 Google & Azure: Added the "EnableLegacyUnknownFiles" configuration option Alain Mazy <am@osimis.io> parents: 56 diff changeset	105 catch (std::exception& ex)
16e419fe80c5 Google & Azure: Added the "EnableLegacyUnknownFiles" configuration option Alain Mazy <am@osimis.io> parents: 56 diff changeset	106 {
16e419fe80c5 Google & Azure: Added the "EnableLegacyUnknownFiles" configuration option Alain Mazy <am@osimis.io> parents: 56 diff changeset	107 if (firstExceptionMessage.empty())
16e419fe80c5 Google & Azure: Added the "EnableLegacyUnknownFiles" configuration option Alain Mazy <am@osimis.io> parents: 56 diff changeset	108 {
16e419fe80c5 Google & Azure: Added the "EnableLegacyUnknownFiles" configuration option Alain Mazy <am@osimis.io> parents: 56 diff changeset	109 firstExceptionMessage = "AzureBlobStorage: error opening file for reading " + std::string(path) + ": " + ex.what();
16e419fe80c5 Google & Azure: Added the "EnableLegacyUnknownFiles" configuration option Alain Mazy <am@osimis.io> parents: 56 diff changeset	110 }
16e419fe80c5 Google & Azure: Added the "EnableLegacyUnknownFiles" configuration option Alain Mazy <am@osimis.io> parents: 56 diff changeset	111 //ignore to retry
16e419fe80c5 Google & Azure: Added the "EnableLegacyUnknownFiles" configuration option Alain Mazy <am@osimis.io> parents: 56 diff changeset	112 }
1 fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	113 }
70 16e419fe80c5 Google & Azure: Added the "EnableLegacyUnknownFiles" configuration option Alain Mazy <am@osimis.io> parents: 56 diff changeset	114 throw StoragePluginException(firstExceptionMessage);
1 fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	115 }
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	116
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	117 virtual ~Reader()
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	118 {
70 16e419fe80c5 Google & Azure: Added the "EnableLegacyUnknownFiles" configuration option Alain Mazy <am@osimis.io> parents: 56 diff changeset	119 }
1 fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	120
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	121 virtual size_t GetSize()
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	122 {
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	123 try
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	124 {
99 f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	125 return static_cast<size_t>(size_);
1 fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	126 }
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	127 catch (std::exception& ex)
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	128 {
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	129 throw StoragePluginException("AzureBlobStorage: error while reading file " + std::string(path_) + ": " + ex.what());
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	130 }
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	131 }
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	132
39 50d0be413c42 implemented ReadRange (only in Azure plugin right now) Alain Mazy <am@osimis.io> parents: 37 diff changeset	133 virtual void ReadWhole(char* data, size_t size)
1 fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	134 {
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	135 try
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	136 {
99 f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	137 as::BlockBlobClient blobClient = client_.GetBlockBlobClient(path_);
f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	138 blobClient.DownloadTo(reinterpret_cast<uint8_t*>(data), static_cast<int64_t>(size));
1 fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	139 }
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	140 catch (std::exception& ex)
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	141 {
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	142 throw StoragePluginException("AzureBlobStorage: error while reading file " + std::string(path_) + ": " + ex.what());
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	143 }
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	144 }
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	145
39 50d0be413c42 implemented ReadRange (only in Azure plugin right now) Alain Mazy <am@osimis.io> parents: 37 diff changeset	146 virtual void ReadRange(char* data, size_t size, size_t fromOffset)
50d0be413c42 implemented ReadRange (only in Azure plugin right now) Alain Mazy <am@osimis.io> parents: 37 diff changeset	147 {
50d0be413c42 implemented ReadRange (only in Azure plugin right now) Alain Mazy <am@osimis.io> parents: 37 diff changeset	148 try
50d0be413c42 implemented ReadRange (only in Azure plugin right now) Alain Mazy <am@osimis.io> parents: 37 diff changeset	149 {
99 f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	150 as::BlockBlobClient blobClient = client_.GetBlockBlobClient(path_);
f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	151 as::DownloadBlobToOptions options;
f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	152 options.Range = Azure::Core::Http::HttpRange();
f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	153 options.Range.Value().Length = static_cast<int64_t>(size);
f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	154 options.Range.Value().Offset = static_cast<int64_t>(fromOffset);
39 50d0be413c42 implemented ReadRange (only in Azure plugin right now) Alain Mazy <am@osimis.io> parents: 37 diff changeset	155
99 f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	156 blobClient.DownloadTo(reinterpret_cast<uint8_t*>(data), static_cast<int64_t>(size), options);
39 50d0be413c42 implemented ReadRange (only in Azure plugin right now) Alain Mazy <am@osimis.io> parents: 37 diff changeset	157 }
50d0be413c42 implemented ReadRange (only in Azure plugin right now) Alain Mazy <am@osimis.io> parents: 37 diff changeset	158 catch (std::exception& ex)
50d0be413c42 implemented ReadRange (only in Azure plugin right now) Alain Mazy <am@osimis.io> parents: 37 diff changeset	159 {
50d0be413c42 implemented ReadRange (only in Azure plugin right now) Alain Mazy <am@osimis.io> parents: 37 diff changeset	160 throw StoragePluginException("AzureBlobStorage: error while reading partial file " + std::string(path_) + ": " + ex.what());
50d0be413c42 implemented ReadRange (only in Azure plugin right now) Alain Mazy <am@osimis.io> parents: 37 diff changeset	161 }
50d0be413c42 implemented ReadRange (only in Azure plugin right now) Alain Mazy <am@osimis.io> parents: 37 diff changeset	162 }
1 fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	163 };
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	164
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	165
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	166
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	167 const char* AzureBlobStoragePluginFactory::GetStoragePluginName()
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	168 {
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	169 return "Azure Blob Storage";
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	170 }
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	171
94 1bc055199cd2 Added a description for all plugins Alain Mazy <am@osimis.io> parents: 92 diff changeset	172 const char* AzureBlobStoragePluginFactory::GetStorageDescription()
1bc055199cd2 Added a description for all plugins Alain Mazy <am@osimis.io> parents: 92 diff changeset	173 {
1bc055199cd2 Added a description for all plugins Alain Mazy <am@osimis.io> parents: 92 diff changeset	174 return "Stores the Orthanc storage area in Azure Blob";
1bc055199cd2 Added a description for all plugins Alain Mazy <am@osimis.io> parents: 92 diff changeset	175 }
1bc055199cd2 Added a description for all plugins Alain Mazy <am@osimis.io> parents: 92 diff changeset	176
1bc055199cd2 Added a description for all plugins Alain Mazy <am@osimis.io> parents: 92 diff changeset	177
99 f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	178 // bool IsSasTokenAccountLevel(utility::string_t sasToken)
f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	179 // {
f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	180 // // Use cpprestsdk's utility::string_t here since the expected argument is the return value of
f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	181 // // as::storage_credentials::sas_token(), which is type utility::string_t (which is a std::wstring on Windows and a std::string on Linux)
f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	182 // size_t newIdx = 0;
f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	183 // size_t prevIdx = 0;
f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	184 // while ((newIdx = sasToken.find('&', prevIdx)) != utility::string_t::npos)
f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	185 // {
f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	186 // utility::string_t kvpair = sasToken.substr(prevIdx, newIdx - prevIdx);
f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	187 // prevIdx = newIdx + 1; // start next time from char after '&'
46 3b8fab63313d Add "CreateContainerIfNotExists" config for Azure Mark Poscablo <Mark.Poscablo@varian.com> parents: 15 diff changeset	188
99 f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	189 // size_t equalsIdx = kvpair.find('=');
f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	190 // utility::string_t key = kvpair.substr(0, equalsIdx);
f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	191 // #ifdef WIN32
f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	192 // const wchar_t* srt = L"srt";
f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	193 // #else
f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	194 // const char* srt = "srt";
f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	195 // #endif
f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	196 // if (key == srt) // only account SAS has this parameter
f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	197 // return true;
89 62752402edbb azure build for Windows platform Alain Mazy <alain@mazy.be> parents: 81 diff changeset	198
99 f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	199 // }
46 3b8fab63313d Add "CreateContainerIfNotExists" config for Azure Mark Poscablo <Mark.Poscablo@varian.com> parents: 15 diff changeset	200
99 f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	201 // return false;
f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	202 // }
46 3b8fab63313d Add "CreateContainerIfNotExists" config for Azure Mark Poscablo <Mark.Poscablo@varian.com> parents: 15 diff changeset	203
79 16514270d9ca fix Alain Mazy <am@osimis.io> parents: 78 diff changeset	204 IStorage* AzureBlobStoragePluginFactory::CreateStorage(const std::string& nameForLogs, const OrthancPlugins::OrthancConfiguration& orthancConfig)
1 fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	205 {
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	206 std::string connectionString;
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	207 std::string containerName;
15 2a02b21f0a19 migration + storage structure Alain Mazy parents: 12 diff changeset	208 bool enableLegacyStorageStructure;
70 16e419fe80c5 Google & Azure: Added the "EnableLegacyUnknownFiles" configuration option Alain Mazy <am@osimis.io> parents: 56 diff changeset	209 bool storageContainsUnknownFiles;
46 3b8fab63313d Add "CreateContainerIfNotExists" config for Azure Mark Poscablo <Mark.Poscablo@varian.com> parents: 15 diff changeset	210 bool createContainerIfNotExists;
1 fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	211
81 e29987d80ecf fix Alain Mazy <am@osimis.io> parents: 80 diff changeset	212 if (orthancConfig.IsSection(GetConfigurationSectionName()))
1 fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	213 {
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	214 OrthancPlugins::OrthancConfiguration pluginSection;
81 e29987d80ecf fix Alain Mazy <am@osimis.io> parents: 80 diff changeset	215 orthancConfig.GetSection(pluginSection, GetConfigurationSectionName());
1 fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	216
78 d7295e8678d7 renames Alain Mazy <am@osimis.io> parents: 71 diff changeset	217 if (!BaseStorage::ReadCommonConfiguration(enableLegacyStorageStructure, storageContainsUnknownFiles, pluginSection))
15 2a02b21f0a19 migration + storage structure Alain Mazy parents: 12 diff changeset	218 {
2a02b21f0a19 migration + storage structure Alain Mazy parents: 12 diff changeset	219 return nullptr;
2a02b21f0a19 migration + storage structure Alain Mazy parents: 12 diff changeset	220 }
2a02b21f0a19 migration + storage structure Alain Mazy parents: 12 diff changeset	221
1 fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	222 if (!pluginSection.LookupStringValue(connectionString, "ConnectionString"))
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	223 {
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	224 OrthancPlugins::LogError("AzureBlobStorage/ConnectionString configuration missing. Unable to initialize plugin");
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	225 return nullptr;
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	226 }
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	227
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	228 if (!pluginSection.LookupStringValue(containerName, "ContainerName"))
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	229 {
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	230 OrthancPlugins::LogError("AzureBlobStorage/ContainerName configuration missing. Unable to initialize plugin");
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	231 return nullptr;
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	232 }
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	233
12 a203d0a4fd8f Azure: now removing spaces and CR at the end of the connectionString since it prevented the plugin to initialize. Alain Mazy parents: 11 diff changeset	234 boost::trim(connectionString); // without that, if there's an EOL in the string, it fails with "provided uri is invalid"
a203d0a4fd8f Azure: now removing spaces and CR at the end of the connectionString since it prevented the plugin to initialize. Alain Mazy parents: 11 diff changeset	235 boost::trim(containerName);
46 3b8fab63313d Add "CreateContainerIfNotExists" config for Azure Mark Poscablo <Mark.Poscablo@varian.com> parents: 15 diff changeset	236
3b8fab63313d Add "CreateContainerIfNotExists" config for Azure Mark Poscablo <Mark.Poscablo@varian.com> parents: 15 diff changeset	237 createContainerIfNotExists = pluginSection.GetBooleanValue("CreateContainerIfNotExists", true);
1 fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	238 }
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	239 else if (orthancConfig.IsSection("BlobStorage")) // backward compatibility with the old plugin:
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	240 {
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	241 OrthancPlugins::LogWarning("AzureBlobStorage: you're using an old configuration format for the plugin.");
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	242
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	243 OrthancPlugins::OrthancConfiguration pluginSection;
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	244 orthancConfig.GetSection(pluginSection, "BlobStorage");
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	245
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	246 std::string accountName;
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	247 std::string accountKey;
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	248
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	249 if (!pluginSection.LookupStringValue(containerName, "ContainerName"))
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	250 {
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	251 OrthancPlugins::LogError("BlobStorage/AccountName configuration missing. Unable to initialize plugin");
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	252 return nullptr;
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	253 }
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	254
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	255 if (!pluginSection.LookupStringValue(accountName, "AccountName"))
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	256 {
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	257 OrthancPlugins::LogError("BlobStorage/AccountName configuration missing. Unable to initialize plugin");
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	258 return nullptr;
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	259 }
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	260
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	261 if (!pluginSection.LookupStringValue(accountKey, "AccountKey"))
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	262 {
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	263 OrthancPlugins::LogError("BlobStorage/ContainerName configuration missing. Unable to initialize plugin");
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	264 return nullptr;
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	265 }
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	266
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	267 std::ostringstream connectionStringBuilder;
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	268 connectionStringBuilder << "DefaultEndpointsProtocol=https;AccountName=" << accountName << ";AccountKey=" << accountKey;
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	269 connectionString = connectionStringBuilder.str();
46 3b8fab63313d Add "CreateContainerIfNotExists" config for Azure Mark Poscablo <Mark.Poscablo@varian.com> parents: 15 diff changeset	270
3b8fab63313d Add "CreateContainerIfNotExists" config for Azure Mark Poscablo <Mark.Poscablo@varian.com> parents: 15 diff changeset	271 createContainerIfNotExists = pluginSection.GetBooleanValue("CreateContainerIfNotExists", true);
1 fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	272 }
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	273 else
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	274 {
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	275 OrthancPlugins::LogWarning(std::string(GetStoragePluginName()) + " plugin, section missing. Plugin is not enabled.");
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	276 return nullptr;
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	277 }
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	278
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	279 try
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	280 {
11 1b85dc5eb372 more logs for azure plugin Alain Mazy parents: 1 diff changeset	281 OrthancPlugins::LogInfo("Connecting to Azure storage ...");
1b85dc5eb372 more logs for azure plugin Alain Mazy parents: 1 diff changeset	282
99 f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	283 as::BlobContainerClient client = as::BlobContainerClient::CreateFromConnectionString(connectionString, containerName);
11 1b85dc5eb372 more logs for azure plugin Alain Mazy parents: 1 diff changeset	284 OrthancPlugins::LogInfo("Blob client created");
1b85dc5eb372 more logs for azure plugin Alain Mazy parents: 1 diff changeset	285
99 f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	286 if (createContainerIfNotExists)
f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	287 {
f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	288 // Note: in version up to 2.1.2, we had this code:
f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	289 // // blobContainer.create_if_not_exists() throws an error if a service SAS (for a blob container)
f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	290 // // was used in the connectionString.
f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	291 // // Only allow the use of this function when using storage account-level credentials, whether
f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	292 // // through accountName/accountKey combo or account SAS.
f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	293 // if ((storageAccount.credentials().is_account_key() \|\|
f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	294 // (storageAccount.credentials().is_sas() && IsSasTokenAccountLevel(storageAccount.credentials().sas_token())))
f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	295 // && createContainerIfNotExists)
1 fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	296
99 f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	297 auto createResult = client.CreateIfNotExists();
f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	298 if (createResult.Value.Created)
46 3b8fab63313d Add "CreateContainerIfNotExists" config for Azure Mark Poscablo <Mark.Poscablo@varian.com> parents: 15 diff changeset	299 {
3b8fab63313d Add "CreateContainerIfNotExists" config for Azure Mark Poscablo <Mark.Poscablo@varian.com> parents: 15 diff changeset	300 OrthancPlugins::LogWarning("Blob Storage Area container has been created. ** check in the Azure console that your container is private **");
3b8fab63313d Add "CreateContainerIfNotExists" config for Azure Mark Poscablo <Mark.Poscablo@varian.com> parents: 15 diff changeset	301 }
1 fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	302 }
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	303
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	304 OrthancPlugins::LogInfo("Blob storage initialized");
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	305
99 f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	306 return new AzureBlobStoragePlugin(nameForLogs, client, enableLegacyStorageStructure, storageContainsUnknownFiles);
1 fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	307 }
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	308 catch (const std::exception& e)
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	309 {
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	310 OrthancPlugins::LogError(std::string("AzureBlobStorage plugin: failed to initialize plugin: ") + e.what());
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	311 return nullptr;
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	312 }
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	313
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	314 }
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	315
99 f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	316 AzureBlobStoragePlugin::AzureBlobStoragePlugin(const std::string& nameForLogs, const as::BlobContainerClient& blobClient, bool enableLegacyStorageStructure, bool storageContainsUnknownFiles)
79 16514270d9ca fix Alain Mazy <am@osimis.io> parents: 78 diff changeset	317 : BaseStorage(nameForLogs, enableLegacyStorageStructure),
15 2a02b21f0a19 migration + storage structure Alain Mazy parents: 12 diff changeset	318 blobClient_(blobClient),
70 16e419fe80c5 Google & Azure: Added the "EnableLegacyUnknownFiles" configuration option Alain Mazy <am@osimis.io> parents: 56 diff changeset	319 storageContainsUnknownFiles_(storageContainsUnknownFiles)
1 fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	320 {
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	321
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	322 }
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	323
78 d7295e8678d7 renames Alain Mazy <am@osimis.io> parents: 71 diff changeset	324 IStorage::IWriter* AzureBlobStoragePlugin::GetWriterForObject(const char* uuid, OrthancPluginContentType type, bool encryptionEnabled)
1 fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	325 {
99 f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	326 return new Writer(GetPath(uuid, type, encryptionEnabled), blobClient_);
1 fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	327 }
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	328
78 d7295e8678d7 renames Alain Mazy <am@osimis.io> parents: 71 diff changeset	329 IStorage::IReader* AzureBlobStoragePlugin::GetReaderForObject(const char* uuid, OrthancPluginContentType type, bool encryptionEnabled)
1 fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	330 {
70 16e419fe80c5 Google & Azure: Added the "EnableLegacyUnknownFiles" configuration option Alain Mazy <am@osimis.io> parents: 56 diff changeset	331 std::list<std::string> paths;
16e419fe80c5 Google & Azure: Added the "EnableLegacyUnknownFiles" configuration option Alain Mazy <am@osimis.io> parents: 56 diff changeset	332 paths.push_back(GetPath(uuid, type, encryptionEnabled, false));
16e419fe80c5 Google & Azure: Added the "EnableLegacyUnknownFiles" configuration option Alain Mazy <am@osimis.io> parents: 56 diff changeset	333 if (storageContainsUnknownFiles_)
16e419fe80c5 Google & Azure: Added the "EnableLegacyUnknownFiles" configuration option Alain Mazy <am@osimis.io> parents: 56 diff changeset	334 {
16e419fe80c5 Google & Azure: Added the "EnableLegacyUnknownFiles" configuration option Alain Mazy <am@osimis.io> parents: 56 diff changeset	335 paths.push_back(GetPath(uuid, type, encryptionEnabled, true));
16e419fe80c5 Google & Azure: Added the "EnableLegacyUnknownFiles" configuration option Alain Mazy <am@osimis.io> parents: 56 diff changeset	336 }
16e419fe80c5 Google & Azure: Added the "EnableLegacyUnknownFiles" configuration option Alain Mazy <am@osimis.io> parents: 56 diff changeset	337
99 f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	338 return new Reader(paths, blobClient_);
1 fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	339 }
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	340
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	341 void AzureBlobStoragePlugin::DeleteObject(const char* uuid, OrthancPluginContentType type, bool encryptionEnabled)
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	342 {
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	343 std::string path = GetPath(uuid, type, encryptionEnabled);
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	344
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	345 try
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	346 {
99 f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	347 as::BlockBlobClient blobClient = blobClient_.GetBlockBlobClient(path);
f4e05641c108 rewrote using the latest azure C++ sdk Alain Mazy <am@osimis.io> parents: 94 diff changeset	348 blobClient.Delete();
1 fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	349 }
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	350 catch (std::exception& ex)
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	351 {
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	352 throw StoragePluginException("AzureBlobStorage: error while deleting file " + std::string(path) + ": " + ex.what());
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	353 }
fc26a8fc54d5 initial release Alain Mazy <alain@mazy.be> parents: diff changeset	354 }

Mercurial > hg > orthanc-object-storage

annotate Azure/AzureBlobStoragePlugin.cpp @ 99:f4e05641c108