X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=include%2Fostatus_conversation.php;h=2fa7d7a54451621b53973a3af59cffdbdaf9d9f2;hb=660bd39efad52b1c69bd8dd0ca27141b81f84ca5;hp=65c0d67871bc8a988ccd6dcc27fdade0dfc4a0c7;hpb=b0e8dbc4da0e7aaa87fdae1bc7802e990c6dc2ce;p=friendica.git diff --git a/include/ostatus_conversation.php b/include/ostatus_conversation.php index 65c0d67871..2fa7d7a544 100644 --- a/include/ostatus_conversation.php +++ b/include/ostatus_conversation.php @@ -28,7 +28,7 @@ function check_conversations() { logger('complete_conversation: cron_start'); $start = date("Y-m-d H:i:s", time() - ($poll_timeframe * 60)); - $conversations = q("SELECT * FROM `term` WHERE `type` = 7 AND `term` > '%s'", + $conversations = q("SELECT * FROM `term` WHERE `type` = 7 AND `term` > '%s'", dbesc($start)); foreach ($conversations AS $conversation) { $id = $conversation['oid']; @@ -44,6 +44,14 @@ function check_conversations() { function complete_conversation($itemid, $conversation_url, $only_add_conversation = false) { global $a; + if (intval(get_config('system','ostatus_poll_interval')) == -2) + return; + + if ($a->last_ostatus_conversation_url == $conversation_url) + return; + + $a->last_ostatus_conversation_url = $conversation_url; + //logger('complete_conversation: completing conversation url '.$conversation_url.' for id '.$itemid); $messages = q("SELECT `uid`, `parent`, `created` FROM `item` WHERE `id` = %d LIMIT 1", intval($itemid)); @@ -136,7 +144,7 @@ function complete_conversation($itemid, $conversation_url, $only_add_conversatio if ($message_exists) { if ($parent["id"] != 0) { $existing_message = $message_exists[0]; - $r = q("UPDATE `item` SET `parent` = %d, `parent-uri` = '%s', `thr-parent` = '%s' WHERE `id` = %d LIMIT 1", + $r = q("UPDATE `item` SET `parent` = %d, `parent-uri` = '%s', `thr-parent` = '%s' WHERE `id` = %d", intval($parent["id"]), dbesc($parent["uri"]), dbesc($parent_uri),