class APIEntrepriseService # create etablissement with EtablissementAdapter # enqueue api_entreprise jobs to retrieve # all informations we can get about a SIRET. # # Returns nil if the SIRET is unknown # # Raises a APIEntreprise::API::Error::RequestFailed exception on transient errors # (timeout, 5XX HTTP error code, etc.) def self.create_etablissement(dossier_or_champ, siret, user_id = nil) etablissement_params = APIEntreprise::EtablissementAdapter.new(siret, dossier_or_champ.procedure.id).to_params return nil if etablissement_params.empty? etablissement = dossier_or_champ.build_etablissement(etablissement_params) etablissement.save! [ APIEntreprise::EntrepriseJob, APIEntreprise::AssociationJob, APIEntreprise::ExercicesJob, APIEntreprise::EffectifsJob, APIEntreprise::EffectifsAnnuelsJob, APIEntreprise::AttestationSocialeJob, APIEntreprise::BilansBdfJob ].each do |job| job.perform_later(etablissement.id, dossier_or_champ.procedure.id) end APIEntreprise::AttestationFiscaleJob.perform_later(etablissement.id, dossier_or_champ.procedure.id, user_id) etablissement end def self.api_up?(uname = "apie_2_etablissements") statuses = APIEntreprise::API.new.current_status.fetch(:results) # find results having uname = apie_2_etablissements status = statuses.find { |result| result[:uname] == uname } status.fetch(:code) == 200 rescue => e Sentry.capture_exception(e, extra: { uname: uname }) nil end end