Expose mediator-scan API through the Scan app

apps/app/src/main/scala/org/lfdecentralizedtrust/splice/config/ConfigTransforms.scala

@@ -435,6 +435,8 @@ object ConfigTransforms {
           .modify(portTransform(bump, _))
           .focus(_.sequencerAdminClient)
           .modify(portTransform(bump, _))
+          .focus(_.mediatorAdminClient)
+          .modify(portTransform(bump, _))
           .focus(_.bftSequencers)
           .modify(_.map(_.focus(_.sequencerAdminClient).modify(portTransform(bump, _))))
       ),
@@ -547,6 +549,8 @@ object ConfigTransforms {
           .modify(portTransform(bump, _))
           .focus(_.sequencerAdminClient)
           .modify(portTransform(bump, _))
+          .focus(_.mediatorAdminClient)
+          .modify(portTransform(bump, _))
       } else {
         config
       }
@@ -565,6 +569,8 @@ object ConfigTransforms {
           .modify(_.map(setPortPrefix(range)))
           .focus(_.sequencerAdminClient.port)
           .modify(setPortPrefix(range))
+          .focus(_.mediatorAdminClient.port)
+          .modify(setPortPrefix(range))
           .focus(_.bftSequencers)
           .modify(_.map(_.focus(_.sequencerAdminClient.port).modify(setPortPrefix(range))))
       } else {

apps/app/src/main/scala/org/lfdecentralizedtrust/splice/config/SpliceConfig.scala

@@ -16,6 +16,7 @@ import org.lfdecentralizedtrust.splice.scan.config.{
   ScanAppBackendConfig,
   ScanAppClientConfig,
   ScanCacheConfig,
+  MediatorVerdictIngestionConfig,
   ScanSynchronizerConfig,
   CacheConfig as SpliceCacheConfig,
 }
@@ -443,6 +444,9 @@ object SpliceConfig {
       )
     implicit val scanCacheConfigReader: ConfigReader[ScanCacheConfig] =
       deriveReader[ScanCacheConfig]
+    implicit val mediatorVerdictIngestionConfigReader
+        : ConfigReader[MediatorVerdictIngestionConfig] =
+      deriveReader[MediatorVerdictIngestionConfig]
     implicit val cacheConfigReader: ConfigReader[SpliceCacheConfig] =
       deriveReader[SpliceCacheConfig]
     implicit val scanConfigReader: ConfigReader[ScanAppBackendConfig] =
@@ -856,6 +860,9 @@ object SpliceConfig {
       deriveWriter[ScanAppBackendConfig]
     implicit val scanCacheConfigWriter: ConfigWriter[ScanCacheConfig] =
       deriveWriter[ScanCacheConfig]
+    implicit val mediatorVerdictIngestionConfigWriter
+        : ConfigWriter[MediatorVerdictIngestionConfig] =
+      deriveWriter[MediatorVerdictIngestionConfig]
     implicit val cacheConfigWriter: ConfigWriter[SpliceCacheConfig] =
       deriveWriter[SpliceCacheConfig]
 

apps/app/src/main/scala/org/lfdecentralizedtrust/splice/console/ScanAppReference.scala

@@ -502,6 +502,29 @@ abstract class ScanAppReference(
     }
   }
 
+  def getEventHistory(
+      count: Int,
+      after: Option[(Long, String)],
+      encoding: definitions.DamlValueEncoding,
+  ): Seq[definitions.EventHistoryItem] = {
+    consoleEnvironment.run {
+      httpCommand(
+        HttpScanAppClient.GetEventHistory(count, after, encoding)
+      )
+    }
+  }
+
+  def getEventById(
+      updateId: String,
+      damlValueEncoding: Option[definitions.DamlValueEncoding],
+  ): definitions.EventHistoryItem = {
+    consoleEnvironment.run {
+      httpCommand(
+        HttpScanAppClient.GetEventById(updateId, damlValueEncoding)
+      )
+    }
+  }
+
   def getSpliceInstanceNames() = {
     consoleEnvironment.run {
       httpCommand(HttpScanAppClient.GetSpliceInstanceNames())

apps/app/src/pack/examples/sv-helm/scan-values.yaml

@@ -5,6 +5,7 @@ migration:
 # Replace MIGRATION_ID with the current migration ID of the global synchronizer.
 participantAddress: "participant-MIGRATION_ID"
 sequencerAddress: "global-domain-MIGRATION_ID-sequencer"
+mediatorAddress: "global-domain-MIGRATION_ID-mediator"
 
 persistence:
   host: apps-pg

apps/app/src/test/resources/include/scans/sv1-scan.conf

@@ -6,6 +6,7 @@
     ledger-api.client-config.port = 5101
   }
   sequencer-admin-client.port = 5109
+  mediator-admin-client.port = 5107
   admin-api.port = 5012
   sv-user = "sv1"
   is-first-sv = true

apps/app/src/test/resources/include/scans/sv2-scan.conf

@@ -6,6 +6,7 @@
     ledger-api.client-config.port = 5201
   }
   sequencer-admin-client.port = 5209
+  mediator-admin-client.port = 5207
   admin-api.port = 5112
   sv-user = "sv2"
 }

apps/app/src/test/resources/include/scans/sv3-scan.conf

@@ -6,6 +6,7 @@
     ledger-api.client-config.port = 5301
   }
   sequencer-admin-client.port = 5309
+  mediator-admin-client.port = 5307
   admin-api.port = 5212
   sv-user = "sv3"
 }

apps/app/src/test/resources/include/scans/sv4-scan.conf

@@ -6,6 +6,7 @@
     ledger-api.client-config.port = 5401
   }
   sequencer-admin-client.port = 5409
+  mediator-admin-client.port = 5407
   admin-api.port = 5312
   sv-user = "sv4"
 }

apps/app/src/test/resources/local-sv-node/scan-app/app.conf

@@ -17,6 +17,11 @@ _scan_sequencer_admin_client {
   port = 9109
 }
 
+_scan_mediator_admin_client {
+  address = "0.0.0.0"
+  port = 9107
+}
+
 canton {
   scan-apps {
     sv1ScanLocal {
@@ -37,6 +42,7 @@ canton {
       }
       participant-client = ${_scan_participant_client}
       sequencer-admin-client = ${_scan_sequencer_admin_client}
+      mediator-admin-client = ${_scan_mediator_admin_client}
       sv-user = "sv1"
     }
   }