2010-07-18 15:02:55 +02:00
< ? php
2016-11-24 01:11:22 +01:00
/**
* @ file include / items . php
*/
use \Friendica\ParseUrl ;
2011-08-20 13:53:11 +02:00
require_once ( 'include/bbcode.php' );
require_once ( 'include/oembed.php' );
2011-02-01 14:10:04 +01:00
require_once ( 'include/salmon.php' );
2011-08-20 13:53:11 +02:00
require_once ( 'include/crypto.php' );
2012-07-08 00:20:24 +02:00
require_once ( 'include/Photo.php' );
2013-01-11 01:20:16 +01:00
require_once ( 'include/tags.php' );
2014-03-16 17:12:56 +01:00
require_once ( 'include/files.php' );
2013-01-17 23:20:40 +01:00
require_once ( 'include/text.php' );
2013-01-05 00:47:29 +01:00
require_once ( 'include/email.php' );
2014-03-09 09:19:14 +01:00
require_once ( 'include/threads.php' );
2015-01-06 07:23:11 +01:00
require_once ( 'include/socgraph.php' );
2015-06-06 13:15:37 +02:00
require_once ( 'include/plaintext.php' );
2015-06-07 23:18:02 +02:00
require_once ( 'include/ostatus.php' );
2015-09-27 14:02:05 +02:00
require_once ( 'include/feed.php' );
2016-01-23 12:39:37 +01:00
require_once ( 'include/Contact.php' );
2015-04-05 20:43:06 +02:00
require_once ( 'mod/share.php' );
2016-01-28 22:58:05 +01:00
require_once ( 'include/enotify.php' );
2016-02-05 21:25:20 +01:00
require_once ( 'include/dfrn.php' );
2016-04-13 22:21:23 +02:00
require_once ( 'include/group.php' );
2010-07-18 15:02:55 +02:00
2015-06-23 16:13:09 +02:00
require_once ( 'library/defuse/php-encryption-1.2.1/Crypto.php' );
2010-09-09 05:14:17 +02:00
function construct_verb ( $item ) {
2016-10-22 12:14:41 +02:00
if ( $item [ 'verb' ])
2010-09-09 05:14:17 +02:00
return $item [ 'verb' ];
return ACTIVITY_POST ;
}
2012-07-07 01:09:23 +02:00
/* limit_body_size ()
*
* The purpose of this function is to apply system message length limits to
* imported messages without including any embedded photos in the length
*/
2016-10-22 12:14:41 +02:00
if ( ! function_exists ( 'limit_body_size' )) {
2012-07-07 01:09:23 +02:00
function limit_body_size ( $body ) {
2013-04-28 13:30:20 +02:00
// logger('limit_body_size: start', LOGGER_DEBUG);
2012-07-07 01:09:23 +02:00
$maxlen = get_max_import_size ();
// If the length of the body, including the embedded images, is smaller
2012-07-08 00:20:24 +02:00
// than the maximum, then don't waste time looking for the images
2016-10-22 12:14:41 +02:00
if ( $maxlen && ( strlen ( $body ) > $maxlen )) {
2012-07-07 01:09:23 +02:00
2012-07-08 00:20:24 +02:00
logger ( 'limit_body_size: the total body length exceeds the limit' , LOGGER_DEBUG );
$orig_body = $body ;
$new_body = '' ;
$textlen = 0 ;
$max_found = false ;
2012-07-07 01:09:23 +02:00
2012-07-08 00:20:24 +02:00
$img_start = strpos ( $orig_body , '[img' );
$img_st_close = ( $img_start !== false ? strpos ( substr ( $orig_body , $img_start ), ']' ) : false );
$img_end = ( $img_start !== false ? strpos ( substr ( $orig_body , $img_start ), '[/img]' ) : false );
while (( $img_st_close !== false ) && ( $img_end !== false )) {
2012-07-07 01:09:23 +02:00
2012-07-08 00:20:24 +02:00
$img_st_close ++ ; // make it point to AFTER the closing bracket
$img_end += $img_start ;
$img_end += strlen ( '[/img]' );
2012-07-07 01:09:23 +02:00
2016-10-22 12:14:41 +02:00
if ( ! strcmp ( substr ( $orig_body , $img_start + $img_st_close , 5 ), 'data:' )) {
2012-07-08 00:20:24 +02:00
// This is an embedded image
2012-07-07 01:09:23 +02:00
2016-10-22 12:14:41 +02:00
if ( ( $textlen + $img_start ) > $maxlen ) {
if ( $textlen < $maxlen ) {
2012-07-08 00:20:24 +02:00
logger ( 'limit_body_size: the limit happens before an embedded image' , LOGGER_DEBUG );
$new_body = $new_body . substr ( $orig_body , 0 , $maxlen - $textlen );
$textlen = $maxlen ;
}
2016-10-22 12:14:41 +02:00
} else {
2012-07-08 00:20:24 +02:00
$new_body = $new_body . substr ( $orig_body , 0 , $img_start );
2012-07-08 02:47:13 +02:00
$textlen += $img_start ;
2012-07-08 00:20:24 +02:00
}
$new_body = $new_body . substr ( $orig_body , $img_start , $img_end - $img_start );
2016-10-22 12:14:41 +02:00
} else {
2012-07-07 01:09:23 +02:00
2016-10-22 12:14:41 +02:00
if ( ( $textlen + $img_end ) > $maxlen ) {
if ( $textlen < $maxlen ) {
2012-07-08 00:20:24 +02:00
logger ( 'limit_body_size: the limit happens before the end of a non-embedded image' , LOGGER_DEBUG );
$new_body = $new_body . substr ( $orig_body , 0 , $maxlen - $textlen );
$textlen = $maxlen ;
}
2016-10-22 12:14:41 +02:00
} else {
2012-07-08 00:20:24 +02:00
$new_body = $new_body . substr ( $orig_body , 0 , $img_end );
$textlen += $img_end ;
}
2012-07-07 01:09:23 +02:00
}
2012-07-08 00:20:24 +02:00
$orig_body = substr ( $orig_body , $img_end );
2012-07-07 01:09:23 +02:00
2016-10-22 12:14:41 +02:00
if ( $orig_body === false ) // in case the body ends on a closing image tag
2012-07-08 00:20:24 +02:00
$orig_body = '' ;
2012-07-07 01:09:23 +02:00
2012-07-08 00:20:24 +02:00
$img_start = strpos ( $orig_body , '[img' );
$img_st_close = ( $img_start !== false ? strpos ( substr ( $orig_body , $img_start ), ']' ) : false );
$img_end = ( $img_start !== false ? strpos ( substr ( $orig_body , $img_start ), '[/img]' ) : false );
}
2012-07-07 01:09:23 +02:00
2016-10-22 12:14:41 +02:00
if ( ( $textlen + strlen ( $orig_body )) > $maxlen ) {
if ( $textlen < $maxlen ) {
2012-07-08 00:20:24 +02:00
logger ( 'limit_body_size: the limit happens after the end of the last image' , LOGGER_DEBUG );
$new_body = $new_body . substr ( $orig_body , 0 , $maxlen - $textlen );
$textlen = $maxlen ;
}
2016-10-22 12:14:41 +02:00
} else {
2012-07-08 00:20:24 +02:00
logger ( 'limit_body_size: the text size with embedded images extracted did not violate the limit' , LOGGER_DEBUG );
$new_body = $new_body . $orig_body ;
$textlen += strlen ( $orig_body );
2012-07-07 01:09:23 +02:00
}
2012-07-08 00:20:24 +02:00
return $new_body ;
2016-10-22 12:14:41 +02:00
} else
2012-07-07 01:09:23 +02:00
return $body ;
}}
2010-11-04 00:48:21 +01:00
2012-06-30 09:25:22 +02:00
function title_is_body ( $title , $body ) {
$title = strip_tags ( $title );
$title = trim ( $title );
2012-08-17 07:59:21 +02:00
$title = html_entity_decode ( $title , ENT_QUOTES , 'UTF-8' );
2012-06-30 09:25:22 +02:00
$title = str_replace ( array ( " \n " , " \r " , " \t " , " " ), array ( " " , " " , " " , " " ), $title );
$body = strip_tags ( $body );
$body = trim ( $body );
2012-08-17 07:59:21 +02:00
$body = html_entity_decode ( $body , ENT_QUOTES , 'UTF-8' );
2012-06-30 09:25:22 +02:00
$body = str_replace ( array ( " \n " , " \r " , " \t " , " " ), array ( " " , " " , " " , " " ), $body );
if ( strlen ( $title ) < strlen ( $body ))
$body = substr ( $body , 0 , strlen ( $title ));
if (( $title != $body ) and ( substr ( $title , - 3 ) == " ... " )) {
$pos = strrpos ( $title , " ... " );
if ( $pos > 0 ) {
$title = substr ( $title , 0 , $pos );
$body = substr ( $body , 0 , $pos );
}
}
return ( $title == $body );
}
2010-07-19 05:49:10 +02:00
2014-10-20 08:03:47 +02:00
function add_page_info_data ( $data ) {
2014-10-20 08:10:21 +02:00
call_hooks ( 'page_info_data' , $data );
2014-01-05 16:10:02 +01:00
2014-04-04 10:52:53 +02:00
// It maybe is a rich content, but if it does have everything that a link has,
// then treat it that way
if (( $data [ " type " ] == " rich " ) AND is_string ( $data [ " title " ]) AND
2016-11-13 20:09:47 +01:00
is_string ( $data [ " text " ]) AND ( sizeof ( $data [ " images " ]) > 0 )) {
2014-04-04 10:52:53 +02:00
$data [ " type " ] = " link " ;
2016-11-13 20:09:47 +01:00
}
2014-01-05 16:10:02 +01:00
2016-11-12 21:23:00 +01:00
if ((( $data [ " type " ] != " link " ) AND ( $data [ " type " ] != " video " ) AND ( $data [ " type " ] != " photo " )) OR ( $data [ " title " ] == $data [ " url " ])) {
2016-11-13 09:50:01 +01:00
return " " ;
2016-11-12 21:23:00 +01:00
}
2014-01-05 16:10:02 +01:00
2016-11-13 20:09:47 +01:00
if ( $no_photos AND ( $data [ " type " ] == " photo " )) {
return " " ;
}
2014-01-05 16:10:02 +01:00
2016-11-13 20:09:47 +01:00
if ( sizeof ( $data [ " images " ]) > 0 ) {
2016-04-17 20:43:41 +02:00
$preview = $data [ " images " ][ 0 ];
2016-11-13 20:09:47 +01:00
} else {
2016-04-17 20:43:41 +02:00
$preview = " " ;
2016-11-13 20:09:47 +01:00
}
2016-04-17 20:43:41 +02:00
// Escape some bad characters
$data [ " url " ] = str_replace ( array ( " [ " , " ] " ), array ( " [ " , " ] " ), htmlentities ( $data [ " url " ], ENT_QUOTES , 'UTF-8' , false ));
$data [ " title " ] = str_replace ( array ( " [ " , " ] " ), array ( " [ " , " ] " ), htmlentities ( $data [ " title " ], ENT_QUOTES , 'UTF-8' , false ));
$text = " [attachment type=' " . $data [ " type " ] . " ' " ;
2016-11-12 21:23:00 +01:00
if ( $data [ " text " ] == " " ) {
$data [ " text " ] = $data [ " title " ];
}
if ( $data [ " text " ] == " " ) {
$data [ " text " ] = $data [ " url " ];
}
2016-11-13 20:09:47 +01:00
if ( $data [ " url " ] != " " ) {
2016-04-17 20:43:41 +02:00
$text .= " url=' " . $data [ " url " ] . " ' " ;
2016-11-13 20:09:47 +01:00
}
if ( $data [ " title " ] != " " ) {
2016-04-17 20:43:41 +02:00
$text .= " title=' " . $data [ " title " ] . " ' " ;
2016-11-13 20:09:47 +01:00
}
2016-04-17 20:43:41 +02:00
if ( sizeof ( $data [ " images " ]) > 0 ) {
$preview = str_replace ( array ( " [ " , " ] " ), array ( " [ " , " ] " ), htmlentities ( $data [ " images " ][ 0 ][ " src " ], ENT_QUOTES , 'UTF-8' , false ));
// if the preview picture is larger than 500 pixels then show it in a larger mode
// But only, if the picture isn't higher than large (To prevent huge posts)
2016-11-13 20:09:47 +01:00
if (( $data [ " images " ][ 0 ][ " width " ] >= 500 ) AND ( $data [ " images " ][ 0 ][ " width " ] >= $data [ " images " ][ 0 ][ " height " ])) {
2016-04-17 20:43:41 +02:00
$text .= " image=' " . $preview . " ' " ;
2016-11-13 20:09:47 +01:00
} else {
2016-04-17 20:43:41 +02:00
$text .= " preview=' " . $preview . " ' " ;
2016-11-13 20:09:47 +01:00
}
2014-06-15 23:33:25 +02:00
}
2016-11-13 20:09:47 +01:00
2016-04-17 20:43:41 +02:00
$text .= " ] " . $data [ " text " ] . " [/attachment] " ;
2014-04-04 10:52:53 +02:00
2014-10-03 12:18:33 +02:00
$hashtags = " " ;
2014-10-20 08:03:47 +02:00
if ( isset ( $data [ " keywords " ]) AND count ( $data [ " keywords " ])) {
2014-10-03 13:02:15 +02:00
$hashtags = " \n " ;
foreach ( $data [ " keywords " ] AS $keyword ) {
2016-01-14 21:56:37 +01:00
/// @todo make a positive list of allowed characters
$hashtag = str_replace ( array ( " " , " + " , " / " , " . " , " # " , " ' " , " ’ " , " ` " , " ( " , " ) " , " „ " , " “ " ),
array ( " " , " " , " " , " " , " " , " " , " " , " " , " " , " " , " " , " " ), $keyword );
2016-12-19 14:26:13 +01:00
$hashtags .= " #[url= " . App :: get_baseurl () . " /search?tag= " . rawurlencode ( $hashtag ) . " ] " . $hashtag . " [/url] " ;
2014-10-03 13:02:15 +02:00
}
}
2014-10-03 12:18:33 +02:00
2016-04-17 20:43:41 +02:00
return " \n " . $text . $hashtags ;
2014-04-04 10:52:53 +02:00
}
2015-01-20 22:54:25 +01:00
function query_page_info ( $url , $no_photos = false , $photo = " " , $keywords = false , $keyword_blacklist = " " ) {
2014-10-20 08:03:47 +02:00
2016-11-24 01:11:22 +01:00
$data = ParseUrl :: getSiteinfoCached ( $url , true );
2014-10-20 08:03:47 +02:00
2014-12-17 21:57:38 +01:00
if ( $photo != " " )
$data [ " images " ][ 0 ][ " src " ] = $photo ;
2015-01-20 22:54:25 +01:00
logger ( 'fetch page info for ' . $url . ' ' . print_r ( $data , true ), LOGGER_DEBUG );
2014-10-20 08:03:47 +02:00
if ( ! $keywords AND isset ( $data [ " keywords " ]))
unset ( $data [ " keywords " ]);
2014-10-30 00:24:23 +01:00
if (( $keyword_blacklist != " " ) AND isset ( $data [ " keywords " ])) {
$list = explode ( " , " , $keyword_blacklist );
foreach ( $list AS $keyword ) {
$keyword = trim ( $keyword );
$index = array_search ( $keyword , $data [ " keywords " ]);
if ( $index !== false )
unset ( $data [ " keywords " ][ $index ]);
}
}
2015-01-20 22:54:25 +01:00
return ( $data );
}
function add_page_keywords ( $url , $no_photos = false , $photo = " " , $keywords = false , $keyword_blacklist = " " ) {
$data = query_page_info ( $url , $no_photos , $photo , $keywords , $keyword_blacklist );
$tags = " " ;
if ( isset ( $data [ " keywords " ]) AND count ( $data [ " keywords " ])) {
foreach ( $data [ " keywords " ] AS $keyword ) {
$hashtag = str_replace ( array ( " " , " + " , " / " , " . " , " # " , " ' " ),
array ( " " , " " , " " , " " , " " , " " ), $keyword );
if ( $tags != " " )
$tags .= " , " ;
2016-12-19 14:26:13 +01:00
$tags .= " #[url= " . App :: get_baseurl () . " /search?tag= " . rawurlencode ( $hashtag ) . " ] " . $hashtag . " [/url] " ;
2015-01-20 22:54:25 +01:00
}
}
return ( $tags );
}
function add_page_info ( $url , $no_photos = false , $photo = " " , $keywords = false , $keyword_blacklist = " " ) {
$data = query_page_info ( $url , $no_photos , $photo , $keywords , $keyword_blacklist );
2014-10-20 08:03:47 +02:00
$text = add_page_info_data ( $data );
return ( $text );
}
2014-04-04 10:52:53 +02:00
function add_page_info_to_body ( $body , $texturl = false , $no_photos = false ) {
2014-06-15 23:33:25 +02:00
logger ( 'add_page_info_to_body: fetch page info for body ' . $body , LOGGER_DEBUG );
2014-04-04 10:52:53 +02:00
2014-06-15 23:33:25 +02:00
$URLSearchString = " ^ \ [ \ ] " ;
2014-04-04 10:52:53 +02:00
2016-12-12 07:46:02 +01:00
// Fix for Mastodon where the mentions are in a different format
$body = preg_replace ( " / \ [url \ =([ $URLSearchString ]*) \ ]([#!@])(.*?) \ [ \ /url \ ]/ism " ,
'$2[url=$1]$3[/url]' , $body );
2014-06-15 23:33:25 +02:00
// Adding these spaces is a quick hack due to my problems with regular expressions :)
preg_match ( " /[^!#@] \ [url \ ]([ $URLSearchString ]*) \ [ \ /url \ ]/ism " , " " . $body , $matches );
2014-04-04 10:52:53 +02:00
2014-06-15 23:33:25 +02:00
if ( ! $matches )
preg_match ( " /[^!#@] \ [url \ =([ $URLSearchString ]*) \ ](.*?) \ [ \ /url \ ]/ism " , " " . $body , $matches );
2014-04-04 10:52:53 +02:00
// Convert urls without bbcode elements
if ( ! $matches AND $texturl ) {
preg_match ( " /([^ \ ] \ =' " . '"' . " ]|^)(https? \ : \ / \ /[a-zA-Z0-9 \ : \ / \ - \ ? \ & \ ; \ . \ = \ _ \ ~ \ # \ % \$ \ ! \ + \ ,]+)/ism " , " " . $body , $matches );
2014-01-05 16:10:02 +01:00
2014-04-04 10:52:53 +02:00
// Yeah, a hack. I really hate regular expressions :)
2014-06-15 23:33:25 +02:00
if ( $matches )
$matches [ 1 ] = $matches [ 2 ];
2014-01-05 16:10:02 +01:00
}
2014-06-15 23:33:25 +02:00
if ( $matches )
2014-07-27 16:10:09 +02:00
$footer = add_page_info ( $matches [ 1 ], $no_photos );
// Remove the link from the body if the link is attached at the end of the post
if ( isset ( $footer ) AND ( trim ( $footer ) != " " ) AND ( strpos ( $footer , $matches [ 1 ]))) {
$removedlink = trim ( str_replace ( $matches [ 1 ], " " , $body ));
2014-07-27 21:59:44 +02:00
if (( $removedlink == " " ) OR strstr ( $body , $removedlink ))
2014-07-27 16:10:09 +02:00
$body = $removedlink ;
2014-07-27 21:59:44 +02:00
$url = str_replace ( array ( '/' , '.' ), array ( '\/' , '\.' ), $matches [ 1 ]);
$removedlink = preg_replace ( " / \ [url \ = " . $url . " \ ](.*?) \ [ \ /url \ ]/ism " , '' , $body );
if (( $removedlink == " " ) OR strstr ( $body , $removedlink ))
2014-07-27 16:10:09 +02:00
$body = $removedlink ;
}
// Add the page information to the bottom
if ( isset ( $footer ) AND ( trim ( $footer ) != " " ))
$body .= $footer ;
2014-01-05 16:10:02 +01:00
2014-06-15 23:33:25 +02:00
return $body ;
2014-01-05 16:10:02 +01:00
}
2015-12-25 23:17:34 +01:00
/**
* Adds a " lang " specification in a " postopts " element of given $arr ,
* if possible and not already present .
* Expects " body " element to exist in $arr .
*
* @ todo Add a parameter to request forcing override
*/
2015-09-23 10:47:34 +02:00
function item_add_language_opt ( & $arr ) {
if ( version_compare ( PHP_VERSION , '5.3.0' , '<' )) return ; // LanguageDetect.php not available ?
2015-09-23 11:11:12 +02:00
if ( x ( $arr , 'postopts' ) )
2015-09-23 10:47:34 +02:00
{
if ( strstr ( $arr [ 'postopts' ], 'lang=' ) )
{
// do not override
2015-12-25 23:17:34 +01:00
/// @TODO Add parameter to request overriding
2015-09-23 10:47:34 +02:00
return ;
}
$postopts = $arr [ 'postopts' ];
2016-10-22 12:14:41 +02:00
} else {
2015-09-23 10:47:34 +02:00
$postopts = " " ;
}
require_once ( 'library/langdet/Text/LanguageDetect.php' );
$naked_body = preg_replace ( '/\[(.+?)\]/' , '' , $arr [ 'body' ]);
$l = new Text_LanguageDetect ;
//$lng = $l->detectConfidence($naked_body);
//$arr['postopts'] = (($lng['language']) ? 'lang=' . $lng['language'] . ';' . $lng['confidence'] : '');
$lng = $l -> detect ( $naked_body , 3 );
if ( sizeof ( $lng ) > 0 ) {
2015-09-23 11:39:36 +02:00
if ( $postopts != " " ) $postopts .= '&' ; // arbitrary separator, to be reviewed
2015-09-23 10:47:34 +02:00
$postopts .= 'lang=' ;
$sep = " " ;
foreach ( $lng as $language => $score ) {
$postopts .= $sep . $language . " ; " . $score ;
$sep = ':' ;
}
$arr [ 'postopts' ] = $postopts ;
}
}
2016-02-03 05:00:26 +01:00
/**
* @ brief Creates an unique guid out of a given uri
*
* @ param string $uri uri of an item entry
2016-11-15 08:05:43 +01:00
* @ param string $host ( Optional ) hostname for the GUID prefix
2016-02-03 05:00:26 +01:00
* @ return string unique guid
*/
2016-11-14 07:55:17 +01:00
function uri_to_guid ( $uri , $host = " " ) {
2016-02-03 05:00:26 +01:00
// Our regular guid routine is using this kind of prefix as well
// We have to avoid that different routines could accidentally create the same value
2016-02-02 20:57:19 +01:00
$parsed = parse_url ( $uri );
2016-11-14 07:55:17 +01:00
if ( $host == " " ) {
$host = $parsed [ " host " ];
}
$guid_prefix = hash ( " crc32 " , $host );
2016-02-02 20:57:19 +01:00
2016-02-03 05:00:26 +01:00
// Remove the scheme to make sure that "https" and "http" doesn't make a difference
2016-02-02 20:57:19 +01:00
unset ( $parsed [ " scheme " ]);
$host_id = implode ( " / " , $parsed );
2016-02-03 05:00:26 +01:00
// We could use any hash algorithm since it isn't a security issue
2016-02-02 20:57:19 +01:00
$host_hash = hash ( " ripemd128 " , $host_id );
return $guid_prefix . $host_hash ;
}
2014-12-21 21:19:37 +01:00
function item_store ( $arr , $force_parent = false , $notify = false , $dontcache = false ) {
2010-07-19 05:49:10 +02:00
2016-11-14 07:55:17 +01:00
$a = get_app ();
2014-09-01 14:40:29 +02:00
// If it is a posting where users should get notifications, then define it as wall posting
if ( $notify ) {
$arr [ 'wall' ] = 1 ;
$arr [ 'type' ] = 'wall' ;
2014-09-01 15:28:31 +02:00
$arr [ 'origin' ] = 1 ;
$arr [ 'last-child' ] = 1 ;
2014-09-01 14:40:29 +02:00
$arr [ 'network' ] = NETWORK_DFRN ;
2016-11-14 07:55:17 +01:00
// We have to avoid duplicates. So we create the GUID in form of a hash of the plink or uri.
// In difference to the call to "uri_to_guid" several lines below we add the hash of our own host.
// This is done because our host is the original creator of the post.
if ( isset ( $arr [ 'plink' ])) {
$arr [ 'guid' ] = uri_to_guid ( $arr [ 'plink' ], $a -> get_hostname ());
} elseif ( isset ( $arr [ 'uri' ])) {
$arr [ 'guid' ] = uri_to_guid ( $arr [ 'uri' ], $a -> get_hostname ());
}
2014-09-01 14:40:29 +02:00
}
2014-03-09 09:19:14 +01:00
// If a Diaspora signature structure was passed in, pull it out of the
2011-08-29 04:22:27 +02:00
// item array and set it aside for later storage.
$dsprsig = null ;
2016-10-22 12:14:41 +02:00
if ( x ( $arr , 'dsprsig' )) {
2016-12-01 14:50:26 +01:00
$encoded_signature = $arr [ 'dsprsig' ];
2011-08-29 04:22:27 +02:00
$dsprsig = json_decode ( base64_decode ( $arr [ 'dsprsig' ]));
unset ( $arr [ 'dsprsig' ]);
}
2015-05-26 23:33:38 +02:00
// Converting the plink
if ( $arr [ 'network' ] == NETWORK_OSTATUS ) {
if ( isset ( $arr [ 'plink' ]))
2016-03-30 12:43:15 +02:00
$arr [ 'plink' ] = ostatus :: convert_href ( $arr [ 'plink' ]);
2015-05-26 23:33:38 +02:00
elseif ( isset ( $arr [ 'uri' ]))
2016-03-30 12:43:15 +02:00
$arr [ 'plink' ] = ostatus :: convert_href ( $arr [ 'uri' ]);
2015-05-26 23:33:38 +02:00
}
2016-10-22 12:14:41 +02:00
if ( x ( $arr , 'gravity' ))
2010-09-10 09:42:53 +02:00
$arr [ 'gravity' ] = intval ( $arr [ 'gravity' ]);
2016-10-22 12:14:41 +02:00
elseif ( $arr [ 'parent-uri' ] === $arr [ 'uri' ])
2010-09-10 07:02:28 +02:00
$arr [ 'gravity' ] = 0 ;
2016-10-22 12:14:41 +02:00
elseif ( activity_match ( $arr [ 'verb' ], ACTIVITY_POST ))
2010-09-10 07:02:28 +02:00
$arr [ 'gravity' ] = 6 ;
2013-01-17 23:20:40 +01:00
else
2010-11-10 05:38:24 +01:00
$arr [ 'gravity' ] = 6 ; // extensible catchall
2010-09-10 07:02:28 +02:00
2016-10-22 12:14:41 +02:00
if ( ! x ( $arr , 'type' ))
2010-11-10 05:38:24 +01:00
$arr [ 'type' ] = 'remote' ;
2011-02-02 03:20:25 +01:00
2014-05-12 15:33:20 +02:00
2014-05-12 19:02:03 +02:00
2014-05-12 15:33:20 +02:00
/* check for create date and expire time */
$uid = intval ( $arr [ 'uid' ]);
2015-05-26 23:33:38 +02:00
$r = q ( " SELECT expire FROM user WHERE uid = %d " , intval ( $uid ));
2016-12-14 09:42:36 +01:00
if ( dbm :: is_result ( $r )) {
2014-05-12 15:33:20 +02:00
$expire_interval = $r [ 0 ][ 'expire' ];
2014-05-12 19:02:03 +02:00
if ( $expire_interval > 0 ) {
$expire_date = new DateTime ( '- ' . $expire_interval . ' days' , new DateTimeZone ( 'UTC' ));
$created_date = new DateTime ( $arr [ 'created' ], new DateTimeZone ( 'UTC' ));
if ( $created_date < $expire_date ) {
logger ( 'item-store: item created (' . $arr [ 'created' ] . ') before expiration time (' . $expire_date -> format ( DateTime :: W3C ) . '). ignored. ' . print_r ( $arr , true ), LOGGER_DEBUG );
return 0 ;
}
2014-05-12 15:33:20 +02:00
}
}
2015-11-30 23:13:56 +01:00
// Do we already have this item?
// We have to check several networks since Friendica posts could be repeated via OStatus (maybe Diasporsa as well)
if ( in_array ( trim ( $arr [ 'network' ]), array ( NETWORK_DIASPORA , NETWORK_DFRN , NETWORK_OSTATUS , " " ))) {
$r = q ( " SELECT `id`, `network` FROM `item` WHERE `uri` = '%s' AND `uid` = %d AND `network` IN ('%s', '%s', '%s') LIMIT 1 " ,
dbesc ( trim ( $arr [ 'uri' ])),
intval ( $uid ),
dbesc ( NETWORK_DIASPORA ),
dbesc ( NETWORK_DFRN ),
dbesc ( NETWORK_OSTATUS )
);
if ( $r ) {
// We only log the entries with a different user id than 0. Otherwise we would have too many false positives
if ( $uid != 0 )
logger ( " Item with uri " . $arr [ 'uri' ] . " already existed for user " . $uid . " with id " . $r [ 0 ][ " id " ] . " target network " . $r [ 0 ][ " network " ] . " - new network: " . $arr [ 'network' ]);
return ( $r [ 0 ][ " id " ]);
}
}
2011-02-02 03:20:25 +01:00
// Shouldn't happen but we want to make absolutely sure it doesn't leak from a plugin.
2014-05-18 18:59:10 +02:00
// Deactivated, since the bbcode parser can handle with it - and it destroys posts with some smileys that contain "<"
2016-10-22 12:14:41 +02:00
//if ((strpos($arr['body'],'<') !== false) || (strpos($arr['body'],'>') !== false))
2014-05-18 18:59:10 +02:00
// $arr['body'] = strip_tags($arr['body']);
2011-02-02 03:20:25 +01:00
2015-09-23 10:47:34 +02:00
item_add_language_opt ( $arr );
2012-07-12 07:45:14 +02:00
2015-09-07 23:33:02 +02:00
if ( $notify )
$guid_prefix = " " ;
2016-02-02 20:57:19 +01:00
elseif (( trim ( $arr [ 'guid' ]) == " " ) AND ( trim ( $arr [ 'plink' ]) != " " ))
$arr [ 'guid' ] = uri_to_guid ( $arr [ 'plink' ]);
elseif (( trim ( $arr [ 'guid' ]) == " " ) AND ( trim ( $arr [ 'uri' ]) != " " ))
$arr [ 'guid' ] = uri_to_guid ( $arr [ 'uri' ]);
2015-12-03 14:38:04 +01:00
else {
$parsed = parse_url ( $arr [ " author-link " ]);
$guid_prefix = hash ( " crc32 " , $parsed [ " host " ]);
}
2011-02-02 03:20:25 +01:00
2010-11-10 05:38:24 +01:00
$arr [ 'wall' ] = (( x ( $arr , 'wall' )) ? intval ( $arr [ 'wall' ]) : 0 );
2015-09-07 23:33:02 +02:00
$arr [ 'guid' ] = (( x ( $arr , 'guid' )) ? notags ( trim ( $arr [ 'guid' ])) : get_guid ( 32 , $guid_prefix ));
2016-11-14 07:55:17 +01:00
$arr [ 'uri' ] = (( x ( $arr , 'uri' )) ? notags ( trim ( $arr [ 'uri' ])) : item_new_uri ( $a -> get_hostname (), $uid , $arr [ 'guid' ]));
2011-05-23 03:40:00 +02:00
$arr [ 'extid' ] = (( x ( $arr , 'extid' )) ? notags ( trim ( $arr [ 'extid' ])) : '' );
2015-10-09 07:39:38 +02:00
$arr [ 'author-name' ] = (( x ( $arr , 'author-name' )) ? trim ( $arr [ 'author-name' ]) : '' );
2010-11-10 05:38:24 +01:00
$arr [ 'author-link' ] = (( x ( $arr , 'author-link' )) ? notags ( trim ( $arr [ 'author-link' ])) : '' );
$arr [ 'author-avatar' ] = (( x ( $arr , 'author-avatar' )) ? notags ( trim ( $arr [ 'author-avatar' ])) : '' );
2015-10-09 07:39:38 +02:00
$arr [ 'owner-name' ] = (( x ( $arr , 'owner-name' )) ? trim ( $arr [ 'owner-name' ]) : '' );
2010-11-10 05:38:24 +01:00
$arr [ 'owner-link' ] = (( x ( $arr , 'owner-link' )) ? notags ( trim ( $arr [ 'owner-link' ])) : '' );
$arr [ 'owner-avatar' ] = (( x ( $arr , 'owner-avatar' )) ? notags ( trim ( $arr [ 'owner-avatar' ])) : '' );
$arr [ 'created' ] = (( x ( $arr , 'created' ) !== false ) ? datetime_convert ( 'UTC' , 'UTC' , $arr [ 'created' ]) : datetime_convert ());
$arr [ 'edited' ] = (( x ( $arr , 'edited' ) !== false ) ? datetime_convert ( 'UTC' , 'UTC' , $arr [ 'edited' ]) : datetime_convert ());
2015-04-05 20:43:06 +02:00
$arr [ 'commented' ] = (( x ( $arr , 'commented' ) !== false ) ? datetime_convert ( 'UTC' , 'UTC' , $arr [ 'commented' ]) : datetime_convert ());
$arr [ 'received' ] = (( x ( $arr , 'received' ) !== false ) ? datetime_convert ( 'UTC' , 'UTC' , $arr [ 'received' ]) : datetime_convert ());
$arr [ 'changed' ] = (( x ( $arr , 'changed' ) !== false ) ? datetime_convert ( 'UTC' , 'UTC' , $arr [ 'changed' ]) : datetime_convert ());
2015-10-09 07:39:38 +02:00
$arr [ 'title' ] = (( x ( $arr , 'title' )) ? trim ( $arr [ 'title' ]) : '' );
$arr [ 'location' ] = (( x ( $arr , 'location' )) ? trim ( $arr [ 'location' ]) : '' );
2010-11-10 05:38:24 +01:00
$arr [ 'coord' ] = (( x ( $arr , 'coord' )) ? notags ( trim ( $arr [ 'coord' ])) : '' );
$arr [ 'last-child' ] = (( x ( $arr , 'last-child' )) ? intval ( $arr [ 'last-child' ]) : 0 );
$arr [ 'visible' ] = (( x ( $arr , 'visible' ) !== false ) ? intval ( $arr [ 'visible' ]) : 1 );
$arr [ 'deleted' ] = 0 ;
2016-11-14 07:55:17 +01:00
$arr [ 'parent-uri' ] = (( x ( $arr , 'parent-uri' )) ? notags ( trim ( $arr [ 'parent-uri' ])) : $arr [ 'uri' ]);
2010-11-10 05:38:24 +01:00
$arr [ 'verb' ] = (( x ( $arr , 'verb' )) ? notags ( trim ( $arr [ 'verb' ])) : '' );
$arr [ 'object-type' ] = (( x ( $arr , 'object-type' )) ? notags ( trim ( $arr [ 'object-type' ])) : '' );
$arr [ 'object' ] = (( x ( $arr , 'object' )) ? trim ( $arr [ 'object' ]) : '' );
$arr [ 'target-type' ] = (( x ( $arr , 'target-type' )) ? notags ( trim ( $arr [ 'target-type' ])) : '' );
$arr [ 'target' ] = (( x ( $arr , 'target' )) ? trim ( $arr [ 'target' ]) : '' );
2011-02-16 11:07:11 +01:00
$arr [ 'plink' ] = (( x ( $arr , 'plink' )) ? notags ( trim ( $arr [ 'plink' ])) : '' );
2010-11-12 05:32:20 +01:00
$arr [ 'allow_cid' ] = (( x ( $arr , 'allow_cid' )) ? trim ( $arr [ 'allow_cid' ]) : '' );
$arr [ 'allow_gid' ] = (( x ( $arr , 'allow_gid' )) ? trim ( $arr [ 'allow_gid' ]) : '' );
$arr [ 'deny_cid' ] = (( x ( $arr , 'deny_cid' )) ? trim ( $arr [ 'deny_cid' ]) : '' );
$arr [ 'deny_gid' ] = (( x ( $arr , 'deny_gid' )) ? trim ( $arr [ 'deny_gid' ]) : '' );
2010-12-08 05:47:53 +01:00
$arr [ 'private' ] = (( x ( $arr , 'private' )) ? intval ( $arr [ 'private' ]) : 0 );
2011-09-05 04:58:03 +02:00
$arr [ 'bookmark' ] = (( x ( $arr , 'bookmark' )) ? intval ( $arr [ 'bookmark' ]) : 0 );
2011-02-02 03:20:25 +01:00
$arr [ 'body' ] = (( x ( $arr , 'body' )) ? trim ( $arr [ 'body' ]) : '' );
2011-04-06 02:41:02 +02:00
$arr [ 'tag' ] = (( x ( $arr , 'tag' )) ? notags ( trim ( $arr [ 'tag' ])) : '' );
2011-04-07 06:59:07 +02:00
$arr [ 'attach' ] = (( x ( $arr , 'attach' )) ? notags ( trim ( $arr [ 'attach' ])) : '' );
2011-06-21 04:08:40 +02:00
$arr [ 'app' ] = (( x ( $arr , 'app' )) ? notags ( trim ( $arr [ 'app' ])) : '' );
2011-10-17 23:52:03 +02:00
$arr [ 'origin' ] = (( x ( $arr , 'origin' )) ? intval ( $arr [ 'origin' ]) : 0 );
2013-11-02 10:49:44 +01:00
$arr [ 'network' ] = (( x ( $arr , 'network' )) ? trim ( $arr [ 'network' ]) : '' );
2014-11-09 01:13:07 +01:00
$arr [ 'postopts' ] = (( x ( $arr , 'postopts' )) ? trim ( $arr [ 'postopts' ]) : '' );
$arr [ 'resource-id' ] = (( x ( $arr , 'resource-id' )) ? trim ( $arr [ 'resource-id' ]) : '' );
$arr [ 'event-id' ] = (( x ( $arr , 'event-id' )) ? intval ( $arr [ 'event-id' ]) : 0 );
$arr [ 'inform' ] = (( x ( $arr , 'inform' )) ? trim ( $arr [ 'inform' ]) : '' );
$arr [ 'file' ] = (( x ( $arr , 'file' )) ? trim ( $arr [ 'file' ]) : '' );
2010-11-12 05:32:20 +01:00
2016-06-13 22:21:33 +02:00
// Items cannot be stored before they happen ...
if ( $arr [ 'created' ] > datetime_convert ())
$arr [ 'created' ] = datetime_convert ();
// We haven't invented time travel by now.
if ( $arr [ 'edited' ] > datetime_convert ())
$arr [ 'edited' ] = datetime_convert ();
2016-02-09 06:42:00 +01:00
2016-02-13 12:26:58 +01:00
if (( $arr [ 'author-link' ] == " " ) AND ( $arr [ 'owner-link' ] == " " ))
logger ( " Both author-link and owner-link are empty. Called by: " . App :: callstack (), LOGGER_DEBUG );
2016-02-09 06:42:00 +01:00
2014-07-22 00:36:20 +02:00
if ( $arr [ 'plink' ] == " " ) {
2016-12-19 14:26:13 +01:00
$arr [ 'plink' ] = App :: get_baseurl () . '/display/' . urlencode ( $arr [ 'guid' ]);
2014-07-22 00:36:20 +02:00
}
2013-11-02 10:49:44 +01:00
if ( $arr [ 'network' ] == " " ) {
2015-10-08 00:25:55 +02:00
$r = q ( " SELECT `network` FROM `contact` WHERE `network` IN ('%s', '%s', '%s') AND `nurl` = '%s' AND `uid` = %d LIMIT 1 " ,
dbesc ( NETWORK_DFRN ), dbesc ( NETWORK_DIASPORA ), dbesc ( NETWORK_OSTATUS ),
dbesc ( normalise_link ( $arr [ 'author-link' ])),
2013-11-02 10:49:44 +01:00
intval ( $arr [ 'uid' ])
);
2016-12-13 10:44:13 +01:00
if ( ! dbm :: is_result ( $r ))
2015-10-08 00:25:55 +02:00
$r = q ( " SELECT `network` FROM `gcontact` WHERE `network` IN ('%s', '%s', '%s') AND `nurl` = '%s' LIMIT 1 " ,
dbesc ( NETWORK_DFRN ), dbesc ( NETWORK_DIASPORA ), dbesc ( NETWORK_OSTATUS ),
dbesc ( normalise_link ( $arr [ 'author-link' ]))
);
2016-12-13 10:44:13 +01:00
if ( ! dbm :: is_result ( $r ))
2015-10-08 00:25:55 +02:00
$r = q ( " SELECT `network` FROM `contact` WHERE `id` = %d AND `uid` = %d LIMIT 1 " ,
intval ( $arr [ 'contact-id' ]),
intval ( $arr [ 'uid' ])
);
2016-12-14 09:42:36 +01:00
if ( dbm :: is_result ( $r ))
2013-11-02 10:49:44 +01:00
$arr [ 'network' ] = $r [ 0 ][ " network " ];
// Fallback to friendica (why is it empty in some cases?)
if ( $arr [ 'network' ] == " " )
$arr [ 'network' ] = NETWORK_DFRN ;
logger ( " item_store: Set network to " . $arr [ " network " ] . " for " . $arr [ " uri " ], LOGGER_DEBUG );
}
2012-08-05 13:30:51 +02:00
2016-01-23 12:39:37 +01:00
// The contact-id should be set before "item_store" was called - but there seems to be some issues
if ( $arr [ " contact-id " ] == 0 ) {
// First we are looking for a suitable contact that matches with the author of the post
2016-01-28 18:06:17 +01:00
// This is done only for comments (See below explanation at "gcontact-id")
2016-10-22 12:14:41 +02:00
if ( $arr [ 'parent-uri' ] != $arr [ 'uri' ])
2016-01-28 18:06:17 +01:00
$arr [ " contact-id " ] = get_contact ( $arr [ 'author-link' ], $uid );
2016-01-23 12:39:37 +01:00
// If not present then maybe the owner was found
if ( $arr [ " contact-id " ] == 0 )
$arr [ " contact-id " ] = get_contact ( $arr [ 'owner-link' ], $uid );
// Still missing? Then use the "self" contact of the current user
if ( $arr [ " contact-id " ] == 0 ) {
$r = q ( " SELECT `id` FROM `contact` WHERE `self` AND `uid` = %d " , intval ( $uid ));
if ( $r )
$arr [ " contact-id " ] = $r [ 0 ][ " id " ];
}
2016-01-28 18:06:17 +01:00
logger ( " Contact-id was missing for post " . $arr [ " guid " ] . " from user id " . $uid . " - now set to " . $arr [ " contact-id " ], LOGGER_DEBUG );
2016-01-23 12:39:37 +01:00
}
2016-01-28 18:06:17 +01:00
if ( $arr [ " gcontact-id " ] == 0 ) {
// The gcontact should mostly behave like the contact. But is is supposed to be global for the system.
// This means that wall posts, repeated posts, etc. should have the gcontact id of the owner.
// On comments the author is the better choice.
2016-10-22 12:14:41 +02:00
if ( $arr [ 'parent-uri' ] === $arr [ 'uri' ])
2016-01-28 18:06:17 +01:00
$arr [ " gcontact-id " ] = get_gcontact_id ( array ( " url " => $arr [ 'owner-link' ], " network " => $arr [ 'network' ],
" photo " => $arr [ 'owner-avatar' ], " name " => $arr [ 'owner-name' ]));
else
$arr [ " gcontact-id " ] = get_gcontact_id ( array ( " url " => $arr [ 'author-link' ], " network " => $arr [ 'network' ],
" photo " => $arr [ 'author-avatar' ], " name " => $arr [ 'author-name' ]));
}
2016-01-05 15:34:27 +01:00
2016-06-15 21:20:55 +02:00
if ( $arr [ " author-id " ] == 0 )
$arr [ " author-id " ] = get_contact ( $arr [ " author-link " ], 0 );
if ( $arr [ " owner-id " ] == 0 )
$arr [ " owner-id " ] = get_contact ( $arr [ " owner-link " ], 0 );
2015-05-10 20:43:41 +02:00
if ( $arr [ 'guid' ] != " " ) {
// Checking if there is already an item with the same guid
logger ( 'checking for an item for user ' . $arr [ 'uid' ] . ' on network ' . $arr [ 'network' ] . ' with the guid ' . $arr [ 'guid' ], LOGGER_DEBUG );
$r = q ( " SELECT `guid` FROM `item` WHERE `guid` = '%s' AND `network` = '%s' AND `uid` = '%d' LIMIT 1 " ,
dbesc ( $arr [ 'guid' ]), dbesc ( $arr [ 'network' ]), intval ( $arr [ 'uid' ]));
2016-12-14 09:42:36 +01:00
if ( dbm :: is_result ( $r )) {
2015-05-10 20:43:41 +02:00
logger ( 'found item with guid ' . $arr [ 'guid' ] . ' for user ' . $arr [ 'uid' ] . ' on network ' . $arr [ 'network' ], LOGGER_DEBUG );
return 0 ;
}
}
2015-03-01 17:33:55 +01:00
// Check for hashtags in the body and repair or add hashtag links
item_body_set_hashtags ( $arr );
2012-08-05 13:30:51 +02:00
$arr [ 'thr-parent' ] = $arr [ 'parent-uri' ];
2016-10-22 12:14:41 +02:00
if ( $arr [ 'parent-uri' ] === $arr [ 'uri' ]) {
2010-11-12 05:32:20 +01:00
$parent_id = 0 ;
2012-02-28 13:56:16 +01:00
$parent_deleted = 0 ;
2010-11-12 05:32:20 +01:00
$allow_cid = $arr [ 'allow_cid' ];
$allow_gid = $arr [ 'allow_gid' ];
$deny_cid = $arr [ 'deny_cid' ];
$deny_gid = $arr [ 'deny_gid' ];
2014-08-31 23:52:25 +02:00
$notify_type = 'wall-new' ;
2016-10-22 12:14:41 +02:00
} else {
2010-11-12 05:32:20 +01:00
2013-01-27 23:25:04 +01:00
// find the parent and snarf the item id and ACLs
2011-03-08 23:40:33 +01:00
// and anything else we need to inherit
2010-11-12 05:32:20 +01:00
2011-10-12 11:21:18 +02:00
$r = q ( " SELECT * FROM `item` WHERE `uri` = '%s' AND `uid` = %d ORDER BY `id` ASC LIMIT 1 " ,
2010-11-12 05:32:20 +01:00
dbesc ( $arr [ 'parent-uri' ]),
intval ( $arr [ 'uid' ])
);
2016-12-14 09:42:36 +01:00
if ( dbm :: is_result ( $r )) {
2010-12-05 08:16:16 +01:00
// is the new message multi-level threaded?
// even though we don't support it now, preserve the info
// and re-attach to the conversation parent.
2016-10-22 12:14:41 +02:00
if ( $r [ 0 ][ 'uri' ] != $r [ 0 ][ 'parent-uri' ]) {
2010-12-05 08:16:16 +01:00
$arr [ 'parent-uri' ] = $r [ 0 ][ 'parent-uri' ];
2014-03-09 09:19:14 +01:00
$z = q ( " SELECT * FROM `item` WHERE `uri` = '%s' AND `parent-uri` = '%s' AND `uid` = %d
2011-10-12 11:21:18 +02:00
ORDER BY `id` ASC LIMIT 1 " ,
2011-08-09 04:10:36 +02:00
dbesc ( $r [ 0 ][ 'parent-uri' ]),
dbesc ( $r [ 0 ][ 'parent-uri' ]),
intval ( $arr [ 'uid' ])
);
2016-10-22 12:14:41 +02:00
if ( $z && count ( $z ))
2011-08-09 04:10:36 +02:00
$r = $z ;
2010-12-05 08:16:16 +01:00
}
2011-02-04 13:25:53 +01:00
$parent_id = $r [ 0 ][ 'id' ];
$parent_deleted = $r [ 0 ][ 'deleted' ];
$allow_cid = $r [ 0 ][ 'allow_cid' ];
$allow_gid = $r [ 0 ][ 'allow_gid' ];
$deny_cid = $r [ 0 ][ 'deny_cid' ];
$deny_gid = $r [ 0 ][ 'deny_gid' ];
2011-03-08 23:40:33 +01:00
$arr [ 'wall' ] = $r [ 0 ][ 'wall' ];
2014-08-31 23:52:25 +02:00
$notify_type = 'comment-new' ;
2012-06-11 14:28:08 +02:00
// if the parent is private, force privacy for the entire conversation
2014-03-09 09:19:14 +01:00
// This differs from the above settings as it subtly allows comments from
// email correspondents to be private even if the overall thread is not.
2012-06-11 14:28:08 +02:00
2016-10-22 12:14:41 +02:00
if ( $r [ 0 ][ 'private' ])
2012-06-29 02:43:29 +02:00
$arr [ 'private' ] = $r [ 0 ][ 'private' ];
2012-06-11 14:28:08 +02:00
2012-06-19 02:19:56 +02:00
// Edge case. We host a public forum that was originally posted to privately.
// The original author commented, but as this is a comment, the permissions
2014-03-09 09:19:14 +01:00
// weren't fixed up so it will still show the comment as private unless we fix it here.
2012-06-19 02:19:56 +02:00
2016-10-22 12:14:41 +02:00
if (( intval ( $r [ 0 ][ 'forum_mode' ]) == 1 ) && ( ! $r [ 0 ][ 'private' ]))
2012-06-19 02:19:56 +02:00
$arr [ 'private' ] = 0 ;
2014-03-09 09:19:14 +01:00
// If its a post from myself then tag the thread as "mention"
logger ( " item_store: Checking if parent " . $parent_id . " has to be tagged as mention for user " . $arr [ 'uid' ], LOGGER_DEBUG );
2016-10-07 08:05:43 +02:00
$u = q ( " SELECT `nickname` FROM `user` WHERE `uid` = %d " , intval ( $arr [ 'uid' ]));
2016-12-20 15:37:27 +01:00
if ( dbm :: is_result ( $u )) {
2014-03-09 09:19:14 +01:00
$a = get_app ();
2016-12-19 14:26:13 +01:00
$self = normalise_link ( App :: get_baseurl () . '/profile/' . $u [ 0 ][ 'nickname' ]);
2014-03-09 09:19:14 +01:00
logger ( " item_store: 'myself' is " . $self . " for parent " . $parent_id . " checking against " . $arr [ 'author-link' ] . " and " . $arr [ 'owner-link' ], LOGGER_DEBUG );
if (( normalise_link ( $arr [ 'author-link' ]) == $self ) OR ( normalise_link ( $arr [ 'owner-link' ]) == $self )) {
q ( " UPDATE `thread` SET `mention` = 1 WHERE `iid` = %d " , intval ( $parent_id ));
logger ( " item_store: tagged thread " . $parent_id . " as mention for user " . $self , LOGGER_DEBUG );
}
}
2016-10-07 08:05:43 +02:00
} else {
2011-02-04 02:40:04 +01:00
// Allow one to see reply tweets from status.net even when
// we don't have or can't see the original post.
2016-10-22 12:14:41 +02:00
if ( $force_parent ) {
2011-02-04 02:40:04 +01:00
logger ( 'item_store: $force_parent=true, reply converted to top-level post.' );
$parent_id = 0 ;
$arr [ 'parent-uri' ] = $arr [ 'uri' ];
2011-05-04 11:20:44 +02:00
$arr [ 'gravity' ] = 0 ;
2016-10-22 12:14:41 +02:00
} else {
2015-06-07 23:18:02 +02:00
logger ( 'item_store: item parent ' . $arr [ 'parent-uri' ] . ' for ' . $arr [ 'uid' ] . ' was not found - ignoring item' );
2011-02-04 02:40:04 +01:00
return 0 ;
}
2013-01-11 01:20:16 +01:00
2012-02-27 23:08:00 +01:00
$parent_deleted = 0 ;
2010-11-12 05:32:20 +01:00
}
}
2010-07-19 05:49:10 +02:00
2015-11-30 23:13:56 +01:00
$r = q ( " SELECT `id` FROM `item` WHERE `uri` = '%s' AND `network` IN ('%s', '%s') AND `uid` = %d LIMIT 1 " ,
2011-10-03 15:04:17 +02:00
dbesc ( $arr [ 'uri' ]),
2015-05-27 08:16:05 +02:00
dbesc ( $arr [ 'network' ]),
2015-11-30 23:13:56 +01:00
dbesc ( NETWORK_DFRN ),
2011-10-12 11:21:18 +02:00
intval ( $arr [ 'uid' ])
2011-10-03 15:04:17 +02:00
);
2016-10-17 20:38:51 +02:00
if ( dbm :: is_result ( $r )) {
logger ( 'duplicated item with the same uri found. ' . print_r ( $arr , true ));
2011-10-03 15:04:17 +02:00
return 0 ;
2015-05-27 08:16:05 +02:00
}
2016-10-17 20:38:51 +02:00
// On Friendica and Diaspora the GUID is unique
if ( in_array ( $arr [ 'network' ], array ( NETWORK_DFRN , NETWORK_DIASPORA ))) {
$r = q ( " SELECT `id` FROM `item` WHERE `guid` = '%s' AND `uid` = %d LIMIT 1 " ,
dbesc ( $arr [ 'guid' ]),
intval ( $arr [ 'uid' ])
);
if ( dbm :: is_result ( $r )) {
logger ( 'duplicated item with the same guid found. ' . print_r ( $arr , true ));
return 0 ;
}
} else {
// Check for an existing post with the same content. There seems to be a problem with OStatus.
$r = q ( " SELECT `id` FROM `item` WHERE `body` = '%s' AND `network` = '%s' AND `created` = '%s' AND `contact-id` = %d AND `uid` = %d LIMIT 1 " ,
dbesc ( $arr [ 'body' ]),
dbesc ( $arr [ 'network' ]),
dbesc ( $arr [ 'created' ]),
intval ( $arr [ 'contact-id' ]),
intval ( $arr [ 'uid' ])
);
if ( dbm :: is_result ( $r )) {
logger ( 'duplicated item with the same body found. ' . print_r ( $arr , true ));
return 0 ;
}
2011-10-03 15:04:17 +02:00
}
2011-08-08 02:29:26 +02:00
2015-03-09 00:45:53 +01:00
// Is this item available in the global items (with uid=0)?
if ( $arr [ " uid " ] == 0 ) {
$arr [ " global " ] = true ;
2016-10-29 22:17:33 +02:00
// Set the global flag on all items if this was a global item entry
2016-04-03 16:36:05 +02:00
q ( " UPDATE `item` SET `global` = 1 WHERE `uri` = '%s' " , dbesc ( $arr [ " uri " ]));
2016-10-22 12:14:41 +02:00
} else {
2016-04-03 16:36:05 +02:00
$isglobal = q ( " SELECT `global` FROM `item` WHERE `uid` = 0 AND `uri` = '%s' " , dbesc ( $arr [ " uri " ]));
2015-03-09 00:45:53 +01:00
$arr [ " global " ] = ( count ( $isglobal ) > 0 );
}
2016-10-07 08:05:43 +02:00
// ACL settings
2016-10-22 12:14:41 +02:00
if ( strlen ( $allow_cid ) || strlen ( $allow_gid ) || strlen ( $deny_cid ) || strlen ( $deny_gid ))
2016-10-07 08:05:43 +02:00
$private = 1 ;
else
$private = $arr [ 'private' ];
$arr [ " allow_cid " ] = $allow_cid ;
$arr [ " allow_gid " ] = $allow_gid ;
$arr [ " deny_cid " ] = $deny_cid ;
$arr [ " deny_gid " ] = $deny_gid ;
$arr [ " private " ] = $private ;
$arr [ " deleted " ] = $parent_deleted ;
2015-03-07 21:24:39 +01:00
// Fill the cache field
put_item_in_cache ( $arr );
2015-09-07 23:14:18 +02:00
if ( $notify )
call_hooks ( 'post_local' , $arr );
else
call_hooks ( 'post_remote' , $arr );
2010-12-22 23:16:22 +01:00
2016-10-22 12:14:41 +02:00
if ( x ( $arr , 'cancel' )) {
2012-01-31 05:49:54 +01:00
logger ( 'item_store: post cancelled by plugin.' );
return 0 ;
}
2016-10-29 22:17:33 +02:00
// Check for already added items.
// There is a timing issue here that sometimes creates double postings.
// An unique index would help - but the limitations of MySQL (maximum size of index values) prevent this.
if ( $arr [ " uid " ] == 0 ) {
$r = qu ( " SELECT `id` FROM `item` WHERE `uri` = '%s' AND `uid` = 0 LIMIT 1 " , dbesc ( trim ( $arr [ 'uri' ])));
if ( dbm :: is_result ( $r )) {
logger ( 'Global item already stored. URI: ' . $arr [ 'uri' ] . ' on network ' . $arr [ 'network' ], LOGGER_DEBUG );
return 0 ;
}
}
2015-01-25 00:19:59 +01:00
// Store the unescaped version
$unescaped = $arr ;
2010-07-19 05:49:10 +02:00
dbesc_array ( $arr );
2010-08-20 23:33:15 +02:00
2010-11-04 03:47:07 +01:00
logger ( 'item_store: ' . print_r ( $arr , true ), LOGGER_DATA );
2016-10-24 10:10:27 +02:00
q ( " COMMIT " );
2016-10-21 20:25:21 +02:00
q ( " START TRANSACTION; " );
2014-01-05 16:10:02 +01:00
$r = dbq ( " INSERT INTO `item` (` "
. implode ( " `, ` " , array_keys ( $arr ))
. " `) VALUES (' "
. implode ( " ', ' " , array_values ( $arr ))
2016-10-29 22:17:33 +02:00
. " ') " );
2010-07-19 05:49:10 +02:00
2015-01-25 00:19:59 +01:00
// And restore it
$arr = $unescaped ;
2010-07-19 05:49:10 +02:00
2016-10-29 22:17:33 +02:00
// When the item was successfully stored we fetch the ID of the item.
if ( dbm :: is_result ( $r )) {
$r = q ( " SELECT LAST_INSERT_ID() AS `item-id` " );
if ( dbm :: is_result ( $r )) {
$current_post = $r [ 0 ][ 'item-id' ];
} else {
// This shouldn't happen
$current_post = 0 ;
}
} else {
// This can happen - for example - if there are locking timeouts.
2016-12-01 14:50:26 +01:00
q ( " ROLLBACK " );
// Store the data into a spool file so that we can try again later.
// At first we restore the Diaspora signature that we removed above.
2016-12-01 23:52:35 +01:00
if ( isset ( $encoded_signature )) {
2016-12-01 14:50:26 +01:00
$arr [ 'dsprsig' ] = $encoded_signature ;
2016-12-01 23:52:35 +01:00
}
2016-12-01 14:50:26 +01:00
// Now we store the data in the spool directory
2016-12-01 21:53:18 +01:00
$file = 'item-' . round ( microtime ( true ) * 10000 ) . " .msg " ;
$spool = get_spoolpath () . '/' . $file ;
2016-12-01 14:50:26 +01:00
file_put_contents ( $spool , json_encode ( $arr ));
2016-12-01 21:53:18 +01:00
logger ( " Item wasn't stored - Item was spooled into file " . $file , LOGGER_DEBUG );
2016-10-29 22:17:33 +02:00
return 0 ;
}
if ( $current_post == 0 ) {
// This is one of these error messages that never should occur.
logger ( " couldn't find created item - we better quit now. " );
2016-12-01 14:50:26 +01:00
q ( " ROLLBACK " );
2016-10-29 22:17:33 +02:00
return 0 ;
}
// How much entries have we created?
// We wouldn't need this query when we could use an unique index - but MySQL has length problems with them.
$r = q ( " SELECT COUNT(*) AS `entries` FROM `item` WHERE `uri` = '%s' AND `uid` = %d AND `network` = '%s' " ,
2015-01-25 00:19:59 +01:00
dbesc ( $arr [ 'uri' ]),
2015-10-10 14:26:07 +02:00
intval ( $arr [ 'uid' ]),
dbesc ( $arr [ 'network' ])
2010-07-19 05:49:10 +02:00
);
2011-05-30 07:50:36 +02:00
2016-10-29 22:17:33 +02:00
if ( ! dbm :: is_result ( $r )) {
// This shouldn't happen, since COUNT always works when the database connection is there.
logger ( " We couldn't count the stored entries. Very strange ... " );
2016-12-01 14:50:26 +01:00
q ( " ROLLBACK " );
2015-11-30 23:13:56 +01:00
return 0 ;
2016-10-29 22:17:33 +02:00
}
2015-06-02 22:07:39 +02:00
2016-10-29 22:17:33 +02:00
if ( $r [ 0 ][ " entries " ] > 1 ) {
// There are duplicates. We delete our just created entry.
logger ( 'Duplicated post occurred. uri = ' . $arr [ 'uri' ] . ' uid = ' . $arr [ 'uid' ]);
2014-01-05 16:10:02 +01:00
2016-10-29 22:17:33 +02:00
// Yes, we could do a rollback here - but we are having many users with MyISAM.
q ( " DELETE FROM `item` WHERE `id` = %d " , intval ( $current_post ));
q ( " COMMIT " );
return 0 ;
} elseif ( $r [ 0 ][ " entries " ] == 0 ) {
// This really should never happen since we quit earlier if there were problems.
logger ( " Something is terribly wrong. We haven't found our created entry. " );
2016-12-01 14:50:26 +01:00
q ( " ROLLBACK " );
2010-09-09 05:14:17 +02:00
return 0 ;
}
2010-07-19 05:49:10 +02:00
2016-10-29 22:17:33 +02:00
logger ( 'item_store: created item ' . $current_post );
item_set_last_item ( $arr );
2016-10-22 12:14:41 +02:00
if ( ! $parent_id || ( $arr [ 'parent-uri' ] === $arr [ 'uri' ]))
2010-11-12 05:32:20 +01:00
$parent_id = $current_post ;
2011-02-04 22:37:04 +01:00
2016-10-07 08:05:43 +02:00
// Set parent id
$r = q ( " UPDATE `item` SET `parent` = %d WHERE `id` = %d " ,
2010-07-19 05:49:10 +02:00
intval ( $parent_id ),
intval ( $current_post )
);
2014-06-15 23:33:25 +02:00
$arr [ 'id' ] = $current_post ;
$arr [ 'parent' ] = $parent_id ;
2012-06-12 07:09:50 +02:00
2011-09-19 04:04:11 +02:00
// update the commented timestamp on the parent
2015-02-22 17:34:04 +01:00
// Only update "commented" if it is really a comment
2015-02-23 12:44:50 +01:00
if (( $arr [ 'verb' ] == ACTIVITY_POST ) OR ! get_config ( " system " , " like_no_comment " ))
2015-02-22 17:34:04 +01:00
q ( " UPDATE `item` SET `commented` = '%s', `changed` = '%s' WHERE `id` = %d " ,
dbesc ( datetime_convert ()),
dbesc ( datetime_convert ()),
intval ( $parent_id )
);
else
q ( " UPDATE `item` SET `changed` = '%s' WHERE `id` = %d " ,
dbesc ( datetime_convert ()),
intval ( $parent_id )
);
2011-09-16 15:49:24 +02:00
2016-10-22 12:14:41 +02:00
if ( $dsprsig ) {
2016-01-20 16:00:43 +01:00
2016-01-23 12:39:37 +01:00
// Friendica servers lower than 3.4.3-2 had double encoded the signature ...
2016-01-20 16:00:43 +01:00
// We can check for this condition when we decode and encode the stuff again.
if ( base64_encode ( base64_decode ( base64_decode ( $dsprsig -> signature ))) == base64_decode ( $dsprsig -> signature )) {
$dsprsig -> signature = base64_decode ( $dsprsig -> signature );
logger ( " Repaired double encoded signature from handle " . $dsprsig -> signer , LOGGER_DEBUG );
}
2011-08-29 04:22:27 +02:00
q ( " insert into sign (`iid`,`signed_text`,`signature`,`signer`) values (%d,'%s','%s','%s') " ,
intval ( $current_post ),
dbesc ( $dsprsig -> signed_text ),
dbesc ( $dsprsig -> signature ),
dbesc ( $dsprsig -> signer )
);
}
2013-04-19 15:55:07 +02:00
$deleted = tag_deliver ( $arr [ 'uid' ], $current_post );
2015-02-16 22:11:51 +01:00
// current post can be deleted if is for a community page and no mention are
2013-04-19 15:55:07 +02:00
// in it.
2014-12-21 21:19:37 +01:00
if ( ! $deleted AND ! $dontcache ) {
2014-01-05 16:10:02 +01:00
2016-12-19 14:42:20 +01:00
$r = q ( 'SELECT * FROM `item` WHERE `id` = %d' , intval ( $current_post ));
if (( dbm :: is_result ( $r )) && ( count ( $r ) == 1 )) {
2015-09-07 23:14:18 +02:00
if ( $notify )
call_hooks ( 'post_local_end' , $r [ 0 ]);
else
call_hooks ( 'post_remote_end' , $r [ 0 ]);
2015-02-16 22:11:51 +01:00
} else
2014-03-16 17:12:56 +01:00
logger ( 'item_store: new item not found in DB, id ' . $current_post );
2013-04-19 15:55:07 +02:00
}
2014-03-16 17:12:56 +01:00
2016-10-29 22:17:33 +02:00
if ( $arr [ 'parent-uri' ] === $arr [ 'uri' ]) {
add_thread ( $current_post );
} else {
update_thread ( $parent_id );
}
q ( " COMMIT " );
// 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.
2015-02-09 23:04:18 +01:00
create_tags_from_item ( $current_post );
2014-03-16 17:12:56 +01:00
create_files_from_item ( $current_post );
2016-10-30 00:06:18 +02:00
// If this is now the last-child, force all _other_ children of this parent to *not* be last-child
// It is done after the transaction to avoid dead locks.
2016-10-29 22:17:33 +02:00
if ( $arr [ 'last-child' ]) {
$r = q ( " UPDATE `item` SET `last-child` = 0 WHERE `parent-uri` = '%s' AND `uid` = %d AND `id` != %d " ,
dbesc ( $arr [ 'uri' ]),
intval ( $arr [ 'uid' ]),
intval ( $current_post )
);
}
2016-10-23 23:59:40 +02:00
2016-10-29 22:17:33 +02:00
if ( $arr [ 'parent-uri' ] === $arr [ 'uri' ]) {
2016-10-23 23:59:40 +02:00
add_shadow_thread ( $current_post );
2016-10-21 20:25:21 +02:00
} else {
2016-10-29 23:27:56 +02:00
add_shadow_entry ( $current_post );
2015-03-21 20:23:47 +01:00
}
2015-02-09 21:52:08 +01:00
2016-01-28 22:58:05 +01:00
check_item_notification ( $current_post , $uid );
2014-08-31 23:52:25 +02:00
if ( $notify )
2016-08-01 07:48:43 +02:00
proc_run ( PRIORITY_HIGH , " include/notifier.php " , $notify_type , $current_post );
2014-08-31 23:52:25 +02:00
2010-07-19 05:49:10 +02:00
return $current_post ;
}
2014-07-22 00:36:20 +02:00
2016-10-14 07:45:32 +02:00
/**
* @ brief Set " success_update " and " last-item " to the date of the last time we heard from this contact
*
* This can be used to filter for inactive contacts .
* Only do this for public postings to avoid privacy problems , since poco data is public .
* Don 't set this value if it isn' t from the owner ( could be an author that we don ' t know )
*
* @ param array $arr Contains the just posted item record
*/
function item_set_last_item ( $arr ) {
$update = ( ! $arr [ 'private' ] AND (( $arr [ " author-link " ] === $arr [ " owner-link " ]) OR ( $arr [ " parent-uri " ] === $arr [ " uri " ])));
// Is it a forum? Then we don't care about the rules from above
if ( ! $update AND ( $arr [ " network " ] == NETWORK_DFRN ) AND ( $arr [ " parent-uri " ] === $arr [ " uri " ])) {
$isforum = q ( " SELECT `forum` FROM `contact` WHERE `id` = %d AND `forum` " ,
intval ( $arr [ 'contact-id' ]));
2016-10-22 12:14:41 +02:00
if ( $isforum ) {
2016-10-14 07:45:32 +02:00
$update = true ;
2016-10-22 12:14:41 +02:00
}
2016-10-14 07:45:32 +02:00
}
2016-10-22 12:14:41 +02:00
if ( $update ) {
2016-10-14 07:45:32 +02:00
q ( " UPDATE `contact` SET `success_update` = '%s', `last-item` = '%s' WHERE `id` = %d " ,
dbesc ( $arr [ 'received' ]),
dbesc ( $arr [ 'received' ]),
intval ( $arr [ 'contact-id' ])
);
2016-10-22 12:14:41 +02:00
}
2016-10-14 07:45:32 +02:00
// Now do the same for the system wide contacts with uid=0
if ( ! $arr [ 'private' ]) {
q ( " UPDATE `contact` SET `success_update` = '%s', `last-item` = '%s' WHERE `id` = %d " ,
dbesc ( $arr [ 'received' ]),
dbesc ( $arr [ 'received' ]),
intval ( $arr [ 'owner-id' ])
);
2016-10-22 12:14:41 +02:00
if ( $arr [ 'owner-id' ] != $arr [ 'author-id' ]) {
2016-10-14 07:45:32 +02:00
q ( " UPDATE `contact` SET `success_update` = '%s', `last-item` = '%s' WHERE `id` = %d " ,
dbesc ( $arr [ 'received' ]),
dbesc ( $arr [ 'received' ]),
intval ( $arr [ 'author-id' ])
);
2016-10-22 12:14:41 +02:00
}
2016-10-14 07:45:32 +02:00
}
}
2015-03-01 17:33:55 +01:00
function item_body_set_hashtags ( & $item ) {
$tags = get_tags ( $item [ " body " ]);
// No hashtags?
2016-10-22 12:14:41 +02:00
if ( ! count ( $tags ))
2015-03-01 17:33:55 +01:00
return ( false );
// This sorting is important when there are hashtags that are part of other hashtags
// Otherwise there could be problems with hashtags like #test and #test2
rsort ( $tags );
$a = get_app ();
$URLSearchString = " ^ \ [ \ ] " ;
// All hashtags should point to the home server
2015-03-03 14:10:42 +01:00
//$item["body"] = preg_replace("/#\[url\=([$URLSearchString]*)\](.*?)\[\/url\]/ism",
2016-12-19 14:26:13 +01:00
// "#[url=".App::get_baseurl()."/search?tag=$2]$2[/url]", $item["body"]);
2015-03-01 17:33:55 +01:00
2015-03-03 14:10:42 +01:00
//$item["tag"] = preg_replace("/#\[url\=([$URLSearchString]*)\](.*?)\[\/url\]/ism",
2016-12-19 14:26:13 +01:00
// "#[url=".App::get_baseurl()."/search?tag=$2]$2[/url]", $item["tag"]);
2015-03-01 17:33:55 +01:00
// mask hashtags inside of url, bookmarks and attachments to avoid urls in urls
$item [ " body " ] = preg_replace_callback ( " / \ [url \ =([ $URLSearchString ]*) \ ](.*?) \ [ \ /url \ ]/ism " ,
function ( $match ){
2015-06-02 18:59:46 +02:00
return ( " [url= " . str_replace ( " # " , " # " , $match [ 1 ]) . " ] " . str_replace ( " # " , " # " , $match [ 2 ]) . " [/url] " );
2015-03-01 17:33:55 +01:00
}, $item [ " body " ]);
$item [ " body " ] = preg_replace_callback ( " / \ [bookmark \ =([ $URLSearchString ]*) \ ](.*?) \ [ \ /bookmark \ ]/ism " ,
function ( $match ){
2015-06-02 18:59:46 +02:00
return ( " [bookmark= " . str_replace ( " # " , " # " , $match [ 1 ]) . " ] " . str_replace ( " # " , " # " , $match [ 2 ]) . " [/bookmark] " );
2015-03-01 17:33:55 +01:00
}, $item [ " body " ]);
$item [ " body " ] = preg_replace_callback ( " / \ [attachment (.*) \ ](.*?) \ [ \ /attachment \ ]/ism " ,
function ( $match ){
return ( " [attachment " . str_replace ( " # " , " # " , $match [ 1 ]) . " ] " . $match [ 2 ] . " [/attachment] " );
}, $item [ " body " ]);
// Repair recursive urls
$item [ " body " ] = preg_replace ( " /# \ [url \ =([ $URLSearchString ]*) \ ](.*?) \ [ \ /url \ ]/ism " ,
" # $ 2 " , $item [ " body " ]);
2015-06-02 18:59:46 +02:00
2015-03-01 17:33:55 +01:00
foreach ( $tags as $tag ) {
2016-10-22 12:14:41 +02:00
if ( strpos ( $tag , '#' ) !== 0 )
2015-03-01 17:33:55 +01:00
continue ;
2016-10-22 12:14:41 +02:00
if ( strpos ( $tag , '[url=' ))
2015-03-01 17:33:55 +01:00
continue ;
$basetag = str_replace ( '_' , ' ' , substr ( $tag , 1 ));
2015-03-01 20:40:38 +01:00
2016-12-19 14:26:13 +01:00
$newtag = '#[url=' . App :: get_baseurl () . '/search?tag=' . rawurlencode ( $basetag ) . ']' . $basetag . '[/url]' ;
2015-03-01 20:40:38 +01:00
$item [ " body " ] = str_replace ( $tag , $newtag , $item [ " body " ]);
2016-10-22 12:14:41 +02:00
if ( ! stristr ( $item [ " tag " ], " /search?tag= " . $basetag . " ] " . $basetag . " [/url] " )) {
if ( strlen ( $item [ " tag " ]))
2015-03-01 20:40:38 +01:00
$item [ " tag " ] = ',' . $item [ " tag " ];
$item [ " tag " ] = $newtag . $item [ " tag " ];
}
2015-03-01 17:33:55 +01:00
}
// Convert back the masked hashtags
$item [ " body " ] = str_replace ( " # " , " # " , $item [ " body " ]);
}
2014-07-22 00:36:20 +02:00
function get_item_guid ( $id ) {
$r = q ( " SELECT `guid` FROM `item` WHERE `id` = %d LIMIT 1 " , intval ( $id ));
2016-12-13 10:44:13 +01:00
if ( dbm :: is_result ( $r ))
2014-07-22 00:36:20 +02:00
return ( $r [ 0 ][ " guid " ]);
else
return ( " " );
}
2014-07-26 15:01:01 +02:00
function get_item_id ( $guid , $uid = 0 ) {
$nick = " " ;
$id = 0 ;
if ( $uid == 0 )
$uid == local_user ();
// Does the given user have this item?
if ( $uid ) {
$r = q ( " SELECT `item`.`id`, `user`.`nickname` FROM `item` INNER JOIN `user` ON `user`.`uid` = `item`.`uid`
WHERE `item` . `visible` = 1 AND `item` . `deleted` = 0 and `item` . `moderated` = 0
AND `item` . `guid` = '%s' AND `item` . `uid` = % d " , dbesc( $guid ), intval( $uid ));
2016-12-13 10:44:13 +01:00
if ( dbm :: is_result ( $r )) {
2014-07-26 15:01:01 +02:00
$id = $r [ 0 ][ " id " ];
$nick = $r [ 0 ][ " nickname " ];
}
}
// Or is it anywhere on the server?
if ( $nick == " " ) {
$r = q ( " SELECT `item`.`id`, `user`.`nickname` FROM `item` INNER JOIN `user` ON `user`.`uid` = `item`.`uid`
WHERE `item` . `visible` = 1 AND `item` . `deleted` = 0 and `item` . `moderated` = 0
AND `item` . `allow_cid` = '' AND `item` . `allow_gid` = ''
AND `item` . `deny_cid` = '' AND `item` . `deny_gid` = ''
AND `item` . `private` = 0 AND `item` . `wall` = 1
AND `item` . `guid` = '%s' " , dbesc( $guid ));
2016-12-13 10:44:13 +01:00
if ( dbm :: is_result ( $r )) {
2014-07-26 15:01:01 +02:00
$id = $r [ 0 ][ " id " ];
$nick = $r [ 0 ][ " nickname " ];
}
}
return ( array ( " nick " => $nick , " id " => $id ));
}
2014-03-16 17:12:56 +01:00
// return - test
2010-09-27 01:30:21 +02:00
function get_item_contact ( $item , $contacts ) {
2016-10-22 12:14:41 +02:00
if ( ! count ( $contacts ) || ( ! is_array ( $item )))
2010-09-27 01:30:21 +02:00
return false ;
foreach ( $contacts as $contact ) {
2016-10-22 12:14:41 +02:00
if ( $contact [ 'id' ] == $item [ 'contact-id' ]) {
2010-09-27 01:30:21 +02:00
return $contact ;
break ; // NOTREACHED
}
}
return false ;
}
2013-04-19 15:55:07 +02:00
/**
* look for mention tags and setup a second delivery chain for forum / community posts if appropriate
* @ param int $uid
* @ param int $item_id
* @ return bool true if item was deleted , else false
*/
2012-02-10 06:18:50 +01:00
function tag_deliver ( $uid , $item_id ) {
2011-11-16 05:30:34 +01:00
2014-03-09 09:19:14 +01:00
//
2011-11-19 07:20:08 +01:00
2011-11-16 05:30:34 +01:00
$a = get_app ();
2012-02-10 06:18:50 +01:00
$mention = false ;
2011-11-16 05:30:34 +01:00
2012-05-07 08:06:21 +02:00
$u = q ( " select * from user where uid = %d limit 1 " ,
2012-02-10 06:18:50 +01:00
intval ( $uid )
2011-11-16 05:30:34 +01:00
);
2016-12-20 15:37:27 +01:00
if ( ! dbm :: is_result ( $u )) {
2011-11-16 05:30:34 +01:00
return ;
2016-12-20 15:37:27 +01:00
}
2011-11-16 05:30:34 +01:00
2012-02-10 06:18:50 +01:00
$community_page = (( $u [ 0 ][ 'page-flags' ] == PAGE_COMMUNITY ) ? true : false );
2012-05-18 04:35:24 +02:00
$prvgroup = (( $u [ 0 ][ 'page-flags' ] == PAGE_PRVGROUP ) ? true : false );
2012-02-10 06:18:50 +01:00
2016-12-20 15:37:27 +01:00
$i = q ( " SELECT * FROM `item` WHERE `id` = %d AND `uid` = %d LIMIT 1 " ,
2011-11-16 05:30:34 +01:00
intval ( $item_id ),
intval ( $uid )
);
2016-12-20 15:37:27 +01:00
if ( ! dbm :: is_result ( $i )) {
2011-11-16 05:30:34 +01:00
return ;
2016-12-20 15:37:27 +01:00
}
2011-11-16 05:30:34 +01:00
$item = $i [ 0 ];
2016-12-19 14:26:13 +01:00
$link = normalise_link ( App :: get_baseurl () . '/profile/' . $u [ 0 ][ 'nickname' ]);
2011-11-16 05:30:34 +01:00
2012-01-04 22:50:12 +01:00
// Diaspora uses their own hardwired link URL in @-tags
// instead of the one we supply with webfinger
2016-12-19 14:26:13 +01:00
$dlink = normalise_link ( App :: get_baseurl () . '/u/' . $u [ 0 ][ 'nickname' ]);
2012-01-04 22:50:12 +01:00
2012-01-03 23:27:00 +01:00
$cnt = preg_match_all ( '/[\@\!]\[url\=(.*?)\](.*?)\[\/url\]/ism' , $item [ 'body' ], $matches , PREG_SET_ORDER );
2016-10-22 12:14:41 +02:00
if ( $cnt ) {
2011-11-16 05:30:34 +01:00
foreach ( $matches as $mtch ) {
2016-10-22 12:14:41 +02:00
if ( link_compare ( $link , $mtch [ 1 ]) || link_compare ( $dlink , $mtch [ 1 ])) {
2012-02-10 06:18:50 +01:00
$mention = true ;
logger ( 'tag_deliver: mention found: ' . $mtch [ 2 ]);
2011-11-16 05:30:34 +01:00
}
}
}
2016-10-22 12:14:41 +02:00
if ( ! $mention ){
2013-04-19 15:55:07 +02:00
if ( ( $community_page || $prvgroup ) &&
( ! $item [ 'wall' ]) && ( ! $item [ 'origin' ]) && ( $item [ 'id' ] == $item [ 'parent' ])){
// mmh.. no mention.. community page or private group... no wall.. no origin.. top-post (not a comment)
// delete it!
logger ( " tag_deliver: no-mention top-level post to communuty or private group. delete. " );
2013-11-02 16:13:11 +01:00
q ( " DELETE FROM item WHERE id = %d and uid = %d " ,
2013-04-19 15:55:07 +02:00
intval ( $item_id ),
intval ( $uid )
);
return true ;
}
2011-11-16 05:30:34 +01:00
return ;
2013-04-19 15:55:07 +02:00
}
2013-11-02 10:49:44 +01:00
2012-09-27 03:24:19 +02:00
$arr = array ( 'item' => $item , 'user' => $u [ 0 ], 'contact' => $r [ 0 ]);
call_hooks ( 'tagged' , $arr );
2016-10-22 12:14:41 +02:00
if (( ! $community_page ) && ( ! $prvgroup ))
2012-05-18 07:44:52 +02:00
return ;
2012-05-18 04:35:24 +02:00
2011-11-19 07:20:08 +01:00
2012-02-10 09:08:23 +01:00
// tgroup delivery - setup a second delivery chain
// prevent delivery looping - only proceed
// if the message originated elsewhere and is a top-level post
2011-11-19 07:20:08 +01:00
2016-10-22 12:14:41 +02:00
if (( $item [ 'wall' ]) || ( $item [ 'origin' ]) || ( $item [ 'id' ] != $item [ 'parent' ]))
2012-02-10 09:08:23 +01:00
return ;
2011-11-16 05:30:34 +01:00
2012-02-10 09:08:23 +01:00
// now change this copy of the post to a forum head message and deliver to all the tgroup members
2011-11-16 05:30:34 +01:00
2012-02-10 06:18:50 +01:00
2012-02-17 03:29:09 +01:00
$c = q ( " select name, url, thumb from contact where self = 1 and uid = %d limit 1 " ,
intval ( $u [ 0 ][ 'uid' ])
);
2016-12-22 16:58:50 +01:00
if ( ! count ( $c )) {
2012-02-17 03:29:09 +01:00
return ;
2016-12-22 16:58:50 +01:00
}
2012-02-17 03:29:09 +01:00
2012-05-07 08:06:21 +02:00
// also reset all the privacy bits to the forum default permissions
$private = ( $u [ 0 ][ 'allow_cid' ] || $u [ 0 ][ 'allow_gid' ] || $u [ 0 ][ 'deny_cid' ] || $u [ 0 ][ 'deny_gid' ]) ? 1 : 0 ;
2012-05-18 07:44:52 +02:00
$forum_mode = (( $prvgroup ) ? 2 : 1 );
2016-12-22 16:58:50 +01:00
q ( " UPDATE `item` SET `wall` = 1, `origin` = 1, `forum_mode` = %d, `owner-name` = '%s', `owner-link` = '%s', `owner-avatar` = '%s',
`private` = % d , `allow_cid` = '%s' , `allow_gid` = '%s' , `deny_cid` = '%s' , `deny_gid` = '%s' WHERE `id` = % d " ,
2012-05-18 07:44:52 +02:00
intval ( $forum_mode ),
2012-02-17 03:29:09 +01:00
dbesc ( $c [ 0 ][ 'name' ]),
dbesc ( $c [ 0 ][ 'url' ]),
dbesc ( $c [ 0 ][ 'thumb' ]),
2012-05-07 08:06:21 +02:00
intval ( $private ),
dbesc ( $u [ 0 ][ 'allow_cid' ]),
dbesc ( $u [ 0 ][ 'allow_gid' ]),
dbesc ( $u [ 0 ][ 'deny_cid' ]),
dbesc ( $u [ 0 ][ 'deny_gid' ]),
2012-02-10 09:08:23 +01:00
intval ( $item_id )
);
2014-03-09 09:19:14 +01:00
update_thread ( $item_id );
2012-02-10 09:08:23 +01:00
2016-08-01 07:48:43 +02:00
proc_run ( PRIORITY_HIGH , 'include/notifier.php' , 'tgroup' , $item_id );
2012-02-10 09:08:23 +01:00
2011-11-16 05:30:34 +01:00
}
2012-09-13 03:53:20 +02:00
function tgroup_check ( $uid , $item ) {
$a = get_app ();
$mention = false ;
// check that the message originated elsewhere and is a top-level post
2016-10-22 12:14:41 +02:00
if (( $item [ 'wall' ]) || ( $item [ 'origin' ]) || ( $item [ 'uri' ] != $item [ 'parent-uri' ]))
2012-09-13 03:53:20 +02:00
return false ;
2016-12-20 15:37:27 +01:00
/// @TODO Encapsulate this or find it encapsulated and replace all occurrances
$u = q ( " SELECT * FROM `user` WHERE `uid` = %d LIMIT 1 " ,
2012-09-13 03:53:20 +02:00
intval ( $uid )
);
2016-12-20 15:37:27 +01:00
if ( ! dbm :: is_result ( $u )) {
2012-09-13 03:53:20 +02:00
return false ;
2016-12-20 15:37:27 +01:00
}
2012-09-13 03:53:20 +02:00
$community_page = (( $u [ 0 ][ 'page-flags' ] == PAGE_COMMUNITY ) ? true : false );
$prvgroup = (( $u [ 0 ][ 'page-flags' ] == PAGE_PRVGROUP ) ? true : false );
2016-12-19 14:26:13 +01:00
$link = normalise_link ( App :: get_baseurl () . '/profile/' . $u [ 0 ][ 'nickname' ]);
2012-09-13 03:53:20 +02:00
// Diaspora uses their own hardwired link URL in @-tags
// instead of the one we supply with webfinger
2016-12-19 14:26:13 +01:00
$dlink = normalise_link ( App :: get_baseurl () . '/u/' . $u [ 0 ][ 'nickname' ]);
2012-09-13 03:53:20 +02:00
$cnt = preg_match_all ( '/[\@\!]\[url\=(.*?)\](.*?)\[\/url\]/ism' , $item [ 'body' ], $matches , PREG_SET_ORDER );
2016-10-22 12:14:41 +02:00
if ( $cnt ) {
2016-12-22 16:58:50 +01:00
foreach ( $matches as $mtch ) {
2016-10-22 12:14:41 +02:00
if ( link_compare ( $link , $mtch [ 1 ]) || link_compare ( $dlink , $mtch [ 1 ])) {
2012-09-13 03:53:20 +02:00
$mention = true ;
logger ( 'tgroup_check: mention found: ' . $mtch [ 2 ]);
}
}
}
2016-12-22 16:58:50 +01:00
if ( ! $mention ) {
2012-09-13 03:53:20 +02:00
return false ;
2016-12-22 16:58:50 +01:00
}
2012-09-13 03:53:20 +02:00
2016-12-22 16:58:50 +01:00
/// @TODO Combines both return statements into one
return (( $community_page ) || ( $prvgroup ));
2010-09-27 01:30:21 +02:00
}
2010-10-01 04:41:22 +02:00
2013-03-20 02:00:12 +01:00
/*
This function returns true if $update has an edited timestamp newer
than $existing , i . e . $update contains new data which should override
what ' s already there . If there is no timestamp yet , the update is
assumed to be newer . If the update has no timestamp , the existing
item is assumed to be up - to - date . If the timestamps are equal it
assumes the update has been seen before and should be ignored .
*/
function edited_timestamp_is_newer ( $existing , $update ) {
2016-12-22 16:58:50 +01:00
if ( ! x ( $existing , 'edited' ) || ! $existing [ 'edited' ]) {
return true ;
}
if ( ! x ( $update , 'edited' ) || ! $update [ 'edited' ]) {
return false ;
}
$existing_edited = datetime_convert ( 'UTC' , 'UTC' , $existing [ 'edited' ]);
$update_edited = datetime_convert ( 'UTC' , 'UTC' , $update [ 'edited' ]);
return ( strcmp ( $existing_edited , $update_edited ) < 0 );
2013-03-20 02:00:12 +01:00
}
2011-02-08 06:16:39 +01:00
/**
2010-10-22 06:48:22 +02:00
*
* consume_feed - process atom feed and update anything / everything we might need to update
*
2011-02-08 06:16:39 +01:00
* $xml = the ( atom ) feed to consume - RSS isn ' t as fully supported but may work for simple feeds .
*
2010-10-22 06:48:22 +02:00
* $importer = the contact_record ( joined to user_record ) of the local user who owns this relationship .
* It is this person ' s stuff that is going to be updated .
* $contact = the person who is sending us stuff . If not set , we MAY be processing a " follow " activity
2014-05-12 19:02:03 +02:00
* from an external network and MAY create an appropriate contact record . Otherwise , we MUST
2010-10-22 06:48:22 +02:00
* have a contact record .
2014-05-12 19:02:03 +02:00
* $hub = should we find a hub declation in the feed , pass it back to our calling process , who might ( or
2010-10-22 06:48:22 +02:00
* might not ) try and subscribe to it .
2011-10-04 13:38:58 +02:00
* $datedir sorts in reverse order
2014-05-12 19:02:03 +02:00
* $pass - by default ( $pass = 0 ) we cannot guarantee that a parent item has been
2011-10-04 13:38:58 +02:00
* imported prior to its children being seen in the stream unless we are certain
* of how the feed is arranged / ordered .
* With $pass = 1 , we only pull parent items out of the stream .
* With $pass = 2 , we only pull children ( comments / likes ) .
2010-10-22 06:48:22 +02:00
*
2011-10-04 13:38:58 +02:00
* So running this twice , first with pass 1 and then with pass 2 will do the right
* thing regardless of feed ordering . This won ' t be adequate in a fully - threaded
* model where comments can have sub - threads . That would require some massive sorting
* to get all the feed items into a mostly linear ordering , and might still require
2014-03-16 17:12:56 +01:00
* recursion .
2010-10-22 06:48:22 +02:00
*/
2011-10-04 12:06:34 +02:00
function consume_feed ( $xml , $importer , & $contact , & $hub , $datedir = 0 , $pass = 0 ) {
2015-06-07 23:18:02 +02:00
if ( $contact [ 'network' ] === NETWORK_OSTATUS ) {
if ( $pass < 2 ) {
2015-12-03 14:38:04 +01:00
// Test - remove before flight
//$tempfile = tempnam(get_temppath(), "ostatus2");
//file_put_contents($tempfile, $xml);
2015-06-07 23:18:02 +02:00
logger ( " Consume OStatus messages " , LOGGER_DEBUG );
2016-03-30 12:43:15 +02:00
ostatus :: import ( $xml , $importer , $contact , $hub );
2015-06-07 23:18:02 +02:00
}
return ;
}
2010-10-01 04:41:22 +02:00
2015-09-27 14:02:05 +02:00
if ( $contact [ 'network' ] === NETWORK_FEED ) {
if ( $pass < 2 ) {
logger ( " Consume feeds " , LOGGER_DEBUG );
feed_import ( $xml , $importer , $contact , $hub );
}
return ;
}
2016-02-04 23:52:06 +01:00
2016-02-03 23:04:52 +01:00
if ( $contact [ 'network' ] === NETWORK_DFRN ) {
logger ( " Consume DFRN messages " , LOGGER_DEBUG );
$r = q ( " SELECT `contact`.*, `contact`.`uid` AS `importer_uid`,
2016-04-17 20:43:41 +02:00
`contact` . `pubkey` AS `cpubkey` ,
`contact` . `prvkey` AS `cprvkey` ,
`contact` . `thumb` AS `thumb` ,
`contact` . `url` as `url` ,
`contact` . `name` as `senderName` ,
`user` .*
FROM `contact`
LEFT JOIN `user` ON `contact` . `uid` = `user` . `uid`
WHERE `contact` . `id` = % d AND `user` . `uid` = % d " ,
dbesc ( $contact [ " id " ]), dbesc ( $importer [ " uid " ])
);
2016-02-03 23:04:52 +01:00
if ( $r ) {
2016-02-04 23:52:06 +01:00
logger ( " Now import the DFRN feed " );
2016-02-05 21:25:20 +01:00
dfrn :: import ( $xml , $r [ 0 ], true );
2016-02-03 23:04:52 +01:00
return ;
}
}
2016-02-05 21:25:20 +01:00
}
2016-02-04 23:52:06 +01:00
2016-02-05 21:25:20 +01:00
function item_is_remote_self ( $contact , & $datarray ) {
$a = get_app ();
2013-01-11 01:20:16 +01:00
2016-02-05 21:25:20 +01:00
if ( ! $contact [ 'remote_self' ])
return false ;
2011-01-14 00:45:42 +01:00
2016-02-05 21:25:20 +01:00
// Prevent the forwarding of posts that are forwarded
if ( $datarray [ " extid " ] == NETWORK_DFRN )
return false ;
2011-01-14 00:45:42 +01:00
2016-02-05 21:25:20 +01:00
// Prevent to forward already forwarded posts
if ( $datarray [ " app " ] == $a -> get_hostname ())
return false ;
2013-01-11 01:20:16 +01:00
2016-02-05 21:25:20 +01:00
// Only forward posts
if ( $datarray [ " verb " ] != ACTIVITY_POST )
return false ;
2011-01-14 00:45:42 +01:00
2016-02-05 21:25:20 +01:00
if (( $contact [ 'network' ] != NETWORK_FEED ) AND $datarray [ 'private' ])
return false ;
2011-01-14 00:45:42 +01:00
2016-02-05 21:25:20 +01:00
$datarray2 = $datarray ;
logger ( 'remote-self start - Contact ' . $contact [ 'url' ] . ' - ' . $contact [ 'remote_self' ] . ' Item ' . print_r ( $datarray , true ), LOGGER_DEBUG );
if ( $contact [ 'remote_self' ] == 2 ) {
$r = q ( " SELECT `id`,`url`,`name`,`thumb` FROM `contact` WHERE `uid` = %d AND `self` " ,
intval ( $contact [ 'uid' ]));
2016-12-13 10:44:13 +01:00
if ( dbm :: is_result ( $r )) {
2016-02-05 21:25:20 +01:00
$datarray [ 'contact-id' ] = $r [ 0 ][ " id " ];
2011-01-14 00:45:42 +01:00
2016-02-05 21:25:20 +01:00
$datarray [ 'owner-name' ] = $r [ 0 ][ " name " ];
$datarray [ 'owner-link' ] = $r [ 0 ][ " url " ];
$datarray [ 'owner-avatar' ] = $r [ 0 ][ " thumb " ];
2011-01-14 00:45:42 +01:00
2016-02-05 21:25:20 +01:00
$datarray [ 'author-name' ] = $datarray [ 'owner-name' ];
$datarray [ 'author-link' ] = $datarray [ 'owner-link' ];
$datarray [ 'author-avatar' ] = $datarray [ 'owner-avatar' ];
2011-01-14 00:45:42 +01:00
}
2011-10-24 13:17:46 +02:00
2016-02-05 21:25:20 +01:00
if ( $contact [ 'network' ] != NETWORK_FEED ) {
$datarray [ " guid " ] = get_guid ( 32 );
unset ( $datarray [ " plink " ]);
$datarray [ " uri " ] = item_new_uri ( $a -> get_hostname (), $contact [ 'uid' ], $datarray [ " guid " ]);
$datarray [ " parent-uri " ] = $datarray [ " uri " ];
$datarray [ " extid " ] = $contact [ 'network' ];
$urlpart = parse_url ( $datarray2 [ 'author-link' ]);
$datarray [ " app " ] = $urlpart [ " host " ];
} else
$datarray [ 'private' ] = 0 ;
2011-02-08 13:25:27 +01:00
}
2016-02-05 21:25:20 +01:00
if ( $contact [ 'network' ] != NETWORK_FEED ) {
// Store the original post
$r = item_store ( $datarray2 , false , false );
logger ( 'remote-self post original item - Contact ' . $contact [ 'url' ] . ' return ' . $r . ' Item ' . print_r ( $datarray2 , true ), LOGGER_DEBUG );
} else
$datarray [ " app " ] = " Feed " ;
2014-10-29 01:05:09 +01:00
return true ;
}
2011-10-03 01:18:01 +02:00
function new_follower ( $importer , $contact , $datarray , $item , $sharing = false ) {
2010-10-25 05:39:24 +02:00
$url = notags ( trim ( $datarray [ 'author-link' ]));
$name = notags ( trim ( $datarray [ 'author-name' ]));
$photo = notags ( trim ( $datarray [ 'author-avatar' ]));
2015-07-13 23:50:33 +02:00
if ( is_object ( $item )) {
$rawtag = $item -> get_item_tags ( NAMESPACE_ACTIVITY , 'actor' );
2016-10-22 12:14:41 +02:00
if ( $rawtag && $rawtag [ 0 ][ 'child' ][ NAMESPACE_POCO ][ 'preferredUsername' ][ 0 ][ 'data' ])
2015-07-13 23:50:33 +02:00
$nick = $rawtag [ 0 ][ 'child' ][ NAMESPACE_POCO ][ 'preferredUsername' ][ 0 ][ 'data' ];
} else
$nick = $item ;
2010-10-25 05:39:24 +02:00
2016-10-22 12:14:41 +02:00
if ( is_array ( $contact )) {
if (( $contact [ 'network' ] == NETWORK_OSTATUS && $contact [ 'rel' ] == CONTACT_IS_SHARING )
2011-10-03 01:18:01 +02:00
|| ( $sharing && $contact [ 'rel' ] == CONTACT_IS_FOLLOWER )) {
2013-11-02 16:13:11 +01:00
$r = q ( " UPDATE `contact` SET `rel` = %d, `writable` = 1 WHERE `id` = %d AND `uid` = %d " ,
2011-08-08 01:15:54 +02:00
intval ( CONTACT_IS_FRIEND ),
2010-10-25 05:39:24 +02:00
intval ( $contact [ 'id' ]),
intval ( $importer [ 'uid' ])
);
}
// send email notification to owner?
2015-11-28 01:03:26 +01:00
} else {
2013-01-11 01:20:16 +01:00
2011-07-02 02:39:16 +02:00
// create contact record
2010-10-22 06:48:22 +02:00
2015-11-28 01:03:26 +01:00
$r = q ( " INSERT INTO `contact` (`uid`, `created`, `url`, `nurl`, `name`, `nick`, `photo`, `network`, `rel`,
`blocked` , `readonly` , `pending` , `writable` )
VALUES ( % d , '%s' , '%s' , '%s' , '%s' , '%s' , '%s' , '%s' , % d , 0 , 0 , 1 , 1 ) " ,
2010-10-25 05:39:24 +02:00
intval ( $importer [ 'uid' ]),
dbesc ( datetime_convert ()),
dbesc ( $url ),
2011-11-02 00:08:07 +01:00
dbesc ( normalise_link ( $url )),
2010-10-25 05:39:24 +02:00
dbesc ( $name ),
dbesc ( $nick ),
dbesc ( $photo ),
2011-10-03 01:18:01 +02:00
dbesc (( $sharing ) ? NETWORK_ZOT : NETWORK_OSTATUS ),
intval (( $sharing ) ? CONTACT_IS_SHARING : CONTACT_IS_FOLLOWER )
2010-10-25 05:39:24 +02:00
);
2016-04-13 22:21:23 +02:00
$r = q ( " SELECT `id`, `network` FROM `contact` WHERE `uid` = %d AND `url` = '%s' AND `pending` = 1 LIMIT 1 " ,
2010-10-25 05:39:24 +02:00
intval ( $importer [ 'uid' ]),
2011-10-03 01:18:01 +02:00
dbesc ( $url )
2010-10-25 05:39:24 +02:00
);
2016-12-14 09:42:36 +01:00
if ( dbm :: is_result ( $r )) {
2016-06-25 13:56:55 +02:00
$contact_record = $r [ 0 ];
update_contact_avatar ( $photo , $importer [ " uid " ], $contact_record [ " id " ], true );
2010-10-25 05:39:24 +02:00
}
2014-09-06 18:15:18 +02:00
2015-11-28 01:03:26 +01:00
2010-11-06 22:40:19 +01:00
$r = q ( " SELECT * FROM `user` WHERE `uid` = %d LIMIT 1 " ,
intval ( $importer [ 'uid' ])
);
2011-01-09 22:18:56 +01:00
$a = get_app ();
2016-09-18 23:21:18 +02:00
2016-12-14 09:42:36 +01:00
if ( dbm :: is_result ( $r ) AND ! in_array ( $r [ 0 ][ 'page-flags' ], array ( PAGE_SOAPBOX , PAGE_FREELOVE ))) {
2015-11-28 01:03:26 +01:00
// create notification
$hash = random_string ();
2016-10-22 12:14:41 +02:00
if ( is_array ( $contact_record )) {
2015-11-28 01:03:26 +01:00
$ret = q ( " INSERT INTO `intro` ( `uid`, `contact-id`, `blocked`, `knowyou`, `hash`, `datetime`)
VALUES ( % d , % d , 0 , 0 , '%s' , '%s' ) " ,
intval ( $importer [ 'uid' ]),
intval ( $contact_record [ 'id' ]),
dbesc ( $hash ),
dbesc ( datetime_convert ())
);
}
2012-05-18 07:44:52 +02:00
2016-04-13 22:21:23 +02:00
$def_gid = get_default_group ( $importer [ 'uid' ], $contact_record [ " network " ]);
2016-10-22 12:14:41 +02:00
if ( intval ( $def_gid ))
2016-04-13 22:21:23 +02:00
group_add_member ( $importer [ 'uid' ], '' , $contact_record [ 'id' ], $def_gid );
2012-05-18 07:44:52 +02:00
2016-10-22 12:14:41 +02:00
if (( $r [ 0 ][ 'notify-flags' ] & NOTIFY_INTRO ) &&
2015-11-28 01:03:26 +01:00
in_array ( $r [ 0 ][ 'page-flags' ], array ( PAGE_NORMAL ))) {
2014-09-06 18:15:18 +02:00
notification ( array (
'type' => NOTIFY_INTRO ,
'notify_flags' => $r [ 0 ][ 'notify-flags' ],
'language' => $r [ 0 ][ 'language' ],
'to_name' => $r [ 0 ][ 'username' ],
'to_email' => $r [ 0 ][ 'email' ],
'uid' => $r [ 0 ][ 'uid' ],
2016-12-19 14:26:13 +01:00
'link' => App :: get_baseurl () . '/notifications/intro' ,
2014-09-06 18:15:18 +02:00
'source_name' => (( strlen ( stripslashes ( $contact_record [ 'name' ]))) ? stripslashes ( $contact_record [ 'name' ]) : t ( '[Name Withheld]' )),
'source_link' => $contact_record [ 'url' ],
'source_photo' => $contact_record [ 'photo' ],
'verb' => ( $sharing ? ACTIVITY_FRIEND : ACTIVITY_FOLLOW ),
'otype' => 'intro'
2010-11-06 22:40:19 +01:00
));
2014-09-06 18:15:18 +02:00
2010-11-06 22:40:19 +01:00
}
2016-12-13 10:44:13 +01:00
} elseif ( dbm :: is_result ( $r ) AND in_array ( $r [ 0 ][ 'page-flags' ], array ( PAGE_SOAPBOX , PAGE_FREELOVE ))) {
2015-11-28 01:03:26 +01:00
$r = q ( " UPDATE `contact` SET `pending` = 0 WHERE `uid` = %d AND `url` = '%s' AND `pending` LIMIT 1 " ,
intval ( $importer [ 'uid' ]),
dbesc ( $url )
);
2010-11-06 22:40:19 +01:00
}
2015-11-28 01:03:26 +01:00
2010-10-25 05:39:24 +02:00
}
2010-10-22 06:48:22 +02:00
}
2016-02-05 21:25:20 +01:00
function lose_follower ( $importer , $contact , $datarray = array (), $item = " " ) {
2010-10-22 06:48:22 +02:00
2016-10-22 12:14:41 +02:00
if (( $contact [ 'rel' ] == CONTACT_IS_FRIEND ) || ( $contact [ 'rel' ] == CONTACT_IS_SHARING )) {
2013-11-02 16:13:11 +01:00
q ( " UPDATE `contact` SET `rel` = %d WHERE `id` = %d " ,
2011-08-08 01:15:54 +02:00
intval ( CONTACT_IS_SHARING ),
2010-10-25 05:39:24 +02:00
intval ( $contact [ 'id' ])
);
2016-10-22 12:14:41 +02:00
} else {
2010-10-25 05:39:24 +02:00
contact_remove ( $contact [ 'id' ]);
}
2010-10-22 06:48:22 +02:00
}
2016-02-05 21:25:20 +01:00
function lose_sharer ( $importer , $contact , $datarray = array (), $item = " " ) {
2011-10-03 01:18:01 +02:00
2016-10-22 12:14:41 +02:00
if (( $contact [ 'rel' ] == CONTACT_IS_FRIEND ) || ( $contact [ 'rel' ] == CONTACT_IS_FOLLOWER )) {
2013-11-02 16:13:11 +01:00
q ( " UPDATE `contact` SET `rel` = %d WHERE `id` = %d " ,
2011-10-03 01:18:01 +02:00
intval ( CONTACT_IS_FOLLOWER ),
intval ( $contact [ 'id' ])
);
2016-10-22 12:14:41 +02:00
} else {
2011-10-03 01:18:01 +02:00
contact_remove ( $contact [ 'id' ]);
}
}
2011-10-05 03:53:56 +02:00
function subscribe_to_hub ( $url , $importer , $contact , $hubmode = 'subscribe' ) {
2010-10-01 06:38:45 +02:00
2012-06-07 08:10:32 +02:00
$a = get_app ();
2016-10-22 12:14:41 +02:00
if ( is_array ( $importer )) {
2010-10-01 06:38:45 +02:00
$r = q ( " SELECT `nickname` FROM `user` WHERE `uid` = %d LIMIT 1 " ,
intval ( $importer [ 'uid' ])
);
}
2011-09-22 13:11:39 +02:00
2014-05-12 19:02:03 +02:00
// Diaspora has different message-ids in feeds than they do
2011-09-22 13:11:39 +02:00
// through the direct Diaspora protocol. If we try and use
// the feed, we'll get duplicates. So don't.
2016-12-13 10:44:13 +01:00
if (( ! dbm :: is_result ( $r )) || $contact [ 'network' ] === NETWORK_DIASPORA )
2010-10-01 06:38:45 +02:00
return ;
$push_url = get_config ( 'system' , 'url' ) . '/pubsub/' . $r [ 0 ][ 'nickname' ] . '/' . $contact [ 'id' ];
2010-10-15 13:20:42 +02:00
// Use a single verify token, even if multiple hubs
$verify_token = (( strlen ( $contact [ 'hub-verify' ])) ? $contact [ 'hub-verify' ] : random_string ());
2010-10-01 06:38:45 +02:00
2011-09-22 13:11:39 +02:00
$params = 'hub.mode=' . $hubmode . '&hub.callback=' . urlencode ( $push_url ) . '&hub.topic=' . urlencode ( $contact [ 'poll' ]) . '&hub.verify=async&hub.verify_token=' . $verify_token ;
2010-10-01 06:38:45 +02:00
2011-10-05 03:53:56 +02:00
logger ( 'subscribe_to_hub: ' . $hubmode . ' ' . $contact [ 'name' ] . ' to hub ' . $url . ' endpoint: ' . $push_url . ' with verifier ' . $verify_token );
2010-11-05 04:47:44 +01:00
2016-10-22 12:14:41 +02:00
if ( ! strlen ( $contact [ 'hub-verify' ]) OR ( $contact [ 'hub-verify' ] != $verify_token )) {
2013-11-02 16:13:11 +01:00
$r = q ( " UPDATE `contact` SET `hub-verify` = '%s' WHERE `id` = %d " ,
2010-10-15 13:20:42 +02:00
dbesc ( $verify_token ),
intval ( $contact [ 'id' ])
);
}
2010-10-01 06:38:45 +02:00
2012-06-07 08:10:32 +02:00
post_url ( $url , $params );
logger ( 'subscribe_to_hub: returns: ' . $a -> get_curl_code (), LOGGER_DEBUG );
2013-01-11 01:20:16 +01:00
2010-10-01 06:38:45 +02:00
return ;
2010-11-02 01:56:36 +01:00
}
2012-07-08 00:20:24 +02:00
function fix_private_photos ( $s , $uid , $item = null , $cid = 0 ) {
2013-03-03 17:44:41 +01:00
2016-10-22 12:14:41 +02:00
if ( get_config ( 'system' , 'disable_embedded' ))
2013-03-03 17:44:41 +01:00
return $s ;
2011-05-01 02:24:37 +02:00
$a = get_app ();
2012-05-28 06:01:58 +02:00
2013-03-03 17:44:41 +01:00
logger ( 'fix_private_photos: check for photos' , LOGGER_DEBUG );
2016-12-19 14:26:13 +01:00
$site = substr ( App :: get_baseurl (), strpos ( App :: get_baseurl (), '://' ));
2011-05-01 02:24:37 +02:00
2012-07-08 00:20:24 +02:00
$orig_body = $s ;
$new_body = '' ;
$img_start = strpos ( $orig_body , '[img' );
$img_st_close = ( $img_start !== false ? strpos ( substr ( $orig_body , $img_start ), ']' ) : false );
2012-07-08 02:47:13 +02:00
$img_len = ( $img_start !== false ? strpos ( substr ( $orig_body , $img_start + $img_st_close + 1 ), '[/img]' ) : false );
2012-07-08 00:20:24 +02:00
while ( ( $img_st_close !== false ) && ( $img_len !== false ) ) {
$img_st_close ++ ; // make it point to AFTER the closing bracket
$image = substr ( $orig_body , $img_start + $img_st_close , $img_len );
2012-05-28 06:01:58 +02:00
logger ( 'fix_private_photos: found photo ' . $image , LOGGER_DEBUG );
2012-07-08 00:20:24 +02:00
2016-10-22 12:14:41 +02:00
if ( stristr ( $image , $site . '/photo/' )) {
2012-07-08 00:20:24 +02:00
// Only embed locally hosted photos
2012-05-28 06:01:58 +02:00
$replace = false ;
2011-05-01 02:24:37 +02:00
$i = basename ( $image );
2013-02-08 08:43:55 +01:00
$i = str_replace ( array ( '.jpg' , '.png' , '.gif' ), array ( '' , '' , '' ), $i );
2011-05-01 02:24:37 +02:00
$x = strpos ( $i , '-' );
2012-07-08 00:20:24 +02:00
2016-10-22 12:14:41 +02:00
if ( $x ) {
2011-05-01 02:24:37 +02:00
$res = substr ( $i , $x + 1 );
$i = substr ( $i , 0 , $x );
$r = q ( " SELECT * FROM `photo` WHERE `resource-id` = '%s' AND `scale` = %d AND `uid` = %d " ,
dbesc ( $i ),
intval ( $res ),
intval ( $uid )
);
2016-10-22 12:14:41 +02:00
if ( $r ) {
2012-05-28 06:01:58 +02:00
// Check to see if we should replace this photo link with an embedded image
// 1. No need to do so if the photo is public
// 2. If there's a contact-id provided, see if they're in the access list
2014-05-12 19:02:03 +02:00
// for the photo. If so, embed it.
2012-05-28 06:01:58 +02:00
// 3. Otherwise, if we have an item, see if the item permissions match the photo
// permissions, regardless of order but first check to see if they're an exact
// match to save some processing overhead.
2016-10-22 12:14:41 +02:00
if ( has_permissions ( $r [ 0 ])) {
if ( $cid ) {
2012-05-28 06:01:58 +02:00
$recips = enumerate_permissions ( $r [ 0 ]);
2016-10-22 12:14:41 +02:00
if ( in_array ( $cid , $recips )) {
2014-05-12 19:02:03 +02:00
$replace = true ;
2012-05-28 06:01:58 +02:00
}
2016-10-22 12:14:41 +02:00
} elseif ( $item ) {
if ( compare_permissions ( $item , $r [ 0 ]))
2012-05-28 06:01:58 +02:00
$replace = true ;
}
}
2016-10-22 12:14:41 +02:00
if ( $replace ) {
2012-07-08 00:20:24 +02:00
$data = $r [ 0 ][ 'data' ];
$type = $r [ 0 ][ 'type' ];
// If a custom width and height were specified, apply before embedding
2016-10-22 12:14:41 +02:00
if ( preg_match ( " / \ [img \ =([0-9]*)x([0-9]*) \ ]/is " , substr ( $orig_body , $img_start , $img_st_close ), $match )) {
2012-07-08 00:20:24 +02:00
logger ( 'fix_private_photos: scaling photo' , LOGGER_DEBUG );
$width = intval ( $match [ 1 ]);
$height = intval ( $match [ 2 ]);
$ph = new Photo ( $data , $type );
2016-10-22 12:14:41 +02:00
if ( $ph -> is_valid ()) {
2012-07-08 00:20:24 +02:00
$ph -> scaleImage ( max ( $width , $height ));
$data = $ph -> imageString ();
$type = $ph -> getType ();
}
}
2012-05-29 01:51:52 +02:00
logger ( 'fix_private_photos: replacing photo' , LOGGER_DEBUG );
2012-07-08 00:20:24 +02:00
$image = 'data:' . $type . ';base64,' . base64_encode ( $data );
logger ( 'fix_private_photos: replaced: ' . $image , LOGGER_DATA );
2012-05-28 06:01:58 +02:00
}
2011-05-01 02:24:37 +02:00
}
}
2014-05-12 19:02:03 +02:00
}
2012-07-08 00:20:24 +02:00
$new_body = $new_body . substr ( $orig_body , 0 , $img_start + $img_st_close ) . $image . '[/img]' ;
$orig_body = substr ( $orig_body , $img_start + $img_st_close + $img_len + strlen ( '[/img]' ));
2016-10-22 12:14:41 +02:00
if ( $orig_body === false )
2012-07-08 00:20:24 +02:00
$orig_body = '' ;
$img_start = strpos ( $orig_body , '[img' );
$img_st_close = ( $img_start !== false ? strpos ( substr ( $orig_body , $img_start ), ']' ) : false );
2012-07-08 02:47:13 +02:00
$img_len = ( $img_start !== false ? strpos ( substr ( $orig_body , $img_start + $img_st_close + 1 ), '[/img]' ) : false );
2011-05-01 02:24:37 +02:00
}
2012-07-08 00:20:24 +02:00
2012-07-08 02:47:13 +02:00
$new_body = $new_body . $orig_body ;
2012-07-08 00:20:24 +02:00
return ( $new_body );
2011-05-01 02:24:37 +02:00
}
2012-05-28 06:01:58 +02:00
function has_permissions ( $obj ) {
2016-10-22 12:14:41 +02:00
if (( $obj [ 'allow_cid' ] != '' ) || ( $obj [ 'allow_gid' ] != '' ) || ( $obj [ 'deny_cid' ] != '' ) || ( $obj [ 'deny_gid' ] != '' ))
2012-05-28 06:01:58 +02:00
return true ;
return false ;
}
function compare_permissions ( $obj1 , $obj2 ) {
2014-05-12 19:02:03 +02:00
// first part is easy. Check that these are exactly the same.
2016-10-22 12:14:41 +02:00
if (( $obj1 [ 'allow_cid' ] == $obj2 [ 'allow_cid' ])
2012-05-28 06:01:58 +02:00
&& ( $obj1 [ 'allow_gid' ] == $obj2 [ 'allow_gid' ])
&& ( $obj1 [ 'deny_cid' ] == $obj2 [ 'deny_cid' ])
&& ( $obj1 [ 'deny_gid' ] == $obj2 [ 'deny_gid' ]))
return true ;
// This is harder. Parse all the permissions and compare the resulting set.
$recipients1 = enumerate_permissions ( $obj1 );
$recipients2 = enumerate_permissions ( $obj2 );
sort ( $recipients1 );
sort ( $recipients2 );
2016-10-22 12:14:41 +02:00
if ( $recipients1 == $recipients2 )
2012-05-28 06:01:58 +02:00
return true ;
return false ;
}
// returns an array of contact-ids that are allowed to see this object
function enumerate_permissions ( $obj ) {
$allow_people = expand_acl ( $obj [ 'allow_cid' ]);
$allow_groups = expand_groups ( expand_acl ( $obj [ 'allow_gid' ]));
$deny_people = expand_acl ( $obj [ 'deny_cid' ]);
$deny_groups = expand_groups ( expand_acl ( $obj [ 'deny_gid' ]));
$recipients = array_unique ( array_merge ( $allow_people , $allow_groups ));
$deny = array_unique ( array_merge ( $deny_people , $deny_groups ));
$recipients = array_diff ( $recipients , $deny );
return $recipients ;
}
2011-05-01 02:24:37 +02:00
2011-04-06 02:41:02 +02:00
function item_getfeedtags ( $item ) {
$ret = array ();
$matches = false ;
2011-06-08 07:13:07 +02:00
$cnt = preg_match_all ( '|\#\[url\=(.*?)\](.*?)\[\/url\]|' , $item [ 'tag' ], $matches );
2016-10-22 12:14:41 +02:00
if ( $cnt ) {
2011-11-12 11:53:53 +01:00
for ( $x = 0 ; $x < $cnt ; $x ++ ) {
2016-10-22 12:14:41 +02:00
if ( $matches [ 1 ][ $x ])
2015-11-27 23:16:54 +01:00
$ret [ $matches [ 2 ][ $x ]] = array ( '#' , $matches [ 1 ][ $x ], $matches [ 2 ][ $x ]);
2011-04-06 02:41:02 +02:00
}
}
2014-05-12 19:02:03 +02:00
$matches = false ;
2011-06-08 07:13:07 +02:00
$cnt = preg_match_all ( '|\@\[url\=(.*?)\](.*?)\[\/url\]|' , $item [ 'tag' ], $matches );
2016-10-22 12:14:41 +02:00
if ( $cnt ) {
2011-11-12 11:53:53 +01:00
for ( $x = 0 ; $x < $cnt ; $x ++ ) {
2016-10-22 12:14:41 +02:00
if ( $matches [ 1 ][ $x ])
2011-10-25 05:33:54 +02:00
$ret [] = array ( '@' , $matches [ 1 ][ $x ], $matches [ 2 ][ $x ]);
2011-04-06 02:41:02 +02:00
}
2014-05-12 19:02:03 +02:00
}
2011-04-06 02:41:02 +02:00
return $ret ;
}
2014-06-02 23:41:33 +02:00
function item_expire ( $uid , $days , $network = " " , $force = false ) {
2011-03-16 01:31:49 +01:00
2016-10-22 12:14:41 +02:00
if (( ! $uid ) || ( $days < 1 ))
2011-03-16 01:31:49 +01:00
return ;
2012-05-29 08:24:10 +02:00
// $expire_network_only = save your own wall posts
// and just expire conversations started by others
2012-05-29 10:14:53 +02:00
$expire_network_only = get_pconfig ( $uid , 'expire' , 'network_only' );
2012-05-29 08:24:10 +02:00
$sql_extra = (( intval ( $expire_network_only )) ? " AND wall = 0 " : " " );
2014-06-02 23:41:33 +02:00
if ( $network != " " ) {
$sql_extra .= sprintf ( " AND network = '%s' " , dbesc ( $network ));
// There is an index "uid_network_received" but not "uid_network_created"
// This avoids the creation of another index just for one purpose.
// And it doesn't really matter wether to look at "received" or "created"
$range = " AND `received` < UTC_TIMESTAMP() - INTERVAL %d DAY " ;
} else
$range = " AND `created` < UTC_TIMESTAMP() - INTERVAL %d DAY " ;
2016-08-03 15:59:25 +02:00
$r = q ( " SELECT `file`, `resource-id`, `starred`, `type`, `id` FROM `item`
2014-06-02 23:41:33 +02:00
WHERE `uid` = % d $range
2014-05-12 19:02:03 +02:00
AND `id` = `parent`
2012-05-29 08:24:10 +02:00
$sql_extra
2011-03-16 01:31:49 +01:00
AND `deleted` = 0 " ,
intval ( $uid ),
intval ( $days )
);
2016-12-13 10:44:13 +01:00
if ( ! dbm :: is_result ( $r ))
2011-03-16 01:31:49 +01:00
return ;
2011-11-17 15:53:59 +01:00
$expire_items = get_pconfig ( $uid , 'expire' , 'items' );
$expire_items = (( $expire_items === false ) ? 1 : intval ( $expire_items )); // default if not set: 1
2013-01-11 01:20:16 +01:00
2014-06-02 23:41:33 +02:00
// Forcing expiring of items - but not notes and marked items
if ( $force )
$expire_items = true ;
2011-11-17 15:53:59 +01:00
$expire_notes = get_pconfig ( $uid , 'expire' , 'notes' );
$expire_notes = (( $expire_notes === false ) ? 1 : intval ( $expire_notes )); // default if not set: 1
2011-11-22 04:01:05 +01:00
$expire_starred = get_pconfig ( $uid , 'expire' , 'starred' );
$expire_starred = (( $expire_starred === false ) ? 1 : intval ( $expire_starred )); // default if not set: 1
2013-01-11 01:20:16 +01:00
2011-11-17 15:53:59 +01:00
$expire_photos = get_pconfig ( $uid , 'expire' , 'photos' );
$expire_photos = (( $expire_photos === false ) ? 0 : intval ( $expire_photos )); // default if not set: 0
2013-01-11 01:20:16 +01:00
2011-11-22 04:01:05 +01:00
logger ( 'expire: # items=' . count ( $r ) . " ; expire items: $expire_items , expire notes: $expire_notes , expire starred: $expire_starred , expire photos: $expire_photos " );
2011-03-16 01:31:49 +01:00
foreach ( $r as $item ) {
2012-03-27 09:54:34 +02:00
// don't expire filed items
2016-10-22 12:14:41 +02:00
if ( strpos ( $item [ 'file' ], '[' ) !== false )
2012-03-27 09:54:34 +02:00
continue ;
2011-03-16 01:31:49 +01:00
// Only expire posts, not photos and photo comments
2016-10-22 12:14:41 +02:00
if ( $expire_photos == 0 && strlen ( $item [ 'resource-id' ]))
2011-11-17 15:53:59 +01:00
continue ;
2016-10-22 12:14:41 +02:00
if ( $expire_starred == 0 && intval ( $item [ 'starred' ]))
2011-11-22 04:01:05 +01:00
continue ;
2016-10-22 12:14:41 +02:00
if ( $expire_notes == 0 && $item [ 'type' ] == 'note' )
2011-03-16 01:31:49 +01:00
continue ;
2016-10-22 12:14:41 +02:00
if ( $expire_items == 0 && $item [ 'type' ] != 'note' )
2011-11-17 15:53:59 +01:00
continue ;
2012-05-05 16:05:32 +02:00
drop_item ( $item [ 'id' ], false );
2011-03-16 01:31:49 +01:00
}
2016-08-01 07:48:43 +02:00
proc_run ( PRIORITY_HIGH , " include/notifier.php " , " expire " , $uid );
2014-05-12 19:02:03 +02:00
2011-06-11 05:39:46 +02:00
}
2011-06-16 05:43:39 +02:00
function drop_items ( $items ) {
$uid = 0 ;
2016-10-22 12:14:41 +02:00
if ( ! local_user () && ! remote_user ())
2012-01-25 03:59:55 +01:00
return ;
2016-10-22 12:14:41 +02:00
if ( count ( $items )) {
2011-06-16 05:43:39 +02:00
foreach ( $items as $item ) {
$owner = drop_item ( $item , false );
2016-10-22 12:14:41 +02:00
if ( $owner && ! $uid )
2011-06-16 05:43:39 +02:00
$uid = $owner ;
}
}
// multiple threads may have been deleted, send an expire notification
2016-10-22 12:14:41 +02:00
if ( $uid )
2016-08-01 07:48:43 +02:00
proc_run ( PRIORITY_HIGH , " include/notifier.php " , " expire " , $uid );
2011-06-16 05:43:39 +02:00
}
function drop_item ( $id , $interactive = true ) {
$a = get_app ();
// locate item to be deleted
$r = q ( " SELECT * FROM `item` WHERE `id` = %d LIMIT 1 " ,
intval ( $id )
);
2016-12-13 10:44:13 +01:00
if ( ! dbm :: is_result ( $r )) {
2016-10-22 12:14:41 +02:00
if ( ! $interactive )
2011-06-16 05:43:39 +02:00
return 0 ;
notice ( t ( 'Item not found.' ) . EOL );
2016-12-19 14:26:13 +01:00
goaway ( App :: get_baseurl () . '/' . $_SESSION [ 'return_url' ]);
2011-06-16 05:43:39 +02:00
}
$item = $r [ 0 ];
$owner = $item [ 'uid' ];
2016-11-14 18:49:51 +01:00
$contact_id = 0 ;
2012-09-05 07:50:28 +02:00
2011-06-16 05:43:39 +02:00
// check if logged in user is either the author or owner of this item
2016-10-22 12:14:41 +02:00
if ( is_array ( $_SESSION [ 'remote' ])) {
2012-09-05 07:50:28 +02:00
foreach ( $_SESSION [ 'remote' ] as $visitor ) {
2016-10-22 12:14:41 +02:00
if ( $visitor [ 'uid' ] == $item [ 'uid' ] && $visitor [ 'cid' ] == $item [ 'contact-id' ]) {
2016-11-14 18:49:51 +01:00
$contact_id = $visitor [ 'cid' ];
2012-09-05 07:50:28 +02:00
break ;
}
}
}
2016-11-14 18:49:51 +01:00
if (( local_user () == $item [ 'uid' ]) || ( $contact_id ) || ( ! $interactive )) {
2011-06-16 05:43:39 +02:00
2013-01-26 20:52:21 +01:00
// Check if we should do HTML-based delete confirmation
2016-10-22 12:14:41 +02:00
if ( $_REQUEST [ 'confirm' ]) {
2013-01-26 20:52:21 +01:00
// <form> can't take arguments in its "action" parameter
// so add any arguments as hidden inputs
$query = explode_querystring ( $a -> query_string );
$inputs = array ();
foreach ( $query [ 'args' ] as $arg ) {
2016-10-22 12:14:41 +02:00
if ( strpos ( $arg , 'confirm=' ) === false ) {
2013-01-26 20:52:21 +01:00
$arg_parts = explode ( '=' , $arg );
$inputs [] = array ( 'name' => $arg_parts [ 0 ], 'value' => $arg_parts [ 1 ]);
}
}
return replace_macros ( get_markup_template ( 'confirm.tpl' ), array (
'$method' => 'get' ,
'$message' => t ( 'Do you really want to delete this item?' ),
'$extra_inputs' => $inputs ,
'$confirm' => t ( 'Yes' ),
'$confirm_url' => $query [ 'base' ],
'$confirm_name' => 'confirmed' ,
'$cancel' => t ( 'Cancel' ),
));
}
// Now check how the user responded to the confirmation query
2016-10-22 12:14:41 +02:00
if ( $_REQUEST [ 'canceled' ]) {
2016-12-19 14:26:13 +01:00
goaway ( App :: get_baseurl () . '/' . $_SESSION [ 'return_url' ]);
2013-01-26 20:52:21 +01:00
}
2012-08-06 06:43:20 +02:00
logger ( 'delete item: ' . $item [ 'id' ], LOGGER_DEBUG );
2011-06-16 05:43:39 +02:00
// delete the item
2013-11-02 16:13:11 +01:00
$r = q ( " UPDATE `item` SET `deleted` = 1, `title` = '', `body` = '', `edited` = '%s', `changed` = '%s' WHERE `id` = %d " ,
2011-06-16 05:43:39 +02:00
dbesc ( datetime_convert ()),
dbesc ( datetime_convert ()),
intval ( $item [ 'id' ])
);
2013-01-11 01:20:16 +01:00
create_tags_from_item ( $item [ 'id' ]);
2014-03-16 17:12:56 +01:00
create_files_from_item ( $item [ 'id' ]);
2015-01-07 01:46:13 +01:00
delete_thread ( $item [ 'id' ], $item [ 'parent-uri' ]);
2011-06-16 05:43:39 +02:00
2012-05-05 16:05:32 +02:00
// clean up categories and tags so they don't end up as orphans
$matches = false ;
$cnt = preg_match_all ( '/<(.*?)>/' , $item [ 'file' ], $matches , PREG_SET_ORDER );
2016-10-22 12:14:41 +02:00
if ( $cnt ) {
2012-05-05 16:05:32 +02:00
foreach ( $matches as $mtch ) {
file_tag_unsave_file ( $item [ 'uid' ], $item [ 'id' ], $mtch [ 1 ], true );
}
}
$matches = false ;
$cnt = preg_match_all ( '/\[(.*?)\]/' , $item [ 'file' ], $matches , PREG_SET_ORDER );
2016-10-22 12:14:41 +02:00
if ( $cnt ) {
2012-05-05 16:05:32 +02:00
foreach ( $matches as $mtch ) {
file_tag_unsave_file ( $item [ 'uid' ], $item [ 'id' ], $mtch [ 1 ], false );
}
}
2014-05-12 19:02:03 +02:00
// If item is a link to a photo resource, nuke all the associated photos
2011-06-16 05:43:39 +02:00
// (visitors will not have photo resources)
// This only applies to photos uploaded from the photos page. Photos inserted into a post do not
2014-05-12 19:02:03 +02:00
// generate a resource-id and therefore aren't intimately linked to the item.
2011-06-16 05:43:39 +02:00
2016-10-22 12:14:41 +02:00
if ( strlen ( $item [ 'resource-id' ])) {
2011-06-16 05:43:39 +02:00
q ( " DELETE FROM `photo` WHERE `resource-id` = '%s' AND `uid` = %d " ,
dbesc ( $item [ 'resource-id' ]),
intval ( $item [ 'uid' ])
);
// ignore the result
}
// If item is a link to an event, nuke the event record.
2016-10-22 12:14:41 +02:00
if ( intval ( $item [ 'event-id' ])) {
2013-11-02 16:13:11 +01:00
q ( " DELETE FROM `event` WHERE `id` = %d AND `uid` = %d " ,
2011-06-16 05:43:39 +02:00
intval ( $item [ 'event-id' ]),
intval ( $item [ 'uid' ])
);
// ignore the result
}
2015-05-23 22:35:02 +02:00
// If item has attachments, drop them
foreach ( explode ( " , " , $item [ 'attach' ]) as $attach ){
preg_match ( " |attach/( \ d+)| " , $attach , $matches );
q ( " DELETE FROM `attach` WHERE `id` = %d AND `uid` = %d " ,
intval ( $matches [ 1 ]),
local_user ()
);
// ignore the result
}
2012-05-05 16:05:32 +02:00
// clean up item_id and sign meta-data tables
2013-11-02 10:49:44 +01:00
/*
// Old code - caused very long queries and warning entries in the mysql logfiles:
2012-05-05 16:05:32 +02:00
$r = q ( " DELETE FROM item_id where iid in (select id from item where parent = %d and uid = %d) " ,
intval ( $item [ 'id' ]),
intval ( $item [ 'uid' ])
);
$r = q ( " DELETE FROM sign where iid in (select id from item where parent = %d and uid = %d) " ,
intval ( $item [ 'id' ]),
intval ( $item [ 'uid' ])
);
2013-11-02 10:49:44 +01:00
*/
// The new code splits the queries since the mysql optimizer really has bad problems with subqueries
// Creating list of parents
$r = q ( " select id from item where parent = %d and uid = %d " ,
intval ( $item [ 'id' ]),
intval ( $item [ 'uid' ])
);
$parentid = " " ;
foreach ( $r AS $row ) {
if ( $parentid != " " )
$parentid .= " , " ;
$parentid .= $row [ " id " ];
}
// Now delete them
if ( $parentid != " " ) {
$r = q ( " DELETE FROM item_id where iid in (%s) " , dbesc ( $parentid ));
$r = q ( " DELETE FROM sign where iid in (%s) " , dbesc ( $parentid ));
}
2011-06-16 05:43:39 +02:00
// If it's the parent of a comment thread, kill all the kids
2016-10-22 12:14:41 +02:00
if ( $item [ 'uri' ] == $item [ 'parent-uri' ]) {
2012-02-10 00:58:26 +01:00
$r = q ( " UPDATE `item` SET `deleted` = 1, `edited` = '%s', `changed` = '%s', `body` = '' , `title` = ''
2011-06-16 05:43:39 +02:00
WHERE `parent-uri` = '%s' AND `uid` = % d " ,
dbesc ( datetime_convert ()),
dbesc ( datetime_convert ()),
dbesc ( $item [ 'parent-uri' ]),
intval ( $item [ 'uid' ])
);
2015-02-09 23:04:18 +01:00
create_tags_from_itemuri ( $item [ 'parent-uri' ], $item [ 'uid' ]);
create_files_from_itemuri ( $item [ 'parent-uri' ], $item [ 'uid' ]);
2014-03-09 09:19:14 +01:00
delete_thread_uri ( $item [ 'parent-uri' ], $item [ 'uid' ]);
2011-06-16 05:43:39 +02:00
// ignore the result
2016-10-22 12:14:41 +02:00
} else {
2011-06-16 05:43:39 +02:00
// ensure that last-child is set in case the comment that had it just got wiped.
q ( " UPDATE `item` SET `last-child` = 0, `changed` = '%s' WHERE `parent-uri` = '%s' AND `uid` = %d " ,
dbesc ( datetime_convert ()),
dbesc ( $item [ 'parent-uri' ]),
intval ( $item [ 'uid' ])
);
2013-01-11 01:20:16 +01:00
// who is the last child now?
2011-06-16 05:43:39 +02:00
$r = q ( " SELECT `id` FROM `item` WHERE `parent-uri` = '%s' AND `type` != 'activity' AND `deleted` = 0 AND `uid` = %d ORDER BY `edited` DESC LIMIT 1 " ,
dbesc ( $item [ 'parent-uri' ]),
intval ( $item [ 'uid' ])
);
2016-12-14 09:42:36 +01:00
if ( dbm :: is_result ( $r )) {
2013-11-02 16:13:11 +01:00
q ( " UPDATE `item` SET `last-child` = 1 WHERE `id` = %d " ,
2011-06-16 05:43:39 +02:00
intval ( $r [ 0 ][ 'id' ])
);
2012-06-01 03:40:12 +02:00
}
2011-06-16 05:43:39 +02:00
}
2015-05-23 22:35:02 +02:00
2011-06-16 05:43:39 +02:00
$drop_id = intval ( $item [ 'id' ]);
2012-05-05 16:05:32 +02:00
2011-06-16 05:43:39 +02:00
// send the notification upstream/downstream as the case may be
2016-08-01 07:48:43 +02:00
proc_run ( PRIORITY_HIGH , " include/notifier.php " , " drop " , $drop_id );
2012-11-02 00:42:40 +01:00
2016-10-22 12:14:41 +02:00
if ( ! $interactive )
2011-06-16 05:43:39 +02:00
return $owner ;
2016-12-19 14:26:13 +01:00
goaway ( App :: get_baseurl () . '/' . $_SESSION [ 'return_url' ]);
2011-06-16 05:43:39 +02:00
//NOTREACHED
2016-10-22 12:14:41 +02:00
} else {
if ( ! $interactive )
2011-06-16 05:43:39 +02:00
return 0 ;
notice ( t ( 'Permission denied.' ) . EOL );
2016-12-19 14:26:13 +01:00
goaway ( App :: get_baseurl () . '/' . $_SESSION [ 'return_url' ]);
2011-06-16 05:43:39 +02:00
//NOTREACHED
}
2013-01-11 01:20:16 +01:00
2011-10-23 09:24:37 +02:00
}
2012-06-13 05:46:30 +02:00
function first_post_date ( $uid , $wall = false ) {
2014-03-09 09:19:14 +01:00
$r = q ( " select id, created from item
where uid = % d and wall = % d and deleted = 0 and visible = 1 AND moderated = 0
2012-06-13 06:38:10 +02:00
and id = parent
2012-06-13 05:46:30 +02:00
order by created asc limit 1 " ,
intval ( $uid ),
intval ( $wall ? 1 : 0 )
);
2016-12-14 09:42:36 +01:00
if ( dbm :: is_result ( $r )) {
2012-06-13 06:39:39 +02:00
// logger('first_post_date: ' . $r[0]['id'] . ' ' . $r[0]['created'], LOGGER_DATA);
2012-06-13 07:52:34 +02:00
return substr ( datetime_convert ( '' , date_default_timezone_get (), $r [ 0 ][ 'created' ]), 0 , 10 );
2012-06-13 06:34:28 +02:00
}
2012-06-13 05:46:30 +02:00
return false ;
}
2015-05-19 01:03:08 +02:00
/* modified posted_dates() {below} to arrange the list in years */
function list_post_dates ( $uid , $wall ) {
$dnow = datetime_convert ( '' , date_default_timezone_get (), 'now' , 'Y-m-d' );
2015-06-02 18:59:46 +02:00
$dthen = first_post_date ( $uid , $wall );
2016-10-22 12:14:41 +02:00
if ( ! $dthen )
2015-05-19 01:03:08 +02:00
return array ();
2015-06-02 18:59:46 +02:00
2015-05-19 01:03:08 +02:00
// Set the start and end date to the beginning of the month
2015-06-06 13:15:37 +02:00
$dnow = substr ( $dnow , 0 , 8 ) . '01' ;
2015-05-19 01:03:08 +02:00
$dthen = substr ( $dthen , 0 , 8 ) . '01' ;
2015-06-02 18:59:46 +02:00
2015-05-19 01:03:08 +02:00
$ret = array ();
2015-06-02 18:59:46 +02:00
2015-05-19 01:03:08 +02:00
// Starting with the current month, get the first and last days of every
// month down to and including the month of the first post
while ( substr ( $dnow , 0 , 7 ) >= substr ( $dthen , 0 , 7 )) {
$dyear = intval ( substr ( $dnow , 0 , 4 ));
$dstart = substr ( $dnow , 0 , 8 ) . '01' ;
$dend = substr ( $dnow , 0 , 8 ) . get_dim ( intval ( $dnow ), intval ( substr ( $dnow , 5 )));
$start_month = datetime_convert ( '' , '' , $dstart , 'Y-m-d' );
$end_month = datetime_convert ( '' , '' , $dend , 'Y-m-d' );
$str = day_translate ( datetime_convert ( '' , '' , $dnow , 'F' ));
2016-10-22 12:14:41 +02:00
if ( ! $ret [ $dyear ])
2015-05-19 01:03:08 +02:00
$ret [ $dyear ] = array ();
2015-06-06 13:15:37 +02:00
$ret [ $dyear ][] = array ( $str , $end_month , $start_month );
2015-05-19 01:03:08 +02:00
$dnow = datetime_convert ( '' , '' , $dnow . ' -1 month' , 'Y-m-d' );
}
return $ret ;
}
2012-06-13 05:46:30 +02:00
function posted_dates ( $uid , $wall ) {
2012-06-13 07:52:34 +02:00
$dnow = datetime_convert ( '' , date_default_timezone_get (), 'now' , 'Y-m-d' );
2012-06-13 05:46:30 +02:00
$dthen = first_post_date ( $uid , $wall );
2016-10-22 12:14:41 +02:00
if ( ! $dthen )
2012-06-13 05:46:30 +02:00
return array ();
2014-09-03 01:43:04 +02:00
// Set the start and end date to the beginning of the month
$dnow = substr ( $dnow , 0 , 8 ) . '01' ;
$dthen = substr ( $dthen , 0 , 8 ) . '01' ;
2012-06-13 07:52:34 +02:00
2012-06-13 05:46:30 +02:00
$ret = array ();
2012-07-08 16:46:46 +02:00
// Starting with the current month, get the first and last days of every
// month down to and including the month of the first post
while ( substr ( $dnow , 0 , 7 ) >= substr ( $dthen , 0 , 7 )) {
2012-06-14 05:59:19 +02:00
$dstart = substr ( $dnow , 0 , 8 ) . '01' ;
$dend = substr ( $dnow , 0 , 8 ) . get_dim ( intval ( $dnow ), intval ( substr ( $dnow , 5 )));
$start_month = datetime_convert ( '' , '' , $dstart , 'Y-m-d' );
$end_month = datetime_convert ( '' , '' , $dend , 'Y-m-d' );
2012-06-13 05:46:30 +02:00
$str = day_translate ( datetime_convert ( '' , '' , $dnow , 'F Y' ));
2014-06-15 23:33:25 +02:00
$ret [] = array ( $str , $end_month , $start_month );
2012-06-13 05:46:30 +02:00
$dnow = datetime_convert ( '' , '' , $dnow . ' -1 month' , 'Y-m-d' );
}
return $ret ;
}
function posted_date_widget ( $url , $uid , $wall ) {
$o = '' ;
2012-06-14 01:17:45 +02:00
2016-10-22 12:14:41 +02:00
if ( ! feature_enabled ( $uid , 'archives' ))
2012-11-22 17:14:22 +01:00
return $o ;
2012-06-14 01:17:45 +02:00
// For former Facebook folks that left because of "timeline"
2016-10-22 12:14:41 +02:00
/* if ( $wall && intval ( get_pconfig ( $uid , 'system' , 'no_wall_archive_widget' )))
2012-11-22 17:14:22 +01:00
return $o ; */
2015-06-02 18:59:46 +02:00
2015-05-19 01:03:08 +02:00
$visible_years = get_pconfig ( $uid , 'system' , 'archive_visible_years' );
2016-10-22 12:14:41 +02:00
if ( ! $visible_years )
2015-06-02 18:59:46 +02:00
$visible_years = 5 ;
2015-06-06 13:15:37 +02:00
$ret = list_post_dates ( $uid , $wall );
2015-06-02 18:59:46 +02:00
2016-12-19 14:42:20 +01:00
if ( ! dbm :: is_result ( $ret ))
2012-06-13 05:46:30 +02:00
return $o ;
2015-06-06 13:15:37 +02:00
$cutoff_year = intval ( datetime_convert ( '' , date_default_timezone_get (), 'now' , 'Y' )) - $visible_years ;
2015-05-19 01:03:08 +02:00
$cutoff = (( array_key_exists ( $cutoff_year , $ret )) ? true : false );
2015-06-02 18:59:46 +02:00
2012-06-13 05:46:30 +02:00
$o = replace_macros ( get_markup_template ( 'posted_date_widget.tpl' ), array (
'$title' => t ( 'Archives' ),
2015-05-19 01:03:08 +02:00
'$size' => $visible_years ,
'$cutoff_year' => $cutoff_year ,
'$cutoff' => $cutoff ,
2012-06-13 05:46:30 +02:00
'$url' => $url ,
2015-05-19 01:03:08 +02:00
'$dates' => $ret ,
2015-06-06 13:15:37 +02:00
'$showmore' => t ( 'show more' )
2015-05-19 01:03:08 +02:00
2012-06-13 05:46:30 +02:00
));
return $o ;
2012-06-29 21:40:54 +02:00
}