From 2020ea23b106c159a705c26e6c79156aafde75ba Mon Sep 17 00:00:00 2001
From: fabrixxm <fabrix.xm@gmail.com>
Date: Mon, 24 Jan 2011 22:01:56 +0100
Subject: [PATCH] Mods to script runned via CLI to permits to run also included

---
 include/directory.php |  4 ++--
 include/notifier.php  | 39 ++++++++++++++++++++++-----------------
 include/poller.php    | 10 ++++++----
 include/queue.php     |  6 +++---
 4 files changed, 33 insertions(+), 26 deletions(-)

diff --git a/include/directory.php b/include/directory.php
index 5f835dc4bf..4fdcf49281 100644
--- a/include/directory.php
+++ b/include/directory.php
@@ -11,7 +11,7 @@
 
 
 	if($argc != 2)
-		exit;
+		return;
 
 	load_config('system');
 
@@ -24,5 +24,5 @@
 
 	fetch_url($dir . '?url=' . bin2hex($argv[1]));
 
-	exit;
+	return;
 
diff --git a/include/notifier.php b/include/notifier.php
index 4efdad4ce4..bb38ecf515 100644
--- a/include/notifier.php
+++ b/include/notifier.php
@@ -16,7 +16,7 @@
 	require_once('include/bbcode.php');
 
 	if($argc < 3)
-		exit;
+		return;
 
 	$a->set_baseurl(get_config('system','url'));
 
@@ -29,8 +29,9 @@
 		case 'mail':
 		default:
 			$item_id = intval($argv[2]);
-			if(! $item_id)
-				killme();
+			if(! $item_id){
+				killme(); return;
+			}
 			break;
 	}
 
@@ -42,8 +43,9 @@
 		$message = q("SELECT * FROM `mail` WHERE `id` = %d LIMIT 1",
 				intval($item_id)
 		);
-		if(! count($message))
-			killme();
+		if(! count($message)){
+			killme(); return;
+		}
 		$uid = $message[0]['uid'];
 		$recipients[] = $message[0]['contact-id'];
 		$item = $message[0];
@@ -55,8 +57,9 @@
 		$r = q("SELECT `parent`, `uid`, `edited` FROM `item` WHERE `id` = %d LIMIT 1",
 			intval($item_id)
 		);
-		if(! count($r))
-			killme();
+		if(! count($r)){
+			killme(); return;
+		}
 
 		$parent_id = $r[0]['parent'];
 		$uid = $r[0]['uid'];
@@ -66,8 +69,9 @@
 			intval($parent_id)
 		);
 
-		if(! count($items))
-			killme();
+		if(! count($items)){
+			killme(); return;
+		}
 	}
 
 	$r = q("SELECT `contact`.*, `user`.`nickname`, `user`.`sprvkey`, `user`.`spubkey`, `user`.`page-flags` 
@@ -78,9 +82,9 @@
 
 	if(count($r))
 		$owner = $r[0];
-	else
-		killme();
-
+	else {
+		killme(); return;
+	}
 	$hub = get_config('system','huburl');
 
 	// If this is a public conversation, notify the feed hub
@@ -150,8 +154,9 @@
 
 		$r = q("SELECT * FROM `contact` WHERE `id` IN ( $conversant_str ) AND `blocked` = 0 AND `pending` = 0");
 
-		if( ! count($r))
-			killme();
+		if( ! count($r)){
+			killme(); return;
+		}
 
 		$contacts = $r;
 	}
@@ -248,9 +253,9 @@
 	$r = q("SELECT * FROM `contact` WHERE `id` IN ( %s ) AND `blocked` = 0 ",
 		dbesc($recip_str)
 	);
-	if(! count($r))
-		killme();
-
+	if(! count($r)){
+		killme(); return;
+	}
 	// delivery loop
 
 	require_once('include/salmon.php');
diff --git a/include/poller.php b/include/poller.php
index 024b9fbcd3..a4bc607677 100644
--- a/include/poller.php
+++ b/include/poller.php
@@ -19,11 +19,12 @@
 	$a->set_baseurl(get_config('system','url'));
 
 	logger('poller: start');
-
+	
 	// run queue delivery process in the background
 
 	$php_path = ((x($a->config,'php_path') && strlen($a->config['php_path'])) ? $a->config['php_path'] : 'php');
-	proc_close(proc_open("\"$php_path\" \"include/queue.php\" &", array(), $foo));
+	//proc_close(proc_open("\"$php_path\" \"include/queue.php\" &", array(), $foo));
+	proc_run($php_path,"include/queue.php");
 
 
 	$hub_update = false;
@@ -46,8 +47,9 @@
 		$sql_extra 
 		AND `self` = 0 AND `blocked` = 0 AND `readonly` = 0 ORDER BY RAND()");
 
-	if(! count($contacts))
-		killme();
+	if(! count($contacts)){
+		killme(); return;
+	}
 
 	foreach($contacts as $contact) {
 
diff --git a/include/queue.php b/include/queue.php
index 96ddfa81bc..fae93e328b 100644
--- a/include/queue.php
+++ b/include/queue.php
@@ -50,9 +50,9 @@ function remove_queue_item($id) {
 		
 	$r = q("SELECT `id` FROM `queue` WHERE `last` < UTC_TIMESTAMP() - INTERVAL 15 MINUTE ");
 
-	if(! count($r))
-		killme();
-
+	if(! count($r)){
+		killme(); return;
+	}
 	// delivery loop
 
 	require_once('include/salmon.php');