-
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.
Add tool to list bootstrapped commands
- Loading branch information
1 parent
f6f2b4b
commit 72e723c
Showing
5 changed files
with
160 additions
and
123 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
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,152 @@ | ||
| open Core | ||
| open Async | ||
| open Sequencer_lib | ||
| open Mina_base | ||
|
|
||
| let printf = Core.printf | ||
|
|
||
| let print_endline = Core.print_endline | ||
|
|
||
| let committer = | ||
| let list = | ||
| ( "commits-list" | ||
| , Command.basic ~summary:"List all of the transactions in the database" | ||
| (let%map_open.Command db_dir = | ||
| flag "--db-dir" | ||
| (optional_with_default "db" string) | ||
| ~doc:"string Directory to store the database" | ||
| in | ||
| fun () -> | ||
| let kvdb = Kvdb.of_dir db_dir in | ||
| let indices = Executor.Commits_store.get_index kvdb in | ||
| printf "Found %d transactions\n%!" (List.length indices) ; | ||
| List.iter indices ~f:(fun (source, target) -> | ||
| printf "Source: %s\nTarget: %s\n\n%!" | ||
| (Frozen_ledger_hash.to_decimal_string source) | ||
| (Frozen_ledger_hash.to_decimal_string target) ) ) ) | ||
| in | ||
|
|
||
| let get = | ||
| ( "get" | ||
| , Command.basic ~summary:"Find the command with the given source and target" | ||
| (let%map_open.Command db_dir = | ||
| flag "--db-dir" | ||
| (optional_with_default "db" string) | ||
| ~doc:"string Directory to store the database" | ||
| and source = | ||
| flag "--source" (required string) | ||
| ~doc:"string The source ledger of the transaction" | ||
| and target = | ||
| flag "--target" (required string) | ||
| ~doc:"string The target ledger of the transaction" | ||
| in | ||
| fun () -> | ||
| let kvdb = Kvdb.of_dir db_dir in | ||
| match | ||
| Executor.Commits_store.get_commit kvdb | ||
| ~source:(Frozen_ledger_hash.of_decimal_string source) | ||
| ~target:(Frozen_ledger_hash.of_decimal_string target) | ||
| with | ||
| | Some commit -> | ||
| print_endline | ||
| (Yojson.Safe.pretty_to_string @@ Zkapp_command.to_yojson commit) | ||
| | None -> | ||
| printf "No commit found\n%!" ) ) | ||
| in | ||
| let send = | ||
| ( "send" | ||
| , Command.basic ~summary:"Send a transaction to the sequencer" | ||
| (let%map_open.Command db_dir = | ||
| flag "--db-dir" | ||
| (optional_with_default "db" string) | ||
| ~doc:"string Directory to store the database" | ||
| and l1_uri = flag "--l1-uri" (required string) ~doc:"string L1 URI" | ||
| and fee_arg = | ||
| flag "--fee" (required int) ~doc:"int The fee amount in nanomina" | ||
| and nonce_opt = | ||
| flag "--nonce" (optional int) | ||
| ~doc:"int Will be fetched from the network if not provided" | ||
| and source = | ||
| flag "--source" (required string) | ||
| ~doc:"string The source ledger of the transaction" | ||
| and target = | ||
| flag "--target" (required string) | ||
| ~doc:"string The target ledger of the transaction" | ||
| in | ||
| let signer = | ||
| Signature_lib.( | ||
| Keypair.of_private_key_exn @@ Private_key.of_base58_check_exn | ||
| @@ Sys.getenv_exn "MINA_PRIVATE_KEY") | ||
| in | ||
| let l1_uri : Uri.t Cli_lib.Flag.Types.with_name = | ||
| Cli_lib.Flag.Types.{ value = Uri.of_string l1_uri; name = "l1-uri" } | ||
| in | ||
| let kvdb = Kvdb.of_dir db_dir in | ||
| fun () -> | ||
| Thread_safe.block_on_async_exn (fun () -> | ||
| let command = | ||
| Option.value_exn ~message:"No commit found" | ||
| @@ Executor.Commits_store.get_commit kvdb | ||
| ~source:(Frozen_ledger_hash.of_decimal_string source) | ||
| ~target:(Frozen_ledger_hash.of_decimal_string target) | ||
| in | ||
| let%bind nonce = | ||
| match nonce_opt with | ||
| | Some nonce -> | ||
| return nonce | ||
| | None -> | ||
| Sequencer_lib.Gql_client.fetch_nonce l1_uri | ||
| (Signature_lib.Public_key.compress signer.public_key) | ||
| in | ||
| let executor = Executor.create ~nonce ~l1_uri ~signer ~kvdb () in | ||
| let command = | ||
| Zkapp_command. | ||
| { command with | ||
| fee_payer = | ||
| { command.fee_payer with | ||
| body = | ||
| { command.fee_payer.body with | ||
| fee = Currency.Fee.of_nanomina_int_exn fee_arg | ||
| } | ||
| } | ||
| } | ||
| in | ||
| Executor.send_zkapp_command executor command ) ) ) | ||
| in | ||
| ( "committer" | ||
| , Command.group | ||
| ~summary:"Script to manually send commiting transactions to L1" | ||
| [ list; get; send ] ) | ||
|
|
||
| let da_layer = | ||
| let bootstrap_commands = | ||
| ( "bootstrap-commands" | ||
| , Command.basic ~summary:"List commands to be applied when bootstrapping" | ||
| (let%map_open.Command target = | ||
| flag "--target" (required string) | ||
| ~doc:"string The target ledger of the transaction (decimal string)" | ||
| and da_contract_address = | ||
| flag "--da-contract-address" (required string) | ||
| ~doc:"string The address of the DA contract" | ||
| in | ||
| fun () -> | ||
| Thread_safe.block_on_async_exn (fun () -> | ||
| let%bind commands = | ||
| Da_layer.get_batches | ||
| Da_layer.{ da_contract_address = Some da_contract_address } | ||
| ~to_:target | ||
| in | ||
| printf "Found %d commands\n%!" (List.length commands) ; | ||
| return | ||
| @@ List.iter commands ~f:(fun command -> | ||
| printf "%s\n\n%!" | ||
| ( Yojson.Safe.pretty_to_string | ||
| @@ User_command.to_yojson command ) ) ) ) ) | ||
| in | ||
| ( "da-layer" | ||
| , Command.group ~summary:"Tool to interact with the DA layer of the sequencer" | ||
| [ bootstrap_commands ] ) | ||
|
|
||
| let () = | ||
| Command.group ~summary:"Sequencer CLI" [ committer; da_layer ] | ||
| |> Command_unix.run |
This file was deleted.
Oops, something went wrong.
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