usage_log_repo_group_summary_test.go 1.2 KB

123456789101112131415161718192021222324252627282930313233
  1. //go:build unit
  2. package repository
  3. import (
  4. "context"
  5. "testing"
  6. "time"
  7. "github.com/DATA-DOG/go-sqlmock"
  8. "github.com/stretchr/testify/require"
  9. )
  10. func TestUsageLogRepositoryGetAllGroupUsageSummaryUsesRollupTail(t *testing.T) {
  11. db, mock := newSQLMock(t)
  12. repo := newUsageLogRepositoryWithSQL(nil, db)
  13. useGroupUsageRepositoryTestTimezone(t, "America/New_York")
  14. todayStart := time.Date(2026, 3, 9, 4, 0, 0, 0, time.UTC)
  15. yesterdayStart := time.Date(2026, 3, 8, 5, 0, 0, 0, time.UTC)
  16. mock.ExpectQuery(`(?s)usage_group_rollup_state.*usage_group_daily_rollups.*created_at >= state\.tail_start`).
  17. WithArgs(todayStart, yesterdayStart, "America/New_York", "2026-03-09", "2026-03-08").
  18. WillReturnRows(sqlmock.NewRows([]string{"group_id", "total_cost", "today_cost", "yesterday_cost"}).
  19. AddRow(int64(7), 12.5, 1.25, 2.5))
  20. result, err := repo.GetAllGroupUsageSummary(context.Background(), todayStart)
  21. require.NoError(t, err)
  22. require.Equal(t, int64(7), result[0].GroupID)
  23. require.InDelta(t, 12.5, result[0].TotalCost, 0.0000001)
  24. require.InDelta(t, 1.25, result[0].TodayCost, 0.0000001)
  25. require.InDelta(t, 2.5, result[0].YesterdayCost, 0.0000001)
  26. require.NoError(t, mock.ExpectationsWereMet())
  27. }