import org.cloudfoundry.reactor.TokenProvider; //导入依赖的package包/类
private CloudFoundryOperations doCreateOperations(CloudFoundryClient cloudFoundryClient,
														 ConnectionContext connectionContext,
														 TokenProvider tokenProvider,
														 String org,
														 String space) {
	ReactorDopplerClient dopplerClient = ReactorDopplerClient.builder()
			.connectionContext(connectionContext)
			.tokenProvider(tokenProvider)
			.build();

	ReactorUaaClient uaaClient = ReactorUaaClient.builder()
			.connectionContext(connectionContext)
			.tokenProvider(tokenProvider)
			.build();

	return DefaultCloudFoundryOperations.builder()
			.cloudFoundryClient(cloudFoundryClient)
			.dopplerClient(dopplerClient)
			.uaaClient(uaaClient)
			.organization(org)
			.space(space)
			.build();
}
 

import org.cloudfoundry.reactor.TokenProvider; //导入依赖的package包/类
private CloudFoundryOperations createCloudFoundryOperations() {
    DefaultConnectionContext connectionContext = DefaultConnectionContext.builder()
        .apiHost(apiHost)
        .build();

    TokenProvider tokenProvider = PasswordGrantTokenProvider.builder()
        .password(password)
        .username(userName)
        .build();

    ReactorCloudFoundryClient reactorClient = ReactorCloudFoundryClient.builder()
        .connectionContext(connectionContext)
        .tokenProvider(tokenProvider)
        .build();

    CloudFoundryOperations cloudFoundryOperations = DefaultCloudFoundryOperations.builder()
        .cloudFoundryClient(reactorClient)
        .organization(organization)
        .space(space)
        .build();

    return cloudFoundryOperations;
}
 

import org.cloudfoundry.reactor.TokenProvider; //导入依赖的package包/类
@Before
public void setup()
{
	String host = System.getenv("CF_HOST");
	String username = System.getenv("CF_USERNAME");
	String password = System.getenv("CF_PASSWORD");

	if(host == null || username == null || password == null)
	{
		throw new RuntimeException("CF_HOST, CF_USERNAME and CF_PASSWORD must be set");
	}

	ConnectionContext connectionContext = DefaultConnectionContext.builder().apiHost(host).skipSslValidation(true).build();
	TokenProvider tokenProvider = PasswordGrantTokenProvider.builder().username(username).password(password).build();

	ReactorUaaClient uaaClient = ReactorUaaClient.builder().connectionContext(connectionContext).tokenProvider(tokenProvider).build();
	uaa = new ReactorUaaClientFacade(uaaClient);
}
 

import org.cloudfoundry.reactor.TokenProvider; //导入依赖的package包/类
@Before
public void setup()
{
	String host = System.getenv("CF_HOST");
	String username = System.getenv("CF_USERNAME");
	String password = System.getenv("CF_PASSWORD");

	if(host == null || username == null || password == null)
	{
		throw new RuntimeException("CF_HOST, CF_USERNAME and CF_PASSWORD must be set");
	}

	ConnectionContext connectionContext = DefaultConnectionContext.builder().apiHost(host).skipSslValidation(true).build();
	TokenProvider tokenProvider = PasswordGrantTokenProvider.builder().username(username).password(password).build();
	cfClient = ReactorCloudFoundryClient.builder().connectionContext(connectionContext).tokenProvider(tokenProvider).build();
	cfOps = DefaultCloudFoundryOperations.builder().cloudFoundryClient(cfClient).build();
	facade = new ReactorCfClientFacade(cfClient, mock(ModifyingUserOps.class));
}
 

import org.cloudfoundry.reactor.TokenProvider; //导入依赖的package包/类
protected CloudFoundryOperations getCfOperations() {
    CfProperties cfAppProperties = this.cfPropertiesMapper.getProperties();

    ConnectionContext connectionContext = DefaultConnectionContext.builder()
        .apiHost(cfAppProperties.ccHost())
        .skipSslValidation(true)
        .proxyConfiguration(tryGetProxyConfiguration(cfAppProperties))
        .build();

    TokenProvider tokenProvider = getTokenProvider(cfAppProperties);

    CloudFoundryClient cfClient = ReactorCloudFoundryClient.builder()
        .connectionContext(connectionContext)
        .tokenProvider(tokenProvider)
        .build();

    CloudFoundryOperations cfOperations = DefaultCloudFoundryOperations.builder()
        .cloudFoundryClient(cfClient)
        .organization(cfAppProperties.org())
        .space(cfAppProperties.space())
        .build();

    return cfOperations;
}
 

import org.cloudfoundry.reactor.TokenProvider; //导入依赖的package包/类
@Bean
public CloudFoundryOperations cloudFoundryOperations(CloudFoundryClient cloudFoundryClient,
													 ConnectionContext connectionContext,
													 TokenProvider tokenProvider,
													 CloudFoundryConnectionProperties properties) {
	ReactorDopplerClient.builder()
		.connectionContext(connectionContext)
		.tokenProvider(tokenProvider)
		.build();

	ReactorUaaClient.builder()
		.connectionContext(connectionContext)
		.tokenProvider(tokenProvider)
		.build();

	return DefaultCloudFoundryOperations.builder()
		.cloudFoundryClient(cloudFoundryClient)
		.organization(properties.getOrg())
		.space(properties.getSpace())
		.build();
}
 

import org.cloudfoundry.reactor.TokenProvider; //导入依赖的package包/类
@Bean
public ReactorCloudFoundryClient cloudFoundryClient(
        ConnectionContext connectionContext,
        TokenProvider tokenProvider) {
    return ReactorCloudFoundryClient
            .builder()
            .connectionContext(connectionContext)
            .tokenProvider(tokenProvider).build();
}
 

import org.cloudfoundry.reactor.TokenProvider; //导入依赖的package包/类
@Bean
public ReactorDopplerClient dopplerClient(ConnectionContext connectionContext,
                                          TokenProvider tokenProvider) {
    return ReactorDopplerClient
            .builder()
            .connectionContext(connectionContext)
            .tokenProvider(tokenProvider)
            .build();
}
 

import org.cloudfoundry.reactor.TokenProvider; //导入依赖的package包/类
@Bean
ReactorUaaClient uaaClient(ConnectionContext ctx, TokenProvider tokenProvider) {
    return ReactorUaaClient
            .builder()
            .connectionContext(ctx)
            .tokenProvider(tokenProvider)
            .build();
}
 

import org.cloudfoundry.reactor.TokenProvider; //导入依赖的package包/类
@Override
public CloudFoundryOperations getOperations(String email, String password, URL apiEndpoint, String org, String space) {
	CloudFoundryClient client = getCloudFoundryClient(email, password, apiEndpoint);
	ConnectionContext context = connectionContext(apiEndpoint);
	TokenProvider tokenProvider = tokenProvider(email, password);
	return doCreateOperations(client, context, tokenProvider, org, space);
}
 

import org.cloudfoundry.reactor.TokenProvider; //导入依赖的package包/类
@Bean
ReactorCloudFoundryClient cloudFoundryClient(ConnectionContext connectionContext, TokenProvider tokenProvider) {
    return ReactorCloudFoundryClient.builder()
        .connectionContext(connectionContext)
        .tokenProvider(tokenProvider)
        .build();
}
 

import org.cloudfoundry.reactor.TokenProvider; //导入依赖的package包/类
@Bean
CloudFoundryClient cloudFoundryClient(ConnectionContext connectionContext, TokenProvider tokenProvider)
{
	return ReactorCloudFoundryClient.builder()
			.connectionContext(connectionContext)
			.tokenProvider(tokenProvider)
			.build();
}
 

import org.cloudfoundry.reactor.TokenProvider; //导入依赖的package包/类
@Bean
UaaClient uaaClient(ConnectionContext connectionContext, TokenProvider tokenProvider) {
	return ReactorUaaClient.builder()
			.connectionContext(connectionContext)
			.tokenProvider(tokenProvider)
			.build();
}
 

import org.cloudfoundry.reactor.TokenProvider; //导入依赖的package包/类
@Bean(initMethod = "checkCompatibility")
ReactorCloudFoundryClient cloudFoundryClient(ConnectionContext connectionContext, TokenProvider tokenProvider) {
    return ReactorCloudFoundryClient.builder()
            .connectionContext(connectionContext)
            .tokenProvider(tokenProvider)
            .build();
}
 

import org.cloudfoundry.reactor.TokenProvider; //导入依赖的package包/类
@Bean
ReactorCloudFoundryClient cloudFoundryClient(ConnectionContext connectionContext, TokenProvider tokenProvider) {
    return ReactorCloudFoundryClient.builder()
            .connectionContext(connectionContext)
            .tokenProvider(tokenProvider)
            .build();
}
 

import org.cloudfoundry.reactor.TokenProvider; //导入依赖的package包/类
protected TokenProvider getTokenProvider(CfProperties cfAppProperties) {
    if (cfAppProperties.ccToken() == null &&
        (cfAppProperties.ccUser() == null && cfAppProperties.ccPassword() == null)) {
        throw new IllegalStateException("One of token or user/password should be provided");
    }

    if (cfAppProperties.ccToken() != null) {
        return new StaticTokenProvider(cfAppProperties.ccToken());
    } else {
        return PasswordGrantTokenProvider.builder()
            .password(cfAppProperties.ccPassword())
            .username(cfAppProperties.ccUser())
            .build();
    }
}
 

import org.cloudfoundry.reactor.TokenProvider; //导入依赖的package包/类
@Test
    public void getAppDetailTests() {
        ConnectionContext connectionContext = DefaultConnectionContext.builder()
            .apiHost("api.local.pcfdev.io")
            .skipSslValidation(true)
            .build();

        TokenProvider tokenProvider = PasswordGrantTokenProvider.builder()
            .password("admin")
            .username("admin")
            .build();

        CloudFoundryClient cfClient = ReactorCloudFoundryClient.builder()
            .connectionContext(connectionContext)
            .tokenProvider(tokenProvider)
            .build();

        CloudFoundryOperations cfOperations = DefaultCloudFoundryOperations.builder()
            .cloudFoundryClient(cfClient)
            .organization("pcfdev-org")
            .space("pcfdev-space")
            .build();

        CfAppDetailsDelegate appDetailsTaskDelegate = new CfAppDetailsDelegate();
        CfProperties cfAppProps = envDetails();
        Mono<Optional<ApplicationDetail>> applicationDetailMono = appDetailsTaskDelegate
            .getAppDetails(cfOperations, cfAppProps);


//		Mono<Void> resp = applicationDetailMono.then(applicationDetail -> Mono.fromSupplier(() -> {
//			return 1;
//		})).then();
//
//		resp.block();
//		ApplicationDetail applicationDetail = applicationDetailMono.block(Duration.ofMillis(5000));
//		System.out.println("applicationDetail = " + applicationDetail);
    }
 

import org.cloudfoundry.reactor.TokenProvider; //导入依赖的package包/类
@Bean
@ConditionalOnMissingBean
public CloudFoundryClient cloudFoundryClient(ConnectionContext connectionContext, TokenProvider tokenProvider) {
	return ReactorCloudFoundryClient.builder()
		.connectionContext(connectionContext)
		.tokenProvider(tokenProvider)
		.build();
}
 

import org.cloudfoundry.reactor.TokenProvider; //导入依赖的package包/类
@Bean
@ConditionalOnMissingBean
public TokenProvider tokenProvider(CloudFoundryConnectionProperties properties) {
	return PasswordGrantTokenProvider.builder()
		.username(properties.getUsername())
		.password(properties.getPassword())
		.build();
}
 

import org.cloudfoundry.reactor.TokenProvider; //导入依赖的package包/类
@Bean
public TokenProvider tokenProvider(CloudFoundryConnectionProperties properties) {
	return PasswordGrantTokenProvider.builder()
			.username(properties.getUsername())
			.password(properties.getPassword())
			.build();
}