]> git.mxchange.org Git - friendica.git/blobdiff - mod/item.php
salmon protocol changes magicsig draft-experimental, fixes to hostxrd
[friendica.git] / mod / item.php
index 9d7b954a84465a41d505a8b27d2d82c514817f2d..fd5d405ff6cac3a071a431f95220c4eaf37dd147 100644 (file)
@@ -6,6 +6,8 @@
  * text stuff. This function handles status, wall-to-wall status, 
  * local comments, and remote coments - that are posted on this site 
  * (as opposed to being delivered in a feed).
+ * Also processed here are posts and comments coming through the 
+ * statusnet/twitter API. 
  * All of these become an "item" which is our basic unit of 
  * information.
  * Posts that originate externally or do not fall into the above 
@@ -33,22 +35,61 @@ function item_post(&$a) {
 
        call_hooks('post_local_start', $_POST);
 
+       $api_source = ((x($_POST,'api_source')) ? true : false);
+
+       /**
+        * Is this a reply to something?
+        */
+
        $parent = ((x($_POST,'parent')) ? intval($_POST['parent']) : 0);
+       $parent_uri = ((x($_POST,'parent_uri')) ? trim($_POST['parent_uri']) : '');
 
        $parent_item = null;
        $parent_contact = null;
+       $thr_parent = '';
+       $parid = 0;
+       $r = false;
 
-       if($parent) {
-               $r = q("SELECT * FROM `item` WHERE `id` = %d LIMIT 1",
-                       intval($parent)
-               );
-               if(! count($r)) {
+       if($parent || $parent_uri) {
+
+               if(! x($_POST,'type'))
+                       $_POST['type'] = 'net-comment';
+
+               if($parent) {
+                       $r = q("SELECT * FROM `item` WHERE `id` = %d LIMIT 1",
+                               intval($parent)
+                       );
+               }
+               elseif($parent_uri && local_user()) {
+                       // This is coming from an API source, and we are logged in
+                       $r = q("SELECT * FROM `item` WHERE `uri` = '%s' AND `uid` = %d LIMIT 1",
+                               dbesc($parent_uri),
+                               intval(local_user())
+                       );
+               }
+               // if this isn't the real parent of the conversation, find it
+               if($r !== false && count($r)) {
+                       $parid = $r[0]['parent'];
+                       if($r[0]['id'] != $r[0]['parent']) {
+                               $r = q("SELECT * FROM `item` WHERE `id` = `parent` AND `parent` = %d LIMIT 1",
+                                       intval($parid)
+                               );
+                       }
+               }
+
+               if(($r === false) || (! count($r))) {
                        notice( t('Unable to locate original post.') . EOL);
                        if(x($_POST,'return')) 
                                goaway($a->get_baseurl() . "/" . $_POST['return'] );
                        killme();
                }
                $parent_item = $r[0];
+               $parent = $r[0]['id'];
+
+               // multi-level threading - preserve the info but re-parent to our single level threading
+               if(($parid) && ($parid != $parent))
+                       $thr_parent = $parent_uri;
+
                if($parent_item['contact-id'] && $uid) {
                        $r = q("SELECT * FROM `contact` WHERE `id` = %d AND `uid` = %d LIMIT 1",
                                intval($parent_item['contact-id']),
@@ -59,9 +100,11 @@ function item_post(&$a) {
                }
        }
 
+       if($parent) logger('mod_post: parent=' . $parent);
+
        $profile_uid = ((x($_POST,'profile_uid')) ? intval($_POST['profile_uid']) : 0);
        $post_id     = ((x($_POST['post_id']))    ? intval($_POST['post_id'])     : 0);
-       $app         = ((x($_POST['source']))     ? notags($_POST['source'])      : '');
+       $app         = ((x($_POST['source']))     ? strip_tags($_POST['source'])  : '');
 
        if(! can_write_wall($a,$profile_uid)) {
                notice( t('Permission denied.') . EOL) ;
@@ -180,16 +223,16 @@ function item_post(&$a) {
                        $contact_record = $r[0];
        }
 
+
+
        $post_type = notags(trim($_POST['type']));
 
        if($post_type === 'net-comment') {
                if($parent_item !== null) {
-                       if($parent_item['type'] === 'remote') {
-                               $post_type = 'remote-comment';
-                       } 
-                       else {          
+                       if($parent_item['wall'] == 1)
                                $post_type = 'wall-comment';
-                       }
+                       else
+                               $post_type = 'remote-comment';
                }
        }
 
@@ -244,6 +287,10 @@ function item_post(&$a) {
        }
 
 
+       /**
+        * Next link in any attachment references we find in the post.
+        */
+
        $match = false;
 
        if(preg_match_all("/\[attachment\](.*?)\[\/attachment\]/",$body,$match)) {
@@ -257,6 +304,10 @@ function item_post(&$a) {
                                if(count($r)) {
                                        $r = q("UPDATE `attach` SET `allow_cid` = '%s', `allow_gid` = '%s', `deny_cid` = '%s', `deny_gid` = '%s'
                                                WHERE `uid` = %d AND `id` = %d LIMIT 1",
+                                               dbesc($str_contact_allow),
+                                               dbesc($str_group_allow),
+                                               dbesc($str_contact_deny),
+                                               dbesc($str_group_deny),
                                                intval($profile_uid),
                                                intval($attach)
                                        );
@@ -265,10 +316,6 @@ function item_post(&$a) {
                }
        }
 
-
-
-
-
        /**
         * Fold multi-line [code] sequences
         */
@@ -285,13 +332,21 @@ function item_post(&$a) {
 
        $tags = get_tags($body);
 
-       if(($parent_contact) && ($parent_contact['network'] === 'stat') && ($parent_contact['nick']) && (! in_array('@' . $parent_contact['nick'],$tags))) {
+       /**
+        * add a statusnet style reply tag if the original post was from there
+        * and we are replying, and there isn't one already
+        */
+
+       if(($parent_contact) && ($parent_contact['network'] === 'stat') 
+               && ($parent_contact['nick']) && (! in_array('@' . $parent_contact['nick'],$tags))) {
                $body = '@' . $parent_contact['nick'] . ' ' . $body;
                $tags[] = '@' . $parent_contact['nick'];
        }               
 
        if(count($tags)) {
                foreach($tags as $tag) {
+                       if(isset($profile))
+                               unset($profile);
                        if(strpos($tag,'#') === 0) {
                                if(strpos($tag,'[url='))
                                        continue;
@@ -325,7 +380,7 @@ function item_post(&$a) {
                                else {
                                        $newname = $name;
                                        $alias = '';
-                                       if(strstr($name,'_')) {
+                                       if(strstr($name,'_') || strstr($name,' ')) {
                                                $newname = str_replace('_',' ',$name);
                                                $r = q("SELECT * FROM `contact` WHERE `name` = '%s' AND `uid` = %d LIMIT 1",
                                                        dbesc($newname),
@@ -385,7 +440,7 @@ function item_post(&$a) {
                        if(count($r)) {
                                if(strlen($attachments))
                                        $attachments .= ',';
-                               $attachments .= '[attach]href="' . $a->get_baseurl() . '/attach/' . $r[0]['id'] . '" size="' . $r[0]['filesize'] . '" type="' . $r[0]['filetype'] . '" title="' . (($r[0]['filename']) ? $r[0]['filename'] : ' ') . '"[/attach]'; 
+                               $attachments .= '[attach]href="' . $a->get_baseurl() . '/attach/' . $r[0]['id'] . '" length="' . $r[0]['filesize'] . '" type="' . $r[0]['filetype'] . '" title="' . (($r[0]['filename']) ? $r[0]['filename'] : '') . '"[/attach]'; 
                        }
                        $body = str_replace($match[1],'',$body);
                }
@@ -419,6 +474,7 @@ function item_post(&$a) {
        $datarray['author-avatar'] = $author['thumb'];
        $datarray['created']       = datetime_convert();
        $datarray['edited']        = datetime_convert();
+       $datarray['received']      = datetime_convert();
        $datarray['changed']       = datetime_convert();
        $datarray['uri']           = $uri;
        $datarray['title']         = $title;
@@ -436,6 +492,7 @@ function item_post(&$a) {
        $datarray['private']       = $private;
        $datarray['pubmail']       = $pubmail_enable;
        $datarray['attach']        = $attachments;
+       $datarray['thr-parent']    = $thr_parent;
 
        /**
         * These fields are for the convenience of plugins...
@@ -473,9 +530,9 @@ function item_post(&$a) {
 
 
        $r = q("INSERT INTO `item` (`uid`,`type`,`wall`,`gravity`,`contact-id`,`owner-name`,`owner-link`,`owner-avatar`, 
-               `author-name`, `author-link`, `author-avatar`, `created`, `edited`, `changed`, `uri`, `title`, `body`, `app`, `location`, `coord`, 
+               `author-name`, `author-link`, `author-avatar`, `created`, `edited`, `received`, `changed`, `uri`, `thr-parent`, `title`, `body`, `app`, `location`, `coord`, 
                `tag`, `inform`, `verb`, `allow_cid`, `allow_gid`, `deny_cid`, `deny_gid`, `private`, `pubmail`, `attach` )
-               VALUES( %d, '%s', %d, %d, %d, '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', %d, %d, '%s' )",
+               VALUES( %d, '%s', %d, %d, %d, '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', %d, %d, '%s' )",
                intval($datarray['uid']),
                dbesc($datarray['type']),
                intval($datarray['wall']),
@@ -489,8 +546,10 @@ function item_post(&$a) {
                dbesc($datarray['author-avatar']),
                dbesc($datarray['created']),
                dbesc($datarray['edited']),
+               dbesc($datarray['received']),
                dbesc($datarray['changed']),
                dbesc($datarray['uri']),
+               dbesc($datarray['thr-parent']),
                dbesc($datarray['title']),
                dbesc($datarray['body']),
                dbesc($datarray['app']),
@@ -723,12 +782,16 @@ function item_post(&$a) {
        }
 
        logger('post_complete');
+
+       // figure out how to return, depending on from whence we came
+
+       if($api_source)
+               return;
+
        if((x($_POST,'return')) && strlen($_POST['return'])) {
                logger('return: ' . $_POST['return']);
                goaway($a->get_baseurl() . "/" . $_POST['return'] );
        }
-       if($_POST['api_source'])
-               return;
        $json = array('success' => 1);
        if(x($_POST,'jsreload') && strlen($_POST['jsreload']))
                $json['reload'] = $a->get_baseurl() . '/' . $_POST['jsreload'];