Hi, I am trying to run following canton topology.
one canton domain and 2 canton participants and every component is being deployed separately.
on my local machine. I am not able to connect the canton domains.
I am getting following errors
participant.domains.connect(“mydomain”, “http://192.168.29.50:10018”)
ERROR c.d.c.c.ConsoleEnvironment - Request failed for participant. GrpcClientError: INVALID_ARGUMENT/SyncServiceAlreadyAdded(DomainAlias(mydomain)) Request: RegisterDomain(DomainConnectionConfig(DomainAlias(mydomain),http://192.168.29.50:10018,true,None,None,0)) Trailers: Metadata(content-type=application/grpc) Command execution failed.
mydomain is running as I have double-checked by looking at the service running on that port and firewall is not blocking it.
any help is very much appreciated.
This is my domain configuration.
@ mydomain.config res0: com.digitalasset.canton.domain.config.DomainConfig = DomainConfig( InitConfig(true, NonNegativeDuration(PT30S)), false, PublicServerConfig("127.0.0.1", 10018, None, PT1H), AdminServerConfig("127.0.0.1", 10019, None), Memory, Tink(), IdentityConfig(AutoApprove(true)), DomainParameters( NonNegativeDuration(PT10S), NonNegativeDuration(PT10S), NonNegativeDuration(PT1S), NonNegativeDuration(PT1M), NonNegativeDuration(PT1M), NonNegativeDuration(PT1M), 200, 10485760 ), InProcess(Embedded, true), None, None )
so I think the configuration is only supporting the connection requests made from localhost. (127.0.0.1)
PublicServerConfig("127.0.0.1", 10018, None, PT1H),
AdminServerConfig("127.0.0.1", 10019, None),
how do I configure the domain so it can accept requests made externally?
PublicServerConfig("0.0.0.0", 10018, None, PT1H),
AdminServerConfig("0.0.0.0", 10019, None),
basically I think this will resolve the issue.
Hey @Shubham-koli
First note, there is @Darko and there is @Ratko_Veprek. The names are similar, the persons not 
The first error you post says that you have already configured the domain connection. The error reads: SyncServiceAlreadyAdded(DomainAlias(mydomain), ...
You can’t register multiple domains under the same name. If you want to amend the configuration, you can use the participant.domains.modify(config: DomainConnectionConfig) command. If you need to change the setting for a domain configuration on the participant, you can get the current configuration using val current = participant.domains.config("mydomain") and then set the config using participant.domains.modify(current.copy(connection="https://..."))
And you are right with your observation. Canton is a bit conservative and binds by default only to localhost so that you don’t expose your data by accident on the open internet. I.e. we wanted to avoid to create news like this: https://www.qwant.com/?q=Thousands+of+MongoDB+Databases+Found+Exposed+on+the+Internet
I assume that you want to be able to connect a participant node running on one machine to a domain running on another. So, you have to change the domain config of the domain to listen to 0.0.0.0:
canton {
domains {
mydomain {
public-api {
port = 10018
address = 0.0.0.0
}
}
}
}
Please let me know if this helps.
3 Likes
Thanks @Ratko_Veprek.
Actually I’m trying to put canton on k8’s and my participant node was not able to connect the domain. I just tested this locally and I think exposing the ports globally has solved the problem.
1 Like
Hey @Ratko_Veprek, Thanks for your help!
I was able to deploy the canton components on Kubernetes successfully.
2 Likes
I am also not able to connect to canton domains. Getting below error -
ERROR c.d.c.ConsoleScriptRunner - java.util.concurrent.TimeoutException: Futures timed out after [20 seconds]
at scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:259)
at scala.concurrent.impl.Promise$DefaultPromise.result(Promise.scala:263)
at scala.concurrent.Await$.$anonfun$result$1(package.scala:220)
at scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:57)
at scala.concurrent.Await$.result(package.scala:146)
at com.microsoft.daphne.LedgerCommon$.execute(LedgerCommon.scala:14)
at com.microsoft.daphne.DaphneNetworkSetup$.setupParticipants(DaphneNetworkSetup.scala:107)
at ammonite.canton.interpreter.canton$minusscript_2$.<init>(demo.sc:139)
at ammonite.canton.interpreter.canton$minusscript_2$.<clinit>(demo.sc)
at ammonite.canton.interpreter.canton$minusscript_2.$main(demo.sc)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base/java.lang.reflect.Method.invoke(Method.java:566)
at ammonite.runtime.Evaluator$$anon$1.$anonfun$evalMain$1(Evaluator.scala:108)
at ammonite.util.Util$.withContextClassloader(Util.scala:24)
at ammonite.runtime.Evaluator$$anon$1.evalMain(Evaluator.scala:90)
at ammonite.runtime.Evaluator$$anon$1.$anonfun$processScriptBlock$1(Evaluator.scala:153)
at ammonite.util.Catching.map(Res.scala:117)
at ammonite.runtime.Evaluator$$anon$1.processScriptBlock(Evaluator.scala:150)
at ammonite.interp.Interpreter.$anonfun$processSingleBlock$4(Interpreter.scala:324)
at ammonite.util.Res$Success.flatMap(Res.scala:62)
at ammonite.interp.Interpreter.$anonfun$processSingleBlock$3(Interpreter.scala:315)
at ammonite.util.Res$Success.flatMap(Res.scala:62)
at ammonite.interp.Interpreter.$anonfun$processSingleBlock$2(Interpreter.scala:312)
at ammonite.util.Catching.flatMap(Res.scala:115)
at ammonite.interp.Interpreter.processSingleBlock(Interpreter.scala:311)
at ammonite.interp.Interpreter.$anonfun$processModule$8(Interpreter.scala:392)
at ammonite.interp.Interpreter.$anonfun$processAllScriptBlocks$3(Interpreter.scala:520)
at ammonite.util.Res$Success.flatMap(Res.scala:62)
at ammonite.interp.Interpreter.compileRunBlock$1(Interpreter.scala:506)
at ammonite.interp.Interpreter.$anonfun$processAllScriptBlocks$15(Interpreter.scala:567)
at ammonite.util.Res$Success.flatMap(Res.scala:62)
at ammonite.interp.Interpreter.$anonfun$processAllScriptBlocks$14(Interpreter.scala:564)
at ammonite.util.Res$Success.flatMap(Res.scala:62)
at ammonite.interp.Interpreter.$anonfun$processAllScriptBlocks$12(Interpreter.scala:561)
at scala.Option.getOrElse(Option.scala:189)
at ammonite.interp.Interpreter.loop$1(Interpreter.scala:561)
at ammonite.interp.Interpreter.processAllScriptBlocks(Interpreter.scala:599)
at ammonite.interp.Interpreter.$anonfun$processModule$6(Interpreter.scala:394)
at ammonite.util.Catching.flatMap(Res.scala:115)
at ammonite.interp.Interpreter.$anonfun$processModule$5(Interpreter.scala:385)
at ammonite.util.Res$Success.flatMap(Res.scala:62)
at ammonite.interp.Interpreter.processModule(Interpreter.scala:375)
at com.digitalasset.canton.console.HeadlessConsole$.runCode(HeadlessConsole.scala:111)
at com.digitalasset.canton.console.HeadlessConsole$.$anonfun$apply$2(HeadlessConsole.scala:55)
at scala.util.Either.flatMap(Either.scala:341)
at com.digitalasset.canton.console.HeadlessConsole$.$anonfun$apply$1(HeadlessConsole.scala:54)
at better.files.Dispose.apply(Dispose.scala:81)
at com.digitalasset.canton.console.HeadlessConsole$.apply(HeadlessConsole.scala:46)
at com.digitalasset.canton.ConsoleScriptRunner$.run(Runner.scala:184)
at com.digitalasset.canton.ConsoleScriptRunner.run(Runner.scala:106)
at com.digitalasset.canton.CantonAppDriver.delayedEndpoint$com$digitalasset$canton$CantonAppDriver$1(CantonAppDriver.scala:157)
at com.digitalasset.canton.CantonAppDriver$delayedInit$body.apply(CantonAppDriver.scala:27)
at scala.Function0.apply$mcV$sp(Function0.scala:39)
at scala.Function0.apply$mcV$sp$(Function0.scala:39)
at scala.runtime.AbstractFunction0.apply$mcV$sp(AbstractFunction0.scala:17)
at scala.App.$anonfun$main$1$adapted(App.scala:80)
at scala.collection.immutable.List.foreach(List.scala:392)
at scala.App.main(App.scala:80)
at scala.App.main$(App.scala:78)
at com.digitalasset.canton.CantonAppDriver.main(CantonAppDriver.scala:27)
at com.digitalasset.canton.CantonCommunityApp.main(CantonCommunityApp.scala)
Really appreciate your help in this,
1 Like
Are you sure that the domain is up and running, listening to the appropriate port on an accessible IP? Given that you try to connect to a demo setup (according to the demo.sc filename), my best guess would be that you’ve been using a wrong port /inaccessible IP address.
Please have a look at the log file in log/canton.log as well (run Canton with -v to turn on debug logging).
3 Likes
My bad, it’s because of private network issues. Thank you.
2 Likes