TTA-Cert/TC4/start.ts

import * as dotevnv from "dotenv"
import {toUtf8String,parseUnits,ContractFactory, parseEther,JsonRpcProvider, Contract, JsonRpcSigner, Wallet,ContractTransactionResponse, MaxInt256
    ,Transaction,formatEther,
    ZeroHash,ethers,keccak256
} from 'ethers'
import chalk from "chalk";
// import * as chalk from "chalk";
// import {foregroundColorNames} from 'chalk';

import {Calulator} from "../inc/calc";
import { TokenIssuer } from "../inc/TokenIssuer";
import {
    SecurityToken,
    SecurityToken__factory,
} from '../typechain'
// import { HardhatEthersSigner } from "@nomicfoundation/hardhat-ethers/signers";
import {checkReceipt,checkReceipt2, setProvider,getDeploymentAddresses, 
    getElapsed, sleep,getBlockInfo} from '../inc/util'
dotevnv.config();
if (!process.env.RPCURL) {
    console.log(`No rpcur value specified...`)
}


console.log(`목적 서버 : ${process.env.RPCURL}`);

async function getNonce(addr: string): Promise<number> {
    const nonce = await provider.getTransactionCount(addr);
    return nonce;
}


async function info(symbol: string) {
    const proxy = getDeploymentAddresses(symbol).address;
    console.log(`토큰 주소 : ${proxy}`);

    const token = new SecurityToken__factory(issuer).attach(proxy) as SecurityToken;
    await token.connect(admin);
    const ops = await token.operators();
    console.log(ops);

    // token.grantRole(keccak256('OPERATOR_ROLE'),'0xaaa')
    
}   

async function transfer(symbol:string,from: Wallet, to: Wallet, amount: number = 1, count: number = 10) {

    const proxy = getDeploymentAddresses(symbol).address;
    console.log(`토큰 주소 : ${proxy}`);



    const token = new SecurityToken__factory(issuer).attach(proxy) as SecurityToken;
    await token.connect(admin);
    
    // const ops = await token.operators();
    // console.log(ops);
    
    let balance1= await token.balanceOf(from);
    let balance2 = await token.balanceOf(to);
    const b  = await token.isTokenHolderKYC(from);
    if(!b) {
        console.log('holder kyc error');
        return;
    }

    const partitions = await token.getDefaultPartitions();
    console.log(chalk.yellow('###################### 전송전 잔고 ###################################'))
    console.log(`balance of sender(${from.address}) = ${balance1}\r\nbalance of receiver(${to.address}) = ${balance2}`);

    // token.on(token.filters.Transfer, async (...args) => {
    //     const lastArg = args[args.length - 1];
    //     console.log(lastArg);
    //     console.log('on transfer by partition');
    // })

    
    let nonce = await getNonce(signer.address);
    let txids = [];
    let proms = [];
    let firstTx:string = null;
    let lastTx:string = null;
    const start = Date.now();

    console.log(chalk.cyan(`전송시작 시간 : ${new Date(start).toUTCString()}`));
    

    console.log(chalk.yellow(`sending ${count} transactions`));
    for(let i = 0; i < count; i++) {
        const tx = await token.operatorTransferByPartition.populateTransaction(
            partitions[0],
            from.address,
            to.address,
            amount,
            ZeroHash,
            ZeroHash,
            {
                // gasPrice: 0,
                gasLimit: 2100000,
                nonce: nonce,
                type: 2,
                chainId: 1337
            }
        );
        ++nonce;
        // console.log(tx);
        
        const signed =  await signer.signTransaction(tx);
        const pm = provider.send('eth_sendRawTransaction',[signed]);

        if(i == 0) {
            firstTx = keccak256(signed);
        }
        if (i == count -1) {
            lastTx = keccak256(signed);
        }
        proms.push(pm);
    }

    let txs = await Promise.all(proms);

    const elapsed = getElapsed(start,1000);
    console.log(`all tx sent in ${elapsed} seconds`);

    console.log(`first Tx = ${firstTx}`);
    console.log(`last Tx = ${lastTx}`);
    
    let txMap = new Map<string,boolean>();
    txs.forEach(txid => {
        // txids.push({txid: txid});
        txMap.set(txid,false);
    });
    const blockHashes = await checkReceipt2(txMap,[firstTx as string, lastTx as string], 'wait for receipt...');

    const firstBlockHash = blockHashes.get(firstTx);
    const lastBlockHash = blockHashes.get(lastTx);
    console.log(`firstBlockHash = ${firstBlockHash} \nlastBlockHash = ${lastBlockHash}`);

    balance1= await token.balanceOf(from);
    balance2 = await token.balanceOf(to);
    console.log(chalk.yellow('###################### 전송후 잔고 ###################################'))
    console.log(`balance of sender(${from.address}) = ${balance1}\r\nbalance of receiver(${to.address}) = ${balance2}`);
    // console.log(`balance of sender = ${balance1}, balance of receiver = ${balance2}`);
    
    
    const lastB = await getBlockInfo(lastBlockHash);
    const lastTimeStamp = parseInt(lastB.timestamp,16);
    console.log(`eth_getBlockByHash(${lastBlockHash}).timestamp = ${lastTimeStamp}`)

    const d = new Date(lastTimeStamp * 1000);
    console.log(chalk.cyan(`전송종료 시간(블록완결시간) : ${d.toUTCString()}`));

    console.log(chalk.yellow(`start timestamp = ${start}`));
    console.log(chalk.yellow(`end timestamp = ${lastTimeStamp * 1000}`));

    const tps = calc.CTPS(count,start,lastTimeStamp * 1000);
    console.log(`CTPS = ${tps}`);

}




const calc = new Calulator();
const rpcUrl = process.env.RPCURL;
const provider = new JsonRpcProvider(rpcUrl);
setProvider(provider);

const admin = new Wallet('0xc87509a1c067bbde78beb793e6fa76530b6382a4c0241e5e4a9ec0a0f44dc0d3',provider);
const issuer = new Wallet('0x8f2a55949038a9610f50fb23b5883af3b4ecb3c3bb792cbcefbd1542c692be63',provider);
// const signer = new Wallet('0x55d1000aa2057a878b5f7902158615f889cb1e9b811f7e1e9c0b4518399ba84a',provider);
const signer = issuer;
const holder1 = new Wallet('0xae6ae8e5ccbfb04590405997ee2d52d2b330726137b875053c36d94e974d162f',provider);
const holder2 = new Wallet('0xac0974bec39a17e36ba4a6b4d238ff944bacb478cbed5efcae784d7bf4f2ff80',provider);

async function main() {
     transfer('test001',holder2, holder1,1, 1000);
}

main();