Press n or j to go to the next uncovered block, b, p or k for the previous block.
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 | 18x 18x 18x 18x 14x 18x 2x 3x 3x 3x 2x 2x 2x 2x 2x 14x 14x 3x 2x 3x | import * as Crypto from '@cardano-sdk/crypto';
import { BlockfrostClient, BlockfrostProvider, fetchSequentially } from '../blockfrost';
import { Cardano, MULTISIG_CIP_ID, Serialization } from '@cardano-sdk/core';
import { Logger } from 'ts-log';
import { MultiSigRegistration, MultiSigTransaction, SharedWalletProvider } from './types';
import type { Responses } from '@blockfrost/blockfrost-js';
const MULTI_SIG_LABEL = MULTISIG_CIP_ID;
const isMultiSigRegistration = (metadata: unknown): metadata is MultiSigRegistration =>
!!metadata && typeof metadata === 'object' && 'participants' in metadata;
export class BlockfrostSharedWalletProvider extends BlockfrostProvider implements SharedWalletProvider {
constructor(client: BlockfrostClient, logger: Logger) {
super(client, logger);
}
private async getNativeScripts(txId: Cardano.TransactionId): Promise<Cardano.Script[]> {
const response = await this.request<Responses['tx_content_cbor']>(`txs/${txId}/cbor`);
const transaction = Serialization.Transaction.fromCbor(Serialization.TxCBOR(response.cbor)).toCore();
return transaction.auxiliaryData?.scripts ?? [];
}
async discoverWallets(pubKey: Crypto.Ed25519KeyHashHex): Promise<MultiSigTransaction[]> {
const batchSize = 100;
const multiSigTransactions = await fetchSequentially<Responses['tx_metadata_label_json'][0], MultiSigTransaction>(
{
haveEnoughItems: (wallets, _) => wallets.length < batchSize,
paginationOptions: { count: batchSize },
request: (paginationQueryString) =>
this.request<Responses['tx_metadata_label_json']>(
`metadata/txs/labels/${MULTI_SIG_LABEL}?${paginationQueryString}`
),
responseTranslator: (wallets) =>
wallets
.filter((wallet) => {
const metadata = wallet.json_metadata;
return isMultiSigRegistration(metadata) && metadata?.participants?.[pubKey];
})
.map((wallet) => ({
metadata: wallet.json_metadata as unknown as MultiSigRegistration,
nativeScripts: [],
txId: Cardano.TransactionId(wallet.tx_hash)
}))
},
[]
);
return await Promise.all(
multiSigTransactions.map(async (wallet) => ({
...wallet,
nativeScripts: await this.getNativeScripts(wallet.txId)
}))
);
}
}
|