mirror of
https://github.com/discourse/discourse.git
synced 2025-02-25 18:55:32 -06:00
FIX: This should not have been checked in.
This commit is contained in:
parent
c3745ee861
commit
55b35a05ed
@ -1,37 +0,0 @@
|
|||||||
module Jobs
|
|
||||||
class CleanUpRedisKeys < Jobs::Scheduled
|
|
||||||
every 1.week
|
|
||||||
|
|
||||||
def execute(args)
|
|
||||||
return unless Rails.configuration.multisite
|
|
||||||
return unless SiteSetting.clean_up_redis_keys
|
|
||||||
|
|
||||||
dbs = RailsMultisite::ConnectionManagement.all_dbs
|
|
||||||
dbs << Discourse::SIDEKIQ_NAMESPACE
|
|
||||||
|
|
||||||
regexp = /((\$(?<message_bus>\w+)$)|(^?(?<namespace>\w+):))/
|
|
||||||
|
|
||||||
cursor = 0
|
|
||||||
redis = $redis.without_namespace
|
|
||||||
|
|
||||||
loop do
|
|
||||||
cursor, keys = redis.scan(cursor)
|
|
||||||
cursor = cursor.to_i
|
|
||||||
|
|
||||||
redis.multi do
|
|
||||||
keys.each do |key|
|
|
||||||
if match = key.match(regexp)
|
|
||||||
db_name = match[:message_bus] || match[:namespace]
|
|
||||||
|
|
||||||
if !dbs.include?(db_name)
|
|
||||||
redis.del(key)
|
|
||||||
end
|
|
||||||
end
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
break if cursor == 0
|
|
||||||
end
|
|
||||||
end
|
|
||||||
end
|
|
||||||
end
|
|
Loading…
Reference in New Issue
Block a user