Cloud Firestore V1 Client - Class FirestoreClient (1.47.0)

use Google\ApiCore\ApiException;
use Google\ApiCore\ServerStream;
use Google\Cloud\Firestore\V1\BatchGetDocumentsRequest;
use Google\Cloud\Firestore\V1\BatchGetDocumentsResponse;
use Google\Cloud\Firestore\V1\Client\FirestoreClient;

/**
 * @param string $database         The database name. In the format:
 *                                 `projects/{project_id}/databases/{database_id}`.
 * @param string $documentsElement The names of the documents to retrieve. In the format:
 *                                 `projects/{project_id}/databases/{database_id}/documents/{document_path}`.
 *                                 The request will fail if any of the document is not a child resource of the
 *                                 given `database`. Duplicate names will be elided.
 */
function batch_get_documents_sample(string $database, string $documentsElement): void
{
    // Create a client.
    $firestoreClient = new FirestoreClient();

    // Prepare the request message.
    $documents = [$documentsElement,];
    $request = (new BatchGetDocumentsRequest())
        ->setDatabase($database)
        ->setDocuments($documents);

    // Call the API and handle any network failures.
    try {
        /** @var ServerStream $stream */
        $stream = $firestoreClient->batchGetDocuments($request);

        /** @var BatchGetDocumentsResponse $element */
        foreach ($stream->readAll() as $element) {
            printf('Element data: %s' . PHP_EOL, $element->serializeToJsonString());
        }
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

/**
 * Helper to execute the sample.
 *
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function callSample(): void
{
    $database = '[DATABASE]';
    $documentsElement = '[DOCUMENTS]';

    batch_get_documents_sample($database, $documentsElement);
}

use Google\ApiCore\ApiException;
use Google\Cloud\Firestore\V1\BatchWriteRequest;
use Google\Cloud\Firestore\V1\BatchWriteResponse;
use Google\Cloud\Firestore\V1\Client\FirestoreClient;

/**
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function batch_write_sample(): void
{
    // Create a client.
    $firestoreClient = new FirestoreClient();

    // Prepare the request message.
    $request = new BatchWriteRequest();

    // Call the API and handle any network failures.
    try {
        /** @var BatchWriteResponse $response */
        $response = $firestoreClient->batchWrite($request);
        printf('Response data: %s' . PHP_EOL, $response->serializeToJsonString());
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

use Google\ApiCore\ApiException;
use Google\Cloud\Firestore\V1\BeginTransactionRequest;
use Google\Cloud\Firestore\V1\BeginTransactionResponse;
use Google\Cloud\Firestore\V1\Client\FirestoreClient;

/**
 * @param string $database The database name. In the format:
 *                         `projects/{project_id}/databases/{database_id}`.
 */
function begin_transaction_sample(string $database): void
{
    // Create a client.
    $firestoreClient = new FirestoreClient();

    // Prepare the request message.
    $request = (new BeginTransactionRequest())
        ->setDatabase($database);

    // Call the API and handle any network failures.
    try {
        /** @var BeginTransactionResponse $response */
        $response = $firestoreClient->beginTransaction($request);
        printf('Response data: %s' . PHP_EOL, $response->serializeToJsonString());
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

/**
 * Helper to execute the sample.
 *
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function callSample(): void
{
    $database = '[DATABASE]';

    begin_transaction_sample($database);
}

use Google\ApiCore\ApiException;
use Google\Cloud\Firestore\V1\Client\FirestoreClient;
use Google\Cloud\Firestore\V1\CommitRequest;
use Google\Cloud\Firestore\V1\CommitResponse;
use Google\Cloud\Firestore\V1\Write;

/**
 * @param string $database The database name. In the format:
 *                         `projects/{project_id}/databases/{database_id}`.
 */
function commit_sample(string $database): void
{
    // Create a client.
    $firestoreClient = new FirestoreClient();

    // Prepare the request message.
    $writes = [new Write()];
    $request = (new CommitRequest())
        ->setDatabase($database)
        ->setWrites($writes);

    // Call the API and handle any network failures.
    try {
        /** @var CommitResponse $response */
        $response = $firestoreClient->commit($request);
        printf('Response data: %s' . PHP_EOL, $response->serializeToJsonString());
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

/**
 * Helper to execute the sample.
 *
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function callSample(): void
{
    $database = '[DATABASE]';

    commit_sample($database);
}

use Google\ApiCore\ApiException;
use Google\Cloud\Firestore\V1\Client\FirestoreClient;
use Google\Cloud\Firestore\V1\CreateDocumentRequest;
use Google\Cloud\Firestore\V1\Document;

/**
 * @param string $parent       The parent resource. For example:
 *                             `projects/{project_id}/databases/{database_id}/documents` or
 *                             `projects/{project_id}/databases/{database_id}/documents/chatrooms/{chatroom_id}`
 * @param string $collectionId The collection ID, relative to `parent`, to list. For example:
 *                             `chatrooms`.
 * @param string $documentId   The client-assigned document ID to use for this document.
 *
 *                             Optional. If not specified, an ID will be assigned by the service.
 */
function create_document_sample(string $parent, string $collectionId, string $documentId): void
{
    // Create a client.
    $firestoreClient = new FirestoreClient();

    // Prepare the request message.
    $document = new Document();
    $request = (new CreateDocumentRequest())
        ->setParent($parent)
        ->setCollectionId($collectionId)
        ->setDocumentId($documentId)
        ->setDocument($document);

    // Call the API and handle any network failures.
    try {
        /** @var Document $response */
        $response = $firestoreClient->createDocument($request);
        printf('Response data: %s' . PHP_EOL, $response->serializeToJsonString());
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

/**
 * Helper to execute the sample.
 *
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function callSample(): void
{
    $parent = '[PARENT]';
    $collectionId = '[COLLECTION_ID]';
    $documentId = '[DOCUMENT_ID]';

    create_document_sample($parent, $collectionId, $documentId);
}

use Google\ApiCore\ApiException;
use Google\Cloud\Firestore\V1\Client\FirestoreClient;
use Google\Cloud\Firestore\V1\DeleteDocumentRequest;

/**
 * @param string $name The resource name of the Document to delete. In the format:
 *                     `projects/{project_id}/databases/{database_id}/documents/{document_path}`.
 */
function delete_document_sample(string $name): void
{
    // Create a client.
    $firestoreClient = new FirestoreClient();

    // Prepare the request message.
    $request = (new DeleteDocumentRequest())
        ->setName($name);

    // Call the API and handle any network failures.
    try {
        $firestoreClient->deleteDocument($request);
        printf('Call completed successfully.' . PHP_EOL);
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

/**
 * Helper to execute the sample.
 *
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function callSample(): void
{
    $name = '[NAME]';

    delete_document_sample($name);
}

use Google\ApiCore\ApiException;
use Google\Cloud\Firestore\V1\Client\FirestoreClient;
use Google\Cloud\Firestore\V1\Document;
use Google\Cloud\Firestore\V1\GetDocumentRequest;

/**
 * @param string $name The resource name of the Document to get. In the format:
 *                     `projects/{project_id}/databases/{database_id}/documents/{document_path}`.
 */
function get_document_sample(string $name): void
{
    // Create a client.
    $firestoreClient = new FirestoreClient();

    // Prepare the request message.
    $request = (new GetDocumentRequest())
        ->setName($name);

    // Call the API and handle any network failures.
    try {
        /** @var Document $response */
        $response = $firestoreClient->getDocument($request);
        printf('Response data: %s' . PHP_EOL, $response->serializeToJsonString());
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

/**
 * Helper to execute the sample.
 *
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function callSample(): void
{
    $name = '[NAME]';

    get_document_sample($name);
}

use Google\ApiCore\ApiException;
use Google\ApiCore\PagedListResponse;
use Google\Cloud\Firestore\V1\Client\FirestoreClient;
use Google\Cloud\Firestore\V1\ListCollectionIdsRequest;

/**
 * @param string $parent The parent document. In the format:
 *                       `projects/{project_id}/databases/{database_id}/documents/{document_path}`.
 *                       For example:
 *                       `projects/my-project/databases/my-database/documents/chatrooms/my-chatroom`
 */
function list_collection_ids_sample(string $parent): void
{
    // Create a client.
    $firestoreClient = new FirestoreClient();

    // Prepare the request message.
    $request = (new ListCollectionIdsRequest())
        ->setParent($parent);

    // Call the API and handle any network failures.
    try {
        /** @var PagedListResponse $response */
        $response = $firestoreClient->listCollectionIds($request);

        /** @var string $element */
        foreach ($response as $element) {
            printf('Element data: %s' . PHP_EOL, $element);
        }
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

/**
 * Helper to execute the sample.
 *
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function callSample(): void
{
    $parent = '[PARENT]';

    list_collection_ids_sample($parent);
}

use Google\ApiCore\ApiException;
use Google\ApiCore\PagedListResponse;
use Google\Cloud\Firestore\V1\Client\FirestoreClient;
use Google\Cloud\Firestore\V1\Document;
use Google\Cloud\Firestore\V1\ListDocumentsRequest;

/**
 * @param string $parent       The parent resource name. In the format:
 *                             `projects/{project_id}/databases/{database_id}/documents` or
 *                             `projects/{project_id}/databases/{database_id}/documents/{document_path}`.
 *
 *                             For example:
 *                             `projects/my-project/databases/my-database/documents` or
 *                             `projects/my-project/databases/my-database/documents/chatrooms/my-chatroom`
 * @param string $collectionId Optional. The collection ID, relative to `parent`, to list.
 *
 *                             For example: `chatrooms` or `messages`.
 *
 *                             This is optional, and when not provided, Firestore will list documents
 *                             from all collections under the provided `parent`.
 */
function list_documents_sample(string $parent, string $collectionId): void
{
    // Create a client.
    $firestoreClient = new FirestoreClient();

    // Prepare the request message.
    $request = (new ListDocumentsRequest())
        ->setParent($parent)
        ->setCollectionId($collectionId);

    // Call the API and handle any network failures.
    try {
        /** @var PagedListResponse $response */
        $response = $firestoreClient->listDocuments($request);

        /** @var Document $element */
        foreach ($response as $element) {
            printf('Element data: %s' . PHP_EOL, $element->serializeToJsonString());
        }
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

/**
 * Helper to execute the sample.
 *
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function callSample(): void
{
    $parent = '[PARENT]';
    $collectionId = '[COLLECTION_ID]';

    list_documents_sample($parent, $collectionId);
}

use Google\ApiCore\ApiException;
use Google\ApiCore\BidiStream;
use Google\Cloud\Firestore\V1\Client\FirestoreClient;
use Google\Cloud\Firestore\V1\ListenRequest;
use Google\Cloud\Firestore\V1\ListenResponse;

/**
 * @param string $database The database name. In the format:
 *                         `projects/{project_id}/databases/{database_id}`.
 */
function listen_sample(string $database): void
{
    // Create a client.
    $firestoreClient = new FirestoreClient();

    // Prepare the request message.
    $request = (new ListenRequest())
        ->setDatabase($database);

    // Call the API and handle any network failures.
    try {
        /** @var BidiStream $stream */
        $stream = $firestoreClient->listen();
        $stream->writeAll([$request,]);

        /** @var ListenResponse $element */
        foreach ($stream->closeWriteAndReadAll() as $element) {
            printf('Element data: %s' . PHP_EOL, $element->serializeToJsonString());
        }
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

/**
 * Helper to execute the sample.
 *
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function callSample(): void
{
    $database = '[DATABASE]';

    listen_sample($database);
}

use Google\ApiCore\ApiException;
use Google\ApiCore\PagedListResponse;
use Google\Cloud\Firestore\V1\Client\FirestoreClient;
use Google\Cloud\Firestore\V1\Cursor;
use Google\Cloud\Firestore\V1\PartitionQueryRequest;

/**
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function partition_query_sample(): void
{
    // Create a client.
    $firestoreClient = new FirestoreClient();

    // Prepare the request message.
    $request = new PartitionQueryRequest();

    // Call the API and handle any network failures.
    try {
        /** @var PagedListResponse $response */
        $response = $firestoreClient->partitionQuery($request);

        /** @var Cursor $element */
        foreach ($response as $element) {
            printf('Element data: %s' . PHP_EOL, $element->serializeToJsonString());
        }
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

use Google\ApiCore\ApiException;
use Google\Cloud\Firestore\V1\Client\FirestoreClient;
use Google\Cloud\Firestore\V1\RollbackRequest;

/**
 * @param string $database    The database name. In the format:
 *                            `projects/{project_id}/databases/{database_id}`.
 * @param string $transaction The transaction to roll back.
 */
function rollback_sample(string $database, string $transaction): void
{
    // Create a client.
    $firestoreClient = new FirestoreClient();

    // Prepare the request message.
    $request = (new RollbackRequest())
        ->setDatabase($database)
        ->setTransaction($transaction);

    // Call the API and handle any network failures.
    try {
        $firestoreClient->rollback($request);
        printf('Call completed successfully.' . PHP_EOL);
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

/**
 * Helper to execute the sample.
 *
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function callSample(): void
{
    $database = '[DATABASE]';
    $transaction = '...';

    rollback_sample($database, $transaction);
}

use Google\ApiCore\ApiException;
use Google\ApiCore\ServerStream;
use Google\Cloud\Firestore\V1\Client\FirestoreClient;
use Google\Cloud\Firestore\V1\RunAggregationQueryRequest;
use Google\Cloud\Firestore\V1\RunAggregationQueryResponse;

/**
 * @param string $parent The parent resource name. In the format:
 *                       `projects/{project_id}/databases/{database_id}/documents` or
 *                       `projects/{project_id}/databases/{database_id}/documents/{document_path}`.
 *                       For example:
 *                       `projects/my-project/databases/my-database/documents` or
 *                       `projects/my-project/databases/my-database/documents/chatrooms/my-chatroom`
 */
function run_aggregation_query_sample(string $parent): void
{
    // Create a client.
    $firestoreClient = new FirestoreClient();

    // Prepare the request message.
    $request = (new RunAggregationQueryRequest())
        ->setParent($parent);

    // Call the API and handle any network failures.
    try {
        /** @var ServerStream $stream */
        $stream = $firestoreClient->runAggregationQuery($request);

        /** @var RunAggregationQueryResponse $element */
        foreach ($stream->readAll() as $element) {
            printf('Element data: %s' . PHP_EOL, $element->serializeToJsonString());
        }
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

/**
 * Helper to execute the sample.
 *
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function callSample(): void
{
    $parent = '[PARENT]';

    run_aggregation_query_sample($parent);
}

use Google\ApiCore\ApiException;
use Google\ApiCore\ServerStream;
use Google\Cloud\Firestore\V1\Client\FirestoreClient;
use Google\Cloud\Firestore\V1\RunQueryRequest;
use Google\Cloud\Firestore\V1\RunQueryResponse;

/**
 * @param string $parent The parent resource name. In the format:
 *                       `projects/{project_id}/databases/{database_id}/documents` or
 *                       `projects/{project_id}/databases/{database_id}/documents/{document_path}`.
 *                       For example:
 *                       `projects/my-project/databases/my-database/documents` or
 *                       `projects/my-project/databases/my-database/documents/chatrooms/my-chatroom`
 */
function run_query_sample(string $parent): void
{
    // Create a client.
    $firestoreClient = new FirestoreClient();

    // Prepare the request message.
    $request = (new RunQueryRequest())
        ->setParent($parent);

    // Call the API and handle any network failures.
    try {
        /** @var ServerStream $stream */
        $stream = $firestoreClient->runQuery($request);

        /** @var RunQueryResponse $element */
        foreach ($stream->readAll() as $element) {
            printf('Element data: %s' . PHP_EOL, $element->serializeToJsonString());
        }
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

/**
 * Helper to execute the sample.
 *
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function callSample(): void
{
    $parent = '[PARENT]';

    run_query_sample($parent);
}

use Google\ApiCore\ApiException;
use Google\Cloud\Firestore\V1\Client\FirestoreClient;
use Google\Cloud\Firestore\V1\Document;
use Google\Cloud\Firestore\V1\DocumentMask;
use Google\Cloud\Firestore\V1\UpdateDocumentRequest;

/**
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function update_document_sample(): void
{
    // Create a client.
    $firestoreClient = new FirestoreClient();

    // Prepare the request message.
    $document = new Document();
    $updateMask = new DocumentMask();
    $request = (new UpdateDocumentRequest())
        ->setDocument($document)
        ->setUpdateMask($updateMask);

    // Call the API and handle any network failures.
    try {
        /** @var Document $response */
        $response = $firestoreClient->updateDocument($request);
        printf('Response data: %s' . PHP_EOL, $response->serializeToJsonString());
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

use Google\ApiCore\ApiException;
use Google\ApiCore\BidiStream;
use Google\Cloud\Firestore\V1\Client\FirestoreClient;
use Google\Cloud\Firestore\V1\WriteRequest;
use Google\Cloud\Firestore\V1\WriteResponse;

/**
 * @param string $database The database name. In the format:
 *                         `projects/{project_id}/databases/{database_id}`.
 *                         This is only required in the first message.
 */
function write_sample(string $database): void
{
    // Create a client.
    $firestoreClient = new FirestoreClient();

    // Prepare the request message.
    $request = (new WriteRequest())
        ->setDatabase($database);

    // Call the API and handle any network failures.
    try {
        /** @var BidiStream $stream */
        $stream = $firestoreClient->write();
        $stream->writeAll([$request,]);

        /** @var WriteResponse $element */
        foreach ($stream->closeWriteAndReadAll() as $element) {
            printf('Element data: %s' . PHP_EOL, $element->serializeToJsonString());
        }
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

/**
 * Helper to execute the sample.
 *
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function callSample(): void
{
    $database = '[DATABASE]';

    write_sample($database);
}