package backup

import (
	"context"

	"github.com/pingcap/errors"
	"github.com/tidbcloud/dataflow-service/app/repo/entity"
	"github.com/tidbcloud/dataflow-service/internal/db"
	"github.com/tidbcloud/dataflow-service/internal/db/dbutil"
)

type PiTRTimeRange struct {
	LogBackup   entity.LogBackup
	LogBackupID entity.ID
	BucketID    entity.ID
	StartTS     int64
	EndTS       int64
}

func (m Model) GetLogBackupsByCluster(ctx context.Context, clusterID entity.ID) ([]entity.LogBackup, error) {
	dbIns := db.GetDBWithContext(ctx)
	logBackups, err := dbutil.GetLogBackupsByCluster(dbIns, clusterID)
	if err != nil {
		return nil, errors.Annotate(err, "get log backups")
	}
	return logBackups, nil
}