bitPickups/friendica_2020-09-1_sharedHosting
1
0
Fork 0
Code Pull requests Activity

Preparation for not storing the file field into the item table.

Browse source
This commit is contained in:
Michael 2018-06-30 21:15:24 +00:00
parent 5ba1427806
commit 60dcdd0b27
2 changed files with 64 additions and 23 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

70
src/Model/Item.php
View file

@ -122,6 +122,12 @@ class Item extends BaseObject
$row['tag'] = Term::tagTextFromItemId($row['id']); $row['tag'] = Term::tagTextFromItemId($row['id']);
} }
/// @todo This is a preparation
// Build the file string out of the term entries
//if (isset($row['id']) && array_key_exists('file', $row)) {
// $row['file'] = Term::fileTextFromItemId($row['id']);
//}
// We can always comment on posts from these networks // We can always comment on posts from these networks
if (isset($row['writable']) && !empty($row['network']) && if (isset($row['writable']) && !empty($row['network']) &&
in_array($row['network'], [NETWORK_DFRN, NETWORK_DIASPORA, NETWORK_OSTATUS])) { in_array($row['network'], [NETWORK_DFRN, NETWORK_DIASPORA, NETWORK_OSTATUS])) {
@ -535,6 +541,12 @@ class Item extends BaseObject
$selected[] = 'id'; $selected[] = 'id';
} }
/// @todo This is a preparation
// To be able to fetch the files we need the item id
//if (in_array('file', $selected) && !in_array('id', $selected)) {
// $selected[] = 'id';
//}
$selection = []; $selection = [];
foreach ($fields as $table => $table_fields) { foreach ($fields as $table => $table_fields) {
foreach ($table_fields as $field => $select) { foreach ($table_fields as $field => $select) {
@ -621,6 +633,14 @@ class Item extends BaseObject
$tags = ''; $tags = '';
} }
if (array_key_exists('file', $fields)) {
$files = $fields['file'];
/// @todo This is a preparation
//unset($fields['file']);
} else {
$files = '';
}
if (!empty($fields)) { if (!empty($fields)) {
$success = dba::update('item', $fields, $condition); $success = dba::update('item', $fields, $condition);
@ -644,8 +664,8 @@ class Item extends BaseObject
Term::insertFromTagFieldByItemId($item['id'], $tags); Term::insertFromTagFieldByItemId($item['id'], $tags);
} }
if (array_key_exists('file', $fields)) { if (!empty($files)) {
Term::insertFromFileFieldByItemId($item['id']); Term::insertFromFileFieldByItemId($item['id'], $files);
} }
self::updateThread($item['id']); self::updateThread($item['id']);
@ -717,7 +737,7 @@ class Item extends BaseObject
$fields = ['id', 'uri', 'uid', 'parent', 'parent-uri', 'origin', $fields = ['id', 'uri', 'uid', 'parent', 'parent-uri', 'origin',
'deleted', 'file', 'resource-id', 'event-id', 'attach', 'deleted', 'file', 'resource-id', 'event-id', 'attach',
'verb', 'object-type', 'object', 'target', 'contact-id']; 'verb', 'object-type', 'object', 'target', 'contact-id'];
$item = dba::selectFirst('item', $fields, ['id' => $item_id]); $item = self::selectFirst($fields, ['id' => $item_id]);
if (!DBM::is_result($item)) { if (!DBM::is_result($item)) {
logger('Item with ID ' . $item_id . " hasn't been found.", LOGGER_DEBUG); logger('Item with ID ' . $item_id . " hasn't been found.", LOGGER_DEBUG);
return false; return false;
@ -728,7 +748,7 @@ class Item extends BaseObject
return false; return false;
} }
$parent = dba::selectFirst('item', ['origin'], ['id' => $item['parent']]); $parent = self::selectFirst(['origin'], ['id' => $item['parent']]);
if (!DBM::is_result($parent)) { if (!DBM::is_result($parent)) {
$parent = ['origin' => false]; $parent = ['origin' => false];
} }
@ -785,7 +805,7 @@ class Item extends BaseObject
dba::update('item', $item_fields, ['id' => $item['id']]); dba::update('item', $item_fields, ['id' => $item['id']]);
Term::insertFromTagFieldByItemId($item['id'], ''); Term::insertFromTagFieldByItemId($item['id'], '');
Term::insertFromFileFieldByItemId($item['id']); Term::insertFromFileFieldByItemId($item['id'], '');
self::deleteThread($item['id'], $item['parent-uri']); self::deleteThread($item['id'], $item['parent-uri']);
if (!self::exists(["`uri` = ? AND `uid` != 0 AND NOT `deleted`", $item['uri']])) { if (!self::exists(["`uri` = ? AND `uid` != 0 AND NOT `deleted`", $item['uri']])) {
@ -808,7 +828,7 @@ class Item extends BaseObject
} elseif ($item['uid'] != 0) { } elseif ($item['uid'] != 0) {
// When we delete just our local user copy of an item, we have to set a marker to hide it // When we delete just our local user copy of an item, we have to set a marker to hide it
$global_item = dba::selectFirst('item', ['id'], ['uri' => $item['uri'], 'uid' => 0, 'deleted' => false]); $global_item = self::selectFirst(['id'], ['uri' => $item['uri'], 'uid' => 0, 'deleted' => false]);
if (DBM::is_result($global_item)) { if (DBM::is_result($global_item)) {
dba::update('user-item', ['hidden' => true], ['iid' => $global_item['id'], 'uid' => $item['uid']], true); dba::update('user-item', ['hidden' => true], ['iid' => $global_item['id'], 'uid' => $item['uid']], true);
} }
@ -832,7 +852,7 @@ class Item extends BaseObject
return; return;
} }
$i = dba::selectFirst('item', ['id', 'contact-id', 'tag'], ['uri' => $xt->id, 'uid' => $item['uid']]); $i = self::selectFirst(['id', 'contact-id', 'tag'], ['uri' => $xt->id, 'uid' => $item['uid']]);
if (!DBM::is_result($i)) { if (!DBM::is_result($i)) {
return; return;
} }
@ -1048,7 +1068,7 @@ class Item extends BaseObject
$condition = ["`uri` = ? AND `uid` = ? AND `network` IN (?, ?, ?)", $condition = ["`uri` = ? AND `uid` = ? AND `network` IN (?, ?, ?)",
trim($item['uri']), $item['uid'], trim($item['uri']), $item['uid'],
NETWORK_DIASPORA, NETWORK_DFRN, NETWORK_OSTATUS]; NETWORK_DIASPORA, NETWORK_DFRN, NETWORK_OSTATUS];
$existing = dba::selectFirst('item', ['id', 'network'], $condition); $existing = self::selectFirst(['id', 'network'], $condition);
if (DBM::is_result($existing)) { if (DBM::is_result($existing)) {
// We only log the entries with a different user id than 0. Otherwise we would have too many false positives // We only log the entries with a different user id than 0. Otherwise we would have too many false positives
if ($uid != 0) { if ($uid != 0) {
@ -1205,7 +1225,7 @@ class Item extends BaseObject
'wall', 'private', 'forum_mode', 'origin']; 'wall', 'private', 'forum_mode', 'origin'];
$condition = ['uri' => $item['parent-uri'], 'uid' => $item['uid']]; $condition = ['uri' => $item['parent-uri'], 'uid' => $item['uid']];
$params = ['order' => ['id' => false]]; $params = ['order' => ['id' => false]];
$parent = dba::selectFirst('item', $fields, $condition, $params); $parent = self::selectFirst($fields, $condition, $params);
if (DBM::is_result($parent)) { if (DBM::is_result($parent)) {
// is the new message multi-level threaded? // is the new message multi-level threaded?
@ -1219,7 +1239,7 @@ class Item extends BaseObject
'parent-uri' => $item['parent-uri'], 'parent-uri' => $item['parent-uri'],
'uid' => $item['uid']]; 'uid' => $item['uid']];
$params = ['order' => ['id' => false]]; $params = ['order' => ['id' => false]];
$toplevel_parent = dba::selectFirst('item', $fields, $condition, $params); $toplevel_parent = self::selectFirst($fields, $condition, $params);
if (DBM::is_result($toplevel_parent)) { if (DBM::is_result($toplevel_parent)) {
$parent = $toplevel_parent; $parent = $toplevel_parent;
@ -1371,6 +1391,14 @@ class Item extends BaseObject
$tags = ''; $tags = '';
} }
if (array_key_exists('file', $item)) {
$files = $item['file'];
/// @todo This is a preparation
//unset($item['file']);
} else {
$files = '';
}
// We are doing this outside of the transaction to avoid timing problems // We are doing this outside of the transaction to avoid timing problems
self::insertContent($item); self::insertContent($item);
@ -1478,7 +1506,7 @@ class Item extends BaseObject
* in it. * in it.
*/ */
if (!$deleted && !$dontcache) { if (!$deleted && !$dontcache) {
$posted_item = dba::selectFirst('item', [], ['id' => $current_post]); $posted_item = self::selectFirst(self::ITEM_FIELDLIST, ['id' => $current_post]);
if (DBM::is_result($posted_item)) { if (DBM::is_result($posted_item)) {
if ($notify) { if ($notify) {
Addon::callHooks('post_local_end', $posted_item); Addon::callHooks('post_local_end', $posted_item);
@ -1506,8 +1534,8 @@ class Item extends BaseObject
Term::insertFromTagFieldByItemId($current_post, $tags); Term::insertFromTagFieldByItemId($current_post, $tags);
} }
if (array_key_exists('file', $item)) { if (!empty($files)) {
Term::insertFromFileFieldByItemId($current_post); Term::insertFromFileFieldByItemId($current_post, $files);
} }
if ($item['parent-uri'] === $item['uri']) { if ($item['parent-uri'] === $item['uri']) {
@ -1626,7 +1654,7 @@ class Item extends BaseObject
public static function distribute($itemid, $signed_text = '') public static function distribute($itemid, $signed_text = '')
{ {
$condition = ["`id` IN (SELECT `parent` FROM `item` WHERE `id` = ?)", $itemid]; $condition = ["`id` IN (SELECT `parent` FROM `item` WHERE `id` = ?)", $itemid];
$parent = dba::selectFirst('item', ['owner-id'], $condition); $parent = self::selectFirst(['owner-id'], $condition);
if (!DBM::is_result($parent)) { if (!DBM::is_result($parent)) {
return; return;
} }
@ -1659,7 +1687,7 @@ class Item extends BaseObject
$origin_uid = 0; $origin_uid = 0;
if ($item['uri'] != $item['parent-uri']) { if ($item['uri'] != $item['parent-uri']) {
$parents = dba::select('item', ['uid', 'origin'], ["`uri` = ? AND `uid` != 0", $item['parent-uri']]); $parents = self::select(['uid', 'origin'], ["`uri` = ? AND `uid` != 0", $item['parent-uri']]);
while ($parent = dba::fetch($parents)) { while ($parent = dba::fetch($parents)) {
$users[$parent['uid']] = $parent['uid']; $users[$parent['uid']] = $parent['uid'];
if ($parent['origin'] && !$item['origin']) { if ($parent['origin'] && !$item['origin']) {
@ -1740,7 +1768,7 @@ class Item extends BaseObject
{ {
$fields = ['uid', 'private', 'moderated', 'visible', 'deleted', 'network']; $fields = ['uid', 'private', 'moderated', 'visible', 'deleted', 'network'];
$condition = ['id' => $itemid, 'parent' => [0, $itemid]]; $condition = ['id' => $itemid, 'parent' => [0, $itemid]];
$item = dba::selectFirst('item', $fields, $condition); $item = self::selectFirst($fields, $condition);
if (!DBM::is_result($item)) { if (!DBM::is_result($item)) {
return; return;
@ -2046,7 +2074,7 @@ class Item extends BaseObject
public static function getGuidById($id) public static function getGuidById($id)
{ {
$item = dba::selectFirst('item', ['guid'], ['id' => $id]); $item = self::selectFirst(['guid'], ['id' => $id]);
if (DBM::is_result($item)) { if (DBM::is_result($item)) {
return $item['guid']; return $item['guid'];
} else { } else {
@ -2110,7 +2138,7 @@ class Item extends BaseObject
$community_page = (($user['page-flags'] == PAGE_COMMUNITY) ? true : false); $community_page = (($user['page-flags'] == PAGE_COMMUNITY) ? true : false);
$prvgroup = (($user['page-flags'] == PAGE_PRVGROUP) ? true : false); $prvgroup = (($user['page-flags'] == PAGE_PRVGROUP) ? true : false);
$item = dba::selectFirst('item', [], ['id' => $item_id]); $item = self::selectFirst(self::ITEM_FIELDLIST, ['id' => $item_id]);
if (!DBM::is_result($item)) { if (!DBM::is_result($item)) {
return; return;
} }
@ -2596,7 +2624,7 @@ class Item extends BaseObject
logger('like: verb ' . $verb . ' item ' . $item_id); logger('like: verb ' . $verb . ' item ' . $item_id);
$item = dba::selectFirst('item', [], ['`id` = ? OR `uri` = ?', $item_id, $item_id]); $item = self::selectFirst(self::ITEM_FIELDLIST, ['`id` = ? OR `uri` = ?', $item_id, $item_id]);
if (!DBM::is_result($item)) { if (!DBM::is_result($item)) {
logger('like: unknown item ' . $item_id); logger('like: unknown item ' . $item_id);
return false; return false;
@ -2773,7 +2801,7 @@ EOT;
'moderated', 'visible', 'starred', 'bookmark', 'contact-id', 'moderated', 'visible', 'starred', 'bookmark', 'contact-id',
'deleted', 'origin', 'forum_mode', 'mention', 'network', 'author-id', 'owner-id']; 'deleted', 'origin', 'forum_mode', 'mention', 'network', 'author-id', 'owner-id'];
$condition = ["`id` = ? AND (`parent` = ? OR `parent` = 0)", $itemid, $itemid]; $condition = ["`id` = ? AND (`parent` = ? OR `parent` = 0)", $itemid, $itemid];
$item = dba::selectFirst('item', $fields, $condition); $item = self::selectFirst($fields, $condition);
if (!DBM::is_result($item)) { if (!DBM::is_result($item)) {
return; return;
@ -2795,7 +2823,7 @@ EOT;
'deleted', 'origin', 'forum_mode', 'network', 'author-id', 'owner-id']; 'deleted', 'origin', 'forum_mode', 'network', 'author-id', 'owner-id'];
$condition = ["`id` = ? AND (`parent` = ? OR `parent` = 0)", $itemid, $itemid]; $condition = ["`id` = ? AND (`parent` = ? OR `parent` = 0)", $itemid, $itemid];
$item = dba::selectFirst('item', $fields, $condition); $item = self::selectFirst($fields, $condition);
if (!DBM::is_result($item)) { if (!DBM::is_result($item)) {
return; return;
} }

17
src/Model/Term.php
View file

@ -35,6 +35,17 @@ class Term
return $tag_text; return $tag_text;
} }
public static function fileTextFromItemId($itemid)
{
$file_text = '';
$condition = ['otype' => TERM_OBJ_POST, 'oid' => $itemid, 'type' => [TERM_FILE, TERM_CATEGORY]];
$tags = dba::select('term', [], $condition);
while ($tag = dba::fetch($tags)) {
$file_text .= '[' . $tag['term'] . ']';
}
return $file_text;
}
public static function insertFromTagFieldByItemId($itemid, $tags) public static function insertFromTagFieldByItemId($itemid, $tags)
{ {
$profile_base = System::baseUrl(); $profile_base = System::baseUrl();
@ -150,9 +161,9 @@ class Term
* @param integer $itemid item id * @param integer $itemid item id
* @return void * @return void
*/ */
public static function insertFromFileFieldByItemId($itemid) public static function insertFromFileFieldByItemId($itemid, $files)
{ {
$message = Item::selectFirst(['uid', 'deleted', 'file'], ['id' => $itemid]); $message = Item::selectFirst(['uid', 'deleted'], ['id' => $itemid]);
if (!DBM::is_result($message)) { if (!DBM::is_result($message)) {
return; return;
} }
@ -164,6 +175,8 @@ class Term
return; return;
} }
$message['file'] = $files;
if (preg_match_all("/\[(.*?)\]/ism", $message["file"], $files)) { if (preg_match_all("/\[(.*?)\]/ism", $message["file"], $files)) {
foreach ($files[1] as $file) { foreach ($files[1] as $file) {
dba::insert('term', [ dba::insert('term', [