update canton to 20251030.17361.v46825b7e

tell-slack: canton

Author: Azure Pipelines Daml Build

sdk/canton/community/admin-api/src/main/protobuf/com/digitalasset/canton/admin/participant/v30/participant_repair_service.proto

@@ -120,8 +120,9 @@ message MigrateSynchronizerResponse {}
 message ExportAcsOldRequest {
   option deprecated = true;
 
-  // The parties for which the ACS should be exported
-  // Required
+  // The parties for which the ACS should be exported.
+  // If empty, the ACS of all parties will be exported.
+  // Optional
   repeated string parties = 1;
 
   // The IDs of the synchronizers to filter the contracts by

sdk/canton/community/admin-api/src/main/protobuf/com/digitalasset/canton/admin/participant/v30/party_management_service.proto

@@ -253,7 +253,7 @@ message ExportPartyAcsRequest {
 
   // The maximum duration the service will wait to find the topology transaction that activates the party on
   // the target participant.
-  // If not set, the service use will use a default timeout.
+  // If not set, the service will use a default timeout.
   // Optional
   google.protobuf.Duration wait_for_activation_timeout = 5;
 }
@@ -342,7 +342,7 @@ message ClearPartyOnboardingFlagRequest {
 
   // The maximum duration the service will wait to find the topology transaction
   // that activates the party.
-  // If not set, the service use will use a default timeout.
+  // If not set, the service will use a default timeout.
   // Optional
   google.protobuf.Duration wait_for_activation_timeout = 4;
 }

sdk/canton/community/app-base/src/main/scala/com/digitalasset/canton/console/AdminCommandRunner.scala

@@ -23,7 +23,7 @@ trait AdminCommandRunner {
     * configured with an HTTP interface.
     */
   protected[console] def adminCommand[Result](
-      grpcCommand: GrpcAdminCommand[_, _, Result]
+      grpcCommand: GrpcAdminCommand[?, ?, Result]
   ): ConsoleCommandResult[Result]
 
   protected[console] def tracedLogger: TracedLogger
@@ -58,15 +58,15 @@ object AdminCommandRunner {
 trait LedgerApiCommandRunner {
 
   protected[console] def ledgerApiCommand[Result](
-      command: GrpcAdminCommand[_, _, Result]
+      command: GrpcAdminCommand[?, ?, Result]
   ): ConsoleCommandResult[Result]
 
   protected[console] def token: Option[String]
 }
 
 trait PublicApiCommandRunner {
   protected[console] def publicApiCommand[Result](
-      command: GrpcAdminCommand[_, _, Result]
+      command: GrpcAdminCommand[?, ?, Result]
   ): ConsoleCommandResult[Result]
 }
 

sdk/canton/community/app-base/src/main/scala/com/digitalasset/canton/console/CantonHealthAdministration.scala

@@ -89,7 +89,7 @@ object CantonHealthAdministration {
   }
 
   private def statusMap[A <: InstanceReference](
-      nodes: NodeReferences[A, _, _]
+      nodes: NodeReferences[A, ?, ?]
   ): Map[String, () => NodeStatus[A#Status]] =
     nodes.all.map(node => node.name -> (() => node.health.status)).toMap
 }

sdk/canton/community/app-base/src/main/scala/com/digitalasset/canton/console/ConsoleEnvironment.scala

@@ -397,33 +397,33 @@ class ConsoleEnvironment(
 
   /** Assemble top level values with their identifier name, value binding, and help description.
     */
-  protected def topLevelValues: Seq[TopLevelValue[_]] = {
+  protected def topLevelValues: Seq[TopLevelValue[?]] = {
     val nodeTopic = Seq(topicNodeReferences)
-    val localParticipantBinds: Seq[TopLevelValue[_]] =
+    val localParticipantBinds: Seq[TopLevelValue[?]] =
       participants.local.map(p =>
         TopLevelValue(p.name, helpText("participant", p.name), p, nodeTopic)
       )
-    val remoteParticipantBinds: Seq[TopLevelValue[_]] =
+    val remoteParticipantBinds: Seq[TopLevelValue[?]] =
       participants.remote.map(p =>
         TopLevelValue(p.name, helpText("remote participant", p.name), p, nodeTopic)
       )
-    val localMediatorBinds: Seq[TopLevelValue[_]] =
+    val localMediatorBinds: Seq[TopLevelValue[?]] =
       mediators.local.map(d =>
         TopLevelValue(d.name, helpText("local mediator", d.name), d, nodeTopic)
       )
-    val remoteMediatorBinds: Seq[TopLevelValue[_]] =
+    val remoteMediatorBinds: Seq[TopLevelValue[?]] =
       mediators.remote.map(d =>
         TopLevelValue(d.name, helpText("remote mediator", d.name), d, nodeTopic)
       )
-    val localSequencerBinds: Seq[TopLevelValue[_]] =
+    val localSequencerBinds: Seq[TopLevelValue[?]] =
       sequencers.local.map(d =>
         TopLevelValue(d.name, helpText("local sequencer", d.name), d, nodeTopic)
       )
-    val remoteSequencerBinds: Seq[TopLevelValue[_]] =
+    val remoteSequencerBinds: Seq[TopLevelValue[?]] =
       sequencers.remote.map(d =>
         TopLevelValue(d.name, helpText("remote sequencer", d.name), d, nodeTopic)
       )
-    val clockBinds: Option[TopLevelValue[_]] =
+    val clockBinds: Option[TopLevelValue[?]] =
       environment.simClock.map(cl =>
         TopLevelValue("clock", "Simulated time", new SimClockCommand(cl))
       )
@@ -454,7 +454,7 @@ class ConsoleEnvironment(
   /** Bindings for ammonite Add a reference to this instance to resolve implicit references within
     * the console
     */
-  lazy val bindings: Either[RuntimeException, IndexedSeq[Bind[_]]] = {
+  lazy val bindings: Either[RuntimeException, IndexedSeq[Bind[?]]] = {
     import cats.syntax.traverse.*
     for {
       bindsWithoutSelfAlias <- topLevelValues.traverse(_.asBind)
@@ -463,7 +463,7 @@ class ConsoleEnvironment(
     } yield binds.toIndexedSeq
   }
 
-  private def validateNameUniqueness(binds: Seq[Bind[_]]) = {
+  private def validateNameUniqueness(binds: Seq[Bind[?]]) = {
     val nonUniqueNames =
       binds.map(_.name).groupBy(identity).collect {
         case (name, occurrences) if occurrences.sizeIs > 1 =>
@@ -498,7 +498,7 @@ class ConsoleEnvironment(
 
   /** So we can we make this available
     */
-  protected def selfAlias(): Bind[_] = Bind(ConsoleEnvironmentBinding.BindingName, this)
+  protected def selfAlias(): Bind[?] = Bind(ConsoleEnvironmentBinding.BindingName, this)
 
   override def onClosed(): Unit =
     LifeCycle.close(

sdk/canton/community/app-base/src/main/scala/com/digitalasset/canton/console/ConsoleMacros.scala

@@ -334,7 +334,7 @@ trait ConsoleMacros extends NamedLogging with NoTracing {
     private def mapToLedgerApiValue(value: Any): Value = {
 
       // assuming that String.toString = id, we'll just map any Map to a string map without casting
-      def safeMapCast(map: Map[_, _]): Map[String, Any] = map.map { case (key, value) =>
+      def safeMapCast(map: Map[?, ?]): Map[String, Any] = map.map { case (key, value) =>
         (key.toString, value)
       }
 
@@ -351,7 +351,7 @@ trait ConsoleMacros extends NamedLogging with NoTracing {
         case x: Instant => Value.Sum.Timestamp(x.toEpochMilli * 1000L)
         case x: Option[Any] => Value.Sum.Optional(Optional(value = x.map(mapToLedgerApiValue)))
         case x: Value.Sum => x
-        case x: Map[_, _] => Value.Sum.Record(buildArguments(safeMapCast(x)))
+        case x: Map[?, ?] => Value.Sum.Record(buildArguments(safeMapCast(x)))
         case x: (Any, Any) => productToLedgerApiRecord(x)
         case x: (Any, Any, Any) => productToLedgerApiRecord(x)
         case _ =>
@@ -1062,7 +1062,7 @@ trait ConsoleMacros extends NamedLogging with NoTracing {
     // Helper to find all HA-active nodes
     private def allPrunableNodes(implicit
         env: ConsoleEnvironment
-    ): Map[String, PruningSchedulerAdministration[_]] =
+    ): Map[String, PruningSchedulerAdministration[?]] =
       (env.participants.all.collect { case p if p.health.active => p.name -> p.pruning }
         ++ env.sequencers.all.collect {
           case s

sdk/canton/community/app-base/src/main/scala/com/digitalasset/canton/console/GrpcAdminCommandRunner.scala

@@ -61,7 +61,7 @@ class GrpcAdminCommandRunner(
 
   def runCommandAsync[Result](
       instanceName: String,
-      command: GrpcAdminCommand[_, _, Result],
+      command: GrpcAdminCommand[?, ?, Result],
       clientConfig: ClientConfig,
       token: Option[String],
   )(implicit traceContext: TraceContext): (NonNegativeDuration, EitherT[Future, String, Result]) = {
@@ -121,7 +121,7 @@ class GrpcAdminCommandRunner(
 
   def runCommandWithExistingTrace[Result](
       instanceName: String,
-      command: GrpcAdminCommand[_, _, Result],
+      command: GrpcAdminCommand[?, ?, Result],
       clientConfig: ClientConfig,
       token: Option[String],
   )(implicit traceContext: TraceContext): ConsoleCommandResult[Result] = {
@@ -138,7 +138,7 @@ class GrpcAdminCommandRunner(
 
   def runCommand[Result](
       instanceName: String,
-      command: GrpcAdminCommand[_, _, Result],
+      command: GrpcAdminCommand[?, ?, Result],
       clientConfig: ClientConfig,
       token: Option[String],
   ): ConsoleCommandResult[Result] =

sdk/canton/community/app-base/src/main/scala/com/digitalasset/canton/console/commands/ParticipantRepairAdministration.scala

@@ -39,7 +39,6 @@ import io.grpc.Context
 
 import java.time.Instant
 import java.util.UUID
-import scala.annotation.nowarn
 
 class ParticipantRepairAdministration(
     val consoleEnvironment: ConsoleEnvironment,
@@ -172,7 +171,8 @@ class ParticipantRepairAdministration(
         |
         |
         |The arguments are:
-        |- parties: identifying contracts having at least one stakeholder from the given set
+        |- parties: identifying contracts having at least one stakeholder from the given set.
+        |           if empty, contracts of all parties will be exported.
         |- partiesOffboarding: true if the parties will be offboarded (party migration)
         |- outputFile: the output file name where to store the data.
         |- filterSynchronizerId: restrict the export to a given synchronizer
@@ -187,7 +187,10 @@ class ParticipantRepairAdministration(
         |         request.
         """
   )
-  @nowarn("cat=deprecation")
+  @deprecated(
+    "Method export_acs_old has been deprecated. Use acs_export_instead. For party replication, see participant.parties.export_acs",
+    since = "3.4",
+  )
   def export_acs_old(
       parties: Set[PartyId],
       partiesOffboarding: Boolean,
@@ -259,6 +262,10 @@ class ParticipantRepairAdministration(
         |DEPRECATION NOTICE: A future release removes this command, use `export_acs` instead.
         """
   )
+  @deprecated(
+    "Method import_acs_old has been deprecated. Use import_acs instead. For party replication, see participant.parties.import_party_acs",
+    since = "3.4",
+  )
   def import_acs_old(
       inputFile: String = ParticipantRepairAdministration.ExportAcsDefaultFile,
       workflowIdPrefix: String = "",

sdk/canton/community/app-base/src/main/scala/com/digitalasset/canton/console/declarative/DeclarativeParticipantApi.scala

@@ -90,7 +90,7 @@ class DeclarativeParticipantApi(
   private def queryApi[Result](
       runner: GrpcAdminCommandRunner,
       cfg: ClientConfig,
-      command: GrpcAdminCommand[_, _, Result],
+      command: GrpcAdminCommand[?, ?, Result],
   )(implicit traceContext: TraceContext): Either[QueryResult, Result] = if (
     closeContext.context.isClosing
   )
@@ -107,12 +107,12 @@ class DeclarativeParticipantApi(
     )
 
   private def queryAdminApi[Result](
-      command: GrpcAdminCommand[_, _, Result]
+      command: GrpcAdminCommand[?, ?, Result]
   )(implicit traceContext: TraceContext): Either[String, Result] =
     queryApi(adminApiRunner, adminApiConfig, command).leftMap(_.str)
 
   private def queryLedgerApi[Result](
-      command: GrpcAdminCommand[_, _, Result]
+      command: GrpcAdminCommand[?, ?, Result]
   )(implicit traceContext: TraceContext): Either[String, Result] =
     queryApi(ledgerApiRunner, ledgerApiConfig, command).leftMap(_.str)
 
@@ -125,12 +125,12 @@ class DeclarativeParticipantApi(
   }
 
   private def queryAdminApiIfExists[Result](
-      command: GrpcAdminCommand[_, _, Result]
+      command: GrpcAdminCommand[?, ?, Result]
   )(implicit traceContext: TraceContext): Either[String, Option[Result]] =
     toOptionalE(queryApi(adminApiRunner, adminApiConfig, command))
 
   private def queryLedgerApiIfExists[Result](
-      command: GrpcAdminCommand[_, _, Result]
+      command: GrpcAdminCommand[?, ?, Result]
   )(implicit traceContext: TraceContext): Either[String, Option[Result]] =
     toOptionalE(queryApi(ledgerApiRunner, ledgerApiConfig, command))
 

sdk/canton/community/app-base/src/main/scala/com/digitalasset/canton/console/package.scala

@@ -37,7 +37,7 @@ package object console {
 
   /** Strip the Object suffix from the name of the provided class
     */
-  def objectClassNameWithoutSuffix(c: Class[_]): String =
+  def objectClassNameWithoutSuffix(c: Class[?]): String =
     c.getName.stripSuffix("$").replace('$', '.')
 
 }