summaryrefslogtreecommitdiff
path: root/app/Integration/SlackWebhook.php
blob: e216ed5b31b62a465dbf5506f01ddb277cb3008d (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
<?php

namespace Kanboard\Integration;

/**
 * Slack Webhook
 *
 * @package  integration
 * @author   Frederic Guillot
 */
class SlackWebhook extends \Kanboard\Core\Base
{
    /**
     * Return true if Slack is enabled for this project or globally
     *
     * @access public
     * @param  integer  $project_id
     * @return boolean
     */
    public function isActivated($project_id)
    {
        return $this->config->get('integration_slack_webhook') == 1 || $this->projectIntegration->hasValue($project_id, 'slack', 1);
    }

    /**
     * Get wehbook url
     *
     * @access public
     * @param  integer  $project_id
     * @return string
     */
    public function getWebhookUrl($project_id)
    {
        if ($this->config->get('integration_slack_webhook') == 1) {
            return $this->config->get('integration_slack_webhook_url');
        }

        $options = $this->projectIntegration->getParameters($project_id);
        return isset($options['slack_webhook_url']) ? $options['slack_webhook_url'] : '';
    }

    /**
     * Get optional Slack channel
     *
     * @access public
     * @param  integer  $project_id
     * @return string
     */
    public function getChannel($project_id)
    {
        $channel = $this->config->get('integration_slack_webhook_channel');

        if (! empty($channel)) {
            return $channel;
        }

        $options = $this->projectIntegration->getParameters($project_id);
        return isset($options['slack_webhook_channel']) ? $options['slack_webhook_channel'] : '';
    }

    /**
     * Send notification to Slack
     *
     * @access public
     * @param  integer     $project_id      Project id
     * @param  integer     $task_id         Task id
     * @param  string      $event_name      Event name
     * @param  array       $event           Event data
     */
    public function notify($project_id, $task_id, $event_name, array $event)
    {
        if ($this->isActivated($project_id)) {

            $project = $this->project->getbyId($project_id);

            $event['event_name'] = $event_name;
            $event['author'] = $this->user->getFullname($this->session['user']);

            $message = '*['.$project['name'].']* ';
            $message .= str_replace('&quot;', '"', $this->projectActivity->getTitle($event));
            $message .= isset($event['task']['title']) ? ' ('.$event['task']['title'].')' : '';

            if ($this->config->get('application_url')) {
                $message .= ' - <'.$this->helper->url->href('task', 'show', array('task_id' => $task_id, 'project_id' => $project_id), false, '', true);
                $message .= '|'.t('view the task on Kanboard').'>';
            }

            $this->sendMessage($project_id, $message);
        }
    }

    /**
     * Send message to Slack
     *
     * @access public
     * @param  integer  $project_id
     * @param  string   $message
     */
    public function sendMessage($project_id, $message)
    {
        $payload = array(
            'text' => $message,
            'username' => 'Kanboard',
            'icon_url' => 'http://kanboard.net/assets/img/favicon.png',
        );

        $this->sendPayload($project_id, $payload);
    }

    /**
     * Send payload to Slack
     *
     * @access public
     * @param  integer  $project_id
     * @param  array    $payload
     */
    public function sendPayload($project_id, array $payload)
    {
        $channel = $this->getChannel($project_id);

        if (! empty($channel)) {
            $payload['channel'] = $channel;
        }

        $this->httpClient->postJson($this->getWebhookUrl($project_id), $payload);
    }
}