lib/tasks/organisations.rake


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31

namespace :organisations do
  def api_retrieve_organisation
    conf = Rails.application.config.try(:stif_portail_api)
    raise 'Rails.application.config.stif_portail_api settings is not defined' unless conf

    conn = Faraday.new(:url => conf[:url]) do |c|
      c.headers['Authorization'] = "Token token=\"#{conf[:key]}\""
      c.adapter  Faraday.default_adapter
    end

    resp = conn.get '/api/v1/organizations'
    JSON.parse resp.body if resp.status == 200
  end

  def sync_organisations data
    data.each do |el|
      Organisation.find_or_create_by(code: el['code']).tap do |org|
        org.name      = el['name']
        org.synced_at = Time.now
        org.save if org.changed?
        puts "✓ Organisation #{org.name} has been updated" unless Rails.env.test?
      end
    end
  end

  desc "Sync organisations from stif portail"
  task sync: :environment  do
    data = api_retrieve_organisation
    sync_organisations(data) if data
  end
end