* @param inputStream the input stream of data to upload
     * @param size the size of the data in bytes
     * @param contentType the MIME type of the content
     */
    void uploadObject(String objectName, InputStream inputStream, long size, String contentType);

    /**
     * Downloads an object from storage.
     *
     * @param objectName the name/path of the object to download

    }

    @Override
    public void uploadObject(final String objectName, final InputStream inputStream, final long size, final String contentType) {
        try {
            final PutObjectRequest request =
                    PutObjectRequest.builder().bucket(bucket).key(objectName).contentType(contentType).contentLength(size).build();
            s3Client.putObject(request, RequestBody.fromInputStream(inputStream, size));

                .contentType("application/octet-stream")
                .build());
        minioClient.putObject(PutObjectArgs.builder()
                .bucket(bucketName)
                .object("dir1/file2.txt")
                .stream(new ByteArrayInputStream("file2".getBytes()), 5, -1)
                .contentType("application/octet-stream")
                .build());

    }

    @Override
    public void uploadObject(final String objectName, final InputStream inputStream, final long size, final String contentType) {
        try {
            final BlobId blobId = BlobId.of(bucket, objectName);
            final BlobInfo blobInfo = BlobInfo.newBuilder(blobId).setContentType(contentType).build();
            storage.createFrom(blobInfo, inputStream);
        } catch (final Exception e) {

        Handler.GcsURLConnection conn = (Handler.GcsURLConnection) handler.openConnection(url);

        // Should return null when auto-connect fails due to missing project ID
        String contentType = conn.getContentType();
        assertNull(contentType);
    }

    /**
     * Test that getLastModified() attempts to connect if not connected.
     */
    public void test_getLastModified_autoConnect() throws Exception {

        Handler.StorageURLConnection conn = (Handler.StorageURLConnection) handler.openConnection(url);

        // Should return null when auto-connect fails due to missing endpoint
        String contentType = conn.getContentType();
        assertNull(contentType);
    }

    /**
     * Test that getLastModified() attempts to connect if not connected.
     */
    public void test_getLastModified_autoConnect() throws Exception {

        @Override
        public String getContentType() {
            try {
                if (!connected) {
                    connect();
                }
                return getHeadObject().contentType();
            } catch (final IOException e) {
                return null;
            }
        }

        /**
         * Gets the date of the S3 object.

class ParameterInType(Enum):
    query = "query"
    header = "header"
    path = "path"
    cookie = "cookie"


class Encoding(BaseModelWithConfig):
    contentType: Optional[str] = None
    headers: Optional[dict[str, Union["Header", Reference]]] = None
    style: Optional[str] = None
    explode: Optional[bool] = None
    allowReserved: Optional[bool] = None

                            "Failed to log out.", new SsoProcessException(msg));
                }
                return new StreamResponse("metadata").contentType("application/xhtml+xml").stream(out -> {
                    try (final Writer writer = new OutputStreamWriter(out.stream(), Constants.UTF_8_CHARSET)) {
                        writer.write(metadata);
                    }

            responseData.setCharSet(getCharset());
            responseData.setLastModified(headObject.lastModified() == null ? null : Date.from(headObject.lastModified()));
            responseData.setMimeType(headObject.contentType());

            // Add metadata
            if (headObject.metadata() != null) {
                headObject.metadata().forEach(responseData::addMetaData);
            }