Skip to content

Commit

Permalink
FlowClient
Browse files Browse the repository at this point in the history 
Access API functions (except sendTransaction which requires signing)
  • Loading branch information
@bluesign
bluesign committed Jun 14, 2021
1 parent 0df165d commit a349697
Show file tree
Hide file tree
Showing 2 changed files with 285 additions and 0 deletions.
Binary file added .DS_Store
View file
Binary file not shown.
285 changes: 285 additions & 0 deletions src/FlowClient.php
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,285 @@
<?php
namespace Flow\Access;

require '../vendor/autoload.php';

class FlowClient extends \Grpc\BaseStub{

public function obj2dic($obj){

$iterators = array("CollectionGuarantees","BlockSeals","Signatures","Contracts","Keys","Results","Events");
$binary = array("ExecutionReceiptSignatures","Signatures","ResultApprovalSignatures");
$identifiers = array("TransactionId","PublicKey","Address", "ParentId","Id","CollectionId","BlockId","ExecutionReceiptId");

$class = new \ReflectionObject($obj);
$methods = $class->getMethods();
$result = array();

foreach($methods as $method){
if (strpos($method, "get")!=0){
$reflectionMethod = $class->getMethod($method->name);
$name = substr($method->name, 3);

$value = $reflectionMethod->invoke($obj);

if (in_array($name, $binary)){
$bytes = "";
foreach ($value as $v){
$bytes .= $v;
}
$value = bin2hex($bytes);
}

if (is_object($value)){
if (in_array($name, $iterators))
{
$inner = array();
foreach ($value as $k => $v) {
if (is_object($v)){
$inner[$k] = $this->obj2dic($v);
}
else{
$inner[$k]=$v;
}
}
$value =$inner;
}
else{
$value = $this->obj2dic($value);
}
}

if (is_string($value)){
if (in_array($name, $identifiers)){
$value = bin2hex($value);
}
}

$result[$name] = $value;

}
}
return $result;
}


public function __construct($hostname, $opts, $channel = null) {
parent::__construct($hostname, $opts, $channel);


}

public function process(\Google\Protobuf\Internal\Message $argument, $requestEndpoint, $expectedResponse, $metadata=[],$options=[]){

$response = $this->_simpleRequest("/flow.access.AccessAPI/$requestEndpoint",
$argument,
['\\Flow\Access\\' . $expectedResponse, 'decode'],
$metadata, $options)->wait();

$status = $response[1];
if ($status->code!=0)
{
throw new \Exception("Error: $status->code Details: $status->details");
}
return $response[0];
}

public function ping(){
$message = new PingRequest();
$response = $this->process($message, "Ping", "PingResponse");
return $this->obj2dic($response);
}

public function getLatestBlockHeader(){
$message = new GetLatestBlockHeaderRequest();
$response = $this->process($message, "GetLatestBlockHeader", "BlockHeaderResponse");
return $this->obj2dic($response->getBlock());
}

public function getBlockHeaderByID($id="LATEST"){
if ($id=="LATEST"){
return getLatestBlockHeader();
}
$message = new GetBlockHeaderByIDRequest();
$message->setId(hex2bin(str_pad($id, 64, "0", STR_PAD_LEFT)));
$response = $this->process($message, "GetBlockHeaderByID", "BlockHeaderResponse");
return $this->obj2dic($response->getBlock());
}

public function getBlockHeaderByHeight($height="LATEST"){
if ($height=="LATEST"){
return getLatestBlockHeader();
}
$message = new GetBlockHeaderByHeightRequest();
$message->setHeight($height);
$response = $this->process($message, "GetBlockHeaderByHeight", "BlockHeaderResponse");
return $this->obj2dic($response->getBlock());
}

public function getLatestBlock(){
$message = new GetLatestBlockRequest();
$response = $this->process($message, "GetLatestBlock", "BlockResponse");
return $this->obj2dic($response->getBlock());
}

public function getBlockByID($id="LATEST"){
if ($id=="LATEST"){
return getLatestBlock();
}
$message = new GetBlockByIDRequest();
$message->setId(hex2bin(str_pad($id, 64, "0", STR_PAD_LEFT)));
$response = $this->process($message, "GetBlockByID", "BlockResponse");
return $this->obj2dic($response->getBlock());
}

public function getBlockByHeight($height="LATEST"){
if ($height=="LATEST"){
return getLatestBlock();
}
$message = new GetBlockByHeightRequest();
$message->setHeight($height);
$response = $this->process($message, "GetBlockByHeight", "BlockResponse");
return $this->obj2dic($response->getBlock());
}

public function getCollectionByID($id){
$message = new GetCollectionByIDRequest();
$message->setId(hex2bin(str_pad($id, 64, "0", STR_PAD_LEFT)));
$response = $this->process($message, "GetCollectionByID", "CollectionResponse");
return $this->obj2dic($response->GetCollection());
}

public function getTransaction($id){
$message = new GetTransactionRequest();
$message->setId(hex2bin(str_pad($id, 64, "0", STR_PAD_LEFT)));
$response = $this->process($message, "GetTransaction", "TransactionResponse");
return $this->obj2dic($response->GetTransaction());
}

public function getTransactionResult($id){
$message = new GetTransactionResultRequest();
$message->setId(hex2bin(str_pad($id, 64, "0", STR_PAD_LEFT)));
$response = $this->process($message, "GetTransactionResult", "TransactionResultResponse");
return $this->obj2dic($response);
}

public function getAccount($address){
$message = new GetAccountRequest();
$message->setId(hex2bin(str_pad($address, 16, "0", STR_PAD_LEFT)));
$response = $this->process($message, "GetAccount", "GetAccountResponse");
return $this->obj2dic($response->getAccount());
}

public function getAccountAtLatestBlock($address){
$message = new GetAccountAtLatestBlockRequest();
$message->setId(hex2bin(str_pad($address, 16, "0", STR_PAD_LEFT)));
$response = $this->process($message, "GetAccountAtLatestBlock", "GetAccountResponse");
return $this->obj2dic($response->getAccount());
}

public function getAccountAtBlockHeight($address, $block_height="LATEST"){
if ($block_height=="LATEST"){
return getAccountAtLatestBlock($address);
}
$message = new GetAccountAtBlockHeightRequest();
$message->setId(hex2bin(str_pad($address, 16, "0", STR_PAD_LEFT)));
$message->setBlockHeight($block_height);
$response = $this->process($message, "GetAccountAtBlockHeight", "GetAccountResponse");
return $this->obj2dic($response->getAccount());
}

public function executeScriptAtLatestBlock($script){
$message = new ExecuteScriptAtLatestBlockRequest();
$message->setScript($script);
$response = $this->process($message, "ExecuteScriptAtLatestBlock", "ExecuteScriptResponse");
return $this->obj2dic($response);
}
public function executeScriptAtBlockID($script, $block_id="LATEST"){
if ($block_id=="LATEST"){
return executeScriptAtLatestBlock($script);
}
$message = new ExecuteScriptAtBlockIDRequest();
$message->setScript($script);
$message->setBlockId($block_id);
$response = $this->process($message, "ExecuteScriptAtBlockID", "ExecuteScriptResponse");
return $this->obj2dic($response);
}

public function executeScriptAtBlockHeight($script, $block_height="LATEST"){
if ($block_height=="LATEST"){
return executeScriptAtLatestBlock($script);
}
$message = new ExecuteScriptAtBlockHeightRequest();
$message->setScript($script);
$message->setBlockHeight($block_height);
$response = $this->process($message, "ExecuteScriptAtBlockHeight", "ExecuteScriptResponse");
return $this->obj2dic($response);
}

public function getEventsForHeightRange($type, $start_height, $end_height){
$message = new GetEventsForHeightRangeRequest();
$message->setType($type);
$message->setStartHeight($start_height);
$message->setEndHeight($end_height);
$response = $this->process($message, "GetEventsForHeightRange", "EventsResponse");
return $this->obj2dic($response["results"]);
}

public function getEventsForBlockIDs($type, $block_ids){
$message = new GetEventsForBlockIDsRequest();
$message->setType($type);
$blocks = array();
foreach($block_ids as $b){
$blocks[]=hex2bin(str_pad($b, 64, "0", STR_PAD_LEFT));
}
$message->setBlockIds($blocks);
$response = $this->process($message, "GetEventsForBlockIDs", "EventsResponse");
return $this->obj2dic($response)["Results"];
}

public function getNetworkParameters(){
$message = new GetNetworkParametersRequest();
$response = $this->process($message, "GetNetworkParameters", "GetNetworkParametersResponse");
return $this->obj2dic($response)["Results"];
}

public function getLatestProtocolStateSnapshot(){
$message = new GetLatestProtocolStateSnapshotRequest();
$response = $this->process($message, "GetLatestProtocolStateSnapshot", "ProtocolStateSnapshotResponse");
return $this->obj2dic($response);
}

}

$client = new FlowClient('access.mainnet.nodes.onflow.org:9000', [
'credentials' => \Grpc\ChannelCredentials::createInsecure(),
]);

try{

//print_r($client->getLatestBlockHeader());
//print_r($client->getBlockHeaderByHeight(0));
//print_r($client->getBlockHeaderByID("7bc42fe85d32ca513769a74f97f7e1a7bad6c9407f0d934c2aa645ef9cf613c7"));

//print_r($client->getLatestBlock());
//print_r($client->getBlockByHeight(15509598));
//print_r($client->getBlockByID("7a37e8c2a6295887acb35478f85d0ef201ee707feea5012fc0ff773438d647d1"));

//print_r($client->getAccount("0b2a3299cc857e29"));
//print_r($client->getAccountAtLatestBlock("0b2a3299cc857e29"));
//print_r($client->getAccountAtBlockHeight("0b2a3299cc857e29",0));

print_r($client->executeScriptAtLatestBlock("pub fun main(): Int {return 1}"));
//print_r($client->executeScriptAtBlockHeight("pub fun main(): Int {return 1}",0));
//print_r($client->executeScriptAtBlockID("pub fun main(): Int {return 1}","7bc42fe85d32ca513769a74f97f7e1a7bad6c9407f0d934c2aa645ef9cf613c7"));
//print_r($client->getNetworkParameters());
//print_r($client->getLatestProtocolStateSnapshot());


//print_r($client->getEventsForBlockIDs("A.0b2a3299cc857e29.TopShot.Withdraw", ["7fd240c558e13986013be111cfd05a7c6938405cb5b84c2bb8f4d501dcea3bab", "45c9126536c86096ee4adf0bc18280a05f53250377c075010eaca98e645cc536"]));
}
catch (\Exception $e) {
print_r($e->getMessage());
}


0 comments on commit a349697

Please sign in to comment.