ctl

var (
	PingMethod             = "PING"
	FlushMethod            = "FLUSH"
	TaskMethod             = "TASK"
	UseSnapshotMethod      = "USESNAPSHOT"
	GetSnapshotMethod      = "GETSNAPSHOT"
	CheckpointMethod       = "CHECKPOINT"
	GlobalCheckpointMethod = "GLOBALCHECKPOINT"
	ForceGCMethod          = "FORCEGC"
	InspectMethod          = "INSPECT"
	LabelMethod            = "LABEL"
	WorkStateMethod        = "WORKSTATE"
	SyncCommitMethod       = "SYNCCOMMIT"
	AddFaultPointMethod    = "ADDFAULTPOINT"
	BackupMethod           = "BACKUP"
	TraceSpanMethod        = "TRACESPAN"
	CoreDumpMethod         = "COREDUMP"
	InterceptCommitMethod  = "INTERCEPTCOMMIT"
	MergeObjectsMethod     = "MERGEOBJECTS"
	DisableCKPMethod       = "DISABLECKP"
	DiskCleanerMethod      = "DISKCLEANER"

	GetProtocolVersionMethod = "GETPROTOCOLVERSION"
	SetProtocolVersionMethod = "SETPROTOCOLVERSION"

	RemoveRemoteLockTable = strings.ToUpper("RemoveRemoteLockTable")
	GetLatestBind         = strings.ToUpper("GetLatestBind")
	UnsubscribeTable      = "UNSUBSCRIBE_TABLE"

	HandleTxnTrace = strings.ToUpper("txn-trace")

	ReloadAutoIncrementCache = strings.ToUpper("reload-auto-increment-cache")
)

var MoCtlTNCmdSender = func(ctx context.Context, proc *process.Process, requests []txn.CNOpRequest) ([]txn.CNOpResponse, error) {
	txnOp := proc.TxnOperator
	if txnOp == nil {
		return nil, moerr.NewInternalError(ctx, "ctl: txn operator is nil")
	}

	debugRequests := make([]txn.TxnRequest, 0, len(requests))
	for _, req := range requests {
		tq := txn.NewTxnRequest(&req)
		tq.Method = txn.TxnMethod_DEBUG
		debugRequests = append(debugRequests, tq)
	}
	result, err := txnOp.Debug(ctx, debugRequests)
	if err != nil {
		return nil, err
	}
	defer result.Release()

	responses := make([]txn.CNOpResponse, 0, len(requests))
	for _, resp := range result.Responses {
		responses = append(responses, *resp.CNOpResponse)
	}
	return responses, nil
}