Implement Contact sync to Salesforce

Author: fspeirs

app/jobs/salesforce/contact_sync_job.rb

@@ -0,0 +1,17 @@
+# frozen_string_literal: true
+
+module Salesforce
+  class ContactSyncJob < SalesforceSyncJob
+    MODEL_CLASS = Salesforce::Contact
+
+    def perform(school_id:)
+      school = ::School.find(school_id)
+
+      sf_contact = Salesforce::Contact.find_by(pi_accounts_unique_id__c: school.creator_id)
+      raise SalesforceRecordNotFound, "Contact not found for creator_id: #{school.creator_id}" unless sf_contact
+
+      sf_contact.experiencecsagreetouxcontact__c = school.creator_agree_to_ux_contact
+      sf_contact.save!
+    end
+  end
+end

app/models/salesforce/contact.rb

@@ -0,0 +1,8 @@
+# frozen_string_literal: true
+
+module Salesforce
+  class Contact < Salesforce::Base
+    self.table_name = 'salesforce.contact'
+    self.primary_key = :pi_accounts_unique_id__c
+  end
+end

lib/tasks/salesforce_sync.rake

@@ -14,4 +14,11 @@ namespace :salesforce_sync do
       Salesforce::RoleSyncJob.perform_later(role_id:)
     end
   end
+
+  desc 'Sync creator_agree_to_ux_contact for all Schools to Salesforce Contact'
+  task contact: :environment do
+    School.pluck(:id).each do |school_id|
+      Salesforce::ContactSyncJob.perform_later(school_id:)
+    end
+  end
 end

spec/factories/salesforce/contact.rb

@@ -0,0 +1,7 @@
+# frozen_string_literal: true
+
+FactoryBot.define do
+  factory(:salesforce_contact, class: 'Salesforce::Contact') do
+    pi_accounts_unique_id__c { SecureRandom.uuid }
+  end
+end

spec/jobs/salesforce/contact_sync_job_spec.rb

@@ -0,0 +1,57 @@
+# frozen_string_literal: true
+
+require 'rails_helper'
+
+RSpec.describe Salesforce::ContactSyncJob do
+  subject(:perform_job) { described_class.perform_now(school_id: school.id) }
+
+  let(:school) { create(:school, creator_agree_to_ux_contact: true) }
+  let!(:sf_contact) { create(:salesforce_contact, pi_accounts_unique_id__c: school.creator_id) }
+
+  it 'sets experiencecsagreetouxcontact__c from school.creator_agree_to_ux_contact' do
+    perform_job
+    expect(sf_contact.reload.experiencecsagreetouxcontact__c).to be(true)
+  end
+
+  it 'saves the contact' do
+    expect { perform_job }.not_to raise_error
+  end
+
+  context 'when the Contact is not found in Salesforce' do
+    before { sf_contact.destroy }
+
+    it 'retries the job' do
+      expect { perform_job }.to have_enqueued_job(described_class).with(school_id: school.id)
+    end
+  end
+
+  context 'when the Salesforce contact fails to save' do
+    let(:sf_contact_double) { instance_double(Salesforce::Contact) }
+
+    before do
+      allow(Salesforce::Contact).to receive(:find_by)
+        .with(pi_accounts_unique_id__c: school.creator_id)
+        .and_return(sf_contact_double)
+      allow(sf_contact_double).to receive(:experiencecsagreetouxcontact__c=)
+      allow(sf_contact_double).to receive(:save!).and_raise(ActiveRecord::RecordInvalid)
+    end
+
+    it 'raises an error' do
+      expect { perform_job }.to raise_error(ActiveRecord::RecordInvalid)
+    end
+  end
+
+  context 'when SALESFORCE_ENABLED is false' do
+    around do |example|
+      ClimateControl.modify(SALESFORCE_ENABLED: 'false') do
+        example.run
+      end
+    end
+
+    it 'discards the job without syncing' do
+      sf_contact.update!(experiencecsagreetouxcontact__c: false)
+      perform_job
+      expect(sf_contact.reload.experiencecsagreetouxcontact__c).to be(false)
+    end
+  end
+end