Method handlePutCollectionConfigSync

rest/admin_api.go:1162–1229

()

}

func (h *handler) handlePutCollectionConfigSync() error {
	h.assertAdminOnly()

	if !h.server.persistentConfig {
		return base.HTTPErrorf(http.StatusBadRequest, "endpoint only supports persistent config mode")
	}

	js, err := h.readJavascript()
	if err != nil {
		return err
	}

	bucket := h.db.Bucket.GetName()
	dbName := h.db.Name

	var updatedConfigStr string
	var updatedDbConfig *DatabaseConfig
	cas, err := h.server.BootstrapContext.UpdateConfig(h.ctx(), bucket, h.server.Config.Bootstrap.ConfigGroupID, dbName, func(bucketDbConfig *DatabaseConfig) (updatedConfig *DatabaseConfig, err error) {
		if h.headerDoesNotMatchEtag(bucketDbConfig.Version) {
			return nil, base.HTTPErrorf(http.StatusPreconditionFailed, "Provided If-Match header does not match current config version")
		}

		if bucketDbConfig.Scopes != nil {
			config := bucketDbConfig.Scopes[h.collection.ScopeName].Collections[h.collection.Name]
			config.SyncFn = &js
			bucketDbConfig.Scopes[h.collection.ScopeName].Collections[h.collection.Name] = config
			updatedConfigStr = fmt.Sprintf(`{"scopes": {"%s": {"collections": { "%s": { "sync": "%s"}}}}}`, h.collection.ScopeName, h.collection.Name, js)
		} else if base.IsDefaultCollection(h.collection.ScopeName, h.collection.Name) {
			bucketDbConfig.Sync = &js
			updatedConfigStr = fmt.Sprintf(`{"sync": "%s"}`, js)
		}

		validateReplications := false
		if err := bucketDbConfig.validate(h.ctx(), !h.getBoolQuery(paramDisableOIDCValidation), validateReplications); err != nil {
			return nil, base.NewHTTPError(http.StatusBadRequest, err.Error())
		}

		bucketDbConfig.Version, err = GenerateDatabaseConfigVersionID(h.ctx(), bucketDbConfig.Version, &bucketDbConfig.DbConfig)
		if err != nil {
			return nil, err
		}

		bucketDbConfig.SGVersion = base.ProductVersion.String()
		updatedDbConfig = bucketDbConfig
		return bucketDbConfig, nil
	})
	if err != nil {
		return err
	}
	updatedDbConfig.cfgCas = cas

	dbCreds, _ := h.server.Config.DatabaseCredentials[dbName]
	bucketCreds, _ := h.server.Config.BucketCredentials[bucket]
	if err := updatedDbConfig.setup(h.ctx(), dbName, h.server.Config.Bootstrap, dbCreds, bucketCreds, h.server.Config.IsServerless()); err != nil {
		return err
	}

	h.server._databasesLock.Lock()