in Sources/OSS/ClientObjectBasic.swift [9:48]
func putObject(
_ request: PutObjectRequest,
_ options: OperationOptions? = nil
) async throws -> PutObjectResult {
var input = OperationInput(
operationName: "PutObject",
method: "PUT"
)
input.bucket = try request.bucket.ensureRequired(field: "request.bucket")
input.key = try request.key.ensureRequired(field: "request.key")
if let progress = request.progress {
input.metadata.set(
key: AttributeKeys.progressDelegate,
value: ProgressDelegateDesc(delegate: ProgressWithRetry(progress), upload: true)
)
}
if clientImpl.hasFeatureFlag(FeatureFlag.enableCRC64CheckUpload) {
input.metadata.append(
key: AttributeKeys.responseHandler,
value: ChekerUploadCrcResponseHandler()
)
}
var req = request
var customDeserializers: [SerdeSerializeDelegate] = [Serde.serializePutObject]
if clientImpl.hasFeatureFlag(FeatureFlag.autoDetectMimeType) {
customDeserializers.append(Serde.addContentType)
}
try Serde.serializeInput(&req, &input, customDeserializers)
var output = try await clientImpl.execute(with: &input, args: options)
var result = PutObjectResult()
try Serde.deserializeOutput(&result, &output, [Serde.deserializePutObject])
return result
}