jongheeda
/
TTA-Cert
Watch 1
Star 0
Fork 0
Code Issues 0 Pull Requests 0 Releases 0 Wiki Activity
Browse Source

w

master
Simon Lee 1 year ago
parent
b2e0221ac0
commit
9232688764
8 changed files with 208 additions and 157 deletions
Split View Show Diff Stats
  1. 15
    3
      .env
  2. 3
    0
      BCG_TEST_deployments copy.json
  3. 1
    1
      BCG_TEST_deployments.json
  4. 103
    40
      TC2/start.ts
  5. 2
    2
      TC3/start.ts
  6. 1
    1
      TC4/start.ts
  7. 0
    110
      TC6/start.ts
  8. 83
    0
      TC9/start.ts

+ 15
- 3
.env View File

@@ -5,8 +5,20 @@
# CHAINID=1337

#OCI
# RPCURL=http://193.123.252.127:80
# CHAINID=1337
# GATE_WAY=https://api.stopulse.co.kr/main/v1/
# GATE_WAY_RAW=https://api.stopulse.co.kr/
# AUTHTOKEN=580c6006687220df84f83d7c345c00ad9829de0694bd00c09e211d8c810b7510



#dev
RPCURL=http://193.123.252.127:80
CHAINID=1337
GATE_WAY=https://api.stopulse.co.kr/main/v1/
GATE_WAY_RAW=https://api.stopulse.co.kr/
AUTHTOKEN=580c6006687220df84f83d7c345c00ad9829de0694bd00c09e211d8c810b7510
GATE_WAY=http://172.25.1.108/main/v1/
GATE_WAY_RAW=http://172.25.1.108/
AUTHTOKEN=18851850e4237cc34ea0a7a1de7cb5af362ee854363b60983ed4c18d9b12cb27




+ 3
- 0
BCG_TEST_deployments copy.json View File

@@ -0,0 +1,3 @@
{
"address": "0x42707a63160580896582e65703e0985d920f9ca6"
}

+ 1
- 1
BCG_TEST_deployments.json View File

@@ -1,3 +1,3 @@
{
"address": "0x42707a63160580896582e65703e0985d920f9ca6"
"address": "0xA3a3112b6C00225f1Aa331c2EbCD691d1De3f2bd"
}

+ 103
- 40
TC2/start.ts View File

@@ -1,7 +1,7 @@
import * as dotevnv from "dotenv"
import {toUtf8String,parseUnits,ContractFactory, parseEther,JsonRpcProvider, Contract, JsonRpcSigner, Wallet,ContractTransactionResponse, MaxInt256
,Transaction,formatEther,
ZeroHash,ethers,keccak256
ZeroHash,ethers,keccak256,id
} from 'ethers'
import {Calulator} from "../inc/calc";
import axios from "axios";
@@ -13,7 +13,7 @@ import {
import chalk from "chalk";
import {checkReceipt,checkReceipt2, setProvider,getDeploymentAddresses,
getElapsed, sleep,getBlockInfo} from '../inc/util'
import { sign } from "crypto";
dotevnv.config();
if (!process.env.RPCURL) {
console.log(`No rpcur value specified...`)
@@ -27,33 +27,79 @@ async function getNonce(addr: string): Promise<number> {



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


const token = new SecurityToken__factory(issuer).attach(proxy) as SecurityToken;
await token.connect(admin);
const adminToken = await token.connect(admin);

const n = await token.decimals();
const decimals = Number(n);
const digit = 10 ** Number(decimals);

const ops = await token.operators();
console.log(ops);

let operatorRegistered = false;
for(let i = 0; i < ops.length; i++) {
//console.log(`${ops[i].toLocaleLowerCase()} == ${issuer.address.toLocaleLowerCase()}`)
if( ops[i].toLocaleLowerCase() == issuer.address.toLocaleLowerCase()) {
operatorRegistered = true;
}
}
if(!operatorRegistered) {
console.log('issuer not registered as operator .. so register');
let ret = await adminToken.grantRole( id('OPERATOR_ROLE'),issuer,{ gasLimit: 20000000});
await ret.wait();
}

const balance = await token.balanceOf(firstHolder);
const partitions = await token.getDefaultPartitions();
console.log(partitions);

let balance = await token.balanceOf(firstHolder);
console.log(`initial balance = ${balance}`);

let b = await token.isTokenHolderKYC('0x2071ec931b2567a1418e9bc34b786d654a079b43');
let addressesToKyc = [];
let b = await token.isTokenHolderKYC(firstHolder);
if(!b) {
console.log('kyc check first!');
return;
console.log('firstHolder needs to be registered');
addressesToKyc.push(firstHolder);
}

await token.KYCtokenHolders([holder1.address,holder2.address]);

b = await token.isTokenHolderKYC(holder1.address);
if(!b) {
console.log('kyc check first!');
return;
console.log('holder1 needs to be registered');
addressesToKyc.push(holder1.address);
}
b = await token.isTokenHolderKYC(holder2.address);
if(!b) {
console.log('holder1 needs to be registered');
addressesToKyc.push(holder2.address);
}

if(addressesToKyc.length != 0) {
let r = await token.KYCtokenHolders(addressesToKyc);
await r.wait();
}
// token.grantRole(keccak256('OPERATOR_ROLE'),'0xaaa')

balance = await token.balanceOf(holder1);
let fixedBalance = (1/digit) * Number(balance);
console.log(`holder1(${holder1.address}) balance = ${fixedBalance.toFixed(decimals)}`);
if(Number(balance) == 0) {
console.log('holder1 needs to be filled..');
let r = await token.operatorTransferByPartition(partitions[0],firstHolder,holder1, amount * digit,ZeroHash,ZeroHash,{gasLimit: 20000000});
await r.wait();
}
balance = await token.balanceOf(holder2);
fixedBalance = (1/digit) * Number(balance);
console.log(`holder2(${holder2.address}) balance = ${fixedBalance.toFixed(decimals)}`);
if(Number(balance) == 0) {
console.log('holder2 needs to be filled..');
let r = await token.operatorTransferByPartition(partitions[0],firstHolder,holder2, amount * digit,ZeroHash,ZeroHash,{gasLimit: 20000000});
await r.wait();
}

}

function getAuthHeader(token: string) : any{
@@ -97,6 +143,13 @@ async function send(signedTransaction: string) {
return ret;
}

async function sign(tx: Transaction,signer: Wallet) : Promise<any> {

const signed = await signer.signTransaction(tx);

return {nonce: tx.nonce, sig: signed , txid: keccak256(signed)}
}

async function transfer(signer: Wallet,symbol:string,from: Wallet, to: Wallet, amount: number = 1, count: number = 10) {
const proxy = getDeploymentAddresses(symbol).address;
console.log(`토큰 주소 : ${proxy}`);
@@ -104,8 +157,6 @@ async function transfer(signer: Wallet,symbol:string,from: Wallet, to: Wallet, a
const token = new SecurityToken__factory(issuer).attach(proxy) as SecurityToken;
const decimals = await token.decimals();
const digit = 10 ** Number(decimals);
//console.log(`자릿수 = ${digit}`);


let fb = await getBalance(symbol,from.address);
let tb = await getBalance(symbol,to.address);
@@ -116,45 +167,58 @@ async function transfer(signer: Wallet,symbol:string,from: Wallet, to: Wallet, a

let firstTx:string = null;
let lastTx:string = null;
const start = Date.now();
let start = Date.now();
console.log(chalk.cyan(`전송시작 시간 : ${new Date(start).toUTCString()}`));

console.log(chalk.yellow(`sending ${count} transactions`));
let signedData = [];
let unsignedProms = [];
for(let i = 0; i < count; i++) {
const rawTx = await getTx(signer.address,symbol,from.address,to.address, amount * digit);
const tx = Transaction.from(rawTx.data);
const signed = await signer.signTransaction(tx);
signedData.push(signed);

if(i == 0) {
firstTx = keccak256(signed);
} else if(i == count -1) {
lastTx = keccak256(signed);
}
unsignedProms.push(getTx(signer.address,symbol,from.address,to.address, amount * digit));
}

// const start = Date.now();
// console.log(chalk.cyan(`전송시작 시간 : ${new Date(start).toUTCString()}`));
let txMap = new Map<string,boolean>();
let unsigned = await Promise.all(unsignedProms);
let signedProms = [];
unsigned.forEach(u => {
const tx = Transaction.from(u.data);
signedProms.push(sign(tx,signer));
});
let signedData = await Promise.all(signedProms);
const elapsed = getElapsed(start,1000);
console.log(`TxPrepared within ${elapsed} seconds`);
console.log(chalk.yellow(`sending ${count} transactions`));

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

let proms = [];
for(let i = 0; i < count; i++) {
proms.push(send(signedData[i]));
console.log(`sending ${i} , nonce : ${signedData[i].nonce}`);
proms.push(send(signedData[i].sig));
}

let resolved = await Promise.all(proms);

let txMap = new Map<string,boolean>();
resolved.forEach(tx => {
txMap.set(tx.data.transactionHash,false)
//console.log(tx.data.transactionHash);
});

console.log(`sent txid count = ${txMap.size}`);

let nonce = 0;
signedData.forEach( tx => {
if(tx.nonce > nonce) {
lastTx = tx.txid;
}
})
const blockHashes = await checkReceipt2(txMap,[firstTx as string, lastTx as string], 'wait for receipt...');
const firstBlockHash = blockHashes.get(firstTx);
//const firstBlockHash = blockHashes.get(firstTx);
const lastBlockHash = blockHashes.get(lastTx);
console.log(`firstBlockHash = ${firstBlockHash} \nlastBlockHash = ${lastBlockHash}`);
//console.log(`firstBlockHash = ${firstBlockHash} \nlastBlockHash = ${lastBlockHash}`);
console.log(`lastBlockHash = ${lastBlockHash}`);
fb = await getBalance(symbol,from.address);
tb = await getBalance(symbol,to.address);
@@ -163,8 +227,6 @@ async function transfer(signer: Wallet,symbol:string,from: Wallet, to: Wallet, a
console.log(chalk.yellow('###################### 전송후 잔고 ###################################'))
console.log(`balance of sender(${from.address}) = ${fb.toFixed(Number(decimals))}\r\nbalance of receiver(${to.address}) = ${tb.toFixed(Number(decimals))}`);

console.log(firstTx);

const lastB = await getBlockInfo(lastBlockHash);
const lastTimeStamp = parseInt(lastB.timestamp,16);
console.log(`eth_getBlockByHash(${lastBlockHash}).timestamp = ${lastTimeStamp}`)
@@ -181,7 +243,7 @@ async function transfer(signer: Wallet,symbol:string,from: Wallet, to: Wallet, a
}


const firstHolder = '0x2071ec931b2567a1418e9bc34b786d654a079b43';
const firstHolder = '0x3050C8Eab31E2cbB6d29683f831CaB2FD52a9872';
const calc = new Calulator();
const rpcUrl = process.env.RPCURL;
const gateWay = process.env.GATE_WAY;
@@ -199,7 +261,8 @@ const holder2 = new Wallet('0xac0974bec39a17e36ba4a6b4d238ff944bacb478cbed5efcae
console.log(`목적 서버 : ${gateWay}`);

async function main() {
transfer(holder1,'BCG_TEST',holder1, holder2,1, 1000);
//spareToken('BCG_TEST');
transfer(holder1,'BCG_TEST',holder2, holder1,1, 4);
}

main();

+ 2
- 2
TC3/start.ts View File

@@ -138,9 +138,9 @@ const holder2 = new Wallet('0xac0974bec39a17e36ba4a6b4d238ff944bacb478cbed5efcae
console.log(`목적 서버 : ${gateWay}`);

async function main() {
await readHealth('BCG_TEST',holder1,5000);
//await readHealth('BCG_TEST',holder1,1000);
//await readTest('BCG_TEST',holder1,1000);
await readTest('BCG_TEST',holder1,5000);
}

main();

+ 1
- 1
TC4/start.ts View File

@@ -138,7 +138,7 @@ const holder1 = new Wallet('0xae6ae8e5ccbfb04590405997ee2d52d2b330726137b875053c
const holder2 = new Wallet('0xac0974bec39a17e36ba4a6b4d238ff944bacb478cbed5efcae784d7bf4f2ff80',provider);

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

main();

+ 0
- 110
TC6/start.ts View File

@@ -37,116 +37,6 @@ async function info(symbol: string) {
}


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

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}`);

}


async function testSecurity(symbol: string, operator: Wallet, tobeOperator: Wallet,holder: Wallet, user1: Wallet, user2: Wallet) {

+ 83
- 0
TC9/start.ts View File

@@ -0,0 +1,83 @@
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 {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'
import { sign } from "crypto";
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 getTransferData(symbol:string,from: Wallet, to: Wallet, amount: number = 1): Promise<any> {
const proxy = getDeploymentAddresses(symbol).address;
console.log(`토큰 주소 : ${proxy}`);
const token = new SecurityToken__factory(issuer).attach(proxy) as SecurityToken;
const partitions = await token.getDefaultPartitions();
let nonce = await getNonce(signer.address);
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
}
);
const signed = await signer.signTransaction(tx);
return signed;
}

async function getOperatorGrantData(symbol:string,from: Wallet, to: Wallet, amount: number = 1): Promise<any> {
const proxy = getDeploymentAddresses(symbol).address;
console.log(`토큰 주소 : ${proxy}`);
const token = new SecurityToken__factory(issuer).attach(proxy) as SecurityToken;
//ret = await adminToken.grantRole( id('OPERATOR_ROLE'),tobeOperator,{ gasLimit: 20000000});

}

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() {
const tx = await getTransferData('test001',holder2, holder1,1);
console.log(tx);

}

main();


Write Preview
Loading…
Cancel
Save