package message

import (
	"context"
	"fmt"
	"time"

	"github.com/tidbcloud/AgentTeam/internal/coredb"
)

func CurrentDBTimestamp(ctx context.Context, queryer coredb.QueryRower) (time.Time, error) {
	if queryer == nil {
		return time.Time{}, fmt.Errorf("db queryer is required")
	}
	var now time.Time
	if err := queryer.QueryRow(ctx, `SELECT CURRENT_TIMESTAMP`).Scan(&now); err != nil {
		return time.Time{}, fmt.Errorf("load current db timestamp: %w", err)
	}
	return now.UTC(), nil
}