diff options
author | Thibaut Girka <thib@sitedethib.com> | 2018-08-22 20:56:32 +0200 |
---|---|---|
committer | Thibaut Girka <thib@sitedethib.com> | 2018-08-22 20:56:32 +0200 |
commit | e70fc059a9511d43b42c2502514f6220b416cdd5 (patch) | |
tree | abc0ea9862c55c2e114c855b20eb4a35f1141709 /app/lib | |
parent | 628fca50e20bcf41f206877083fc5ee8789c1088 (diff) | |
parent | 56f882aed6fc81bbe4fb8821f11ba196795c99a8 (diff) |
Merge branch 'master' into glitch-soc/merge-upstream
Diffstat (limited to 'app/lib')
-rw-r--r-- | app/lib/ostatus/activity/creation.rb | 11 |
1 files changed, 10 insertions, 1 deletions
diff --git a/app/lib/ostatus/activity/creation.rb b/app/lib/ostatus/activity/creation.rb index d3a303a0c..8f8c70052 100644 --- a/app/lib/ostatus/activity/creation.rb +++ b/app/lib/ostatus/activity/creation.rb @@ -7,7 +7,7 @@ class OStatus::Activity::Creation < OStatus::Activity::Base return [nil, false] end - return [nil, false] if @account.suspended? + return [nil, false] if @account.suspended? || invalid_origin? RedisLock.acquire(lock_options) do |lock| if lock.acquired? @@ -204,6 +204,15 @@ class OStatus::Activity::Creation < OStatus::Activity::Base end end + def invalid_origin? + return false unless id.start_with?('http') # Legacy IDs cannot be checked + + needle = Addressable::URI.parse(id).normalized_host + + !(needle.casecmp(@account.domain).zero? || + needle.casecmp(Addressable::URI.parse(@account.remote_url.presence || @account.uri).normalized_host).zero?) + end + def lock_options { redis: Redis.current, key: "create:#{id}" } end |