X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=statusnet%2Fstatusnet.php;h=e96a8967a95c64946e7188db05f191f9bc56fe73;hb=461b3db9f449fdb1ce780a337cf2f1bb7aa35ac5;hp=b16dedf846144dcbd350b8dbe623cb1fb4ac35b6;hpb=4a66fd3c8bc5d78b640695743dcafeeb46e31c9a;p=friendica-addons.git diff --git a/statusnet/statusnet.php b/statusnet/statusnet.php old mode 100755 new mode 100644 index b16dedf8..9158052a --- a/statusnet/statusnet.php +++ b/statusnet/statusnet.php @@ -1,7 +1,8 @@ * Author: Michael Vogel @@ -32,10 +33,8 @@ * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. * */ - - -/*** - * We have to alter the TwitterOAuth class a little bit to work with any StatusNet +/* + * We have to alter the TwitterOAuth class a little bit to work with any GNU Social * installation abroad. Basically it's only make the API path variable and be happy. * * Thank you guys for the Twitter compatible API! @@ -43,792 +42,799 @@ define('STATUSNET_DEFAULT_POLL_INTERVAL', 5); // given in minutes -require_once('library/twitteroauth.php'); - -class StatusNetOAuth extends TwitterOAuth { - function get_maxlength() { - $config = $this->get($this->host . 'statusnet/config.json'); - return $config->site->textlimit; - } - function accessTokenURL() { return $this->host.'oauth/access_token'; } - function authenticateURL() { return $this->host.'oauth/authenticate'; } - function authorizeURL() { return $this->host.'oauth/authorize'; } - function requestTokenURL() { return $this->host.'oauth/request_token'; } - function __construct($apipath, $consumer_key, $consumer_secret, $oauth_token = NULL, $oauth_token_secret = NULL) { - parent::__construct($consumer_key, $consumer_secret, $oauth_token, $oauth_token_secret); - $this->host = $apipath; - } - /** - * Make an HTTP request - * - * @return API results - * - * Copied here from the twitteroauth library and complemented by applying the proxy settings of friendica - */ - function http($url, $method, $postfields = NULL) { - $this->http_info = array(); - $ci = curl_init(); - /* Curl settings */ - $prx = get_config('system','proxy'); - if(strlen($prx)) { - curl_setopt($ci, CURLOPT_HTTPPROXYTUNNEL, 1); - curl_setopt($ci, CURLOPT_PROXY, $prx); - $prxusr = get_config('system','proxyuser'); - if(strlen($prxusr)) - curl_setopt($ci, CURLOPT_PROXYUSERPWD, $prxusr); - } - curl_setopt($ci, CURLOPT_USERAGENT, $this->useragent); - curl_setopt($ci, CURLOPT_CONNECTTIMEOUT, $this->connecttimeout); - curl_setopt($ci, CURLOPT_TIMEOUT, $this->timeout); - curl_setopt($ci, CURLOPT_RETURNTRANSFER, TRUE); - curl_setopt($ci, CURLOPT_HTTPHEADER, array('Expect:')); - curl_setopt($ci, CURLOPT_SSL_VERIFYPEER, $this->ssl_verifypeer); - curl_setopt($ci, CURLOPT_HEADERFUNCTION, array($this, 'getHeader')); - curl_setopt($ci, CURLOPT_HEADER, FALSE); - - switch ($method) { - case 'POST': - curl_setopt($ci, CURLOPT_POST, TRUE); - if (!empty($postfields)) { - curl_setopt($ci, CURLOPT_POSTFIELDS, $postfields); - } - break; - case 'DELETE': - curl_setopt($ci, CURLOPT_CUSTOMREQUEST, 'DELETE'); - if (!empty($postfields)) { - $url = "{$url}?{$postfields}"; - } - } - - curl_setopt($ci, CURLOPT_URL, $url); - $response = curl_exec($ci); - $this->http_code = curl_getinfo($ci, CURLINFO_HTTP_CODE); - $this->http_info = array_merge($this->http_info, curl_getinfo($ci)); - $this->url = $url; - curl_close ($ci); - return $response; - } +require_once 'library/twitteroauth.php'; +require_once 'include/enotify.php'; + +use Friendica\App; +use Friendica\Content\OEmbed; +use Friendica\Core\Config; +use Friendica\Core\PConfig; +use Friendica\Model\GContact; +use Friendica\Model\Group; +use Friendica\Model\Photo; +use Friendica\Model\User; + +class StatusNetOAuth extends TwitterOAuth +{ + function get_maxlength() + { + $config = $this->get($this->host . 'statusnet/config.json'); + return $config->site->textlimit; + } + + function accessTokenURL() + { + return $this->host . 'oauth/access_token'; + } + + function authenticateURL() + { + return $this->host . 'oauth/authenticate'; + } + + function authorizeURL() + { + return $this->host . 'oauth/authorize'; + } + + function requestTokenURL() + { + return $this->host . 'oauth/request_token'; + } + + function __construct($apipath, $consumer_key, $consumer_secret, $oauth_token = NULL, $oauth_token_secret = NULL) + { + parent::__construct($consumer_key, $consumer_secret, $oauth_token, $oauth_token_secret); + $this->host = $apipath; + } + + /** + * Make an HTTP request + * + * @return API results + * + * Copied here from the twitteroauth library and complemented by applying the proxy settings of friendica + */ + function http($url, $method, $postfields = NULL) + { + $this->http_info = []; + $ci = curl_init(); + /* Curl settings */ + $prx = Config::get('system', 'proxy'); + if (strlen($prx)) { + curl_setopt($ci, CURLOPT_HTTPPROXYTUNNEL, 1); + curl_setopt($ci, CURLOPT_PROXY, $prx); + $prxusr = Config::get('system', 'proxyuser'); + if (strlen($prxusr)) { + curl_setopt($ci, CURLOPT_PROXYUSERPWD, $prxusr); + } + } + curl_setopt($ci, CURLOPT_USERAGENT, $this->useragent); + curl_setopt($ci, CURLOPT_CONNECTTIMEOUT, $this->connecttimeout); + curl_setopt($ci, CURLOPT_TIMEOUT, $this->timeout); + curl_setopt($ci, CURLOPT_RETURNTRANSFER, TRUE); + curl_setopt($ci, CURLOPT_HTTPHEADER, ['Expect:']); + curl_setopt($ci, CURLOPT_SSL_VERIFYPEER, $this->ssl_verifypeer); + curl_setopt($ci, CURLOPT_HEADERFUNCTION, [$this, 'getHeader']); + curl_setopt($ci, CURLOPT_HEADER, FALSE); + + switch ($method) { + case 'POST': + curl_setopt($ci, CURLOPT_POST, TRUE); + if (!empty($postfields)) { + curl_setopt($ci, CURLOPT_POSTFIELDS, $postfields); + } + break; + case 'DELETE': + curl_setopt($ci, CURLOPT_CUSTOMREQUEST, 'DELETE'); + if (!empty($postfields)) { + $url = "{$url}?{$postfields}"; + } + } + + curl_setopt($ci, CURLOPT_URL, $url); + $response = curl_exec($ci); + $this->http_code = curl_getinfo($ci, CURLINFO_HTTP_CODE); + $this->http_info = array_merge($this->http_info, curl_getinfo($ci)); + $this->url = $url; + curl_close($ci); + return $response; + } } -function statusnet_install() { +function statusnet_install() +{ // we need some hooks, for the configuration and for sending tweets - register_hook('connector_settings', 'addon/statusnet/statusnet.php', 'statusnet_settings'); + register_hook('connector_settings', 'addon/statusnet/statusnet.php', 'statusnet_settings'); register_hook('connector_settings_post', 'addon/statusnet/statusnet.php', 'statusnet_settings_post'); register_hook('notifier_normal', 'addon/statusnet/statusnet.php', 'statusnet_post_hook'); register_hook('post_local', 'addon/statusnet/statusnet.php', 'statusnet_post_local'); - register_hook('jot_networks', 'addon/statusnet/statusnet.php', 'statusnet_jot_nets'); + register_hook('jot_networks', 'addon/statusnet/statusnet.php', 'statusnet_jot_nets'); register_hook('cron', 'addon/statusnet/statusnet.php', 'statusnet_cron'); - logger("installed statusnet"); + register_hook('prepare_body', 'addon/statusnet/statusnet.php', 'statusnet_prepare_body'); + register_hook('check_item_notification', 'addon/statusnet/statusnet.php', 'statusnet_check_item_notification'); + logger("installed GNU Social"); } - -function statusnet_uninstall() { - unregister_hook('connector_settings', 'addon/statusnet/statusnet.php', 'statusnet_settings'); +function statusnet_uninstall() +{ + unregister_hook('connector_settings', 'addon/statusnet/statusnet.php', 'statusnet_settings'); unregister_hook('connector_settings_post', 'addon/statusnet/statusnet.php', 'statusnet_settings_post'); unregister_hook('notifier_normal', 'addon/statusnet/statusnet.php', 'statusnet_post_hook'); unregister_hook('post_local', 'addon/statusnet/statusnet.php', 'statusnet_post_local'); - unregister_hook('jot_networks', 'addon/statusnet/statusnet.php', 'statusnet_jot_nets'); + unregister_hook('jot_networks', 'addon/statusnet/statusnet.php', 'statusnet_jot_nets'); unregister_hook('cron', 'addon/statusnet/statusnet.php', 'statusnet_cron'); + unregister_hook('prepare_body', 'addon/statusnet/statusnet.php', 'statusnet_prepare_body'); + unregister_hook('check_item_notification', 'addon/statusnet/statusnet.php', 'statusnet_check_item_notification'); // old setting - remove only unregister_hook('post_local_end', 'addon/statusnet/statusnet.php', 'statusnet_post_hook'); - unregister_hook('plugin_settings', 'addon/statusnet/statusnet.php', 'statusnet_settings'); + unregister_hook('plugin_settings', 'addon/statusnet/statusnet.php', 'statusnet_settings'); unregister_hook('plugin_settings_post', 'addon/statusnet/statusnet.php', 'statusnet_settings_post'); +} +function statusnet_check_item_notification(App $a, &$notification_data) +{ + $notification_data["profiles"][] = PConfig::get($notification_data["uid"], 'statusnet', 'own_url'); } -function statusnet_jot_nets(&$a,&$b) { - if(! local_user()) +function statusnet_jot_nets(App $a, &$b) +{ + if (!local_user()) { return; + } - $statusnet_post = get_pconfig(local_user(),'statusnet','post'); - if(intval($statusnet_post) == 1) { - $statusnet_defpost = get_pconfig(local_user(),'statusnet','post_by_default'); + $statusnet_post = PConfig::get(local_user(), 'statusnet', 'post'); + if (intval($statusnet_post) == 1) { + $statusnet_defpost = PConfig::get(local_user(), 'statusnet', 'post_by_default'); $selected = ((intval($statusnet_defpost) == 1) ? ' checked="checked" ' : ''); - $b .= '
' - . t('Post to StatusNet') . '
'; + $b .= '
' + . t('Post to GNU Social') . '
'; } } -function statusnet_settings_post ($a,$post) { - if(! local_user()) - return; - // don't check statusnet settings if statusnet submit button is not clicked - if (!x($_POST,'statusnet-submit')) return; - +function statusnet_settings_post(App $a, $post) +{ + if (!local_user()) { + return; + } + // don't check GNU Social settings if GNU Social submit button is not clicked + if (!x($_POST, 'statusnet-submit')) { + return; + } + if (isset($_POST['statusnet-disconnect'])) { - /*** - * if the statusnet-disconnect checkbox is set, clear the statusnet configuration - */ - del_pconfig(local_user(), 'statusnet', 'consumerkey'); - del_pconfig(local_user(), 'statusnet', 'consumersecret'); - del_pconfig(local_user(), 'statusnet', 'post'); - del_pconfig(local_user(), 'statusnet', 'post_by_default'); - del_pconfig(local_user(), 'statusnet', 'oauthtoken'); - del_pconfig(local_user(), 'statusnet', 'oauthsecret'); - del_pconfig(local_user(), 'statusnet', 'baseapi'); - del_pconfig(local_user(), 'statusnet', 'post_taglinks'); - del_pconfig(local_user(), 'statusnet', 'lastid'); - del_pconfig(local_user(), 'statusnet', 'mirror_posts'); - del_pconfig(local_user(), 'statusnet', 'intelligent_shortening'); + /* * * + * if the GNU Social-disconnect checkbox is set, clear the GNU Social configuration + */ + PConfig::delete(local_user(), 'statusnet', 'consumerkey'); + PConfig::delete(local_user(), 'statusnet', 'consumersecret'); + PConfig::delete(local_user(), 'statusnet', 'post'); + PConfig::delete(local_user(), 'statusnet', 'post_by_default'); + PConfig::delete(local_user(), 'statusnet', 'oauthtoken'); + PConfig::delete(local_user(), 'statusnet', 'oauthsecret'); + PConfig::delete(local_user(), 'statusnet', 'baseapi'); + PConfig::delete(local_user(), 'statusnet', 'lastid'); + PConfig::delete(local_user(), 'statusnet', 'mirror_posts'); + PConfig::delete(local_user(), 'statusnet', 'import'); + PConfig::delete(local_user(), 'statusnet', 'create_user'); + PConfig::delete(local_user(), 'statusnet', 'own_id'); } else { - if (isset($_POST['statusnet-preconf-apiurl'])) { - /*** - * If the user used one of the preconfigured StatusNet server credentials - * use them. All the data are available in the global config. - * Check the API Url never the less and blame the admin if it's not working ^^ - */ - $globalsn = get_config('statusnet', 'sites'); - foreach ( $globalsn as $asn) { - if ($asn['apiurl'] == $_POST['statusnet-preconf-apiurl'] ) { - $apibase = $asn['apiurl']; - $c = fetch_url( $apibase . 'statusnet/version.xml' ); - if (strlen($c) > 0) { - set_pconfig(local_user(), 'statusnet', 'consumerkey', $asn['consumerkey'] ); - set_pconfig(local_user(), 'statusnet', 'consumersecret', $asn['consumersecret'] ); - set_pconfig(local_user(), 'statusnet', 'baseapi', $asn['apiurl'] ); - set_pconfig(local_user(), 'statusnet', 'application_name', $asn['applicationname'] ); - } else { - notice( t('Please contact your site administrator.
The provided API URL is not valid.').EOL.$asn['apiurl'].EOL ); - } - } - } - goaway($a->get_baseurl().'/settings/connectors'); - } else { - if (isset($_POST['statusnet-consumersecret'])) { - // check if we can reach the API of the StatusNet server - // we'll check the API Version for that, if we don't get one we'll try to fix the path but will - // resign quickly after this one try to fix the path ;-) - $apibase = $_POST['statusnet-baseapi']; - $c = fetch_url( $apibase . 'statusnet/version.xml' ); - if (strlen($c) > 0) { - // ok the API path is correct, let's save the settings - set_pconfig(local_user(), 'statusnet', 'consumerkey', $_POST['statusnet-consumerkey']); - set_pconfig(local_user(), 'statusnet', 'consumersecret', $_POST['statusnet-consumersecret']); - set_pconfig(local_user(), 'statusnet', 'baseapi', $apibase ); - set_pconfig(local_user(), 'statusnet', 'application_name', $_POST['statusnet-applicationname'] ); - } else { - // the API path is not correct, maybe missing trailing / ? - $apibase = $apibase . '/'; - $c = fetch_url( $apibase . 'statusnet/version.xml' ); - if (strlen($c) > 0) { - // ok the API path is now correct, let's save the settings - set_pconfig(local_user(), 'statusnet', 'consumerkey', $_POST['statusnet-consumerkey']); - set_pconfig(local_user(), 'statusnet', 'consumersecret', $_POST['statusnet-consumersecret']); - set_pconfig(local_user(), 'statusnet', 'baseapi', $apibase ); - } else { - // still not the correct API base, let's do noting - notice( t('We could not contact the StatusNet API with the Path you entered.').EOL ); - } - } - goaway($a->get_baseurl().'/settings/connectors'); - } else { - if (isset($_POST['statusnet-pin'])) { - // if the user supplied us with a PIN from StatusNet, let the magic of OAuth happen - $api = get_pconfig(local_user(), 'statusnet', 'baseapi'); - $ckey = get_pconfig(local_user(), 'statusnet', 'consumerkey' ); - $csecret = get_pconfig(local_user(), 'statusnet', 'consumersecret' ); + if (isset($_POST['statusnet-preconf-apiurl'])) { + /* * * + * If the user used one of the preconfigured GNU Social server credentials + * use them. All the data are available in the global config. + * Check the API Url never the less and blame the admin if it's not working ^^ + */ + $globalsn = Config::get('statusnet', 'sites'); + foreach ($globalsn as $asn) { + if ($asn['apiurl'] == $_POST['statusnet-preconf-apiurl']) { + $apibase = $asn['apiurl']; + $c = fetch_url($apibase . 'statusnet/version.xml'); + if (strlen($c) > 0) { + PConfig::set(local_user(), 'statusnet', 'consumerkey', $asn['consumerkey']); + PConfig::set(local_user(), 'statusnet', 'consumersecret', $asn['consumersecret']); + PConfig::set(local_user(), 'statusnet', 'baseapi', $asn['apiurl']); + //PConfig::set(local_user(), 'statusnet', 'application_name', $asn['applicationname'] ); + } else { + notice(t('Please contact your site administrator.
The provided API URL is not valid.') . EOL . $asn['apiurl'] . EOL); + } + } + } + goaway('settings/connectors'); + } else { + if (isset($_POST['statusnet-consumersecret'])) { + // check if we can reach the API of the GNU Social server + // we'll check the API Version for that, if we don't get one we'll try to fix the path but will + // resign quickly after this one try to fix the path ;-) + $apibase = $_POST['statusnet-baseapi']; + $c = fetch_url($apibase . 'statusnet/version.xml'); + if (strlen($c) > 0) { + // ok the API path is correct, let's save the settings + PConfig::set(local_user(), 'statusnet', 'consumerkey', $_POST['statusnet-consumerkey']); + PConfig::set(local_user(), 'statusnet', 'consumersecret', $_POST['statusnet-consumersecret']); + PConfig::set(local_user(), 'statusnet', 'baseapi', $apibase); + //PConfig::set(local_user(), 'statusnet', 'application_name', $_POST['statusnet-applicationname'] ); + } else { + // the API path is not correct, maybe missing trailing / ? + $apibase = $apibase . '/'; + $c = fetch_url($apibase . 'statusnet/version.xml'); + if (strlen($c) > 0) { + // ok the API path is now correct, let's save the settings + PConfig::set(local_user(), 'statusnet', 'consumerkey', $_POST['statusnet-consumerkey']); + PConfig::set(local_user(), 'statusnet', 'consumersecret', $_POST['statusnet-consumersecret']); + PConfig::set(local_user(), 'statusnet', 'baseapi', $apibase); + } else { + // still not the correct API base, let's do noting + notice(t('We could not contact the GNU Social API with the Path you entered.') . EOL); + } + } + goaway('settings/connectors'); + } else { + if (isset($_POST['statusnet-pin'])) { + // if the user supplied us with a PIN from GNU Social, let the magic of OAuth happen + $api = PConfig::get(local_user(), 'statusnet', 'baseapi'); + $ckey = PConfig::get(local_user(), 'statusnet', 'consumerkey'); + $csecret = PConfig::get(local_user(), 'statusnet', 'consumersecret'); // the token and secret for which the PIN was generated were hidden in the settings - // form as token and token2, we need a new connection to Twitter using these token + // form as token and token2, we need a new connection to GNU Social using these token // and secret to request a Access Token with the PIN $connection = new StatusNetOAuth($api, $ckey, $csecret, $_POST['statusnet-token'], $_POST['statusnet-token2']); - $token = $connection->getAccessToken( $_POST['statusnet-pin'] ); + $token = $connection->getAccessToken($_POST['statusnet-pin']); // ok, now that we have the Access Token, save them in the user config - set_pconfig(local_user(),'statusnet', 'oauthtoken', $token['oauth_token']); - set_pconfig(local_user(),'statusnet', 'oauthsecret', $token['oauth_token_secret']); - set_pconfig(local_user(),'statusnet', 'post', 1); - set_pconfig(local_user(),'statusnet', 'post_taglinks', 1); - // reload the Addon Settings page, if we don't do it see Bug #42 - goaway($a->get_baseurl().'/settings/connectors'); + PConfig::set(local_user(), 'statusnet', 'oauthtoken', $token['oauth_token']); + PConfig::set(local_user(), 'statusnet', 'oauthsecret', $token['oauth_token_secret']); + PConfig::set(local_user(), 'statusnet', 'post', 1); + PConfig::set(local_user(), 'statusnet', 'post_taglinks', 1); + // reload the Addon Settings page, if we don't do it see Bug #42 + goaway('settings/connectors'); } else { // if no PIN is supplied in the POST variables, the user has changed the setting // to post a dent for every new __public__ posting to the wall - set_pconfig(local_user(),'statusnet','post',intval($_POST['statusnet-enable'])); - set_pconfig(local_user(),'statusnet','post_by_default',intval($_POST['statusnet-default'])); - set_pconfig(local_user(),'statusnet','post_taglinks',intval($_POST['statusnet-sendtaglinks'])); - set_pconfig(local_user(), 'statusnet', 'mirror_posts', intval($_POST['statusnet-mirror'])); - set_pconfig(local_user(), 'statusnet', 'intelligent_shortening', intval($_POST['statusnet-shortening'])); - info( t('StatusNet settings updated.') . EOL); - }}}} + PConfig::set(local_user(), 'statusnet', 'post', intval($_POST['statusnet-enable'])); + PConfig::set(local_user(), 'statusnet', 'post_by_default', intval($_POST['statusnet-default'])); + PConfig::set(local_user(), 'statusnet', 'mirror_posts', intval($_POST['statusnet-mirror'])); + PConfig::set(local_user(), 'statusnet', 'import', intval($_POST['statusnet-import'])); + PConfig::set(local_user(), 'statusnet', 'create_user', intval($_POST['statusnet-create_user'])); + + if (!intval($_POST['statusnet-mirror'])) + PConfig::delete(local_user(), 'statusnet', 'lastid'); + + info(t('GNU Social settings updated.') . EOL); + } + } + } + } } -function statusnet_settings(&$a,&$s) { - if(! local_user()) - return; - $a->page['htmlhead'] .= '' . "\r\n"; - /*** + +function statusnet_settings(App $a, &$s) +{ + if (!local_user()) { + return; + } + $a->page['htmlhead'] .= '' . "\r\n"; + /* * * * 1) Check that we have a base api url and a consumer key & secret * 2) If no OAuthtoken & stuff is present, generate button to get some - * allow the user to cancel the connection process at this step + * allow the user to cancel the connection process at this step * 3) Checkbox for "Send public notices (respect size limitation) */ - $api = get_pconfig(local_user(), 'statusnet', 'baseapi'); - $ckey = get_pconfig(local_user(), 'statusnet', 'consumerkey' ); - $csecret = get_pconfig(local_user(), 'statusnet', 'consumersecret' ); - $otoken = get_pconfig(local_user(), 'statusnet', 'oauthtoken' ); - $osecret = get_pconfig(local_user(), 'statusnet', 'oauthsecret' ); - $enabled = get_pconfig(local_user(), 'statusnet', 'post'); + $api = PConfig::get(local_user(), 'statusnet', 'baseapi'); + $ckey = PConfig::get(local_user(), 'statusnet', 'consumerkey'); + $csecret = PConfig::get(local_user(), 'statusnet', 'consumersecret'); + $otoken = PConfig::get(local_user(), 'statusnet', 'oauthtoken'); + $osecret = PConfig::get(local_user(), 'statusnet', 'oauthsecret'); + $enabled = PConfig::get(local_user(), 'statusnet', 'post'); $checked = (($enabled) ? ' checked="checked" ' : ''); - $defenabled = get_pconfig(local_user(),'statusnet','post_by_default'); - $defchecked = (($defenabled) ? ' checked="checked" ' : ''); - $linksenabled = get_pconfig(local_user(),'statusnet','post_taglinks'); - $linkschecked = (($linksenabled) ? ' checked="checked" ' : ''); - - $mirrorenabled = get_pconfig(local_user(),'statusnet','mirror_posts'); + $defenabled = PConfig::get(local_user(), 'statusnet', 'post_by_default'); + $defchecked = (($defenabled) ? ' checked="checked" ' : ''); + $mirrorenabled = PConfig::get(local_user(), 'statusnet', 'mirror_posts'); $mirrorchecked = (($mirrorenabled) ? ' checked="checked" ' : ''); - $shorteningenabled = get_pconfig(local_user(),'statusnet','intelligent_shortening'); - $shorteningchecked = (($shorteningenabled) ? ' checked="checked" ' : ''); - - $s .= '
'; - $s .= '

'. t('StatusNet Posting Settings').'

'; - - if ( (!$ckey) && (!$csecret) ) { - /*** + $import = PConfig::get(local_user(), 'statusnet', 'import'); + $importselected = ["", "", ""]; + $importselected[$import] = ' selected="selected"'; + //$importenabled = PConfig::get(local_user(),'statusnet','import'); + //$importchecked = (($importenabled) ? ' checked="checked" ' : ''); + $create_userenabled = PConfig::get(local_user(), 'statusnet', 'create_user'); + $create_userchecked = (($create_userenabled) ? ' checked="checked" ' : ''); + + $css = (($enabled) ? '' : '-disabled'); + + $s .= ''; + $s .= '

' . t('GNU Social Import/Export/Mirror') . '

'; + $s .= ''; + $s .= '
'; + $s .= ''; + //$s .= ''; + $s .= ''; + $s .= '
'; + /* + $s .= ''; + $s .= ''; + $s .= '
'; + */ $s .= '
'; - $s .= ''; - $s .= ''; + $s .= ''; + $s .= ''; $s .= '
'; - $s .= '
'; + $s .= '
'; } } - $s .= '
'; + $s .= '
'; } +function statusnet_post_local(App $a, &$b) +{ + if ($b['edit']) { + return; + } -function statusnet_post_local(&$a,&$b) { - if($b['edit']) + if (!local_user() || (local_user() != $b['uid'])) { return; + } - if((local_user()) && (local_user() == $b['uid']) && (! $b['private'])) { + $statusnet_post = PConfig::get(local_user(), 'statusnet', 'post'); + $statusnet_enable = (($statusnet_post && x($_REQUEST, 'statusnet_enable')) ? intval($_REQUEST['statusnet_enable']) : 0); - $statusnet_post = get_pconfig(local_user(),'statusnet','post'); - $statusnet_enable = (($statusnet_post && x($_REQUEST,'statusnet_enable')) ? intval($_REQUEST['statusnet_enable']) : 0); + // if API is used, default to the chosen settings + if ($b['api_source'] && intval(PConfig::get(local_user(), 'statusnet', 'post_by_default'))) { + $statusnet_enable = 1; + } - // if API is used, default to the chosen settings - if($_REQUEST['api_source'] && intval(get_pconfig(local_user(),'statusnet','post_by_default'))) - $statusnet_enable = 1; + if (!$statusnet_enable) { + return; + } - if(! $statusnet_enable) - return; + if (strlen($b['postopts'])) { + $b['postopts'] .= ','; + } - if(strlen($b['postopts'])) - $b['postopts'] .= ','; - $b['postopts'] .= 'statusnet'; - } + $b['postopts'] .= 'statusnet'; } -if (! function_exists( 'short_link' )) { -function short_link($url) { - require_once('library/slinky.php'); - $slinky = new Slinky( $url ); - $yourls_url = get_config('yourls','url1'); - if ($yourls_url) { - $yourls_username = get_config('yourls','username1'); - $yourls_password = get_config('yourls', 'password1'); - $yourls_ssl = get_config('yourls', 'ssl1'); - $yourls = new Slinky_YourLS(); - $yourls->set( 'username', $yourls_username ); - $yourls->set( 'password', $yourls_password ); - $yourls->set( 'ssl', $yourls_ssl ); - $yourls->set( 'yourls-url', $yourls_url ); - $slinky->set_cascade( array( $yourls, new Slinky_UR1ca(), new Slinky_Trim(), new Slinky_IsGd(), new Slinky_TinyURL() ) ); - } - else { - // setup a cascade of shortening services - // try to get a short link from these services - // in the order ur1.ca, trim, id.gd, tinyurl - $slinky->set_cascade( array( new Slinky_UR1ca(), new Slinky_Trim(), new Slinky_IsGd(), new Slinky_TinyURL() ) ); - } - return $slinky->short(); -} }; - -function statusnet_shortenmsg($b, $max_char) { - require_once("include/bbcode.php"); - require_once("include/html2plain.php"); - - // Looking for the first image - $image = ''; - if(preg_match("/\[img\=([0-9]*)x([0-9]*)\](.*?)\[\/img\]/is",$b['body'],$matches)) - $image = $matches[3]; - - if ($image == '') - if(preg_match("/\[img\](.*?)\[\/img\]/is",$b['body'],$matches)) - $image = $matches[1]; - - $multipleimages = (strpos($b['body'], "[img") != strrpos($b['body'], "[img")); - - // When saved into the database the content is sent through htmlspecialchars - // That means that we have to decode all image-urls - $image = htmlspecialchars_decode($image); - - $body = $b["body"]; - if ($b["title"] != "") - $body = $b["title"]."\n\n".$body; - - if (strpos($body, "[bookmark") !== false) { - // splitting the text in two parts: - // before and after the bookmark - $pos = strpos($body, "[bookmark"); - $body1 = substr($body, 0, $pos); - $body2 = substr($body, $pos); - - // Removing all quotes after the bookmark - // they are mostly only the content after the bookmark. - $body2 = preg_replace("/\[quote\=([^\]]*)\](.*?)\[\/quote\]/ism",'',$body2); - $body2 = preg_replace("/\[quote\](.*?)\[\/quote\]/ism",'',$body2); - $body = $body1.$body2; - } - - // Add some newlines so that the message could be cut better - $body = str_replace(array("[quote", "[bookmark", "[/bookmark]", "[/quote]"), - array("\n[quote", "\n[bookmark", "[/bookmark]\n", "[/quote]\n"), $body); - - // remove the recycle signs and the names since they aren't helpful on twitter - // recycle 1 - $recycle = html_entity_decode("♲ ", ENT_QUOTES, 'UTF-8'); - $body = preg_replace( '/'.$recycle.'\[url\=(\w+.*?)\](\w+.*?)\[\/url\]/i', "\n", $body); - // recycle 2 (Test) - $recycle = html_entity_decode("◌ ", ENT_QUOTES, 'UTF-8'); - $body = preg_replace( '/'.$recycle.'\[url\=(\w+.*?)\](\w+.*?)\[\/url\]/i', "\n", $body); - - // remove the share element - //$body = preg_replace("/\[share(.*?)\](.*?)\[\/share\]/ism","\n\n$2\n\n",$body); - - // At first convert the text to html - $html = bbcode($body, false, false, 2); - - // Then convert it to plain text - //$msg = trim($b['title']." \n\n".html2plain($html, 0, true)); - $msg = trim(html2plain($html, 0, true)); - $msg = html_entity_decode($msg,ENT_QUOTES,'UTF-8'); - - // Removing multiple newlines - while (strpos($msg, "\n\n\n") !== false) - $msg = str_replace("\n\n\n", "\n\n", $msg); - - // Removing multiple spaces - while (strpos($msg, " ") !== false) - $msg = str_replace(" ", " ", $msg); - - $origmsg = $msg; - - // Removing URLs - $msg = preg_replace('/(https?\:\/\/[a-zA-Z0-9\:\/\-\?\&\;\.\=\_\~\#\%\$\!\+\,]+)/i', "", $msg); - - $msg = trim($msg); - - $link = ''; - // look for bookmark-bbcode and handle it with priority - if(preg_match("/\[bookmark\=([^\]]*)\](.*?)\[\/bookmark\]/is",$b['body'],$matches)) - $link = $matches[1]; - - $multiplelinks = (strpos($b['body'], "[bookmark") != strrpos($b['body'], "[bookmark")); - - // If there is no bookmark element then take the first link - if ($link == '') { - $links = collecturls($html); - if (sizeof($links) > 0) { - reset($links); - $link = current($links); - } - $multiplelinks = (sizeof($links) > 1); - } - - $msglink = ""; - if ($multiplelinks) - $msglink = $b["plink"]; - else if ($link != "") - $msglink = $link; - else if ($multipleimages) - $msglink = $b["plink"]; - else if ($image != "") - $msglink = $image; - - if (($msglink == "") and strlen($msg) > $max_char) - $msglink = $b["plink"]; - - // If the message is short enough then don't modify it. (if the link exists in the original message) - if ((strlen(trim($origmsg)) <= $max_char) AND (($msglink == "") OR strpos($origmsg, $msglink))) - return(array("msg"=>trim($origmsg), "image"=>"")); - - // If the message is short enough and contains a picture then post the picture as well - if ((strlen(trim($origmsg)) <= ($max_char - 20)) AND strpos($origmsg, $msglink)) - return(array("msg"=>trim($origmsg), "image"=>$image)); - - // If the message is short enough and the link exists in the original message don't modify it as well - if ((strlen(trim($origmsg)) <= $max_char) AND strpos($origmsg, $msglink)) - return(array("msg"=>trim($origmsg), "image"=>"")); - - // Preserve the unshortened link - $orig_link = $msglink; - - if (strlen($msglink) > 20) - $msglink = short_link($msglink); - - if (strlen(trim($msg." ".$msglink)) > $max_char) { - $msg = substr($msg, 0, $max_char - (strlen($msglink))); - $lastchar = substr($msg, -1); - $msg = substr($msg, 0, -1); - $pos = strrpos($msg, "\n"); - if ($pos > 0) - $msg = substr($msg, 0, $pos); - else if ($lastchar != "\n") - $msg = substr($msg, 0, -3)."..."; - } - //$msg = str_replace("\n", " ", $msg); - - // Removing multiple spaces - again - while (strpos($msg, " ") !== false) - $msg = str_replace(" ", " ", $msg); - - //return(array("msg"=>trim($msg."\n".$msglink), "image"=>$image)); - - // Looking if the link points to an image - $img_str = fetch_url($orig_link); - - $tempfile = tempnam(get_config("system","temppath"), "cache"); - file_put_contents($tempfile, $img_str); - $mime = image_type_to_mime_type(exif_imagetype($tempfile)); - unlink($tempfile); - - if (($image == $orig_link) OR (substr($mime, 0, 6) == "image/")) - return(array("msg"=>trim($msg), "image"=>$orig_link)); - else if (($image != $orig_link) AND ($image != "") AND (strlen($msg." ".$msglink) <= ($max_char - 20))) - return(array("msg"=>trim($msg." ".$msglink)."\n", "image"=>$image)); - else - return(array("msg"=>trim($msg." ".$msglink), "image"=>"")); +function statusnet_action(App $a, $uid, $pid, $action) +{ + $api = PConfig::get($uid, 'statusnet', 'baseapi'); + $ckey = PConfig::get($uid, 'statusnet', 'consumerkey'); + $csecret = PConfig::get($uid, 'statusnet', 'consumersecret'); + $otoken = PConfig::get($uid, 'statusnet', 'oauthtoken'); + $osecret = PConfig::get($uid, 'statusnet', 'oauthsecret'); + + $connection = new StatusNetOAuth($api, $ckey, $csecret, $otoken, $osecret); + + logger("statusnet_action '" . $action . "' ID: " . $pid, LOGGER_DATA); + + switch ($action) { + case "delete": + $result = $connection->post("statuses/destroy/" . $pid); + break; + case "like": + $result = $connection->post("favorites/create/" . $pid); + break; + case "unlike": + $result = $connection->post("favorites/destroy/" . $pid); + break; + } + logger("statusnet_action '" . $action . "' send, result: " . print_r($result, true), LOGGER_DEBUG); } -function statusnet_post_hook(&$a,&$b) { - +function statusnet_post_hook(App $a, &$b) +{ /** - * Post to statusnet + * Post to GNU Social */ + if (!PConfig::get($b["uid"], 'statusnet', 'import')) { + if ($b['deleted'] || $b['private'] || ($b['created'] !== $b['edited'])) + return; + } + + $api = PConfig::get($b["uid"], 'statusnet', 'baseapi'); + $hostname = preg_replace("=https?://([\w\.]*)/.*=ism", "$1", $api); + + if ($b['parent'] != $b['id']) { + logger("statusnet_post_hook: parameter " . print_r($b, true), LOGGER_DATA); + + // Looking if its a reply to a GNU Social post + $hostlength = strlen($hostname) + 2; + if ((substr($b["parent-uri"], 0, $hostlength) != $hostname . "::") && (substr($b["extid"], 0, $hostlength) != $hostname . "::") && (substr($b["thr-parent"], 0, $hostlength) != $hostname . "::")) { + logger("statusnet_post_hook: no GNU Social post " . $b["parent"]); + return; + } + + $r = q("SELECT `item`.`author-link`, `item`.`uri`, `contact`.`nick` AS contact_nick + FROM `item` INNER JOIN `contact` ON `contact`.`id` = `item`.`contact-id` + WHERE `item`.`uri` = '%s' AND `item`.`uid` = %d LIMIT 1", dbesc($b["thr-parent"]), intval($b["uid"])); + + if (!count($r)) { + logger("statusnet_post_hook: no parent found " . $b["thr-parent"]); + return; + } else { + $iscomment = true; + $orig_post = $r[0]; + } + + //$nickname = "@[url=".$orig_post["author-link"]."]".$orig_post["contact_nick"]."[/url]"; + //$nicknameplain = "@".$orig_post["contact_nick"]; + + $nick = preg_replace("=https?://(.*)/(.*)=ism", "$2", $orig_post["author-link"]); + + $nickname = "@[url=" . $orig_post["author-link"] . "]" . $nick . "[/url]"; + $nicknameplain = "@" . $nick; + + logger("statusnet_post_hook: comparing " . $nickname . " and " . $nicknameplain . " with " . $b["body"], LOGGER_DEBUG); + if ((strpos($b["body"], $nickname) === false) && (strpos($b["body"], $nicknameplain) === false)) { + $b["body"] = $nickname . " " . $b["body"]; + } + + logger("statusnet_post_hook: parent found " . print_r($orig_post, true), LOGGER_DEBUG); + } else { + $iscomment = false; - if($b['deleted'] || $b['private'] || ($b['created'] !== $b['edited'])) + if ($b['private'] || !strstr($b['postopts'], 'statusnet')) { + return; + } + + // 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]); + if ($b['contact-id'] != $self['id']) { + return; + } + } + + if (($b['verb'] == ACTIVITY_POST) && $b['deleted']) { + statusnet_action($a, $b["uid"], substr($orig_post["uri"], $hostlength), "delete"); + } + + if ($b['verb'] == ACTIVITY_LIKE) { + logger("statusnet_post_hook: parameter 2 " . substr($b["thr-parent"], $hostlength), LOGGER_DEBUG); + if ($b['deleted']) + statusnet_action($a, $b["uid"], substr($b["thr-parent"], $hostlength), "unlike"); + else + statusnet_action($a, $b["uid"], substr($b["thr-parent"], $hostlength), "like"); return; + } - if(! strstr($b['postopts'],'statusnet')) + if ($b['deleted'] || ($b['created'] !== $b['edited'])) { return; + } - if($b['parent'] != $b['id']) + // if posts comes from GNU Social don't send it back + if ($b['extid'] == NETWORK_STATUSNET) { return; + } - // if posts comes from statusnet don't send it back - if($b['app'] == "StatusNet") + if ($b['app'] == "StatusNet") { return; + } - logger('statusnet post invoked'); + logger('GNU Socialpost invoked'); - load_pconfig($b['uid'], 'statusnet'); + PConfig::load($b['uid'], 'statusnet'); - $api = get_pconfig($b['uid'], 'statusnet', 'baseapi'); - $ckey = get_pconfig($b['uid'], 'statusnet', 'consumerkey'); - $csecret = get_pconfig($b['uid'], 'statusnet', 'consumersecret'); - $otoken = get_pconfig($b['uid'], 'statusnet', 'oauthtoken'); - $osecret = get_pconfig($b['uid'], 'statusnet', 'oauthsecret'); - $intelligent_shortening = get_pconfig($b['uid'], 'statusnet', 'intelligent_shortening'); + $api = PConfig::get($b['uid'], 'statusnet', 'baseapi'); + $ckey = PConfig::get($b['uid'], 'statusnet', 'consumerkey'); + $csecret = PConfig::get($b['uid'], 'statusnet', 'consumersecret'); + $otoken = PConfig::get($b['uid'], 'statusnet', 'oauthtoken'); + $osecret = PConfig::get($b['uid'], 'statusnet', 'oauthsecret'); - // Global setting overrides this - if (get_config('statusnet','intelligent_shortening')) - $intelligent_shortening = get_config('statusnet','intelligent_shortening'); + if ($ckey && $csecret && $otoken && $osecret) { + // If it's a repeated message from GNU Social then do a native retweet and exit + if (statusnet_is_retweet($a, $b['uid'], $b['body'])) { + return; + } - if($ckey && $csecret && $otoken && $osecret) { + require_once 'include/bbcode.php'; + $dent = new StatusNetOAuth($api, $ckey, $csecret, $otoken, $osecret); + $max_char = $dent->get_maxlength(); // max. length for a dent - require_once('include/bbcode.php'); - $dent = new StatusNetOAuth($api,$ckey,$csecret,$otoken,$osecret); - $max_char = $dent->get_maxlength(); // max. length for a dent - // we will only work with up to two times the length of the dent - // we can later send to StatusNet. This way we can "gain" some - // information during shortening of potential links but do not - // shorten all the links in a 200000 character long essay. + PConfig::set($b['uid'], 'statusnet', 'max_char', $max_char); $tempfile = ""; - $intelligent_shortening = get_config('statusnet','intelligent_shortening'); - if (!$intelligent_shortening) { - if (! $b['title']=='') { - $tmp = $b['title'].": \n".$b['body']; - // $tmp = substr($tmp, 0, 4*$max_char); - } else { - $tmp = $b['body']; // substr($b['body'], 0, 3*$max_char); - } - // if [url=bla][img]blub.png[/img][/url] get blub.png - $tmp = preg_replace( '/\[url\=(https?\:\/\/[a-zA-Z0-9\:\/\-\?\&\;\.\=\_\~\#\%\$\!\+\,]+)\]\[img\](\\w+.*?)\\[\\/img\]\\[\\/url\]/i', '$2', $tmp); - // preserve links to images, videos and audios - $tmp = preg_replace( '/\[img\=([0-9]*)x([0-9]*)\](.*?)\[\/img\]/ism', '$3', $tmp); - $tmp = preg_replace( '/\[\\/?img(\\s+.*?\]|\])/i', '', $tmp); - $tmp = preg_replace( '/\[\\/?video(\\s+.*?\]|\])/i', '', $tmp); - $tmp = preg_replace( '/\[\\/?youtube(\\s+.*?\]|\])/i', '', $tmp); - $tmp = preg_replace( '/\[\\/?vimeo(\\s+.*?\]|\])/i', '', $tmp); - $tmp = preg_replace( '/\[\\/?audio(\\s+.*?\]|\])/i', '', $tmp); - $linksenabled = get_pconfig($b['uid'],'statusnet','post_taglinks'); - // if a #tag is linked, don't send the [url] over to SN - // that is, don't send if the option is not set in the - // connector settings - if ($linksenabled=='0') { - // #-tags - $tmp = preg_replace( '/#\[url\=(\w+.*?)\](\w+.*?)\[\/url\]/i', '#$2', $tmp); - // @-mentions - $tmp = preg_replace( '/@\[url\=(\w+.*?)\](\w+.*?)\[\/url\]/i', '@$2', $tmp); - // recycle 1 - $recycle = html_entity_decode("♲ ", ENT_QUOTES, 'UTF-8'); - $tmp = preg_replace( '/'.$recycle.'\[url\=(\w+.*?)\](\w+.*?)\[\/url\]/i', $recycle.'$2', $tmp); - // recycle 2 (test) - $recycle = html_entity_decode("◌ ", ENT_QUOTES, 'UTF-8'); - $tmp = preg_replace( '/'.$recycle.'\[url\=(\w+.*?)\](\w+.*?)\[\/url\]/i', $recycle.'$2', $tmp); - } - // preserve links to webpages - $tmp = preg_replace( '/\[url\=(https?\:\/\/[a-zA-Z0-9\:\/\-\?\&\;\.\=\_\~\#\%\$\!\+\,]+)\](\w+.*?)\[\/url\]/i', '$2 $1', $tmp); - $tmp = preg_replace( '/\[bookmark\=(https?\:\/\/[a-zA-Z0-9\:\/\-\?\&\;\.\=\_\~\#\%\$\!\+\,]+)\](\w+.*?)\[\/bookmark\]/i', '$2 $1', $tmp); - // find all http or https links in the body of the entry and - // apply the shortener if the link is longer then 20 characters - if (( strlen($tmp)>$max_char ) && ( $max_char > 0 )) { - preg_match_all ( '/(https?\:\/\/[a-zA-Z0-9\:\/\-\?\&\;\.\=\_\~\#\%\$\!\+\,]+)/i', $tmp, $allurls ); - foreach ($allurls as $url) { - foreach ($url as $u) { - if (strlen($u)>20) { - $sl = short_link($u); - $tmp = str_replace( $u, $sl, $tmp ); - } - } - } - } - // ok, all the links we want to send out are save, now strip - // away the remaining bbcode - //$msg = strip_tags(bbcode($tmp, false, false)); - $msg = bbcode($tmp, false, false, true); - $msg = str_replace(array('
','
'),"\n",$msg); - $msg = strip_tags($msg); - - // quotes not working - let's try this - $msg = html_entity_decode($msg); - - if (( strlen($msg) > $max_char) && $max_char > 0) { - $shortlink = short_link( $b['plink'] ); - // the new message will be shortened such that "... $shortlink" - // will fit into the character limit - $msg = nl2br(substr($msg, 0, $max_char-strlen($shortlink)-4)); - $msg = str_replace(array('
','
'),' ',$msg); - $e = explode(' ', $msg); - // remove the last word from the cut down message to - // avoid sending cut words to the MicroBlog - array_pop($e); - $msg = implode(' ', $e); - $msg .= '... ' . $shortlink; - } - - $msg = trim($msg); - $postdata = array('status' => $msg); - } else { - $msgarr = statusnet_shortenmsg($b, $max_char); - $msg = $msgarr["msg"]; + require_once "include/plaintext.php"; + require_once "include/network.php"; + $msgarr = plaintext($b, $max_char, true, 7); + $msg = $msgarr["text"]; + + if (($msg == "") && isset($msgarr["title"])) + $msg = shortenmsg($msgarr["title"], $max_char - 50); + + $image = ""; + + if (isset($msgarr["url"]) && ($msgarr["type"] != "photo")) { + if ((strlen($msgarr["url"]) > 20) && + ((strlen($msg . " \n" . $msgarr["url"]) > $max_char))) { + $msg .= " \n" . short_link($msgarr["url"]); + } else { + $msg .= " \n" . $msgarr["url"]; + } + } elseif (isset($msgarr["image"]) && ($msgarr["type"] != "video")) { $image = $msgarr["image"]; - if ($image != "") { - $img_str = fetch_url($image); - $tempfile = tempnam(get_config("system","temppath"), "cache"); - file_put_contents($tempfile, $img_str); - $postdata = array("status" => $msg, "media[]" => $tempfile); - } else - $postdata = array("status"=>$msg); + } + + if ($image != "") { + $img_str = fetch_url($image); + $tempfile = tempnam(get_temppath(), "cache"); + file_put_contents($tempfile, $img_str); + $postdata = ["status" => $msg, "media[]" => $tempfile]; + } else { + $postdata = ["status" => $msg]; } // and now dent it :-) - if(strlen($msg)) { - - // New code that is able to post pictures - require_once("addon/statusnet/codebird.php"); - $cb = \CodebirdSN\CodebirdSN::getInstance(); - $cb->setAPIEndpoint($api); - $cb->setConsumerKey($ckey, $csecret); - $cb->setToken($otoken, $osecret); - $result = $cb->statuses_update($postdata); - //$result = $dent->post('statuses/update', $postdata); - logger('statusnet_post send, result: ' . print_r($result, true). - "\nmessage: ".$msg, LOGGER_DEBUG."\nOriginal post: ".print_r($b, true)."\nPost Data: ".print_r($postdata, true)); - if ($result->error) { - logger('Send to StatusNet failed: "' . $result->error . '"'); - } - } - if ($tempfile != "") + if (strlen($msg)) { + if ($iscomment) { + $postdata["in_reply_to_status_id"] = substr($orig_post["uri"], $hostlength); + logger('statusnet_post send reply ' . print_r($postdata, true), LOGGER_DEBUG); + } + + // New code that is able to post pictures + require_once "addon/statusnet/codebird.php"; + $cb = \CodebirdSN\CodebirdSN::getInstance(); + $cb->setAPIEndpoint($api); + $cb->setConsumerKey($ckey, $csecret); + $cb->setToken($otoken, $osecret); + $result = $cb->statuses_update($postdata); + //$result = $dent->post('statuses/update', $postdata); + logger('statusnet_post send, result: ' . print_r($result, true) . + "\nmessage: " . $msg, LOGGER_DEBUG . "\nOriginal post: " . print_r($b, true) . "\nPost Data: " . print_r($postdata, true)); + + if ($result->source) { + PConfig::set($b["uid"], "statusnet", "application_name", strip_tags($result->source)); + } + + if ($result->error) { + logger('Send to GNU Social failed: "' . $result->error . '"'); + } elseif ($iscomment) { + logger('statusnet_post: Update extid ' . $result->id . " for post id " . $b['id']); + q("UPDATE `item` SET `extid` = '%s', `body` = '%s' WHERE `id` = %d", + dbesc($hostname . "::" . $result->id), + dbesc($result->text), + intval($b['id']) + ); + } + } + if ($tempfile != "") { unlink($tempfile); + } } } -function statusnet_plugin_admin_post(&$a){ - - $sites = array(); - - foreach($_POST['sitename'] as $id=>$sitename){ - $sitename=trim($sitename); - $apiurl=trim($_POST['apiurl'][$id]); - if (! (substr($apiurl, -1)=='/')) - $apiurl=$apiurl.'/'; - $secret=trim($_POST['secret'][$id]); - $key=trim($_POST['key'][$id]); - $applicationname = ((x($_POST, 'applicationname')) ? notags(trim($_POST['applicationname'][$id])):''); - if ($sitename!="" && - $apiurl!="" && - $secret!="" && - $key!="" && - !x($_POST['delete'][$id])){ - - $sites[] = Array( - 'sitename' => $sitename, - 'apiurl' => $apiurl, - 'consumersecret' => $secret, - 'consumerkey' => $key, - 'applicationname' => $applicationname - ); +function statusnet_plugin_admin_post(App $a) +{ + $sites = []; + + foreach ($_POST['sitename'] as $id => $sitename) { + $sitename = trim($sitename); + $apiurl = trim($_POST['apiurl'][$id]); + if (!(substr($apiurl, -1) == '/')) { + $apiurl = $apiurl . '/'; + } + $secret = trim($_POST['secret'][$id]); + $key = trim($_POST['key'][$id]); + //$applicationname = ((x($_POST, 'applicationname')) ? notags(trim($_POST['applicationname'][$id])):''); + if ($sitename != "" && + $apiurl != "" && + $secret != "" && + $key != "" && + !x($_POST['delete'][$id])) { + + $sites[] = [ + 'sitename' => $sitename, + 'apiurl' => $apiurl, + 'consumersecret' => $secret, + 'consumerkey' => $key, + //'applicationname' => $applicationname + ]; } } - - $sites = set_config('statusnet','sites', $sites); - + + $sites = Config::set('statusnet', 'sites', $sites); } -function statusnet_plugin_admin(&$a, &$o){ - - $sites = get_config('statusnet','sites'); - $sitesform=array(); - if (is_array($sites)){ - foreach($sites as $id=>$s){ - $sitesform[] = Array( - 'sitename' => Array("sitename[$id]", "Site name", $s['sitename'], ""), - 'apiurl' => Array("apiurl[$id]", "Api url", $s['apiurl'], t("Base API Path \x28remember the trailing /\x29") ), - 'secret' => Array("secret[$id]", "Secret", $s['consumersecret'], ""), - 'key' => Array("key[$id]", "Key", $s['consumerkey'], ""), - 'applicationname' => Array("applicationname[$id]", "Application name", $s['applicationname'], ""), - 'delete' => Array("delete[$id]", "Delete", False , "Check to delete this preset"), - ); +function statusnet_plugin_admin(App $a, &$o) +{ + $sites = Config::get('statusnet', 'sites'); + $sitesform = []; + if (is_array($sites)) { + foreach ($sites as $id => $s) { + $sitesform[] = [ + 'sitename' => ["sitename[$id]", "Site name", $s['sitename'], ""], + 'apiurl' => ["apiurl[$id]", "Api url", $s['apiurl'], t("Base API Path \x28remember the trailing /\x29")], + 'secret' => ["secret[$id]", "Secret", $s['consumersecret'], ""], + 'key' => ["key[$id]", "Key", $s['consumerkey'], ""], + //'applicationname' => Array("applicationname[$id]", "Application name", $s['applicationname'], ""), + 'delete' => ["delete[$id]", "Delete", False, "Check to delete this preset"], + ]; } } /* empty form to add new site */ $id++; - $sitesform[] = Array( - 'sitename' => Array("sitename[$id]", t("Site name"), "", ""), - 'apiurl' => Array("apiurl[$id]", "Api url", "", t("Base API Path \x28remember the trailing /\x29") ), - 'secret' => Array("secret[$id]", t("Consumer Secret"), "", ""), - 'key' => Array("key[$id]", t("Consumer Key"), "", ""), - 'applicationname' => Array("applicationname[$id]", t("Application name"), "", ""), - ); - - $t = get_markup_template( "admin.tpl", "addon/statusnet/" ); - $o = replace_macros($t, array( - '$submit' => t('Submit'), + $sitesform[] = [ + 'sitename' => ["sitename[$id]", t("Site name"), "", ""], + 'apiurl' => ["apiurl[$id]", "Api url", "", t("Base API Path \x28remember the trailing /\x29")], + 'secret' => ["secret[$id]", t("Consumer Secret"), "", ""], + 'key' => ["key[$id]", t("Consumer Key"), "", ""], + //'applicationname' => Array("applicationname[$id]", t("Application name"), "", ""), + ]; + + $t = get_markup_template("admin.tpl", "addon/statusnet/"); + $o = replace_macros($t, [ + '$submit' => t('Save Settings'), '$sites' => $sitesform, - )); + ]); +} + +function statusnet_prepare_body(App $a, &$b) +{ + if ($b["item"]["network"] != NETWORK_STATUSNET) { + return; + } + + if ($b["preview"]) { + $max_char = PConfig::get(local_user(), 'statusnet', 'max_char'); + if (intval($max_char) == 0) { + $max_char = 140; + } + + require_once "include/plaintext.php"; + $item = $b["item"]; + $item["plink"] = $a->get_baseurl() . "/display/" . $a->user["nickname"] . "/" . $item["parent"]; + + $r = q("SELECT `item`.`author-link`, `item`.`uri`, `contact`.`nick` AS contact_nick + FROM `item` INNER JOIN `contact` ON `contact`.`id` = `item`.`contact-id` + WHERE `item`.`uri` = '%s' AND `item`.`uid` = %d LIMIT 1", + dbesc($item["thr-parent"]), + intval(local_user())); + + if (count($r)) { + $orig_post = $r[0]; + //$nickname = "@[url=".$orig_post["author-link"]."]".$orig_post["contact_nick"]."[/url]"; + //$nicknameplain = "@".$orig_post["contact_nick"]; + + $nick = preg_replace("=https?://(.*)/(.*)=ism", "$2", $orig_post["author-link"]); + + $nickname = "@[url=" . $orig_post["author-link"] . "]" . $nick . "[/url]"; + $nicknameplain = "@" . $nick; + + if ((strpos($item["body"], $nickname) === false) && (strpos($item["body"], $nicknameplain) === false)) { + $item["body"] = $nickname . " " . $item["body"]; + } + } + + $msgarr = plaintext($item, $max_char, true, 7); + $msg = $msgarr["text"]; + + if (isset($msgarr["url"]) && ($msgarr["type"] != "photo")) { + $msg .= " " . $msgarr["url"]; + } + + if (isset($msgarr["image"])) { + $msg .= " " . $msgarr["image"]; + } + + $b['html'] = nl2br(htmlspecialchars($msg)); + } } -function statusnet_cron($a,$b) { - $last = get_config('statusnet','last_poll'); +function statusnet_cron(App $a, $b) +{ + $last = Config::get('statusnet', 'last_poll'); - $poll_interval = intval(get_config('statusnet','poll_interval')); - if(! $poll_interval) + $poll_interval = intval(Config::get('statusnet', 'poll_interval')); + if (!$poll_interval) { $poll_interval = STATUSNET_DEFAULT_POLL_INTERVAL; + } - if($last) { + if ($last) { $next = $last + ($poll_interval * 60); - if($next > time()) { + if ($next > time()) { logger('statusnet: poll intervall not reached'); return; } @@ -836,105 +842,992 @@ function statusnet_cron($a,$b) { logger('statusnet: cron_start'); $r = q("SELECT * FROM `pconfig` WHERE `cat` = 'statusnet' AND `k` = 'mirror_posts' AND `v` = '1' ORDER BY RAND() "); - if(count($r)) { - foreach($r as $rr) { - logger('statusnet: fetching for user '.$rr['uid']); + if (count($r)) { + foreach ($r as $rr) { + logger('statusnet: fetching for user ' . $rr['uid']); statusnet_fetchtimeline($a, $rr['uid']); } } + $abandon_days = intval(Config::get('system', 'account_abandon_days')); + if ($abandon_days < 1) { + $abandon_days = 0; + } + + $abandon_limit = date("Y-m-d H:i:s", time() - $abandon_days * 86400); + + $r = q("SELECT * FROM `pconfig` WHERE `cat` = 'statusnet' AND `k` = 'import' AND `v` ORDER BY RAND()"); + if (count($r)) { + foreach ($r as $rr) { + if ($abandon_days != 0) { + $user = q("SELECT `login_date` FROM `user` WHERE uid=%d AND `login_date` >= '%s'", $rr['uid'], $abandon_limit); + if (!count($user)) { + logger('abandoned account: timeline from user ' . $rr['uid'] . ' will not be imported'); + continue; + } + } + + logger('statusnet: importing timeline from user ' . $rr['uid']); + statusnet_fetchhometimeline($a, $rr["uid"], $rr["v"]); + } + } + logger('statusnet: cron_end'); - set_config('statusnet','last_poll', time()); + Config::set('statusnet', 'last_poll', time()); } -function statusnet_fetchtimeline($a, $uid) { - $ckey = get_pconfig($uid, 'statusnet', 'consumerkey'); - $csecret = get_pconfig($uid, 'statusnet', 'consumersecret'); - $api = get_pconfig($uid, 'statusnet', 'baseapi'); - $otoken = get_pconfig($uid, 'statusnet', 'oauthtoken'); - $osecret = get_pconfig($uid, 'statusnet', 'oauthsecret'); - $lastid = get_pconfig($uid, 'statusnet', 'lastid'); - - // get the application name for the SN app - // 1st try personal config, then system config and fallback to the - // hostname of the node if neither one is set. - $application_name = get_pconfig( $uid, 'statusnet', 'application_name'); - if ($application_name == "") - $application_name = get_config('statusnet', 'application_name'); - if ($application_name == "") +function statusnet_fetchtimeline(App $a, $uid) +{ + $ckey = PConfig::get($uid, 'statusnet', 'consumerkey'); + $csecret = PConfig::get($uid, 'statusnet', 'consumersecret'); + $api = PConfig::get($uid, 'statusnet', 'baseapi'); + $otoken = PConfig::get($uid, 'statusnet', 'oauthtoken'); + $osecret = PConfig::get($uid, 'statusnet', 'oauthsecret'); + $lastid = PConfig::get($uid, 'statusnet', 'lastid'); + + require_once 'mod/item.php'; + require_once 'include/items.php'; + + // get the application name for the SN app + // 1st try personal config, then system config and fallback to the + // hostname of the node if neither one is set. + $application_name = PConfig::get($uid, 'statusnet', 'application_name'); + if ($application_name == "") { + $application_name = Config::get('statusnet', 'application_name'); + } + if ($application_name == "") { $application_name = $a->get_hostname(); + } - $connection = new StatusNetOAuth($api, $ckey,$csecret,$otoken,$osecret); + $connection = new StatusNetOAuth($api, $ckey, $csecret, $otoken, $osecret); - $parameters = array("exclude_replies" => true, "trim_user" => true, "contributor_details" => false, "include_rts" => false); + $parameters = ["exclude_replies" => true, "trim_user" => true, "contributor_details" => false, "include_rts" => false]; $first_time = ($lastid == ""); - if ($lastid <> "") + if ($lastid <> "") { $parameters["since_id"] = $lastid; + } $items = $connection->get('statuses/user_timeline', $parameters); - if (!is_array($items)) + if (!is_array($items)) { return; + } $posts = array_reverse($items); - if (count($posts)) { - foreach ($posts as $post) { - if ($post->id > $lastid) - $lastid = $post->id; + if (count($posts)) { + foreach ($posts as $post) { + if ($post->id > $lastid) + $lastid = $post->id; - if ($first_time) - continue; + if ($first_time) { + continue; + } - if ($post->source == "activity") - continue; + if ($post->source == "activity") { + continue; + } - if (is_object($post->retweeted_status)) - continue; + if (is_object($post->retweeted_status)) { + continue; + } - if ($post->in_reply_to_status_id != "") - continue; + if ($post->in_reply_to_status_id != "") { + continue; + } - if (!strpos($post->source, $application_name)) { - $_SESSION["authenticated"] = true; - $_SESSION["uid"] = $uid; + if (!stristr($post->source, $application_name)) { + $_SESSION["authenticated"] = true; + $_SESSION["uid"] = $uid; - unset($_REQUEST); - $_REQUEST["type"] = "wall"; - $_REQUEST["api_source"] = true; - $_REQUEST["profile_uid"] = $uid; - $_REQUEST["source"] = "StatusNet"; + unset($_REQUEST); + $_REQUEST["type"] = "wall"; + $_REQUEST["api_source"] = true; + $_REQUEST["profile_uid"] = $uid; + //$_REQUEST["source"] = "StatusNet"; + $_REQUEST["source"] = $post->source; + $_REQUEST["extid"] = NETWORK_STATUSNET; - //$_REQUEST["date"] = $post->created_at; + if (isset($post->id)) { + $_REQUEST['message_id'] = item_new_uri($a->get_hostname(), $uid, NETWORK_STATUSNET . ":" . $post->id); + } - $_REQUEST["title"] = ""; + //$_REQUEST["date"] = $post->created_at; - $_REQUEST["body"] = $post->text; - if (is_string($post->place->name)) - $_REQUEST["location"] = $post->place->name; + $_REQUEST["title"] = ""; - if (is_string($post->place->full_name)) - $_REQUEST["location"] = $post->place->full_name; + $_REQUEST["body"] = add_page_info_to_body($post->text, true); + if (is_string($post->place->name)) { + $_REQUEST["location"] = $post->place->name; + } - if (is_array($post->geo->coordinates)) - $_REQUEST["coord"] = $post->geo->coordinates[0]." ".$post->geo->coordinates[1]; + if (is_string($post->place->full_name)) { + $_REQUEST["location"] = $post->place->full_name; + } - if (is_array($post->coordinates->coordinates)) - $_REQUEST["coord"] = $post->coordinates->coordinates[1]." ".$post->coordinates->coordinates[0]; + if (is_array($post->geo->coordinates)) { + $_REQUEST["coord"] = $post->geo->coordinates[0] . " " . $post->geo->coordinates[1]; + } - //print_r($_REQUEST); - if ($_REQUEST["body"] != "") { - logger('statusnet: posting for user '.$uid); + if (is_array($post->coordinates->coordinates)) { + $_REQUEST["coord"] = $post->coordinates->coordinates[1] . " " . $post->coordinates->coordinates[0]; + } - require_once('mod/item.php'); - item_post($a); + //print_r($_REQUEST); + if ($_REQUEST["body"] != "") { + logger('statusnet: posting for user ' . $uid); + + item_post($a); + } } - } - } + } } - set_pconfig($uid, 'statusnet', 'lastid', $lastid); + PConfig::set($uid, 'statusnet', 'lastid', $lastid); +} + +function statusnet_address($contact) +{ + $hostname = normalise_link($contact->statusnet_profile_url); + $nickname = $contact->screen_name; + + $hostname = preg_replace("=https?://([\w\.]*)/.*=ism", "$1", $contact->statusnet_profile_url); + + $address = $contact->screen_name . "@" . $hostname; + + return $address; } +function statusnet_fetch_contact($uid, $contact, $create_user) +{ + if ($contact->statusnet_profile_url == "") { + return -1; + } + + GContact::update(["url" => $contact->statusnet_profile_url, + "network" => NETWORK_STATUSNET, "photo" => $contact->profile_image_url, + "name" => $contact->name, "nick" => $contact->screen_name, + "location" => $contact->location, "about" => $contact->description, + "addr" => statusnet_address($contact), "generation" => 3]); + + $r = q("SELECT * FROM `contact` WHERE `uid` = %d AND `alias` = '%s' AND `network` = '%s'LIMIT 1", intval($uid), dbesc(normalise_link($contact->statusnet_profile_url)), dbesc(NETWORK_STATUSNET)); + + if (!count($r) && !$create_user) { + return 0; + } + + if (count($r) && ($r[0]["readonly"] || $r[0]["blocked"])) { + logger("statusnet_fetch_contact: Contact '" . $r[0]["nick"] . "' is blocked or readonly.", LOGGER_DEBUG); + return -1; + } + + if (!count($r)) { + // create contact record + q("INSERT INTO `contact` ( `uid`, `created`, `url`, `nurl`, `addr`, `alias`, `notify`, `poll`, + `name`, `nick`, `photo`, `network`, `rel`, `priority`, + `location`, `about`, `writable`, `blocked`, `readonly`, `pending` ) + VALUES ( %d, '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', %d, %d, '%s', '%s', %d, 0, 0, 0 ) ", + intval($uid), + dbesc(datetime_convert()), + dbesc($contact->statusnet_profile_url), + dbesc(normalise_link($contact->statusnet_profile_url)), + dbesc(statusnet_address($contact)), + dbesc(normalise_link($contact->statusnet_profile_url)), + dbesc(''), + dbesc(''), + dbesc($contact->name), + dbesc($contact->screen_name), + dbesc($contact->profile_image_url), + dbesc(NETWORK_STATUSNET), + intval(CONTACT_IS_FRIEND), + intval(1), + dbesc($contact->location), + dbesc($contact->description), + intval(1) + ); + + $r = q("SELECT * FROM `contact` WHERE `alias` = '%s' AND `uid` = %d AND `network` = '%s' LIMIT 1", + dbesc($contact->statusnet_profile_url), + intval($uid), + dbesc(NETWORK_STATUSNET)); + + if (!count($r)) { + return false; + } + + $contact_id = $r[0]['id']; + + Group::addMember(User::getDefaultGroup($uid), $contact_id); + + $photos = Photo::importProfilePhoto($contact->profile_image_url, $uid, $contact_id); + + q("UPDATE `contact` SET `photo` = '%s', + `thumb` = '%s', + `micro` = '%s', + `avatar-date` = '%s' + WHERE `id` = %d", + dbesc($photos[0]), + dbesc($photos[1]), + dbesc($photos[2]), + dbesc(datetime_convert()), + intval($contact_id) + ); + } else { + // update profile photos once every two weeks as we have no notification of when they change. + //$update_photo = (($r[0]['avatar-date'] < datetime_convert('','','now -2 days')) ? true : false); + $update_photo = ($r[0]['avatar-date'] < datetime_convert('', '', 'now -12 hours')); + + // check that we have all the photos, this has been known to fail on occasion + if ((!$r[0]['photo']) || (!$r[0]['thumb']) || (!$r[0]['micro']) || ($update_photo)) { + logger("statusnet_fetch_contact: Updating contact " . $contact->screen_name, LOGGER_DEBUG); + + $photos = Photo::importProfilePhoto($contact->profile_image_url, $uid, $r[0]['id']); + + q("UPDATE `contact` SET `photo` = '%s', + `thumb` = '%s', + `micro` = '%s', + `name-date` = '%s', + `uri-date` = '%s', + `avatar-date` = '%s', + `url` = '%s', + `nurl` = '%s', + `addr` = '%s', + `name` = '%s', + `nick` = '%s', + `location` = '%s', + `about` = '%s' + WHERE `id` = %d", + dbesc($photos[0]), + dbesc($photos[1]), + dbesc($photos[2]), + dbesc(datetime_convert()), + dbesc(datetime_convert()), + dbesc(datetime_convert()), + dbesc($contact->statusnet_profile_url), + dbesc(normalise_link($contact->statusnet_profile_url)), + dbesc(statusnet_address($contact)), + dbesc($contact->name), + dbesc($contact->screen_name), + dbesc($contact->location), + dbesc($contact->description), + intval($r[0]['id']) + ); + } + } + + return $r[0]["id"]; +} + +function statusnet_fetchuser(App $a, $uid, $screen_name = "", $user_id = "") +{ + $ckey = PConfig::get($uid, 'statusnet', 'consumerkey'); + $csecret = PConfig::get($uid, 'statusnet', 'consumersecret'); + $api = PConfig::get($uid, 'statusnet', 'baseapi'); + $otoken = PConfig::get($uid, 'statusnet', 'oauthtoken'); + $osecret = PConfig::get($uid, 'statusnet', 'oauthsecret'); + + require_once "addon/statusnet/codebird.php"; + + $cb = \Codebird\Codebird::getInstance(); + $cb->setConsumerKey($ckey, $csecret); + $cb->setToken($otoken, $osecret); + + $r = q("SELECT * FROM `contact` WHERE `self` = 1 AND `uid` = %d LIMIT 1", + intval($uid)); + + if (count($r)) { + $self = $r[0]; + } else { + return; + } + + $parameters = []; + + if ($screen_name != "") { + $parameters["screen_name"] = $screen_name; + } + + if ($user_id != "") { + $parameters["user_id"] = $user_id; + } + + // Fetching user data + $user = $cb->users_show($parameters); + + if (!is_object($user)) { + return; + } + + $contact_id = statusnet_fetch_contact($uid, $user, true); + + return $contact_id; +} + +function statusnet_createpost(App $a, $uid, $post, $self, $create_user, $only_existing_contact) +{ + require_once "include/html2bbcode.php"; + + logger("statusnet_createpost: start", LOGGER_DEBUG); + + $api = PConfig::get($uid, 'statusnet', 'baseapi'); + $hostname = preg_replace("=https?://([\w\.]*)/.*=ism", "$1", $api); + + $postarray = []; + $postarray['network'] = NETWORK_STATUSNET; + $postarray['gravity'] = 0; + $postarray['uid'] = $uid; + $postarray['wall'] = 0; + + if (is_object($post->retweeted_status)) { + $content = $post->retweeted_status; + statusnet_fetch_contact($uid, $content->user, false); + } else { + $content = $post; + } + + $postarray['uri'] = $hostname . "::" . $content->id; + + $r = q("SELECT * FROM `item` WHERE `extid` = '%s' AND `uid` = %d LIMIT 1", + dbesc($postarray['uri']), + intval($uid) + ); + + if (count($r)) { + return []; + } + + $contactid = 0; + + if ($content->in_reply_to_status_id != "") { + + $parent = $hostname . "::" . $content->in_reply_to_status_id; + + $r = q("SELECT * FROM `item` WHERE `uri` = '%s' AND `uid` = %d LIMIT 1", + dbesc($parent), + intval($uid) + ); + if (count($r)) { + $postarray['thr-parent'] = $r[0]["uri"]; + $postarray['parent-uri'] = $r[0]["parent-uri"]; + $postarray['parent'] = $r[0]["parent"]; + $postarray['object-type'] = ACTIVITY_OBJ_COMMENT; + } else { + $r = q("SELECT * FROM `item` WHERE `extid` = '%s' AND `uid` = %d LIMIT 1", + dbesc($parent), + intval($uid) + ); + if (count($r)) { + $postarray['thr-parent'] = $r[0]['uri']; + $postarray['parent-uri'] = $r[0]['parent-uri']; + $postarray['parent'] = $r[0]['parent']; + $postarray['object-type'] = ACTIVITY_OBJ_COMMENT; + } else { + $postarray['thr-parent'] = $postarray['uri']; + $postarray['parent-uri'] = $postarray['uri']; + $postarray['object-type'] = ACTIVITY_OBJ_NOTE; + } + } + + // Is it me? + $own_url = PConfig::get($uid, 'statusnet', 'own_url'); + + if ($content->user->id == $own_url) { + $r = q("SELECT * FROM `contact` WHERE `self` = 1 AND `uid` = %d LIMIT 1", + intval($uid)); + + if (count($r)) { + $contactid = $r[0]["id"]; + + $postarray['owner-name'] = $r[0]["name"]; + $postarray['owner-link'] = $r[0]["url"]; + $postarray['owner-avatar'] = $r[0]["photo"]; + } else { + return []; + } + } + // Don't create accounts of people who just comment something + $create_user = false; + } else { + $postarray['parent-uri'] = $postarray['uri']; + $postarray['object-type'] = ACTIVITY_OBJ_NOTE; + } + + if ($contactid == 0) { + $contactid = statusnet_fetch_contact($uid, $post->user, $create_user); + $postarray['owner-name'] = $post->user->name; + $postarray['owner-link'] = $post->user->statusnet_profile_url; + $postarray['owner-avatar'] = $post->user->profile_image_url; + } + if (($contactid == 0) && !$only_existing_contact) { + $contactid = $self['id']; + } elseif ($contactid <= 0) { + return []; + } + + $postarray['contact-id'] = $contactid; + + $postarray['verb'] = ACTIVITY_POST; + + $postarray['author-name'] = $content->user->name; + $postarray['author-link'] = $content->user->statusnet_profile_url; + $postarray['author-avatar'] = $content->user->profile_image_url; + + // To-Do: Maybe unreliable? Can the api be entered without trailing "/"? + $hostname = str_replace("/api/", "/notice/", PConfig::get($uid, 'statusnet', 'baseapi')); + + $postarray['plink'] = $hostname . $content->id; + $postarray['app'] = strip_tags($content->source); + + if ($content->user->protected) { + $postarray['private'] = 1; + $postarray['allow_cid'] = '<' . $self['id'] . '>'; + } + + $postarray['body'] = html2bbcode($content->statusnet_html); + + $converted = statusnet_convertmsg($a, $postarray['body'], false); + $postarray['body'] = $converted["body"]; + $postarray['tag'] = $converted["tags"]; + + $postarray['created'] = datetime_convert('UTC', 'UTC', $content->created_at); + $postarray['edited'] = datetime_convert('UTC', 'UTC', $content->created_at); + + if (is_string($content->place->name)) { + $postarray["location"] = $content->place->name; + } + + if (is_string($content->place->full_name)) { + $postarray["location"] = $content->place->full_name; + } + + if (is_array($content->geo->coordinates)) { + $postarray["coord"] = $content->geo->coordinates[0] . " " . $content->geo->coordinates[1]; + } + + if (is_array($content->coordinates->coordinates)) { + $postarray["coord"] = $content->coordinates->coordinates[1] . " " . $content->coordinates->coordinates[0]; + } + + logger("statusnet_createpost: end", LOGGER_DEBUG); + + return $postarray; +} + +function statusnet_checknotification(App $a, $uid, $own_url, $top_item, $postarray) +{ + // This function necer worked and need cleanup + $user = q("SELECT * FROM `contact` WHERE `uid` = %d AND `self` LIMIT 1", + intval($uid) + ); + + if (!count($user)) { + return; + } + + // Is it me? + if (link_compare($user[0]["url"], $postarray['author-link'])) { + return; + } + + $own_user = q("SELECT * FROM `contact` WHERE `uid` = %d AND `alias` = '%s' LIMIT 1", + intval($uid), + dbesc($own_url) + ); + + if (!count($own_user)) { + return; + } + + // Is it me from GNU Social? + if (link_compare($own_user[0]["url"], $postarray['author-link'])) { + return; + } + + $myconv = q("SELECT `author-link`, `author-avatar`, `parent` FROM `item` WHERE `parent-uri` = '%s' AND `uid` = %d AND `parent` != 0 AND `deleted` = 0", + dbesc($postarray['parent-uri']), + intval($uid) + ); + + if (count($myconv)) { + foreach ($myconv as $conv) { + // now if we find a match, it means we're in this conversation + if (!link_compare($conv['author-link'], $user[0]["url"]) && !link_compare($conv['author-link'], $own_user[0]["url"])) { + continue; + } + + require_once 'include/enotify.php'; + + $conv_parent = $conv['parent']; + + notification([ + 'type' => NOTIFY_COMMENT, + 'notify_flags' => $user[0]['notify-flags'], + 'language' => $user[0]['language'], + 'to_name' => $user[0]['username'], + 'to_email' => $user[0]['email'], + 'uid' => $user[0]['uid'], + 'item' => $postarray, + 'link' => $a->get_baseurl() . '/display/' . urlencode(get_item_guid($top_item)), + 'source_name' => $postarray['author-name'], + 'source_link' => $postarray['author-link'], + 'source_photo' => $postarray['author-avatar'], + 'verb' => ACTIVITY_POST, + 'otype' => 'item', + 'parent' => $conv_parent, + ]); + + // only send one notification + break; + } + } +} + +function statusnet_fetchhometimeline(App $a, $uid, $mode = 1) +{ + $conversations = []; + + $ckey = PConfig::get($uid, 'statusnet', 'consumerkey'); + $csecret = PConfig::get($uid, 'statusnet', 'consumersecret'); + $api = PConfig::get($uid, 'statusnet', 'baseapi'); + $otoken = PConfig::get($uid, 'statusnet', 'oauthtoken'); + $osecret = PConfig::get($uid, 'statusnet', 'oauthsecret'); + $create_user = PConfig::get($uid, 'statusnet', 'create_user'); + + // "create_user" is deactivated, since currently you cannot add users manually by now + $create_user = true; + + logger("statusnet_fetchhometimeline: Fetching for user " . $uid, LOGGER_DEBUG); + + require_once 'library/twitteroauth.php'; + require_once 'include/items.php'; + + $connection = new StatusNetOAuth($api, $ckey, $csecret, $otoken, $osecret); + + $own_contact = statusnet_fetch_own_contact($a, $uid); + + $r = q("SELECT * FROM `contact` WHERE `id` = %d AND `uid` = %d LIMIT 1", + intval($own_contact), + intval($uid)); + + if (count($r)) { + $nick = $r[0]["nick"]; + } else { + logger("statusnet_fetchhometimeline: Own GNU Social contact not found for user " . $uid, LOGGER_DEBUG); + return; + } + + $r = q("SELECT * FROM `contact` WHERE `self` = 1 AND `uid` = %d LIMIT 1", + intval($uid)); + + if (count($r)) { + $self = $r[0]; + } else { + logger("statusnet_fetchhometimeline: Own contact not found for user " . $uid, LOGGER_DEBUG); + return; + } + + $u = q("SELECT * FROM user WHERE uid = %d LIMIT 1", + intval($uid)); + if (!count($u)) { + logger("statusnet_fetchhometimeline: Own user not found for user " . $uid, LOGGER_DEBUG); + return; + } + + $parameters = ["exclude_replies" => false, "trim_user" => false, "contributor_details" => true, "include_rts" => true]; + //$parameters["count"] = 200; + + if ($mode == 1) { + // Fetching timeline + $lastid = PConfig::get($uid, 'statusnet', 'lasthometimelineid'); + //$lastid = 1; + + $first_time = ($lastid == ""); + + if ($lastid != "") { + $parameters["since_id"] = $lastid; + } + + $items = $connection->get('statuses/home_timeline', $parameters); + + if (!is_array($items)) { + if (is_object($items) && isset($items->error)) { + $errormsg = $items->error; + } elseif (is_object($items)) { + $errormsg = print_r($items, true); + } elseif (is_string($items) || is_float($items) || is_int($items)) { + $errormsg = $items; + } else { + $errormsg = "Unknown error"; + } + + logger("statusnet_fetchhometimeline: Error fetching home timeline: " . $errormsg, LOGGER_DEBUG); + return; + } + + $posts = array_reverse($items); + + logger("statusnet_fetchhometimeline: Fetching timeline for user " . $uid . " " . sizeof($posts) . " items", LOGGER_DEBUG); + + if (count($posts)) { + foreach ($posts as $post) { + + if ($post->id > $lastid) { + $lastid = $post->id; + } + + if ($first_time) { + continue; + } + + if (isset($post->statusnet_conversation_id)) { + if (!isset($conversations[$post->statusnet_conversation_id])) { + statusnet_complete_conversation($a, $uid, $self, $create_user, $nick, $post->statusnet_conversation_id); + $conversations[$post->statusnet_conversation_id] = $post->statusnet_conversation_id; + } + } else { + $postarray = statusnet_createpost($a, $uid, $post, $self, $create_user, true); + + if (trim($postarray['body']) == "") { + continue; + } + + $item = item_store($postarray); + $postarray["id"] = $item; + + logger('statusnet_fetchhometimeline: User ' . $self["nick"] . ' posted home timeline item ' . $item); + + if ($item && !function_exists("check_item_notification")) { + statusnet_checknotification($a, $uid, $nick, $item, $postarray); + } + } + } + } + PConfig::set($uid, 'statusnet', 'lasthometimelineid', $lastid); + } + + // Fetching mentions + $lastid = PConfig::get($uid, 'statusnet', 'lastmentionid'); + $first_time = ($lastid == ""); + + if ($lastid != "") { + $parameters["since_id"] = $lastid; + } + + $items = $connection->get('statuses/mentions_timeline', $parameters); + + if (!is_array($items)) { + logger("statusnet_fetchhometimeline: Error fetching mentions: " . print_r($items, true), LOGGER_DEBUG); + return; + } + + $posts = array_reverse($items); + + logger("statusnet_fetchhometimeline: Fetching mentions for user " . $uid . " " . sizeof($posts) . " items", LOGGER_DEBUG); + + if (count($posts)) { + foreach ($posts as $post) { + if ($post->id > $lastid) { + $lastid = $post->id; + } + + if ($first_time) { + continue; + } + + $postarray = statusnet_createpost($a, $uid, $post, $self, false, false); + + if (isset($post->statusnet_conversation_id)) { + if (!isset($conversations[$post->statusnet_conversation_id])) { + statusnet_complete_conversation($a, $uid, $self, $create_user, $nick, $post->statusnet_conversation_id); + $conversations[$post->statusnet_conversation_id] = $post->statusnet_conversation_id; + } + } else { + if (trim($postarray['body']) == "") { + continue; + } + + $item = item_store($postarray); + $postarray["id"] = $item; + + logger('statusnet_fetchhometimeline: User ' . $self["nick"] . ' posted mention timeline item ' . $item); + + if ($item && function_exists("check_item_notification")) { + check_item_notification($item, $uid, NOTIFY_TAGSELF); + } + } + + $r = q("SELECT * FROM `item` WHERE `uri` = '%s' AND `uid` = %d LIMIT 1", + dbesc($postarray['uri']), + intval($uid) + ); + if (count($r)) { + $item = $r[0]['id']; + $parent_id = $r[0]['parent']; + } + + if (($item != 0) && !function_exists("check_item_notification")) { + require_once 'include/enotify.php'; + notification([ + 'type' => NOTIFY_TAGSELF, + 'notify_flags' => $u[0]['notify-flags'], + 'language' => $u[0]['language'], + 'to_name' => $u[0]['username'], + 'to_email' => $u[0]['email'], + 'uid' => $u[0]['uid'], + 'item' => $postarray, + 'link' => $a->get_baseurl() . '/display/' . urlencode(get_item_guid($item)), + 'source_name' => $postarray['author-name'], + 'source_link' => $postarray['author-link'], + 'source_photo' => $postarray['author-avatar'], + 'verb' => ACTIVITY_TAG, + 'otype' => 'item', + 'parent' => $parent_id, + ]); + } + } + } + + PConfig::set($uid, 'statusnet', 'lastmentionid', $lastid); +} + +function statusnet_complete_conversation(App $a, $uid, $self, $create_user, $nick, $conversation) +{ + $ckey = PConfig::get($uid, 'statusnet', 'consumerkey'); + $csecret = PConfig::get($uid, 'statusnet', 'consumersecret'); + $api = PConfig::get($uid, 'statusnet', 'baseapi'); + $otoken = PConfig::get($uid, 'statusnet', 'oauthtoken'); + $osecret = PConfig::get($uid, 'statusnet', 'oauthsecret'); + $own_url = PConfig::get($uid, 'statusnet', 'own_url'); + + require_once 'library/twitteroauth.php'; + + $connection = new StatusNetOAuth($api, $ckey, $csecret, $otoken, $osecret); + + $parameters["count"] = 200; + + $items = $connection->get('statusnet/conversation/' . $conversation, $parameters); + if (is_array($items)) { + $posts = array_reverse($items); + + foreach ($posts AS $post) { + $postarray = statusnet_createpost($a, $uid, $post, $self, false, false); + + if (trim($postarray['body']) == "") { + continue; + } + + $item = item_store($postarray); + $postarray["id"] = $item; + + logger('statusnet_complete_conversation: User ' . $self["nick"] . ' posted home timeline item ' . $item); + + if ($item && !function_exists("check_item_notification")) { + statusnet_checknotification($a, $uid, $nick, $item, $postarray); + } + } + } +} + +function statusnet_convertmsg(App $a, $body, $no_tags = false) +{ + require_once "include/items.php"; + require_once "include/network.php"; + + $body = preg_replace("=\[url\=https?://([0-9]*).([0-9]*).([0-9]*).([0-9]*)/([0-9]*)\](.*?)\[\/url\]=ism", "$1.$2.$3.$4/$5", $body); + + $URLSearchString = "^\[\]"; + $links = preg_match_all("/[^!#@]\[url\=([$URLSearchString]*)\](.*?)\[\/url\]/ism", $body, $matches, PREG_SET_ORDER); + + $footer = ""; + $footerurl = ""; + $footerlink = ""; + $type = ""; + + if ($links) { + foreach ($matches AS $match) { + $search = "[url=" . $match[1] . "]" . $match[2] . "[/url]"; + + logger("statusnet_convertmsg: expanding url " . $match[1], LOGGER_DEBUG); + + $expanded_url = original_url($match[1]); + + logger("statusnet_convertmsg: fetching data for " . $expanded_url, LOGGER_DEBUG); + + $oembed_data = OEmbed::fetchURL($expanded_url, true); + + logger("statusnet_convertmsg: fetching data: done", LOGGER_DEBUG); + + if ($type == "") { + $type = $oembed_data->type; + } + + if ($oembed_data->type == "video") { + //$body = str_replace($search, "[video]".$expanded_url."[/video]", $body); + $type = $oembed_data->type; + $footerurl = $expanded_url; + $footerlink = "[url=" . $expanded_url . "]" . $expanded_url . "[/url]"; + + $body = str_replace($search, $footerlink, $body); + } elseif (($oembed_data->type == "photo") && isset($oembed_data->url) && !$dontincludemedia) { + $body = str_replace($search, "[url=" . $expanded_url . "][img]" . $oembed_data->url . "[/img][/url]", $body); + } elseif ($oembed_data->type != "link") { + $body = str_replace($search, "[url=" . $expanded_url . "]" . $expanded_url . "[/url]", $body); + } else { + $img_str = fetch_url($expanded_url, true, $redirects, 4); + + $tempfile = tempnam(get_temppath(), "cache"); + file_put_contents($tempfile, $img_str); + $mime = image_type_to_mime_type(exif_imagetype($tempfile)); + unlink($tempfile); + + if (substr($mime, 0, 6) == "image/") { + $type = "photo"; + $body = str_replace($search, "[img]" . $expanded_url . "[/img]", $body); + } else { + $type = $oembed_data->type; + $footerurl = $expanded_url; + $footerlink = "[url=" . $expanded_url . "]" . $expanded_url . "[/url]"; + + $body = str_replace($search, $footerlink, $body); + } + } + } + + if ($footerurl != "") { + $footer = add_page_info($footerurl); + } + + if (($footerlink != "") && (trim($footer) != "")) { + $removedlink = trim(str_replace($footerlink, "", $body)); + + if (($removedlink == "") || strstr($body, $removedlink)) { + $body = $removedlink; + } + + $body .= $footer; + } + } + + if ($no_tags) { + return ["body" => $body, "tags" => ""]; + } + + $str_tags = ''; + + $cnt = preg_match_all("/([!#@])\[url\=([$URLSearchString]*)\](.*?)\[\/url\]/ism", $body, $matches, PREG_SET_ORDER); + if ($cnt) { + foreach ($matches as $mtch) { + if (strlen($str_tags)) { + $str_tags .= ','; + } + + if ($mtch[1] == "#") { + // Replacing the hash tags that are directed to the GNU Social server with internal links + $snhash = "#[url=" . $mtch[2] . "]" . $mtch[3] . "[/url]"; + $frdchash = '#[url=' . $a->get_baseurl() . '/search?tag=' . rawurlencode($mtch[3]) . ']' . $mtch[3] . '[/url]'; + $body = str_replace($snhash, $frdchash, $body); + + $str_tags .= $frdchash; + } else { + $str_tags .= "@[url=" . $mtch[2] . "]" . $mtch[3] . "[/url]"; + } + // To-Do: + // There is a problem with links with to GNU Social groups, so these links are stored with "@" like friendica groups + //$str_tags .= $mtch[1]."[url=".$mtch[2]."]".$mtch[3]."[/url]"; + } + } + + return ["body" => $body, "tags" => $str_tags]; +} + +function statusnet_fetch_own_contact(App $a, $uid) +{ + $ckey = PConfig::get($uid, 'statusnet', 'consumerkey'); + $csecret = PConfig::get($uid, 'statusnet', 'consumersecret'); + $api = PConfig::get($uid, 'statusnet', 'baseapi'); + $otoken = PConfig::get($uid, 'statusnet', 'oauthtoken'); + $osecret = PConfig::get($uid, 'statusnet', 'oauthsecret'); + $own_url = PConfig::get($uid, 'statusnet', 'own_url'); + + $contact_id = 0; + + if ($own_url == "") { + require_once 'library/twitteroauth.php'; + + $connection = new StatusNetOAuth($api, $ckey, $csecret, $otoken, $osecret); + + // Fetching user data + $user = $connection->get('account/verify_credentials'); + + PConfig::set($uid, 'statusnet', 'own_url', normalise_link($user->statusnet_profile_url)); + + $contact_id = statusnet_fetch_contact($uid, $user, true); + } else { + $r = q("SELECT * FROM `contact` WHERE `uid` = %d AND `alias` = '%s' LIMIT 1", + intval($uid), dbesc($own_url)); + if (count($r)) { + $contact_id = $r[0]["id"]; + } else { + PConfig::delete($uid, 'statusnet', 'own_url'); + } + } + return $contact_id; +} + +function statusnet_is_retweet(App $a, $uid, $body) +{ + $body = trim($body); + + // Skip if it isn't a pure repeated messages + // Does it start with a share? + if (strpos($body, "[share") > 0) { + return false; + } + + // Does it end with a share? + if (strlen($body) > (strrpos($body, "[/share]") + 8)) { + return false; + } + + $attributes = preg_replace("/\[share(.*?)\]\s?(.*?)\s?\[\/share\]\s?/ism", "$1", $body); + // Skip if there is no shared message in there + if ($body == $attributes) { + return false; + } + + $link = ""; + preg_match("/link='(.*?)'/ism", $attributes, $matches); + if ($matches[1] != "") { + $link = $matches[1]; + } + + preg_match('/link="(.*?)"/ism', $attributes, $matches); + if ($matches[1] != "") { + $link = $matches[1]; + } + + $ckey = PConfig::get($uid, 'statusnet', 'consumerkey'); + $csecret = PConfig::get($uid, 'statusnet', 'consumersecret'); + $api = PConfig::get($uid, 'statusnet', 'baseapi'); + $otoken = PConfig::get($uid, 'statusnet', 'oauthtoken'); + $osecret = PConfig::get($uid, 'statusnet', 'oauthsecret'); + $hostname = preg_replace("=https?://([\w\.]*)/.*=ism", "$1", $api); + + $id = preg_replace("=https?://" . $hostname . "/notice/(.*)=ism", "$1", $link); + + if ($id == $link) { + return false; + } + + logger('statusnet_is_retweet: Retweeting id ' . $id . ' for user ' . $uid, LOGGER_DEBUG); + + $connection = new StatusNetOAuth($api, $ckey, $csecret, $otoken, $osecret); + + $result = $connection->post('statuses/retweet/' . $id); + + logger('statusnet_is_retweet: result ' . print_r($result, true), LOGGER_DEBUG); + + return isset($result->id); +}