Merge branch '18995-code-cleanup-1'
[arvados.git] / apps / workbench / test / integration / work_units_test.rb
1 # Copyright (C) The Arvados Authors. All rights reserved.
2 #
3 # SPDX-License-Identifier: AGPL-3.0
4
5 require 'helpers/fake_websocket_helper'
6 require 'integration_helper'
7
8 class WorkUnitsTest < ActionDispatch::IntegrationTest
9   include FakeWebsocketHelper
10
11   setup do
12     need_javascript
13   end
14
15   [[true, 25, 100,
16     ['/pipeline_instances/zzzzz-d1hrv-1yfj61234abcdk3',
17      '/pipeline_instances/zzzzz-d1hrv-1yfj61234abcdk4',
18      '/jobs/zzzzz-8i9sb-grx15v5mjnsyxk7',
19      '/jobs/zzzzz-8i9sb-n7omg50bvt0m1nf',
20      '/container_requests/zzzzz-xvhdp-cr4completedcr2',
21      '/container_requests/zzzzz-xvhdp-cr4requestercn2'],
22     ['/pipeline_instances/zzzzz-d1hrv-scarxiyajtshq3l',
23      '/container_requests/zzzzz-xvhdp-oneof60crs00001']],
24    [false, 25, 100,
25     ['/pipeline_instances/zzzzz-d1hrv-1yfj61234abcdk3',
26      '/pipeline_instances/zzzzz-d1hrv-1yfj61234abcdk4',
27      '/container_requests/zzzzz-xvhdp-cr4completedcr2'],
28     ['/pipeline_instances/zzzzz-d1hrv-scarxiyajtshq3l',
29      '/container_requests/zzzzz-xvhdp-oneof60crs00001',
30      '/jobs/zzzzz-8i9sb-grx15v5mjnsyxk7',
31      '/jobs/zzzzz-8i9sb-n7omg50bvt0m1nf',
32      '/container_requests/zzzzz-xvhdp-cr4requestercn2'
33     ]]
34   ].each do |show_children, expected_min, expected_max, expected, not_expected|
35     test "scroll all_processes page with show_children=#{show_children}" do
36       visit page_with_token('active', "/all_processes")
37
38       if show_children
39         find('#IncludeChildProcs').click
40         wait_for_ajax
41       end
42
43       page_scrolls = expected_max/20 + 2
44       within('.arv-recent-all-processes') do
45         (0..page_scrolls).each do |i|
46           page.driver.scroll_to 0, 999000
47           begin
48             wait_for_ajax
49           rescue
50           end
51         end
52       end
53
54       # Verify that expected number of processes are found
55       found_items = page.all('tr[data-object-uuid]')
56       found_count = found_items.count
57       if expected_min == expected_max
58         assert_equal(true, found_count == expected_min,
59                      "Not found expected number of items. Expected #{expected_min} and found #{found_count}")
60         assert page.has_no_text? 'request failed'
61       else
62         assert_equal(true, found_count>=expected_min,
63                      "Found too few items. Expected at least #{expected_min} and found #{found_count}")
64         assert_equal(true, found_count<=expected_max,
65                      "Found too many items. Expected at most #{expected_max} and found #{found_count}")
66       end
67
68       # verify that all expected uuid links are found
69       expected.each do |link|
70         assert_selector "a[href=\"#{link}\"]"
71       end
72
73       # verify that none of the not_expected uuid links are found
74       not_expected.each do |link|
75         assert_no_selector "a[href=\"#{link}\"]"
76       end
77     end
78   end
79
80   [
81     ['containers', 'running', false],
82     ['container_requests', 'running', true],
83   ].each do |type, fixture, cancelable, confirm_cancellation|
84     test "cancel button for #{type}/#{fixture}" do
85       if cancelable
86         need_selenium 'to cancel'
87       end
88
89       obj = api_fixture(type)[fixture]
90       visit page_with_token "active", "/#{type}/#{obj['uuid']}"
91
92       assert_text 'created_at'
93       if cancelable
94         assert_text 'priority: 501' if type.include?('container')
95         if type.include?('pipeline')
96           assert_selector 'a', text: 'Pause'
97           first('a,link', text: 'Pause').click
98         else
99           assert_selector 'button', text: 'Cancel'
100           first('a,button', text: 'Cancel').click
101         end
102         if confirm_cancellation
103           alert = page.driver.browser.switch_to.alert
104           alert.accept
105         end
106         wait_for_ajax
107       end
108
109       if type.include?('pipeline')
110         assert_selector 'a', text: 'Resume'
111         assert_no_selector 'a', text: 'Pause'
112       elsif type.include?('job')
113         assert_text 'Cancelled'
114         assert_text 'Paused'  # this job has a pipeline child which was also cancelled
115         assert_no_selector 'button', text: 'Cancel'
116       elsif cancelable
117         assert_text 'priority: 0'
118       end
119     end
120   end
121
122   [
123     ['container_requests', 'running'],
124     ['container_requests', 'completed'],
125   ].each do |type, fixture|
126     test "edit description for #{type}/#{fixture}" do
127       obj = api_fixture(type)[fixture]
128       visit page_with_token "active", "/#{type}/#{obj['uuid']}"
129
130       within('.arv-description-as-subtitle') do
131         find('.fa-pencil').click
132         find('.editable-input textarea').set('*Textile description for object*')
133         find('.editable-submit').click
134       end
135       wait_for_ajax
136
137       # verify description
138       assert page.has_no_text? '*Textile description for object*'
139       assert page.has_text? 'Textile description for object'
140     end
141   end
142
143   [
144     ['Workflow with default input specifications', 'this workflow has inputs specified', 'Provide a value for the following'],
145   ].each do |template_name, preview_txt, process_txt|
146     test "run a process using template #{template_name} from dashboard" do
147       visit page_with_token('admin')
148       assert_text 'Recent processes' # seeing dashboard now
149
150       within('.recent-processes-actions') do
151         assert page.has_link?('All processes')
152         find('a', text: 'Run a process').click
153       end
154
155       # in the chooser, verify preview and click Next button
156       within('.modal-dialog') do
157         find('.selectable', text: template_name).click
158         assert_text preview_txt
159         find('.btn', text: 'Next: choose inputs').click
160       end
161
162       # in the process page now
163       assert_text process_txt
164       assert_selector 'a', text: template_name
165
166       assert_equal "true", find('span[data-name="reuse_steps"]').text
167
168       assert_equal "Set value for ex_string_def", find('div.form-group > div.form-control-static > a', text: "hello-testing-123")[:"data-title"]
169
170       page.assert_selector 'a.disabled,button.disabled', text: 'Run'
171     end
172   end
173
174   test 'display container state changes in Container Request live log' do
175     use_fake_websocket_driver
176     c = api_fixture('containers')['queued']
177     cr = api_fixture('container_requests')['queued']
178     visit page_with_token('active', '/container_requests/'+cr['uuid'])
179     click_link('Log')
180
181     # The attrs of the "terminal window" text div in the log tab
182     # indicates which objects' events are worth displaying. Events
183     # that arrive too early (before that div exists) are not
184     # shown. For the user's sake, these early logs should also be
185     # retrieved and shown one way or another -- but in this particular
186     # test, we are only interested in logs that arrive by
187     # websocket. Therefore, to avoid races, we wait for the log tab to
188     # display before sending any events.
189     assert_text 'Recent logs'
190
191     [[{
192         event_type: 'dispatch',
193         properties: {
194           text: "dispatch logged a fake message\n",
195         },
196       }, "dispatch logged"],
197      [{
198         event_type: 'update',
199         properties: {
200           old_attributes: {state: 'Locked'},
201           new_attributes: {state: 'Queued'},
202         },
203       }, "Container #{c['uuid']} was returned to the queue"],
204      [{
205         event_type: 'update',
206         properties: {
207           old_attributes: {state: 'Queued'},
208           new_attributes: {state: 'Locked'},
209         },
210       }, "Container #{c['uuid']} was taken from the queue by a dispatch process"],
211      [{
212         event_type: 'crunch-run',
213         properties: {
214           text: "according to fake crunch-run,\nsome setup stuff happened on the compute node\n",
215         },
216       }, "setup stuff happened"],
217      [{
218         event_type: 'update',
219         properties: {
220           old_attributes: {state: 'Locked'},
221           new_attributes: {state: 'Running'},
222         },
223       }, "Container #{c['uuid']} started"],
224      [{
225         event_type: 'update',
226         properties: {
227           old_attributes: {state: 'Running'},
228           new_attributes: {state: 'Complete', exit_code: 1},
229         },
230       }, "Container #{c['uuid']} finished"],
231      # It's unrealistic for state to change again once it's Complete,
232      # but the logging code doesn't care, so we do it to keep the test
233      # simple.
234      [{
235         event_type: 'update',
236         properties: {
237           old_attributes: {state: 'Running'},
238           new_attributes: {state: 'Cancelled'},
239         },
240       }, "Container #{c['uuid']} was cancelled"],
241     ].each do |send_event, expect_log_text|
242       assert_no_text(expect_log_text)
243       fake_websocket_event(send_event.merge(object_uuid: c['uuid']))
244       assert_text(expect_log_text)
245     end
246   end
247
248   test 'Run from workflows index page' do
249     visit page_with_token('active', '/workflows')
250
251     wf_count = page.all('a[data-original-title="show workflow"]').count
252     assert_equal true, wf_count>0
253
254     # Run one of the workflows
255     wf_name = 'Workflow with input specifications'
256     within('tr', text: wf_name) do
257       find('a,button', text: 'Run').click
258     end
259
260     # Choose project for the container_request being created
261     within('.modal-dialog') do
262       find('.selectable', text: 'A Project').click
263       find('button', text: 'Choose').click
264     end
265
266     # In newly created container_request page now
267     assert_text 'A Project' # CR created in "A Project"
268     assert_text "This container request was created from the workflow #{wf_name}"
269     assert_match /Provide a value for .* then click the \"Run\" button to start the workflow/, page.text
270   end
271
272   test 'Run workflow from show page' do
273     visit page_with_token('active', '/workflows/zzzzz-7fd4e-validwithinputs')
274
275     find('a,button', text: 'Run this workflow').click
276
277     # Choose project for the container_request being created
278     within('.modal-dialog') do
279       find('.selectable', text: 'A Project').click
280       find('button', text: 'Choose').click
281     end
282
283     # In newly created container_request page now
284     assert_text 'A Project' # CR created in "A Project"
285     assert_text "This container request was created from the workflow"
286     assert_match /Provide a value for .* then click the \"Run\" button to start the workflow/, page.text
287   end
288
289   test "create workflow with WorkflowRunnerResources" do
290     visit page_with_token('active', '/workflows/zzzzz-7fd4e-validwithinput3')
291
292     find('a,button', text: 'Run this workflow').click
293
294     # Choose project for the container_request being created
295     within('.modal-dialog') do
296       find('.selectable', text: 'A Project').click
297       find('button', text: 'Choose').click
298     end
299     click_link 'Advanced'
300     click_link("API response")
301     assert_text('"container_image": "arvados/jobs:2.0.4"')
302     assert_text('"vcpus": 2')
303     assert_text('"ram": 1293942784')
304     assert_text('"--collection-cache-size=678"')
305
306   end
307 end