false,'message' => ''); $a = get_app(); $is_red = false; if(! allowed_url($url)) { $result['message'] = t('Channel is blocked on this site.'); return $result; } if(! $url) { $result['message'] = t('Channel location missing.'); return $result; } $arr = array('url' => $url, 'channel' => array()); call_hooks('follow', $arr); if($arr['channel']['success']) $ret = $arr['channel']; else $ret = zot_finger($url,$channel); if($ret['success']) { $is_red = true; $j = json_decode($ret['body'],true); } if($is_red && $j) { $my_perms = PERMS_W_STREAM|PERMS_W_MAIL; logger('follow: ' . $url . ' ' . print_r($j,true), LOGGER_DEBUG); if(! ($j['success'] && $j['guid'])) { $result['message'] = t('Response from remote channel was incomplete.'); logger('mod_follow: ' . $result['message']); return $result; } // Premium channel, set confirm before callback to avoid recursion if(array_key_exists('connect_url',$j) && (! $confirm)) goaway(zid($j['connect_url'])); // 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(! service_class_allows($uid,'total_channels',$total_channels)) { $result['message'] = upgrade_message(); return $result; } // do we have an xchan and hubloc? // If not, create them. $x = import_xchan($j); if(array_key_exists('deleted',$j) && intval($j['deleted'])) { $result['message'] = t('Channel was deleted and no longer exists.'); return $result; } if(! $x['success']) return $x; $xchan_hash = $x['hash']; $their_perms = 0; $global_perms = get_perms(); if( array_key_exists('permissions',$j) && array_key_exists('data',$j['permissions'])) { $permissions = crypto_unencapsulate(array( 'data' => $j['permissions']['data'], 'key' => $j['permissions']['key'], 'iv' => $j['permissions']['iv']), $channel['channel_prvkey']); if($permissions) $permissions = json_decode($permissions,true); logger('decrypted permissions: ' . print_r($permissions,true), LOGGER_DATA); } else $permissions = $j['permissions']; foreach($permissions as $k => $v) { if($v) { $their_perms = $their_perms | intval($global_perms[$k][1]); } } } else { // attempt network auto-discovery $my_perms = 0; $their_perms = 0; $xchan_hash = ''; } if(! $xchan_hash) { $result['message'] = t('Channel discovery failed.'); logger('follow: ' . $result['message']); return $result; } if((local_user()) && $uid == local_user()) { $aid = get_account_id(); $hash = get_observer_hash(); $ch = $a->get_channel(); $default_group = $ch['channel_default_group']; } else { $r = q("select * from channel where channel_id = %d limit 1", intval($uid) ); if(! $r) { $result['message'] = t('local account not found.'); return $result; } $aid = $r[0]['channel_account_id']; $hash = $r[0]['channel_hash']; $default_group = $r[0]['channel_default_group']; } if($hash == $xchan_hash) { $result['message'] = t('Cannot connect to yourself.'); return $result; } $r = q("select abook_xchan from abook where abook_xchan = '%s' and abook_channel = %d limit 1", dbesc($xchan_hash), intval($uid) ); if($r) { $x = q("update abook set abook_their_perms = %d where abook_id = %d limit 1", intval($their_perms), intval($r[0]['abook_id']) ); } else { $r = q("insert into abook ( abook_account, abook_channel, abook_xchan, abook_their_perms, abook_my_perms, abook_created, abook_updated ) values( %d, %d, '%s', %d, %d, '%s', '%s' ) ", intval($aid), intval($uid), dbesc($xchan_hash), intval($their_perms), intval($my_perms), dbesc(datetime_convert()), dbesc(datetime_convert()) ); } if(! $r) logger('mod_follow: abook creation failed'); $r = q("select abook.*, xchan.* from abook left join xchan on abook_xchan = xchan_hash where abook_xchan = '%s' and abook_channel = %d limit 1", dbesc($xchan_hash), intval($uid) ); if($r) { $result['abook'] = $r[0]; if($is_red) proc_run('php', 'include/notifier.php', 'permission_update', $result['abook']['abook_id']); } $arr = array('channel_id' => $uid, 'abook' => $result['abook']); call_hooks('follow', $arr); /** If there is a default group for this channel, add this member to it */ if($default_group) { require_once('include/group.php'); $g = group_rec_byhash($uid,$default_group); if($g) group_add_member($uid,'',$xchan_hash,$g['id']); } $result['success'] = true; return $result; }