2021-03-17 11:09:03 -04:00
|
|
|
# frozen_string_literal: true
|
|
|
|
|
|
|
|
require "spec_helper"
|
|
|
|
|
2021-05-13 17:10:08 -04:00
|
|
|
RSpec.describe API::Helpers::Caching, :use_clean_rails_redis_caching do
|
2021-03-17 11:09:03 -04:00
|
|
|
subject(:instance) { Class.new.include(described_class).new }
|
|
|
|
|
2021-05-13 17:10:08 -04:00
|
|
|
let_it_be(:project) { create(:project) }
|
|
|
|
let_it_be(:user) { create(:user) }
|
2021-04-09 11:09:10 -04:00
|
|
|
|
2021-05-13 17:10:08 -04:00
|
|
|
let(:presenter) { API::Entities::Todo }
|
2021-03-17 11:09:03 -04:00
|
|
|
|
2021-05-13 17:10:08 -04:00
|
|
|
let(:return_value) do
|
|
|
|
{
|
|
|
|
foo: "bar"
|
|
|
|
}
|
|
|
|
end
|
|
|
|
|
|
|
|
let(:kwargs) do
|
|
|
|
{
|
|
|
|
expires_in: 1.minute
|
|
|
|
}
|
|
|
|
end
|
|
|
|
|
|
|
|
before do
|
|
|
|
# We have to stub #body as it's a Grape method
|
|
|
|
# unavailable in the module by itself
|
|
|
|
allow(instance).to receive(:body) do |data|
|
|
|
|
data
|
2021-03-17 11:09:03 -04:00
|
|
|
end
|
|
|
|
|
2021-05-13 17:10:08 -04:00
|
|
|
allow(instance).to receive(:current_user) { user }
|
|
|
|
end
|
|
|
|
|
|
|
|
describe "#present_cached" do
|
2021-03-17 11:09:03 -04:00
|
|
|
subject do
|
|
|
|
instance.present_cached(presentable, **kwargs)
|
|
|
|
end
|
|
|
|
|
2021-05-13 17:10:08 -04:00
|
|
|
let(:kwargs) do
|
|
|
|
{
|
|
|
|
with: presenter,
|
|
|
|
project: project
|
|
|
|
}
|
2021-03-17 11:09:03 -04:00
|
|
|
end
|
|
|
|
|
2021-06-22 05:07:12 -04:00
|
|
|
context 'single object' do
|
2021-03-17 11:09:03 -04:00
|
|
|
let_it_be(:presentable) { create(:todo, project: project) }
|
|
|
|
|
2021-06-22 05:07:12 -04:00
|
|
|
it_behaves_like 'object cache helper'
|
2021-03-17 11:09:03 -04:00
|
|
|
end
|
|
|
|
|
2021-06-22 05:07:12 -04:00
|
|
|
context 'collection of objects' do
|
2021-03-17 11:09:03 -04:00
|
|
|
let_it_be(:presentable) { Array.new(5).map { create(:todo, project: project) } }
|
|
|
|
|
2021-06-22 05:07:12 -04:00
|
|
|
it_behaves_like 'collection cache helper'
|
2021-03-17 11:09:03 -04:00
|
|
|
end
|
|
|
|
end
|
2021-05-13 17:10:08 -04:00
|
|
|
|
|
|
|
describe "#cache_action" do
|
|
|
|
def perform
|
|
|
|
instance.cache_action(cache_key, **kwargs) do
|
|
|
|
expensive_thing.do_very_expensive_action
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
|
|
|
subject { perform }
|
|
|
|
|
|
|
|
let(:expensive_thing) { double(do_very_expensive_action: return_value) }
|
|
|
|
let(:cache_key) do
|
|
|
|
[user, :foo]
|
|
|
|
end
|
|
|
|
|
|
|
|
it { is_expected.to be_a(Gitlab::Json::PrecompiledJson) }
|
|
|
|
|
|
|
|
it "represents the correct data" do
|
|
|
|
expect(subject.to_s).to eq(Gitlab::Json.dump(return_value).to_s)
|
|
|
|
end
|
|
|
|
|
|
|
|
it "only calls the expensive action once" do
|
|
|
|
expected_kwargs = described_class::DEFAULT_CACHE_OPTIONS.merge(kwargs)
|
|
|
|
|
|
|
|
expect(expensive_thing).to receive(:do_very_expensive_action).once
|
|
|
|
expect(instance.cache).to receive(:fetch).with(cache_key, **expected_kwargs).exactly(5).times.and_call_original
|
|
|
|
|
|
|
|
5.times { perform }
|
|
|
|
end
|
|
|
|
|
|
|
|
it "handles nested cache calls" do
|
|
|
|
nested_call = instance.cache_action(cache_key, **kwargs) do
|
|
|
|
instance.cache_action([:nested], **kwargs) do
|
|
|
|
expensive_thing.do_very_expensive_action
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
|
|
|
expect(nested_call.to_s).to eq(subject.to_s)
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
|
|
|
describe "#cache_action_if" do
|
|
|
|
subject do
|
|
|
|
instance.cache_action_if(conditional, cache_key, **kwargs) do
|
|
|
|
return_value
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
|
|
|
let(:cache_key) do
|
|
|
|
[user, :conditional_if]
|
|
|
|
end
|
|
|
|
|
|
|
|
context "conditional is truthy" do
|
|
|
|
let(:conditional) { "truthy thing" }
|
|
|
|
|
|
|
|
it { is_expected.to be_a(Gitlab::Json::PrecompiledJson) }
|
|
|
|
|
|
|
|
it "caches the block" do
|
|
|
|
expect(instance).to receive(:cache_action).with(cache_key, **kwargs)
|
|
|
|
|
|
|
|
subject
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
|
|
|
context "conditional is falsey" do
|
|
|
|
let(:conditional) { false }
|
|
|
|
|
|
|
|
it { is_expected.to eq(return_value) }
|
|
|
|
|
|
|
|
it "doesn't cache the block" do
|
|
|
|
expect(instance).not_to receive(:cache_action).with(cache_key, **kwargs)
|
|
|
|
|
|
|
|
subject
|
|
|
|
end
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
|
|
|
describe "#cache_action_unless" do
|
|
|
|
subject do
|
|
|
|
instance.cache_action_unless(conditional, cache_key, **kwargs) do
|
|
|
|
return_value
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
|
|
|
let(:cache_key) do
|
|
|
|
[user, :conditional_unless]
|
|
|
|
end
|
|
|
|
|
|
|
|
context "conditional is truthy" do
|
|
|
|
let(:conditional) { "truthy thing" }
|
|
|
|
|
|
|
|
it { is_expected.to eq(return_value) }
|
|
|
|
|
|
|
|
it "doesn't cache the block" do
|
|
|
|
expect(instance).not_to receive(:cache_action).with(cache_key, **kwargs)
|
|
|
|
|
|
|
|
subject
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
|
|
|
context "conditional is falsey" do
|
|
|
|
let(:conditional) { false }
|
|
|
|
|
|
|
|
it { is_expected.to be_a(Gitlab::Json::PrecompiledJson) }
|
|
|
|
|
|
|
|
it "caches the block" do
|
|
|
|
expect(instance).to receive(:cache_action).with(cache_key, **kwargs)
|
|
|
|
|
|
|
|
subject
|
|
|
|
end
|
|
|
|
end
|
|
|
|
end
|
2021-03-17 11:09:03 -04:00
|
|
|
end
|