Method fetch

coderd/notifications/notifier.go:208–222

fetch retrieves messages from the queue by "acquiring a lease" whereby this notifier is the exclusive handler of these messages until they are dispatched - or until the lease expires (in exceptional cases).

(ctx context.Context)

// fetch retrieves messages from the queue by "acquiring a lease" whereby this notifier is the exclusive handler of these
// messages until they are dispatched - or until the lease expires (in exceptional cases).
func (n *notifier) fetch(ctx context.Context) ([]database.AcquireNotificationMessagesRow, error) {
	msgs, err := n.store.AcquireNotificationMessages(ctx, database.AcquireNotificationMessagesParams{
		// #nosec G115 - Safe conversion for lease count which is expected to be within int32 range
		Count: int32(n.cfg.LeaseCount),
		// #nosec G115 - Safe conversion for max send attempts which is expected to be within int32 range
		MaxAttemptCount: int32(n.cfg.MaxSendAttempts),
		NotifierID:      n.id,
		LeaseSeconds:    int32(n.cfg.LeasePeriod.Value().Seconds()),
	})
	if err != nil {
		return nil, xerrors.Errorf("acquire messages: %w", err)
	}

	return msgs, nil
}

// prepare has two roles:
// 1. render the title & body templates