Add stripe-customer-id header to GitHub ingest flow

- Add headers parameter to RAG ingest pipeline options
- Pass headers through GitHub blob, PR, and issue ingest functions
- Call buildAiGatewayHeaders in processRepository

This ensures AI Gateway requests during GitHub repository ingestion include Stripe customer ID for billing attribution.

Author: shige

apps/studio.giselles.ai/lib/vector-stores/github/ingest/blobs/ingest-github-blobs.ts

@@ -24,6 +24,7 @@ export async function ingestGitHubBlobs(params: {
 	teamDbId: number;
 	embeddingProfileId: EmbeddingProfileId;
 	embeddingComplete?: EmbeddingCompleteCallback;
+	headers?: Record<string, string>;
 }): Promise<void> {
 	const { repositoryIndexDbId, isInitialIngest } = await getRepositoryIndexInfo(
 		params.source,
@@ -55,6 +56,7 @@ export async function ingestGitHubBlobs(params: {
 		}),
 		embeddingProfileId: params.embeddingProfileId,
 		embeddingComplete: params.embeddingComplete,
+		headers: params.headers,
 	});
 
 	const result = await ingest();

apps/studio.giselles.ai/lib/vector-stores/github/ingest/issues/ingest-github-issues.ts

@@ -21,6 +21,7 @@ export async function ingestGitHubIssues(params: {
 	teamDbId: number;
 	embeddingProfileId: EmbeddingProfileId;
 	embeddingComplete?: EmbeddingCompleteCallback;
+	headers?: Record<string, string>;
 }): Promise<void> {
 	const { repositoryIndexDbId } = await getRepositoryIndexInfo(
 		params.source,
@@ -80,6 +81,7 @@ export async function ingestGitHubIssues(params: {
 		},
 		embeddingProfileId: params.embeddingProfileId,
 		embeddingComplete: params.embeddingComplete,
+		headers: params.headers,
 	});
 
 	const result = await ingest();

apps/studio.giselles.ai/lib/vector-stores/github/ingest/process-repository.ts

@@ -15,6 +15,7 @@ import {
 } from "@/db";
 import type { TeamWithSubscription } from "@/services/teams";
 import { fetchTeamByDbId } from "@/services/teams/fetch-team";
+import { buildAiGatewayHeaders } from "../../shared/ai-gateway-headers";
 import type { RepositoryWithStatuses } from "../types";
 import {
 	createBlobMetadata,
@@ -76,12 +77,15 @@ const CONTENT_PROCESSORS: Record<
 			},
 		});
 
+		const headers = buildAiGatewayHeaders(team);
+
 		await ingestGitHubBlobs({
 			octokitClient: octokit,
 			source: { owner, repo, commitSha: commit.sha },
 			teamDbId,
 			embeddingProfileId,
 			embeddingComplete,
+			headers,
 		});
 
 		return {
@@ -108,12 +112,15 @@ const CONTENT_PROCESSORS: Record<
 			},
 		});
 
+		const headers = buildAiGatewayHeaders(team);
+
 		await ingestGitHubPullRequests({
 			githubAuthConfig: buildGitHubAuthConfig(installationId),
 			source: { owner, repo },
 			teamDbId,
 			embeddingProfileId,
 			embeddingComplete,
+			headers,
 		});
 
 		const lastPrNumber = await getLastIngestedPrNumber(
@@ -144,12 +151,15 @@ const CONTENT_PROCESSORS: Record<
 			},
 		});
 
+		const headers = buildAiGatewayHeaders(team);
+
 		await ingestGitHubIssues({
 			githubAuthConfig: buildGitHubAuthConfig(installationId),
 			source: { owner, repo },
 			teamDbId,
 			embeddingProfileId,
 			embeddingComplete,
+			headers,
 		});
 
 		const lastIssueNumber = await getLastIngestedIssueNumber(

apps/studio.giselles.ai/lib/vector-stores/github/ingest/pull-requests/ingest-github-pull-requests.ts

@@ -26,6 +26,7 @@ export async function ingestGitHubPullRequests(params: {
 	teamDbId: number;
 	embeddingProfileId: EmbeddingProfileId;
 	embeddingComplete?: EmbeddingCompleteCallback;
+	headers?: Record<string, string>;
 }): Promise<void> {
 	const { repositoryIndexDbId } = await getRepositoryIndexInfo(
 		params.source,
@@ -59,6 +60,7 @@ export async function ingestGitHubPullRequests(params: {
 		}),
 		embeddingProfileId: params.embeddingProfileId,
 		embeddingComplete: params.embeddingComplete,
+		headers: params.headers,
 	});
 
 	const result = await ingest();

packages/rag/src/ingest/pipeline.ts

@@ -45,6 +45,9 @@ export interface IngestPipelineOptions<
 	parallelLimit?: number;
 	onProgress?: (progress: IngestProgress) => void;
 	onError?: (error: IngestError) => void;
+
+	// Optional headers for AI Gateway requests
+	headers?: Record<string, string>;
 }
 
 const DEFAULT_MAX_BATCH_SIZE = 100;
@@ -113,6 +116,7 @@ export function createPipeline<
 		{
 			embeddingComplete,
 			transport: useGateway ? "gateway" : "provider",
+			headers: useGateway ? options.headers : undefined,
 		},
 	);