1 files changed, 112 insertions, 0 deletions
diff --git a/app/services/namespaces/in_product_marketing_emails_service.rb b/app/services/namespaces/in_product_marketing_emails_service.rb
new file mode 100644
index 00000000000..45b4619ddbe
--- /dev/null
+++ b/app/services/namespaces/in_product_marketing_emails_service.rb
@@ -0,0 +1,112 @@
+# frozen_string_literal: true
+
+module Namespaces
+  class InProductMarketingEmailsService
+    include Gitlab::Experimentation::GroupTypes
+
+    INTERVAL_DAYS = [1, 5, 10].freeze
+    TRACKS = {
+      create: :git_write,
+      verify: :pipeline_created,
+      trial: :trial_started,
+      team: :user_added
+    }.freeze
+
+    def self.send_for_all_tracks_and_intervals
+      TRACKS.each_key do |track|
+        INTERVAL_DAYS.each do |interval|
+          new(track, interval).execute
+        end
+      end
+    end
+
+    def initialize(track, interval)
+      @track = track
+      @interval = interval
+      @sent_email_user_ids = []
+    end
+
+    def execute
+      groups_for_track.each_batch do |groups|
+        groups.each do |group|
+          send_email_for_group(group)
+        end
+      end
+    end
+
+    private
+
+    attr_reader :track, :interval, :sent_email_user_ids
+
+    def send_email_for_group(group)
+      experiment_enabled_for_group = experiment_enabled_for_group?(group)
+      experiment_add_group(group, experiment_enabled_for_group)
+      return unless experiment_enabled_for_group
+
+      users_for_group(group).each do |user|
+        send_email(user, group) if can_perform_action?(user, group)
+      end
+    end
+
+    def experiment_enabled_for_group?(group)
+      Gitlab::Experimentation.in_experiment_group?(:in_product_marketing_emails, subject: group)
+    end
+
+    def experiment_add_group(group, experiment_enabled_for_group)
+      variant = experiment_enabled_for_group ? GROUP_EXPERIMENTAL : GROUP_CONTROL
+      Experiment.add_group(:in_product_marketing_emails, variant: variant, group: group)
+    end
+
+    # rubocop: disable CodeReuse/ActiveRecord
+    def groups_for_track
+      onboarding_progress_scope = OnboardingProgress
+        .completed_actions_with_latest_in_range(completed_actions, range)
+        .incomplete_actions(incomplete_action)
+
+      Group.joins(:onboarding_progress).merge(onboarding_progress_scope)
+    end
+
+    def users_for_group(group)
+      group.users.where(email_opted_in: true)
+        .where.not(id: sent_email_user_ids)
+    end
+    # rubocop: enable CodeReuse/ActiveRecord
+
+    def can_perform_action?(user, group)
+      case track
+      when :create
+        user.can?(:create_projects, group)
+      when :verify
+        user.can?(:create_projects, group)
+      when :trial
+        user.can?(:start_trial, group)
+      when :team
+        user.can?(:admin_group_member, group)
+      else
+        raise NotImplementedError, "No ability defined for track #{track}"
+      end
+    end
+
+    def send_email(user, group)
+      NotificationService.new.in_product_marketing(user.id, group.id, track, series)
+      sent_email_user_ids << user.id
+    end
+
+    def completed_actions
+      index = TRACKS.keys.index(track)
+      index == 0 ? [:created] : TRACKS.values[0..index - 1]
+    end
+
+    def range
+      (interval + 1).days.ago.beginning_of_day..(interval + 1).days.ago.end_of_day
+    end
+
+    def incomplete_action
+      TRACKS[track]
+    end
+
+    def series
+      INTERVAL_DAYS.index(interval)
+    end
+  end
+end