Function NewStoreEnqueuer

coderd/notifications/enqueuer.go:52–72

NewStoreEnqueuer creates an Enqueuer implementation which can persist notification messages in the store.

(cfg codersdk.NotificationsConfig, store Store, helpers template.FuncMap, log slog.Logger, clock quartz.Clock)

// NewStoreEnqueuer creates an Enqueuer implementation which can persist notification messages in the store.
func NewStoreEnqueuer(cfg codersdk.NotificationsConfig, store Store, helpers template.FuncMap, log slog.Logger, clock quartz.Clock) (*StoreEnqueuer, error) {
	var method database.NotificationMethod
	// TODO(DanielleMaywood):
	// Currently we do not want to allow setting `inbox` as the default notification method.
	// As of 2025-03-25, setting this to `inbox` would cause a crash on the deployment
	// notification settings page. Until we make a future decision on this we want to disallow
	// setting it.
	if err := method.Scan(cfg.Method.String()); err != nil || method == database.NotificationMethodInbox {
		return nil, InvalidDefaultNotificationMethodError{Method: cfg.Method.String()}
	}

	return &StoreEnqueuer{
		store:          store,
		log:            log,
		defaultMethod:  method,
		defaultEnabled: cfg.Enabled(),
		inboxEnabled:   cfg.Inbox.Enabled.Value(),
		helpers:        helpers,
		clock:          clock,
	}, nil
}

// Enqueue queues a notification message for later delivery, assumes no structured input data.
// Returns the IDs of successfully enqueued messages, if any.