(ctx context.Context, arg time.Time)
| 6399 | } |
| 6400 | |
| 6401 | func (q *querier) SelectUsageEventsForPublishing(ctx context.Context, arg time.Time) ([]database.UsageEvent, error) { |
| 6402 | // ActionUpdate because we're updating the publish_started_at column. |
| 6403 | if err := q.authorizeContext(ctx, policy.ActionUpdate, rbac.ResourceUsageEvent); err != nil { |
| 6404 | return nil, err |
| 6405 | } |
| 6406 | return q.db.SelectUsageEventsForPublishing(ctx, arg) |
| 6407 | } |
| 6408 | |
| 6409 | func (q *querier) SoftDeleteChatMessageByID(ctx context.Context, id int64) error { |
| 6410 | msg, err := q.db.GetChatMessageByID(ctx, id) |
nothing calls this directly
no test coverage detected