Skip to content

Commit

Permalink
ran lint:fix
Browse files Browse the repository at this point in the history
  • Loading branch information
@bee344
bee344 committed Nov 3, 2023
1 parent 05100b6 commit 6b4789f
Showing 1 changed file with 115 additions and 94 deletions.
209 changes: 115 additions & 94 deletions scripts/testNetworkLiquidAssets.ts
View file
Original file line number Diff line number Diff line change
Expand Up @@ -2,135 +2,156 @@

import { ApiPromise, WsProvider } from '@polkadot/api';
import { Keyring } from '@polkadot/keyring';
import { KeyringPair } from '@polkadot/keyring/types'
import { KeyringPair } from '@polkadot/keyring/types';
import { cryptoWaitReady } from '@polkadot/util-crypto';
import chalk from 'chalk';

import { KUSAMA_ASSET_HUB_WS_URL } from './consts';
import { awaitBlockProduction, delay, logWithDate } from './util';


const ASSET_ID = 1;
const ASSET_NAME = "Testy";
const ASSET_TICKER = "TSTY";
const ASSET_NAME = 'Testy';
const ASSET_TICKER = 'TSTY';
const ASSET_DECIMALS = 12;
const ASSET_MIN = 1;

const asset = {
parents: 0,
interior: {
X2: [
{ palletInstance: 50 },
{ generalIndex: ASSET_ID },
]
}

parents: 0,
interior: {
X2: [{ palletInstance: 50 }, { generalIndex: ASSET_ID }],
},
};

const native = {
parents: 1,
interior: {
Here: '',
},
parents: 1,
interior: {
Here: '',
},
};

const createAssetCall = (api: ApiPromise, admin: KeyringPair) => {
return api.tx.assets.create(ASSET_ID, admin.address, ASSET_MIN)
return api.tx.assets.create(ASSET_ID, admin.address, ASSET_MIN);
};

const setMetadataCall = (api: ApiPromise) => {
return api.tx.assets.setMetadata(ASSET_ID, ASSET_NAME, ASSET_TICKER, ASSET_DECIMALS)
return api.tx.assets.setMetadata(ASSET_ID, ASSET_NAME, ASSET_TICKER, ASSET_DECIMALS);
};

const mintCall = (api: ApiPromise, to: KeyringPair, amount: number) => {
return api.tx.assets.mint(ASSET_ID, to.address, amount)
}
return api.tx.assets.mint(ASSET_ID, to.address, amount);
};

const createLiquidityPoolCall = (api: ApiPromise) => {
// For now, we have to override the types of the Assets until PJS is updated
return api.tx.assetConversion.createPool(<any>native, <any>asset)
// For now, we have to override the types of the Assets until PJS is updated
// eslint-disable-next-line @typescript-eslint/no-unsafe-argument
return api.tx.assetConversion.createPool(<any>native, <any>asset);

Check warning on line 47 in scripts/testNetworkLiquidAssets.ts

View workflow job for this annotation

GitHub Actions / lint 

Unexpected any. Specify a different type

Check warning on line 47 in scripts/testNetworkLiquidAssets.ts

View workflow job for this annotation

GitHub Actions / lint 

Unexpected any. Specify a different type
};

const addLiquidityCall = (api: ApiPromise, amountNative: number, amountAsset: number, to: KeyringPair) => {
// For now, we have to override the types of the Assets until PJS is updated
return api.tx.assetConversion.addLiquidity(<any>native, <any>asset, amountNative, amountAsset, 0, 0, to.address)
// For now, we have to override the types of the Assets until PJS is updated
// eslint-disable-next-line @typescript-eslint/no-unsafe-argument
return api.tx.assetConversion.addLiquidity(<any>native, <any>asset, amountNative, amountAsset, 0, 0, to.address);

Check warning on line 53 in scripts/testNetworkLiquidAssets.ts

View workflow job for this annotation

GitHub Actions / lint 

Unexpected any. Specify a different type

Check warning on line 53 in scripts/testNetworkLiquidAssets.ts

View workflow job for this annotation

GitHub Actions / lint 

Unexpected any. Specify a different type
};

const transferLPTokensCall = (api: ApiPromise, token: number, amount: number, to: KeyringPair) => {
return api.tx.poolAssets.transferKeepAlive(token, to.address, amount)
}
return api.tx.poolAssets.transferKeepAlive(token, to.address, amount);
};

const main = async () => {
logWithDate(chalk.yellow('Initializing script to create a liquidity pool on Kusama Asset Hub'));
await cryptoWaitReady();

const keyring = new Keyring({ type: 'sr25519' });
const alice = keyring.addFromUri('//Alice');
const bob = keyring.addFromUri('//Bob');

const api = await ApiPromise.create({
provider: new WsProvider(KUSAMA_ASSET_HUB_WS_URL),
noInitWarn: true,
});

await api.isReady;

logWithDate(chalk.green('Created a connection to Kusama AssetHub'));

const txs = [];
const create = createAssetCall(api, alice);
const setMetadata = setMetadataCall(api);
const mint = mintCall(api, alice, 10000000000000);
const createPool = createLiquidityPoolCall(api);
const addLiquidity = addLiquidityCall(api, 10000000000000, 10000000000000, alice);

txs.push(create);
txs.push(setMetadata);
txs.push(mint);
txs.push(createPool);
txs.push(addLiquidity);


await api.tx.utility.batch(txs).signAndSend(alice);

await delay(24000);

const nextLpToken = await api.query.assetConversion.nextPoolAssetId();

const lpToken = Number(nextLpToken) - 1;

logWithDate(chalk.yellow('Asset and Liquidity Pool created'));

logWithDate(chalk.green(`Liquidity Pool Token ID: ${lpToken}`));

const startingBalances = await api.query.poolAssets.account.entries(lpToken);

startingBalances.slice(1).forEach(([{ args: [lpToken, address] }, value]) => {
logWithDate(chalk.blue(`LP Token: ${lpToken}, Account: ${address}, Starting liquidty token balance: ${value.unwrap().balance.toHuman()}`));
});

await delay(24000);

logWithDate(chalk.magenta('Sending 1,000,000,000,000 lpTokens from Alice to Bob on Kusama Asset Hub'));

await transferLPTokensCall(api, 0, 1000000000000, bob).signAndSend(alice);

await delay(24000);

const newBalances = await api.query.poolAssets.account.entries(lpToken);
newBalances.slice(1).forEach(([{ args: [lpToken, address] }, value]) => {
logWithDate(chalk.blue(`LP Token: ${lpToken}, Account: ${address}, New liquidty token balance: ${value.unwrap().balance.toHuman()}`));
});

await api.disconnect().then(() => {
logWithDate(chalk.yellow('Polkadot-js successfully disconnected from asset-hub'));
});

logWithDate(chalk.yellow('Initializing script to create a liquidity pool on Kusama Asset Hub'));
await cryptoWaitReady();

const keyring = new Keyring({ type: 'sr25519' });
const alice = keyring.addFromUri('//Alice');
const bob = keyring.addFromUri('//Bob');

const api = await ApiPromise.create({
provider: new WsProvider(KUSAMA_ASSET_HUB_WS_URL),
noInitWarn: true,
});

await api.isReady;

logWithDate(chalk.green('Created a connection to Kusama AssetHub'));

const txs = [];
const create = createAssetCall(api, alice);
const setMetadata = setMetadataCall(api);
const mint = mintCall(api, alice, 10000000000000);
const createPool = createLiquidityPoolCall(api);
const addLiquidity = addLiquidityCall(api, 10000000000000, 10000000000000, alice);

txs.push(create);
txs.push(setMetadata);
txs.push(mint);
txs.push(createPool);
txs.push(addLiquidity);

await api.tx.utility.batch(txs).signAndSend(alice);

await delay(24000);

const nextLpToken = await api.query.assetConversion.nextPoolAssetId();

const lpToken = Number(nextLpToken) - 1;

logWithDate(chalk.yellow('Asset and Liquidity Pool created'));

logWithDate(chalk.green(`Liquidity Pool Token ID: ${lpToken}`));

const startingBalances = await api.query.poolAssets.account.entries(lpToken);

startingBalances.slice(1).forEach(
([
{
args: [lpToken, address],
},
value,
]) => {
logWithDate(
chalk.blue(
`LP Token: ${Number(lpToken)}, Account: ${address.toString()}, Starting liquidty token balance: ${value
.unwrap()
.balance.toHuman()}`
)
);
}
);

await delay(24000);

logWithDate(chalk.magenta('Sending 1,000,000,000,000 lpTokens from Alice to Bob on Kusama Asset Hub'));

await transferLPTokensCall(api, 0, 1000000000000, bob).signAndSend(alice);

await delay(24000);

const newBalances = await api.query.poolAssets.account.entries(lpToken);
newBalances.slice(1).forEach(
([
{
args: [lpToken, address],
},
value,
]) => {
logWithDate(
chalk.blue(
`LP Token: ${Number(lpToken)}, Account: ${address.toString()}, New liquidty token balance: ${value
.unwrap()
.balance.toHuman()}`
)
);
}
);

await api.disconnect().then(() => {
logWithDate(chalk.yellow('Polkadot-js successfully disconnected from asset-hub'));
});
};

// eslint-disable-next-line @typescript-eslint/no-floating-promises
awaitBlockProduction(KUSAMA_ASSET_HUB_WS_URL).then(async () => {
await main()
.catch(console.error)
.finally(() => process.exit());
await main()
.catch(console.error)
.finally(() => process.exit());
});

0 comments on commit 6b4789f

Please sign in to comment.