2 changed files with 122 additions and 0 deletions
@ -0,0 +1,99 @@
|
||||
<?php |
||||
function add_thread($itemid) { |
||||
$items = q("SELECT `uid`, `created`, `edited`, `commented`, `received`, `changed`, `wall`, `private`, `pubmail`, `moderated`, `visible`, `spam`, `starred`, `bookmark`, `contact-id`, |
||||
`deleted`, `origin`, `forum_mode`, `mention`, `network` FROM `item` WHERE `id` = %d AND (`parent` = %d OR `parent` = 0) LIMIT 1", intval($itemid), intval($itemid)); |
||||
|
||||
if (!$items) |
||||
return; |
||||
|
||||
$item = $items[0]; |
||||
$item['iid'] = $itemid; |
||||
|
||||
$result = dbq("INSERT INTO `thread` (`" |
||||
.implode("`, `", array_keys($item)) |
||||
."`) VALUES ('" |
||||
.implode("', '", array_values($item)) |
||||
."')" ); |
||||
|
||||
logger("add_thread: Add thread for item ".$itemid." - ".print_r($result, true), LOGGER_DEBUG); |
||||
} |
||||
|
||||
function update_thread_uri($itemuri, $uid) { |
||||
$messages = q("SELECT `id` FROM `item` WHERE uri ='%s' AND uid=%d", dbesc($itemuri), intval($uid)); |
||||
|
||||
if(count($messages)) |
||||
foreach ($messages as $message) |
||||
update_thread($message["id"]); |
||||
} |
||||
|
||||
function update_thread($itemid, $setmention = false) { |
||||
$items = q("SELECT `uid`, `created`, `edited`, `commented`, `received`, `changed`, `wall`, `private`, `pubmail`, `moderated`, `visible`, `spam`, `starred`, `bookmark`, `contact-id`, |
||||
`deleted`, `origin`, `forum_mode`, `network` FROM `item` WHERE `id` = %d AND (`parent` = %d OR `parent` = 0) LIMIT 1", intval($itemid), intval($itemid)); |
||||
|
||||
if (!$items) |
||||
return; |
||||
|
||||
$item = $items[0]; |
||||
|
||||
if ($setmention) |
||||
$item["mention"] = 1; |
||||
|
||||
$sql = ""; |
||||
|
||||
foreach ($item AS $field => $data) { |
||||
if ($sql != "") |
||||
$sql .= ", "; |
||||
|
||||
$sql .= "`".$field."` = '".$data."'"; |
||||
} |
||||
|
||||
$result = q("UPDATE `thread` SET ".$sql." WHERE `iid` = %d", $itemid); |
||||
|
||||
logger("update_thread: Update thread for item ".$itemid." - ".print_r($result, true)." ".print_r($item, true), LOGGER_DEBUG); |
||||
} |
||||
|
||||
function delete_thread_uri($itemuri, $uid) { |
||||
$messages = q("SELECT `id` FROM `item` WHERE uri ='%s' AND uid=%d", dbesc($itemuri), intval($uid)); |
||||
|
||||
if(count($messages)) |
||||
foreach ($messages as $message) |
||||
delete_thread($message["id"]); |
||||
} |
||||
|
||||
function delete_thread($itemid) { |
||||
$result = q("DELETE FROM `thread` WHERE `iid` = %d", intval($itemid)); |
||||
|
||||
logger("delete_thread: Deleted thread for item ".$itemid." - ".print_r($result, true), LOGGER_DEBUG); |
||||
} |
||||
|
||||
function update_threads() { |
||||
global $db; |
||||
|
||||
logger("update_threads: start"); |
||||
|
||||
$messages = $db->q("SELECT `id` FROM `item` WHERE `id` = `parent`", true); |
||||
|
||||
logger("update_threads: fetched messages: ".count($messages)); |
||||
|
||||
while ($message = $db->qfetch()) |
||||
add_thread($message["id"]); |
||||
$db->qclose(); |
||||
} |
||||
|
||||
function update_threads_mention() { |
||||
$a = get_app(); |
||||
|
||||
$users = q("SELECT `uid`, `nickname` FROM `user` ORDER BY `uid`"); |
||||
|
||||
foreach ($users AS $user) { |
||||
$self = normalise_link($a->get_baseurl() . '/profile/' . $user['nickname']); |
||||
$selfhttps = str_replace("http://", "https://", $self); |
||||
$parents = q("SELECT DISTINCT(`parent`) FROM `item` WHERE `uid` = %d AND |
||||
((`owner-link` IN ('%s', '%s')) OR (`author-link` IN ('%s', '%s')))", |
||||
$user["uid"], $self, $selfhttps, $self, $selfhttps); |
||||
|
||||
foreach ($parents AS $parent) |
||||
q("UPDATE `thread` SET `mention` = 1 WHERE `iid` = %d", $parent["parent"]); |
||||
} |
||||
} |
||||
?> |
@ -0,0 +1,23 @@
|
||||
<?php |
||||
require_once("boot.php"); |
||||
require_once("include/threads.php"); |
||||
|
||||
global $a, $db; |
||||
|
||||
if(is_null($a)) |
||||
$a = new App; |
||||
|
||||
if(is_null($db)) { |
||||
@include(".htconfig.php"); |
||||
require_once("include/dba.php"); |
||||
$db = new dba($db_host, $db_user, $db_pass, $db_data); |
||||
unset($db_host, $db_user, $db_pass, $db_data); |
||||
} |
||||
|
||||
load_config('config'); |
||||
load_config('system'); |
||||
|
||||
update_threads(); |
||||
update_threads_mention(); |
||||
killme(); |
||||
?> |
Loading…
Reference in new issue