OXIESEC PANEL

Name	Size	Modified	Perms
📁 ..	-	08/14/2024 08:01:07 AM	rwxr-xr-x
📄 BatchingContext.php	6.76 KB	08/14/2024 07:59:09 AM	rw-r--r--
📄 BlockingContext.php	4.77 KB	08/14/2024 07:59:09 AM	rw-r--r--
📄 ConcurrencyContext.php	4.73 KB	08/14/2024 07:59:09 AM	rw-r--r--
📄 CredentialsContext.php	4.07 KB	08/14/2024 07:59:09 AM	rw-r--r--
📄 CrtContext.php	8.28 KB	08/14/2024 07:59:09 AM	rw-r--r--
📄 GuzzleV5HandlerTest.php	2.62 KB	08/14/2024 07:59:09 AM	rw-r--r--
📄 GuzzleV6StreamHandlerTest.php	2.44 KB	08/14/2024 07:59:09 AM	rw-r--r--
📄 IntegUtils.php	1.53 KB	08/14/2024 07:59:09 AM	rw-r--r--
📄 MultipartContext.php	7.36 KB	08/14/2024 07:59:09 AM	rw-r--r--
📄 NativeStreamContext.php	4.65 KB	08/14/2024 07:59:09 AM	rw-r--r--
📄 S3Context.php	11.13 KB	08/14/2024 07:59:09 AM	rw-r--r--
📄 S3EncryptionContext.php	7.44 KB	08/14/2024 07:59:09 AM	rw-r--r--
📄 S3EncryptionContextV2.php	7.79 KB	08/14/2024 07:59:09 AM	rw-r--r--
📄 SmokeContext.php	12.25 KB	08/14/2024 07:59:09 AM	rw-r--r--

Editing: CrtContext.php

<?php
namespace Aws\Test\Integ;

use Aws\CloudFront\CloudFrontClient;
use Aws\CloudFrontKeyValueStore\CloudFrontKeyValueStoreClient;
use Aws\EventBridge\EventBridgeClient;
use Aws\EventBridge\Exception\EventBridgeException;
use Aws\Sts\StsClient;
use Behat\Behat\Context\Context;
use Behat\Behat\Context\SnippetAcceptingContext;
use Aws\S3\S3Client;
use Aws\S3Control\S3ControlClient;
use Behat\Gherkin\Node\TableNode;
use GuzzleHttp\Client;
use GuzzleHttp\Psr7;
use PHPUnit\Framework\Assert;
use Psr\Http\Message\StreamInterface;

class CrtContext implements Context, SnippetAcceptingContext
{
    use IntegUtils;

private static $multiRegionAccessPoint;
    private static $tempFile;
    private static $globalEndpoint;

/** @var EventBridgeClient */
    private $eventBridgeClient;
    /** @var array */
    private $eventConfig;
    /** @var S3Client */
    private $s3Client;
    /** @var StreamInterface */
    private $stream;
    /** @var RequestInterface */
    private $presignedRequest;
    /** @var string */
    private $keyvaluestore;

/**
     * @BeforeFeature @mrap
     */
    public static function setMultiRegionAccessPoint()
    {
        $sts = new StsClient([
            'region' => 'us-east-1',
            'version' => 'latest'
        ]);
        $identity = $sts->getCallerIdentity([])['Account'];
        $s3control = new S3ControlClient([
            'region' => 'us-west-2',
            'version' => 'latest'
        ]);
        $mraps = $s3control->listMultiRegionAccessPoints([
            'AccountId' => $identity
        ]);
        $alias = $mraps['AccessPoints'][0]['Alias'];
        $mrap = "arn:aws:s3::{$identity}:accesspoint/{$alias}";
        self::$multiRegionAccessPoint = $mrap;
    }

/**
     * @BeforeFeature @mrap
     */
    public static function createTempFile()
    {
        self::$tempFile = tempnam(sys_get_temp_dir(), 'mrap-test');
        file_put_contents(self::$tempFile, str_repeat('x', 128 * 1024));
    }

/**
     * @AfterFeature @mrap
     */
    public static function deleteTempFile()
    {
        unlink(self::$tempFile);
    }

/**
     * @BeforeFeature @eventbridge
     */
    public static function setGlobalEndpoint()
    {
        $eventBridgeClient = new EventBridgeClient([
            'region' => 'us-east-1',
            'version' => 'latest'
        ]);

$result = $eventBridgeClient->describeEndpoint([
                'Name' => 'test-endpoint'
            ]);

self::$globalEndpoint = $result['EndpointId'];
    }

/**
     * @Given I have a s3 client and I have a file
     */
    public function iHaveAnClientAndIHaveAFile()
    {
        $this->s3Client = self::getSdk()->createS3();
        $this->stream = Psr7\Utils::streamFor(Psr7\Utils::tryFopen(self::$tempFile, 'r'));
    }

/**
     * @Given I upload the file to my multi-region access point
     */
    public function iUploadTheFileToMyMultiRegionAccessPoint()
    {
        $this->s3Client->putObject([
            'Bucket' => self::$multiRegionAccessPoint,
            'Key' => 'mrap-test',
            'Body' => $this->stream,
        ]);
    }

/**
     * @Then I can confirm the object exists
     */
    public function iConfirmTheObjectHasBeenCreated()
    {
        Assert::assertTrue(
            $this->s3Client->doesObjectExistV2(self::$multiRegionAccessPoint, 'mrap-test')
        );
    }

/**
     * @Given I have a s3 client and I have multi-region access point
     */
    public function iHaveAS3ClientAndIHaveAMultiRegionAccessPoint()
    {
        $this->s3Client = self::getSdk()->createS3();
        Assert::assertTrue(
            $this->s3Client->doesBucketExistV2(self::$multiRegionAccessPoint)
        );
    }

/**
     * @Then I can confirm my access point has at least one object
     */
    public function iCanConfirmMyAccessPointHasAtLeastOneObject()
    {
        $result = $this->s3Client->listObjectsV2(['Bucket' => self::$multiRegionAccessPoint]);
        Assert::assertNotTrue(empty($result['Contents']));
    }

/**
     * @When I use the PutObject operation and update the file to have a body of "test"
     */
    public function iUseThePutObjectOperationAndUpdateTheFileToHaveABodyOfTest()
    {
        $this->s3Client->putObject([
            'Bucket' => self::$multiRegionAccessPoint,
            'Key' => 'mrap-test',
            'Body' => 'test',
        ]);
    }

/**
     * @Then I can confirm the object has been updated
     * @Given I have uploaded an object to S3 with a key of `mrap-test` and a body of `test`
     */
    public function iCanConfirmTheObjectHasBeenUpdated()
    {
        $result = $this->s3Client->getObject(['Bucket' => self::$multiRegionAccessPoint, 'Key' => 'mrap-test']);
        Assert::assertEquals(
            'test',
            (string)$result['Body']
        );
    }

/**
     * @When I create a pre-signed request for a :command command with:
     */
    public function iCreateAPreSignedUrlForACommandWith(
        $commandName,
        TableNode $table
    )
    {
        $args = ['Bucket' => self::$multiRegionAccessPoint];
        foreach ($table as $row) {
            $args[$row['key']] = $row['value'];
        }
        $client = $this->s3Client;
        $command = $client->getCommand($commandName, $args);
        $this->presignedRequest = $client
            ->createPresignedRequest($command, '+1 hour');
    }

/**
     * @Then the contents of the response to the presigned request should be :body
     */
    public function theContentsAtThePresignedUrlShouldBe($body)
    {
        // Not using assertStringFileEquals here due to issues with remote files
        Assert::assertEquals(
            $body,
            file_get_contents($this->presignedRequest->getUri())
        );
    }

/**
     * @Given I send the pre-signed request
     */
    public function iSendThePreSignedRequest()
    {
        (new Client())->send($this->presignedRequest);
    }

/**
     * @When I delete the object
     */
    public function iDeleteTheObject()
    {
        $this->s3Client->deleteObject([
            'Bucket' => self::$multiRegionAccessPoint,
            'Key' => 'mrap-test',
        ]);
    }

/**
     * @Then I can confirm the object has been deleted
     */
    public function iCanConfirmTheObjectHasBeenDeleted()
    {
        Assert::assertFalse(
            $this->s3Client->doesObjectExistV2(self::$multiRegionAccessPoint, 'mrap-test')
        );
    }

/**
     * @Given I have an eventbridge client and I have an event configuration
     */
    public function iHaveAnEventbridgeClientAndIHaveAnEventConfiguration()
    {
        $this->eventBridgeClient = new EventBridgeClient([
            'region' => 'us-east-1',
            'version' => 'latest'
        ]);
        $this->eventConfig = [[]];
    }

/**
     * @Then I can upload an event using my global endpoint
     */
    public function iCanUploadAnEventUsingMyGlobalEndpoint()
    {
        $result = $this->eventBridgeClient->putEvents([
            'EndpointId' => self::$globalEndpoint,
            'Entries' => $this->eventConfig
        ]);

Assert::assertEquals('200', $result['@metadata']['statusCode']);
    }

/**
     * @Given I have a cloudfront client and I have a key-value store
     */
    public function iHaveACloudfrontClientAndIHaveAKeyValueStore()
    {
        $cloudfrontClient = new CloudfrontClient([
            'region' => 'us-east-1',
            'version' => 'latest'
        ]);

$result = $cloudfrontClient->listKeyValueStores();
        $this->keyvaluestore = $result['KeyValueStoreList']['Items']['0']['ARN'];
    }

/**
     * @Then I can describe my key-value store using sigv4a
     */
    public function iCanDescribeMyKeyValueStoreUsingSigV4a()
    {
        $keyValueStoreClient = new CloudFrontKeyValueStoreClient([
            'region' => 'us-east-1',
            'version' => 'latest'
        ]);

$result = $keyValueStoreClient->describeKeyValueStore([
                'KvsARN' => $this->keyvaluestore
            ]);

Assert::assertEquals('200', $result['@metadata']['statusCode']);
    }
}