Class: Tasks::FieldOccurrences::InaturalistImportController

Inherits:
ApplicationController
  • Object
show all
Includes:
TaskControllerConfiguration
Defined in:
app/controllers/tasks/field_occurrences/inaturalist_import_controller.rb

Constant Summary collapse

IMPORT_LIMIT = 
50
FIND_LIMIT = 
200

Instance Method Summary collapse

Methods included from TaskControllerConfiguration

#set_is_task_controller

Instance Method Details

#check_for_existing ⇒ Object

GET /tasks/field_occurrences/inaturalist_import/check_for_existing.json



56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
 
# File 'app/controllers/tasks/field_occurrences/inaturalist_import_controller.rb', line 56

def check_for_existing
  uuids = params[:uuids] || []
  existing_fo_by_uuid = existing_field_occurrences_for_uuids(uuids)
  fo_data = fetch_field_occurrence_data(existing_fo_by_uuid)

  found = existing_fo_by_uuid.map { |uuid, fo_id|
    fo = fo_data[fo_id]
    {
      uuid:,
      field_occurrence_id: fo_id,
      browse_url: helpers.browse_field_occurrence_task_path(field_occurrence_id: fo_id),
      taxon_name: fo[:taxon_name],
      image_count: fo[:image_count],
      sound_count: fo[:sound_count]
    }
  }

  render json: { found: }
end

#existing_field_occurrences_for(results) ⇒ Object (private) 



102
103
104
 
# File 'app/controllers/tasks/field_occurrences/inaturalist_import_controller.rb', line 102

def existing_field_occurrences_for(results)
  existing_field_occurrences_for_uuids(results.filter_map { |r| r['uuid'] })
end

#existing_field_occurrences_for_uuids(uuids) ⇒ Object (private) 



106
107
108
 
# File 'app/controllers/tasks/field_occurrences/inaturalist_import_controller.rb', line 106

def existing_field_occurrences_for_uuids(uuids)
  FieldOccurrence.by_inat_uuids(uuids, project_id: sessions_current_project_id)
end

#fetch_field_occurrence_data(existing_fo_by_uuid) ⇒ Object (private) 



135
136
137
138
139
140
141
142
143
144
145
146
147
148
 
# File 'app/controllers/tasks/field_occurrences/inaturalist_import_controller.rb', line 135

def fetch_field_occurrence_data(existing_fo_by_uuid)
  return {} if existing_fo_by_uuid.empty?

  FieldOccurrence
    .where(id: existing_fo_by_uuid.values)
    .includes(:depictions, :conveyances, taxon_determinations: { otu: :taxon_name })
    .each_with_object({}) do |fo, h|
      h[fo.id] = {
        image_count: fo.depictions.size,
        sound_count: fo.conveyances.size,
        taxon_name: helpers.otu_tag(fo.taxon_determinations.first.otu)
      }
    end
end

#fetch_inat_results(observation_ids) ⇒ Object (private) 



95
96
97
98
99
100
 
# File 'app/controllers/tasks/field_occurrences/inaturalist_import_controller.rb', line 95

def fetch_inat_results(observation_ids)
  ::Vendor::Nasturtium.by_observation_ids(observation_ids)
rescue Timeout::Error
  render json: { error: 'The iNaturalist API did not respond in time. Please try again.' }, status: :service_unavailable
  nil
end

#find ⇒ Object

GET /tasks/field_occurrences/inaturalist_import/find.json



13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
 
# File 'app/controllers/tasks/field_occurrences/inaturalist_import_controller.rb', line 13

def find
  observation_ids = params[:observation_ids] || []
  if observation_ids.size > FIND_LIMIT
    render json: { error: "Maximum #{FIND_LIMIT} observations per submission." }, status: :unprocessable_entity
    return
  end

  results = fetch_inat_results(observation_ids)
  return unless results

  existing_fo_by_uuid = existing_field_occurrences_for(results)
  fo_data = fetch_field_occurrence_data(existing_fo_by_uuid)
  use_community_taxon = params[:use_community_taxon] != false

  summary = helpers.inaturalist_find_summary(results, existing_fo_by_uuid, fo_data:, use_community_taxon:) +
            not_found_rows(observation_ids, results)

  render json: { summary: }
end

#import ⇒ Object

POST /tasks/field_occurrences/inaturalist_import/import.json



34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
 
# File 'app/controllers/tasks/field_occurrences/inaturalist_import_controller.rb', line 34

def import
  observation_ids = params[:observation_ids] || []
  if observation_ids.size > IMPORT_LIMIT
    render json: { error: "Maximum #{IMPORT_LIMIT} observations per submission." }, status: :unprocessable_entity
    return
  end

  results = fetch_inat_results(observation_ids)
  return unless results

  existing_fo_by_uuid = existing_field_occurrences_for(results)
  opts = import_options

  queue_import(results, existing_fo_by_uuid, opts)

  summary = helpers.inaturalist_import_summary(results, existing_fo_by_uuid, **opts) +
            not_found_rows(observation_ids, results)

  render json: { summary: }
end

#import_options ⇒ Object (private) 



115
116
117
118
119
120
121
 
# File 'app/controllers/tasks/field_occurrences/inaturalist_import_controller.rb', line 115

def import_options
  {
    use_community_taxon: params[:use_community_taxon] != false,
    import_images: params[:import_images] == true,
    import_sounds: params[:import_sounds] == true,
  }
end

#index ⇒ Object 



9
10
 
# File 'app/controllers/tasks/field_occurrences/inaturalist_import_controller.rb', line 9

def index
end

#not_found_rows(observation_ids, results) ⇒ Object (private) 



110
111
112
113
 
# File 'app/controllers/tasks/field_occurrences/inaturalist_import_controller.rb', line 110

def not_found_rows(observation_ids, results)
  (observation_ids.to_set - results.map { |r| r['id'].to_s }.to_set)
    .map { |id| { observation_id: id, status: 'not_found' } }
end

#queue_import(results, existing_fo_by_uuid, opts) ⇒ Object (private) 



123
124
125
126
127
128
129
130
131
132
133
 
# File 'app/controllers/tasks/field_occurrences/inaturalist_import_controller.rb', line 123

def queue_import(results, existing_fo_by_uuid, opts)
  new_results = results.reject { |r| existing_fo_by_uuid.key?(r['uuid']) }

  InaturalistImportJob.perform_later(
    results: new_results,
    project_id: sessions_current_project_id,
    user_id: sessions_current_user_id,
    match_otu_by_name: params[:match_otu_by_name] == true,
    **opts
  ) if new_results.any?
end

#recent ⇒ Object

GET /tasks/field_occurrences/inaturalist_import/recent.json



77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
 
# File 'app/controllers/tasks/field_occurrences/inaturalist_import_controller.rb', line 77

def recent
  fos = FieldOccurrence
    .joins(:identifiers)
    .where(
      project_id: sessions_current_project_id,
      identifiers: { type: 'Identifier::Global::Uuid::InaturalistObservation' }
    )
    .order(created_at: :desc)
    .page(params[:page])
    .per(params.fetch(:per_page, 10).to_i.clamp(1, 100))
    .includes(:collecting_event, :identifiers, :depictions, :conveyances, taxon_determinations: { otu: :taxon_name })

  assign_pagination(fos)
  render json: { field_occurrences: fos.map { |fo| helpers.serialize_inat_field_occurrence(fo) } }
end