Digest for Unmoderated Notes

app/controllers/admin_controller.rb

@@ -371,6 +371,11 @@ def queue
     end
   end
 
+  def test_digest_email_spam
+    DigestSpamJob.perform_async(0)
+    redirect_to "/spam"
+  end
+
   def smtp_test
     require 'socket'
 

app/jobs/digest_spam_job.rb

@@ -0,0 +1,15 @@
+class DigestSpamJob
+  include Sidekiq::Worker
+  def perform(frequency_digest)
+    if frequency_digest.zero?
+      tag_digest = 'digest:daily'
+    elsif frequency_digest == 1
+      tag_digest = 'digest:weekly'
+    end
+    users = User.where(role: %w(moderator admin))
+        .includes(:user_tags)
+        .where('user_tags.value=?', tag_digest)
+        .references(:user_tags)
+    users.each(&:send_digest_email_spam)
+  end
+end

app/mailers/admin_mailer.rb

@@ -120,4 +120,15 @@ def notify_moderators_of_spam(node, moderator)
       subject: subject
     )
   end
+
+  def send_digest_spam(nodes, frequency_digest)
+    if frequency_digest == User::Frequency::DAILY
+      @subject = 'Your daily digest for moderation'
+    elsif frequency_digest == User::Frequency::WEEKLY
+      @subject = 'Your weekly digest for moderation'
+    end
+    moderators = User.where(role: %w(moderator admin)).collect(&:email)
+    @nodes = nodes
+    mail(to: moderators, subject: @subject)
+  end
 end

app/models/user.rb

@@ -268,6 +268,23 @@ def content_followed_in_period(start_time, end_time, node_type = 'note', include
     .distinct
   end
 
+  def unmoderated_in_period(start_time, end_time)
+    tag_following = TagSelection.where(following: true, user_id: uid)
+    ids = []
+    tag_following.each do |tagname|
+      ids += NodeTag.where(tid: tagname.tid).collect(&:nid)
+    end
+    range = "(created >= #{start_time.to_i} AND created <= #{end_time.to_i})"
+    Node.where(nid: ids)
+    .includes(:revision, :tag)
+    .references(:node_revision)
+    .where('node.status = 4')
+    .where(type: 'note')
+    .where(range)
+    .order('node_revisions.timestamp DESC')
+    .distinct
+  end
+
   def social_link(site)
     return nil unless has_power_tag(site)
 
@@ -356,6 +373,19 @@ def send_digest_email
     end
   end
 
+  def send_digest_email_spam
+    if has_tag('digest:weekly')
+      @frequency_digest = Frequency::WEEKLY
+      @nodes_unmoderated = unmoderated_in_period(1.week.ago, Time.current)
+    else
+      @frequency_digest = Frequency::DAILY
+      @nodes_unmoderated = unmoderated_in_period(1.day.ago, Time.current)
+    end
+    if @nodes_unmoderated.size.positive?
+      AdminMailer.send_digest_spam(@nodes_unmoderated, @frequency_digest).deliver_now
+    end
+ end
+
   def tag_counts
     tags = {}
     Node.order('nid DESC').where(type: 'note', status: 1, uid: id).limit(20).each do |node|

app/views/admin_mailer/send_digest_spam.html.erb

@@ -0,0 +1,39 @@
+<header style="margin:0 auto; text-align:center; width:100%;">
+  <img src="https://avatars2.githubusercontent.com/u/4621650?s=200&v=4">
+  <p style="font-size:1.5em; color:blue;">[Public Lab] <%= @subject %></p>
+  <p style="font-size:1em; color:blue;"><%= Time.now.strftime("%B %-d %Y") %></p>
+  <p style="font-size:1em; font-family:sans-serif; margin-bottom:0; color:grey;">Unmoderated Notes at <a href="https://publiclab.org" style="color:green; text-decoration: none;">PublicLab.org</a></p>
+  <hr style="height:1px; background-color:black; width:50%; background-color:green;">
+</header>
+
+<ul style="list-style-type:none; height:auto; font-family:sans-serif;width:auto;">
+    <% @nodes.each do |n| %>
+        <li style="position:relative; height:auto; width:90vw;">
+            <div style="padding:3vh 0 0 5vw ;">
+                <a style="text-decoration:none; color:black; font-weight:500; font-size:1.5em; " href="<%= ActionMailer::Base.default_url_options[:host] + n.path %>"><%= n.title %></a>
+            </div> 
+            <table style="padding-left:5vw; font-size:1em;width:70vw">  
+                <tbody> <tr><td style="width:8vh;">
+                    <% if n.author.photo? %>
+                        <img style="width:7vh; height:7vh; border-radius:50%; padding-top:2vh" src="https://<%= ActionMailer::Base.default_url_options[:host] %><%= n.author.photo_path(:thumb) %>"/>
+                    <% else %>
+                        <img style="width:7vh; height:7vh;border-radius:50%;padding-top:2vh;" src="https://www.gravatar.com/avatar/1aedb8d9dc4751e229a335e371db8058"/>
+                    <% end %>
+                </td>
+                <td style= "font-size: 2vh;">
+                    <p style="font-weight:500; "><%= n.author.username.capitalize %> </p>
+                    <span style="color:#999;font-weight:500;">created at <%= n.created_at.strftime("%B %-d %Y") %></span>
+                </td></tr>
+            </table>
+            <div style="padding-left:5vw;">
+                <p style="color:black; font-size:1.0em; line-height: 1.6;"><%= n.body.truncate(300) %></p>
+            </div>
+            <a style="color:green; text-decoration:none; padding-left:5vw" href="https://<%= ActionMailer::Base.default_url_options[:host] %>/moderate/publish/<%= n.id %>">Approve</a>   <a style="color:red; text-decoration:none;"href="https://<%= ActionMailer::Base.default_url_options[:host] %>/moderate/spam/<%= n.id %>">Spam</a></div>
+            <hr style="border:none; height:1px; width: 45%; background-color:grey; margin-top:2%;">
+        </li>
+    <% end %>
+</ul>
+<div style="margin:5% 0 0 8vw; font-size:1em;">
+    <p style=" text-decoration:none;">Click <a style="color:blue; text-decoration:none;"href="https://<%= ActionMailer::Base.default_url_options[:host] %>/subscriptions">here</a> to choose your followed topics</p>
+    <p style=" text-decoration:none;">Click <a style="color:blue; text-decoration:none;"  href="https://<%= ActionMailer::Base.default_url_options[:host] %>/settings">here</a> to change your subscription settings</p>
+</div>

app/views/users/profile.html.erb

@@ -209,8 +209,11 @@
         <%= form_tag "/users/test_digest_email", method: :post do %>
           <%= submit_tag "Test Digest Email", class: "btn btn-info", style: "width: 100%;" %>
         <% end %>
+        <%= form_tag "/admin/test_digest_email_spam", method: :post do %>
+          <%= submit_tag "Test Spam Digest Email", class: "btn btn-sm btn-primary mt-2", style: "width: 100%;" %>
+        <% end %>
       <% end %>
-
+      
     <% end %>
 
     <hr />

config/routes.rb

@@ -335,7 +335,8 @@
   get 'questions/liked(/:tagnames)' => 'questions#liked'
 
   post 'users/test_digest_email' => 'users#test_digest_email'
-
+  post 'admin/test_digest_email_spam' => 'admin#test_digest_email_spam'
+
   get 'comment/delete/:id' => 'comment#delete'
   get 'comment/update/:id' => 'comment#update'
   post 'comment/update/:id' => 'comment#update'

config/schedule.rb

@@ -46,8 +46,10 @@
 
 every 1.day do
   runner "DigestMailJob.perform_async(0)"
+  runner "DigestSpamJob.perform_async(0)"
 end
 
 every 1.week do
   runner "DigestMailJob.perform_async(1)"
+  runner "DigestSpamJob.perform_async(1)"
 end

test/functional/admin_controller_test.rb

@@ -638,4 +638,10 @@ def teardown
     assert_response :success
     assert_not_nil assigns(:users)
   end
+
+  test "test digest emails to moderators" do
+    UserSession.create(users(:moderator))
+    post :test_digest_email_spam
+    assert_redirected_to '/spam'
+  end
 end

test/unit/user_test.rb

@@ -305,4 +305,7 @@ class UserTest < ActiveSupport::TestCase
     end
   end
 
+  test 'Send digest email for unmoderated posts' do
+    assert users(:bob).send_digest_email_spam
+  end
 end