TronScan(제작 완료)

참고 : https://github.com/tronscan/tronscan-api

 

이더스캔은 이더스캔 API로 잠깐 깔짝 때보고 회사 업무상 트론을 계속 보게

 

되었는데  트랜젝션 조회 트론스캔을 어떻게 접근해야 될지 고민중이다.

 

지금 현재 트론 상황은  token발행 심볼때문에  몇몇 함수가 막혀 있다.

 

그중에 하나인 tronWeb.trx.getTransactionsRelated  도 지금 사용이 불가능다.

1. full node를 동기화시켜서 DB에 넣을지?

2. 특정 Token에 대한 것만 DB에  넣을지?

 

input /output에 대한 결과를 어떻게 사용자에게 보여주는게 좋을지 판단이 안선다.

 

그래서 우선  트론스캔에 있는 tx를 웹에서 파싱해서 한번 넣어보자...

API가 제공안하니 웹파싱해서 넣는다 해도 큰 무리는 없을것이다.

 

https://tronscan.org/#/transaction/51d1994d5d36693299bba3ed3002ca46849922fd80df0446acbd28609948d09d

index.js

var express = require('express'); var router = express.Router(); const TronWeb = require('tronweb'); const fullNode = 'https://api.shasta.trongrid.io'; const solidityNode = 'https://api.shasta.trongrid.io'; const eventServer = 'https://api.shasta.trongrid.io/'; var privateKey = '123'; var mysql = require('mysql'); var connection = mysql.createConnection({         host: 'localhost',         post: 3306,         user: 'tkpark',         password: '1234',         database: 'tkpark'     }); const tronWeb = new TronWeb( fullNode, solidityNode, eventServer, privateKey   ); tronWeb.setDefaultBlock('latest'); const nodes = tronWeb.isConnected(); const connected = !Object.entries(nodes).map(([ name,   connected]) => {         if (!connected)                   console.error(`Error: $ {name}is not connected`);         return connected; }).includes(false); if (!connected)       res.json( {'result':'connect fail'}) router.get('/createAccount/',function(req,res,next) {         const account = tronWeb.createAccount();         account.then(function (account) { const isValid = tronWeb.isAddress(account.address['hex']);                 console.log('- Private Key:',   account.privateKey);                 console.log('- Base58:',        account.address.base58);                 console.log('- Valid: ',        isValid,        '\n');                 account.isValid = isValid;                 res.json( {'result':account.privateKey, '- Base58': account.address.base58});         }); }); router.get('/getBalance/:Address',function(req,res,next) {         const app = async () => {                 try {                         const Add = req.params.Address;                         const gBalance = await tronWeb.trx.getBalance(Add);                         const gBandwidth = await tronWeb.trx.getBandwidth(Add);                         console.log("getBalance : ", gBalance);                         console.log("getBandwidth : ", gBandwidth);                         console.log("   ", Add);                         res.json( { "getBalance  ": gBalance, "getBandwidth": gBandwidth, "123": Add})                 }catch (error) { console.log('Task Failure',error);                 }         };         app(); }); router.get('/transactionview',function(req,res,next) {                 try{                         var Address = req.query.Address;                         var select_sql = "select *, \"send\" from transactionscan where from_address=? union all select *, \"receive\" from transactionscan where to_address=? order by idx desc;";                         connection.query(select_sql, [Address, Address], function (err, rows, fields) {                         if (!err) {                                 var resultdown = JSON.stringify(rows);                                 var TRList = JSON.parse(resultdown);                                 var Result_data = [];                                 for(var i=0; i<TRList.length; i++){                                         var TR=TRList[i];                                         var info = {                                                 send: TR.send,                                                 idx: TR.idx,                                                 from_address: TR.from_address,                                                 to_address: TR.to_address,                                                 amount: TR.amount,                                                 txid: "https://shasta.tronscan.org/#/transaction/"+ TR.txid                                         };                                         Result_data.push(info);                                 }                                 var result_end={                                         count: Result_data.length, // count                                         Result_data: Result_data                                 };                                 console.log(result_end);                                 res.send(result_end);                                 } else {                                 console.log('query error : ' + err);                                 }                         });                 }catch (error) { console.log('Task Failure',error);                 } }); router.get('/sendToken',function(req,res,next) {         const app = async () => {                 try {                         const gPK = req.query.PK;                         privateKey = tronWeb.setPrivateKey(gPK);                         const gvalue = req.query.value;                         const gsendAddress = await tronWeb.address.fromPrivateKey(gPK);                         const gtoAddress = req.query.toAddress;                         var txid = "";                         var result = "";                         var insert_sql = "insert into transactionscan (from_address, to_address, amount, txid) values (?, ?, ?, ?)";                         var select_sql = "select * from transactionscan where txid=?";                         /*                         console.log("gPK : ", gPK);                         console.log("gvalue : ", gvalue);                         console.log("gsendAddres :", gsendAddress);                         console.log("gtoAddress : ", gtoAddress);                         */                        sendTransaction = await tronWeb.transactionBuilder.sendToken(gtoAddress, gvalue, "1002003", gsendAddress);                         const signedTransaction = await tronWeb.trx.sign(sendTransaction);                         const sendRaw = await tronWeb.trx.sendRawTransaction(signedTransaction);                         result = JSON.stringify(sendRaw, null, 2);                         var TRList = JSON.parse(result);                         var txid = TRList.transaction.txID;                         /*                         console.log('- Transaction:\n' + TRList.transaction.txID);                         res.json( { "gPK  ": gPK, "gvalue  ": gvalue, "gsendAddres ": gsendAddress, "gtoAddress": gtoAddress,'- Transaction:n': TRList.transaction.txID, "Transaction\n": JSON.stringify(sendRaw, null, 2)});                         */  var params = [gsendAddress, gtoAddress, gvalue, txid];                         connection.query(insert_sql, params, function (err, rows, fields) {                         if (!err) {                                 console.log('query error : ' + err);                                 //res.send(err);                          }                         });                         connection.query(select_sql, txid, function (err, rows, fields) {                         if (!err) {                                 console.log(rows);                                 var resultdown = 'rows : ' + JSON.stringify(rows);                                 res.send(resultdown);                                 } else {                                 console.log('query error : ' + err);                                 }                         });                         }catch (error) { console.log('Task Failure',error);                 }         };         app(); });   module.exports = router;

 

실행결과

 

계좌신청
http://192.168.0.118:3000/createAccount/

 

잔액조회 지갑주소
http://192.168.0.118:3000/getBalance/TS4AYYxrF38EA3fDw92mMWbWdFWRJ4VKih
http://192.168.0.118:3000/getBalance/TMDBC4DoS1yQCjBgnPBJWnfTZN9rAKBUHc

 

송금
http://192.168.0.118:3000/sendToken?PK=@@@@@&value=@@@@&toAddress=@@@@@@@@@@

송금시 API가 변경되어서 꼭 tronWeb.setPrivateKey로 다시 세팅하고

받는 사람 주소를 인자에 넣어야 된다.

 tronWeb.transactionBuilder.sendTrx(gtoAddress, gvalue, gsendAddress);

 

 

트렌젝선 조회
http://192.168.0.118:3000/transactionjson?Address=TS4AYYxrF38EA3fDw92mMWbWdFWRJ4VKih

 

 

Mysql DB스키마

CREATE TABLE `transactionscan` (
  `idx` int(11) NOT NULL AUTO_INCREMENT,
  `from_address` varchar(100) NOT NULL COMMENT '보내는 사람 주소',
  `to_address` varchar(100) NOT NULL COMMENT '받는 사람  주소',
  `amount` bigint(20) NOT NULL COMMENT '양',
  `txid` varchar(150) NOT NULL COMMENT '트랜젝션 id',
  `regdate` datetime default current_timestamp,
  PRIMARY KEY (`idx`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='트랜젝션 조회 테이블';

 

MariaDB [tkpark]> desc transactionscan; +--------------+--------------+------+-----+-------------------+----------------+ | Field        | Type         | Null | Key | Default           | Extra          | +--------------+--------------+------+-----+-------------------+----------------+ | idx          | int(11)      | NO   | PRI | NULL              | auto_increment | | from_address | varchar(100) | NO   |     | NULL              |                | | to_address   | varchar(100) | NO   |     | NULL              |                | | amount       | bigint(20)   | NO   |     | NULL              |                | | txid         | varchar(150) | NO   |     | NULL              |                | | regdate      | datetime     | YES  |     | CURRENT_TIMESTAMP |                | +--------------+--------------+------+-----+-------------------+----------------+

 

 

select *, \"send\" from transactionscan where from_address=? union all select *, \"receive\" from transactionscan where to_address=? order by idx desc

해당 쿼리에 대한 결과다.

 

쿼리구문은 당연히 ?가 들어가는 prepared statement

sql 인젝션 방지까지 된다.

 

마지막 부분 조회할때는 지갑 A, B주소로  서로 송금 해보고

A주소로 조회시 send,

파란색 주소를  트랜젝션 조회하면  send한부분 recieve한 부분 보여진다.

빨간색 주소를 트랜잭션 조회해도  send한부분 recieve한 부분 보여진다.

 

트랜젝션 조회시 tronscan 원본에도 조회 되도록

https://shasta.tronscan.org/#/transaction/

4533bb973d7cd4dccc1805b0e43e2a7b341f0e02d23ab8febbe58b994fb8ee73

링크를 함께 뿌려주고 있다.

 

코드 좀 정리 해서 github 라는놈도 한번 써봐야곘다.

회사에서 필요하는 만큼 빨리 잘 만들었다.

 

Dapp 개발하면서 느끼지만 메인넷은 이더리움과 비트코인과 같이

글로벌한 천재들이 있던지

아니면 트론처럼 직원이 많아야 된다.

web3.js나 tronweb이나 API를 유지보수해야될 인력도 어마 어마하게

필요하기 때문이다.