|
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;
|
