(ctx context.Context, arg database.AcquireChatsParams)
| 1577 | } |
| 1578 | |
| 1579 | func (q *querier) AcquireChats(ctx context.Context, arg database.AcquireChatsParams) ([]database.Chat, error) { |
| 1580 | // AcquireChats is a system-level operation used by the chat processor. |
| 1581 | // Authorization is done at the system level, not per-user. |
| 1582 | if err := q.authorizeContext(ctx, policy.ActionUpdate, rbac.ResourceChat); err != nil { |
| 1583 | return nil, err |
| 1584 | } |
| 1585 | return q.db.AcquireChats(ctx, arg) |
| 1586 | } |
| 1587 | |
| 1588 | func (q *querier) AcquireLock(ctx context.Context, id int64) error { |
| 1589 | return q.db.AcquireLock(ctx, id) |
nothing calls this directly
no test coverage detected