9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
|
# File 'app/controllers/source_monitor/item_scrapes_controller.rb', line 9
def create
log_manual_scrape("controller:start", extra: { format: request.format })
enqueue_result = SourceMonitor::Scraping::Enqueuer.enqueue(item: @item, reason: :manual)
log_manual_scrape("controller:enqueue_result", extra: { status: enqueue_result.status, message: enqueue_result.message })
flash_key, flash_message = scrape_flash_payload(enqueue_result)
status = enqueue_result.failure? ? :unprocessable_entity : :ok
respond_to do |format|
format.turbo_stream do
responder = SourceMonitor::TurboStreams::StreamResponder.new
if enqueue_result.enqueued? || enqueue_result.already_enqueued?
@item.reload
responder.replace_details(
@item,
partial: "source_monitor/items/details_wrapper",
locals: { item: @item }
)
end
if flash_message
level = flash_key == :notice ? :info : :error
responder.toast(message: flash_message, level:, delay_ms: toast_delay_for(level))
end
render turbo_stream: responder.render(view_context), status: status
end
format.html do
if flash_key && flash_message
redirect_to source_monitor.item_path(@item), flash: { flash_key => flash_message }
else
redirect_to source_monitor.item_path(@item)
end
end
end
end
|