mirror of
https://codeberg.org/streams/streams.git
synced 2024-09-22 09:35:25 +00:00
184 lines
4.5 KiB
PHP
184 lines
4.5 KiB
PHP
<?php
|
|
namespace Zotlabs\Module;
|
|
|
|
use App;
|
|
use Zotlabs\Web\Controller;
|
|
use Zotlabs\Lib\Activity;
|
|
|
|
require_once('include/security.php');
|
|
require_once('include/bbcode.php');
|
|
|
|
|
|
|
|
class Subthread extends Controller {
|
|
|
|
function get() {
|
|
|
|
if (! local_channel()) {
|
|
return;
|
|
}
|
|
|
|
$sys = get_sys_channel();
|
|
$channel = App::get_channel();
|
|
|
|
$item_id = ((argc() > 2) ? notags(trim(argv(2))) : 0);
|
|
|
|
if (argv(1) === 'sub') {
|
|
$activity = ACTIVITY_FOLLOW;
|
|
}
|
|
elseif (argv(1) === 'unsub') {
|
|
$activity = ACTIVITY_IGNORE;
|
|
}
|
|
|
|
$i = q("select * from item where id = %d and uid = %d",
|
|
intval($item_id),
|
|
intval(local_channel())
|
|
);
|
|
|
|
if (! $i) {
|
|
// try the global public stream
|
|
$i = q("select * from item where id = %d and uid = %d",
|
|
intval($postid),
|
|
intval($sys['channel_id'])
|
|
);
|
|
// try the local public stream
|
|
if (! $i) {
|
|
$i = q("select * from item where id = %d and item_wall = 1 and item_private = 0",
|
|
intval($postid)
|
|
);
|
|
}
|
|
|
|
if ($i && local_channel() && (! is_sys_channel(local_channel()))) {
|
|
$i = [ copy_of_pubitem($channel, $i[0]['mid']) ];
|
|
$item_id = (($i) ? $i[0]['id'] : 0);
|
|
}
|
|
}
|
|
|
|
if (! $i) {
|
|
return;
|
|
}
|
|
|
|
$r = q("select * from item where id = parent and id = %d limit 1",
|
|
dbesc($i[0]['parent'])
|
|
);
|
|
|
|
if ((! $item_id) || (! $r)) {
|
|
logger('subthread: no item ' . $item_id);
|
|
return;
|
|
}
|
|
|
|
$item = $r[0];
|
|
|
|
$owner_uid = $item['uid'];
|
|
$observer = App::get_observer();
|
|
$ob_hash = (($observer) ? $observer['xchan_hash'] : '');
|
|
|
|
if (! perm_is_allowed($owner_uid,$ob_hash,'post_comments')) {
|
|
return;
|
|
}
|
|
|
|
$sys = get_sys_channel();
|
|
|
|
$owner_uid = $item['uid'];
|
|
$owner_aid = $item['aid'];
|
|
|
|
// if this is a "discover" item, (item['uid'] is the sys channel),
|
|
// fallback to the item comment policy, which should've been
|
|
// respected when generating the conversation thread.
|
|
// Even if the activity is rejected by the item owner, it should still get attached
|
|
// to the local discover conversation on this site.
|
|
|
|
if (($owner_uid != $sys['channel_id']) && (! perm_is_allowed($owner_uid,$observer['xchan_hash'],'post_comments'))) {
|
|
notice( t('Permission denied') . EOL);
|
|
killme();
|
|
}
|
|
|
|
$r = q("select * from xchan where xchan_hash = '%s' limit 1",
|
|
dbesc($item['owner_xchan'])
|
|
);
|
|
if ($r) {
|
|
$thread_owner = $r[0];
|
|
}
|
|
else {
|
|
killme();
|
|
}
|
|
|
|
$r = q("select * from xchan where xchan_hash = '%s' limit 1",
|
|
dbesc($item['author_xchan'])
|
|
);
|
|
if ($r) {
|
|
$item_author = $r[0];
|
|
}
|
|
else {
|
|
killme();
|
|
}
|
|
|
|
$uuid = new_uuid();
|
|
$mid = z_root() . '/item/' . $uuid;
|
|
|
|
$post_type = (($item['resource_type'] === 'photo') ? t('photo') : t('status'));
|
|
|
|
$links = array(array('rel' => 'alternate','type' => 'text/html', 'href' => $item['plink']));
|
|
$objtype = (($item['resource_type'] === 'photo') ? ACTIVITY_OBJ_PHOTO : ACTIVITY_OBJ_NOTE );
|
|
|
|
$body = $item['body'];
|
|
|
|
$obj = Activity::fetch_item( [ 'id' => $item['mid'] ] );
|
|
$objtype = $obj['type'];
|
|
|
|
if (! intval($item['item_thread_top']))
|
|
$post_type = 'comment';
|
|
|
|
if ($activity === ACTIVITY_FOLLOW) {
|
|
$bodyverb = t('%1$s is following %2$s\'s %3$s');
|
|
}
|
|
if ($activity === ACTIVITY_IGNORE) {
|
|
$bodyverb = t('%1$s stopped following %2$s\'s %3$s');
|
|
}
|
|
|
|
$arr = [];
|
|
|
|
$arr['uuid'] = $uuid;
|
|
$arr['mid'] = $mid;
|
|
$arr['aid'] = $owner_aid;
|
|
$arr['uid'] = $owner_uid;
|
|
$arr['parent'] = $item['id'];
|
|
$arr['parent_mid'] = $item['mid'];
|
|
$arr['thr_parent'] = $item['mid'];
|
|
$arr['owner_xchan'] = $thread_owner['xchan_hash'];
|
|
$arr['author_xchan'] = $observer['xchan_hash'];
|
|
$arr['item_origin'] = 1;
|
|
$arr['item_notshown'] = 1;
|
|
|
|
if (intval($item['item_wall'])) {
|
|
$arr['item_wall'] = 1;
|
|
}
|
|
else {
|
|
$arr['item_wall'] = 0;
|
|
}
|
|
|
|
$ulink = '[zrl=' . $item_author['xchan_url'] . ']' . $item_author['xchan_name'] . '[/zrl]';
|
|
$alink = '[zrl=' . $observer['xchan_url'] . ']' . $observer['xchan_name'] . '[/zrl]';
|
|
$plink = '[zrl=' . z_root() . '/display/' . gen_link_id($item['mid']) . ']' . $post_type . '[/zrl]';
|
|
|
|
$arr['body'] = sprintf( $bodyverb, $alink, $ulink, $plink );
|
|
|
|
$arr['verb'] = $activity;
|
|
$arr['obj_type'] = $objtype;
|
|
$arr['obj'] = json_encode($obj);
|
|
|
|
$arr['allow_cid'] = $item['allow_cid'];
|
|
$arr['allow_gid'] = $item['allow_gid'];
|
|
$arr['deny_cid'] = $item['deny_cid'];
|
|
$arr['deny_gid'] = $item['deny_gid'];
|
|
|
|
$post = item_store($arr);
|
|
$post_id = $post['item_id'];
|
|
|
|
$arr['id'] = $post_id;
|
|
|
|
call_hooks('post_local_end', $arr);
|
|
|
|
killme();
|
|
}
|
|
}
|