-
Notifications
You must be signed in to change notification settings - Fork 25
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
1f06787
commit ce9c015
Showing
3 changed files
with
700 additions
and
675 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,167 +1,192 @@ | ||
| import {TonClient} from "@eversdk/core"; | ||
| import { | ||
| Abi, accountForExecutorAccount, | ||
| ParamsOfEncodeMessage, | ||
| ResultOfProcessMessage, | ||
| ResultOfRunExecutor, | ||
| Signer, | ||
| } from "@eversdk/core"; | ||
|
|
||
| export type AccountDeployParams = { | ||
| tvc: string, initFunctionName?: string, | ||
| initFunctionInput?: any, | ||
| initData?: any, | ||
| } | ||
|
|
||
| export class AccountError extends Error { | ||
| } | ||
|
|
||
| export class Account { | ||
| readonly client: TonClient; | ||
| readonly abi: Abi; | ||
| readonly signer: Signer; | ||
|
|
||
| private readonly deployParams: AccountDeployParams | null; | ||
| private address: string | null; | ||
| private cachedBoc: string | null; | ||
| private cachedBocLt: string | null; | ||
| private minExpectedLt: string; | ||
|
|
||
| // private cachedParsed: any | null; | ||
|
|
||
| constructor( | ||
| client: TonClient, | ||
| abi: Abi, | ||
| signer: Signer, | ||
| addressOrDeploy: string | AccountDeployParams, | ||
| ) { | ||
| this.client = client; | ||
| this.abi = abi; | ||
| this.signer = signer; | ||
| if (typeof addressOrDeploy === "string") { | ||
| this.address = addressOrDeploy; | ||
| this.deployParams = null; | ||
| } else { | ||
| this.address = null; | ||
| this.deployParams = addressOrDeploy; | ||
| } | ||
| this.cachedBoc = null; | ||
| this.cachedBocLt = null; | ||
| this.minExpectedLt = "0x0"; | ||
| } | ||
|
|
||
| async getAddress(): Promise<string> { | ||
| let address = this.address; | ||
| if (!address) { | ||
| const deployParams = this.getParamsOfDeployMessage(); | ||
| address = (await this.client.abi.encode_message(deployParams)).address; | ||
| this.address = address; | ||
| } | ||
| return address; | ||
| } | ||
|
|
||
| getParamsOfDeployMessage(): ParamsOfEncodeMessage { | ||
| const params = this.deployParams; | ||
| if (!params) { | ||
| throw this.errorDeployParamsRequired(); | ||
| } | ||
| return { | ||
| abi: this.abi, | ||
| signer: this.signer, | ||
| deploy_set: { | ||
| tvc: params.tvc, | ||
| initial_data: params.initData, | ||
| }, | ||
| call_set: params.initFunctionName | ||
| ? { | ||
| function_name: params.initFunctionName, | ||
| input: params.initFunctionInput, | ||
| } | ||
| : undefined, | ||
| }; | ||
| } | ||
|
|
||
| async deploy(): Promise<ResultOfProcessMessage> { | ||
| const deployParams = this.getParamsOfDeployMessage(); | ||
| this.address = (await this.client.abi.encode_message(deployParams)).address; | ||
| const result = await this.client.processing.process_message({ | ||
| message_encode_params: deployParams, | ||
| send_events: false, | ||
| }); | ||
| this.setMinExpectedLt(result.transaction["lt"]); | ||
| return result; | ||
| } | ||
|
|
||
| async run(functionName: string, input?: any): Promise<ResultOfProcessMessage> { | ||
| return await this.client.processing.process_message({ | ||
| message_encode_params: { | ||
| address: await this.getAddress(), | ||
| abi: this.abi, | ||
| signer: this.signer, | ||
| call_set: { | ||
| function_name: functionName, | ||
| input, | ||
| }, | ||
| }, | ||
| send_events: false, | ||
| }); | ||
| } | ||
|
|
||
| async runLocal(functionName: string, input: any): Promise<ResultOfRunExecutor> { | ||
| const message = await this.client.abi.encode_message({ | ||
| abi: this.abi, | ||
| signer: this.signer, | ||
| call_set: { | ||
| function_name: functionName, | ||
| input, | ||
| }, | ||
| }); | ||
| const result = await this.client.tvm.run_executor({ | ||
| account: accountForExecutorAccount(await this.boc()), | ||
| abi: this.abi, | ||
| message: message.message, | ||
| }); | ||
| if (result.account) { | ||
| this.cachedBoc = result.account; | ||
| } | ||
| return result; | ||
| } | ||
|
|
||
| setMinExpectedLt(minExpectedLt: string) { | ||
| if (this.cachedBocLt && Number(minExpectedLt) > Number(this.cachedBocLt)) { | ||
| this.dropCachedData() | ||
| } | ||
| this.minExpectedLt = minExpectedLt; | ||
| } | ||
|
|
||
| dropCachedData() { | ||
| this.cachedBoc = null; | ||
| } | ||
|
|
||
| async boc(): Promise<string> { | ||
| if (this.cachedBoc) { | ||
| return this.cachedBoc; | ||
| } | ||
| const { boc, last_trans_lt } = (await this.client.net.wait_for_collection({ | ||
| collection: "accounts", | ||
| filter: { | ||
| id: {eq: this.address}, | ||
| last_trans_lt: {ge: this.minExpectedLt}, | ||
| }, | ||
| result: "boc last_trans_lt", | ||
| })).result; | ||
| this.cachedBoc = boc; | ||
| this.cachedBocLt = last_trans_lt; | ||
| return boc; | ||
| } | ||
|
|
||
| async getAccount(): Promise<any> { | ||
| return (await this.client.boc.parse_account({ | ||
| boc: await this.boc(), | ||
| })).parsed; | ||
| } | ||
|
|
||
| private errorDeployParamsRequired(): AccountError { | ||
| return new AccountError(`Deploy params required. `); | ||
| } | ||
| } | ||
| import {TonClient} from "@eversdk/core"; | ||
| import { | ||
| Abi, accountForExecutorAccount, | ||
| ParamsOfEncodeMessage, | ||
| ResultOfProcessMessage, | ||
| ResultOfRunExecutor, | ||
| Signer, | ||
| } from "@eversdk/core"; | ||
|
|
||
| export const MAX_WAIT_TIME = 40_000; // 40 sec | ||
|
|
||
| export type AccountDeployParams = { | ||
| tvc: string, initFunctionName?: string, | ||
| initFunctionInput?: any, | ||
| initData?: any, | ||
| } | ||
|
|
||
| export class AccountError extends Error { | ||
| } | ||
|
|
||
| export class Account { | ||
| readonly client: TonClient; | ||
| readonly abi: Abi; | ||
| readonly signer: Signer; | ||
|
|
||
| private readonly deployParams: AccountDeployParams | null; | ||
| private address: string | null; | ||
| private cachedBoc: string | null; | ||
| private cachedBocLt: string | null; | ||
| private minExpectedLt: string; | ||
|
|
||
| // private cachedParsed: any | null; | ||
|
|
||
| constructor( | ||
| client: TonClient, | ||
| abi: Abi, | ||
| signer: Signer, | ||
| addressOrDeploy: string | AccountDeployParams, | ||
| ) { | ||
| this.client = client; | ||
| this.abi = abi; | ||
| this.signer = signer; | ||
| if (typeof addressOrDeploy === "string") { | ||
| this.address = addressOrDeploy; | ||
| this.deployParams = null; | ||
| } else { | ||
| this.address = null; | ||
| this.deployParams = addressOrDeploy; | ||
| } | ||
| this.cachedBoc = null; | ||
| this.cachedBocLt = null; | ||
| this.minExpectedLt = "0x0"; | ||
| } | ||
|
|
||
| async getAddress(): Promise<string> { | ||
| let address = this.address; | ||
| if (!address) { | ||
| const deployParams = this.getParamsOfDeployMessage(); | ||
| address = (await this.client.abi.encode_message(deployParams)).address; | ||
| this.address = address; | ||
| } | ||
| return address; | ||
| } | ||
|
|
||
| getParamsOfDeployMessage(): ParamsOfEncodeMessage { | ||
| const params = this.deployParams; | ||
| if (!params) { | ||
| throw this.errorDeployParamsRequired(); | ||
| } | ||
| return { | ||
| abi: this.abi, | ||
| signer: this.signer, | ||
| deploy_set: { | ||
| tvc: params.tvc, | ||
| initial_data: params.initData, | ||
| }, | ||
| call_set: params.initFunctionName | ||
| ? { | ||
| function_name: params.initFunctionName, | ||
| input: params.initFunctionInput, | ||
| } | ||
| : undefined, | ||
| }; | ||
| } | ||
|
|
||
| async deploy(): Promise<ResultOfProcessMessage> { | ||
| const deployParams = this.getParamsOfDeployMessage(); | ||
| this.address = (await this.client.abi.encode_message(deployParams)).address; | ||
| const result = await this.client.processing.process_message({ | ||
| message_encode_params: deployParams, | ||
| send_events: false, | ||
| }); | ||
| this.setMinExpectedLt(result.transaction["lt"]); | ||
| return result; | ||
| } | ||
|
|
||
| async run(functionName: string, input?: any): Promise<ResultOfProcessMessage> { | ||
| return await this.client.processing.process_message({ | ||
| message_encode_params: { | ||
| address: await this.getAddress(), | ||
| abi: this.abi, | ||
| signer: this.signer, | ||
| call_set: { | ||
| function_name: functionName, | ||
| input, | ||
| }, | ||
| }, | ||
| send_events: false, | ||
| }); | ||
| } | ||
|
|
||
| async runLocal(functionName: string, input: any): Promise<ResultOfRunExecutor> { | ||
| const message = await this.client.abi.encode_message({ | ||
| abi: this.abi, | ||
| signer: this.signer, | ||
| call_set: { | ||
| function_name: functionName, | ||
| input, | ||
| }, | ||
| }); | ||
| const result = await this.client.tvm.run_executor({ | ||
| account: accountForExecutorAccount(await this.boc()), | ||
| abi: this.abi, | ||
| message: message.message, | ||
| }); | ||
| if (result.account) { | ||
| this.cachedBoc = result.account; | ||
| } | ||
| return result; | ||
| } | ||
|
|
||
| setMinExpectedLt(minExpectedLt: string) { | ||
| if (this.cachedBocLt && Number(minExpectedLt) > Number(this.cachedBocLt)) { | ||
| this.dropCachedData() | ||
| } | ||
| this.minExpectedLt = minExpectedLt; | ||
| } | ||
|
|
||
| dropCachedData() { | ||
| this.cachedBoc = null; | ||
| } | ||
|
|
||
| async boc(): Promise<string> { | ||
| if (this.cachedBoc) { | ||
| return this.cachedBoc; | ||
| } | ||
| const query = ` | ||
| query($address:String!) { | ||
| blockchain { | ||
| account( | ||
| address: $address | ||
| ) { | ||
| info { | ||
| boc | ||
| last_trans_lt | ||
| } | ||
| } | ||
| } | ||
| }`; | ||
| const variables = {address: this.address}; | ||
| let last_trans_lt; | ||
| let boc; | ||
| let delay = 0 | ||
| const timeLimit = Date.now() + MAX_WAIT_TIME // 40 sec | ||
| while (!(last_trans_lt >= this.minExpectedLt) && (Date.now() < timeLimit)) { | ||
| if (delay > 0) { | ||
| await new Promise(resolve => setTimeout(resolve, delay)); | ||
| if (delay < 5000) { | ||
| delay += 1000 | ||
| } | ||
| } else { | ||
| delay = 1000 | ||
| } | ||
| const { result } = await this.client.net.query({ query, variables }); | ||
| boc = result.data.blockchain.account.info.boc; | ||
| last_trans_lt = result.data.blockchain.account.info.last_trans_lt; | ||
| } | ||
| this.cachedBoc = boc; | ||
| this.cachedBocLt = last_trans_lt; | ||
| return boc; | ||
| } | ||
|
|
||
| async getAccount(): Promise<any> { | ||
| return (await this.client.boc.parse_account({ | ||
| boc: await this.boc(), | ||
| })).parsed; | ||
| } | ||
|
|
||
| private errorDeployParamsRequired(): AccountError { | ||
| return new AccountError(`Deploy params required. `); | ||
| } | ||
| } |
Oops, something went wrong.