Function addGraph

packages/plugins/microsoft/src/sdk/plugin.ts:158–220

(config: MicrosoftGraphConfig)

    });

  const addGraph = (config: MicrosoftGraphConfig) =>
    Effect.gen(function* () {
      const graph = yield* buildMicrosoftGraphOpenApiSpec(config, httpClientLayer, urlPolicy);
      const slug = IntegrationSlug.make(config.slug?.trim() || DEFAULT_MICROSOFT_SLUG);

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

      const specHash = yield* sha256Hex(graph.specText);
      const integrationConfig: MicrosoftGraphIntegrationConfig = {
        specHash,
        sourceUrl: graph.specUrl,
        microsoftGraphPresetIds: graph.presetIds,
        microsoftGraphCustomScopes: graph.customScopes,
        microsoftGraphScopes: graph.scopes,
        microsoftGraphExactPaths: graph.exactPaths,
        microsoftGraphPathPrefixes: graph.pathPrefixes,
        microsoftGraphTagPrefixes: graph.tagPrefixes,
        microsoftGraphCoversFullGraph: graph.coversFullGraph,
        microsoftGraphAuthorizationUrl: graph.authorizationUrl,
        microsoftGraphTokenUrl: graph.tokenUrl,
        microsoftGraphClientCredentialsTokenUrl: graph.clientCredentialsTokenUrl,
        authenticationTemplate: graph.authenticationTemplate,
        ...(config.baseUrl ? { baseUrl: config.baseUrl } : {}),
      };

      yield* ctx.storage.putSpec(specHash, graph.specText);

      const persisted = yield* ctx.transaction(
        Effect.gen(function* () {
          yield* ctx.core.integrations.register({
            slug,
            name: config.name?.trim() || "Microsoft Graph",
            description: config.description ?? "Selected Microsoft Graph workloads.",
            config:
              integrationConfig satisfies MicrosoftGraphIntegrationConfig as IntegrationConfig,
            canRemove: true,
            canRefresh: true,
          });
          return yield* persistGraphOperations(graph, String(slug), specHash);
        }),
      );

      // Default the health check to `GET /me` (the canonical Graph identity
      // endpoint) when the selected workloads include it, so connections report
      // alive/expired + who-am-I out of the box. The operations were streamed
      // to storage above, so find the binding there. Best-effort: a Graph
      // selection without /me just leaves the check unconfigured (the editor
      // remains available).
      const meOperation = (yield* ctx.storage.listOperations(String(slug))).find(
        (op) => op.binding.method.toLowerCase() === "get" && op.binding.pathTemplate === "/me",
      );
      if (meOperation) {
        yield* ctx.core.integrations.setHealthCheck(slug, {
          operation: meOperation.toolName,
          identityField: "userPrincipalName",