public virtual async Task GetDocumentAsync()

in Elastic.SemanticKernel.Connectors.Elasticsearch/MockableElasticsearchClient.cs [182:210]

• 25 lines of code
• 3 McCabe index (conditional complexity)

    public virtual async Task<(string id, JsonObject document)?> GetDocumentAsync(
        IndexName indexName,
        Id id,
        CancellationToken cancellationToken = default)
    {
        Verify.NotNull(indexName);
        Verify.NotNull(id);

        var response = await ElasticsearchClient
            .GetAsync<JsonObject>(
                new GetRequest(indexName, id)
                {
                    RequestConfiguration = CustomUserAgentRequestConfiguration
                },
                cancellationToken)
            .ConfigureAwait(false);

        if (!response.IsSuccess())
        {
            throw new TransportException(PipelineFailure.Unexpected, "Failed to execute request.", response);
        }

        if (!response.Found)
        {
            return null;
        }

        return (response.Id, response.Source!);
    }