harukin/core
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

make the queue api accessible to addons

Browse Source
This commit is contained in:
redmatrix 2015-12-21 17:00:42 -08:00
parent bc5a675cdf
commit 7a9fe0907a
2 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
include/queue_fn.php
View File

@ -88,6 +88,7 @@ function queue_deliver($outq, $immediate = false) {
} }
} }
else { else {
// zot sites should all have a site record, unless they've been dead for as long as // zot sites should all have a site record, unless they've been dead for as long as
// your site has existed. Since we don't know for sure what these sites are, // your site has existed. Since we don't know for sure what these sites are,
// call them unknown // call them unknown
@ -100,6 +101,11 @@ function queue_deliver($outq, $immediate = false) {
} }
} }
$arr = array('outq' => $outq, 'handled' => false, 'immediate' => $immediate);
call_hooks('queue_deliver',$arr);
if($arr['handled'])
return;
// "post" queue driver - used for diaspora and friendica-over-diaspora communications. // "post" queue driver - used for diaspora and friendica-over-diaspora communications.
if($outq['outq_driver'] === 'post') { if($outq['outq_driver'] === 'post') {
@ -122,7 +128,7 @@ function queue_deliver($outq, $immediate = false) {
else { else {
logger('deliver: queue post returned ' . $result['return_code'] logger('deliver: queue post returned ' . $result['return_code']
. ' from ' . $outq['outq_posturl'],LOGGER_DEBUG); . ' from ' . $outq['outq_posturl'],LOGGER_DEBUG);
update_queue_item($argv[$x]); update_queue_item($outq['outq_posturl']);
} }
return; return;
} }

2
version.inc
View File

@ -1 +1 @@
2015-12-20.1252 2015-12-21.1253