S3Client.cpp 136 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114
  1. /**
  2. * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
  3. * SPDX-License-Identifier: Apache-2.0.
  4. */
  5. #include <aws/core/utils/Outcome.h>
  6. #include <aws/core/auth/AWSAuthSigner.h>
  7. #include <aws/core/client/CoreErrors.h>
  8. #include <aws/core/client/RetryStrategy.h>
  9. #include <aws/core/http/HttpClient.h>
  10. #include <aws/core/http/HttpResponse.h>
  11. #include <aws/core/http/HttpClientFactory.h>
  12. #include <aws/core/auth/AWSCredentialsProviderChain.h>
  13. #include <aws/core/utils/xml/XmlSerializer.h>
  14. #include <aws/core/utils/memory/stl/AWSStringStream.h>
  15. #include <aws/core/utils/threading/Executor.h>
  16. #include <aws/core/utils/DNS.h>
  17. #include <aws/core/utils/logging/LogMacros.h>
  18. #include <aws/core/utils/logging/ErrorMacros.h>
  19. #include <aws/core/utils/event/EventStream.h>
  20. #include <aws/core/platform/Environment.h>
  21. #include <aws/s3/S3Client.h>
  22. #include <aws/s3/S3ErrorMarshaller.h>
  23. #include <aws/s3/S3EndpointProvider.h>
  24. #include <aws/s3/model/AbortMultipartUploadRequest.h>
  25. #include <aws/s3/model/CompleteMultipartUploadRequest.h>
  26. #include <aws/s3/model/CopyObjectRequest.h>
  27. #include <aws/s3/model/CreateBucketRequest.h>
  28. #include <aws/s3/model/CreateMultipartUploadRequest.h>
  29. #include <aws/s3/model/DeleteBucketRequest.h>
  30. #include <aws/s3/model/DeleteBucketAnalyticsConfigurationRequest.h>
  31. #include <aws/s3/model/DeleteBucketCorsRequest.h>
  32. #include <aws/s3/model/DeleteBucketEncryptionRequest.h>
  33. #include <aws/s3/model/DeleteBucketIntelligentTieringConfigurationRequest.h>
  34. #include <aws/s3/model/DeleteBucketInventoryConfigurationRequest.h>
  35. #include <aws/s3/model/DeleteBucketLifecycleRequest.h>
  36. #include <aws/s3/model/DeleteBucketMetricsConfigurationRequest.h>
  37. #include <aws/s3/model/DeleteBucketOwnershipControlsRequest.h>
  38. #include <aws/s3/model/DeleteBucketPolicyRequest.h>
  39. #include <aws/s3/model/DeleteBucketReplicationRequest.h>
  40. #include <aws/s3/model/DeleteBucketTaggingRequest.h>
  41. #include <aws/s3/model/DeleteBucketWebsiteRequest.h>
  42. #include <aws/s3/model/DeleteObjectRequest.h>
  43. #include <aws/s3/model/DeleteObjectTaggingRequest.h>
  44. #include <aws/s3/model/DeleteObjectsRequest.h>
  45. #include <aws/s3/model/DeletePublicAccessBlockRequest.h>
  46. #include <aws/s3/model/GetBucketAccelerateConfigurationRequest.h>
  47. #include <aws/s3/model/GetBucketAclRequest.h>
  48. #include <aws/s3/model/GetBucketAnalyticsConfigurationRequest.h>
  49. #include <aws/s3/model/GetBucketCorsRequest.h>
  50. #include <aws/s3/model/GetBucketEncryptionRequest.h>
  51. #include <aws/s3/model/GetBucketIntelligentTieringConfigurationRequest.h>
  52. #include <aws/s3/model/GetBucketInventoryConfigurationRequest.h>
  53. #include <aws/s3/model/GetBucketLifecycleConfigurationRequest.h>
  54. #include <aws/s3/model/GetBucketLocationRequest.h>
  55. #include <aws/s3/model/GetBucketLoggingRequest.h>
  56. #include <aws/s3/model/GetBucketMetricsConfigurationRequest.h>
  57. #include <aws/s3/model/GetBucketNotificationConfigurationRequest.h>
  58. #include <aws/s3/model/GetBucketOwnershipControlsRequest.h>
  59. #include <aws/s3/model/GetBucketPolicyRequest.h>
  60. #include <aws/s3/model/GetBucketPolicyStatusRequest.h>
  61. #include <aws/s3/model/GetBucketReplicationRequest.h>
  62. #include <aws/s3/model/GetBucketRequestPaymentRequest.h>
  63. #include <aws/s3/model/GetBucketTaggingRequest.h>
  64. #include <aws/s3/model/GetBucketVersioningRequest.h>
  65. #include <aws/s3/model/GetBucketWebsiteRequest.h>
  66. #include <aws/s3/model/GetObjectRequest.h>
  67. #include <aws/s3/model/GetObjectAclRequest.h>
  68. #include <aws/s3/model/GetObjectAttributesRequest.h>
  69. #include <aws/s3/model/GetObjectLegalHoldRequest.h>
  70. #include <aws/s3/model/GetObjectLockConfigurationRequest.h>
  71. #include <aws/s3/model/GetObjectRetentionRequest.h>
  72. #include <aws/s3/model/GetObjectTaggingRequest.h>
  73. #include <aws/s3/model/GetObjectTorrentRequest.h>
  74. #include <aws/s3/model/GetPublicAccessBlockRequest.h>
  75. #include <aws/s3/model/HeadBucketRequest.h>
  76. #include <aws/s3/model/HeadObjectRequest.h>
  77. #include <aws/s3/model/ListBucketAnalyticsConfigurationsRequest.h>
  78. #include <aws/s3/model/ListBucketIntelligentTieringConfigurationsRequest.h>
  79. #include <aws/s3/model/ListBucketInventoryConfigurationsRequest.h>
  80. #include <aws/s3/model/ListBucketMetricsConfigurationsRequest.h>
  81. #include <aws/s3/model/ListMultipartUploadsRequest.h>
  82. #include <aws/s3/model/ListObjectVersionsRequest.h>
  83. #include <aws/s3/model/ListObjectsRequest.h>
  84. #include <aws/s3/model/ListObjectsV2Request.h>
  85. #include <aws/s3/model/ListPartsRequest.h>
  86. #include <aws/s3/model/PutBucketAccelerateConfigurationRequest.h>
  87. #include <aws/s3/model/PutBucketAclRequest.h>
  88. #include <aws/s3/model/PutBucketAnalyticsConfigurationRequest.h>
  89. #include <aws/s3/model/PutBucketCorsRequest.h>
  90. #include <aws/s3/model/PutBucketEncryptionRequest.h>
  91. #include <aws/s3/model/PutBucketIntelligentTieringConfigurationRequest.h>
  92. #include <aws/s3/model/PutBucketInventoryConfigurationRequest.h>
  93. #include <aws/s3/model/PutBucketLifecycleConfigurationRequest.h>
  94. #include <aws/s3/model/PutBucketLoggingRequest.h>
  95. #include <aws/s3/model/PutBucketMetricsConfigurationRequest.h>
  96. #include <aws/s3/model/PutBucketNotificationConfigurationRequest.h>
  97. #include <aws/s3/model/PutBucketOwnershipControlsRequest.h>
  98. #include <aws/s3/model/PutBucketPolicyRequest.h>
  99. #include <aws/s3/model/PutBucketReplicationRequest.h>
  100. #include <aws/s3/model/PutBucketRequestPaymentRequest.h>
  101. #include <aws/s3/model/PutBucketTaggingRequest.h>
  102. #include <aws/s3/model/PutBucketVersioningRequest.h>
  103. #include <aws/s3/model/PutBucketWebsiteRequest.h>
  104. #include <aws/s3/model/PutObjectRequest.h>
  105. #include <aws/s3/model/PutObjectAclRequest.h>
  106. #include <aws/s3/model/PutObjectLegalHoldRequest.h>
  107. #include <aws/s3/model/PutObjectLockConfigurationRequest.h>
  108. #include <aws/s3/model/PutObjectRetentionRequest.h>
  109. #include <aws/s3/model/PutObjectTaggingRequest.h>
  110. #include <aws/s3/model/PutPublicAccessBlockRequest.h>
  111. #include <aws/s3/model/RestoreObjectRequest.h>
  112. #include <aws/s3/model/SelectObjectContentRequest.h>
  113. #include <aws/s3/model/UploadPartRequest.h>
  114. #include <aws/s3/model/UploadPartCopyRequest.h>
  115. #include <aws/s3/model/WriteGetObjectResponseRequest.h>
  116. using namespace Aws;
  117. using namespace Aws::Auth;
  118. using namespace Aws::Client;
  119. using namespace Aws::S3;
  120. using namespace Aws::S3::Model;
  121. using namespace Aws::Http;
  122. using namespace Aws::Utils::Xml;
  123. using ResolveEndpointOutcome = Aws::Endpoint::ResolveEndpointOutcome;
  124. const char* S3Client::SERVICE_NAME = "s3";
  125. const char* S3Client::ALLOCATION_TAG = "S3Client";
  126. S3Client::S3Client(const S3::S3ClientConfiguration& clientConfiguration,
  127. std::shared_ptr<S3EndpointProviderBase> endpointProvider) :
  128. BASECLASS(clientConfiguration,
  129. Aws::MakeShared<Aws::Auth::DefaultAuthSignerProvider>(ALLOCATION_TAG,
  130. Aws::MakeShared<DefaultAWSCredentialsProviderChain>(ALLOCATION_TAG),
  131. SERVICE_NAME,
  132. Aws::Region::ComputeSignerRegion(clientConfiguration.region),
  133. clientConfiguration.payloadSigningPolicy,
  134. /*doubleEncodeValue*/ false),
  135. Aws::MakeShared<S3ErrorMarshaller>(ALLOCATION_TAG)),
  136. m_clientConfiguration(clientConfiguration),
  137. m_executor(clientConfiguration.executor),
  138. m_endpointProvider(std::move(endpointProvider))
  139. {
  140. init(m_clientConfiguration);
  141. }
  142. S3Client::S3Client(const AWSCredentials& credentials,
  143. std::shared_ptr<S3EndpointProviderBase> endpointProvider,
  144. const S3::S3ClientConfiguration& clientConfiguration) :
  145. BASECLASS(clientConfiguration,
  146. Aws::MakeShared<Aws::Auth::DefaultAuthSignerProvider>(ALLOCATION_TAG,
  147. Aws::MakeShared<SimpleAWSCredentialsProvider>(ALLOCATION_TAG, credentials),
  148. SERVICE_NAME,
  149. Aws::Region::ComputeSignerRegion(clientConfiguration.region),
  150. clientConfiguration.payloadSigningPolicy,
  151. /*doubleEncodeValue*/ false),
  152. Aws::MakeShared<S3ErrorMarshaller>(ALLOCATION_TAG)),
  153. m_clientConfiguration(clientConfiguration),
  154. m_executor(clientConfiguration.executor),
  155. m_endpointProvider(std::move(endpointProvider))
  156. {
  157. init(m_clientConfiguration);
  158. }
  159. S3Client::S3Client(const std::shared_ptr<AWSCredentialsProvider>& credentialsProvider,
  160. std::shared_ptr<S3EndpointProviderBase> endpointProvider,
  161. const S3::S3ClientConfiguration& clientConfiguration) :
  162. BASECLASS(clientConfiguration,
  163. Aws::MakeShared<Aws::Auth::DefaultAuthSignerProvider>(ALLOCATION_TAG,
  164. credentialsProvider,
  165. SERVICE_NAME,
  166. Aws::Region::ComputeSignerRegion(clientConfiguration.region),
  167. clientConfiguration.payloadSigningPolicy,
  168. /*doubleEncodeValue*/ false),
  169. Aws::MakeShared<S3ErrorMarshaller>(ALLOCATION_TAG)),
  170. m_clientConfiguration(clientConfiguration),
  171. m_executor(clientConfiguration.executor),
  172. m_endpointProvider(std::move(endpointProvider))
  173. {
  174. init(m_clientConfiguration);
  175. }
  176. /* Legacy constructors due deprecation */
  177. S3Client::S3Client(const Client::ClientConfiguration& clientConfiguration,
  178. Aws::Client::AWSAuthV4Signer::PayloadSigningPolicy signPayloads /*= Never*/,
  179. bool useVirtualAddressing /*= true*/,
  180. Aws::S3::US_EAST_1_REGIONAL_ENDPOINT_OPTION USEast1RegionalEndPointOption) :
  181. BASECLASS(clientConfiguration,
  182. Aws::MakeShared<Aws::Auth::DefaultAuthSignerProvider>(ALLOCATION_TAG,
  183. Aws::MakeShared<DefaultAWSCredentialsProviderChain>(ALLOCATION_TAG),
  184. SERVICE_NAME,
  185. Aws::Region::ComputeSignerRegion(clientConfiguration.region),
  186. signPayloads,
  187. /*doubleEncodeValue*/ false),
  188. Aws::MakeShared<S3ErrorMarshaller>(ALLOCATION_TAG)),
  189. m_clientConfiguration(clientConfiguration, signPayloads, useVirtualAddressing, USEast1RegionalEndPointOption),
  190. m_executor(clientConfiguration.executor),
  191. m_endpointProvider(Aws::MakeShared<S3EndpointProvider>(ALLOCATION_TAG))
  192. {
  193. init(m_clientConfiguration);
  194. }
  195. S3Client::S3Client(const AWSCredentials& credentials,
  196. const Client::ClientConfiguration& clientConfiguration,
  197. Aws::Client::AWSAuthV4Signer::PayloadSigningPolicy signPayloads /*= Never*/,
  198. bool useVirtualAddressing /*= true*/,
  199. Aws::S3::US_EAST_1_REGIONAL_ENDPOINT_OPTION USEast1RegionalEndPointOption) :
  200. BASECLASS(clientConfiguration,
  201. Aws::MakeShared<Aws::Auth::DefaultAuthSignerProvider>(ALLOCATION_TAG,
  202. Aws::MakeShared<SimpleAWSCredentialsProvider>(ALLOCATION_TAG, credentials),
  203. SERVICE_NAME,
  204. Aws::Region::ComputeSignerRegion(clientConfiguration.region),
  205. signPayloads,
  206. /*doubleEncodeValue*/ false),
  207. Aws::MakeShared<S3ErrorMarshaller>(ALLOCATION_TAG)),
  208. m_clientConfiguration(clientConfiguration, signPayloads, useVirtualAddressing, USEast1RegionalEndPointOption),
  209. m_executor(clientConfiguration.executor),
  210. m_endpointProvider(Aws::MakeShared<S3EndpointProvider>(ALLOCATION_TAG))
  211. {
  212. init(m_clientConfiguration);
  213. }
  214. S3Client::S3Client(const std::shared_ptr<AWSCredentialsProvider>& credentialsProvider,
  215. const Client::ClientConfiguration& clientConfiguration,
  216. Aws::Client::AWSAuthV4Signer::PayloadSigningPolicy signPayloads /*= Never*/,
  217. bool useVirtualAddressing /*= true*/,
  218. Aws::S3::US_EAST_1_REGIONAL_ENDPOINT_OPTION USEast1RegionalEndPointOption) :
  219. BASECLASS(clientConfiguration,
  220. Aws::MakeShared<Aws::Auth::DefaultAuthSignerProvider>(ALLOCATION_TAG,
  221. credentialsProvider,
  222. SERVICE_NAME,
  223. Aws::Region::ComputeSignerRegion(clientConfiguration.region),
  224. signPayloads,
  225. /*doubleEncodeValue*/ false),
  226. Aws::MakeShared<S3ErrorMarshaller>(ALLOCATION_TAG)),
  227. m_clientConfiguration(clientConfiguration, signPayloads, useVirtualAddressing, USEast1RegionalEndPointOption),
  228. m_executor(clientConfiguration.executor),
  229. m_endpointProvider(Aws::MakeShared<S3EndpointProvider>(ALLOCATION_TAG))
  230. {
  231. init(m_clientConfiguration);
  232. }
  233. /* End of legacy constructors due deprecation */
  234. S3Client::~S3Client()
  235. {
  236. }
  237. std::shared_ptr<S3EndpointProviderBase>& S3Client::accessEndpointProvider()
  238. {
  239. return m_endpointProvider;
  240. }
  241. void S3Client::init(const S3::S3ClientConfiguration& config)
  242. {
  243. AWSClient::SetServiceClientName("S3");
  244. AWS_CHECK_PTR(SERVICE_NAME, m_endpointProvider);
  245. m_endpointProvider->InitBuiltInParameters(config);
  246. }
  247. void S3Client::OverrideEndpoint(const Aws::String& endpoint)
  248. {
  249. AWS_CHECK_PTR(SERVICE_NAME, m_endpointProvider);
  250. m_endpointProvider->OverrideEndpoint(endpoint);
  251. }
  252. AbortMultipartUploadOutcome S3Client::AbortMultipartUpload(const AbortMultipartUploadRequest& request) const
  253. {
  254. AWS_OPERATION_CHECK_PTR(m_endpointProvider, AbortMultipartUpload, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  255. if (!request.BucketHasBeenSet())
  256. {
  257. AWS_LOGSTREAM_ERROR("AbortMultipartUpload", "Required field: Bucket, is not set");
  258. return AbortMultipartUploadOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  259. }
  260. if (!request.KeyHasBeenSet())
  261. {
  262. AWS_LOGSTREAM_ERROR("AbortMultipartUpload", "Required field: Key, is not set");
  263. return AbortMultipartUploadOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Key]", false));
  264. }
  265. if (!request.UploadIdHasBeenSet())
  266. {
  267. AWS_LOGSTREAM_ERROR("AbortMultipartUpload", "Required field: UploadId, is not set");
  268. return AbortMultipartUploadOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [UploadId]", false));
  269. }
  270. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  271. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, AbortMultipartUpload, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  272. endpointResolutionOutcome.GetResult().AddPathSegments(request.GetKey());
  273. return AbortMultipartUploadOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_DELETE));
  274. }
  275. CompleteMultipartUploadOutcome S3Client::CompleteMultipartUpload(const CompleteMultipartUploadRequest& request) const
  276. {
  277. AWS_OPERATION_CHECK_PTR(m_endpointProvider, CompleteMultipartUpload, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  278. if (!request.BucketHasBeenSet())
  279. {
  280. AWS_LOGSTREAM_ERROR("CompleteMultipartUpload", "Required field: Bucket, is not set");
  281. return CompleteMultipartUploadOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  282. }
  283. if (!request.KeyHasBeenSet())
  284. {
  285. AWS_LOGSTREAM_ERROR("CompleteMultipartUpload", "Required field: Key, is not set");
  286. return CompleteMultipartUploadOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Key]", false));
  287. }
  288. if (!request.UploadIdHasBeenSet())
  289. {
  290. AWS_LOGSTREAM_ERROR("CompleteMultipartUpload", "Required field: UploadId, is not set");
  291. return CompleteMultipartUploadOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [UploadId]", false));
  292. }
  293. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  294. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, CompleteMultipartUpload, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  295. endpointResolutionOutcome.GetResult().AddPathSegments(request.GetKey());
  296. return CompleteMultipartUploadOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_POST));
  297. }
  298. CopyObjectOutcome S3Client::CopyObject(const CopyObjectRequest& request) const
  299. {
  300. AWS_OPERATION_CHECK_PTR(m_endpointProvider, CopyObject, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  301. if (!request.BucketHasBeenSet())
  302. {
  303. AWS_LOGSTREAM_ERROR("CopyObject", "Required field: Bucket, is not set");
  304. return CopyObjectOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  305. }
  306. if (!request.CopySourceHasBeenSet())
  307. {
  308. AWS_LOGSTREAM_ERROR("CopyObject", "Required field: CopySource, is not set");
  309. return CopyObjectOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [CopySource]", false));
  310. }
  311. if (!request.KeyHasBeenSet())
  312. {
  313. AWS_LOGSTREAM_ERROR("CopyObject", "Required field: Key, is not set");
  314. return CopyObjectOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Key]", false));
  315. }
  316. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  317. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, CopyObject, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  318. endpointResolutionOutcome.GetResult().AddPathSegments(request.GetKey());
  319. return CopyObjectOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_PUT));
  320. }
  321. CreateBucketOutcome S3Client::CreateBucket(const CreateBucketRequest& request) const
  322. {
  323. AWS_OPERATION_CHECK_PTR(m_endpointProvider, CreateBucket, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  324. if (!request.BucketHasBeenSet())
  325. {
  326. AWS_LOGSTREAM_ERROR("CreateBucket", "Required field: Bucket, is not set");
  327. return CreateBucketOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  328. }
  329. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  330. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, CreateBucket, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  331. return CreateBucketOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_PUT));
  332. }
  333. CreateMultipartUploadOutcome S3Client::CreateMultipartUpload(const CreateMultipartUploadRequest& request) const
  334. {
  335. AWS_OPERATION_CHECK_PTR(m_endpointProvider, CreateMultipartUpload, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  336. if (!request.BucketHasBeenSet())
  337. {
  338. AWS_LOGSTREAM_ERROR("CreateMultipartUpload", "Required field: Bucket, is not set");
  339. return CreateMultipartUploadOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  340. }
  341. if (!request.KeyHasBeenSet())
  342. {
  343. AWS_LOGSTREAM_ERROR("CreateMultipartUpload", "Required field: Key, is not set");
  344. return CreateMultipartUploadOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Key]", false));
  345. }
  346. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  347. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, CreateMultipartUpload, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  348. Aws::StringStream ss;
  349. endpointResolutionOutcome.GetResult().AddPathSegments(request.GetKey());
  350. ss.str("?uploads");
  351. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  352. return CreateMultipartUploadOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_POST));
  353. }
  354. DeleteBucketOutcome S3Client::DeleteBucket(const DeleteBucketRequest& request) const
  355. {
  356. AWS_OPERATION_CHECK_PTR(m_endpointProvider, DeleteBucket, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  357. if (!request.BucketHasBeenSet())
  358. {
  359. AWS_LOGSTREAM_ERROR("DeleteBucket", "Required field: Bucket, is not set");
  360. return DeleteBucketOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  361. }
  362. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  363. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, DeleteBucket, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  364. return DeleteBucketOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_DELETE));
  365. }
  366. DeleteBucketAnalyticsConfigurationOutcome S3Client::DeleteBucketAnalyticsConfiguration(const DeleteBucketAnalyticsConfigurationRequest& request) const
  367. {
  368. AWS_OPERATION_CHECK_PTR(m_endpointProvider, DeleteBucketAnalyticsConfiguration, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  369. if (!request.BucketHasBeenSet())
  370. {
  371. AWS_LOGSTREAM_ERROR("DeleteBucketAnalyticsConfiguration", "Required field: Bucket, is not set");
  372. return DeleteBucketAnalyticsConfigurationOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  373. }
  374. if (!request.IdHasBeenSet())
  375. {
  376. AWS_LOGSTREAM_ERROR("DeleteBucketAnalyticsConfiguration", "Required field: Id, is not set");
  377. return DeleteBucketAnalyticsConfigurationOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Id]", false));
  378. }
  379. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  380. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, DeleteBucketAnalyticsConfiguration, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  381. Aws::StringStream ss;
  382. ss.str("?analytics");
  383. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  384. return DeleteBucketAnalyticsConfigurationOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_DELETE));
  385. }
  386. DeleteBucketCorsOutcome S3Client::DeleteBucketCors(const DeleteBucketCorsRequest& request) const
  387. {
  388. AWS_OPERATION_CHECK_PTR(m_endpointProvider, DeleteBucketCors, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  389. if (!request.BucketHasBeenSet())
  390. {
  391. AWS_LOGSTREAM_ERROR("DeleteBucketCors", "Required field: Bucket, is not set");
  392. return DeleteBucketCorsOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  393. }
  394. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  395. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, DeleteBucketCors, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  396. Aws::StringStream ss;
  397. ss.str("?cors");
  398. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  399. return DeleteBucketCorsOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_DELETE));
  400. }
  401. DeleteBucketEncryptionOutcome S3Client::DeleteBucketEncryption(const DeleteBucketEncryptionRequest& request) const
  402. {
  403. AWS_OPERATION_CHECK_PTR(m_endpointProvider, DeleteBucketEncryption, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  404. if (!request.BucketHasBeenSet())
  405. {
  406. AWS_LOGSTREAM_ERROR("DeleteBucketEncryption", "Required field: Bucket, is not set");
  407. return DeleteBucketEncryptionOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  408. }
  409. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  410. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, DeleteBucketEncryption, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  411. Aws::StringStream ss;
  412. ss.str("?encryption");
  413. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  414. return DeleteBucketEncryptionOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_DELETE));
  415. }
  416. DeleteBucketIntelligentTieringConfigurationOutcome S3Client::DeleteBucketIntelligentTieringConfiguration(const DeleteBucketIntelligentTieringConfigurationRequest& request) const
  417. {
  418. AWS_OPERATION_CHECK_PTR(m_endpointProvider, DeleteBucketIntelligentTieringConfiguration, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  419. if (!request.BucketHasBeenSet())
  420. {
  421. AWS_LOGSTREAM_ERROR("DeleteBucketIntelligentTieringConfiguration", "Required field: Bucket, is not set");
  422. return DeleteBucketIntelligentTieringConfigurationOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  423. }
  424. if (!request.IdHasBeenSet())
  425. {
  426. AWS_LOGSTREAM_ERROR("DeleteBucketIntelligentTieringConfiguration", "Required field: Id, is not set");
  427. return DeleteBucketIntelligentTieringConfigurationOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Id]", false));
  428. }
  429. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  430. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, DeleteBucketIntelligentTieringConfiguration, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  431. Aws::StringStream ss;
  432. ss.str("?intelligent-tiering");
  433. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  434. return DeleteBucketIntelligentTieringConfigurationOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_DELETE));
  435. }
  436. DeleteBucketInventoryConfigurationOutcome S3Client::DeleteBucketInventoryConfiguration(const DeleteBucketInventoryConfigurationRequest& request) const
  437. {
  438. AWS_OPERATION_CHECK_PTR(m_endpointProvider, DeleteBucketInventoryConfiguration, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  439. if (!request.BucketHasBeenSet())
  440. {
  441. AWS_LOGSTREAM_ERROR("DeleteBucketInventoryConfiguration", "Required field: Bucket, is not set");
  442. return DeleteBucketInventoryConfigurationOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  443. }
  444. if (!request.IdHasBeenSet())
  445. {
  446. AWS_LOGSTREAM_ERROR("DeleteBucketInventoryConfiguration", "Required field: Id, is not set");
  447. return DeleteBucketInventoryConfigurationOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Id]", false));
  448. }
  449. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  450. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, DeleteBucketInventoryConfiguration, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  451. Aws::StringStream ss;
  452. ss.str("?inventory");
  453. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  454. return DeleteBucketInventoryConfigurationOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_DELETE));
  455. }
  456. DeleteBucketLifecycleOutcome S3Client::DeleteBucketLifecycle(const DeleteBucketLifecycleRequest& request) const
  457. {
  458. AWS_OPERATION_CHECK_PTR(m_endpointProvider, DeleteBucketLifecycle, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  459. if (!request.BucketHasBeenSet())
  460. {
  461. AWS_LOGSTREAM_ERROR("DeleteBucketLifecycle", "Required field: Bucket, is not set");
  462. return DeleteBucketLifecycleOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  463. }
  464. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  465. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, DeleteBucketLifecycle, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  466. Aws::StringStream ss;
  467. ss.str("?lifecycle");
  468. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  469. return DeleteBucketLifecycleOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_DELETE));
  470. }
  471. DeleteBucketMetricsConfigurationOutcome S3Client::DeleteBucketMetricsConfiguration(const DeleteBucketMetricsConfigurationRequest& request) const
  472. {
  473. AWS_OPERATION_CHECK_PTR(m_endpointProvider, DeleteBucketMetricsConfiguration, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  474. if (!request.BucketHasBeenSet())
  475. {
  476. AWS_LOGSTREAM_ERROR("DeleteBucketMetricsConfiguration", "Required field: Bucket, is not set");
  477. return DeleteBucketMetricsConfigurationOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  478. }
  479. if (!request.IdHasBeenSet())
  480. {
  481. AWS_LOGSTREAM_ERROR("DeleteBucketMetricsConfiguration", "Required field: Id, is not set");
  482. return DeleteBucketMetricsConfigurationOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Id]", false));
  483. }
  484. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  485. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, DeleteBucketMetricsConfiguration, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  486. Aws::StringStream ss;
  487. ss.str("?metrics");
  488. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  489. return DeleteBucketMetricsConfigurationOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_DELETE));
  490. }
  491. DeleteBucketOwnershipControlsOutcome S3Client::DeleteBucketOwnershipControls(const DeleteBucketOwnershipControlsRequest& request) const
  492. {
  493. AWS_OPERATION_CHECK_PTR(m_endpointProvider, DeleteBucketOwnershipControls, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  494. if (!request.BucketHasBeenSet())
  495. {
  496. AWS_LOGSTREAM_ERROR("DeleteBucketOwnershipControls", "Required field: Bucket, is not set");
  497. return DeleteBucketOwnershipControlsOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  498. }
  499. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  500. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, DeleteBucketOwnershipControls, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  501. Aws::StringStream ss;
  502. ss.str("?ownershipControls");
  503. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  504. return DeleteBucketOwnershipControlsOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_DELETE));
  505. }
  506. DeleteBucketPolicyOutcome S3Client::DeleteBucketPolicy(const DeleteBucketPolicyRequest& request) const
  507. {
  508. AWS_OPERATION_CHECK_PTR(m_endpointProvider, DeleteBucketPolicy, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  509. if (!request.BucketHasBeenSet())
  510. {
  511. AWS_LOGSTREAM_ERROR("DeleteBucketPolicy", "Required field: Bucket, is not set");
  512. return DeleteBucketPolicyOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  513. }
  514. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  515. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, DeleteBucketPolicy, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  516. Aws::StringStream ss;
  517. ss.str("?policy");
  518. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  519. return DeleteBucketPolicyOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_DELETE));
  520. }
  521. DeleteBucketReplicationOutcome S3Client::DeleteBucketReplication(const DeleteBucketReplicationRequest& request) const
  522. {
  523. AWS_OPERATION_CHECK_PTR(m_endpointProvider, DeleteBucketReplication, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  524. if (!request.BucketHasBeenSet())
  525. {
  526. AWS_LOGSTREAM_ERROR("DeleteBucketReplication", "Required field: Bucket, is not set");
  527. return DeleteBucketReplicationOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  528. }
  529. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  530. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, DeleteBucketReplication, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  531. Aws::StringStream ss;
  532. ss.str("?replication");
  533. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  534. return DeleteBucketReplicationOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_DELETE));
  535. }
  536. DeleteBucketTaggingOutcome S3Client::DeleteBucketTagging(const DeleteBucketTaggingRequest& request) const
  537. {
  538. AWS_OPERATION_CHECK_PTR(m_endpointProvider, DeleteBucketTagging, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  539. if (!request.BucketHasBeenSet())
  540. {
  541. AWS_LOGSTREAM_ERROR("DeleteBucketTagging", "Required field: Bucket, is not set");
  542. return DeleteBucketTaggingOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  543. }
  544. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  545. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, DeleteBucketTagging, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  546. Aws::StringStream ss;
  547. ss.str("?tagging");
  548. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  549. return DeleteBucketTaggingOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_DELETE));
  550. }
  551. DeleteBucketWebsiteOutcome S3Client::DeleteBucketWebsite(const DeleteBucketWebsiteRequest& request) const
  552. {
  553. AWS_OPERATION_CHECK_PTR(m_endpointProvider, DeleteBucketWebsite, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  554. if (!request.BucketHasBeenSet())
  555. {
  556. AWS_LOGSTREAM_ERROR("DeleteBucketWebsite", "Required field: Bucket, is not set");
  557. return DeleteBucketWebsiteOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  558. }
  559. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  560. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, DeleteBucketWebsite, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  561. Aws::StringStream ss;
  562. ss.str("?website");
  563. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  564. return DeleteBucketWebsiteOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_DELETE));
  565. }
  566. DeleteObjectOutcome S3Client::DeleteObject(const DeleteObjectRequest& request) const
  567. {
  568. AWS_OPERATION_CHECK_PTR(m_endpointProvider, DeleteObject, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  569. if (!request.BucketHasBeenSet())
  570. {
  571. AWS_LOGSTREAM_ERROR("DeleteObject", "Required field: Bucket, is not set");
  572. return DeleteObjectOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  573. }
  574. if (!request.KeyHasBeenSet())
  575. {
  576. AWS_LOGSTREAM_ERROR("DeleteObject", "Required field: Key, is not set");
  577. return DeleteObjectOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Key]", false));
  578. }
  579. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  580. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, DeleteObject, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  581. endpointResolutionOutcome.GetResult().AddPathSegments(request.GetKey());
  582. return DeleteObjectOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_DELETE));
  583. }
  584. DeleteObjectTaggingOutcome S3Client::DeleteObjectTagging(const DeleteObjectTaggingRequest& request) const
  585. {
  586. AWS_OPERATION_CHECK_PTR(m_endpointProvider, DeleteObjectTagging, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  587. if (!request.BucketHasBeenSet())
  588. {
  589. AWS_LOGSTREAM_ERROR("DeleteObjectTagging", "Required field: Bucket, is not set");
  590. return DeleteObjectTaggingOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  591. }
  592. if (!request.KeyHasBeenSet())
  593. {
  594. AWS_LOGSTREAM_ERROR("DeleteObjectTagging", "Required field: Key, is not set");
  595. return DeleteObjectTaggingOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Key]", false));
  596. }
  597. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  598. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, DeleteObjectTagging, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  599. Aws::StringStream ss;
  600. endpointResolutionOutcome.GetResult().AddPathSegments(request.GetKey());
  601. ss.str("?tagging");
  602. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  603. return DeleteObjectTaggingOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_DELETE));
  604. }
  605. DeleteObjectsOutcome S3Client::DeleteObjects(const DeleteObjectsRequest& request) const
  606. {
  607. AWS_OPERATION_CHECK_PTR(m_endpointProvider, DeleteObjects, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  608. if (!request.BucketHasBeenSet())
  609. {
  610. AWS_LOGSTREAM_ERROR("DeleteObjects", "Required field: Bucket, is not set");
  611. return DeleteObjectsOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  612. }
  613. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  614. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, DeleteObjects, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  615. Aws::StringStream ss;
  616. ss.str("?delete");
  617. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  618. return DeleteObjectsOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_POST));
  619. }
  620. DeletePublicAccessBlockOutcome S3Client::DeletePublicAccessBlock(const DeletePublicAccessBlockRequest& request) const
  621. {
  622. AWS_OPERATION_CHECK_PTR(m_endpointProvider, DeletePublicAccessBlock, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  623. if (!request.BucketHasBeenSet())
  624. {
  625. AWS_LOGSTREAM_ERROR("DeletePublicAccessBlock", "Required field: Bucket, is not set");
  626. return DeletePublicAccessBlockOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  627. }
  628. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  629. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, DeletePublicAccessBlock, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  630. Aws::StringStream ss;
  631. ss.str("?publicAccessBlock");
  632. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  633. return DeletePublicAccessBlockOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_DELETE));
  634. }
  635. GetBucketAccelerateConfigurationOutcome S3Client::GetBucketAccelerateConfiguration(const GetBucketAccelerateConfigurationRequest& request) const
  636. {
  637. AWS_OPERATION_CHECK_PTR(m_endpointProvider, GetBucketAccelerateConfiguration, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  638. if (!request.BucketHasBeenSet())
  639. {
  640. AWS_LOGSTREAM_ERROR("GetBucketAccelerateConfiguration", "Required field: Bucket, is not set");
  641. return GetBucketAccelerateConfigurationOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  642. }
  643. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  644. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, GetBucketAccelerateConfiguration, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  645. Aws::StringStream ss;
  646. ss.str("?accelerate");
  647. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  648. return GetBucketAccelerateConfigurationOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_GET));
  649. }
  650. GetBucketAclOutcome S3Client::GetBucketAcl(const GetBucketAclRequest& request) const
  651. {
  652. AWS_OPERATION_CHECK_PTR(m_endpointProvider, GetBucketAcl, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  653. if (!request.BucketHasBeenSet())
  654. {
  655. AWS_LOGSTREAM_ERROR("GetBucketAcl", "Required field: Bucket, is not set");
  656. return GetBucketAclOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  657. }
  658. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  659. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, GetBucketAcl, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  660. Aws::StringStream ss;
  661. ss.str("?acl");
  662. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  663. return GetBucketAclOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_GET));
  664. }
  665. GetBucketAnalyticsConfigurationOutcome S3Client::GetBucketAnalyticsConfiguration(const GetBucketAnalyticsConfigurationRequest& request) const
  666. {
  667. AWS_OPERATION_CHECK_PTR(m_endpointProvider, GetBucketAnalyticsConfiguration, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  668. if (!request.BucketHasBeenSet())
  669. {
  670. AWS_LOGSTREAM_ERROR("GetBucketAnalyticsConfiguration", "Required field: Bucket, is not set");
  671. return GetBucketAnalyticsConfigurationOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  672. }
  673. if (!request.IdHasBeenSet())
  674. {
  675. AWS_LOGSTREAM_ERROR("GetBucketAnalyticsConfiguration", "Required field: Id, is not set");
  676. return GetBucketAnalyticsConfigurationOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Id]", false));
  677. }
  678. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  679. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, GetBucketAnalyticsConfiguration, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  680. Aws::StringStream ss;
  681. ss.str("?analytics");
  682. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  683. return GetBucketAnalyticsConfigurationOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_GET));
  684. }
  685. GetBucketCorsOutcome S3Client::GetBucketCors(const GetBucketCorsRequest& request) const
  686. {
  687. AWS_OPERATION_CHECK_PTR(m_endpointProvider, GetBucketCors, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  688. if (!request.BucketHasBeenSet())
  689. {
  690. AWS_LOGSTREAM_ERROR("GetBucketCors", "Required field: Bucket, is not set");
  691. return GetBucketCorsOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  692. }
  693. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  694. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, GetBucketCors, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  695. Aws::StringStream ss;
  696. ss.str("?cors");
  697. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  698. return GetBucketCorsOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_GET));
  699. }
  700. GetBucketEncryptionOutcome S3Client::GetBucketEncryption(const GetBucketEncryptionRequest& request) const
  701. {
  702. AWS_OPERATION_CHECK_PTR(m_endpointProvider, GetBucketEncryption, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  703. if (!request.BucketHasBeenSet())
  704. {
  705. AWS_LOGSTREAM_ERROR("GetBucketEncryption", "Required field: Bucket, is not set");
  706. return GetBucketEncryptionOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  707. }
  708. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  709. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, GetBucketEncryption, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  710. Aws::StringStream ss;
  711. ss.str("?encryption");
  712. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  713. return GetBucketEncryptionOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_GET));
  714. }
  715. GetBucketIntelligentTieringConfigurationOutcome S3Client::GetBucketIntelligentTieringConfiguration(const GetBucketIntelligentTieringConfigurationRequest& request) const
  716. {
  717. AWS_OPERATION_CHECK_PTR(m_endpointProvider, GetBucketIntelligentTieringConfiguration, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  718. if (!request.BucketHasBeenSet())
  719. {
  720. AWS_LOGSTREAM_ERROR("GetBucketIntelligentTieringConfiguration", "Required field: Bucket, is not set");
  721. return GetBucketIntelligentTieringConfigurationOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  722. }
  723. if (!request.IdHasBeenSet())
  724. {
  725. AWS_LOGSTREAM_ERROR("GetBucketIntelligentTieringConfiguration", "Required field: Id, is not set");
  726. return GetBucketIntelligentTieringConfigurationOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Id]", false));
  727. }
  728. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  729. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, GetBucketIntelligentTieringConfiguration, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  730. Aws::StringStream ss;
  731. ss.str("?intelligent-tiering");
  732. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  733. return GetBucketIntelligentTieringConfigurationOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_GET));
  734. }
  735. GetBucketInventoryConfigurationOutcome S3Client::GetBucketInventoryConfiguration(const GetBucketInventoryConfigurationRequest& request) const
  736. {
  737. AWS_OPERATION_CHECK_PTR(m_endpointProvider, GetBucketInventoryConfiguration, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  738. if (!request.BucketHasBeenSet())
  739. {
  740. AWS_LOGSTREAM_ERROR("GetBucketInventoryConfiguration", "Required field: Bucket, is not set");
  741. return GetBucketInventoryConfigurationOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  742. }
  743. if (!request.IdHasBeenSet())
  744. {
  745. AWS_LOGSTREAM_ERROR("GetBucketInventoryConfiguration", "Required field: Id, is not set");
  746. return GetBucketInventoryConfigurationOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Id]", false));
  747. }
  748. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  749. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, GetBucketInventoryConfiguration, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  750. Aws::StringStream ss;
  751. ss.str("?inventory");
  752. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  753. return GetBucketInventoryConfigurationOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_GET));
  754. }
  755. GetBucketLifecycleConfigurationOutcome S3Client::GetBucketLifecycleConfiguration(const GetBucketLifecycleConfigurationRequest& request) const
  756. {
  757. AWS_OPERATION_CHECK_PTR(m_endpointProvider, GetBucketLifecycleConfiguration, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  758. if (!request.BucketHasBeenSet())
  759. {
  760. AWS_LOGSTREAM_ERROR("GetBucketLifecycleConfiguration", "Required field: Bucket, is not set");
  761. return GetBucketLifecycleConfigurationOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  762. }
  763. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  764. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, GetBucketLifecycleConfiguration, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  765. Aws::StringStream ss;
  766. ss.str("?lifecycle");
  767. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  768. return GetBucketLifecycleConfigurationOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_GET));
  769. }
  770. GetBucketLocationOutcome S3Client::GetBucketLocation(const GetBucketLocationRequest& request) const
  771. {
  772. AWS_OPERATION_CHECK_PTR(m_endpointProvider, GetBucketLocation, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  773. if (!request.BucketHasBeenSet())
  774. {
  775. AWS_LOGSTREAM_ERROR("GetBucketLocation", "Required field: Bucket, is not set");
  776. return GetBucketLocationOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  777. }
  778. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  779. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, GetBucketLocation, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  780. Aws::StringStream ss;
  781. ss.str("?location");
  782. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  783. return GetBucketLocationOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_GET));
  784. }
  785. GetBucketLoggingOutcome S3Client::GetBucketLogging(const GetBucketLoggingRequest& request) const
  786. {
  787. AWS_OPERATION_CHECK_PTR(m_endpointProvider, GetBucketLogging, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  788. if (!request.BucketHasBeenSet())
  789. {
  790. AWS_LOGSTREAM_ERROR("GetBucketLogging", "Required field: Bucket, is not set");
  791. return GetBucketLoggingOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  792. }
  793. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  794. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, GetBucketLogging, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  795. Aws::StringStream ss;
  796. ss.str("?logging");
  797. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  798. return GetBucketLoggingOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_GET));
  799. }
  800. GetBucketMetricsConfigurationOutcome S3Client::GetBucketMetricsConfiguration(const GetBucketMetricsConfigurationRequest& request) const
  801. {
  802. AWS_OPERATION_CHECK_PTR(m_endpointProvider, GetBucketMetricsConfiguration, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  803. if (!request.BucketHasBeenSet())
  804. {
  805. AWS_LOGSTREAM_ERROR("GetBucketMetricsConfiguration", "Required field: Bucket, is not set");
  806. return GetBucketMetricsConfigurationOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  807. }
  808. if (!request.IdHasBeenSet())
  809. {
  810. AWS_LOGSTREAM_ERROR("GetBucketMetricsConfiguration", "Required field: Id, is not set");
  811. return GetBucketMetricsConfigurationOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Id]", false));
  812. }
  813. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  814. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, GetBucketMetricsConfiguration, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  815. Aws::StringStream ss;
  816. ss.str("?metrics");
  817. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  818. return GetBucketMetricsConfigurationOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_GET));
  819. }
  820. GetBucketNotificationConfigurationOutcome S3Client::GetBucketNotificationConfiguration(const GetBucketNotificationConfigurationRequest& request) const
  821. {
  822. AWS_OPERATION_CHECK_PTR(m_endpointProvider, GetBucketNotificationConfiguration, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  823. if (!request.BucketHasBeenSet())
  824. {
  825. AWS_LOGSTREAM_ERROR("GetBucketNotificationConfiguration", "Required field: Bucket, is not set");
  826. return GetBucketNotificationConfigurationOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  827. }
  828. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  829. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, GetBucketNotificationConfiguration, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  830. Aws::StringStream ss;
  831. ss.str("?notification");
  832. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  833. return GetBucketNotificationConfigurationOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_GET));
  834. }
  835. GetBucketOwnershipControlsOutcome S3Client::GetBucketOwnershipControls(const GetBucketOwnershipControlsRequest& request) const
  836. {
  837. AWS_OPERATION_CHECK_PTR(m_endpointProvider, GetBucketOwnershipControls, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  838. if (!request.BucketHasBeenSet())
  839. {
  840. AWS_LOGSTREAM_ERROR("GetBucketOwnershipControls", "Required field: Bucket, is not set");
  841. return GetBucketOwnershipControlsOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  842. }
  843. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  844. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, GetBucketOwnershipControls, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  845. Aws::StringStream ss;
  846. ss.str("?ownershipControls");
  847. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  848. return GetBucketOwnershipControlsOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_GET));
  849. }
  850. GetBucketPolicyOutcome S3Client::GetBucketPolicy(const GetBucketPolicyRequest& request) const
  851. {
  852. AWS_OPERATION_CHECK_PTR(m_endpointProvider, GetBucketPolicy, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  853. if (!request.BucketHasBeenSet())
  854. {
  855. AWS_LOGSTREAM_ERROR("GetBucketPolicy", "Required field: Bucket, is not set");
  856. return GetBucketPolicyOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  857. }
  858. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  859. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, GetBucketPolicy, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  860. Aws::StringStream ss;
  861. ss.str("?policy");
  862. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  863. return GetBucketPolicyOutcome(MakeRequestWithUnparsedResponse(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_GET));
  864. }
  865. GetBucketPolicyStatusOutcome S3Client::GetBucketPolicyStatus(const GetBucketPolicyStatusRequest& request) const
  866. {
  867. AWS_OPERATION_CHECK_PTR(m_endpointProvider, GetBucketPolicyStatus, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  868. if (!request.BucketHasBeenSet())
  869. {
  870. AWS_LOGSTREAM_ERROR("GetBucketPolicyStatus", "Required field: Bucket, is not set");
  871. return GetBucketPolicyStatusOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  872. }
  873. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  874. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, GetBucketPolicyStatus, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  875. Aws::StringStream ss;
  876. ss.str("?policyStatus");
  877. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  878. return GetBucketPolicyStatusOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_GET));
  879. }
  880. GetBucketReplicationOutcome S3Client::GetBucketReplication(const GetBucketReplicationRequest& request) const
  881. {
  882. AWS_OPERATION_CHECK_PTR(m_endpointProvider, GetBucketReplication, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  883. if (!request.BucketHasBeenSet())
  884. {
  885. AWS_LOGSTREAM_ERROR("GetBucketReplication", "Required field: Bucket, is not set");
  886. return GetBucketReplicationOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  887. }
  888. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  889. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, GetBucketReplication, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  890. Aws::StringStream ss;
  891. ss.str("?replication");
  892. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  893. return GetBucketReplicationOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_GET));
  894. }
  895. GetBucketRequestPaymentOutcome S3Client::GetBucketRequestPayment(const GetBucketRequestPaymentRequest& request) const
  896. {
  897. AWS_OPERATION_CHECK_PTR(m_endpointProvider, GetBucketRequestPayment, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  898. if (!request.BucketHasBeenSet())
  899. {
  900. AWS_LOGSTREAM_ERROR("GetBucketRequestPayment", "Required field: Bucket, is not set");
  901. return GetBucketRequestPaymentOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  902. }
  903. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  904. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, GetBucketRequestPayment, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  905. Aws::StringStream ss;
  906. ss.str("?requestPayment");
  907. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  908. return GetBucketRequestPaymentOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_GET));
  909. }
  910. GetBucketTaggingOutcome S3Client::GetBucketTagging(const GetBucketTaggingRequest& request) const
  911. {
  912. AWS_OPERATION_CHECK_PTR(m_endpointProvider, GetBucketTagging, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  913. if (!request.BucketHasBeenSet())
  914. {
  915. AWS_LOGSTREAM_ERROR("GetBucketTagging", "Required field: Bucket, is not set");
  916. return GetBucketTaggingOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  917. }
  918. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  919. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, GetBucketTagging, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  920. Aws::StringStream ss;
  921. ss.str("?tagging");
  922. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  923. return GetBucketTaggingOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_GET));
  924. }
  925. GetBucketVersioningOutcome S3Client::GetBucketVersioning(const GetBucketVersioningRequest& request) const
  926. {
  927. AWS_OPERATION_CHECK_PTR(m_endpointProvider, GetBucketVersioning, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  928. if (!request.BucketHasBeenSet())
  929. {
  930. AWS_LOGSTREAM_ERROR("GetBucketVersioning", "Required field: Bucket, is not set");
  931. return GetBucketVersioningOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  932. }
  933. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  934. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, GetBucketVersioning, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  935. Aws::StringStream ss;
  936. ss.str("?versioning");
  937. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  938. return GetBucketVersioningOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_GET));
  939. }
  940. GetBucketWebsiteOutcome S3Client::GetBucketWebsite(const GetBucketWebsiteRequest& request) const
  941. {
  942. AWS_OPERATION_CHECK_PTR(m_endpointProvider, GetBucketWebsite, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  943. if (!request.BucketHasBeenSet())
  944. {
  945. AWS_LOGSTREAM_ERROR("GetBucketWebsite", "Required field: Bucket, is not set");
  946. return GetBucketWebsiteOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  947. }
  948. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  949. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, GetBucketWebsite, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  950. Aws::StringStream ss;
  951. ss.str("?website");
  952. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  953. return GetBucketWebsiteOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_GET));
  954. }
  955. GetObjectOutcome S3Client::GetObject(const GetObjectRequest& request) const
  956. {
  957. AWS_OPERATION_CHECK_PTR(m_endpointProvider, GetObject, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  958. if (!request.BucketHasBeenSet())
  959. {
  960. AWS_LOGSTREAM_ERROR("GetObject", "Required field: Bucket, is not set");
  961. return GetObjectOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  962. }
  963. if (!request.KeyHasBeenSet())
  964. {
  965. AWS_LOGSTREAM_ERROR("GetObject", "Required field: Key, is not set");
  966. return GetObjectOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Key]", false));
  967. }
  968. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  969. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, GetObject, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  970. endpointResolutionOutcome.GetResult().AddPathSegments(request.GetKey());
  971. return GetObjectOutcome(MakeRequestWithUnparsedResponse(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_GET));
  972. }
  973. GetObjectOutcomeCallable S3Client::GetObjectCallable(const GetObjectRequest& request) const
  974. {
  975. auto task = Aws::MakeShared< std::packaged_task< GetObjectOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->GetObject(request); } );
  976. auto packagedFunction = [task]() { (*task)(); };
  977. m_executor->Submit(packagedFunction);
  978. return task->get_future();
  979. }
  980. void S3Client::GetObjectAsync(const GetObjectRequest& request, const GetObjectResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
  981. {
  982. m_executor->Submit( [this, request, handler, context]()
  983. {
  984. handler(this, request, GetObject(request), context);
  985. } );
  986. }
  987. GetObjectAclOutcome S3Client::GetObjectAcl(const GetObjectAclRequest& request) const
  988. {
  989. AWS_OPERATION_CHECK_PTR(m_endpointProvider, GetObjectAcl, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  990. if (!request.BucketHasBeenSet())
  991. {
  992. AWS_LOGSTREAM_ERROR("GetObjectAcl", "Required field: Bucket, is not set");
  993. return GetObjectAclOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  994. }
  995. if (!request.KeyHasBeenSet())
  996. {
  997. AWS_LOGSTREAM_ERROR("GetObjectAcl", "Required field: Key, is not set");
  998. return GetObjectAclOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Key]", false));
  999. }
  1000. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1001. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, GetObjectAcl, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1002. Aws::StringStream ss;
  1003. endpointResolutionOutcome.GetResult().AddPathSegments(request.GetKey());
  1004. ss.str("?acl");
  1005. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  1006. return GetObjectAclOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_GET));
  1007. }
  1008. GetObjectAttributesOutcome S3Client::GetObjectAttributes(const GetObjectAttributesRequest& request) const
  1009. {
  1010. AWS_OPERATION_CHECK_PTR(m_endpointProvider, GetObjectAttributes, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1011. if (!request.BucketHasBeenSet())
  1012. {
  1013. AWS_LOGSTREAM_ERROR("GetObjectAttributes", "Required field: Bucket, is not set");
  1014. return GetObjectAttributesOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1015. }
  1016. if (!request.KeyHasBeenSet())
  1017. {
  1018. AWS_LOGSTREAM_ERROR("GetObjectAttributes", "Required field: Key, is not set");
  1019. return GetObjectAttributesOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Key]", false));
  1020. }
  1021. if (!request.ObjectAttributesHasBeenSet())
  1022. {
  1023. AWS_LOGSTREAM_ERROR("GetObjectAttributes", "Required field: ObjectAttributes, is not set");
  1024. return GetObjectAttributesOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [ObjectAttributes]", false));
  1025. }
  1026. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1027. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, GetObjectAttributes, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1028. Aws::StringStream ss;
  1029. endpointResolutionOutcome.GetResult().AddPathSegments(request.GetKey());
  1030. ss.str("?attributes");
  1031. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  1032. return GetObjectAttributesOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_GET));
  1033. }
  1034. GetObjectLegalHoldOutcome S3Client::GetObjectLegalHold(const GetObjectLegalHoldRequest& request) const
  1035. {
  1036. AWS_OPERATION_CHECK_PTR(m_endpointProvider, GetObjectLegalHold, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1037. if (!request.BucketHasBeenSet())
  1038. {
  1039. AWS_LOGSTREAM_ERROR("GetObjectLegalHold", "Required field: Bucket, is not set");
  1040. return GetObjectLegalHoldOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1041. }
  1042. if (!request.KeyHasBeenSet())
  1043. {
  1044. AWS_LOGSTREAM_ERROR("GetObjectLegalHold", "Required field: Key, is not set");
  1045. return GetObjectLegalHoldOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Key]", false));
  1046. }
  1047. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1048. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, GetObjectLegalHold, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1049. Aws::StringStream ss;
  1050. endpointResolutionOutcome.GetResult().AddPathSegments(request.GetKey());
  1051. ss.str("?legal-hold");
  1052. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  1053. return GetObjectLegalHoldOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_GET));
  1054. }
  1055. GetObjectLockConfigurationOutcome S3Client::GetObjectLockConfiguration(const GetObjectLockConfigurationRequest& request) const
  1056. {
  1057. AWS_OPERATION_CHECK_PTR(m_endpointProvider, GetObjectLockConfiguration, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1058. if (!request.BucketHasBeenSet())
  1059. {
  1060. AWS_LOGSTREAM_ERROR("GetObjectLockConfiguration", "Required field: Bucket, is not set");
  1061. return GetObjectLockConfigurationOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1062. }
  1063. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1064. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, GetObjectLockConfiguration, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1065. Aws::StringStream ss;
  1066. ss.str("?object-lock");
  1067. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  1068. return GetObjectLockConfigurationOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_GET));
  1069. }
  1070. GetObjectRetentionOutcome S3Client::GetObjectRetention(const GetObjectRetentionRequest& request) const
  1071. {
  1072. AWS_OPERATION_CHECK_PTR(m_endpointProvider, GetObjectRetention, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1073. if (!request.BucketHasBeenSet())
  1074. {
  1075. AWS_LOGSTREAM_ERROR("GetObjectRetention", "Required field: Bucket, is not set");
  1076. return GetObjectRetentionOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1077. }
  1078. if (!request.KeyHasBeenSet())
  1079. {
  1080. AWS_LOGSTREAM_ERROR("GetObjectRetention", "Required field: Key, is not set");
  1081. return GetObjectRetentionOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Key]", false));
  1082. }
  1083. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1084. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, GetObjectRetention, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1085. Aws::StringStream ss;
  1086. endpointResolutionOutcome.GetResult().AddPathSegments(request.GetKey());
  1087. ss.str("?retention");
  1088. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  1089. return GetObjectRetentionOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_GET));
  1090. }
  1091. GetObjectTaggingOutcome S3Client::GetObjectTagging(const GetObjectTaggingRequest& request) const
  1092. {
  1093. AWS_OPERATION_CHECK_PTR(m_endpointProvider, GetObjectTagging, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1094. if (!request.BucketHasBeenSet())
  1095. {
  1096. AWS_LOGSTREAM_ERROR("GetObjectTagging", "Required field: Bucket, is not set");
  1097. return GetObjectTaggingOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1098. }
  1099. if (!request.KeyHasBeenSet())
  1100. {
  1101. AWS_LOGSTREAM_ERROR("GetObjectTagging", "Required field: Key, is not set");
  1102. return GetObjectTaggingOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Key]", false));
  1103. }
  1104. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1105. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, GetObjectTagging, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1106. Aws::StringStream ss;
  1107. endpointResolutionOutcome.GetResult().AddPathSegments(request.GetKey());
  1108. ss.str("?tagging");
  1109. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  1110. return GetObjectTaggingOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_GET));
  1111. }
  1112. GetObjectTorrentOutcome S3Client::GetObjectTorrent(const GetObjectTorrentRequest& request) const
  1113. {
  1114. AWS_OPERATION_CHECK_PTR(m_endpointProvider, GetObjectTorrent, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1115. if (!request.BucketHasBeenSet())
  1116. {
  1117. AWS_LOGSTREAM_ERROR("GetObjectTorrent", "Required field: Bucket, is not set");
  1118. return GetObjectTorrentOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1119. }
  1120. if (!request.KeyHasBeenSet())
  1121. {
  1122. AWS_LOGSTREAM_ERROR("GetObjectTorrent", "Required field: Key, is not set");
  1123. return GetObjectTorrentOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Key]", false));
  1124. }
  1125. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1126. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, GetObjectTorrent, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1127. Aws::StringStream ss;
  1128. endpointResolutionOutcome.GetResult().AddPathSegments(request.GetKey());
  1129. ss.str("?torrent");
  1130. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  1131. return GetObjectTorrentOutcome(MakeRequestWithUnparsedResponse(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_GET));
  1132. }
  1133. GetPublicAccessBlockOutcome S3Client::GetPublicAccessBlock(const GetPublicAccessBlockRequest& request) const
  1134. {
  1135. AWS_OPERATION_CHECK_PTR(m_endpointProvider, GetPublicAccessBlock, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1136. if (!request.BucketHasBeenSet())
  1137. {
  1138. AWS_LOGSTREAM_ERROR("GetPublicAccessBlock", "Required field: Bucket, is not set");
  1139. return GetPublicAccessBlockOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1140. }
  1141. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1142. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, GetPublicAccessBlock, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1143. Aws::StringStream ss;
  1144. ss.str("?publicAccessBlock");
  1145. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  1146. return GetPublicAccessBlockOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_GET));
  1147. }
  1148. HeadBucketOutcome S3Client::HeadBucket(const HeadBucketRequest& request) const
  1149. {
  1150. AWS_OPERATION_CHECK_PTR(m_endpointProvider, HeadBucket, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1151. if (!request.BucketHasBeenSet())
  1152. {
  1153. AWS_LOGSTREAM_ERROR("HeadBucket", "Required field: Bucket, is not set");
  1154. return HeadBucketOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1155. }
  1156. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1157. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, HeadBucket, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1158. return HeadBucketOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_HEAD));
  1159. }
  1160. HeadObjectOutcome S3Client::HeadObject(const HeadObjectRequest& request) const
  1161. {
  1162. AWS_OPERATION_CHECK_PTR(m_endpointProvider, HeadObject, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1163. if (!request.BucketHasBeenSet())
  1164. {
  1165. AWS_LOGSTREAM_ERROR("HeadObject", "Required field: Bucket, is not set");
  1166. return HeadObjectOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1167. }
  1168. if (!request.KeyHasBeenSet())
  1169. {
  1170. AWS_LOGSTREAM_ERROR("HeadObject", "Required field: Key, is not set");
  1171. return HeadObjectOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Key]", false));
  1172. }
  1173. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1174. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, HeadObject, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1175. endpointResolutionOutcome.GetResult().AddPathSegments(request.GetKey());
  1176. return HeadObjectOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_HEAD));
  1177. }
  1178. ListBucketAnalyticsConfigurationsOutcome S3Client::ListBucketAnalyticsConfigurations(const ListBucketAnalyticsConfigurationsRequest& request) const
  1179. {
  1180. AWS_OPERATION_CHECK_PTR(m_endpointProvider, ListBucketAnalyticsConfigurations, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1181. if (!request.BucketHasBeenSet())
  1182. {
  1183. AWS_LOGSTREAM_ERROR("ListBucketAnalyticsConfigurations", "Required field: Bucket, is not set");
  1184. return ListBucketAnalyticsConfigurationsOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1185. }
  1186. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1187. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, ListBucketAnalyticsConfigurations, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1188. Aws::StringStream ss;
  1189. ss.str("?analytics");
  1190. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  1191. return ListBucketAnalyticsConfigurationsOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_GET));
  1192. }
  1193. ListBucketIntelligentTieringConfigurationsOutcome S3Client::ListBucketIntelligentTieringConfigurations(const ListBucketIntelligentTieringConfigurationsRequest& request) const
  1194. {
  1195. AWS_OPERATION_CHECK_PTR(m_endpointProvider, ListBucketIntelligentTieringConfigurations, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1196. if (!request.BucketHasBeenSet())
  1197. {
  1198. AWS_LOGSTREAM_ERROR("ListBucketIntelligentTieringConfigurations", "Required field: Bucket, is not set");
  1199. return ListBucketIntelligentTieringConfigurationsOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1200. }
  1201. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1202. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, ListBucketIntelligentTieringConfigurations, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1203. Aws::StringStream ss;
  1204. ss.str("?intelligent-tiering");
  1205. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  1206. return ListBucketIntelligentTieringConfigurationsOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_GET));
  1207. }
  1208. ListBucketInventoryConfigurationsOutcome S3Client::ListBucketInventoryConfigurations(const ListBucketInventoryConfigurationsRequest& request) const
  1209. {
  1210. AWS_OPERATION_CHECK_PTR(m_endpointProvider, ListBucketInventoryConfigurations, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1211. if (!request.BucketHasBeenSet())
  1212. {
  1213. AWS_LOGSTREAM_ERROR("ListBucketInventoryConfigurations", "Required field: Bucket, is not set");
  1214. return ListBucketInventoryConfigurationsOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1215. }
  1216. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1217. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, ListBucketInventoryConfigurations, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1218. Aws::StringStream ss;
  1219. ss.str("?inventory");
  1220. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  1221. return ListBucketInventoryConfigurationsOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_GET));
  1222. }
  1223. ListBucketMetricsConfigurationsOutcome S3Client::ListBucketMetricsConfigurations(const ListBucketMetricsConfigurationsRequest& request) const
  1224. {
  1225. AWS_OPERATION_CHECK_PTR(m_endpointProvider, ListBucketMetricsConfigurations, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1226. if (!request.BucketHasBeenSet())
  1227. {
  1228. AWS_LOGSTREAM_ERROR("ListBucketMetricsConfigurations", "Required field: Bucket, is not set");
  1229. return ListBucketMetricsConfigurationsOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1230. }
  1231. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1232. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, ListBucketMetricsConfigurations, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1233. Aws::StringStream ss;
  1234. ss.str("?metrics");
  1235. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  1236. return ListBucketMetricsConfigurationsOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_GET));
  1237. }
  1238. ListBucketsOutcome S3Client::ListBuckets() const
  1239. {
  1240. AWS_OPERATION_CHECK_PTR(m_endpointProvider, ListBuckets, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1241. const Aws::Vector<Aws::Endpoint::EndpointParameter> staticEndpointParameters;
  1242. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(staticEndpointParameters);
  1243. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, ListBuckets, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1244. return ListBucketsOutcome(MakeRequest(endpointResolutionOutcome.GetResult(), "ListBuckets", Aws::Http::HttpMethod::HTTP_GET));
  1245. }
  1246. ListMultipartUploadsOutcome S3Client::ListMultipartUploads(const ListMultipartUploadsRequest& request) const
  1247. {
  1248. AWS_OPERATION_CHECK_PTR(m_endpointProvider, ListMultipartUploads, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1249. if (!request.BucketHasBeenSet())
  1250. {
  1251. AWS_LOGSTREAM_ERROR("ListMultipartUploads", "Required field: Bucket, is not set");
  1252. return ListMultipartUploadsOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1253. }
  1254. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1255. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, ListMultipartUploads, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1256. Aws::StringStream ss;
  1257. ss.str("?uploads");
  1258. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  1259. return ListMultipartUploadsOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_GET));
  1260. }
  1261. ListObjectVersionsOutcome S3Client::ListObjectVersions(const ListObjectVersionsRequest& request) const
  1262. {
  1263. AWS_OPERATION_CHECK_PTR(m_endpointProvider, ListObjectVersions, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1264. if (!request.BucketHasBeenSet())
  1265. {
  1266. AWS_LOGSTREAM_ERROR("ListObjectVersions", "Required field: Bucket, is not set");
  1267. return ListObjectVersionsOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1268. }
  1269. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1270. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, ListObjectVersions, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1271. Aws::StringStream ss;
  1272. ss.str("?versions");
  1273. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  1274. return ListObjectVersionsOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_GET));
  1275. }
  1276. ListObjectsOutcome S3Client::ListObjects(const ListObjectsRequest& request) const
  1277. {
  1278. AWS_OPERATION_CHECK_PTR(m_endpointProvider, ListObjects, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1279. if (!request.BucketHasBeenSet())
  1280. {
  1281. AWS_LOGSTREAM_ERROR("ListObjects", "Required field: Bucket, is not set");
  1282. return ListObjectsOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1283. }
  1284. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1285. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, ListObjects, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1286. return ListObjectsOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_GET));
  1287. }
  1288. ListObjectsV2Outcome S3Client::ListObjectsV2(const ListObjectsV2Request& request) const
  1289. {
  1290. AWS_OPERATION_CHECK_PTR(m_endpointProvider, ListObjectsV2, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1291. if (!request.BucketHasBeenSet())
  1292. {
  1293. AWS_LOGSTREAM_ERROR("ListObjectsV2", "Required field: Bucket, is not set");
  1294. return ListObjectsV2Outcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1295. }
  1296. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1297. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, ListObjectsV2, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1298. Aws::StringStream ss;
  1299. ss.str("?list-type=2");
  1300. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  1301. return ListObjectsV2Outcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_GET));
  1302. }
  1303. ListPartsOutcome S3Client::ListParts(const ListPartsRequest& request) const
  1304. {
  1305. AWS_OPERATION_CHECK_PTR(m_endpointProvider, ListParts, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1306. if (!request.BucketHasBeenSet())
  1307. {
  1308. AWS_LOGSTREAM_ERROR("ListParts", "Required field: Bucket, is not set");
  1309. return ListPartsOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1310. }
  1311. if (!request.KeyHasBeenSet())
  1312. {
  1313. AWS_LOGSTREAM_ERROR("ListParts", "Required field: Key, is not set");
  1314. return ListPartsOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Key]", false));
  1315. }
  1316. if (!request.UploadIdHasBeenSet())
  1317. {
  1318. AWS_LOGSTREAM_ERROR("ListParts", "Required field: UploadId, is not set");
  1319. return ListPartsOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [UploadId]", false));
  1320. }
  1321. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1322. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, ListParts, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1323. endpointResolutionOutcome.GetResult().AddPathSegments(request.GetKey());
  1324. return ListPartsOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_GET));
  1325. }
  1326. PutBucketAccelerateConfigurationOutcome S3Client::PutBucketAccelerateConfiguration(const PutBucketAccelerateConfigurationRequest& request) const
  1327. {
  1328. AWS_OPERATION_CHECK_PTR(m_endpointProvider, PutBucketAccelerateConfiguration, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1329. if (!request.BucketHasBeenSet())
  1330. {
  1331. AWS_LOGSTREAM_ERROR("PutBucketAccelerateConfiguration", "Required field: Bucket, is not set");
  1332. return PutBucketAccelerateConfigurationOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1333. }
  1334. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1335. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, PutBucketAccelerateConfiguration, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1336. Aws::StringStream ss;
  1337. ss.str("?accelerate");
  1338. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  1339. return PutBucketAccelerateConfigurationOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_PUT));
  1340. }
  1341. PutBucketAclOutcome S3Client::PutBucketAcl(const PutBucketAclRequest& request) const
  1342. {
  1343. AWS_OPERATION_CHECK_PTR(m_endpointProvider, PutBucketAcl, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1344. if (!request.BucketHasBeenSet())
  1345. {
  1346. AWS_LOGSTREAM_ERROR("PutBucketAcl", "Required field: Bucket, is not set");
  1347. return PutBucketAclOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1348. }
  1349. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1350. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, PutBucketAcl, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1351. Aws::StringStream ss;
  1352. ss.str("?acl");
  1353. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  1354. return PutBucketAclOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_PUT));
  1355. }
  1356. PutBucketAnalyticsConfigurationOutcome S3Client::PutBucketAnalyticsConfiguration(const PutBucketAnalyticsConfigurationRequest& request) const
  1357. {
  1358. AWS_OPERATION_CHECK_PTR(m_endpointProvider, PutBucketAnalyticsConfiguration, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1359. if (!request.BucketHasBeenSet())
  1360. {
  1361. AWS_LOGSTREAM_ERROR("PutBucketAnalyticsConfiguration", "Required field: Bucket, is not set");
  1362. return PutBucketAnalyticsConfigurationOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1363. }
  1364. if (!request.IdHasBeenSet())
  1365. {
  1366. AWS_LOGSTREAM_ERROR("PutBucketAnalyticsConfiguration", "Required field: Id, is not set");
  1367. return PutBucketAnalyticsConfigurationOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Id]", false));
  1368. }
  1369. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1370. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, PutBucketAnalyticsConfiguration, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1371. Aws::StringStream ss;
  1372. ss.str("?analytics");
  1373. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  1374. return PutBucketAnalyticsConfigurationOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_PUT));
  1375. }
  1376. PutBucketCorsOutcome S3Client::PutBucketCors(const PutBucketCorsRequest& request) const
  1377. {
  1378. AWS_OPERATION_CHECK_PTR(m_endpointProvider, PutBucketCors, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1379. if (!request.BucketHasBeenSet())
  1380. {
  1381. AWS_LOGSTREAM_ERROR("PutBucketCors", "Required field: Bucket, is not set");
  1382. return PutBucketCorsOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1383. }
  1384. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1385. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, PutBucketCors, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1386. Aws::StringStream ss;
  1387. ss.str("?cors");
  1388. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  1389. return PutBucketCorsOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_PUT));
  1390. }
  1391. PutBucketEncryptionOutcome S3Client::PutBucketEncryption(const PutBucketEncryptionRequest& request) const
  1392. {
  1393. AWS_OPERATION_CHECK_PTR(m_endpointProvider, PutBucketEncryption, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1394. if (!request.BucketHasBeenSet())
  1395. {
  1396. AWS_LOGSTREAM_ERROR("PutBucketEncryption", "Required field: Bucket, is not set");
  1397. return PutBucketEncryptionOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1398. }
  1399. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1400. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, PutBucketEncryption, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1401. Aws::StringStream ss;
  1402. ss.str("?encryption");
  1403. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  1404. return PutBucketEncryptionOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_PUT));
  1405. }
  1406. PutBucketIntelligentTieringConfigurationOutcome S3Client::PutBucketIntelligentTieringConfiguration(const PutBucketIntelligentTieringConfigurationRequest& request) const
  1407. {
  1408. AWS_OPERATION_CHECK_PTR(m_endpointProvider, PutBucketIntelligentTieringConfiguration, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1409. if (!request.BucketHasBeenSet())
  1410. {
  1411. AWS_LOGSTREAM_ERROR("PutBucketIntelligentTieringConfiguration", "Required field: Bucket, is not set");
  1412. return PutBucketIntelligentTieringConfigurationOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1413. }
  1414. if (!request.IdHasBeenSet())
  1415. {
  1416. AWS_LOGSTREAM_ERROR("PutBucketIntelligentTieringConfiguration", "Required field: Id, is not set");
  1417. return PutBucketIntelligentTieringConfigurationOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Id]", false));
  1418. }
  1419. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1420. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, PutBucketIntelligentTieringConfiguration, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1421. Aws::StringStream ss;
  1422. ss.str("?intelligent-tiering");
  1423. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  1424. return PutBucketIntelligentTieringConfigurationOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_PUT));
  1425. }
  1426. PutBucketInventoryConfigurationOutcome S3Client::PutBucketInventoryConfiguration(const PutBucketInventoryConfigurationRequest& request) const
  1427. {
  1428. AWS_OPERATION_CHECK_PTR(m_endpointProvider, PutBucketInventoryConfiguration, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1429. if (!request.BucketHasBeenSet())
  1430. {
  1431. AWS_LOGSTREAM_ERROR("PutBucketInventoryConfiguration", "Required field: Bucket, is not set");
  1432. return PutBucketInventoryConfigurationOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1433. }
  1434. if (!request.IdHasBeenSet())
  1435. {
  1436. AWS_LOGSTREAM_ERROR("PutBucketInventoryConfiguration", "Required field: Id, is not set");
  1437. return PutBucketInventoryConfigurationOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Id]", false));
  1438. }
  1439. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1440. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, PutBucketInventoryConfiguration, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1441. Aws::StringStream ss;
  1442. ss.str("?inventory");
  1443. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  1444. return PutBucketInventoryConfigurationOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_PUT));
  1445. }
  1446. PutBucketLifecycleConfigurationOutcome S3Client::PutBucketLifecycleConfiguration(const PutBucketLifecycleConfigurationRequest& request) const
  1447. {
  1448. AWS_OPERATION_CHECK_PTR(m_endpointProvider, PutBucketLifecycleConfiguration, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1449. if (!request.BucketHasBeenSet())
  1450. {
  1451. AWS_LOGSTREAM_ERROR("PutBucketLifecycleConfiguration", "Required field: Bucket, is not set");
  1452. return PutBucketLifecycleConfigurationOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1453. }
  1454. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1455. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, PutBucketLifecycleConfiguration, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1456. Aws::StringStream ss;
  1457. ss.str("?lifecycle");
  1458. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  1459. return PutBucketLifecycleConfigurationOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_PUT));
  1460. }
  1461. PutBucketLoggingOutcome S3Client::PutBucketLogging(const PutBucketLoggingRequest& request) const
  1462. {
  1463. AWS_OPERATION_CHECK_PTR(m_endpointProvider, PutBucketLogging, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1464. if (!request.BucketHasBeenSet())
  1465. {
  1466. AWS_LOGSTREAM_ERROR("PutBucketLogging", "Required field: Bucket, is not set");
  1467. return PutBucketLoggingOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1468. }
  1469. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1470. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, PutBucketLogging, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1471. Aws::StringStream ss;
  1472. ss.str("?logging");
  1473. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  1474. return PutBucketLoggingOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_PUT));
  1475. }
  1476. PutBucketMetricsConfigurationOutcome S3Client::PutBucketMetricsConfiguration(const PutBucketMetricsConfigurationRequest& request) const
  1477. {
  1478. AWS_OPERATION_CHECK_PTR(m_endpointProvider, PutBucketMetricsConfiguration, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1479. if (!request.BucketHasBeenSet())
  1480. {
  1481. AWS_LOGSTREAM_ERROR("PutBucketMetricsConfiguration", "Required field: Bucket, is not set");
  1482. return PutBucketMetricsConfigurationOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1483. }
  1484. if (!request.IdHasBeenSet())
  1485. {
  1486. AWS_LOGSTREAM_ERROR("PutBucketMetricsConfiguration", "Required field: Id, is not set");
  1487. return PutBucketMetricsConfigurationOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Id]", false));
  1488. }
  1489. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1490. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, PutBucketMetricsConfiguration, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1491. Aws::StringStream ss;
  1492. ss.str("?metrics");
  1493. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  1494. return PutBucketMetricsConfigurationOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_PUT));
  1495. }
  1496. PutBucketNotificationConfigurationOutcome S3Client::PutBucketNotificationConfiguration(const PutBucketNotificationConfigurationRequest& request) const
  1497. {
  1498. AWS_OPERATION_CHECK_PTR(m_endpointProvider, PutBucketNotificationConfiguration, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1499. if (!request.BucketHasBeenSet())
  1500. {
  1501. AWS_LOGSTREAM_ERROR("PutBucketNotificationConfiguration", "Required field: Bucket, is not set");
  1502. return PutBucketNotificationConfigurationOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1503. }
  1504. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1505. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, PutBucketNotificationConfiguration, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1506. Aws::StringStream ss;
  1507. ss.str("?notification");
  1508. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  1509. return PutBucketNotificationConfigurationOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_PUT));
  1510. }
  1511. PutBucketOwnershipControlsOutcome S3Client::PutBucketOwnershipControls(const PutBucketOwnershipControlsRequest& request) const
  1512. {
  1513. AWS_OPERATION_CHECK_PTR(m_endpointProvider, PutBucketOwnershipControls, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1514. if (!request.BucketHasBeenSet())
  1515. {
  1516. AWS_LOGSTREAM_ERROR("PutBucketOwnershipControls", "Required field: Bucket, is not set");
  1517. return PutBucketOwnershipControlsOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1518. }
  1519. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1520. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, PutBucketOwnershipControls, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1521. Aws::StringStream ss;
  1522. ss.str("?ownershipControls");
  1523. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  1524. return PutBucketOwnershipControlsOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_PUT));
  1525. }
  1526. PutBucketPolicyOutcome S3Client::PutBucketPolicy(const PutBucketPolicyRequest& request) const
  1527. {
  1528. AWS_OPERATION_CHECK_PTR(m_endpointProvider, PutBucketPolicy, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1529. if (!request.BucketHasBeenSet())
  1530. {
  1531. AWS_LOGSTREAM_ERROR("PutBucketPolicy", "Required field: Bucket, is not set");
  1532. return PutBucketPolicyOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1533. }
  1534. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1535. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, PutBucketPolicy, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1536. Aws::StringStream ss;
  1537. ss.str("?policy");
  1538. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  1539. return PutBucketPolicyOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_PUT));
  1540. }
  1541. PutBucketReplicationOutcome S3Client::PutBucketReplication(const PutBucketReplicationRequest& request) const
  1542. {
  1543. AWS_OPERATION_CHECK_PTR(m_endpointProvider, PutBucketReplication, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1544. if (!request.BucketHasBeenSet())
  1545. {
  1546. AWS_LOGSTREAM_ERROR("PutBucketReplication", "Required field: Bucket, is not set");
  1547. return PutBucketReplicationOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1548. }
  1549. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1550. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, PutBucketReplication, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1551. Aws::StringStream ss;
  1552. ss.str("?replication");
  1553. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  1554. return PutBucketReplicationOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_PUT));
  1555. }
  1556. PutBucketRequestPaymentOutcome S3Client::PutBucketRequestPayment(const PutBucketRequestPaymentRequest& request) const
  1557. {
  1558. AWS_OPERATION_CHECK_PTR(m_endpointProvider, PutBucketRequestPayment, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1559. if (!request.BucketHasBeenSet())
  1560. {
  1561. AWS_LOGSTREAM_ERROR("PutBucketRequestPayment", "Required field: Bucket, is not set");
  1562. return PutBucketRequestPaymentOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1563. }
  1564. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1565. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, PutBucketRequestPayment, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1566. Aws::StringStream ss;
  1567. ss.str("?requestPayment");
  1568. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  1569. return PutBucketRequestPaymentOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_PUT));
  1570. }
  1571. PutBucketTaggingOutcome S3Client::PutBucketTagging(const PutBucketTaggingRequest& request) const
  1572. {
  1573. AWS_OPERATION_CHECK_PTR(m_endpointProvider, PutBucketTagging, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1574. if (!request.BucketHasBeenSet())
  1575. {
  1576. AWS_LOGSTREAM_ERROR("PutBucketTagging", "Required field: Bucket, is not set");
  1577. return PutBucketTaggingOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1578. }
  1579. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1580. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, PutBucketTagging, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1581. Aws::StringStream ss;
  1582. ss.str("?tagging");
  1583. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  1584. return PutBucketTaggingOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_PUT));
  1585. }
  1586. PutBucketVersioningOutcome S3Client::PutBucketVersioning(const PutBucketVersioningRequest& request) const
  1587. {
  1588. AWS_OPERATION_CHECK_PTR(m_endpointProvider, PutBucketVersioning, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1589. if (!request.BucketHasBeenSet())
  1590. {
  1591. AWS_LOGSTREAM_ERROR("PutBucketVersioning", "Required field: Bucket, is not set");
  1592. return PutBucketVersioningOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1593. }
  1594. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1595. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, PutBucketVersioning, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1596. Aws::StringStream ss;
  1597. ss.str("?versioning");
  1598. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  1599. return PutBucketVersioningOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_PUT));
  1600. }
  1601. PutBucketWebsiteOutcome S3Client::PutBucketWebsite(const PutBucketWebsiteRequest& request) const
  1602. {
  1603. AWS_OPERATION_CHECK_PTR(m_endpointProvider, PutBucketWebsite, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1604. if (!request.BucketHasBeenSet())
  1605. {
  1606. AWS_LOGSTREAM_ERROR("PutBucketWebsite", "Required field: Bucket, is not set");
  1607. return PutBucketWebsiteOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1608. }
  1609. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1610. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, PutBucketWebsite, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1611. Aws::StringStream ss;
  1612. ss.str("?website");
  1613. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  1614. return PutBucketWebsiteOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_PUT));
  1615. }
  1616. PutObjectOutcome S3Client::PutObject(const PutObjectRequest& request) const
  1617. {
  1618. AWS_OPERATION_CHECK_PTR(m_endpointProvider, PutObject, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1619. if (!request.BucketHasBeenSet())
  1620. {
  1621. AWS_LOGSTREAM_ERROR("PutObject", "Required field: Bucket, is not set");
  1622. return PutObjectOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1623. }
  1624. if (!request.KeyHasBeenSet())
  1625. {
  1626. AWS_LOGSTREAM_ERROR("PutObject", "Required field: Key, is not set");
  1627. return PutObjectOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Key]", false));
  1628. }
  1629. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1630. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, PutObject, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1631. endpointResolutionOutcome.GetResult().AddPathSegments(request.GetKey());
  1632. return PutObjectOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_PUT));
  1633. }
  1634. PutObjectOutcomeCallable S3Client::PutObjectCallable(const PutObjectRequest& request) const
  1635. {
  1636. auto task = Aws::MakeShared< std::packaged_task< PutObjectOutcome() > >(ALLOCATION_TAG, [this, request](){ return this->PutObject(request); } );
  1637. auto packagedFunction = [task]() { (*task)(); };
  1638. m_executor->Submit(packagedFunction);
  1639. return task->get_future();
  1640. }
  1641. void S3Client::PutObjectAsync(const PutObjectRequest& request, const PutObjectResponseReceivedHandler& handler, const std::shared_ptr<const Aws::Client::AsyncCallerContext>& context) const
  1642. {
  1643. m_executor->Submit( [this, request, handler, context]()
  1644. {
  1645. handler(this, request, PutObject(request), context);
  1646. } );
  1647. }
  1648. PutObjectAclOutcome S3Client::PutObjectAcl(const PutObjectAclRequest& request) const
  1649. {
  1650. AWS_OPERATION_CHECK_PTR(m_endpointProvider, PutObjectAcl, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1651. if (!request.BucketHasBeenSet())
  1652. {
  1653. AWS_LOGSTREAM_ERROR("PutObjectAcl", "Required field: Bucket, is not set");
  1654. return PutObjectAclOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1655. }
  1656. if (!request.KeyHasBeenSet())
  1657. {
  1658. AWS_LOGSTREAM_ERROR("PutObjectAcl", "Required field: Key, is not set");
  1659. return PutObjectAclOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Key]", false));
  1660. }
  1661. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1662. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, PutObjectAcl, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1663. Aws::StringStream ss;
  1664. endpointResolutionOutcome.GetResult().AddPathSegments(request.GetKey());
  1665. ss.str("?acl");
  1666. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  1667. return PutObjectAclOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_PUT));
  1668. }
  1669. PutObjectLegalHoldOutcome S3Client::PutObjectLegalHold(const PutObjectLegalHoldRequest& request) const
  1670. {
  1671. AWS_OPERATION_CHECK_PTR(m_endpointProvider, PutObjectLegalHold, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1672. if (!request.BucketHasBeenSet())
  1673. {
  1674. AWS_LOGSTREAM_ERROR("PutObjectLegalHold", "Required field: Bucket, is not set");
  1675. return PutObjectLegalHoldOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1676. }
  1677. if (!request.KeyHasBeenSet())
  1678. {
  1679. AWS_LOGSTREAM_ERROR("PutObjectLegalHold", "Required field: Key, is not set");
  1680. return PutObjectLegalHoldOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Key]", false));
  1681. }
  1682. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1683. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, PutObjectLegalHold, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1684. Aws::StringStream ss;
  1685. endpointResolutionOutcome.GetResult().AddPathSegments(request.GetKey());
  1686. ss.str("?legal-hold");
  1687. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  1688. return PutObjectLegalHoldOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_PUT));
  1689. }
  1690. PutObjectLockConfigurationOutcome S3Client::PutObjectLockConfiguration(const PutObjectLockConfigurationRequest& request) const
  1691. {
  1692. AWS_OPERATION_CHECK_PTR(m_endpointProvider, PutObjectLockConfiguration, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1693. if (!request.BucketHasBeenSet())
  1694. {
  1695. AWS_LOGSTREAM_ERROR("PutObjectLockConfiguration", "Required field: Bucket, is not set");
  1696. return PutObjectLockConfigurationOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1697. }
  1698. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1699. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, PutObjectLockConfiguration, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1700. Aws::StringStream ss;
  1701. ss.str("?object-lock");
  1702. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  1703. return PutObjectLockConfigurationOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_PUT));
  1704. }
  1705. PutObjectRetentionOutcome S3Client::PutObjectRetention(const PutObjectRetentionRequest& request) const
  1706. {
  1707. AWS_OPERATION_CHECK_PTR(m_endpointProvider, PutObjectRetention, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1708. if (!request.BucketHasBeenSet())
  1709. {
  1710. AWS_LOGSTREAM_ERROR("PutObjectRetention", "Required field: Bucket, is not set");
  1711. return PutObjectRetentionOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1712. }
  1713. if (!request.KeyHasBeenSet())
  1714. {
  1715. AWS_LOGSTREAM_ERROR("PutObjectRetention", "Required field: Key, is not set");
  1716. return PutObjectRetentionOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Key]", false));
  1717. }
  1718. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1719. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, PutObjectRetention, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1720. Aws::StringStream ss;
  1721. endpointResolutionOutcome.GetResult().AddPathSegments(request.GetKey());
  1722. ss.str("?retention");
  1723. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  1724. return PutObjectRetentionOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_PUT));
  1725. }
  1726. PutObjectTaggingOutcome S3Client::PutObjectTagging(const PutObjectTaggingRequest& request) const
  1727. {
  1728. AWS_OPERATION_CHECK_PTR(m_endpointProvider, PutObjectTagging, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1729. if (!request.BucketHasBeenSet())
  1730. {
  1731. AWS_LOGSTREAM_ERROR("PutObjectTagging", "Required field: Bucket, is not set");
  1732. return PutObjectTaggingOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1733. }
  1734. if (!request.KeyHasBeenSet())
  1735. {
  1736. AWS_LOGSTREAM_ERROR("PutObjectTagging", "Required field: Key, is not set");
  1737. return PutObjectTaggingOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Key]", false));
  1738. }
  1739. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1740. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, PutObjectTagging, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1741. Aws::StringStream ss;
  1742. endpointResolutionOutcome.GetResult().AddPathSegments(request.GetKey());
  1743. ss.str("?tagging");
  1744. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  1745. return PutObjectTaggingOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_PUT));
  1746. }
  1747. PutPublicAccessBlockOutcome S3Client::PutPublicAccessBlock(const PutPublicAccessBlockRequest& request) const
  1748. {
  1749. AWS_OPERATION_CHECK_PTR(m_endpointProvider, PutPublicAccessBlock, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1750. if (!request.BucketHasBeenSet())
  1751. {
  1752. AWS_LOGSTREAM_ERROR("PutPublicAccessBlock", "Required field: Bucket, is not set");
  1753. return PutPublicAccessBlockOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1754. }
  1755. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1756. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, PutPublicAccessBlock, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1757. Aws::StringStream ss;
  1758. ss.str("?publicAccessBlock");
  1759. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  1760. return PutPublicAccessBlockOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_PUT));
  1761. }
  1762. RestoreObjectOutcome S3Client::RestoreObject(const RestoreObjectRequest& request) const
  1763. {
  1764. AWS_OPERATION_CHECK_PTR(m_endpointProvider, RestoreObject, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1765. if (!request.BucketHasBeenSet())
  1766. {
  1767. AWS_LOGSTREAM_ERROR("RestoreObject", "Required field: Bucket, is not set");
  1768. return RestoreObjectOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1769. }
  1770. if (!request.KeyHasBeenSet())
  1771. {
  1772. AWS_LOGSTREAM_ERROR("RestoreObject", "Required field: Key, is not set");
  1773. return RestoreObjectOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Key]", false));
  1774. }
  1775. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1776. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, RestoreObject, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1777. Aws::StringStream ss;
  1778. endpointResolutionOutcome.GetResult().AddPathSegments(request.GetKey());
  1779. ss.str("?restore");
  1780. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  1781. return RestoreObjectOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_POST));
  1782. }
  1783. SelectObjectContentOutcome S3Client::SelectObjectContent(SelectObjectContentRequest& request) const
  1784. {
  1785. AWS_OPERATION_CHECK_PTR(m_endpointProvider, SelectObjectContent, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1786. if (!request.BucketHasBeenSet())
  1787. {
  1788. AWS_LOGSTREAM_ERROR("SelectObjectContent", "Required field: Bucket, is not set");
  1789. return SelectObjectContentOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1790. }
  1791. if (!request.KeyHasBeenSet())
  1792. {
  1793. AWS_LOGSTREAM_ERROR("SelectObjectContent", "Required field: Key, is not set");
  1794. return SelectObjectContentOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Key]", false));
  1795. }
  1796. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1797. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, SelectObjectContent, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1798. Aws::StringStream ss;
  1799. endpointResolutionOutcome.GetResult().AddPathSegments(request.GetKey());
  1800. ss.str("?select&select-type=2");
  1801. endpointResolutionOutcome.GetResult().SetQueryString(ss.str());
  1802. request.SetResponseStreamFactory(
  1803. [&] { request.GetEventStreamDecoder().Reset(); return Aws::New<Aws::Utils::Event::EventDecoderStream>(ALLOCATION_TAG, request.GetEventStreamDecoder()); }
  1804. );
  1805. return SelectObjectContentOutcome(MakeRequestWithEventStream(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_POST));
  1806. }
  1807. UploadPartOutcome S3Client::UploadPart(const UploadPartRequest& request) const
  1808. {
  1809. AWS_OPERATION_CHECK_PTR(m_endpointProvider, UploadPart, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1810. if (!request.BucketHasBeenSet())
  1811. {
  1812. AWS_LOGSTREAM_ERROR("UploadPart", "Required field: Bucket, is not set");
  1813. return UploadPartOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1814. }
  1815. if (!request.KeyHasBeenSet())
  1816. {
  1817. AWS_LOGSTREAM_ERROR("UploadPart", "Required field: Key, is not set");
  1818. return UploadPartOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Key]", false));
  1819. }
  1820. if (!request.PartNumberHasBeenSet())
  1821. {
  1822. AWS_LOGSTREAM_ERROR("UploadPart", "Required field: PartNumber, is not set");
  1823. return UploadPartOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [PartNumber]", false));
  1824. }
  1825. if (!request.UploadIdHasBeenSet())
  1826. {
  1827. AWS_LOGSTREAM_ERROR("UploadPart", "Required field: UploadId, is not set");
  1828. return UploadPartOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [UploadId]", false));
  1829. }
  1830. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1831. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, UploadPart, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1832. endpointResolutionOutcome.GetResult().AddPathSegments(request.GetKey());
  1833. return UploadPartOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_PUT));
  1834. }
  1835. UploadPartCopyOutcome S3Client::UploadPartCopy(const UploadPartCopyRequest& request) const
  1836. {
  1837. AWS_OPERATION_CHECK_PTR(m_endpointProvider, UploadPartCopy, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1838. if (!request.BucketHasBeenSet())
  1839. {
  1840. AWS_LOGSTREAM_ERROR("UploadPartCopy", "Required field: Bucket, is not set");
  1841. return UploadPartCopyOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Bucket]", false));
  1842. }
  1843. if (!request.CopySourceHasBeenSet())
  1844. {
  1845. AWS_LOGSTREAM_ERROR("UploadPartCopy", "Required field: CopySource, is not set");
  1846. return UploadPartCopyOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [CopySource]", false));
  1847. }
  1848. if (!request.KeyHasBeenSet())
  1849. {
  1850. AWS_LOGSTREAM_ERROR("UploadPartCopy", "Required field: Key, is not set");
  1851. return UploadPartCopyOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [Key]", false));
  1852. }
  1853. if (!request.PartNumberHasBeenSet())
  1854. {
  1855. AWS_LOGSTREAM_ERROR("UploadPartCopy", "Required field: PartNumber, is not set");
  1856. return UploadPartCopyOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [PartNumber]", false));
  1857. }
  1858. if (!request.UploadIdHasBeenSet())
  1859. {
  1860. AWS_LOGSTREAM_ERROR("UploadPartCopy", "Required field: UploadId, is not set");
  1861. return UploadPartCopyOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [UploadId]", false));
  1862. }
  1863. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1864. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, UploadPartCopy, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1865. endpointResolutionOutcome.GetResult().AddPathSegments(request.GetKey());
  1866. return UploadPartCopyOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_PUT));
  1867. }
  1868. WriteGetObjectResponseOutcome S3Client::WriteGetObjectResponse(const WriteGetObjectResponseRequest& request) const
  1869. {
  1870. AWS_OPERATION_CHECK_PTR(m_endpointProvider, WriteGetObjectResponse, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE);
  1871. if (!request.RequestRouteHasBeenSet())
  1872. {
  1873. AWS_LOGSTREAM_ERROR("WriteGetObjectResponse", "Required field: RequestRoute, is not set");
  1874. return WriteGetObjectResponseOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [RequestRoute]", false));
  1875. }
  1876. if (!request.RequestTokenHasBeenSet())
  1877. {
  1878. AWS_LOGSTREAM_ERROR("WriteGetObjectResponse", "Required field: RequestToken, is not set");
  1879. return WriteGetObjectResponseOutcome(Aws::Client::AWSError<S3Errors>(S3Errors::MISSING_PARAMETER, "MISSING_PARAMETER", "Missing required field [RequestToken]", false));
  1880. }
  1881. ResolveEndpointOutcome endpointResolutionOutcome = m_endpointProvider->ResolveEndpoint(request.GetEndpointContextParams());
  1882. AWS_OPERATION_CHECK_SUCCESS(endpointResolutionOutcome, WriteGetObjectResponse, CoreErrors, CoreErrors::ENDPOINT_RESOLUTION_FAILURE, endpointResolutionOutcome.GetError().GetMessage());
  1883. auto addPrefixErr = endpointResolutionOutcome.GetResult().AddPrefixIfMissing("" + request.GetRequestRoute() + ".");
  1884. AWS_CHECK(SERVICE_NAME, !addPrefixErr, addPrefixErr->GetMessage(), WriteGetObjectResponseOutcome(addPrefixErr.value()));
  1885. endpointResolutionOutcome.GetResult().AddPathSegments("/WriteGetObjectResponse");
  1886. return WriteGetObjectResponseOutcome(MakeRequest(request, endpointResolutionOutcome.GetResult(), Aws::Http::HttpMethod::HTTP_POST));
  1887. }
  1888. #include<aws/core/utils/HashingUtils.h>
  1889. Aws::String S3Client::GeneratePresignedUrl(const Aws::String& bucket,
  1890. const Aws::String& key,
  1891. Aws::Http::HttpMethod method,
  1892. uint64_t expirationInSeconds)
  1893. {
  1894. return GeneratePresignedUrl(bucket, key, method, {}, expirationInSeconds);
  1895. }
  1896. Aws::String S3Client::GeneratePresignedUrl(const Aws::String& bucket,
  1897. const Aws::String& key,
  1898. Aws::Http::HttpMethod method,
  1899. const Http::HeaderValueCollection& customizedHeaders,
  1900. uint64_t expirationInSeconds)
  1901. {
  1902. if (!m_endpointProvider)
  1903. {
  1904. AWS_LOGSTREAM_ERROR(ALLOCATION_TAG, "Presigned URL generating failed. Endpoint provider is not initialized.");
  1905. return {};
  1906. }
  1907. ResolveEndpointOutcome computeEndpointOutcome = m_endpointProvider->ResolveEndpoint({{Aws::String("Bucket"), bucket}});
  1908. if (!computeEndpointOutcome.IsSuccess())
  1909. {
  1910. AWS_LOGSTREAM_ERROR(ALLOCATION_TAG, "Presigned URL generating failed. Encountered error: " << computeEndpointOutcome.GetError().GetMessage());
  1911. return {};
  1912. }
  1913. Aws::Endpoint::AWSEndpoint& endpoint = computeEndpointOutcome.GetResult();
  1914. URI uri(endpoint.GetURL());
  1915. uri.SetPath(uri.GetPath() + "/" + key);
  1916. endpoint.SetURL(uri.GetURIString());
  1917. return AWSClient::GeneratePresignedUrl(endpoint, method, customizedHeaders, expirationInSeconds);
  1918. }
  1919. Aws::String S3Client::GeneratePresignedUrlWithSSES3(const Aws::String& bucket,
  1920. const Aws::String& key,
  1921. Aws::Http::HttpMethod method,
  1922. uint64_t expirationInSeconds)
  1923. {
  1924. Aws::Http::HeaderValueCollection headers;
  1925. headers.emplace(Aws::S3::SSEHeaders::SERVER_SIDE_ENCRYPTION, Aws::S3::Model::ServerSideEncryptionMapper::GetNameForServerSideEncryption(Aws::S3::Model::ServerSideEncryption::AES256));
  1926. return GeneratePresignedUrl(bucket, key, method, headers, expirationInSeconds);
  1927. }
  1928. Aws::String S3Client::GeneratePresignedUrlWithSSES3(const Aws::String& bucket,
  1929. const Aws::String& key,
  1930. Aws::Http::HttpMethod method,
  1931. Http::HeaderValueCollection customizedHeaders,
  1932. uint64_t expirationInSeconds)
  1933. {
  1934. customizedHeaders.emplace(Aws::S3::SSEHeaders::SERVER_SIDE_ENCRYPTION, Aws::S3::Model::ServerSideEncryptionMapper::GetNameForServerSideEncryption(Aws::S3::Model::ServerSideEncryption::AES256));
  1935. return GeneratePresignedUrl(bucket, key, method, customizedHeaders, expirationInSeconds);
  1936. }
  1937. Aws::String S3Client::GeneratePresignedUrlWithSSEKMS(const Aws::String& bucket,
  1938. const Aws::String& key,
  1939. Aws::Http::HttpMethod method,
  1940. const Aws::String& kmsMasterKeyId,
  1941. uint64_t expirationInSeconds)
  1942. {
  1943. Aws::Http::HeaderValueCollection headers;
  1944. headers.emplace(Aws::S3::SSEHeaders::SERVER_SIDE_ENCRYPTION, Aws::S3::Model::ServerSideEncryptionMapper::GetNameForServerSideEncryption(Aws::S3::Model::ServerSideEncryption::aws_kms));
  1945. headers.emplace(Aws::S3::SSEHeaders::SERVER_SIDE_ENCRYPTION_AWS_KMS_KEY_ID, kmsMasterKeyId);
  1946. return GeneratePresignedUrl(bucket, key, method, headers, expirationInSeconds);
  1947. }
  1948. Aws::String S3Client::GeneratePresignedUrlWithSSEKMS(const Aws::String& bucket,
  1949. const Aws::String& key,
  1950. Aws::Http::HttpMethod method,
  1951. Http::HeaderValueCollection customizedHeaders,
  1952. const Aws::String& kmsMasterKeyId,
  1953. uint64_t expirationInSeconds)
  1954. {
  1955. customizedHeaders.emplace(Aws::S3::SSEHeaders::SERVER_SIDE_ENCRYPTION, Aws::S3::Model::ServerSideEncryptionMapper::GetNameForServerSideEncryption(Aws::S3::Model::ServerSideEncryption::aws_kms));
  1956. customizedHeaders.emplace(Aws::S3::SSEHeaders::SERVER_SIDE_ENCRYPTION_AWS_KMS_KEY_ID, kmsMasterKeyId);
  1957. return GeneratePresignedUrl(bucket, key, method, customizedHeaders, expirationInSeconds);
  1958. }
  1959. Aws::String S3Client::GeneratePresignedUrlWithSSEC(const Aws::String& bucket,
  1960. const Aws::String& key,
  1961. Aws::Http::HttpMethod method,
  1962. const Aws::String& base64EncodedAES256Key,
  1963. uint64_t expirationInSeconds)
  1964. {
  1965. Aws::Http::HeaderValueCollection headers;
  1966. headers.emplace(Aws::S3::SSEHeaders::SERVER_SIDE_ENCRYPTION_CUSTOMER_ALGORITHM, Aws::S3::Model::ServerSideEncryptionMapper::GetNameForServerSideEncryption(Aws::S3::Model::ServerSideEncryption::AES256));
  1967. headers.emplace(Aws::S3::SSEHeaders::SERVER_SIDE_ENCRYPTION_CUSTOMER_KEY, base64EncodedAES256Key);
  1968. Aws::Utils::ByteBuffer buffer = Aws::Utils::HashingUtils::Base64Decode(base64EncodedAES256Key);
  1969. Aws::String strBuffer(reinterpret_cast<char*>(buffer.GetUnderlyingData()), buffer.GetLength());
  1970. headers.emplace(Aws::S3::SSEHeaders::SERVER_SIDE_ENCRYPTION_CUSTOMER_KEY_MD5, Aws::Utils::HashingUtils::Base64Encode(Aws::Utils::HashingUtils::CalculateMD5(strBuffer)));
  1971. return GeneratePresignedUrl(bucket, key, method, headers, expirationInSeconds);
  1972. }
  1973. Aws::String S3Client::GeneratePresignedUrlWithSSEC(const Aws::String& bucket,
  1974. const Aws::String& key,
  1975. Aws::Http::HttpMethod method,
  1976. Http::HeaderValueCollection customizedHeaders,
  1977. const Aws::String& base64EncodedAES256Key,
  1978. uint64_t expirationInSeconds)
  1979. {
  1980. customizedHeaders.emplace(Aws::S3::SSEHeaders::SERVER_SIDE_ENCRYPTION_CUSTOMER_ALGORITHM, Aws::S3::Model::ServerSideEncryptionMapper::GetNameForServerSideEncryption(Aws::S3::Model::ServerSideEncryption::AES256));
  1981. customizedHeaders.emplace(Aws::S3::SSEHeaders::SERVER_SIDE_ENCRYPTION_CUSTOMER_KEY, base64EncodedAES256Key);
  1982. Aws::Utils::ByteBuffer buffer = Aws::Utils::HashingUtils::Base64Decode(base64EncodedAES256Key);
  1983. Aws::String strBuffer(reinterpret_cast<char*>(buffer.GetUnderlyingData()), buffer.GetLength());
  1984. customizedHeaders.emplace(Aws::S3::SSEHeaders::SERVER_SIDE_ENCRYPTION_CUSTOMER_KEY_MD5, Aws::Utils::HashingUtils::Base64Encode(Aws::Utils::HashingUtils::CalculateMD5(strBuffer)));
  1985. return GeneratePresignedUrl(bucket, key, method, customizedHeaders, expirationInSeconds);
  1986. }
  1987. bool S3Client::MultipartUploadSupported() const
  1988. {
  1989. return true;
  1990. }