]> git.mxchange.org Git - friendica.git/blobdiff - mod/item.php
Bugfix Diaspora: We exited with the wrong return values and the guid for messages...
[friendica.git] / mod / item.php
index bcf7a4b4693699db540603e27e4ba72e3e7280ad..f696a96a7ee7d1c10d4965325cfe01a344a6d200 100644 (file)
@@ -15,6 +15,8 @@
  * posting categories go through item_store() instead of this function.
  */
 
+use Friendica\App;
+
 require_once 'include/crypto.php';
 require_once 'include/enotify.php';
 require_once 'include/email.php';
@@ -23,13 +25,13 @@ require_once 'include/files.php';
 require_once 'include/threads.php';
 require_once 'include/text.php';
 require_once 'include/items.php';
-require_once 'include/Scrape.php';
+require_once 'include/probe.php';
 require_once 'include/diaspora.php';
 require_once 'include/Contact.php';
 
 function item_post(App $a) {
 
-       if ((! local_user()) && (! remote_user()) && (! x($_REQUEST,'commenter'))) {
+       if ((! local_user()) && (! remote_user()) && (! x($_REQUEST, 'commenter'))) {
                return;
        }
 
@@ -71,8 +73,8 @@ function item_post(App $a) {
        }
 
        // Is this a reply to something?
-       $parent = ((x($_REQUEST,'parent')) ? intval($_REQUEST['parent']) : 0);
-       $parent_uri = ((x($_REQUEST,'parent_uri')) ? trim($_REQUEST['parent_uri']) : '');
+       $parent = ((x($_REQUEST, 'parent')) ? intval($_REQUEST['parent']) : 0);
+       $parent_uri = ((x($_REQUEST, 'parent_uri')) ? trim($_REQUEST['parent_uri']) : '');
 
        $parent_item = null;
        $parent_contact = null;
@@ -85,7 +87,7 @@ function item_post(App $a) {
 
                $objecttype = ACTIVITY_OBJ_COMMENT;
 
-               if (! x($_REQUEST,'type')) {
+               if (! x($_REQUEST, 'type')) {
                        $_REQUEST['type'] = 'net-comment';
                }
 
@@ -114,7 +116,7 @@ function item_post(App $a) {
 
                if (! dbm::is_result($r)) {
                        notice( t('Unable to locate original post.') . EOL);
-                       if (x($_REQUEST,'return')) {
+                       if (x($_REQUEST, 'return')) {
                                goaway($return_path);
                        }
                        killme();
@@ -142,7 +144,6 @@ function item_post(App $a) {
                                $parent_contact = get_contact_details_by_url($thrparent[0]["author-link"]);
 
                                if (!isset($parent_contact["nick"])) {
-                                       require_once 'include/Scrape.php';
                                        $probed_contact = probe_url($thrparent[0]["author-link"]);
                                        if ($probed_contact["network"] != NETWORK_FEED) {
                                                $parent_contact = $probed_contact;
@@ -167,11 +168,11 @@ function item_post(App $a) {
                logger('mod_item: item_post parent=' . $parent);
        }
 
-       $profile_uid = ((x($_REQUEST,'profile_uid')) ? intval($_REQUEST['profile_uid']) : 0);
-       $post_id     = ((x($_REQUEST,'post_id'))     ? intval($_REQUEST['post_id'])     : 0);
-       $app         = ((x($_REQUEST,'source'))      ? strip_tags($_REQUEST['source'])  : '');
-       $extid       = ((x($_REQUEST,'extid'))       ? strip_tags($_REQUEST['extid'])   : '');
-       $object      = ((x($_REQUEST,'object'))      ? $_REQUEST['object']              : '');
+       $profile_uid = ((x($_REQUEST, 'profile_uid')) ? intval($_REQUEST['profile_uid']) : 0);
+       $post_id     = ((x($_REQUEST, 'post_id'))     ? intval($_REQUEST['post_id'])     : 0);
+       $app         = ((x($_REQUEST, 'source'))      ? strip_tags($_REQUEST['source'])  : '');
+       $extid       = ((x($_REQUEST, 'extid'))       ? strip_tags($_REQUEST['extid'])   : '');
+       $object      = ((x($_REQUEST, 'object'))      ? $_REQUEST['object']              : '');
 
        // Check for multiple posts with the same message id (when the post was created via API)
        if (($message_id != '') AND ($profile_uid != 0)) {
@@ -325,8 +326,9 @@ function item_post(App $a) {
                // if using the API, we won't see pubmail_enable - figure out if it should be set
 
                if ($api_source && $profile_uid && $profile_uid == local_user() && (! $private)) {
-                       $mail_disabled = ((function_exists('imap_open') && (! get_config('system','imap_disabled'))) ? 0 : 1);
+                       $mail_disabled = ((function_exists('imap_open') && (! get_config('system', 'imap_disabled'))) ? 0 : 1);
                        if (! $mail_disabled) {
+                               /// @TODO Check if only pubmail is loaded, * loads all columns
                                $r = q("SELECT * FROM `mailacct` WHERE `uid` = %d AND `server` != '' LIMIT 1",
                                        intval(local_user())
                                );
@@ -372,7 +374,7 @@ function item_post(App $a) {
                $r = q("SELECT * FROM `contact` WHERE `uid` = %d AND `self` = 1 LIMIT 1",
                        intval($_SESSION['uid']));
        } elseif(remote_user()) {
-               if (is_array($_SESSION['remote'])) {
+               if (x($_SESSION, 'remote') && is_array($_SESSION['remote'])) {
                        foreach ($_SESSION['remote'] as $v) {
                                if ($v['uid'] == $profile_uid) {
                                        $contact_id = $v['cid'];
@@ -544,7 +546,7 @@ function item_post(App $a) {
        if ($parent AND ($parent_contact['network'] == NETWORK_OSTATUS)) {
                $contact = '@[url=' . $parent_contact['url'] . ']' . $parent_contact['nick'] . '[/url]';
 
-               if (!in_array($contact,$tags)) {
+               if (!in_array($contact, $tags)) {
                        $body = $contact . ' ' . $body;
                        $tags[] = $contact;
                }
@@ -581,6 +583,7 @@ function item_post(App $a) {
                         * Robert Johnson should be first in the $tags array
                         */
                        $fullnametagged = false;
+                       /// @TODO $tagged is initialized above if() block and is not filled, maybe old-lost code?
                        foreach ($tagged as $nextTag) {
                                if (stristr($nextTag, $tag . ' ')) {
                                        $fullnametagged = true;
@@ -647,7 +650,7 @@ function item_post(App $a) {
        // even if the post arrived via API we are considering that it
        // originated on this site by default for determining relayability.
 
-       $origin = ((x($_REQUEST,'origin')) ? intval($_REQUEST['origin']) : 1);
+       $origin = ((x($_REQUEST, 'origin')) ? intval($_REQUEST['origin']) : 1);
 
        $notify_type = (($parent) ? 'comment-new' : 'wall-new' );
 
@@ -721,6 +724,18 @@ function item_post(App $a) {
        $datarray['last-child'] = 1;
        $datarray['visible'] = 1;
 
+       $datarray['protocol'] = PROTOCOL_DFRN;
+
+       $r = dba::fetch_first("SELECT `conversation-uri`, `conversation-href` FROM `conversation` WHERE `item-uri` = ?", $datarray['parent-uri']);
+       if (dbm::is_result($r)) {
+               if ($r['conversation-uri'] != '') {
+                       $datarray['conversation-uri'] = $r['conversation-uri'];
+               }
+               if ($r['conversation-href'] != '') {
+                       $datarray['conversation-href'] = $r['conversation-href'];
+               }
+       }
+
        if ($orig_post) {
                $datarray['edit'] = true;
        }
@@ -749,7 +764,7 @@ function item_post(App $a) {
                }
 
                $json = array('cancel' => 1);
-               if (x($_REQUEST,'jsreload') && strlen($_REQUEST['jsreload'])) {
+               if (x($_REQUEST, 'jsreload') && strlen($_REQUEST['jsreload'])) {
                        $json['reload'] = App::get_baseurl() . '/' . $_REQUEST['jsreload'];
                }
 
@@ -760,6 +775,8 @@ function item_post(App $a) {
        // Fill the cache field
        put_item_in_cache($datarray);
 
+       $datarray = store_conversation($datarray);
+
        if ($orig_post) {
                $r = q("UPDATE `item` SET `title` = '%s', `body` = '%s', `tag` = '%s', `attach` = '%s', `file` = '%s', `rendered-html` = '%s', `rendered-hash` = '%s', `edited` = '%s', `changed` = '%s' WHERE `id` = %d AND `uid` = %d",
                        dbesc($datarray['title']),
@@ -783,7 +800,7 @@ function item_post(App $a) {
                file_tag_update_pconfig($uid,$categories_old,$categories_new,'category');
 
                proc_run(PRIORITY_HIGH, "include/notifier.php", 'edit_post', $post_id);
-               if ((x($_REQUEST,'return')) && strlen($return_path)) {
+               if ((x($_REQUEST, 'return')) && strlen($return_path)) {
                        logger('return: ' . $return_path);
                        goaway($return_path);
                }
@@ -792,8 +809,7 @@ function item_post(App $a) {
                $post_id = 0;
        }
 
-       q("COMMIT");
-       q("START TRANSACTION;");
+       dba::transaction();
 
        $r = q("INSERT INTO `item` (`guid`, `extid`, `uid`,`type`,`wall`,`gravity`, `network`, `contact-id`,
                                        `owner-name`,`owner-link`,`owner-avatar`, `owner-id`,
@@ -883,7 +899,7 @@ function item_post(App $a) {
        }
 
        if ($post_id == 0) {
-               q("COMMIT");
+               dba::commit();
                logger('mod_item: unable to retrieve post that was just stored.');
                notice(t('System error. Post not saved.') . EOL);
                goaway($return_path);
@@ -976,7 +992,7 @@ function item_post(App $a) {
                                if (! strlen($addr)) {
                                        continue;
                                }
-                               $disclaimer = '<hr />' . sprintf( t('This message was sent to you by %s, a member of the Friendica social network.'),$a->user['username'])
+                               $disclaimer = '<hr />' . sprintf( t('This message was sent to you by %s, a member of the Friendica social network.'), $a->user['username'])
                                        . '<br />';
                                $disclaimer .= sprintf( t('You may visit them online at %s'), App::get_baseurl() . '/profile/' . $a->user['nickname']) . EOL;
                                $disclaimer .= t('Please contact the sender by replying to this post if you do not wish to receive these messages.') . EOL;
@@ -1009,7 +1025,7 @@ function item_post(App $a) {
                update_thread($parent, true);
        }
 
-       q("COMMIT");
+       dba::commit();
 
        create_tags_from_item($post_id);
        create_files_from_item($post_id);
@@ -1088,7 +1104,6 @@ function item_content(App $a) {
  * @return boolean true if replaced, false if not replaced
  */
 function handle_tag(App $a, &$body, &$inform, &$str_tags, $profile_uid, $tag, $network = "") {
-       require_once 'include/Scrape.php';
        require_once 'include/socgraph.php';
 
        $replaced = false;
@@ -1200,9 +1215,9 @@ function handle_tag(App $a, &$body, &$inform, &$str_tags, $profile_uid, $tag, $n
                        }
                } else {
                        $r = false;
-                       if (strrpos($name,'+')) {
+                       if (strrpos($name, '+')) {
                                // Is it in format @nick+number?
-                               $tagcid = intval(substr($name,strrpos($name,'+') + 1));
+                               $tagcid = intval(substr($name, strrpos($name, '+') + 1));
 
                                $r = q("SELECT `id`, `url`, `nick`, `name`, `alias`, `network` FROM `contact` WHERE `id` = %d AND `uid` = %d LIMIT 1",
                                                intval($tagcid),
@@ -1271,22 +1286,24 @@ function handle_tag(App $a, &$body, &$inform, &$str_tags, $profile_uid, $tag, $n
 
                        $replaced = true;
                        // create profile link
-                       $profile = str_replace(',','%2c',$profile);
-                       $newtag = '@[url='.$profile.']'.$newname.'[/url]';
-                       $body = str_replace('@'.$name, $newtag, $body);
+                       $profile = str_replace(',', '%2c', $profile);
+                       $newtag = '@[url=' . $profile . ']' . $newname . '[/url]';
+                       $body = str_replace('@' . $name, $newtag, $body);
                        // append tag to str_tags
-                       if (! stristr($str_tags,$newtag)) {
+                       if (! stristr($str_tags, $newtag)) {
                                if (strlen($str_tags)) {
                                        $str_tags .= ',';
                                }
                                $str_tags .= $newtag;
                        }
 
-                       // Status.Net seems to require the numeric ID URL in a mention if the person isn't
-                       // subscribed to you. But the nickname URL is OK if they are. Grrr. We'll tag both.
+                       /*
+                        * Status.Net seems to require the numeric ID URL in a mention if the person isn't
+                        * subscribed to you. But the nickname URL is OK if they are. Grrr. We'll tag both.
+                        */
                        if (strlen($alias)) {
-                               $newtag = '@[url='.$alias.']'.$newname.'[/url]';
-                               if (! stristr($str_tags,$newtag)) {
+                               $newtag = '@[url=' . $alias . ']' . $newname . '[/url]';
+                               if (! stristr($str_tags, $newtag)) {
                                        if (strlen($str_tags)) {
                                                $str_tags .= ',';
                                        }