From ef2bc47cc6d8f6be3fda65aec366ad237396a52c Mon Sep 17 00:00:00 2001 From: Michael Vogel Date: Sun, 6 Mar 2016 20:36:28 +0100 Subject: [PATCH 1/2] New way of fetching the conversation id for thread completion --- include/ostatus.php | 41 ++++++++++++++++++++++++++++++++++++----- 1 file changed, 36 insertions(+), 5 deletions(-) diff --git a/include/ostatus.php b/include/ostatus.php index 44431967e..138f51090 100644 --- a/include/ostatus.php +++ b/include/ostatus.php @@ -537,7 +537,7 @@ function ostatus_import($xml,$importer,&$contact, &$hub) { } else $item["parent-uri"] = $item["uri"]; - $item_id = ostatus_completion($conversation, $importer["uid"], $item); + $item_id = ostatus_completion($conversation, $importer["uid"], $item, $self); if (!$item_id) { logger("Error storing item", LOGGER_DEBUG); @@ -676,18 +676,49 @@ function ostatus_conv_fetch_actor($actor) { update_gcontact($contact); } +function ostatus_fetch_conversation($self, $conversation_url = "") { -function ostatus_completion($conversation_url, $uid, $item = array()) { + if ($conversation_url != "") { + $elements = explode(":", $conversation_url); + + if ((count($elements) <= 2) OR ($elements[0] != "tag")) + return $conversation_url; + } + + if ($self == "") + return ""; + + $json = str_replace(".atom", ".json", $self); + + $raw = fetch_url($json); + if ($raw == "") + return ""; + + $data = json_decode($raw); + if (!is_object($data)) + return ""; + + $conversation_id = $data->statusnet_conversation_id; + + $pos = strpos($self, "/api/statuses/show/"); + $base_url = substr($self, 0, $pos); + + return $base_url."/conversation/".$conversation_id; +} + +function ostatus_completion($conversation_url, $uid, $item = array(), $self = "") { $a = get_app(); $item_stored = -1; - $conversation_url = ostatus_convert_href($conversation_url); + //$conversation_url = ostatus_convert_href($conversation_url); + $conversation_url = ostatus_fetch_conversation($self, $conversation_url); // If the thread shouldn't be completed then store the item and go away // Don't do a completion on liked content - if (((intval(get_config('system','ostatus_poll_interval')) == -2) AND (count($item) > 0)) OR ($item["verb"] == ACTIVITY_LIKE)) { + if (((intval(get_config('system','ostatus_poll_interval')) == -2) AND (count($item) > 0)) OR + ($item["verb"] == ACTIVITY_LIKE) OR ($conversation_url == "")) { //$arr["app"] .= " (OStatus-NoCompletion)"; $item_stored = item_store($item, true); return($item_stored); @@ -726,7 +757,7 @@ function ostatus_completion($conversation_url, $uid, $item = array()) { $pageno = 1; $items = array(); - logger('fetching conversation url '.$conv.' ('.$conversation_url.') for user '.$uid); + logger('fetching conversation url '.$conv.' (Self: '.$self.') for user '.$uid); do { $conv_arr = z_fetch_url($conv."?page=".$pageno); From 4ef44c67b84a9f8d66b91a61123b10fe2be75784 Mon Sep 17 00:00:00 2001 From: Michael Vogel Date: Sun, 6 Mar 2016 21:06:52 +0100 Subject: [PATCH 2/2] Added documentation --- include/ostatus.php | 16 ++++++++++++---- 1 file changed, 12 insertions(+), 4 deletions(-) diff --git a/include/ostatus.php b/include/ostatus.php index 138f51090..54b70e6d6 100644 --- a/include/ostatus.php +++ b/include/ostatus.php @@ -676,13 +676,21 @@ function ostatus_conv_fetch_actor($actor) { update_gcontact($contact); } -function ostatus_fetch_conversation($self, $conversation_url = "") { +/** + * @brief Fetches the conversation url for a given item link or conversation id + * + * @param string $self The link to the posting + * @param string $conversation_id The conversation id + * + * @return string The conversation url + */ +function ostatus_fetch_conversation($self, $conversation_id = "") { - if ($conversation_url != "") { - $elements = explode(":", $conversation_url); + if ($conversation_id != "") { + $elements = explode(":", $conversation_id); if ((count($elements) <= 2) OR ($elements[0] != "tag")) - return $conversation_url; + return $conversation_id; } if ($self == "")