Function userBlipHandler

db/blip_handler.go:116–126

userBlipHandler wraps another blip handler with code that reloads the user object when the user or the user's roles have changed, to make sure that the replication has the latest channel access grants. Uses a userChangeWaiter to detect changes to the user or roles. Note that in the case of a pushed

(next blipHandlerFunc)

// triggering a user access change, this happens at write time (via MarkPrincipalsChanged), and doesn't
// depend on the userChangeWaiter.
func userBlipHandler(next blipHandlerFunc) blipHandlerFunc {
	return func(bh *blipHandler, bm *blip.Message) error {

		// Reload user if it has changed
		if err := bh.refreshUser(); err != nil {
			return err
		}
		// Call down to the underlying handler and return it's value
		return next(bh, bm)
	}
}

func (bh *blipHandler) refreshUser() error {