Skip to content

Commit 95bcc23

Browse files
committed
Return availableAt as Instant
1 parent a112275 commit 95bcc23

File tree

6 files changed

+11
-12
lines changed

6 files changed

+11
-12
lines changed

src/main/java/dev/erichaag/develocity/api/BazelBuild.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -29,8 +29,8 @@ public String getId() {
2929
}
3030

3131
@Override
32-
public long getAvailableAt() {
33-
return build.getAvailableAt();
32+
public Instant getAvailableAt() {
33+
return Instant.ofEpochMilli(build.getAvailableAt());
3434
}
3535

3636
@Override

src/main/java/dev/erichaag/develocity/api/Build.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@ public sealed interface Build permits GradleBuild, MavenBuild, BazelBuild, SbtBu
1313

1414
String getId();
1515

16-
long getAvailableAt();
16+
Instant getAvailableAt();
1717

1818
String getBuildToolVersion();
1919

src/main/java/dev/erichaag/develocity/api/GradleBuild.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -36,8 +36,8 @@ public String getId() {
3636
}
3737

3838
@Override
39-
public long getAvailableAt() {
40-
return build.getAvailableAt();
39+
public Instant getAvailableAt() {
40+
return Instant.ofEpochMilli(build.getAvailableAt());
4141
}
4242

4343
@Override

src/main/java/dev/erichaag/develocity/api/MavenBuild.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -33,8 +33,8 @@ public String getId() {
3333
}
3434

3535
@Override
36-
public long getAvailableAt() {
37-
return build.getAvailableAt();
36+
public Instant getAvailableAt() {
37+
return Instant.ofEpochMilli(build.getAvailableAt());
3838
}
3939

4040
@Override

src/main/java/dev/erichaag/develocity/api/SbtBuild.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -23,8 +23,8 @@ public String getId() {
2323
}
2424

2525
@Override
26-
public long getAvailableAt() {
27-
return build.getAvailableAt();
26+
public Instant getAvailableAt() {
27+
return Instant.ofEpochMilli(build.getAvailableAt());
2828
}
2929

3030
@Override

src/main/java/dev/erichaag/develocity/processing/BuildProcessorWorker.java

+2-3
Original file line numberDiff line numberDiff line change
@@ -88,13 +88,12 @@ public void process() {
8888
}
8989

9090
private List<Build> discoverBuilds(String query, Instant since) {
91-
final var sinceMilli = since.toEpochMilli();
9291
final var builds = new ArrayList<Build>();
9392
while (true) {
9493
final var response = develocity.getBuilds(query, maxDiscoveryBuildsPerRequest, getLastId(builds));
9594
if (response.isEmpty()) return builds;
96-
if (response.getLast().getAvailableAt() < sinceMilli) {
97-
builds.addAll(response.stream().filter(it -> it.getAvailableAt() >= sinceMilli).toList());
95+
if (response.getLast().getAvailableAt().compareTo(since) < 0) {
96+
builds.addAll(response.stream().filter(it -> it.getAvailableAt().compareTo(since) >= 0).toList());
9897
return builds;
9998
}
10099
builds.addAll(response);

0 commit comments

Comments
 (0)