create ApiEntreprise::EffectifsAdapter

app/lib/api_entreprise/api.rb

@@ -3,6 +3,7 @@ class ApiEntreprise::API
   ETABLISSEMENT_RESOURCE_NAME = "etablissements"
   EXERCICES_RESOURCE_NAME = "exercices"
   RNA_RESOURCE_NAME = "associations"
+  EFFECTIFS_RESOURCE_NAME = "effectifs_mensuels_acoss_covid"
 
   TIMEOUT = 15
 
@@ -28,6 +29,11 @@ class ApiEntreprise::API
     call(RNA_RESOURCE_NAME, siret, procedure_id)
   end
 
+  def self.effectifs(siren, procedure_id, annee, mois)
+    endpoint = [EFFECTIFS_RESOURCE_NAME, annee, mois, "entreprise"].join('/')
+    call(endpoint, siren, procedure_id)
+  end
+
   private
 
   def self.call(resource_name, siret_or_siren, procedure_id)

app/lib/api_entreprise/effectifs_adapter.rb

@@ -0,0 +1,26 @@
+class ApiEntreprise::EffectifsAdapter < ApiEntreprise::Adapter
+  def initialize(siren, procedure_id, annee, mois)
+    @siren = siren
+    @procedure_id = procedure_id
+    @annee = annee
+    @mois = mois
+  end
+
+  private
+
+  def get_resource
+    ApiEntreprise::API.effectifs(@siren, @procedure_id, @annee, @mois)
+  end
+
+  def process_params
+    if data_source[:effectifs_mensuels].present?
+      {
+        effectif_mensuel: data_source[:effectifs_mensuels],
+        effectif_mois: @mois,
+        effectif_annee: @annee
+      }
+    else
+      {}
+    end
+  end
+end