* * @author Peter Lai * @license MIT */ namespace Web3; use Web3\Eth; use Web3\Net; use Web3\Personal; use Web3\Utils; use Web3\Providers\Provider; use Web3\Providers\HttpProvider; use Web3\RequestManagers\RequestManager; use Web3\RequestManagers\HttpRequestManager; use Web3\Validators\HexValidator; class Web3 { /** * provider * * @var \Web3\Providers\Provider */ protected $provider; /** * eth * * @var \Web3\Eth */ protected $eth; /** * net * * @var \Web3\Net */ protected $net; /** * personal * * @var \Web3\Personal */ protected $personal; /** * utils * * @var \Web3\Utils */ protected $utils; /** * methods * * @var array */ private $methods = [ 'web3_clientVersion' => [], 'web3_sha3' => [ 'params' => [ [ 'validators' => HexValidator::class ] ] ] ]; /** * construct * * @param mixed string | Web3\Providers\Provider $provider * @return void */ public function __construct($provider) { if (is_string($provider) && (filter_var($provider, FILTER_VALIDATE_URL) !== false)) { // check the uri schema if (preg_match('/^https?:\/\//', $provider) === 1) { $requestManager = new HttpRequestManager($provider); $this->provider = new HttpProvider($requestManager); } } else if ($provider instanceof Provider) { $this->provider = $provider; } } /** * call * * @param string $name * @param array $arguments * @return void */ public function __call($name, $arguments) { if (empty($this->provider)) { throw new \RuntimeException('Please set provider first.'); } $class = explode('\\', get_class()); if (strtolower($class[1]) === 'web3' && preg_match('/^[a-zA-Z0-9]+$/', $name) === 1) { $method = strtolower($class[1]) . '_' . $name; if (!array_key_exists($method, $this->methods)) { throw new \RuntimeException('Unallowed rpc method: ' . $method); } $allowedMethod = $this->methods[$method]; if ($this->provider->isBatch) { $callback = null; } else { $callback = array_pop($arguments); if (is_callable($callback) !== true) { throw new \InvalidArgumentException('The last param must be callback function.'); } } if (isset($allowedMethod['params']) && is_array($allowedMethod['params'])) { // validate params foreach ($allowedMethod['params'] as $key => $param) { if (isset($param['validators'])) { if (is_array($param['validators'])) { $isError = true; foreach ($param['validators'] as $rule) { if (isset($arguments[$key])) { if (call_user_func([$rule, 'validate'], $arguments[$key]) === true) { $isError = false; break; } } else { if (isset($param['default'])) { $arguments[$key] = $param['default']; $isError = false; break; } } } if ($isError === true) { throw new \RuntimeException('Wrong type of ' . $name . ' method argument ' . $key . '.'); } } else { if (!isset($arguments[$key]) || call_user_func([$param['validators'], 'validate'], $arguments[$key]) === false) { if (isset($param['default']) && !isset($arguments[$key])) { $arguments[$key] = $param['default']; } else { throw new \RuntimeException('Wrong type of ' . $name . ' method argument ' . $key . '.'); } } } } } } $this->provider->send($method, $arguments, $callback); } } /** * get * * @param string $name * @return mixed */ public function __get($name) { $method = 'get' . ucfirst($name); if (method_exists($this, $method)) { return call_user_func_array([$this, $method], []); } } /** * set * * @param string $name * @param mixed $value * @return bool */ public function __set($name, $value) { $method = 'set' . ucfirst($name); if (method_exists($this, $method)) { return call_user_func_array([$this, $method], [$value]); } return false; } /** * getProvider * * @return void */ public function getProvider() { return $this->provider; } /** * setProvider * * @param $provider * @return bool */ public function setProvider($provider) { if ($provider instanceof Provider) { $this->provider = $provider; return true; } return false; } /** * getEth * * @return \Web3\Eth */ public function getEth() { if (!isset($this->eth)) { $eth = new Eth($this->provider); $this->eth = $eth; } return $this->eth; } /** * getNet * * @return \Web3\Net */ public function getNet() { if (!isset($this->net)) { $net = new Net($this->provider); $this->net = $net; } return $this->net; } /** * getPersonal * * @return \Web3\Personal */ public function getPersonal() { if (!isset($this->personal)) { $personal = new Personal($this->provider); $this->personal = $personal; } return $this->personal; } /** * getUtils * * @return \Web3\Utils */ public function getUtils() { if (!isset($this->utils)) { $utils = new Utils; $this->utils = $utils; } return $this->utils; } /** * batch * * @param bool $status * @return void */ public function batch($status) { $status = is_bool($status); $this->provider->batch($status); } }