14001731018

Committed 21 Mar 2025 10:10PM UTC coverage: 60.221% (-0.8%) from 61.046%

Build # 14001731018

Build Type

push

github

Committed by

jgabardini

Commit Message

remove bundle cache

Run Details

3111 of 5166 relevant lines covered (60.22%)

6.75 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

88.52

/app/controllers/api/contacts_controller.rb

# frozen_string_literal: true

module Api
  class ContactsController < ApplicationController
    # Skip CSRF if needed
    skip_before_action :verify_authenticity_token
    wrap_parameters false # to avoid nested contact

    def create
      validator = ContactValidator.new(contact_params)
      if validator.valid?
        contact = build_contact
        begin
          ActiveRecord::Base.transaction do
            contact.save!
            process_assessment(contact)
            process_notifications(contact)
          end
          render json: { data: contact.as_json(only: %i[id status assessment_report_url]) }, status: :created
        rescue ActiveRecord::RecordInvalid => e
          log_error('Validation failed during processing', e.message)
          render json: { error: e.message }, status: 422
        rescue StandardError => e
          log_error('Unexpected error', { error: e.message, backtrace: e.backtrace&.first(5) })
          render json: { error: 'Processing failed' }, status: 500
        end
      else
        log_error('Validation failed', "#{validator.error} #{contact_params}")
        render json: { error: validator.error }, status: 422
      end
    rescue ActiveRecord::RecordNotFound => e
      render json: { error: 'Resource not found' }, status: 422
    end

    def status
      contact = Contact.find(params[:contact_id])
      render json: { status: contact.status, assessment_report_url: contact.assessment_report_url }
    end

    private

    def contact_params
      params.permit(:name, :email, :context, :subject, :message, :company, :secret, :language, :resource_slug,
                    :can_we_contact, :suscribe, :initial_slug, :assessment_id, assessment_results: {})
    end

    def build_contact
      form_data = {
        name: contact_params[:name],
        email: contact_params[:email],
        company: contact_params[:company],
        message: contact_params[:message],
        page: contact_params[:context],
        language: contact_params[:language],
        initial_slug: contact_params[:initial_slug],
        can_we_contact: %w[true on 1].include?(contact_params[:can_we_contact]),
        suscribe: %w[true on 1].include?(contact_params[:suscribe])
      }

      if contact_params[:resource_slug].present?
        resource = Resource.find_by!(slug: contact_params[:resource_slug])
        form_data.merge!(
          resource_title_es: resource.title_es,
          resource_getit_es: resource.getit_es,
          resource_title_en: resource.title_en,
          resource_getit_en: resource.getit_en,
          resource_slug: resource.slug
        )
      end

      if contact_params[:assessment_id].present?
        form_data[:assessment_id] = contact_params[:assessment_id]
        form_data[:assessment_results] = contact_params[:assessment_results]
      end
      Contact.new(
        trigger_type: determine_trigger_type,
        email: contact_params[:email],
        form_data:,
        assessment_id: contact_params[:assessment_id]
      )
    end

    def determine_trigger_type
      if contact_params[:assessment_id].present? && contact_params[:assessment_results].present?
        'assessment_submission'
      elsif contact_params[:resource_slug].present?
        'download_form'
      else
        'contact_form'
      end
    end

    def process_assessment(contact)
      return unless contact.trigger_type == 'assessment_submission'

      # contact.assessment = Assessment.find(contact.form_data['assessment_id'].to_i)
      assessment_results = contact.form_data['assessment_results']
      ActiveRecord::Base.transaction do
        assessment_results.each do |question_id, answer_id|
          contact.responses.create!(
            question_id:,
            answer_id:
          )
        end
      end
      # GenerateAssessmentResultJob.perform_later(contact.id)
      true
    rescue ActiveRecord::RecordInvalid => e
      log_error('Response creation failed', e.message)
      raise # Re-raise to fail the transaction and signal the controller
    rescue JSON::ParserError => e
      log_error('Invalid assessment_results JSON', e.message)
      raise
    end

    def process_notifications(contact)
      language = (contact.form_data['language'] || 'es').to_sym
      templates = MailTemplate.where(
        trigger_type: contact.trigger_type,
        lang: language,
        active: true,
        delivery_schedule: 'immediate'
      )
      Log.log(:mail, :info, 'Found templates', templates.map(&:identifier))

      templates.each do |template|
        NotificationMailer.custom_notification(contact, template).deliver_later(queue: 'default')
      rescue StandardError => e
        log_error('Notification delivery failed', e.message)
      end
    end

    def log_error(message, details)
      Log.log(:mail, :error, message, details)
    end
  end
end

1	# frozen_string_literal: true
2
3	module Api	1✔
4	class ContactsController < ApplicationController	1✔
5	# Skip CSRF if needed
6	skip_before_action :verify_authenticity_token	1✔
7	wrap_parameters false # to avoid nested contact	1✔
8
9	def create	1✔
10	validator = ContactValidator.new(contact_params)	27✔
11	if validator.valid?	27✔
12	contact = build_contact	23✔
13	begin
14	ActiveRecord::Base.transaction do	22✔
15	contact.save!	22✔
16	process_assessment(contact)	20✔
17	process_notifications(contact)	20✔
18	end
19	render json: { data: contact.as_json(only: %i[id status assessment_report_url]) }, status: :created	20✔
20	rescue ActiveRecord::RecordInvalid => e
21	log_error('Validation failed during processing', e.message)	1✔
22	render json: { error: e.message }, status: 422	1✔
23	rescue StandardError => e
24	log_error('Unexpected error', { error: e.message, backtrace: e.backtrace&.first(5) })	1✔
25	render json: { error: 'Processing failed' }, status: 500	1✔
26	end
27	else
28	log_error('Validation failed', "#{validator.error} #{contact_params}")	4✔
29	render json: { error: validator.error }, status: 422	4✔
30	end
31	rescue ActiveRecord::RecordNotFound => e
32	render json: { error: 'Resource not found' }, status: 422	1✔
33	end
34
35	def status	1✔
36	contact = Contact.find(params[:contact_id])	×
37	render json: { status: contact.status, assessment_report_url: contact.assessment_report_url }	×
38	end
39
40	private	1✔
41
42	def contact_params	1✔
43	params.permit(:name, :email, :context, :subject, :message, :company, :secret, :language, :resource_slug,	383✔
44	:can_we_contact, :suscribe, :initial_slug, :assessment_id, assessment_results: {})
45	end
46
47	def build_contact	1✔
48	form_data = {
49	name: contact_params[:name],	23✔
50	email: contact_params[:email],
51	company: contact_params[:company],
52	message: contact_params[:message],
53	page: contact_params[:context],
54	language: contact_params[:language],
55	initial_slug: contact_params[:initial_slug],
56	can_we_contact: %w[true on 1].include?(contact_params[:can_we_contact]),
57	suscribe: %w[true on 1].include?(contact_params[:suscribe])
58	}
59
60	if contact_params[:resource_slug].present?	23✔
61	resource = Resource.find_by!(slug: contact_params[:resource_slug])	8✔
62	form_data.merge!(	7✔
63	resource_title_es: resource.title_es,
64	resource_getit_es: resource.getit_es,
65	resource_title_en: resource.title_en,
66	resource_getit_en: resource.getit_en,
67	resource_slug: resource.slug
68	)
69	end
70
71	if contact_params[:assessment_id].present?	22✔
72	form_data[:assessment_id] = contact_params[:assessment_id]	2✔
73	form_data[:assessment_results] = contact_params[:assessment_results]	2✔
74	end
75	Contact.new(	22✔
76	trigger_type: determine_trigger_type,
77	email: contact_params[:email],
78	form_data:,
79	assessment_id: contact_params[:assessment_id]
80	)
81	end
82
83	def determine_trigger_type	1✔
84	if contact_params[:assessment_id].present? && contact_params[:assessment_results].present?	22✔
85	'assessment_submission'	2✔
86	elsif contact_params[:resource_slug].present?	20✔
87	'download_form'	5✔
88	else
89	'contact_form'	15✔
90	end
91	end
92
93	def process_assessment(contact)	1✔
94	return unless contact.trigger_type == 'assessment_submission'	20✔
95
96	# contact.assessment = Assessment.find(contact.form_data['assessment_id'].to_i)
97	assessment_results = contact.form_data['assessment_results']	2✔
98	ActiveRecord::Base.transaction do	2✔
99	assessment_results.each do \|question_id, answer_id\|	2✔
100	contact.responses.create!(	2✔
101	question_id:,
102	answer_id:
103	)
104	end
105	end
106	# GenerateAssessmentResultJob.perform_later(contact.id)
107	true	2✔
108	rescue ActiveRecord::RecordInvalid => e
109	log_error('Response creation failed', e.message)	×
110	raise # Re-raise to fail the transaction and signal the controller	×
111	rescue JSON::ParserError => e
112	log_error('Invalid assessment_results JSON', e.message)	×
113	raise	×
114	end
115
116	def process_notifications(contact)	1✔
117	language = (contact.form_data['language'] \|\| 'es').to_sym	20✔
118	templates = MailTemplate.where(	20✔
119	trigger_type: contact.trigger_type,
120	lang: language,
121	active: true,
122	delivery_schedule: 'immediate'
123	)
124	Log.log(:mail, :info, 'Found templates', templates.map(&:identifier))	20✔
125
126	templates.each do \|template\|	20✔
127	NotificationMailer.custom_notification(contact, template).deliver_later(queue: 'default')	11✔
128	rescue StandardError => e
129	log_error('Notification delivery failed', e.message)	×
130	end
131	end
132
133	def log_error(message, details)	1✔
134	Log.log(:mail, :error, message, details)	6✔
135	end
136	end
137	end

kleer-la / eventer / 14001731018

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous