1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
|
# frozen_string_literal: true
module Users
class InProductMarketingEmail < ApplicationRecord
include BulkInsertSafe
BUILD_IOS_APP_GUIDE = 'build_ios_app_guide'
CAMPAIGNS = [BUILD_IOS_APP_GUIDE].freeze
belongs_to :user
validates :user, presence: true
validates :track, :series, presence: true, if: -> { campaign.blank? }
validates :campaign, presence: true, if: -> { track.blank? && series.blank? }
validates :campaign, inclusion: { in: CAMPAIGNS }, allow_nil: true
validates :user_id, uniqueness: {
scope: [:track, :series],
message: 'track series email has already been sent'
}, if: -> { track.present? }
validates :user_id, uniqueness: {
scope: :campaign,
message: 'campaign email has already been sent'
}, if: -> { campaign.present? }
validate :campaign_or_track_series
enum track: {
create: 0,
verify: 1,
trial: 2,
team: 3,
experience: 4,
team_short: 5,
trial_short: 6,
admin_verify: 7,
invite_team: 8
}, _suffix: true
# Tracks we don't send emails for (e.g. unsuccessful experiment). These
# are kept since we already have DB records that use the enum value.
INACTIVE_TRACK_NAMES = %w[invite_team experience].freeze
ACTIVE_TRACKS = tracks.except(*INACTIVE_TRACK_NAMES)
scope :for_user_with_track_and_series, -> (user, track, series) do
where(user: user, track: track, series: series)
end
scope :without_track_and_series, -> (track, series) do
join_condition = for_user.and(for_track_and_series(track, series))
users_without_records(join_condition)
end
scope :without_campaign, -> (campaign) do
join_condition = for_user.and(for_campaign(campaign))
users_without_records(join_condition)
end
def self.users_table
User.arel_table
end
def self.distinct_users_sql
name = users_table.table_name
Arel.sql("DISTINCT ON(#{name}.id) #{name}.*")
end
def self.users_without_records(condition)
arel_join = users_table.join(arel_table, Arel::Nodes::OuterJoin).on(condition)
joins(arel_join.join_sources)
.where(in_product_marketing_emails: { id: nil })
.select(distinct_users_sql)
end
def self.for_user
arel_table[:user_id].eq(users_table[:id])
end
def self.for_campaign(campaign)
arel_table[:campaign].eq(campaign)
end
def self.for_track_and_series(track, series)
arel_table[:track].eq(ACTIVE_TRACKS[track])
.and(arel_table[:series]).eq(series)
end
def self.save_cta_click(user, track, series)
email = for_user_with_track_and_series(user, track, series).take
email.update(cta_clicked_at: Time.zone.now) if email && email.cta_clicked_at.blank?
end
private
def campaign_or_track_series
if campaign.present? && (track.present? || series.present?)
errors.add(:campaign, 'should be a campaign or a track and series but not both')
end
end
end
end
|
