aboutsummaryrefslogtreecommitdiffstats
path: root/include
diff options
context:
space:
mode:
authorfriendica <info@friendica.com>2013-01-01 23:56:27 -0800
committerfriendica <info@friendica.com>2013-01-01 23:56:27 -0800
commit50d1cb2e3afe265004c7c08c8a63876c4b541469 (patch)
tree917fa3317eac2ec6f2d23462775e83fab014ce9d /include
parent4d7fe15d3b31f7c5279b08c73e23cb21f906cd15 (diff)
downloadvolse-hubzilla-50d1cb2e3afe265004c7c08c8a63876c4b541469.tar.gz
volse-hubzilla-50d1cb2e3afe265004c7c08c8a63876c4b541469.tar.bz2
volse-hubzilla-50d1cb2e3afe265004c7c08c8a63876c4b541469.zip
start building social graph
Diffstat (limited to 'include')
-rw-r--r--include/onepoll.php18
-rw-r--r--include/socgraph.php145
2 files changed, 65 insertions, 98 deletions
diff --git a/include/onepoll.php b/include/onepoll.php
index 1d7ac226d..147d21430 100644
--- a/include/onepoll.php
+++ b/include/onepoll.php
@@ -94,19 +94,17 @@ function onepoll_run($argv, $argc){
// set last updated timestamp
-/*
- if($contact['poco']) {
- $r = q("SELECT count(*) as total from glink
- where `cid` = %d and updated > UTC_TIMESTAMP() - INTERVAL 1 DAY",
- intval($contact['id'])
+ $r = null;
+
+ if($contact['xchan_connurl']) {
+ $r = q("SELECT xlink_id from xlink
+ where xlink_xchan = '%s'and updated > UTC_TIMESTAMP() - INTERVAL 1 DAY",
+ intval($contact['xchan_hash'])
);
}
- if(count($r)) {
- if(! $r[0]['total']) {
- poco_load($contact['id'],$importer_uid,0,$contact['poco']);
- }
+ if($r) {
+ poco_load($contact['xchan_hash'],$contact['xchan_connurl']);
}
-*/
return;
}
diff --git a/include/socgraph.php b/include/socgraph.php
index a878c1683..250f61891 100644
--- a/include/socgraph.php
+++ b/include/socgraph.php
@@ -20,151 +20,120 @@ require_once('include/datetime.php');
-function poco_load($cid, $uid = 0,$zcid = 0,$url = null) {
+function poco_load($xchan = null,$url = null) {
$a = get_app();
- if($cid) {
- if((! $url) || (! $uid)) {
- $r = q("select `poco`, `uid` from `contact` where `id` = %d limit 1",
- intval($cid)
- );
- if(count($r)) {
- $url = $r[0]['poco'];
- $uid = $r[0]['uid'];
- }
+ if($xchan && ! $url) {
+ $r = q("select xchan_connurl from xchan where xchan_hash = %d limit 1",
+ intval($xchan)
+ );
+ if($r) {
+ $url = $r[0]['xchan_connurl'];
+ $uid = $r[0]['abook_channel'];
}
- if(! $uid)
- return;
}
if(! $url)
return;
- $url = $url . (($uid) ? '/@me/@all?fields=displayName,urls,photos' : '?fields=displayName,urls,photos') ;
- logger('poco_load: ' . $url, LOGGER_DEBUG);
+ $url = $url . '?fields=displayName,hash,urls,photos' ;
- $s = fetch_url($url);
+ logger('poco_load: ' . $url, LOGGER_DEBUG);
- logger('poco_load: returns ' . $s, LOGGER_DATA);
+ $s = z_fetch_url($url);
- logger('poco_load: return code: ' . $a->get_curl_code(), LOGGER_DEBUG);
+ logger('poco_load: returns ' . print_r($s,true), LOGGER_DATA);
- if(($a->get_curl_code() > 299) || (! $s))
+ if(! $s['success'])
return;
- $j = json_decode($s);
+ $j = json_decode($s['body'],true);
- logger('poco_load: json: ' . print_r($j,true),LOGGER_DATA);
+ logger('poco_load: ' . print_r($j,true),LOGGER_DATA);
- if(! isset($j->entry))
+ if(! x($j,'entry') && is_array($j['entry']))
return;
$total = 0;
- foreach($j->entry as $entry) {
+ foreach($j['entry'] as $entry) {
$total ++;
$profile_url = '';
$profile_photo = '';
- $connect_url = '';
+ $address = '';
$name = '';
+ $hash = '';
- $name = $entry->displayName;
+ $name = $entry['displayName'];
+ $hash = $entry['hash'];
- if(isset($entry->urls)) {
- foreach($entry->urls as $url) {
- if($url->type == 'profile') {
- $profile_url = $url->value;
+ if(x($entry,'urls') && is_array($entry['urls'])) {
+ foreach($entry['urls'] as $url) {
+ if($url['type'] == 'profile') {
+ $profile_url = $url['value'];
continue;
}
- if($url->type == 'webfinger') {
- $connect_url = str_replace('acct:' , '', $url->value);
+ if($url['type'] == 'zot') {
+ $address = str_replace('acct:' , '', $url['value']);
continue;
}
}
}
- if(isset($entry->photos)) {
- foreach($entry->photos as $photo) {
- if($photo->type == 'profile') {
- $profile_photo = $photo->value;
+ if(x($entry,'photos') && is_array($entry['photos'])) {
+ foreach($entry['photos'] as $photo) {
+ if($photo['type'] == 'profile') {
+ $profile_photo = $photo['value'];
continue;
}
}
}
- if((! $name) || (! $profile_url) || (! $profile_photo))
+ if((! $name) || (! $profile_url) || (! $profile_photo) || (! $hash) || (! $address))
continue;
- $x = q("select * from `gcontact` where `nurl` = '%s' limit 1",
- dbesc(normalise_link($profile_url))
+ $x = q("select xchan_hash from xchan where xchan_hash = '%s' limit 1",
+ dbesc($hash)
);
- if(count($x)) {
- $gcid = $x[0]['id'];
-
- if($x[0]['name'] != $name || $x[0]['photo'] != $profile_photo) {
- q("update gcontact set `name` = '%s', `photo` = '%s', `connect` = '%s', `url` = '%s'
- where `nurl` = '%s' limit 1",
- dbesc($name),
- dbesc($profile_photo),
- dbesc($connect_url),
- dbesc($profile_url),
- dbesc(normalise_link($profile_url))
- );
+ // We've never seen this person before. Import them.
+
+ if(($x !== false) && (! count($x))) {
+ if($address) {
+ $z = zot_finger($address,null);
+ if($z['success']) {
+ $j = json_decode($z['body'],true);
+ if($j)
+ import_xchan($j);
+ }
}
}
- else {
- q("insert into `gcontact` (`name`,`url`,`nurl`,`photo`,`connect`)
- values ( '%s', '%s', '%s', '%s','%s') ",
- dbesc($name),
- dbesc($profile_url),
- dbesc(normalise_link($profile_url)),
- dbesc($profile_photo),
- dbesc($connect_url)
- );
- $x = q("select * from `gcontact` where `nurl` = '%s' limit 1",
- dbesc(normalise_link($profile_url))
- );
- if(count($x))
- $gcid = $x[0]['id'];
- }
- if(! $gcid)
- return;
-
- $r = q("select * from glink where `cid` = %d and `uid` = %d and `gcid` = %d and `zcid` = %d limit 1",
- intval($cid),
- intval($uid),
- intval($gcid),
- intval($zcid)
+
+
+ $r = q("select * from xlink where xlink_xchan = '%s' and xlink_link = '%s' limit 1",
+ dbesc($xchan),
+ dbesc($hash)
);
- if(! count($r)) {
- q("insert into glink ( `cid`,`uid`,`gcid`,`zcid`, `updated`) values (%d,%d,%d,%d, '%s') ",
- intval($cid),
- intval($uid),
- intval($gcid),
- intval($zcid),
+ if(! $r) {
+ q("insert into xlink ( xlink_xchan, xlink_link, xlink_updated ) values ( '%s', '%s', '%s' ) ",
+ dbesc($xchan),
+ dbesc($hash),
dbesc(datetime_convert())
);
}
else {
- q("update glink set updated = '%s' where `cid` = %d and `uid` = %d and `gcid` = %d and zcid = %d limit 1",
+ q("update xlink set xlink_updated = '%s' where xlink_id = %d limit 1",
dbesc(datetime_convert()),
- intval($cid),
- intval($uid),
- intval($gcid),
- intval($zcid)
+ intval($r[0]['xlink_id'])
);
}
}
logger("poco_load: loaded $total entries",LOGGER_DEBUG);
- q("delete from glink where `cid` = %d and `uid` = %d and `zcid` = %d and `updated` < UTC_TIMESTAMP - INTERVAL 2 DAY",
- intval($cid),
- intval($uid),
- intval($zcid)
+ q("delete from xlink where xlink_xchan = '%s' and xlink_updated` < UTC_TIMESTAMP - INTERVAL 2 DAY",
+ dbesc($xchan)
);
-
}