API v3: allow eager loading owner repos

This commit is contained in:
Konstantin Haase 2015-04-28 14:58:21 +02:00
parent bac3b38153
commit 595163619d
8 changed files with 102 additions and 28 deletions

View File

@ -42,11 +42,12 @@ module Travis::API::V3
def render_value(value, **options) def render_value(value, **options)
case value case value
when Hash then value.map { |k, v| [k, render_value(v)] }.to_h when Hash then value.map { |k, v| [k, render_value(v)] }.to_h
when Array then value.map { |v | render_value(v) } when Array then value.map { |v | render_value(v) }
when *PRIMITIVE then value when *PRIMITIVE then value
when Time then value.strftime('%Y-%m-%dT%H:%M:%SZ') when Time then value.strftime('%Y-%m-%dT%H:%M:%SZ')
when Model then render_model(value, **options) when Model then render_model(value, **options)
when ActiveRecord::Relation then render_value(value.to_a, **options)
else raise ArgumentError, 'cannot render %p (%p)' % [value.class, value] else raise ArgumentError, 'cannot render %p (%p)' % [value.class, value]
end end
end end

View File

@ -34,15 +34,16 @@ module Travis::API::V3
new(model, **options).render(representation) new(model, **options).render(representation)
end end
attr_reader :model, :options, :script_name, :include, :included attr_reader :model, :options, :script_name, :include, :included, :access_control
attr_writer :href attr_writer :href
def initialize(model, script_name: nil, include: [], included: [], **options) def initialize(model, script_name: nil, include: [], included: [], access_control: nil, **options)
@model = model @model = model
@options = options @options = options
@script_name = script_name @script_name = script_name
@include = include @include = include
@included = included @included = included
@access_control = access_control
end end
def href def href
@ -69,7 +70,11 @@ module Travis::API::V3
nested_included = included + [model] nested_included = included + [model]
modes = {} modes = {}
excepted_type = result[:@type].to_s if include.any? if include.any?
excepted_type = result[:@type].to_s
fields = fields.dup
end
include.each do |qualified_field| include.each do |qualified_field|
raise WrongParams, 'illegal format for include parameter'.freeze unless /\A(?<prefix>\w+)\.(?<field>\w+)\Z$/ =~ qualified_field raise WrongParams, 'illegal format for include parameter'.freeze unless /\A(?<prefix>\w+)\.(?<field>\w+)\Z$/ =~ qualified_field
next if prefix != excepted_type next if prefix != excepted_type

View File

@ -5,7 +5,19 @@ module Travis::API::V3
class Renderer::Owner < Renderer::ModelRenderer class Renderer::Owner < Renderer::ModelRenderer
include Renderer::AvatarURL include Renderer::AvatarURL
representation(:minimal, :id, :login) representation(:minimal, :id, :login)
representation(:standard, :id, :login, :name, :github_id, :avatar_url) representation(:standard, :id, :login, :name, :github_id, :avatar_url)
representation(:additional, :repositories)
def initialize(*)
super
owner_includes = include.select { |i| i.start_with?('owner.'.freeze) }
owner_includes.each { |i| include << i.sub('owner.'.freeze, "#{self.class.type}.") }
end
def repositories
access_control.visible_repositories(@model.repositories)
end
end end
end end

View File

@ -1,9 +1,9 @@
module Travis::API::V3 module Travis::API::V3
class Result class Result
attr_accessor :type, :resource, :status, :href attr_accessor :access_control, :type, :resource, :status, :href
def initialize(type, resource = [], status: 200) def initialize(access_control, type, resource = [], status: 200)
@type, @resource, @status = type, resource, status @access_control, @type, @resource, @status = access_control, type, resource, status
end end
def respond_to_missing?(method, *) def respond_to_missing?(method, *)
@ -19,7 +19,7 @@ module Travis::API::V3
href = self.href href = self.href
href = V3.location(env) if href.nil? and env['REQUEST_METHOD'.freeze] == 'GET'.freeze href = V3.location(env) if href.nil? and env['REQUEST_METHOD'.freeze] == 'GET'.freeze
include = params['include'.freeze].to_s.split(?,.freeze) include = params['include'.freeze].to_s.split(?,.freeze)
Renderer[type].render(resource, href: href, script_name: env['SCRIPT_NAME'.freeze], include: include) Renderer[type].render(resource, href: href, script_name: env['SCRIPT_NAME'.freeze], include: include, access_control: access_control)
end end
def method_missing(method, *args) def method_missing(method, *args)

View File

@ -21,7 +21,7 @@ module Travis::API::V3
result = service.run result = service.run
render(result, env_params, env) render(result, env_params, env)
rescue Error => error rescue Error => error
result = Result.new(:error, error) result = Result.new(access_control, :error, error)
headers = error.status == 404 ? CASCADE : {} headers = error.status == 404 ? CASCADE : {}
V3.response(result.render(env_params, env), headers, status: error.status) V3.response(result.render(env_params, env), headers, status: error.status)
end end

View File

@ -61,9 +61,13 @@ module Travis::API::V3
self.class.result_type self.class.result_type
end end
def result(*args)
Result.new(access_control, *args)
end
def run def run
not_found unless result = run! not_found unless result = run!
result = Result.new(result_type, result) unless result.is_a? Result result = result(result_type, result) unless result.is_a? Result
result result
end end
@ -75,7 +79,7 @@ module Travis::API::V3
def accepted(**payload) def accepted(**payload)
payload[:resource_type] ||= result_type payload[:resource_type] ||= result_type
Result.new(:accepted, payload, status: 202) result(:accepted, payload, status: 202)
end end
def not_implemented def not_implemented

View File

@ -1,11 +1,13 @@
require 'spec_helper' require 'spec_helper'
describe Travis::API::V3::Result do describe Travis::API::V3::Result do
subject(:result) { described_class.new(:example) } let(:access_control) { Object.new }
subject(:result) { described_class.new(access_control, :example) }
example { expect(result.type) .to be == :example } example { expect(result.type) .to be == :example }
example { expect(result.resource) .to be == [] } example { expect(result.resource) .to be == [] }
example { expect(result.example) .to be == [] } example { expect(result.example) .to be == [] }
example { expect(result.access_control) .to be == access_control }
example do example do
result << 42 result << 42

View File

@ -7,7 +7,7 @@ describe Travis::API::V3::Services::Owner::Find do
after { org.delete } after { org.delete }
describe 'existing org, public api' do describe 'existing org, public api' do
before { get("/v3/owner/example-org") } before { get("/v3/owner/example-org") }
example { expect(last_response).to be_ok } example { expect(last_response).to be_ok }
example { expect(JSON.load(body)).to be == { example { expect(JSON.load(body)).to be == {
"@type" => "organization", "@type" => "organization",
@ -20,8 +20,58 @@ describe Travis::API::V3::Services::Owner::Find do
}} }}
end end
describe 'eager loading repositories via organization.repositories' do
let(:repo) { Repository.new(name: 'example-repo', owner_name: 'example-org', owner_id: org.id, owner_type: 'Organization')}
before { repo.save! }
after { repo.destroy }
before { get("/v3/owner/example-org?include=organization.repositories,user.repositories") }
example { expect(last_response).to be_ok }
example { expect(JSON.load(body)).to be == {
"@type" => "organization",
"@href" => "/v3/org/#{org.id}",
"id" => org.id,
"login" => "example-org",
"name" => nil,
"github_id" => nil,
"avatar_url" => nil,
"repositories" => [{
"@type" => "repository",
"@href" => "/repo/#{repo.id}",
"id" => repo.id,
"slug" => "example-org/example-repo"
}]
}}
end
describe 'eager loading repositories via owner.repositories' do
let(:repo) { Repository.new(name: 'example-repo', owner_name: 'example-org', owner_id: org.id, owner_type: 'Organization')}
before { repo.save! }
after { repo.destroy }
before { get("/v3/owner/example-org?include=owner.repositories") }
example { expect(last_response).to be_ok }
example { expect(JSON.load(body)).to be == {
"@type" => "organization",
"@href" => "/v3/org/#{org.id}",
"id" => org.id,
"login" => "example-org",
"name" => nil,
"github_id" => nil,
"avatar_url" => nil,
"repositories" => [{
"@type" => "repository",
"@href" => "/repo/#{repo.id}",
"id" => repo.id,
"slug" => "example-org/example-repo"
}]
}}
end
describe 'it is not case sensitive' do describe 'it is not case sensitive' do
before { get("/v3/owner/example-ORG") } before { get("/v3/owner/example-ORG") }
example { expect(last_response).to be_ok } example { expect(last_response).to be_ok }
example { expect(JSON.load(body)).to be == { example { expect(JSON.load(body)).to be == {
"@type" => "organization", "@type" => "organization",