-
Notifications
You must be signed in to change notification settings - Fork 1
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
Showing
8 changed files
with
357 additions
and
11 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 |
|---|---|---|
| @@ -0,0 +1,17 @@ | ||
| defmodule Tezex.Application do | ||
| # See https://hexdocs.pm/elixir/Application.html | ||
| # for more information on OTP Applications | ||
| @moduledoc false | ||
|
|
||
| use Application | ||
|
|
||
| @impl true | ||
| def start(_type, _args) do | ||
| children = [{Finch, name: Tezex.Finch}] | ||
|
|
||
| # See https://hexdocs.pm/elixir/Supervisor.html | ||
| # for other strategies and supported options | ||
| opts = [strategy: :one_for_one, name: Tezex.Supervisor] | ||
| Supervisor.start_link(children, opts) | ||
| end | ||
| end |
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
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 |
|---|---|---|
| @@ -0,0 +1,166 @@ | ||
| defmodule Tezex.Rpc do | ||
| alias Tezex.Crypto | ||
| alias Tezex.Crypto.Base58Check | ||
| alias Tezex.ForgeOperation | ||
| alias Tezex.Rpc | ||
| alias Tezex.Transaction | ||
|
|
||
| @type t() :: %__MODULE__{ | ||
| endpoint: binary(), | ||
| chain_id: binary(), | ||
| headers: Finch.Request.headers(), | ||
| opts: Finch.request_opts() | ||
| } | ||
|
|
||
| defstruct [:endpoint, chain_id: "main", headers: [], opts: []] | ||
|
|
||
| # Various constants for the Tezos platforms. Fees are expressed in µtz unless otherwise noted, storage unit is bytes. | ||
| @operation_group_watermark <<3>> | ||
|
|
||
| @default_simple_transaction_fee 1420 | ||
| @default_transaction_storage_limit 496 | ||
| @default_transaction_gas_limit 10600 | ||
|
|
||
| @default_delegation_fee 1258 | ||
| @default_delegation_storage_limit 0 | ||
| @default_delegation_gas_limit 1100 | ||
|
|
||
| @default_key_reveal_fee 1270 | ||
| @default_key_reveal_storage_limit 0 | ||
| @default_key_reveal_gas_limit 1100 | ||
|
|
||
| @p005_manager_contract_withdrawal_gas_limit 26283 | ||
| @p005_manager_contract_deposit_gas_limit 15285 | ||
| @p005_manager_contract_withdrawal_storage_limit 496 | ||
|
|
||
| @p001_storage_rate 1_000_000 / 1000 | ||
| @p007_storage_rate 250_000 / 1000 | ||
| @storage_rate @p007_storage_rate | ||
|
|
||
| @base_operation_fee 100 | ||
|
|
||
| @p009_block_gas_cap 10_400_000 | ||
| @p010_block_gas_cap 5_200_000 | ||
| @p016_block_gas_cap 2_600_000 | ||
| @p007_operation_gas_cap 1_040_000 | ||
| @operation_gas_cap @p007_operation_gas_cap | ||
| @block_gas_cap @p016_block_gas_cap | ||
|
|
||
| @p010_operation_storage_cap 60_000 | ||
| @p011_operation_storage_cap 32_768 | ||
| @operation_storage_cap @p011_operation_storage_cap | ||
|
|
||
| @empty_account_storage_burn 257 | ||
|
|
||
| @default_baker_vig 200 | ||
|
|
||
| @gas_limit_padding 1000 | ||
| @storage_limit_padding 25 | ||
|
|
||
| @head_branch_offset 54 | ||
| @max_branch_offset 64 | ||
|
|
||
| # Outbound operation queue timeout in seconds. After this period, TezosOperationQueue will attempt to submit the transactions currently in queue. | ||
| @default_batch_delay 25 | ||
|
|
||
| @p009_block_time 60 | ||
| @p010_block_time 30 | ||
| @default_block_time @p010_block_time | ||
|
|
||
| @genesis_block_time ~U[2018-06-30 10:07:32.000Z] | ||
|
|
||
| def build_contract_operation( | ||
| %Rpc{} = rpc, | ||
| public_key_hash, | ||
| counter, | ||
| contract, | ||
| amount, | ||
| fee, | ||
| storage_limit, | ||
| gas_limit, | ||
| entrypoint, | ||
| parameters, | ||
| encoded_private_key | ||
| ) do | ||
| parameters = | ||
| cond do | ||
| not is_nil(parameters) -> %{entrypoint: entrypoint || "default", value: parameters} | ||
| not is_nil(entrypoint) -> %{entrypoint: entrypoint, value: []} | ||
| true -> nil | ||
| end | ||
|
|
||
| %Transaction{ | ||
| source: public_key_hash, | ||
| destination: contract, | ||
| amount: Integer.to_string(amount), | ||
| storage_limit: Integer.to_string(storage_limit), | ||
| gas_limit: Integer.to_string(gas_limit), | ||
| counter: Integer.to_string(counter), | ||
| fee: Integer.to_string(fee), | ||
| kind: "transaction", | ||
| parameters: parameters | ||
| } | ||
| end | ||
|
|
||
| def send_operation(%Rpc{} = rpc, operations, encoded_private_key, offset) do | ||
| {:ok, block_head} = get_block_at_offset(rpc, offset) | ||
| block_hash = binary_part(block_head["hash"], 0, 51) | ||
|
|
||
| forged_operation_group = | ||
| ForgeOperation.forge_operation_group(%{"branch" => block_hash, "contents" => operations}) | ||
|
|
||
| op_signature = | ||
| Crypto.sign_message( | ||
| encoded_private_key, | ||
| @operation_group_watermark <> forged_operation_group | ||
| ) | ||
|
|
||
| signed_op_group = forged_operation_group <> op_signature | ||
|
|
||
| op_pair = %{bytes: signed_op_group, signature: op_signature} | ||
|
|
||
| applied = preapply_operation(rpc, block_hash, block_head["protocol"], operations, op_pair) | ||
| injected_op = inject_operation(rpc, op_pair) | ||
|
|
||
| %{results: applied[0], operation_group_id: injected_op = inject_operation(rpc, op_pair)} | ||
| end | ||
|
|
||
| def get_counter_for_account(%Rpc{} = rpc, address) do | ||
| with {:ok, n} <- get(rpc, "/blocks/head/context/contracts/#{address}/counter"), | ||
| {n, ""} <- Integer.parse(n) do | ||
| n | ||
| end | ||
| end | ||
|
|
||
| def get_next_counter_for_account(%Rpc{} = rpc, address) do | ||
| get_counter_for_account(rpc, address) + 1 | ||
| end | ||
|
|
||
| def get_block(%Rpc{} = rpc, hash \\ "head") do | ||
| get(rpc, "/blocks/#{hash}") | ||
| end | ||
|
|
||
| def get_block_at_offset(%Rpc{} = rpc, offset) do | ||
| if offset <= 0 do | ||
| get_block(rpc) | ||
| end | ||
|
|
||
| {:ok, head} = get_block(rpc) | ||
| get(rpc, "/blocks/#{head["header"]["level"] - offset}") | ||
| end | ||
|
|
||
| def get(%Rpc{} = rpc, path) do | ||
| url = | ||
| URI.parse(rpc.endpoint) | ||
| |> URI.append_path("/chains/#{rpc.chain_id}") | ||
| |> URI.append_path(path) | ||
| |> URI.to_string() | ||
|
|
||
| Finch.build(:get, url, rpc.headers) | ||
| |> Finch.request(Tezex.Finch, rpc.opts) | ||
| |> case do | ||
| {:ok, %Finch.Response{status: 200, body: body}} -> Jason.decode(body) | ||
| {:error, _} = err -> err | ||
| end | ||
| end | ||
| end |
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 |
|---|---|---|
| @@ -0,0 +1,53 @@ | ||
| defmodule Tezex.Transaction do | ||
| alias Tezex.Transaction | ||
|
|
||
| @type t() :: %__MODULE__{ | ||
| source: binary() | nil, | ||
| destination: binary(), | ||
| fee: pos_integer() | nil, | ||
| counter: integer() | nil, | ||
| gas_limit: pos_integer() | nil, | ||
| amount: pos_integer() | nil, | ||
| destination: binary(), | ||
| storage_limit: pos_integer() | nil, | ||
| parameters: map() | nil | ||
| } | ||
|
|
||
| defstruct [ | ||
| :kind, | ||
| :destination, | ||
| :source, | ||
| fee: 0, | ||
| counter: 0, | ||
| gas_limit: 0, | ||
| amount: 0, | ||
| storage_limit: 0, | ||
| parameters: nil | ||
| ] | ||
|
|
||
| defimpl Jason.Encoder do | ||
| def encode(%Transaction{parameters: nil} = transaction, opts) do | ||
| transaction | ||
| |> Map.from_struct() | ||
| |> Map.drop([:parameters]) | ||
| |> encode(opts) | ||
| end | ||
|
|
||
| def encode(%Transaction{} = transaction, opts) do | ||
| transaction | ||
| |> Map.from_struct() | ||
| |> encode(opts) | ||
| end | ||
|
|
||
| def encode(value, opts) do | ||
| value | ||
| |> Map.put(:kind, "transaction") | ||
| |> Map.update!(:fee, &to_string/1) | ||
| |> Map.update!(:gas_limit, &to_string/1) | ||
| |> Map.update!(:amount, &to_string/1) | ||
| |> Map.update!(:storage_limit, &to_string/1) | ||
| |> Map.update!(:counter, &to_string/1) | ||
| |> Jason.Encode.map(opts) | ||
| end | ||
| end | ||
| end |
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
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
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
Oops, something went wrong.