'salmon', 'href' => z_root() . '/salmon/' . $b['channel']['channel_address']);
$b['result']['links'][] = array('rel' => 'http://salmon-protocol.org/ns/salmon-replies', 'href' => z_root() . '/salmon/' . $b['channel']['channel_address']);
$b['result']['links'][] = array('rel' => 'http://salmon-protocol.org/ns/salmon-mention', 'href' => z_root() . '/salmon/' . $b['channel']['channel_address']);
}
function gnusoc_personal_xrd(&$a,&$b) {
$b['xml'] = str_replace('',
'' . "\r\n" . '' . "\r\n" . '' . "\r\n" . '', $b['xml']);
}
function gnusoc_follow_allow(&$a, &$b) {
if($b['xchan']['xchan_network'] !== 'gnusoc')
return;
$allowed = get_pconfig($b['channel_id'],'system','gnusoc_allowed');
if($allowed === false)
$allowed = 1;
$b['allowed'] = $allowed;
$b['singleton'] = 1; // this network does not support channel clones
}
function gnusoc_follow_local(&$a,&$b) {
require_once('addon/pubsubhubbub/pubsubhubbub.php');
if($b['abook']['abook_xchan'] && $b['abook']['xchan_network'] === 'gnusoc') {
$hubs = get_xconfig($b['abook']['abook_xchan'],'system','push_hubs');
if($hubs) {
foreach($hubs as $hub) {
pubsubhubbub_subscribe($hub,$b['channel'],$b['abook'],'',$hubmode = 'subscribe');
}
}
}
}
function gnusoc_feature_settings_post(&$a,&$b) {
if($_POST['gnusoc-submit']) {
set_pconfig(local_channel(),'system','gnusoc_allowed',intval($_POST['gnusoc_allowed']));
info( t('GNU-Social Protocol Settings updated.') . EOL);
}
}
function gnusoc_feature_settings(&$a,&$s) {
$gnusoc_allowed = get_pconfig(local_channel(),'system','gnusoc_allowed');
if($gnusoc_allowed === false)
$gnus_allowed = get_config('gnusoc','allowed');
$sc .= replace_macros(get_markup_template('field_checkbox.tpl'), array(
'$field' => array('gnusoc_allowed', t('Enable the (experimental) GNU-Social protocol for this channel'), $gnusoc_allowed, '', $yes_no),
));
$s .= replace_macros(get_markup_template('generic_addon_settings.tpl'), array(
'$addon' => array('gnusoc', '
' . t('GNU-Social Protocol Settings'), '', t('Submit')),
'$content' => $sc
));
return;
}
function get_salmon_key($uri,$keyhash) {
$ret = array();
logger('Fetching salmon key for ' . $uri, LOGGER_DEBUG, LOG_INFO);
$x = webfinger_rfc7033($uri,true);
logger('webfinger returns: ' . print_r($x,true), LOGGER_DATA, LOG_DEBUG);
if($x && array_key_exists('links',$x) && $x['links']) {
foreach($x['links'] as $link) {
if(array_key_exists('rel',$link) && $link['rel'] === 'magic-public-key') {
$ret[] = $link['href'];
}
}
}
else {
$arr = old_webfinger($uri);
logger('old webfinger returns: ' . print_r($arr,true), LOGGER_DATA, LOG_DEBUG);
if(is_array($arr)) {
foreach($arr as $a) {
if($a['@attributes']['rel'] === 'magic-public-key') {
$ret[] = $a['@attributes']['href'];
}
}
}
else {
return '';
}
}
// We have found at least one key URL
// If it's inline, parse it - otherwise get the key
if(count($ret)) {
for($x = 0; $x < count($ret); $x ++) {
if(substr($ret[$x],0,5) === 'data:') {
$ret[$x] = convert_salmon_key($ret[$x]);
}
}
}
logger('Key located: ' . print_r($ret,true), LOGGER_DEBUG, LOG_INFO);
if(count($ret) == 1) {
// We only found one one key so we don't care if the hash matches.
// If it's the wrong key we'll find out soon enough because
// message verification will fail. This also covers some older
// software which don't supply a keyhash. As long as they only
// have one key we'll be right.
return $ret[0];
}
else {
foreach($ret as $a) {
$hash = base64url_encode(hash('sha256',$a));
if($hash == $keyhash)
return $a;
}
}
return '';
}
function slapper($owner,$url,$slap) {
// does contact have a salmon endpoint?
if(! strlen($url))
return;
if(! $owner['channel_prvkey']) {
logger(sprintf("channel '%s' (%d) does not have a salmon private key. Send failed.",
$owner['channel_address'],$owner['channel_id']));
return;
}
logger('slapper called for ' .$url . '. Data: ' . $slap, LOGGER_DATA, LOG_DEBUG);
// create a magic envelope
$data = base64url_encode($slap, false); // do not strip padding
$data_type = 'application/atom+xml';
$encoding = 'base64url';
$algorithm = 'RSA-SHA256';
$keyhash = base64url_encode(hash('sha256',salmon_key($owner['channel_pubkey'])),true);
$data = str_replace(array(" ","\t","\r","\n"),array("","","",""),$data);
// precomputed base64url encoding of data_type, encoding, algorithm concatenated with periods
$precomputed = '.YXBwbGljYXRpb24vYXRvbSt4bWw=.YmFzZTY0dXJs.UlNBLVNIQTI1Ng==';
$signature = base64url_encode(rsa_sign($data . $precomputed,$owner['channel_prvkey']));
$salmon_tpl = get_markup_template('magicsig.tpl','addon/gnusoc/');
$salmon = replace_macros($salmon_tpl,array(
'$data' => $data,
'$encoding' => $encoding,
'$algorithm' => $algorithm,
'$keyhash' => $keyhash,
'$signature' => $signature
));
logger('salmon: ' . $salmon, LOGGER_DATA);
$hash = random_string();
queue_insert(array(
'hash' => $hash,
'account_id' => $owner['channel_account_id'],
'channel_id' => $owner['channel_id'],
'driver' => 'slap',
'posturl' => $url,
'notify' => '',
'msg' => $salmon,
));
return $hash;
}
function gnusoc_queue_deliver(&$a,&$b) {
$outq = $b['outq'];
if($outq['outq_driver'] !== 'slap')
return;
$b['handled'] = true;
$headers = array(
'Content-type: application/magic-envelope+xml',
'Content-length: ' . strlen($outq['outq_msg']));
$counter = 0;
$result = z_post_url($outq['outq_posturl'], $outq['outq_msg'], $counter, array('headers' => $headers, 'novalidate' => true));
if($result['success'] && $result['return_code'] < 300) {
logger('slap_deliver: queue post success to ' . $outq['outq_posturl'], LOGGER_DEBUG);
if($b['base']) {
q("update site set site_update = '%s', site_dead = 0 where site_url = '%s' ",
dbesc(datetime_convert()),
dbesc($b['base'])
);
}
q("update dreport set dreport_result = '%s', dreport_time = '%s' where dreport_queue = '%s' limit 1",
dbesc('accepted for delivery'),
dbesc(datetime_convert()),
dbesc($outq['outq_hash'])
);
remove_queue_item($outq['outq_hash']);
}
else {
logger('slap_deliver: queue post returned ' . $result['return_code']
. ' from ' . $outq['outq_posturl'],LOGGER_DEBUG);
update_queue_item($outq['outq_hash']);
}
return;
}
function gnusoc_remote_follow($channel,$xchan) {
$slap = replace_macros(get_markup_template('follow_slap.tpl','addon/gnusoc/'),array(
'$name' => xmlify($channel['channel_name']),
'$nick' => xmlify($channel['channel_address']),
'$profile_page' => xmlify(z_root() . '/channel/' . $channel['channel_address']),
'$thumb' => xmlify($channel['xchan_photo_l']),
'$item_id' => z_root() . '/display/' . xmlify(random_string()),
'$title' => xmlify(t('Follow')),
'$published' => datetime_convert('UTC','UTC','now',ATOM_TIME),
'$type' => 'html',
'$content' => xmlify(sprintf( t('%1$s is now following %2$s'),$channel['channel_name'],$xchan['xchan_name'])),
'$remote_profile' => xmlify($xchan['xchan_url']),
'$remote_photo' => xmlify($xchan['xchan_photo_l']),
'$remote_thumb' => xmlify($xchan['xchan_photo_m']),
'$remote_nick' => xmlify(substr($xchan['xchan_addr'],0,strpos($xchan['xchan_addr'],'@'))),
'$remote_name' => xmlify($xchan['xchan_name']),
'$verb' => xmlify(ACTIVITY_FOLLOW),
'$ostat_follow' => ''
));
logger('follow xml: ' . $slap, LOGGER_DATA);
$deliver = '';
$y = q("select * from hubloc where hubloc_hash = '%s'",
dbesc($xchan['xchan_hash'])
);
if($y) {
$deliver = slapper($channel,$y[0]['hubloc_callback'],$slap);
}
return $deliver;
}
function gnusoc_permissions_create(&$a,&$b) {
if($b['recipient']['xchan_network'] === 'gnusoc') {
$b['deliveries'] = gnusoc_remote_follow($b['sender'],$b['recipient']);
if($b['deliveries'])
$b['success'] = 1;
}
}
function gnusoc_notifier_process(&$a,&$b) {
logger('notifier process gnusoc');
if(! ($b['normal_mode'] || $b['relay_to_owner']))
return;
if($b['private'] || $b['packet_type'] || $b['mail'])
return;
if($b['target_item']['public_policy']) {
logger('non-public post');
return;
}
if($b['top_level_post']) {
// should have been processed by pubsubhubub
logger('not a comment');
return;
}
$channel = $b['channel'];
if(! perm_is_allowed($channel['channel_id'],'','view_stream'))
return;
// find gnusoc subscribers following this $owner
$r = q("select * from abook left join hubloc on abook_xchan = hubloc_hash where hubloc_network = 'gnusoc' and abook_channel = %d",
intval($channel['channel_id'])
);
if(! $r)
return;
$recips = array();
foreach($r as $rr) {
if(perm_is_allowed($channel['channel_id'],$rr['hubloc_hash'],'view_stream'))
$recips[] = $rr['hubloc_hash'];
}
if(! $recips)
return;
$slap = get_atom_entry($target_item,'html',null,null,false);
$slap = str_replace('','',$slap);
foreach($recips as $recip) {
$h = slapper($channel,$recip['hubloc_callback'],$slap);
$b['queued'][] = $h;
}
}
function gnusoc_follow_from_feed(&$a,&$b) {
$item = $b['item'];
$importer = $b['channel'];
$xchan = $b['xchan'];
$author = $b['author'];
$b['caught'] = true;
logger('follow activity received');
if(($author) && (! $xchan)) {
$r = q("select * from xchan where xchan_guid = '%s' limit 1",
dbesc($author['author_link'])
);
if(! $r) {
if(discover_by_webbie($author['author_link'])) {
$r = q("select * from xchan where xchan_guid = '%s' limit 1",
dbesc($author['author_link'])
);
if(! $r) {
logger('discovery failed');
return;
}
}
$xchan = $r[0];
}
$r = q("select * from abook where abook_channel = %d and abook_xchan = '%s' limit 1",
intval($importer['channel_id']),
dbesc($xchan['xchan_hash'])
);
if($r) {
$contact = $r[0];
$newperms = PERMS_R_STREAM|PERMS_R_PROFILE|PERMS_R_PHOTOS|PERMS_R_ABOOK|PERMS_W_STREAM|PERMS_W_COMMENT|PERMS_W_MAIL|PERMS_W_CHAT|PERMS_R_STORAGE|PERMS_R_PAGES;
$abook_instance = $contact['abook_instance'];
if($abook_instance)
$abook_instance .= ',';
$abook_instance .= z_root();
$r = q("update abook set abook_their_perms = %d, abook_instance = '%s' where abook_id = %d and abook_channel = %d",
intval($newperms),
dbesc($abook_instance),
intval($contact['abook_id']),
intval($importer['channel_id'])
);
}
else {
$role = get_pconfig($importer['channel_id'],'system','permissions_role');
if($role) {
$x = get_role_perms($role);
if($x['perms_auto'])
$default_perms = $x['perms_accept'];
}
if(! $default_perms)
$default_perms = intval(get_pconfig($importer['channel_id'],'system','autoperms'));
$their_perms = PERMS_R_STREAM|PERMS_R_PROFILE|PERMS_R_PHOTOS|PERMS_R_ABOOK|PERMS_W_STREAM|PERMS_W_COMMENT|PERMS_W_MAIL|PERMS_W_CHAT|PERMS_R_STORAGE|PERMS_R_PAGES;
$closeness = get_pconfig($importer['channel_id'],'system','new_abook_closeness');
if($closeness === false)
$closeness = 80;
$r = q("insert into abook ( abook_account, abook_channel, abook_xchan, abook_my_perms, abook_their_perms, abook_closeness, abook_created, abook_updated, abook_connected, abook_dob, abook_pending, abook_instance ) values ( %d, %d, '%s', %d, %d, %d, '%s', '%s', '%s', '%s', %d, '%s' )",
intval($importer['channel_account_id']),
intval($importer['channel_id']),
dbesc($xchan['xchan_hash']),
intval($default_perms),
intval($their_perms),
intval($closeness),
dbesc(datetime_convert()),
dbesc(datetime_convert()),
dbesc(datetime_convert()),
dbesc(NULL_DATE),
intval(($default_perms) ? 0 : 1),
dbesc(z_root())
);
if($r) {
logger("New GNU-Social follower received for {$importer['channel_name']}");
$new_connection = q("select * from abook left join xchan on abook_xchan = xchan_hash left join hubloc on hubloc_hash = xchan_hash where abook_channel = %d and abook_xchan = '%s' order by abook_created desc limit 1",
intval($importer['channel_id']),
dbesc($xchan['xchan_hash'])
);
if($new_connection) {
require_once('include/enotify.php');
notification(array(
'type' => NOTIFY_INTRO,
'from_xchan' => $xchan['xchan_hash'],
'to_xchan' => $importer['channel_hash'],
'link' => z_root() . '/connedit/' . $new_connection[0]['abook_id'],
));
if($default_perms) {
// Send back a sharing notification to them
$deliver = gnusoc_remote_follow($importer,$new_connection[0]);
if($deliver)
proc_run('php','include/deliver.php',$deliver);
}
$clone = array();
foreach($new_connection[0] as $k => $v) {
if(strpos($k,'abook_') === 0) {
$clone[$k] = $v;
}
}
unset($clone['abook_id']);
unset($clone['abook_account']);
unset($clone['abook_channel']);
$abconfig = load_abconfig($importer['channel_hash'],$clone['abook_xchan']);
if($abconfig)
$clone['abconfig'] = $abconfig;
build_sync_packet($importer['channel_id'], array('abook' => array($clone)));
}
}
}
return;
}
}