Debug email sending for different versions

api/app/actors/Emails.scala → api/app/lib/Emails.scala

@@ -1,8 +1,8 @@
-package actors
+package lib
 
 import db.{ApplicationsDao, Authorization, MembershipsDao, SubscriptionsDao}
 import io.apibuilder.api.v0.models._
-import lib._
+import org.joda.time.DateTime
 import play.api.Logging
 
 import javax.inject.{Inject, Singleton}
@@ -46,13 +46,13 @@ class Emails @Inject() (
     implicit filter: Subscription => Boolean = { _ => true }
   ): Unit = {
     eachSubscription(context, org, publication, { subscription =>
-      if (filter(subscription)) {
-        email.sendHtml(
-          to = Person(subscription.user),
-          subject = subject,
-          body = body
-        )
-      }
+      val result = filter(subscription)
+      println(s"[${DateTime.now} DEBUG_FILTER] result: $result")
+      email.sendHtml(
+        to = Person(subscription.user),
+        subject = subject,
+        body = body
+      )
     })
   }
 
@@ -80,7 +80,7 @@ class Emails @Inject() (
     }
   }
 
-  private[actors] def isAuthorized(
+  private[lib] def isAuthorized(
     context: Emails.Context,
     organization: Organization,
     user: User

api/app/processor/CheckInvariantsProcessor.scala

@@ -34,7 +34,6 @@ class CheckInvariantsProcessor @Inject()(
   private[this] def sendResults(results: Seq[InvariantResult]): Unit = {
     val (noErrors, withErrors) = results.partition(_.count == 0)
 
-    println(s"# Invariants checked with no errors: ${noErrors.length}")
     if (withErrors.nonEmpty) {
       lazy val subject = if (withErrors.length == 1) {
         "1 Error"

api/app/processor/DiffVersionProcessor.scala

@@ -1,13 +1,12 @@
 package processor
 
-import actors.Emails
 import cats.data.ValidatedNec
 import cats.implicits._
 import db._
 import io.apibuilder.api.v0.models._
 import io.apibuilder.task.v0.models.json._
 import io.apibuilder.task.v0.models.{DiffVersionData, TaskType}
-import lib.{AppConfig, ServiceDiff}
+import lib.{AppConfig, ServiceDiff, Emails}
 import play.twirl.api.Html
 
 import java.util.UUID

api/app/processor/EmailProcessor.scala

@@ -1,13 +1,12 @@
 package processor
 
-import actors.Emails
 import cats.data.ValidatedNec
 import cats.implicits._
 import db.{Authorization, InternalTasksDao, OrganizationsDao, UsersDao}
 import io.apibuilder.api.v0.models.Publication
 import io.apibuilder.task.v0.models._
 import io.apibuilder.task.v0.models.json._
-import lib.{AppConfig, EmailUtil, Person, Role}
+import lib.{AppConfig, EmailUtil, Person, Emails, Role}
 import play.api.libs.json.Json
 
 import java.sql.Connection

api/test/actors/EmailsSpec.scala → api/test/lib/EmailsSpec.scala

@@ -1,7 +1,6 @@
-package actors
+package lib
 
 import io.apibuilder.api.v0.models.Visibility
-import lib.Role
 import org.scalatestplus.play.PlaySpec
 import org.scalatestplus.play.guice.GuiceOneAppPerSuite
 

api/test/util/Daos.scala

@@ -1,10 +1,9 @@
 package util
 
-import actors.Emails
+import db._
 import db.generated.SessionsDao
 import db.generators.{GeneratorsDao, ServicesDao}
-import db._
-import lib.DatabaseServiceFetcher
+import lib.{DatabaseServiceFetcher, Emails}
 import play.api.Application
 import play.api.inject.Injector
 
@@ -38,7 +37,7 @@ trait Daos {
   def servicesDao: ServicesDao = injector.instanceOf[db.generators.ServicesDao]
   def generatorsDao: GeneratorsDao = injector.instanceOf[db.generators.GeneratorsDao]
 
-  def emails: Emails = injector.instanceOf[actors.Emails]
+  def emails: Emails = injector.instanceOf[Emails]
 
   def sessionHelper: SessionHelper = injector.instanceOf[SessionHelper]
 }