Skip to content

Commit 5e65dcb

Browse files
seurosseuros
committed
Fix Redis connection
1 parent 48e79ba commit 5e65dcb

File tree

12 files changed

+75
-75
lines changed

12 files changed

+75
-75
lines changed

‎app/controllers/alerts_controller.rb

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -21,9 +21,9 @@ def create
2121
def index
2222
@alerts = []
2323
[:traction, :google_analytics].each do |type|
24-
count = REDIS.get(count_key(type))
24+
count = Redis.current.get(count_key(type))
2525
next if count.nil?
26-
@alerts << { type: type, count: count, data: REDIS.zrangebyscore(history_key(type), 0, Time.now.to_i, withscores: true) }
26+
@alerts << { type: type, count: count, data: Redis.current.zrangebyscore(history_key(type), 0, Time.now.to_i, withscores: true) }
2727
end
2828
end
2929

@@ -48,7 +48,7 @@ def get_alert
4848
def process_traction_alert(data)
4949
if can_report_traction?(data[:url])
5050
update_history
51-
REDIS.set(last_sent_key(:traction, data[:url]), Time.now.to_i)
51+
Redis.current.set(last_sent_key(:traction, data[:url]), Time.now.to_i)
5252
Notifier.alert_admin(:traction, data[:url], data[:message]).deliver
5353
end
5454
end
@@ -60,22 +60,22 @@ def process_google_analytics(data)
6060
if can_report_visitors?
6161
if data[:viewers] > ENV['SITE_VISITORS_MAX_ALERT_LIMIT']
6262
update_history
63-
REDIS.set(last_sent_key(:google_analytics), Time.now.to_i)
63+
Redis.current.set(last_sent_key(:google_analytics), Time.now.to_i)
6464
Notifier.alert_admin(:a_lot_of_visitors, data[:url], message).deliver!
6565
elsif data[:viewers] < ENV['SITE_VISITORS_MIN_ALERT_LIMIT']
6666
update_history
67-
REDIS.set(last_sent_key(:google_analytics), Time.now.to_i)
67+
Redis.current.set(last_sent_key(:google_analytics), Time.now.to_i)
6868
Notifier.alert_admin(:too_few_visitors, data[:url], message).deliver!
6969
end
7070
end
7171
end
7272

7373
def can_report_visitors?
74-
Time.at(REDIS.get(last_sent_key(:google_analytics)).to_i) < GA_VISITORS_ALERT_INTERVAL.ago
74+
Time.at(Redis.current.get(last_sent_key(:google_analytics)).to_i) < GA_VISITORS_ALERT_INTERVAL.ago
7575
end
7676

7777
def can_report_traction?(url)
78-
Time.at(REDIS.get(last_sent_key(:traction, url)).to_i) < TRACTION_ALERT_INTERVAL.ago
78+
Time.at(Redis.current.get(last_sent_key(:traction, url)).to_i) < TRACTION_ALERT_INTERVAL.ago
7979
end
8080

8181
def last_sent_key(type, subkey=nil)
@@ -93,10 +93,10 @@ def history_key(type)
9393
end
9494

9595
def update_stats
96-
REDIS.incr(count_key(@alert[:type]))
96+
Redis.current.incr(count_key(@alert[:type]))
9797
end
9898

9999
def update_history
100-
REDIS.zadd(history_key(@alert[:type]), Time.now.to_i, @alert[:data])
100+
Redis.current.zadd(history_key(@alert[:type]), Time.now.to_i, @alert[:data])
101101
end
102102
end

‎app/jobs/generate_top_users_composite.rb

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -14,13 +14,13 @@ def perform
1414

1515
def cache_users
1616
users = User.top(108).map { |u| {u.username => u.thumbnail_url} }.to_json
17-
REDIS.set "top_users", users
17+
Redis.current.set 'top_users', users
1818
end
1919

2020
def cache_images
2121
IMAGE_PATH.mkpath
2222

23-
users = JSON.parse(REDIS.get("top_users"))
23+
users = JSON.parse(Redis.current.get('top_users'))
2424
users.each.with_index do |pair, i|
2525
username, url = pair.keys.first, pair.values.first
2626

‎app/jobs/process_team.rb

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -10,14 +10,14 @@ def perform
1010
if team.team_members.size <= 0
1111
puts "Destroying: #{team.name}"
1212
team.destroy
13-
REDIS.zrem(Team::LEADERBOARD_KEY, team.id.to_s)
13+
Redis.current.zrem(Team::LEADERBOARD_KEY, team.id.to_s)
1414
else
1515
puts "Processing: #{team.name}"
1616
team.recalculate!
1717
if team.team_members.size < 3
18-
REDIS.zrem(Team::LEADERBOARD_KEY, team.id.to_s)
18+
Redis.current.zrem(Team::LEADERBOARD_KEY, team.id.to_s)
1919
else
20-
REDIS.zadd(Team::LEADERBOARD_KEY, team.score.to_f, team.id.to_s)
20+
Redis.current.zadd(Team::LEADERBOARD_KEY, team.score.to_f, team.id.to_s)
2121
end
2222
end
2323
when :reindex

‎app/models/event.rb

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -25,9 +25,9 @@ def generate_event(event_type, audience, data={}, drip_rate=:immediately)
2525
activity_feed_keys.each_with_index do |activity_feed_key, index|
2626
data.merge!({ channel: channels[index] }.with_indifferent_access)
2727
score_for_event = Time.now.to_f
28-
REDIS.zadd(activity_feed_key, score_for_event.to_f, data)
29-
count = REDIS.zcard(activity_feed_key)
30-
REDIS.zremrangebyrank(activity_feed_key, 0, count - TABLE_SIZE) if count > TABLE_SIZE
28+
Redis.current.zadd(activity_feed_key, score_for_event.to_f, data)
29+
count = Redis.current.zcard(activity_feed_key)
30+
Redis.current.zremrangebyrank(activity_feed_key, 0, count - TABLE_SIZE) if count > TABLE_SIZE
3131
end
3232
end
3333
end
@@ -57,7 +57,7 @@ def user_activity(user, from, to, limit, publish=false)
5757

5858
activity_feed_keys.each do |activity_feed_key|
5959
i = 1
60-
REDIS.zrangebyscore(activity_feed_key, from, to).each do |activity|
60+
Redis.current.zrangebyscore(activity_feed_key, from, to).each do |activity|
6161

6262
Rails.logger.warn("[EVAL:#{i}] Event#user_activity(user = #{user.inspect}, from = #{from.inspect}, limit = #{limit.inspect}, publish = #{publish.inspect}) set to eval activity = #{activity.inspect}") if ENV['DEBUG']
6363
i += 1

‎app/models/leaderboard_redis_rank.rb

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@ module ClassMethods
88
def top(page = 1, total = 50, country=nil)
99
end_range = (page * total) - 1
1010
start_range = (end_range - total) + 1
11-
ids = REDIS.zrevrange(Team::LEADERBOARD_KEY, start_range, end_range)
11+
ids = Redis.current.zrevrange(Team::LEADERBOARD_KEY, start_range, end_range)
1212
Team.find(ids).sort_by(&:rank)
1313
end
1414
end
@@ -20,21 +20,21 @@ def next_highest_competitors(number = 2)
2020
def higher_competitors(number = 1)
2121
low = [rank - number - 1, 0].max
2222
high = [rank - 2, 0].max
23-
total_member_count >= 3 && rank-1 != low ? REDIS.zrevrange(Team::LEADERBOARD_KEY, low, high) : []
23+
total_member_count >= 3 && rank-1 != low ? Redis.current.zrevrange(Team::LEADERBOARD_KEY, low, high) : []
2424
end
2525

2626
def lower_competitors(number = 1)
2727
low = [rank, 0].max
2828
high = [rank + number - 1, 0].max
29-
total_member_count >= 3 && rank != high ? REDIS.zrevrange(Team::LEADERBOARD_KEY, low, high) : []
29+
total_member_count >= 3 && rank != high ? Redis.current.zrevrange(Team::LEADERBOARD_KEY, low, high) : []
3030
end
3131

3232
def next_lowest_competitors(number = 2)
3333
@lower_competitor ||= Team.find(lower_competitors(number)).sort_by(&:rank)
3434
end
3535

3636
def rank
37-
@rank ||= (REDIS.zrevrank(Team::LEADERBOARD_KEY, id.to_s) || -1).to_i + 1
37+
@rank ||= (Redis.current.zrevrank(Team::LEADERBOARD_KEY, id.to_s) || -1).to_i + 1
3838
end
3939

4040
end

‎app/models/lifecycle_marketing.rb

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -17,10 +17,10 @@ def send_reminders_to_create_team
1717

1818
def send_reminders_to_invite_team_members
1919
key = 'email:team-reminders:teams-emailed'
20-
REDIS.del(key)
20+
Redis.current.del(key)
2121
valid_activity_users.where("team_document_id IS NOT NULL").where(remind_to_invite_team_members: nil).find_each do |user|
22-
unless REDIS.sismember(key, user.team_document_id) or Team.find(user.team_document_id).created_at < 1.week.ago
23-
REDIS.sadd key, user.team_document_id
22+
unless Redis.current.sismember(key, user.team_document_id) or Team.find(user.team_document_id).created_at < 1.week.ago
23+
Redis.current.sadd key, user.team_document_id
2424
Notifier.remind_to_invite_team_members(user.username).deliver
2525
end
2626
end

‎app/models/opportunity.rb

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -149,11 +149,11 @@ def applicants
149149

150150
def viewed_by(viewer)
151151
epoch_now = Time.now.to_i
152-
REDIS.incr(impressions_key)
152+
Redis.current.incr(impressions_key)
153153
if viewer.is_a?(User)
154-
REDIS.zadd(user_views_key, epoch_now, viewer.id)
154+
Redis.current.zadd(user_views_key, epoch_now, viewer.id)
155155
else
156-
REDIS.zadd(user_anon_views_key, epoch_now, viewer)
156+
Redis.current.zadd(user_anon_views_key, epoch_now, viewer)
157157
end
158158
end
159159

@@ -171,13 +171,13 @@ def user_anon_views_key
171171

172172
def viewers(since = 0)
173173
epoch_now = Time.now.to_i
174-
viewer_ids = REDIS.zrevrange(user_views_key, since, epoch_now)
174+
viewer_ids = Redis.current.zrevrange(user_views_key, since, epoch_now)
175175
User.where(id: viewer_ids).all
176176
end
177177

178178
def total_views(epoch_since = 0)
179179
epoch_now = Time.now.to_i
180-
REDIS.zcount(user_views_key, epoch_since, epoch_now) + REDIS.zcount(user_anon_views_key, epoch_since, epoch_now)
180+
Redis.current.zcount(user_views_key, epoch_since, epoch_now) + Redis.current.zcount(user_anon_views_key, epoch_since, epoch_now)
181181
end
182182

183183
def team

‎app/models/protip.rb

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -883,25 +883,25 @@ def topics_changed?
883883

884884
def viewed_by(viewer)
885885
epoch_now = Time.now.to_i
886-
REDIS.incr(impressions_key)
886+
Redis.current.incr(impressions_key)
887887
if viewer.is_a?(User)
888-
REDIS.zadd(user_views_key, epoch_now, viewer.id)
888+
Redis.current.zadd(user_views_key, epoch_now, viewer.id)
889889
generate_event(viewer: viewer.username) unless viewer_ids(5.minutes.ago.to_i).include? viewer.id.to_s
890890
index_search if viewer.admin?
891891
else
892-
REDIS.zadd(user_anon_views_key, epoch_now, viewer)
893-
count = REDIS.zcard(user_anon_views_key)
894-
REDIS.zremrangebyrank(user_anon_views_key, -(count - 100), -1) if count > 100
892+
Redis.current.zadd(user_anon_views_key, epoch_now, viewer)
893+
count = Redis.current.zcard(user_anon_views_key)
894+
Redis.current.zremrangebyrank(user_anon_views_key, -(count - 100), -1) if count > 100
895895
end
896896

897897
update_score! if (total_views % COUNTABLE_VIEWS_CHUNK) == 0
898898
end
899899

900900
def viewed_by?(viewer)
901901
if viewer.is_a?(User)
902-
!REDIS.zrank(user_views_key, viewer.id).nil?
902+
!Redis.current.zrank(user_views_key, viewer.id).nil?
903903
else
904-
!REDIS.zrank(user_anon_views_key, viewer).nil?
904+
!Redis.current.zrank(user_anon_views_key, viewer).nil?
905905
end
906906
end
907907

@@ -932,16 +932,16 @@ def viewers(since=0)
932932

933933
def viewer_ids(since=0)
934934
epoch_now = Time.now.to_i
935-
REDIS.zrangebyscore(user_views_key, since, epoch_now)
935+
Redis.current.zrangebyscore(user_views_key, since, epoch_now)
936936
end
937937

938938
def total_views(epoch_since = 0)
939939
if epoch_since.to_i == 0
940-
REDIS.get(impressions_key).to_i
940+
Redis.current.get(impressions_key).to_i
941941
else
942942
epoch_now = Time.now.to_i
943943
epoch_since = epoch_since.to_i
944-
REDIS.zcount(user_views_key, epoch_since, epoch_now) + REDIS.zcount(user_anon_views_key, epoch_since, epoch_now)
944+
Redis.current.zcount(user_views_key, epoch_since, epoch_now) + Redis.current.zcount(user_anon_views_key, epoch_since, epoch_now)
945945
end
946946
end
947947

‎app/models/team.rb

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -632,7 +632,7 @@ def team_members_with_scores
632632
end
633633

634634
def log_history!
635-
REDIS.rpush("team:#{id.to_s}:score", {
635+
Redis.current.rpush("team:#{id.to_s}:score", {
636636
date: Date.today,
637637
score: self.score,
638638
size: self.size
@@ -687,27 +687,27 @@ def user_detail_views_key
687687

688688
def viewed_by(viewer)
689689
epoch_now = Time.now.to_i
690-
REDIS.incr(impressions_key)
690+
Redis.current.incr(impressions_key)
691691
if viewer.is_a?(User)
692-
REDIS.zadd(user_views_key, epoch_now, viewer.id)
692+
Redis.current.zadd(user_views_key, epoch_now, viewer.id)
693693
else
694-
REDIS.zadd(user_anon_views_key, epoch_now, viewer)
694+
Redis.current.zadd(user_anon_views_key, epoch_now, viewer)
695695
end
696696
end
697697

698698
def impressions
699-
REDIS.get(impressions_key).to_i
699+
Redis.current.get(impressions_key).to_i
700700
end
701701

702702
def viewers(since=0)
703703
epoch_now = Time.now.to_i
704-
viewer_ids = REDIS.zrevrangebyscore(user_views_key, epoch_now, since)
704+
viewer_ids = Redis.current.zrevrangebyscore(user_views_key, epoch_now, since)
705705
User.where(id: viewer_ids).all
706706
end
707707

708708
def total_views(epoch_since = 0)
709709
epoch_now = Time.now.to_i
710-
REDIS.zcount(user_views_key, epoch_since, epoch_now) + REDIS.zcount(user_anon_views_key, epoch_since, epoch_now)
710+
Redis.current.zcount(user_views_key, epoch_since, epoch_now) + Redis.current.zcount(user_anon_views_key, epoch_since, epoch_now)
711711
end
712712

713713
def followers
@@ -806,19 +806,19 @@ def all_jobs
806806
def record_exit(viewer, exit_url, exit_target_type, furthest_scrolled, time_spent)
807807
epoch_now = Time.now.to_i
808808
data = visitor_data(exit_url, exit_target_type, furthest_scrolled, time_spent, (viewer.respond_to?(:id) && viewer.try(:id)) || viewer, epoch_now, nil)
809-
REDIS.zadd(user_detail_views_key, epoch_now, data)
809+
Redis.current.zadd(user_detail_views_key, epoch_now, data)
810810
end
811811

812812
def detailed_visitors(since = 0)
813-
REDIS.zrangebyscore(user_detail_views_key, since, Time.now.to_i).map do |visitor_string|
813+
Redis.current.zrangebyscore(user_detail_views_key, since, Time.now.to_i).map do |visitor_string|
814814
visitor = HashStringParser.better_than_eval(visitor_string)
815815
visitor[:user] = identify_visitor(visitor[:user_id])
816816
visitor
817817
end
818818
end
819819

820820
def simple_visitors(since = 0)
821-
all_visitors = REDIS.zrangebyscore(user_views_key, since, Time.now.to_i, withscores: true) + REDIS.zrangebyscore(user_anon_views_key, since, Time.now.to_i, withscores: true)
821+
all_visitors = Redis.current.zrangebyscore(user_views_key, since, Time.now.to_i, withscores: true) + Redis.current.zrangebyscore(user_anon_views_key, since, Time.now.to_i, withscores: true)
822822
Hash[*all_visitors.flatten].collect do |viewer_id, timestamp|
823823
visitor_data(nil, nil, nil, 0, viewer_id, timestamp, identify_visitor(viewer_id))
824824
end

‎app/models/usage.rb

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,15 +1,15 @@
11
class Usage
22
class << self
33
def page_view(user_id)
4-
REDIS.zadd(dated_key('view'), 1, user_id)
4+
Redis.current.zadd(dated_key('view'), 1, user_id)
55
end
66

77
def unique_visitors_on(date = Date.today)
8-
REDIS.zcount(dated_key('view', date), 1, 1000000)
8+
Redis.current.zcount(dated_key('view', date), 1, 1000000)
99
end
1010

1111
def top_ten_users_today
12-
ids = REDIS.zrevrange(dated_key('view'), 0, 10, withscores: true)
12+
ids = Redis.current.zrevrange(dated_key('view'), 0, 10, withscores: true)
1313
User.where(id: ids).all
1414
end
1515

0 commit comments

Comments
 (0)