discourse/lib/topic_retriever.rb

Ignoring revisions in .git-blame-ignore-revs. Click here to bypass and see the normal blame view.

56 lines
1.2 KiB
Ruby
Raw Normal View History

# frozen_string_literal: true
class TopicRetriever
2017-07-27 21:20:09 -04:00
def initialize(embed_url, opts = nil)
@embed_url = embed_url
@opts = opts || {}
@author_username = @opts[:author_username]
end
def retrieve
perform_retrieve unless (invalid_url? || retrieved_recently?)
end
private
2018-06-07 01:28:18 -04:00
def invalid_url?
!EmbeddableHost.url_allowed?(@embed_url)
end
2018-06-07 01:28:18 -04:00
def retrieved_recently?
# We can disable the throttle for some users, such as staff
return false if @opts[:no_throttle]
2018-06-07 01:28:18 -04:00
# Throttle other users to once every 60 seconds
retrieved_key = "retrieved_topic"
if Discourse.redis.setnx(retrieved_key, "1")
Discourse.redis.expire(retrieved_key, 60)
2018-06-07 01:28:18 -04:00
return false
end
2018-06-07 01:28:18 -04:00
true
end
2018-06-07 01:28:18 -04:00
def perform_retrieve
# It's possible another process or job found the embed already. So if that happened bail out.
return if TopicEmbed.where(embed_url: @embed_url).exists?
2018-06-07 01:28:18 -04:00
fetch_http
end
2018-06-07 01:28:18 -04:00
def fetch_http
if @author_username.nil?
username = SiteSetting.embed_by_username.downcase
else
username = @author_username
end
2018-06-07 01:28:18 -04:00
user = User.where(username_lower: username.downcase).first
return if user.blank?
TopicEmbed.import_remote(user, @embed_url)
end
end