customerTokenService = Bootstrap::getObjectManager()->get(CustomerTokenServiceInterface::class); $this->customerGroup = Bootstrap::getObjectManager()->get(Group::class); $this->customerRepository = Bootstrap::getObjectManager()->get(CustomerRepositoryInterface::class); $this->fixtures = Bootstrap::getObjectManager()->get(DataFixtureStorageManager::class)->getStorage(); } /** * Tests that cache id header changes based on customer group and remains consistent for same customer group */ #[ DataFixture(ProductFixture::class, as: 'product'), DataFixture(CustomerFixture::class, as: 'customer'), ] public function testCacheIdHeaderWithCustomerGroup(): void { $customerEmail = $this->fixtures->get('customer')->getEmail(); $query = <<fixtures->get('product')->getSku()}"}}) { items { id name sku description { html } } } } QUERY; $response = $this->graphQlQueryWithResponseHeaders( $query, [], '', $this->getHeaderMap($customerEmail) ); $this->assertArrayHasKey(CacheIdCalculator::CACHE_ID_HEADER, $response['headers']); $cacheId = $response['headers'][CacheIdCalculator::CACHE_ID_HEADER]; $this->assertTrue((boolean)preg_match('/^[0-9a-f]{64}$/i', $cacheId)); $customer = $this->customerRepository->get($customerEmail); $customerGroupId = $this->customerGroup->load('Retailer', 'customer_group_code')->getId(); // change the customer group of this customer from the default group $customer->setGroupId($customerGroupId); $this->customerRepository->save($customer); $responseAfterCustomerGroupChange = $this->graphQlQueryWithResponseHeaders( $query, [], '', $this->getHeaderMap($customerEmail) ); $this->assertArrayHasKey( CacheIdCalculator::CACHE_ID_HEADER, $responseAfterCustomerGroupChange['headers'] ); $cacheIdCustomerGroupChange = $responseAfterCustomerGroupChange['headers'][CacheIdCalculator::CACHE_ID_HEADER]; // Verify that the cache id generated is a 64 character long $this->assertTrue((boolean)preg_match('/^[0-9a-f]{64}$/i', $cacheId)); // check that the cache ids generated before and after customer group changes are not equal $this->assertNotEquals($cacheId, $cacheIdCustomerGroupChange); //Change the customer groupId back to Default General $customer->setGroupId(1); $this->customerRepository->save($customer); $responseDefaultCustomerGroup = $this->graphQlQueryWithResponseHeaders( $query, [], '', $this->getHeaderMap($customerEmail) ); //Verify that the cache id is same as original $cacheId $this->assertEquals( $responseDefaultCustomerGroup['headers'][CacheIdCalculator::CACHE_ID_HEADER], $cacheId ); } /** * Authentication header map * * @param string $username * @return array * * @throws AuthenticationException * @throws EmailNotConfirmedException */ private function getHeaderMap(string $username): array { $customerToken = $this->customerTokenService->createCustomerAccessToken($username, 'password'); return ['Authorization' => 'Bearer ' . $customerToken]; } }