Commit 170c3af0 authored by Adam Hegyi's avatar Adam Hegyi

Reduce N+1 queries on deploy keys index page

- Add test to prevent further N+1 queries
parent 8a6ea16a
...@@ -9,7 +9,7 @@ class DeployKey < Key ...@@ -9,7 +9,7 @@ class DeployKey < Key
scope :in_projects, ->(projects) { joins(:deploy_keys_projects).where('deploy_keys_projects.project_id in (?)', projects) } scope :in_projects, ->(projects) { joins(:deploy_keys_projects).where('deploy_keys_projects.project_id in (?)', projects) }
scope :are_public, -> { where(public: true) } scope :are_public, -> { where(public: true) }
scope :with_projects, -> { includes(deploy_keys_projects: { project: [:route, :namespace] }) } scope :with_projects, -> { includes(deploy_keys_projects: { project: [:route, namespace: :route] }) }
ignore_column :can_push, remove_after: '2019-12-15', remove_with: '12.6' ignore_column :can_push, remove_after: '2019-12-15', remove_with: '12.6'
...@@ -24,7 +24,7 @@ class DeployKey < Key ...@@ -24,7 +24,7 @@ class DeployKey < Key
end end
def almost_orphaned? def almost_orphaned?
self.deploy_keys_projects.count == 1 self.deploy_keys_projects.size == 1
end end
def destroyed_when_orphaned? def destroyed_when_orphaned?
...@@ -44,7 +44,11 @@ class DeployKey < Key ...@@ -44,7 +44,11 @@ class DeployKey < Key
end end
def deploy_keys_project_for(project) def deploy_keys_project_for(project)
deploy_keys_projects.find_by(project: project) if association(:deploy_keys_projects).loaded?
deploy_keys_projects.find { |dkp| dkp.project_id.eql?(project&.id) }
else
deploy_keys_projects.find_by(project: project)
end
end end
def projects_with_write_access def projects_with_write_access
......
...@@ -997,7 +997,7 @@ class User < ApplicationRecord ...@@ -997,7 +997,7 @@ class User < ApplicationRecord
end end
def project_deploy_keys def project_deploy_keys
DeployKey.in_projects(authorized_projects.select(:id)).distinct(:id) @project_deploy_keys ||= DeployKey.in_projects(authorized_projects.select(:id)).distinct(:id)
end end
def highest_role def highest_role
......
...@@ -3,10 +3,7 @@ ...@@ -3,10 +3,7 @@
class DeployKeyPolicy < BasePolicy class DeployKeyPolicy < BasePolicy
with_options scope: :subject, score: 0 with_options scope: :subject, score: 0
condition(:private_deploy_key) { @subject.private? } condition(:private_deploy_key) { @subject.private? }
condition(:has_deploy_key) { @user.project_deploy_keys.any? { |pdk| pdk.id.eql?(@subject.id) } }
# rubocop: disable CodeReuse/ActiveRecord
condition(:has_deploy_key) { @user.project_deploy_keys.exists?(id: @subject.id) }
# rubocop: enable CodeReuse/ActiveRecord
rule { anonymous }.prevent_all rule { anonymous }.prevent_all
......
...@@ -3,6 +3,8 @@ ...@@ -3,6 +3,8 @@
module Projects module Projects
module Settings module Settings
class DeployKeysPresenter < Gitlab::View::Presenter::Simple class DeployKeysPresenter < Gitlab::View::Presenter::Simple
include Gitlab::Utils::StrongMemoize
presents :project presents :project
delegate :size, to: :enabled_keys, prefix: true delegate :size, to: :enabled_keys, prefix: true
delegate :size, to: :available_project_keys, prefix: true delegate :size, to: :available_project_keys, prefix: true
...@@ -13,37 +15,45 @@ module Projects ...@@ -13,37 +15,45 @@ module Projects
end end
def enabled_keys def enabled_keys
project.deploy_keys strong_memoize(:enabled_keys) do
project.deploy_keys.with_projects
end
end end
def available_keys def available_keys
current_user strong_memoize(:available_keys) do
.accessible_deploy_keys current_user
.id_not_in(enabled_keys.select(:id)) .accessible_deploy_keys
.with_projects .id_not_in(enabled_keys.select(:id))
.with_projects
end
end end
def available_project_keys def available_project_keys
current_user strong_memoize(:available_project_keys) do
.project_deploy_keys current_user
.id_not_in(enabled_keys.select(:id)) .project_deploy_keys
.with_projects .id_not_in(enabled_keys.select(:id))
.with_projects
end
end end
def available_public_keys def available_public_keys
DeployKey strong_memoize(:available_public_keys) do
.are_public DeployKey
.id_not_in(enabled_keys.select(:id)) .are_public
.id_not_in(available_project_keys.select(:id)) .id_not_in(enabled_keys.select(:id))
.with_projects .id_not_in(available_project_keys.select(:id))
.with_projects
end
end end
def as_json def as_json
serializer = DeployKeySerializer.new # rubocop: disable CodeReuse/Serializer serializer = DeployKeySerializer.new # rubocop: disable CodeReuse/Serializer
opts = { user: current_user, project: project } opts = { user: current_user, project: project, readable_project_ids: readable_project_ids }
{ {
enabled_keys: serializer.represent(enabled_keys.with_projects, opts), enabled_keys: serializer.represent(enabled_keys, opts),
available_project_keys: serializer.represent(available_project_keys, opts), available_project_keys: serializer.represent(available_project_keys, opts),
public_keys: serializer.represent(available_public_keys, opts) public_keys: serializer.represent(available_public_keys, opts)
} }
...@@ -56,6 +66,26 @@ module Projects ...@@ -56,6 +66,26 @@ module Projects
def form_partial_path def form_partial_path
'projects/deploy_keys/form' 'projects/deploy_keys/form'
end end
private
# Caching all readable project ids for the user that are associated with the queried deploy keys
def readable_project_ids
strong_memoize(:readable_projects_by_id) do
Set.new(user_readable_project_ids)
end
end
# rubocop: disable CodeReuse/ActiveRecord
def user_readable_project_ids
project_ids = (available_keys + available_project_keys + available_public_keys)
.flat_map { |deploy_key| deploy_key.deploy_keys_projects.map(&:project_id) }
.compact
.uniq
current_user.authorized_projects(Gitlab::Access::GUEST).id_in(project_ids).pluck(:id)
end
# rubocop: enable CodeReuse/ActiveRecord
end end
end end
end end
...@@ -11,8 +11,7 @@ class DeployKeyEntity < Grape::Entity ...@@ -11,8 +11,7 @@ class DeployKeyEntity < Grape::Entity
expose :updated_at expose :updated_at
expose :deploy_keys_projects, using: DeployKeysProjectEntity do |deploy_key| expose :deploy_keys_projects, using: DeployKeysProjectEntity do |deploy_key|
deploy_key.deploy_keys_projects.select do |deploy_key_project| deploy_key.deploy_keys_projects.select do |deploy_key_project|
!deploy_key_project.project&.pending_delete? && !deploy_key_project.project&.pending_delete? && (allowed_to_read_project?(deploy_key_project.project) || options[:user].admin?)
Ability.allowed?(options[:user], :read_project, deploy_key_project.project)
end end
end end
expose :can_edit expose :can_edit
...@@ -23,4 +22,12 @@ class DeployKeyEntity < Grape::Entity ...@@ -23,4 +22,12 @@ class DeployKeyEntity < Grape::Entity
Ability.allowed?(options[:user], :update_deploy_key, object) || Ability.allowed?(options[:user], :update_deploy_key, object) ||
Ability.allowed?(options[:user], :update_deploy_keys_project, object.deploy_keys_project_for(options[:project])) Ability.allowed?(options[:user], :update_deploy_keys_project, object.deploy_keys_project_for(options[:project]))
end end
def allowed_to_read_project?(project)
if options[:readable_project_ids]
options[:readable_project_ids].include?(project.id)
else
Ability.allowed?(options[:user], :read_project, project)
end
end
end end
---
title: Optimize loading the repository deploy keys page
merge_request: 20970
author:
type: performance
# frozen_string_literal: true
class AddIndexToProjectsDeployKeysDeployKey < ActiveRecord::Migration[5.2]
include Gitlab::Database::MigrationHelpers
disable_ddl_transaction!
DOWNTIME = false
def up
add_concurrent_index :deploy_keys_projects, :deploy_key_id
end
def down
remove_concurrent_index :deploy_keys_projects, :deploy_key_id
end
end
...@@ -1293,6 +1293,7 @@ ActiveRecord::Schema.define(version: 2019_12_06_122926) do ...@@ -1293,6 +1293,7 @@ ActiveRecord::Schema.define(version: 2019_12_06_122926) do
t.datetime "created_at" t.datetime "created_at"
t.datetime "updated_at" t.datetime "updated_at"
t.boolean "can_push", default: false, null: false t.boolean "can_push", default: false, null: false
t.index ["deploy_key_id"], name: "index_deploy_keys_projects_on_deploy_key_id"
t.index ["project_id"], name: "index_deploy_keys_projects_on_project_id" t.index ["project_id"], name: "index_deploy_keys_projects_on_project_id"
end end
......
...@@ -46,17 +46,27 @@ describe Projects::DeployKeysController do ...@@ -46,17 +46,27 @@ describe Projects::DeployKeysController do
create(:deploy_keys_project, project: project_private, deploy_key: create(:another_deploy_key)) create(:deploy_keys_project, project: project_private, deploy_key: create(:another_deploy_key))
end end
before do context 'when user has access to all projects where deploy keys are used' do
project2.add_developer(user) before do
project2.add_developer(user)
end
it 'returns json in a correct format' do
get :index, params: params.merge(format: :json)
expect(json_response.keys).to match_array(%w(enabled_keys available_project_keys public_keys))
expect(json_response['enabled_keys'].count).to eq(1)
expect(json_response['available_project_keys'].count).to eq(1)
expect(json_response['public_keys'].count).to eq(1)
end
end end
it 'returns json in a correct format' do context 'when user has no access to all projects where deploy keys are used' do
get :index, params: params.merge(format: :json) it 'returns json in a correct format' do
get :index, params: params.merge(format: :json)
expect(json_response.keys).to match_array(%w(enabled_keys available_project_keys public_keys)) expect(json_response['available_project_keys'].count).to eq(0)
expect(json_response['enabled_keys'].count).to eq(1) end
expect(json_response['available_project_keys'].count).to eq(1)
expect(json_response['public_keys'].count).to eq(1)
end end
end end
end end
......
...@@ -5,11 +5,6 @@ require 'spec_helper' ...@@ -5,11 +5,6 @@ require 'spec_helper'
describe Projects::Settings::DeployKeysPresenter do describe Projects::Settings::DeployKeysPresenter do
let(:project) { create(:project) } let(:project) { create(:project) }
let(:user) { create(:user) } let(:user) { create(:user) }
let(:deploy_key) { create(:deploy_key, public: true) }
let!(:deploy_keys_project) do
create(:deploy_keys_project, project: project, deploy_key: deploy_key)
end
subject(:presenter) do subject(:presenter) do
described_class.new(project, current_user: user) described_class.new(project, current_user: user)
...@@ -20,6 +15,12 @@ describe Projects::Settings::DeployKeysPresenter do ...@@ -20,6 +15,12 @@ describe Projects::Settings::DeployKeysPresenter do
end end
describe '#enabled_keys' do describe '#enabled_keys' do
let!(:deploy_key) { create(:deploy_key, public: true) }
let!(:deploy_keys_project) do
create(:deploy_keys_project, project: project, deploy_key: deploy_key)
end
it 'returns currently enabled keys' do it 'returns currently enabled keys' do
expect(presenter.enabled_keys).to eq [deploy_keys_project.deploy_key] expect(presenter.enabled_keys).to eq [deploy_keys_project.deploy_key]
end end
...@@ -53,4 +54,54 @@ describe Projects::Settings::DeployKeysPresenter do ...@@ -53,4 +54,54 @@ describe Projects::Settings::DeployKeysPresenter do
expect(presenter.available_project_keys_size).to eq(1) expect(presenter.available_project_keys_size).to eq(1)
end end
end end
context 'prevent N + 1 queries' do
before do
create_records
project.add_maintainer(user)
end
def create_records
other_project = create(:project)
other_project.add_maintainer(user)
create(:deploy_keys_project, project: project, deploy_key: create(:deploy_key))
create(:deploy_keys_project, project: other_project, deploy_key: create(:deploy_key))
create(:deploy_key, public: true)
end
def execute_with_query_count
ActiveRecord::QueryRecorder.new { execute_presenter }.count
end
def execute_presenter
described_class.new(project, current_user: user).as_json
end
it 'returns correct counts' do
result = execute_presenter
expect(result[:enabled_keys].size).to eq(1)
expect(result[:available_project_keys].size).to eq(1)
expect(result[:public_keys].size).to eq(1)
end
it 'does not increase the query count' do
execute_presenter # make sure everything is cached
count_before = execute_with_query_count
3.times { create_records }
count_after = execute_with_query_count
expect(count_after).to eq(count_before)
result = execute_presenter
expect(result[:enabled_keys].size).to eq(4)
expect(result[:available_project_keys].size).to eq(4)
expect(result[:public_keys].size).to eq(4)
end
end
end end
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment