]> git.mxchange.org Git - friendica.git/blob - mod/item.php
Merge pull request #11241 from annando/timing
[friendica.git] / mod / item.php
1 <?php
2 /**
3  * @copyright Copyright (C) 2010-2022, the Friendica project
4  *
5  * @license GNU AGPL version 3 or any later version
6  *
7  * This program is free software: you can redistribute it and/or modify
8  * it under the terms of the GNU Affero General Public License as
9  * published by the Free Software Foundation, either version 3 of the
10  * License, or (at your option) any later version.
11  *
12  * This program is distributed in the hope that it will be useful,
13  * but WITHOUT ANY WARRANTY; without even the implied warranty of
14  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
15  * GNU Affero General Public License for more details.
16  *
17  * You should have received a copy of the GNU Affero General Public License
18  * along with this program.  If not, see <https://www.gnu.org/licenses/>.
19  *
20  * This is the POST destination for most all locally posted
21  * text stuff. This function handles status, wall-to-wall status,
22  * local comments, and remote coments that are posted on this site
23  * (as opposed to being delivered in a feed).
24  * Also processed here are posts and comments coming through the
25  * statusnet/twitter API.
26  *
27  * All of these become an "item" which is our basic unit of
28  * information.
29  */
30
31 use Friendica\App;
32 use Friendica\Content\Item as ItemHelper;
33 use Friendica\Content\PageInfo;
34 use Friendica\Content\Text\BBCode;
35 use Friendica\Core\Hook;
36 use Friendica\Core\Logger;
37 use Friendica\Core\Protocol;
38 use Friendica\Core\Session;
39 use Friendica\Core\System;
40 use Friendica\Core\Worker;
41 use Friendica\Database\DBA;
42 use Friendica\DI;
43 use Friendica\Model\APContact;
44 use Friendica\Model\Attach;
45 use Friendica\Model\Contact;
46 use Friendica\Model\Conversation;
47 use Friendica\Model\FileTag;
48 use Friendica\Model\Item;
49 use Friendica\Model\ItemURI;
50 use Friendica\Model\Notification;
51 use Friendica\Model\Photo;
52 use Friendica\Model\Post;
53 use Friendica\Model\Tag;
54 use Friendica\Model\User;
55 use Friendica\Network\HTTPException;
56 use Friendica\Object\EMail\ItemCCEMail;
57 use Friendica\Protocol\Activity;
58 use Friendica\Security\Security;
59 use Friendica\Util\DateTimeFormat;
60 use Friendica\Util\ParseUrl;
61 use Friendica\Worker\Delivery;
62
63 function item_post(App $a) {
64         if (!Session::isAuthenticated()) {
65                 throw new HTTPException\ForbiddenException();
66         }
67
68         $uid = local_user();
69
70         if (!empty($_REQUEST['dropitems'])) {
71                 $arr_drop = explode(',', $_REQUEST['dropitems']);
72                 foreach ($arr_drop as $item) {
73                         Item::deleteForUser(['id' => $item], $uid);
74                 }
75
76                 $json = ['success' => 1];
77                 System::jsonExit($json);
78         }
79
80         Hook::callAll('post_local_start', $_REQUEST);
81
82         Logger::debug('postvars', ['_REQUEST' => $_REQUEST]);
83
84         $api_source = $_REQUEST['api_source'] ?? false;
85
86         $return_path = $_REQUEST['return'] ?? '';
87         $preview = intval($_REQUEST['preview'] ?? 0);
88
89         /*
90          * Check for doubly-submitted posts, and reject duplicates
91          * Note that we have to ignore previews, otherwise nothing will post
92          * after it's been previewed
93          */
94         if (!$preview && !empty($_REQUEST['post_id_random'])) {
95                 if (!empty($_SESSION['post-random']) && $_SESSION['post-random'] == $_REQUEST['post_id_random']) {
96                         Logger::info('item post: duplicate post');
97                         item_post_return(DI::baseUrl(), $api_source, $return_path);
98                 } else {
99                         $_SESSION['post-random'] = $_REQUEST['post_id_random'];
100                 }
101         }
102
103         // Is this a reply to something?
104         $parent_item_id = intval($_REQUEST['parent'] ?? 0);
105         $thr_parent_uri = trim($_REQUEST['parent_uri'] ?? '');
106
107         $parent_item = null;
108         $toplevel_item = null;
109         $toplevel_item_id = 0;
110         $toplevel_user_id = null;
111
112         $objecttype = null;
113         $profile_uid = ($_REQUEST['profile_uid'] ?? 0) ?: local_user();
114         $posttype = ($_REQUEST['post_type'] ?? '') ?: Item::PT_ARTICLE;
115
116         if ($parent_item_id || $thr_parent_uri) {
117                 if ($parent_item_id) {
118                         $parent_item = Post::selectFirst(Item::ITEM_FIELDLIST, ['id' => $parent_item_id]);
119                 } elseif ($thr_parent_uri) {
120                         $parent_item = Post::selectFirst(Item::ITEM_FIELDLIST, ['uri' => $thr_parent_uri, 'uid' => $profile_uid]);
121                 }
122
123                 // if this isn't the top-level parent of the conversation, find it
124                 if (DBA::isResult($parent_item)) {
125                         // The URI and the contact is taken from the direct parent which needn't to be the top parent
126                         $thr_parent_uri = $parent_item['uri'];
127                         $toplevel_item = $parent_item;
128
129                         if ($parent_item['gravity'] != GRAVITY_PARENT) {
130                                 $toplevel_item = Post::selectFirst(Item::ITEM_FIELDLIST, ['id' => $toplevel_item['parent']]);
131                         }
132                 }
133
134                 if (!DBA::isResult($toplevel_item)) {
135                         notice(DI::l10n()->t('Unable to locate original post.'));
136                         if ($return_path) {
137                                 DI::baseUrl()->redirect($return_path);
138                         }
139                         throw new HTTPException\NotFoundException(DI::l10n()->t('Unable to locate original post.'));
140                 }
141
142                 // When commenting on a public post then store the post for the current user
143                 // This enables interaction like starring and saving into folders
144                 if ($toplevel_item['uid'] == 0) {
145                         $stored = Item::storeForUserByUriId($toplevel_item['uri-id'], local_user());
146                         Logger::info('Public item stored for user', ['uri-id' => $toplevel_item['uri-id'], 'uid' => $uid, 'stored' => $stored]);
147                         if ($stored) {
148                                 $toplevel_item = Post::selectFirst(Item::ITEM_FIELDLIST, ['id' => $stored]);
149                         }
150                 }
151
152                 $toplevel_item_id = $toplevel_item['id'];
153                 $toplevel_user_id = $toplevel_item['uid'];
154
155                 $objecttype = Activity\ObjectType::COMMENT;
156         }
157
158         if ($toplevel_item_id) {
159                 Logger::info('mod_item: item_post', ['parent' => $toplevel_item_id]);
160         }
161
162         $post_id     = intval($_REQUEST['post_id'] ?? 0);
163         $app         = strip_tags($_REQUEST['source'] ?? '');
164         $extid       = strip_tags($_REQUEST['extid'] ?? '');
165         $object      = $_REQUEST['object'] ?? '';
166
167         // Don't use "defaults" here. It would turn 0 to 1
168         if (!isset($_REQUEST['wall'])) {
169                 $wall = 1;
170         } else {
171                 $wall = $_REQUEST['wall'];
172         }
173
174         // Ensure that the user id in a thread always stay the same
175         if (!is_null($toplevel_user_id) && in_array($toplevel_user_id, [local_user(), 0])) {
176                 $profile_uid = $toplevel_user_id;
177         }
178
179         // Allow commenting if it is an answer to a public post
180         $allow_comment = local_user() && $toplevel_item_id && in_array($toplevel_item['private'], [Item::PUBLIC, Item::UNLISTED]) && in_array($toplevel_item['network'], Protocol::FEDERATED);
181
182         // Now check that valid personal details have been provided
183         if (!Security::canWriteToUserWall($profile_uid) && !$allow_comment) {
184                 Logger::notice('Permission denied.', ['local' => local_user(), 'profile_uid' => $profile_uid, 'toplevel_item_id' => $toplevel_item_id, 'network' => $toplevel_item['network']]);
185                 notice(DI::l10n()->t('Permission denied.'));
186                 if ($return_path) {
187                         DI::baseUrl()->redirect($return_path);
188                 }
189
190                 throw new HTTPException\ForbiddenException(DI::l10n()->t('Permission denied.'));
191         }
192
193         // Init post instance
194         $orig_post = null;
195
196         // is this an edited post?
197         if ($post_id > 0) {
198                 $orig_post = Post::selectFirst(Item::ITEM_FIELDLIST, ['id' => $post_id]);
199         }
200
201         $user = User::getById($profile_uid, ['allow_cid', 'allow_gid', 'deny_cid', 'deny_gid']);
202         if (!DBA::isResult($user) && !$toplevel_item_id) {
203                 return 0;
204         }
205
206         $categories = '';
207         $postopts = '';
208         $emailcc = '';
209         $body = $_REQUEST['body'] ?? '';
210         $has_attachment = $_REQUEST['has_attachment'] ?? 0;
211
212         // If we have a speparate attachment, we need to add it to the body.
213         if (!empty($has_attachment)) {
214                 $attachment_type  = $_REQUEST['attachment_type'] ??  '';
215                 $attachment_title = $_REQUEST['attachment_title'] ?? '';
216                 $attachment_text  = $_REQUEST['attachment_text'] ??  '';
217
218                 $attachment_url     = hex2bin($_REQUEST['attachment_url'] ??     '');
219                 $attachment_img_src = hex2bin($_REQUEST['attachment_img_src'] ?? '');
220
221                 $attachment_img_width  = $_REQUEST['attachment_img_width'] ??  0;
222                 $attachment_img_height = $_REQUEST['attachment_img_height'] ?? 0;
223
224                 // Fetch the basic attachment data
225                 $attachment = ParseUrl::getSiteinfoCached($attachment_url);
226                 unset($attachment['keywords']);
227
228                 // Overwrite the basic data with possible changes from the frontend
229                 $attachment['type'] = $attachment_type;
230                 $attachment['title'] = $attachment_title;
231                 $attachment['text'] = $attachment_text;
232                 $attachment['url'] = $attachment_url;
233
234                 if (!empty($attachment_img_src)) {
235                         $attachment['images'] = [
236                                 0 => [
237                                         'src'    => $attachment_img_src,
238                                         'width'  => $attachment_img_width,
239                                         'height' => $attachment_img_height
240                                 ]
241                         ];
242                 } else {
243                         unset($attachment['images']);
244                 }
245
246                 $att_bbcode = "\n" . PageInfo::getFooterFromData($attachment);
247                 $body .= $att_bbcode;
248         }
249
250         // Convert links with empty descriptions to links without an explicit description
251         $body = preg_replace('#\[url=([^\]]*?)\]\[/url\]#ism', '[url]$1[/url]', $body);
252
253         if (!empty($orig_post)) {
254                 $str_group_allow   = $orig_post['allow_gid'];
255                 $str_contact_allow = $orig_post['allow_cid'];
256                 $str_group_deny    = $orig_post['deny_gid'];
257                 $str_contact_deny  = $orig_post['deny_cid'];
258                 $location          = $orig_post['location'];
259                 $coord             = $orig_post['coord'];
260                 $verb              = $orig_post['verb'];
261                 $objecttype        = $orig_post['object-type'];
262                 $app               = $orig_post['app'];
263                 $categories        = Post\Category::getTextByURIId($orig_post['uri-id'], $orig_post['uid']);
264                 $title             = trim($_REQUEST['title'] ?? '');
265                 $body              = trim($body);
266                 $private           = $orig_post['private'];
267                 $pubmail_enabled   = $orig_post['pubmail'];
268                 $network           = $orig_post['network'];
269                 $guid              = $orig_post['guid'];
270                 $extid             = $orig_post['extid'];
271         } else {
272                 $aclFormatter = DI::aclFormatter();
273                 $str_contact_allow = isset($_REQUEST['contact_allow']) ? $aclFormatter->toString($_REQUEST['contact_allow']) : $user['allow_cid'] ?? '';
274                 $str_group_allow   = isset($_REQUEST['group_allow'])   ? $aclFormatter->toString($_REQUEST['group_allow'])   : $user['allow_gid'] ?? '';
275                 $str_contact_deny  = isset($_REQUEST['contact_deny'])  ? $aclFormatter->toString($_REQUEST['contact_deny'])  : $user['deny_cid']  ?? '';
276                 $str_group_deny    = isset($_REQUEST['group_deny'])    ? $aclFormatter->toString($_REQUEST['group_deny'])    : $user['deny_gid']  ?? '';
277
278                 $visibility = $_REQUEST['visibility'] ?? '';
279                 if ($visibility === 'public') {
280                         // The ACL selector introduced in version 2019.12 sends ACL input data even when the Public visibility is selected
281                         $str_contact_allow = $str_group_allow = $str_contact_deny = $str_group_deny = '';
282                 } else if ($visibility === 'custom') {
283                         // Since we know from the visibility parameter the item should be private, we have to prevent the empty ACL
284                         // case that would make it public. So we always append the author's contact id to the allowed contacts.
285                         // See https://github.com/friendica/friendica/issues/9672
286                         $str_contact_allow .= $aclFormatter->toString(Contact::getPublicIdByUserId($uid));
287                 }
288
289                 $title             = trim($_REQUEST['title']    ?? '');
290                 $location          = trim($_REQUEST['location'] ?? '');
291                 $coord             = trim($_REQUEST['coord']    ?? '');
292                 $verb              = trim($_REQUEST['verb']     ?? '');
293                 $emailcc           = trim($_REQUEST['emailcc']  ?? '');
294                 $body              = trim($body);
295                 $network           = trim(($_REQUEST['network']  ?? '') ?: Protocol::DFRN);
296                 $guid              = System::createUUID();
297
298                 $postopts = $_REQUEST['postopts'] ?? '';
299
300                 if (strlen($str_group_allow) || strlen($str_contact_allow) || strlen($str_group_deny) || strlen($str_contact_deny)) {
301                         $private = Item::PRIVATE;
302                 } elseif (DI::pConfig()->get($profile_uid, 'system', 'unlisted')) {
303                         $private = Item::UNLISTED;
304                 } else {
305                         $private = Item::PUBLIC;
306                 }
307
308                 // If this is a comment, set the permissions from the parent.
309
310                 if ($toplevel_item) {
311                         // for non native networks use the network of the original post as network of the item
312                         if (($toplevel_item['network'] != Protocol::DIASPORA)
313                                 && ($toplevel_item['network'] != Protocol::OSTATUS)
314                                 && ($network == "")) {
315                                 $network = $toplevel_item['network'];
316                         }
317
318                         $str_contact_allow = $toplevel_item['allow_cid'] ?? '';
319                         $str_group_allow   = $toplevel_item['allow_gid'] ?? '';
320                         $str_contact_deny  = $toplevel_item['deny_cid'] ?? '';
321                         $str_group_deny    = $toplevel_item['deny_gid'] ?? '';
322                         $private           = $toplevel_item['private'];
323
324                         $wall              = $toplevel_item['wall'];
325                 }
326
327                 $pubmail_enabled = ($_REQUEST['pubmail_enable'] ?? false) && !$private;
328
329                 // if using the API, we won't see pubmail_enable - figure out if it should be set
330                 if ($api_source && $profile_uid && $profile_uid == local_user() && !$private) {
331                         if (function_exists('imap_open') && !DI::config()->get('system', 'imap_disabled')) {
332                                 $pubmail_enabled = DBA::exists('mailacct', ["`uid` = ? AND `server` != ? AND `pubmail`", local_user(), '']);
333                         }
334                 }
335
336                 if (!strlen($body)) {
337                         if ($preview) {
338                                 System::jsonExit(['preview' => '']);
339                         }
340
341                         notice(DI::l10n()->t('Empty post discarded.'));
342                         if ($return_path) {
343                                 DI::baseUrl()->redirect($return_path);
344                         }
345
346                         throw new HTTPException\BadRequestException(DI::l10n()->t('Empty post discarded.'));
347                 }
348         }
349
350         if (!empty($categories)) {
351                 // get the "fileas" tags for this post
352                 $filedas = FileTag::fileToArray($categories);
353         }
354
355         $list_array = explode(',', trim($_REQUEST['category'] ?? ''));
356         $categories = FileTag::arrayToFile($list_array, 'category');
357
358         if (!empty($filedas) && is_array($filedas)) {
359                 // append the fileas stuff to the new categories list
360                 $categories .= FileTag::arrayToFile($filedas);
361         }
362
363         // get contact info for poster
364
365         $author = null;
366         $self   = false;
367         $contact_id = 0;
368
369         if (local_user() && ((local_user() == $profile_uid) || $allow_comment)) {
370                 $self = true;
371                 $author = DBA::selectFirst('contact', [], ['uid' => local_user(), 'self' => true]);
372         } elseif (!empty(Session::getRemoteContactID($profile_uid))) {
373                 $author = DBA::selectFirst('contact', [], ['id' => Session::getRemoteContactID($profile_uid)]);
374         }
375
376         if (DBA::isResult($author)) {
377                 $contact_id = $author['id'];
378         }
379
380         // get contact info for owner
381         if ($profile_uid == local_user() || $allow_comment) {
382                 $contact_record = $author ?: [];
383         } else {
384                 $contact_record = DBA::selectFirst('contact', [], ['uid' => $profile_uid, 'self' => true]) ?: [];
385         }
386
387         // Look for any tags and linkify them
388         $inform   = '';
389         $private_forum = false;
390         $private_id = null;
391         $only_to_forum = false;
392         $forum_contact = [];
393
394         // Personal notes must never be altered to a forum post.
395         if ($posttype != Item::PT_PERSONAL_NOTE) {
396                 // Convert mentions in the body to a unified format
397                 $body = BBCode::setMentions($body, local_user() ? local_user() : $profile_uid, $network);
398
399                 // Search for forum mentions
400                 foreach (Tag::getFromBody($body, Tag::TAG_CHARACTER[Tag::MENTION] . Tag::TAG_CHARACTER[Tag::EXCLUSIVE_MENTION]) as $tag) {
401                         $contact = Contact::getByURLForUser($tag[2], $profile_uid);
402                         if (!empty($inform)) {
403                                 $inform .= ',';
404                         }
405                         $inform .= 'cid:' . $contact['id'];
406
407                         if (!$toplevel_item_id || empty($contact['cid']) || ($contact['contact-type'] != Contact::TYPE_COMMUNITY)) {
408                                 continue;
409                         }
410
411                         if (!empty($contact['prv']) || ($tag[1] == Tag::TAG_CHARACTER[Tag::EXCLUSIVE_MENTION])) {
412                                 $private_forum = $contact['prv'];
413                                 $only_to_forum = ($tag[1] == Tag::TAG_CHARACTER[Tag::EXCLUSIVE_MENTION]);
414                                 $private_id = $contact['id'];
415                                 $forum_contact = $contact;
416                                 Logger::info('Private forum or exclusive mention', ['url' => $tag[2], 'mention' => $tag[1]]);
417                         } elseif ($str_contact_allow == '<' . $contact['id'] . '>') {
418                                 $private_forum = false;
419                                 $only_to_forum = true;
420                                 $private_id = $contact['id'];
421                                 $forum_contact = $contact;
422                                 Logger::info('Public forum', ['url' => $tag[2], 'mention' => $tag[1]]);
423                         } else {
424                                 Logger::info('Post with forum mention will not be converted to a forum post', ['url' => $tag[2], 'mention' => $tag[1]]);
425                         }
426                 }
427                 Logger::info('Got inform', ['inform' => $inform]);
428         }
429
430         $original_contact_id = $contact_id;
431
432         if (!$toplevel_item_id && !empty($forum_contact) && ($private_forum || $only_to_forum)) {
433                 // we tagged a forum in a top level post. Now we change the post
434                 $private = $private_forum ? Item::PRIVATE : Item::UNLISTED;
435
436                 if ($only_to_forum) {
437                         $postopts = '';
438                 }
439
440                 if (!$private_forum) {
441                         $str_contact_allow = '';
442                         $str_group_allow   = '';
443                         $str_contact_deny  = '';
444                         $str_group_deny    = '';
445                 }
446
447                 if ($private_forum || !APContact::getByURL($forum_contact['url'])) {
448                         $str_group_allow = '';
449                         $str_contact_deny = '';
450                         $str_group_deny = '';
451                         if ($private_forum) {
452                                 $str_contact_allow = '<' . $private_id . '>';
453                         } else {
454                                 $str_contact_allow = '';
455                         }
456                         $contact_id = $private_id;
457                         $contact_record = $forum_contact;
458                         $_REQUEST['origin'] = false;
459                         $wall = 0;
460                 }
461         }
462
463         /*
464          * When a photo was uploaded into the message using the (profile wall) ajax
465          * uploader, The permissions are initially set to disallow anybody but the
466          * owner from seeing it. This is because the permissions may not yet have been
467          * set for the post. If it's private, the photo permissions should be set
468          * appropriately. But we didn't know the final permissions on the post until
469          * now. So now we'll look for links of uploaded messages that are in the
470          * post and set them to the same permissions as the post itself.
471          */
472
473         $match = null;
474
475         if (!$preview && Photo::setPermissionFromBody($body, $uid, $original_contact_id, $str_contact_allow, $str_group_allow, $str_contact_deny, $str_group_deny)) {
476                 $objecttype = Activity\ObjectType::IMAGE;
477         }
478
479         /*
480          * Next link in any attachment references we find in the post.
481          */
482         $match = [];
483
484         /// @todo these lines should be moved to Model/Attach (Once it exists)
485         if (!$preview && preg_match_all("/\[attachment\](.*?)\[\/attachment\]/", $body, $match)) {
486                 $attaches = $match[1];
487                 if (count($attaches)) {
488                         foreach ($attaches as $attach) {
489                                 // Ensure to only modify attachments that you own
490                                 $srch = '<' . intval($original_contact_id) . '>';
491
492                                 $condition = ['allow_cid' => $srch, 'allow_gid' => '', 'deny_cid' => '', 'deny_gid' => '',
493                                                 'id' => $attach];
494                                 if (!Attach::exists($condition)) {
495                                         continue;
496                                 }
497
498                                 $fields = ['allow_cid' => $str_contact_allow, 'allow_gid' => $str_group_allow,
499                                                 'deny_cid' => $str_contact_deny, 'deny_gid' => $str_group_deny];
500                                 $condition = ['id' => $attach];
501                                 Attach::update($fields, $condition);
502                         }
503                 }
504         }
505
506         // embedded bookmark or attachment in post? set bookmark flag
507
508         $data = BBCode::getAttachmentData($body);
509         $match = [];
510         if ((preg_match_all("/\[bookmark\=([^\]]*)\](.*?)\[\/bookmark\]/ism", $body, $match, PREG_SET_ORDER) || isset($data["type"]))
511                 && ($posttype != Item::PT_PERSONAL_NOTE)) {
512                 $posttype = Item::PT_PAGE;
513                 $objecttype =  Activity\ObjectType::BOOKMARK;
514         }
515
516         $body = DI::bbCodeVideo()->transform($body);
517
518         $body = BBCode::scaleExternalImages($body);
519
520         // Setting the object type if not defined before
521         if (!$objecttype) {
522                 $objecttype = Activity\ObjectType::NOTE; // Default value
523                 $objectdata = BBCode::getAttachedData($body);
524
525                 if ($objectdata["type"] == "link") {
526                         $objecttype = Activity\ObjectType::BOOKMARK;
527                 } elseif ($objectdata["type"] == "video") {
528                         $objecttype = Activity\ObjectType::VIDEO;
529                 } elseif ($objectdata["type"] == "photo") {
530                         $objecttype = Activity\ObjectType::IMAGE;
531                 }
532
533         }
534
535         $attachments = '';
536         $match = [];
537
538         if (preg_match_all('/(\[attachment\]([0-9]+)\[\/attachment\])/',$body,$match)) {
539                 foreach ($match[2] as $mtch) {
540                         $fields = ['id', 'filename', 'filesize', 'filetype'];
541                         $attachment = Attach::selectFirst($fields, ['id' => $mtch]);
542                         if ($attachment !== false) {
543                                 if (strlen($attachments)) {
544                                         $attachments .= ',';
545                                 }
546                                 $attachments .= Post\Media::getAttachElement(DI::baseUrl() . '/attach/' . $attachment['id'],
547                                         $attachment['filesize'], $attachment['filetype'], $attachment['filename'] ?? '');
548                         }
549                         $body = str_replace($match[1],'',$body);
550                 }
551         }
552
553         if (!strlen($verb)) {
554                 $verb = Activity::POST;
555         }
556
557         if ($network == "") {
558                 $network = Protocol::DFRN;
559         }
560
561         $gravity = ($toplevel_item_id ? GRAVITY_COMMENT : GRAVITY_PARENT);
562
563         // even if the post arrived via API we are considering that it
564         // originated on this site by default for determining relayability.
565
566         // Don't use "defaults" here. It would turn 0 to 1
567         if (!isset($_REQUEST['origin'])) {
568                 $origin = 1;
569         } else {
570                 $origin = $_REQUEST['origin'];
571         }
572
573         $uri = Item::newURI($api_source ? $profile_uid : $uid, $guid);
574
575         // Fallback so that we alway have a parent uri
576         if (!$thr_parent_uri || !$toplevel_item_id) {
577                 $thr_parent_uri = $uri;
578         }
579
580         $datarray = [];
581         $datarray['uid']           = $profile_uid;
582         $datarray['wall']          = $wall;
583         $datarray['gravity']       = $gravity;
584         $datarray['network']       = $network;
585         $datarray['contact-id']    = $contact_id;
586         $datarray['owner-name']    = $contact_record['name'] ?? '';
587         $datarray['owner-link']    = $contact_record['url'] ?? '';
588         $datarray['owner-avatar']  = $contact_record['thumb'] ?? '';
589         $datarray['owner-id']      = Contact::getIdForURL($datarray['owner-link']);
590         $datarray['author-name']   = $author['name'];
591         $datarray['author-link']   = $author['url'];
592         $datarray['author-avatar'] = $author['thumb'];
593         $datarray['author-id']     = Contact::getIdForURL($datarray['author-link']);
594         $datarray['created']       = DateTimeFormat::utcNow();
595         $datarray['edited']        = DateTimeFormat::utcNow();
596         $datarray['commented']     = DateTimeFormat::utcNow();
597         $datarray['received']      = DateTimeFormat::utcNow();
598         $datarray['changed']       = DateTimeFormat::utcNow();
599         $datarray['extid']         = $extid;
600         $datarray['guid']          = $guid;
601         $datarray['uri']           = $uri;
602         $datarray['title']         = $title;
603         $datarray['body']          = $body;
604         $datarray['app']           = $app;
605         $datarray['location']      = $location;
606         $datarray['coord']         = $coord;
607         $datarray['file']          = $categories;
608         $datarray['inform']        = $inform;
609         $datarray['verb']          = $verb;
610         $datarray['post-type']     = $posttype;
611         $datarray['object-type']   = $objecttype;
612         $datarray['allow_cid']     = $str_contact_allow;
613         $datarray['allow_gid']     = $str_group_allow;
614         $datarray['deny_cid']      = $str_contact_deny;
615         $datarray['deny_gid']      = $str_group_deny;
616         $datarray['private']       = $private;
617         $datarray['pubmail']       = $pubmail_enabled;
618         $datarray['attach']        = $attachments;
619
620         $datarray['thr-parent']    = $thr_parent_uri;
621
622         $datarray['postopts']      = $postopts;
623         $datarray['origin']        = $origin;
624         $datarray['object']        = $object;
625
626         $datarray['attachments']   = $_REQUEST['attachments'] ?? [];
627
628         /*
629          * These fields are for the convenience of addons...
630          * 'self' if true indicates the owner is posting on their own wall
631          * If parent is 0 it is a top-level post.
632          */
633         $datarray['parent']        = $toplevel_item_id;
634         $datarray['self']          = $self;
635
636         // This triggers posts via API and the mirror functions
637         $datarray['api_source'] = $api_source;
638
639         // This field is for storing the raw conversation data
640         $datarray['protocol'] = Conversation::PARCEL_DIRECT;
641         $datarray['direction'] = Conversation::PUSH;
642
643         $conversation = DBA::selectFirst('conversation', ['conversation-uri', 'conversation-href'], ['item-uri' => $datarray['thr-parent']]);
644         if (DBA::isResult($conversation)) {
645                 if ($conversation['conversation-uri'] != '') {
646                         $datarray['conversation-uri'] = $conversation['conversation-uri'];
647                 }
648                 if ($conversation['conversation-href'] != '') {
649                         $datarray['conversation-href'] = $conversation['conversation-href'];
650                 }
651         }
652
653         if ($orig_post) {
654                 $datarray['edit'] = true;
655         } else {
656                 // If this was a share, add missing data here
657                 $datarray = Item::addShareDataFromOriginal($datarray);
658
659                 $datarray['edit'] = false;
660         }
661
662         // Check for hashtags in the body and repair or add hashtag links
663         if ($preview || $orig_post) {
664                 $datarray['body'] = Item::setHashtags($datarray['body']);
665         }
666
667         // preview mode - prepare the body for display and send it via json
668         if ($preview) {
669                 // We set the datarray ID to -1 because in preview mode the dataray
670                 // doesn't have an ID.
671                 $datarray["id"] = -1;
672                 $datarray["uri-id"] = -1;
673                 $datarray["author-network"] = Protocol::DFRN;
674
675                 $o = DI::conversation()->create([array_merge($contact_record, $datarray)], 'search', false, true);
676
677                 System::jsonExit(['preview' => $o]);
678         }
679
680         Hook::callAll('post_local',$datarray);
681
682         if (!empty($_REQUEST['scheduled_at'])) {
683                 $scheduled_at = DateTimeFormat::convert($_REQUEST['scheduled_at'], 'UTC', $a->getTimeZone());
684                 if ($scheduled_at > DateTimeFormat::utcNow()) {
685                         unset($datarray['created']);
686                         unset($datarray['edited']);
687                         unset($datarray['commented']);
688                         unset($datarray['received']);
689                         unset($datarray['changed']);
690                         unset($datarray['edit']);
691                         unset($datarray['self']);
692                         unset($datarray['api_source']);
693
694                         Post\Delayed::add($datarray['uri'], $datarray, PRIORITY_HIGH, Post\Delayed::PREPARED_NO_HOOK, $scheduled_at);
695                         item_post_return(DI::baseUrl(), $api_source, $return_path);
696                 }
697         }
698
699         if (!empty($datarray['cancel'])) {
700                 Logger::info('mod_item: post cancelled by addon.');
701                 if ($return_path) {
702                         DI::baseUrl()->redirect($return_path);
703                 }
704
705                 $json = ['cancel' => 1];
706                 if (!empty($_REQUEST['jsreload'])) {
707                         $json['reload'] = DI::baseUrl() . '/' . $_REQUEST['jsreload'];
708                 }
709
710                 System::jsonExit($json);
711         }
712
713         $datarray['uri-id'] = ItemURI::getIdByURI($datarray['uri']);
714
715         if ($orig_post) {
716                 // Fill the cache field
717                 // This could be done in Item::update as well - but we have to check for the existance of some fields.
718                 Item::putInCache($datarray);
719
720                 $fields = [
721                         'title' => $datarray['title'],
722                         'body' => $datarray['body'],
723                         'attach' => $datarray['attach'],
724                         'file' => $datarray['file'],
725                         'rendered-html' => $datarray['rendered-html'],
726                         'rendered-hash' => $datarray['rendered-hash'],
727                         'edited' => DateTimeFormat::utcNow(),
728                         'changed' => DateTimeFormat::utcNow()];
729
730                 Item::update($fields, ['id' => $post_id]);
731
732                 if ($return_path) {
733                         DI::baseUrl()->redirect($return_path);
734                 }
735
736                 throw new HTTPException\OKException(DI::l10n()->t('Post updated.'));
737         }
738
739         unset($datarray['edit']);
740         unset($datarray['self']);
741         unset($datarray['api_source']);
742
743         $post_id = Item::insert($datarray);
744
745         if (!$post_id) {
746                 notice(DI::l10n()->t('Item wasn\'t stored.'));
747                 if ($return_path) {
748                         DI::baseUrl()->redirect($return_path);
749                 }
750
751                 throw new HTTPException\InternalServerErrorException(DI::l10n()->t('Item wasn\'t stored.'));
752         }
753
754         $datarray = Post::selectFirst(Item::ITEM_FIELDLIST, ['id' => $post_id]);
755
756         if (!DBA::isResult($datarray)) {
757                 Logger::error('Item couldn\'t be fetched.', ['post_id' => $post_id]);
758                 if ($return_path) {
759                         DI::baseUrl()->redirect($return_path);
760                 }
761
762                 throw new HTTPException\InternalServerErrorException(DI::l10n()->t('Item couldn\'t be fetched.'));
763         }
764
765         Tag::storeFromBody($datarray['uri-id'], $datarray['body']);
766
767         if (!\Friendica\Content\Feature::isEnabled($uid, 'explicit_mentions') && ($datarray['gravity'] == GRAVITY_COMMENT)) {
768                 Tag::createImplicitMentions($datarray['uri-id'], $datarray['thr-parent-id']);
769         }
770
771         // These notifications are sent if someone else is commenting other your wall
772         if ($contact_record != $author) {
773                 if ($toplevel_item_id) {
774                         DI::notify()->createFromArray([
775                                 'type'  => Notification\Type::COMMENT,
776                                 'otype' => Notification\ObjectType::ITEM,
777                                 'verb'  => Activity::POST,
778                                 'uid'   => $profile_uid,
779                                 'cid'   => $datarray['author-id'],
780                                 'item'  => $datarray,
781                                 'link'  => DI::baseUrl() . '/display/' . urlencode($datarray['guid']),
782                         ]);
783                 } elseif (empty($forum_contact)) {
784                         DI::notify()->createFromArray([
785                                 'type'  => Notification\Type::WALL,
786                                 'otype' => Notification\ObjectType::ITEM,
787                                 'verb'  => Activity::POST,
788                                 'uid'   => $profile_uid,
789                                 'cid'   => $datarray['author-id'],
790                                 'item'  => $datarray,
791                                 'link'  => DI::baseUrl() . '/display/' . urlencode($datarray['guid']),
792                         ]);
793                 }
794         }
795
796         Hook::callAll('post_local_end', $datarray);
797
798         if (strlen($emailcc) && $profile_uid == local_user()) {
799                 $recipients = explode(',', $emailcc);
800                 if (count($recipients)) {
801                         foreach ($recipients as $recipient) {
802                                 $address = trim($recipient);
803                                 if (!strlen($address)) {
804                                         continue;
805                                 }
806                                 DI::emailer()->send(new ItemCCEMail(DI::app(), DI::l10n(), DI::baseUrl(),
807                                         $datarray, $address, $author['thumb'] ?? ''));
808                         }
809                 }
810         }
811
812         // When we are doing some forum posting via ! we have to start the notifier manually.
813         // These kind of posts don't initiate the notifier call in the item class.
814         if ($only_to_forum) {
815                 Worker::add(['priority' => PRIORITY_HIGH, 'dont_fork' => false], "Notifier", Delivery::POST, (int)$datarray['uri-id'], (int)$datarray['uid']);
816         }
817
818         Logger::info('post_complete');
819
820         if ($api_source) {
821                 return $post_id;
822         }
823
824         item_post_return(DI::baseUrl(), $api_source, $return_path);
825         // NOTREACHED
826 }
827
828 function item_post_return($baseurl, $api_source, $return_path)
829 {
830         if ($api_source) {
831                 return;
832         }
833
834         if ($return_path) {
835                 DI::baseUrl()->redirect($return_path);
836         }
837
838         $json = ['success' => 1];
839         if (!empty($_REQUEST['jsreload'])) {
840                 $json['reload'] = $baseurl . '/' . $_REQUEST['jsreload'];
841         }
842
843         Logger::info('post_json', ['json' => $json]);
844
845         System::jsonExit($json);
846 }
847
848 function item_content(App $a)
849 {
850         if (!Session::isAuthenticated()) {
851                 throw new HTTPException\UnauthorizedException();
852         }
853
854         $args = DI::args();
855
856         if (!$args->has(3)) {
857                 throw new HTTPException\BadRequestException();
858         }
859
860         $o = '';
861         switch ($args->get(1)) {
862                 case 'drop':
863                         if (DI::mode()->isAjax()) {
864                                 Item::deleteForUser(['id' => $args->get(2)], local_user());
865                                 // ajax return: [<item id>, 0 (no perm) | <owner id>]
866                                 System::jsonExit([intval($args->get(2)), local_user()]);
867                         } else {
868                                 if (!empty($args->get(3))) {
869                                         $o = drop_item($args->get(2), $args->get(3));
870                                 } else {
871                                         $o = drop_item($args->get(2));
872                                 }
873                         }
874                         break;
875                 case 'block':
876                         $item = Post::selectFirstForUser(local_user(), ['guid', 'author-id', 'parent', 'gravity'], ['id' => $args->get(2)]);
877                         if (empty($item['author-id'])) {
878                                 throw new HTTPException\NotFoundException('Item not found');
879                         }
880
881                         Contact\User::setBlocked($item['author-id'], local_user(), true);
882
883                         if (DI::mode()->isAjax()) {
884                                 // ajax return: [<item id>, 0 (no perm) | <owner id>]
885                                 System::jsonExit([intval($args->get(2)), local_user()]);
886                         } else {
887                                 item_redirect_after_action($item, $args->get(3));
888                         }
889                         break;
890         }
891
892         return $o;
893 }
894
895 /**
896  * @param int    $id
897  * @param string $return
898  * @return string
899  * @throws HTTPException\InternalServerErrorException
900  */
901 function drop_item(int $id, string $return = '')
902 {
903         // locate item to be deleted
904         $fields = ['id', 'uid', 'guid', 'contact-id', 'deleted', 'gravity', 'parent'];
905         $item = Post::selectFirstForUser(local_user(), $fields, ['id' => $id]);
906
907         if (!DBA::isResult($item)) {
908                 notice(DI::l10n()->t('Item not found.'));
909                 DI::baseUrl()->redirect('network');
910         }
911
912         if ($item['deleted']) {
913                 return '';
914         }
915
916         $contact_id = 0;
917
918         // check if logged in user is either the author or owner of this item
919         if (Session::getRemoteContactID($item['uid']) == $item['contact-id']) {
920                 $contact_id = $item['contact-id'];
921         }
922
923         if ((local_user() == $item['uid']) || $contact_id) {
924                 // delete the item
925                 Item::deleteForUser(['id' => $item['id']], local_user());
926
927                 item_redirect_after_action($item, $return);
928         } else {
929                 Logger::notice('Permission denied.', ['local' => local_user(), 'uid' => $item['uid'], 'cid' => $contact_id]);
930                 notice(DI::l10n()->t('Permission denied.'));
931                 DI::baseUrl()->redirect('display/' . $item['guid']);
932                 //NOTREACHED
933         }
934
935         return '';
936 }
937
938 function item_redirect_after_action($item, $returnUrlHex)
939 {
940         $return_url = hex2bin($returnUrlHex);
941
942         // removes update_* from return_url to ignore Ajax refresh
943         $return_url = str_replace("update_", "", $return_url);
944
945         // Check if delete a comment
946         if ($item['gravity'] == GRAVITY_COMMENT) {
947                 if (!empty($item['parent'])) {
948                         $parentitem = Post::selectFirstForUser(local_user(), ['guid'], ['id' => $item['parent']]);
949                 }
950
951                 // Return to parent guid
952                 if (!empty($parentitem)) {
953                         DI::baseUrl()->redirect('display/' . $parentitem['guid']);
954                         //NOTREACHED
955                 } // In case something goes wrong
956                 else {
957                         DI::baseUrl()->redirect('network');
958                         //NOTREACHED
959                 }
960         } else {
961                 // if unknown location or deleting top level post called from display
962                 if (empty($return_url) || strpos($return_url, 'display') !== false) {
963                         DI::baseUrl()->redirect('network');
964                         //NOTREACHED
965                 } else {
966                         DI::baseUrl()->redirect($return_url);
967                         //NOTREACHED
968                 }
969         }
970 }