intval($page_owner_uid)
);
Term::insertFromTagFieldByItemUri($rr['parent-uri'], $page_owner_uid);
- delete_thread_uri($rr['parent-uri'], $page_owner_uid);
+ Item::deleteThreadFromUri($rr['parent-uri'], $page_owner_uid);
$drop_id = intval($rr['id']);
intval($page_owner_uid)
);
Term::insertFromTagFieldByItemUri($i[0]['uri'], $page_owner_uid);
- delete_thread_uri($i[0]['uri'], $page_owner_uid);
+ Item::deleteThreadFromUri($i[0]['uri'], $page_owner_uid);
$url = System::baseUrl();
$drop_id = intval($i[0]['id']);
intval($page_owner_uid)
);
Term::insertFromTagFieldByItemId($item_id);
- update_thread($item_id);
+ Item::updateThread($item_id);
$best = 0;
foreach ($p as $scales) {
intval($link_item['parent']),
intval(local_user())
);
- update_thread($link_item['parent']);
+ Item::updateThread($link_item['parent']);
}
if ($link_item['coord']) {
Term::insertFromTagFieldByItemId($item['id']);
Term::insertFromFileFieldByItemId($item['id']);
- update_thread($item['id']);
+ self::updateThread($item['id']);
Worker::add(PRIORITY_HIGH, "Notifier", 'edit_post', $item['id']);
}
Term::insertFromTagFieldByItemId($item['id']);
Term::insertFromFileFieldByItemId($item['id']);
- delete_thread($item['id'], $item['parent-uri']);
+ self::deleteThread($item['id'], $item['parent-uri']);
// If it's the parent of a comment thread, kill all the kids
if ($item['id'] == $item['parent']) {
}
if ($arr['parent-uri'] === $arr['uri']) {
- add_thread($current_post);
+ self::addThread($current_post);
} else {
- update_thread($parent_id);
+ self::updateThread($parent_id);
}
dba::commit();
dbesc($u[0]['deny_gid']),
intval($item_id)
);
- update_thread($item_id);
+ self::updateThread($item_id);
Worker::add(['priority' => PRIORITY_HIGH, 'dont_fork' => true], 'Notifier', 'tgroup', $item_id);
return true;
}
- function add_thread($itemid, $onlyshadow = false) {
+ private static function addThread($itemid, $onlyshadow = false) {
$items = q("SELECT `uid`, `created`, `edited`, `commented`, `received`, `changed`, `wall`, `private`, `pubmail`,
`moderated`, `visible`, `spam`, `starred`, `bookmark`, `contact-id`, `gcontact-id`,
`deleted`, `origin`, `forum_mode`, `mention`, `network`, `author-id`, `owner-id`
}
}
- function update_thread_uri($itemuri, $uid) {
+ public static function updateThreadFromUri($itemuri, $uid) {
$messages = q("SELECT `id` FROM `item` WHERE uri ='%s' AND uid=%d", dbesc($itemuri), intval($uid));
if (DBM::is_result($messages)) {
foreach ($messages as $message) {
- update_thread($message["id"]);
+ self::updateThread($message["id"]);
}
}
}
- function update_thread($itemid, $setmention = false) {
+ public static function updateThread($itemid, $setmention = false) {
$items = q("SELECT `uid`, `guid`, `title`, `body`, `created`, `edited`, `commented`, `received`, `changed`, `wall`, `private`, `pubmail`, `moderated`, `visible`, `spam`, `starred`, `bookmark`, `contact-id`, `gcontact-id`,
`deleted`, `origin`, `forum_mode`, `network`, `rendered-html`, `rendered-hash` FROM `item` WHERE `id` = %d AND (`parent` = %d OR `parent` = 0) LIMIT 1", intval($itemid), intval($itemid));
logger("Updating public shadow for post ".$items[0]["id"]." - guid ".$item["guid"]." Result: ".print_r($result, true), LOGGER_DEBUG);
}
- function delete_thread_uri($itemuri, $uid) {
+ public static function deleteThreadFromUri($itemuri, $uid) {
$messages = q("SELECT `id` FROM `item` WHERE uri ='%s' AND uid=%d", dbesc($itemuri), intval($uid));
if (DBM::is_result($messages)) {
foreach ($messages as $message) {
- delete_thread($message["id"], $itemuri);
+ self::deleteThread($message["id"], $itemuri);
}
}
}
- function delete_thread($itemid, $itemuri = "") {
+ public static function deleteThread($itemid, $itemuri = "") {
$item = q("SELECT `uid` FROM `thread` WHERE `iid` = %d", intval($itemid));
if (!DBM::is_result($item)) {
// Using dba::delete at this time could delete the associated item entries
$result = dba::e("DELETE FROM `thread` WHERE `iid` = ?", $itemid);
- logger("delete_thread: Deleted thread for item ".$itemid." - ".print_r($result, true), LOGGER_DEBUG);
+ logger("deleteThread: Deleted thread for item ".$itemid." - ".print_r($result, true), LOGGER_DEBUG);
if ($itemuri != "") {
$r = q("SELECT `id` FROM `item` WHERE `uri` = '%s' AND NOT `deleted` AND NOT (`uid` IN (%d, 0))",
);
if (!DBM::is_result($r)) {
dba::delete('item', ['uri' => $itemuri, 'uid' => 0]);
- logger("delete_thread: Deleted shadow for item ".$itemuri, LOGGER_DEBUG);
+ logger("deleteThread: Deleted shadow for item ".$itemuri, LOGGER_DEBUG);
}
}
}
dba::update('item', $fields, $condition);
Term::insertFromTagFieldByItemUri($item["uri"], $importer["importer_uid"]);
- update_thread_uri($item["uri"], $importer["importer_uid"]);
+ Item::updateThreadFromUri($item["uri"], $importer["importer_uid"]);
$changed = true;
);
Term::insertFromTagFieldByItemUri($uri, $importer["uid"]);
Term::insertFromFileFieldByItemUri($uri, $importer["uid"]);
- update_thread_uri($uri, $importer["uid"]);
+ Item::updateThreadFromUri($uri, $importer["uid"]);
} else {
$r = q(
"UPDATE `item` SET `deleted` = 1, `edited` = '%s', `changed` = '%s',
);
Term::insertFromTagFieldByItemUri($uri, $importer["uid"]);
Term::insertFromFileFieldByItemUri($uri, $importer["uid"]);
- update_thread_uri($uri, $importer["importer_uid"]);
+ Item::updateThreadFromUri($uri, $importer["importer_uid"]);
// if this is a relayed delete, propagate it to other recipients