(ctx context.Context, arg database.UpdateChatHeartbeatsParams)
| 6634 | } |
| 6635 | |
| 6636 | func (q *querier) UpdateChatHeartbeats(ctx context.Context, arg database.UpdateChatHeartbeatsParams) ([]uuid.UUID, error) { |
| 6637 | // The batch heartbeat is a system-level operation filtered by |
| 6638 | // worker_id. Authorization is enforced by the AsChatd context |
| 6639 | // at the call site rather than per-row, because checking each |
| 6640 | // row individually would defeat the purpose of batching. |
| 6641 | if err := q.authorizeContext(ctx, policy.ActionUpdate, rbac.ResourceChat); err != nil { |
| 6642 | return nil, err |
| 6643 | } |
| 6644 | return q.db.UpdateChatHeartbeats(ctx, arg) |
| 6645 | } |
| 6646 | |
| 6647 | func (q *querier) UpdateChatLabelsByID(ctx context.Context, arg database.UpdateChatLabelsByIDParams) (database.Chat, error) { |
| 6648 | chat, err := q.db.GetChatByID(ctx, arg.ID) |
nothing calls this directly
no test coverage detected