feat: Implement weekly email report

Gemfile

@@ -75,6 +75,7 @@ gem 'validate_url'
 
 # Background job processing
 gem 'sidekiq', '< 6'
+gem 'sidekiq-cron', '~> 1.1'
 
 # Misc support gems
 gem 'rails-settings-cached', '~> 0.7.2'

Gemfile.lock

@@ -141,6 +141,8 @@ GEM
     errbase (0.1.1)
     erubi (1.8.0)
     erubis (2.7.0)
+    et-orbi (1.2.1)
+      tzinfo
     excon (0.64.0)
     execjs (2.7.0)
     factory_bot (5.0.2)
@@ -157,6 +159,9 @@ GEM
     font-awesome-rails (4.7.0.5)
       railties (>= 3.2, < 6.1)
     formatador (0.2.5)
+    fugit (1.2.1)
+      et-orbi (~> 1.1, >= 1.1.8)
+      raabro (~> 1.1)
     globalid (0.4.2)
       activesupport (>= 4.2.0)
     groupdate (4.1.1)
@@ -274,6 +279,7 @@ GEM
       method_source (~> 0.9.0)
     public_suffix (3.0.3)
     puma (3.12.1)
+    raabro (1.1.6)
     rack (2.0.7)
     rack-protection (2.0.5)
       rack
@@ -377,6 +383,9 @@ GEM
       rack (>= 1.5.0)
       rack-protection (>= 1.5.0)
       redis (>= 3.3.5, < 5)
+    sidekiq-cron (1.1.0)
+      fugit (~> 1.1)
+      sidekiq (>= 4.2.1)
     simple_form (4.1.0)
       actionpack (>= 5.0)
       activemodel (>= 5.0)
@@ -496,6 +505,7 @@ DEPENDENCIES
   shoulda (~> 3.5)
   shoulda-matchers (~> 2.0)
   sidekiq (< 6)
+  sidekiq-cron (~> 1.1)
   simple_form
   simple_spark
   simplecov

app/assets/javascripts/manage/lib/setupDataTables.js

@@ -39,6 +39,7 @@ var setupDataTables = function() {
       { orderable: true, data: "email" },
       { orderable: true, data: "role" },
       { orderable: true, data: "active" },
+      { orderable: true, data: "receive_weekly_report" },
       { orderable: true, data: "created_at" }
     ]
   });

app/controllers/manage/admins_controller.rb

@@ -46,7 +46,7 @@ def destroy
 
   def user_params
     params.require(:user).permit(
-      :email, :password, :password_confirmation, :remember_me, :role, :is_active
+      :email, :password, :password_confirmation, :remember_me, :role, :is_active, :receive_weekly_report
     )
   end
 

app/controllers/manage/messages_controller.rb

@@ -59,14 +59,14 @@ def deliver
   end
 
   def preview
-    email = Mailer.bulk_message_email(@message.id, current_user.id, nil, true)
+    email = UserMailer.bulk_message_email(@message.id, current_user.id, nil, true)
     render html: email.body.raw_source.html_safe
   end
 
   def live_preview
     body = params[:body] || ""
     message = Message.new(body: body)
-    email = Mailer.bulk_message_email(nil, current_user.id, message, true)
+    email = UserMailer.bulk_message_email(nil, current_user.id, message, true)
     render html: email.body.raw_source.html_safe
   end
 
@@ -88,7 +88,7 @@ def template
   def template_preview
     body = File.read("app/views/manage/messages/_template_example.html.md")
     message = Message.new(body: body)
-    email = Mailer.bulk_message_email(nil, current_user.id, message, true)
+    email = UserMailer.bulk_message_email(nil, current_user.id, message, true)
     render html: email.body.raw_source.html_safe
   end
 

app/datatables/admin_datatable.rb

@@ -7,6 +7,7 @@ def view_columns
       email: { source: "User.email" },
       role: { source: "User.role", searchable: false },
       active: { source: "User.is_active", searchable: false },
+      receive_weekly_report: { source: "User.receive_weekly_report", searchable: false },
       created_at: { source: "User.created_at", searchable: false },
     }
   end
@@ -20,6 +21,7 @@ def data
         email: link_to(bold(record.email), manage_admin_path(record)),
         role: record.role.titleize,
         active: record.is_active ? '<span class="badge badge-secondary">Active</span>'.html_safe : '<span class="badge badge-danger">Inactive<span>'.html_safe,
+        receive_weekly_report: record.receive_weekly_report ? '<span class="badge badge-success">Yes</span>'.html_safe : '<span class="badge badge-secondary">No<span>'.html_safe,
         created_at: display_datetime(record.created_at),
       }
     end

app/jobs/admin_weekly_report_job.rb

@@ -0,0 +1,11 @@
+class AdminWeeklyReportJob < ApplicationJob
+  queue_as :default
+
+  def perform
+    # Queue all eligible users and let the is_active (or other) logic determine if they should really receive it
+    users = User.where(receive_weekly_report: true)
+    users.each do |user|
+      AdminMailer.weekly_report(user.id).deliver_later
+    end
+  end
+end

app/jobs/bulk_message_job.rb

@@ -9,7 +9,7 @@ def perform(message)
     recipients = self.class.build_recipients(message.recipients)
 
     recipients.each do |recipient|
-      Mailer.bulk_message_email(message.id, recipient).deliver_later
+      UserMailer.bulk_message_email(message.id, recipient).deliver_later
     end
 
     message.update_attribute(:delivered_at, Time.now)

app/mailers/admin_mailer.rb

@@ -0,0 +1,53 @@
+class AdminMailer < ApplicationMailer
+  include Roadie::Rails::Automatic
+  add_template_helper(HackathonManagerHelper)
+
+  layout "admin_mailer"
+
+  def weekly_report(user_id)
+    # Don't send emails more than 7 days after event starts
+    stop_date = Date.parse(HackathonConfig["event_start_date"]) + 7.days
+    return if Date.today > stop_date
+
+    @user = User.find_by_id(user_id)
+
+    return unless @user.safe_receive_weekly_report
+
+    @period_start = 7.days.ago.at_beginning_of_day
+    @period_end = 1.day.ago.at_end_of_day
+    @period = @period_start..@period_end
+
+    @applications = report_metric(Questionnaire, :created_at)
+    @rsvp_confirmed = report_metric(Questionnaire.where(acc_status: "rsvp_confirmed"), :acc_status_date)
+    @rsvp_denied = report_metric(Questionnaire.where(acc_status: "rsvp_denied"), :acc_status_date)
+
+    @bus_metrics = BusList.all.map do |bus_list|
+      {
+        name: bus_list.name,
+        total: bus_list.passengers.count,
+      }
+    end
+
+    @messages_sent = Message.bulk.where(delivered_at: @period).count
+
+    @new_admissions_metrics = [@applications, @rsvp_confirmed, @rsvp_denied].any? { |x| x[:new].positive? }
+    @new_communication_metrics = @messages_sent.positive?
+
+    # Don't send email if no new activity
+    return if !@new_admissions_metrics && !@new_bus_list_metrics && !@new_communication_metrics
+
+    mail(
+      to: pretty_email(@user.full_name, @user.email),
+      subject: "Your Weekly Report",
+    )
+  end
+
+  private
+
+  def report_metric(query_base, new_query_field)
+    {
+      new: query_base.where(new_query_field => @period).count,
+      total: query_base.count,
+    }
+  end
+end

app/mailers/application_mailer.rb

@@ -1,4 +1,10 @@
 class ApplicationMailer < ActionMailer::Base
-  default from: -> { HackathonConfig['email_from'] }
-  layout 'mailer'
+  default from: -> { HackathonConfig["email_from"] }
+  layout "user_mailer"
+
+  def pretty_email(name, email)
+    return email if name.blank?
+
+    "\"#{name}\" <#{email}>"
+  end
 end

app/mailers/mail_preview.rb

@@ -2,7 +2,11 @@
   class MailPreview < ActionMailer::Preview
     def bulk_message_email
       message = Message.first
-      Mailer.bulk_message_email(message, User.first.id)
+      UserMailer.bulk_message_email(message, User.first.id)
+    end
+
+    def admin_weekly_report
+      AdminMailer.weekly_report(User.first.id)
     end
   end
 end

app/mailers/mailer.rb → app/mailers/user_mailer.rb

@@ -1,40 +1,30 @@
-class Mailer < ApplicationMailer
+class UserMailer < ApplicationMailer
   include Roadie::Rails::Automatic
   add_template_helper(HackathonManagerHelper)
 
-  default from: -> { HackathonConfig['email_from'] }
-
   def bulk_message_email(message_id, user_id, message = nil, use_examples = false)
-    @message      = message || Message.find_by_id(message_id)
-    @user         = User.find_by_id(user_id)
+    @message = message || Message.find_by_id(message_id)
+    @user = User.find_by_id(user_id)
     @use_examples = use_examples
     return if @user.blank? || @message.blank?
 
     mail(
       to: pretty_email(@user.full_name, @user.email),
-      subject: @message.subject
+      subject: @message.subject,
     )
   end
 
   def incomplete_reminder_email(user_id)
     @user = User.find_by_id(user_id)
-    return if @user.blank? || @user.admin? || @user.questionnaire || Time.now.to_date > Date.parse(HackathonConfig['last_day_to_apply'])
+    return if @user.blank? || @user.admin? || @user.questionnaire || Time.now.to_date > Date.parse(HackathonConfig["last_day_to_apply"])
 
     Message.queue_for_trigger("user.24hr_incomplete_application", @user.id)
   end
 
   rescue_from SparkPostRails::DeliveryException do |e|
     error_codes_to_not_retry = [
-      "1902" # Generation rejection
+      "1902", # Generation rejection
     ]
     raise e unless e.blank? || error_codes_to_not_retry.include?(e.service_code)
   end
-
-  private
-
-  def pretty_email(name, email)
-    return email if name.blank?
-
-    "\"#{name}\" <#{email}>"
-  end
 end

app/models/message.rb

@@ -171,7 +171,7 @@ def self.for_trigger(trigger)
   end
 
   def self.queue_for_trigger(trigger, user_id)
-    for_trigger(trigger).map { |message| Mailer.bulk_message_email(message.id, user_id).deliver_later }
+    for_trigger(trigger).map { |message| UserMailer.bulk_message_email(message.id, user_id).deliver_later }
   end
 
   def self.bulk

app/models/user.rb

@@ -32,14 +32,19 @@ def send_devise_notification(notification, *args)
 
   def queue_reminder_email
     return if reminder_sent_at
-    Mailer.incomplete_reminder_email(id).deliver_later(wait: 1.day)
+    UserMailer.incomplete_reminder_email(id).deliver_later(wait: 1.day)
     update_attribute(:reminder_sent_at, Time.now)
   end
 
   def email=(value)
     super value.try(:downcase)
   end
 
+  def safe_receive_weekly_report
+    return false unless is_active
+    receive_weekly_report
+  end
+
   def first_name
     return "" if questionnaire.blank?
     questionnaire.first_name

app/views/admin_mailer/weekly_report.haml

@@ -0,0 +1,50 @@
+%h1 Your Weekly Report
+
+%p
+  For the week of
+  %strong
+    = @period_start.strftime("%A, %B %-d")
+    –
+    = @period_end.strftime("%A, %B %-d")
+
+%h2 Admissions
+
+- if @new_admissions_metrics
+  %p
+    📥 
+    %strong= @applications[:new]
+    new applications (#{@applications[:total]} total)
+
+  %p
+    ✅ 
+    %strong= @rsvp_confirmed[:new]
+    new RSVP confirmations (#{@rsvp_confirmed[:total]} total)
+
+  %p
+    ❌ 
+    %strong= @rsvp_denied[:new]
+    new RSVP denials (#{@rsvp_denied[:total]} total)
+- else
+  %p
+    %em No change from last week
+
+%h2 Transportation
+
+- @bus_metrics.each do |bus_metric|
+  %p
+    %u= bus_metric[:name]
+    %br
+    🚌 
+    %strong= bus_metric[:total]
+    total passengers
+
+%h2 Communication
+
+- if @new_communication_metrics
+  %p
+    ✉️ 
+    %strong= @messages_sent
+    new bulk emails sent out
+- else
+  %p
+    %em No new bulk emails sent