Implement module to link stack to GitHub repository

src/api.ts

@@ -94,6 +94,12 @@ export const functionsDefaultRegion = utils.envOverride(
   "FIREBASE_FUNCTIONS_DEFAULT_REGION",
   "us-central1"
 );
+
+export const cloudbuildOrigin = utils.envOverride(
+  "FIREBASE_CLOUDBUILD_URL",
+  "https://cloudbuild.googleapis.com"
+);
+
 export const cloudschedulerOrigin = utils.envOverride(
   "FIREBASE_CLOUDSCHEDULER_URL",
   "https://cloudscheduler.googleapis.com"

src/commands/index.ts

@@ -150,6 +150,8 @@ export function load(client: any): any {
     client.internaltesting.frameworks.compose = loadCommand("internaltesting-frameworks-compose");
     client.internaltesting.functions = {};
     client.internaltesting.functions.discover = loadCommand("internaltesting-functions-discover");
+    client.internaltesting.frameworks = {};
+    client.internaltesting.frameworks.init = loadCommand("internaltesting-frameworks-init");
   }
   client.login = loadCommand("login");
   client.login.add = loadCommand("login-add");

src/commands/internaltesting-frameworks-init.ts

@@ -0,0 +1,14 @@
+import { Command } from "../command";
+import { linkGitHubRepository } from "../init/features/composer/repo";
+import { Options } from "../options";
+import { needProjectId } from "../projectUtils";
+import requireInteractive from "../requireInteractive";
+
+export const command = new Command("internaltesting:frameworks:init")
+  .description("connect github repo to cloud build")
+  .before(requireInteractive)
+  .action(async (options: Options) => {
+    const projectId = needProjectId(options);
+    await linkGitHubRepository(projectId, "us-central2", "stack0");
+    // TODO: send repo metadata to control plane
+  });

src/gcp/cloudbuild.ts

@@ -0,0 +1,179 @@
+import { Client } from "../apiv2";
+import { cloudbuildOrigin } from "../api";
+
+const client = new Client({
+  urlPrefix: cloudbuildOrigin,
+  auth: true,
+  apiVersion: "v2",
+});
+
+export interface OperationMetadata {
+  createTime: string;
+  endTime: string;
+  target: string;
+  verb: string;
+  requestedCancellation: boolean;
+  apiVersion: string;
+}
+
+export interface Operation {
+  name: string;
+  metadata?: OperationMetadata;
+  done: boolean;
+  error?: { code: number; message: string; details: unknown };
+  response?: any;
+}
+
+export interface GitHubConfig {
+  authorizerCredential?: {
+    oauthTokenSecretVersion: string;
+    username: string;
+  };
+  appInstallationId?: string;
+}
+
+type InstallationStage =
+  | "STAGE_UNSPECIFIED"
+  | "PENDING_CREATE_APP"
+  | "PENDING_USER_OAUTH"
+  | "PENDING_INSTALL_APP"
+  | "COMPLETE";
+
+type ConnectionOutputOnlyFields = "createTime" | "updateTime" | "installationState" | "reconciling";
+
+export interface Connection {
+  name?: string;
+  disabled?: boolean;
+  annotations?: {
+    [key: string]: string;
+  };
+  etag?: string;
+  githubConfig?: GitHubConfig;
+  createTime: string;
+  updateTime: string;
+  installationState: {
+    stage: InstallationStage;
+    message: string;
+    actionUri: string;
+  };
+  reconciling: boolean;
+}
+
+type RepositoryOutputOnlyFields = "createTime" | "updateTime";
+
+export interface Repository {
+  name?: string;
+  remoteUri: string;
+  annotations?: {
+    [key: string]: string;
+  };
+  etag?: string;
+  createTime: string;
+  updateTime: string;
+}
+
+interface LinkableRepositories {
+  repositories: Repository[];
+  nextPageToken: string;
+}
+
+/**
+ * Creates a Cloud Build V2 Connection.
+ */
+export async function createConnection(
+  projectId: string,
+  location: string,
+  connectionId: string
+): Promise<Operation> {
+  const res = await client.post<Omit<Connection, ConnectionOutputOnlyFields>, Operation>(
+    `projects/${projectId}/locations/${location}/connections`,
+    { githubConfig: {} },
+    { queryParams: { connectionId } }
+  );
+  return res.body;
+}
+
+/**
+ * Gets metadata for a Cloud Build V2 Connection.
+ */
+export async function getConnection(
+  projectId: string,
+  location: string,
+  connectionId: string
+): Promise<Connection> {
+  const name = `projects/${projectId}/locations/${location}/connections/${connectionId}`;
+  const res = await client.get<Connection>(name);
+  return res.body;
+}
+
+/**
+ * Deletes a Cloud Build V2 Connection.
+ */
+export async function deleteConnection(
+  projectId: string,
+  location: string,
+  connectionId: string
+): Promise<Operation> {
+  const name = `projects/${projectId}/locations/${location}/connections/${connectionId}`;
+  const res = await client.delete<Operation>(name);
+  return res.body;
+}
+
+/**
+ * Gets a list of repositories that can be added to the provided Connection.
+ */
+export async function fetchLinkableRepositories(
+  projectId: string,
+  location: string,
+  connectionId: string
+): Promise<LinkableRepositories> {
+  const name = `projects/${projectId}/locations/${location}/connections/${connectionId}:fetchLinkableRepositories`;
+  const res = await client.get<LinkableRepositories>(name);
+  return res.body;
+}
+
+/**
+ * Creates a Cloud Build V2 Repository.
+ */
+export async function createRepository(
+  projectId: string,
+  location: string,
+  connectionId: string,
+  repositoryId: string,
+  remoteUri: string
+): Promise<Operation> {
+  const res = await client.post<Omit<Repository, RepositoryOutputOnlyFields>, Operation>(
+    `projects/${projectId}/locations/${location}/connections/${connectionId}/repositories`,
+    { remoteUri },
+    { queryParams: { repositoryId } }
+  );
+  return res.body;
+}
+
+/**
+ * Gets metadata for a Cloud Build V2 Repository.
+ */
+export async function getRepository(
+  projectId: string,
+  location: string,
+  connectionId: string,
+  repositoryId: string
+): Promise<Repository> {
+  const name = `projects/${projectId}/locations/${location}/connections/${connectionId}/repositories/${repositoryId}`;
+  const res = await client.get<Repository>(name);
+  return res.body;
+}
+
+/**
+ * Deletes a Cloud Build V2 Repository.
+ */
+export async function deleteRepository(
+  projectId: string,
+  location: string,
+  connectionId: string,
+  repositoryId: string
+) {
+  const name = `projects/${projectId}/locations/${location}/connections/${connectionId}/repositories/${repositoryId}`;
+  const res = await client.delete<Operation>(name);
+  return res.body;
+}