Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@

package org.lfdecentralizedtrust.splice.sv.onboarding.domainmigration

import cats.implicits.catsSyntaxApplicativeByName
import cats.syntax.either.*
import com.daml.grpc.adapter.ExecutionSequencerFactory
import org.lfdecentralizedtrust.splice.config.{
Expand Down Expand Up @@ -57,9 +58,11 @@ import org.lfdecentralizedtrust.splice.sv.store.{SvDsoStore, SvStore, SvSvStore}
import org.lfdecentralizedtrust.splice.sv.util.SvUtil
import org.lfdecentralizedtrust.splice.util.TemplateJsonDecoder
import com.digitalasset.canton.admin.api.client.data.{NodeStatus, WaitingForInitialization}
import com.digitalasset.canton.config.RequireTypes.NonNegativeInt
import com.digitalasset.canton.data.CantonTimestamp
import com.digitalasset.canton.lifecycle.CloseContext
import com.digitalasset.canton.logging.NamedLoggerFactory
import com.digitalasset.canton.protocol.DynamicSynchronizerParameters
import com.digitalasset.canton.resource.DbStorage
import com.digitalasset.canton.sequencing.SequencerConnections
import com.digitalasset.canton.time.Clock
Expand Down Expand Up @@ -258,12 +261,22 @@ class DomainMigrationInitializer(
packageVersionSupport,
svStore.key.svParty,
)
// trigger more or less a noop topology transaction so that the ledger api event notifier is initialized for the sync and propagates all the parties from the genesis import to the ledger api
// this will basically be reverted in the trigger
_ <- participantAdminConnection
.ensureDomainParameters(
decentralizedSynchronizerId,
_.tryUpdate(confirmationRequestsMaxRate =
DynamicSynchronizerParameters.defaultConfirmationRequestsMaxRate + NonNegativeInt.one
),
)
.unlessA(migrationDump.domainDataSnapshot.synchronizerWasPaused)
_ <- newJoiningNodeInitializer(None, newCometBftNode).onboard(
decentralizedSynchronizerId,
dsoAutomationService,
svAutomation,
skipTrafficReconciliationTriggers = true,
unpauseSynchronizer = true,
unpauseSynchronizer = migrationDump.domainDataSnapshot.synchronizerWasPaused,
)
} yield (
decentralizedSynchronizerId,
Expand Down
6 changes: 3 additions & 3 deletions nix/canton-sources.json
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
{
"version": "3.5.0-snapshot.20251203.17571.0.vd0c5d709",
"version": "3.5.0-snapshot.20251219.17699.0.v0c2121fb",
"tooling_sdk_version": "3.3.0-snapshot.20250415.13756.0.vafc5c867",
"daml_release": "v3.3.0-snapshot.20250417.0",
"enterprise_sha256": "sha256:10087gk3b2nq7c0sd77hf5mmgn5d104xhbkx27i3wjhmyimf6q56",
"oss_sha256": "sha256:10087gk3b2nq7c0sd77hf5mmgn5d104xhbkx27i3wjhmyimf6q56"
"enterprise_sha256": "sha256:02jraib0sx5y8ivcgh4ql38cbam6vffhjscj5hb2055d5yrrh4lz",
"oss_sha256": "sha256:02jraib0sx5y8ivcgh4ql38cbam6vffhjscj5hb2055d5yrrh4lz"
}
Loading