Skip to content

Commit bec0799

Browse files
committed
Merge branch '890-event-parameters' into 2.x
2 parents 751456b + b115e02 commit bec0799

File tree

2 files changed

+50
-1
lines changed

2 files changed

+50
-1
lines changed

cloudfoundry-client/src/main/java/org/cloudfoundry/client/v2/events/_ListEventsRequest.java

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -36,6 +36,20 @@ abstract class _ListEventsRequest extends PaginatedRequest {
3636
@Nullable
3737
abstract List<String> getActees();
3838

39+
/**
40+
* The organization ids
41+
*/
42+
@FilterParameter("organization_guid")
43+
@Nullable
44+
abstract List<String> getOrganizationIds();
45+
46+
/**
47+
* The space ids
48+
*/
49+
@FilterParameter("space_guid")
50+
@Nullable
51+
abstract List<String> getSpaceIds();
52+
3953
/**
4054
* The timestamps
4155
*/

integration-test/src/test/java/org/cloudfoundry/client/v2/EventsTest.java

Lines changed: 36 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,6 @@
2929
import reactor.test.StepVerifier;
3030

3131
import java.time.Duration;
32-
import java.util.concurrent.TimeoutException;
3332

3433
public final class EventsTest extends AbstractIntegrationTest {
3534

@@ -89,6 +88,42 @@ public void listFilterByActee() {
8988
.verify(Duration.ofMinutes(5));
9089
}
9190

91+
@Test
92+
public void listFilterByOrganizationId() {
93+
getFirstEvent(this.cloudFoundryClient)
94+
.then(resource -> Mono.when(
95+
Mono.just(resource),
96+
this.cloudFoundryClient.events()
97+
.list(ListEventsRequest.builder()
98+
.organizationId(ResourceUtils.getEntity(resource).getOrganizationId())
99+
.build())
100+
.flatMapMany(ResourceUtils::getResources)
101+
.next()
102+
))
103+
.as(StepVerifier::create)
104+
.consumeNextWith(tupleEquality())
105+
.expectComplete()
106+
.verify(Duration.ofMinutes(5));
107+
}
108+
109+
@Test
110+
public void listFilterBySpaceId() {
111+
getFirstEvent(this.cloudFoundryClient)
112+
.then(resource -> Mono.when(
113+
Mono.just(resource),
114+
this.cloudFoundryClient.events()
115+
.list(ListEventsRequest.builder()
116+
.spaceId(ResourceUtils.getEntity(resource).getSpaceId())
117+
.build())
118+
.flatMapMany(ResourceUtils::getResources)
119+
.next()
120+
))
121+
.as(StepVerifier::create)
122+
.consumeNextWith(tupleEquality())
123+
.expectComplete()
124+
.verify(Duration.ofMinutes(5));
125+
}
126+
92127
@Test
93128
public void listFilterByTimestamp() {
94129
getFirstEvent(this.cloudFoundryClient)

0 commit comments

Comments
 (0)