AsyncDocumentsClient.java

/**
 * This file was auto-generated by Fern from our API Definition.
 */
package com.cloudpdf.api.resources.documents;

import com.cloudpdf.api.core.ClientOptions;
import com.cloudpdf.api.core.RequestOptions;
import com.cloudpdf.api.resources.documents.requests.DeleteDocumentsRequest;
import com.cloudpdf.api.resources.documents.requests.DocumentsCommitRequest;
import com.cloudpdf.api.resources.documents.requests.DocumentsImportFromRequest;
import com.cloudpdf.api.resources.documents.requests.DocumentsInitRequest;
import com.cloudpdf.api.resources.documents.requests.DownloadDocumentsRequest;
import com.cloudpdf.api.resources.documents.requests.GetDocumentsRequest;
import com.cloudpdf.api.resources.documents.requests.ListDocumentsRequest;
import com.cloudpdf.api.resources.documents.requests.ThumbnailDocumentsRequest;
import com.cloudpdf.api.resources.documents.requests.UploadProxyDocumentsRequest;
import com.cloudpdf.api.types.DocumentsCommit200Response;
import com.cloudpdf.api.types.DocumentsGet200Response;
import com.cloudpdf.api.types.DocumentsImportFrom200Response;
import com.cloudpdf.api.types.DocumentsInit200Response;
import com.cloudpdf.api.types.DocumentsList200Response;
import com.cloudpdf.api.types.DocumentsUploadProxy200Response;
import java.io.File;
import java.io.InputStream;
import java.util.concurrent.CompletableFuture;
import okhttp3.MediaType;

public class AsyncDocumentsClient {
    protected final ClientOptions clientOptions;

    private final AsyncRawDocumentsClient rawClient;

    public AsyncDocumentsClient(ClientOptions clientOptions) {
        this.clientOptions = clientOptions;
        this.rawClient = new AsyncRawDocumentsClient(clientOptions);
    }

    /**
     * Get responses with HTTP metadata like headers
     */
    public AsyncRawDocumentsClient withRawResponse() {
        return this.rawClient;
    }

    public CompletableFuture<DocumentsList200Response> list(String tenantId) {
        return this.rawClient.list(tenantId).thenApply(response -> response.body());
    }

    public CompletableFuture<DocumentsList200Response> list(String tenantId, RequestOptions requestOptions) {
        return this.rawClient.list(tenantId, requestOptions).thenApply(response -> response.body());
    }

    public CompletableFuture<DocumentsList200Response> list(String tenantId, ListDocumentsRequest request) {
        return this.rawClient.list(tenantId, request).thenApply(response -> response.body());
    }

    public CompletableFuture<DocumentsList200Response> list(
            String tenantId, ListDocumentsRequest request, RequestOptions requestOptions) {
        return this.rawClient.list(tenantId, request, requestOptions).thenApply(response -> response.body());
    }

    public CompletableFuture<DocumentsGet200Response> get(String tenantId, String id) {
        return this.rawClient.get(tenantId, id).thenApply(response -> response.body());
    }

    public CompletableFuture<DocumentsGet200Response> get(String tenantId, String id, RequestOptions requestOptions) {
        return this.rawClient.get(tenantId, id, requestOptions).thenApply(response -> response.body());
    }

    public CompletableFuture<DocumentsGet200Response> get(String tenantId, String id, GetDocumentsRequest request) {
        return this.rawClient.get(tenantId, id, request).thenApply(response -> response.body());
    }

    public CompletableFuture<DocumentsGet200Response> get(
            String tenantId, String id, GetDocumentsRequest request, RequestOptions requestOptions) {
        return this.rawClient.get(tenantId, id, request, requestOptions).thenApply(response -> response.body());
    }

    public CompletableFuture<Void> delete(String tenantId, String id) {
        return this.rawClient.delete(tenantId, id).thenApply(response -> response.body());
    }

    public CompletableFuture<Void> delete(String tenantId, String id, RequestOptions requestOptions) {
        return this.rawClient.delete(tenantId, id, requestOptions).thenApply(response -> response.body());
    }

    public CompletableFuture<Void> delete(String tenantId, String id, DeleteDocumentsRequest request) {
        return this.rawClient.delete(tenantId, id, request).thenApply(response -> response.body());
    }

    public CompletableFuture<Void> delete(
            String tenantId, String id, DeleteDocumentsRequest request, RequestOptions requestOptions) {
        return this.rawClient.delete(tenantId, id, request, requestOptions).thenApply(response -> response.body());
    }

    public CompletableFuture<DocumentsCommit200Response> commit(
            String tenantId, String id, DocumentsCommitRequest request) {
        return this.rawClient.commit(tenantId, id, request).thenApply(response -> response.body());
    }

    public CompletableFuture<DocumentsCommit200Response> commit(
            String tenantId, String id, DocumentsCommitRequest request, RequestOptions requestOptions) {
        return this.rawClient.commit(tenantId, id, request, requestOptions).thenApply(response -> response.body());
    }

    public CompletableFuture<InputStream> download(String tenantId, String id) {
        return this.rawClient.download(tenantId, id).thenApply(response -> response.body());
    }

    public CompletableFuture<InputStream> download(String tenantId, String id, RequestOptions requestOptions) {
        return this.rawClient.download(tenantId, id, requestOptions).thenApply(response -> response.body());
    }

    public CompletableFuture<InputStream> download(String tenantId, String id, DownloadDocumentsRequest request) {
        return this.rawClient.download(tenantId, id, request).thenApply(response -> response.body());
    }

    public CompletableFuture<InputStream> download(
            String tenantId, String id, DownloadDocumentsRequest request, RequestOptions requestOptions) {
        return this.rawClient.download(tenantId, id, request, requestOptions).thenApply(response -> response.body());
    }

    public CompletableFuture<InputStream> thumbnail(String tenantId, String id) {
        return this.rawClient.thumbnail(tenantId, id).thenApply(response -> response.body());
    }

    public CompletableFuture<InputStream> thumbnail(String tenantId, String id, RequestOptions requestOptions) {
        return this.rawClient.thumbnail(tenantId, id, requestOptions).thenApply(response -> response.body());
    }

    public CompletableFuture<InputStream> thumbnail(String tenantId, String id, ThumbnailDocumentsRequest request) {
        return this.rawClient.thumbnail(tenantId, id, request).thenApply(response -> response.body());
    }

    public CompletableFuture<InputStream> thumbnail(
            String tenantId, String id, ThumbnailDocumentsRequest request, RequestOptions requestOptions) {
        return this.rawClient.thumbnail(tenantId, id, request, requestOptions).thenApply(response -> response.body());
    }

    /**
     * This bounded origin-mediated fallback must only be used after documents.init returns upload.kind=proxy. Auto mode prefers a presigned object-store PUT whenever available.
     */
    public CompletableFuture<DocumentsUploadProxy200Response> uploadProxy(
            String tenantId, String id, File file, UploadProxyDocumentsRequest request) {
        return this.rawClient.uploadProxy(tenantId, id, file, request).thenApply(response -> response.body());
    }

    /**
     * This bounded origin-mediated fallback must only be used after documents.init returns upload.kind=proxy. Auto mode prefers a presigned object-store PUT whenever available.
     */
    public CompletableFuture<DocumentsUploadProxy200Response> uploadProxy(
            String tenantId, String id, File file, UploadProxyDocumentsRequest request, RequestOptions requestOptions) {
        return this.rawClient
                .uploadProxy(tenantId, id, file, request, requestOptions)
                .thenApply(response -> response.body());
    }

    public CompletableFuture<DocumentsUploadProxy200Response> uploadProxy(
            String tenantId, String id, InputStream stream, String filename) {
        return this.rawClient.uploadProxy(tenantId, id, stream, filename).thenApply(response -> response.body());
    }

    public CompletableFuture<DocumentsUploadProxy200Response> uploadProxy(
            String tenantId, String id, InputStream stream, String filename, MediaType mediaType) {
        return this.rawClient
                .uploadProxy(tenantId, id, stream, filename, mediaType)
                .thenApply(response -> response.body());
    }

    public CompletableFuture<DocumentsUploadProxy200Response> uploadProxy(
            String tenantId, String id, InputStream stream, String filename, RequestOptions requestOptions) {
        return this.rawClient
                .uploadProxy(tenantId, id, stream, filename, requestOptions)
                .thenApply(response -> response.body());
    }

    public CompletableFuture<DocumentsUploadProxy200Response> uploadProxy(
            String tenantId,
            String id,
            InputStream stream,
            String filename,
            MediaType mediaType,
            RequestOptions requestOptions) {
        return this.rawClient
                .uploadProxy(tenantId, id, stream, filename, mediaType, requestOptions)
                .thenApply(response -> response.body());
    }

    /**
     * Default mode is synchronous and bounded: the response returns only after the transfer verified and committed (or failed). mode=async (connection sources only) answers 202 immediately and an in-process worker performs the transfer with leased, fenced retries; poll the document until ready/failed. The deployment import policy gates scheme, network range, and size; sources must declare a length. CloudPDF copies and owns the bytes — the source is never referenced in place. A 502 marks a retryable upstream failure: retry with the same idempotencyKey to resume the same document. URL sources are capabilities and never echoed back. Connection sources name operator-registered storage (bucket/prefix scope, allowed credential classes, and tenant bindings are deployment configuration); <code>revision</code> is provider-interpreted (S3 VersionId, GCS generation, Azure version id).
     */
    public CompletableFuture<DocumentsImportFrom200Response> importFrom(
            String tenantId, DocumentsImportFromRequest request) {
        return this.rawClient.importFrom(tenantId, request).thenApply(response -> response.body());
    }

    /**
     * Default mode is synchronous and bounded: the response returns only after the transfer verified and committed (or failed). mode=async (connection sources only) answers 202 immediately and an in-process worker performs the transfer with leased, fenced retries; poll the document until ready/failed. The deployment import policy gates scheme, network range, and size; sources must declare a length. CloudPDF copies and owns the bytes — the source is never referenced in place. A 502 marks a retryable upstream failure: retry with the same idempotencyKey to resume the same document. URL sources are capabilities and never echoed back. Connection sources name operator-registered storage (bucket/prefix scope, allowed credential classes, and tenant bindings are deployment configuration); <code>revision</code> is provider-interpreted (S3 VersionId, GCS generation, Azure version id).
     */
    public CompletableFuture<DocumentsImportFrom200Response> importFrom(
            String tenantId, DocumentsImportFromRequest request, RequestOptions requestOptions) {
        return this.rawClient.importFrom(tenantId, request, requestOptions).thenApply(response -> response.body());
    }

    public CompletableFuture<DocumentsInit200Response> init(String tenantId, DocumentsInitRequest request) {
        return this.rawClient.init(tenantId, request).thenApply(response -> response.body());
    }

    public CompletableFuture<DocumentsInit200Response> init(
            String tenantId, DocumentsInitRequest request, RequestOptions requestOptions) {
        return this.rawClient.init(tenantId, request, requestOptions).thenApply(response -> response.body());
    }
}