'author-id', 'author-link', 'owner-link', 'contact-uid',
'signed_text', 'network'];
- // Field list for "post-content" table that is mixed with the item table
- const MIXED_CONTENT_FIELDLIST = ['title', 'content-warning', 'body', 'location',
- 'coord', 'app', 'rendered-hash', 'rendered-html', 'verb',
- 'object-type', 'object', 'target-type', 'target', 'plink'];
-
- // Field list for "post-content" table that is not present in the "item" table
- const CONTENT_FIELDLIST = ['language', 'raw-body'];
-
// All fields in the item table
const ITEM_FIELDLIST = ['id', 'uid', 'parent', 'uri', 'parent-uri', 'thr-parent',
'guid', 'uri-id', 'parent-uri-id', 'thr-parent-id', 'vid',
'author-id', 'author-link', 'author-name', 'author-avatar', 'author-network',
'owner-id', 'owner-link', 'owner-name', 'owner-avatar', 'causer-id'];
+ // Item fiels that still are in use
+ const USED_FIELDLIST = ['id', 'parent', 'guid', 'uri', 'uri-id', 'parent-uri', 'parent-uri-id',
+ 'thr-parent', 'thr-parent-id', 'created', 'edited', 'commented', 'received', 'changed',
+ 'gravity', 'network', 'owner-id', 'author-id', 'causer-id', 'vid', 'extid', 'post-type',
+ 'global', 'private', 'visible', 'moderated', 'deleted', 'uid', 'contact-id',
+ 'wall', 'origin', 'pubmail', 'starred', 'unseen', 'mention', 'forum_mode', 'psid',
+ 'event-id', 'type', 'bookmark'];
+
+ // Legacy item fields that aren't stored any more in the item table
+ const LEGACY_FIELDLIST = ['uri-hash', 'iaid', 'icid', 'attach',
+ 'allow_cid', 'allow_gid', 'deny_cid', 'deny_gid', 'postopts',
+ 'resource-id', 'inform', 'file', 'location', 'coord', 'tag', 'plink',
+ 'title', 'content-warning', 'body', 'app', 'verb', 'object-type', 'object',
+ 'target-type', 'target', 'author-name', 'author-link', 'author-avatar',
+ 'owner-name', 'owner-link', 'owner-avatar', 'rendered-hash', 'rendered-html'];
+
// List of all verbs that don't need additional content data.
// Never reorder or remove entries from this list. Just add new ones at the end, if needed.
const ACTIVITIES = [
// Update the contact relations
Contact\Relation::store($toplevel_parent['author-id'], $item['author-id'], $item['created']);
-
- unset($item['parent_origin']);
} else {
$parent_id = 0;
$parent_origin = $item['origin'];
}
- // We don't store the causer link, only the id
- unset($item['causer-link']);
-
- // We don't store these fields anymore in the item table
- unset($item['author-link']);
- unset($item['author-name']);
- unset($item['author-avatar']);
- unset($item['author-network']);
-
- unset($item['owner-link']);
- unset($item['owner-name']);
- unset($item['owner-avatar']);
-
$item['parent-uri-id'] = ItemURI::getIdByURI($item['parent-uri']);
$item['thr-parent-id'] = ItemURI::getIdByURI($item['thr-parent']);
$item['edit'] = false;
$item['parent'] = $parent_id;
Hook::callAll('post_local', $item);
- unset($item['edit']);
} else {
Hook::callAll('post_remote', $item);
}
- // Set after the insert because top-level posts are self-referencing
- unset($item['parent']);
-
if (!empty($item['cancel'])) {
Logger::log('post cancelled by addon.');
return 0;
$item['deny_gid']
);
- unset($item['allow_cid']);
- unset($item['allow_gid']);
- unset($item['deny_cid']);
- unset($item['deny_gid']);
-
- // This array field is used to trigger some automatic reactions
- // It is mainly used in the "post_local" hook.
- unset($item['api_source']);
-
if ($item['verb'] == Activity::ANNOUNCE) {
self::setOwnerforResharedItem($item);
}
// Check for hashtags in the body and repair or add hashtag links
$item['body'] = self::setHashtags($item['body']);
- if (!empty($item['attach'])) {
- Post\Media::insertFromAttachment($item['uri-id'], $item['attach']);
- }
-
// Fill the cache field
self::putInCache($item);
$notify_type = Delivery::POST;
}
- if (!in_array($item['verb'], self::ACTIVITIES)) {
- Post\Content::insert($item['uri-id'], $item);
+ // Filling item related side tables
+ if (!empty($item['attach'])) {
+ Post\Media::insertFromAttachment($item['uri-id'], $item['attach']);
}
- $body = $item['body'];
- $verb = $item['verb'];
-
- // We just remove everything that is content
- foreach (array_merge(self::CONTENT_FIELDLIST, self::MIXED_CONTENT_FIELDLIST) as $field) {
- unset($item[$field]);
+ if (!in_array($item['verb'], self::ACTIVITIES)) {
+ Post\Content::insert($item['uri-id'], $item);
}
- unset($item['activity']);
-
- // Filling item related side tables
-
// Diaspora signature
if (!empty($item['diaspora_signed_text'])) {
DBA::replace('diaspora-interaction', ['uri-id' => $item['uri-id'], 'interaction' => $item['diaspora_signed_text']]);
}
- unset($item['diaspora_signed_text']);
-
// Attached file links
if (!empty($item['file'])) {
Post\Category::storeTextByURIId($item['uri-id'], $item['uid'], $item['file']);
}
- unset($item['file']);
-
// Delivery relevant data
$delivery_data = Post\DeliveryData::extractFields($item);
- unset($item['postopts']);
- unset($item['inform']);
if (!empty($item['origin']) || !empty($item['wall']) || !empty($delivery_data['postopts']) || !empty($delivery_data['inform'])) {
Post\DeliveryData::insert($item['uri-id'], $delivery_data);
// Store tags from the body if this hadn't been handled previously in the protocol classes
if (!Tag::existsForPost($item['uri-id'])) {
- Tag::storeFromBody($item['uri-id'], $body);
+ Tag::storeFromBody($item['uri-id'], $item['body']);
}
$id = Post\User::insert($item['uri-id'], $item['uid'], $item);
- if ($id) {
- if ($item['gravity'] == GRAVITY_PARENT) {
- Post\ThreadUser::insert($item['uri-id'], $item['uid'], $item);
- }
+ if (!$id) {
+ Logger::notice('Post-User is already inserted - aborting', ['uid' => $item['uid'], 'uri-id' => $item['uri-id']]);
+ return 0;
+ }
- $condition = ['uri-id' => $item['uri-id'], 'uid' => $item['uid'], 'network' => $item['network']];
- if (Post::exists($condition)) {
- Logger::notice('Item is already inserted - aborting', $condition);
- return 0;
- }
+ if ($item['gravity'] == GRAVITY_PARENT) {
+ Post\ThreadUser::insert($item['uri-id'], $item['uid'], $item);
+ }
- // Remove all fields that aren't part of the item table
- $item = DBStructure::getFieldsForTable('item', $item);
+ $condition = ['uri-id' => $item['uri-id'], 'uid' => $item['uid'], 'network' => $item['network']];
+ if (Post::exists($condition)) {
+ Logger::notice('Item is already inserted - aborting', $condition);
+ return 0;
+ }
- $result = DBA::insert('item', $item);
+ // Remove all fields that aren't part of the item table
+ $table_fields = DBStructure::getFieldsForTable('item', $item);
- // When the item was successfully stored we fetch the ID of the item.
- $current_post = DBA::lastInsertId();
- } else {
- Logger::notice('Post-User is already inserted - aborting', ['uid' => $item['uid'], 'uri-id' => $item['uri-id']]);
- return 0;
+ // We remove all legacy fields that now are stored in other tables
+ foreach (self::LEGACY_FIELDLIST as $field) {
+ unset($table_fields[$field]);
}
+ $result = DBA::insert('item', $table_fields);
+
+ // When the item was successfully stored we fetch the ID of the item.
+ $current_post = DBA::lastInsertId();
+
if (empty($current_post) || !DBA::isResult($result)) {
// On failure store the data into a spool file so that the "SpoolPost" worker can try again later.
Logger::warning('Could not store item. it will be spooled', ['result' => $result, 'id' => $current_post]);
$update_commented = in_array($item['gravity'], [GRAVITY_PARENT, GRAVITY_COMMENT]);
} else {
// Update when it isn't a follow or tag verb
- $update_commented = !in_array($verb, [Activity::FOLLOW, Activity::TAG]);
+ $update_commented = !in_array($item['verb'], [Activity::FOLLOW, Activity::TAG]);
}
if ($update_commented) {
self::updateContact($item);
- UserItem::setNotification($current_post);
+ Post\UserNotification::setNotification($item['uri-id'], $item['uid']);
- check_user_notification($current_post);
+ check_user_notification($item['uri-id'], $item['uid']);
+ //check_user_notification($current_post);
// Distribute items to users who subscribed to their tags
self::distributeByTags($item);
projects / friendica.git / blobdiff