Method CheckSupportedCouchbaseVersion

rest/server_context.go:2215–2275

(ctx context.Context)

}

func (sc *ServerContext) CheckSupportedCouchbaseVersion(ctx context.Context) error {
	clusterSpec := base.CouchbaseClusterSpec{
		Server:        sc.Config.Bootstrap.Server,
		Username:      sc.Config.Bootstrap.Username,
		Password:      sc.Config.Bootstrap.Password,
		X509Certpath:  sc.Config.Bootstrap.X509CertPath,
		X509Keypath:   sc.Config.Bootstrap.X509KeyPath,
		CACertpath:    sc.Config.Bootstrap.CACertPath,
		TLSSkipVerify: base.ValDefault(sc.Config.Bootstrap.ServerTLSSkipVerify, false),
	}

	securityConfig, err := base.GoCBv2SecurityConfig(ctx, base.Ptr(clusterSpec.TLSSkipVerify), clusterSpec.CACertpath)
	if err != nil {
		return fmt.Errorf("failed to create security config: %v", err)
	}

	authenticator, err := base.GoCBv2Authenticator(clusterSpec.Username, clusterSpec.Password, clusterSpec.X509Certpath, clusterSpec.X509Keypath)
	if err != nil {
		return fmt.Errorf("failed to create authenticator: %v", err)
	}

	cluster, err := gocb.Connect(clusterSpec.Server,
		gocb.ClusterOptions{
			Authenticator:  authenticator,
			SecurityConfig: securityConfig,
		})
	if err != nil {
		return fmt.Errorf("failed to create cluster: %v", err)
	}

	err = cluster.WaitUntilReady(5*time.Second, &gocb.WaitUntilReadyOptions{
		ServiceTypes: []gocb.ServiceType{gocb.ServiceTypeManagement},
	})
	if err != nil {
		return fmt.Errorf("failed to wait for cluster to become ready: %v", err)
	}

	major, minor, err := base.GetClusterVersion(cluster)
	if err != nil {
		return fmt.Errorf("failed to get cluster version: %v", err)
	}

	errMsg := fmt.Sprintf(
		"Sync Gateway requires Couchbase Server %d.%d or later, but found cluster version %d.%d",
		CBXDCRCompatibleMajorVersion,
		CBXDCRCompatibleMinorVersion,
		major,
		minor,
	)

	if !base.IsMinimumVersion(uint64(major), uint64(minor), CBXDCRCompatibleMajorVersion, CBXDCRCompatibleMinorVersion) {
		base.ErrorfCtx(ctx, "%s", errMsg)
		return errors.New(errMsg)
	}

	err = cluster.Close(&gocb.ClusterCloseOptions{})
	if err != nil {
		base.WarnfCtx(ctx, "Couldn't close cluster: %v", err)