local delivery

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])
+					);
+				}
+			}
 		}
 	}
 }