Merge pull request #4172 from omnipresent07/websockets-new

Add verbose websockets to the filing api
cfpb · Aug 16, 2021 · 6aac597 · 6aac597
2 parents 6156553 + 16589b4
commit 6aac597
Show file tree

Hide file tree

Showing 6 changed files with 31 additions and 2 deletions.
diff --git a/hmda/src/main/resources/application.conf b/hmda/src/main/resources/application.conf
@@ -56,6 +56,7 @@ akka {
 
   http.server.parsing.max-content-length = 2G
   http.server.default-host-header = "cfpb.gov"
+  http.server.websocket.periodic-keep-alive-max-idle = 1 second
 
   discovery.method = akka-dns
   io.dns.resolver = async-dns

diff --git a/hmda/src/main/scala/hmda/persistence/submission/HmdaValidationError.scala b/hmda/src/main/scala/hmda/persistence/submission/HmdaValidationError.scala
@@ -186,13 +186,13 @@ object HmdaValidationError
             blockingEc,
             timeout
           )
-          _ = tracker ! ValidationDelta(ValidationType.Syntactical, InProgress(50))
+          _ = tracker ! ValidationDelta(ValidationType.Quality, InProgress(50))
           _ = log.info(s"Finished ValidateLar Quality for $submissionId")
           _ = log.info(s"Started validateAsyncLar - Quality for $submissionId")
           larAsyncErrorsQuality <- validateAsyncLar("quality", submissionId)
             .runWith(Sink.ignore)
           _ = log.info(s"Finished ValidateAsyncLar Quality for $submissionId")
-          _ = tracker ! ValidationDelta(ValidationType.Syntactical, InProgress(99))
+          _ = tracker ! ValidationDelta(ValidationType.Quality, InProgress(99))
         } yield (larErrors, larAsyncErrorsQuality)
 
         fQuality.onComplete {

diff --git a/kubernetes/beta/config-maps/cass-operator-configmap.yaml b/kubernetes/beta/config-maps/cass-operator-configmap.yaml
@@ -0,0 +1,8 @@
+apiVersion: v1
+kind: ConfigMap
+metadata:
+  name: cassandra-configmap
+data:
+  cassandra-hosts: cluster1-dc1-service.cass-operator
+  cassandra-keyspace: hmda2_journal_beta
+  cassandra-keyspace-snapshot: hmda2_snapshot_beta
diff --git a/kubernetes/beta/config-maps/strimzi-kafka-configmap.yaml b/kubernetes/beta/config-maps/strimzi-kafka-configmap.yaml
@@ -0,0 +1,6 @@
+apiVersion: v1
+kind: ConfigMap
+metadata:
+  name: kafka-configmap
+data:
+  kafka.hosts: 'strimzi-cluster-kafka-bootstrap.strimzi:9092'
diff --git a/kubernetes/config-maps/cass-operator-configmap.yaml b/kubernetes/config-maps/cass-operator-configmap.yaml
@@ -0,0 +1,8 @@
+apiVersion: v1
+kind: ConfigMap
+metadata:
+  name: cassandra-configmap
+data:
+  cassandra-hosts: cluster1-dc1-service.cass-operator
+  cassandra-keyspace: hmda2_journal
+  cassandra-keyspace-snapshot: hmda2_snapshot
diff --git a/kubernetes/config-maps/strimzi-kafka-configmap.yaml b/kubernetes/config-maps/strimzi-kafka-configmap.yaml
@@ -0,0 +1,6 @@
+apiVersion: v1
+kind: ConfigMap
+metadata:
+  name: kafka-configmap
+data:
+  kafka.hosts: 'strimzi-cluster-kafka-bootstrap.strimzi:9092'