connection working, smtp server needs setup

Author: Nick Grippin

api/src/main/resources/application.conf

@@ -27,6 +27,12 @@ hmda {
     timeout = 10
     timeout = ${?HMDA_HTTP_TIMEOUT}
   }
+  mail {
+    host = "mail_dev"
+    host = ${?HMDA_MAIL_HOST}
+    port = "25"
+    port = ${?HMDA_MAIL_PORT}
+  }
   isDemo = false
   isDemo = ${?HMDA_IS_DEMO}
 }

api/src/main/scala/hmda/api/http/institutions/submissions/SubmissionSignPaths.scala

@@ -28,12 +28,13 @@ import scala.concurrent.{ ExecutionContext, Future }
 import javax.mail._
 import javax.mail.internet.{ InternetAddress, MimeMessage }
 
+import com.typesafe.config.ConfigFactory
+import hmda.query.repository.KeyCloakRepository
 /*
 Questions
 - Which email library to use (Javax)?
 - Which email/port to send from (no-reply)?
 - Send all emails using CC/BCC, or separate (separate)?
-- Strategy of using Institution Persistance to retrieve emails (it's ok)?
  */
 
 trait SubmissionSignPaths
@@ -43,7 +44,8 @@ trait SubmissionSignPaths
     with EditResultsProtocol
     with HmdaCustomDirectives
     with RequestVerificationUtils
-    with ValidationErrorConverter {
+    with ValidationErrorConverter
+    with KeyCloakRepository {
 
   implicit val system: ActorSystem
   implicit val materializer: ActorMaterializer
@@ -98,36 +100,45 @@ trait SubmissionSignPaths
 
     onComplete(fSubmission) {
       case Success(sub) =>
-        emailSignature(supervisor, sub)
+        if (sub.status.code == 10) {
+          emailSignature(supervisor, sub)
+        }
         complete(ToResponseMarshallable(Receipt(sub.end, sub.receipt, sub.status)))
       case Failure(error) => completeWithInternalError(uri, error)
     }
   }
 
   private def emailSignature(supervisor: ActorRef, submission: Submission)(implicit ec: ExecutionContext) = {
-    /*
-      TODO: Get email addresses!!!!
-     */
-    val address = "PLACEHOLDER"
-    sendMail(address, submission)
+    val emails = findEmailsById(submission.id.institutionId)
+    emails.map(emailSeq => {
+      emailSeq.foreach(t => {
+        val username = t._1 + " " + t._2
+        sendMail(t._3, username, submission)
+      })
+    })
+  }
+
+  private def sendMail(address: String, username: String, submission: Submission) = {
+    val config = ConfigFactory.load()
+    val host = config.getString("hmda.mail.host")
+    val port = config.getString("hmda.mail.port")
 
-  private def sendMail(address: String, submission: Submission) = {
     val properties = System.getProperties
-    properties.put("mail.smtp.host", "localhost")
+    properties.put("mail.smtp.host", host)
+    properties.put("mail.smtp.port", port)
+
     val session = Session.getDefaultInstance(properties)
     val message = new MimeMessage(session)
 
-    val date = submission.end
-    val text = s"Congratulations, you've completed filing your HMDA data for filing period ${submission.id.period}.\n" +
+    val text = s"$username,\nCongratulations, you've completed filing your HMDA data for filing period ${submission.id.period}.\n" +
       s"We received your filing on: ${submission.end}\n" +
       s"Your receipt is:${submission.receipt}"
-    message.setFrom(new InternetAddress("test@test.com"))
+    message.setFrom(new InternetAddress("no-reply@test.com"))
     message.setRecipients(Message.RecipientType.TO, address)
     message.setSubject("HMDA Filing Successful")
     message.setText(text)
 
     log.info(s"Sending message to $address with the message \n$text")
-
-    //Transport.send(message)
+    Transport.send(message)
   }
 }

docker-compose.yml

@@ -44,7 +44,7 @@ services:
       APP_URL: https://192.168.99.100
       HMDA_API: https://192.168.99.100:4443/hmda
       KEYCLOAK_URL: https://192.168.99.100:8443/auth/realms/hmda
-      # lb settings 
+      # lb settings
       VIRTUAL_HOST: 'http://*:80/*, https://*:443/*'
       EXCLUDE_PORTS: '443' # use lb's ssl instead of ui's nginx
       FORCE_SSL: 'true' # redirect 80 to 443
@@ -81,6 +81,8 @@ services:
 
   keycloak_db:
     image: postgres:9.6.1
+    ports:
+          - '5433:5432'
     environment:
       POSTGRES_DB: keycloak
       POSTGRES_USER: keycloak

persistence-model/src/main/scala/hmda/persistence/model/HmdaPersistentActor.scala

@@ -24,8 +24,10 @@ abstract class HmdaPersistentActor extends PersistentActor with HmdaActor {
   }
 
   override def receiveCommand: Receive = {
-    case ReceiveTimeout =>
+    case ReceiveTimeout => {
+      log.info("Received Timeout, sending Shutdown message. Thread: " + Thread.currentThread().getName)
       self ! Shutdown
+    }
 
     case Shutdown =>
       context stop self

query/src/main/resources/application.conf

@@ -36,6 +36,26 @@ hmda {
 //  }
 //}
 
+db {
+  driver = "slick.driver.PostgresDriver$"
+  db {
+    driver = org.postgresql.Driver
+    host = "192.168.99.100"
+    host = ${?KEYCLOAK_HOST}
+    port = "5433"
+    port = ${?KEYCLOAK_PORT}
+    database = "keycloak"
+    database = ${?KEYCLOAK_DATABASE}
+    url = "jdbc:postgresql://"${db.db.host}":"${db.db.port}"/"${db.db.database}
+    url = ${?KEYCLOAK_URL_OVERRIDE}
+    user = "keycloak"
+    user = ${?KEYCLOAK_USER}
+    password = "password"
+    password = ${?KEYCLOAK_PASSWORD}
+    connectionPool = disabled
+  }
+}
+
 cassandra {
   host = "192.168.99.100"
   host = ${?CASSANDRA_CLUSTER_HOSTS}

query/src/main/scala/hmda/query/repository/KeyCloakRepository.scala

@@ -0,0 +1,28 @@
+package hmda.query.repository
+
+import slick.basic.DatabaseConfig
+import slick.jdbc.JdbcProfile
+import slick.jdbc.H2Profile.api._
+
+import scala.concurrent.{ ExecutionContext, Future }
+
+trait KeyCloakRepository {
+  val dbConfig = DatabaseConfig.forConfig[JdbcProfile]("db")
+  val db = dbConfig.db
+
+  def findEmailsById(id: String)(implicit ec: ExecutionContext): Future[Seq[(String, String, String)]] = {
+    val query =
+      sql"""SELECT ue.first_name, ue.last_name, ue.email
+         FROM user_entity AS ue
+            INNER JOIN user_attribute AS ua ON ua.user_id = ue.id
+         WHERE ue.realm_id = 'hmda'
+            AND ue.enabled = 't'
+            AND ue.email_verified = 't'
+            AND ua.name = 'institutions'
+            AND (ua.value = '#$id'
+              OR ua.value LIKE '#$id,%'
+              OR ua.value LIKE '%,#$id'
+              OR ua.value LIKE '%,#$id,%')"""
+    db.run(query.as[(String, String, String)])
+  }
+}