diff options
Diffstat (limited to 'include/deliver.php')
| -rw-r--r-- | include/deliver.php | 25 |
1 files changed, 18 insertions, 7 deletions
diff --git a/include/deliver.php b/include/deliver.php index df1596c10..546b75785 100644 --- a/include/deliver.php +++ b/include/deliver.php @@ -20,16 +20,27 @@ function deliver_run($argv, $argc) { dbesc($argv[$x]) ); if($r) { - $result = zot_zot($r[0]['outq_posturl'],$r[0]['outq_notify']); - if($result['success']) { - zot_process_response($result, $r[0]); - } - else { - $y = q("update outq set outq_updated = '%s' where outq_hash = '%s' limit 1", - dbesc(datetime_convert()), + if($r[0]['outq_posturl'] === z_root() . '/post') { + // local delivery + // we should probably batch these and save a few delivery processes + $msg = array('body' => json_encode(array('pickup' => array(array('notify' => json_decode($r[0]['outq_notify'],true),'message' => json_decode($r[0]['outq_msg'],true)))))); + zot_import($msg); + $r = q("delete from outq where outq_hash = '%s' limit 1", dbesc($argv[$x]) ); } + else { + $result = zot_zot($r[0]['outq_posturl'],$r[0]['outq_notify']); + if($result['success']) { + zot_process_response($result, $r[0]); + } + else { + $y = q("update outq set outq_updated = '%s' where outq_hash = '%s' limit 1", + dbesc(datetime_convert()), + dbesc($argv[$x]) + ); + } + } } } } |