coin-canton broadcast

Author: hedi-edelbloute

.changeset/angry-bags-notice.md

@@ -0,0 +1,6 @@
+---
+"@ledgerhq/coin-canton": minor
+"@ledgerhq/live-common": minor
+---
+
+coin-canton broadcast

libs/coin-modules/coin-canton/src/common-logic/transaction/broadcast.ts

@@ -1,6 +1,10 @@
-import { submit } from "../../network/node";
+import coinConfig from "../../config";
+import { submit } from "../../network/gateway";
+
+const useGateway = () => coinConfig.getCoinConfig().useGateway === true;
 
 export async function broadcast(signedTx: string): Promise<string> {
-  const submittedPayment = await submit(signedTx);
-  return submittedPayment.tx_hash;
+  const parsed: { serialized: string; signature: string } = JSON.parse(signedTx);
+  if (useGateway()) return (await submit(parsed.serialized, parsed.signature)).updateId;
+  else throw new Error("Not implemented");
 }

libs/coin-modules/coin-canton/src/common-logic/transaction/estimateFees.ts

@@ -1,16 +1,4 @@
-import { simulate } from "../../network/node";
-import { SimulationError } from "../../types/errors";
-
+// eslint-disable-next-line @typescript-eslint/no-unused-vars
 export async function estimateFees(serializedTransaction: string): Promise<bigint> {
-  try {
-    // We call the node to do a dry run and estimate fees
-    return BigInt(await simulate(serializedTransaction));
-  } catch (e) {
-    // default value is required in case of simulation error, else user will encounter an error in the flow
-    if (e instanceof SimulationError) {
-      return BigInt(1000);
-    } else {
-      throw new Error("Unexpected error while estimating fees.");
-    }
-  }
+  return Promise.resolve(BigInt(10_000)); // TODO replace with real implementation
 }

libs/coin-modules/coin-canton/src/network/gateway.integ.test.ts

@@ -19,6 +19,7 @@ describe("gateway (devnet)", () => {
       },
     }));
   });
+
   describe("prepareOnboarding", () => {
     it("should prepare onboarding", async () => {
       const response = await prepareOnboarding(
@@ -31,6 +32,11 @@ describe("gateway (devnet)", () => {
       expect(response).toHaveProperty("topology_transactions_hash");
     }, 30000);
   });
+
+  describe("submit", () => {
+    it("should submit", async () => {}, 30000);
+  });
+
   describe("getLedgerEnd", () => {
     it("should return ledger end", async () => {
       const end = await getLedgerEnd();

libs/coin-modules/coin-canton/src/network/gateway.ts

@@ -26,6 +26,13 @@ type OnboardingSubmitResponse = {
   };
 };
 
+type TransactionSubmitRequest = {
+  serialized: string;
+  signature: string;
+};
+
+type TransactionSubmitResponse = { updateId: string };
+
 export type InstrumentBalance = {
   instrumentId: string;
   amount: number;
@@ -118,6 +125,18 @@ export async function submitOnboarding(
   return data;
 }
 
+export async function submit(serializedTx: string, signature: string) {
+  const { data } = await network<TransactionSubmitResponse>({
+    method: "POST",
+    url: `${getGatewayUrl()}/v1/node/${getNodeId()}/transaction/submit`,
+    data: {
+      serialized: serializedTx,
+      signature,
+    } satisfies TransactionSubmitRequest,
+  });
+  return data;
+}
+
 export async function getBalance(partyId: string): Promise<InstrumentBalance[]> {
   const { data } = await network<InstrumentBalance[]>({
     method: "GET",

libs/ledger-live-common/src/bridge/generic-alpaca/alpaca/index.ts

@@ -1,24 +1,31 @@
 import { createApi as createXrpApi } from "@ledgerhq/coin-xrp/api/index";
 import { createApi as createStellarApi } from "@ledgerhq/coin-stellar/api/index";
+import { createApi as createCantonApi } from "@ledgerhq/coin-canton/api/index";
+import { createApi as createTronApi } from "@ledgerhq/coin-tron/api/index";
 import { getCurrencyConfiguration } from "../../../config";
 import { getCryptoCurrencyById } from "@ledgerhq/cryptoassets/currencies";
 import { getNetworkAlpacaApi } from "./network/network-alpaca";
 import { Api } from "@ledgerhq/coin-framework/api/types";
 import { XrpCoinConfig } from "@ledgerhq/coin-xrp/config";
 import { StellarCoinConfig } from "@ledgerhq/coin-stellar/config";
+import { CantonCoinConfig } from "@ledgerhq/coin-canton/config";
+import { TronCoinConfig } from "@ledgerhq/coin-tron/config";
 
 export function getAlpacaApi(network, kind): Api<any> {
+  const currency = getCryptoCurrencyById(network);
   if (kind === "local") {
     switch (network) {
       case "ripple":
       case "xrp":
-        return createXrpApi(
-          getCurrencyConfiguration<XrpCoinConfig>(getCryptoCurrencyById("ripple")),
-        ) as Api<any>; // FIXME: createXrpApi returns a strongly typed Api<XrpSender>, fix Api<any> to allow it
+        return createXrpApi(getCurrencyConfiguration<XrpCoinConfig>(currency)) as Api<any>; // FIXME: createXrpApi returns a strongly typed Api<XrpSender>, fix Api<any> to allow it
       case "stellar":
-        return createStellarApi(
-          getCurrencyConfiguration<StellarCoinConfig>(getCryptoCurrencyById("stellar")),
-        ) as Api<any>;
+        return createStellarApi(getCurrencyConfiguration<StellarCoinConfig>(currency)) as Api<any>;
+      case "canton_network_localnet":
+      case "canton_network_devnet":
+      case "canton_network_mainnet":
+        return createCantonApi(getCurrencyConfiguration<CantonCoinConfig>(currency)) as Api<any>;
+      case "tron":
+        return createTronApi(getCurrencyConfiguration<TronCoinConfig>(currency)) as Api<any>;
     }
   }
   return getNetworkAlpacaApi(network) satisfies Partial<Api<any>> as Api<any>;