-
Notifications
You must be signed in to change notification settings - Fork 16
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Project import generated by Copybara.
GitOrigin-RevId: 0dcde0f2906af7561cc4171dadc695e3e5dad4c5
- Loading branch information
1 parent
f113e1c
commit ac35faf
Showing
115 changed files
with
17,382 additions
and
2,435 deletions.
There are no files selected for viewing
Large diffs are not rendered by default.
Oops, something went wrong.
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
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
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,153 @@ | ||
| import { SolanaWithSignerBaseCommand as BaseCommand } from "../../../solana"; | ||
| import { CHECK_ICON } from "../../../utils"; | ||
|
|
||
| import { Flags } from "@oclif/core"; | ||
| import { Keypair } from "@solana/web3.js"; | ||
| import { sleep } from "@switchboard-xyz/common"; | ||
| import { AttestationQueueAccount } from "@switchboard-xyz/solana.js"; | ||
| import chalk from "chalk"; | ||
|
|
||
| export default class AttestationQueueBootstrap extends BaseCommand { | ||
| static enableJsonFlag = true; | ||
|
|
||
| static description = "bootstrap an attestation queue"; | ||
|
|
||
| static flags = { | ||
| ...BaseCommand.flags, | ||
| // queue flags | ||
| authority: Flags.string({ | ||
| char: "a", | ||
| description: | ||
| "alternate keypair that is the authority for the queue and is required to approve permissions", | ||
| }), | ||
| queueKeypair: Flags.string({ | ||
| description: | ||
| "keypair to use for the attestation queue account. This will be the account's publicKey", | ||
| }), | ||
| reward: Flags.string({ | ||
| description: | ||
| "the reward payed out to oracles for responding to an update request on-chain, Ex: A reward of 0.0000075 with a feed with a batchSize of 4 would deduct (4 * 0.0000075) wSOL from an aggregators lease each round.", | ||
| default: "0", | ||
| }), | ||
| allowAuthorityOverrideAfter: Flags.integer({ | ||
| description: | ||
| "Allow authority to force add a node after X seconds with no heartbeat.", | ||
| default: 86_400, // 1 day | ||
| }), | ||
| maxQuoteVerificationAge: Flags.integer({ | ||
| description: | ||
| "The maximum allowable time until a EnclaveAccount needs to be re-verified on-chain.", | ||
| default: 604_800, // 1 week | ||
| }), | ||
| nodeTimeout: Flags.integer({ | ||
| description: | ||
| "The maximum allowable time until a node needs to send a heartbeat.", | ||
| default: 86_400, // 1 day | ||
| }), | ||
| requireAuthorityHeartbeatPermissions: Flags.boolean({ | ||
| description: | ||
| "Even if a heartbeating machine quote verifies with proper measurement, require authority signoff.", | ||
| }), | ||
| requireUsagePermissions: Flags.boolean({ | ||
| description: | ||
| "Require FunctionAccounts to have PermitQueueUsage before they are executed.", | ||
| }), | ||
| enclaveSigner: Flags.string({ | ||
| description: "Signer used for the verifier oracle to verify quotes", | ||
| required: false, | ||
| }), | ||
| }; | ||
|
|
||
| async run() { | ||
| const { flags } = await this.parse(AttestationQueueBootstrap); | ||
|
|
||
| if (this.network === "mainnet-beta") { | ||
| throw new Error( | ||
| `You should only bootstrap a queue on devnet or localnet` | ||
| ); | ||
| } | ||
|
|
||
| let authority: Keypair | undefined; | ||
| if (flags.authority) { | ||
| authority = await this.loadAuthority(flags.authority); | ||
| } | ||
|
|
||
| let queueKeypair: Keypair = Keypair.generate(); | ||
| if (flags.queueKeypair) { | ||
| queueKeypair = await this.loadKeypair(flags.queueKeypair); | ||
| } | ||
| await this.program.verifyNewKeypair(queueKeypair); | ||
|
|
||
| let enclaveSignerKeypair: Keypair = Keypair.generate(); | ||
| if (flags.enclaveSigner) { | ||
| enclaveSignerKeypair = await this.loadKeypair(flags.enclaveSigner); | ||
| } | ||
| await this.program.verifyNewKeypair(enclaveSignerKeypair); | ||
|
|
||
| const bootstrappedQueue = await AttestationQueueAccount.bootstrapNewQueue( | ||
| this.program, | ||
| { | ||
| authority: authority, | ||
| reward: Number(flags.reward), | ||
| allowAuthorityOverrideAfter: flags.allowAuthorityOverrideAfter, | ||
| maxQuoteVerificationAge: flags.maxQuoteVerificationAge, | ||
| requireAuthorityHeartbeatPermission: | ||
| flags.requireAuthorityHeartbeatPermissions, | ||
| requireUsagePermissions: flags.requireUsagePermissions, | ||
| nodeTimeout: flags.nodeTimeout, | ||
| keypair: queueKeypair, | ||
|
|
||
| // | ||
| verifierEnclave: Buffer.from("DefaultMrEnclave"), | ||
| enclaveSigner: enclaveSignerKeypair, | ||
| } | ||
| ); | ||
|
|
||
| const attestationQueueAccount = bootstrappedQueue.attestationQueue.account; | ||
| const verifierAccount = bootstrappedQueue.verifier.account; | ||
| const verifierPermissionAccount = | ||
| bootstrappedQueue.verifier.permissionAccount; | ||
|
|
||
| const signatures = bootstrappedQueue.signatures ?? []; | ||
|
|
||
| if (flags.json) { | ||
| await sleep(1000); | ||
| const attestationQueue = await attestationQueueAccount.loadData(); | ||
| const verifierData = await verifierAccount.loadData(); | ||
| return this.normalizeAccountData(attestationQueueAccount.publicKey, { | ||
| attestationQueue: attestationQueue, | ||
| verifier: verifierData, | ||
| }); | ||
| } | ||
|
|
||
| if (this.silent) { | ||
| this.logger.info(signatures.map((s) => this.toUrl(s)).join("\n")); | ||
| return; | ||
| } | ||
|
|
||
| // handle nicer logging here | ||
| this.logger.info( | ||
| `${chalk.green( | ||
| CHECK_ICON, | ||
| "successfully created an attestation queue" | ||
| )} - ${attestationQueueAccount.publicKey}` | ||
| ); | ||
|
|
||
| // handle nicer logging here | ||
| this.logger.info( | ||
| `${chalk.green(CHECK_ICON, "successfully created a verifier oracle")} - ${ | ||
| verifierAccount.publicKey | ||
| }` | ||
| ); | ||
|
|
||
| this.logger.info( | ||
| `Transaction Signature: ${signatures | ||
| .map((s) => this.toUrl(s)) | ||
| .join("\n")}` | ||
| ); | ||
| } | ||
|
|
||
| async catch(error: any) { | ||
| super.catch(error, "Failed to bootstrap attestation queue account"); | ||
| } | ||
| } |
Oops, something went wrong.