nixsolutions / yandex-php-library

     * @throws UnauthorizedException

     * @throws UnavailableResourceException

     */

    public function createDatabase($databaseId = null, $context = null, $fields = [])

    {

        $response            = $this->sendRequest('PUT', $this->getDatabaseUrl($databaseId, $context, $fields));

        $decodedResponseBody = $this->getDecodedBody($response->getBody());

        $database            = new Database($decodedResponseBody);

        $database->setContext($this->getContext());

        return $database;

    }

    /**

     * @param null|string $databaseId

     * @throws UnauthorizedException

     * @throws UnavailableResourceException

     */

    public function getDatabase($databaseId = null, $context = null, $fields = [])

    {

        $response            = $this->sendRequest('GET', $this->getDatabaseUrl($databaseId, $context, $fields));

        $decodedResponseBody = $this->getDecodedBody($response->getBody());

        $database            = new Database($decodedResponseBody);

        $database->setContext($this->getContext());

        return $database;

    }

    /**

     * @param null|string $databaseId

     * @throws UnauthorizedException

     * @throws UnavailableResourceException

     */

    public function getDatabaseSnapshot($databaseId = null, $context = null, $collectionId = null, $fields = [])

    {

        $response            = $this->sendRequest(

            'GET',

            $this->getDatabaseSnapshotUrl($databaseId, $context, $collectionId, $fields)

        );

        $decodedResponseBody = $this->getDecodedBody($response->getBody());

        $result              = new DatabaseSnapshotResponse($decodedResponseBody);

        return $result;

    }

    /**

     * @param array       $data

     * @throws UnauthorizedException

     * @throws UnavailableResourceException

     */

    public function getDelta($baseRevision = 0, $databaseId = null, $context = null, $fields = [], $limit = null)

    {

        $response            = $this->sendRequest(

            'GET',

            $this->getDatabaseDeltasUrl($databaseId, $context, $fields, $baseRevision, $limit)

        );

        $decodedResponseBody = $this->getDecodedBody($response->getBody());

        $result              = new DatabaseDeltasResponse($decodedResponseBody);

        return $result;

    }

}