-
Notifications
You must be signed in to change notification settings - Fork 424
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #3974 from osmosis-labs/stage
Publish Stage
- Loading branch information
Showing
71 changed files
with
3,503 additions
and
1,665 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,97 @@ | ||
| import { Chain } from "@osmosis-labs/types"; | ||
| import { getNomicRelayerUrl, isNil, poll } from "@osmosis-labs/utils"; | ||
| import { getCheckpoint } from "nomic-bitcoin"; | ||
|
|
||
| import type { | ||
| BridgeEnvironment, | ||
| BridgeTransferStatus, | ||
| TransferStatusProvider, | ||
| TransferStatusReceiver, | ||
| TxSnapshot, | ||
| } from "../interface"; | ||
| import { NomicProviderId } from "./utils"; | ||
|
|
||
| export class NomicTransferStatusProvider implements TransferStatusProvider { | ||
| readonly providerId = NomicProviderId; | ||
| readonly sourceDisplayName = "Nomic Bridge"; | ||
| public statusReceiverDelegate?: TransferStatusReceiver; | ||
|
|
||
| constructor( | ||
| protected readonly chainList: Chain[], | ||
| readonly env: BridgeEnvironment | ||
| ) {} | ||
|
|
||
| /** Request to start polling a new transaction. */ | ||
| async trackTxStatus(snapshot: TxSnapshot): Promise<void> { | ||
| const { sendTxHash } = snapshot; | ||
|
|
||
| if (!snapshot.nomicCheckpointIndex) { | ||
| throw new Error("Nomic checkpoint index is required. Skipping tracking."); | ||
| } | ||
|
|
||
| await poll({ | ||
| fn: async () => { | ||
| const checkpoint = await getCheckpoint( | ||
| { | ||
| relayers: getNomicRelayerUrl({ env: this.env }), | ||
| bitcoinNetwork: this.env === "mainnet" ? "bitcoin" : "testnet", | ||
| }, | ||
| snapshot.nomicCheckpointIndex! | ||
| ); | ||
|
|
||
| if (isNil(checkpoint.txid)) { | ||
| return; | ||
| } | ||
|
|
||
| return { | ||
| id: snapshot.sendTxHash, | ||
| status: "success", | ||
| } as BridgeTransferStatus; | ||
| }, | ||
| validate: (incomingStatus) => incomingStatus !== undefined, | ||
| interval: 30_000, | ||
| maxAttempts: undefined, // unlimited attempts while tab is open or until success/fail | ||
| }) | ||
| .then((s) => { | ||
| if (s) this.receiveConclusiveStatus(sendTxHash, s); | ||
| }) | ||
| .catch((e) => console.error(`Polling Nomic has failed`, e)); | ||
| } | ||
|
|
||
| receiveConclusiveStatus( | ||
| sendTxHash: string, | ||
| txStatus: BridgeTransferStatus | undefined | ||
| ): void { | ||
| if (txStatus && txStatus.id) { | ||
| const { status, reason } = txStatus; | ||
| this.statusReceiverDelegate?.receiveNewTxStatus( | ||
| sendTxHash, | ||
| status, | ||
| reason | ||
| ); | ||
| } else { | ||
| console.error( | ||
| "Nomic transfer finished poll but neither succeeded or failed" | ||
| ); | ||
| } | ||
| } | ||
|
|
||
| makeExplorerUrl(snapshot: TxSnapshot): string { | ||
| const { | ||
| sendTxHash, | ||
| fromChain: { chainId: fromChainId }, | ||
| } = snapshot; | ||
|
|
||
| const chain = this.chainList.find( | ||
| (chain) => chain.chain_id === fromChainId | ||
| ); | ||
|
|
||
| if (!chain) throw new Error("Chain not found: " + fromChainId); | ||
| if (chain.explorers.length === 0) { | ||
| // attempt to link to mintscan since this is an IBC transfer | ||
| return `https://www.mintscan.io/${chain.chain_name}/txs/${sendTxHash}`; | ||
| } | ||
|
|
||
| return chain.explorers[0].tx_page.replace("{txHash}", sendTxHash); | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1 @@ | ||
| export const NomicProviderId = "Nomic"; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,65 @@ | ||
| import { | ||
| BridgeChain, | ||
| BridgeExternalUrl, | ||
| BridgeProvider, | ||
| BridgeProviderContext, | ||
| BridgeQuote, | ||
| BridgeSupportedAsset, | ||
| BridgeTransactionRequest, | ||
| GetBridgeSupportedAssetsParams, | ||
| } from "../interface"; | ||
|
|
||
| export class PenumbraBridgeProvider implements BridgeProvider { | ||
| static readonly ID = "Penumbra"; | ||
| readonly providerName = PenumbraBridgeProvider.ID; | ||
|
|
||
| constructor(protected readonly ctx: BridgeProviderContext) {} | ||
|
|
||
| async getQuote(): Promise<BridgeQuote> { | ||
| throw new Error("Penumbra quotes are currently not supported."); | ||
| } | ||
|
|
||
| async getSupportedAssets({ | ||
| asset, | ||
| }: GetBridgeSupportedAssetsParams): Promise< | ||
| (BridgeChain & BridgeSupportedAsset)[] | ||
| > { | ||
| // just supports SOL via Penumbra | ||
|
|
||
| const assetListAsset = this.ctx.assetLists | ||
| .flatMap(({ assets }) => assets) | ||
| .find( | ||
| (a) => a.coinMinimalDenom.toLowerCase() === asset.address.toLowerCase() | ||
| ); | ||
|
|
||
| if (assetListAsset) { | ||
| const penumbraCounterparty = assetListAsset.counterparty.find( | ||
| (c) => c.chainName === "penumbra" | ||
| ); | ||
|
|
||
| if (penumbraCounterparty) { | ||
| return [ | ||
| { | ||
| transferTypes: ["external-url"], | ||
| chainId: "penumbra", | ||
| chainName: "Penumbra", | ||
| chainType: "penumbra", | ||
| denom: penumbraCounterparty.symbol, | ||
| address: penumbraCounterparty.sourceDenom, | ||
| decimals: penumbraCounterparty.decimals, | ||
| }, | ||
| ]; | ||
| } | ||
| } | ||
|
|
||
| return []; | ||
| } | ||
|
|
||
| async getTransactionData(): Promise<BridgeTransactionRequest> { | ||
| throw new Error("Penumbra transactions are currently not supported."); | ||
| } | ||
|
|
||
| async getExternalUrl(): Promise<BridgeExternalUrl | undefined> { | ||
| throw new Error("Penumbra external urls are currently not supported."); | ||
| } | ||
| } |
Oops, something went wrong.