38 lines
1.1 KiB
PHP
38 lines
1.1 KiB
PHP
<?php
|
|
|
|
namespace AsyncAws\S3\Result;
|
|
|
|
use AsyncAws\Core\Exception\Http\HttpException;
|
|
use AsyncAws\Core\Exception\InvalidArgument;
|
|
use AsyncAws\Core\Response;
|
|
use AsyncAws\Core\Waiter;
|
|
use AsyncAws\S3\Input\HeadObjectRequest;
|
|
use AsyncAws\S3\S3Client;
|
|
|
|
class ObjectNotExistsWaiter extends Waiter
|
|
{
|
|
protected const WAIT_TIMEOUT = 100.0;
|
|
protected const WAIT_DELAY = 5.0;
|
|
|
|
protected function extractState(Response $response, ?HttpException $exception): string
|
|
{
|
|
if (404 === $response->getStatusCode()) {
|
|
return self::STATE_SUCCESS;
|
|
}
|
|
|
|
return null === $exception ? self::STATE_PENDING : self::STATE_FAILURE;
|
|
}
|
|
|
|
protected function refreshState(): Waiter
|
|
{
|
|
if (!$this->awsClient instanceof S3Client) {
|
|
throw new InvalidArgument('missing client injected in waiter result');
|
|
}
|
|
if (!$this->input instanceof HeadObjectRequest) {
|
|
throw new InvalidArgument('missing last request injected in waiter result');
|
|
}
|
|
|
|
return $this->awsClient->objectNotExists($this->input);
|
|
}
|
|
}
|