(ctx context.Context, chatID uuid.UUID)
| 6335 | } |
| 6336 | |
| 6337 | func (q *querier) PopNextQueuedMessage(ctx context.Context, chatID uuid.UUID) (database.ChatQueuedMessage, error) { |
| 6338 | chat, err := q.db.GetChatByID(ctx, chatID) |
| 6339 | if err != nil { |
| 6340 | return database.ChatQueuedMessage{}, err |
| 6341 | } |
| 6342 | if err := q.authorizeContext(ctx, policy.ActionUpdate, chat); err != nil { |
| 6343 | return database.ChatQueuedMessage{}, err |
| 6344 | } |
| 6345 | return q.db.PopNextQueuedMessage(ctx, chatID) |
| 6346 | } |
| 6347 | |
| 6348 | func (q *querier) ReduceWorkspaceAgentShareLevelToAuthenticatedByTemplate(ctx context.Context, templateID uuid.UUID) error { |
| 6349 | template, err := q.db.GetTemplateByID(ctx, templateID) |
nothing calls this directly
no test coverage detected