Function addBundle

packages/plugins/google/src/sdk/plugin.ts:186–238

(config: GoogleBundleConfig)

  const httpClientLayer = options?.httpClientLayer ?? ctx.httpClientLayer;

  const addBundle = (config: GoogleBundleConfig) =>
    Effect.gen(function* () {
      const urls = uniqueUrls(config.urls);
      const conversion = yield* fetchGoogleBundleConversion(urls, httpClientLayer);
      const compiled = yield* compileOpenApiSpec(conversion.specText);
      const slug = IntegrationSlug.make(config.slug?.trim() || DEFAULT_GOOGLE_SLUG);

      const existing = yield* ctx.core.integrations.get(slug);
      if (existing) {
        return yield* new IntegrationAlreadyExistsError({ slug });
      }

      const specHash = yield* sha256Hex(conversion.specText);
      const integrationConfig: GoogleIntegrationConfig = {
        specHash,
        googleDiscoveryUrls: urls,
        ...(config.baseUrl ? { baseUrl: config.baseUrl } : {}),
        ...(conversion.authenticationTemplate
          ? { authenticationTemplate: conversion.authenticationTemplate }
          : {}),
      };

      yield* ctx.storage.putSpec(specHash, conversion.specText);
      yield* ctx.storage.putDefs(specHash, JSON.stringify(compiled.hoistedDefs));

      yield* ctx.transaction(
        Effect.gen(function* () {
          yield* ctx.core.integrations.register({
            slug,
            name: config.name?.trim() || "Google",
            description: config.description ?? "Google APIs",
            config: integrationConfig satisfies GoogleIntegrationConfig as IntegrationConfig,
            canRemove: true,
            canRefresh: true,
          });
          yield* ctx.storage.putOperations(
            String(slug),
            openApiStoredOperationsFromCompiled(String(slug), compiled),
          );
        }),
      );

      // Default the health check to the People API identity call (`people.get`
      // with `resourceName=people/me`) when the bundle includes the People API,
      // so connections report alive/expired + identity out of the box. Declared
      // through core's own storage; the user can adjust it via the editor.
      const defaultHealthCheck = defaultGoogleHealthCheck(urls, compiled.definitions);
      if (defaultHealthCheck) {
        yield* ctx.core.integrations.setHealthCheck(slug, defaultHealthCheck);
      }

      return { slug, toolCount: compiled.definitions.length };
    });

  const updateBundle = (rawSlug: string, input?: GoogleUpdateInput) =>
    Effect.gen(function* () {