poco debugging cont.

2 files changed, 23 insertions, 7 deletions

diff --git a/include/onepoll.php b/include/onepoll.php
index 99c6df998..5bc7742d1 100644
--- a/include/onepoll.php
+++ b/include/onepoll.php
@@ -4,6 +4,8 @@ require_once('boot.php');
 require_once('include/cli_startup.php');
 require_once('include/zot.php');
 require_once('include/socgraph.php');
+require_once('include/Contact.php');
+
 
 function onepoll_run($argv, $argc){
 
@@ -68,7 +70,7 @@ function onepoll_run($argv, $argc){
 
 	logger("onepoll: poll: ({$contact['id']}) IMPORTER: {$importer['xchan_name']}, CONTACT: {$contact['xchan_name']}");
 
-	$last_update = (($contact['last_update'] === '0000-00-00 00:00:00') 
+	$last_update = (($contact['abook_updated'] === '0000-00-00 00:00:00') 
 		? datetime_convert('UTC','UTC','now - 7 days')
 		: datetime_convert('UTC','UTC',$contact['abook_updated'])
 	);
@@ -77,20 +79,27 @@ function onepoll_run($argv, $argc){
 
 	$x = zot_refresh($contact,$importer);
 
+	$responded = false;
+
 	if(! $x) {
 		// mark for death
 
 	}
 	else {
-		q("update abook set abook_updated = '%s' where abook_id = %d limit 1",
+		q("update abook set abook_updated = '%s', abook_connected = '%s' where abook_id = %d limit 1",
+			dbesc(datetime_convert()),
 			dbesc(datetime_convert()),
 			intval($contact['abook_id'])
 		);
+		$responded = true;
 
 		// if marked for death, reset
 
 	}
 
+	if(! $responded)
+		return;
+
 	if($contact['xchan_connurl']) {
 		$feedurl = str_replace('/poco/','/zotfeed/',$channel['xchan_connurl']);
 		
diff --git a/include/socgraph.php b/include/socgraph.php
index 081927dcc..dd7fa90d4 100644
--- a/include/socgraph.php
+++ b/include/socgraph.php
@@ -31,8 +31,10 @@ function poco_load($xchan = null,$url = null) {
 		}
 	}
 
-	if(! $url)
+	if(! $url) {
+		logger('poco_load: no url');
 		return;
+	}
 
 
 	$url = $url . '?fields=displayName,hash,urls,photos' ;
@@ -41,17 +43,20 @@ function poco_load($xchan = null,$url = null) {
 
 	$s = z_fetch_url($url);
 
-	logger('poco_load: returns ' . print_r($s,true), LOGGER_DATA);
 
-	if(! $s['success'])
+	if(! $s['success']) {
+		logger('poco_load: returns ' . print_r($s,true));
 		return;
+	}
 
 	$j = json_decode($s['body'],true);
 
 	logger('poco_load: ' . print_r($j,true),LOGGER_DATA);
 
-	if(! x($j,'entry') && is_array($j['entry']))
+	if(! ((x($j,'entry')) && (is_array($j['entry'])))) {
+		logger('poco_load: no entries');
 		return;
+	}
 
 	$total = 0;
 	foreach($j['entry'] as $entry) {
@@ -87,8 +92,10 @@ function poco_load($xchan = null,$url = null) {
 			}
 		}
 
-		if((! $name) || (! $profile_url) || (! $profile_photo) || (! $hash) || (! $address))
+		if((! $name) || (! $profile_url) || (! $profile_photo) || (! $hash) || (! $address)) {
+			logger('poco_load: missing data');
 			continue; 
+		}
 		 
 		$x = q("select xchan_hash from xchan where xchan_hash = '%s' limit 1",
 			dbesc($hash)