<?php
namespace app\common\services;
use app\common\repositories\system\config\ConfigValueRepository;
use Exception;
use GuzzleHttp\Client as HttpClient;
use kornrunner\Secp256k1;
use think\exception\ValidateException;
use think\facade\Cache;
use think\facade\Log;
use Web3\Contract;
use Web3\Providers\HttpProvider;
use Web3\RequestManagers\HttpRequestManager;
use Web3\Utils;
use Web3\Web3;
use Web3p\EthereumTx\Transaction;
use Web3p\EthereumUtil\Util;
class JsonRpc
{
protected $web3;
protected $callback;
protected $chainId;
public function __construct($callback = null)
{
// Set the custom chain RPC URL and Chain ID
$rpcUrl = env('moralis.rpc_url');
$this->chainId = env('moralis.bscchain');
// Create a new HttpProvider instance
$provider = new HttpProvider(new HttpRequestManager($rpcUrl, 30));
$this->web3 = new Web3($provider);
// Set the custom chain ID
// $this->web3->provider->requestManager->ethereum->net->version(function ($err) use ($chainId) {
// if ($err !== null) {
// throw new \Exception('Error setting custom chain ID: ' . $err->getMessage());
// }
// $this->web3->provider->requestManager->ethereum->_chainId = $chainId;
// });
// Set the callback function if provided
if ($callback !== null) {
$this->callback = $callback;
}
}
public function getAddress($privateKey)
{
$util = new Util();
return $util->publicKeyToAddress($util->privateKeyToPublicKey($privateKey));
}
public function getBalance(string $address, callable $callback = null)
{
$callback = $callback ?? $this->callback;
$this->web3->eth->getBalance($address, function ($err, $balance) use ($callback) {
if ($err !== null) {
throw new \Exception('Error getting balance: ' . $err->getMessage());
}
if ($callback !== null) {
// $balanceInEther = $this->web3->utils->fromWei($balance, 'ether');
$balanceInEther = $balance->toString();
call_user_func($callback, $balanceInEther);
}
});
}
/**基于给定的选项创建一个过滤器对象，接收状态变化时的通知
* @param $contractAddress
* @param callable|null $callback
* @return void
* @throws \Exception
* @author Admin
* @date 2023-09-09 12:00
*/
public function newFilter($contractAddress, callable $callback = null)
{
$callback = $callback ?? $this->callback;
$this->web3->eth->newFilter([
"fromBlock" => '0x' . dechex(33128536),
"toBlock" => "latest",
'address' => $contractAddress, // 合约地址
[
"topics" => ["0xddf252ad1be2c89b69c2b068fc378daa952ba7f163c4a11628f55a4df523b3ef"]
]
],function ($err, $fid) use ($callback) {
if ($err !== null) {
throw new \Exception('Error getting newFilter: ' . $err->getMessage());
}
if ($callback !== null) {
call_user_func($callback, $fid);
}
});
}
/** 返回指定编号过滤器中的全部日志
* @param $fid
* @param callable|null $callback
* @return void
* @throws \Exception
* @author Admin
* @date 2023-09-09 12:00
*/
public function getFilterLogs($fid, callable $callback = null)
{
$callback = $callback ?? $this->callback;
$this->web3->eth->getFilterLogs($fid,function ($err, $log) use ($callback) {
if ($err !== null) {
throw new \Exception('Error getting getFilterLogs: ' . $err->getMessage());
}
if ($callback !== null) {
call_user_func($callback, $log);
}
});
}
public function getGasPrice(callable $callback = null)
{
$callback = $callback ?? $this->callback;
$this->web3->eth->gasPrice(function ($err, $gasPrice) use ($callback) {
if ($err !== null) {
throw new \Exception('Error getting gas price: ' . $err->getMessage());
}
if ($callback !== null) {
$gasPrice = $gasPrice->toString();
call_user_func($callback, $gasPrice);
}
});
}
public function sendTransaction(
string $from,
string $to,
float $value,
string $privateKey,
callable $callback = null
) {
$callback = $callback ?? $this->callback;
$eth = $this->web3->eth;
if (substr($privateKey, 0, 2) !== '0x') {
$privateKey = '0x' . $privateKey;
}
$customGas = 21000; // Custom gas limit (in decimal)
$customGasPrice = 5 * 1000000000; // Custom gas price (15 Gwei, in decimal)
$amount = bcmul($value, bcpow(10, 18), 0);
$transaction = [
'from' => $from,
'to' => $to,
'value' => '0x' . dechex($amount),
'gas' => '0x' . dechex($customGas), // Custom gas limit (in hexadecimal)
'gasPrice' => '0x' . dechex($customGasPrice), // Custom gas price (in hexadecimal)
'chainId' => $this->chainId,
];
// Check the sender's balance
$eth->getBalance($from, 'latest', function ($err, $balance) use ($transaction, $privateKey,$from, $callback, $amount) {
if ($err !== null) {
throw new \Exception('Error getting balance: ' . $err->getMessage());
}
if(bccomp($balance->toString(), $amount, 0) < 0){
throw new \Exception(lang("没有足够的",["BRT"]));
}
// Calculate the total cost of the transaction (value + gas * gasPrice)
$totalCost = bcadd($transaction['value'], bcmul(hexdec($transaction['gas']), hexdec($transaction['gasPrice']), 0), 0);
// Compare the sender's balance to the total cost of the transaction
if (bccomp($balance->toString(), $totalCost, 0) < 0) {
throw new \Exception('Insufficient funds for gas * price + value');
}
// If there are sufficient funds, proceed with sending the transaction
// Get the transaction count for the sender address
$this->web3->eth->getTransactionCount($from, 'latest', function ($err, $transactionCount) use ($transaction, $privateKey, $callback) {
if ($err !== null) {
throw new \Exception('Error getting transaction count: ' . $err->getMessage());
}
// Create and sign the transaction
$transaction['nonce'] = '0x' . dechex((int)$transactionCount->toString());
$ethTx = new Transaction($transaction);
$signedTransaction = $ethTx->sign($privateKey);
// Send the signed transaction
$this->web3->eth->sendRawTransaction('0x' . $signedTransaction, function ($err, $transactionHash) use ($callback) {
if ($err !== null) {
throw new \Exception('Error sending transaction: ' . $err->getMessage());
}
if ($callback !== null) {
call_user_func($callback, $transactionHash);
}
});
});
});
}
/** 通过hash 获取交易信息
* @param string $transactionHash
* @param callable|null $callback
* @return void
* @throws \Exception
* @author Admin
* @date 2023-09-04 10:15
*/
public function getTransaction(string $transactionHash, c
