16470: Fixes tests. Avoids closing a DB connection when using threads on tests.
[arvados.git] / services / api / test / functional / arvados / v1 / jobs_controller_test.rb
1 # Copyright (C) The Arvados Authors. All rights reserved.
2 #
3 # SPDX-License-Identifier: AGPL-3.0
4
5 require 'test_helper'
6 require 'helpers/git_test_helper'
7
8 class Arvados::V1::JobsControllerTest < ActionController::TestCase
9
10   test "search jobs by uuid with >= query" do
11     authorize_with :active
12     get :index, params: {
13       filters: [['uuid', '>=', 'zzzzz-8i9sb-pshmckwoma9plh7']]
14     }
15     assert_response :success
16     found = assigns(:objects).collect(&:uuid)
17     assert_equal true, !!found.index('zzzzz-8i9sb-pshmckwoma9plh7')
18     assert_equal false, !!found.index('zzzzz-8i9sb-4cf0nhn6xte809j')
19   end
20
21   test "search jobs by uuid with <= query" do
22     authorize_with :active
23     get :index, params: {
24       filters: [['uuid', '<=', 'zzzzz-8i9sb-pshmckwoma9plh7']]
25     }
26     assert_response :success
27     found = assigns(:objects).collect(&:uuid)
28     assert_equal true, !!found.index('zzzzz-8i9sb-pshmckwoma9plh7')
29     assert_equal true, !!found.index('zzzzz-8i9sb-4cf0nhn6xte809j')
30   end
31
32   test "search jobs by uuid with >= and <= query" do
33     authorize_with :active
34     get :index, params: {
35       filters: [['uuid', '>=', 'zzzzz-8i9sb-pshmckwoma9plh7'],
36               ['uuid', '<=', 'zzzzz-8i9sb-pshmckwoma9plh7']]
37     }
38     assert_response :success
39     found = assigns(:objects).collect(&:uuid)
40     assert_equal found, ['zzzzz-8i9sb-pshmckwoma9plh7']
41   end
42
43   test "search jobs by uuid with < query" do
44     authorize_with :active
45     get :index, params: {
46       filters: [['uuid', '<', 'zzzzz-8i9sb-pshmckwoma9plh7']]
47     }
48     assert_response :success
49     found = assigns(:objects).collect(&:uuid)
50     assert_equal false, !!found.index('zzzzz-8i9sb-pshmckwoma9plh7')
51     assert_equal true, !!found.index('zzzzz-8i9sb-4cf0nhn6xte809j')
52   end
53
54   test "search jobs by uuid with like query" do
55     authorize_with :active
56     get :index, params: {
57       filters: [['uuid', 'like', '%hmckwoma9pl%']]
58     }
59     assert_response :success
60     found = assigns(:objects).collect(&:uuid)
61     assert_equal found, ['zzzzz-8i9sb-pshmckwoma9plh7']
62   end
63
64   test "search jobs by uuid with 'in' query" do
65     authorize_with :active
66     get :index, params: {
67       filters: [['uuid', 'in', ['zzzzz-8i9sb-4cf0nhn6xte809j',
68                                 'zzzzz-8i9sb-pshmckwoma9plh7']]]
69     }
70     assert_response :success
71     found = assigns(:objects).collect(&:uuid)
72     assert_equal found.sort, ['zzzzz-8i9sb-4cf0nhn6xte809j',
73                               'zzzzz-8i9sb-pshmckwoma9plh7']
74   end
75
76   test "search jobs by uuid with 'not in' query" do
77     exclude_uuids = [jobs(:running).uuid,
78                      jobs(:running_cancelled).uuid]
79     authorize_with :active
80     get :index, params: {
81       filters: [['uuid', 'not in', exclude_uuids]]
82     }
83     assert_response :success
84     found = assigns(:objects).collect(&:uuid)
85     assert_not_empty found, "'not in' query returned nothing"
86     assert_empty(found & exclude_uuids,
87                  "'not in' query returned uuids I asked not to get")
88   end
89
90   ['=', '!='].each do |operator|
91     [['uuid', 'zzzzz-8i9sb-pshmckwoma9plh7'],
92      ['output', nil]].each do |attr, operand|
93       test "search jobs with #{attr} #{operator} #{operand.inspect} query" do
94         authorize_with :active
95         get :index, params: {
96           filters: [[attr, operator, operand]]
97         }
98         assert_response :success
99         values = assigns(:objects).collect { |x| x.send(attr) }
100         assert_not_empty values, "query should return non-empty result"
101         if operator == '='
102           assert_empty values - [operand], "query results do not satisfy query"
103         else
104           assert_empty values & [operand], "query results do not satisfy query"
105         end
106       end
107     end
108   end
109
110   test "search jobs by started_at with < query" do
111     authorize_with :active
112     get :index, params: {
113       filters: [['started_at', '<', Time.now.to_s]]
114     }
115     assert_response :success
116     found = assigns(:objects).collect(&:uuid)
117     assert_equal true, !!found.index('zzzzz-8i9sb-pshmckwoma9plh7')
118   end
119
120   test "search jobs by started_at with > query" do
121     authorize_with :active
122     get :index, params: {
123       filters: [['started_at', '>', Time.now.to_s]]
124     }
125     assert_response :success
126     assert_equal 0, assigns(:objects).count
127   end
128
129   test "search jobs by started_at with >= query on metric date" do
130     authorize_with :active
131     get :index, params: {
132       filters: [['started_at', '>=', '2014-01-01']]
133     }
134     assert_response :success
135     found = assigns(:objects).collect(&:uuid)
136     assert_equal true, !!found.index('zzzzz-8i9sb-pshmckwoma9plh7')
137   end
138
139   test "search jobs by started_at with >= query on metric date and time" do
140     authorize_with :active
141     get :index, params: {
142       filters: [['started_at', '>=', '2014-01-01 01:23:45']]
143     }
144     assert_response :success
145     found = assigns(:objects).collect(&:uuid)
146     assert_equal true, !!found.index('zzzzz-8i9sb-pshmckwoma9plh7')
147   end
148
149   test "search jobs with 'any' operator" do
150     authorize_with :active
151     get :index, params: {
152       where: { any: ['contains', 'pshmckw'] }
153     }
154     assert_response :success
155     found = assigns(:objects).collect(&:uuid)
156     assert_equal 0, found.index('zzzzz-8i9sb-pshmckwoma9plh7')
157     assert_equal 1, found.count
158   end
159
160   test "search jobs by nonexistent column with < query" do
161     authorize_with :active
162     get :index, params: {
163       filters: [['is_borked', '<', 'fizzbuzz']]
164     }
165     assert_response 422
166   end
167
168   [:spectator, :admin].each_with_index do |which_token, i|
169     test "get job queue as #{which_token} user" do
170       authorize_with which_token
171       get :queue
172       assert_response :success
173       assert_equal 0, assigns(:objects).count
174     end
175   end
176
177   test "job includes assigned nodes" do
178     authorize_with :active
179     get :show, params: {id: jobs(:nearly_finished_job).uuid}
180     assert_response :success
181     assert_equal([nodes(:busy).uuid], json_response["node_uuids"])
182   end
183
184   test 'get job with components' do
185     authorize_with :active
186     get :show, params: {id: jobs(:running_job_with_components).uuid}
187     assert_response :success
188     assert_not_nil json_response["components"]
189     assert_equal ["component1", "component2"], json_response["components"].keys
190   end
191 end