Add an embeded view

Add another service

app/Resources/views/default/embedded.html.twig

@@ -0,0 +1,16 @@
+{% extends 'layout.html.twig' %}
+
+{% block contents %}
+<div id="welcome">
+    <h1><span>Embeded version</span> {{ service }} @ {{ page }}</h1>
+</div>
+
+<pre style="border: 1px solid #333;">{{ contents }}</pre>
+
+<div id="next">
+    <h2>What's next?</h2>
+    <p>
+        <a href="{{ path('home') }}">Back to home</a>
+    </p>
+</div>
+{% endblock %}

app/Resources/views/default/index.html.twig

@@ -18,6 +18,10 @@
             <strong>Call an API</strong>
             <a href="{{ path('last_release') }}">Get the last Tolerance release</a>
         </li>
+        <li>
+            <strong>Embedded page</strong>
+            <a href="{{ path('embedded', {'service': 'service2', 'page': 'last-release'}) }}">Displayed page <code>/last-release</code> of service <code>service2</code></a>
+        </li>
     </ul>
 </div>
 {% endblock %}

app/config/config.yml

@@ -70,19 +70,20 @@ swiftmailer:
 
 # CSA Guzzle Configuration
 csa_guzzle:
+    profiler: %kernel.debug%
     clients:
         github_api:
             config:
                 base_uri: https://api.github.com
                 timeout: 2.0
                 headers:
                     Accept: application/vnd.github.v3+json
+        internal: ~
 
 # Tolerance configuration
 tolerance:
     message_profile:
         current_peer:
-            service: ExampleSymfony
             environment: %kernel.environment%
 
         storage:

app/config/services.yml

@@ -17,3 +17,8 @@ services:
     app.neo4j.client:
         class: Neoxygen\NeoClient\Client
         factory: ["@app.neo4j.client_builder", build]
+
+    app.tolerance.current_peer_enhancer:
+        class: App\Tolerance\CurrentPeerEnhancer
+        decorates: tolerance.message_profile.peer.resolver.current
+        arguments: ["@app.tolerance.current_peer_enhancer.inner"]

docker-compose.yml

@@ -1,11 +1,25 @@
-app:
+service1:
     build: .
     volumes:
         - .:/app
     links:
         - neo4j
+        - service2
     expose:
         - 80
+    environment:
+        TOLERANCE_SERVICE_NAME: "First Service"
+
+service2:
+    build: .
+    volumes:
+        - .:/app
+    links:
+        - neo4j
+    expose:
+        - 80
+    environment:
+        TOLERANCE_SERVICE_NAME: "Second Service"
+
 neo4j:
     image: neo4j
-

src/App/Tolerance/CurrentPeerEnhancer.php

@@ -0,0 +1,35 @@
+<?php
+
+namespace App\Tolerance;
+
+use Tolerance\MessageProfile\Peer\ArbitraryPeer;
+use Tolerance\MessageProfile\Peer\Resolver\PeerResolver;
+
+final class CurrentPeerEnhancer implements PeerResolver
+{
+    /**
+     * @var PeerResolver
+     */
+    private $decoratedPeerResolver;
+
+    /**
+     * @param PeerResolver $decoratedPeerResolver
+     */
+    public function __construct(PeerResolver $decoratedPeerResolver)
+    {
+        $this->decoratedPeerResolver = $decoratedPeerResolver;
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function resolve()
+    {
+        $peer = $this->decoratedPeerResolver->resolve();
+
+        return ArbitraryPeer::fromArray(array_merge($peer->getArray(), [
+            'service' => getenv('TOLERANCE_SERVICE_NAME'),
+            'container' => getenv('HOSTNAME'),
+        ]));
+    }
+}

src/AppBundle/Controller/DefaultController.php

@@ -2,6 +2,7 @@
 
 namespace AppBundle\Controller;
 
+use GuzzleHttp\Client;
 use GuzzleHttp\Psr7\Response;
 use Sensio\Bundle\FrameworkExtraBundle\Configuration\Route;
 use Symfony\Bundle\FrameworkBundle\Controller\Controller;
@@ -32,4 +33,29 @@ public function releaseAction()
             'release' => $release,
         ]);
     }
+
+    /**
+     * @Route("/embedded/{service}/{page}", name="embedded")
+     */
+    public function embeddedAction($service, $page)
+    {
+        $url = sprintf('http://%s/app_dev.php/%s', $service, $page);
+        $response = $this->getClient('internal')->get($url);
+
+        return $this->render('default/embedded.html.twig', [
+            'service' => $service,
+            'page' => $page,
+            'contents' => $response->getBody()->getContents(),
+        ]);
+    }
+
+    /**
+     * @param string $name
+     *
+     * @return Client
+     */
+    private function getClient($name)
+    {
+        return $this->get('csa_guzzle.client.'.$name);
+    }
 }