Add Gitlab webhook

3 files changed, 637 insertions, 0 deletions

diff --git a/app/Integration/Base.php b/app/Integration/Base.php
new file mode 100644
index 00000000..babf8c8f
--- /dev/null
+++ b/app/Integration/Base.php
@@ -0,0 +1,49 @@
+<?php
+
+namespace Integration;
+
+use Pimple\Container;
+
+/**
+ * Base class
+ *
+ * @package  integration
+ * @author   Frederic Guillot
+ *
+ * @property \Model\Task                   $task
+ * @property \Model\TaskFinder             $taskFinder
+ * @property \Model\User                   $user
+ */
+abstract class Base
+{
+    /**
+     * Container instance
+     *
+     * @access protected
+     * @var \Pimple\Container
+     */
+    protected $container;
+
+    /**
+     * Constructor
+     *
+     * @access public
+     * @param  \Pimple\Container   $container
+     */
+    public function __construct(Container $container)
+    {
+        $this->container = $container;
+    }
+
+    /**
+     * Load automatically class from the container
+     *
+     * @access public
+     * @param  string $name
+     * @return mixed
+     */
+    public function __get($name)
+    {
+        return $this->container[$name];
+    }
+}
diff --git a/app/Integration/GithubWebhook.php b/app/Integration/GithubWebhook.php
new file mode 100644
index 00000000..fd0b49f6
--- /dev/null
+++ b/app/Integration/GithubWebhook.php
@@ -0,0 +1,375 @@
+<?php
+
+namespace Integration;
+
+use Event\GenericEvent;
+use Model\Task;
+
+/**
+ * Github Webhook
+ *
+ * @package  integration
+ * @author   Frederic Guillot
+ */
+class GithubWebhook extends Base
+{
+    /**
+     * Events
+     *
+     * @var string
+     */
+    const EVENT_ISSUE_OPENED           = 'github.webhook.issue.opened';
+    const EVENT_ISSUE_CLOSED           = 'github.webhook.issue.closed';
+    const EVENT_ISSUE_REOPENED         = 'github.webhook.issue.reopened';
+    const EVENT_ISSUE_ASSIGNEE_CHANGE  = 'github.webhook.issue.assignee';
+    const EVENT_ISSUE_LABEL_CHANGE     = 'github.webhook.issue.label';
+    const EVENT_ISSUE_COMMENT          = 'github.webhook.issue.commented';
+    const EVENT_COMMIT                 = 'github.webhook.commit';
+
+    /**
+     * Project id
+     *
+     * @access private
+     * @var integer
+     */
+    private $project_id = 0;
+
+    /**
+     * Set the project id
+     *
+     * @access public
+     * @param  integer   $project_id   Project id
+     */
+    public function setProjectId($project_id)
+    {
+        $this->project_id = $project_id;
+    }
+
+    /**
+     * Parse Github events
+     *
+     * @access public
+     * @param  string  $type      Github event type
+     * @param  array   $payload   Github event
+     * @return boolean
+     */
+    public function parsePayload($type, array $payload)
+    {
+        switch ($type) {
+            case 'push':
+                return $this->parsePushEvent($payload);
+            case 'issues':
+                return $this->parseIssueEvent($payload);
+            case 'issue_comment':
+                return $this->parseCommentIssueEvent($payload);
+        }
+
+        return false;
+    }
+
+    /**
+     * Parse Push events (list of commits)
+     *
+     * @access public
+     * @param  array   $payload   Event data
+     * @return boolean
+     */
+    public function parsePushEvent(array $payload)
+    {
+        foreach ($payload['commits'] as $commit) {
+
+            $task_id = $this->task->getTaskIdFromText($commit['message']);
+
+            if (! $task_id) {
+                continue;
+            }
+
+            $task = $this->taskFinder->getById($task_id);
+
+            if (! $task) {
+                continue;
+            }
+
+            if ($task['is_active'] == Task::STATUS_OPEN && $task['project_id'] == $this->project_id) {
+                $this->container['dispatcher']->dispatch(
+                    self::EVENT_COMMIT,
+                    new GenericEvent(array('task_id' => $task_id) + $task)
+                );
+            }
+        }
+
+        return true;
+    }
+
+    /**
+     * Parse issue events
+     *
+     * @access public
+     * @param  array   $payload   Event data
+     * @return boolean
+     */
+    public function parseIssueEvent(array $payload)
+    {
+        switch ($payload['action']) {
+            case 'opened':
+                return $this->handleIssueOpened($payload['issue']);
+            case 'closed':
+                return $this->handleIssueClosed($payload['issue']);
+            case 'reopened':
+                return $this->handleIssueReopened($payload['issue']);
+            case 'assigned':
+                return $this->handleIssueAssigned($payload['issue']);
+            case 'unassigned':
+                return $this->handleIssueUnassigned($payload['issue']);
+            case 'labeled':
+                return $this->handleIssueLabeled($payload['issue'], $payload['label']);
+            case 'unlabeled':
+                return $this->handleIssueUnlabeled($payload['issue'], $payload['label']);
+        }
+
+        return false;
+    }
+
+    /**
+     * Parse comment issue events
+     *
+     * @access public
+     * @param  array   $payload   Event data
+     * @return boolean
+     */
+    public function parseCommentIssueEvent(array $payload)
+    {
+        $task = $this->taskFinder->getByReference($payload['issue']['number']);
+        $user = $this->user->getByUsername($payload['comment']['user']['login']);
+
+        if ($task && $user) {
+
+            $event = array(
+                'project_id' => $this->project_id,
+                'reference' => $payload['comment']['id'],
+                'comment' => $payload['comment']['body'],
+                'user_id' => $user['id'],
+                'task_id' => $task['id'],
+            );
+
+            $this->container['dispatcher']->dispatch(
+                self::EVENT_ISSUE_COMMENT,
+                new GenericEvent($event)
+            );
+
+            return true;
+        }
+
+        return false;
+    }
+
+    /**
+     * Handle new issues
+     *
+     * @access public
+     * @param  array    $issue   Issue data
+     * @return boolean
+     */
+    public function handleIssueOpened(array $issue)
+    {
+        $event = array(
+            'project_id' => $this->project_id,
+            'reference' => $issue['number'],
+            'title' => $issue['title'],
+            'description' => $issue['body']."\n\n[".t('Github Issue').']('.$issue['html_url'].')',
+        );
+
+        $this->container['dispatcher']->dispatch(
+            self::EVENT_ISSUE_OPENED,
+            new GenericEvent($event)
+        );
+
+        return true;
+    }
+
+    /**
+     * Handle issue closing
+     *
+     * @access public
+     * @param  array    $issue   Issue data
+     * @return boolean
+     */
+    public function handleIssueClosed(array $issue)
+    {
+        $task = $this->taskFinder->getByReference($issue['number']);
+
+        if ($task) {
+            $event = array(
+                'project_id' => $this->project_id,
+                'task_id' => $task['id'],
+                'reference' => $issue['number'],
+            );
+
+            $this->container['dispatcher']->dispatch(
+                self::EVENT_ISSUE_CLOSED,
+                new GenericEvent($event)
+            );
+
+            return true;
+        }
+
+        return false;
+    }
+
+    /**
+     * Handle issue reopened
+     *
+     * @access public
+     * @param  array    $issue   Issue data
+     * @return boolean
+     */
+    public function handleIssueReopened(array $issue)
+    {
+        $task = $this->taskFinder->getByReference($issue['number']);
+
+        if ($task) {
+            $event = array(
+                'project_id' => $this->project_id,
+                'task_id' => $task['id'],
+                'reference' => $issue['number'],
+            );
+
+            $this->container['dispatcher']->dispatch(
+                self::EVENT_ISSUE_REOPENED,
+                new GenericEvent($event)
+            );
+
+            return true;
+        }
+
+        return false;
+    }
+
+    /**
+     * Handle issue assignee change
+     *
+     * @access public
+     * @param  array    $issue   Issue data
+     * @return boolean
+     */
+    public function handleIssueAssigned(array $issue)
+    {
+        $user = $this->user->getByUsername($issue['assignee']['login']);
+        $task = $this->taskFinder->getByReference($issue['number']);
+
+        if ($user && $task) {
+
+            $event = array(
+                'project_id' => $this->project_id,
+                'task_id' => $task['id'],
+                'owner_id' => $user['id'],
+                'reference' => $issue['number'],
+            );
+
+            $this->container['dispatcher']->dispatch(
+                self::EVENT_ISSUE_ASSIGNEE_CHANGE,
+                new GenericEvent($event)
+            );
+
+            return true;
+        }
+
+        return false;
+    }
+
+    /**
+     * Handle unassigned issue
+     *
+     * @access public
+     * @param  array    $issue   Issue data
+     * @return boolean
+     */
+    public function handleIssueUnassigned(array $issue)
+    {
+        $task = $this->taskFinder->getByReference($issue['number']);
+
+        if ($task) {
+
+            $event = array(
+                'project_id' => $this->project_id,
+                'task_id' => $task['id'],
+                'owner_id' => 0,
+                'reference' => $issue['number'],
+            );
+
+            $this->container['dispatcher']->dispatch(
+                self::EVENT_ISSUE_ASSIGNEE_CHANGE,
+                new GenericEvent($event)
+            );
+
+            return true;
+        }
+
+        return false;
+    }
+
+    /**
+     * Handle labeled issue
+     *
+     * @access public
+     * @param  array    $issue   Issue data
+     * @param  array    $label   Label data
+     * @return boolean
+     */
+    public function handleIssueLabeled(array $issue, array $label)
+    {
+        $task = $this->taskFinder->getByReference($issue['number']);
+
+        if ($task) {
+
+            $event = array(
+                'project_id' => $this->project_id,
+                'task_id' => $task['id'],
+                'reference' => $issue['number'],
+                'label' => $label['name'],
+            );
+
+            $this->container['dispatcher']->dispatch(
+                self::EVENT_ISSUE_LABEL_CHANGE,
+                new GenericEvent($event)
+            );
+
+            return true;
+        }
+
+        return false;
+    }
+
+    /**
+     * Handle unlabeled issue
+     *
+     * @access public
+     * @param  array    $issue   Issue data
+     * @param  array    $label   Label data
+     * @return boolean
+     */
+    public function handleIssueUnlabeled(array $issue, array $label)
+    {
+        $task = $this->taskFinder->getByReference($issue['number']);
+
+        if ($task) {
+
+            $event = array(
+                'project_id' => $this->project_id,
+                'task_id' => $task['id'],
+                'reference' => $issue['number'],
+                'label' => $label['name'],
+                'category_id' => 0,
+            );
+
+            $this->container['dispatcher']->dispatch(
+                self::EVENT_ISSUE_LABEL_CHANGE,
+                new GenericEvent($event)
+            );
+
+            return true;
+        }
+
+        return false;
+    }
+}
diff --git a/app/Integration/GitlabWebhook.php b/app/Integration/GitlabWebhook.php
new file mode 100644
index 00000000..f5df32a6
--- /dev/null
+++ b/app/Integration/GitlabWebhook.php
@@ -0,0 +1,213 @@
+<?php
+
+namespace Integration;
+
+use Event\GenericEvent;
+use Event\TaskEvent;
+use Model\Task;
+
+/**
+ * Gitlab Webhook
+ *
+ * @package  integration
+ * @author   Frederic Guillot
+ */
+class GitlabWebhook extends Base
+{
+    /**
+     * Events
+     *
+     * @var string
+     */
+    const EVENT_ISSUE_OPENED           = 'gitlab.webhook.issue.opened';
+    const EVENT_ISSUE_CLOSED           = 'gitlab.webhook.issue.closed';
+    const EVENT_COMMIT                 = 'gitlab.webhook.commit';
+
+    /**
+     * Supported webhook events
+     *
+     * @var string
+     */
+    const TYPE_PUSH  = 'push';
+    const TYPE_ISSUE = 'issue';
+
+    /**
+     * Project id
+     *
+     * @access private
+     * @var integer
+     */
+    private $project_id = 0;
+
+    /**
+     * Set the project id
+     *
+     * @access public
+     * @param  integer   $project_id   Project id
+     */
+    public function setProjectId($project_id)
+    {
+        $this->project_id = $project_id;
+    }
+
+    /**
+     * Parse events
+     *
+     * @access public
+     * @param  array   $payload   Gitlab event
+     * @return boolean
+     */
+    public function parsePayload(array $payload)
+    {
+        switch ($this->getType($payload)) {
+            case self::TYPE_PUSH:
+                return $this->handlePushEvent($payload);
+            case self::TYPE_ISSUE;
+                return $this->handleIssueEvent($payload);
+        }
+
+        return false;
+    }
+
+    /**
+     * Get event type
+     *
+     * @access public
+     * @param  array   $payload   Gitlab event
+     * @return string
+     */
+    public function getType(array $payload)
+    {
+        if (isset($payload['object_kind']) && $payload['object_kind'] === 'issue') {
+            return self::TYPE_ISSUE;
+        }
+
+        if (isset($payload['commits'])) {
+            return self::TYPE_PUSH;
+        }
+
+        return '';
+    }
+
+    /**
+     * Parse push event
+     *
+     * @access public
+     * @param  array   $payload   Gitlab event
+     * @return boolean
+     */
+    public function handlePushEvent(array $payload)
+    {
+        foreach ($payload['commits'] as $commit) {
+            $this->handleCommit($commit);
+        }
+
+        return true;
+    }
+
+    /**
+     * Parse commit
+     *
+     * @access public
+     * @param  array   $commit   Gitlab commit
+     * @return boolean
+     */
+    public function handleCommit(array $commit)
+    {
+        $task_id = $this->task->getTaskIdFromText($commit['message']);
+
+        if (! $task_id) {
+            return false;
+        }
+
+        $task = $this->taskFinder->getById($task_id);
+
+        if (! $task) {
+            return false;
+        }
+
+        if ($task['is_active'] == Task::STATUS_OPEN && $task['project_id'] == $this->project_id) {
+
+            $this->container['dispatcher']->dispatch(
+                self::EVENT_COMMIT,
+                new TaskEvent(array('task_id' => $task_id) + $task)
+            );
+
+            return true;
+        }
+
+        return false;
+    }
+
+    /**
+     * Parse issue event
+     *
+     * @access public
+     * @param  array   $payload   Gitlab event
+     * @return boolean
+     */
+    public function handleIssueEvent(array $payload)
+    {
+        switch ($payload['object_attributes']['state']) {
+            case 'opened':
+                return $this->handleIssueOpened($payload['object_attributes']);
+            case 'closed':
+                return $this->handleIssueClosed($payload['object_attributes']);
+        }
+
+        return false;
+    }
+
+    /**
+     * Handle new issues
+     *
+     * @access public
+     * @param  array    $issue   Issue data
+     * @return boolean
+     */
+    public function handleIssueOpened(array $issue)
+    {
+        $event = array(
+            'project_id' => $this->project_id,
+            'reference' => $issue['id'],
+            'title' => $issue['title'],
+            'description' => $issue['description']."\n\n[".t('Gitlab Issue').']('.$issue['url'].')',
+        );
+
+        $this->container['dispatcher']->dispatch(
+            self::EVENT_ISSUE_OPENED,
+            new GenericEvent($event)
+        );
+
+        return true;
+    }
+
+    /**
+     * Handle issue closing
+     *
+     * @access public
+     * @param  array    $issue   Issue data
+     * @return boolean
+     */
+    public function handleIssueClosed(array $issue)
+    {
+        $task = $this->taskFinder->getByReference($issue['id']);
+
+        if ($task) {
+            $event = array(
+                'project_id' => $this->project_id,
+                'task_id' => $task['id'],
+                'reference' => $issue['id'],
+            );
+
+            $this->container['dispatcher']->dispatch(
+                self::EVENT_ISSUE_CLOSED,
+                new GenericEvent($event)
+            );
+
+            return true;
+        }
+
+        return false;
+    }
+}