Add an anonymous consumer to handle github post-push hooks

app/config/config.yml

@@ -112,10 +112,15 @@ old_sound_rabbit_mq:
             exchange_options: {name: 'upload-bundle', type: direct, durable: true }
             queue_options:    {name: 'upload-bundle'}
             callback:         knp_bundles.consumer.update_bundle
+    anon_consumers:
+        github_hook:
+            connection: default
+            exchange_options: {name: 'github-hooks', type: topic }
+            callback:         knp_bundles.consumer.github_hook
 
 nelmio_solarium:
     adapter:
         class: Solarium_Client_Adapter_Http
         host: %solarium.host%
         port: %solarium.port%
-        path: %solarium.path%
+        path: %solarium.path%

src/Knp/Bundle/KnpBundlesBundle/Consumer/GithubHookConsumer.php

@@ -0,0 +1,79 @@
+<?php
+
+namespace Knp\Bundle\KnpBundlesBundle\Consumer;
+
+use OldSound\RabbitMqBundle\RabbitMq\ConsumerInterface;
+use OldSound\RabbitMqBundle\RabbitMq\Producer;
+
+use Symfony\Component\HttpKernel\Log\LoggerInterface;
+
+use Doctrine\Common\Persistence\ObjectManager;
+
+/**
+* 
+*/
+class GithubHookConsumer implements ConsumerInterface
+{
+    /**
+     * @var OldSound\RabbitMqBundle\RabbitMq\Producer
+     */
+    private $producer;
+
+    /**
+     * @var Doctrine\Common\Persistence\ObjectManager
+     */
+    private $manager;
+
+    /**
+     * @var Symfony\Component\HttpKernel\Log\LoggerInterface
+     */
+    private $logger;
+
+    public function __construct(ObjectManager $manager, Producer $producer)
+    {
+        $this->producer = $producer;
+        $this->manager = $manager;
+    } 
+
+    /**
+     * {@inheritDoc}
+     */
+    public function execute($msg)
+    {
+        if ($this->logger) {
+            $this->logger->info('[GithubHookConsumer] Received a github post push hook');
+        }
+
+        if (is_null($payload = json_decode($msg->body))) {
+            if ($this->logger) {
+                $this->logger->err('[GithubHookConsumer] Unable to decode payload');
+            }
+
+            return;
+        }
+
+        $bundles = $this->manager->getRepository('KnpBundlesBundle:Bundle');
+
+        $bundle = $bundles->findOneBy(array(
+            'name' => $payload->repository->name,
+            'username' => $payload->repository->owner->name
+        ));
+
+        if (!$bundle) {
+            if ($this->logger) {
+                $this->logger->warn(sprintf('[GithubHookConsumer] unknown bundle %s/%s', 
+                  $payload->repository->name, 
+                  $payload->repository->owner->name));
+            }
+
+            return;
+        }
+
+        $this->producer->publish(serialize(array('bundle_id' => $bundle->getId())));
+    }
+
+    public function setLogger(LoggerInterface $logger)
+    {
+        $this->logger = $logger;
+    }
+}

src/Knp/Bundle/KnpBundlesBundle/Resources/config/services.yml

@@ -4,6 +4,7 @@ parameters:
     knp_bundles.trending_bundle_twitterer.class: Knp\Bundle\KnpBundlesBundle\Twitterer\TrendingBundleTwitterer
     knp_bundles.trending_bundle_tweet.template: "Discover {name}, today's trending #Symfony2 bundle {url} on #KnpBundles"
     knp_bundles.consumer.update_bundle.class: Knp\Bundle\KnpBundlesBundle\Consumer\UpdateBundleConsumer
+    knp_bundles.consumer.github_hook.class: Knp\Bundle\KnpBundlesBundle\Consumer\GithubHookConsumer
     knp_bundles.user.manager.class: Knp\Bundle\KnpBundlesBundle\Entity\UserManager
     knp_bundles.output.class: Symfony\Component\Console\Output\NullOutput
     knp_bundles.travis.class: Knp\Bundle\KnpBundlesBundle\Travis\Travis
@@ -124,3 +125,12 @@ services:
             - @knp_bundles.imagine
         calls:
             - [ setCacheDir, [%kernel.cache_dir%] ]
+
+    knp_bundles.consumer.github_hook:
+        public: false
+        class: %knp_bundles.consumer.github_hook.class%
+        arguments:
+            - @doctrine.orm.entity_manager
+            - @old_sound_rabbit_mq.update_bundle_producer
+        calls:
+            - [ setLogger, [@logger]]