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"
	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")
	CtlReaderMethod          = strings.ToUpper("reader")
	GetTableShards           = strings.ToUpper("get-table-shards")
	MoTableStats             = strings.ToUpper("MoTableStats")
	WorkspaceThreshold       = strings.ToUpper("WorkspaceThreshold")
	TableExtra               = strings.ToUpper("table-extra")
	PrefetchOnSubscribed     = strings.ToUpper("prefetch-on-subscribed")
	GCCatalogCacheMethod     = strings.ToUpper("GCCatalogCache")
)

var MoCtlTNCmdSender = func(ctx context.Context, proc *process.Process, requests []txn.CNOpRequest) ([]txn.CNOpResponse, error) {
	txnOp := proc.GetTxnOperator()
	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
}