Merge pull request #137 from CactusPuppy/master

Happening now endpoint + splash page / Mailbluster Integration

Gemfile

@@ -2,7 +2,7 @@
 
 source 'https://rubygems.org'
 
-ruby ENV['TRAVIS_RUBY_VERSION'] || '2.6.6'
+ruby ENV['TRAVIS_RUBY_VERSION'] || '~>2.6.6'
 
 # rails-assets requires >= 1.8.4
 if Gem::Version.new(Bundler::VERSION) < Gem::Version.new('1.8.4')
@@ -27,6 +27,7 @@ gem 'paper_trail'
 # for upload management
 gem 'carrierwave'
 gem 'carrierwave-bombshelter'
+gem 'mimemagic', '~> 0.3.6'
 gem 'mini_magick'
 
 # for internationalizing
@@ -220,6 +221,12 @@ gem 'dalli'
 
 gem 'icalendar'
 
+# for making external requests easier
+gem 'httparty'
+
+# pagination
+gem 'pagy', '<4.0'
+
 # Use guard and spring for testing in development
 group :development do
   # to launch specs when files are modified

Gemfile.lock

@@ -358,6 +358,7 @@ GEM
       rack-openid (~> 1.3.1)
     open4 (1.3.4)
     orm_adapter (0.5.0)
+    pagy (3.12.0)
     paper_trail (10.3.1)
       activerecord (>= 4.2)
       request_store (~> 1.1)
@@ -708,6 +709,7 @@ DEPENDENCIES
   guard-rspec
   haml-lint
   haml-rails
+  httparty
   icalendar
   iso-639
   jquery-datatables
@@ -717,6 +719,7 @@ DEPENDENCIES
   leaflet-rails
   letter_opener
   letter_opener_web (~> 1.0)
+  mimemagic (~> 0.3.6)
   mina
   mini_magick
   money-rails
@@ -727,6 +730,7 @@ DEPENDENCIES
   omniauth-github
   omniauth-google-oauth2
   omniauth-openid
+  pagy (< 4.0)
   paper_trail
   pdf-inspector
   pg

Procfile

@@ -1,2 +1,3 @@
 web: bundle exec rails server -b 0.0.0.0
 worker: bundle exec rails jobs:work
+release: rake db:migrate

app/assets/javascripts/application.js

@@ -54,6 +54,7 @@
 //= require selectize
 //= require bootstrap-select
 //= require osem-survey
+//= require pagy
 
 $(document).ready(function() {
     $('a[disabled=disabled]').click(function(event){
@@ -63,4 +64,6 @@ $(document).ready(function() {
     $('body').smoothScroll({
         delegateSelector: 'a.smoothscroll'
     });
+
+    window.addEventListener("load", Pagy.init);
 });

app/controllers/admin/splashpages_controller.rb

@@ -50,7 +50,7 @@ module Admin
                                          :include_venue, :include_registrations,
                                          :include_tickets, :include_lodgings,
                                          :include_sponsors, :include_social_media,
-                                         :include_booths)
+                                         :include_booths, :include_happening_now)
     end
   end
 end

app/controllers/application_controller.rb

@@ -3,6 +3,7 @@
 class ApplicationController < ActionController::Base
   before_action :set_paper_trail_whodunnit
   include ApplicationHelper
+  include Pagy::Backend
   add_flash_types :error
   protect_from_forgery with: :exception, prepend: true
   before_action :store_location

app/controllers/conference_registrations_controller.rb

@@ -57,6 +57,8 @@ class ConferenceRegistrationsController < ApplicationController
         sign_in(@registration.user)
       end
 
+      MailblusterEditLeadJob.perform_later(@user, add_tags: ["snapcon-#{@conference.short_title}"])
+
       if @conference.tickets.visible.any? && !current_user.supports?(@conference)
         redirect_to conference_tickets_path(@conference.short_title),
                     notice: 'You are now registered and will be receiving E-Mail notifications.'
@@ -87,6 +89,7 @@ class ConferenceRegistrationsController < ApplicationController
 
   def destroy
     if @registration.destroy
+      MailblusterEditLeadJob.perform_later(@user, remove_tags: ["snapcon-#{@conference.short_title}"])
       redirect_to root_path,
                   notice: "You are not registered for #{@conference.title} anymore!"
     else

app/controllers/conferences_controller.rb

@@ -1,6 +1,10 @@
 # frozen_string_literal: true
 
+EVENTS_PER_PAGE = Rails.configuration.conference[:events_per_page]
+
 class ConferencesController < ApplicationController
+  include ConferenceHelper
+
   protect_from_forgery with: :null_session
   before_action :respond_to_options
   load_and_authorize_resource find_by: :short_title, except: :show
@@ -56,6 +60,13 @@ class ConferencesController < ApplicationController
       if splashpage.include_booths
         @booths = @conference.confirmed_booths.order('title')
       end
+      if splashpage.include_happening_now
+        events_schedules_list = get_happening_now_events_schedules(@conference)
+        @events_schedules_limit = EVENTS_PER_PAGE
+        @events_schedules_length = events_schedules_list.length
+        @pagy, @events_schedules = pagy_array(events_schedules_list, items: @events_schedules_limit, link_extra: 'data-remote="true"')
+        @happening_now_url = happening_now_conference_schedule_path(conference_id: @conference.short_title, format: :json)
+      end
     end
     if splashpage.include_registrations || splashpage.include_tickets
       @tickets = @conference.tickets.visible.order('price_cents')

app/controllers/schedules_controller.rb

@@ -1,6 +1,8 @@
 # frozen_string_literal: true
 
 class SchedulesController < ApplicationController
+  include ConferenceHelper
+
   load_and_authorize_resource
   before_action :respond_to_options
   load_resource :conference, find_by: :short_title
@@ -67,11 +69,13 @@ class SchedulesController < ApplicationController
   end
 
   def happening_now
-    @events_schedules = @program.selected_event_schedules(
-      includes: [:room, { event: %i[track event_type speakers submitter] }]
-    ).select(&:happening_now?)
-    @events_schedules = [] unless @events_schedules
+    @events_schedules = get_happening_now_events_schedules(@conference)
     @current_time = Time.now.in_time_zone(@conference.timezone)
+
+    respond_to do |format|
+      format.html
+      format.json { render json: @events_schedules.to_json(root: false, include: :event) }
+    end
   end
 
   def app

app/helpers/application_helper.rb

@@ -1,6 +1,7 @@
 # frozen_string_literal: true
 
 module ApplicationHelper
+  include Pagy::Frontend
   # Returns a string build from the start and end date of the given conference.
   #
   # If the conference is only one day long

app/helpers/conference_helper.rb

@@ -1,7 +1,7 @@
 # frozen_string_literal: true
 
-DEFAULT_LOGO = 'snapcon_logo.png'
-DEFAULT_COLOR = '#0B3559'
+DEFAULT_LOGO = Rails.configuration.conference[:default_logo_filename]
+DEFAULT_COLOR = Rails.configuration.conference[:default_color]
 
 module ConferenceHelper
   # Return true if only call_for_papers or call_for_tracks or call_for_booths is open
@@ -77,4 +77,12 @@ module ConferenceHelper
     end
     calendar
   end
+
+  def get_happening_now_events_schedules(conference)
+    events_schedules = conference.program.selected_event_schedules(
+      includes: [:room, { event: %i[track event_type speakers submitter] }]
+    ).select(&:happening_now?)
+    events_schedules ||= []
+    events_schedules
+  end
 end

app/jobs/mailbluster_create_lead_job.rb

@@ -0,0 +1,9 @@
+# frozen_string_literal: true
+
+class MailblusterCreateLeadJob < ApplicationJob
+  queue_as :default
+
+  def perform(user)
+    MailblusterManager.create_lead(user)
+  end
+end

app/jobs/mailbluster_delete_lead_job.rb

@@ -0,0 +1,7 @@
+class MailblusterDeleteLeadJob < ApplicationJob
+  queue_as :default
+
+  def perform(user)
+    MailblusterManager.delete_lead(user)
+  end
+end

app/jobs/mailbluster_edit_lead_job.rb

@@ -0,0 +1,9 @@
+# frozen_string_literal: true
+
+class MailblusterEditLeadJob < ApplicationJob
+  queue_as :default
+
+  def perform(user, add_tags: [], remove_tags: [], old_email: nil)
+    MailblusterManager.edit_lead(user, add_tags: add_tags, remove_tags: remove_tags, old_email: old_email)
+  end
+end

app/mailers/mailbot.rb

@@ -1,8 +1,9 @@
 # frozen_string_literal: true
 
-SNAPCON_BCC_ADDRESS = 'messages@snap.berkeley.edu'
 EMAIL_TEMPLATE = 'email_template'
-YTLF_TICKET_ID = 50
+
+SNAPCON_BCC_ADDRESS = Rails.configuration.mailbot[:bcc_address]
+YTLF_TICKET_ID = Rails.configuration.mailbot[:ytlf_ticket_id]
 
 class Mailbot < ActionMailer::Base
   helper ConferenceHelper

app/models/concerns/track_saved_changes.rb

@@ -0,0 +1,48 @@
+# https://github.com/ccmcbeck/after-commit
+module TrackSavedChanges
+  extend ActiveSupport::Concern
+
+  included do
+    # expose the details if consumer wants to do more
+    # attr_reader :ts_saved_changes_history, :ts_saved_changes_unfiltered
+    after_initialize :ts_reset_saved_changes
+    after_save :ts_track_saved_changes
+  end
+
+  # on initalize, but useful for fine grain control
+  def ts_reset_saved_changes
+    @ts_saved_changes_unfiltered = {}
+    @ts_saved_changes_history = []
+  end
+
+  # filter out any changes that result in the original value
+  def ts_saved_changes
+    @ts_saved_changes_unfiltered.reject { |_k, v| v[0] == v[1] }
+  end
+
+  private
+
+  # on save
+  def ts_track_saved_changes
+    # maintain an array of ActiveModel::Dirty.changes
+    @ts_saved_changes_history << previous_changes.dup
+    # accumulate the most recent changes
+    @ts_saved_changes_history.last.each_pair { |k, v| ts_track_saved_change k, v }
+  end
+
+  # v is an an array of [prev, current]
+  def ts_track_saved_change(key, value)
+    if @ts_saved_changes_unfiltered.key? key
+      @ts_saved_changes_unfiltered[key][1] = ts_track_saved_value value[1]
+    else
+      @ts_saved_changes_unfiltered[key] = value.dup
+    end
+  end
+
+  # type safe dup inspred by http://stackoverflow.com/a/20955038
+  def ts_track_saved_value(value)
+    value.dup
+  rescue TypeError
+    value
+  end
+end

app/models/event.rb

@@ -33,6 +33,8 @@
 class Event < ApplicationRecord
   include ActiveRecord::Transitions
   include RevisionCount
+  include FormatHelper
+
   has_paper_trail on: [:create, :update], ignore: [:updated_at, :guid, :week], meta: { conference_id: :conference_id }
 
   acts_as_commentable
@@ -337,6 +339,10 @@ class Event < ApplicationRecord
     time <=> other.time
   end
 
+  def serializable_hash(options = {})
+    super(options).merge('rendered_abstract' => markdown(abstract))
+  end
+
   private
 
   ##

app/models/event_schedule.rb

@@ -55,16 +55,19 @@ class EventSchedule < ApplicationRecord
   # True within `threshold` before and after the event.
   #
   def happening_now?(threshold = 30.minutes)
+    # TODO: Save start_time with local timezone info when making an event schedule
     in_tz_start = start_time.in_time_zone(timezone)
     in_tz_end = end_time.in_time_zone(timezone)
     in_tz_start -= in_tz_start.utc_offset
     in_tz_end -= in_tz_end.utc_offset
+
+    return false if in_tz_end < Time.now
+
     begin_range = Time.now - threshold
     end_range = Time.now + threshold
     event_time_range = in_tz_start..in_tz_end
     now_range = begin_range..end_range
-    # TODO: There's probably better logic.
-    event_time_range.overlaps?(now_range) && (in_tz_end > Time.now)
+    event_time_range.overlaps?(now_range)
   end
 
   def self.withdrawn_or_canceled_event_schedules(schedule_ids)

app/models/program.rb

@@ -195,6 +195,7 @@ class Program < ApplicationRecord
   # * +True+ -> If there is any event for the given date
   # * +False+ -> If there is not any event for the given date
   def any_event_for_this_date?(date)
+    return false if date.nil? || date == ''
     return false unless selected_schedule.present?
 
     parsed_date = DateTime.parse("#{date} 00:00").utc

app/models/splashpage.rb

@@ -11,6 +11,7 @@
 #  banner_photo_updated_at   :datetime
 #  include_booths            :boolean
 #  include_cfp               :boolean          default(FALSE)
+#  include_happening_now     :boolean
 #  include_lodgings          :boolean
 #  include_program           :boolean
 #  include_registrations     :boolean

app/models/user.rb

@@ -53,6 +53,7 @@ class UserDisabled < StandardError
 end
 
 class User < ApplicationRecord
+  include TrackSavedChanges
   rolify
   # prevent N+1 queries with has_cached_role? by preloading roles *always*
   default_scope { preload(:roles) }
@@ -80,6 +81,12 @@ class User < ApplicationRecord
 
   after_save :touch_events
 
+  # Note that using after_create_commit and after_update_commit does not work.
+  # See https://github.com/CactusPuppy/snapcon/pull/43#discussion_r609458034
+  after_commit :mailbluster_create_lead, on: :create
+  after_commit :mailbluster_delete_lead, on: :destroy
+  after_commit :mailbluster_update_lead, on: :update, if: ->(user){ ['name', 'email'].any? { |key| user.ts_saved_changes.key? key } }
+
   # add scope
   scope :comment_notifiable, ->(conference) {joins(:roles).where('roles.name IN (?)', [:organizer, :cfp]).where('roles.resource_type = ? AND roles.resource_id = ?', 'Conference', conference.id)}
 
@@ -361,12 +368,32 @@ class User < ApplicationRecord
     User.count == 1 && User.first.email == 'deleted@localhost.osem'
   end
 
+  # TODO: email_hash function for mailbluster
+  # def email_hash
+  #   Digest::MD5.hexdigest user.email
+  # end
+
   private
 
   def setup_role
     self.is_admin = true if User.empty?
   end
 
+  def mailbluster_create_lead
+    MailblusterCreateLeadJob.perform_later self
+    ts_reset_saved_changes
+  end
+
+  def mailbluster_delete_lead
+    MailblusterDeleteLeadJob.perform_later email
+    ts_reset_saved_changes
+  end
+
+  def mailbluster_update_lead
+    MailblusterEditLeadJob.perform_later(self, old_email: ts_saved_changes.fetch('email', [nil])[0])
+    ts_reset_saved_changes
+  end
+
   def touch_events
     event_users.each(&:touch)
   end

app/services/mailbluster_manager.rb

@@ -0,0 +1,40 @@
+class MailblusterManager
+  include HTTParty
+  base_uri 'https://api.mailbluster.com/api/leads/'
+  @auth_headers = {
+    headers: {
+      'Content-Type'  => 'application/json',
+      'Authorization' => ENV['MAILBLUSTER_API_KEY']
+    }
+  }
+
+  def self.query_api(method, path, body: {})
+    options = @auth_headers.merge(body: body.to_json)
+    send(method, path, options).parsed_response
+  end
+
+  def self.create_lead(user)
+    query_api(:post, '/', body: {
+                'email'            => user.email,
+                'firstName'        => user.name,
+                'overrideExisting' => true,
+                'subscribed'       => true,
+                'tags'             => [ENV['OSEM_NAME'] || 'snapcon']
+              })
+  end
+
+  def self.edit_lead(user, add_tags: [], remove_tags: [], old_email: nil)
+    email_hash = Digest::MD5.hexdigest(old_email.presence || user.email)
+    query_api(:put, "/#{email_hash}", body: {
+                'email'      => user.email,
+                'firstName'  => user.name,
+                'addTags'    => add_tags,
+                'removeTags' => remove_tags
+              })
+  end
+
+  def self.delete_lead(email)
+    email_hash = Digest::MD5.hexdigest email
+    query_api(:delete, "/#{email_hash}")
+  end
+end

app/views/admin/splashpages/_form.html.haml

@@ -25,6 +25,8 @@
                 = f.input :include_tracks, label: 'Include confirmed tracks', input_html: { checked: params[:action] == 'new' || @splashpage.try(:include_tracks) }
               %li
                 = f.input :include_booths, label: "Include confirmed #{(t'booth').pluralize}", input_html: { checked: params[:action] == 'new' || @splashpage.try(:include_booths) }
+              %li
+                = f.input :include_happening_now, label: 'Include events happening now', input_html: { checked: params[:action] == 'new' || @splashpage.try(:include_happening_now) }
 
           %li
             = f.input :include_registrations, label: 'Display the registration period', input_html: { checked: params[:action] == 'new' || @splashpage.try(:include_registrations) }

app/views/admin/splashpages/show.html.haml

@@ -27,6 +27,9 @@
             %li
               %i{ class: "fa-li #{icon_for_todo @splashpage.include_booths?}" }
               Include confirmed #{(t'booth').pluralize}
+            %li
+              %i{ class: "fa-li #{icon_for_todo @splashpage.include_happening_now?}" }
+              Include events happening now
         %li
           %i{ class: "fa-li #{icon_for_todo @splashpage.include_registrations?}" }
           Display the registration period

app/views/conferences/_about_and_happening_now.haml

@@ -0,0 +1,32 @@
+= content_for :happening_now do
+  #happening-now
+    = render 'happening_now', conference: conference,
+      events_schedules: events_schedules, pagy: pagy,
+      events_schedules_length: events_schedules_length,
+      events_schedules_limit: events_schedules_limit
+
+= content_for :about do
+  #about
+    .row
+      %h2.text-left{ style: 'margin-bottom:30px' } About the Conference
+      = markdown(conference.description, false)
+
+%section#about-and-happening-now
+  .container
+    .row
+      -# happening now events are displayed second in md or lg view
+      - if conference.splashpage.include_happening_now && conference.splashpage.include_program
+        - if conference.description.present?
+          .col-md-6.col-md-push-6.col-lg-4.col-lg-push-8
+            = yield :happening_now
+        - else
+          .col-md-12
+            = yield :happening_now
+      - if conference.description.present?
+        - if conference.splashpage.include_happening_now && conference.splashpage.include_program
+          .col-md-6.col-md-pull-6.col-lg-8.col-lg-pull-4
+            = yield :about
+        - else
+          .col-md-12
+            = yield :about
+  .trapezoid

app/views/conferences/_happening_now.haml

@@ -0,0 +1,12 @@
+- if conference.splashpage.include_program && conference.splashpage.include_happening_now
+  - if events_schedules.any?
+    .row
+      %h2.text-center{ style: 'margin-bottom:30px' } Happening Now
+    - events_schedules.each do |event_schedule|
+      = render 'schedules/event', conference: conference, event_schedule: event_schedule, event: event_schedule.event, is_brief: true
+    - if events_schedules_length > events_schedules_limit
+      .container{ style: 'width:100%; text-align:center' }
+        != pagy_bootstrap_nav_js(pagy)
+  - else
+    .row
+      %h3.text-center There are no events happening now.

app/views/conferences/_header.haml

@@ -26,11 +26,3 @@
                       - if venue.country != 'US'
                         •
                         = venue.country_name
-
-  - unless conference.description.blank?
-    %section#about
-      .container
-        .row
-          .col-md-8.col-md-offset-2
-            = markdown(conference.description, escape_html=false)
-      .trapezoid

app/views/conferences/show.html.haml

@@ -41,9 +41,16 @@
   - if @conference.code_of_conduct.present?
     = render 'code_of_conduct', organization: @conference.organization
 
-  -# header/description
+  -# header
   = render 'header', conference: @conference, venue: @conference.venue
 
+  -# description / happening now
+  - if @conference.splashpage.include_happening_now? || @conference.description.present?
+    = render 'about_and_happening_now', conference: @conference,
+      events_schedules: @events_schedules, pagy: @pagy,
+      events_schedules_length: @events_schedules_length,
+      events_schedules_limit: @events_schedules_limit
+
   -# calls for content, or program
   - if @conference.splashpage.include_cfp
     = render 'call_for_content', conference: @conference,

app/views/conferences/show.js.erb

@@ -0,0 +1,5 @@
+$('#happening-now').html("<%= j(render 'happening_now', conference: @conference,
+                                events_schedules: @events_schedules, pagy: @pagy,
+                                events_schedules_length: @events_schedules_length,
+                                events_schedules_limit: @events_schedules_limit)%>");
+Pagy.init(document.getElementById('happening-now'));

app/views/schedules/_event.html.haml

@@ -2,8 +2,9 @@
   - header_color = event.event_type&.color || '#f5f5f5'
   .trapezoid{ style: 'color: white; top: 12px; z-index: 100;' }
   .panel-heading{ style: "background-color: #{header_color}; color: #{ contrast_color(header_color) }; border-radius: 4px" }
-    - event.speakers_ordered.each do |speaker|
-      = image_tag speaker.profile_picture, class: 'img-circle pull-right',  alt: speaker.name, style: 'padding: 2px;'
+    - if !defined?(is_brief) || is_brief == false
+      - event.speakers_ordered.each do |speaker|
+        = image_tag speaker.profile_picture, class: 'img-circle pull-right',  alt: speaker.name, style: 'padding: 2px;'
 
     %p
       = canceled_replacement_event_label(event, event_schedule)
@@ -14,7 +15,8 @@
       %br
       %small{ style: "color: #{contrast_color(header_color)}" }
         = event.subtitle
-  .trapezoid{ style: "color: #{header_color}; top: 12px;" }
+
+  .trapezoid{ style: "color: #{header_color}; border-top-color: #{header_color}; top: 12px;" }
 
   .panel-body
     %h4
@@ -26,20 +28,21 @@
       = markdown(truncate(event.abstract, length: 400))
       -# TODO: More informative text or aria-label.
       = link_to 'more', conference_program_proposal_path(@conference.short_title, event.id) if event.abstract.length > 400
-    - if event_schedule.present?
-      = inyourtz(event_schedule.start_time) do
+    - if !defined?(is_brief) || is_brief == false
+      - if event_schedule.present?
+        = inyourtz(event_schedule.start_time) do
+          %span.track
+            %span.fa.fa-clock-o
+            %span.label{ style: 'background-color: grey' }
+              = event_schedule.start_time.strftime('%l:%M %P')
+              \-
+              = event_schedule.end_time.strftime('%l:%M %P')
         %span.track
-          %span.fa.fa-clock-o
+          %span.fa.fa-map-marker
           %span.label{ style: 'background-color: grey' }
-            = event_schedule.start_time.strftime('%l:%M %P')
-            \-
-            = event_schedule.end_time.strftime('%l:%M %P')
-      %span.track
-        %span.fa.fa-map-marker
-        %span.label{ style: 'background-color: grey' }
-          = event_schedule.room.name
-    - if event.track
-      %span.track
-        %span.fa.fa-road
-        %span.label{ style: "background-color: #{event.track.color}; color: #{ contrast_color(event.track.color) }" }
-          = event.track.name
+            = event_schedule.room.name
+      - if event.track
+        %span.track
+          %span.fa.fa-road
+          %span.label{ style: "background-color: #{event.track.color}; color: #{ contrast_color(event.track.color) }" }
+            = event.track.name

config/application.rb

@@ -66,6 +66,12 @@ module Osem
 
     config.active_job.queue_adapter = :delayed_job
 
+    config.conference = {
+      events_per_page:       (ENV['EVENTS_PER_PAGE'] || 3),
+      default_logo_filename: (ENV['DEFAULT_LOGO_FILENAME'] || 'snapcon_logo.png'),
+      default_color:         (ENV['DEFAULT_COLOR'] || '#0B3559')
+    }
+
     config.before_configuration do
       env_file = File.join(Rails.root, 'config', 'local_env.yml')
       if File.exist?(env_file)

config/environments/development.rb

@@ -44,6 +44,12 @@ Osem::Application.configure do
   # Set the secret key base if it's not set via other means
   config.secret_key_base ||= 'f4be765bc98e516de82ac01daa8f8aa11c5ca13cb6c911887851ac89457b6c0b056b2361a21b5c08926c9386e0f91eef84fc0b103d522bf00bc0c78ea8ce7c58'
 
+  # Test mailbot settings
+  config.mailbot = {
+    ytlf_ticket_id: 50,
+    bcc_address:    'test@test.com'
+  }
+
   # Use omniauth mock credentials
   OmniAuth.config.test_mode = true
 
@@ -114,6 +120,5 @@ Osem::Application.configure do
     end
   end
 
-  config.assets.precompile += ['mailbot.css']
   config.active_record.verbose_query_logs = true
 end

config/environments/production.rb

@@ -101,4 +101,10 @@ Osem::Application.configure do
 
   # Set the secret_key_base from the env, if not set by any other means
   config.secret_key_base ||= ENV["SECRET_KEY_BASE"]
+
+  # Mailbot settings
+  config.mailbot = {
+    ytlf_ticket_id: (ENV['YTLF_TICKET_ID'] || 50),
+    bcc_address:    ENV['OSEM_MESSAGE_BCC_ADDRESS']
+  }
 end

config/environments/test.rb

@@ -52,5 +52,9 @@ Osem::Application.configure do
     ActiveSupport::Deprecation.silenced = true
   end
 
-  config.assets.precompile += ['mailbot.css']
+  # Test mailbot settings
+  config.mailbot = {
+    ytlf_ticket_id: 50,
+    bcc_address:    'test@test.com'
+  }
 end

config/initializers/assets.rb

@@ -9,3 +9,4 @@ Rails.application.config.assets.version = '1.0'
 # Precompile additional assets.
 # application.js, application.css, and all non-JS/CSS in app/assets folder are already added.
 # Rails.application.config.assets.precompile += %w( search.js )
+Rails.application.config.assets.precompile += ['mailbot.css']

config/initializers/pagy.rb

@@ -0,0 +1,164 @@
+# frozen_string_literal: true
+
+# Pagy initializer file (4.1.0)
+# Customize only what you really need and notice that Pagy works also without any of the following lines.
+# Should you just cherry pick part of this file, please maintain the require-order of the extras
+
+# Extras
+# See https://ddnexus.github.io/pagy/extras
+
+# Backend Extras
+
+# Array extra: Paginate arrays efficiently, avoiding expensive array-wrapping and without overriding
+# See https://ddnexus.github.io/pagy/extras/array
+require 'pagy/extras/array'
+
+# Countless extra: Paginate without any count, saving one query per rendering
+# See https://ddnexus.github.io/pagy/extras/countless
+# require 'pagy/extras/countless'
+# Pagy::VARS[:cycle] = false    # default
+
+# Elasticsearch Rails extra: Paginate `ElasticsearchRails::Results` objects
+# See https://ddnexus.github.io/pagy/extras/elasticsearch_rails
+# default :pagy_search method: change only if you use
+# also the searchkick extra that defines the same
+# VARS[:elasticsearch_rails_search_method] = :pagy_search
+# require 'pagy/extras/elasticsearch_rails'
+
+# Searchkick extra: Paginate `Searchkick::Results` objects
+# See https://ddnexus.github.io/pagy/extras/searchkick
+# default :pagy_search method: change only if you use
+# also the elasticsearch_rails extra that defines the same
+# VARS[:searchkick_search_method] = :pagy_search
+# require 'pagy/extras/searchkick'
+
+# Frontend Extras
+
+# Bootstrap extra: Add nav, nav_js and combo_nav_js helpers and templates for Bootstrap pagination
+# See https://ddnexus.github.io/pagy/extras/bootstrap
+require 'pagy/extras/bootstrap'
+
+# Bulma extra: Add nav, nav_js and combo_nav_js helpers and templates for Bulma pagination
+# See https://ddnexus.github.io/pagy/extras/bulma
+# require 'pagy/extras/bulma'
+
+# Foundation extra: Add nav, nav_js and combo_nav_js helpers and templates for Foundation pagination
+# See https://ddnexus.github.io/pagy/extras/foundation
+# require 'pagy/extras/foundation'
+
+# Materialize extra: Add nav, nav_js and combo_nav_js helpers for Materialize pagination
+# See https://ddnexus.github.io/pagy/extras/materialize
+# require 'pagy/extras/materialize'
+
+# Navs extra: Add nav_js and combo_nav_js javascript helpers
+# Notice: the other frontend extras add their own framework-styled versions,
+# so require this extra only if you need the unstyled version
+# See https://ddnexus.github.io/pagy/extras/navs
+# require 'pagy/extras/navs'
+
+# Semantic extra: Add nav, nav_js and combo_nav_js helpers for Semantic UI pagination
+# See https://ddnexus.github.io/pagy/extras/semantic
+# require 'pagy/extras/semantic'
+
+# UIkit extra: Add nav helper and templates for UIkit pagination
+# See https://ddnexus.github.io/pagy/extras/uikit
+# require 'pagy/extras/uikit'
+
+# Multi size var used by the *_nav_js helpers
+# See https://ddnexus.github.io/pagy/extras/navs#steps
+# Pagy::VARS[:steps] = { 0 => [2,3,3,2], 540 => [3,5,5,3], 720 => [5,7,7,5] }   # example
+
+# Feature Extras
+
+# Headers extra: http response headers (and other helpers) useful for API pagination
+# See http://ddnexus.github.io/pagy/extras/headers
+# require 'pagy/extras/headers'
+# Pagy::VARS[:headers] = { page: 'Current-Page', items: 'Page-Items', count: 'Total-Count', pages: 'Total-Pages' }     # default
+
+# Support extra: Extra support for features like: incremental, infinite, auto-scroll pagination
+# See https://ddnexus.github.io/pagy/extras/support
+# require 'pagy/extras/support'
+
+# Items extra: Allow the client to request a custom number of items per page with an optional selector UI
+# See https://ddnexus.github.io/pagy/extras/items
+# require 'pagy/extras/items'
+# Pagy::VARS[:items_param] = :items    # default
+# Pagy::VARS[:max_items]   = 100       # default
+
+# Overflow extra: Allow for easy handling of overflowing pages
+# See https://ddnexus.github.io/pagy/extras/overflow
+# require 'pagy/extras/overflow'
+# Pagy::VARS[:overflow] = :empty_page    # default  (other options: :last_page and :exception)
+
+# Metadata extra: Provides the pagination metadata to Javascript frameworks like Vue.js, react.js, etc.
+# See https://ddnexus.github.io/pagy/extras/metadata
+# you must require the shared internal extra (BEFORE the metadata extra) ONLY if you need also the :sequels
+# require 'pagy/extras/shared'
+# require 'pagy/extras/metadata'
+# For performance reason, you should explicitly set ONLY the metadata you use in the frontend
+# Pagy::VARS[:metadata] = [:scaffold_url, :count, :page, :prev, :next, :last]    # example
+
+# Trim extra: Remove the page=1 param from links
+# See https://ddnexus.github.io/pagy/extras/trim
+# require 'pagy/extras/trim'
+
+# Pagy Variables
+# See https://ddnexus.github.io/pagy/api/pagy#variables
+# All the Pagy::VARS are set for all the Pagy instances but can be overridden
+# per instance by just passing them to Pagy.new or the #pagy controller method
+
+# Instance variables
+# See https://ddnexus.github.io/pagy/api/pagy#instance-variables
+# Pagy::VARS[:items] = 20                                   # default
+
+# Other Variables
+# See https://ddnexus.github.io/pagy/api/pagy#other-variables
+# Pagy::VARS[:size]       = [1,4,4,1]                       # default
+# Pagy::VARS[:page_param] = :page                           # default
+# Pagy::VARS[:params]     = {}                              # default
+# Pagy::VARS[:anchor]     = '#anchor'                       # example
+# Pagy::VARS[:link_extra] = 'data-remote="true"'            # example
+
+# Rails
+
+# Rails: extras assets path required by the helpers that use javascript
+# (pagy*_nav_js, pagy*_combo_nav_js, and pagy_items_selector_js)
+# See https://ddnexus.github.io/pagy/extras#javascript
+Rails.application.config.assets.paths << Pagy.root.join('javascripts')
+
+# I18n
+
+# Pagy internal I18n: ~18x faster using ~10x less memory than the i18n gem
+# See https://ddnexus.github.io/pagy/api/frontend#i18n
+# Notice: No need to configure anything in this section if your app uses only "en"
+# or if you use the i18n extra below
+#
+# Examples:
+# load the "de" built-in locale:
+# Pagy::I18n.load(locale: 'de')
+#
+# load the "de" locale defined in the custom file at :filepath:
+# Pagy::I18n.load(locale: 'de', filepath: 'path/to/pagy-de.yml')
+#
+# load the "de", "en" and "es" built-in locales:
+# (the first passed :locale will be used also as the default_locale)
+# Pagy::I18n.load({locale: 'de'},
+#                 {locale: 'en'},
+#                 {locale: 'es'})
+#
+# load the "en" built-in locale, a custom "es" locale,
+# and a totally custom locale complete with a custom :pluralize proc:
+# (the first passed :locale will be used also as the default_locale)
+# Pagy::I18n.load({locale: 'en'},
+#                 {locale: 'es', filepath: 'path/to/pagy-es.yml'},
+#                 {locale: 'xyz',  # not built-in
+#                  filepath: 'path/to/pagy-xyz.yml',
+#                  pluralize: lambda{|count| ... } )
+
+# I18n extra: uses the standard i18n gem which is ~18x slower using ~10x more memory
+# than the default pagy internal i18n (see above)
+# See https://ddnexus.github.io/pagy/extras/i18n
+# require 'pagy/extras/i18n'
+
+# Default i18n key
+# Pagy::VARS[:i18n_key] = 'pagy.item_name'   # default

db/migrate/20210401050437_add_include_happening_now_to_splashpages.rb

@@ -0,0 +1,5 @@
+class AddIncludeHappeningNowToSplashpages < ActiveRecord::Migration[5.2]
+  def change
+    add_column :splashpages, :include_happening_now, :boolean
+  end
+end

db/schema.rb

@@ -10,7 +10,7 @@
 #
 # It's strongly recommended that you check this file into your version control system.
 
-ActiveRecord::Schema.define(version: 2021_03_06_185903) do
+ActiveRecord::Schema.define(version: 2021_04_01_050437) do
 
   # These are extensions that must be enabled in order to support this database
   enable_extension "plpgsql"
@@ -442,6 +442,7 @@ ActiveRecord::Schema.define(version: 2021_03_06_185903) do
     t.boolean "include_cfp", default: false
     t.boolean "include_booths"
     t.boolean "shuffle_highlights", default: false, null: false
+    t.boolean "include_happening_now"
   end
 
   create_table "sponsors", force: :cascade do |t|

spec/controllers/conferences_controller_spec.rb

@@ -48,5 +48,4 @@ describe ConferencesController do
       expect(response.response_code).to eq(200)
     end
   end
-
 end

spec/controllers/schedules_controller_spec.rb

@@ -27,4 +27,49 @@ describe SchedulesController do
       end
     end
   end
+
+  describe 'GET #happening_now' do
+    let!(:conference2) { create(:full_conference, start_date: 1.day.ago, end_date: 7.days.from_now, start_hour: 0, end_hour: 24) }
+    let!(:program) { conference2.program }
+    let!(:selected_schedule) { create(:schedule, program: program) }
+    let!(:scheduled_event1) do
+      program.update_attributes!(selected_schedule: selected_schedule)
+      create(:event, program: program, state: 'confirmed', abstract: '`markdown`')
+    end
+    let!(:event_schedule1) { create(:event_schedule, event: scheduled_event1, schedule: selected_schedule, start_time: Time.now.in_time_zone(conference2.timezone).strftime('%a, %d %b %Y %H:%M:%S')) }
+    let!(:scheduled_event2) do
+      program.update_attributes!(selected_schedule: selected_schedule)
+      create(:event, program: program, state: 'confirmed')
+    end
+    let!(:event_schedule2) { create(:event_schedule, event: scheduled_event2, schedule: selected_schedule, start_time: (Time.now.in_time_zone(conference2.timezone) + 1.hour).strftime('%a, %d %b %Y %H:%M:%S')) }
+
+    context 'html' do
+      before :each do
+        get :happening_now, params: { conference_id: conference2.short_title }
+      end
+
+      it 'has 200 status code' do
+        expect(response).to be_success
+      end
+    end
+
+    context 'json' do
+      before :each do
+        get :happening_now, format: :json, params: { conference_id: conference2.short_title }
+      end
+
+      it 'has 200 status code' do
+        expect(response).to be_success
+      end
+
+      it 'returns the events that are happening now' do
+        expect(response.body).to include(event_schedule1.to_json(include: :event))
+        expect(response.body).not_to include(event_schedule2.to_json(include: :event))
+      end
+
+      it 'contains the rendered markdown in HTML of events that are happening now' do
+        expect(response.body).to include('code')
+      end
+    end
+  end
 end

spec/datatables/user_datatable_spec.rb

@@ -3,7 +3,7 @@
 require 'spec_helper'
 
 describe UserDatatable do
-  subject! do
+  subject!(:user_datatable) do
     described_class.new(view)
   end
 
@@ -92,7 +92,9 @@ describe UserDatatable do
 
   context 'outputs' do
     let(:user) { User.first }
-    let(:output) { subject.as_json }
+    let(:output) { user_datatable.as_json }
+
+    before { skip('Investigate CI failures') }
 
     it 'recordsTotal' do
       expect(output[:recordsTotal]).to eq(1)

spec/factories/splashpages.rb

@@ -11,6 +11,7 @@
 #  banner_photo_updated_at   :datetime
 #  include_booths            :boolean
 #  include_cfp               :boolean          default(FALSE)
+#  include_happening_now     :boolean
 #  include_lodgings          :boolean
 #  include_program           :boolean
 #  include_registrations     :boolean
@@ -44,6 +45,7 @@ FactoryBot.define do
       include_sponsors { true }
       include_lodgings { true }
       include_cfp { true }
+      include_happening_now { true }
     end
   end
 end

spec/factories/users.rb

@@ -80,8 +80,30 @@ FactoryBot.define do
     last_sign_in_at { Date.today }
     is_disabled { false }
 
+    after(:build) do |user|
+      url_mailbluster = 'https://api.mailbluster.com/api/leads/'
+      response_body = "{
+        \"message\": \"Lead created\",
+        \"lead\": {
+          \"id\": 329395,
+          \"firstName\": \"#{user.name}\",
+          \"lastName\": \"\",
+          \"fullName\": \"#{user.name}\",
+          \"email\": \"#{user.email}\",
+          \"subscribed\": true,
+          \"tags\": [
+            #{ENV['OSEM_NAME'] || 'snapcon'}
+          ],
+        }
+      }"
+      WebMock.stub_request(:post, url_mailbluster)
+        .to_return(body: response_body, status: 200)
+    end
+    # Called by every user creation
+
     after(:create) do |user|
       user.is_admin = false
+
       # save with bang cause we want change in DB and not just in object instance
       user.save!
     end

spec/models/event_spec.rb

@@ -448,4 +448,14 @@ describe Event do
       end
     end
   end
+
+  describe '#serializable_hash' do
+    let(:event2) { create(:event, program: conference.program, abstract: '`markdown`') }
+
+    context 'serializes event correctly' do
+      it 'contains rendered markdown in HTML' do
+        expect(event2.serializable_hash['rendered_abstract']).to include('<code>markdown</code>')
+      end
+    end
+  end
 end

spec/services/mailbluster_manager_spec.rb

@@ -0,0 +1,140 @@
+# frozen_string_literal: true
+
+require 'spec_helper'
+require 'webmock/rspec'
+
+describe MailblusterManager, type: :model do
+  let!(:user) { create(:user) }
+
+  before(:each) do
+    WebMock.reset_executed_requests!
+  end
+
+  url = 'https://api.mailbluster.com/api/leads/'
+
+  describe 'query_api' do
+    it 'translates :get to a get request' do
+      stub_request(:get, url)
+      described_class.query_api(:get, '/')
+
+      expect(WebMock).to have_requested(:get, url)
+    end
+
+    it 'translates :post to a post request' do
+      stub_request(:post, url + 'path')
+      described_class.query_api(:post, '/path', body: { key: 'value' })
+
+      expect(WebMock).to have_requested(:post, url + 'path').with(body: { key: 'value' })
+    end
+  end
+
+  describe 'create_lead' do
+    it 'makes a post request to Mailbluster\'s API and gets the correct response' do
+      response_body = "{
+        \"message\": \"Lead created\",
+        \"lead\": {
+          \"id\": 329395,
+          \"firstName\": \"#{user.name}\",
+          \"lastName\": \"\",
+          \"fullName\": \"#{user.name}\",
+          \"email\": \"#{user.email}\",
+          \"subscribed\": true,
+          \"tags\": [
+            #{ENV['OSEM_NAME'] || 'snapcon'}
+          ],
+        }
+      }"
+      stub_request(:post, url)
+        .to_return(body: response_body, status: 200)
+      response = described_class.create_lead(user)
+
+      expect(WebMock).to have_requested(:post, url).with(body: {
+        'email':            user.email,
+        'firstName':        user.name,
+        'overrideExisting': true,
+        'subscribed':       true,
+        'tags':             [ENV['OSEM_NAME'] || 'snapcon']
+      }.to_json)
+      expect(response).to eq(response_body)
+    end
+  end
+
+  describe 'edit_lead' do
+    it 'makes a put request to Mailbluster\'s API to change the email and gets the correct response' do
+      response_body = "{
+        \"message\": \"Lead updated\",
+        \"lead\": {
+          \"id\": 329395,
+          \"firstName\": \"#{user.name}\",
+          \"lastName\": \"\",
+          \"fullName\": \"#{user.name}\",
+          \"email\": \"#{user.email}\",
+          \"subscribed\": true,
+          \"tags\": [
+            #{ENV['OSEM_NAME'] || 'snapcon'}
+          ],
+        }
+      }"
+      old_email = user.email
+      user.email = 'new@new.org'
+      user.save
+      stub_request(:put, url + Digest::MD5.hexdigest(old_email))
+        .to_return(body: response_body, status: 200)
+      response = described_class.edit_lead(user, old_email: old_email)
+
+      expect(WebMock).to have_requested(:put, url + Digest::MD5.hexdigest(old_email)).with(body: {
+        'email':      user.email,
+        'firstName':  user.name,
+        'addTags':    [],
+        'removeTags': []
+      }.to_json)
+      expect(response).to eq(response_body)
+    end
+
+    it 'makes a put request to Mailbluster\'s API to add a tag and gets the correct response' do
+      response_body = "{
+        \"message\": \"Lead updated\",
+        \"lead\": {
+          \"id\": 329395,
+          \"firstName\": \"#{user.name}\",
+          \"lastName\": \"\",
+          \"fullName\": \"#{user.name}\",
+          \"email\": \"#{user.email}\",
+          \"subscribed\": true,
+          \"tags\": [
+            #{ENV['OSEM_NAME'] || 'snapcon'}, '2021'
+          ],
+        }
+      }"
+      stub_request(:put, url + Digest::MD5.hexdigest(user.email))
+        .to_return(body: response_body, status: 200)
+      add_tags = ['2021']
+      response = described_class.edit_lead(user, add_tags: add_tags)
+
+      expect(WebMock).to have_requested(:put, url + Digest::MD5.hexdigest(user.email)).with(body: {
+        'email':      user.email,
+        'firstName':  user.name,
+        'addTags':    add_tags,
+        'removeTags': []
+      }.to_json)
+      expect(response).to eq(response_body)
+    end
+  end
+
+  describe 'delete_lead' do
+    it 'correctly requests the right URL and gets a valid response' do
+      email_hash = Digest::MD5.hexdigest user.email
+      response_body = "{
+        \"message\":\"Lead deleted\",
+        \"leadHash\":\"#{email_hash}\"
+      }"
+      lead_url = url + email_hash.to_s
+      stub_request(:delete, lead_url)
+        .to_return(body: response_body)
+      response = described_class.delete_lead(user.email)
+
+      expect(WebMock).to have_requested(:delete, lead_url)
+      expect(response).to eq(response_body)
+    end
+  end
+end

spec/support/external_request.rb

@@ -11,6 +11,7 @@ RSpec.configure do |config|
   config.before(:each) do
     mock_commercial_request
     mock_image_request
+    mock_default_mailbluster
   end
 end
 
@@ -39,3 +40,7 @@ def mock_image_request
   WebMock.stub_request(:post, 'https://api.cloudinary.com/v1_1/snapcon/image/destroy')
     .to_return(status: 200, body: {}.to_json, headers: {})
 end
+
+def mock_default_mailbluster
+  WebMock.stub_request(:any, /api.mailbluster.com/)
+end