From d4657c89c2e69d06941d687c570e914c62ab2d06 Mon Sep 17 00:00:00 2001 From: friendica Date: Thu, 1 Nov 2012 01:54:51 -0700 Subject: merging zot_finger schema additions --- include/follow.php | 138 +++++++++++++++++------------------------------------ 1 file changed, 45 insertions(+), 93 deletions(-) (limited to 'include/follow.php') diff --git a/include/follow.php b/include/follow.php index 47163fb73..058e77b89 100644 --- a/include/follow.php +++ b/include/follow.php @@ -31,8 +31,8 @@ function new_contact($uid,$url,$channel,$interactive = false) { call_hooks('follow', $arr); - if(x($arr['contact'],'name')) - $ret = $arr['contact']; + if($arr['channel']['success'])) + $ret = $arr['channel']; else $ret = zot_finger($url,$channel,false); @@ -41,118 +41,70 @@ function new_contact($uid,$url,$channel,$interactive = false) { } -// logger('follow: ' . print_r($j,true)); + logger('follow: ' . $url . ' ' . print_r($j,true)); killme(); - if($ret['network'] === NETWORK_DFRN) { - if($interactive) { - if(strlen($a->path)) - $myaddr = bin2hex($a->get_baseurl() . '/channel/' . $a->user['nickname']); - else - $myaddr = bin2hex($a->user['nickname'] . '@' . $a->get_hostname()); - - goaway($ret['request'] . "&addr=$myaddr"); - - // NOTREACHED - } - } - else { - if(get_config('system','dfrn_only')) { - $result['message'] = t('This site is not configured to allow communications with other networks.') . EOL; - $result['message'] != t('No compatible communication protocols or feeds were discovered.') . EOL; - return $result; - } - } - - // do we have enough information? - - if(! ((x($ret,'name')) && (x($ret,'poll')) && ((x($ret,'url')) || (x($ret,'addr'))))) { - $result['message'] .= t('The profile address specified does not provide adequate information.') . EOL; - if(! x($ret,'poll')) - $result['message'] .= t('No compatible communication protocols or feeds were discovered.') . EOL; - if(! x($ret,'name')) - $result['message'] .= t('An author or name was not found.') . EOL; - if(! x($ret,'url')) - $result['message'] .= t('No browser URL could be matched to this address.') . EOL; - if(strpos($url,'@') !== false) { - $result['message'] .= t('Unable to match @-style Identity Address with a known protocol or email contact.') . EOL; - $result['message'] .= t('Use mailto: in front of address to force email check.') . EOL; - } + if(! ($j->success && $j->guid)) { + $result['message'] = t('Unable to communicate with requested channel.'); return $result; } - if($ret['network'] === NETWORK_OSTATUS && get_config('system','ostatus_disabled')) { - $result['message'] .= t('The profile address specified belongs to a network which has been disabled on this site.') . EOL; - $ret['notify'] = ''; - } - - - + // check service class limits + $r = q("select count(*) as total from abook where abook_channel = %d and not (abook_flags & %d)", + intval($uid), + intval(ABOOK_FLAG_SELF) + ); + if($r) + $total_channels = $r[0]['total']; - if(! $ret['notify']) { - $result['message'] .= t('Limited profile. This person will be unable to receive direct/personal notifications from you.') . EOL; + if(! service_class_allows($uid,'total_channels',$total_channels)) { + $result['message'] .= upgrade_message(); + return $result; } - $writeable = ((($ret['network'] === NETWORK_OSTATUS) && ($ret['notify'])) ? 1 : 0); - - - $hidden = 0; + // do we have an xchan and hubloc? + // If not, create them. + + $xchan_hash = base64_urlencode(hash('whirlpool',$j->quid . $j->guid_sg, true)); + + $r = q("select * from xchan where xchan_hash = '%s' limit 1", + dbesc($xchan_hash) + ); + if(! $r) { + $x = q("insert into xchan ( xchan_hash, xchan_guid, xchan_guid_sig, xchan_pubkey, xchan_photo_mimetype, + xchan_photo_l, xchan_addr, xchan_url, xchan_name, xchan_network, xchan_photo_date, xchan_name_date) + values ( '%s', '%s', '%s', '%s' , '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s') ", + dbesc($xchan_hash), + dbesc($j->guid), + dbesc($j->guid_sig), + dbesc($j->key), + dbesc($j->photo_mimetype), + dbesc($j->photo), + dbesc($j->address), + dbesc($j->url), + dbesc($j->name), + dbesc('zot'), + dbesc($j->photo_updated), + dbesc($j->name_updated) + ); + } - // check if we already have a contact - // the poll url is more reliable than the profile url, as we may have - // indirect links or webfinger links - $r = q("SELECT * FROM `contact` WHERE `uid` = %d AND `poll` = '%s' LIMIT 1", - intval($uid), - dbesc($ret['poll']) - ); - - - if(count($r)) { - // update contact - if($r[0]['rel'] == CONTACT_IS_FOLLOWER || ($network === NETWORK_DIASPORA && $r[0]['rel'] == CONTACT_IS_SHARING)) { - q("UPDATE `contact` SET `rel` = %d , `readonly` = 0 WHERE `id` = %d AND `uid` = %d LIMIT 1", - intval(CONTACT_IS_FRIEND), - intval($r[0]['id']), - intval($uid) - ); - } - } - else { - // check service class limits + // Do we already have an abook entry? + // go directly to the abook edit page. - $r = q("select count(*) as total from contact where uid = %d and pending = 0 and self = 0", - intval($uid) - ); - if(count($r)) - $total_contacts = $r[0]['total']; - if(! service_class_allows($uid,'total_contacts',$total_contacts)) { - $result['message'] .= upgrade_message(); - return $result; - } - $r = q("select count(network) as total from contact where uid = %d and network = '%s' and pending = 0 and self = 0", - intval($uid), - dbesc($network) - ); - if(count($r)) - $total_network = $r[0]['total']; + - if(! service_class_allows($uid,'total_contacts_' . $network,$total_network)) { - $result['message'] .= upgrade_message(); - return $result; - } - $new_relation = (($ret['network'] === NETWORK_MAIL) ? CONTACT_IS_FRIEND : CONTACT_IS_SHARING); - // create contact record - $r = q("INSERT INTO `contact` ( `uid`, `created`, `url`, `nurl`, `addr`, `alias`, `batch`, `notify`, `poll`, `poco`, `name`, `nick`, `photo`, `network`, `pubkey`, `rel`, `priority`, + $r = q("INSERT INTO `contact` ( `uid`, `created`, `url`, `nurl`, `addr`, `alias`, `batch`, `notify`, `poll`, `poco`, `name`, `nick`, `photo`, `network`, `pubkey`, `rel`, `priority`, `writable`, `hidden`, `blocked`, `readonly`, `pending` ) VALUES ( %d, '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', %d, %d, %d, %d, 0, 0, 0) ", intval($uid), -- cgit v1.2.3