public Mono<Void> updateBrokerApp(String appName, String brokerClientId, List<String> appBrokerProperties) {
	return cloudFoundryOperations.applications().get(GetApplicationRequest.builder().name(appName).build())
		.map(ApplicationDetail::getId)
		.flatMap(applicationId -> cloudFoundryClient.applicationsV2().update(UpdateApplicationRequest
			.builder()
			.applicationId(applicationId)
			.putAllEnvironmentJsons(appBrokerDeployerEnvironmentVariables(brokerClientId))
			.putAllEnvironmentJsons(propertiesToEnvironment(appBrokerProperties))
			.name(appName)
			.memory(1024)
			.build())
			.thenReturn(applicationId))
		.then(cloudFoundryOperations.applications().restart(RestartApplicationRequest.builder()
			.name(appName)
			.build()))
		.doOnSuccess(item -> LOG.info("Updated broker app " + appName))
		.doOnError(error -> LOG.error("Error updating broker app " + appName + ": " + error))
		.then();
}
 

@Test
public void testCfPushWithoutEnvOrServices() throws Exception {
    CloudFoundryOperations cfOperations = mock(CloudFoundryOperations.class);
    Applications mockApplications = mock(Applications.class);
    when(cfOperations.applications()).thenReturn(mockApplications);
    when(mockApplications.push(any(PushApplicationRequest.class))).thenReturn(Mono.empty());
    when(mockApplications.restart(any(RestartApplicationRequest.class))).thenReturn(Mono.empty());

    Services mockServices = mock(Services.class);
    when(cfOperations.services()).thenReturn(mockServices);
    ServiceInstance mockInstance = ServiceInstance.builder().name("testservice").id("id").type(ServiceInstanceType.MANAGED).build();
    when(mockServices.getInstance(any(GetServiceInstanceRequest.class))).thenReturn(Mono.just(mockInstance));

    CfProperties cfAppProperties = sampleApp();
    cfPushDelegate.push(cfOperations, cfAppProperties);
}
 

private Mono<Void> restartApp(AppDetail detail) {
	return DefaultCloudFoundryOperations.builder()
			.from(opsClient)
			.organization(detail.getOrganization())
			.space(detail.getSpace())
			.build()
				.applications()
					.restart(RestartApplicationRequest.builder().name(detail.getAppName()).build());
}
 

void restartApp(String name) {
	this.cloudFoundryOperations.applications()
			.restart(RestartApplicationRequest.builder().name(name).build());
}
 

@TaskAction
public void restartApp() {

    CloudFoundryOperations cfOperations = getCfOperations();
    CfProperties cfProperties = getCfProperties();

    Mono<Void> resp = cfOperations.applications()
        .restart(RestartApplicationRequest.builder().name(cfProperties.name()).build());

    resp.block(Duration.ofMillis(defaultWaitTimeout));

}