git.delta.rocks / unique-network / refs/commits / 735c2a469e47

1//2// This file is subject to the terms and conditions defined in3// file 'LICENSE', which is part of this source code package.4//56import { WsProvider, ApiPromise } from "@polkadot/api";7import type { AccountId, Address, ApplyExtrinsicResult, DispatchError, DispatchInfo, EventRecord, Extrinsic, ExtrinsicStatus, Hash, RuntimeDispatchInfo } from '@polkadot/types/interfaces';8import { IKeyringPair } from "@polkadot/types/types";910import config from "../config";11import promisifySubstrate from "./promisify-substrate";12import { ApiOptions, SubmittableExtrinsic, ApiTypes } from "@polkadot/api/types";13import rtt from "../../../runtime_types.json";1415function defaultApiOptions(): ApiOptions {16  const wsProvider = new WsProvider(config.substrateUrl);17  return { provider: wsProvider, types: rtt };18}1920export default async function usingApi(action: (api: ApiPromise) => Promise<void>, settings: ApiOptions | undefined = undefined): Promise<void> {21  settings = settings || defaultApiOptions();22  let api: ApiPromise = new ApiPromise(settings);2324  // TODO: Remove, this is temporary: Filter unneeded API output 25  // (Jaco promised it will be removed in the next version)26  const consoleLog = console.log;27  console.log = (message: string) => {28    if (!(message.includes("API/INIT: Capabilities detected") || message.includes("2021-"))) {29      consoleLog(message);30    }31  };3233  try {34    await promisifySubstrate(api, async () => {35      if(api) {36        await api.isReadyOrError;37        await action(api);38      }39    })();40  } finally {41    await api.disconnect();42    console.log = consoleLog;43  }44}4546enum TransactionStatus {47  Success,48  Fail,49  NotReady50}5152function getTransactionStatus(events: EventRecord[], status: ExtrinsicStatus): TransactionStatus {53  if (status.isReady) {54    return TransactionStatus.NotReady;55  }56  if (status.isBroadcast) {57    return TransactionStatus.NotReady;58  } 59  if (status.isInBlock || status.isFinalized) {60    if(events.filter(e => e.event.data.method === 'ExtrinsicFailed').length > 0) {61      return TransactionStatus.Fail;62    }63    if(events.filter(e => e.event.data.method === 'ExtrinsicSuccess').length > 0) {64      return TransactionStatus.Success;65    }66  }6768  return TransactionStatus.Fail;69}7071export function72submitTransactionAsync(sender: IKeyringPair, transaction: SubmittableExtrinsic<ApiTypes>): Promise<EventRecord[]> {73  return new Promise(async (resolve, reject) => {74    try {75      await transaction.signAndSend(sender, ({ events = [], status }) => {76        const transactionStatus = getTransactionStatus(events, status);7778        if (transactionStatus === TransactionStatus.Success) {79          resolve(events);80        } else if (transactionStatus === TransactionStatus.Fail) {81          console.log(`Something went wrong with transaction. Status: ${status}`);82          reject(events);83        }84      });85    } catch (e) {86      console.log('Error: ', e);87      reject(e);88    }89  });90}9192export function submitTransactionExpectFailAsync(sender: IKeyringPair, transaction: SubmittableExtrinsic<ApiTypes>): Promise<EventRecord[]> {93  const consoleError = console.error;94  const consoleLog = console.log;95  console.error = () => {};96  console.log = () => {};9798  return new Promise<EventRecord[]>(async function(res, rej) {99    const resolve = (rec: EventRecord[]) => {100      setTimeout(() => {101        res(rec);102        console.error = consoleError;103        console.log = consoleLog;104      });105    };106    const reject = (errror: any) => {107      setTimeout(() => {108        rej(errror);109        console.error = consoleError;110        console.log = consoleLog;111      });112    };113    try {114      await transaction.signAndSend(sender, ({ events = [], status }) => {115        const transactionStatus = getTransactionStatus(events, status);116117        console.log('transactionStatus', transactionStatus, 'events', events);118119        if (transactionStatus == TransactionStatus.Success) {120          resolve(events);121        } else if (transactionStatus == TransactionStatus.Fail) {122          reject(events);123        }124      });125    } catch (e) {126      reject(e);127    }128  });129}