git.delta.rocks / unique-network / refs/commits / d6234d028cb3

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 { EventRecord } from '@polkadot/types/interfaces/system/types';8import { ExtrinsicStatus } from '@polkadot/types/interfaces/author/types';9import { IKeyringPair } from "@polkadot/types/types";1011import config from "../config";12import promisifySubstrate from "./promisify-substrate";13import { ApiOptions, SubmittableExtrinsic, ApiTypes } from "@polkadot/api/types";14import rtt from "../../../runtime_types.json";1516function defaultApiOptions(): ApiOptions {17  const wsProvider = new WsProvider(config.substrateUrl);18  return { provider: wsProvider, types: rtt };19}2021export default async function usingApi(action: (api: ApiPromise) => Promise<void>, settings: ApiOptions | undefined = undefined): Promise<void> {22  settings = settings || defaultApiOptions();23  let api: ApiPromise = new ApiPromise(settings);2425  try {26    await promisifySubstrate(api, async () => {27      if(api) {28        await api.isReadyOrError;29        await action(api);30      }31    })();32  } finally {33    await api.disconnect();34  }35}3637enum TransactionStatus {38  Success,39  Fail,40  NotReady41}4243function getTransactionStatus(events: EventRecord[], status: ExtrinsicStatus): TransactionStatus {44  if (status.isReady) {45    return TransactionStatus.NotReady;46  }47  if (status.isBroadcast) {48    return TransactionStatus.NotReady;49  } 50  if (status.isInBlock || status.isFinalized) {51    if(events.filter(e => e.event.data.method === 'ExtrinsicFailed').length > 0) {52      return TransactionStatus.Fail;53    }54    if(events.filter(e => e.event.data.method === 'ExtrinsicSuccess').length > 0) {55      return TransactionStatus.Success;56    }57  }5859  return TransactionStatus.Fail;60}6162export function63submitTransactionAsync(sender: IKeyringPair, transaction: SubmittableExtrinsic<ApiTypes>): Promise<EventRecord[]> {64  return new Promise(async (resolve, reject) => {65    try {66      await transaction.signAndSend(sender, ({ events = [], status }) => {67        const transactionStatus = getTransactionStatus(events, status);6869        if (transactionStatus === TransactionStatus.Success) {70          resolve(events);71        } else if (transactionStatus === TransactionStatus.Fail) {72          console.log(`Something went wrong with transaction. Status: ${status}`);73          reject(events);74        }75      });76    } catch (e) {77      console.log('Error: ', e);78      reject(e);79    }80  });81}8283export function submitTransactionExpectFailAsync(sender: IKeyringPair, transaction: SubmittableExtrinsic<ApiTypes>): Promise<EventRecord[]> {84  const consoleError = console.error;85  const consoleLog = console.log;86  console.error = () => {};87  console.log = () => {};8889  return new Promise<EventRecord[]>(async function(res, rej) {90    const resolve = (rec: EventRecord[]) => {91      setTimeout(() => {92        res(rec);93        console.error = consoleError;94        console.log = consoleLog;95      });96    };97    const reject = (errror: any) => {98      setTimeout(() => {99        rej(errror);100        console.error = consoleError;101        console.log = consoleLog;102      });103    };104    try {105      await transaction.signAndSend(sender, ({ events = [], status }) => {106        const transactionStatus = getTransactionStatus(events, status);107108        // console.log('transactionStatus', transactionStatus, 'events', events);109110        if (transactionStatus === TransactionStatus.Success) {111          resolve(events);112        } else if (transactionStatus === TransactionStatus.Fail) {113          reject(events);114        }115      });116    } catch (e) {117      reject(e);118    }119  });120}