add pubsubhubbub support to feed contacts
This commit is contained in:
parent
bb59c9c32a
commit
0a1697d13a
|
@ -2,6 +2,10 @@
|
||||||
|
|
||||||
require_once("boot.php");
|
require_once("boot.php");
|
||||||
|
|
||||||
|
function logger($txt, $lvl=""){
|
||||||
|
echo $txt."\n";
|
||||||
|
}
|
||||||
|
|
||||||
function RemoveReply($subject) {
|
function RemoveReply($subject) {
|
||||||
while (in_array(strtolower(substr($subject, 0, 3)), array("re:", "aw:")))
|
while (in_array(strtolower(substr($subject, 0, 3)), array("re:", "aw:")))
|
||||||
$subject = trim(substr($subject, 4));
|
$subject = trim(substr($subject, 4));
|
||||||
|
@ -541,10 +545,10 @@ function onepoll_run(&$argv, &$argc){
|
||||||
if($contact['network'] === NETWORK_DFRN || $contact['blocked'] || $contact['readonly'])
|
if($contact['network'] === NETWORK_DFRN || $contact['blocked'] || $contact['readonly'])
|
||||||
$hubmode = 'unsubscribe';
|
$hubmode = 'unsubscribe';
|
||||||
|
|
||||||
if($contact['network'] === NETWORK_OSTATUS && (! $contact['hub-verify']))
|
if(($contact['network'] === NETWORK_OSTATUS || $contact['network'] == NETWORK_FEED) && (! $contact['hub-verify']))
|
||||||
$hub_update = true;
|
$hub_update = true;
|
||||||
|
|
||||||
if((strlen($hub)) && ($hub_update) && ($contact['rel'] != CONTACT_IS_FOLLOWER)) {
|
if((strlen($hub)) && ($hub_update) && (($contact['rel'] != CONTACT_IS_FOLLOWER) || $contact['network'] == NETWORK_FEED) ) {
|
||||||
logger('poller: hub ' . $hubmode . ' : ' . $hub . ' contact name : ' . $contact['name'] . ' local user : ' . $importer['name']);
|
logger('poller: hub ' . $hubmode . ' : ' . $hub . ' contact name : ' . $contact['name'] . ' local user : ' . $importer['name']);
|
||||||
$hubs = explode(',', $hub);
|
$hubs = explode(',', $hub);
|
||||||
if(count($hubs)) {
|
if(count($hubs)) {
|
||||||
|
|
|
@ -121,11 +121,12 @@ function pubsub_post(&$a) {
|
||||||
$importer = $r[0];
|
$importer = $r[0];
|
||||||
|
|
||||||
$r = q("SELECT * FROM `contact` WHERE `subhub` = 1 AND `id` = %d AND `uid` = %d
|
$r = q("SELECT * FROM `contact` WHERE `subhub` = 1 AND `id` = %d AND `uid` = %d
|
||||||
AND ( `rel` = %d OR `rel` = %d ) AND `blocked` = 0 AND `readonly` = 0 LIMIT 1",
|
AND ( `rel` = %d OR `rel` = %d OR network = '%s' ) AND `blocked` = 0 AND `readonly` = 0 LIMIT 1",
|
||||||
intval($contact_id),
|
intval($contact_id),
|
||||||
intval($importer['uid']),
|
intval($importer['uid']),
|
||||||
intval(CONTACT_IS_SHARING),
|
intval(CONTACT_IS_SHARING),
|
||||||
intval(CONTACT_IS_FRIEND)
|
intval(CONTACT_IS_FRIEND),
|
||||||
|
dbesc(NETWORK_FEED)
|
||||||
);
|
);
|
||||||
|
|
||||||
if(! count($r)) {
|
if(! count($r)) {
|
||||||
|
|
Loading…
Reference in New Issue
Block a user