Add support for configurable HTTP request factory for proxy clients

Author: jdreesen

src/DependencyInjection/Configuration.php

@@ -641,6 +641,10 @@ private function getHttpDispatcherNode()
                     ->defaultNull()
                     ->info('Httplug async client service name to use for sending the requests.')
                 ->end()
+                ->scalarNode('request_factory')
+                    ->defaultNull()
+                    ->info('Service name of factory for PSR-7 messages.')
+                ->end()
             ->end()
         ;
 

src/DependencyInjection/FOSHttpCacheExtension.php

@@ -430,6 +430,10 @@ private function loadVarnish(ContainerBuilder $container, XmlFileLoader $loader,
         $container->setParameter('fos_http_cache.proxy_client.varnish.options', $options);
 
         $loader->load('varnish.xml');
+
+        $requestFactory = $config['http']['request_factory'] ? new Reference($config['http']['request_factory']) : null;
+        $container->getDefinition('fos_http_cache.proxy_client.varnish')
+            ->replaceArgument(2, $requestFactory);
     }
 
     private function loadNginx(ContainerBuilder $container, XmlFileLoader $loader, array $config)
@@ -439,6 +443,10 @@ private function loadNginx(ContainerBuilder $container, XmlFileLoader $loader, a
             'purge_location' => $config['purge_location'],
         ]);
         $loader->load('nginx.xml');
+
+        $requestFactory = $config['http']['request_factory'] ? new Reference($config['http']['request_factory']) : null;
+        $container->getDefinition('fos_http_cache.proxy_client.nginx')
+            ->replaceArgument(2, $requestFactory);
     }
 
     private function loadSymfony(ContainerBuilder $container, XmlFileLoader $loader, array $config)
@@ -465,6 +473,10 @@ private function loadSymfony(ContainerBuilder $container, XmlFileLoader $loader,
         $container->setParameter('fos_http_cache.proxy_client.symfony.options', $options);
 
         $loader->load('symfony.xml');
+
+        $requestFactory = $config['http']['request_factory'] ? new Reference($config['http']['request_factory']) : null;
+        $container->getDefinition('fos_http_cache.proxy_client.symfony')
+            ->replaceArgument(2, $requestFactory);
     }
 
     private function loadCloudflare(ContainerBuilder $container, XmlFileLoader $loader, array $config)
@@ -478,6 +490,10 @@ private function loadCloudflare(ContainerBuilder $container, XmlFileLoader $load
         $container->setParameter('fos_http_cache.proxy_client.cloudflare.options', $options);
 
         $loader->load('cloudflare.xml');
+
+        $requestFactory = $config['http']['request_factory'] ? new Reference($config['http']['request_factory']) : null;
+        $container->getDefinition('fos_http_cache.proxy_client.cloudflare')
+            ->replaceArgument(2, $requestFactory);
     }
 
     private function loadCloudfront(ContainerBuilder $container, XmlFileLoader $loader, array $config)
@@ -514,6 +530,10 @@ private function loadFastly(ContainerBuilder $container, XmlFileLoader $loader,
         $container->setParameter('fos_http_cache.proxy_client.fastly.options', $options);
 
         $loader->load('fastly.xml');
+
+        $requestFactory = $config['http']['request_factory'] ? new Reference($config['http']['request_factory']) : null;
+        $container->getDefinition('fos_http_cache.proxy_client.fastly')
+            ->replaceArgument(2, $requestFactory);
     }
 
     /**

src/Resources/config/cloudflare.xml

@@ -10,6 +10,7 @@
                  public="true">
             <argument type="service" id="fos_http_cache.proxy_client.cloudflare.http_dispatcher"/>
             <argument>%fos_http_cache.proxy_client.cloudflare.options%</argument>
+            <argument /> <!-- request factory -->
         </service>
     </services>
 

src/Resources/config/fastly.xml

@@ -10,6 +10,7 @@
                  public="false">
             <argument type="service" id="fos_http_cache.proxy_client.fastly.http_dispatcher"/>
             <argument>%fos_http_cache.proxy_client.fastly.options%</argument>
+            <argument /> <!-- request factory -->
         </service>
     </services>
 

src/Resources/config/nginx.xml

@@ -10,6 +10,7 @@
                  public="true">
             <argument type="service" id="fos_http_cache.proxy_client.nginx.http_dispatcher"/>
             <argument>%fos_http_cache.proxy_client.nginx.options%</argument>
+            <argument /> <!-- request factory -->
         </service>
     </services>
 

src/Resources/config/symfony.xml

@@ -10,6 +10,7 @@
                  public="true">
             <argument type="service" id="fos_http_cache.proxy_client.symfony.http_dispatcher"/>
             <argument>%fos_http_cache.proxy_client.symfony.options%</argument>
+            <argument /> <!-- request factory -->
         </service>
     </services>
 

src/Resources/config/varnish.xml

@@ -10,6 +10,7 @@
                  public="true">
             <argument type="service" id="fos_http_cache.proxy_client.varnish.http_dispatcher"/>
             <argument>%fos_http_cache.proxy_client.varnish.options%</argument>
+            <argument /> <!-- request factory -->
         </service>
     </services>