create mailer and worker for updated discussions

app/assets/stylesheets/discussions.scss

@@ -1,5 +1,10 @@
 .user-discussion-card{
   width: 100%;
+
+  &:hover{
+    box-shadow: 1px 1px 1px 1px lightgrey;
+  }
+
   .existing-profile-image{
     width: 18px;
 
@@ -21,6 +26,8 @@
 
   .discussion-messages-list{
     margin-bottom: 5px;
+    max-height: 250px;
+    overflow-y: scroll;
 
     li{
       padding: 0;

app/controllers/discussions_controller.rb

@@ -10,6 +10,13 @@ def create
     @discussion.user = current_user
 
     @discussion.save
+
+    DiscussionFollower.find_or_create_by(user_id: current_user.id, discussion_id: @discussion.id)
+
+    if (@discussion.parent_type == 'SpeakerResource')
+      DiscussionFollower.find_or_create_by(user_id: @discussion.parent.user.id, discussion_id: @discussion.id)
+    end
+
   end
 
 

app/controllers/user_messages_controller.rb

@@ -8,6 +8,13 @@ def create
     @user_message.user = current_user
 
     @user_message.save
+
+    if (@user_message.parent_type == 'Discussion')
+      #   add the user to follow that discussion
+      DiscussionFollower.find_or_create_by(user_id: current_user.id, discussion_id: @user_message.parent_id)
+
+    end
+
   end
 
 

app/mailers/event_communication_mailer.rb

@@ -128,6 +128,18 @@ def comment_reply_email(user, comment, event)
         to: @user.email,
         subject: "#{@event.name} :: #{@replying_user.name} :: New Comment"
     )
+  end
+
+
+  def discussions_updated_email(user, discussions)
+
+    @user = user
+    @discussions = discussions
+
+    mail(
+        to: @user.email,
+        subject: 'Communities :: Discussion Updates On Sessions You Follow'
+    )
 
   end
 

app/models/data_form_entity_response_group.rb

@@ -11,6 +11,9 @@ class DataFormEntityResponseGroup < ApplicationRecord
   has_one :speaker_resource
 
 
+  delegate :event, :to => :event_data_form_entity_group, :allow_nil => true
+
+
   # setting the default value of registration_status
   attribute :registration_status_id, :integer, default: RegistrationStatus.find_by(name: "registered").id
 

app/models/discussion.rb

@@ -4,6 +4,7 @@ class Discussion < ApplicationRecord
 
 
   has_many :user_messages, as: :parent
+  has_many :discussion_followers
 
 
 end

app/models/speaker_resource.rb

@@ -5,5 +5,7 @@ class SpeakerResource < ApplicationRecord
 
 
   delegate :user, :to => :data_form_entity_response_group, :allow_nil => true
+  delegate :event, :to => :data_form_entity_response_group, :allow_nil => true
+
 
 end

app/models/user.rb

@@ -18,6 +18,7 @@ class User < ApplicationRecord
   has_many :user_event_locations
   has_many :fixed_email_edfegs
   has_many :event_updates
+  has_many :discussion_followers
 
   has_one_attached :profile_image
 

app/views/mailers/event_communication_mailer/discussions_updated_email.html.erb

@@ -0,0 +1,50 @@
+
+<table style="width: 550px; margin: 0 auto; background-color: white; border-radius: 5px; padding: 25px;">
+  <tbody>
+
+  <tr>
+    <td>
+      <p>Hi <%= @user.name %>!</p>
+      <p>
+        Here's the list of your followed discussions which have updates!
+      </p>
+      <div style="text-align: center">
+      </div>
+      <div>
+        <ul style="padding: 0 2px;">
+          <% @discussions.group_by(&:parent).each do |parent, discussions| %>
+            <li style="list-style: none; padding: 3px; background: #84f1ff12;">
+              <h4> Session :: <%= parent.title.blank? ? parent.event.name : parent.title %></h4>
+              <ul style="padding: 0;">
+                <% discussions.each do |discussion| %>
+                <li style="list-style: none; padding: 5px; background: #d3d3d33b; border-bottom: 1px dotted lightgrey;">
+                  <p style="font-weight: bold; margin: 0;">
+                    <%= discussion.topic %>
+                    <br>
+                    <small style="background-color: #f99952; color: white; border-radius: 15px; padding: 2px 5px;">
+                      <% if discussion.discussion_followers.length == 1 %>
+                      New!
+                      <% else %>
+                      <%= discussion.discussion_followers.length %> Followers
+                      <% end %>
+                    </small>
+                  </p>
+                  <p style="margin: 0;">
+                    <small>
+                      <%= simple_format(discussion.description) %>
+                    </small>
+                  </p>
+                </li>
+                <% end %>
+              </ul>
+            </li>
+          <% end %>
+        </ul>
+      </div>
+
+    </td>
+  </tr>
+
+  </tbody>
+
+</table>

app/views/speaker_resources/session_discussions.html.erb

@@ -51,7 +51,7 @@
   <div class="current-discussions">
     <% if allowed_view?(:discussions, :create) %>
     <button type="button" class="btn btn-primary mb-3" data-toggle="modal" data-target="#new-discussion-modal">
-      Ask The Speaker
+      Ask <%= @resource.user.name %>!
     </button>
     <% else %>
     <%= link_to "Sign In / Sign Up To Create Discussion", user_google_oauth2_omniauth_authorize_path, class: 'btn btn-primary mb-3' %>

app/workers/discussion_messages_worker.rb

@@ -0,0 +1,24 @@
+class DiscussionMessagesWorker
+  @queue = :discussion_messages_mails
+
+  # send an email for all the new messages to the speaker and the person who created the discussion
+  # this email needs to be sent exactly at 11.59pm everyday for perfect functioning
+  def self.perform
+  #   get all the discussions which were created from the last time
+  discussions = Discussion.where(created_at: Time.now.beginning_of_day..Time.now)
+
+  #   get all the messages which were created from the last time
+  messages = UserMessage.includes(:user).where(created_at: Time.now.beginning_of_day..Time.now, parent_type: "Discussion")
+
+
+    all_discussion_ids = (discussions.map(&:id) + messages.map(&:parent_id)).uniq
+  #   get all the discussion followers and send them an update about all these discussions updated
+    DiscussionFollower.where(discussion_id: all_discussion_ids).group_by(&:user).each do |user, followers|
+      discussions = Discussion.where(id: followers.map(&:discussion_id)).uniq
+      EventCommunicationMailer.discussions_updated_email(user, discussions).deliver_now
+    end
+
+
+
+  end
+end

db/migrate/20181224154449_add_send_discussion_mails_to_users.rb

@@ -0,0 +1,5 @@
+class AddSendDiscussionMailsToUsers < ActiveRecord::Migration[5.2]
+  def change
+    add_column :users, :send_discussion_mails, :boolean, default: true
+  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: 2018_12_18_010416) do
+ActiveRecord::Schema.define(version: 2018_12_24_154449) do
 
   # These are extensions that must be enabled in order to support this database
   enable_extension "plpgsql"
@@ -462,6 +462,7 @@
     t.text "linkedin"
     t.text "github"
     t.text "twitter"
+    t.boolean "send_discussion_mails", default: true
     t.index ["confirmation_token"], name: "index_users_on_confirmation_token", unique: true
     t.index ["email"], name: "index_users_on_email", unique: true
     t.index ["reset_password_token"], name: "index_users_on_reset_password_token", unique: true

test/mailers/previews/event_communication_mailer_preview.rb

@@ -46,4 +46,10 @@ def comment_reply_email
     )
   end
 
+
+  def discussions_updated_email
+    EventCommunicationMailer.discussions_updated_email(SpeakerResource.last.user, Discussion.all.limit(25))
+
+  end
+
 end