summaryrefslogtreecommitdiffstats
path: root/app/lib
diff options
context:
space:
mode:
authorThibG <thib@sitedethib.com>2020-07-22 11:45:35 +0200
committerGitHub <noreply@github.com>2020-07-22 11:45:35 +0200
commit5d9acc0ce41aa0274fef2dd321a8fad1fb0665ea (patch)
tree7389893c0fc6ec2e0c4be123d390643c122dccd8 /app/lib
parentf55dd193f9a62623054dba1537d01bd7f5cd32f3 (diff)
Fix not handling Undo on some activity types when they aren't inlined (#14346)
* Fix not handling Undo on some activity types when they aren't inlined When receiving an Undo for a non-inlined activity, try looking it up in database using the URI. The queries are ad-hoc because we don't have a global index of object URIs, and not all activity types are stored in database with an index on their URI. Announces are just statuses, and have an index on URIs, so this check can be done efficiently. Accepts cannot be handled at all because we don't record their URI at any point. Follows don't have an index on URI, but they have an index on the issuing account, which should make such queries largely manageable. Likes don't have an index on URI, they have an index on the issuing account, but the number of favs per account may be very high, so I decided not to handle that. Blocks don't have an index on URI, but they have an index on the issuing account, which should make such queries largely manageable. In all cases, if an Undo could not be handled properly, we call `delete_later!` because that does not require us to know more than the URI of the undone property. * Add tests * Make newer blocks overwrite older ones Allows re-synchronizing block info by re-blocking and un-blocking again when the original Undo Block has been lost.
Diffstat (limited to 'app/lib')
-rw-r--r--app/lib/activitypub/activity/block.rb7
-rw-r--r--app/lib/activitypub/activity/undo.rb51
2 files changed, 57 insertions, 1 deletions
diff --git a/app/lib/activitypub/activity/block.rb b/app/lib/activitypub/activity/block.rb
index a17a2d50a6a..90477bf3369 100644
--- a/app/lib/activitypub/activity/block.rb
+++ b/app/lib/activitypub/activity/block.rb
@@ -4,7 +4,12 @@ class ActivityPub::Activity::Block < ActivityPub::Activity
def perform
target_account = account_from_uri(object_uri)
- return if target_account.nil? || !target_account.local? || @account.blocking?(target_account)
+ return if target_account.nil? || !target_account.local?
+
+ if @account.blocking?(target_account)
+ @account.block_relationships.find_by(target_account: target_account).update(uri: @json['id']) if @json['id'].present?
+ return
+ end
UnfollowService.new.call(target_account, @account) if target_account.following?(@account)
diff --git a/app/lib/activitypub/activity/undo.rb b/app/lib/activitypub/activity/undo.rb
index 599823c6e25..9eff1b71c9d 100644
--- a/app/lib/activitypub/activity/undo.rb
+++ b/app/lib/activitypub/activity/undo.rb
@@ -13,11 +13,62 @@ class ActivityPub::Activity::Undo < ActivityPub::Activity
undo_like
when 'Block'
undo_block
+ when nil
+ handle_reference
end
end
private
+ def handle_reference
+ # Some implementations do not inline the object, and as we don't have a
+ # global index, we have to guess what object it is.
+ return if object_uri.nil?
+
+ try_undo_announce || try_undo_accept || try_undo_follow || try_undo_like || try_undo_block || delete_later!(object_uri)
+ end
+
+ def try_undo_announce
+ status = Status.where.not(reblog_of_id: nil).find_by(uri: object_uri, account: @account)
+ if status.present?
+ RemoveStatusService.new.call(status)
+ true
+ else
+ false
+ end
+ end
+
+ def try_undo_accept
+ # We can't currently handle `Undo Accept` as we don't record `Accept`'s uri
+ false
+ end
+
+ def try_undo_follow
+ follow = @account.follow_requests.find_by(uri: object_uri) || @account.active_relationships.find_by(uri: object_uri)
+
+ if follow.present?
+ follow.destroy
+ true
+ else
+ false
+ end
+ end
+
+ def try_undo_like
+ # There is an index on accounts, but an account may have *many* favs, so this may be too costly
+ false
+ end
+
+ def try_undo_block
+ block = @account.block_relationships.find_by(uri: object_uri)
+ if block.present?
+ UnblockService.new.call(@account, block.target_account)
+ true
+ else
+ false
+ end
+ end
+
def undo_announce
return if object_uri.nil?