Function execute

worker/src/components/github/remove-org-membership.ts:138–285

({ inputs }, context)

    ],
  },
  async execute({ inputs }, context) {
    const { organization, teamSlug, userIdentifier, connectionId } = inputSchema.parse(inputs);

    const trimmedConnectionId = connectionId.trim();

    if (trimmedConnectionId.length === 0) {
      throw new ConfigurationError(
        'GitHub connection ID is required when using an existing connection.',
        {
          configKey: 'connectionId',
        },
      );
    }

    context.emitProgress(
      `Retrieving GitHub access token from connection ${trimmedConnectionId}...`,
    );
    const connectionToken = await fetchConnectionAccessToken(trimmedConnectionId, context);
    const accessToken = connectionToken.accessToken;
    const tokenType = connectionToken.tokenType ?? 'Bearer';
    const tokenScope =
      Array.isArray(connectionToken.scopes) && connectionToken.scopes.length > 0
        ? connectionToken.scopes.join(' ')
        : undefined;

    const authorizationScheme =
      tokenType && tokenType.trim().length > 0 ? tokenType.trim() : 'Bearer';

    const headers = {
      // Use token obtained via selected authentication mode
      Authorization: `${authorizationScheme} ${accessToken}`,
      Accept: 'application/vnd.github+json',
      'User-Agent': 'shipsecai-worker/1.0',
      'X-GitHub-Api-Version': '2022-11-28',
    };

    const login = await resolveLogin(userIdentifier, headers, context);

    let teamRemovalStatus: 'removed' | 'not_found' | 'skipped' = 'skipped';
    let removedFromTeam = false;

    if (teamSlug) {
      context.emitProgress(`Removing ${login} from team ${teamSlug}...`);
      let teamResponse: Response;
      try {
        teamResponse = await context.http.fetch(
          `https://api.github.com/orgs/${encodeURIComponent(organization)}/teams/${encodeURIComponent(teamSlug)}/memberships/${encodeURIComponent(login)}`,
          {
            method: 'DELETE',
            headers,
          },
        );
      } catch (error) {
        throw new NetworkError(
          `GitHub API request failed while removing ${login} from team ${teamSlug}: ${(error as Error).message}`,
          { cause: error as Error },
        );
      }