aboutsummaryrefslogtreecommitdiffstats
path: root/include/zot.php
diff options
context:
space:
mode:
authorfriendica <info@friendica.com>2015-02-11 15:26:35 -0800
committerfriendica <info@friendica.com>2015-02-11 15:26:35 -0800
commit8c061f143f7e019fdea3a2a03d96fc4ec8e39edd (patch)
treeb1785617fc94741f93b8b41116fc5c538c2de5da /include/zot.php
parent3f76cbf40b57b34f32a64435ca125c0576985c34 (diff)
downloadvolse-hubzilla-8c061f143f7e019fdea3a2a03d96fc4ec8e39edd.tar.gz
volse-hubzilla-8c061f143f7e019fdea3a2a03d96fc4ec8e39edd.tar.bz2
volse-hubzilla-8c061f143f7e019fdea3a2a03d96fc4ec8e39edd.zip
more efficient processing of response activities, plus a proof of concept fix for the problem of receiving a delete notification before we actually get the item which we're supposed to delete.
Diffstat (limited to 'include/zot.php')
-rw-r--r--include/zot.php61
1 files changed, 44 insertions, 17 deletions
diff --git a/include/zot.php b/include/zot.php
index 7e9a6ee54..7fd6f0d4a 100644
--- a/include/zot.php
+++ b/include/zot.php
@@ -1576,6 +1576,12 @@ function process_delivery($sender,$arr,$deliveries,$relay,$public = false,$reque
// remove_community_tag is a no-op if this isn't a community tag activity
remove_community_tag($sender,$arr,$channel['channel_id']);
+ // set these just in case we need to store a fresh copy of the deleted post.
+ // This could happen if the delete got here before the original post did.
+
+ $arr['aid'] = $channel['channel_account_id'];
+ $arr['uid'] = $channel['channel_id'];
+
$item_id = delete_imported_item($sender,$arr,$channel['channel_id']);
$result[] = array($d['hash'],(($item_id) ? 'deleted' : 'delete_failed'),$channel['channel_name'] . ' <' . $channel['channel_address'] . '@' . get_app()->get_hostname() . '>',$arr['mid']);
@@ -1725,35 +1731,56 @@ function delete_imported_item($sender,$item,$uid) {
logger('delete_imported_item invoked',LOGGER_DEBUG);
- $r = q("select id, item_restrict from item where ( author_xchan = '%s' or owner_xchan = '%s' or source_xchan = '%s' )
- and mid = '%s' and uid = %d limit 1",
- dbesc($sender['hash']),
- dbesc($sender['hash']),
- dbesc($sender['hash']),
+ $ownership_valid = false;
+ $item_found = false;
+ $post_id = 0;
+
+ $r = q("select id, item_restrict, author_xchan, owner_xchan, source_xchan from item where mid = '%s' and uid = %d limit 1",
dbesc($item['mid']),
intval($uid)
);
+ if($r) {
+ if($r[0]['author_xchan'] === $sender['hash'] || $r[0]['owner_xchan'] === $sender['hash'] || $r[0]['source_xchan'] === $sender['hash'])
+ $ownership_valid = true;
+ $post_id = $r[0]['id'];
+ $item_found = true;
+ }
+ else {
- if(! $r) {
+ // perhaps the item is still in transit and the delete notification got here before the actual item did. Store it with the deleted flag set.
+ // item_store() won't try to deliver any notifications or start delivery chains if this flag is set.
+ // This means we won't end up with potentially even more delivery threads trying to push this delete notification.
+ // But this will ensure that if the (undeleted) original post comes in at a later date, we'll reject it because it will have an older timestamp.
+
+ logger('delete received for non-existent item - storing item data.');
+ if($arr['author_xchan'] === $sender['hash'] || $arr['owner_xchan'] === $sender['hash'] || $arr['source_xchan'] === $sender['hash']) {
+ $ownership_valid = true;
+ $item_result = item_store($arr);
+ $post_id = $item_result['item_id'];
+ }
+ }
+
+ if($ownership_valid == false) {
logger('delete_imported_item: failed: ownership issue');
return false;
}
- if($r[0]['item_restrict'] & ITEM_DELETED) {
- logger('delete_imported_item: item was already deleted');
- return false;
- }
+ if($item_found) {
+ if($r[0]['item_restrict'] & ITEM_DELETED) {
+ logger('delete_imported_item: item was already deleted');
+ return false;
+ }
- require_once('include/items.php');
+ require_once('include/items.php');
- // Use phased deletion to set the deleted flag, call both tag_deliver and the notifier to notify downstream channels
- // and then clean up after ourselves with a cron job after several days to do the delete_item_lowlevel() (DROPITEM_PHASE2).
+ // Use phased deletion to set the deleted flag, call both tag_deliver and the notifier to notify downstream channels
+ // and then clean up after ourselves with a cron job after several days to do the delete_item_lowlevel() (DROPITEM_PHASE2).
- drop_item($r[0]['id'],false, DROPITEM_PHASE1);
-
- tag_deliver($uid,$r[0]['id']);
+ drop_item($post_id,false, DROPITEM_PHASE1);
+ tag_deliver($uid,$post_id);
+ }
- return $r[0]['id'];
+ return $post_id;
}
function process_mail_delivery($sender,$arr,$deliveries) {