dbauthz

mtojek · mtojek · commit 73bb5bdf0325 · 2024-09-11T09:19:24.000+02:00
diff --git a/coderd/database/dbauthz/dbauthz.go b/coderd/database/dbauthz/dbauthz.go
@@ -1145,7 +1145,10 @@ func (q *querier) DeleteOldProvisionerDaemons(ctx context.Context) error {
 }
 
 func (q *querier) DeleteOldReportGeneratorLogs(ctx context.Context, frequencyDays int32) error {
-	panic("not implemented")
+	if err := q.authorizeContext(ctx, policy.ActionDelete, rbac.ResourceSystem); err != nil {
+		return err
+	}
+	return q.db.DeleteOldReportGeneratorLogs(ctx, frequencyDays)
 }
 
 func (q *querier) DeleteOldWorkspaceAgentLogs(ctx context.Context, threshold time.Time) error {
@@ -1442,7 +1445,10 @@ func (q *querier) GetExternalAuthLinksByUserID(ctx context.Context, userID uuid.
 }
 
 func (q *querier) GetFailedWorkspaceBuildsByTemplateID(ctx context.Context, arg database.GetFailedWorkspaceBuildsByTemplateIDParams) ([]database.GetFailedWorkspaceBuildsByTemplateIDRow, error) {
-	panic("not implemented")
+	if err := q.authorizeContext(ctx, policy.ActionRead, rbac.ResourceSystem); err != nil {
+		return nil, err
+	}
+	return q.db.GetFailedWorkspaceBuildsByTemplateID(ctx, arg)
 }
 
 func (q *querier) GetFileByHashAndCreator(ctx context.Context, arg database.GetFileByHashAndCreatorParams) (database.File, error) {
@@ -1872,7 +1878,10 @@ func (q *querier) GetReplicasUpdatedAfter(ctx context.Context, updatedAt time.Ti
 }
 
 func (q *querier) GetReportGeneratorLogByUserAndTemplate(ctx context.Context, arg database.GetReportGeneratorLogByUserAndTemplateParams) (database.ReportGeneratorLog, error) {
-	panic("not implemented")
+	if err := q.authorizeContext(ctx, policy.ActionRead, rbac.ResourceSystem); err != nil {
+		return database.ReportGeneratorLog{}, err
+	}
+	return q.db.GetReportGeneratorLogByUserAndTemplate(ctx, arg)
 }
 
 func (q *querier) GetRuntimeConfig(ctx context.Context, key string) (string, error) {
@@ -2486,7 +2495,10 @@ func (q *querier) GetWorkspaceBuildParameters(ctx context.Context, workspaceBuil
 }
 
 func (q *querier) GetWorkspaceBuildStatsByTemplates(ctx context.Context, since time.Time) ([]database.GetWorkspaceBuildStatsByTemplatesRow, error) {
-	panic("not implemented")
+	if err := q.authorizeContext(ctx, policy.ActionRead, rbac.ResourceSystem); err != nil {
+		return nil, err
+	}
+	return q.db.GetWorkspaceBuildStatsByTemplates(ctx, since)
 }
 
 func (q *querier) GetWorkspaceBuildsByWorkspaceID(ctx context.Context, arg database.GetWorkspaceBuildsByWorkspaceIDParams) ([]database.WorkspaceBuild, error) {
@@ -3937,7 +3949,10 @@ func (q *querier) UpsertProvisionerDaemon(ctx context.Context, arg database.Upse
 }
 
 func (q *querier) UpsertReportGeneratorLog(ctx context.Context, arg database.UpsertReportGeneratorLogParams) error {
-	panic("not implemented")
+	if err := q.authorizeContext(ctx, policy.ActionCreate, rbac.ResourceSystem); err != nil {
+		return err
+	}
+	return q.db.UpsertReportGeneratorLog(ctx, arg)
 }
 
 func (q *querier) UpsertRuntimeConfig(ctx context.Context, arg database.UpsertRuntimeConfigParams) error {

Original file line number	Diff line number	Diff line change
`@@ -1145,7 +1145,10 @@ func (q *querier) DeleteOldProvisionerDaemons(ctx context.Context) error {`
`1145`	`1145`	`}`
`1146`	`1146`
`1147`	`1147`	`func (q *querier) DeleteOldReportGeneratorLogs(ctx context.Context, frequencyDays int32) error {`
`1148`		`- panic("not implemented")`
	`1148`	`+ if err := q.authorizeContext(ctx, policy.ActionDelete, rbac.ResourceSystem); err != nil {`
	`1149`	`+ return err`
	`1150`	`+ }`
	`1151`	`+ return q.db.DeleteOldReportGeneratorLogs(ctx, frequencyDays)`
`1149`	`1152`	`}`
`1150`	`1153`
`1151`	`1154`	`func (q *querier) DeleteOldWorkspaceAgentLogs(ctx context.Context, threshold time.Time) error {`
`@@ -1442,7 +1445,10 @@ func (q *querier) GetExternalAuthLinksByUserID(ctx context.Context, userID uuid.`
`1442`	`1445`	`}`
`1443`	`1446`
`1444`	`1447`	`func (q *querier) GetFailedWorkspaceBuildsByTemplateID(ctx context.Context, arg database.GetFailedWorkspaceBuildsByTemplateIDParams) ([]database.GetFailedWorkspaceBuildsByTemplateIDRow, error) {`
`1445`		`- panic("not implemented")`
	`1448`	`+ if err := q.authorizeContext(ctx, policy.ActionRead, rbac.ResourceSystem); err != nil {`
	`1449`	`+ return nil, err`
	`1450`	`+ }`
	`1451`	`+ return q.db.GetFailedWorkspaceBuildsByTemplateID(ctx, arg)`
`1446`	`1452`	`}`
`1447`	`1453`
`1448`	`1454`	`func (q *querier) GetFileByHashAndCreator(ctx context.Context, arg database.GetFileByHashAndCreatorParams) (database.File, error) {`
`@@ -1872,7 +1878,10 @@ func (q *querier) GetReplicasUpdatedAfter(ctx context.Context, updatedAt time.Ti`
`1872`	`1878`	`}`
`1873`	`1879`
`1874`	`1880`	`func (q *querier) GetReportGeneratorLogByUserAndTemplate(ctx context.Context, arg database.GetReportGeneratorLogByUserAndTemplateParams) (database.ReportGeneratorLog, error) {`
`1875`		`- panic("not implemented")`
	`1881`	`+ if err := q.authorizeContext(ctx, policy.ActionRead, rbac.ResourceSystem); err != nil {`
	`1882`	`+ return database.ReportGeneratorLog{}, err`
	`1883`	`+ }`
	`1884`	`+ return q.db.GetReportGeneratorLogByUserAndTemplate(ctx, arg)`
`1876`	`1885`	`}`
`1877`	`1886`
`1878`	`1887`	`func (q *querier) GetRuntimeConfig(ctx context.Context, key string) (string, error) {`
`@@ -2486,7 +2495,10 @@ func (q *querier) GetWorkspaceBuildParameters(ctx context.Context, workspaceBuil`
`2486`	`2495`	`}`
`2487`	`2496`
`2488`	`2497`	`func (q *querier) GetWorkspaceBuildStatsByTemplates(ctx context.Context, since time.Time) ([]database.GetWorkspaceBuildStatsByTemplatesRow, error) {`
`2489`		`- panic("not implemented")`
	`2498`	`+ if err := q.authorizeContext(ctx, policy.ActionRead, rbac.ResourceSystem); err != nil {`
	`2499`	`+ return nil, err`
	`2500`	`+ }`
	`2501`	`+ return q.db.GetWorkspaceBuildStatsByTemplates(ctx, since)`
`2490`	`2502`	`}`
`2491`	`2503`
`2492`	`2504`	`func (q *querier) GetWorkspaceBuildsByWorkspaceID(ctx context.Context, arg database.GetWorkspaceBuildsByWorkspaceIDParams) ([]database.WorkspaceBuild, error) {`
`@@ -3937,7 +3949,10 @@ func (q *querier) UpsertProvisionerDaemon(ctx context.Context, arg database.Upse`
`3937`	`3949`	`}`
`3938`	`3950`
`3939`	`3951`	`func (q *querier) UpsertReportGeneratorLog(ctx context.Context, arg database.UpsertReportGeneratorLogParams) error {`
`3940`		`- panic("not implemented")`
	`3952`	`+ if err := q.authorizeContext(ctx, policy.ActionCreate, rbac.ResourceSystem); err != nil {`
	`3953`	`+ return err`
	`3954`	`+ }`
	`3955`	`+ return q.db.UpsertReportGeneratorLog(ctx, arg)`
`3941`	`3956`	`}`
`3942`	`3957`
`3943`	`3958`	`func (q *querier) UpsertRuntimeConfig(ctx context.Context, arg database.UpsertRuntimeConfigParams) error {`