(ctx context.Context, t *testing.T, db database.Store, agent database.WorkspaceAgent, agentLastConnectedAt *time.Time, output string)
| 758 | } |
| 759 | |
| 760 | func mustCreateAgentLogs(ctx context.Context, t *testing.T, db database.Store, agent database.WorkspaceAgent, agentLastConnectedAt *time.Time, output string) { |
| 761 | t.Helper() |
| 762 | if agentLastConnectedAt != nil { |
| 763 | require.NoError(t, db.UpdateWorkspaceAgentConnectionByID(ctx, database.UpdateWorkspaceAgentConnectionByIDParams{ |
| 764 | ID: agent.ID, |
| 765 | LastConnectedAt: sql.NullTime{Time: *agentLastConnectedAt, Valid: true}, |
| 766 | })) |
| 767 | } |
| 768 | _, err := db.InsertWorkspaceAgentLogs(ctx, database.InsertWorkspaceAgentLogsParams{ |
| 769 | AgentID: agent.ID, |
| 770 | CreatedAt: agent.CreatedAt, |
| 771 | Output: []string{output}, |
| 772 | Level: []database.LogLevel{database.LogLevelDebug}, |
| 773 | }) |
| 774 | require.NoError(t, err) |
| 775 | // Make sure that agent logs have been collected. |
| 776 | agentLogs, err := db.GetWorkspaceAgentLogsAfter(ctx, database.GetWorkspaceAgentLogsAfterParams{ |
| 777 | AgentID: agent.ID, |
| 778 | }) |
| 779 | require.NoError(t, err) |
| 780 | require.NotEmpty(t, agentLogs, "agent logs must be present") |
| 781 | } |
| 782 | |
| 783 | func TestDeleteOldWorkspaceAgentLogsRetention(t *testing.T) { |
| 784 | t.Parallel() |
no test coverage detected