Google Ads Attribution | blade47/dub Wiki | doc0

Public

GET(req) → googleAdsOAuthProvider.exchangeCodeForToken() → prisma.project.findUniqueOrThrow() → googleAdsAuthTokenSchema.parse() → GoogleAdsApi.listAccessibleCustomers() → prisma.installedIntegration.findFirst() → googleAdsSettingsSchema.parse() → installIntegration() → waitUntil(googleAdsInstalledWorkspaces.add()) → redirect()

Configuration Key	Value / Source	Purpose
`name`	`"Google Ads"`	Provider identifier used in error logging
`clientId`	`process.env.GOOGLE_ADS_CLIENT_ID!`	Google API OAuth client identifier
`clientSecret`	`process.env.GOOGLE_ADS_CLIENT_SECRET!`	Google API OAuth client secret
`authUrl`	`"https://accounts.google.com/o/oauth2/v2/auth"`	Initial user authorization endpoint
`tokenUrl`	`"https://oauth2.googleapis.com/token"`	Token exchange and refresh endpoint
`redirectUri`	`${APP_DOMAIN_WITH_NGROK}/api/google-ads/callback`	OAuth redirect callback URI
`redisStatePrefix`	`"google-ads:oauth:state"`	Redis key prefix for storing CSRF state
`bodyFormat`	`"form"`	Request payload format for token endpoints
`authorizationMethod`	`"body"`	Method for passing client credentials

Header Key	Source / Value	Purpose
`Authorization`	`Bearer ${accessToken}`	OAuth access token for authentication
`developer-token`	`process.env.GOOGLE_ADS_DEVELOPER_TOKEN!`	Google Ads developer token
`Content-Type`	`application/json`	Specifies JSON payload formatting
`login-customer-id`	`loginCustomerId` (hyphens removed)	Manager customer ID context when querying client accounts

Validation Check	Trigger Condition	Error Message / Outcome
Plan Capability	Workspace plan lacks advanced features	`"Google Ads integration is only available on Advanced and Enterprise plans."`
Installation Check	Integration record not found in database	`"Google Ads integration is not installed on your workspace."`
Customer Selection	`customerId` is missing while mappings are populated	`"A Google Ads account is required to configure conversion actions."`
Resource Prefix	Mapping `conversionAction` does not start with `customers/{id}/conversionActions/`	`"Invalid lead conversion action."` or `"Invalid sale conversion action."`
Event Uniqueness	Duplicate event names assigned across mappings	Handled by `getGoogleAdsEventMappingsError`

Payload Field	Source / Derivation	Fallback Value
`timestamp`	Explicit parameter or current ISO string	`new Date().toISOString()`
`identity_hash`	`getIdentityHash(req)`	`""`
`click_id`	Passed `clickId` parameter	`null` (aborts recording)
`ip`	`ipAddress(req)` (Vercel) or `LOCALHOST_IP`	`""` (omitted for EU countries)
`continent`	`x-vercel-ip-continent` header	`""`
`country`	`geolocation(req).country`	`"Unknown"`
`device`	Capitalized `ua.device.type`	`"Desktop"`
`referer`	`referrer` param or `referer` header	`"(direct)"`

waitUntil(
  (async () => {
    const response = await Promise.allSettled([
      fetchWithRetry(
        `${process.env.TINYBIRD_API_URL}/v0/events?name=dub_click_events&wait=true`,
        {
          method: "POST",
          headers: {
            Authorization: `Bearer ${process.env.TINYBIRD_API_KEY}`,
          },
          body: JSON.stringify(clickData),
        },
      ).then((res) => res.json()),
      recordClickCache.set({
        domain,
        key,
        identityHash,
        clickId,
      }),
      publishLinkClickEvent({
        linkId,
        timestamp: clickData.timestamp,
        ...(workspaceId && url && { workspaceId }),
        ...(programId && partnerId && { programId, partnerId }),
      }),
      publishWorkspaceClickEvent(clickData),
    ]);
  })(),
);

queueGoogleAdsConversionUpload({
  workspaceId: workspace.id,
  eventType: EventType.lead,
  eventId: leadData.event_id,
  eventName: leadData.event_name,
  conversionDateTime: new Date().toISOString(),
  conversionCount: 1,
  click: {
    id: clickData.click_id,
    url: clickData.url,
  },
})

Parameter	Type	Lead Workflow Source	Sale Workflow Source
`workspaceId`	`string`	`workspace.id`	`workspace.id`
`eventType`	`EventType`	`EventType.lead`	`EventType.sale`
`eventId`	`string`	`leadData.event_id`	`saleData.event_id`
`eventName`	`string`	`leadData.event_name`	`saleData.event_name`
`conversionDateTime`	`string`	`new Date().toISOString()`	`new Date().toISOString()`
`conversionCount`	`number`	`1`	Omitted
`conversionValue`	`number`	Omitted	`saleData.amount`
`currencyCode`	`string`	Omitted	`saleData.currency`
`click.id`	`string`	`clickData.click_id`	`saleData.click_id`
`click.url`	`string`	`clickData.url`	`saleData.url`

const response = await qstash.publishJSON({
  url: `${APP_DOMAIN_WITH_NGROK}/api/google-ads/upload-conversion`,
  body: payload,
  retries: 3,
  deduplicationId: `google-ads-${payload.workspaceId}-${payload.eventId}`,
});

export const POST = withCron(async ({ rawBody }) => {
  const payload = googleAdsConversionUploadSchema.parse(JSON.parse(rawBody));
  const { message, status } = await uploadGoogleAdsConversion(payload);
 
  if (status === "failed") {
    return logAndRespond(message, { status: 500, logLevel: "error" });
  }
 
  return logAndRespond(message, {
    logLevel: status === "skipped" ? "warn" : "info",
  });
});

Google Ads Attribution | blade47/dub Wiki | doc0