// Copyright 2021 PingCAP, 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,
// See the License for the specific language governing permissions and
// limitations under the License.

package redo

import (
	"context"
	"os"

	"github.com/pingcap/ticdc/cmd/util"
	"github.com/pingcap/ticdc/pkg/errors"
	"github.com/pingcap/ticdc/pkg/logger"
	"github.com/spf13/cobra"
)

// options defines flags for the `redo` command.
type options struct {
	storage  string
	dir      string
	logLevel string
}

// newOptions creates new options for the `server` command.
func newOptions() *options {
	return &options{}
}

// addFlags receives a *cobra.Command reference and binds
// flags related to template printing to it.
func (o *options) addFlags(cmd *cobra.Command) {
	cmd.PersistentFlags().StringVar(&o.storage, "storage", "", "storage of redo log, specify the url where backup redo logs will store, eg, \"s3://bucket/path/prefix\"")
	cmd.PersistentFlags().StringVar(&o.dir, "tmp-dir", "", "temporary path used to download redo log with S3 backend")
	cmd.PersistentFlags().StringVar(&o.logLevel, "log-level", "info", "log level (etc: debug|info|warn|error)")
	// the possible error returned from MarkFlagRequired is `no such flag`
	cmd.MarkFlagRequired("storage") //nolint:errcheck
}

// NewCmdRedo creates the `redo` command.
func NewCmdRedo() *cobra.Command {
	o := newOptions()

	cmds := &cobra.Command{
		Use:   "redo",
		Short: "Manage redo logs of TiCDC cluster",

		PersistentPreRunE: func(cmd *cobra.Command, args []string) error {
			// Here we will initialize the logging configuration and set the current default context.
			err := logger.InitLogger(&logger.Config{Level: o.logLevel})
			if err != nil {
				cmd.Printf("init logger error %v\n", errors.Trace(err))
				os.Exit(1)
			}
			ctx, cancel := context.WithCancel(context.Background())
			cmd.SetContext(ctx)
			util.LogHTTPProxies()
			// A notify that complete immediately, it skips the second signal essentially.
			doneNotify := func() <-chan struct{} {
				done := make(chan struct{})
				close(done)
				return done
			}
			util.InitSignalHandling(doneNotify, cancel)
			return nil
		},
		Run: func(cmd *cobra.Command, args []string) {
		},
	}
	o.addFlags(cmds)

	// Add subcommands.
	cmds.AddCommand(newCmdApply(o))
	cmds.AddCommand(newCmdMeta(o))

	return cmds
}