(t *testing.T)
| 597 | } |
| 598 | |
| 599 | func TestTelemetryItem(t *testing.T) { |
| 600 | t.Parallel() |
| 601 | ctx := testutil.Context(t, testutil.WaitMedium) |
| 602 | db, _ := dbtestutil.NewDB(t) |
| 603 | key := testutil.GetRandomName(t) |
| 604 | value := time.Now().Format(time.RFC3339) |
| 605 | |
| 606 | err := db.InsertTelemetryItemIfNotExists(ctx, database.InsertTelemetryItemIfNotExistsParams{ |
| 607 | Key: key, |
| 608 | Value: value, |
| 609 | }) |
| 610 | require.NoError(t, err) |
| 611 | |
| 612 | item, err := db.GetTelemetryItem(ctx, key) |
| 613 | require.NoError(t, err) |
| 614 | require.Equal(t, item.Key, key) |
| 615 | require.Equal(t, item.Value, value) |
| 616 | |
| 617 | // Inserting a new value should not update the existing value |
| 618 | err = db.InsertTelemetryItemIfNotExists(ctx, database.InsertTelemetryItemIfNotExistsParams{ |
| 619 | Key: key, |
| 620 | Value: "new_value", |
| 621 | }) |
| 622 | require.NoError(t, err) |
| 623 | |
| 624 | item, err = db.GetTelemetryItem(ctx, key) |
| 625 | require.NoError(t, err) |
| 626 | require.Equal(t, item.Value, value) |
| 627 | |
| 628 | // Upserting a new value should update the existing value |
| 629 | err = db.UpsertTelemetryItem(ctx, database.UpsertTelemetryItemParams{ |
| 630 | Key: key, |
| 631 | Value: "new_value", |
| 632 | }) |
| 633 | require.NoError(t, err) |
| 634 | |
| 635 | item, err = db.GetTelemetryItem(ctx, key) |
| 636 | require.NoError(t, err) |
| 637 | require.Equal(t, item.Value, "new_value") |
| 638 | } |
| 639 | |
| 640 | func TestPrebuiltWorkspacesTelemetry(t *testing.T) { |
| 641 | t.Parallel() |
nothing calls this directly
no test coverage detected