Functions.php

<?php

namespace Appwrite\Services;

use Appwrite\AppwriteException;
use Appwrite\Client;
use Appwrite\Service;
use Appwrite\InputFile;
use Appwrite\Enums\Runtime;
use Appwrite\Enums\Scopes;
use Appwrite\Enums\TemplateReferenceType;
use Appwrite\Enums\VCSReferenceType;
use Appwrite\Enums\DeploymentDownloadType;
use Appwrite\Enums\ExecutionMethod;

class Functions extends Service
{
    public function __construct(Client $client)
    {
        parent::__construct($client);
    }

    /**
     * Get a list of all the project's functions. You can use the query params to
     * filter your results.
     *
     * @param ?array $queries
     * @param ?string $search
     * @param ?bool $total
     * @throws AppwriteException
     * @return \Appwrite\Models\FunctionList
     */
    public function list(?array $queries = null, ?string $search = null, ?bool $total = null): \Appwrite\Models\FunctionList
    {
        $apiPath = str_replace(
            [],
            [],
            '/functions'
        );

        $apiParams = [];

        if (!is_null($queries)) {
            $apiParams['queries'] = $queries;
        }

        if (!is_null($search)) {
            $apiParams['search'] = $search;
        }

        if (!is_null($total)) {
            $apiParams['total'] = $total;
        }

        $apiHeaders = [];

        $response = $this->client->call(
            Client::METHOD_GET,
            $apiPath,
            $apiHeaders,
            $apiParams
        );

        if (!is_array($response)) {
            throw new \UnexpectedValueException('Expected array response when hydrating a response model.');
        }

        return \Appwrite\Models\FunctionList::from($response);

    }

    /**
     * Create a new function. You can pass a list of
     * [permissions](https://appwrite.io/docs/permissions) to allow different
     * project users or team with access to execute the function using the client
     * API.
     *
     * @param string $functionId
     * @param string $name
     * @param Runtime $runtime
     * @param ?array $execute
     * @param ?array $events
     * @param ?string $schedule
     * @param ?int $timeout
     * @param ?bool $enabled
     * @param ?bool $logging
     * @param ?string $entrypoint
     * @param ?string $commands
     * @param ?array $scopes
     * @param ?string $installationId
     * @param ?string $providerRepositoryId
     * @param ?string $providerBranch
     * @param ?bool $providerSilentMode
     * @param ?string $providerRootDirectory
     * @param ?string $buildSpecification
     * @param ?string $runtimeSpecification
     * @param ?int $deploymentRetention
     * @throws AppwriteException
     * @return \Appwrite\Models\FunctionModel
     */
    public function create(string $functionId, string $name, Runtime $runtime, ?array $execute = null, ?array $events = null, ?string $schedule = null, ?int $timeout = null, ?bool $enabled = null, ?bool $logging = null, ?string $entrypoint = null, ?string $commands = null, ?array $scopes = null, ?string $installationId = null, ?string $providerRepositoryId = null, ?string $providerBranch = null, ?bool $providerSilentMode = null, ?string $providerRootDirectory = null, ?string $buildSpecification = null, ?string $runtimeSpecification = null, ?int $deploymentRetention = null): \Appwrite\Models\FunctionModel
    {
        $apiPath = str_replace(
            [],
            [],
            '/functions'
        );

        $apiParams = [];
        $apiParams['functionId'] = $functionId;
        $apiParams['name'] = $name;
        $apiParams['runtime'] = $runtime;

        if (!is_null($execute)) {
            $apiParams['execute'] = $execute;
        }

        if (!is_null($events)) {
            $apiParams['events'] = $events;
        }

        if (!is_null($schedule)) {
            $apiParams['schedule'] = $schedule;
        }

        if (!is_null($timeout)) {
            $apiParams['timeout'] = $timeout;
        }

        if (!is_null($enabled)) {
            $apiParams['enabled'] = $enabled;
        }

        if (!is_null($logging)) {
            $apiParams['logging'] = $logging;
        }

        if (!is_null($entrypoint)) {
            $apiParams['entrypoint'] = $entrypoint;
        }

        if (!is_null($commands)) {
            $apiParams['commands'] = $commands;
        }

        if (!is_null($scopes)) {
            $apiParams['scopes'] = $scopes;
        }

        if (!is_null($installationId)) {
            $apiParams['installationId'] = $installationId;
        }

        if (!is_null($providerRepositoryId)) {
            $apiParams['providerRepositoryId'] = $providerRepositoryId;
        }

        if (!is_null($providerBranch)) {
            $apiParams['providerBranch'] = $providerBranch;
        }

        if (!is_null($providerSilentMode)) {
            $apiParams['providerSilentMode'] = $providerSilentMode;
        }

        if (!is_null($providerRootDirectory)) {
            $apiParams['providerRootDirectory'] = $providerRootDirectory;
        }

        if (!is_null($buildSpecification)) {
            $apiParams['buildSpecification'] = $buildSpecification;
        }

        if (!is_null($runtimeSpecification)) {
            $apiParams['runtimeSpecification'] = $runtimeSpecification;
        }

        if (!is_null($deploymentRetention)) {
            $apiParams['deploymentRetention'] = $deploymentRetention;
        }

        $apiHeaders = [];
        $apiHeaders['content-type'] = 'application/json';

        $response = $this->client->call(
            Client::METHOD_POST,
            $apiPath,
            $apiHeaders,
            $apiParams
        );

        if (!is_array($response)) {
            throw new \UnexpectedValueException('Expected array response when hydrating a response model.');
        }

        return \Appwrite\Models\FunctionModel::from($response);

    }

    /**
     * Get a list of all runtimes that are currently active on your instance.
     *
     * @throws AppwriteException
     * @return \Appwrite\Models\RuntimeList
     */
    public function listRuntimes(): \Appwrite\Models\RuntimeList
    {
        $apiPath = str_replace(
            [],
            [],
            '/functions/runtimes'
        );

        $apiParams = [];

        $apiHeaders = [];

        $response = $this->client->call(
            Client::METHOD_GET,
            $apiPath,
            $apiHeaders,
            $apiParams
        );

        if (!is_array($response)) {
            throw new \UnexpectedValueException('Expected array response when hydrating a response model.');
        }

        return \Appwrite\Models\RuntimeList::from($response);

    }

    /**
     * List allowed function specifications for this instance.
     *
     * @throws AppwriteException
     * @return \Appwrite\Models\SpecificationList
     */
    public function listSpecifications(): \Appwrite\Models\SpecificationList
    {
        $apiPath = str_replace(
            [],
            [],
            '/functions/specifications'
        );

        $apiParams = [];

        $apiHeaders = [];

        $response = $this->client->call(
            Client::METHOD_GET,
            $apiPath,
            $apiHeaders,
            $apiParams
        );

        if (!is_array($response)) {
            throw new \UnexpectedValueException('Expected array response when hydrating a response model.');
        }

        return \Appwrite\Models\SpecificationList::from($response);

    }

    /**
     * Get a function by its unique ID.
     *
     * @param string $functionId
     * @throws AppwriteException
     * @return \Appwrite\Models\FunctionModel
     */
    public function get(string $functionId): \Appwrite\Models\FunctionModel
    {
        $apiPath = str_replace(
            ['{functionId}'],
            [$functionId],
            '/functions/{functionId}'
        );

        $apiParams = [];
        $apiParams['functionId'] = $functionId;

        $apiHeaders = [];

        $response = $this->client->call(
            Client::METHOD_GET,
            $apiPath,
            $apiHeaders,
            $apiParams
        );

        if (!is_array($response)) {
            throw new \UnexpectedValueException('Expected array response when hydrating a response model.');
        }

        return \Appwrite\Models\FunctionModel::from($response);

    }

    /**
     * Update function by its unique ID.
     *
     * @param string $functionId
     * @param string $name
     * @param ?Runtime $runtime
     * @param ?array $execute
     * @param ?array $events
     * @param ?string $schedule
     * @param ?int $timeout
     * @param ?bool $enabled
     * @param ?bool $logging
     * @param ?string $entrypoint
     * @param ?string $commands
     * @param ?array $scopes
     * @param ?string $installationId
     * @param ?string $providerRepositoryId
     * @param ?string $providerBranch
     * @param ?bool $providerSilentMode
     * @param ?string $providerRootDirectory
     * @param ?string $buildSpecification
     * @param ?string $runtimeSpecification
     * @param ?int $deploymentRetention
     * @throws AppwriteException
     * @return \Appwrite\Models\FunctionModel
     */
    public function update(string $functionId, string $name, ?Runtime $runtime = null, ?array $execute = null, ?array $events = null, ?string $schedule = null, ?int $timeout = null, ?bool $enabled = null, ?bool $logging = null, ?string $entrypoint = null, ?string $commands = null, ?array $scopes = null, ?string $installationId = null, ?string $providerRepositoryId = null, ?string $providerBranch = null, ?bool $providerSilentMode = null, ?string $providerRootDirectory = null, ?string $buildSpecification = null, ?string $runtimeSpecification = null, ?int $deploymentRetention = null): \Appwrite\Models\FunctionModel
    {
        $apiPath = str_replace(
            ['{functionId}'],
            [$functionId],
            '/functions/{functionId}'
        );

        $apiParams = [];
        $apiParams['functionId'] = $functionId;
        $apiParams['name'] = $name;

        if (!is_null($runtime)) {
            $apiParams['runtime'] = $runtime;
        }

        if (!is_null($execute)) {
            $apiParams['execute'] = $execute;
        }

        if (!is_null($events)) {
            $apiParams['events'] = $events;
        }

        if (!is_null($schedule)) {
            $apiParams['schedule'] = $schedule;
        }

        if (!is_null($timeout)) {
            $apiParams['timeout'] = $timeout;
        }

        if (!is_null($enabled)) {
            $apiParams['enabled'] = $enabled;
        }

        if (!is_null($logging)) {
            $apiParams['logging'] = $logging;
        }

        if (!is_null($entrypoint)) {
            $apiParams['entrypoint'] = $entrypoint;
        }

        if (!is_null($commands)) {
            $apiParams['commands'] = $commands;
        }

        if (!is_null($scopes)) {
            $apiParams['scopes'] = $scopes;
        }

        if (!is_null($installationId)) {
            $apiParams['installationId'] = $installationId;
        }
        $apiParams['providerRepositoryId'] = $providerRepositoryId;

        if (!is_null($providerBranch)) {
            $apiParams['providerBranch'] = $providerBranch;
        }

        if (!is_null($providerSilentMode)) {
            $apiParams['providerSilentMode'] = $providerSilentMode;
        }

        if (!is_null($providerRootDirectory)) {
            $apiParams['providerRootDirectory'] = $providerRootDirectory;
        }

        if (!is_null($buildSpecification)) {
            $apiParams['buildSpecification'] = $buildSpecification;
        }

        if (!is_null($runtimeSpecification)) {
            $apiParams['runtimeSpecification'] = $runtimeSpecification;
        }

        if (!is_null($deploymentRetention)) {
            $apiParams['deploymentRetention'] = $deploymentRetention;
        }

        $apiHeaders = [];
        $apiHeaders['content-type'] = 'application/json';

        $response = $this->client->call(
            Client::METHOD_PUT,
            $apiPath,
            $apiHeaders,
            $apiParams
        );

        if (!is_array($response)) {
            throw new \UnexpectedValueException('Expected array response when hydrating a response model.');
        }

        return \Appwrite\Models\FunctionModel::from($response);

    }

    /**
     * Delete a function by its unique ID.
     *
     * @param string $functionId
     * @throws AppwriteException
     * @return string
     */
    public function delete(string $functionId): string
    {
        $apiPath = str_replace(
            ['{functionId}'],
            [$functionId],
            '/functions/{functionId}'
        );

        $apiParams = [];
        $apiParams['functionId'] = $functionId;

        $apiHeaders = [];
        $apiHeaders['content-type'] = 'application/json';

        $response = $this->client->call(
            Client::METHOD_DELETE,
            $apiPath,
            $apiHeaders,
            $apiParams
        );

        return $response;

    }

    /**
     * Update the function active deployment. Use this endpoint to switch the code
     * deployment that should be used when visitor opens your function.
     *
     * @param string $functionId
     * @param string $deploymentId
     * @throws AppwriteException
     * @return \Appwrite\Models\FunctionModel
     */
    public function updateFunctionDeployment(string $functionId, string $deploymentId): \Appwrite\Models\FunctionModel
    {
        $apiPath = str_replace(
            ['{functionId}'],
            [$functionId],
            '/functions/{functionId}/deployment'
        );

        $apiParams = [];
        $apiParams['functionId'] = $functionId;
        $apiParams['deploymentId'] = $deploymentId;

        $apiHeaders = [];
        $apiHeaders['content-type'] = 'application/json';

        $response = $this->client->call(
            Client::METHOD_PATCH,
            $apiPath,
            $apiHeaders,
            $apiParams
        );

        if (!is_array($response)) {
            throw new \UnexpectedValueException('Expected array response when hydrating a response model.');
        }

        return \Appwrite\Models\FunctionModel::from($response);

    }

    /**
     * Get a list of all the function's code deployments. You can use the query
     * params to filter your results.
     *
     * @param string $functionId
     * @param ?array $queries
     * @param ?string $search
     * @param ?bool $total
     * @throws AppwriteException
     * @return \Appwrite\Models\DeploymentList
     */
    public function listDeployments(string $functionId, ?array $queries = null, ?string $search = null, ?bool $total = null): \Appwrite\Models\DeploymentList
    {
        $apiPath = str_replace(
            ['{functionId}'],
            [$functionId],
            '/functions/{functionId}/deployments'
        );

        $apiParams = [];
        $apiParams['functionId'] = $functionId;

        if (!is_null($queries)) {
            $apiParams['queries'] = $queries;
        }

        if (!is_null($search)) {
            $apiParams['search'] = $search;
        }

        if (!is_null($total)) {
            $apiParams['total'] = $total;
        }

        $apiHeaders = [];

        $response = $this->client->call(
            Client::METHOD_GET,
            $apiPath,
            $apiHeaders,
            $apiParams
        );

        if (!is_array($response)) {
            throw new \UnexpectedValueException('Expected array response when hydrating a response model.');
        }

        return \Appwrite\Models\DeploymentList::from($response);

    }

    /**
     * Create a new function code deployment. Use this endpoint to upload a new
     * version of your code function. To execute your newly uploaded code, you'll
     * need to update the function's deployment to use your new deployment UID.
     * 
     * This endpoint accepts a tar.gz file compressed with your code. Make sure to
     * include any dependencies your code has within the compressed file. You can
     * learn more about code packaging in the [Appwrite Cloud Functions
     * tutorial](https://appwrite.io/docs/functions).
     * 
     * Use the "command" param to set the entrypoint used to execute your code.
     *
     * @param string $functionId
     * @param InputFile $code
     * @param bool $activate
     * @param ?string $entrypoint
     * @param ?string $commands
     * @throws AppwriteException
     * @return \Appwrite\Models\Deployment
     */
    public function createDeployment(string $functionId, InputFile $code, bool $activate, ?string $entrypoint = null, ?string $commands = null, ?callable $onProgress = null): \Appwrite\Models\Deployment
    {
        $apiPath = str_replace(
            ['{functionId}'],
            [$functionId],
            '/functions/{functionId}/deployments'
        );

        $apiParams = [];
        $apiParams['functionId'] = $functionId;
        $apiParams['code'] = $code;
        $apiParams['activate'] = $activate;

        if (!is_null($entrypoint)) {
            $apiParams['entrypoint'] = $entrypoint;
        }

        if (!is_null($commands)) {
            $apiParams['commands'] = $commands;
        }

        $apiHeaders = [];
        $apiHeaders['content-type'] = 'multipart/form-data';
        $size = 0;
        $mimeType = null;
        $postedName = null;
        if(empty($code->getPath() ?? null)) {
            $size = strlen($code->getData());
            $mimeType = $code->getMimeType();
            $postedName = $code->getFilename();
            if ($size <= Client::CHUNK_SIZE) {
                $apiParams['code'] = new \CURLFile('data://' . $mimeType . ';base64,' . base64_encode($code->getData()), $mimeType, $postedName);
                $response = $this->client->call(Client::METHOD_POST, $apiPath, [
                            'content-type' => 'multipart/form-data',
                        ], $apiParams);
                if (!is_array($response)) {
                    throw new \UnexpectedValueException('Expected array response when hydrating a response model.');
                }

                return \Appwrite\Models\Deployment::from($response);
            }
        } else {
            $size = filesize($code->getPath());
            $mimeType = $code->getMimeType() ?? mime_content_type($code->getPath());
            $postedName = $code->getFilename() ?? basename($code->getPath());
            //send single file if size is less than or equal to 5MB
            if ($size <= Client::CHUNK_SIZE) {
                $apiParams['code'] = new \CURLFile($code->getPath(), $mimeType, $postedName);
                $response = $this->client->call(Client::METHOD_POST, $apiPath, [
                            'content-type' => 'multipart/form-data',
                        ], $apiParams);
                if (!is_array($response)) {
                    throw new \UnexpectedValueException('Expected array response when hydrating a response model.');
                }

                return \Appwrite\Models\Deployment::from($response);
            }
        }

        $id = '';
        $counter = 0;


        $apiHeaders = ['content-type' => 'multipart/form-data'];
        $handle = null;

        if(!empty($code->getPath())) {
            $handle = @fopen($code->getPath(), "rb");
        }

        $uploadId = '';
                $totalChunks = (int) ceil($size / Client::CHUNK_SIZE);
        $chunks = [];
        $start = $counter * Client::CHUNK_SIZE;
        while ($start < $size) {
            $chunks[] = [
                'index' => $counter,
                'start' => $start,
                'end' => min($start + Client::CHUNK_SIZE, $size),
            ];
            $counter++;
            $start += Client::CHUNK_SIZE;
        }

        $readChunk = function(int $start, int $end) use ($handle, $code) {
            if(!empty($handle)) {
                fseek($handle, $start);
                return @fread($handle, $end - $start);
            }

            return substr($code->getData(), $start, $end - $start);
        };

        $uploadChunk = function(array $chunk, string $currentUploadId = '') use ($readChunk, $apiPath, $apiHeaders, $apiParams, $mimeType, $postedName, $size) {
            $chunkParams = $apiParams;
            $chunkHeaders = $apiHeaders;
            $data = $readChunk($chunk['start'], $chunk['end']);
            $chunkParams['code'] = new \CURLFile('data://' . $mimeType . ';base64,' . base64_encode($data), $mimeType, $postedName);
            $chunkHeaders['content-range'] = 'bytes ' . $chunk['start'] . '-' . ($chunk['end'] - 1) . '/' . $size;
            if(!empty($currentUploadId)) {
                $chunkHeaders['x-appwrite-id'] = $currentUploadId;
            }

            return $this->client->call(Client::METHOD_POST, $apiPath, $chunkHeaders, $chunkParams);
        };

        $isUploadComplete = function($chunkResponse) use ($totalChunks): bool {
            if(!is_array($chunkResponse) || !isset($chunkResponse['chunksUploaded'])) {
                return false;
            }

            return (int) $chunkResponse['chunksUploaded'] >= (int) ($chunkResponse['chunksTotal'] ?? $totalChunks);
        };

        if (!empty($chunks)) {
            $response = $uploadChunk($chunks[0], $uploadId);
            if(empty($uploadId)) {
                $uploadId = $response['$id'];
            }
            $completedCount = $chunks[0]['index'] + 1;
            $uploadedSize = $chunks[0]['end'];
            if($onProgress !== null) {
                $onProgress([
                    '$id' => $response['$id'],
                    'progress' => $uploadedSize / $size * 100,
                    'sizeUploaded' => $uploadedSize,
                    'chunksTotal' => $totalChunks,
                    'chunksUploaded' => $completedCount,
                ]);
            }

            $remainingChunks = array_slice($chunks, 1);
            $clientConfig = \Closure::bind(function() {
                if (property_exists($this, 'key') && $this->key !== null) {
                    $this->headers['authorization'] = $this->getAuthorization();
                }

                return [$this->endpoint, $this->headers, $this->selfSigned, $this->timeout, $this->connectTimeout];
            }, $this->client, Client::class);
            $flattenParams = \Closure::bind(function(array $params): array {
                return $this->flatten($params);
            }, $this->client, Client::class);
            [$endpoint, $globalHeaders, $selfSigned, $timeout, $connectTimeout] = $clientConfig();
            $responseHeaders = [];
            $lastResponse = $response;
            $completedResponse = null;

            $makeHandle = function(array $chunk) use ($readChunk, $apiPath, $apiHeaders, $apiParams, $mimeType, $postedName, $size, $uploadId, $endpoint, $globalHeaders, $selfSigned, $timeout, $connectTimeout, $flattenParams, &$responseHeaders) {
                $chunkParams = $apiParams;
                $chunkHeaders = array_merge($globalHeaders, $apiHeaders);
                $data = $readChunk($chunk['start'], $chunk['end']);
                $chunkParams['code'] = new \CURLFile('data://' . $mimeType . ';base64,' . base64_encode($data), $mimeType, $postedName);
                $chunkHeaders['content-range'] = 'bytes ' . $chunk['start'] . '-' . ($chunk['end'] - 1) . '/' . $size;
                if(!empty($uploadId)) {
                    $chunkHeaders['x-appwrite-id'] = $uploadId;
                }

                $headers = [];
                foreach ($chunkHeaders as $key => $value) {
                    $headers[] = $key . ':' . $value;
                }

                $ch = curl_init($endpoint . $apiPath);
                $responseHeaders[spl_object_id($ch)] = [];
                curl_setopt($ch, CURLOPT_CUSTOMREQUEST, Client::METHOD_POST);
                curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
                curl_setopt($ch, CURLOPT_USERAGENT, php_uname('s') . '-' . php_uname('r') . ':php-' . phpversion());
                curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
                curl_setopt($ch, CURLOPT_FOLLOWLOCATION, true);
                curl_setopt($ch, CURLOPT_POSTFIELDS, $flattenParams($chunkParams));
                curl_setopt($ch, CURLOPT_HEADERFUNCTION, function($curl, $header) use (&$responseHeaders) {
                    $length = strlen($header);
                    $header = explode(':', strtolower($header), 2);
                    if (count($header) >= 2) {
                        $responseHeaders[spl_object_id($curl)][strtolower(trim($header[0]))] = trim($header[1]);
                    }

                    return $length;
                });
                if($selfSigned) {
                    curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
                    curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
                }
                if($timeout !== null) {
                    curl_setopt($ch, CURLOPT_TIMEOUT, $timeout);
                }
                if($connectTimeout !== null) {
                    curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, $connectTimeout);
                }

                return $ch;
            };

            $nextChunk = 0;
            while ($nextChunk < count($remainingChunks)) {
                $multiHandle = curl_multi_init();
                $handles = [];
                for ($i = 0; $i < 8 && $nextChunk < count($remainingChunks); $i++, $nextChunk++) {
                    $chunk = $remainingChunks[$nextChunk];
                    $ch = $makeHandle($chunk);
                    $handles[spl_object_id($ch)] = ['handle' => $ch, 'chunk' => $chunk];
                    curl_multi_add_handle($multiHandle, $ch);
                }

                try {
                    do {
                        $status = curl_multi_exec($multiHandle, $active);
                        if ($active) {
                            curl_multi_select($multiHandle);
                        }
                    } while ($active && ($status == CURLM_OK || $status == CURLM_CALL_MULTI_PERFORM));

                    foreach ($handles as $handleInfo) {
                        $ch = $handleInfo['handle'];
                        $body = curl_multi_getcontent($ch);
                        $statusCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
                        $contentType = $responseHeaders[spl_object_id($ch)]['content-type'] ?? '';

                        if (curl_errno($ch)) {
                            throw new AppwriteException(curl_error($ch), $statusCode, '', $body);
                        }

                        $chunkResponse = str_starts_with($contentType, 'application/json') ? json_decode($body, true) : $body;

                        if($statusCode >= 400) {
                            if(is_array($chunkResponse)) {
                                throw new AppwriteException($chunkResponse['message'], $statusCode, $chunkResponse['type'] ?? '', json_encode($chunkResponse));
                            }

                            throw new AppwriteException($chunkResponse, $statusCode, '', $chunkResponse);
                        }

                        $completedCount++;
                        $uploadedSize += $handleInfo['chunk']['end'] - $handleInfo['chunk']['start'];
                        $lastResponse = $chunkResponse;
                        if($isUploadComplete($chunkResponse)) {
                            $completedResponse = $chunkResponse;
                        }
                        if($onProgress !== null) {
                            $onProgress([
                                '$id' => $uploadId,
                                'progress' => $uploadedSize / $size * 100,
                                'sizeUploaded' => $uploadedSize,
                                'chunksTotal' => $totalChunks,
                                'chunksUploaded' => $completedCount,
                            ]);
                        }
                    }
                } finally {
                    foreach ($handles as $handleInfo) {
                        curl_multi_remove_handle($multiHandle, $handleInfo['handle']);
                        curl_close($handleInfo['handle']);
                    }
                    curl_multi_close($multiHandle);
                }
            }
            $response = $completedResponse ?? $lastResponse;

        }
        if(!empty($handle)) {
            @fclose($handle);
        }
        if (!is_array($response)) {
            throw new \UnexpectedValueException('Expected array response when hydrating a response model.');
        }

        return \Appwrite\Models\Deployment::from($response);

    }

    /**
     * Create a new build for an existing function deployment. This endpoint
     * allows you to rebuild a deployment with the updated function configuration,
     * including its entrypoint and build commands if they have been modified. The
     * build process will be queued and executed asynchronously. The original
     * deployment's code will be preserved and used for the new build.
     *
     * @param string $functionId
     * @param string $deploymentId
     * @param ?string $buildId
     * @throws AppwriteException
     * @return \Appwrite\Models\Deployment
     */
    public function createDuplicateDeployment(string $functionId, string $deploymentId, ?string $buildId = null): \Appwrite\Models\Deployment
    {
        $apiPath = str_replace(
            ['{functionId}'],
            [$functionId],
            '/functions/{functionId}/deployments/duplicate'
        );

        $apiParams = [];
        $apiParams['functionId'] = $functionId;
        $apiParams['deploymentId'] = $deploymentId;

        if (!is_null($buildId)) {
            $apiParams['buildId'] = $buildId;
        }

        $apiHeaders = [];
        $apiHeaders['content-type'] = 'application/json';

        $response = $this->client->call(
            Client::METHOD_POST,
            $apiPath,
            $apiHeaders,
            $apiParams
        );

        if (!is_array($response)) {
            throw new \UnexpectedValueException('Expected array response when hydrating a response model.');
        }

        return \Appwrite\Models\Deployment::from($response);

    }

    /**
     * Create a deployment based on a template.
     * 
     * Use this endpoint with combination of
     * [listTemplates](https://appwrite.io/docs/products/functions/templates) to
     * find the template details.
     *
     * @param string $functionId
     * @param string $repository
     * @param string $owner
     * @param string $rootDirectory
     * @param TemplateReferenceType $type
     * @param string $reference
     * @param ?bool $activate
     * @throws AppwriteException
     * @return \Appwrite\Models\Deployment
     */
    public function createTemplateDeployment(string $functionId, string $repository, string $owner, string $rootDirectory, TemplateReferenceType $type, string $reference, ?bool $activate = null): \Appwrite\Models\Deployment
    {
        $apiPath = str_replace(
            ['{functionId}'],
            [$functionId],
            '/functions/{functionId}/deployments/template'
        );

        $apiParams = [];
        $apiParams['functionId'] = $functionId;
        $apiParams['repository'] = $repository;
        $apiParams['owner'] = $owner;
        $apiParams['rootDirectory'] = $rootDirectory;
        $apiParams['type'] = $type;
        $apiParams['reference'] = $reference;

        if (!is_null($activate)) {
            $apiParams['activate'] = $activate;
        }

        $apiHeaders = [];
        $apiHeaders['content-type'] = 'application/json';

        $response = $this->client->call(
            Client::METHOD_POST,
            $apiPath,
            $apiHeaders,
            $apiParams
        );

        if (!is_array($response)) {
            throw new \UnexpectedValueException('Expected array response when hydrating a response model.');
        }

        return \Appwrite\Models\Deployment::from($response);

    }

    /**
     * Create a deployment when a function is connected to VCS.
     * 
     * This endpoint lets you create deployment from a branch, commit, or a tag.
     *
     * @param string $functionId
     * @param VCSReferenceType $type
     * @param string $reference
     * @param ?bool $activate
     * @throws AppwriteException
     * @return \Appwrite\Models\Deployment
     */
    public function createVcsDeployment(string $functionId, VCSReferenceType $type, string $reference, ?bool $activate = null): \Appwrite\Models\Deployment
    {
        $apiPath = str_replace(
            ['{functionId}'],
            [$functionId],
            '/functions/{functionId}/deployments/vcs'
        );

        $apiParams = [];
        $apiParams['functionId'] = $functionId;
        $apiParams['type'] = $type;
        $apiParams['reference'] = $reference;

        if (!is_null($activate)) {
            $apiParams['activate'] = $activate;
        }

        $apiHeaders = [];
        $apiHeaders['content-type'] = 'application/json';

        $response = $this->client->call(
            Client::METHOD_POST,
            $apiPath,
            $apiHeaders,
            $apiParams
        );

        if (!is_array($response)) {
            throw new \UnexpectedValueException('Expected array response when hydrating a response model.');
        }

        return \Appwrite\Models\Deployment::from($response);

    }

    /**
     * Get a function deployment by its unique ID.
     *
     * @param string $functionId
     * @param string $deploymentId
     * @throws AppwriteException
     * @return \Appwrite\Models\Deployment
     */
    public function getDeployment(string $functionId, string $deploymentId): \Appwrite\Models\Deployment
    {
        $apiPath = str_replace(
            ['{functionId}', '{deploymentId}'],
            [$functionId, $deploymentId],
            '/functions/{functionId}/deployments/{deploymentId}'
        );

        $apiParams = [];
        $apiParams['functionId'] = $functionId;
        $apiParams['deploymentId'] = $deploymentId;

        $apiHeaders = [];

        $response = $this->client->call(
            Client::METHOD_GET,
            $apiPath,
            $apiHeaders,
            $apiParams
        );

        if (!is_array($response)) {
            throw new \UnexpectedValueException('Expected array response when hydrating a response model.');
        }

        return \Appwrite\Models\Deployment::from($response);

    }

    /**
     * Delete a code deployment by its unique ID.
     *
     * @param string $functionId
     * @param string $deploymentId
     * @throws AppwriteException
     * @return string
     */
    public function deleteDeployment(string $functionId, string $deploymentId): string
    {
        $apiPath = str_replace(
            ['{functionId}', '{deploymentId}'],
            [$functionId, $deploymentId],
            '/functions/{functionId}/deployments/{deploymentId}'
        );

        $apiParams = [];
        $apiParams['functionId'] = $functionId;
        $apiParams['deploymentId'] = $deploymentId;

        $apiHeaders = [];
        $apiHeaders['content-type'] = 'application/json';

        $response = $this->client->call(
            Client::METHOD_DELETE,
            $apiPath,
            $apiHeaders,
            $apiParams
        );

        return $response;

    }

    /**
     * Get a function deployment content by its unique ID. The endpoint response
     * return with a 'Content-Disposition: attachment' header that tells the
     * browser to start downloading the file to user downloads directory.
     *
     * @param string $functionId
     * @param string $deploymentId
     * @param ?DeploymentDownloadType $type
     * @throws AppwriteException
     * @return string
     */
    public function getDeploymentDownload(string $functionId, string $deploymentId, ?DeploymentDownloadType $type = null): string
    {
        $apiPath = str_replace(
            ['{functionId}', '{deploymentId}'],
            [$functionId, $deploymentId],
            '/functions/{functionId}/deployments/{deploymentId}/download'
        );

        $apiParams = [];
        $apiParams['functionId'] = $functionId;
        $apiParams['deploymentId'] = $deploymentId;

        if (!is_null($type)) {
            $apiParams['type'] = $type;
        }

        $apiHeaders = [];

        $response = $this->client->call(
            Client::METHOD_GET,
            $apiPath,
            $apiHeaders,
            $apiParams
        );

        return $response;

    }

    /**
     * Cancel an ongoing function deployment build. If the build is already in
     * progress, it will be stopped and marked as canceled. If the build hasn't
     * started yet, it will be marked as canceled without executing. You cannot
     * cancel builds that have already completed (status 'ready') or failed. The
     * response includes the final build status and details.
     *
     * @param string $functionId
     * @param string $deploymentId
     * @throws AppwriteException
     * @return \Appwrite\Models\Deployment
     */
    public function updateDeploymentStatus(string $functionId, string $deploymentId): \Appwrite\Models\Deployment
    {
        $apiPath = str_replace(
            ['{functionId}', '{deploymentId}'],
            [$functionId, $deploymentId],
            '/functions/{functionId}/deployments/{deploymentId}/status'
        );

        $apiParams = [];
        $apiParams['functionId'] = $functionId;
        $apiParams['deploymentId'] = $deploymentId;

        $apiHeaders = [];
        $apiHeaders['content-type'] = 'application/json';

        $response = $this->client->call(
            Client::METHOD_PATCH,
            $apiPath,
            $apiHeaders,
            $apiParams
        );

        if (!is_array($response)) {
            throw new \UnexpectedValueException('Expected array response when hydrating a response model.');
        }

        return \Appwrite\Models\Deployment::from($response);

    }

    /**
     * Get a list of all the current user function execution logs. You can use the
     * query params to filter your results.
     *
     * @param string $functionId
     * @param ?array $queries
     * @param ?bool $total
     * @throws AppwriteException
     * @return \Appwrite\Models\ExecutionList
     */
    public function listExecutions(string $functionId, ?array $queries = null, ?bool $total = null): \Appwrite\Models\ExecutionList
    {
        $apiPath = str_replace(
            ['{functionId}'],
            [$functionId],
            '/functions/{functionId}/executions'
        );

        $apiParams = [];
        $apiParams['functionId'] = $functionId;

        if (!is_null($queries)) {
            $apiParams['queries'] = $queries;
        }

        if (!is_null($total)) {
            $apiParams['total'] = $total;
        }

        $apiHeaders = [];

        $response = $this->client->call(
            Client::METHOD_GET,
            $apiPath,
            $apiHeaders,
            $apiParams
        );

        if (!is_array($response)) {
            throw new \UnexpectedValueException('Expected array response when hydrating a response model.');
        }

        return \Appwrite\Models\ExecutionList::from($response);

    }

    /**
     * Trigger a function execution. The returned object will return you the
     * current execution status. You can ping the `Get Execution` endpoint to get
     * updates on the current execution status. Once this endpoint is called, your
     * function execution process will start asynchronously.
     *
     * @param string $functionId
     * @param ?string $body
     * @param ?bool $async
     * @param ?string $xpath
     * @param ?ExecutionMethod $method
     * @param ?array $headers
     * @param ?string $scheduledAt
     * @throws AppwriteException
     * @return \Appwrite\Models\Execution
     */
    public function createExecution(string $functionId, ?string $body = null, ?bool $async = null, ?string $xpath = null, ?ExecutionMethod $method = null, ?array $headers = null, ?string $scheduledAt = null): \Appwrite\Models\Execution
    {
        $apiPath = str_replace(
            ['{functionId}'],
            [$functionId],
            '/functions/{functionId}/executions'
        );

        $apiParams = [];
        $apiParams['functionId'] = $functionId;

        if (!is_null($body)) {
            $apiParams['body'] = $body;
        }

        if (!is_null($async)) {
            $apiParams['async'] = $async;
        }

        if (!is_null($xpath)) {
            $apiParams['path'] = $xpath;
        }

        if (!is_null($method)) {
            $apiParams['method'] = $method;
        }

        if (!is_null($headers)) {
            $apiParams['headers'] = $headers;
        }
        $apiParams['scheduledAt'] = $scheduledAt;

        $apiHeaders = [];
        $apiHeaders['content-type'] = 'application/json';

        $response = $this->client->call(
            Client::METHOD_POST,
            $apiPath,
            $apiHeaders,
            $apiParams
        );

        if (!is_array($response)) {
            throw new \UnexpectedValueException('Expected array response when hydrating a response model.');
        }

        return \Appwrite\Models\Execution::from($response);

    }

    /**
     * Get a function execution log by its unique ID.
     *
     * @param string $functionId
     * @param string $executionId
     * @throws AppwriteException
     * @return \Appwrite\Models\Execution
     */
    public function getExecution(string $functionId, string $executionId): \Appwrite\Models\Execution
    {
        $apiPath = str_replace(
            ['{functionId}', '{executionId}'],
            [$functionId, $executionId],
            '/functions/{functionId}/executions/{executionId}'
        );

        $apiParams = [];
        $apiParams['functionId'] = $functionId;
        $apiParams['executionId'] = $executionId;

        $apiHeaders = [];

        $response = $this->client->call(
            Client::METHOD_GET,
            $apiPath,
            $apiHeaders,
            $apiParams
        );

        if (!is_array($response)) {
            throw new \UnexpectedValueException('Expected array response when hydrating a response model.');
        }

        return \Appwrite\Models\Execution::from($response);

    }

    /**
     * Delete a function execution by its unique ID.
     *
     * @param string $functionId
     * @param string $executionId
     * @throws AppwriteException
     * @return string
     */
    public function deleteExecution(string $functionId, string $executionId): string
    {
        $apiPath = str_replace(
            ['{functionId}', '{executionId}'],
            [$functionId, $executionId],
            '/functions/{functionId}/executions/{executionId}'
        );

        $apiParams = [];
        $apiParams['functionId'] = $functionId;
        $apiParams['executionId'] = $executionId;

        $apiHeaders = [];
        $apiHeaders['content-type'] = 'application/json';

        $response = $this->client->call(
            Client::METHOD_DELETE,
            $apiPath,
            $apiHeaders,
            $apiParams
        );

        return $response;

    }

    /**
     * Get a list of all variables of a specific function.
     *
     * @param string $functionId
     * @param ?array $queries
     * @param ?bool $total
     * @throws AppwriteException
     * @return \Appwrite\Models\VariableList
     */
    public function listVariables(string $functionId, ?array $queries = null, ?bool $total = null): \Appwrite\Models\VariableList
    {
        $apiPath = str_replace(
            ['{functionId}'],
            [$functionId],
            '/functions/{functionId}/variables'
        );

        $apiParams = [];
        $apiParams['functionId'] = $functionId;

        if (!is_null($queries)) {
            $apiParams['queries'] = $queries;
        }

        if (!is_null($total)) {
            $apiParams['total'] = $total;
        }

        $apiHeaders = [];

        $response = $this->client->call(
            Client::METHOD_GET,
            $apiPath,
            $apiHeaders,
            $apiParams
        );

        if (!is_array($response)) {
            throw new \UnexpectedValueException('Expected array response when hydrating a response model.');
        }

        return \Appwrite\Models\VariableList::from($response);

    }

    /**
     * Create a new function environment variable. These variables can be accessed
     * in the function at runtime as environment variables.
     *
     * @param string $functionId
     * @param string $variableId
     * @param string $key
     * @param string $value
     * @param ?bool $secret
     * @throws AppwriteException
     * @return \Appwrite\Models\Variable
     */
    public function createVariable(string $functionId, string $variableId, string $key, string $value, ?bool $secret = null): \Appwrite\Models\Variable
    {
        $apiPath = str_replace(
            ['{functionId}'],
            [$functionId],
            '/functions/{functionId}/variables'
        );

        $apiParams = [];
        $apiParams['functionId'] = $functionId;
        $apiParams['variableId'] = $variableId;
        $apiParams['key'] = $key;
        $apiParams['value'] = $value;

        if (!is_null($secret)) {
            $apiParams['secret'] = $secret;
        }

        $apiHeaders = [];
        $apiHeaders['content-type'] = 'application/json';

        $response = $this->client->call(
            Client::METHOD_POST,
            $apiPath,
            $apiHeaders,
            $apiParams
        );

        if (!is_array($response)) {
            throw new \UnexpectedValueException('Expected array response when hydrating a response model.');
        }

        return \Appwrite\Models\Variable::from($response);

    }

    /**
     * Get a variable by its unique ID.
     *
     * @param string $functionId
     * @param string $variableId
     * @throws AppwriteException
     * @return \Appwrite\Models\Variable
     */
    public function getVariable(string $functionId, string $variableId): \Appwrite\Models\Variable
    {
        $apiPath = str_replace(
            ['{functionId}', '{variableId}'],
            [$functionId, $variableId],
            '/functions/{functionId}/variables/{variableId}'
        );

        $apiParams = [];
        $apiParams['functionId'] = $functionId;
        $apiParams['variableId'] = $variableId;

        $apiHeaders = [];

        $response = $this->client->call(
            Client::METHOD_GET,
            $apiPath,
            $apiHeaders,
            $apiParams
        );

        if (!is_array($response)) {
            throw new \UnexpectedValueException('Expected array response when hydrating a response model.');
        }

        return \Appwrite\Models\Variable::from($response);

    }

    /**
     * Update variable by its unique ID.
     *
     * @param string $functionId
     * @param string $variableId
     * @param ?string $key
     * @param ?string $value
     * @param ?bool $secret
     * @throws AppwriteException
     * @return \Appwrite\Models\Variable
     */
    public function updateVariable(string $functionId, string $variableId, ?string $key = null, ?string $value = null, ?bool $secret = null): \Appwrite\Models\Variable
    {
        $apiPath = str_replace(
            ['{functionId}', '{variableId}'],
            [$functionId, $variableId],
            '/functions/{functionId}/variables/{variableId}'
        );

        $apiParams = [];
        $apiParams['functionId'] = $functionId;
        $apiParams['variableId'] = $variableId;
        $apiParams['key'] = $key;
        $apiParams['value'] = $value;
        $apiParams['secret'] = $secret;

        $apiHeaders = [];
        $apiHeaders['content-type'] = 'application/json';

        $response = $this->client->call(
            Client::METHOD_PUT,
            $apiPath,
            $apiHeaders,
            $apiParams
        );

        if (!is_array($response)) {
            throw new \UnexpectedValueException('Expected array response when hydrating a response model.');
        }

        return \Appwrite\Models\Variable::from($response);

    }

    /**
     * Delete a variable by its unique ID.
     *
     * @param string $functionId
     * @param string $variableId
     * @throws AppwriteException
     * @return string
     */
    public function deleteVariable(string $functionId, string $variableId): string
    {
        $apiPath = str_replace(
            ['{functionId}', '{variableId}'],
            [$functionId, $variableId],
            '/functions/{functionId}/variables/{variableId}'
        );

        $apiParams = [];
        $apiParams['functionId'] = $functionId;
        $apiParams['variableId'] = $variableId;

        $apiHeaders = [];
        $apiHeaders['content-type'] = 'application/json';

        $response = $this->client->call(
            Client::METHOD_DELETE,
            $apiPath,
            $apiHeaders,
            $apiParams
        );

        return $response;

    }
}