Method RequiresCollectionAccessUpdate

db/users.go:268–300

RequiresCollectionAccessUpdate returns true if the provided map of CollectionAccessConfig requires an update to the principal

(ctx context.Context, princ auth.Principal, updates map[string]map[string]*auth.CollectionAccessConfig)

// RequiresCollectionAccessUpdate returns true if the provided map of CollectionAccessConfig requires an update to the principal
func (dbc *DatabaseContext) RequiresCollectionAccessUpdate(ctx context.Context, princ auth.Principal, updates map[string]map[string]*auth.CollectionAccessConfig) (bool, error) {
	requiresUpdate := false
	for scopeName, scope := range updates {
		if scope != nil {
			for collectionName, updatedCollectionAccess := range scope {
				_, err := dbc.GetDatabaseCollection(scopeName, collectionName)
				if err != nil {
					return false, base.HTTPErrorf(http.StatusNotFound, "keyspace specified in collection_access (%s) not found", fmt.Sprintf("%s.%s.%s", dbc.Name, scopeName, collectionName))
				}
				if updatedCollectionAccess.Channels_ != nil {
					return false, base.HTTPErrorf(http.StatusBadRequest, "collection_access.all_channels is read-only")
				}
				if updatedCollectionAccess.JWTChannels_ != nil {
					return false, base.HTTPErrorf(http.StatusBadRequest, "collection_access.jwt_channels is read-only")
				}
				if updatedCollectionAccess.JWTLastUpdated != nil {
					return false, base.HTTPErrorf(http.StatusBadRequest, "collection_access.jwt_last_updated is read-only")
				}
				if updatedCollectionAccess == nil {
					if princ.CollectionExplicitChannels(scopeName, collectionName) != nil {
						requiresUpdate = true
					}
				} else {
					if !princ.CollectionExplicitChannels(scopeName, collectionName).Equals(updatedCollectionAccess.ExplicitChannels_) {
						requiresUpdate = true
					}
				}
			}
		}
	}

	return requiresUpdate, nil
}