Method refreshUser

db/blip_handler.go:128–161

()

}

func (bh *blipHandler) refreshUser() error {

	bc := bh.BlipSyncContext
	if bc.userName != "" {
		// Check whether user needs to be refreshed
		bc.dbUserLock.Lock()
		defer bc.dbUserLock.Unlock()
		userChanged := bc.userChangeWaiter.RefreshUserCount()

		// If changed, refresh the user and db while holding the lock
		if userChanged {
			// Refresh the BlipSyncContext database
			err := bc.blipContextDb.ReloadUser(bh.loggingCtx)
			if err != nil {
				return base.NewHTTPError(CBLReconnectErrorCode, err.Error())
			}
			newUser := bc.blipContextDb.User()
			err = newUser.InitializeRoles()
			if err != nil {
				return base.NewHTTPError(CBLReconnectErrorCode, err.Error())
			}
			bc.userChangeWaiter.RefreshUserKeys(newUser, bc.blipContextDb.MetadataKeys)
			// refresh the handler's database with the new BlipSyncContext database
			bh.db = bh._copyContextDatabase()
			if bh.collection != nil {
				bh.collection = &DatabaseCollectionWithUser{
					DatabaseCollection: bh.collection.DatabaseCollection,
					user:               bh.db.User(),
				}
			}
		}
	}
	return nil
}

// collectionBlipHandler wraps another blip handler to specify a collection
func collectionBlipHandler(next blipHandlerFunc) blipHandlerFunc {