diff options
Diffstat (limited to 'include/items.php')
| -rw-r--r-- | include/items.php | 41 |
1 files changed, 40 insertions, 1 deletions
diff --git a/include/items.php b/include/items.php index 688ef244a..d726e961c 100644 --- a/include/items.php +++ b/include/items.php @@ -577,7 +577,7 @@ function dfrn_deliver($contact,$atom,$debugging = false) { } -function consume_feed($xml,$importer,$contact) { +function consume_feed($xml,$importer,$contact, &$hub) { require_once('simplepie/simplepie.inc'); @@ -593,6 +593,12 @@ function consume_feed($xml,$importer,$contact) { $photo_timestamp = ''; $photo_url = ''; + + $foundhub = $feed->get_link(0,'hub'); + + if(strlen($foundhub)) + $hub = $foundhub; + $rawtags = $feed->get_feed_tags( SIMPLEPIE_NAMESPACE_ATOM_10, 'author'); if($rawtags) { $elems = $rawtags[0]['child'][SIMPLEPIE_NAMESPACE_ATOM_10]; @@ -808,4 +814,37 @@ function consume_feed($xml,$importer,$contact) { } } +} + + +function subscribe_to_hub($url,$importer,$contact) { + + if(is_array($importer)) { + $r = q("SELECT `nickname` FROM `user` WHERE `uid` = %d LIMIT 1", + intval($importer['uid']) + ); + } + if(! count($r)) + return; + + $params = array(); + + $push_url = get_config('system','url') . '/pubsub/' . $r[0]['nickname'] . '/' . $contact['id']; + + $verify_token = random_string(); + + $params['hub.mode'] = 'subscribe'; + $params['hub.callback'] = urlencode($push_url); + $params['hub.topic'] = urlencode($contact['poll']); + $params['hub.verify'] = 'async'; + $params['hub.verify_token'] = $verify_token; + + $r = q("UPDATE `contact` SET `hub-verify` = '%s' WHERE `id` = %d LIMIT 1", + dbesc($verify_token), + intval($contact['id']) + ); + + post_url($url,$params); + return; + }
\ No newline at end of file |