index.js

const bitcoin = require('bitcoinjs-lib')
const request = require('request-promise-native')
var express = require('express');
var url = require('url');
var router = express.Router();
var app = express();

const log4js = require('log4js');
log4js.configure({
  appenders: { 
	normal: { 
		type: 'file', 
		filename: "/root/omniwallet/logs/file.log",
		maxLogSize: 1024*1024*1,
		backups: 100		
	} },
  categories: { 
	default: { 
		appenders: ['normal'], 
		level: 'info' 
	} }
});

const logger = log4js.getLogger('normal');


const net = bitcoin.networks.bitcoin
  // bitcoin.networks.testnet
  // bitcoin.networks.bitcoin

const API = net === bitcoin.networks.testnet
  ? `https://test-insight.swap.online/insight-api`
  : `https://insight.bitpay.com/api`

const fetchUnspents = (address) =>
  request(`${API}/addr/${address}/utxo/`).then(JSON.parse)

const broadcastTx = (txRaw) =>
  request.post(`${API}/tx/send`, {
    json: true,
    body: {
      rawtx: txRaw,
    },
 })
  
const getBalance = (address) =>
  request.post(`https://api.omniexplorer.info/v1/address/addr/`, {
    json: false,
	headers: {
            "content-type": "application/x-www-form-urlencoded",
        },	
	formData: { addr: address}    
  })  

  
//生成交易
const createSimpleSend = async (fetchUnspents, alice_pair, send_address, recipient_address, amount = 10) => {
  //构建txBuilder
  const txBuilder = new bitcoin.TransactionBuilder(net)
  //获取未花费的交易
  const unspents = await fetchUnspents(send_address)  
  //最低交易546聪
  const fundValue     = 546 // dust
  //手续费  固定5000聪
  var feeValue      = 5000
  //获取inputs
  var totalUnspent = 0
  const outputsNum = 3
  //遍历未花费交易列表，生成交易输入项
  console.log((new Date()).toLocaleString(),"未花费记录条数：", unspents.length)
  for (var i=0; i< unspents.length; i++){
	//if (unspents[i].confirmations < 6) {
	//	console.log("tx: ",unspents[i].txid,"confirmations: ", unspents[i].confirmations)
	//	continue
	//}
	totalUnspent = totalUnspent +  unspents[i].satoshis
	txBuilder.addInput(unspents[i].txid,  unspents[i].vout, 0xfffffffe)
	console.log("tx:",unspents[i].txid,"satoshis:",unspents[i].satoshis,"confirmations:", unspents[i].confirmations)
	//feeValue = (i+1) * 180 + outputsNum * 34 + 10 + 40 //暂时没有实时计算手续费，固定5000聪
	//如果当前未花费交易金额已经大于 最低交易*2+手续费，跳出循环 
	//减去两次最低交易是因为找零余额也必须大于最低交易费 不然会被比特币网络限制
	if (totalUnspent > feeValue + fundValue + fundValue){
		break
	}
  }  
  //判断未花费交易金额是否足够，不足抛出异常
  if (totalUnspent < feeValue + fundValue + fundValue) {
	//console.log((new Date()).toLocaleString(),`Total less than fee: ${totalUnspent} < ${feeValue} + ${fundValue}`)
    throw new Error(`Total less than fee: ${totalUnspent} < ${feeValue} + ${fundValue}`)
  }  
  //计算剩余金额
  const skipValue     = totalUnspent - fundValue - feeValue	
  logger.info("totalUnspent:"+totalUnspent.toString(10)+" feeValue:"+feeValue.toString(10)+" fundValue:"+fundValue.toString(10)+" skipValue:"+skipValue.toString(10))
  console.log("totalUnspent:"+totalUnspent.toString(10)+" feeValue:"+feeValue.toString(10)+" fundValue:"+fundValue.toString(10)+" skipValue:"+skipValue.toString(10))
  //构建USDT交易	
  const simple_send = [
    "6f6d6e69", // omni
    "0000",     // version
    "00000000001f", // 31 for Tether
    ("0000000000000000"+amount.toString(16)).substr(-16)
  ].join('')
  const data = Buffer.from(simple_send, "hex")
  const omniOutput = bitcoin.script.compile([
    bitcoin.opcodes.OP_RETURN,
    data
  ])
  //添加交易输出项
  txBuilder.addOutput(recipient_address, fundValue) // should be first!
  txBuilder.addOutput(omniOutput, 0)
  txBuilder.addOutput(send_address, skipValue)
  //签名输入项
  txBuilder.__tx.ins.forEach((input, index) => {
    txBuilder.sign(index, alice_pair)
  })
  return txBuilder
}

app.get('/wallet/usdt/sendto', function (req, res, next) {	 
	logger.info("转账Url",req.url)
	console.log("转账Url",req.url)	
	try
	{
		var arg = url.parse(req.url, true).query; 
		var privkey = arg.privkey
		var fromaddress = arg.fromaddress
		var toaddress = arg.toaddress			
		var amount = parseInt(arg.amount) 	
		if (amount <= 0){
			throw new Error(`amount:${amount} <= 0 `)
		}
	}catch(err){
		logger.error('金额非法:', err.message)
		console.log((new Date()).toLocaleString(), "金额非法",err.message); 
		var json = {};
		json.msg = "金额非法"
		json.errcode = -3
		res.end(JSON.stringify(json))	
		return		
	}
	
	logger.info("转账从",fromaddress,"到",toaddress,amount)
	console.log((new Date()).toLocaleString(),"转账从",fromaddress,"到",toaddress,amount)		
	try{		
		var alice = bitcoin.ECPair.fromWIF(privkey, net)		
	}catch(err){
		logger.error('私钥格式有误:', err.message)
		console.log((new Date()).toLocaleString(), "私钥格式有误",err.message); 
		var json = {};
		json.msg = "私钥格式有误"
		json.errcode = -2
		res.end(JSON.stringify(json))	
		return		
	}
	
	try{
		// Construct tx
		const omni_tx = createSimpleSend(fetchUnspents, alice, fromaddress, toaddress, amount)		
		omni_tx.then(tx => {
			const txRaw = tx.buildIncomplete()
			var txResult = broadcastTx(txRaw.toHex())
			txResult.then(tx => {	 
				var json = {};
				json.errcode = 0
				json.txid = tx.txid
				res.end(JSON.stringify(json))
				logger.info(tx)			
				console.log((new Date()).toLocaleString(),"交易成功:",json)	  
			})
			.catch( (err) => {
				logger.error('发送tx请求失败:', err.message)
				console.log((new Date()).toLocaleString(), "发送tx请求失败",err.message);     //网络请求失败返回的数据  
				var json = {};				
				json.errcode = -1
				json.msg = "交易失败"
				res.end(JSON.stringify(json))
				return
			});	
		})
		.catch((err) => {
			logger.error('构建simplesend失败:', err.message)
			console.log((new Date()).toLocaleString(),'构建simplesend失败', err.message);     //网络请求失败返回的数据  	
			var json = {};			
			json.errcode = -1
			json.msg = "交易失败"
			res.end(JSON.stringify(json))
			return
		});	
	}catch(err){
		logger.error('发生未知异常:', err.message)
		console.log((new Date()).toLocaleString(), "发生未知异常",err.message); 
		var json = {};
		json.msg = "交易失败"
		json.errcode = -1
		res.end(JSON.stringify(json))	
		return		
	}
})

app.get('/wallet/usdt/balance', function (req, res, next){
	logger.info("查询余额Url",req.url)
	console.log("查询余额Url",req.url)		
	var arg = url.parse(req.url, true).query; 
	var address = arg.address
	logger.info("查询余额,地址:",address)
	console.log((new Date()).toLocaleString(),"查询余额,地址:",address)
	try{
		var balanceResult = getBalance(address)
		balanceResult.then(balance =>{
			logger.debug(balance)
			var r = JSON.parse(balance)
			for (var i=0; i< r.balance.length; i++){
				if (r.balance[i].id == 31){				
					var json = {};
					json.amount = parseInt(r.balance[i].value)
					json.errcode = 0
					res.end(JSON.stringify(json))
					console.log((new Date()).toLocaleString(),"余额:",json)
					return;
				}
			}
			var json = {};
			json.msg = "没有查询到记录"
			json.errcode = -1
			res.end(JSON.stringify(json))
		}).catch((err) => {
			logger.error('获取余额失败:', err.message)
			console.log((new Date()).toLocaleString(),"获取余额失败",err.message);     //网络请求失败返回的数据  
			var json = {};
			json.errcode = -1
			json.msg = "获取余额失败"
			res.end(JSON.stringify(json))
		});
	}catch(err){
		logger.error('请求获取余额异常:', err.message)
		console.log((new Date()).toLocaleString(),"请求获取余额异常",err.message);     //网络请求失败返回的数据  		
		var json = {};
		json.msg = "获取余额异常"
		json.errcode = -1
		res.end(JSON.stringify(json))			 
	}			
})

module.exports = router;

var server = app.listen(83, function () {   //监听端口
  var host = server.address().address
  var port = server.address().port
  console.log('Example app listening at http://%s:%s', host, port);
})