SmProvider

.changeset/major-numbers-relax.md

@@ -0,0 +1,8 @@
+---
+'@galacticcouncil/sdk-next': minor
+'@galacticcouncil/xc-core': minor
+'@galacticcouncil/common': minor
+'@galacticcouncil/xc': minor
+---
+
+smoldot provider support

packages/common/src/substrate/SubstrateApis.ts

@@ -1,4 +1,5 @@
 import { createClient, PolkadotClient } from 'polkadot-api';
+import { JsonRpcProvider } from '@polkadot-api/json-rpc-provider';
 import { getWsProvider } from 'polkadot-api/ws-provider';
 import { LRUCache } from 'lru-cache';
 import { Subscription } from 'rxjs';
@@ -103,6 +104,24 @@ export class SubstrateApis {
     return this.createClient(endpoints, opts);
   }
 
+  public smApi(key: string, provider: JsonRpcProvider): PolkadotClient {
+    if (this._cache.has(key)) {
+      return this._cache.get(key)!.client;
+    }
+
+    const client = createClient(provider, this._metadataCache);
+    console.log(`Created PAPI sm client for ${key}`);
+
+    const connection: CachedConnection = {
+      client,
+      provider: provider as WsProvider,
+      endpoints: [key],
+      currentEndpointIndex: 0,
+    };
+    this._cache.set(key, connection, { noDisposeOnSet: true });
+    return client;
+  }
+
   public release() {
     for (const [key, connection] of this._cache.entries()) {
       this.stopHealthProbe(connection);

packages/sdk-next/src/api/provider/chainspec/hydration.ts

@@ -0,0 +1,33 @@
+export const chainSpec = `{
+  "name": "Hydration",
+  "id": "hydra",
+  "chainType": "Live",
+  "bootNodes": [
+    "/dns/p2p-01.hydra.hydradx.io/tcp/30333/p2p/12D3KooWHzv7XVVBwY4EX1aKJBU6qzEjqGk6XtoFagr5wEXx6MsH",
+    "/dns/p2p-02.hydra.hydradx.io/tcp/30333/p2p/12D3KooWR72FwHrkGNTNes6U5UHQezWLmrKu6b45MvcnRGK8J3S6",
+    "/dns/p2p-03.hydra.hydradx.io/tcp/30333/p2p/12D3KooWFDwxZinAjgmLVgsideCmdB2bz911YgiQdLEiwKovezUz",
+    "/dns4/boot.helikon.io/tcp/15120/p2p/12D3KooWDcQY1L2ny3F7YPyP4snCZZYc4eKWgPLEzdBvWBUjH5Yt",
+    "/dns4/boot.helikon.io/tcp/15125/wss/p2p/12D3KooWDcQY1L2ny3F7YPyP4snCZZYc4eKWgPLEzdBvWBUjH5Yt",
+    "/dns/hydration.boot.stake.plus/tcp/30332/wss/p2p/12D3KooWGZaDfqPyzVxhA3k1qv72P7xqYTJS8W9U7GWUEdXYhtUU",
+    "/dns/hydration.boot.stake.plus/tcp/31332/wss/p2p/12D3KooWBJMG8LCh6pLYbGapA3SNzjhQWE87ieGux41jKQrrf5js",
+    "/dns/hydration-boot-ng.dwellir.com/tcp/443/wss/p2p/12D3KooWMNf1YGh3rxaiWPjzQ1UKQxKq2WSjAKdrSgdcYaFH4ie5",
+    "/dns/hydration-boot-ng.dwellir.com/tcp/30366/p2p/12D3KooWMNf1YGh3rxaiWPjzQ1UKQxKq2WSjAKdrSgdcYaFH4ie5",
+    "/dns/hydration-bootnode.radiumblock.com/tcp/30333/p2p/12D3KooWCtrMH4H2p5XkGHkU7K4CcbSmErouNuN3j7Bysj4a8hJX",
+    "/dns/hydration-bootnode.radiumblock.com/tcp/30336/wss/p2p/12D3KooWCtrMH4H2p5XkGHkU7K4CcbSmErouNuN3j7Bysj4a8hJX"
+  ],
+  "telemetryEndpoints": [
+    ["/dns/telemetry.polkadot.io/tcp/443/x-parity-wss/%2Fsubmit%2F", 0],
+    ["/dns/telemetry.hydradx.io/tcp/9000/x-parity-wss/%2Fsubmit%2F", 0]
+  ],
+  "protocolId": "hdx",
+  "properties": {
+    "tokenDecimals": 12,
+    "tokenSymbol": "HDX"
+  },
+  "relay_chain": "polkadot",
+  "para_id": 2034,
+  "codeSubstitutes": {},
+  "genesis": {
+    "stateRootHash": "0x33a542156b00e7dd467e2b7704563abd84f888ccbc6afd6f1a1802a55db1d4de"
+  }
+}`;

packages/sdk-next/src/api/provider/smoldot.ts

@@ -1,6 +1,8 @@
 import { getSmProvider } from 'polkadot-api/sm-provider';
 
-export async function getSm(chainSpec: string) {
+import { chainSpec } from './chainspec/hydration';
+
+export async function getSm() {
   const { start } = await import('polkadot-api/smoldot');
   const { chainSpec: relayChainSpec } =
     await import('polkadot-api/chains/polkadot');

packages/xc-core/src/chain/Parachain.ts

@@ -1,4 +1,5 @@
 import { PolkadotClient } from 'polkadot-api';
+import { JsonRpcProvider } from '@polkadot-api/json-rpc-provider';
 import { withLegacy } from '@polkadot-api/legacy-provider';
 
 import { SubstrateApis } from '@galacticcouncil/common';
@@ -55,6 +56,7 @@ export interface ParachainAssetData extends ChainAssetData {
 export interface ParachainParams extends ChainParams<ParachainAssetData> {
   genesisHash: string;
   parachainId: number;
+  smProvider?: JsonRpcProvider;
   ss58Format: number;
   treasury?: string;
   usesChainDecimals?: boolean;
@@ -74,6 +76,8 @@ export class Parachain extends Chain<ParachainAssetData> {
 
   readonly parachainId: number;
 
+  smProvider: JsonRpcProvider | undefined;
+
   readonly ss58Format: number;
 
   readonly treasury: string | undefined;
@@ -97,6 +101,7 @@ export class Parachain extends Chain<ParachainAssetData> {
   constructor({
     genesisHash,
     parachainId,
+    smProvider,
     ss58Format,
     treasury,
     usesChainDecimals = false,
@@ -112,6 +117,7 @@ export class Parachain extends Chain<ParachainAssetData> {
     super({ ...others });
     this.genesisHash = genesisHash;
     this.parachainId = parachainId;
+    this.smProvider = smProvider;
     this.ss58Format = ss58Format;
     this.treasury = treasury;
     this.usesChainDecimals = usesChainDecimals;
@@ -126,6 +132,9 @@ export class Parachain extends Chain<ParachainAssetData> {
 
   get client(): PolkadotClient {
     const pool = SubstrateApis.getInstance();
+    if (this.smProvider) {
+      return pool.smApi(this.key, this.smProvider);
+    }
     return pool.api(this.ws, {
       wsProviderOpts: this.usesLegacyEnhancer
         ? { innerEnhancer: withLegacy() }

packages/xc/src/factory.ts

@@ -28,6 +28,11 @@ export async function createXcContext(opts: XcOpts = {}): Promise<XcCtx> {
   // Get chain ctx
   const hydration = config.getChain('hydration') as Parachain;
 
+  // Configure smoldot provider if provided
+  if (opts.smProvider) {
+    hydration.smProvider = opts.smProvider;
+  }
+
   // Initialize clients
   const whScan = new WormholeScan();
   const whTransfer = new WormholeTransfer(config, hydration.parachainId);

packages/xc/src/types.ts

@@ -1,3 +1,4 @@
+import type { JsonRpcProvider } from '@polkadot-api/json-rpc-provider';
 import type { ConfigService } from '@galacticcouncil/xc-core';
 import type {
   Wallet,
@@ -18,4 +19,5 @@ export type XcCtx = {
 
 export type XcOpts = {
   poolCtx?: pool.PoolContextProvider;
+  smProvider?: JsonRpcProvider;
 };