-
Notifications
You must be signed in to change notification settings - Fork 66
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #1125 from onflow/chasefleming/flix-integratin
Execute FLIX scripts/transactions
- Loading branch information
Showing
8 changed files
with
209 additions
and
33 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
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,163 @@ | ||
| /* | ||
| * Flow CLI | ||
| * | ||
| * Copyright 2019 Dapper Labs, Inc. | ||
| * | ||
| * Licensed under the Apache License, Version 2.0 (the "License"); | ||
| * you may not use this file except in compliance with the License. | ||
| * You may obtain a copy of the License at | ||
| * | ||
| * http://www.apache.org/licenses/LICENSE-2.0 | ||
| * | ||
| * Unless required by applicable law or agreed to in writing, software | ||
| * distributed under the License is distributed on an "AS IS" BASIS, | ||
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
| * See the License for the specific language governing permissions and | ||
| * limitations under the License. | ||
| */ | ||
|
|
||
| package super | ||
|
|
||
| import ( | ||
| "context" | ||
| "encoding/hex" | ||
| "fmt" | ||
| "os" | ||
|
|
||
| "github.com/onflow/flixkit-go" | ||
|
|
||
| "github.com/onflow/flow-cli/flowkit/output" | ||
| "github.com/onflow/flow-cli/internal/command" | ||
| "github.com/onflow/flow-cli/internal/scripts" | ||
| "github.com/onflow/flow-cli/internal/transactions" | ||
|
|
||
| "github.com/onflow/flow-cli/flowkit" | ||
|
|
||
| "github.com/spf13/cobra" | ||
| ) | ||
|
|
||
| type flixFlags struct { | ||
| ArgsJSON string `default:"" flag:"args-json" info:"arguments in JSON-Cadence format"` | ||
| BlockID string `default:"" flag:"block-id" info:"block ID to execute the script at"` | ||
| BlockHeight uint64 `default:"" flag:"block-height" info:"block height to execute the script at"` | ||
| Signer string `default:"" flag:"signer" info:"Account name from configuration used to sign the transaction as proposer, payer and suthorizer"` | ||
| Proposer string `default:"" flag:"proposer" info:"Account name from configuration used as proposer"` | ||
| Payer string `default:"" flag:"payer" info:"Account name from configuration used as payer"` | ||
| Authorizers []string `default:"" flag:"authorizer" info:"Name of a single or multiple comma-separated accounts used as authorizers from configuration"` | ||
| Include []string `default:"" flag:"include" info:"Fields to include in the output"` | ||
| Exclude []string `default:"" flag:"exclude" info:"Fields to exclude from the output (events)"` | ||
| GasLimit uint64 `default:"1000" flag:"gas-limit" info:"transaction gas limit"` | ||
| } | ||
|
|
||
| var flags = flixFlags{} | ||
|
|
||
| var FlixCommand = &command.Command{ | ||
| Cmd: &cobra.Command{ | ||
| Use: "flix <id | name | path>", | ||
| Short: "Execute FLIX template with a given id, name, or local filename", | ||
| Example: "flow flix multiply 2 3", | ||
| Args: cobra.ArbitraryArgs, | ||
| GroupID: "super", | ||
| }, | ||
| Flags: &flags, | ||
| RunS: execute, | ||
| } | ||
|
|
||
| type flixQueryTypes string | ||
|
|
||
| const ( | ||
| flixName flixQueryTypes = "name" | ||
| flixPath flixQueryTypes = "path" | ||
| flixId flixQueryTypes = "id" | ||
| ) | ||
|
|
||
| func isHex(str string) bool { | ||
| if len(str) != 64 { | ||
| return false | ||
| } | ||
| _, err := hex.DecodeString(str) | ||
| return err == nil | ||
| } | ||
|
|
||
| func isPath(path string) bool { | ||
| _, err := os.Stat(path) | ||
| return err == nil | ||
| } | ||
|
|
||
| func getType(s string) flixQueryTypes { | ||
| switch { | ||
| case isPath(s): | ||
| return flixPath | ||
| case isHex(s): | ||
| return flixId | ||
| default: | ||
| return flixName | ||
| } | ||
| } | ||
|
|
||
| func execute( | ||
| args []string, | ||
| _ command.GlobalFlags, | ||
| logger output.Logger, | ||
| flow flowkit.Services, | ||
| state *flowkit.State, | ||
| ) (result command.Result, err error) { | ||
| flixService := flixkit.NewFlixService(&flixkit.Config{}) | ||
| ctx := context.Background() | ||
| var template *flixkit.FlowInteractionTemplate | ||
| flixQuery := args[0] | ||
|
|
||
| switch getType(flixQuery) { | ||
| case flixId: | ||
| template, err = flixService.GetFlixByID(ctx, flixQuery) | ||
| if err != nil { | ||
| return nil, fmt.Errorf("could not find flix with id %s: %w", flixQuery, err) | ||
| } | ||
|
|
||
| case flixName: | ||
| template, err = flixService.GetFlix(ctx, flixQuery) | ||
| if err != nil { | ||
| return nil, fmt.Errorf("could not find flix with name %s: %w", flixQuery, err) | ||
| } | ||
|
|
||
| case flixPath: | ||
| file, err := os.ReadFile(flixQuery) | ||
| if err != nil { | ||
| return nil, fmt.Errorf("could not read flix file %s: %w", flixQuery, err) | ||
| } | ||
| template, err = flixkit.ParseFlix(string(file)) | ||
| if err != nil { | ||
| return nil, fmt.Errorf("could not parse flix from file %s: %w", flixQuery, err) | ||
| } | ||
|
|
||
| default: | ||
| return nil, fmt.Errorf("invalid flix query type: %s", flixQuery) | ||
| } | ||
|
|
||
| cadenceWithImportsReplaced, err := template.GetAndReplaceCadenceImports(flow.Network().Name) | ||
| if err != nil { | ||
| logger.Error("could not replace imports") | ||
| return nil, err | ||
| } | ||
|
|
||
| if template.IsScript() { | ||
| scriptsFlags := scripts.Flags{ | ||
| ArgsJSON: flags.ArgsJSON, | ||
| BlockID: flags.BlockID, | ||
| BlockHeight: flags.BlockHeight, | ||
| } | ||
| return scripts.SendScript([]byte(cadenceWithImportsReplaced), args[1:], "", flow, scriptsFlags) | ||
| } | ||
|
|
||
| transactionFlags := transactions.Flags{ | ||
| ArgsJSON: flags.ArgsJSON, | ||
| Signer: flags.Signer, | ||
| Proposer: flags.Proposer, | ||
| Payer: flags.Payer, | ||
| Authorizers: flags.Authorizers, | ||
| Include: flags.Include, | ||
| Exclude: flags.Exclude, | ||
| GasLimit: flags.GasLimit, | ||
| } | ||
| return transactions.SendTransaction([]byte(cadenceWithImportsReplaced), args[1:], "", flow, state, transactionFlags) | ||
| } |
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