[NEW] selfupdate
This commit is contained in:
86
cmd/selfupdate.go
Normal file
86
cmd/selfupdate.go
Normal file
@@ -0,0 +1,86 @@
|
||||
/*
|
||||
Copyright © 2022 NAME HERE <EMAIL ADDRESS>
|
||||
*/
|
||||
package cmd
|
||||
|
||||
import (
|
||||
"context"
|
||||
"dummy/util"
|
||||
"fmt"
|
||||
"runtime"
|
||||
|
||||
"github.com/minio/minio-go/v7"
|
||||
"github.com/minio/selfupdate"
|
||||
"github.com/spf13/cobra"
|
||||
)
|
||||
|
||||
var (
|
||||
Ver string
|
||||
List bool
|
||||
)
|
||||
|
||||
// selfupdateCmd represents the selfupdate command
|
||||
var selfupdateCmd = &cobra.Command{
|
||||
Use: "selfupdate",
|
||||
Short: "Updates to latest or specific version",
|
||||
Long: `Updates to latest or specific version of dummy.
|
||||
|
||||
To update to latest version use:
|
||||
dummy selfupdate
|
||||
|
||||
To update to version 0.0.3 use:
|
||||
dummy selfupdate --version=0.0.3`,
|
||||
RunE: func(cmd *cobra.Command, args []string) error {
|
||||
|
||||
// Initialize minio client
|
||||
isps3 := util.S3{
|
||||
Endpoint: "isp-dev.paasdev.sk:9000",
|
||||
AccessKeyID: "LHHV6WR7EEMRS1RLX6BW",
|
||||
SecretAccessKey: "m8PvnzpRB4ORYwcJtzeJpboFUIBAfbZ3wwh3Bkcp",
|
||||
UseSSL: true,
|
||||
}
|
||||
err := isps3.Init()
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
if List {
|
||||
updateCol := isps3.Client.ListObjects(context.Background(), "dummy", minio.ListObjectsOptions{
|
||||
Prefix: fmt.Sprintf("%s/dummy", runtime.GOOS),
|
||||
})
|
||||
|
||||
fmt.Println("Available updates:")
|
||||
for object := range updateCol {
|
||||
if object.Err != nil {
|
||||
return err
|
||||
}
|
||||
fmt.Println(object.Key)
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
path := fmt.Sprintf("%s/dummy-%s", runtime.GOOS, Ver)
|
||||
fmt.Println("Updating dummy to: ", path)
|
||||
// Read the update
|
||||
update, err := isps3.Client.GetObject(context.Background(), "dummy", path, minio.GetObjectOptions{})
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
// Do update
|
||||
err = selfupdate.Apply(update, selfupdate.Options{})
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
fmt.Println("Update finished")
|
||||
return nil
|
||||
},
|
||||
}
|
||||
|
||||
func init() {
|
||||
rootCmd.AddCommand(selfupdateCmd)
|
||||
|
||||
selfupdateCmd.Flags().StringVar(&Ver, "version", "latest", "Version to install (optional)")
|
||||
selfupdateCmd.Flags().BoolVar(&List, "list", false, "List available versions (optional)")
|
||||
|
||||
selfupdateCmd.MarkFlagsMutuallyExclusive("version", "list")
|
||||
}
|
Reference in New Issue
Block a user