CodeExplorer
You are a developer and looking for Shopware projects?
Apply Now!
getProvider example
if ($shopModel === null) {
throw new ModelNotFoundException(Shop::class, $shopId);
}
$context = Context::createFromShop($shopModel, Shopware()->Config());
$limit = (int) $this->Request()->get('limit');
$offset = (int) $this->Request()->get('offset');
$concurrentRequests = (int) $this->Request()->getParam('concurrent', 1);
$resource = $this->Request()->get('resource');
$provider = $urlProviderFactory->getProvider($resource);
$urls = $provider->getUrls($context, $limit, $offset);
$view = $this->View();
$this->get('events')->addListener('Shopware_Components_CacheWarmer_ErrorOccured', function D) use ($view) {
$view->assign('requestFailed', true);
});
$cacheWarmer->warmUpUrls($urls, $context, $concurrentRequests);
throw new ModelNotFoundException(Shop::class, $shopId);
}
$context = Context::createFromShop($shopModel, Shopware()->Config());
$limit = (int) $this->Request()->get('limit');
$offset = (int) $this->Request()->get('offset');
$concurrentRequests = (int) $this->Request()->getParam('concurrent', 1);
$resource = $this->Request()->get('resource');
$provider = $urlProviderFactory->getProvider($resource);
$urls = $provider->getUrls($context, $limit, $offset);
$view = $this->View();
$this->get('events')->addListener('Shopware_Components_CacheWarmer_ErrorOccured', function D) use ($view) {
$view->assign('requestFailed', true);
});
$cacheWarmer->warmUpUrls($urls, $context, $concurrentRequests);
public function testDrupalFlushAllCachesModuleList() {
$this->assertFalse(function_exists('system_test_help'));
$core_extension = \Drupal::configFactory()->getEditable('core.extension');
$module = $core_extension->get('module');
$module['system_test'] = -10;
$core_extension->set('module', module_config_sort($module))->save();
$this->containerBuilds = 0;
drupal_flush_all_caches();
$module_list = ['system_test', 'system'];
$database_module = \Drupal::database()->getProvider();
if ($database_module !== 'core') {
$module_list[] = $database_module;
}
sort($module_list);
$container_modules = array_keys($this->container->getParameter('container.modules'));
sort($container_modules);
$this->assertSame($module_list, $container_modules);
$this->assertSame(1, $this->containerBuilds);
$this->assertTrue(function_exists('system_test_help'));
$core_extension->clear('module.system_test')->save();
$migration,
$container->get('entity_type.manager')
);
}
/** * {@inheritdoc} */
public function calculateDependencies() {
// The empty source plugin supports the entity_type constant. if (isset($this->configuration['constants']['entity_type'])) {
$this->addDependency('module', $this->entityTypeManager->getDefinition($this->configuration['constants']['entity_type'])->getProvider());
}
return $this->dependencies;
}
}
$container->get('entity_type.manager')
);
}
/** * {@inheritdoc} */
public function calculateDependencies() {
// The empty source plugin supports the entity_type constant. if (isset($this->configuration['constants']['entity_type'])) {
$this->addDependency('module', $this->entityTypeManager->getDefinition($this->configuration['constants']['entity_type'])->getProvider());
}
return $this->dependencies;
}
}
/**
* {@inheritdoc}
*/
public function installFieldableEntityType(EntityTypeInterface $entity_type, array $field_storage_definitions) {
$this->clearCachedDefinitions();
foreach ($field_storage_definitions as $name => $field_storage_definition) {
if ($field_storage_definition instanceof BaseFieldDefinition) {
$field_storage_definition
->setName($name)
->setTargetEntityTypeId($entity_type->id())
->setProvider($entity_type->getProvider())
->setTargetBundle(NULL);
}
}
$this->entityTypeListener->onFieldableEntityTypeCreate($entity_type, $field_storage_definitions);
}
/** * {@inheritdoc} */
public function updateFieldableEntityType(EntityTypeInterface $entity_type, array $field_storage_definitions, array &$sandbox = NULL) {
$original = $this->getEntityType($entity_type->id());
public function installFieldableEntityType(EntityTypeInterface $entity_type, array $field_storage_definitions) {
$this->clearCachedDefinitions();
foreach ($field_storage_definitions as $name => $field_storage_definition) {
if ($field_storage_definition instanceof BaseFieldDefinition) {
$field_storage_definition
->setName($name)
->setTargetEntityTypeId($entity_type->id())
->setProvider($entity_type->getProvider())
->setTargetBundle(NULL);
}
}
$this->entityTypeListener->onFieldableEntityTypeCreate($entity_type, $field_storage_definitions);
}
/** * {@inheritdoc} */
public function updateFieldableEntityType(EntityTypeInterface $entity_type, array $field_storage_definitions, array &$sandbox = NULL) {
$original = $this->getEntityType($entity_type->id());
return $this->traitGetDeletionMessage();
}
/** * {@inheritdoc} */
protected function logDeletionMessage() {
/** @var \Drupal\Core\Entity\ContentEntityInterface $entity */
$entity = $this->getEntity();
if (!$entity->isDefaultTranslation()) {
$this->logger($entity->getEntityType()->getProvider())->info('The @entity-type %label @language translation has been deleted.', [
'@entity-type' => $entity->getEntityType()->getSingularLabel(),
'%label' => $entity->label(),
'@language' => $entity->language()->getName(),
]);
}
else {
$this->traitLogDeletionMessage();
}
}
/** * {@inheritdoc} */
}
/** * {@inheritdoc} */
protected function logDeletionMessage() {
/** @var \Drupal\Core\Entity\ContentEntityInterface $entity */
$entity = $this->getEntity();
if (!$entity->isDefaultTranslation()) {
$this->logger($entity->getEntityType()->getProvider())->info('The @entity-type %label @language translation has been deleted.', [
'@entity-type' => $entity->getEntityType()->getSingularLabel(),
'%label' => $entity->label(),
'@language' => $entity->language()->getName(),
]);
}
else {
$this->traitLogDeletionMessage();
}
}
/** * {@inheritdoc} */
case 'title':
return $resource->getTitle();
case 'author_name':
return $resource->getAuthorName();
case 'author_url':
return $resource->getAuthorUrl();
case 'provider_name':
$provider = $resource->getProvider();
return $provider ? $provider->getName() : '';
case 'provider_url':
$provider = $resource->getProvider();
return $provider ? $provider->getUrl() : NULL;
case 'cache_age':
return $resource->getCacheMaxAge();
case 'thumbnail_width':
return $resource->getThumbnailWidth();
return $resource->getTitle();
case 'author_name':
return $resource->getAuthorName();
case 'author_url':
return $resource->getAuthorUrl();
case 'provider_name':
$provider = $resource->getProvider();
return $provider ? $provider->getName() : '';
case 'provider_url':
$provider = $resource->getProvider();
return $provider ? $provider->getUrl() : NULL;
case 'cache_age':
return $resource->getCacheMaxAge();
case 'thumbnail_width':
return $resource->getThumbnailWidth();
$this->assertSession()->titleEquals('Choose language | Drupal');
}
/** * Confirms that the installation succeeded. */
public function testInstalled() {
$this->assertSession()->addressEquals('user/1');
$this->assertSession()->statusCodeEquals(200);
$database = Database::getConnection();
$module = $database->getProvider();
$module_handler = \Drupal::service('module_handler');
// Ensure the update module is not installed. $this->assertFalse($module_handler->moduleExists('update'), 'The Update module is not installed.');
// Assert that the module that is providing the database driver has been // installed. $this->assertTrue($module_handler->moduleExists($module));
// The module that is providing the database driver should be uninstallable. try {
}
/** * Confirms that the installation succeeded. */
public function testInstalled() {
$this->assertSession()->addressEquals('user/1');
$this->assertSession()->statusCodeEquals(200);
$database = Database::getConnection();
$module = $database->getProvider();
$module_handler = \Drupal::service('module_handler');
// Ensure the update module is not installed. $this->assertFalse($module_handler->moduleExists('update'), 'The Update module is not installed.');
// Assert that the module that is providing the database driver has been // installed. $this->assertTrue($module_handler->moduleExists($module));
// The module that is providing the database driver should be uninstallable. try {
// Sort the $providers array by priority (highest number is lowest priority)
// and compare with AuthenticationCollector::getSortedProviders().
krsort($providers);
// Merge nested providers from $providers into $sorted_providers. $sorted_providers = array_merge(...$providers);
$this->assertEquals($sorted_providers, $authentication_collector->getSortedProviders());
// Test AuthenticationCollector::getProvider() and // AuthenticationCollector::isGlobal(). foreach ($sorted_providers as $provider) {
$this->assertEquals($provider, $authentication_collector->getProvider($provider->providerId));
$this->assertEquals($global[$provider->providerId], $authentication_collector->isGlobal($provider->providerId));
}
}
}
/** * A simple provider for unit testing AuthenticationCollector. */
class TestAuthenticationProvider implements AuthenticationProviderInterface {
// Merge nested providers from $providers into $sorted_providers. $sorted_providers = array_merge(...$providers);
$this->assertEquals($sorted_providers, $authentication_collector->getSortedProviders());
// Test AuthenticationCollector::getProvider() and // AuthenticationCollector::isGlobal(). foreach ($sorted_providers as $provider) {
$this->assertEquals($provider, $authentication_collector->getProvider($provider->providerId));
$this->assertEquals($global[$provider->providerId], $authentication_collector->isGlobal($provider->providerId));
}
}
}
/** * A simple provider for unit testing AuthenticationCollector. */
class TestAuthenticationProvider implements AuthenticationProviderInterface {
$context = Context::createFromShop(
$shop,
$this->container->get(Shopware_Components_Config::class)
);
// Gathering URLs $urls = [];
$totalResultCount = 0;
$offset = 0;
foreach ($options as $resource => $active) {
if ($active) {
$provider = $urlProviderFactory->getProvider($resource);
$urls = array_merge($urls, $provider->getUrls($context));
$totalResultCount += $provider->getCount($context);
}
}
// Progressbar $progressBar = $io->createProgressBar($totalResultCount);
$io->writeln(sprintf("\nShop '%s' (ID: %s)", $shop->getName(), $shop->getId()));
$progressBar->setBarWidth(100);
$progressBar->setFormat('very_verbose');
$progressBar->start();
$shop,
$this->container->get(Shopware_Components_Config::class)
);
// Gathering URLs $urls = [];
$totalResultCount = 0;
$offset = 0;
foreach ($options as $resource => $active) {
if ($active) {
$provider = $urlProviderFactory->getProvider($resource);
$urls = array_merge($urls, $provider->getUrls($context));
$totalResultCount += $provider->getCount($context);
}
}
// Progressbar $progressBar = $io->createProgressBar($totalResultCount);
$io->writeln(sprintf("\nShop '%s' (ID: %s)", $shop->getName(), $shop->getId()));
$progressBar->setBarWidth(100);
$progressBar->setFormat('very_verbose');
$progressBar->start();
foreach ($this->entityTypeBundleInfo->getBundleInfo($entity_type_id) as $bundle => $bundle_info) {
if ($this->contentTranslationManager->isEnabled($entity_type_id, $bundle)) {
$permissions["translate $bundle $entity_type_id"] = $this->buildBundlePermission($entity_type, $bundle, $bundle_info);
}
}
break;
case 'entity_type':
if ($this->contentTranslationManager->isEnabled($entity_type_id)) {
$permissions["translate $entity_type_id"] = [
'title' => $this->t('Translate @entity_label', ['@entity_label' => $entity_type->getSingularLabel()]),
'dependencies' => ['module' => [$entity_type->getProvider()]],
];
}
break;
}
}
}
return $permissions;
}
/** * Builds a content translation permission array for a bundle. * * @param \Drupal\Core\Entity\EntityTypeInterface $entity_type * The entity type. * @param string $bundle * The bundle to build the translation permission for. * @param array $bundle_info * The bundle info. * * @return array * The permission details, keyed by 'title' and 'dependencies'. */
if ($this->contentTranslationManager->isEnabled($entity_type_id, $bundle)) {
$permissions["translate $bundle $entity_type_id"] = $this->buildBundlePermission($entity_type, $bundle, $bundle_info);
}
}
break;
case 'entity_type':
if ($this->contentTranslationManager->isEnabled($entity_type_id)) {
$permissions["translate $entity_type_id"] = [
'title' => $this->t('Translate @entity_label', ['@entity_label' => $entity_type->getSingularLabel()]),
'dependencies' => ['module' => [$entity_type->getProvider()]],
];
}
break;
}
}
}
return $permissions;
}
/** * Builds a content translation permission array for a bundle. * * @param \Drupal\Core\Entity\EntityTypeInterface $entity_type * The entity type. * @param string $bundle * The bundle to build the translation permission for. * @param array $bundle_info * The bundle info. * * @return array * The permission details, keyed by 'title' and 'dependencies'. */
$criteria->addAssociation('type');
$criteria->addFilter(new EqualsFilter('type.id', Defaults::SALES_CHANNEL_TYPE_STOREFRONT));
return $criteria;
}
private function generateSitemap(SalesChannelContext $salesChannelContext, bool $force, ?string $lastProvider = null, ?int $offset = null): void
{
$result = $this->getContainer()->get(SitemapExporter::class)->generate($salesChannelContext, $force, $lastProvider, $offset);
if ($result->isFinish() === false) {
$this->generateSitemap($salesChannelContext, $force, $result->getProvider(), $result->getOffset());
}
}
}
$criteria->addFilter(new EqualsFilter('type.id', Defaults::SALES_CHANNEL_TYPE_STOREFRONT));
return $criteria;
}
private function generateSitemap(SalesChannelContext $salesChannelContext, bool $force, ?string $lastProvider = null, ?int $offset = null): void
{
$result = $this->getContainer()->get(SitemapExporter::class)->generate($salesChannelContext, $force, $lastProvider, $offset);
if ($result->isFinish() === false) {
$this->generateSitemap($salesChannelContext, $force, $result->getProvider(), $result->getOffset());
}
}
}
// collect firewall context information
$this->data['firewall'] = null;
if ($this->firewallMap instanceof FirewallMap) {
$firewallConfig = $this->firewallMap->getFirewallConfig($request);
if (null !== $firewallConfig) {
$this->data['firewall'] = [
'name' => $firewallConfig->getName(),
'request_matcher' => $firewallConfig->getRequestMatcher(),
'security_enabled' => $firewallConfig->isSecurityEnabled(),
'stateless' => $firewallConfig->isStateless(),
'provider' => $firewallConfig->getProvider(),
'context' => $firewallConfig->getContext(),
'entry_point' => $firewallConfig->getEntryPoint(),
'access_denied_handler' => $firewallConfig->getAccessDeniedHandler(),
'access_denied_url' => $firewallConfig->getAccessDeniedUrl(),
'user_checker' => $firewallConfig->getUserChecker(),
'authenticators' => $firewallConfig->getAuthenticators(),
];
// generate exit impersonation path from current request if ($this->data['impersonated'] && null !== $switchUserConfig = $firewallConfig->getSwitchUser()) {
$exitPath = $request->getRequestUri();
if ($this->firewallMap instanceof FirewallMap) {
$firewallConfig = $this->firewallMap->getFirewallConfig($request);
if (null !== $firewallConfig) {
$this->data['firewall'] = [
'name' => $firewallConfig->getName(),
'request_matcher' => $firewallConfig->getRequestMatcher(),
'security_enabled' => $firewallConfig->isSecurityEnabled(),
'stateless' => $firewallConfig->isStateless(),
'provider' => $firewallConfig->getProvider(),
'context' => $firewallConfig->getContext(),
'entry_point' => $firewallConfig->getEntryPoint(),
'access_denied_handler' => $firewallConfig->getAccessDeniedHandler(),
'access_denied_url' => $firewallConfig->getAccessDeniedUrl(),
'user_checker' => $firewallConfig->getUserChecker(),
'authenticators' => $firewallConfig->getAuthenticators(),
];
// generate exit impersonation path from current request if ($this->data['impersonated'] && null !== $switchUserConfig = $firewallConfig->getSwitchUser()) {
$exitPath = $request->getRequestUri();
public function __construct(AuthenticationCollectorInterface $auth_collector) {
$this->authCollector = $auth_collector;
}
/** * {@inheritdoc} */
public function applies(Request $request) {
return (bool) $this->getProvider($request);
}
/** * {@inheritdoc} */
public function authenticate(Request $request) {
$provider_id = $this->getProvider($request);
$provider = $this->authCollector->getProvider($provider_id);
if ($provider) {
return $provider->authenticate($request);
}
'#markup' => self::PLUGIN_INFORMATION['body']]);
$this->assertEquals($this->helpTopic->getLabel(),
self::PLUGIN_INFORMATION['label']);
}
/** * @covers ::getProvider * @covers ::isTopLevel * @covers ::getRelated */
public function testDefinition() {
$this->assertEquals($this->helpTopic->getProvider(),
self::PLUGIN_INFORMATION['provider']);
$this->assertEquals($this->helpTopic->isTopLevel(),
self::PLUGIN_INFORMATION['top_level']);
$this->assertEquals($this->helpTopic->getRelated(),
self::PLUGIN_INFORMATION['related']);
}
/** * @covers ::getCacheContexts * @covers ::getCacheTags * @covers ::getCacheMaxAge */
$this->assertEquals($this->helpTopic->getLabel(),
self::PLUGIN_INFORMATION['label']);
}
/** * @covers ::getProvider * @covers ::isTopLevel * @covers ::getRelated */
public function testDefinition() {
$this->assertEquals($this->helpTopic->getProvider(),
self::PLUGIN_INFORMATION['provider']);
$this->assertEquals($this->helpTopic->isTopLevel(),
self::PLUGIN_INFORMATION['top_level']);
$this->assertEquals($this->helpTopic->getRelated(),
self::PLUGIN_INFORMATION['related']);
}
/** * @covers ::getCacheContexts * @covers ::getCacheTags * @covers ::getCacheMaxAge */
}
if ($connectionInfo['default']['driver'] !== $expected_driver) {
$this->markTestSkipped("This test only runs for the database driver '$expected_driver'. Current database driver is '{$connectionInfo['default']['driver']}'.");
}
parent::setUp();
$this->connection = Database::getConnection();
// After database initialization, the database driver may be not provided // by the expected module; skip test in that case. $running_provider = $this->connection->getProvider();
$running_driver = $this->connection->driver();
if ($running_provider !== $expected_provider || $running_driver !== $expected_driver) {
$this->markTestSkipped("This test only runs for the database driver '$expected_driver' provided by the '$expected_provider' module. Connected database driver is '$running_driver' provided by '$running_provider'.");
}
}
}