feat(france-travail): add rendez-vous-partenaire api webhooks for participation v2

.env.example

@@ -51,3 +51,9 @@ CARNET_DE_BORD_URL=https://demo.carnetdebord.inclusion.beta.gouv.fr
 CARNET_DE_BORD_API_SECRET=secret_api_token
 
 DEPARTMENTS_WHERE_PARCOURS_DISABLED=44
+
+# France Travail Recette
+FRANCE_TRAVAIL_AUTH_URL=https://entreprise-r.ft-qvr.fr
+FRANCE_TRAVAIL_API_URL=https://api-r.ft-qvr.io
+FRANCE_TRAVAIL_CLIENT_ID=client_id
+FRANCE_TRAVAIL_CLIENT_SECRET=client_secret

.env.test

@@ -15,6 +15,8 @@ AGENT_CONNECT_CLIENT_SECRET=client_secret
 
 # France Travail
 FRANCE_TRAVAIL_AUTH_URL=https://somefakeauthurl.fr
-FRANCE_TRAVAIL_RDV_API_URL=https://francetravailfakerdvurl.fr
+FRANCE_TRAVAIL_API_URL=https://francetravailfakerdvurl.fr
+FRANCE_TRAVAIL_CLIENT_ID=client_id
+FRANCE_TRAVAIL_CLIENT_SECRET=client_secret
 
 AGENT_SIGNATURE_KEY=bc995863-5c80-43a3-a31d-0da216e814a4

app/clients/france_travail_client.rb

@@ -0,0 +1,33 @@
+class FranceTravailClient
+  def self.create_participation(payload:, headers:)
+    Faraday.post(
+      "#{ENV['FRANCE_TRAVAIL_API_URL']}/partenaire/rendez-vous-partenaire/v1/rendez-vous",
+      payload.to_json,
+      headers
+    )
+  end
+
+  def self.update_participation(payload:, headers:)
+    Faraday.put(
+      "#{ENV['FRANCE_TRAVAIL_API_URL']}/partenaire/rendez-vous-partenaire/v1/rendez-vous",
+      payload.to_json,
+      headers
+    )
+  end
+
+  def self.delete_participation(france_travail_id:, headers:)
+    Faraday.delete(
+      "#{ENV['FRANCE_TRAVAIL_API_URL']}/partenaire/rendez-vous-partenaire/v1/rendez-vous/#{france_travail_id}",
+      {},
+      headers
+    )
+  end
+
+  def self.retrieve_user_token(payload:, headers:)
+    Faraday.post(
+      "#{ENV['FRANCE_TRAVAIL_API_URL']}/partenaire/rechercher-usager/v1/usagers/recherche",
+      payload.to_json,
+      headers
+    )
+  end
+end

app/clients/france_travail_headers.rb

@@ -0,0 +1,13 @@
+class FranceTravailHeaders
+  def self.for_user(user)
+    FranceTravailApi::BuildUserAuthenticatedHeaders.call(user: user).headers
+  end
+
+  def self.for_client
+    access_token = FranceTravailApi::RetrieveAccessToken.call.access_token
+    {
+      "Authorization" => "Bearer #{access_token}",
+      "Content-Type" => "application/json"
+    }
+  end
+end

app/jobs/outgoing_webhooks/france_travail/locked_and_ordered_job_base.rb

@@ -0,0 +1,11 @@
+module OutgoingWebhooks
+  module FranceTravail
+    class LockedAndOrderedJobBase < ApplicationJob
+      include LockedAndOrderedJobs
+
+      def self.job_timestamp(timestamp:, **)
+        timestamp
+      end
+    end
+  end
+end

app/jobs/outgoing_webhooks/france_travail/process_participation_job.rb

@@ -0,0 +1,14 @@
+module OutgoingWebhooks
+  module FranceTravail
+    class ProcessParticipationJob < LockedAndOrderedJobBase
+      def self.lock_key(participation_id:, **)
+        "#{base_lock_key}:#{participation_id}"
+      end
+
+      def perform(participation_id:, timestamp:, event:)
+        call_service!(FranceTravailApi::ProcessParticipation, participation_id: participation_id, timestamp: timestamp,
+                                                              event: event)
+      end
+    end
+  end
+end

app/models/concerns/participation/france_travail_payload.rb

@@ -0,0 +1,90 @@
+module Participation::FranceTravailPayload
+  extend ActiveSupport::Concern
+
+  # rubocop:disable Metrics/AbcSize
+  def to_ft_payload
+    {
+      id: france_travail_id,
+      adresse: lieu&.address,
+      date: starts_at.to_datetime,
+      duree: duration_in_min,
+      information: motif.instruction_for_rdv,
+      initiateur: france_travail_initiateur,
+      libelleAdresse: organisation.name,
+      modaliteContact: france_travail_modalite,
+      motif: france_travail_motif,
+      organisme: {
+        code: france_travail_organisme_code,
+        emailContact: organisation.email,
+        idStructure: organisation.safir_code,
+        libelleStructure: organisation.name,
+        telephoneContact: organisation.phone_number
+      },
+      statut: france_travail_statut,
+      telephoneContactUsager: user.phone_number,
+      theme: motif.name,
+      typeReception: france_travail_type_reception,
+      interlocuteur: {
+        email: agents.first.email,
+        nom: agents.first.last_name,
+        prenom: agents.first.first_name
+      }
+    }
+  end
+  # rubocop:enable Metrics/AbcSize
+
+  # Liste des modalités FT (on ne prend en compte que le physique et le telephone): PHYSIQUE, TELEPHONE, VISIO
+  def france_travail_modalite
+    by_phone? ? "TELEPHONE" : "PHYSIQUE"
+  end
+
+  # Liste des initiateurs FT : USAGER, PARTENAIRE
+  def france_travail_initiateur
+    created_by_user? ? "USAGER" : "PARTENAIRE"
+  end
+
+  # Liste des motifs FT : AUT, ACC, ORI
+  def france_travail_motif
+    case motif.motif_category&.motif_category_type
+    when "rsa_orientation"
+      "ORI"
+    when "rsa_accompagnement"
+      "ACC"
+    else
+      "AUT"
+    end
+  end
+
+  # Liste des codes organismes FT : IND, FT, CD, DCD, ML, CE
+  def france_travail_organisme_code
+    case organisation.organisation_type
+    when "conseil_departemental"
+      "CD"
+    when "france_travail"
+      "FT"
+    when "delegataire_rsa"
+      "DCD"
+    else
+      "IND"
+    end
+  end
+
+  # Liste des types de réception FT : COL, IND
+  def france_travail_type_reception
+    collectif? ? "COL" : "IND"
+  end
+
+  # Liste des statuts FT : PRIS, EFFECTUE, MODIFIE, ABSENT, ANNULE
+  def france_travail_statut
+    case status
+    when "seen"
+      "EFFECTUE"
+    when "excused", "revoked"
+      "ANNULE"
+    when "noshow"
+      "ABSENT"
+    else
+      "PRIS"
+    end
+  end
+end

app/models/concerns/participation/france_travail_webhooks.rb

@@ -0,0 +1,33 @@
+# For france travail the webhooks are specific, we have to adapt to FT specs as they could not
+# implement a system integrating our webhooks, so we separated the two webhooks logic.
+module Participation::FranceTravailWebhooks
+  extend ActiveSupport::Concern
+
+  included do
+    after_commit on: :create, if: -> { eligible_for_france_travail_webhook? } do
+      OutgoingWebhooks::FranceTravail::ProcessParticipationJob.perform_later(
+        participation_id: id, timestamp: created_at, event: :create
+      )
+    end
+
+    after_commit on: :update, if: -> { eligible_for_france_travail_webhook? } do
+      OutgoingWebhooks::FranceTravail::ProcessParticipationJob.perform_later(
+        participation_id: id, timestamp: updated_at, event: :update
+      )
+    end
+
+    around_destroy lambda { |participation, block|
+      if participation.eligible_for_france_travail_webhook?
+        OutgoingWebhooks::FranceTravail::ProcessParticipationJob.perform_later(
+          participation_id: participation.id, timestamp: Time.current, event: :delete
+        )
+      end
+
+      block.call
+    }
+  end
+
+  def eligible_for_france_travail_webhook?
+    organisation.france_travail? && user.birth_date? && user.nir?
+  end
+end

app/models/participation.rb

@@ -2,6 +2,8 @@ class Participation < ApplicationRecord
   include Notificable
   include HasCurrentCategoryConfiguration
   include RdvParticipationStatus
+  include Participation::FranceTravailWebhooks
+  include Participation::FranceTravailPayload
 
   belongs_to :rdv
   belongs_to :follow_up
@@ -14,6 +16,7 @@ class Participation < ApplicationRecord
 
   has_many :notifications, dependent: :destroy
   has_many :follow_up_invitations, through: :follow_up, source: :invitations
+  has_many :agents, through: :rdv
 
   has_one :organisation, through: :rdv
 
@@ -28,7 +31,7 @@ class Participation < ApplicationRecord
 
   enum created_by: { agent: "agent", user: "user", prescripteur: "prescripteur" }, _prefix: :created_by
 
-  delegate :starts_at, :motif_name,
+  delegate :starts_at, :motif, :lieu, :collectif?, :by_phone?, :duration_in_min,
            :rdv_solidarites_url, :rdv_solidarites_rdv_id, :instruction_for_rdv,
            to: :rdv
   delegate :department, :department_id, to: :organisation

app/models/rdv.rb

@@ -7,7 +7,6 @@ class Rdv < ApplicationRecord
   include Notificable
   include RdvParticipationStatus
   include WebhookDeliverable
-  include Rdv::FranceTravailWebhooks
   include HasCurrentCategoryConfiguration
 
   after_commit :notify_participations_to_users, on: :update, if: :should_notify_users?

app/models/webhook_receipt.rb

@@ -2,7 +2,4 @@ class WebhookReceipt < ApplicationRecord
   belongs_to :webhook_endpoint, optional: true
 
   validates :resource_model, :resource_id, :timestamp, presence: true
-
-  # france travail webhooks are not linked to a webhook_endpoint
-  scope :france_travail, -> { where(webhook_endpoint_id: nil) }
 end