Redis connection pooling updates

This commit is contained in:
Fosco Marotto
2021-01-16 13:52:11 -05:00
parent 8a3ed8d921
commit 8d48c3ce3d
6 changed files with 64 additions and 48 deletions

View File

@@ -22,17 +22,19 @@ class Api::V1::Accounts::CredentialsController < Api::BaseController
@account = current_account
if !@account.user.confirmed?
redisResult = Redis.current.get("account:#{@account.id}:last_email_confirmation_resend") || 0
Redis.current.with do |conn|
redisResult = conn.get("account:#{@account.id}:last_email_confirmation_resend") || 0
@lastSentDate = redisResult
if redisResult != 0
@lastSentDate = Time.at(redisResult.to_i).utc
end
if @lastSentDate == 0 || (@lastSentDate != 0 && Time.now.utc - @lastSentDate >= 1.hour)
@user = Account.find(@account.id).user || raise(ActiveRecord::RecordNotFound)
Redis.current.set("account:#{@account.id}:last_email_confirmation_resend", Time.now.utc.to_i)
@user.resend_confirmation_instructions
@lastSentDate = redisResult
if redisResult != 0
@lastSentDate = Time.at(redisResult.to_i).utc
end
if @lastSentDate == 0 || (@lastSentDate != 0 && Time.now.utc - @lastSentDate >= 1.hour)
@user = Account.find(@account.id).user || raise(ActiveRecord::RecordNotFound)
conn.set("account:#{@account.id}:last_email_confirmation_resend", Time.now.utc.to_i)
@user.resend_confirmation_instructions
end
end
end

View File

@@ -3,7 +3,9 @@
class Api::V1::ExpensesController < EmptyController
def show
amount = Redis.current.get("monthly_funding_amount") || 0
Redis.current.with do |conn|
amount = conn.get("monthly_funding_amount") || 0
end
amount = [amount.to_f, 100].min
render json: { "expenses": amount }
end

View File

@@ -28,38 +28,40 @@ class Api::V1::PopularLinksController < Api::BaseController
end
def get_cards
body = Redis.current.get("popular_links:card_ids")
if body.nil? || body.empty?
statusIds = Status.where('statuses.created_at > ?', 24.hours.ago)
.joins(:status_stat)
.order('status_stats.favourites_count DESC')
.where('status_stats.favourites_count > 15')
.joins("LEFT JOIN preview_cards_statuses ON statuses.id = preview_cards_statuses.status_id")
.where('preview_cards_statuses.status_id IS NOT NULL')
.limit(100)
.pluck('statuses.id')
Redis.current.with do |conn|
body = conn.get("popular_links:card_ids")
if body.nil? || body.empty?
statusIds = Status.where('statuses.created_at > ?', 24.hours.ago)
.joins(:status_stat)
.order('status_stats.favourites_count DESC')
.where('status_stats.favourites_count > 15')
.joins("LEFT JOIN preview_cards_statuses ON statuses.id = preview_cards_statuses.status_id")
.where('preview_cards_statuses.status_id IS NOT NULL')
.limit(100)
.pluck('statuses.id')
cards = PreviewCard.joins("LEFT JOIN preview_cards_statuses ON preview_cards.id = preview_cards_statuses.preview_card_id")
.where('preview_cards_statuses.preview_card_id IS NOT NULL')
.where('preview_cards_statuses.status_id IN (?)', statusIds)
.having('COUNT(preview_cards_statuses.preview_card_id) > 1')
.where('preview_cards.updated_at > ?', 24.hours.ago)
.order('COUNT(preview_cards_statuses.preview_card_id) DESC')
.group('preview_cards.id')
.limit(10)
card_ids = cards.map(&:id)
conn.set("popular_links:card_ids", card_ids.join(','))
conn.expire("popular_links:card_ids", 15.minutes.seconds)
return cards
else
cards = PreviewCard.where(id: body.split(','))
return cards
end
cards = PreviewCard.joins("LEFT JOIN preview_cards_statuses ON preview_cards.id = preview_cards_statuses.preview_card_id")
.where('preview_cards_statuses.preview_card_id IS NOT NULL')
.where('preview_cards_statuses.status_id IN (?)', statusIds)
.having('COUNT(preview_cards_statuses.preview_card_id) > 1')
.where('preview_cards.updated_at > ?', 24.hours.ago)
.order('COUNT(preview_cards_statuses.preview_card_id) DESC')
.group('preview_cards.id')
.limit(10)
card_ids = cards.map(&:id)
Redis.current.set("popular_links:card_ids", card_ids.join(','))
Redis.current.expire("popular_links:card_ids", 15.minutes.seconds)
return cards
else
cards = PreviewCard.where(id: body.split(','))
return cards
end
end
end

View File

@@ -3,7 +3,9 @@
class Api::V1::TrendingHashtagsController < EmptyController
def show
tags = Redis.current.get("admin_trending_hashtags") || ""
Redis.current.with do |conn|
tags = conn.get("admin_trending_hashtags") || ""
end
tags = tags.strip.split(", ")
render json: { trending_hashtags: tags }
end