(t *testing.T)
| 244 | } |
| 245 | |
| 246 | func TestUpsertBoundaryUsageStats_Insert(t *testing.T) { |
| 247 | t.Parallel() |
| 248 | |
| 249 | db, _ := dbtestutil.NewDB(t) |
| 250 | ctx := dbauthz.AsBoundaryUsageTracker(context.Background()) |
| 251 | |
| 252 | replicaID := uuid.New() |
| 253 | |
| 254 | // Set different values for delta vs cumulative to verify INSERT uses delta. |
| 255 | newPeriod, err := db.UpsertBoundaryUsageStats(ctx, database.UpsertBoundaryUsageStatsParams{ |
| 256 | ReplicaID: replicaID, |
| 257 | UniqueWorkspacesDelta: 5, |
| 258 | UniqueUsersDelta: 3, |
| 259 | UniqueWorkspacesCount: 999, // should be ignored on INSERT |
| 260 | UniqueUsersCount: 999, // should be ignored on INSERT |
| 261 | AllowedRequests: 100, |
| 262 | DeniedRequests: 10, |
| 263 | }) |
| 264 | require.NoError(t, err) |
| 265 | require.True(t, newPeriod, "should return true for insert") |
| 266 | |
| 267 | // Verify INSERT used the delta values, not cumulative. |
| 268 | summary, err := db.GetAndResetBoundaryUsageSummary(ctx, 60000) |
| 269 | require.NoError(t, err) |
| 270 | require.Equal(t, int64(5), summary.UniqueWorkspaces) |
| 271 | require.Equal(t, int64(3), summary.UniqueUsers) |
| 272 | } |
| 273 | |
| 274 | func TestUpsertBoundaryUsageStats_Update(t *testing.T) { |
| 275 | t.Parallel() |
nothing calls this directly
no test coverage detected