Serializer Adapter JMS and default Symfony

src/DependencyInjection/Configuration.php

@@ -99,8 +99,20 @@ private function createClientsNode()
                             ->thenInvalid('Class %s is missing. Did you forget to add guzzlehttp/services to your project\'s composer.json?')
                         ->end()
                     ->end()
+                    ->arrayNode('serializer')
+                        ->children()
+                            ->scalarNode('type')->defaultValue('symfony')
+                                ->validate()
+                                    ->ifNotInArray(['symfony', 'jms'])
+                                    ->thenInvalid('Invalid serializer adapter')
+                                ->end()
+                            ->end()
+                            ->scalarNode('service')->defaultValue('serialzer')->end()
+                        ->end()
+                    ->end()
                 ->end()
             ->end()
+            ->end()
         ;
 
         return $node;

src/DependencyInjection/CsaGuzzleExtension.php

@@ -116,8 +116,17 @@ private function processClientsConfiguration(array $config, ContainerBuilder $co
                     $name
                 )));
                 $serviceDefinition->addArgument(['process' => false]);
-                $serviceDefinition->addMethodCall('setSerializer', [new Reference('serializer')]);
-                $serviceDefinition->addMethodCall('addProcess');
+                if (isset($options['serializer']) && is_array($options['serializer'])) {
+                    if ($options['serializer']['type'] === 'jms') {
+                        $jmsAdapter = new Definition('Csa\Bundle\GuzzleBundle\Serializer\JMSAdapter');
+                        $jmsAdapter->addArgument(new Reference($options['serializer']['service']));
+                        $container->setDefinition('csa_guzzle.adapter.jms', $jmsAdapter);
+                        $options['serializer']['service'] = 'csa_guzzle.adapter.jms';
+
+                    }
+                    $serviceDefinition->addMethodCall('setSerializer', [new Reference($options['serializer']['service'])]);
+                    $serviceDefinition->addMethodCall('addProcess');
+                }
 
                 $container->setDefinition(sprintf('csa_guzzle.service.%s', $name), $serviceDefinition);
                 $container->getDefinition('csa_guzzle.paramconverter.guzzle')->addMethodCall(

src/GuzzleHttp/Cache/DoctrineAdapter.php

@@ -27,6 +27,7 @@ public function __construct(Cache $cache, $ttl = 0)
 
     public function fetch(RequestInterface $request)
     {
+
         $key = $this->getKey($request);
 
         if ($this->cache->contains($key)) {

src/GuzzleHttp/Command/Guzzle/GuzzleClient.php

@@ -10,7 +10,7 @@
 
 use Csa\Bundle\GuzzleBundle\GuzzleHttp\Command\Guzzle\Subscriber\ProcessResponse;
 use GuzzleHttp\Command\Guzzle\GuzzleClient as AbstractGuzzleClient;
-use JMS\Serializer\SerializerInterface;
+use Symfony\Component\Serializer\SerializerInterface;
 
 class GuzzleClient extends AbstractGuzzleClient
 {
@@ -20,7 +20,7 @@ class GuzzleClient extends AbstractGuzzleClient
     protected $serializer;
 
     /**
-     * @param SerializerInterface $serializer
+     * @param \Symfony\Component\Serializer\SerializerInterface $serializer
      */
     public function setSerializer(SerializerInterface $serializer)
     {

src/GuzzleHttp/Command/Guzzle/Subscriber/ProcessResponse.php

@@ -21,7 +21,7 @@
 use GuzzleHttp\Command\Guzzle\ResponseLocation\ReasonPhraseLocation;
 use GuzzleHttp\Command\Guzzle\ResponseLocation\HeaderLocation;
 use GuzzleHttp\Command\Guzzle\ResponseLocation\XmlLocation;
-use JMS\Serializer\SerializerInterface;
+use Symfony\Component\Serializer\SerializerInterface;
 
 /**
  * Class ProcessResponse
@@ -40,9 +40,9 @@ class ProcessResponse implements SubscriberInterface
     private $serializer;
 
     /**
-     * @param \GuzzleHttp\Command\Guzzle\DescriptionInterface $description
-     * @param \JMS\Serializer\SerializerInterface             $serializer
-     * @param array                                           $responseLocations
+     * @param \GuzzleHttp\Command\Guzzle\DescriptionInterface   $description
+     * @param \Symfony\Component\Serializer\SerializerInterface $serializer
+     * @param array                                             $responseLocations
      */
     public function __construct(
         DescriptionInterface $description,

src/GuzzleHttp/Subscriber/CacheSubscriber.php

@@ -16,6 +16,9 @@
 use GuzzleHttp\Event\CompleteEvent;
 use GuzzleHttp\Event\RequestEvents;
 use GuzzleHttp\Event\SubscriberInterface;
+use GuzzleHttp\Message\MessageFactory;
+use GuzzleHttp\Message\MessageParser;
+use GuzzleHttp\Message\Response;
 
 /**
  * Csa Guzzle Cache integration
@@ -48,6 +51,8 @@ public function onBefore(BeforeEvent $event)
 
             return;
         }
+        $messageFactory = new MessageFactory();
+        $response = $messageFactory->fromMessage($response);
 
         $request->getConfig()->set('cache_lookup', 'HIT');
         $request->getConfig()->set('cache_hit', true);

src/Serializer/JMSAdapter.php

@@ -0,0 +1,62 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: AJanssen
+ * Date: 05-06-15
+ * Time: 15:22
+ */
+
+namespace Csa\Bundle\GuzzleBundle\Serializer;
+
+
+use JMS\Serializer\DeserializationContext;
+use JMS\Serializer\SerializationContext;
+use Symfony\Component\Serializer\SerializerInterface;
+use \JMS\Serializer\SerializerInterface as JMSSerializerInterface;
+
+class JMSAdapter implements SerializerInterface
+{
+    /**
+     * @var JMSSerializerInterface
+     */
+    private $serializer;
+
+    /**
+     * @param \JMS\Serializer\SerializerInterface $serializer
+     */
+    public function __construct(JMSSerializerInterface $serializer)
+    {
+        $this->serializer = $serializer;
+    }
+
+    /**
+     * Serializes data in the appropriate format.
+     *
+     * @param mixed  $data    any data
+     * @param string $format  format name
+     * @param array  $context options normalizers/encoders have access to
+     *
+     * @return string
+     */
+    public function serialize($data, $format, array $context = [])
+    {
+        return $this->serializer->serialize($data, $format, SerializationContext::create($context));
+    }
+
+    /**
+     * Deserializes data into the given type.
+     *
+     * @param mixed  $data
+     * @param string $type
+     * @param string $format
+     * @param array  $context
+     *
+     * @return object
+     */
+    public function deserialize($data, $type, $format, array $context = [])
+    {
+        return $this->serializer->deserialize($data, $type, $format, DeserializationContext::create($context));
+    }
+
+
+}