cmd

var (
	// Host ss-proxy host
	Host string
	// Port ss-proxy port
	Port uint16
	// Username ss-proxy username
	Username string
	// Password ss-proxy password
	Password string
	// AgentPort agent-server port
	AgentPort uint16
	// BackupPath openGauss data backup path
	BackupPath string
	// BackupModeStr openGauss data backup mode string (FULL or PTRACK)
	BackupModeStr string
	// BackupMode openGauss data backup mode (FULL or PTRACK)
	BackupMode model.DBBackupMode
	// ThreadsNum openGauss data backup task thread num
	ThreadsNum uint8
	// CSN openGauss data backup commit sequence number
	CSN string
	// RecordID openGauss data backup record id
	RecordID string
)

var BackupCmd = &cobra.Command{
	Use:   "backup",
	Short: "Backup a database cluster",
	Run: func(cmd *cobra.Command, args []string) {
		cmd.Flags().VisitAll(func(flag *pflag.Flag) {
			fmt.Printf("Flag: %s Value: %s\n", flag.Name, flag.Value)
		})

		switch BackupModeStr {
		case "FULL", "full":
			BackupMode = model.DBBackModeFull
		case "PTRACK", "ptrack":
			BackupMode = model.DBBackModePTrack
		}
		if BackupMode == model.DBBackModePTrack {
			logging.Warn("Please make sure all openGauss nodes have been set correct configuration about ptrack. You can refer to https://support.huaweicloud.com/intl/zh-cn/devg-opengauss/opengauss_devg_1362.html for more details.")
		}

		logging.Info(fmt.Sprintf("Default backup path: %s", pkg.DefaultRootDir()))

		if err := backup(); err != nil {
			logging.Error(err.Error())
		}
	},
}

var DeleteCmd = &cobra.Command{
	Use:   "delete",
	Short: "Delete a backup record",
	Run: func(cmd *cobra.Command, args []string) {
		cmd.Flags().VisitAll(func(flag *pflag.Flag) {
			fmt.Printf("Flag: %s Value: %s\n", flag.Name, flag.Value)
		})

		if CSN == "" && RecordID == "" {
			logging.Error("Please specify csn or record id")
			return
		}

		if CSN != "" && RecordID != "" {
			logging.Error("Please specify only one of csn and record id")
			return
		}

		if err := deleteRecord(); err != nil {
			logging.Error(err.Error())
		}
	},
}

var RestoreCmd = &cobra.Command{
	Use:   "restore",
	Short: "Restore a database cluster ",
	Run: func(cmd *cobra.Command, args []string) {
		cmd.Flags().VisitAll(func(flag *pflag.Flag) {
			fmt.Printf("Flag: %s Value: %s\n", flag.Name, flag.Value)
		})

		if CSN == "" && RecordID == "" {
			logging.Error("Please specify csn or record id")
			return
		}

		if CSN != "" && RecordID != "" {
			logging.Error("Please specify only one of csn and record id")
			return
		}

		if err := restore(); err != nil {
			logging.Error(err.Error())
		}
	},
}

var RootCmd = &cobra.Command{
	Use:   "gs_pitr",
	Short: "PITR tools for openGauss",

	CompletionOptions: cobra.CompletionOptions{
		DisableDefaultCmd: true,
		HiddenDefaultCmd:  true,
	},
}

var ShowCmd = &cobra.Command{
	Use:   "show",
	Short: "Show backup history",
	Run: func(cmd *cobra.Command, args []string) {
		if CSN != "" && RecordID != "" {
			logging.Error("Please specify only one of csn and record id")
			return
		}

		if err := show(); err != nil {
			logging.Error(err.Error())
		}
	},
}