feat: read, write and trace api

starknet-io · Sep 12, 2022 · d488ab2 · d488ab2
1 parent 6ebe32b
commit d488ab2
Show file tree

Hide file tree

Showing 3 changed files with 339 additions and 128 deletions.
diff --git a/src/provider/rpc.ts b/src/provider/rpc.ts
@@ -90,6 +90,10 @@ export class RpcProvider implements ProviderInterface {
     );
   }
 
+  public async getBlockHashAndNumber(): Promise<RPC.BlockHashAndNumber> {
+    return this.fetchEndpoint('starknet_blockHashAndNumber');
+  }
+
   public async getBlockWithTxHashes(
     blockIdentifier: BlockIdentifier = 'pending'
   ): Promise<RPC.GetBlockWithTxHashesResponse> {
@@ -104,10 +108,29 @@ export class RpcProvider implements ProviderInterface {
     return this.fetchEndpoint('starknet_getBlockWithTxs', [block.identifier]);
   }
 
+  public async getClassHashAt(
+    blockIdentifier: BlockIdentifier,
+    contractAddress: RPC.ContractAddress
+  ): Promise<RPC.Felt> {
+    return this.fetchEndpoint('starknet_getClassHashAt', [blockIdentifier, contractAddress]);
+  }
+
   public async getNonce(contractAddress: string): Promise<any> {
     return this.fetchEndpoint('starknet_getNonce', [contractAddress]);
   }
 
+  public async getPendingTransactions(): Promise<RPC.Transaction> {
+    return this.fetchEndpoint('starknet_pendingTransactions');
+  }
+
+  public async getProtocolVersion(): Promise<Error> {
+    throw new Error('Pathfinder does not implement this rpc 0.1.0 method');
+  }
+
+  public async getStateUpdate(blockIdentifier: BlockIdentifier): Promise<RPC.StateUpdate> {
+    return this.fetchEndpoint('starknet_getStateUpdate', [blockIdentifier]);
+  }
+
   public async getStorageAt(
     contractAddress: string,
     key: BigNumberish,
@@ -146,11 +169,23 @@ export class RpcProvider implements ProviderInterface {
     );
   }
 
+  // TODO: Check, changed response from common interface to rpc
+  public async getClass(classHash: RPC.Felt): Promise<RPC.ContractClass> {
+    return this.fetchEndpoint('starknet_getClass', [classHash]);
+  }
+
   public async getClassAt(contractAddress: string, blockIdentifier: BlockIdentifier): Promise<any> {
     const block = new Block(blockIdentifier);
     return this.fetchEndpoint('starknet_getClassAt', [block.identifier, contractAddress]);
   }
 
+  public async getCode(
+    _contractAddress: string,
+    _blockIdentifier?: BlockIdentifier
+  ): Promise<GetCodeResponse> {
+    throw new Error('RPC 0.1.0 does not implement getCode function');
+  }
+
   public async getEstimateFee(
     invocation: Invocation,
     blockIdentifier: BlockIdentifier = 'pending',
@@ -234,11 +269,12 @@ export class RpcProvider implements ProviderInterface {
     return this.responseParser.parseCallContractResponse(result);
   }
 
-  public async getCode(
-    _contractAddress: string,
-    _blockIdentifier?: BlockIdentifier
-  ): Promise<GetCodeResponse> {
-    throw new Error('RPC 0.1.0 does not implement getCode function');
+  public async traceTransaction(transactionHash: RPC.TransactionHash): Promise<RPC.Trace> {
+    return this.fetchEndpoint('starknet_traceTransaction', [transactionHash]);
+  }
+
+  public async traceBlockTransactions(blockHash: RPC.BlockHash): Promise<RPC.Traces> {
+    return this.fetchEndpoint('starknet_traceBlockTransactions', [blockHash]);
   }
 
   public async waitForTransaction(txHash: BigNumberish, retryInterval: number = 8000) {