friendica
/
friendica
mirror of https://github.com/friendica/friendica
6
0
Fork 1
Code Issues Packages Projects Releases 1 Wiki Activity

The central item fetch does work now and the API now uses these functions

This commit is contained in:
Michael 2018-06-09 16:56:37 +00:00
parent 4874e589f1
commit baf316e898
4 changed files with 324 additions and 315 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

435
include/api.php
View File

@ -686,14 +686,8 @@ function api_get_user(App $a, $contact_id = null)
$uinfo[0]['network'] = NETWORK_DFRN; $uinfo[0]['network'] = NETWORK_DFRN;
} }
$usr = q( $usr = dba::selectFirst('user', ['default-location'], ['uid' => api_user()]);
"SELECT * FROM `user` WHERE `uid` = %d LIMIT 1", $profile = dba::selectFirst('profile', ['about'], ['uid' => api_user(), 'is-default' => true]);
intval(api_user())
);
$profile = q(
"SELECT * FROM `profile` WHERE `uid` = %d AND `is-default` = 1 LIMIT 1",
intval(api_user())
);
/// @TODO old-lost code? (twice) /// @TODO old-lost code? (twice)
// Counting is deactivated by now, due to performance issues // Counting is deactivated by now, due to performance issues
@ -760,14 +754,14 @@ function api_get_user(App $a, $contact_id = null)
$pcontact_id = Contact::getIdForURL($uinfo[0]['url'], 0, true); $pcontact_id = Contact::getIdForURL($uinfo[0]['url'], 0, true);
if (!empty($profile[0]['about'])) { if (!empty($profile['about'])) {
$description = $profile[0]['about']; $description = $profile['about'];
} else { } else {
$description = $uinfo[0]["about"]; $description = $uinfo[0]["about"];
} }
if (!empty($usr[0]['default-location'])) { if (!empty($usr['default-location'])) {
$location = $usr[0]['default-location']; $location = $usr['default-location'];
} elseif (!empty($uinfo[0]["location"])) { } elseif (!empty($uinfo[0]["location"])) {
$location = $uinfo[0]["location"]; $location = $uinfo[0]["location"];
} else { } else {
@ -1602,7 +1596,6 @@ function api_search($type)
} }
$data = []; $data = [];
$sql_extra = '';
if (!x($_REQUEST, 'q')) { if (!x($_REQUEST, 'q')) {
throw new BadRequestException("q parameter is required."); throw new BadRequestException("q parameter is required.");
@ -1622,24 +1615,20 @@ function api_search($type)
$start = $page * $count; $start = $page * $count;
if ($max_id > 0) { $condition = ["`verb` = ? AND `item`.`id` > ?
$sql_extra .= ' AND `item`.`id` <= ' . intval($max_id); AND (`item`.`uid` = 0 OR (`item`.`uid` = ? AND NOT `item`.`global`))
} AND `item`.`body` LIKE CONCAT('%',?,'%')",
ACTIVITY_POST, $since_id, api_user(), $_REQUEST['q']];
$r = dba::p( if ($max_id > 0) {
"SELECT ".item_fieldlists()." $condition[0] .= " AND `item`.`id` <= ?";
FROM `item` ".item_joins(api_user())." $condition[] = $max_id;
WHERE ".item_condition()." AND (`item`.`uid` = 0 OR (`item`.`uid` = ? AND NOT `item`.`global`)) }
AND `item`.`body` LIKE CONCAT('%',?,'%')
$sql_extra
AND `item`.`id`>?
ORDER BY `item`.`id` DESC LIMIT ".intval($start)." ,".intval($count)." ",
api_user(),
$_REQUEST['q'],
$since_id
);
$data['status'] = api_format_items(dba::inArray($r), $user_info); $params = ['order' => ['id' => true], 'limit' => [$start, $count]];
$statuses = Item::select(api_user(), [], $condition, $params);
$data['status'] = api_format_items(dba::inArray($statuses), $user_info);
return api_format_data("statuses", $type, $data); return api_format_data("statuses", $type, $data);
} }
@ -1689,33 +1678,24 @@ function api_statuses_home_timeline($type)
$start = $page * $count; $start = $page * $count;
$sql_extra = ''; $condition = ["`uid` = ? AND `verb` = ? AND `item`.`id` > ?", api_user(), ACTIVITY_POST, $since_id];
if ($max_id > 0) { if ($max_id > 0) {
$sql_extra .= ' AND `item`.`id` <= ' . intval($max_id); $condition[0] .= " AND `item`.`id` <= ?";
$condition[] = $max_id;
} }
if ($exclude_replies > 0) { if ($exclude_replies > 0) {
$sql_extra .= ' AND `item`.`parent` = `item`.`id`'; $condition[0] .= ' AND `item`.`parent` = `item`.`id`';
} }
if ($conversation_id > 0) { if ($conversation_id > 0) {
$sql_extra .= ' AND `item`.`parent` = ' . intval($conversation_id); $condition[0] .= " AND `item`.`parent` = ?";
$condition[] = $conversation_id;
} }
$r = q("SELECT `item`.* FROM `item` $params = ['order' => ['id' => true], 'limit' => [$start, $count]];
STRAIGHT_JOIN `contact` ON `contact`.`id` = `item`.`contact-id` $statuses = Item::select(api_user(), [], $condition, $params);
AND (NOT `contact`.`blocked` OR `contact`.`pending`)
WHERE `item`.`uid` = %d AND `verb` = '%s'
AND `item`.`visible` AND NOT `item`.`moderated` AND NOT `item`.`deleted`
$sql_extra
AND `item`.`id` > %d
ORDER BY `item`.`id` DESC LIMIT %d ,%d",
intval(api_user()),
dbesc(ACTIVITY_POST),
intval($since_id),
intval($start),
intval($count)
);
$ret = api_format_items($r, $user_info, false, $type); $ret = api_format_items(dba::inArray($statuses), $user_info, false, $type);
// Set all posts from the query above to seen // Set all posts from the query above to seen
$idarray = []; $idarray = [];
@ -1779,61 +1759,35 @@ function api_statuses_public_timeline($type)
$sql_extra = ''; $sql_extra = '';
if ($exclude_replies && !$conversation_id) { if ($exclude_replies && !$conversation_id) {
if ($max_id > 0) { $condition = ["`verb` = ? AND `iid` > ? AND NOT `private` AND `wall` AND NOT `user`.`hidewall`",
$sql_extra = 'AND `thread`.`iid` <= ' . intval($max_id); ACTIVITY_POST, $since_id];
}
$r = dba::p( if ($max_id > 0) {
"SELECT " . item_fieldlists() . " $condition[0] .= " AND `thread`.`iid` <= ?";
FROM `thread` $condition[] = $max_id;
STRAIGHT_JOIN `item` ON `item`.`id` = `thread`.`iid` }
" . item_joins(api_user()) . "
STRAIGHT_JOIN `user` ON `user`.`uid` = `thread`.`uid`
AND NOT `user`.`hidewall`
AND `verb` = ?
AND NOT `thread`.`private`
AND `thread`.`wall`
AND `thread`.`visible`
AND NOT `thread`.`deleted`
AND NOT `thread`.`moderated`
AND `thread`.`iid` > ?
$sql_extra
ORDER BY `thread`.`iid` DESC
LIMIT " . intval($start) . ", " . intval($count),
ACTIVITY_POST,
$since_id
);
$r = dba::inArray($r); $params = ['order' => ['iid' => true], 'limit' => [$start, $count]];
$statuses = Item::selectThread(api_user(), [], $condition, $params);
$r = dba::inArray($statuses);
} else { } else {
if ($max_id > 0) { $condition = ["`uid` = ? AND `verb` = ? AND `id` > ? AND NOT `user`.`hidewall` AND `item`.`origin`",
$sql_extra = 'AND `item`.`id` <= ' . intval($max_id); api_user(), ACTIVITY_POST, $since_id];
}
if ($conversation_id > 0) {
$sql_extra .= ' AND `item`.`parent` = ' . intval($conversation_id);
}
$r = dba::p( if ($max_id > 0) {
"SELECT " . item_fieldlists() . " $condition[0] .= " AND `item`.`id` <= ?";
FROM `item` $condition[] = $max_id;
" . item_joins(api_user()) . " }
STRAIGHT_JOIN `user` ON `user`.`uid` = `item`.`uid` if ($conversation_id > 0) {
AND NOT `user`.`hidewall` $condition[0] .= " AND `item`.`parent` = ?";
AND `verb` = ? $condition[] = $conversation_id;
AND NOT `item`.`private` }
AND `item`.`wall`
AND `item`.`visible`
AND NOT `item`.`deleted`
AND NOT `item`.`moderated`
AND `item`.`id` > ?
$sql_extra
ORDER BY `item`.`id` DESC
LIMIT " . intval($start) . ", " . intval($count),
ACTIVITY_POST,
$since_id
);
$r = dba::inArray($r); $params = ['order' => ['id' => true], 'limit' => [$start, $count]];
$statuses = Item::select(api_user(), [], $condition, $params);
$r = dba::inArray($statuses);
} }
$ret = api_format_items($r, $user_info, false, $type); $ret = api_format_items($r, $user_info, false, $type);
@ -1881,33 +1835,18 @@ function api_statuses_networkpublic_timeline($type)
} }
$start = ($page - 1) * $count; $start = ($page - 1) * $count;
$sql_extra = ''; $condition = ["`uid` = 0 AND `verb` = ? AND `thread`.`iid` > ? AND NOT `private`",
if ($max_id > 0) { ACTIVITY_POST, $since_id];
$sql_extra = 'AND `thread`.`iid` <= ' . intval($max_id);
}
$r = dba::p( if ($max_id > 0) {
"SELECT " . item_fieldlists() . " $condition[0] .= " AND `thread`.`iid` <= ?";
FROM `thread` $condition[] = $max_id;
STRAIGHT_JOIN `item` ON `item`.`id` = `thread`.`iid` }
" . item_joins(api_user()) . "
WHERE `thread`.`uid` = 0
AND `verb` = ?
AND NOT `thread`.`private`
AND `thread`.`visible`
AND NOT `thread`.`deleted`
AND NOT `thread`.`moderated`
AND `thread`.`iid` > ?
$sql_extra
ORDER BY `thread`.`iid` DESC
LIMIT " . intval($start) . ", " . intval($count),
ACTIVITY_POST,
$since_id
);
$r = dba::inArray($r); $params = ['order' => ['iid' => true], 'limit' => [$start, $count]];
$statuses = Item::selectThread(api_user(), [], $condition, $params);
$ret = api_format_items($r, $user_info, false, $type); $ret = api_format_items(dba::inArray($statuses), $user_info, false, $type);
$data = ['status' => $ret]; $data = ['status' => $ret];
switch ($type) { switch ($type) {
@ -1955,13 +1894,6 @@ function api_statuses_show($type)
$conversation = (x($_REQUEST, 'conversation') ? 1 : 0); $conversation = (x($_REQUEST, 'conversation') ? 1 : 0);
$sql_extra = '';
if ($conversation) {
$sql_extra .= " AND `item`.`parent` = %d ORDER BY `id` ASC ";
} else {
$sql_extra .= " AND `item`.`id` = %d";
}
// try to fetch the item for the local user - or the public item, if there is no local one // try to fetch the item for the local user - or the public item, if there is no local one
$uri_item = dba::selectFirst('item', ['uri'], ['id' => $id]); $uri_item = dba::selectFirst('item', ['uri'], ['id' => $id]);
if (!DBM::is_result($uri_item)) { if (!DBM::is_result($uri_item)) {
@ -1975,24 +1907,22 @@ function api_statuses_show($type)
$id = $item['id']; $id = $item['id'];
$r = q( if ($conversation) {
"SELECT `item`.* FROM `item` $condition = ['parent' => $id, 'verb' => ACTIVITY_POST];
STRAIGHT_JOIN `contact` ON `contact`.`id` = `item`.`contact-id` $params = ['order' => ['id' => true]];
AND (NOT `contact`.`blocked` OR `contact`.`pending`) } else {
WHERE `item`.`visible` AND NOT `item`.`moderated` AND NOT `item`.`deleted` $condition = ['id' => $id, 'verb' => ACTIVITY_POST];
AND `item`.`uid` IN (0, %d) AND `item`.`verb` = '%s' $params = [];
$sql_extra", }
intval(api_user()),
dbesc(ACTIVITY_POST), $statuses = Item::select(api_user(), [], $condition, $params);
intval($id)
);
/// @TODO How about copying this to above methods which don't check $r ? /// @TODO How about copying this to above methods which don't check $r ?
if (!DBM::is_result($r)) { if (!DBM::is_result($items)) {
throw new BadRequestException("There is no status with this id."); throw new BadRequestException("There is no status with this id.");
} }
$ret = api_format_items($r, $user_info, false, $type); $ret = api_format_items(dba::inArray($statuses), $user_info, false, $type);
if ($conversation) { if ($conversation) {
$data = ['status' => $ret]; $data = ['status' => $ret];
@ -2057,33 +1987,22 @@ function api_conversation_show($type)
$id = $parent['id']; $id = $parent['id'];
$sql_extra = ''; $condition = ["`parent` = ? AND `uid` IN (0, ?) AND `verb` = ? AND `item`.`id` > ?",
$id, api_user(), ACTIVITY_POST, $since_id];
if ($max_id > 0) { if ($max_id > 0) {
$sql_extra = ' AND `item`.`id` <= ' . intval($max_id); $condition[0] .= " AND `item`.`id` <= ?";
$condition[] = $max_id;
} }
$r = q("SELECT `item`.* FROM `item` $params = ['order' => ['id' => true], 'limit' => [$start, $count]];
STRAIGHT_JOIN `contact` ON `contact`.`id` = `item`.`contact-id` $statuses = Item::select(api_user(), [], $condition, $params);
AND (NOT `contact`.`blocked` OR `contact`.`pending`)
WHERE `item`.`parent` = %d AND `item`.`visible`
AND NOT `item`.`moderated` AND NOT `item`.`deleted`
AND `item`.`uid` IN (0, %d) AND `item`.`verb` = '%s'
AND `item`.`id`>%d $sql_extra
ORDER BY `item`.`id` DESC LIMIT %d ,%d",
intval($id),
intval(api_user()),
dbesc(ACTIVITY_POST),
intval($since_id),
intval($start),
intval($count)
);
if (!DBM::is_result($r)) { if (!DBM::is_result($items)) {
throw new BadRequestException("There is no status with this id."); throw new BadRequestException("There is no status with id $id.");
} }
$ret = api_format_items($r, $user_info, false, $type); $ret = api_format_items(dba::inArray($statuses), $user_info, false, $type);
$data = ['status' => $ret]; $data = ['status' => $ret];
return api_format_data("statuses", $type, $data); return api_format_data("statuses", $type, $data);
@ -2126,24 +2045,17 @@ function api_statuses_repeat($type)
logger('API: api_statuses_repeat: '.$id); logger('API: api_statuses_repeat: '.$id);
$r = q("SELECT `item`.* FROM `item` $fields = ['body', 'author-name', 'author-link', 'author-avatar', 'guid', 'created', 'plink'];
STRAIGHT_JOIN `contact` ON `contact`.`id` = `item`.`contact-id` $item = Item::selectFirst(api_user(), $fields, ['id' => $id, 'private' => false]);
AND (NOT `contact`.`blocked` OR `contact`.`pending`)
WHERE `item`.`visible` AND NOT `item`.`moderated` AND NOT `item`.`deleted`
AND NOT `item`.`private`
AND `item`.`id`=%d",
intval($id)
);
/// @TODO other style than above functions! if (DBM::is_result($item) && $item['body'] != "") {
if (DBM::is_result($r) && $r[0]['body'] != "") { if (strpos($item['body'], "[/share]") !== false) {
if (strpos($r[0]['body'], "[/share]") !== false) { $pos = strpos($item['body'], "[share");
$pos = strpos($r[0]['body'], "[share"); $post = substr($item['body'], $pos);
$post = substr($r[0]['body'], $pos);
} else { } else {
$post = share_header($r[0]['author-name'], $r[0]['author-link'], $r[0]['author-avatar'], $r[0]['guid'], $r[0]['created'], $r[0]['plink']); $post = share_header($item['author-name'], $item['author-link'], $item['author-avatar'], $item['guid'], $item['created'], $item['plink']);
$post .= $r[0]['body']; $post .= $item['body'];
$post .= "[/share]"; $post .= "[/share]";
} }
$_REQUEST['body'] = $post; $_REQUEST['body'] = $post;
@ -2244,32 +2156,19 @@ function api_statuses_mentions($type)
$start = ($page - 1) * $count; $start = ($page - 1) * $count;
$sql_extra = ''; $condition = ["`uid` = ? AND `verb` = ? AND `item`.`id` > ? AND `author-id` != ?
AND `item`.`parent` IN (SELECT `iid` FROM `thread` WHERE `uid` = ? AND `mention` AND NOT `ignored`)",
api_user(), ACTIVITY_POST, $since_id, $user_info['pid'], api_user()];
if ($max_id > 0) { if ($max_id > 0) {
$sql_extra = ' AND `item`.`id` <= ' . intval($max_id); $condition[0] .= " AND `item`.`id` <= ?";
$condition[] = $max_id;
} }
$r = q("SELECT `item`.* FROM `item` FORCE INDEX (`uid_id`) $params = ['order' => ['id' => true], 'limit' => [$start, $count]];
STRAIGHT_JOIN `contact` ON `contact`.`id` = `item`.`contact-id` $statuses = Item::select(api_user(), [], $condition, $params);
AND (NOT `contact`.`blocked` OR `contact`.`pending`)
WHERE `item`.`uid` = %d AND `item`.`verb` = '%s'
AND `item`.`author-id` != %d
AND `item`.`visible` AND NOT `item`.`moderated` AND NOT `item`.`deleted`
AND `item`.`parent` IN (SELECT `iid` FROM `thread` WHERE `uid` = %d AND `mention` AND NOT `ignored`)
$sql_extra
AND `item`.`id` > %d
ORDER BY `item`.`id` DESC LIMIT %d ,%d",
intval(api_user()),
dbesc(ACTIVITY_POST),
intval($user_info['pid']),
intval(api_user()),
intval($since_id),
intval($start),
intval($count)
);
$ret = api_format_items($r, $user_info, false, $type); $ret = api_format_items(dba::inArray($statuses), $user_info, false, $type);
$data = ['status' => $ret]; $data = ['status' => $ret];
switch ($type) { switch ($type) {
@ -2325,41 +2224,31 @@ function api_statuses_user_timeline($type)
} }
$start = ($page - 1) * $count; $start = ($page - 1) * $count;
$sql_extra = ''; $condition = ["`uid` = ? AND `verb` = ? AND `item`.`id` > ? AND `item`.`contact-id` = ?",
api_user(), ACTIVITY_POST, $since_id, $user_info['cid']];
if ($user_info['self'] == 1) { if ($user_info['self'] == 1) {
$sql_extra .= " AND `item`.`wall` = 1 "; $condition[0] .= ' AND `item`.`wall` ';
} }
if ($exclude_replies > 0) { if ($exclude_replies > 0) {
$sql_extra .= ' AND `item`.`parent` = `item`.`id`'; $condition[0] .= ' AND `item`.`parent` = `item`.`id`';
} }
if ($conversation_id > 0) { if ($conversation_id > 0) {
$sql_extra .= ' AND `item`.`parent` = ' . intval($conversation_id); $condition[0] .= " AND `item`.`parent` = ?";
$condition[] = $conversation_id;
} }
if ($max_id > 0) { if ($max_id > 0) {
$sql_extra .= ' AND `item`.`id` <= ' . intval($max_id); $condition[0] .= " AND `item`.`id` <= ?";
$condition[] = $max_id;
} }
$r = q("SELECT `item`.* FROM `item` FORCE INDEX (`uid_contactid_id`) $params = ['order' => ['id' => true], 'limit' => [$start, $count]];
STRAIGHT_JOIN `contact` ON `contact`.`id` = `item`.`contact-id` $statuses = Item::select(api_user(), [], $condition, $params);
AND (NOT `contact`.`blocked` OR `contact`.`pending`)
WHERE `item`.`uid` = %d AND `verb` = '%s'
AND `item`.`contact-id` = %d
AND `item`.`visible` AND NOT `item`.`moderated` AND NOT `item`.`deleted`
$sql_extra
AND `item`.`id` > %d
ORDER BY `item`.`id` DESC LIMIT %d ,%d",
intval(api_user()),
dbesc(ACTIVITY_POST),
intval($user_info['cid']),
intval($since_id),
intval($start),
intval($count)
);
$ret = api_format_items($r, $user_info, true, $type); $ret = api_format_items(dba::inArray($statuses), $user_info, true, $type);
$data = ['status' => $ret]; $data = ['status' => $ret];
switch ($type) { switch ($type) {
@ -2409,24 +2298,24 @@ function api_favorites_create_destroy($type)
$itemid = intval($_REQUEST['id']); $itemid = intval($_REQUEST['id']);
} }
$item = q("SELECT * FROM `item` WHERE `id`=%d AND `uid`=%d LIMIT 1", $itemid, api_user()); $item = Item::selectFirst(api_user(), [], ['id' => $itemid, 'uid' => api_user()]);
if (!DBM::is_result($item) || count($item) == 0) { if (!DBM::is_result($item)) {
throw new BadRequestException("Invalid item."); throw new BadRequestException("Invalid item.");
} }
switch ($action) { switch ($action) {
case "create": case "create":
$item[0]['starred'] = 1; $item['starred'] = 1;
break; break;
case "destroy": case "destroy":
$item[0]['starred'] = 0; $item['starred'] = 0;
break; break;
default: default:
throw new BadRequestException("Invalid action ".$action); throw new BadRequestException("Invalid action ".$action);
} }
$r = Item::update(['starred' => $item[0]['starred']], ['id' => $itemid]); $r = Item::update(['starred' => $item['starred']], ['id' => $itemid]);
if ($r === false) { if ($r === false) {
throw new InternalServerErrorException("DB error"); throw new InternalServerErrorException("DB error");
@ -2434,7 +2323,7 @@ function api_favorites_create_destroy($type)
$user_info = api_get_user($a); $user_info = api_get_user($a);
$rets = api_format_items($item, $user_info, false, $type); $rets = api_format_items([$item], $user_info, false, $type);
$ret = $rets[0]; $ret = $rets[0];
$data = ['status' => $ret]; $data = ['status' => $ret];
@ -2478,8 +2367,6 @@ function api_favorites($type)
if ($user_info['self'] == 0) { if ($user_info['self'] == 0) {
$ret = []; $ret = [];
} else { } else {
$sql_extra = "";
// params // params
$since_id = (x($_REQUEST, 'since_id') ? $_REQUEST['since_id'] : 0); $since_id = (x($_REQUEST, 'since_id') ? $_REQUEST['since_id'] : 0);
$max_id = (x($_REQUEST, 'max_id') ? $_REQUEST['max_id'] : 0); $max_id = (x($_REQUEST, 'max_id') ? $_REQUEST['max_id'] : 0);
@ -2491,26 +2378,19 @@ function api_favorites($type)
$start = $page*$count; $start = $page*$count;
$condition = ["`uid` = ? AND `verb` = ? AND `id` > ? AND `starred`",
api_user(), ACTIVITY_POST, $since_id];
$params = ['order' => ['id' => true], 'limit' => [$start, $count]];
if ($max_id > 0) { if ($max_id > 0) {
$sql_extra .= ' AND `item`.`id` <= ' . intval($max_id); $condition[0] .= " AND `item`.`id` <= ?";
$condition[] = $max_id;
} }
$r = q("SELECT `item`.* FROM `item` $statuses = Item::select(api_user(), [], $condition, $params);
STRAIGHT_JOIN `contact` ON `contact`.`id` = `item`.`contact-id`
AND (NOT `contact`.`blocked` OR `contact`.`pending`)
WHERE `item`.`uid` = %d
AND `item`.`visible` AND NOT `item`.`moderated` AND NOT `item`.`deleted`
AND `item`.`starred`
$sql_extra
AND `item`.`id`>%d
ORDER BY `item`.`id` DESC LIMIT %d ,%d",
intval(api_user()),
intval($since_id),
intval($start),
intval($count)
);
$ret = api_format_items($r, $user_info, false, $type); $ret = api_format_items(dba::inArray($statuses), $user_info, false, $type);
} }
$data = ['status' => $ret]; $data = ['status' => $ret];
@ -3300,32 +3180,23 @@ function api_lists_statuses($type)
$start = $page * $count; $start = $page * $count;
$sql_extra = ''; $condition = ["`uid` = ? AND `verb` = ? AND `id` > ? AND `group_member`.`gid` = ?",
if ($max_id > 0) { api_user(), ACTIVITY_POST, $since_id, $_REQUEST['list_id']];
$sql_extra .= ' AND `item`.`id` <= ' . intval($max_id);
}
if ($exclude_replies > 0) {
$sql_extra .= ' AND `item`.`parent` = `item`.`id`';
}
if ($conversation_id > 0) {
$sql_extra .= ' AND `item`.`parent` = ' . intval($conversation_id);
}
$statuses = dba::p("SELECT `item`.* FROM `item` if ($max_id > 0) {
STRAIGHT_JOIN `contact` ON `contact`.`id` = `item`.`contact-id` $condition[0] .= " AND `item`.`id` <= ?";
AND (NOT `contact`.`blocked` OR `contact`.`pending`) $condition[] = $max_id;
STRAIGHT_JOIN `group_member` ON `group_member`.`contact-id` = `item`.`contact-id` }
WHERE `item`.`uid` = ? AND `verb` = ? if ($exclude_replies > 0) {
AND `item`.`visible` AND NOT `item`.`moderated` AND NOT `item`.`deleted` $condition[0] .= ' AND `item`.`parent` = `item`.`id`';
$sql_extra }
AND `item`.`id`>? if ($conversation_id > 0) {
AND `group_member`.`gid` = ? $condition[0] .= " AND `item`.`parent` = ?";
ORDER BY `item`.`id` DESC LIMIT ".intval($start)." ,".intval($count), $condition[] = $conversation_id;
api_user(), }
ACTIVITY_POST,
$since_id, $params = ['order' => ['id' => true], 'limit' => [$start, $count]];
$_REQUEST['list_id'] $statuses = Item::select(api_user(), [], $condition, $params);
);
$items = api_format_items(dba::inArray($statuses), $user_info, false, $type); $items = api_format_items(dba::inArray($statuses), $user_info, false, $type);
@ -4847,19 +4718,13 @@ function prepare_photo_data($type, $scale, $photo_id)
$data['photo']['friendica_activities'] = api_format_items_activities($item[0], $type); $data['photo']['friendica_activities'] = api_format_items_activities($item[0], $type);
// retrieve comments on photo // retrieve comments on photo
$r = q("SELECT `item`.* FROM `item` $condition = ["`parent` = ? AND `uid` = ? AND (`verb` = ? OR `type`='photo')",
STRAIGHT_JOIN `contact` ON `contact`.`id` = `item`.`contact-id` $item[0]['parent'], api_user(), ACTIVITY_POST];
AND (NOT `contact`.`blocked` OR `contact`.`pending`)
WHERE `item`.`parent` = %d AND `item`.`visible` $statuses = Item::select(api_user(), [], $condition);
AND NOT `item`.`moderated` AND NOT `item`.`deleted`
AND `item`.`uid` = %d AND (`item`.`verb`='%s' OR `type`='photo')",
intval($item[0]['parent']),
intval(api_user()),
dbesc(ACTIVITY_POST)
);
// prepare output of comments // prepare output of comments
$commentData = api_format_items($r, $user_info, false, $type); $commentData = api_format_items(dba::inArray($statuses), $user_info, false, $type);
$comments = []; $comments = [];
if ($type == "xml") { if ($type == "xml") {
$k = 0; $k = 0;
@ -5849,14 +5714,10 @@ function api_friendica_notification_seen($type)
$nm->setSeen($note); $nm->setSeen($note);
if ($note['otype']=='item') { if ($note['otype']=='item') {
// would be really better with an ItemsManager and $im->getByID() :-P // would be really better with an ItemsManager and $im->getByID() :-P
$r = q( $item = Item::selectFirst(api_user(), [], ['id' => $note['iid'], 'uid' => api_user()]);
"SELECT * FROM `item` WHERE `id`=%d AND `uid`=%d", if (DBM::is_result($$item)) {
intval($note['iid']),
intval(local_user())
);
if ($r!==false) {
// we found the item, return it to the user // we found the item, return it to the user
$ret = api_format_items($r, $user_info, false, $type); $ret = api_format_items([$item], $user_info, false, $type);
$data = ['status' => $ret]; $data = ['status' => $ret];
return api_format_data("status", $type, $data); return api_format_data("status", $type, $data);
} }

6
include/conversation.php
View File

@ -467,8 +467,8 @@ function item_joins($uid = 0) {
AND NOT `contact`.`blocked` AND NOT `contact`.`blocked`
AND ((NOT `contact`.`readonly` AND NOT `contact`.`pending` AND (`contact`.`rel` IN (%s, %s))) AND ((NOT `contact`.`readonly` AND NOT `contact`.`pending` AND (`contact`.`rel` IN (%s, %s)))
OR `contact`.`self` OR (`item`.`id` != `item`.`parent`) OR `contact`.`uid` = 0) OR `contact`.`self` OR (`item`.`id` != `item`.`parent`) OR `contact`.`uid` = 0)
INNER JOIN `contact` AS `author` ON `author`.`id`=`item`.`author-id` AND NOT `author`.`blocked` STRAIGHT_JOIN `contact` AS `author` ON `author`.`id`=`item`.`author-id` AND NOT `author`.`blocked`
INNER JOIN `contact` AS `owner` ON `owner`.`id`=`item`.`owner-id` AND NOT `owner`.`blocked` STRAIGHT_JOIN `contact` AS `owner` ON `owner`.`id`=`item`.`owner-id` AND NOT `owner`.`blocked`
LEFT JOIN `user-item` ON `user-item`.`iid` = `item`.`id` AND `user-item`.`uid` = %d LEFT JOIN `user-item` ON `user-item`.`iid` = `item`.`id` AND `user-item`.`uid` = %d
LEFT JOIN `event` ON `event-id` = `event`.`id`", LEFT JOIN `event` ON `event-id` = `event`.`id`",
CONTACT_IS_SHARING, CONTACT_IS_FRIEND, intval($uid) CONTACT_IS_SHARING, CONTACT_IS_FRIEND, intval($uid)
@ -734,7 +734,7 @@ function conversation(App $a, $items, $mode, $update, $preview = false, $order =
'guid' => (($preview) ? 'Q0' : $item['guid']), 'guid' => (($preview) ? 'Q0' : $item['guid']),
'network' => $item['item_network'], 'network' => $item['item_network'],
'network_name' => ContactSelector::networkToName($item['item_network'], $profile_link), 'network_name' => ContactSelector::networkToName($item['item_network'], $profile_link),
'linktitle' => L10n::t('View %s\'s profile @ %s', $profile_name, ((strlen($item['author-link'])) ? $item['author-link'] : $item['url'])), 'linktitle' => L10n::t('View %s\'s profile @ %s', $profile_name, $item['author-link']),
'profile_url' => $profile_link, 'profile_url' => $profile_link,
'item_photo_menu' => item_photo_menu($item), 'item_photo_menu' => item_photo_menu($item),
'name' => $profile_name_e, 'name' => $profile_name_e,

12
include/enotify.php
View File

@ -129,7 +129,7 @@ function notification($params)
$item = null; $item = null;
if ($params['otype'] === 'item' && $parent_id) { if ($params['otype'] === 'item' && $parent_id) {
$item = dba::selectFirst('item', [], ['id' => $parent_id]); $item = Item::selectFirst($params['uid'], [], ['id' => $parent_id]);
} }
$item_post_type = item_post_type($item); $item_post_type = item_post_type($item);
@ -739,7 +739,7 @@ function check_item_notification($itemid, $uid, $defaulttype = "") {
// Only act if it is a "real" post // Only act if it is a "real" post
// We need the additional check for the "local_profile" because of mixed situations on connector networks // We need the additional check for the "local_profile" because of mixed situations on connector networks
$item = q("SELECT `id`, `mention`, `tag`,`parent`, `title`, `body`, `author-name`, `author-link`, `author-avatar`, `guid`, $item = q("SELECT `id`, `mention`, `tag`,`parent`, `title`, `body`, `author-id`, `guid`,
`parent-uri`, `uri`, `contact-id` `parent-uri`, `uri`, `contact-id`
FROM `item` WHERE `id` = %d AND `verb` IN ('%s', '') AND `type` != 'activity' AND FROM `item` WHERE `id` = %d AND `verb` IN ('%s', '') AND `type` != 'activity' AND
NOT (`author-link` IN ($profile_list)) LIMIT 1", NOT (`author-link` IN ($profile_list)) LIMIT 1",
@ -747,6 +747,8 @@ function check_item_notification($itemid, $uid, $defaulttype = "") {
if (!$item) if (!$item)
return false; return false;
$author = dba::selectFirst('contact', ['name', 'thumb', 'url'], ['id' => $item[0]['author-id']]);
// Generate the notification array // Generate the notification array
$params = []; $params = [];
$params["uid"] = $uid; $params["uid"] = $uid;
@ -758,9 +760,9 @@ function check_item_notification($itemid, $uid, $defaulttype = "") {
$params["parent"] = $item[0]["parent"]; $params["parent"] = $item[0]["parent"];
$params["link"] = System::baseUrl().'/display/'.urlencode($item[0]["guid"]); $params["link"] = System::baseUrl().'/display/'.urlencode($item[0]["guid"]);
$params["otype"] = 'item'; $params["otype"] = 'item';
$params["source_name"] = $item[0]["author-name"]; $params["source_name"] = $author["name"];
$params["source_link"] = $item[0]["author-link"]; $params["source_link"] = $author["url"];
$params["source_photo"] = $item[0]["author-avatar"]; $params["source_photo"] = $author["thumb"];
if ($item[0]["parent-uri"] === $item[0]["uri"]) { if ($item[0]["parent-uri"] === $item[0]["uri"]) {
// Send a notification for every new post? // Send a notification for every new post?

186
src/Model/Item.php
View File

@ -33,38 +33,184 @@ require_once 'include/text.php';
class Item extends BaseObject class Item extends BaseObject
{ {
public static function select(array $fields = [], array $condition = [], $params = [], $uid = null) public static function selectFirst($uid, array $fields = [], array $condition = [], $params = [])
{ {
require_once 'include/conversation.php'; $params['limit'] = 1;
$result = self::select($uid, $fields, $condition, $params);
$item_fields = ['id', 'guid']; if (is_bool($result)) {
return $result;
} else {
$row = dba::fetch($result);
dba::close($result);
return $row;
}
}
$select_fields = item_fieldlists(); public static function select($uid, array $selected = [], array $condition = [], $params = [])
{
$fields = self::fieldlist();
$select_fields = self::constructSelectFields($fields, $selected);
$condition_string = dba::buildCondition($condition); $condition_string = dba::buildCondition($condition);
foreach ($item_fields as $field) { $condition_string = self::addTablesToFields($condition_string, $fields);
$search = [" `" . $field . "`", "(`" . $field . "`"];
$replace = [" `item`.`" . $field . "`", "(`item`.`" . $field . "`"];
$condition_string = str_replace($search, $replace, $condition_string);
}
$condition_string = $condition_string . ' AND ' . item_condition(); $condition_string = $condition_string . ' AND ' . self::condition();
if (!empty($uid)) { $param_string = self::addTablesToFields(dba::buildParameter($params), $fields);
$condition_string .= " AND `item`.`uid` = ?";
$condition['uid'] = $uid;
}
$param_string = dba::buildParameter($params); $table = "`item` " . self::constructJoins($uid, $select_fields . $condition_string . $param_string, false);
$table = "`item` " . item_joins($uid);
$sql = "SELECT " . $select_fields . " FROM " . $table . $condition_string . $param_string; $sql = "SELECT " . $select_fields . " FROM " . $table . $condition_string . $param_string;
echo $sql;
$result = dba::p($sql, $condition);
return dba::inArray($result); return dba::p($sql, $condition);
}
public static function selectFirstThread($uid, array $fields = [], array $condition = [], $params = [])
{
$params['limit'] = 1;
$result = self::selectThread($uid, $fields, $condition, $params);
if (is_bool($result)) {
return $result;
} else {
$row = dba::fetch($result);
dba::close($result);
return $row;
}
}
public static function selectThread($uid, array $selected = [], array $condition = [], $params = [])
{
$fields = self::fieldlist();
$threadfields = ['thread' => ['iid', 'uid', 'contact-id', 'owner-id', 'author-id',
'created', 'edited', 'commented', 'received', 'changed', 'wall', 'private',
'pubmail', 'moderated', 'visible', 'starred', 'ignored', 'bookmark',
'unseen', 'deleted', 'origin', 'forum_mode', 'mention', 'network']];
$select_fields = self::constructSelectFields($fields, $selected);
$condition_string = dba::buildCondition($condition);
$condition_string = self::addTablesToFields($condition_string, $threadfields);
$condition_string = self::addTablesToFields($condition_string, $fields);
$condition_string = $condition_string . ' AND ' . self::condition();
$param_string = dba::buildParameter($params);
$param_string = self::addTablesToFields($param_string, $threadfields);
$param_string = self::addTablesToFields($param_string, $fields);
$table = "`thread` " . self::constructJoins($uid, $select_fields . $condition_string . $param_string, true);
$sql = "SELECT " . $select_fields . " FROM " . $table . $condition_string . $param_string;
return dba::p($sql, $condition);
}
private static function fieldlist()
{
$item_fields = ['author-id', 'owner-id', 'contact-id', 'uid', 'id', 'parent',
'uri', 'thr-parent', 'parent-uri', 'content-warning',
'commented', 'created', 'edited', 'received', 'verb', 'object-type', 'postopts', 'plink',
'guid', 'wall', 'private', 'starred', 'origin', 'title', 'body', 'file', 'event-id',
'location', 'coord', 'app', 'attach', 'rendered-hash', 'rendered-html', 'object',
'allow_cid', 'allow_gid', 'deny_cid', 'deny_gid',
'id' => 'item_id', 'network' => 'item_network'];
$author_fields = ['url' => 'author-link', 'name' => 'author-name', 'thumb' => 'author-avatar'];
$owner_fields = ['url' => 'owner-link', 'name' => 'owner-name', 'thumb' => 'owner-avatar'];
$contact_fields = ['url' => 'contact-link', 'name' => 'contact-name', 'thumb' => 'contact-avatar',
'network', 'url', 'name', 'writable', 'self', 'id' => 'cid', 'alias'];
$event_fields = ['created' => 'event-created', 'edited' => 'event-edited',
'start' => 'event-start','finish' => 'event-finish',
'summary' => 'event-summary','desc' => 'event-desc',
'location' => 'event-location', 'type' => 'event-type',
'nofinish' => 'event-nofinish','adjust' => 'event-adjust',
'ignore' => 'event-ignore', 'id' => 'event-id'];
return ['item' => $item_fields, 'author' => $author_fields, 'owner' => $owner_fields,
'contact' => $contact_fields, 'event' => $event_fields];
}
private static function condition()
{
return "`item`.`visible` AND NOT `item`.`deleted` AND NOT `item`.`moderated` AND (`user-item`.`hidden` IS NULL OR NOT `user-item`.`hidden`) ";
}
private static function constructJoins($uid, $sql_commands, $thread_mode)
{
if ($thread_mode) {
$master_table = "`thread`";
$master_table_key = "`thread`.`iid`";
$joins = "STRAIGHT_JOIN `item` ON `item`.`id` = `thread`.`iid` ";
} else {
$master_table = "`item`";
$master_table_key = "`item`.`id`";
$joins = '';
}
$joins .= sprintf("STRAIGHT_JOIN `contact` ON `contact`.`id` = $master_table.`contact-id`
AND NOT `contact`.`blocked`
AND ((NOT `contact`.`readonly` AND NOT `contact`.`pending` AND (`contact`.`rel` IN (%s, %s)))
OR `contact`.`self` OR (`item`.`id` != `item`.`parent`) OR `contact`.`uid` = 0)
STRAIGHT_JOIN `contact` AS `author` ON `author`.`id` = $master_table.`author-id` AND NOT `author`.`blocked`
STRAIGHT_JOIN `contact` AS `owner` ON `owner`.`id` = $master_table.`owner-id` AND NOT `owner`.`blocked`
LEFT JOIN `user-item` ON `user-item`.`iid` = $master_table_key AND `user-item`.`uid` = %d",
CONTACT_IS_SHARING, CONTACT_IS_FRIEND, intval($uid));
if (strpos($sql_commands, "`group_member`.") !== false) {
$joins .= " STRAIGHT_JOIN `group_member` ON `group_member`.`contact-id` = $master_table.`contact-id`";
}
if (strpos($sql_commands, "`user`.") !== false) {
$joins .= " STRAIGHT_JOIN `user` ON `user`.`uid` = $master_table.`uid`";
}
if (strpos($sql_commands, "`event`.") !== false) {
$joins .= " LEFT JOIN `event` ON `event-id` = `event`.`id`";
}
return $joins;
}
private static function constructSelectFields($fields, $selected)
{
$selection = [];
foreach ($fields as $table => $table_fields) {
foreach ($table_fields as $field => $select) {
if (empty($selected) || in_array($select, $selected)) {
if (is_int($field)) {
$selection[] = "`" . $table . "`.`".$select."`";
} else {
$selection[] = "`" . $table . "`.`" . $field . "` AS `".$select ."`";
}
}
}
}
return implode(", ", $selection);
}
private static function addTablesToFields($query, $fields)
{
foreach ($fields as $table => $table_fields) {
foreach ($table_fields as $alias => $field) {
if (is_int($alias)) {
$replace_field = $field;
} else {
$replace_field = $alias;
}
$search = "/([^\.])`" . $field . "`/i";
$replace = "$1`" . $table . "`.`" . $replace_field . "`";
$query = preg_replace($search, $replace, $query);
}
}
return $query;
} }
/** /**