Merge branch 'cd-v3' of github.com:travis-ci/travis-api into cd-v3

This commit is contained in:
carlad 2016-04-14 10:40:49 +02:00
commit d522072705
34 changed files with 800 additions and 452 deletions

View File

@ -18,4 +18,7 @@ services:
- redis - redis
before_script: before_script:
- 'RAILS_ENV=test bundle exec rake db:create db:migrate --trace' - 'RAILS_ENV=test bundle exec rake db:create --trace'
script:
- bundle exec rspec spec

View File

@ -1,7 +1,7 @@
source 'https://rubygems.org' source 'https://rubygems.org'
gemspec gemspec
ruby '2.1.6' if ENV.key?('DYNO') ruby '2.1.7' if ENV.key?('DYNO')
gem 's3', github: 'travis-ci/s3' gem 's3', github: 'travis-ci/s3'
@ -37,9 +37,11 @@ gem 'customerio'
group :test do group :test do
gem 'rspec', '~> 2.13' gem 'rspec', '~> 2.13'
gem 'rspec-its'
gem 'factory_girl', '~> 2.4.0' gem 'factory_girl', '~> 2.4.0'
gem 'mocha', '~> 0.12' gem 'mocha', '~> 0.12'
gem 'database_cleaner', '~> 0.8.0' gem 'database_cleaner', '~> 0.8.0'
gem 'travis-migrations', github: 'travis-ci/travis-migrations'
end end
group :development do group :development do

View File

@ -36,9 +36,9 @@ GIT
GIT GIT
remote: git://github.com/rtomayko/rack-cache.git remote: git://github.com/rtomayko/rack-cache.git
revision: f96febebed7700337e8c362403b081e45b8e4f13 revision: 2d6618172c39c53dceab2e2946d87496154f3e52
specs: specs:
rack-cache (1.5.1) rack-cache (1.6.1)
rack (>= 0.4) rack (>= 0.4)
GIT GIT
@ -50,7 +50,7 @@ GIT
GIT GIT
remote: git://github.com/travis-ci/travis-core.git remote: git://github.com/travis-ci/travis-core.git
revision: 3a9f6e4c14bb1eacb93609e1864c9c547a13c1a4 revision: f7b3a76b3f39c28bb5cf7b9dc24acec13908a11a
specs: specs:
travis-core (0.0.1) travis-core (0.0.1)
actionmailer (~> 3.2.19) actionmailer (~> 3.2.19)
@ -72,6 +72,12 @@ GIT
travis-config (~> 0.1.0) travis-config (~> 0.1.0)
virtus (~> 1.0.0) virtus (~> 1.0.0)
GIT
remote: git://github.com/travis-ci/travis-migrations.git
revision: fcf6eea3e3122a7cbb857826db835de69974c54d
specs:
travis-migrations (0.0.1)
GIT GIT
remote: git://github.com/travis-ci/travis-sidekiqs.git remote: git://github.com/travis-ci/travis-sidekiqs.git
revision: 21a2fee158e25252dd78f5fa31e81b4f6583be23 revision: 21a2fee158e25252dd78f5fa31e81b4f6583be23
@ -87,7 +93,7 @@ GIT
GIT GIT
remote: git://github.com/travis-ci/travis-yaml.git remote: git://github.com/travis-ci/travis-yaml.git
revision: 9ebe328e7546c696dd374a8cf773d93276f98e4f revision: 032caed23af8ed1ed55e9204bb91316f3ada2f74
specs: specs:
travis-yaml (0.2.0) travis-yaml (0.2.0)
@ -111,12 +117,12 @@ PATH
GEM GEM
remote: https://rubygems.org/ remote: https://rubygems.org/
specs: specs:
actionmailer (3.2.22) actionmailer (3.2.22.2)
actionpack (= 3.2.22) actionpack (= 3.2.22.2)
mail (~> 2.5.4) mail (~> 2.5.4)
actionpack (3.2.22) actionpack (3.2.22.2)
activemodel (= 3.2.22) activemodel (= 3.2.22.2)
activesupport (= 3.2.22) activesupport (= 3.2.22.2)
builder (~> 3.0.0) builder (~> 3.0.0)
erubis (~> 2.7.0) erubis (~> 2.7.0)
journey (~> 1.0.4) journey (~> 1.0.4)
@ -126,15 +132,15 @@ GEM
sprockets (~> 2.2.1) sprockets (~> 2.2.1)
active_model_serializers (0.9.0) active_model_serializers (0.9.0)
activemodel (>= 3.2) activemodel (>= 3.2)
activemodel (3.2.22) activemodel (3.2.22.2)
activesupport (= 3.2.22) activesupport (= 3.2.22.2)
builder (~> 3.0.0) builder (~> 3.0.0)
activerecord (3.2.22) activerecord (3.2.22.2)
activemodel (= 3.2.22) activemodel (= 3.2.22.2)
activesupport (= 3.2.22) activesupport (= 3.2.22.2)
arel (~> 3.0.2) arel (~> 3.0.2)
tzinfo (~> 0.3.29) tzinfo (~> 0.3.29)
activesupport (3.2.22) activesupport (3.2.22.2)
i18n (~> 0.6, >= 0.6.4) i18n (~> 0.6, >= 0.6.4)
multi_json (~> 1.0) multi_json (~> 1.0)
addressable (2.4.0) addressable (2.4.0)
@ -145,7 +151,7 @@ GEM
descendants_tracker (~> 0.0.4) descendants_tracker (~> 0.0.4)
ice_nine (~> 0.11.0) ice_nine (~> 0.11.0)
thread_safe (~> 0.3, >= 0.3.1) thread_safe (~> 0.3, >= 0.3.1)
backports (3.6.7) backports (3.6.8)
builder (3.0.4) builder (3.0.4)
bunny (0.8.0) bunny (0.8.0)
celluloid (0.16.0) celluloid (0.16.0)
@ -193,9 +199,9 @@ GEM
httparty (0.11.0) httparty (0.11.0)
multi_json (~> 1.0) multi_json (~> 1.0)
multi_xml (>= 0.5.2) multi_xml (>= 0.5.2)
httpclient (2.7.0.1) httpclient (2.7.1)
i18n (0.7.0) i18n (0.7.0)
ice_nine (0.11.1) ice_nine (0.11.2)
jemalloc (1.0.1) jemalloc (1.0.1)
journey (1.0.4) journey (1.0.4)
json (1.8.3) json (1.8.3)
@ -246,9 +252,9 @@ GEM
rack rack
rack-test (0.6.3) rack-test (0.6.3)
rack (>= 1.0) rack (>= 1.0)
railties (3.2.22) railties (3.2.22.2)
actionpack (= 3.2.22) actionpack (= 3.2.22.2)
activesupport (= 3.2.22) activesupport (= 3.2.22.2)
rack-ssl (~> 1.3.2) rack-ssl (~> 1.3.2)
rake (>= 0.8.7) rake (>= 0.8.7)
rdoc (~> 3.4) rdoc (~> 3.4)
@ -276,6 +282,9 @@ GEM
rspec-core (2.99.2) rspec-core (2.99.2)
rspec-expectations (2.99.2) rspec-expectations (2.99.2)
diff-lcs (>= 1.1.3, < 2.0) diff-lcs (>= 1.1.3, < 2.0)
rspec-its (1.0.1)
rspec-core (>= 2.99.0.beta1)
rspec-expectations (>= 2.99.0.beta1)
rspec-mocks (2.99.2) rspec-mocks (2.99.2)
sidekiq (3.3.0) sidekiq (3.3.0)
celluloid (>= 0.16.0) celluloid (>= 0.16.0)
@ -322,7 +331,7 @@ GEM
treetop (1.4.15) treetop (1.4.15)
polyglot polyglot
polyglot (>= 0.3.1) polyglot (>= 0.3.1)
tzinfo (0.3.46) tzinfo (0.3.47)
unicorn (4.8.3) unicorn (4.8.3)
kgio (~> 2.6) kgio (~> 2.6)
rack rack
@ -362,6 +371,7 @@ DEPENDENCIES
rb-fsevent (~> 0.9.1) rb-fsevent (~> 0.9.1)
rerun rerun
rspec (~> 2.13) rspec (~> 2.13)
rspec-its
s3! s3!
sentry-raven! sentry-raven!
simplecov simplecov
@ -372,8 +382,12 @@ DEPENDENCIES
travis-api! travis-api!
travis-config (~> 0.1.0) travis-config (~> 0.1.0)
travis-core! travis-core!
travis-migrations!
travis-sidekiqs! travis-sidekiqs!
travis-support! travis-support!
travis-yaml! travis-yaml!
unicorn unicorn
yard-sinatra! yard-sinatra!
BUNDLED WITH
1.11.2

View File

@ -7,7 +7,7 @@ This is the app running on https://api.travis-ci.org/
1. PostgreSQL 9.3 or higher 1. PostgreSQL 9.3 or higher
1. Redis 1. Redis
1. RabbitMQ 1. RabbitMQ
1. Nginx *NB: If working on Ubuntu please install Nginx manually from source. [This guide](http://www.rackspace.com/knowledge_center/article/ubuntu-and-debian-installing-nginx-from-source) is helpful but make sure you install the [latest stable version](https://www.nginx.com/resources/wiki/start/topics/tutorials/install/#stable), include the user name on your ubuntu machine when compiling (add `--user=[yourusername]` as an option when running `./configure`), and don't follow any subsequent server configuration steps. Travis-api will start and configure its own nginx server when run locally. 1. Nginx *NB: If working on Ubuntu please install Nginx manually from source. [This guide](http://www.rackspace.com/knowledge_center/article/ubuntu-and-debian-installing-nginx-from-source) is helpful but make sure you install the [latest stable version](https://www.nginx.com/resources/wiki/start/topics/tutorials/install/#stable), include the user name on your ubuntu machine when compiling (add `--user=[yourusername]` as an option when running `./configure`), and don't follow any subsequent server configuration steps. Travis-api will start and configure its own nginx server when run locally.
## Installation ## Installation
@ -17,8 +17,10 @@ This is the app running on https://api.travis-ci.org/
### Database setup ### Database setup
1. `rake db:create db:migrate` NB detail for how `rake` sets up the database can be found in the `Rakefile`. In the `namespace :db` block you will see the database name for development is hardcoded to `travis-development`. If you are using a different configuration you will have to make your own adjustments.
2. for testing 'RAILS_ENV=test bundle exec rake db:create db:migrate --trace'
1. `bundle exec rake db:create`
2. for testing 'RAILS_ENV=test bundle exec rake db:create --trace'
1. Clone `travis-logs` and copy the `logs` database (assume the PostgreSQL user is `postgres`): 1. Clone `travis-logs` and copy the `logs` database (assume the PostgreSQL user is `postgres`):
```sh-session ```sh-session
cd .. cd ..
@ -31,7 +33,7 @@ pg_dump -t logs travis_logs_development | psql -U postgres travis_development
Repeat the database steps for `RAILS_ENV=test`. Repeat the database steps for `RAILS_ENV=test`.
```sh-session ```sh-session
RAILS_ENV=test rake db:create db:structure:load RAILS_ENV=test bundle exec rake db:create
pushd ../travis-logs pushd ../travis-logs
RAILS_ENV=test rvm jruby do bundle exec rake db:migrate RAILS_ENV=test rvm jruby do bundle exec rake db:migrate
psql -c "DROP TABLE IF EXISTS logs CASCADE" -U postgres travis_test psql -c "DROP TABLE IF EXISTS logs CASCADE" -U postgres travis_test

150
Rakefile
View File

@ -1,127 +1,45 @@
require 'bundler/setup' require 'rake'
require 'travis' require 'travis/migrations'
require 'travis/engine'
begin task default: :spec
ENV['SCHEMA'] = File.expand_path('../db/schema.rb', $:.detect { |p| p.include?('travis-core') })
require 'micro_migrations'
rescue LoadError
# we can't load micro migrations on production
end
require 'travis'
begin namespace :db do
require 'rspec/core/rake_task' if ENV["RAILS_ENV"] == 'test'
RSpec::Core::RakeTask.new desc 'Create and migrate the test database'
task default: :spec task :create do
rescue LoadError sh 'createdb travis_test' rescue nil
warn "could not load rspec" sh "psql -q travis_test < #{Gem.loaded_specs['travis-migrations'].full_gem_path}/db/structure.sql"
end
else
desc 'Create and migrate the development database'
task :create do
sh 'createdb travis_development' rescue nil
sh "psql -q travis_development < #{Gem.loaded_specs['travis-migrations'].full_gem_path}/db/structure.sql"
end
end
end end
desc "generate gemspec" desc "generate gemspec"
task 'travis-api.gemspec' do task 'travis-api.gemspec' do
content = File.read 'travis-api.gemspec' content = File.read 'travis-api.gemspec'
fields = { fields = {
authors: `git shortlog -sn`.scan(/[^\d\s].*/), authors: `git shortlog -sn`.scan(/[^\d\s].*/),
email: `git shortlog -sne`.scan(/[^<]+@[^>]+/), email: `git shortlog -sne`.scan(/[^<]+@[^>]+/),
files: `git ls-files`.split("\n").reject { |f| f =~ /^(\.|Gemfile)/ } files: `git ls-files`.split("\n").reject { |f| f =~ /^(\.|Gemfile)/ }
} }
fields.each do |field, values| fields.each do |field, values|
updated = " s.#{field} = [" updated = " s.#{field} = ["
updated << values.map { |v| "\n %p" % v }.join(',') updated << values.map { |v| "\n %p" % v }.join(',')
updated << "\n ]" updated << "\n ]"
content.sub!(/ s\.#{field} = \[\n( .*\n)* \]/, updated) content.sub!(/ s\.#{field} = \[\n( .*\n)* \]/, updated)
end end
File.open('travis-api.gemspec', 'w') { |f| f << content } File.open('travis-api.gemspec', 'w') { |f| f << content }
end end
task default: 'travis-api.gemspec' task default: 'travis-api.gemspec'
tasks_path = File.expand_path('../lib/tasks/*.rake', __FILE__) tasks_path = File.expand_path('../lib/tasks/*.rake', __FILE__)
Dir.glob(tasks_path).each { |r| import r } Dir.glob(tasks_path).each { |r| import r }
module ActiveRecord
class Migration
class << self
attr_accessor :disable_ddl_transaction
end
# Disable DDL transactions for this migration.
def self.disable_ddl_transaction!
@disable_ddl_transaction = true
end
def disable_ddl_transaction # :nodoc:
self.class.disable_ddl_transaction
end
end
class Migrator
def use_transaction?(migration)
!migration.disable_ddl_transaction && Base.connection.supports_ddl_transactions?
end
def ddl_transaction(migration, &block)
if use_transaction?(migration)
Base.transaction { block.call }
else
block.call
end
end
def migrate(&block)
current = migrations.detect { |m| m.version == current_version }
target = migrations.detect { |m| m.version == @target_version }
if target.nil? && @target_version && @target_version > 0
raise UnknownMigrationVersionError.new(@target_version)
end
start = up? ? 0 : (migrations.index(current) || 0)
finish = migrations.index(target) || migrations.size - 1
runnable = migrations[start..finish]
# skip the last migration if we're headed down, but not ALL the way down
runnable.pop if down? && target
ran = []
runnable.each do |migration|
if block && !block.call(migration)
next
end
Base.logger.info "Migrating to #{migration.name} (#{migration.version})" if Base.logger
seen = migrated.include?(migration.version.to_i)
# On our way up, we skip migrating the ones we've already migrated
next if up? && seen
# On our way down, we skip reverting the ones we've never migrated
if down? && !seen
migration.announce 'never migrated, skipping'; migration.write
next
end
begin
ddl_transaction(migration) do
migration.migrate(@direction)
record_version_state_after_migrating(migration.version)
end
ran << migration
rescue => e
canceled_msg = Base.connection.supports_ddl_transactions? ? "this and " : ""
raise StandardError, "An error has occurred, #{canceled_msg}all later migrations canceled:\n\n#{e}", e.backtrace
end
end
ran
end
end
class MigrationProxy
delegate :disable_ddl_transaction, to: :migration
end
end

View File

@ -20,4 +20,3 @@ development:
test: test:
<<: *defaults <<: *defaults
database: travis_test database: travis_test

View File

@ -122,7 +122,6 @@ module Travis::Api
use Travis::Api::App::Middleware::Logging use Travis::Api::App::Middleware::Logging
use Travis::Api::App::Middleware::ScopeCheck use Travis::Api::App::Middleware::ScopeCheck
use Travis::Api::App::Middleware::UserAgentTracker use Travis::Api::App::Middleware::UserAgentTracker
use Travis::Api::App::Middleware::Metriks
# make sure this is below ScopeCheck so we have the token # make sure this is below ScopeCheck so we have the token
use Rack::Attack if Endpoint.production? use Rack::Attack if Endpoint.production?
@ -133,6 +132,9 @@ module Travis::Api
# rewrite should come after V3 hook # rewrite should come after V3 hook
use Travis::Api::App::Middleware::Rewrite use Travis::Api::App::Middleware::Rewrite
# v3 has its own metriks
use Travis::Api::App::Middleware::Metriks
SettingsEndpoint.subclass :env_vars SettingsEndpoint.subclass :env_vars
if Travis.config.endpoints.ssh_key if Travis.config.endpoints.ssh_key
SingletonSettingsEndpoint.subclass :ssh_key SingletonSettingsEndpoint.subclass :ssh_key
@ -197,8 +199,10 @@ module Travis::Api
Travis::Database.connect Travis::Database.connect
if Travis.config.logs_database if Travis.config.logs_database
Log.establish_connection 'logs_database' pool_size = ENV['DATABASE_POOL_SIZE']
Log::Part.establish_connection 'logs_database' Travis.config.logs_database[:pool] = pool_size.to_i if pool_size
Travis::LogsModel.establish_connection 'logs_database'
end end
end end

View File

@ -61,7 +61,7 @@ class Rack::Attack
# Ban after: 10 POST requests within 30 seconds # Ban after: 10 POST requests within 30 seconds
blacklist('spamming with POST requests') do |request| blacklist('spamming with POST requests') do |request|
Rack::Attack::Allow2Ban.filter(request.identifier, maxretry: 10, findtime: 30.seconds, bantime: bantime(1.hour)) do Rack::Attack::Allow2Ban.filter(request.identifier, maxretry: 10, findtime: 30.seconds, bantime: bantime(1.hour)) do
request.post? and not POST_WHITELISTED.include? '/auth/github' request.post? and not POST_WHITELISTED.include? request.path
end end
end end

View File

@ -17,7 +17,7 @@ module Travis
def data def data
{ {
'build' => build_data(build), 'build' => build_data(build),
'commit' => commit_data(build.commit), 'commit' => commit_data(build.commit, build.repository),
'jobs' => options[:include_jobs] ? build.matrix.map { |job| job_data(job) } : [], 'jobs' => options[:include_jobs] ? build.matrix.map { |job| job_data(job) } : [],
'annotations' => options[:include_jobs] ? Annotations.new(annotations(build), @options).data["annotations"] : [], 'annotations' => options[:include_jobs] ? Annotations.new(annotations(build), @options).data["annotations"] : [],
} }
@ -44,11 +44,12 @@ module Travis
} }
end end
def commit_data(commit) def commit_data(commit, repository)
{ {
'id' => commit.id, 'id' => commit.id,
'sha' => commit.commit, 'sha' => commit.commit,
'branch' => commit.branch, 'branch' => commit.branch,
'branch_is_default' => branch_is_default(commit, repository),
'message' => commit.message, 'message' => commit.message,
'committed_at' => format_date(commit.committed_at), 'committed_at' => format_date(commit.committed_at),
'author_name' => commit.author_name, 'author_name' => commit.author_name,
@ -78,6 +79,10 @@ module Travis
} }
end end
def branch_is_default(commit, repository)
repository.default_branch == commit.branch
end
def annotations(build) def annotations(build)
build.matrix.map(&:annotations).flatten build.matrix.map(&:annotations).flatten
end end

View File

@ -15,7 +15,7 @@ module Travis
def data def data
{ {
'job' => job_data(job), 'job' => job_data(job),
'commit' => commit_data(job.commit), 'commit' => commit_data(job.commit, job.repository),
'annotations' => Annotations.new(job.annotations, @options).data["annotations"], 'annotations' => Annotations.new(job.annotations, @options).data["annotations"],
} }
end end
@ -42,11 +42,12 @@ module Travis
} }
end end
def commit_data(commit) def commit_data(commit, repository)
{ {
'id' => commit.id, 'id' => commit.id,
'sha' => commit.commit, 'sha' => commit.commit,
'branch' => commit.branch, 'branch' => commit.branch,
'branch_is_default' => branch_is_default(commit, repository),
'message' => commit.message, 'message' => commit.message,
'committed_at' => format_date(commit.committed_at), 'committed_at' => format_date(commit.committed_at),
'author_name' => commit.author_name, 'author_name' => commit.author_name,
@ -56,6 +57,10 @@ module Travis
'compare_url' => commit.compare_url, 'compare_url' => commit.compare_url,
} }
end end
def branch_is_default(commit, repository)
repository.default_branch == commit.branch
end
end end
end end
end end

View File

@ -35,6 +35,7 @@ module Travis
NotImplemented = ServerError .create('request not (yet) implemented', status: 501) NotImplemented = ServerError .create('request not (yet) implemented', status: 501)
RequestLimitReached = ClientError .create('request limit reached for resource', status: 429) RequestLimitReached = ClientError .create('request limit reached for resource', status: 429)
AlreadySyncing = ClientError .create('sync already in progress', status: 409) AlreadySyncing = ClientError .create('sync already in progress', status: 409)
MethodNotAllowed = ClientError .create('method not allowed', status: 405)
end end
end end
end end

View File

@ -0,0 +1,103 @@
require 'metriks'
module Travis::API::V3
class Metrics
class MetriksTracker
def initialize(prefix: "api.v3")
@prefx = prefix
end
def time(name, duration)
::Metriks.timer("#{@prefix}.#{name}").update(duration)
end
def mark(name)
::Metriks.meter("#{@prefix}.#{name}").mark
end
end
class Processor
attr_reader :queue, :tracker
def initialize(queue_size: 1000, tracker: MetriksTracker.new)
@tracker = tracker
@queue = queue_size ? ::SizedQueue.new(queue_size) : ::Queue.new
end
def create(**options)
Metrics.new(self, **options)
end
def start
Thread.new { loop { process(queue.pop) } }
end
def process(metrics)
metrics.process(tracker)
rescue Exception => e
$stderr.puts e.message, e.backtrace
end
end
def initialize(processor, time: Time.now)
@processor = processor
@start_time = time
@name_after = nil
@ticks = []
@success = nil
@name = "unknown".freeze
end
def tick(event, time: Time.now)
@ticks << [event, time]
self
end
def success(**options)
finish(true, **options)
end
def failure(**options)
finish(false, **options)
end
def name_after(factory)
@name = nil
@name_after = factory
self
end
def finish(success, time: Time.now, status: nil)
@success = !!success
@status = status
@status ||= success ? 200 : 500
@end_time = time
@processor.queue << self
self
end
def name
@name ||= @name_after.name[/[^:]+::[^:]+$/].underscore.tr(?/.freeze, ?..freeze)
end
def process(tracker)
tracker.mark("status.#{@status}")
if @success
process_ticks(tracker)
tracker.time("#{name}.overall", @end_time - @start_time)
tracker.mark("#{name}.success")
else
tracker.mark("#{name}.failure")
end
end
def process_ticks(tracker)
start = @start_time
@ticks.each do |event, time|
tracker.time("#{name}.#{event}", time - start)
start = time
end
end
end
end

View File

@ -2,12 +2,13 @@ module Travis::API::V3
class Models::Job < Model class Models::Job < Model
self.inheritance_column = :_type_disabled self.inheritance_column = :_type_disabled
has_one :log, dependent: :destroy has_one :log, dependent: :destroy
belongs_to :repository belongs_to :repository
belongs_to :commit belongs_to :commit
belongs_to :build, autosave: true, foreign_key: 'source_id' belongs_to :build, autosave: true, foreign_key: 'source_id'
belongs_to :owner, polymorphic: true belongs_to :owner, polymorphic: true
serialize :config serialize :config
serialize :debug_options
end end
end end

View File

@ -9,5 +9,9 @@ module Travis::API::V3
def restart? def restart?
write? write?
end end
def debug?
write?
end
end end
end end

View File

@ -1,9 +0,0 @@
require 'travis/api/v3/permissions/generic'
module Travis::API::V3
class Permissions::Lint < Permissions::Generic
def lint?
write?
end
end
end

View File

@ -1,14 +0,0 @@
require 'travis/yaml'
module Travis::API::V3
class Queries::Lint < Query
def lint
request.body.rewind
content = params[:content] || request.body.read
parsed = Travis::Yaml.parse(content)
warnings = parsed.nested_warnings.map { |k, m| { key: k, message: m } }
payload = { lint: { warnings: warnings } }.to_json
payload
end
end
end

View File

@ -1,7 +1,7 @@
module Travis::API::V3 module Travis::API::V3
class Queries::Repositories < Query class Queries::Repositories < Query
params :active, :private, :starred, prefix: :repository params :active, :private, :starred, prefix: :repository
sortable_by :id, :github_id, :owner_name, :name, active: sort_condition(:active) sortable_by :id, :github_id, :owner_name, :name, active: sort_condition(:active), :'default_branch.last_build' => 'builds.started_at'
def for_member(user, **options) def for_member(user, **options)
all(user: user, **options).joins(:users).where(users: user_condition(user), invalidated_at: nil) all(user: user, **options).joins(:users).where(users: user_condition(user), invalidated_at: nil)

View File

@ -1,9 +1,21 @@
module Travis::API::V3 module Travis::API::V3
module Renderer::Lint module Renderer::Lint
AVAILABLE_ATTRIBUTES = [ :warnings ]
extend self extend self
def render(payload) def available_attributes
Renderer.render_value(payload) AVAILABLE_ATTRIBUTES
end
def render(lint, **)
{
:@type => 'lint'.freeze,
:warnings => warnings_for(lint)
}
end
def warnings_for(lint)
lint.nested_warnings.map { |k, m| { key: k, message: m } }
end end
end end
end end

View File

@ -1,30 +1,50 @@
module Travis::API::V3 module Travis::API::V3
class Router class Router
include Travis::API::V3 include Travis::API::V3
attr_accessor :routes attr_accessor :routes, :metrics_processor
def initialize(routes = Routes) def initialize(routes = Routes)
@routes = routes @routes = routes
@metrics_processor = Metrics::Processor.new
metrics_processor.start
routes.draw_routes routes.draw_routes
end end
def call(env) def call(env)
return service_index(env) if env['PATH_INFO'.freeze] == ?/.freeze return service_index(env) if env['PATH_INFO'.freeze] == ?/.freeze
metrics = @metrics_processor.create
access_control = AccessControl.new(env) access_control = AccessControl.new(env)
factory, params = routes.factory_for(env['REQUEST_METHOD'.freeze], env['PATH_INFO'.freeze])
env_params = params(env) env_params = params(env)
factory, params = routes.factory_for(env['REQUEST_METHOD'.freeze], env['PATH_INFO'.freeze])
raise NotFound unless factory raise NotFound unless factory
metrics.name_after(factory)
filtered = factory.filter_params(env_params) filtered = factory.filter_params(env_params)
service = factory.new(access_control, filtered.merge(params)) service = factory.new(access_control, filtered.merge(params), env['rack.input'.freeze])
result = service.run
metrics.tick(:prepare)
result = service.run
metrics.tick(:service)
env_params.each_key { |key| result.ignored_param(key, reason: "not whitelisted".freeze) unless filtered.include?(key) } env_params.each_key { |key| result.ignored_param(key, reason: "not whitelisted".freeze) unless filtered.include?(key) }
render(result, env_params, env) response = render(result, env_params, env)
metrics.tick(:renderer)
metrics.success(status: response[0])
response
rescue Error => error rescue Error => error
result = Result.new(access_control, :error, error) metrics.tick(:service)
V3.response(result.render(env_params, env), {}, status: error.status)
result = Result.new(access_control, :error, error)
response = V3.response(result.render(env_params, env), {}, status: error.status)
metrics.tick(:rendered)
metrics.failure(status: error.status)
response
end end
def render(result, env_params, env) def render(result, env_params, env)

View File

@ -34,6 +34,7 @@ module Travis::API::V3
post :cancel, '/cancel' post :cancel, '/cancel'
post :restart, '/restart' post :restart, '/restart'
post :debug, '/debug'
end end
resource :lint do resource :lint do

View File

@ -42,13 +42,14 @@ module Travis::API::V3
Queries[result_type] Queries[result_type]
end end
attr_accessor :access_control, :params attr_accessor :access_control, :params, :request_body
def initialize(access_control, params) def initialize(access_control, params, request_body)
@access_control = access_control @access_control = access_control
@params = params @params = params
@queries = {} @queries = {}
@github = {} @github = {}
@request_body = request_body
end end
def query(type = result_type) def query(type = result_type)

View File

@ -0,0 +1,29 @@
module Travis::API::V3
class Services::Job::Debug < Service
params "quiet"
attr_reader :job
def run
raise LoginRequired unless access_control.logged_in? or access_control.full_access?
raise NotFound unless @job = find(:job)
raise WrongCredentials unless Travis.config.debug_tools_enabled or Travis::Features.active?(:debug_tools, job.repository)
access_control.permissions(job).debug!
job.debug_options = debug_data
job.save!
query.restart(access_control.user)
accepted(job: job, state_change: :created)
end
def debug_data
{
stage: 'before_install',
previous_state: job.state,
created_by: access_control.user.login,
quiet: params["quiet"] || false
}
end
end
end

View File

@ -1,7 +1,12 @@
require 'travis/yaml'
module Travis::API::V3 module Travis::API::V3
class Services::Lint::Lint < Service class Services::Lint::Lint < Service
params 'content'
def run! def run!
lint request_body.rewind
content = params['content'.freeze] || request_body.read
Travis::Yaml.parse(content)
end end
end end
end end

View File

@ -7,11 +7,13 @@ require 'travis/api/workers/job_cancellation'
require 'travis/api/workers/job_restart' require 'travis/api/workers/job_restart'
require 'travis/support/amqp' require 'travis/support/amqp'
pool_size = ENV['SIDEKIQ_DB_POOL_SIZE'] || 5
Travis.config.database[:pool] = pool_size.to_i
Travis.config.logs_database[:pool] = pool_size.to_i
Travis::Database.connect Travis::Database.connect
if Travis.config.logs_database if Travis.config.logs_database
Log.establish_connection 'logs_database' Travis::LogsModel.establish_connection 'logs_database'
Log::Part.establish_connection 'logs_database'
end end
Travis::Async.enabled = true Travis::Async.enabled = true

View File

@ -3,6 +3,7 @@ ENV['RACK_ENV'] = ENV['RAILS_ENV'] = ENV['ENV'] = 'test'
require 'support/coverage' require 'support/coverage'
require 'rspec' require 'rspec'
require 'rspec/its'
require 'database_cleaner' require 'database_cleaner'
require 'sinatra/test_helpers' require 'sinatra/test_helpers'
require 'logger' require 'logger'

View File

@ -29,6 +29,7 @@ describe Travis::Api::V2::Http::Build do
'id' => 1, 'id' => 1,
'sha' => '62aae5f70ceee39123ef', 'sha' => '62aae5f70ceee39123ef',
'branch' => 'master', 'branch' => 'master',
'branch_is_default' => true,
'message' => 'the commit message', 'message' => 'the commit message',
'compare_url' => 'https://github.com/svenfuchs/minimal/compare/master...develop', 'compare_url' => 'https://github.com/svenfuchs/minimal/compare/master...develop',
'committed_at' => json_format_time(Time.now.utc - 1.hour), 'committed_at' => json_format_time(Time.now.utc - 1.hour),

View File

@ -31,6 +31,7 @@ describe Travis::Api::V2::Http::Job do
'sha' => '62aae5f70ceee39123ef', 'sha' => '62aae5f70ceee39123ef',
'message' => 'the commit message', 'message' => 'the commit message',
'branch' => 'master', 'branch' => 'master',
'branch_is_default' => true,
'message' => 'the commit message', 'message' => 'the commit message',
'committed_at' => json_format_time(Time.now.utc - 1.hour), 'committed_at' => json_format_time(Time.now.utc - 1.hour),
'committer_name' => 'Sven Fuchs', 'committer_name' => 'Sven Fuchs',

View File

@ -0,0 +1,15 @@
require 'spec_helper'
describe Travis::API::V3::ServiceIndex do
let(:headers) {{ }}
let(:path) { "/v3/repo/1/enable" }
let(:json) { JSON.load(response.body) }
let(:response) { get(path, {}, headers) }
let(:resources) { json.fetch('resources') }
it "handles wrong HTTP method with 405 status" do
response.status.should == 405
end
end

42
spec/v3/metrics_spec.rb Normal file
View File

@ -0,0 +1,42 @@
require 'spec_helper'
describe Travis::API::V3::Metrics do
class TestProcessor
attr_reader :times, :marks, :queue
def initialize
@queue = []
@times = []
@marks = []
end
def time(*args)
times << args
end
def mark(name)
marks << name
end
end
subject(:processor) { TestProcessor.new }
let(:metric) { described_class.new(processor, time: Time.at(0)) }
before do
metric.name_after(Travis::API::V3::Services::Branch::Find)
metric.tick(:example, time: Time.at(10))
metric.tick(:other_example, time: Time.at(15))
metric.success(time: Time.at(25))
metric.process(processor)
end
its(:queue) { should be == [metric] }
its(:times) { should be == [
["branch.find.example", 10.0],
["branch.find.other_example", 5.0],
["branch.find.overall", 25.0]
] }
its(:marks) { should be == ["status.200", "branch.find.success"] }
end

View File

@ -0,0 +1,70 @@
require 'spec_helper'
describe Travis::API::V3::Services::Job::Debug do
let(:repo) { Travis::API::V3::Models::Repository.where(owner_name: 'svenfuchs', name: 'minimal').first }
let(:owner_type) { repo.owner_type.constantize }
let(:owner) { owner_type.find(repo.owner_id)}
let(:build) { repo.builds.last }
let(:jobs) { Travis::API::V3::Models::Build.find(build.id).jobs }
let(:job) { jobs.last }
before { repo.requests.each(&:delete) }
before do
Travis::Features.stubs(:owner_active?).returns(true)
@original_sidekiq = Sidekiq::Client
Sidekiq.send(:remove_const, :Client) # to avoid a warning
Sidekiq::Client = []
Travis.config.stubs(:debug_tools_enabled).returns true
end
after do
Sidekiq.send(:remove_const, :Client) # to avoid a warning
Sidekiq::Client = @original_sidekiq
end
describe "#run" do
context "when unauthenticated" do
before { post("/v3/job/#{job.id}/debug") }
example { expect(last_response.status).to be == 403 }
example { expect(JSON.load(body)).to be == {
"@type" => "error",
"error_type" => "login_required",
"error_message" => "login required"
}}
end
context "when authenticated" do
let(:token) { Travis::Api::App::AccessToken.create(user: repo.owner, app_id: 1) }
let(:headers) {{ 'HTTP_AUTHORIZATION' => "token #{token}" }}
context "without sufficient authorization" do
before { post("/v3/job/#{job.id}/debug", {}, headers) }
example { expect(last_response.status).to be == 403 }
example { expect(JSON.load(body)).to include(
"@type" => "error",
"error_type" => "insufficient_access",
"error_message" => "operation requires debug access to job",
"resource_type" => "job",
)}
end
context "with sufficient authorization" do
let(:params) {{}}
before { Travis::API::V3::Models::Permission.create(repository: repo, user: repo.owner, push: true) }
before { post("/v3/job/#{job.id}/debug", {}, headers) }
example { expect(last_response.status).to be == 202 }
example { expect(job.reload.debug_options).to include(
stage: "before_install",
created_by: owner.login,
quiet: false
) }
end
end
end
end

View File

@ -23,7 +23,8 @@ describe Travis::API::V3::Services::Job::Find do
"@permissions" => { "@permissions" => {
"read" => true, "read" => true,
"cancel" => false, "cancel" => false,
"restart" => false }, "restart" => false,
"debug" => false },
"id" => job.id, "id" => job.id,
"number" => job.number, "number" => job.number,
"state" => job.state, "state" => job.state,
@ -93,7 +94,8 @@ describe Travis::API::V3::Services::Job::Find do
"@permissions" => { "@permissions" => {
"read" => true, "read" => true,
"cancel" => false, "cancel" => false,
"restart" => false }, "restart" => false,
"debug" => false },
"id" => job.id, "id" => job.id,
"number" => job.number, "number" => job.number,
"state" => job.state, "state" => job.state,

View File

@ -21,7 +21,8 @@ describe Travis::API::V3::Services::Jobs::Find do
"@permissions" => { "@permissions" => {
"read" => true, "read" => true,
"cancel" => false, "cancel" => false,
"restart" => false }, "restart" => false,
"debug" => false },
"id" => jobs[0].id, "id" => jobs[0].id,
"number" => "#{jobs[0].number}", "number" => "#{jobs[0].number}",
"state" => "configured", "state" => "configured",
@ -30,45 +31,46 @@ describe Travis::API::V3::Services::Jobs::Find do
"build" => { "build" => {
"@type" => "build", "@type" => "build",
"@href" => "/v3/build/#{build.id}", "@href" => "/v3/build/#{build.id}",
"@representation"=> "minimal", "@representation"=> "minimal",
"id" => build.id, "id" => build.id,
"number" => build.number, "number" => build.number,
"state" => "configured", "state" => "configured",
"duration" => nil, "duration" => nil,
"event_type" => "push", "event_type" => "push",
"previous_state" => "passed", "previous_state" => "passed",
"started_at" => "2010-11-12T13:00:00Z", "started_at" => "2010-11-12T13:00:00Z",
"finished_at" => nil}, "finished_at" => nil},
"queue" => "builds.linux", "queue" => "builds.linux",
"repository" =>{ "repository" =>{
"@type" => "repository", "@type" => "repository",
"@href" => "/v3/repo/1", "@href" => "/v3/repo/1",
"@representation"=>"minimal", "@representation"=>"minimal",
"id" => repo.id, "id" => repo.id,
"name" => "minimal", "name" => "minimal",
"slug" => "svenfuchs/minimal"}, "slug" => "svenfuchs/minimal"},
"commit" =>{ "commit" =>{
"@type" => "commit", "@type" => "commit",
"@representation"=> "minimal", "@representation"=> "minimal",
"id" => commit.id, "id" => commit.id,
"sha" => commit.commit, "sha" => commit.commit,
"ref" => commit.ref, "ref" => commit.ref,
"message" => commit.message, "message" => commit.message,
"compare_url" => commit.compare_url, "compare_url" => commit.compare_url,
"committed_at" =>"2010-11-12T12:55:00Z"}, "committed_at" =>"2010-11-12T12:55:00Z"},
"owner" =>{ "owner" =>{
"@type" => "user", "@type" => "user",
"@href" => "/v3/user/1", "@href" => "/v3/user/1",
"@representation"=> "minimal", "@representation"=> "minimal",
"id" => 1, "id" => 1,
"login" => "svenfuchs"}}, "login" => "svenfuchs"}},
{"@type" => "job", {"@type" => "job",
"@href" => "/v3/job/#{jobs[1].id}", "@href" => "/v3/job/#{jobs[1].id}",
"@representation" => "standard", "@representation" => "standard",
"@permissions" => { "@permissions" => {
"read" => true, "read" => true,
"cancel" => false, "cancel" => false,
"restart" => false }, "restart" => false,
"debug" => false },
"id" => jobs[1].id, "id" => jobs[1].id,
"number" => "#{jobs[1].number}", "number" => "#{jobs[1].number}",
"state" => "configured", "state" => "configured",
@ -77,45 +79,46 @@ describe Travis::API::V3::Services::Jobs::Find do
"build" => { "build" => {
"@type" => "build", "@type" => "build",
"@href" => "/v3/build/#{build.id}", "@href" => "/v3/build/#{build.id}",
"@representation"=> "minimal", "@representation"=> "minimal",
"id" => build.id, "id" => build.id,
"number" => build.number, "number" => build.number,
"state" => "configured", "state" => "configured",
"duration" => nil, "duration" => nil,
"event_type" => "push", "event_type" => "push",
"previous_state" => "passed", "previous_state" => "passed",
"started_at" => "2010-11-12T13:00:00Z", "started_at" => "2010-11-12T13:00:00Z",
"finished_at" => nil}, "finished_at" => nil},
"queue" => "builds.linux", "queue" => "builds.linux",
"repository" =>{ "repository" =>{
"@type" => "repository", "@type" => "repository",
"@href" => "/v3/repo/1", "@href" => "/v3/repo/1",
"@representation"=>"minimal", "@representation"=>"minimal",
"id" => repo.id, "id" => repo.id,
"name" => "minimal", "name" => "minimal",
"slug" => "svenfuchs/minimal"}, "slug" => "svenfuchs/minimal"},
"commit" =>{ "commit" =>{
"@type" => "commit", "@type" => "commit",
"@representation"=> "minimal", "@representation"=> "minimal",
"id" => commit.id, "id" => commit.id,
"sha" => commit.commit, "sha" => commit.commit,
"ref" => commit.ref, "ref" => commit.ref,
"message" => commit.message, "message" => commit.message,
"compare_url" => commit.compare_url, "compare_url" => commit.compare_url,
"committed_at" =>"2010-11-12T12:55:00Z"}, "committed_at" =>"2010-11-12T12:55:00Z"},
"owner" =>{ "owner" =>{
"@type" => "user", "@type" => "user",
"@href" => "/v3/user/1", "@href" => "/v3/user/1",
"@representation"=> "minimal", "@representation"=> "minimal",
"id" => 1, "id" => 1,
"login" => "svenfuchs"}}, "login" => "svenfuchs"}},
{"@type" => "job", {"@type" => "job",
"@href" => "/v3/job/#{jobs[2].id}", "@href" => "/v3/job/#{jobs[2].id}",
"@representation" => "standard", "@representation" => "standard",
"@permissions" => { "@permissions" => {
"read" => true, "read" => true,
"cancel" => false, "cancel" => false,
"restart" => false }, "restart" => false,
"debug" => false },
"id" => jobs[2].id, "id" => jobs[2].id,
"number" => "#{jobs[2].number}", "number" => "#{jobs[2].number}",
"state" => "configured", "state" => "configured",
@ -124,45 +127,46 @@ describe Travis::API::V3::Services::Jobs::Find do
"build" => { "build" => {
"@type" => "build", "@type" => "build",
"@href" => "/v3/build/#{build.id}", "@href" => "/v3/build/#{build.id}",
"@representation"=> "minimal", "@representation"=> "minimal",
"id" => build.id, "id" => build.id,
"number" => build.number, "number" => build.number,
"state" => "configured", "state" => "configured",
"duration" => nil, "duration" => nil,
"event_type" => "push", "event_type" => "push",
"previous_state" => "passed", "previous_state" => "passed",
"started_at" => "2010-11-12T13:00:00Z", "started_at" => "2010-11-12T13:00:00Z",
"finished_at" => nil}, "finished_at" => nil},
"queue" => "builds.linux", "queue" => "builds.linux",
"repository" =>{ "repository" =>{
"@type" => "repository", "@type" => "repository",
"@href" => "/v3/repo/1", "@href" => "/v3/repo/1",
"@representation"=>"minimal", "@representation"=>"minimal",
"id" => repo.id, "id" => repo.id,
"name" => "minimal", "name" => "minimal",
"slug" => "svenfuchs/minimal"}, "slug" => "svenfuchs/minimal"},
"commit" =>{ "commit" =>{
"@type" => "commit", "@type" => "commit",
"@representation"=> "minimal", "@representation"=> "minimal",
"id" => commit.id, "id" => commit.id,
"sha" => commit.commit, "sha" => commit.commit,
"ref" => commit.ref, "ref" => commit.ref,
"message" => commit.message, "message" => commit.message,
"compare_url" => commit.compare_url, "compare_url" => commit.compare_url,
"committed_at" =>"2010-11-12T12:55:00Z"}, "committed_at" =>"2010-11-12T12:55:00Z"},
"owner" =>{ "owner" =>{
"@type" => "user", "@type" => "user",
"@href" => "/v3/user/1", "@href" => "/v3/user/1",
"@representation"=> "minimal", "@representation"=> "minimal",
"id" => 1, "id" => 1,
"login" => "svenfuchs"}}, "login" => "svenfuchs"}},
{"@type" => "job", {"@type" => "job",
"@href" => "/v3/job/#{jobs[3].id}", "@href" => "/v3/job/#{jobs[3].id}",
"@representation" => "standard", "@representation" => "standard",
"@permissions" => { "@permissions" => {
"read" => true, "read" => true,
"cancel" => false, "cancel" => false,
"restart" => false }, "restart" => false,
"debug" => false },
"id" => jobs[3].id, "id" => jobs[3].id,
"number" => "#{jobs[3].number}", "number" => "#{jobs[3].number}",
"state" => "configured", "state" => "configured",
@ -171,38 +175,38 @@ describe Travis::API::V3::Services::Jobs::Find do
"build" => { "build" => {
"@type" => "build", "@type" => "build",
"@href" => "/v3/build/#{build.id}", "@href" => "/v3/build/#{build.id}",
"@representation"=> "minimal", "@representation"=> "minimal",
"id" => build.id, "id" => build.id,
"number" => build.number, "number" => build.number,
"state" => "configured", "state" => "configured",
"duration" => nil, "duration" => nil,
"event_type" => "push", "event_type" => "push",
"previous_state" => "passed", "previous_state" => "passed",
"started_at" => "2010-11-12T13:00:00Z", "started_at" => "2010-11-12T13:00:00Z",
"finished_at" => nil}, "finished_at" => nil},
"queue" => "builds.linux", "queue" => "builds.linux",
"repository" =>{ "repository" =>{
"@type" => "repository", "@type" => "repository",
"@href" => "/v3/repo/1", "@href" => "/v3/repo/1",
"@representation"=>"minimal", "@representation"=>"minimal",
"id" => repo.id, "id" => repo.id,
"name" => "minimal", "name" => "minimal",
"slug" => "svenfuchs/minimal"}, "slug" => "svenfuchs/minimal"},
"commit" =>{ "commit" =>{
"@type" => "commit", "@type" => "commit",
"@representation"=> "minimal", "@representation"=> "minimal",
"id" => commit.id, "id" => commit.id,
"sha" => commit.commit, "sha" => commit.commit,
"ref" => commit.ref, "ref" => commit.ref,
"message" => commit.message, "message" => commit.message,
"compare_url" => commit.compare_url, "compare_url" => commit.compare_url,
"committed_at" =>"2010-11-12T12:55:00Z"}, "committed_at" =>"2010-11-12T12:55:00Z"},
"owner" =>{ "owner" =>{
"@type" => "user", "@type" => "user",
"@href" => "/v3/user/1", "@href" => "/v3/user/1",
"@representation"=> "minimal", "@representation"=> "minimal",
"id" => 1, "id" => 1,
"login" => "svenfuchs"}} "login" => "svenfuchs"}}
] ]
} }
} }
@ -227,7 +231,8 @@ describe Travis::API::V3::Services::Jobs::Find do
"@permissions" => { "@permissions" => {
"read" => true, "read" => true,
"cancel" => false, "cancel" => false,
"restart" => false }, "restart" => false,
"debug" => false },
"id" => jobs[0].id, "id" => jobs[0].id,
"number" => "#{jobs[0].number}", "number" => "#{jobs[0].number}",
"state" => "configured", "state" => "configured",
@ -236,45 +241,46 @@ describe Travis::API::V3::Services::Jobs::Find do
"build" => { "build" => {
"@type" => "build", "@type" => "build",
"@href" => "/v3/build/#{build.id}", "@href" => "/v3/build/#{build.id}",
"@representation"=> "minimal", "@representation"=> "minimal",
"id" => build.id, "id" => build.id,
"number" => build.number, "number" => build.number,
"state" => "configured", "state" => "configured",
"duration" => nil, "duration" => nil,
"event_type" => "push", "event_type" => "push",
"previous_state" => "passed", "previous_state" => "passed",
"started_at" => "2010-11-12T13:00:00Z", "started_at" => "2010-11-12T13:00:00Z",
"finished_at" => nil}, "finished_at" => nil},
"queue" => "builds.linux", "queue" => "builds.linux",
"repository" =>{ "repository" =>{
"@type" => "repository", "@type" => "repository",
"@href" => "/v3/repo/1", "@href" => "/v3/repo/1",
"@representation"=>"minimal", "@representation"=>"minimal",
"id" => repo.id, "id" => repo.id,
"name" => "minimal", "name" => "minimal",
"slug" => "svenfuchs/minimal"}, "slug" => "svenfuchs/minimal"},
"commit" =>{ "commit" =>{
"@type" => "commit", "@type" => "commit",
"@representation"=> "minimal", "@representation"=> "minimal",
"id" => commit.id, "id" => commit.id,
"sha" => commit.commit, "sha" => commit.commit,
"ref" => commit.ref, "ref" => commit.ref,
"message" => commit.message, "message" => commit.message,
"compare_url" => commit.compare_url, "compare_url" => commit.compare_url,
"committed_at" =>"2010-11-12T12:55:00Z"}, "committed_at" =>"2010-11-12T12:55:00Z"},
"owner" =>{ "owner" =>{
"@type" => "user", "@type" => "user",
"@href" => "/v3/user/1", "@href" => "/v3/user/1",
"@representation"=> "minimal", "@representation"=> "minimal",
"id" => 1, "id" => 1,
"login" => "svenfuchs"}}, "login" => "svenfuchs"}},
{"@type" => "job", {"@type" => "job",
"@href" => "/v3/job/#{jobs[1].id}", "@href" => "/v3/job/#{jobs[1].id}",
"@representation" => "standard", "@representation" => "standard",
"@permissions" => { "@permissions" => {
"read" => true, "read" => true,
"cancel" => false, "cancel" => false,
"restart" => false }, "restart" => false,
"debug" => false },
"id" => jobs[1].id, "id" => jobs[1].id,
"number" => "#{jobs[1].number}", "number" => "#{jobs[1].number}",
"state" => "configured", "state" => "configured",
@ -283,45 +289,46 @@ describe Travis::API::V3::Services::Jobs::Find do
"build" => { "build" => {
"@type" => "build", "@type" => "build",
"@href" => "/v3/build/#{build.id}", "@href" => "/v3/build/#{build.id}",
"@representation"=> "minimal", "@representation"=> "minimal",
"id" => build.id, "id" => build.id,
"number" => build.number, "number" => build.number,
"state" => "configured", "state" => "configured",
"duration" => nil, "duration" => nil,
"event_type" => "push", "event_type" => "push",
"previous_state" => "passed", "previous_state" => "passed",
"started_at" => "2010-11-12T13:00:00Z", "started_at" => "2010-11-12T13:00:00Z",
"finished_at" => nil}, "finished_at" => nil},
"queue" => "builds.linux", "queue" => "builds.linux",
"repository" =>{ "repository" =>{
"@type" => "repository", "@type" => "repository",
"@href" => "/v3/repo/1", "@href" => "/v3/repo/1",
"@representation"=>"minimal", "@representation"=>"minimal",
"id" => repo.id, "id" => repo.id,
"name" => "minimal", "name" => "minimal",
"slug" => "svenfuchs/minimal"}, "slug" => "svenfuchs/minimal"},
"commit" =>{ "commit" =>{
"@type" => "commit", "@type" => "commit",
"@representation"=> "minimal", "@representation"=> "minimal",
"id" => commit.id, "id" => commit.id,
"sha" => commit.commit, "sha" => commit.commit,
"ref" => commit.ref, "ref" => commit.ref,
"message" => commit.message, "message" => commit.message,
"compare_url" => commit.compare_url, "compare_url" => commit.compare_url,
"committed_at" =>"2010-11-12T12:55:00Z"}, "committed_at" =>"2010-11-12T12:55:00Z"},
"owner" =>{ "owner" =>{
"@type" => "user", "@type" => "user",
"@href" => "/v3/user/1", "@href" => "/v3/user/1",
"@representation"=> "minimal", "@representation"=> "minimal",
"id" => 1, "id" => 1,
"login" => "svenfuchs"}}, "login" => "svenfuchs"}},
{"@type" => "job", {"@type" => "job",
"@href" => "/v3/job/#{jobs[2].id}", "@href" => "/v3/job/#{jobs[2].id}",
"@representation" => "standard", "@representation" => "standard",
"@permissions" => { "@permissions" => {
"read" => true, "read" => true,
"cancel" => false, "cancel" => false,
"restart" => false }, "restart" => false,
"debug" => false },
"id" => jobs[2].id, "id" => jobs[2].id,
"number" => "#{jobs[2].number}", "number" => "#{jobs[2].number}",
"state" => "configured", "state" => "configured",
@ -330,45 +337,46 @@ describe Travis::API::V3::Services::Jobs::Find do
"build" => { "build" => {
"@type" => "build", "@type" => "build",
"@href" => "/v3/build/#{build.id}", "@href" => "/v3/build/#{build.id}",
"@representation"=> "minimal", "@representation"=> "minimal",
"id" => build.id, "id" => build.id,
"number" => build.number, "number" => build.number,
"state" => "configured", "state" => "configured",
"duration" => nil, "duration" => nil,
"event_type" => "push", "event_type" => "push",
"previous_state" => "passed", "previous_state" => "passed",
"started_at" => "2010-11-12T13:00:00Z", "started_at" => "2010-11-12T13:00:00Z",
"finished_at" => nil}, "finished_at" => nil},
"queue" => "builds.linux", "queue" => "builds.linux",
"repository" =>{ "repository" =>{
"@type" => "repository", "@type" => "repository",
"@href" => "/v3/repo/1", "@href" => "/v3/repo/1",
"@representation"=>"minimal", "@representation"=>"minimal",
"id" => repo.id, "id" => repo.id,
"name" => "minimal", "name" => "minimal",
"slug" => "svenfuchs/minimal"}, "slug" => "svenfuchs/minimal"},
"commit" =>{ "commit" =>{
"@type" => "commit", "@type" => "commit",
"@representation"=> "minimal", "@representation"=> "minimal",
"id" => commit.id, "id" => commit.id,
"sha" => commit.commit, "sha" => commit.commit,
"ref" => commit.ref, "ref" => commit.ref,
"message" => commit.message, "message" => commit.message,
"compare_url" => commit.compare_url, "compare_url" => commit.compare_url,
"committed_at" =>"2010-11-12T12:55:00Z"}, "committed_at" =>"2010-11-12T12:55:00Z"},
"owner" =>{ "owner" =>{
"@type" => "user", "@type" => "user",
"@href" => "/v3/user/1", "@href" => "/v3/user/1",
"@representation"=> "minimal", "@representation"=> "minimal",
"id" => 1, "id" => 1,
"login" => "svenfuchs"}}, "login" => "svenfuchs"}},
{"@type" => "job", {"@type" => "job",
"@href" => "/v3/job/#{jobs[3].id}", "@href" => "/v3/job/#{jobs[3].id}",
"@representation" => "standard", "@representation" => "standard",
"@permissions" => { "@permissions" => {
"read" => true, "read" => true,
"cancel" => false, "cancel" => false,
"restart" => false }, "restart" => false,
"debug" => false },
"id" => jobs[3].id, "id" => jobs[3].id,
"number" => "#{jobs[3].number}", "number" => "#{jobs[3].number}",
"state" => "configured", "state" => "configured",
@ -377,38 +385,38 @@ describe Travis::API::V3::Services::Jobs::Find do
"build" => { "build" => {
"@type" => "build", "@type" => "build",
"@href" => "/v3/build/#{build.id}", "@href" => "/v3/build/#{build.id}",
"@representation"=> "minimal", "@representation"=> "minimal",
"id" => build.id, "id" => build.id,
"number" => build.number, "number" => build.number,
"state" => "configured", "state" => "configured",
"duration" => nil, "duration" => nil,
"event_type" => "push", "event_type" => "push",
"previous_state" => "passed", "previous_state" => "passed",
"started_at" => "2010-11-12T13:00:00Z", "started_at" => "2010-11-12T13:00:00Z",
"finished_at" => nil}, "finished_at" => nil},
"queue" => "builds.linux", "queue" => "builds.linux",
"repository" =>{ "repository" =>{
"@type" => "repository", "@type" => "repository",
"@href" => "/v3/repo/1", "@href" => "/v3/repo/1",
"@representation"=>"minimal", "@representation"=>"minimal",
"id" => repo.id, "id" => repo.id,
"name" => "minimal", "name" => "minimal",
"slug" => "svenfuchs/minimal"}, "slug" => "svenfuchs/minimal"},
"commit" =>{ "commit" =>{
"@type" => "commit", "@type" => "commit",
"@representation"=> "minimal", "@representation"=> "minimal",
"id" => commit.id, "id" => commit.id,
"sha" => commit.commit, "sha" => commit.commit,
"ref" => commit.ref, "ref" => commit.ref,
"message" => commit.message, "message" => commit.message,
"compare_url" => commit.compare_url, "compare_url" => commit.compare_url,
"committed_at" =>"2010-11-12T12:55:00Z"}, "committed_at" =>"2010-11-12T12:55:00Z"},
"owner" =>{ "owner" =>{
"@type" => "user", "@type" => "user",
"@href" => "/v3/user/1", "@href" => "/v3/user/1",
"@representation"=> "minimal", "@representation"=> "minimal",
"id" => 1, "id" => 1,
"login" => "svenfuchs"}} "login" => "svenfuchs"}}
] ]
} }
} }

View File

@ -0,0 +1,34 @@
require 'spec_helper'
describe Travis::API::V3::Services::Lint::Lint do
let(:content) { "foo: bar" }
let(:parsed_body) { JSON.load(last_response.body) }
let(:headers) {{ 'CONTENT_TYPE' => 'text/yaml'}}
describe "accepts content in parameter" do
before { post("v3/lint", content: content ) }
example { expect(last_response).to be_ok }
example { expect(parsed_body).to be == {
"@type" => "lint",
"warnings" => [{
"key" => [],
"message" => "unexpected key \"foo\", dropping"}, {
"key" => [],
"message" => "missing key \"language\", defaulting to \"ruby\""}]}
}
end
describe "accepts content as body" do
before { post("/v3/lint", content, headers) }
example { expect(last_response).to be_ok }
example { expect(parsed_body).to be == {
"@type" => "lint",
"warnings" => [{
"key" => [],
"message" => "unexpected key \"foo\", dropping"}, {
"key" => [],
"message" => "missing key \"language\", defaulting to \"ruby\""}]}
}
end
end

View File

@ -11,6 +11,7 @@ describe Travis::API::V3::Services::Repositories::ForOwner do
before { repo.update_attribute(:private, true) } before { repo.update_attribute(:private, true) }
after { repo.update_attribute(:private, false) } after { repo.update_attribute(:private, false) }
describe "private repository, private API, authenticated as user with access" do describe "private repository, private API, authenticated as user with access" do
before { get("/v3/owner/svenfuchs/repos", {}, headers) } before { get("/v3/owner/svenfuchs/repos", {}, headers) }
example { expect(last_response).to be_ok } example { expect(last_response).to be_ok }
@ -103,4 +104,69 @@ describe Travis::API::V3::Services::Repositories::ForOwner do
example { expect(JSON.load(body)['@href']) .to be == "/v3/repos?starred=false" } example { expect(JSON.load(body)['@href']) .to be == "/v3/repos?starred=false" }
example { expect(JSON.load(body)['repositories']) .to be_empty } example { expect(JSON.load(body)['repositories']) .to be_empty }
end end
describe "sorting by default_branch.last_build" do
let(:repo2) { Travis::API::V3::Models::Repository.create(owner_name: 'svenfuchs', name: 'maximal', owner_id: 1, owner_type: "User", last_build_state: "passed", active: true, last_build_id: 1788, next_build_number: 3) }
before { repo2.save! }
before { get("/v3/owner/svenfuchs/repos?sort_by=default_branch.last_build", {}, headers) }
example { expect(last_response).to be_ok }
example { expect(JSON.load(body)['@href']) .to be == "/v3/owner/svenfuchs/repos?sort_by=default_branch.last_build" }
example { expect(JSON.load(body)['repositories']) .to be == [{
"@type" => "repository",
"@href" => "/v3/repo/1",
"@representation" => "standard",
"@permissions" => {
"read" => true,
"enable" => false,
"disable" => false,
"star" => false,
"unstar" => false,
"create_request"=> false },
"id" => 1,
"name" => "minimal",
"slug" => "svenfuchs/minimal",
"description" => nil,
"github_language" => nil,
"active" => true,
"private" => true,
"owner" => {
"@type" => "user",
"id" => 1,
"login" => "svenfuchs",
"@href" => "/v3/user/1" },
"default_branch" => {
"@type" => "branch",
"@href" => "/v3/repo/1/branch/master",
"@representation"=>"minimal",
"name" => "master" },
"starred" => false }, {
"@type" => "repository",
"@href" => "/v3/repo/#{repo2.id}",
"@representation" => "standard",
"@permissions" => {
"read" => true,
"enable" => false,
"disable" => false,
"star" => false,
"unstar" => false,
"create_request"=> false },
"id" => repo2.id,
"name" => "maximal",
"slug" => "svenfuchs/maximal",
"description" => nil,
"github_language" => nil,
"active" => true,
"private" => false,
"owner" => {
"@type" => "user",
"id" => 1,
"login" => "svenfuchs",
"@href" => "/v3/user/1" },
"default_branch" => {
"@type" => "branch",
"@href" => "/v3/repo/#{repo2.id}/branch/master",
"@representation"=>"minimal",
"name" =>"master" },
"starred"=>false}]}
end
end end