keith/friendica
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

add queue_deliver plugin hook

Browse source
This commit is contained in:
Friendika 2011-06-02 18:26:06 -07:00
parent 2fcb5922c3
commit 1eb177235b
1 changed files with 14 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
include/queue.php
View file

@ -97,7 +97,7 @@ function queue_run($argv, $argc){
$deliver_status = 0; $deliver_status = 0;
switch($contact['network']) { switch($contact['network']) {
case 'dfrn': case NETWORK_DFRN:
logger('queue: dfrndelivery: item ' . $q_item['id'] . ' for ' . $contact['name']); logger('queue: dfrndelivery: item ' . $q_item['id'] . ' for ' . $contact['name']);
$deliver_status = dfrn_deliver($owner,$contact,$data); $deliver_status = dfrn_deliver($owner,$contact,$data);
@ -109,7 +109,7 @@ function queue_run($argv, $argc){
remove_queue_item($q_item['id']); remove_queue_item($q_item['id']);
} }
break; break;
default: case NETWORK_OSTATUS:
if($contact['notify']) { if($contact['notify']) {
logger('queue: slapdelivery: item ' . $q_item['id'] . ' for ' . $contact['name']); logger('queue: slapdelivery: item ' . $q_item['id'] . ' for ' . $contact['name']);
$deliver_status = slapper($owner,$contact['notify'],$data); $deliver_status = slapper($owner,$contact['notify'],$data);
@ -120,6 +120,18 @@ function queue_run($argv, $argc){
remove_queue_item($q_item['id']); remove_queue_item($q_item['id']);
} }
break; break;
default:
$a = get_app();
$params = array('owner' => $owner, 'contact' => $contact, 'queue' => $q_item, 'result' => false);
call_hooks('queue_deliver', $a, $params);
if($params['result'])
remove_queue_item($q_item['id']);
else
update_queue_time($q_item['id']);
break;
} }
} }