feat: add a github client

java-shared-dependencies/dependency-analyzer/pom.xml

@@ -38,6 +38,16 @@
           </arguments>
         </configuration>
       </plugin>
+      <plugin>
+        <groupId>org.apache.maven.plugins</groupId>
+        <artifactId>maven-surefire-plugin</artifactId>
+        <version>3.2.5</version>
+        <configuration>
+          <environmentVariables>
+            <GITHUB_TOKEN>fake_value</GITHUB_TOKEN>
+          </environmentVariables>
+        </configuration>
+      </plugin>
     </plugins>
   </build>
 

java-shared-dependencies/dependency-analyzer/src/main/java/com/google/cloud/external/DepsDevClient.java

@@ -29,7 +29,7 @@
 public class DepsDevClient {
 
   private final HttpClient client;
-  public final Gson gson;
+  private final Gson gson;
   private final static String ADVISORY_URL_BASE = "https://api.deps.dev/v3/advisories/%s";
 
   private final static String DEPENDENCY_URLBASE = "https://api.deps.dev/v3/systems/%s/packages/%s/versions/%s:dependencies";

java-shared-dependencies/dependency-analyzer/src/main/java/com/google/cloud/external/GitHubClient.java

@@ -0,0 +1,100 @@
+package com.google.cloud.external;
+
+import com.google.cloud.model.Interval;
+import com.google.cloud.model.PullRequest;
+import com.google.cloud.model.PullRequestStatus;
+import com.google.gson.Gson;
+import com.google.gson.GsonBuilder;
+import com.google.gson.reflect.TypeToken;
+import java.io.IOException;
+import java.net.URI;
+import java.net.URISyntaxException;
+import java.net.http.HttpClient;
+import java.net.http.HttpRequest;
+import java.net.http.HttpResponse;
+import java.net.http.HttpResponse.BodyHandlers;
+import java.time.Instant;
+import java.time.ZoneId;
+import java.time.ZonedDateTime;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Objects;
+
+public class GitHubClient {
+  private final HttpClient client;
+  private final Gson gson;
+  private final static String PULL_REQUESTS_BASE = "https://api.github.com/repos/%s/%s/pulls?state=all&per_page=100&page=%s";
+  private final static int MAX_PULL_REQUEST_NUM = 1000;
+  private final static String OPEN_STATE = "open";
+
+  public GitHubClient(HttpClient client) {
+    this.client = client;
+    this.gson = new GsonBuilder().create();
+  }
+
+  public PullRequestStatus listMonthlyPullRequestStatusOf(String organization, String repo)
+      throws URISyntaxException, IOException, InterruptedException {
+    return listPullRequestStatus(organization, repo, Interval.MONTHLY);
+  }
+
+  private PullRequestStatus listPullRequestStatus(String organization, String repo, Interval interval)
+      throws URISyntaxException, IOException, InterruptedException {
+    List<PullRequest> pullRequests = listPullRequests(organization, repo);
+    ZonedDateTime now = ZonedDateTime.now();
+    long created = pullRequests
+        .stream()
+        .distinct()
+        .filter(pullRequest -> pullRequest.state().equals(OPEN_STATE))
+        .filter(pullRequest -> {
+          ZonedDateTime createdAt = utcTimeFrom(pullRequest.createdAt());
+          return now.minusDays(interval.getDays()).isBefore(createdAt);
+        })
+        .count();
+
+    long merged = pullRequests
+        .stream()
+        .distinct()
+        .filter(pullRequest -> Objects.nonNull(pullRequest.mergedAt()))
+        .filter(pullRequest -> {
+          ZonedDateTime createdAt = utcTimeFrom(pullRequest.mergedAt());
+          return now.minusDays(interval.getDays()).isBefore(createdAt);
+        })
+        .count();
+
+    return new PullRequestStatus(created, merged, interval);
+  }
+
+  private List<PullRequest> listPullRequests(String organization, String repo)
+      throws URISyntaxException, IOException, InterruptedException {
+    List<PullRequest> pullRequests = new ArrayList<>();
+    int page = 1;
+    while (pullRequests.size() < MAX_PULL_REQUEST_NUM) {
+      HttpResponse<String> response = getResponse(getPullRequestsUrl(organization, repo, page));
+      pullRequests.addAll(gson.fromJson(response.body(), new TypeToken<List<PullRequest>>(){}.getType()));
+      page++;
+    }
+
+    return pullRequests;
+  }
+
+  private String getPullRequestsUrl(String organization, String repo, int page) {
+    return String.format(PULL_REQUESTS_BASE, organization, repo, page);
+  }
+
+  private ZonedDateTime utcTimeFrom(String time) {
+    ZoneId zoneIdUTC = ZoneId.of("UTC");
+    Instant instant = Instant.parse(time);
+    return instant.atZone(zoneIdUTC);
+  }
+
+  private HttpResponse<String> getResponse(String endpoint)
+      throws URISyntaxException, IOException, InterruptedException {
+    HttpRequest request = HttpRequest
+        .newBuilder()
+        .header("Authorization", System.getenv("GITHUB_TOKEN"))
+        .uri(new URI(endpoint))
+        .GET()
+        .build();
+    return client.send(request, BodyHandlers.ofString());
+  }
+}

java-shared-dependencies/dependency-analyzer/src/main/java/com/google/cloud/model/Interval.java

@@ -0,0 +1,16 @@
+package com.google.cloud.model;
+
+public enum Interval {
+  WEEKLY(7),
+  MONTHLY(30);
+
+  private final int days;
+
+  Interval(int days) {
+    this.days = days;
+  }
+
+  public int getDays() {
+    return days;
+  }
+}

java-shared-dependencies/dependency-analyzer/src/main/java/com/google/cloud/model/PullRequest.java

@@ -0,0 +1,13 @@
+package com.google.cloud.model;
+
+import com.google.gson.annotations.SerializedName;
+
+public record PullRequest(
+    String url,
+    String state,
+    @SerializedName("created_at")
+    String createdAt,
+    @SerializedName("merged_at")
+    String mergedAt) {
+
+}

java-shared-dependencies/dependency-analyzer/src/main/java/com/google/cloud/model/PullRequestStatus.java

@@ -0,0 +1,5 @@
+package com.google.cloud.model;
+
+public record PullRequestStatus(long created, long merged, Interval interval) {
+
+}

java-shared-dependencies/dependency-analyzer/src/test/java/com/google/cloud/external/GitHubClientTest.java

@@ -0,0 +1,66 @@
+package com.google.cloud.external;
+
+import static org.junit.Assert.assertEquals;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.Mockito.mock;
+import static org.mockito.Mockito.when;
+
+import com.google.cloud.model.Interval;
+import com.google.cloud.model.PullRequestStatus;
+import java.io.IOException;
+import java.net.URISyntaxException;
+import java.net.http.HttpClient;
+import java.net.http.HttpRequest;
+import java.net.http.HttpResponse;
+import java.net.http.HttpResponse.BodyHandler;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.time.Instant;
+import java.time.ZoneId;
+import java.time.ZonedDateTime;
+import org.junit.Before;
+import org.junit.Test;
+import org.mockito.MockedStatic;
+import org.mockito.Mockito;
+
+public class GitHubClientTest {
+
+  private HttpResponse<String> response;
+  private GitHubClient client;
+
+  @Before
+  public void setUp() throws IOException, InterruptedException {
+    HttpClient httpClient = mock(HttpClient.class);
+    client = new GitHubClient(httpClient);
+    response = mock(HttpResponse.class);
+    when(httpClient.send(any(HttpRequest.class), any(BodyHandler.class)))
+        .thenReturn(response);
+  }
+
+  @Test
+  public void testListMonthlyPullRequestStatusSucceeds()
+      throws URISyntaxException, IOException, InterruptedException {
+    ZonedDateTime fixedNow = ZonedDateTime.parse("2024-05-22T09:33:52Z");
+    ZonedDateTime lastMonth = ZonedDateTime.parse("2024-04-22T09:33:52Z");
+    Instant prInstant = Instant.parse("2024-05-10T09:33:52Z");
+    ZonedDateTime prTime = ZonedDateTime.parse("2024-05-10T09:33:52Z");
+    String responseBody = Files.readString(
+        Path.of("src/test/resources/pull_request_sample_response.txt"));
+
+    try (MockedStatic<ZonedDateTime> mockedLocalDateTime = Mockito.mockStatic(ZonedDateTime.class);
+        MockedStatic<Instant> mockedInstant = Mockito.mockStatic(Instant.class)) {
+      mockedLocalDateTime.when(ZonedDateTime::now).thenReturn(fixedNow);
+      mockedInstant.when(() -> Instant.parse(Mockito.anyString())).thenReturn(prInstant);
+      when(fixedNow.minusDays(30)).thenReturn(lastMonth);
+      when(prInstant.atZone(ZoneId.of("UTC"))).thenReturn(prTime);
+      when(response.body()).thenReturn(responseBody);
+      String org = "";
+      String repo = "";
+      PullRequestStatus status = client.listMonthlyPullRequestStatusOf(org, repo);
+
+      assertEquals(Interval.MONTHLY, status.interval());
+      assertEquals(3, status.created());
+      assertEquals(7, status.merged());
+    }
+  }
+}