natalie/indefero
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Call the configured download webhook when new downloads are created

Browse Source 
or existing downloads are updated.

This feature is sponsored by Scilab.
This commit is contained in:
Thomas Keller 2011-09-26 00:51:33 +02:00
parent b29acd71cb
commit 7ff298af79
4 changed files with 53 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
src/IDF/Commit.php
View File

@ -299,6 +299,7 @@ class IDF_Commit extends Pluf_Model
'project_id' => $project->id,
'authkey' => $project->getWebHookKey(),
'url' => $url,
'method' => 'POST',
);
$item = new IDF_Queue();
$item->type = 'new_commit';

7
src/IDF/Form/UpdateUpload.php
View File

@ -96,7 +96,7 @@ class IDF_Form_UpdateUpload extends Pluf_Form
$this->cleaned_data['label'.$i] = trim($this->cleaned_data['label'.$i]);
if (strpos($this->cleaned_data['label'.$i], ':') !== false) {
list($class, $name) = explode(':', $this->cleaned_data['label'.$i], 2);
list($class, $name) = array(mb_strtolower(trim($class)),
list($class, $name) = array(mb_strtolower(trim($class)),
trim($name));
} else {
$class = 'other';
@ -146,6 +146,9 @@ class IDF_Form_UpdateUpload extends Pluf_Form
$this->upload->modif_dtime = gmdate('Y-m-d H:i:s');
$this->upload->update();
$this->upload->batchAssoc('IDF_Tag', $tags);
// Send the notification
$this->upload->notify($this->project->getConf(), false);
/**
* [signal]
*
@ -166,7 +169,7 @@ class IDF_Form_UpdateUpload extends Pluf_Form
*
*/
$params = array('upload' => $this->upload);
Pluf_Signal::send('IDF_Upload::update',
Pluf_Signal::send('IDF_Upload::update',
'IDF_Form_UpdateUpload', $params);
return $this->upload;
}

39
src/IDF/Upload.php
View File

@ -234,6 +234,45 @@ class IDF_Upload extends Pluf_Model
*/
public function notify($conf, $create=true)
{
$project = $this->get_project();
$url = str_replace(array('%p', '%d'),
array($project->shortname, $this->id),
$conf->getVal('upload_webhook_url', ''));
$tags = array();
foreach ($this->get_tags_list() as $tag) {
$tags[] = $tag->class.':'.$tag->name;
}
$payload = array(
'to_send' => array(
'project' => $project->shortname,
'id' => $this->id,
'summary' => $this->summary,
'changelog' => $this->changelog,
'filename' => $this->file,
'filesize' => $this->filesize,
'md5sum' => $this->md5,
'tags' => $tags,
),
'project_id' => $project->id,
'authkey' => $project->getWebHookKey(),
'url' => $url,
);
if ($create === true) {
$payload['method'] = 'PUT';
$payload['to_send']['creation_date'] = $this->creation_dtime;
} else {
$payload['method'] = 'POST';
$payload['to_send']['update_date'] = $this->modif_dtime;
}
$item = new IDF_Queue();
$item->type = 'upload';
$item->payload = $payload;
$item->create();
if ('' == $conf->getVal('downloads_notification_email', '')) {
return;
}

16
src/IDF/Webhook.php
View File

@ -31,20 +31,20 @@
class IDF_Webhook
{
/**
* Perform the POST request given the webhook payload.
* Perform the request given the webhook payload.
*
* @param array Payload
* @return bool Success or error
*/
public static function postNotification($payload)
public static function processNotification($payload)
{
$data = json_encode($payload['to_send']);
$sign = hash_hmac('md5', $data, $payload['authkey']);
$params = array('http' => array(
'method' => 'POST',
'method' => empty($payload['method']) ? 'POST' : $payload['method'],
'content' => $data,
'user_agent' => 'Indefero Hook Sender (http://www.indefero.net)',
'max_redirects' => 0,
'max_redirects' => 0,
'timeout' => 15,
'header'=> 'Post-Commit-Hook-Hmac: '.$sign."\r\n"
.'Content-Type: application/json'."\r\n",
@ -61,7 +61,7 @@ class IDF_Webhook
if (!isset($meta['wrapper_data'][0]) or $meta['timed_out']) {
return false;
}
if (0 === strpos($meta['wrapper_data'][0], 'HTTP/1.1 2') or
if (0 === strpos($meta['wrapper_data'][0], 'HTTP/1.1 2') or
0 === strpos($meta['wrapper_data'][0], 'HTTP/1.1 3')) {
return true;
}
@ -76,11 +76,11 @@ class IDF_Webhook
public static function process($sender, &$params)
{
$item = $params['item'];
if ($item->type != 'new_commit') {
if (!in_array($item->type, array('new_commit', 'upload'))) {
// We do nothing.
return;
}
if (isset($params['res']['IDF_Webhook::process']) and
if (isset($params['res']['IDF_Webhook::process']) and
$params['res']['IDF_Webhook::process'] == true) {
// Already processed.
return;
@ -90,7 +90,7 @@ class IDF_Webhook
return;
}
// We have either to retry or to push for the first time.
$res = self::postNotification($item->payload);
$res = self::processNotification($item->payload);
if ($res) {
$params['res']['IDF_Webhook::process'] = true;
} elseif ($item->trials >= 9) {