create contacts in instructor signup instead of leads

app/controllers/admin/users_controller.rb

@@ -69,8 +69,8 @@ def mark_users_updated
       redirect_to actions_admin_users_path, notice: 'Incremented unread update count'
     end
 
-    def force_update_lead
-      Newflow::CreateOrUpdateSalesforceLead.call(user: get_user)
+    def force_update_contact
+      Newflow::CreateOrUpdateSalesforceContact.call(user: get_user)
     end
 
     protected

app/handlers/newflow/educator_signup/complete_profile.rb

@@ -108,7 +108,7 @@ def handle
 
         transfer_errors_from(@user, {type: :verbatim}, :fail_if_errors)
 
-        CreateOrUpdateSalesforceLead.perform_later(user: @user)
+        CreateOrUpdateSalesforceContact.perform_later(user: @user)
 
         #output the user to the lev handler
         outputs.user = @user

app/handlers/newflow/educator_signup/sheerid_webhook.rb

@@ -136,7 +136,7 @@ def handle(verification_id=nil)
             event_data: { verification: verification_details_from_sheerid.inspect })
         end
 
-        CreateOrUpdateSalesforceLead.perform_later(user: user)
+        CreateOrUpdateSalesforceContact.perform_later(user: user)
 
 
         SecurityLog.create!(user: user, event_type: :sheerid_webhook_processed)

app/routines/newflow/create_or_update_salesforce_lead.rb → app/routines/newflow/create_or_update_salesforce_contact.rb

@@ -1,9 +1,8 @@
 module Newflow
-  class CreateOrUpdateSalesforceLead
+  class CreateOrUpdateSalesforceContact
 
     lev_routine active_job_enqueue_options: { queue: :salesforce }
 
-    LEAD_SOURCE =  'Account Creation'
     DEFAULT_REFERRING_APP_NAME = 'Accounts'
 
     ADOPTION_STATUS_FROM_USER = {
@@ -24,7 +23,7 @@ def exec(user:)
 
       SecurityLog.create!(
         user: user,
-        event_type: :starting_salesforce_lead_creation
+        event_type: :starting_salesforce_contact_creation
       )
 
       sf_school_id = user.school&.salesforce_id
@@ -47,7 +46,7 @@ def exec(user:)
         adoption_json = build_book_adoption_json_for_salesforce(user)
       end
 
-      # Check the state of the SheerID response and profile completion to determine faculty status for lead
+      # Check the state of the SheerID response and profile completion to determine faculty status for contact
       sheerid_response = SheeridVerification.find_by(verification_id: user.sheerid_verification_id)
       if user.is_profile_complete?
         user.faculty_status = :pending_faculty
@@ -59,47 +58,55 @@ def exec(user:)
         user.faculty_status = :incomplete_signup
       end
 
-
-      if user.salesforce_lead_id
-        lead = OpenStax::Salesforce::Remote::Lead.find_by(email: user.best_email_address_for_salesforce)
+      # Find existing contact or create new one
+      if user.salesforce_contact_id
+        contact = OpenStax::Salesforce::Remote::Contact.find_by(id: user.salesforce_contact_id)
       else
-        lead = OpenStax::Salesforce::Remote::Lead.new(email: user.best_email_address_for_salesforce)
+        # Look for existing contact by email first
+        contact = OpenStax::Salesforce::Remote::Contact.find_by(email: user.best_email_address_for_salesforce)
+
+        # If found, update the user with the contact ID
+        if contact
+          user.salesforce_contact_id = contact.id
+          user.save
+        else
+          # Create new contact
+          contact = OpenStax::Salesforce::Remote::Contact.new(email: user.best_email_address_for_salesforce)
+        end
       end
 
-      if lead.nil?
-        Sentry.capture_message("Lead for user not found #{user.uuid} not found", level: :error)
+      if contact.nil?
+        Sentry.capture_message("Contact for user #{user.uuid} not found", level: :error)
         return
       end
 
-        lead.first_name = user.first_name
-        lead.last_name = user.last_name
-        lead.phone = user.phone_number
-        lead.source = LEAD_SOURCE
-        lead.application_source = DEFAULT_REFERRING_APP_NAME
-        lead.role = sf_role
-        lead.position = sf_position
-        lead.title = user.other_role_name
-        lead.who_chooses_books = user.who_chooses_books
-        lead.subject_interest = user.which_books
-        lead.num_students = user.how_many_students
-        lead.adoption_status = ADOPTION_STATUS_FROM_USER[user.using_openstax_how]
-        lead.adoption_json = adoption_json
-        lead.os_accounts_id = user.id
-        lead.accounts_uuid = user.uuid
-        lead.school = user.most_accurate_school_name
-        lead.city = user.most_accurate_school_city
-        lead.country = user.most_accurate_school_country
-        lead.verification_status = user.faculty_status == User::NO_FACULTY_INFO ? nil : user.faculty_status
-        lead.b_r_i_marketing = user.is_b_r_i_user?
-        lead.title_1_school = user.title_1_school?
-        lead.newsletter = user.receive_newsletter?
-        lead.newsletter_opt_in = user.receive_newsletter?
-        lead.self_reported_school = user.self_reported_school
-        lead.sheerid_school_name = user.sheerid_reported_school
-        lead.account_id = sf_school_id
-        lead.school_id = sf_school_id
-        lead.signup_date = user.created_at.strftime("%Y-%m-%dT%T.%L%z")
-        lead.tracking_parameters = "#{Rails.application.secrets.openstax_url}/accounts/i/signup/"
+      contact.first_name = user.first_name
+      contact.last_name = user.last_name
+      contact.phone = user.phone_number
+      contact.lead_source = DEFAULT_REFERRING_APP_NAME
+      contact.role = sf_role
+      contact.position = sf_position
+      contact.title = user.other_role_name
+      contact.who_chooses_books = user.who_chooses_books
+      contact.subject_interest = user.which_books
+      contact.num_students = user.how_many_students
+      contact.adoption_status = ADOPTION_STATUS_FROM_USER[user.using_openstax_how]
+      contact.adoption_json = adoption_json
+      contact.os_accounts_id = user.id
+      contact.accounts_uuid = user.uuid
+      contact.school = user.most_accurate_school_name
+      contact.city = user.most_accurate_school_city
+      contact.country = user.most_accurate_school_country
+      contact.verification_status = user.faculty_status == User::NO_FACULTY_INFO ? nil : user.faculty_status
+      contact.b_r_i_marketing = user.is_b_r_i_user?
+      contact.title_1_school = user.title_1_school?
+      contact.newsletter = user.receive_newsletter?
+      contact.newsletter_opt_in = user.receive_newsletter?
+      contact.self_reported_school = user.self_reported_school
+      contact.sheerid_school_name = user.sheerid_reported_school
+      contact.account_id = sf_school_id
+      contact.signup_date = user.created_at.strftime("%Y-%m-%dT%T.%L%z")
+      contact.tracking_parameters = "#{Rails.application.secrets.openstax_url}/accounts/i/signup/"
 
       state = user.most_accurate_school_state
       unless state.blank?
@@ -108,40 +115,40 @@ def exec(user:)
       unless state.nil?
         # Figure out if the State is an abbreviation or the full name
         if state == state.upcase
-          lead.state_code = state
+          contact.state_code = state
         else
-          lead.state = state
+          contact.state = state
         end
       end
 
       SecurityLog.create!(
         user: user,
-        event_type: :attempting_to_create_user_lead,
-        event_data: { lead_data: lead }
+        event_type: :attempting_to_create_user_contact,
+        event_data: { contact_data: contact }
       )
 
-      if lead.save
-        user.salesforce_lead_id = lead.id
+      if contact.save
+        user.salesforce_contact_id = contact.id
         if user.save
           SecurityLog.create!(
             user: user,
-            event_type: :created_salesforce_lead,
-            event_data: { lead_id: lead.id.to_s }
+            event_type: :created_salesforce_contact,
+            event_data: { contact_id: contact.id.to_s }
           )
         else
-          if lead.errors.messages.inspect.include? == 'INSUFFICIENT_ACCESS_ON_CROSS_REFERENCE_ENTITY'
+          if contact.errors.messages.inspect.include? == 'INSUFFICIENT_ACCESS_ON_CROSS_REFERENCE_ENTITY'
             Sentry.capture_message("Invalid school (#{user.school.salesforce_id}) for user (#{user.id})")
           end
           SecurityLog.create!(
             user: user,
             event_type: :educator_sign_up_failed,
-            event_data: { lead_id: lead.id }
+            event_data: { contact_id: contact.id }
           )
-          Sentry.capture_message("User #{user.id} was not successfully saved with lead #{lead.id}")
+          Sentry.capture_message("User #{user.id} was not successfully saved with contact #{contact.id}")
         end
       end
 
-      outputs.lead = lead
+      outputs.contact = contact
       outputs.user = user
     end
 
@@ -174,4 +181,4 @@ def build_book_adoption_json_for_salesforce(user)
       adoption_json.to_json
     end
   end
-end
+end

config/routes.rb

@@ -283,7 +283,7 @@
       get 'js_search', on: :collection
       get 'actions', on: :collection
       put 'mark_users_updated', on: :collection
-      post 'force_update_lead', on: :member
+      post 'force_update_contact', on: :member
       delete 'soft_delete', on: :member
     end