Function HandleInboxNotificationEvent

coderd/pubsub/inboxnotification.go:18–32

(cb func(ctx context.Context, payload InboxNotificationEvent, err error))

}

func HandleInboxNotificationEvent(cb func(ctx context.Context, payload InboxNotificationEvent, err error)) func(ctx context.Context, message []byte, err error) {
	return func(ctx context.Context, message []byte, err error) {
		if err != nil {
			cb(ctx, InboxNotificationEvent{}, xerrors.Errorf("inbox notification event pubsub: %w", err))
			return
		}
		var payload InboxNotificationEvent
		if err := json.Unmarshal(message, &payload); err != nil {
			cb(ctx, InboxNotificationEvent{}, xerrors.Errorf("unmarshal inbox notification event"))
			return
		}

		cb(ctx, payload, err)
	}
}

type InboxNotificationEvent struct {
	Kind              InboxNotificationEventKind `json:"kind"`