mirror of
https://github.com/ultravioletrs/cocos.git
synced 2026-06-22 20:00:18 +00:00
d5badba547
CI / lint (push) Has been cancelled
CI / test (agent) (push) Has been cancelled
CI / test (cli) (push) Has been cancelled
CI / test (cmd) (push) Has been cancelled
CI / test (internal) (push) Has been cancelled
CI / test (manager, true) (push) Has been cancelled
CI / test (pkg) (push) Has been cancelled
CI / upload-coverage (push) Has been cancelled
* feat: Implement per-resource KBS configuration, allowing algorithms and datasets to specify individual KBS URLs. Signed-off-by: Sammy Oina <sammyoina@gmail.com> * refactor: Encapsulate CLI error handling and CVM certificate paths within the CLI struct, and add algorithm type to agent's algorithm structure. Signed-off-by: Sammy Oina <sammyoina@gmail.com> * style: Remove blank lines and fix indentation in CLI commands. Signed-off-by: Sammy Oina <sammyoina@gmail.com> * refactor: Update downloadAndDecryptGenericResource to accept KBS URL as a parameter and adjust related tests Signed-off-by: Sammy Oina <sammyoina@gmail.com> * refactor: group CLI configuration into structured types and simplify skopeo decryption key handling Signed-off-by: Sammy Oina <sammyoina@gmail.com> --------- Signed-off-by: Sammy Oina <sammyoina@gmail.com>
85 lines
2.2 KiB
Go
85 lines
2.2 KiB
Go
// Copyright (c) Ultraviolet
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
package cli
|
|
|
|
import (
|
|
"encoding/pem"
|
|
"os"
|
|
"path/filepath"
|
|
|
|
"github.com/fatih/color"
|
|
"github.com/spf13/cobra"
|
|
)
|
|
|
|
const resultFilename = "results.zip"
|
|
|
|
func (cli *CLI) NewResultsCmd() *cobra.Command {
|
|
var outputDir string
|
|
var filename string
|
|
|
|
cmd := &cobra.Command{
|
|
Use: "result <private_key_file_path>",
|
|
Short: "Retrieve computation result file",
|
|
Example: "result <private_key_file_path> --filename my_results.zip --output-dir /path/to/directory",
|
|
Args: cobra.ExactArgs(1),
|
|
Run: func(cmd *cobra.Command, args []string) {
|
|
if cli.connectErr != nil {
|
|
cli.printError(cmd, "Failed to connect to agent: %v ❌ ", cli.connectErr)
|
|
return
|
|
}
|
|
|
|
cmd.Println("⏳ Retrieving computation result file")
|
|
|
|
privKeyFile, err := os.ReadFile(args[0])
|
|
if err != nil {
|
|
cli.printError(cmd, "Error reading private key file: %v ❌ ", err)
|
|
return
|
|
}
|
|
|
|
var outputPath string
|
|
if outputDir != "" {
|
|
if err := os.MkdirAll(outputDir, 0o755); err != nil {
|
|
cli.printError(cmd, "Error creating output directory: %v ❌ ", err)
|
|
return
|
|
}
|
|
outputPath = filepath.Join(outputDir, filename)
|
|
} else {
|
|
outputPath = filename
|
|
}
|
|
|
|
absPath, err := filepath.Abs(outputPath)
|
|
if err != nil {
|
|
absPath = outputPath
|
|
}
|
|
|
|
pemBlock, _ := pem.Decode(privKeyFile)
|
|
|
|
privKey, err := decodeKey(pemBlock)
|
|
if err != nil {
|
|
cli.printError(cmd, "Error decoding private key: %v ❌ ", err)
|
|
return
|
|
}
|
|
|
|
resultFile, err := os.Create(outputPath)
|
|
if err != nil {
|
|
cli.printError(cmd, "Error creating result file: %v ❌ ", err)
|
|
return
|
|
}
|
|
defer resultFile.Close()
|
|
|
|
if err = cli.agentSDK.Result(cmd.Context(), privKey, resultFile); err != nil {
|
|
cli.printError(cmd, "Error retrieving computation result: %v ❌ ", err)
|
|
return
|
|
}
|
|
|
|
cmd.Println(color.New(color.FgGreen).Sprintf("Computation result retrieved and saved successfully! ✔"))
|
|
cmd.Println(color.New(color.FgCyan).Sprintf("📁 Location: %s", absPath))
|
|
},
|
|
}
|
|
|
|
cmd.Flags().StringVarP(&outputDir, "output-dir", "o", "", "Directory where the result file will be saved")
|
|
cmd.Flags().StringVarP(&filename, "filename", "f", resultFilename, "Name of the result file")
|
|
|
|
return cmd
|
|
}
|