+function statusnet_checknotification($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(array(
+ '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($a, $uid, $mode = 1) {
+ $conversations = array();
+
+ $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 = array("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(array(
+ '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($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;
+
+ //print_r($postarray);
+ $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($a, $body, $no_tags = false) {
+
+ require_once("include/oembed.php");
+ 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_fetch_url($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(array("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(array("body"=>$body, "tags"=>$str_tags));
+
+}
+
+function statusnet_fetch_own_contact($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($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));
+}