From 0ab9f2e265c6d981429bd72152af06089a30076f Mon Sep 17 00:00:00 2001 From: Michael Date: Sat, 30 Jun 2018 13:54:01 +0000 Subject: [PATCH 1/3] Preparations to not store the tags in the item table anymore --- database.sql | 1 - include/enotify.php | 41 ++++++++++++++++-------------------- src/Database/DBStructure.php | 1 - src/Model/Item.php | 30 ++++++++++++++++++++++---- src/Model/Term.php | 26 ++++++++++++++++++++--- 5 files changed, 67 insertions(+), 32 deletions(-) diff --git a/database.sql b/database.sql index c452832ac..1ea6abfa0 100644 --- a/database.sql +++ b/database.sql @@ -987,7 +987,6 @@ CREATE TABLE IF NOT EXISTS `term` ( `created` datetime NOT NULL DEFAULT '0001-01-01 00:00:00' COMMENT '', `received` datetime NOT NULL DEFAULT '0001-01-01 00:00:00' COMMENT '', `global` boolean NOT NULL DEFAULT '0' COMMENT '', - `aid` int unsigned NOT NULL DEFAULT 0 COMMENT '', `uid` mediumint unsigned NOT NULL DEFAULT 0 COMMENT 'User id', PRIMARY KEY(`tid`), INDEX `oid_otype_type_term` (`oid`,`otype`,`type`,`term`(32)), diff --git a/include/enotify.php b/include/enotify.php index be9468dd8..f33b16f50 100644 --- a/include/enotify.php +++ b/include/enotify.php @@ -738,18 +738,13 @@ function check_item_notification($itemid, $uid, $defaulttype = "") { // Only act if it is a "real" post // We need the additional check for the "local_profile" because of mixed situations on connector networks - $item = q("SELECT `id`, `mention`, `tag`,`parent`, `title`, `body`, `author-id`, `guid`, - `parent-uri`, `uri`, `contact-id`, `network` - FROM `item` WHERE `id` = %d AND `gravity` IN (%d, %d) AND - NOT (`author-id` IN ($contact_list)) LIMIT 1", - intval($itemid), intval(GRAVITY_PARENT), intval(GRAVITY_COMMENT)); - if (!$item) - return false; - - if ($item[0]['network'] != NETWORK_FEED) { - $author = dba::selectFirst('contact', ['name', 'thumb', 'url'], ['id' => $item[0]['author-id']]); - } else { - $author = dba::selectFirst('contact', ['name', 'thumb', 'url'], ['id' => $item[0]['contact-id']]); + $fields = ['id', 'mention', 'tag', 'parent', 'title', 'body', + 'author-link', 'author-name', 'author-avatar', 'author-id', + 'guid', 'parent-uri', 'uri', 'contact-id', 'network']; + $condition = ['id' => $itemid, 'gravity' => [GRAVITY_PARENT, GRAVITY_COMMENT]]; + $item = Item::selectFirst($fields, $condition); + if (!DBM::is_result($item) || in_array($item['author-id'], $contacts)) { + return; } // Generate the notification array @@ -759,17 +754,17 @@ function check_item_notification($itemid, $uid, $defaulttype = "") { $params["language"] = $user["language"]; $params["to_name"] = $user["username"]; $params["to_email"] = $user["email"]; - $params["item"] = $item[0]; - $params["parent"] = $item[0]["parent"]; - $params["link"] = System::baseUrl().'/display/'.urlencode($item[0]["guid"]); + $params["item"] = $item; + $params["parent"] = $item["parent"]; + $params["link"] = System::baseUrl().'/display/'.urlencode($item["guid"]); $params["otype"] = 'item'; - $params["source_name"] = $author["name"]; - $params["source_link"] = $author["url"]; - $params["source_photo"] = $author["thumb"]; + $params["source_name"] = $item["author-name"]; + $params["source_link"] = $item["author-link"]; + $params["source_photo"] = $item["author-avatar"]; - if ($item[0]["parent-uri"] === $item[0]["uri"]) { + if ($item["parent-uri"] === $item["uri"]) { // Send a notification for every new post? - $send_notification = dba::exists('contact', ['id' => $item[0]['contact-id'], 'notify_new_posts' => true]); + $send_notification = dba::exists('contact', ['id' => $item['contact-id'], 'notify_new_posts' => true]); if (!$send_notification) { $tags = q("SELECT `url` FROM `term` WHERE `otype` = %d AND `oid` = %d AND `type` = %d AND `uid` = %d", @@ -796,11 +791,11 @@ function check_item_notification($itemid, $uid, $defaulttype = "") { $tagged = false; foreach ($profiles AS $profile) { - if (strpos($item[0]["tag"], "=".$profile."]") || strpos($item[0]["body"], "=".$profile."]")) + if (strpos($item["tag"], "=".$profile."]") || strpos($item["body"], "=".$profile."]")) $tagged = true; } - if ($item[0]["mention"] || $tagged || ($defaulttype == NOTIFY_TAGSELF)) { + if ($item["mention"] || $tagged || ($defaulttype == NOTIFY_TAGSELF)) { $params["type"] = NOTIFY_TAGSELF; $params["verb"] = ACTIVITY_TAG; } @@ -810,7 +805,7 @@ function check_item_notification($itemid, $uid, $defaulttype = "") { WHERE `thread`.`iid` = %d AND NOT `thread`.`ignored` AND (`thread`.`mention` OR `item`.`author-id` IN ($contact_list)) LIMIT 1", - intval($item[0]["parent"])); + intval($item["parent"])); if ($parent && !isset($params["type"])) { $params["type"] = NOTIFY_COMMENT; diff --git a/src/Database/DBStructure.php b/src/Database/DBStructure.php index fa49c2903..8970241b2 100644 --- a/src/Database/DBStructure.php +++ b/src/Database/DBStructure.php @@ -1716,7 +1716,6 @@ class DBStructure "created" => ["type" => "datetime", "not null" => "1", "default" => NULL_DATE, "comment" => ""], "received" => ["type" => "datetime", "not null" => "1", "default" => NULL_DATE, "comment" => ""], "global" => ["type" => "boolean", "not null" => "1", "default" => "0", "comment" => ""], - "aid" => ["type" => "int unsigned", "not null" => "1", "default" => "0", "comment" => ""], "uid" => ["type" => "mediumint unsigned", "not null" => "1", "default" => "0", "relation" => ["user" => "uid"], "comment" => "User id"], ], "indexes" => [ diff --git a/src/Model/Item.php b/src/Model/Item.php index 5fe03a81b..c6e4e131c 100644 --- a/src/Model/Item.php +++ b/src/Model/Item.php @@ -117,6 +117,11 @@ class Item extends BaseObject } } + // Build the tag string out of the term entries + if (isset($row['id']) && isset($row['tag'])) { + $row['tag'] = Term::tagTextFromItemId($row['id']); + } + // We can always comment on posts from these networks if (isset($row['writable']) && !empty($row['network']) && in_array($row['network'], [NETWORK_DFRN, NETWORK_DIASPORA, NETWORK_OSTATUS])) { @@ -525,6 +530,11 @@ class Item extends BaseObject */ private static function constructSelectFields($fields, $selected) { + // To be able to fetch the tags we need the item id + if (in_array('tag', $selected) && !in_array('id', $selected)) { + $selected[] = 'id'; + } + $selection = []; foreach ($fields as $table => $table_fields) { foreach ($table_fields as $field => $select) { @@ -622,8 +632,15 @@ class Item extends BaseObject $content_fields['plink'] = $item['plink']; } self::updateContent($content_fields, ['uri' => $item['uri']]); - Term::insertFromTagFieldByItemId($item['id']); - Term::insertFromFileFieldByItemId($item['id']); + + if (array_key_exists('tag', $fields)) { + Term::insertFromTagFieldByItemId($item['id']); + } + + if (array_key_exists('file', $fields)) { + Term::insertFromFileFieldByItemId($item['id']); + } + self::updateThread($item['id']); // We only need to notfiy others when it is an original entry from us. @@ -1471,8 +1488,13 @@ class Item extends BaseObject * Due to deadlock issues with the "term" table we are doing these steps after the commit. * This is not perfect - but a workable solution until we found the reason for the problem. */ - Term::insertFromTagFieldByItemId($current_post); - Term::insertFromFileFieldByItemId($current_post); + if (array_key_exists('tag', $item)) { + Term::insertFromTagFieldByItemId($current_post); + } + + if (array_key_exists('file', $item)) { + Term::insertFromFileFieldByItemId($current_post); + } if ($item['parent-uri'] === $item['uri']) { self::addShadow($current_post); diff --git a/src/Model/Term.php b/src/Model/Term.php index 858714209..53c9da8aa 100644 --- a/src/Model/Term.php +++ b/src/Model/Term.php @@ -15,6 +15,26 @@ require_once 'include/dba.php'; class Term { + public static function tagTextFromItemId($itemid) + { + $tag_text = ''; + $condition = ['otype' => TERM_OBJ_POST, 'oid' => $itemid, 'type' => [TERM_HASHTAG, TERM_MENTION]]; + $tags = dba::select('term', [], $condition); + while ($tag = dba::fetch($tags)) { + if ($tag_text != '') { + $tag_text .= ','; + } + + if ($tag['type'] == 1) { + $tag_text .= '#'; + } else { + $tag_text .= '@'; + } + $tag_text .= '[url=' . $tag['url'] . ']' . $tag['term'] . '[/url]'; + } + return $tag_text; + } + public static function insertFromTagFieldByItemId($itemid) { $profile_base = System::baseUrl(); @@ -57,14 +77,14 @@ class Term $pattern = '/\W\#([^\[].*?)[\s\'".,:;\?!\[\]\/]/ism'; if (preg_match_all($pattern, $data, $matches)) { foreach ($matches[1] as $match) { - $tags['#' . strtolower($match)] = ''; + $tags['#' . $match] = ''; } } $pattern = '/\W([\#@])\[url\=(.*?)\](.*?)\[\/url\]/ism'; if (preg_match_all($pattern, $data, $matches, PREG_SET_ORDER)) { foreach ($matches as $match) { - $tags[$match[1] . strtolower(trim($match[3], ',.:;[]/\"?!'))] = $match[2]; + $tags[$match[1] . trim($match[3], ',.:;[]/\"?!')] = $match[2]; } } @@ -193,7 +213,7 @@ class Term while ($tag = dba::fetch($taglist)) { if ($tag["url"] == "") { - $tag["url"] = $searchpath . strtolower($tag["term"]); + $tag["url"] = $searchpath . $tag["term"]; } $orig_tag = $tag["url"]; From 5ba14278066ce7a398c0aabb41e1c86fe12ea7d8 Mon Sep 17 00:00:00 2001 From: Michael Date: Sat, 30 Jun 2018 15:21:32 +0000 Subject: [PATCH 2/3] We don't store tags in the item table anymore --- src/Model/Item.php | 26 ++++++++++++++++++++------ src/Model/Term.php | 6 ++++-- 2 files changed, 24 insertions(+), 8 deletions(-) diff --git a/src/Model/Item.php b/src/Model/Item.php index c6e4e131c..2cc9041bf 100644 --- a/src/Model/Item.php +++ b/src/Model/Item.php @@ -118,7 +118,7 @@ class Item extends BaseObject } // Build the tag string out of the term entries - if (isset($row['id']) && isset($row['tag'])) { + if (isset($row['id']) && array_key_exists('tag', $row)) { $row['tag'] = Term::tagTextFromItemId($row['id']); } @@ -614,6 +614,13 @@ class Item extends BaseObject } } + if (array_key_exists('tag', $fields)) { + $tags = $fields['tag']; + unset($fields['tag']); + } else { + $tags = ''; + } + if (!empty($fields)) { $success = dba::update('item', $fields, $condition); @@ -633,8 +640,8 @@ class Item extends BaseObject } self::updateContent($content_fields, ['uri' => $item['uri']]); - if (array_key_exists('tag', $fields)) { - Term::insertFromTagFieldByItemId($item['id']); + if (!empty($tags)) { + Term::insertFromTagFieldByItemId($item['id'], $tags); } if (array_key_exists('file', $fields)) { @@ -777,7 +784,7 @@ class Item extends BaseObject 'object' => '', 'target' => '', 'tag' => '', 'postopts' => '', 'attach' => '', 'file' => '']; dba::update('item', $item_fields, ['id' => $item['id']]); - Term::insertFromTagFieldByItemId($item['id']); + Term::insertFromTagFieldByItemId($item['id'], ''); Term::insertFromFileFieldByItemId($item['id']); self::deleteThread($item['id'], $item['parent-uri']); @@ -1357,6 +1364,13 @@ class Item extends BaseObject logger('' . print_r($item,true), LOGGER_DATA); + if (array_key_exists('tag', $item)) { + $tags = $item['tag']; + unset($item['tag']); + } else { + $tags = ''; + } + // We are doing this outside of the transaction to avoid timing problems self::insertContent($item); @@ -1488,8 +1502,8 @@ class Item extends BaseObject * Due to deadlock issues with the "term" table we are doing these steps after the commit. * This is not perfect - but a workable solution until we found the reason for the problem. */ - if (array_key_exists('tag', $item)) { - Term::insertFromTagFieldByItemId($current_post); + if (!empty($tags)) { + Term::insertFromTagFieldByItemId($current_post, $tags); } if (array_key_exists('file', $item)) { diff --git a/src/Model/Term.php b/src/Model/Term.php index 53c9da8aa..85b14174a 100644 --- a/src/Model/Term.php +++ b/src/Model/Term.php @@ -35,7 +35,7 @@ class Term return $tag_text; } - public static function insertFromTagFieldByItemId($itemid) + public static function insertFromTagFieldByItemId($itemid, $tags) { $profile_base = System::baseUrl(); $profile_data = parse_url($profile_base); @@ -43,12 +43,14 @@ class Term $profile_base_friendica = $profile_data['host'] . $profile_path . '/profile/'; $profile_base_diaspora = $profile_data['host'] . $profile_path . '/u/'; - $fields = ['guid', 'uid', 'id', 'edited', 'deleted', 'created', 'received', 'title', 'body', 'tag', 'parent']; + $fields = ['guid', 'uid', 'id', 'edited', 'deleted', 'created', 'received', 'title', 'body', 'parent']; $message = Item::selectFirst($fields, ['id' => $itemid]); if (!DBM::is_result($message)) { return; } + $message['tag'] = $tags; + // Clean up all tags dba::delete('term', ['otype' => TERM_OBJ_POST, 'oid' => $itemid, 'type' => [TERM_HASHTAG, TERM_MENTION]]); From 60dcdd0b277f50d2400add4fb02803af2edca2a2 Mon Sep 17 00:00:00 2001 From: Michael Date: Sat, 30 Jun 2018 21:15:24 +0000 Subject: [PATCH 3/3] Preparation for not storing the file field into the item table. --- src/Model/Item.php | 70 ++++++++++++++++++++++++++++++++-------------- src/Model/Term.php | 17 +++++++++-- 2 files changed, 64 insertions(+), 23 deletions(-) diff --git a/src/Model/Item.php b/src/Model/Item.php index 2cc9041bf..d1e3f6a66 100644 --- a/src/Model/Item.php +++ b/src/Model/Item.php @@ -122,6 +122,12 @@ class Item extends BaseObject $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 if (isset($row['writable']) && !empty($row['network']) && in_array($row['network'], [NETWORK_DFRN, NETWORK_DIASPORA, NETWORK_OSTATUS])) { @@ -535,6 +541,12 @@ class Item extends BaseObject $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 = []; foreach ($fields as $table => $table_fields) { foreach ($table_fields as $field => $select) { @@ -621,6 +633,14 @@ class Item extends BaseObject $tags = ''; } + if (array_key_exists('file', $fields)) { + $files = $fields['file']; + /// @todo This is a preparation + //unset($fields['file']); + } else { + $files = ''; + } + if (!empty($fields)) { $success = dba::update('item', $fields, $condition); @@ -644,8 +664,8 @@ class Item extends BaseObject Term::insertFromTagFieldByItemId($item['id'], $tags); } - if (array_key_exists('file', $fields)) { - Term::insertFromFileFieldByItemId($item['id']); + if (!empty($files)) { + Term::insertFromFileFieldByItemId($item['id'], $files); } self::updateThread($item['id']); @@ -717,7 +737,7 @@ class Item extends BaseObject $fields = ['id', 'uri', 'uid', 'parent', 'parent-uri', 'origin', 'deleted', 'file', 'resource-id', 'event-id', 'attach', '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)) { logger('Item with ID ' . $item_id . " hasn't been found.", LOGGER_DEBUG); return false; @@ -728,7 +748,7 @@ class Item extends BaseObject return false; } - $parent = dba::selectFirst('item', ['origin'], ['id' => $item['parent']]); + $parent = self::selectFirst(['origin'], ['id' => $item['parent']]); if (!DBM::is_result($parent)) { $parent = ['origin' => false]; } @@ -785,7 +805,7 @@ class Item extends BaseObject dba::update('item', $item_fields, ['id' => $item['id']]); Term::insertFromTagFieldByItemId($item['id'], ''); - Term::insertFromFileFieldByItemId($item['id']); + Term::insertFromFileFieldByItemId($item['id'], ''); self::deleteThread($item['id'], $item['parent-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) { // 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)) { dba::update('user-item', ['hidden' => true], ['iid' => $global_item['id'], 'uid' => $item['uid']], true); } @@ -832,7 +852,7 @@ class Item extends BaseObject 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)) { return; } @@ -1048,7 +1068,7 @@ class Item extends BaseObject $condition = ["`uri` = ? AND `uid` = ? AND `network` IN (?, ?, ?)", trim($item['uri']), $item['uid'], NETWORK_DIASPORA, NETWORK_DFRN, NETWORK_OSTATUS]; - $existing = dba::selectFirst('item', ['id', 'network'], $condition); + $existing = self::selectFirst(['id', 'network'], $condition); 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 if ($uid != 0) { @@ -1205,7 +1225,7 @@ class Item extends BaseObject 'wall', 'private', 'forum_mode', 'origin']; $condition = ['uri' => $item['parent-uri'], 'uid' => $item['uid']]; $params = ['order' => ['id' => false]]; - $parent = dba::selectFirst('item', $fields, $condition, $params); + $parent = self::selectFirst($fields, $condition, $params); if (DBM::is_result($parent)) { // is the new message multi-level threaded? @@ -1219,7 +1239,7 @@ class Item extends BaseObject 'parent-uri' => $item['parent-uri'], 'uid' => $item['uid']]; $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)) { $parent = $toplevel_parent; @@ -1371,6 +1391,14 @@ class Item extends BaseObject $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 self::insertContent($item); @@ -1478,7 +1506,7 @@ class Item extends BaseObject * in it. */ 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 ($notify) { Addon::callHooks('post_local_end', $posted_item); @@ -1506,8 +1534,8 @@ class Item extends BaseObject Term::insertFromTagFieldByItemId($current_post, $tags); } - if (array_key_exists('file', $item)) { - Term::insertFromFileFieldByItemId($current_post); + if (!empty($files)) { + Term::insertFromFileFieldByItemId($current_post, $files); } if ($item['parent-uri'] === $item['uri']) { @@ -1626,7 +1654,7 @@ class Item extends BaseObject public static function distribute($itemid, $signed_text = '') { $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)) { return; } @@ -1659,7 +1687,7 @@ class Item extends BaseObject $origin_uid = 0; 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)) { $users[$parent['uid']] = $parent['uid']; if ($parent['origin'] && !$item['origin']) { @@ -1740,7 +1768,7 @@ class Item extends BaseObject { $fields = ['uid', 'private', 'moderated', 'visible', 'deleted', 'network']; $condition = ['id' => $itemid, 'parent' => [0, $itemid]]; - $item = dba::selectFirst('item', $fields, $condition); + $item = self::selectFirst($fields, $condition); if (!DBM::is_result($item)) { return; @@ -2046,7 +2074,7 @@ class Item extends BaseObject public static function getGuidById($id) { - $item = dba::selectFirst('item', ['guid'], ['id' => $id]); + $item = self::selectFirst(['guid'], ['id' => $id]); if (DBM::is_result($item)) { return $item['guid']; } else { @@ -2110,7 +2138,7 @@ class Item extends BaseObject $community_page = (($user['page-flags'] == PAGE_COMMUNITY) ? 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)) { return; } @@ -2596,7 +2624,7 @@ class Item extends BaseObject 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)) { logger('like: unknown item ' . $item_id); return false; @@ -2773,7 +2801,7 @@ EOT; 'moderated', 'visible', 'starred', 'bookmark', 'contact-id', 'deleted', 'origin', 'forum_mode', 'mention', 'network', 'author-id', 'owner-id']; $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)) { return; @@ -2795,7 +2823,7 @@ EOT; 'deleted', 'origin', 'forum_mode', 'network', 'author-id', 'owner-id']; $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)) { return; } diff --git a/src/Model/Term.php b/src/Model/Term.php index 85b14174a..bed44d685 100644 --- a/src/Model/Term.php +++ b/src/Model/Term.php @@ -35,6 +35,17 @@ class Term 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) { $profile_base = System::baseUrl(); @@ -150,9 +161,9 @@ class Term * @param integer $itemid item id * @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)) { return; } @@ -164,6 +175,8 @@ class Term return; } + $message['file'] = $files; + if (preg_match_all("/\[(.*?)\]/ism", $message["file"], $files)) { foreach ($files[1] as $file) { dba::insert('term', [