eth系列json-rpc调用类

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