[Cache] add integration with Messenger to allow computing cached values in a worker

Author: nicolas-grekas

DependencyInjection/Configuration.php

@@ -1041,6 +1041,9 @@ private function addCacheSection(ArrayNodeDefinition $rootNode)
                                     ->scalarNode('provider')
                                         ->info('Overwrite the setting from the default provider for this adapter.')
                                     ->end()
+                                    ->scalarNode('early_expiration_message_bus')
+                                        ->example('"messenger.default_bus" to send early expiration events to the default Messenger bus.')
+                                    ->end()
                                     ->scalarNode('clearer')->end()
                                 ->end()
                             ->end()

DependencyInjection/FrameworkExtension.php

@@ -147,6 +147,7 @@
 use Symfony\Component\Yaml\Command\LintCommand as BaseYamlLintCommand;
 use Symfony\Component\Yaml\Yaml;
 use Symfony\Contracts\Cache\CacheInterface;
+use Symfony\Contracts\Cache\CallbackInterface;
 use Symfony\Contracts\Cache\TagAwareCacheInterface;
 use Symfony\Contracts\HttpClient\HttpClientInterface;
 use Symfony\Contracts\Service\ResetInterface;
@@ -436,6 +437,8 @@ public function load(array $configs, ContainerBuilder $container)
             ->addTag('container.env_var_loader');
         $container->registerForAutoconfiguration(EnvVarProcessorInterface::class)
             ->addTag('container.env_var_processor');
+        $container->registerForAutoconfiguration(CallbackInterface::class)
+            ->addTag('container.reversible');
         $container->registerForAutoconfiguration(ServiceLocator::class)
             ->addTag('container.service_locator');
         $container->registerForAutoconfiguration(ServiceSubscriberInterface::class)

Resources/config/cache.php

@@ -25,6 +25,7 @@
 use Symfony\Component\Cache\Adapter\RedisTagAwareAdapter;
 use Symfony\Component\Cache\Adapter\TagAwareAdapter;
 use Symfony\Component\Cache\Marshaller\DefaultMarshaller;
+use Symfony\Component\Cache\Messenger\EarlyExpirationHandler;
 use Symfony\Component\HttpKernel\CacheClearer\Psr6CacheClearer;
 use Symfony\Contracts\Cache\CacheInterface;
 use Symfony\Contracts\Cache\TagAwareCacheInterface;
@@ -212,6 +213,12 @@
                 null, // use igbinary_serialize() when available
             ])
 
+        ->set('cache.early_expiration_handler', EarlyExpirationHandler::class)
+            ->args([
+                service('reverse_container'),
+            ])
+            ->tag('messenger.message_handler')
+
         ->set('cache.default_clearer', Psr6CacheClearer::class)
             ->args([
                 [],

Resources/config/schema/symfony-1.0.xsd

@@ -284,6 +284,7 @@
         <xsd:attribute name="public" type="xsd:boolean" />
         <xsd:attribute name="default-lifetime" type="xsd:integer" />
         <xsd:attribute name="provider" type="xsd:string" />
+        <xsd:attribute name="early-expiration-message-bus" type="xsd:string" />
         <xsd:attribute name="clearer" type="xsd:string" />
     </xsd:complexType>