Function connectGoogleAccount

e2e/scenarios/google-disabled-api.test.ts:146–204

(input: {
  readonly client: Client;
  readonly emulator: EmulatorClient;
  readonly emulatorBaseUrl: string;
  readonly target: TargetShape;
  readonly integration: IntegrationSlug;
  readonly oauthClient: OAuthClientSlug;
})

  });

const connectGoogleAccount = (input: {
  readonly client: Client;
  readonly emulator: EmulatorClient;
  readonly emulatorBaseUrl: string;
  readonly target: TargetShape;
  readonly integration: IntegrationSlug;
  readonly oauthClient: OAuthClientSlug;
}) =>
  Effect.gen(function* () {
    const redirectUri = new URL("/api/oauth/callback", input.target.baseUrl).toString();
    const credential = yield* Effect.promise(() =>
      input.emulator.credentials.mint({
        type: "oauth-authorization-code",
        redirect_uris: [redirectUri],
      }),
    );
    if (!credential.client_id || !credential.client_secret) {
      return yield* Effect.die(`Google emulator did not mint an OAuth client`);
    }

    yield* input.client.openapi.configure({
      params: { slug: input.integration },
      payload: { baseUrl: input.emulatorBaseUrl },
    });
    yield* input.client.oauth.createClient({
      payload: {
        owner: "org",
        slug: input.oauthClient,
        grant: "authorization_code",
        authorizationUrl: `${input.emulatorBaseUrl}/o/oauth2/v2/auth`,
        tokenUrl: `${input.emulatorBaseUrl}/oauth2/token`,
        clientId: credential.client_id,
        clientSecret: credential.client_secret,
        originIntegration: input.integration,
      },
    });

    const started = yield* input.client.oauth.start({
      payload: {
        client: input.oauthClient,
        clientOwner: "org",
        owner: "org",
        name: CONNECTION,
        integration: input.integration,
        template: GOOGLE_AUTH_TEMPLATE,
        redirectUri,
      },
    });
    expect(started.status, "OAuth starts with an emulator redirect").toBe("redirect");
    if (started.status !== "redirect") return yield* Effect.die("OAuth unexpectedly connected");

    const code = yield* completeGoogleConsent(started.authorizationUrl);
    const completed = yield* input.client.oauth.complete({
      payload: { state: started.state, code },
    });
    expect(completed.integration, "OAuth completion creates the connection").toBe(
      input.integration,
    );