Move Cache to src

relocate the cache class to Friendica\Core namespace
This commit is contained in:
Adam Magness 2017-11-09 11:05:18 -05:00
parent 8b673bf78d
commit 06c3af9b60
21 changed files with 1177 additions and 728 deletions

548
boot.php

File diff suppressed because it is too large Load Diff

View File

@ -5,6 +5,7 @@
*/ */
use Friendica\App; use Friendica\App;
use Friendica\Core\Cache;
use Friendica\Core\Config; use Friendica\Core\Config;
use Friendica\Core\System; use Friendica\Core\System;
use Friendica\Database\DBM; use Friendica\Database\DBM;

View File

@ -1,6 +1,7 @@
<?php <?php
use Friendica\App; use Friendica\App;
use Friendica\Core\Cache;
use Friendica\Core\System; use Friendica\Core\System;
use Friendica\Core\Config; use Friendica\Core\Config;

View File

@ -1,6 +1,7 @@
<?php <?php
use Friendica\App; use Friendica\App;
use Friendica\Core\Cache;
use Friendica\Core\Config; use Friendica\Core\Config;
use Friendica\Database\DBM; use Friendica\Database\DBM;
use Friendica\Network\Probe; use Friendica\Network\Probe;

View File

@ -1,5 +1,5 @@
<?php <?php
use Friendica\Core\Cache;
use Friendica\Core\Config; use Friendica\Core\Config;
use Friendica\Core\Worker; use Friendica\Core\Worker;
use Friendica\Database\DBM; use Friendica\Database\DBM;

View File

@ -1,5 +1,5 @@
<?php <?php
use Friendica\Core\Cache;
use Friendica\Core\Config; use Friendica\Core\Config;
use Friendica\Database\DBM; use Friendica\Database\DBM;
use Friendica\Network\Probe; use Friendica\Network\Probe;

View File

@ -4,6 +4,7 @@
*/ */
use Friendica\App; use Friendica\App;
use Friendica\Core\Cache;
use Friendica\Core\Config; use Friendica\Core\Config;
use Friendica\Core\PConfig; use Friendica\Core\PConfig;
use Friendica\Core\System; use Friendica\Core\System;
@ -13,7 +14,6 @@ use Friendica\Database\DBM;
require_once 'include/ForumManager.php'; require_once 'include/ForumManager.php';
require_once 'include/bbcode.php'; require_once 'include/bbcode.php';
require_once 'mod/proxy.php'; require_once 'mod/proxy.php';
require_once 'include/cache.php';
/** /**
* *
@ -34,20 +34,21 @@ require_once 'include/cache.php';
* the theme is chosen before the _init() function of a theme is run, which will usually * the theme is chosen before the _init() function of a theme is run, which will usually
* load a lot of theme-specific content * load a lot of theme-specific content
* *
* @param App $a * @param object $a App
* @param string $nickname * @param string $nickname string
* @param int $profile * @param int $profile int
* @param array $profiledata * @param array $profiledata array
*/ */
function profile_load(App $a, $nickname, $profile = 0, $profiledata = array()) { function profile_load(App $a, $nickname, $profile = 0, $profiledata = array())
{
$user = q("SELECT `uid` FROM `user` WHERE `nickname` = '%s' LIMIT 1", $user = q(
"SELECT `uid` FROM `user` WHERE `nickname` = '%s' LIMIT 1",
dbesc($nickname) dbesc($nickname)
); );
if (!$user && count($user) && !count($profiledata)) { if (!$user && count($user) && !count($profiledata)) {
logger('profile error: ' . $a->query_string, LOGGER_DEBUG); logger('profile error: ' . $a->query_string, LOGGER_DEBUG);
notice( t('Requested account is not available.') . EOL ); notice(t('Requested account is not available.') . EOL);
$a->error = 404; $a->error = 404;
return; return;
} }
@ -56,7 +57,7 @@ function profile_load(App $a, $nickname, $profile = 0, $profiledata = array()) {
if (empty($pdata) && empty($profiledata)) { if (empty($pdata) && empty($profiledata)) {
logger('profile error: ' . $a->query_string, LOGGER_DEBUG); logger('profile error: ' . $a->query_string, LOGGER_DEBUG);
notice( t('Requested profile is not available.') . EOL ); notice(t('Requested profile is not available.') . EOL);
$a->error = 404; $a->error = 404;
return; return;
} }
@ -64,7 +65,8 @@ function profile_load(App $a, $nickname, $profile = 0, $profiledata = array()) {
// fetch user tags if this isn't the default profile // fetch user tags if this isn't the default profile
if (!$pdata['is-default']) { if (!$pdata['is-default']) {
$x = q("SELECT `pub_keywords` FROM `profile` WHERE `uid` = %d AND `is-default` = 1 LIMIT 1", $x = q(
"SELECT `pub_keywords` FROM `profile` WHERE `uid` = %d AND `is-default` = 1 LIMIT 1",
intval($pdata['profile_uid']) intval($pdata['profile_uid'])
); );
if ($x && count($x)) if ($x && count($x))
@ -79,8 +81,9 @@ function profile_load(App $a, $nickname, $profile = 0, $profiledata = array()) {
$a->page['title'] = $a->profile['name'] . " @ " . $a->config['sitename']; $a->page['title'] = $a->profile['name'] . " @ " . $a->config['sitename'];
if (!$profiledata && !PConfig::get(local_user(),'system','always_my_theme')) if (!$profiledata && !PConfig::get(local_user(), 'system', 'always_my_theme')) {
$_SESSION['theme'] = $a->profile['theme']; $_SESSION['theme'] = $a->profile['theme'];
}
$_SESSION['mobile-theme'] = $a->profile['mobile-theme']; $_SESSION['mobile-theme'] = $a->profile['mobile-theme'];
@ -92,30 +95,35 @@ function profile_load(App $a, $nickname, $profile = 0, $profiledata = array()) {
$theme_info_file = "view/theme/" . current_theme() . "/theme.php"; $theme_info_file = "view/theme/" . current_theme() . "/theme.php";
if (file_exists($theme_info_file)) { if (file_exists($theme_info_file)) {
require_once $theme_info_file; include_once $theme_info_file;
} }
if (! (x($a->page,'aside'))) if (! (x($a->page, 'aside'))) {
$a->page['aside'] = ''; $a->page['aside'] = '';
}
if (local_user() && local_user() == $a->profile['uid'] && $profiledata) { if (local_user() && local_user() == $a->profile['uid'] && $profiledata) {
$a->page['aside'] .= replace_macros(get_markup_template('profile_edlink.tpl'),array( $a->page['aside'] .= replace_macros(
get_markup_template('profile_edlink.tpl'),
array(
'$editprofile' => t('Edit profile'), '$editprofile' => t('Edit profile'),
'$profid' => $a->profile['id'] '$profid' => $a->profile['id']
)); )
);
} }
$block = (((Config::get('system','block_public')) && (! local_user()) && (! remote_user())) ? true : false); $block = (((Config::get('system', 'block_public')) && (! local_user()) && (! remote_user())) ? true : false);
/** /**
* @todo * @todo
* By now, the contact block isn't shown, when a different profile is given * By now, the contact block isn't shown, when a different profile is given
* But: When this profile was on the same server, then we could display the contacts * But: When this profile was on the same server, then we could display the contacts
*/ */
if ($profiledata) if ($profiledata) {
$a->page['aside'] .= profile_sidebar($profiledata, true); $a->page['aside'] .= profile_sidebar($profiledata, true);
else } else {
$a->page['aside'] .= profile_sidebar($a->profile, $block); $a->page['aside'] .= profile_sidebar($a->profile, $block);
}
/*if (! $block) /*if (! $block)
$a->page['aside'] .= contact_block();*/ $a->page['aside'] .= contact_block();*/
@ -132,14 +140,14 @@ function profile_load(App $a, $nickname, $profile = 0, $profiledata = array()) {
* Passing a non-zero profile ID can also allow a preview of a selected profile * Passing a non-zero profile ID can also allow a preview of a selected profile
* by the owner * by the owner
* *
* @param string $nickname * @param string $nickname nick
* @param int $uid * @param int $uid uid
* @param int $profile * @param int $profile ID of the profile
* ID of the profile
* @returns array * @returns array
* Includes all available profile data * Includes all available profile data
*/ */
function get_profiledata_by_nick($nickname, $uid = 0, $profile = 0) { function get_profiledata_by_nick($nickname, $uid = 0, $profile = 0)
{
if (remote_user() && count($_SESSION['remote'])) { if (remote_user() && count($_SESSION['remote'])) {
foreach ($_SESSION['remote'] as $visitor) { foreach ($_SESSION['remote'] as $visitor) {
if ($visitor['uid'] == $uid) { if ($visitor['uid'] == $uid) {
@ -156,7 +164,8 @@ function get_profiledata_by_nick($nickname, $uid = 0, $profile = 0) {
if ($profile) { if ($profile) {
$profile_int = intval($profile); $profile_int = intval($profile);
$r = dba::fetch_first("SELECT `contact`.`id` AS `contact_id`, `contact`.`photo` AS `contact_photo`, $r = dba::fetch_first(
"SELECT `contact`.`id` AS `contact_id`, `contact`.`photo` AS `contact_photo`,
`contact`.`thumb` AS `contact_thumb`, `contact`.`micro` AS `contact_micro`, `contact`.`thumb` AS `contact_thumb`, `contact`.`micro` AS `contact_micro`,
`profile`.`uid` AS `profile_uid`, `profile`.*, `profile`.`uid` AS `profile_uid`, `profile`.*,
`contact`.`avatar-date` AS picdate, `contact`.`addr`, `user`.* `contact`.`avatar-date` AS picdate, `contact`.`addr`, `user`.*
@ -169,7 +178,8 @@ function get_profiledata_by_nick($nickname, $uid = 0, $profile = 0) {
); );
} }
if (!DBM::is_result($r)) { if (!DBM::is_result($r)) {
$r = dba::fetch_first("SELECT `contact`.`id` AS `contact_id`, `contact`.`photo` as `contact_photo`, $r = dba::fetch_first(
"SELECT `contact`.`id` AS `contact_id`, `contact`.`photo` as `contact_photo`,
`contact`.`thumb` AS `contact_thumb`, `contact`.`micro` AS `contact_micro`, `contact`.`thumb` AS `contact_thumb`, `contact`.`micro` AS `contact_micro`,
`profile`.`uid` AS `profile_uid`, `profile`.*, `profile`.`uid` AS `profile_uid`, `profile`.*,
`contact`.`avatar-date` AS picdate, `contact`.`addr`, `user`.* `contact`.`avatar-date` AS picdate, `contact`.`addr`, `user`.*
@ -203,7 +213,8 @@ function get_profiledata_by_nick($nickname, $uid = 0, $profile = 0) {
* @hooks 'profile_sidebar' * @hooks 'profile_sidebar'
* array $arr * array $arr
*/ */
function profile_sidebar($profile, $block = 0) { function profile_sidebar($profile, $block = 0)
{
$a = get_app(); $a = get_app();
$o = ''; $o = '';
@ -230,7 +241,7 @@ function profile_sidebar($profile, $block = 0) {
// don't show connect link to yourself // don't show connect link to yourself
$connect = (($profile['uid'] != local_user()) ? t('Connect') : False); $connect = (($profile['uid'] != local_user()) ? t('Connect') : false);
// don't show connect link to authenticated visitors either // don't show connect link to authenticated visitors either
if (remote_user() && count($_SESSION['remote'])) { if (remote_user() && count($_SESSION['remote'])) {
@ -258,7 +269,7 @@ function profile_sidebar($profile, $block = 0) {
if ($connect && ($profile['network'] != NETWORK_DFRN) && !isset($profile['remoteconnect'])) if ($connect && ($profile['network'] != NETWORK_DFRN) && !isset($profile['remoteconnect']))
$connect = false; $connect = false;
$remoteconnect = NULL; $remoteconnect = null;
if (isset($profile['remoteconnect'])) if (isset($profile['remoteconnect']))
$remoteconnect = $profile['remoteconnect']; $remoteconnect = $profile['remoteconnect'];
@ -272,15 +283,19 @@ function profile_sidebar($profile, $block = 0) {
$wallmessage_link = "wallmessage/".$profile["nickname"]; $wallmessage_link = "wallmessage/".$profile["nickname"];
if (remote_user()) { if (remote_user()) {
$r = q("SELECT `url` FROM `contact` WHERE `uid` = %d AND `id` = '%s' AND `rel` = %d", $r = q(
"SELECT `url` FROM `contact` WHERE `uid` = %d AND `id` = '%s' AND `rel` = %d",
intval($profile['uid']), intval($profile['uid']),
intval(remote_user()), intval(remote_user()),
intval(CONTACT_IS_FRIEND)); intval(CONTACT_IS_FRIEND)
);
} else { } else {
$r = q("SELECT `url` FROM `contact` WHERE `uid` = %d AND `nurl` = '%s' AND `rel` = %d", $r = q(
"SELECT `url` FROM `contact` WHERE `uid` = %d AND `nurl` = '%s' AND `rel` = %d",
intval($profile['uid']), intval($profile['uid']),
dbesc(normalise_link(get_my_url())), dbesc(normalise_link(get_my_url())),
intval(CONTACT_IS_FRIEND)); intval(CONTACT_IS_FRIEND)
);
} }
if ($r) { if ($r) {
$remote_url = $r[0]["url"]; $remote_url = $r[0]["url"];
@ -293,10 +308,12 @@ function profile_sidebar($profile, $block = 0) {
} }
// show edit profile to yourself // show edit profile to yourself
if (!$is_contact && $profile['uid'] == local_user() && feature_enabled(local_user(),'multi_profiles')) { if (!$is_contact && $profile['uid'] == local_user() && feature_enabled(local_user(), 'multi_profiles')) {
$profile['edit'] = array(System::baseUrl(). '/profiles', t('Profiles'),"", t('Manage/edit profiles')); $profile['edit'] = array(System::baseUrl(). '/profiles', t('Profiles'),"", t('Manage/edit profiles'));
$r = q("SELECT * FROM `profile` WHERE `uid` = %d", $r = q(
local_user()); "SELECT * FROM `profile` WHERE `uid` = %d",
local_user()
);
$profile['menu'] = array( $profile['menu'] = array(
'chg_photo' => t('Change profile photo'), 'chg_photo' => t('Change profile photo'),
@ -305,7 +322,6 @@ function profile_sidebar($profile, $block = 0) {
); );
if (DBM::is_result($r)) { if (DBM::is_result($r)) {
foreach ($r as $rr) { foreach ($r as $rr) {
$profile['menu']['entries'][] = array( $profile['menu']['entries'][] = array(
'photo' => $rr['thumb'], 'photo' => $rr['thumb'],
@ -315,14 +331,11 @@ function profile_sidebar($profile, $block = 0) {
'isdefault' => $rr['is-default'], 'isdefault' => $rr['is-default'],
'visibile_to_everybody' => t('visible to everybody'), 'visibile_to_everybody' => t('visible to everybody'),
'edit_visibility' => t('Edit visibility'), 'edit_visibility' => t('Edit visibility'),
); );
} }
} }
} }
if (!$is_contact && $profile['uid'] == local_user() && !feature_enabled(local_user(),'multi_profiles')) { if (!$is_contact && $profile['uid'] == local_user() && !feature_enabled(local_user(), 'multi_profiles')) {
$profile['edit'] = array(System::baseUrl(). '/profiles/'.$profile['id'], t('Edit profile'),"", t('Edit profile')); $profile['edit'] = array(System::baseUrl(). '/profiles/'.$profile['id'], t('Edit profile'),"", t('Edit profile'));
$profile['menu'] = array( $profile['menu'] = array(
'chg_photo' => t('Change profile photo'), 'chg_photo' => t('Change profile photo'),
@ -334,34 +347,36 @@ function profile_sidebar($profile, $block = 0) {
// Fetch the account type // Fetch the account type
$account_type = account_type($profile); $account_type = account_type($profile);
if ((x($profile,'address') == 1) if ((x($profile, 'address') == 1)
|| (x($profile,'location') == 1) || (x($profile, 'location') == 1)
|| (x($profile,'locality') == 1) || (x($profile, 'locality') == 1)
|| (x($profile,'region') == 1) || (x($profile, 'region') == 1)
|| (x($profile,'postal-code') == 1) || (x($profile, 'postal-code') == 1)
|| (x($profile,'country-name') == 1)) || (x($profile, 'country-name') == 1)
) {
$location = t('Location:'); $location = t('Location:');
$gender = ((x($profile,'gender') == 1) ? t('Gender:') : False);
$marital = ((x($profile,'marital') == 1) ? t('Status:') : False);
$homepage = ((x($profile,'homepage') == 1) ? t('Homepage:') : False);
$about = ((x($profile,'about') == 1) ? t('About:') : False);
$xmpp = ((x($profile,'xmpp') == 1) ? t('XMPP:') : False);
if (($profile['hidewall'] || $block) && (! local_user()) && (! remote_user())) {
$location = $pdesc = $gender = $marital = $homepage = $about = False;
} }
$firstname = ((strpos($profile['name'],' ')) $gender = ((x($profile, 'gender') == 1) ? t('Gender:') : false);
? trim(substr($profile['name'],0,strpos($profile['name'],' '))) : $profile['name']);
$lastname = (($firstname === $profile['name']) ? '' : trim(substr($profile['name'],strlen($firstname))));
if ($profile['guid'] != "")
$marital = ((x($profile, 'marital') == 1) ? t('Status:') : false);
$homepage = ((x($profile, 'homepage') == 1) ? t('Homepage:') : false);
$about = ((x($profile, 'about') == 1) ? t('About:') : false);
$xmpp = ((x($profile, 'xmpp') == 1) ? t('XMPP:') : false);
if (($profile['hidewall'] || $block) && (! local_user()) && (! remote_user())) {
$location = $pdesc = $gender = $marital = $homepage = $about = false;
}
$firstname = ((strpos($profile['name'], ' '))
? trim(substr($profile['name'], 0, strpos($profile['name'], ' '))) : $profile['name']);
$lastname = (($firstname === $profile['name']) ? '' : trim(substr($profile['name'], strlen($firstname))));
if ($profile['guid'] != "") {
$diaspora = array( $diaspora = array(
'guid' => $profile['guid'], 'guid' => $profile['guid'],
'podloc' => System::baseUrl(), 'podloc' => System::baseUrl(),
@ -374,19 +389,24 @@ function profile_sidebar($profile, $block = 0) {
'photo100' => $profile['contact_thumb'], 'photo100' => $profile['contact_thumb'],
'photo50' => $profile['contact_micro'], 'photo50' => $profile['contact_micro'],
); );
else } else {
$diaspora = false; $diaspora = false;
}
if (!$block) { if (!$block) {
$contact_block = contact_block(); $contact_block = contact_block();
if (is_array($a->profile) && !$a->profile['hide-friends']) { if (is_array($a->profile) && !$a->profile['hide-friends']) {
$r = q("SELECT `gcontact`.`updated` FROM `contact` INNER JOIN `gcontact` WHERE `gcontact`.`nurl` = `contact`.`nurl` AND `self` AND `uid` = %d LIMIT 1", $r = q(
intval($a->profile['uid'])); "SELECT `gcontact`.`updated` FROM `contact` INNER JOIN `gcontact` WHERE `gcontact`.`nurl` = `contact`.`nurl` AND `self` AND `uid` = %d LIMIT 1",
if (DBM::is_result($r)) intval($a->profile['uid'])
);
if (DBM::is_result($r)) {
$updated = date("c", strtotime($r[0]['updated'])); $updated = date("c", strtotime($r[0]['updated']));
}
$r = q("SELECT COUNT(*) AS `total` FROM `contact` $r = q(
"SELECT COUNT(*) AS `total` FROM `contact`
WHERE `uid` = %d WHERE `uid` = %d
AND NOT `self` AND NOT `blocked` AND NOT `pending` AND NOT `self` AND NOT `blocked` AND NOT `pending`
AND NOT `hidden` AND NOT `archive` AND NOT `hidden` AND NOT `archive`
@ -396,33 +416,40 @@ function profile_sidebar($profile, $block = 0) {
dbesc(NETWORK_DIASPORA), dbesc(NETWORK_DIASPORA),
dbesc(NETWORK_OSTATUS) dbesc(NETWORK_OSTATUS)
); );
if (DBM::is_result($r)) if (DBM::is_result($r)) {
$contacts = intval($r[0]['total']); $contacts = intval($r[0]['total']);
} }
} }
}
$p = array(); $p = array();
foreach ($profile as $k => $v) { foreach ($profile as $k => $v) {
$k = str_replace('-','_',$k); $k = str_replace('-', '_', $k);
$p[$k] = $v; $p[$k] = $v;
} }
if (isset($p["about"])) if (isset($p["about"])) {
$p["about"] = bbcode($p["about"]); $p["about"] = bbcode($p["about"]);
}
if (isset($p["address"])) if (isset($p["address"])) {
$p["address"] = bbcode($p["address"]); $p["address"] = bbcode($p["address"]);
else } else {
$p["address"] = bbcode($p["location"]); $p["address"] = bbcode($p["location"]);
}
if (isset($p["photo"])) { if (isset($p["photo"])) {
$p["photo"] = proxy_url($p["photo"], false, PROXY_SIZE_SMALL); $p["photo"] = proxy_url($p["photo"], false, PROXY_SIZE_SMALL);
} }
if ($a->theme['template_engine'] === 'internal')
if ($a->theme['template_engine'] === 'internal') {
$location = template_escape($location); $location = template_escape($location);
}
$tpl = get_markup_template('profile_vcard.tpl'); $tpl = get_markup_template('profile_vcard.tpl');
$o .= replace_macros($tpl, array( $o .= replace_macros(
$tpl,
array(
'$profile' => $p, '$profile' => $p,
'$xmpp' => $xmpp, '$xmpp' => $xmpp,
'$connect' => $connect, '$connect' => $connect,
@ -433,7 +460,7 @@ function profile_sidebar($profile, $block = 0) {
'$account_type' => $account_type, '$account_type' => $account_type,
'$location' => $location, '$location' => $location,
'$gender' => $gender, '$gender' => $gender,
// '$pdesc' => $pdesc, // '$pdesc' => $pdesc,
'$marital' => $marital, '$marital' => $marital,
'$homepage' => $homepage, '$homepage' => $homepage,
'$about' => $about, '$about' => $about,
@ -442,7 +469,8 @@ function profile_sidebar($profile, $block = 0) {
'$updated' => $updated, '$updated' => $updated,
'$diaspora' => $diaspora, '$diaspora' => $diaspora,
'$contact_block' => $contact_block, '$contact_block' => $contact_block,
)); )
);
$arr = array('profile' => &$profile, 'entry' => &$o); $arr = array('profile' => &$profile, 'entry' => &$o);
@ -452,33 +480,36 @@ function profile_sidebar($profile, $block = 0) {
} }
function get_birthdays() { function get_birthdays()
{
$a = get_app(); $a = get_app();
$o = ''; $o = '';
if (! local_user() || $a->is_mobile || $a->is_tablet) if (! local_user() || $a->is_mobile || $a->is_tablet) {
return $o; return $o;
}
// $mobile_detect = new Mobile_Detect(); /**
// $is_mobile = $mobile_detect->isMobile() || $mobile_detect->isTablet(); * $mobile_detect = new Mobile_Detect();
* $is_mobile = $mobile_detect->isMobile() || $mobile_detect->isTablet();
* if ($is_mobile)
* return $o;
*/
// if ($is_mobile) $bd_format = t('g A l F d'); // 8 AM Friday January 18
// return $o;
$bd_format = t('g A l F d') ; // 8 AM Friday January 18
$bd_short = t('F d'); $bd_short = t('F d');
$cachekey = "get_birthdays:".local_user(); $cachekey = "get_birthdays:".local_user();
$r = Cache::get($cachekey); $r = Cache::get($cachekey);
if (is_null($r)) { if (is_null($r)) {
$s = dba::p("SELECT `event`.*, `event`.`id` AS `eid`, `contact`.* FROM `event` $s = dba::p(
"SELECT `event`.*, `event`.`id` AS `eid`, `contact`.* FROM `event`
INNER JOIN `contact` ON `contact`.`id` = `event`.`cid` INNER JOIN `contact` ON `contact`.`id` = `event`.`cid`
WHERE `event`.`uid` = ? AND `type` = 'birthday' AND `start` < ? AND `finish` > ? WHERE `event`.`uid` = ? AND `type` = 'birthday' AND `start` < ? AND `finish` > ?
ORDER BY `start` ASC ", ORDER BY `start` ASC ",
local_user(), local_user(),
datetime_convert('UTC','UTC','now + 6 days'), datetime_convert('UTC', 'UTC', 'now + 6 days'),
datetime_convert('UTC','UTC','now') datetime_convert('UTC', 'UTC', 'now')
); );
if (DBM::is_result($s)) { if (DBM::is_result($s)) {
$r = dba::inArray($s); $r = dba::inArray($s);
@ -492,21 +523,25 @@ function get_birthdays() {
$istoday = false; $istoday = false;
foreach ($r as $rr) { foreach ($r as $rr) {
if (strlen($rr['name'])) if (strlen($rr['name'])) {
$total ++; $total ++;
if ((strtotime($rr['start'] . ' +00:00') < $now) && (strtotime($rr['finish'] . ' +00:00') > $now)) }
if ((strtotime($rr['start'] . ' +00:00') < $now) && (strtotime($rr['finish'] . ' +00:00') > $now)) {
$istoday = true; $istoday = true;
} }
}
$classtoday = $istoday ? ' birthday-today ' : ''; $classtoday = $istoday ? ' birthday-today ' : '';
if ($total) { if ($total) {
foreach ($r as &$rr) { foreach ($r as &$rr) {
if (! strlen($rr['name'])) if (! strlen($rr['name'])) {
continue; continue;
}
// avoid duplicates // avoid duplicates
if (in_array($rr['cid'],$cids)) if (in_array($rr['cid'], $cids)) {
continue; continue;
}
$cids[] = $rr['cid']; $cids[] = $rr['cid'];
$today = (((strtotime($rr['start'] . ' +00:00') < $now) && (strtotime($rr['finish'] . ' +00:00') > $now)) ? true : false); $today = (((strtotime($rr['start'] . ' +00:00') < $now) && (strtotime($rr['finish'] . ' +00:00') > $now)) ? true : false);
@ -520,14 +555,15 @@ function get_birthdays() {
$rr['link'] = $url; $rr['link'] = $url;
$rr['title'] = $rr['name']; $rr['title'] = $rr['name'];
$rr['date'] = day_translate(datetime_convert('UTC', $a->timezone, $rr['start'], $rr['adjust'] ? $bd_format : $bd_short)) . (($today) ? ' ' . t('[today]') : ''); $rr['date'] = day_translate(datetime_convert('UTC', $a->timezone, $rr['start'], $rr['adjust'] ? $bd_format : $bd_short)) . (($today) ? ' ' . t('[today]') : '');
$rr['startime'] = Null; $rr['startime'] = null;
$rr['today'] = $today; $rr['today'] = $today;
} }
} }
} }
$tpl = get_markup_template("birthdays_reminder.tpl"); $tpl = get_markup_template("birthdays_reminder.tpl");
return replace_macros($tpl, array( return replace_macros(
$tpl,
array(
'$baseurl' => System::baseUrl(), '$baseurl' => System::baseUrl(),
'$classtoday' => $classtoday, '$classtoday' => $classtoday,
'$count' => $total, '$count' => $total,
@ -536,14 +572,14 @@ function get_birthdays() {
'$events' => $r, '$events' => $r,
'$lbr' => '{', // raw brackets mess up if/endif macro processing '$lbr' => '{', // raw brackets mess up if/endif macro processing
'$rbr' => '}' '$rbr' => '}'
)
)); );
} }
function get_events() { function get_events()
{
require_once 'include/bbcode.php'; include_once 'include/bbcode.php';
$a = get_app(); $a = get_app();
@ -551,21 +587,23 @@ function get_events() {
return $o; return $o;
} }
// $mobile_detect = new Mobile_Detect(); /**
// $is_mobile = $mobile_detect->isMobile() || $mobile_detect->isTablet(); * $mobile_detect = new Mobile_Detect();
* $is_mobile = $mobile_detect->isMobile() || $mobile_detect->isTablet();
* if ($is_mobile)
* return $o;
*/
// if ($is_mobile) $bd_format = t('g A l F d'); // 8 AM Friday January 18
// return $o;
$bd_format = t('g A l F d') ; // 8 AM Friday January 18
$bd_short = t('F d'); $bd_short = t('F d');
$s = dba::p("SELECT `event`.* FROM `event` $s = dba::p(
"SELECT `event`.* FROM `event`
WHERE `event`.`uid` = ? AND `type` != 'birthday' AND `start` < ? AND `start` >= ? WHERE `event`.`uid` = ? AND `type` != 'birthday' AND `start` < ? AND `start` >= ?
ORDER BY `start` ASC ", ORDER BY `start` ASC ",
local_user(), local_user(),
datetime_convert('UTC','UTC','now + 7 days'), datetime_convert('UTC', 'UTC', 'now + 7 days'),
datetime_convert('UTC','UTC','now - 1 days') datetime_convert('UTC', 'UTC', 'now - 1 days')
); );
$r = array(); $r = array();
@ -579,29 +617,29 @@ function get_events() {
$total ++; $total ++;
} }
$strt = datetime_convert('UTC',$rr['convert'] ? $a->timezone : 'UTC',$rr['start'],'Y-m-d'); $strt = datetime_convert('UTC', $rr['convert'] ? $a->timezone : 'UTC', $rr['start'], 'Y-m-d');
if ($strt === datetime_convert('UTC',$a->timezone,'now','Y-m-d')) { if ($strt === datetime_convert('UTC', $a->timezone, 'now', 'Y-m-d')) {
$istoday = true; $istoday = true;
} }
$title = strip_tags(html_entity_decode(bbcode($rr['summary']),ENT_QUOTES,'UTF-8')); $title = strip_tags(html_entity_decode(bbcode($rr['summary']), ENT_QUOTES, 'UTF-8'));
if (strlen($title) > 35) { if (strlen($title) > 35) {
$title = substr($title,0,32) . '... '; $title = substr($title, 0, 32) . '... ';
} }
$description = substr(strip_tags(bbcode($rr['desc'])),0,32) . '... '; $description = substr(strip_tags(bbcode($rr['desc'])), 0, 32) . '... ';
if (! $description) { if (! $description) {
$description = t('[No description]'); $description = t('[No description]');
} }
$strt = datetime_convert('UTC',$rr['convert'] ? $a->timezone : 'UTC',$rr['start']); $strt = datetime_convert('UTC', $rr['convert'] ? $a->timezone : 'UTC', $rr['start']);
if (substr($strt,0,10) < datetime_convert('UTC',$a->timezone,'now','Y-m-d')) { if (substr($strt, 0, 10) < datetime_convert('UTC', $a->timezone, 'now', 'Y-m-d')) {
continue; continue;
} }
$today = ((substr($strt,0,10) === datetime_convert('UTC',$a->timezone,'now','Y-m-d')) ? true : false); $today = ((substr($strt, 0, 10) === datetime_convert('UTC', $a->timezone, 'now', 'Y-m-d')) ? true : false);
$rr['title'] = $title; $rr['title'] = $title;
$rr['description'] = $desciption; $rr['description'] = $desciption;
@ -615,27 +653,32 @@ function get_events() {
$classtoday = (($istoday) ? 'event-today' : ''); $classtoday = (($istoday) ? 'event-today' : '');
} }
$tpl = get_markup_template("events_reminder.tpl"); $tpl = get_markup_template("events_reminder.tpl");
return replace_macros($tpl, array( return replace_macros(
$tpl,
array(
'$baseurl' => System::baseUrl(), '$baseurl' => System::baseUrl(),
'$classtoday' => $classtoday, '$classtoday' => $classtoday,
'$count' => count($r), '$count' => count($r),
'$event_reminders' => t('Event Reminders'), '$event_reminders' => t('Event Reminders'),
'$event_title' => t('Events this week:'), '$event_title' => t('Events this week:'),
'$events' => $r, '$events' => $r,
)); )
);
} }
function advanced_profile(App $a) { function advanced_profile(App $a)
{
$o = ''; $o = '';
$uid = $a->profile['uid']; $uid = $a->profile['uid'];
$o .= replace_macros(get_markup_template('section_title.tpl'),array( $o .= replace_macros(
get_markup_template('section_title.tpl'),
array(
'$title' => t('Profile') '$title' => t('Profile')
)); )
);
if ($a->profile['name']) { if ($a->profile['name']) {
$tpl = get_markup_template('profile_advanced.tpl'); $tpl = get_markup_template('profile_advanced.tpl');
$profile = array(); $profile = array();
@ -652,11 +695,10 @@ function advanced_profile(App $a) {
$val = ((intval($a->profile['dob'])) $val = ((intval($a->profile['dob']))
? day_translate(datetime_convert('UTC','UTC',$a->profile['dob'] . ' 00:00 +00:00',$year_bd_format)) ? day_translate(datetime_convert('UTC', 'UTC', $a->profile['dob'] . ' 00:00 +00:00', $year_bd_format))
: day_translate(datetime_convert('UTC','UTC','2001-' . substr($a->profile['dob'],5) . ' 00:00 +00:00',$short_bd_format))); : day_translate(datetime_convert('UTC', 'UTC', '2001-' . substr($a->profile['dob'], 5) . ' 00:00 +00:00', $short_bd_format)));
$profile['birthday'] = array( t('Birthday:'), $val); $profile['birthday'] = array( t('Birthday:'), $val);
} }
if (!empty($a->profile['dob']) if (!empty($a->profile['dob'])
&& $a->profile['dob'] > '0001-01-01' && $a->profile['dob'] > '0001-01-01'
@ -751,7 +793,7 @@ function advanced_profile(App $a) {
} }
//show subcribed forum if it is enabled in the usersettings //show subcribed forum if it is enabled in the usersettings
if (feature_enabled($uid,'forumlist_profile')) { if (feature_enabled($uid, 'forumlist_profile')) {
$profile['forumlist'] = array( t('Forums:'), ForumManager::profile_advanced($uid)); $profile['forumlist'] = array( t('Forums:'), ForumManager::profile_advanced($uid));
} }
@ -759,25 +801,29 @@ function advanced_profile(App $a) {
$profile['edit'] = array(System::baseUrl(). '/profiles/'.$a->profile['id'], t('Edit profile'),"", t('Edit profile')); $profile['edit'] = array(System::baseUrl(). '/profiles/'.$a->profile['id'], t('Edit profile'),"", t('Edit profile'));
} }
return replace_macros($tpl, array( return replace_macros(
$tpl,
array(
'$title' => t('Profile'), '$title' => t('Profile'),
'$basic' => t('Basic'), '$basic' => t('Basic'),
'$advanced' => t('Advanced'), '$advanced' => t('Advanced'),
'$profile' => $profile '$profile' => $profile
)); )
);
} }
return ''; return '';
} }
function profile_tabs($a, $is_owner=False, $nickname=Null) { function profile_tabs($a, $is_owner = false, $nickname = null)
{
//echo "<pre>"; var_dump($a->user); killme(); //echo "<pre>"; var_dump($a->user); killme();
if (is_null($nickname)) { if (is_null($nickname)) {
$nickname = $a->user['nickname']; $nickname = $a->user['nickname'];
} }
if (x($_GET,'tab')) { if (x($_GET, 'tab')) {
$tab = notags(trim($_GET['tab'])); $tab = notags(trim($_GET['tab']));
} }
@ -868,20 +914,21 @@ function profile_tabs($a, $is_owner=False, $nickname=Null) {
$tpl = get_markup_template('common_tabs.tpl'); $tpl = get_markup_template('common_tabs.tpl');
return replace_macros($tpl,array('$tabs' => $arr['tabs'])); return replace_macros($tpl, array('$tabs' => $arr['tabs']));
} }
function get_my_url() { function get_my_url()
{
if (x($_SESSION, 'my_url')) { if (x($_SESSION, 'my_url')) {
return $_SESSION['my_url']; return $_SESSION['my_url'];
} }
return false; return false;
} }
function zrl_init(App $a) { function zrl_init(App $a)
{
$tmp_str = get_my_url(); $tmp_str = get_my_url();
if (validate_url($tmp_str)) { if (validate_url($tmp_str)) {
// Is it a DDoS attempt? // Is it a DDoS attempt?
// The check fetches the cached value from gprobe to reduce the load for this system // The check fetches the cached value from gprobe to reduce the load for this system
$urlparts = parse_url($tmp_str); $urlparts = parse_url($tmp_str);
@ -898,7 +945,8 @@ function zrl_init(App $a) {
} }
} }
function zrl($s, $force = false) { function zrl($s, $force = false)
{
if (! strlen($s)) { if (! strlen($s)) {
return $s; return $s;
} }
@ -930,7 +978,8 @@ function zrl($s, $force = false) {
* @note Returns local_user instead of user ID if "always_my_theme" * @note Returns local_user instead of user ID if "always_my_theme"
* is set to true * is set to true
*/ */
function get_theme_uid() { function get_theme_uid()
{
$uid = ((!empty($_REQUEST['puid'])) ? intval($_REQUEST['puid']) : 0); $uid = ((!empty($_REQUEST['puid'])) ? intval($_REQUEST['puid']) : 0);
if ((local_user()) && ((PConfig::get(local_user(), 'system', 'always_my_theme')) || (! $uid))) { if ((local_user()) && ((PConfig::get(local_user(), 'system', 'always_my_theme')) || (! $uid))) {
return local_user(); return local_user();

View File

@ -5,6 +5,7 @@
*/ */
use Friendica\App; use Friendica\App;
use Friendica\Core\Cache;
use Friendica\Core\System; use Friendica\Core\System;
use Friendica\ParseUrl; use Friendica\ParseUrl;
use Friendica\Core\Config; use Friendica\Core\Config;

View File

@ -4,6 +4,7 @@
*/ */
use Friendica\App; use Friendica\App;
use Friendica\Core\Cache;
use Friendica\Core\System; use Friendica\Core\System;
use Friendica\Core\Config; use Friendica\Core\Config;
use Friendica\Database\DBM; use Friendica\Database\DBM;
@ -23,14 +24,12 @@ require_once 'include/follow.php';
require_once 'include/api.php'; require_once 'include/api.php';
require_once 'mod/proxy.php'; require_once 'mod/proxy.php';
require_once 'include/xml.php'; require_once 'include/xml.php';
require_once 'include/cache.php';
/** /**
* @brief This class contain functions for the OStatus protocol * @brief This class contain functions for the OStatus protocol
*
*/ */
class ostatus { class ostatus
{
private static $itemlist; private static $itemlist;
private static $conv_list = array(); private static $conv_list = array();
@ -45,8 +44,8 @@ class ostatus {
* *
* @return array Array of author related entries for the item * @return array Array of author related entries for the item
*/ */
private static function fetchauthor($xpath, $context, $importer, &$contact, $onlyfetch) { private static function fetchauthor($xpath, $context, $importer, &$contact, $onlyfetch)
{
$author = array(); $author = array();
$author["author-link"] = $xpath->evaluate('atom:author/atom:uri/text()', $context)->item(0)->nodeValue; $author["author-link"] = $xpath->evaluate('atom:author/atom:uri/text()', $context)->item(0)->nodeValue;
$author["author-name"] = $xpath->evaluate('atom:author/atom:name/text()', $context)->item(0)->nodeValue; $author["author-name"] = $xpath->evaluate('atom:author/atom:name/text()', $context)->item(0)->nodeValue;
@ -56,7 +55,7 @@ class ostatus {
$alternate = $xpath->query("atom:author/atom:link[@rel='alternate']", $context)->item(0)->attributes; $alternate = $xpath->query("atom:author/atom:link[@rel='alternate']", $context)->item(0)->attributes;
if (is_object($alternate)) { if (is_object($alternate)) {
foreach ($alternate AS $attributes) { foreach ($alternate as $attributes) {
if (($attributes->name == "href") && ($attributes->textContent != "")) { if (($attributes->name == "href") && ($attributes->textContent != "")) {
$author["author-link"] = $attributes->textContent; $author["author-link"] = $attributes->textContent;
} }
@ -117,10 +116,10 @@ class ostatus {
$avatarlist = array(); $avatarlist = array();
$avatars = $xpath->query("atom:author/atom:link[@rel='avatar']", $context); $avatars = $xpath->query("atom:author/atom:link[@rel='avatar']", $context);
foreach ($avatars AS $avatar) { foreach ($avatars as $avatar) {
$href = ""; $href = "";
$width = 0; $width = 0;
foreach ($avatar->attributes AS $attributes) { foreach ($avatar->attributes as $attributes) {
if ($attributes->name == "href") { if ($attributes->name == "href") {
$href = $attributes->textContent; $href = $attributes->textContent;
} }
@ -148,7 +147,6 @@ class ostatus {
// Only update the contacts if it is an OStatus contact // Only update the contacts if it is an OStatus contact
if ($r && ($r['id'] > 0) && !$onlyfetch && ($contact["network"] == NETWORK_OSTATUS)) { if ($r && ($r['id'] > 0) && !$onlyfetch && ($contact["network"] == NETWORK_OSTATUS)) {
// This contact is vital, so we awake it from the dead // This contact is vital, so we awake it from the dead
unmark_for_death($contact); unmark_for_death($contact);
@ -238,8 +236,8 @@ class ostatus {
* *
* @return array Array of author related entries for the item * @return array Array of author related entries for the item
*/ */
public static function salmon_author($xml, $importer) { public static function salmon_author($xml, $importer)
{
if ($xml == "") if ($xml == "")
return; return;
@ -258,7 +256,7 @@ class ostatus {
$entries = $xpath->query('/atom:entry'); $entries = $xpath->query('/atom:entry');
foreach ($entries AS $entry) { foreach ($entries as $entry) {
// fetch the author // fetch the author
$author = self::fetchauthor($xpath, $entry, $importer, $contact, true); $author = self::fetchauthor($xpath, $entry, $importer, $contact, true);
return $author; return $author;
@ -272,10 +270,11 @@ class ostatus {
* *
* @return array attributes * @return array attributes
*/ */
private static function read_attributes($element) { private static function read_attributes($element)
{
$attribute = array(); $attribute = array();
foreach ($element->attributes AS $attributes) { foreach ($element->attributes as $attributes) {
$attribute[$attributes->name] = $attributes->textContent; $attribute[$attributes->name] = $attributes->textContent;
} }
@ -287,10 +286,11 @@ class ostatus {
* *
* @param string $xml The XML * @param string $xml The XML
* @param array $importer user record of the importing user * @param array $importer user record of the importing user
* @param array $contact * @param array $contact contact
* @param string $hub Called by reference, returns the fetched hub data * @param string $hub Called by reference, returns the fetched hub data
*/ */
public static function import($xml, $importer, &$contact, &$hub) { public static function import($xml, $importer, &$contact, &$hub)
{
self::process($xml, $importer, $contact, $hub); self::process($xml, $importer, $contact, $hub);
} }
@ -306,7 +306,8 @@ class ostatus {
* *
* @return boolean Could the XML be processed? * @return boolean Could the XML be processed?
*/ */
private static function process($xml, $importer, &$contact, &$hub, $stored = false, $initialize = true) { private static function process($xml, $importer, &$contact, &$hub, $stored = false, $initialize = true)
{
if ($initialize) { if ($initialize) {
self::$itemlist = array(); self::$itemlist = array();
self::$conv_list = array(); self::$conv_list = array();
@ -333,7 +334,7 @@ class ostatus {
$hub = ""; $hub = "";
$hub_attributes = $xpath->query("/atom:feed/atom:link[@rel='hub']")->item(0)->attributes; $hub_attributes = $xpath->query("/atom:feed/atom:link[@rel='hub']")->item(0)->attributes;
if (is_object($hub_attributes)) { if (is_object($hub_attributes)) {
foreach ($hub_attributes AS $hub_attribute) { foreach ($hub_attributes as $hub_attribute) {
if ($hub_attribute->name == "href") { if ($hub_attribute->name == "href") {
$hub = $hub_attribute->textContent; $hub = $hub_attribute->textContent;
logger("Found hub ".$hub, LOGGER_DEBUG); logger("Found hub ".$hub, LOGGER_DEBUG);
@ -380,11 +381,11 @@ class ostatus {
// Reverse the order of the entries // Reverse the order of the entries
$entrylist = array(); $entrylist = array();
foreach ($entries AS $entry) { foreach ($entries as $entry) {
$entrylist[] = $entry; $entrylist[] = $entry;
} }
foreach (array_reverse($entrylist) AS $entry) { foreach (array_reverse($entrylist) as $entry) {
// fetch the author // fetch the author
$authorelement = $xpath->query('/atom:entry/atom:author', $entry); $authorelement = $xpath->query('/atom:entry/atom:author', $entry);
@ -473,13 +474,13 @@ class ostatus {
$valid = !empty(self::$itemlist[0]['contact-id']); $valid = !empty(self::$itemlist[0]['contact-id']);
if (!$valid) { if (!$valid) {
// If not, then it depends on this setting // If not, then it depends on this setting
$valid = !Config::get('system','ostatus_full_threads'); $valid = !Config::get('system', 'ostatus_full_threads');
} }
if ($valid) { if ($valid) {
// Never post a thread when the only interaction by our contact was a like // Never post a thread when the only interaction by our contact was a like
$valid = false; $valid = false;
$verbs = array(ACTIVITY_POST, ACTIVITY_SHARE); $verbs = array(ACTIVITY_POST, ACTIVITY_SHARE);
foreach (self::$itemlist AS $item) { foreach (self::$itemlist as $item) {
if (!empty($item['contact-id']) && in_array($item['verb'], $verbs)) { if (!empty($item['contact-id']) && in_array($item['verb'], $verbs)) {
$valid = true; $valid = true;
} }
@ -500,7 +501,7 @@ class ostatus {
$default_contact = $item['contact-id']; $default_contact = $item['contact-id'];
} }
} }
foreach (self::$itemlist AS $item) { foreach (self::$itemlist as $item) {
$found = dba::exists('item', array('uid' => $importer["uid"], 'uri' => $item["uri"])); $found = dba::exists('item', array('uid' => $importer["uid"], 'uri' => $item["uri"]));
if ($found) { if ($found) {
logger("Item with uri ".$item["uri"]." for user ".$importer["uid"]." already exists.", LOGGER_DEBUG); logger("Item with uri ".$item["uri"]." for user ".$importer["uid"]." already exists.", LOGGER_DEBUG);
@ -526,8 +527,8 @@ class ostatus {
return true; return true;
} }
private static function deleteNotice($item) { private static function deleteNotice($item)
{
$condition = array('uid' => $item['uid'], 'author-link' => $item['author-link'], 'uri' => $item['uri']); $condition = array('uid' => $item['uid'], 'author-link' => $item['author-link'], 'uri' => $item['uri']);
$deleted = dba::select('item', array('id', 'parent-uri'), $condition, array('limit' => 1)); $deleted = dba::select('item', array('id', 'parent-uri'), $condition, array('limit' => 1));
if (!DBM::is_result($deleted)) { if (!DBM::is_result($deleted)) {
@ -536,9 +537,12 @@ class ostatus {
} }
// Currently we don't have a central deletion function that we could use in this case. The function "item_drop" doesn't work for that case // Currently we don't have a central deletion function that we could use in this case. The function "item_drop" doesn't work for that case
dba::update('item', array('deleted' => true, 'title' => '', 'body' => '', dba::update(
'item',
array('deleted' => true, 'title' => '', 'body' => '',
'edited' => datetime_convert(), 'changed' => datetime_convert()), 'edited' => datetime_convert(), 'changed' => datetime_convert()),
array('id' => $deleted["id"])); array('id' => $deleted["id"])
);
delete_thread($deleted["id"], $deleted["parent-uri"]); delete_thread($deleted["id"], $deleted["parent-uri"]);
@ -553,7 +557,8 @@ class ostatus {
* @param array $item The item array * @param array $item The item array
* @param array $importer user record of the importing user * @param array $importer user record of the importing user
*/ */
private static function processPost($xpath, $entry, &$item, $importer) { private static function processPost($xpath, $entry, &$item, $importer)
{
$item["body"] = html2bbcode($xpath->query('atom:content/text()', $entry)->item(0)->nodeValue); $item["body"] = html2bbcode($xpath->query('atom:content/text()', $entry)->item(0)->nodeValue);
$item["object-type"] = $xpath->query('activity:object-type/text()', $entry)->item(0)->nodeValue; $item["object-type"] = $xpath->query('activity:object-type/text()', $entry)->item(0)->nodeValue;
if (($item["object-type"] == ACTIVITY_OBJ_BOOKMARK) || ($item["object-type"] == ACTIVITY_OBJ_EVENT)) { if (($item["object-type"] == ACTIVITY_OBJ_BOOKMARK) || ($item["object-type"] == ACTIVITY_OBJ_EVENT)) {
@ -570,7 +575,7 @@ class ostatus {
$conv = $xpath->query('ostatus:conversation', $entry); $conv = $xpath->query('ostatus:conversation', $entry);
if (is_object($conv->item(0))) { if (is_object($conv->item(0))) {
foreach ($conv->item(0)->attributes AS $attributes) { foreach ($conv->item(0)->attributes as $attributes) {
if ($attributes->name == "ref") { if ($attributes->name == "ref") {
$item['conversation-uri'] = $attributes->textContent; $item['conversation-uri'] = $attributes->textContent;
} }
@ -584,7 +589,7 @@ class ostatus {
$inreplyto = $xpath->query('thr:in-reply-to', $entry); $inreplyto = $xpath->query('thr:in-reply-to', $entry);
if (is_object($inreplyto->item(0))) { if (is_object($inreplyto->item(0))) {
foreach ($inreplyto->item(0)->attributes AS $attributes) { foreach ($inreplyto->item(0)->attributes as $attributes) {
if ($attributes->name == "ref") { if ($attributes->name == "ref") {
$item["parent-uri"] = $attributes->textContent; $item["parent-uri"] = $attributes->textContent;
} }
@ -601,8 +606,8 @@ class ostatus {
$categories = $xpath->query('atom:category', $entry); $categories = $xpath->query('atom:category', $entry);
if ($categories) { if ($categories) {
foreach ($categories AS $category) { foreach ($categories as $category) {
foreach ($category->attributes AS $attributes) { foreach ($category->attributes as $attributes) {
if ($attributes->name == "term") { if ($attributes->name == "term") {
$term = $attributes->textContent; $term = $attributes->textContent;
if (strlen($item["tag"])) { if (strlen($item["tag"])) {
@ -628,7 +633,7 @@ class ostatus {
$notice_info = $xpath->query('statusnet:notice_info', $entry); $notice_info = $xpath->query('statusnet:notice_info', $entry);
if ($notice_info && ($notice_info->length > 0)) { if ($notice_info && ($notice_info->length > 0)) {
foreach ($notice_info->item(0)->attributes AS $attributes) { foreach ($notice_info->item(0)->attributes as $attributes) {
if ($attributes->name == "source") { if ($attributes->name == "source") {
$item["app"] = strip_tags($attributes->textContent); $item["app"] = strip_tags($attributes->textContent);
} }
@ -648,7 +653,7 @@ class ostatus {
$item["body"] .= $add_body; $item["body"] .= $add_body;
// Only add additional data when there is no picture in the post // Only add additional data when there is no picture in the post
if (!strstr($item["body"],'[/img]')) { if (!strstr($item["body"], '[/img]')) {
$item["body"] = add_page_info_to_body($item["body"]); $item["body"] = add_page_info_to_body($item["body"]);
} }
@ -693,8 +698,8 @@ class ostatus {
* @param string $conversation The link to the conversation * @param string $conversation The link to the conversation
* @param string $conversation_uri The conversation in "uri" format * @param string $conversation_uri The conversation in "uri" format
*/ */
private static function fetchConversation($conversation, $conversation_uri) { private static function fetchConversation($conversation, $conversation_uri)
{
// Ensure that we only store a conversation once in a process // Ensure that we only store a conversation once in a process
if (isset(self::$conv_list[$conversation])) { if (isset(self::$conv_list[$conversation])) {
return; return;
@ -723,7 +728,7 @@ class ostatus {
$links = $xpath->query('//link'); $links = $xpath->query('//link');
if ($links) { if ($links) {
foreach ($links AS $link) { foreach ($links as $link) {
$attribute = ostatus::read_attributes($link); $attribute = ostatus::read_attributes($link);
if (($attribute['rel'] == 'alternate') && ($attribute['type'] == 'application/atom+xml')) { if (($attribute['rel'] == 'alternate') && ($attribute['type'] == 'application/atom+xml')) {
$file = $attribute['href']; $file = $attribute['href'];
@ -750,8 +755,11 @@ class ostatus {
* @brief Store a feed in several conversation entries * @brief Store a feed in several conversation entries
* *
* @param string $xml The feed * @param string $xml The feed
* @param string $conversation conversation
* @param string $conversation_uri conversation uri
*/ */
private static function storeConversation($xml, $conversation = '', $conversation_uri = '') { private static function storeConversation($xml, $conversation = '', $conversation_uri = '')
{
$doc = new DOMDocument(); $doc = new DOMDocument();
@$doc->loadXML($xml); @$doc->loadXML($xml);
@ -763,7 +771,7 @@ class ostatus {
$entries = $xpath->query('/atom:feed/atom:entry'); $entries = $xpath->query('/atom:feed/atom:entry');
// Now store the entries // Now store the entries
foreach ($entries AS $entry) { foreach ($entries as $entry) {
$doc2 = new DOMDocument(); $doc2 = new DOMDocument();
$doc2->preserveWhiteSpace = false; $doc2->preserveWhiteSpace = false;
$doc2->formatOutput = true; $doc2->formatOutput = true;
@ -776,7 +784,7 @@ class ostatus {
$inreplyto = $xpath->query('thr:in-reply-to', $entry); $inreplyto = $xpath->query('thr:in-reply-to', $entry);
if (is_object($inreplyto->item(0))) { if (is_object($inreplyto->item(0))) {
foreach ($inreplyto->item(0)->attributes AS $attributes) { foreach ($inreplyto->item(0)->attributes as $attributes) {
if ($attributes->name == "ref") { if ($attributes->name == "ref") {
$conv_data['reply-to-uri'] = $attributes->textContent; $conv_data['reply-to-uri'] = $attributes->textContent;
} }
@ -788,7 +796,7 @@ class ostatus {
$conv = $xpath->query('ostatus:conversation', $entry); $conv = $xpath->query('ostatus:conversation', $entry);
if (is_object($conv->item(0))) { if (is_object($conv->item(0))) {
foreach ($conv->item(0)->attributes AS $attributes) { foreach ($conv->item(0)->attributes as $attributes) {
if ($attributes->name == "ref") { if ($attributes->name == "ref") {
$conv_data['conversation-uri'] = $attributes->textContent; $conv_data['conversation-uri'] = $attributes->textContent;
} }
@ -833,7 +841,8 @@ class ostatus {
* *
* @param string $self The link to the self item * @param string $self The link to the self item
*/ */
private static function fetchSelf($self, &$item) { private static function fetchSelf($self, &$item)
{
$condition = array('`item-uri` = ? AND `protocol` IN (?, ?)', $self, PROTOCOL_DFRN, PROTOCOL_OSTATUS_SALMON); $condition = array('`item-uri` = ? AND `protocol` IN (?, ?)', $self, PROTOCOL_DFRN, PROTOCOL_OSTATUS_SALMON);
if (dba::exists('conversation', $condition)) { if (dba::exists('conversation', $condition)) {
logger('Conversation '.$item['uri'].' is already stored.', LOGGER_DEBUG); logger('Conversation '.$item['uri'].' is already stored.', LOGGER_DEBUG);
@ -866,7 +875,8 @@ class ostatus {
* @param string $related_uri The related item in "uri" format * @param string $related_uri The related item in "uri" format
* @param array $importer user record of the importing user * @param array $importer user record of the importing user
*/ */
private static function fetchRelated($related, $related_uri, $importer) { private static function fetchRelated($related, $related_uri, $importer)
{
$condition = array('`item-uri` = ? AND `protocol` IN (?, ?)', $related_uri, PROTOCOL_DFRN, PROTOCOL_OSTATUS_SALMON); $condition = array('`item-uri` = ? AND `protocol` IN (?, ?)', $related_uri, PROTOCOL_DFRN, PROTOCOL_OSTATUS_SALMON);
$conversation = dba::select('conversation', array('source', 'protocol'), $condition, array('limit' => 1)); $conversation = dba::select('conversation', array('source', 'protocol'), $condition, array('limit' => 1));
if (DBM::is_result($conversation)) { if (DBM::is_result($conversation)) {
@ -907,7 +917,7 @@ class ostatus {
$links = $xpath->query('//link'); $links = $xpath->query('//link');
if ($links) { if ($links) {
foreach ($links AS $link) { foreach ($links as $link) {
$attribute = self::read_attributes($link); $attribute = self::read_attributes($link);
if (($attribute['rel'] == 'alternate') && ($attribute['type'] == 'application/atom+xml')) { if (($attribute['rel'] == 'alternate') && ($attribute['type'] == 'application/atom+xml')) {
$atom_file = $attribute['href']; $atom_file = $attribute['href'];
@ -974,7 +984,8 @@ class ostatus {
* *
* @return array with data from links * @return array with data from links
*/ */
private static function processRepeatedItem($xpath, $entry, &$item, $importer) { private static function processRepeatedItem($xpath, $entry, &$item, $importer)
{
$activityobjects = $xpath->query('activity:object', $entry)->item(0); $activityobjects = $xpath->query('activity:object', $entry)->item(0);
if (!is_object($activityobjects)) { if (!is_object($activityobjects)) {
@ -1013,7 +1024,7 @@ class ostatus {
$inreplyto = $xpath->query('thr:in-reply-to', $activityobjects); $inreplyto = $xpath->query('thr:in-reply-to', $activityobjects);
if (is_object($inreplyto->item(0))) { if (is_object($inreplyto->item(0))) {
foreach ($inreplyto->item(0)->attributes AS $attributes) { foreach ($inreplyto->item(0)->attributes as $attributes) {
if ($attributes->name == "ref") { if ($attributes->name == "ref") {
$item["parent-uri"] = $attributes->textContent; $item["parent-uri"] = $attributes->textContent;
} }
@ -1031,18 +1042,20 @@ class ostatus {
* *
* @return array with data from the links * @return array with data from the links
*/ */
private static function processLinks($links, &$item) { private static function processLinks($links, &$item)
{
$link_data = array('add_body' => '', 'self' => ''); $link_data = array('add_body' => '', 'self' => '');
foreach ($links AS $link) { foreach ($links as $link) {
$attribute = self::read_attributes($link); $attribute = self::read_attributes($link);
if (($attribute['rel'] != "") && ($attribute['href'] != "")) { if (($attribute['rel'] != "") && ($attribute['href'] != "")) {
switch ($attribute['rel']) { switch ($attribute['rel']) {
case "alternate": case "alternate":
$item["plink"] = $attribute['href']; $item["plink"] = $attribute['href'];
if (($item["object-type"] == ACTIVITY_OBJ_QUESTION) || if (($item["object-type"] == ACTIVITY_OBJ_QUESTION)
($item["object-type"] == ACTIVITY_OBJ_EVENT)) { || ($item["object-type"] == ACTIVITY_OBJ_EVENT)
) {
$item["body"] .= add_page_info($attribute['href']); $item["body"] .= add_page_info($attribute['href']);
} }
break; break;
@ -1054,7 +1067,7 @@ class ostatus {
} }
break; break;
case "enclosure": case "enclosure":
$filetype = strtolower(substr($attribute['type'], 0, strpos($attribute['type'],'/'))); $filetype = strtolower(substr($attribute['type'], 0, strpos($attribute['type'], '/')));
if ($filetype == 'image') { if ($filetype == 'image') {
$link_data['add_body'] .= "\n[img]".$attribute['href'].'[/img]'; $link_data['add_body'] .= "\n[img]".$attribute['href'].'[/img]';
} else { } else {
@ -1089,15 +1102,16 @@ class ostatus {
return $link_data; return $link_data;
} }
/** /**
* @brief Create an url out of an uri * @brief Create an url out of an uri
* *
* @param string $href URI in the format "parameter1:parameter1:..." * @param string $href URI in the format "parameter1:parameter1:..."
* *
* @return string URL in the format http(s)://.... * @return string URL in the format http(s)://....
*/ */
public static function convert_href($href) { public static function convert_href($href)
$elements = explode(":",$href); {
$elements = explode(":", $href);
if ((count($elements) <= 2) || ($elements[0] != "tag")) if ((count($elements) <= 2) || ($elements[0] != "tag"))
return $href; return $href;
@ -1126,7 +1140,8 @@ class ostatus {
* *
* @return string The guid if the post is a reshare * @return string The guid if the post is a reshare
*/ */
private static function get_reshared_guid($item) { private static function get_reshared_guid($item)
{
$body = trim($item["body"]); $body = trim($item["body"]);
// Skip if it isn't a pure repeated messages // Skip if it isn't a pure repeated messages
@ -1138,7 +1153,7 @@ class ostatus {
if (strlen($body) > (strrpos($body, "[/share]") + 8)) if (strlen($body) > (strrpos($body, "[/share]") + 8))
return ""; return "";
$attributes = preg_replace("/\[share(.*?)\]\s?(.*?)\s?\[\/share\]\s?/ism","$1",$body); $attributes = preg_replace("/\[share(.*?)\]\s?(.*?)\s?\[\/share\]\s?/ism", "$1", $body);
// Skip if there is no shared message in there // Skip if there is no shared message in there
if ($body == $attributes) if ($body == $attributes)
return false; return false;
@ -1162,14 +1177,16 @@ class ostatus {
* *
* @return string The cleaned body * @return string The cleaned body
*/ */
private static function format_picture_post($body) { private static function format_picture_post($body)
{
$siteinfo = get_attached_data($body); $siteinfo = get_attached_data($body);
if (($siteinfo["type"] == "photo")) { if (($siteinfo["type"] == "photo")) {
if (isset($siteinfo["preview"])) if (isset($siteinfo["preview"])) {
$preview = $siteinfo["preview"]; $preview = $siteinfo["preview"];
else } else {
$preview = $siteinfo["image"]; $preview = $siteinfo["image"];
}
// Is it a remote picture? Then make a smaller preview here // Is it a remote picture? Then make a smaller preview here
$preview = proxy_url($preview, false, PROXY_SIZE_SMALL); $preview = proxy_url($preview, false, PROXY_SIZE_SMALL);
@ -1178,10 +1195,11 @@ class ostatus {
$preview = str_replace(array("-0.jpg", "-0.png"), array("-2.jpg", "-2.png"), $preview); $preview = str_replace(array("-0.jpg", "-0.png"), array("-2.jpg", "-2.png"), $preview);
$preview = str_replace(array("-1.jpg", "-1.png"), array("-2.jpg", "-2.png"), $preview); $preview = str_replace(array("-1.jpg", "-1.png"), array("-2.jpg", "-2.png"), $preview);
if (isset($siteinfo["url"])) if (isset($siteinfo["url"])) {
$url = $siteinfo["url"]; $url = $siteinfo["url"];
else } else {
$url = $siteinfo["image"]; $url = $siteinfo["image"];
}
$body = trim($siteinfo["text"])." [url]".$url."[/url]\n[img]".$preview."[/img]"; $body = trim($siteinfo["text"])." [url]".$url."[/url]\n[img]".$preview."[/img]";
} }
@ -1197,8 +1215,8 @@ class ostatus {
* *
* @return object header root element * @return object header root element
*/ */
private static function add_header($doc, $owner) { private static function add_header($doc, $owner)
{
$a = get_app(); $a = get_app();
$root = $doc->createElementNS(NAMESPACE_ATOM1, 'feed'); $root = $doc->createElementNS(NAMESPACE_ATOM1, 'feed');
@ -1256,8 +1274,10 @@ class ostatus {
* *
* @param object $doc XML document * @param object $doc XML document
* @param object $root XML root element where the hub links are added * @param object $root XML root element where the hub links are added
* @param object $nick nick
*/ */
public static function hublinks($doc, $root, $nick) { public static function hublinks($doc, $root, $nick)
{
$h = System::baseUrl() . '/pubsubhubbub/'.$nick; $h = System::baseUrl() . '/pubsubhubbub/'.$nick;
xml::add_element($doc, $root, "link", "", array("href" => $h, "rel" => "hub")); xml::add_element($doc, $root, "link", "", array("href" => $h, "rel" => "hub"));
} }
@ -1269,7 +1289,8 @@ class ostatus {
* @param object $root XML root element where the hub links are added * @param object $root XML root element where the hub links are added
* @param array $item Data of the item that is to be posted * @param array $item Data of the item that is to be posted
*/ */
private static function get_attachment($doc, $root, $item) { private static function get_attachment($doc, $root, $item)
{
$o = ""; $o = "";
$siteinfo = get_attached_data($item["body"]); $siteinfo = get_attached_data($item["body"]);
@ -1334,8 +1355,8 @@ class ostatus {
* *
* @return object author element * @return object author element
*/ */
private static function add_author($doc, $owner) { private static function add_author($doc, $owner)
{
$r = q("SELECT `homepage`, `publish` FROM `profile` WHERE `uid` = %d AND `is-default` LIMIT 1", intval($owner["uid"])); $r = q("SELECT `homepage`, `publish` FROM `profile` WHERE `uid` = %d AND `is-default` LIMIT 1", intval($owner["uid"]));
if (DBM::is_result($r)) { if (DBM::is_result($r)) {
$profile = $r[0]; $profile = $r[0];
@ -1402,7 +1423,6 @@ class ostatus {
* @TODO Picture attachments should look like this: * @TODO Picture attachments should look like this:
* <a href="https://status.pirati.ca/attachment/572819" title="https://status.pirati.ca/file/heluecht-20151202T222602-rd3u49p.gif" * <a href="https://status.pirati.ca/attachment/572819" title="https://status.pirati.ca/file/heluecht-20151202T222602-rd3u49p.gif"
* class="attachment thumbnail" id="attachment-572819" rel="nofollow external">https://status.pirati.ca/attachment/572819</a> * class="attachment thumbnail" id="attachment-572819" rel="nofollow external">https://status.pirati.ca/attachment/572819</a>
*
*/ */
/** /**
@ -1412,7 +1432,8 @@ class ostatus {
* *
* @return string activity * @return string activity
*/ */
private static function construct_verb($item) { private static function construct_verb($item)
{
if ($item['verb']) if ($item['verb'])
return $item['verb']; return $item['verb'];
return ACTIVITY_POST; return ACTIVITY_POST;
@ -1425,7 +1446,8 @@ class ostatus {
* *
* @return string Object type * @return string Object type
*/ */
private static function construct_objecttype($item) { private static function construct_objecttype($item)
{
if (in_array($item['object-type'], array(ACTIVITY_OBJ_NOTE, ACTIVITY_OBJ_COMMENT))) if (in_array($item['object-type'], array(ACTIVITY_OBJ_NOTE, ACTIVITY_OBJ_COMMENT)))
return $item['object-type']; return $item['object-type'];
return ACTIVITY_OBJ_NOTE; return ACTIVITY_OBJ_NOTE;
@ -1437,11 +1459,12 @@ class ostatus {
* @param object $doc XML document * @param object $doc XML document
* @param array $item Data of the item that is to be posted * @param array $item Data of the item that is to be posted
* @param array $owner Contact data of the poster * @param array $owner Contact data of the poster
* @param bool $toplevel * @param bool $toplevel optional default false
* *
* @return object Entry element * @return object Entry element
*/ */
private static function entry($doc, $item, $owner, $toplevel = false) { private static function entry($doc, $item, $owner, $toplevel = false)
{
$repeated_guid = self::get_reshared_guid($item); $repeated_guid = self::get_reshared_guid($item);
if ($repeated_guid != "") if ($repeated_guid != "")
$xml = self::reshare_entry($doc, $item, $owner, $repeated_guid, $toplevel); $xml = self::reshare_entry($doc, $item, $owner, $repeated_guid, $toplevel);
@ -1466,18 +1489,15 @@ class ostatus {
* *
* @return object Source element * @return object Source element
*/ */
private static function source_entry($doc, $contact) { private static function source_entry($doc, $contact)
{
$source = $doc->createElement("source"); $source = $doc->createElement("source");
xml::add_element($doc, $source, "id", $contact["poll"]); xml::add_element($doc, $source, "id", $contact["poll"]);
xml::add_element($doc, $source, "title", $contact["name"]); xml::add_element($doc, $source, "title", $contact["name"]);
xml::add_element($doc, $source, "link", "", array("rel" => "alternate", xml::add_element($doc, $source, "link", "", array("rel" => "alternate", "type" => "text/html", "href" => $contact["alias"]));
"type" => "text/html", xml::add_element($doc, $source, "link", "", array("rel" => "self", "type" => "application/atom+xml", "href" => $contact["poll"]));
"href" => $contact["alias"]));
xml::add_element($doc, $source, "link", "", array("rel" => "self",
"type" => "application/atom+xml",
"href" => $contact["poll"]));
xml::add_element($doc, $source, "icon", $contact["photo"]); xml::add_element($doc, $source, "icon", $contact["photo"]);
xml::add_element($doc, $source, "updated", datetime_convert("UTC","UTC",$contact["success_update"]."+00:00",ATOM_TIME)); xml::add_element($doc, $source, "updated", datetime_convert("UTC", "UTC", $contact["success_update"]."+00:00", ATOM_TIME));
return $source; return $source;
} }
@ -1492,16 +1512,21 @@ class ostatus {
*/ */
private static function contact_entry($url, $owner) { private static function contact_entry($url, $owner) {
$r = q("SELECT * FROM `contact` WHERE `nurl` = '%s' AND `uid` IN (0, %d) ORDER BY `uid` DESC LIMIT 1", $r = q(
dbesc(normalise_link($url)), intval($owner["uid"])); "SELECT * FROM `contact` WHERE `nurl` = '%s' AND `uid` IN (0, %d) ORDER BY `uid` DESC LIMIT 1",
dbesc(normalise_link($url)),
intval($owner["uid"])
);
if (DBM::is_result($r)) { if (DBM::is_result($r)) {
$contact = $r[0]; $contact = $r[0];
$contact["uid"] = -1; $contact["uid"] = -1;
} }
if (!DBM::is_result($r)) { if (!DBM::is_result($r)) {
$r = q("SELECT * FROM `gcontact` WHERE `nurl` = '%s' LIMIT 1", $r = q(
dbesc(normalise_link($url))); "SELECT * FROM `gcontact` WHERE `nurl` = '%s' LIMIT 1",
dbesc(normalise_link($url))
);
if (DBM::is_result($r)) { if (DBM::is_result($r)) {
$contact = $r[0]; $contact = $r[0];
$contact["uid"] = -1; $contact["uid"] = -1;
@ -1509,19 +1534,22 @@ class ostatus {
} }
} }
if (!DBM::is_result($r)) if (!DBM::is_result($r)) {
$contact = owner; $contact = owner;
}
if (!isset($contact["poll"])) { if (!isset($contact["poll"])) {
$data = Probe::uri($url); $data = Probe::uri($url);
$contact["poll"] = $data["poll"]; $contact["poll"] = $data["poll"];
if (!$contact["alias"]) if (!$contact["alias"]) {
$contact["alias"] = $data["alias"]; $contact["alias"] = $data["alias"];
} }
}
if (!isset($contact["alias"])) if (!isset($contact["alias"])) {
$contact["alias"] = $contact["url"]; $contact["alias"] = $contact["url"];
}
return $contact; return $contact;
} }
@ -1537,17 +1565,22 @@ class ostatus {
* *
* @return object Entry element * @return object Entry element
*/ */
private static function reshare_entry($doc, $item, $owner, $repeated_guid, $toplevel) { private static function reshare_entry($doc, $item, $owner, $repeated_guid, $toplevel)
{
if (($item["id"] != $item["parent"]) && (normalise_link($item["author-link"]) != normalise_link($owner["url"]))) { if (($item["id"] != $item["parent"]) && (normalise_link($item["author-link"]) != normalise_link($owner["url"]))) {
logger("OStatus entry is from author ".$owner["url"]." - not from ".$item["author-link"].". Quitting.", LOGGER_DEBUG); logger("OStatus entry is from author ".$owner["url"]." - not from ".$item["author-link"].". Quitting.", LOGGER_DEBUG);
} }
$title = self::entry_header($doc, $entry, $owner, $toplevel); $title = self::entry_header($doc, $entry, $owner, $toplevel);
$r = q("SELECT * FROM `item` WHERE `uid` = %d AND `guid` = '%s' AND NOT `private` AND `network` IN ('%s', '%s', '%s') LIMIT 1", $r = q(
intval($owner["uid"]), dbesc($repeated_guid), "SELECT * FROM `item` WHERE `uid` = %d AND `guid` = '%s' AND NOT `private` AND `network` IN ('%s', '%s', '%s') LIMIT 1",
dbesc(NETWORK_DFRN), dbesc(NETWORK_DIASPORA), dbesc(NETWORK_OSTATUS)); intval($owner["uid"]),
dbesc($repeated_guid),
dbesc(NETWORK_DFRN),
dbesc(NETWORK_DIASPORA),
dbesc(NETWORK_OSTATUS)
);
if (DBM::is_result($r)) { if (DBM::is_result($r)) {
$repeated_item = $r[0]; $repeated_item = $r[0];
} else { } else {
@ -1603,8 +1636,8 @@ class ostatus {
* *
* @return object Entry element with "like" * @return object Entry element with "like"
*/ */
private static function like_entry($doc, $item, $owner, $toplevel) { private static function like_entry($doc, $item, $owner, $toplevel)
{
if (($item["id"] != $item["parent"]) && (normalise_link($item["author-link"]) != normalise_link($owner["url"]))) { if (($item["id"] != $item["parent"]) && (normalise_link($item["author-link"]) != normalise_link($owner["url"]))) {
logger("OStatus entry is from author ".$owner["url"]." - not from ".$item["author-link"].". Quitting.", LOGGER_DEBUG); logger("OStatus entry is from author ".$owner["url"]." - not from ".$item["author-link"].". Quitting.", LOGGER_DEBUG);
} }
@ -1616,8 +1649,11 @@ class ostatus {
$as_object = $doc->createElement("activity:object"); $as_object = $doc->createElement("activity:object");
$parent = q("SELECT * FROM `item` WHERE `uri` = '%s' AND `uid` = %d", $parent = q(
dbesc($item["thr-parent"]), intval($item["uid"])); "SELECT * FROM `item` WHERE `uri` = '%s' AND `uid` = %d",
dbesc($item["thr-parent"]),
intval($item["uid"])
);
$parent_item = (($item['thr-parent']) ? $item['thr-parent'] : $item['parent-uri']); $parent_item = (($item['thr-parent']) ? $item['thr-parent'] : $item['parent-uri']);
xml::add_element($doc, $as_object, "activity:object-type", self::construct_objecttype($parent[0])); xml::add_element($doc, $as_object, "activity:object-type", self::construct_objecttype($parent[0]));
@ -1640,8 +1676,8 @@ class ostatus {
* *
* @return object author element * @return object author element
*/ */
private static function add_person_object($doc, $owner, $contact) { private static function add_person_object($doc, $owner, $contact)
{
$object = $doc->createElement("activity:object"); $object = $doc->createElement("activity:object");
xml::add_element($doc, $object, "activity:object-type", ACTIVITY_OBJ_PERSON); xml::add_element($doc, $object, "activity:object-type", ACTIVITY_OBJ_PERSON);
@ -1700,8 +1736,11 @@ class ostatus {
$item['follow'] = $contact['alias']; $item['follow'] = $contact['alias'];
} }
$r = q("SELECT `id` FROM `contact` WHERE `uid` = %d AND `nurl` = '%s'", $r = q(
intval($owner['uid']), dbesc(normalise_link($contact["url"]))); "SELECT `id` FROM `contact` WHERE `uid` = %d AND `nurl` = '%s'",
intval($owner['uid']),
dbesc(normalise_link($contact["url"]))
);
if (DBM::is_result($r)) { if (DBM::is_result($r)) {
$connect_id = $r[0]['id']; $connect_id = $r[0]['id'];
@ -1719,8 +1758,8 @@ class ostatus {
$action = "unfollow"; $action = "unfollow";
} }
$item["uri"] = $item['parent-uri'] = $item['thr-parent'] = $item["uri"] = $item['parent-uri'] = $item['thr-parent']
'tag:'.get_app()->get_hostname(). = 'tag:'.get_app()->get_hostname().
','.date('Y-m-d').':'.$action.':'.$owner['uid']. ','.date('Y-m-d').':'.$action.':'.$owner['uid'].
':person:'.$connect_id.':'.$item['created']; ':person:'.$connect_id.':'.$item['created'];
@ -1748,8 +1787,8 @@ class ostatus {
* *
* @return object Entry element * @return object Entry element
*/ */
private static function note_entry($doc, $item, $owner, $toplevel) { private static function note_entry($doc, $item, $owner, $toplevel)
{
if (($item["id"] != $item["parent"]) && (normalise_link($item["author-link"]) != normalise_link($owner["url"]))) { if (($item["id"] != $item["parent"]) && (normalise_link($item["author-link"]) != normalise_link($owner["url"]))) {
logger("OStatus entry is from author ".$owner["url"]." - not from ".$item["author-link"].". Quitting.", LOGGER_DEBUG); logger("OStatus entry is from author ".$owner["url"]." - not from ".$item["author-link"].". Quitting.", LOGGER_DEBUG);
} }
@ -1775,7 +1814,8 @@ class ostatus {
* *
* @return string The title for the element * @return string The title for the element
*/ */
private static function entry_header($doc, &$entry, $owner, $toplevel) { private static function entry_header($doc, &$entry, $owner, $toplevel)
{
/// @todo Check if this title stuff is really needed (I guess not) /// @todo Check if this title stuff is really needed (I guess not)
if (!$toplevel) { if (!$toplevel) {
$entry = $doc->createElement("entry"); $entry = $doc->createElement("entry");
@ -1811,10 +1851,11 @@ class ostatus {
* @param string $verb The activity verb * @param string $verb The activity verb
* @param bool $complete Add the "status_net" element? * @param bool $complete Add the "status_net" element?
*/ */
private static function entry_content($doc, $entry, $item, $owner, $title, $verb = "", $complete = true) { private static function entry_content($doc, $entry, $item, $owner, $title, $verb = "", $complete = true)
{
if ($verb == "") if ($verb == "") {
$verb = self::construct_verb($item); $verb = self::construct_verb($item);
}
xml::add_element($doc, $entry, "id", $item["uri"]); xml::add_element($doc, $entry, "id", $item["uri"]);
xml::add_element($doc, $entry, "title", $title); xml::add_element($doc, $entry, "title", $title);
@ -1829,15 +1870,17 @@ class ostatus {
xml::add_element($doc, $entry, "content", $body, array("type" => "html")); xml::add_element($doc, $entry, "content", $body, array("type" => "html"));
xml::add_element($doc, $entry, "link", "", array("rel" => "alternate", "type" => "text/html", xml::add_element($doc, $entry, "link", "", array("rel" => "alternate", "type" => "text/html",
"href" => System::baseUrl()."/display/".$item["guid"])); "href" => System::baseUrl()."/display/".$item["guid"])
);
if ($complete && ($item["id"] > 0)) if ($complete && ($item["id"] > 0)) {
xml::add_element($doc, $entry, "status_net", "", array("notice_id" => $item["id"])); xml::add_element($doc, $entry, "status_net", "", array("notice_id" => $item["id"]));
}
xml::add_element($doc, $entry, "activity:verb", $verb); xml::add_element($doc, $entry, "activity:verb", $verb);
xml::add_element($doc, $entry, "published", datetime_convert("UTC","UTC",$item["created"]."+00:00",ATOM_TIME)); xml::add_element($doc, $entry, "published", datetime_convert("UTC", "UTC", $item["created"]."+00:00", ATOM_TIME));
xml::add_element($doc, $entry, "updated", datetime_convert("UTC","UTC",$item["edited"]."+00:00",ATOM_TIME)); xml::add_element($doc, $entry, "updated", datetime_convert("UTC", "UTC", $item["edited"]."+00:00", ATOM_TIME));
} }
/** /**
@ -1847,19 +1890,21 @@ class ostatus {
* @param object $entry The entry element where the elements are added * @param object $entry The entry element where the elements are added
* @param array $item Data of the item that is to be posted * @param array $item Data of the item that is to be posted
* @param array $owner Contact data of the poster * @param array $owner Contact data of the poster
* @param $complete * @param bool $complete default true
*/ */
private static function entry_footer($doc, $entry, $item, $owner, $complete = true) { private static function entry_footer($doc, $entry, $item, $owner, $complete = true)
{
$mentioned = array(); $mentioned = array();
if (($item['parent'] != $item['id']) || ($item['parent-uri'] !== $item['uri']) || (($item['thr-parent'] !== '') && ($item['thr-parent'] !== $item['uri']))) { if (($item['parent'] != $item['id']) || ($item['parent-uri'] !== $item['uri']) || (($item['thr-parent'] !== '') && ($item['thr-parent'] !== $item['uri']))) {
$parent = q("SELECT `guid`, `author-link`, `owner-link` FROM `item` WHERE `id` = %d", intval($item["parent"])); $parent = q("SELECT `guid`, `author-link`, `owner-link` FROM `item` WHERE `id` = %d", intval($item["parent"]));
$parent_item = (($item['thr-parent']) ? $item['thr-parent'] : $item['parent-uri']); $parent_item = (($item['thr-parent']) ? $item['thr-parent'] : $item['parent-uri']);
$thrparent = q("SELECT `guid`, `author-link`, `owner-link`, `plink` FROM `item` WHERE `uid` = %d AND `uri` = '%s'", $thrparent = q(
"SELECT `guid`, `author-link`, `owner-link`, `plink` FROM `item` WHERE `uid` = %d AND `uri` = '%s'",
intval($owner["uid"]), intval($owner["uid"]),
dbesc($parent_item)); dbesc($parent_item)
);
if ($thrparent) { if ($thrparent) {
$mentioned[$thrparent[0]["author-link"]] = $thrparent[0]["author-link"]; $mentioned[$thrparent[0]["author-link"]] = $thrparent[0]["author-link"];
$mentioned[$thrparent[0]["owner-link"]] = $thrparent[0]["owner-link"]; $mentioned[$thrparent[0]["owner-link"]] = $thrparent[0]["owner-link"];
@ -1909,31 +1954,43 @@ class ostatus {
$tags = item_getfeedtags($item); $tags = item_getfeedtags($item);
if (count($tags)) if (count($tags)) {
foreach ($tags as $t) foreach ($tags as $t) {
if ($t[0] == "@") if ($t[0] == "@") {
$mentioned[$t[1]] = $t[1]; $mentioned[$t[1]] = $t[1];
}
}
}
// Make sure that mentions are accepted (GNU Social has problems with mixing HTTP and HTTPS) // Make sure that mentions are accepted (GNU Social has problems with mixing HTTP and HTTPS)
$newmentions = array(); $newmentions = array();
foreach ($mentioned AS $mention) { foreach ($mentioned as $mention) {
$newmentions[str_replace("http://", "https://", $mention)] = str_replace("http://", "https://", $mention); $newmentions[str_replace("http://", "https://", $mention)] = str_replace("http://", "https://", $mention);
$newmentions[str_replace("https://", "http://", $mention)] = str_replace("https://", "http://", $mention); $newmentions[str_replace("https://", "http://", $mention)] = str_replace("https://", "http://", $mention);
} }
$mentioned = $newmentions; $mentioned = $newmentions;
foreach ($mentioned AS $mention) { foreach ($mentioned as $mention) {
$r = q("SELECT `forum`, `prv` FROM `contact` WHERE `uid` = %d AND `nurl` = '%s'", $r = q(
"SELECT `forum`, `prv` FROM `contact` WHERE `uid` = %d AND `nurl` = '%s'",
intval($owner["uid"]), intval($owner["uid"]),
dbesc(normalise_link($mention))); dbesc(normalise_link($mention))
if ($r[0]["forum"] || $r[0]["prv"]) );
xml::add_element($doc, $entry, "link", "", array("rel" => "mentioned", if ($r[0]["forum"] || $r[0]["prv"]) {
xml::add_element($doc, $entry, "link", "",
array(
"rel" => "mentioned",
"ostatus:object-type" => ACTIVITY_OBJ_GROUP, "ostatus:object-type" => ACTIVITY_OBJ_GROUP,
"href" => $mention)); "href" => $mention)
else );
xml::add_element($doc, $entry, "link", "", array("rel" => "mentioned", } else {
xml::add_element($doc, $entry, "link", "",
array(
"rel" => "mentioned",
"ostatus:object-type" => ACTIVITY_OBJ_PERSON, "ostatus:object-type" => ACTIVITY_OBJ_PERSON,
"href" => $mention)); "href" => $mention)
);
}
} }
if (!$item["private"]) { if (!$item["private"]) {
@ -1945,10 +2002,13 @@ class ostatus {
xml::add_element($doc, $entry, "mastodon:scope", "public"); xml::add_element($doc, $entry, "mastodon:scope", "public");
} }
if (count($tags)) if (count($tags)) {
foreach ($tags as $t) foreach ($tags as $t) {
if ($t[0] != "@") if ($t[0] != "@") {
xml::add_element($doc, $entry, "category", "", array("term" => $t[2])); xml::add_element($doc, $entry, "category", "", array("term" => $t[2]));
}
}
}
self::get_attachment($doc, $entry, $item); self::get_attachment($doc, $entry, $item);
@ -1959,11 +2019,13 @@ class ostatus {
$attributes = array("local_id" => $item["id"], "source" => $app); $attributes = array("local_id" => $item["id"], "source" => $app);
if (isset($parent["id"])) if (isset($parent["id"])) {
$attributes["repeat_of"] = $parent["id"]; $attributes["repeat_of"] = $parent["id"];
}
if ($item["coord"] != "") if ($item["coord"] != "") {
xml::add_element($doc, $entry, "georss:point", $item["coord"]); xml::add_element($doc, $entry, "georss:point", $item["coord"]);
}
xml::add_element($doc, $entry, "statusnet:notice_info", "", $attributes); xml::add_element($doc, $entry, "statusnet:notice_info", "", $attributes);
} }
@ -1972,14 +2034,15 @@ class ostatus {
/** /**
* @brief Creates the XML feed for a given nickname * @brief Creates the XML feed for a given nickname
* *
* @param App $a The application class * @param object $a The application class
* @param string $owner_nick Nickname of the feed owner * @param string $owner_nick Nickname of the feed owner
* @param string $last_update Date of the last update * @param string $last_update Date of the last update
* @param integer $max_items Number of maximum items to fetch * @param integer $max_items Number of maximum items to fetch
* *
* @return string XML feed * @return string XML feed
*/ */
public static function feed(App $a, $owner_nick, &$last_update, $max_items = 300) { public static function feed(App $a, $owner_nick, &$last_update, $max_items = 300)
{
$stamp = microtime(true); $stamp = microtime(true);
$cachekey = "ostatus:feed:".$owner_nick.":".$last_update; $cachekey = "ostatus:feed:".$owner_nick.":".$last_update;
@ -1993,10 +2056,12 @@ class ostatus {
return $result['feed']; return $result['feed'];
} }
$r = q("SELECT `contact`.*, `user`.`nickname`, `user`.`timezone`, `user`.`page-flags` $r = q(
"SELECT `contact`.*, `user`.`nickname`, `user`.`timezone`, `user`.`page-flags`
FROM `contact` INNER JOIN `user` ON `user`.`uid` = `contact`.`uid` FROM `contact` INNER JOIN `user` ON `user`.`uid` = `contact`.`uid`
WHERE `contact`.`self` AND `user`.`nickname` = '%s' LIMIT 1", WHERE `contact`.`self` AND `user`.`nickname` = '%s' LIMIT 1",
dbesc($owner_nick)); dbesc($owner_nick)
);
if (!DBM::is_result($r)) { if (!DBM::is_result($r)) {
return; return;
} }
@ -2007,10 +2072,11 @@ class ostatus {
$last_update = 'now -30 days'; $last_update = 'now -30 days';
} }
$check_date = datetime_convert('UTC','UTC',$last_update,'Y-m-d H:i:s'); $check_date = datetime_convert('UTC', 'UTC', $last_update, 'Y-m-d H:i:s');
$authorid = get_contact($owner["url"], 0); $authorid = get_contact($owner["url"], 0);
$items = q("SELECT `item`.*, `item`.`id` AS `item_id` FROM `item` USE INDEX (`uid_contactid_created`) $items = q(
"SELECT `item`.*, `item`.`id` AS `item_id` FROM `item` USE INDEX (`uid_contactid_created`)
STRAIGHT_JOIN `thread` ON `thread`.`iid` = `item`.`parent` STRAIGHT_JOIN `thread` ON `thread`.`iid` = `item`.`parent`
WHERE `item`.`uid` = %d AND `item`.`contact-id` = %d AND WHERE `item`.`uid` = %d AND `item`.`contact-id` = %d AND
`item`.`author-id` = %d AND `item`.`created` > '%s' AND `item`.`author-id` = %d AND `item`.`created` > '%s' AND
@ -2019,14 +2085,15 @@ class ostatus {
ORDER BY `item`.`created` DESC LIMIT %d", ORDER BY `item`.`created` DESC LIMIT %d",
intval($owner["uid"]), intval($owner["id"]), intval($owner["uid"]), intval($owner["id"]),
intval($authorid), dbesc($check_date), intval($authorid), dbesc($check_date),
dbesc(NETWORK_OSTATUS), dbesc(NETWORK_DFRN), intval($max_items)); dbesc(NETWORK_OSTATUS), dbesc(NETWORK_DFRN), intval($max_items)
);
$doc = new DOMDocument('1.0', 'utf-8'); $doc = new DOMDocument('1.0', 'utf-8');
$doc->formatOutput = true; $doc->formatOutput = true;
$root = self::add_header($doc, $owner); $root = self::add_header($doc, $owner);
foreach ($items AS $item) { foreach ($items as $item) {
if (Config::get('system', 'ostatus_debug')) { if (Config::get('system', 'ostatus_debug')) {
$item['body'] .= '🍼'; $item['body'] .= '🍼';
} }
@ -2056,8 +2123,8 @@ class ostatus {
* *
* @return string XML for the salmon * @return string XML for the salmon
*/ */
public static function salmon($item,$owner) { public static function salmon($item, $owner)
{
$doc = new DOMDocument('1.0', 'utf-8'); $doc = new DOMDocument('1.0', 'utf-8');
$doc->formatOutput = true; $doc->formatOutput = true;

View File

@ -3,7 +3,7 @@
* @file include/photos.php * @file include/photos.php
* @brief Functions related to photo handling. * @brief Functions related to photo handling.
*/ */
use Friendica\Core\Cache;
use Friendica\Core\Config; use Friendica\Core\Config;
use Friendica\Core\PConfig; use Friendica\Core\PConfig;

View File

@ -1,5 +1,8 @@
<?php <?php
/**
* @file include/queue.php
*/
use Friendica\Core\Cache;
use Friendica\Core\Config; use Friendica\Core\Config;
use Friendica\Core\Worker; use Friendica\Core\Worker;
use Friendica\Database\DBM; use Friendica\Database\DBM;
@ -11,9 +14,9 @@ require_once 'include/datetime.php';
require_once 'include/items.php'; require_once 'include/items.php';
require_once 'include/bbcode.php'; require_once 'include/bbcode.php';
require_once 'include/socgraph.php'; require_once 'include/socgraph.php';
require_once 'include/cache.php';
function queue_run(&$argv, &$argc) { function queue_run(&$argv, &$argc)
{
global $a; global $a;
if ($argc > 1) { if ($argc > 1) {
@ -26,15 +29,16 @@ function queue_run(&$argv, &$argc) {
$cachekey_server = 'queue_run:server:'; $cachekey_server = 'queue_run:server:';
if (!$queue_id) { if (!$queue_id) {
logger('queue: start'); logger('queue: start');
// Handling the pubsubhubbub requests // Handling the pubsubhubbub requests
Worker::add(array('priority' => PRIORITY_HIGH, 'dont_fork' => true), 'pubsubpublish'); Worker::add(array('priority' => PRIORITY_HIGH, 'dont_fork' => true), 'pubsubpublish');
$r = q("SELECT `queue`.*, `contact`.`name`, `contact`.`uid` FROM `queue` $r = q(
"SELECT `queue`.*, `contact`.`name`, `contact`.`uid` FROM `queue`
INNER JOIN `contact` ON `queue`.`cid` = `contact`.`id` INNER JOIN `contact` ON `queue`.`cid` = `contact`.`id`
WHERE `queue`.`created` < UTC_TIMESTAMP() - INTERVAL 3 DAY"); WHERE `queue`.`created` < UTC_TIMESTAMP() - INTERVAL 3 DAY"
);
if (DBM::is_result($r)) { if (DBM::is_result($r)) {
foreach ($r as $rr) { foreach ($r as $rr) {
@ -64,10 +68,12 @@ function queue_run(&$argv, &$argc) {
// delivering // delivering
require_once 'include/salmon.php'; include_once 'include/salmon.php';
$r = q("SELECT * FROM `queue` WHERE `id` = %d LIMIT 1", $r = q(
intval($queue_id)); "SELECT * FROM `queue` WHERE `id` = %d LIMIT 1",
intval($queue_id)
);
if (!DBM::is_result($r)) { if (!DBM::is_result($r)) {
return; return;
@ -75,7 +81,8 @@ function queue_run(&$argv, &$argc) {
$q_item = $r[0]; $q_item = $r[0];
$c = q("SELECT * FROM `contact` WHERE `id` = %d LIMIT 1", $c = q(
"SELECT * FROM `contact` WHERE `id` = %d LIMIT 1",
intval($q_item['cid']) intval($q_item['cid'])
); );
@ -111,7 +118,8 @@ function queue_run(&$argv, &$argc) {
} }
} }
$u = q("SELECT `user`.*, `user`.`pubkey` AS `upubkey`, `user`.`prvkey` AS `uprvkey` $u = q(
"SELECT `user`.*, `user`.`pubkey` AS `upubkey`, `user`.`prvkey` AS `uprvkey`
FROM `user` WHERE `uid` = %d LIMIT 1", FROM `user` WHERE `uid` = %d LIMIT 1",
intval($c[0]['uid']) intval($c[0]['uid'])
); );
@ -176,7 +184,6 @@ function queue_run(&$argv, &$argc) {
update_queue_time($q_item['id']); update_queue_time($q_item['id']);
} }
break; break;
} }
logger('Deliver status '.(int)$deliver_status.' for item '.$q_item['id'].' to '.$contact['name'].' <'.$contact['url'].'>'); logger('Deliver status '.(int)$deliver_status.' for item '.$q_item['id'].' to '.$contact['name'].' <'.$contact['url'].'>');

View File

@ -1,27 +1,28 @@
<?php <?php
// Session management functions. These provide database storage of PHP /**
// session info. * Session management functions. These provide database storage of PHP session info.
*/
use Friendica\Core\Cache;
use Friendica\Core\Config; use Friendica\Core\Config;
use Friendica\Database\DBM; use Friendica\Database\DBM;
require_once('include/cache.php');
$session_exists = 0; $session_exists = 0;
$session_expire = 180000; $session_expire = 180000;
function ref_session_open($s, $n) { function ref_session_open($s, $n)
{
return true; return true;
} }
function ref_session_read($id) { function ref_session_read($id)
{
global $session_exists; global $session_exists;
if (!x($id)) { if (!x($id)) {
return ''; return '';
} }
$memcache = cache::memcache(); $memcache = Cache::memcache();
if (is_object($memcache)) { if (is_object($memcache)) {
$data = $memcache->get(get_app()->get_hostname().":session:".$id); $data = $memcache->get(get_app()->get_hostname().":session:".$id);
if (!is_bool($data)) { if (!is_bool($data)) {
@ -56,7 +57,8 @@ function ref_session_read($id) {
* @param string $data Serialized session data * @param string $data Serialized session data
* @return boolean Returns false if parameters are missing, true otherwise * @return boolean Returns false if parameters are missing, true otherwise
*/ */
function ref_session_write($id, $data) { function ref_session_write($id, $data)
{
global $session_exists, $session_expire; global $session_exists, $session_expire;
if (!$id || !$data) { if (!$id || !$data) {
@ -66,7 +68,7 @@ function ref_session_write($id, $data) {
$expire = time() + $session_expire; $expire = time() + $session_expire;
$default_expire = time() + 300; $default_expire = time() + 300;
$memcache = cache::memcache(); $memcache = Cache::memcache();
$a = get_app(); $a = get_app();
if (is_object($memcache) && is_object($a)) { if (is_object($memcache) && is_object($a)) {
$memcache->set($a->get_hostname().":session:".$id, $data, MEMCACHE_COMPRESSED, $expire); $memcache->set($a->get_hostname().":session:".$id, $data, MEMCACHE_COMPRESSED, $expire);
@ -85,12 +87,14 @@ function ref_session_write($id, $data) {
return true; return true;
} }
function ref_session_close() { function ref_session_close()
{
return true; return true;
} }
function ref_session_destroy($id) { function ref_session_destroy($id)
$memcache = cache::memcache(); {
$memcache = Cache::memcache();
if (is_object($memcache)) { if (is_object($memcache)) {
$memcache->delete(get_app()->get_hostname().":session:".$id); $memcache->delete(get_app()->get_hostname().":session:".$id);
@ -101,7 +105,8 @@ function ref_session_destroy($id) {
return true; return true;
} }
function ref_session_gc($expire) { function ref_session_gc($expire)
{
dba::delete('session', array("`expire` < ?", time())); dba::delete('session', array("`expire` < ?", time()));
return true; return true;
} }
@ -117,7 +122,9 @@ if (Config::get('system', 'ssl_policy') == SSL_POLICY_FULL) {
} }
if (!Config::get('system', 'disable_database_session')) { if (!Config::get('system', 'disable_database_session')) {
session_set_save_handler('ref_session_open', 'ref_session_close', session_set_save_handler(
'ref_session_open', 'ref_session_close',
'ref_session_read', 'ref_session_write', 'ref_session_read', 'ref_session_write',
'ref_session_destroy', 'ref_session_gc'); 'ref_session_destroy', 'ref_session_gc'
);
} }

View File

@ -9,6 +9,7 @@
use Friendica\App; use Friendica\App;
use Friendica\Core\System; use Friendica\Core\System;
use Friendica\Core\Cache;
use Friendica\Core\Config; use Friendica\Core\Config;
use Friendica\Core\Worker; use Friendica\Core\Worker;
use Friendica\Database\DBM; use Friendica\Database\DBM;

View File

@ -1,18 +1,20 @@
<?php <?php
/**
* @file include/ping.php
*/
use Friendica\App; use Friendica\App;
use Friendica\Core\Cache;
use Friendica\Core\System; use Friendica\Core\System;
use Friendica\Core\PConfig; use Friendica\Core\PConfig;
use Friendica\Database\DBM; use Friendica\Database\DBM;
require_once('include/datetime.php'); require_once 'include/datetime.php';
require_once('include/bbcode.php'); require_once 'include/bbcode.php';
require_once('include/ForumManager.php'); require_once 'include/ForumManager.php';
require_once('include/group.php'); require_once 'include/group.php';
require_once('mod/proxy.php'); require_once 'mod/proxy.php';
require_once('include/xml.php'); require_once 'include/xml.php';
require_once('include/cache.php'); require_once 'include/enotify.php';
require_once('include/enotify.php');
/** /**
* @brief Outputs the counts and the lists of various notifications * @brief Outputs the counts and the lists of various notifications
@ -96,10 +98,9 @@ function ping_init(App $a)
$data['birthdays'] = $birthdays; $data['birthdays'] = $birthdays;
$data['birthdays-today'] = $birthdays_today; $data['birthdays-today'] = $birthdays_today;
if (local_user()){ if (local_user()) {
// Different login session than the page that is calling us. // Different login session than the page that is calling us.
if (intval($_GET['uid']) && intval($_GET['uid']) != local_user()) { if (intval($_GET['uid']) && intval($_GET['uid']) != local_user()) {
$data = array('result' => array('invalid' => 1)); $data = array('result' => array('invalid' => 1));
if ($format == 'json') { if ($format == 'json') {
@ -120,7 +121,8 @@ function ping_init(App $a)
$notifs = ping_get_notifications(local_user()); $notifs = ping_get_notifications(local_user());
$items_unseen = q("SELECT `item`.`id`, `item`.`parent`, `item`.`verb`, `item`.`wall`, `item`.`author-name`, $items_unseen = q(
"SELECT `item`.`id`, `item`.`parent`, `item`.`verb`, `item`.`wall`, `item`.`author-name`,
`item`.`contact-id`, `item`.`author-link`, `item`.`author-avatar`, `item`.`created`, `item`.`object`, `item`.`contact-id`, `item`.`author-link`, `item`.`author-avatar`, `item`.`created`, `item`.`object`,
`pitem`.`author-name` AS `pname`, `pitem`.`author-link` AS `plink` `pitem`.`author-name` AS `pname`, `pitem`.`author-link` AS `plink`
FROM `item` INNER JOIN `item` AS `pitem` ON `pitem`.`id` = `item`.`parent` FROM `item` INNER JOIN `item` AS `pitem` ON `pitem`.`id` = `item`.`parent`
@ -128,7 +130,8 @@ function ping_init(App $a)
`item`.`deleted` = 0 AND `item`.`uid` = %d AND `pitem`.`parent` != 0 `item`.`deleted` = 0 AND `item`.`uid` = %d AND `pitem`.`parent` != 0
AND `item`.`contact-id` != %d AND `item`.`contact-id` != %d
ORDER BY `item`.`created` DESC", ORDER BY `item`.`created` DESC",
intval(local_user()), intval(local_user()) intval(local_user()),
intval(local_user())
); );
if (DBM::is_result($items_unseen)) { if (DBM::is_result($items_unseen)) {
@ -169,13 +172,15 @@ function ping_init(App $a)
} }
} }
$intros1 = q("SELECT `intro`.`id`, `intro`.`datetime`, $intros1 = q(
"SELECT `intro`.`id`, `intro`.`datetime`,
`fcontact`.`name`, `fcontact`.`url`, `fcontact`.`photo` `fcontact`.`name`, `fcontact`.`url`, `fcontact`.`photo`
FROM `intro` LEFT JOIN `fcontact` ON `intro`.`fid` = `fcontact`.`id` FROM `intro` LEFT JOIN `fcontact` ON `intro`.`fid` = `fcontact`.`id`
WHERE `intro`.`uid` = %d AND `intro`.`blocked` = 0 AND `intro`.`ignore` = 0 AND `intro`.`fid` != 0", WHERE `intro`.`uid` = %d AND `intro`.`blocked` = 0 AND `intro`.`ignore` = 0 AND `intro`.`fid` != 0",
intval(local_user()) intval(local_user())
); );
$intros2 = q("SELECT `intro`.`id`, `intro`.`datetime`, $intros2 = q(
"SELECT `intro`.`id`, `intro`.`datetime`,
`contact`.`name`, `contact`.`url`, `contact`.`photo` `contact`.`name`, `contact`.`url`, `contact`.`photo`
FROM `intro` LEFT JOIN `contact` ON `intro`.`contact-id` = `contact`.`id` FROM `intro` LEFT JOIN `contact` ON `intro`.`contact-id` = `contact`.`id`
WHERE `intro`.`uid` = %d AND `intro`.`blocked` = 0 AND `intro`.`ignore` = 0 AND `intro`.`contact-id` != 0", WHERE `intro`.`uid` = %d AND `intro`.`blocked` = 0 AND `intro`.`ignore` = 0 AND `intro`.`contact-id` != 0",
@ -186,17 +191,20 @@ function ping_init(App $a)
$intros = $intros1 + $intros2; $intros = $intros1 + $intros2;
$myurl = System::baseUrl() . '/profile/' . $a->user['nickname'] ; $myurl = System::baseUrl() . '/profile/' . $a->user['nickname'] ;
$mails = q("SELECT `id`, `from-name`, `from-url`, `from-photo`, `created` FROM `mail` $mails = q(
"SELECT `id`, `from-name`, `from-url`, `from-photo`, `created` FROM `mail`
WHERE `uid` = %d AND `seen` = 0 AND `from-url` != '%s' ", WHERE `uid` = %d AND `seen` = 0 AND `from-url` != '%s' ",
intval(local_user()), intval(local_user()),
dbesc($myurl) dbesc($myurl)
); );
$mail_count = count($mails); $mail_count = count($mails);
if ($a->config['register_policy'] == REGISTER_APPROVE && is_site_admin()){ if ($a->config['register_policy'] == REGISTER_APPROVE && is_site_admin()) {
$regs = q("SELECT `contact`.`name`, `contact`.`url`, `contact`.`micro`, `register`.`created`, COUNT(*) AS `total` $regs = q(
"SELECT `contact`.`name`, `contact`.`url`, `contact`.`micro`, `register`.`created`, COUNT(*) AS `total`
FROM `contact` RIGHT JOIN `register` ON `register`.`uid` = `contact`.`uid` FROM `contact` RIGHT JOIN `register` ON `register`.`uid` = `contact`.`uid`
WHERE `contact`.`self` = 1"); WHERE `contact`.`self` = 1"
);
if (DBM::is_result($regs)) { if (DBM::is_result($regs)) {
$register_count = $regs[0]['total']; $register_count = $regs[0]['total'];
@ -206,7 +214,8 @@ function ping_init(App $a)
$cachekey = "ping_init:".local_user(); $cachekey = "ping_init:".local_user();
$ev = Cache::get($cachekey); $ev = Cache::get($cachekey);
if (is_null($ev)) { if (is_null($ev)) {
$ev = q("SELECT type, start, adjust FROM `event` $ev = q(
"SELECT type, start, adjust FROM `event`
WHERE `event`.`uid` = %d AND `start` < '%s' AND `finish` > '%s' and `ignore` = 0 WHERE `event`.`uid` = %d AND `start` < '%s' AND `finish` > '%s' and `ignore` = 0
ORDER BY `start` ASC ", ORDER BY `start` ASC ",
intval(local_user()), intval(local_user()),
@ -223,25 +232,25 @@ function ping_init(App $a)
if ($all_events) { if ($all_events) {
$str_now = datetime_convert('UTC', $a->timezone, 'now', 'Y-m-d'); $str_now = datetime_convert('UTC', $a->timezone, 'now', 'Y-m-d');
foreach($ev as $x) { foreach ($ev as $x) {
$bd = false; $bd = false;
if ($x['type'] === 'birthday') { if ($x['type'] === 'birthday') {
$birthdays ++; $birthdays ++;
$bd = true; $bd = true;
} } else {
else {
$events ++; $events ++;
} }
if (datetime_convert('UTC', ((intval($x['adjust'])) ? $a->timezone : 'UTC'), $x['start'], 'Y-m-d') === $str_now) { if (datetime_convert('UTC', ((intval($x['adjust'])) ? $a->timezone : 'UTC'), $x['start'], 'Y-m-d') === $str_now) {
$all_events_today ++; $all_events_today ++;
if ($bd) if ($bd) {
$birthdays_today ++; $birthdays_today ++;
else } else {
$events_today ++; $events_today ++;
} }
} }
} }
} }
}
$data['intro'] = $intro_count; $data['intro'] = $intro_count;
$data['mail'] = $mail_count; $data['mail'] = $mail_count;
@ -311,7 +320,7 @@ function ping_init(App $a)
} }
// sort notifications by $[]['date'] // sort notifications by $[]['date']
$sort_function = function($a, $b) { $sort_function = function ($a, $b) {
$adate = strtotime($a['date']); $adate = strtotime($a['date']);
$bdate = strtotime($b['date']); $bdate = strtotime($b['date']);
@ -426,7 +435,8 @@ function ping_get_notifications($uid)
$a = get_app(); $a = get_app();
do { do {
$r = q("SELECT `notify`.*, `item`.`visible`, `item`.`spam`, `item`.`deleted` $r = q(
"SELECT `notify`.*, `item`.`visible`, `item`.`spam`, `item`.`deleted`
FROM `notify` LEFT JOIN `item` ON `item`.`id` = `notify`.`iid` FROM `notify` LEFT JOIN `item` ON `item`.`id` = `notify`.`iid`
WHERE `notify`.`uid` = %d AND `notify`.`msg` != '' WHERE `notify`.`uid` = %d AND `notify`.`msg` != ''
AND NOT (`notify`.`type` IN (%d, %d)) AND NOT (`notify`.`type` IN (%d, %d))
@ -448,7 +458,7 @@ function ping_get_notifications($uid)
$offset += 50; $offset += 50;
} }
foreach ($r AS $notification) { foreach ($r as $notification) {
if (is_null($notification["visible"])) { if (is_null($notification["visible"])) {
$notification["visible"] = true; $notification["visible"] = true;
} }
@ -468,7 +478,8 @@ function ping_get_notifications($uid)
$notification["name"] = strip_tags(bbcode($notification["name"])); $notification["name"] = strip_tags(bbcode($notification["name"]));
$notification["message"] = format_notification_message($notification["name"], strip_tags(bbcode($notification["msg"]))); $notification["message"] = format_notification_message($notification["name"], strip_tags(bbcode($notification["msg"])));
q("UPDATE `notify` SET `name_cache` = '%s', `msg_cache` = '%s' WHERE `id` = %d", q(
"UPDATE `notify` SET `name_cache` = '%s', `msg_cache` = '%s' WHERE `id` = %d",
dbesc($notification["name"]), dbesc($notification["name"]),
dbesc($notification["message"]), dbesc($notification["message"]),
intval($notification["id"]) intval($notification["id"])
@ -477,8 +488,9 @@ function ping_get_notifications($uid)
$notification["href"] = System::baseUrl() . "/notify/view/" . $notification["id"]; $notification["href"] = System::baseUrl() . "/notify/view/" . $notification["id"];
if ($notification["visible"] && !$notification["spam"] && if ($notification["visible"] && !$notification["spam"]
!$notification["deleted"] && !is_array($result[$notification["parent"]])) { && !$notification["deleted"] && !is_array($result[$notification["parent"]])
) {
// Should we condense the notifications or show them all? // Should we condense the notifications or show them all?
if (PConfig::get(local_user(), 'system', 'detailed_notif')) { if (PConfig::get(local_user(), 'system', 'detailed_notif')) {
$result[$notification["id"]] = $notification; $result[$notification["id"]] = $notification;
@ -497,7 +509,7 @@ function ping_get_notifications($uid)
* @deprecated * @deprecated
* *
* @param array $data The initial ping data array * @param array $data The initial ping data array
* @param int $sysnotify_count Number of unseen system notifications * @param int $sysnotify Number of unseen system notifications
* @param array $notifs Complete list of notification * @param array $notifs Complete list of notification
* @param array $sysmsgs List of system notice messages * @param array $sysmsgs List of system notice messages
* @param array $sysmsgs_info List of system info messages * @param array $sysmsgs_info List of system info messages
@ -508,7 +520,7 @@ function ping_get_notifications($uid)
function ping_format_xml_data($data, $sysnotify, $notifs, $sysmsgs, $sysmsgs_info, $groups_unseen, $forums_unseen) function ping_format_xml_data($data, $sysnotify, $notifs, $sysmsgs, $sysmsgs_info, $groups_unseen, $forums_unseen)
{ {
$notifications = array(); $notifications = array();
foreach($notifs as $key => $notif) { foreach ($notifs as $key => $notif) {
$notifications[$key . ':note'] = $notif['message']; $notifications[$key . ':note'] = $notif['message'];
$notifications[$key . ':@attributes'] = array( $notifications[$key . ':@attributes'] = array(
@ -524,10 +536,10 @@ function ping_format_xml_data($data, $sysnotify, $notifs, $sysmsgs, $sysmsgs_inf
} }
$sysmsg = array(); $sysmsg = array();
foreach ($sysmsgs as $key => $m){ foreach ($sysmsgs as $key => $m) {
$sysmsg[$key . ':notice'] = $m; $sysmsg[$key . ':notice'] = $m;
} }
foreach ($sysmsgs_info as $key => $m){ foreach ($sysmsgs_info as $key => $m) {
$sysmsg[$key . ':info'] = $m; $sysmsg[$key . ':info'] = $m;
} }

View File

@ -4,6 +4,7 @@
// https://web.archive.org/web/20160405005550/http://portablecontacts.net/draft-spec.html // https://web.archive.org/web/20160405005550/http://portablecontacts.net/draft-spec.html
use Friendica\App; use Friendica\App;
use Friendica\Core\Cache;
use Friendica\Core\Config; use Friendica\Core\Config;
use Friendica\Database\DBM; use Friendica\Database\DBM;

View File

@ -1,6 +1,7 @@
<?php <?php
use Friendica\App; use Friendica\App;
use Friendica\Core\Cache;
use Friendica\Core\Config; use Friendica\Core\Config;
use Friendica\Database\DBM; use Friendica\Database\DBM;

View File

@ -3,11 +3,11 @@
namespace Friendica; namespace Friendica;
use Friendica\Core\System; use Friendica\Core\System;
use Friendica\Core\Cache;
use Friendica\Core\Config; use Friendica\Core\Config;
use Friendica\Core\PConfig; use Friendica\Core\PConfig;
use Friendica\Database\DBM; use Friendica\Database\DBM;
use Cache;
use dba; use dba;
use Detection\MobileDetect; use Detection\MobileDetect;

243
src/Core/Cache.php Normal file
View File

@ -0,0 +1,243 @@
<?php
/**
* @file src/Core/Cache.php
*/
namespace Friendica\Core;
use Friendica\Core\Config;
use Friendica\Core\PConfig;
use Friendica\Database\DBM;
/**
* @brief Class for storing data for a short time
*/
class Cache
{
/**
* @brief Check for memcache and open a connection if configured
*
* @return object|boolean The memcache object - or "false" if not successful
*/
public static function memcache()
{
if (!function_exists('memcache_connect')) {
return false;
}
if (!Config::get('system', 'memcache')) {
return false;
}
$memcache_host = Config::get('system', 'memcache_host', '127.0.0.1');
$memcache_port = Config::get('system', 'memcache_port', 11211);
$memcache = new Memcache;
if (!$memcache->connect($memcache_host, $memcache_port)) {
return false;
}
return $memcache;
}
/**
* @brief Return the duration for a given cache level
*
* @param integer $level Cache level
*
* @return integer The cache duration in seconds
*/
private static function duration($level)
{
switch ($level) {
case CACHE_MONTH:
$seconds = 2592000;
break;
case CACHE_WEEK:
$seconds = 604800;
break;
case CACHE_DAY:
$seconds = 86400;
break;
case CACHE_HOUR:
$seconds = 3600;
break;
case CACHE_HALF_HOUR:
$seconds = 1800;
break;
case CACHE_QUARTER_HOUR:
$seconds = 900;
break;
case CACHE_FIVE_MINUTES:
$seconds = 300;
break;
case CACHE_MINUTE:
$seconds = 60;
break;
}
return $seconds;
}
/**
* @brief Fetch cached data according to the key
*
* @param string $key The key to the cached data
*
* @return mixed Cached $value or "null" if not found
*/
public static function get($key)
{
$memcache = self::memcache();
if (is_object($memcache)) {
// We fetch with the hostname as key to avoid problems with other applications
$cached = $memcache->get(get_app()->get_hostname().":".$key);
$value = @unserialize($cached);
// Only return a value if the serialized value is valid.
// We also check if the db entry is a serialized
// boolean 'false' value (which we want to return).
if ($cached === serialize(false) || $value !== false) {
return $value;
}
return null;
}
// Frequently clear cache
self::clear($duration);
$r = q(
"SELECT `v` FROM `cache` WHERE `k`='%s' LIMIT 1",
dbesc($key)
);
if (DBM::is_result($r)) {
$cached = $r[0]['v'];
$value = @unserialize($cached);
// Only return a value if the serialized value is valid.
// We also check if the db entry is a serialized
// boolean 'false' value (which we want to return).
if ($cached === serialize(false) || $value !== false) {
return $value;
}
}
return null;
}
/**
* @brief Put data in the cache according to the key
*
* The input $value can have multiple formats.
*
* @param string $key The key to the cached data
* @param mixed $value The value that is about to be stored
* @param integer $duration The cache lifespan
*/
public static function set($key, $value, $duration = CACHE_MONTH)
{
// Do we have an installed memcache? Use it instead.
$memcache = self::memcache();
if (is_object($memcache)) {
// We store with the hostname as key to avoid problems with other applications
$memcache->set(get_app()->get_hostname().":".$key, serialize($value), MEMCACHE_COMPRESSED, self::duration($duration));
return;
}
/// @todo store the cache data in the same way like the config data
q(
"REPLACE INTO `cache` (`k`,`v`,`expire_mode`,`updated`) VALUES ('%s','%s',%d,'%s')",
dbesc($key),
dbesc(serialize($value)),
intval($duration),
dbesc(datetime_convert())
);
}
/**
* @brief Remove outdated data from the cache
*
* @param integer $max_level The maximum cache level that is to be cleared
*/
public static function clear($max_level = CACHE_MONTH)
{
// Clear long lasting cache entries only once a day
if (Config::get("system", "cache_cleared_day") < time() - self::duration(CACHE_DAY)) {
if ($max_level == CACHE_MONTH) {
q(
"DELETE FROM `cache` WHERE `updated` < '%s' AND `expire_mode` = %d",
dbesc(datetime_convert('UTC', 'UTC', "now - 30 days")),
intval(CACHE_MONTH)
);
}
if ($max_level <= CACHE_WEEK) {
q(
"DELETE FROM `cache` WHERE `updated` < '%s' AND `expire_mode` = %d",
dbesc(datetime_convert('UTC', 'UTC', "now - 7 days")),
intval(CACHE_WEEK)
);
}
if ($max_level <= CACHE_DAY) {
q(
"DELETE FROM `cache` WHERE `updated` < '%s' AND `expire_mode` = %d",
dbesc(datetime_convert('UTC', 'UTC', "now - 1 days")),
intval(CACHE_DAY)
);
}
Config::set("system", "cache_cleared_day", time());
}
if (($max_level <= CACHE_HOUR) && (Config::get("system", "cache_cleared_hour")) < time() - self::duration(CACHE_HOUR)) {
q(
"DELETE FROM `cache` WHERE `updated` < '%s' AND `expire_mode` = %d",
dbesc(datetime_convert('UTC', 'UTC', "now - 1 hours")),
intval(CACHE_HOUR)
);
Config::set("system", "cache_cleared_hour", time());
}
if (($max_level <= CACHE_HALF_HOUR) && (Config::get("system", "cache_cleared_half_hour")) < time() - self::duration(CACHE_HALF_HOUR)) {
q(
"DELETE FROM `cache` WHERE `updated` < '%s' AND `expire_mode` = %d",
dbesc(datetime_convert('UTC', 'UTC', "now - 30 minutes")),
intval(CACHE_HALF_HOUR)
);
Config::set("system", "cache_cleared_half_hour", time());
}
if (($max_level <= CACHE_QUARTER_HOUR) && (Config::get("system", "cache_cleared_quarter_hour")) < time() - self::duration(CACHE_QUARTER_HOUR)) {
q(
"DELETE FROM `cache` WHERE `updated` < '%s' AND `expire_mode` = %d",
dbesc(datetime_convert('UTC', 'UTC', "now - 15 minutes")),
intval(CACHE_QUARTER_HOUR)
);
Config::set("system", "cache_cleared_quarter_hour", time());
}
if (($max_level <= CACHE_FIVE_MINUTES) && (Config::get("system", "cache_cleared_five_minute")) < time() - self::duration(CACHE_FIVE_MINUTES)) {
q(
"DELETE FROM `cache` WHERE `updated` < '%s' AND `expire_mode` = %d",
dbesc(datetime_convert('UTC', 'UTC', "now - 5 minutes")),
intval(CACHE_FIVE_MINUTES)
);
Config::set("system", "cache_cleared_five_minute", time());
}
if (($max_level <= CACHE_MINUTE) && (Config::get("system", "cache_cleared_minute")) < time() - self::duration(CACHE_MINUTE)) {
q(
"DELETE FROM `cache` WHERE `updated` < '%s' AND `expire_mode` = %d",
dbesc(datetime_convert('UTC', 'UTC', "now - 1 minutes")),
intval(CACHE_MINUTE)
);
Config::set("system", "cache_cleared_minute", time());
}
}
}

View File

@ -10,11 +10,11 @@ namespace Friendica\Network;
use Friendica\App; use Friendica\App;
use Friendica\Core\System; use Friendica\Core\System;
use Friendica\Core\Cache;
use Friendica\Core\Config; use Friendica\Core\Config;
use Friendica\Database\DBM; use Friendica\Database\DBM;
use dba; use dba;
use Cache;
use xml; use xml;
use DomXPath; use DomXPath;

View File

@ -11,13 +11,13 @@ namespace Friendica\Protocol;
use Friendica\App; use Friendica\App;
use Friendica\Core\System; use Friendica\Core\System;
use Friendica\Core\Cache;
use Friendica\Core\Config; use Friendica\Core\Config;
use Friendica\Core\PConfig; use Friendica\Core\PConfig;
use Friendica\Core\Worker; use Friendica\Core\Worker;
use Friendica\Database\DBM; use Friendica\Database\DBM;
use Friendica\Network\Probe; use Friendica\Network\Probe;
use Cache;
use dba; use dba;
use SimpleXMLElement; use SimpleXMLElement;
use xml; use xml;

View File

@ -7,6 +7,7 @@
<exclude name="PEAR.NamingConventions.ValidVariableName.PrivateNoUnderscore"/> <exclude name="PEAR.NamingConventions.ValidVariableName.PrivateNoUnderscore"/>
<exclude name="PEAR.NamingConventions.ValidFunctionName.PrivateNoUnderscore"/> <exclude name="PEAR.NamingConventions.ValidFunctionName.PrivateNoUnderscore"/>
<exclude name="PEAR.NamingConventions.ValidFunctionName.ScopeNotCamelCaps"/> <exclude name="PEAR.NamingConventions.ValidFunctionName.ScopeNotCamelCaps"/>
<exclude name="PEAR.WhiteSpace.ScopeIndent.IncorrectExact"/>
<exclude name="PSR1.Methods.CamelCapsMethodName.NotCamelCaps"/> <exclude name="PSR1.Methods.CamelCapsMethodName.NotCamelCaps"/>
</rule> </rule>
<description>PSR2 with tabs instead of spaces.</description> <description>PSR2 with tabs instead of spaces.</description>