X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=diaspora%2Fdiaspora.php;h=a547255821144c0e5adf133b338ede76a79e700b;hb=c48776586093e178c9ea94183e44b978456bebf1;hp=53e1890c1c63e5ad4dcd65d1213af2b6ab839793;hpb=e97a64a73525569faa6070db344efeb26acaa140;p=friendica-addons.git diff --git a/diaspora/diaspora.php b/diaspora/diaspora.php old mode 100755 new mode 100644 index 53e1890c..a5472558 --- a/diaspora/diaspora.php +++ b/diaspora/diaspora.php @@ -3,55 +3,74 @@ /** * Name: Diaspora Post Connector * Description: Post to Diaspora - * Version: 0.1 + * Version: 0.2 * Author: Michael Vogel */ -function diaspora_install() { - register_hook('post_local', 'addon/diaspora/diaspora.php', 'diaspora_post_local'); - register_hook('notifier_normal', 'addon/diaspora/diaspora.php', 'diaspora_send'); - register_hook('jot_networks', 'addon/diaspora/diaspora.php', 'diaspora_jot_nets'); - register_hook('connector_settings', 'addon/diaspora/diaspora.php', 'diaspora_settings'); - register_hook('connector_settings_post', 'addon/diaspora/diaspora.php', 'diaspora_settings_post'); - register_hook('queue_predeliver', 'addon/diaspora/diaspora.php', 'diaspora_queue_hook'); +require_once 'addon/diaspora/Diaspora_Connection.php'; + +use Friendica\App; +use Friendica\Content\Text\BBCode; +use Friendica\Core\Addon; +use Friendica\Core\L10n; +use Friendica\Core\PConfig; +use Friendica\Core\Protocol; +use Friendica\Database\DBA; +use Friendica\Model\Queue; + +function diaspora_install() +{ + Addon::registerHook('post_local', 'addon/diaspora/diaspora.php', 'diaspora_post_local'); + Addon::registerHook('notifier_normal', 'addon/diaspora/diaspora.php', 'diaspora_send'); + Addon::registerHook('jot_networks', 'addon/diaspora/diaspora.php', 'diaspora_jot_nets'); + Addon::registerHook('connector_settings', 'addon/diaspora/diaspora.php', 'diaspora_settings'); + Addon::registerHook('connector_settings_post', 'addon/diaspora/diaspora.php', 'diaspora_settings_post'); + Addon::registerHook('queue_predeliver', 'addon/diaspora/diaspora.php', 'diaspora_queue_hook'); } -function diaspora_uninstall() { - unregister_hook('post_local', 'addon/diaspora/diaspora.php', 'diaspora_post_local'); - unregister_hook('notifier_normal', 'addon/diaspora/diaspora.php', 'diaspora_send'); - unregister_hook('jot_networks', 'addon/diaspora/diaspora.php', 'diaspora_jot_nets'); - unregister_hook('connector_settings', 'addon/diaspora/diaspora.php', 'diaspora_settings'); - unregister_hook('connector_settings_post', 'addon/diaspora/diaspora.php', 'diaspora_settings_post'); - unregister_hook('queue_predeliver', 'addon/diaspora/diaspora.php', 'diaspora_queue_hook'); + +function diaspora_uninstall() +{ + Addon::unregisterHook('post_local', 'addon/diaspora/diaspora.php', 'diaspora_post_local'); + Addon::unregisterHook('notifier_normal', 'addon/diaspora/diaspora.php', 'diaspora_send'); + Addon::unregisterHook('jot_networks', 'addon/diaspora/diaspora.php', 'diaspora_jot_nets'); + Addon::unregisterHook('connector_settings', 'addon/diaspora/diaspora.php', 'diaspora_settings'); + Addon::unregisterHook('connector_settings_post', 'addon/diaspora/diaspora.php', 'diaspora_settings_post'); + Addon::unregisterHook('queue_predeliver', 'addon/diaspora/diaspora.php', 'diaspora_queue_hook'); } +function diaspora_jot_nets(App $a, &$b) +{ + if (!local_user()) { + return; + } + + $diaspora_post = PConfig::get(local_user(), 'diaspora', 'post'); -function diaspora_jot_nets(&$a,&$b) { - if(! local_user()) - return; + if (intval($diaspora_post) == 1) { + $diaspora_defpost = PConfig::get(local_user(), 'diaspora', 'post_by_default'); - $diaspora_post = get_pconfig(local_user(),'diaspora','post'); - if(intval($diaspora_post) == 1) { - $diaspora_defpost = get_pconfig(local_user(),'diaspora','post_by_default'); - $selected = ((intval($diaspora_defpost) == 1) ? ' checked="checked" ' : ''); - $b .= '
' - . t('Post to Diaspora') . '
'; - } + $selected = ((intval($diaspora_defpost) == 1) ? ' checked="checked" ' : ''); + + $b .= '
' + . L10n::t('Post to Diaspora') . '
'; + } } -function diaspora_queue_hook(&$a,&$b) { +function diaspora_queue_hook(App $a, &$b) { $hostname = $a->get_hostname(); $qi = q("SELECT * FROM `queue` WHERE `network` = '%s'", - dbesc(NETWORK_DIASPORA2) + DBA::escape(Protocol::DIASPORA2) ); - if(! count($qi)) - return; - require_once('include/queue_fn.php'); + if (!DBA::isResult($qi)) { + return; + } - foreach($qi as $x) { - if($x['network'] !== NETWORK_DIASPORA2) + foreach ($qi as $x) { + if ($x['network'] !== Protocol::DIASPORA2) { continue; + } logger('diaspora_queue: run'); @@ -59,21 +78,21 @@ function diaspora_queue_hook(&$a,&$b) { WHERE `contact`.`self` = 1 AND `contact`.`id` = %d LIMIT 1", intval($x['cid']) ); - if(! count($r)) + + if (!DBA::isResult($r)) { continue; + } $userdata = $r[0]; - $diaspora_username = get_pconfig($userdata['uid'],'diaspora','diaspora_username'); - $diaspora_password = get_pconfig($userdata['uid'],'diaspora','diaspora_password'); - $diaspora_url = get_pconfig($userdata['uid'],'diaspora','diaspora_url'); + $handle = PConfig::get($userdata['uid'], 'diaspora', 'handle'); + $password = PConfig::get($userdata['uid'], 'diaspora', 'password'); + $aspect = PConfig::get($userdata['uid'], 'diaspora', 'aspect'); $success = false; - if($diaspora_url && $diaspora_username && $diaspora_password) { - require_once("addon/diaspora/diasphp.php"); - - logger('diaspora_queue: able to post for user '.$diaspora_username); + if ($handle && $password) { + logger('diaspora_queue: able to post for user '.$handle); $z = unserialize($x['content']); @@ -83,34 +102,37 @@ function diaspora_queue_hook(&$a,&$b) { try { logger('diaspora_queue: prepare', LOGGER_DEBUG); - $conn = new Diasphp($diaspora_url); - logger('diaspora_queue: try to log in '.$diaspora_username, LOGGER_DEBUG); - $conn->login($diaspora_username, $diaspora_password); + $conn = new Diaspora_Connection($handle, $password); + logger('diaspora_queue: try to log in '.$handle, LOGGER_DEBUG); + $conn->logIn(); logger('diaspora_queue: try to send '.$body, LOGGER_DEBUG); - $conn->post($post, $hostname); + $conn->provider = $hostname; + $conn->postStatusMessage($post, $aspect); - logger('diaspora_queue: send '.$userdata['uid'].' success', LOGGER_DEBUG); + logger('diaspora_queue: send '.$userdata['uid'].' success', LOGGER_DEBUG); - $success = true; + $success = true; - remove_queue_item($x['id']); + Queue::removeItem($x['id']); } catch (Exception $e) { logger("diaspora_queue: Send ".$userdata['uid']." failed: ".$e->getMessage(), LOGGER_DEBUG); } - } else + } else { logger('diaspora_queue: send '.$userdata['uid'].' missing username or password', LOGGER_DEBUG); + } if (!$success) { logger('diaspora_queue: delayed'); - update_queue_time($x['id']); + Queue::updateTime($x['id']); } } } -function diaspora_settings(&$a,&$s) { - - if(! local_user()) +function diaspora_settings(App $a, &$s) +{ + if (! local_user()) { return; + } /* Add our stylesheet to the page so we can make our settings look nice */ @@ -118,39 +140,48 @@ function diaspora_settings(&$a,&$s) { /* Get the current state of our config variables */ - $enabled = get_pconfig(local_user(),'diaspora','post'); - + $enabled = PConfig::get(local_user(),'diaspora','post'); $checked = (($enabled) ? ' checked="checked" ' : ''); + $css = (($enabled) ? '' : '-disabled'); - $def_enabled = get_pconfig(local_user(),'diaspora','post_by_default'); + $def_enabled = PConfig::get(local_user(),'diaspora','post_by_default'); $def_checked = (($def_enabled) ? ' checked="checked" ' : ''); - $diaspora_username = get_pconfig(local_user(), 'diaspora', 'diaspora_username'); - $diaspora_password = get_pconfig(local_user(), 'diaspora', 'diaspora_password'); - $diaspora_url = get_pconfig(local_user(), 'diaspora', 'diaspora_url'); + $handle = PConfig::get(local_user(), 'diaspora', 'handle'); + $password = PConfig::get(local_user(), 'diaspora', 'password'); + $aspect = PConfig::get(local_user(),'diaspora','aspect'); $status = ""; - if ($diaspora_username AND $diaspora_password AND $diaspora_url) { - try { - require_once("addon/diaspora/diasphp.php"); + $r = q("SELECT `addr` FROM `contact` WHERE `self` AND `uid` = %d", intval(local_user())); - $conn = new Diasphp($diaspora_url); - $conn->login($diaspora_username, $diaspora_password); - } catch (Exception $e) { - $status = t("Can't login to your Diaspora account. Please check username and password and ensure you used the complete address (including http...)"); + if (DBA::isResult($r)) { + $status = L10n::t("Please remember: You can always be reached from Diaspora with your Friendica handle %s. ", $r[0]['addr']); + $status .= L10n::t('This connector is only meant if you still want to use your old Diaspora account for some time. '); + $status .= L10n::t('However, it is preferred that you tell your Diaspora contacts the new handle %s instead.', $r[0]['addr']); + } + + $aspects = false; + + if ($handle && $password) { + $conn = new Diaspora_Connection($handle, $password); + $conn->logIn(); + $aspects = $conn->getAspects(); + + if (!$aspects) { + $status = L10n::t("Can't login to your Diaspora account. Please check handle (in the format user@domain.tld) and password."); } } /* Add some HTML to the existing form */ $s .= ''; - $s .= '

'. t('Diaspora Export').'

'; + $s .= '

'. L10n::t('Diaspora Export').'

'; $s .= '
'; $s .= ''; + $s .= '
'; } -function diaspora_settings_post(&$a,&$b) { - - if(x($_POST,'diaspora-submit')) { - - set_pconfig(local_user(),'diaspora','post',intval($_POST['diaspora'])); - set_pconfig(local_user(),'diaspora','post_by_default',intval($_POST['diaspora_bydefault'])); - set_pconfig(local_user(),'diaspora','diaspora_username',trim($_POST['diaspora_username'])); - set_pconfig(local_user(),'diaspora','diaspora_password',trim($_POST['diaspora_password'])); - set_pconfig(local_user(),'diaspora','diaspora_url',trim($_POST['diaspora_url'])); - +function diaspora_settings_post(App $a, &$b) +{ + if (!empty($_POST['diaspora-submit'])) { + PConfig::set(local_user(),'diaspora', 'post' , intval($_POST['diaspora'])); + PConfig::set(local_user(),'diaspora', 'post_by_default', intval($_POST['diaspora_bydefault'])); + PConfig::set(local_user(),'diaspora', 'handle' , trim($_POST['handle'])); + PConfig::set(local_user(),'diaspora', 'password' , trim($_POST['password'])); + PConfig::set(local_user(),'diaspora', 'aspect' , trim($_POST['aspect'])); } - } -function diaspora_post_local(&$a,&$b) { - - if($b['edit']) +function diaspora_post_local(App $a, array &$b) +{ + if ($b['edit']) { return; + } - if((! local_user()) || (local_user() != $b['uid'])) + if (!local_user() || (local_user() != $b['uid'])) { return; + } - if($b['private'] || $b['parent']) + if ($b['private'] || $b['parent']) { return; + } - $diaspora_post = intval(get_pconfig(local_user(),'diaspora','post')); + $diaspora_post = intval(PConfig::get(local_user(),'diaspora','post')); $diaspora_enable = (($diaspora_post && x($_REQUEST,'diaspora_enable')) ? intval($_REQUEST['diaspora_enable']) : 0); - if($_REQUEST['api_source'] && intval(get_pconfig(local_user(),'diaspora','post_by_default'))) + if ($b['api_source'] && intval(PConfig::get(local_user(),'diaspora','post_by_default'))) { $diaspora_enable = 1; + } - if(! $diaspora_enable) - return; - - if(strlen($b['postopts'])) - $b['postopts'] .= ','; - $b['postopts'] .= 'diaspora'; -} - + if (!$diaspora_enable) { + return; + } + if (strlen($b['postopts'])) { + $b['postopts'] .= ','; + } + $b['postopts'] .= 'diaspora'; +} -function diaspora_send(&$a,&$b) { +function diaspora_send(App $a, array &$b) +{ $hostname = $a->get_hostname(); logger('diaspora_send: invoked'); - if($b['deleted'] || $b['private'] || ($b['created'] !== $b['edited'])) + if ($b['deleted'] || $b['private'] || ($b['created'] !== $b['edited'])) { return; + } - if(! strstr($b['postopts'],'diaspora')) + if (!strstr($b['postopts'],'diaspora')) { return; + } - if($b['parent'] != $b['id']) + if ($b['parent'] != $b['id']) { return; + } - logger('diaspora_send: prepare posting', LOGGER_DEBUG); + // Dont't post if the post doesn't belong to us. + // This is a check for forum postings + $self = DBA::selectFirst('contact', ['id'], ['uid' => $b['uid'], 'self' => true]); - $diaspora_username = get_pconfig($b['uid'],'diaspora','diaspora_username'); - $diaspora_password = get_pconfig($b['uid'],'diaspora','diaspora_password'); - $diaspora_url = get_pconfig($b['uid'],'diaspora','diaspora_url'); + if ($b['contact-id'] != $self['id']) { + return; + } - if($diaspora_url && $diaspora_username && $diaspora_password) { + logger('diaspora_send: prepare posting', LOGGER_DEBUG); + + $handle = PConfig::get($b['uid'],'diaspora','handle'); + $password = PConfig::get($b['uid'],'diaspora','password'); + $aspect = PConfig::get($b['uid'],'diaspora','aspect'); + if ($handle && $password) { logger('diaspora_send: all values seem to be okay', LOGGER_DEBUG); - require_once('include/bb2diaspora.php'); - $tag_arr = array(); + $tag_arr = []; $tags = ''; $x = preg_match_all('/\#\[(.*?)\](.*?)\[/',$b['tag'],$matches,PREG_SET_ORDER); - if($x) { - foreach($matches as $mtch) { + if ($x) { + foreach ($matches as $mtch) { $tag_arr[] = $mtch[2]; } } - if(count($tag_arr)) + + if (count($tag_arr)) { $tags = implode(',',$tag_arr); + } $title = $b['title']; $body = $b['body']; @@ -286,27 +349,28 @@ function diaspora_send(&$a,&$b) { // remove multiple newlines do { $oldbody = $body; - $body = str_replace("\n\n\n", "\n\n", $body); - } while ($oldbody != $body); + $body = str_replace("\n\n\n", "\n\n", $body); + } while ($oldbody != $body); // convert to markdown - $body = bb2diaspora($body, false, true); + $body = BBCode::toMarkdown($body); // Adding the title - if(strlen($title)) + if (strlen($title)) { $body = "## ".html_entity_decode($title)."\n\n".$body; + } - require_once("addon/diaspora/diasphp.php"); + require_once "addon/diaspora/diasphp.php"; try { logger('diaspora_send: prepare', LOGGER_DEBUG); - $conn = new Diasphp($diaspora_url); - logger('diaspora_send: try to log in '.$diaspora_username, LOGGER_DEBUG); - $conn->login($diaspora_username, $diaspora_password); + $conn = new Diaspora_Connection($handle, $password); + logger('diaspora_send: try to log in '.$handle, LOGGER_DEBUG); + $conn->logIn(); logger('diaspora_send: try to send '.$body, LOGGER_DEBUG); - //throw new Exception('Test'); - $conn->post($body, $hostname); + $conn->provider = $hostname; + $conn->postStatusMessage($body, $aspect); logger('diaspora_send: success'); } catch (Exception $e) { @@ -318,10 +382,10 @@ function diaspora_send(&$a,&$b) { if (count($r)) $a->contact = $r[0]["id"]; - $s = serialize(array('url' => $url, 'item' => $b['id'], 'post' => $body)); - require_once('include/queue_fn.php'); - add_to_queue($a->contact,NETWORK_DIASPORA2,$s); - notice(t('Diaspora post failed. Queued for retry.').EOL); + $s = serialize(['url' => $url, 'item' => $b['id'], 'post' => $body]); + + Queue::add($a->contact, Protocol::DIASPORA2, $s); + notice(L10n::t('Diaspora post failed. Queued for retry.').EOL); } } }