[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_155":156,"_157":158},"routes/_app.x.$handle.$name",{"_95":94,"_32":45,"_103":85,"_27":104,"_13":14,"_105":-5,"_11":106,"_107":108,"_109":110,"_111":112,"_113":114,"_20":-5,"_115":-5,"_116":-5,"_117":25,"_118":119,"_120":121,"_122":-5,"_123":-5,"_124":125},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":78,"_79":80,"_81":82,"_83":25},"version",20,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","ff4efd68-7c59-11f1-9a15-1607ee4eb77e","name","fileType","http","content","// Life Blood — Google Ads connector (READ + WRITE)\n// This REPLACES the existing read-only val. All existing GET behaviour\n// (default report, ?check=conversions, ?check=audit, ?check=creative)\n// is unchanged. New: POST for write actions.\n//\n// ── SAFETY MODEL ──────────────────────────────────────────────────────\n// This val will happily execute a budget change if asked. The actual\n// safeguard is behavioural: Lucy (Claude) is instructed to ALWAYS ask\n// Chris before calling action=update_budget or action=update_bid, and\n// never to send confirmed:true on those actions without his explicit\n// go-ahead in chat. As a second, technical layer, budget/bid mutations\n// in THIS val are hard-blocked unless the request body includes\n// \"confirmed\": true — so even an accidental/looped call fails safe.\n// Every other write action (assets, pause/enable, negatives) is\n// reversible and low-risk, so those run without the confirmed flag.\n//\n// All mutate calls support \"dryRun\": true, which sets Google Ads API\n// validate_only=true — it checks the request is valid and returns no\n// error, but makes no real change. Use this to test before going live.\n//\n// ── ACTIONS (POST body: { action, ...params }) ──────────────────────\n// add_asset_group_assets { assetGroupId, headlines?: string[], descriptions?: string[], longHeadlines?: string[] }\n// remove_asset_group_asset { assetGroupAssetResourceName }\n// pause_campaign { campaignId }\n// enable_campaign { campaignId }\n// pause_ad_group { adGroupId }\n// enable_ad_group { adGroupId }\n// add_negative_keyword { campaignId, text, matchType? } // matchType: EXACT|PHRASE|BROAD, default PHRASE\n// update_budget { campaignBudgetId, amountMicros, confirmed: true }\n// update_bid { adGroupId, cpcBidMicros, confirmed: true }\n// update_conversion_action { conversionActionId, primaryForGoal?, includeInConversionsMetric?, status?, confirmed: true }\n//\n// All actions accept optional \"dryRun\": true.\n\nconst API_VERSION = \"v24\";\nconst env = (k: string) => Deno.env.get(k);\n\nasync function getAccessToken(): Promise {\n const tokenRes = await fetch(\"https://oauth2.googleapis.com/token\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n body: new URLSearchParams({\n client_id: env(\"GOOGLE_ADS_CLIENT_ID\")!,\n client_secret: env(\"GOOGLE_ADS_CLIENT_SECRET\")!,\n refresh_token: env(\"GOOGLE_ADS_REFRESH_TOKEN\")!,\n grant_type: \"refresh_token\",\n }),\n });\n if (!tokenRes.ok) {\n throw new Error(`Token refresh failed: ${await tokenRes.text()}`);\n }\n const { access_token } = await tokenRes.json();\n return access_token;\n}\n\nasync function gaqlSearch(\n customerId: string,\n headers: Record,\n query: string,\n) {\n const res = await fetch(\n `https://googleads.googleapis.com/${API_VERSION}/customers/${customerId}/googleAds:search`,\n { method: \"POST\", headers, body: JSON.stringify({ query }) },\n );\n const data = await res.json();\n if (!res.ok) {\n throw new Error(`GAQL query failed: ${JSON.stringify(data)}`);\n }\n return data.results || [];\n}\n\nasync function mutate(\n customerId: string,\n headers: Record,\n service: string,\n operations: unknown[],\n dryRun: boolean,\n) {\n const res = await fetch(\n `https://googleads.googleapis.com/${API_VERSION}/customers/${customerId}/${service}:mutate`,\n {\n method: \"POST\",\n headers,\n body: JSON.stringify({\n operations,\n validate_only: !!dryRun,\n }),\n },\n );\n const data = await res.json();\n if (!res.ok) {\n throw new Error(`${service} mutate failed: ${JSON.stringify(data)}`);\n }\n return data;\n}\n\nexport default async function (req: Request): Promise {\n const need = [\n \"GOOGLE_ADS_DEVELOPER_TOKEN\",\n \"GOOGLE_ADS_CLIENT_ID\",\n \"GOOGLE_ADS_CLIENT_SECRET\",\n \"GOOGLE_ADS_REFRESH_TOKEN\",\n \"GOOGLE_ADS_CUSTOMER_ID\",\n ];\n const missing = need.filter((k) => !env(k));\n if (missing.length) {\n return Response.json({\n status: \"Connector is set up and waiting for credentials.\",\n missing,\n });\n }\n\n const customerId = env(\"GOOGLE_ADS_CUSTOMER_ID\")!.replace(/-/g, \"\");\n const loginCustomerId = (env(\"GOOGLE_ADS_LOGIN_CUSTOMER_ID\") || \"\").replace(\n /-/g,\n \"\",\n );\n\n let access_token: string;\n try {\n access_token = await getAccessToken();\n } catch (e) {\n return Response.json({ error: String(e) }, { status: 500 });\n }\n\n const headers: Record = {\n Authorization: `Bearer ${access_token}`,\n \"developer-token\": env(\"GOOGLE_ADS_DEVELOPER_TOKEN\")!,\n \"Content-Type\": \"application/json\",\n };\n if (loginCustomerId) headers[\"login-customer-id\"] = loginCustomerId;\n\n // ── WRITE PATH ──────────────────────────────────────────────────\n if (req.method === \"POST\") {\n let body: any;\n try {\n body = await req.json();\n } catch {\n return Response.json({ error: \"Body must be JSON.\" }, { status: 400 });\n }\n const { action, dryRun } = body;\n\n try {\n switch (action) {\n case \"add_asset_group_assets\": {\n const {\n assetGroupId,\n headlines = [],\n descriptions = [],\n longHeadlines = [],\n } = body;\n if (!assetGroupId) {\n return Response.json({ error: \"assetGroupId required\" }, {\n status: 400,\n });\n }\n const assetGroupResourceName =\n `customers/${customerId}/assetGroups/${assetGroupId}`;\n\n // Step 1: create the text assets.\n const textOps: any[] = [];\n const plan: { fieldType: string; tempId: number }[] = [];\n let tempId = -1;\n for (const text of headlines) {\n textOps.push({\n create: {\n resource_name: `customers/${customerId}/assets/${tempId}`,\n text_asset: { text },\n },\n });\n plan.push({ fieldType: \"HEADLINE\", tempId });\n tempId--;\n }\n for (const text of descriptions) {\n textOps.push({\n create: {\n resource_name: `customers/${customerId}/assets/${tempId}`,\n text_asset: { text },\n },\n });\n plan.push({ fieldType: \"DESCRIPTION\", tempId });\n tempId--;\n }\n for (const text of longHeadlines) {\n textOps.push({\n create: {\n resource_name: `customers/${customerId}/assets/${tempId}`,\n text_asset: { text },\n },\n });\n plan.push({ fieldType: \"LONG_HEADLINE\", tempId });\n tempId--;\n }\n if (!textOps.length) {\n return Response.json({\n error:\n \"Provide at least one of headlines / descriptions / longHeadlines\",\n }, { status: 400 });\n }\n\n const assetResult = await mutate(\n customerId,\n headers,\n \"assets\",\n textOps,\n dryRun,\n );\n\n if (dryRun) {\n return Response.json({\n action,\n dryRun: true,\n wouldCreate: plan.length,\n note: \"validate_only=true, nothing was created\",\n });\n }\n\n const createdResourceNames: string[] = assetResult.results.map((\n r: any,\n ) => r.resourceName);\n\n // Step 2: link each new asset into the asset group.\n const linkOps = createdResourceNames.map((rn: string, i: number) => ({\n create: {\n asset_group: assetGroupResourceName,\n asset: rn,\n field_type: plan[i].fieldType,\n },\n }));\n const linkResult = await mutate(\n customerId,\n headers,\n \"assetGroupAssets\",\n linkOps,\n false,\n );\n\n return Response.json({\n action,\n assetGroupId,\n created: linkResult.results.map((r: any) => r.resourceName),\n });\n }\n\n case \"remove_asset_group_asset\": {\n const { assetGroupAssetResourceName } = body;\n if (!assetGroupAssetResourceName) {\n return Response.json({\n error: \"assetGroupAssetResourceName required\",\n }, { status: 400 });\n }\n const result = await mutate(\n customerId,\n headers,\n \"assetGroupAssets\",\n [{ remove: assetGroupAssetResourceName }],\n dryRun,\n );\n return Response.json({ action, dryRun: !!dryRun, result });\n }\n\n case \"pause_campaign\":\n case \"enable_campaign\": {\n const { campaignId } = body;\n if (!campaignId) {\n return Response.json({ error: \"campaignId required\" }, {\n status: 400,\n });\n }\n const status = action === \"pause_campaign\" ? \"PAUSED\" : \"ENABLED\";\n const result = await mutate(\n customerId,\n headers,\n \"campaigns\",\n [{\n update: {\n resource_name:\n `customers/${customerId}/campaigns/${campaignId}`,\n status,\n },\n update_mask: \"status\",\n }],\n dryRun,\n );\n return Response.json({\n action,\n campaignId,\n status,\n dryRun: !!dryRun,\n result,\n });\n }\n\n case \"pause_ad_group\":\n case \"enable_ad_group\": {\n const { adGroupId } = body;\n if (!adGroupId) {\n return Response.json({ error: \"adGroupId required\" }, {\n status: 400,\n });\n }\n const status = action === \"pause_ad_group\" ? \"PAUSED\" : \"ENABLED\";\n const result = await mutate(\n customerId,\n headers,\n \"adGroups\",\n [{\n update: {\n resource_name: `customers/${customerId}/adGroups/${adGroupId}`,\n status,\n },\n update_mask: \"status\",\n }],\n dryRun,\n );\n return Response.json({\n action,\n adGroupId,\n status,\n dryRun: !!dryRun,\n result,\n });\n }\n\n case \"add_negative_keyword\": {\n const { campaignId, text, matchType = \"PHRASE\" } = body;\n if (!campaignId || !text) {\n return Response.json({ error: \"campaignId and text required\" }, {\n status: 400,\n });\n }\n const result = await mutate(\n customerId,\n headers,\n \"campaignCriteria\",\n [{\n create: {\n campaign: `customers/${customerId}/campaigns/${campaignId}`,\n negative: true,\n keyword: { text, match_type: matchType },\n },\n }],\n dryRun,\n );\n return Response.json({\n action,\n campaignId,\n text,\n matchType,\n dryRun: !!dryRun,\n result,\n });\n }\n\n // ── BUDGET / BID — hard-gated, requires confirmed:true ──────\n case \"update_budget\": {\n const { campaignBudgetId, amountMicros, confirmed } = body;\n if (!confirmed) {\n return Response.json({\n error:\n \"Budget changes require confirmed:true. This is a deliberate safeguard — Chris must approve budget changes before this is called.\",\n }, { status: 403 });\n }\n if (!campaignBudgetId || !amountMicros) {\n return Response.json({\n error: \"campaignBudgetId and amountMicros required\",\n }, { status: 400 });\n }\n const result = await mutate(\n customerId,\n headers,\n \"campaignBudgets\",\n [{\n update: {\n resource_name:\n `customers/${customerId}/campaignBudgets/${campaignBudgetId}`,\n amount_micros: amountMicros,\n },\n update_mask: \"amount_micros\",\n }],\n dryRun,\n );\n return Response.json({\n action,\n campaignBudgetId,\n amountMicros,\n dryRun: !!dryRun,\n result,\n });\n }\n\n case \"update_bid\": {\n const { adGroupId, cpcBidMicros, confirmed } = body;\n if (!confirmed) {\n return Response.json({\n error:\n \"Bid changes require confirmed:true. This is a deliberate safeguard — Chris must approve bid changes before this is called.\",\n }, { status: 403 });\n }\n if (!adGroupId || !cpcBidMicros) {\n return Response.json({\n error: \"adGroupId and cpcBidMicros required\",\n }, { status: 400 });\n }\n const result = await mutate(\n customerId,\n headers,\n \"adGroups\",\n [{\n update: {\n resource_name: `customers/${customerId}/adGroups/${adGroupId}`,\n cpc_bid_micros: cpcBidMicros,\n },\n update_mask: \"cpc_bid_micros\",\n }],\n dryRun,\n );\n return Response.json({\n action,\n adGroupId,\n cpcBidMicros,\n dryRun: !!dryRun,\n result,\n });\n }\n\n // ── CONVERSION GOALS — hard-gated, requires confirmed:true ──\n // Changes what \"counts\" toward Maximize Conversions / Target CPA / Target\n // ROAS bidding. Same blast radius as a budget or bid change (it can\n // silently redirect the whole account's optimisation target), so it gets\n // the same safeguard: refused unless the request includes confirmed:true.\n case \"update_conversion_action\": {\n const {\n conversionActionId,\n primaryForGoal,\n includeInConversionsMetric,\n status,\n confirmed,\n } = body;\n if (!confirmed) {\n return Response.json({\n error:\n \"Conversion action changes require confirmed:true. This is a deliberate safeguard — Chris must approve changes to what counts as a conversion before this is called.\",\n }, { status: 403 });\n }\n if (!conversionActionId) {\n return Response.json({ error: \"conversionActionId required\" }, {\n status: 400,\n });\n }\n const update: Record = {\n resource_name:\n `customers/${customerId}/conversionActions/${conversionActionId}`,\n };\n const maskFields: string[] = [];\n if (typeof primaryForGoal === \"boolean\") {\n update.primary_for_goal = primaryForGoal;\n maskFields.push(\"primary_for_goal\");\n }\n if (typeof includeInConversionsMetric === \"boolean\") {\n update.include_in_conversions_metric = includeInConversionsMetric;\n maskFields.push(\"include_in_conversions_metric\");\n }\n if (status) {\n update.status = status; // ENABLED | REMOVED | HIDDEN\n maskFields.push(\"status\");\n }\n if (!maskFields.length) {\n return Response.json({\n error:\n \"Provide at least one of primaryForGoal, includeInConversionsMetric, status\",\n }, { status: 400 });\n }\n const result = await mutate(\n customerId,\n headers,\n \"conversionActions\",\n [{ update, update_mask: maskFields.join(\",\") }],\n dryRun,\n );\n return Response.json({\n action,\n conversionActionId,\n changed: maskFields,\n dryRun: !!dryRun,\n result,\n });\n }\n\n default:\n return Response.json({\n error: `Unknown action \"${action}\".`,\n validActions: [\n \"add_asset_group_assets\",\n \"remove_asset_group_asset\",\n \"pause_campaign\",\n \"enable_campaign\",\n \"pause_ad_group\",\n \"enable_ad_group\",\n \"add_negative_keyword\",\n \"update_budget (needs confirmed:true)\",\n \"update_bid (needs confirmed:true)\",\n \"update_conversion_action (needs confirmed:true)\",\n ],\n }, { status: 400 });\n }\n } catch (e) {\n return Response.json({ error: String(e) }, { status: 500 });\n }\n }\n\n // ── READ PATH (unchanged from the existing val) ────────────────\n const url = new URL(req.url);\n const mode = url.searchParams.get(\"check\");\n try {\n if (mode === \"goals\") {\n const results = await gaqlSearch(\n customerId,\n headers,\n `SELECT campaign.id, campaign.name,\n campaign_conversion_goal.category, campaign_conversion_goal.origin,\n campaign_conversion_goal.biddable\n FROM campaign_conversion_goal\n WHERE campaign.status = 'ENABLED'`,\n ).catch(() => []);\n const custResults = await gaqlSearch(\n customerId,\n headers,\n `SELECT customer_conversion_goal.category, customer_conversion_goal.origin,\n customer_conversion_goal.biddable\n FROM customer_conversion_goal`,\n ).catch(() => []);\n return Response.json({\n check: \"goals\",\n campaignConversionGoals: results.map((r: any) => ({\n campaign: r.campaign?.name,\n category: r.campaignConversionGoal?.category,\n origin: r.campaignConversionGoal?.origin,\n biddable: r.campaignConversionGoal?.biddable,\n })),\n customerConversionGoals: custResults.map((r: any) => ({\n category: r.customerConversionGoal?.category,\n origin: r.customerConversionGoal?.origin,\n biddable: r.customerConversionGoal?.biddable,\n })),\n });\n }\n\n if (mode === \"conversions\") {\n const results = await gaqlSearch(\n customerId,\n headers,\n `SELECT conversion_action.id, conversion_action.resource_name,\n conversion_action.name, conversion_action.status,\n conversion_action.type, conversion_action.category,\n conversion_action.origin, conversion_action.primary_for_goal,\n conversion_action.include_in_conversions_metric\n FROM conversion_action\n ORDER BY conversion_action.name`,\n );\n const actions = results.map((r: any) => ({\n id: r.conversionAction?.id,\n resourceName: r.conversionAction?.resourceName,\n name: r.conversionAction?.name,\n status: r.conversionAction?.status,\n type: r.conversionAction?.type,\n category: r.conversionAction?.category,\n origin: r.conversionAction?.origin,\n // primaryForGoal / includeInConversionsMetric together control whether this\n // action counts toward the \"Conversions\" column that Maximize Conversions /\n // Target CPA / Target ROAS bid strategies actually optimise against.\n primaryForGoal: r.conversionAction?.primaryForGoal,\n includeInConversionsMetric: r.conversionAction\n ?.includeInConversionsMetric,\n }));\n return Response.json({\n check: \"conversion_tracking\",\n found: actions.length,\n actions,\n });\n }\n\n if (mode === \"audit\") {\n const [\n campaigns,\n adGroups,\n keywords,\n ads,\n negatives,\n locations,\n languages,\n networks,\n ] = await Promise.all([\n gaqlSearch(\n customerId,\n headers,\n `SELECT campaign.id, campaign.name, campaign.status,\n campaign.advertising_channel_type, campaign.advertising_channel_sub_type,\n campaign.bidding_strategy_type,\n campaign.target_cpa.target_cpa_micros,\n campaign.target_roas.target_roas,\n campaign.maximize_conversions.target_cpa_micros,\n campaign_budget.id, campaign_budget.amount_micros, campaign_budget.delivery_method,\n campaign_budget.period,\n metrics.impressions, metrics.clicks, metrics.cost_micros,\n metrics.conversions, metrics.ctr, metrics.average_cpc,\n metrics.search_impression_share, metrics.search_budget_lost_impression_share,\n metrics.search_rank_lost_impression_share\n FROM campaign\n WHERE segments.date DURING LAST_30_DAYS`,\n ),\n gaqlSearch(\n customerId,\n headers,\n `SELECT ad_group.id, ad_group.name, ad_group.status, ad_group.type,\n ad_group.cpc_bid_micros, campaign.name,\n metrics.impressions, metrics.clicks, metrics.cost_micros\n FROM ad_group\n WHERE segments.date DURING LAST_30_DAYS`,\n ),\n gaqlSearch(\n customerId,\n headers,\n `SELECT ad_group_criterion.keyword.text, ad_group_criterion.keyword.match_type,\n ad_group_criterion.status, ad_group_criterion.quality_info.quality_score,\n ad_group_criterion.approval_status, ad_group.name,\n metrics.impressions, metrics.clicks, metrics.cost_micros\n FROM keyword_view\n WHERE segments.date DURING LAST_30_DAYS`,\n ).catch(() => []),\n gaqlSearch(\n customerId,\n headers,\n `SELECT ad_group_ad.ad.id, ad_group_ad.status,\n ad_group_ad.policy_summary.approval_status,\n ad_group_ad.ad.type, ad_group.name,\n ad_group_ad.ad.final_urls,\n metrics.impressions, metrics.clicks\n FROM ad_group_ad\n WHERE segments.date DURING LAST_30_DAYS`,\n ),\n gaqlSearch(\n customerId,\n headers,\n `SELECT campaign_criterion.keyword.text, campaign_criterion.negative,\n campaign.name\n FROM campaign_criterion\n WHERE campaign_criterion.type = 'KEYWORD'`,\n ).catch(() => []),\n gaqlSearch(\n customerId,\n headers,\n `SELECT campaign_criterion.location.geo_target_constant, campaign.name,\n campaign_criterion.negative\n FROM campaign_criterion\n WHERE campaign_criterion.type = 'LOCATION'`,\n ).catch(() => []),\n gaqlSearch(\n customerId,\n headers,\n `SELECT campaign_criterion.language.language_constant, campaign.name\n FROM campaign_criterion\n WHERE campaign_criterion.type = 'LANGUAGE'`,\n ).catch(() => []),\n gaqlSearch(\n customerId,\n headers,\n `SELECT campaign.name, campaign.network_settings.target_google_search,\n campaign.network_settings.target_search_network,\n campaign.network_settings.target_content_network,\n campaign.network_settings.target_partner_search_network\n FROM campaign`,\n ).catch(() => []),\n ]);\n return Response.json({\n check: \"campaign_audit\",\n campaigns: campaigns.map((r: any) => ({\n id: r.campaign?.id,\n name: r.campaign?.name,\n status: r.campaign?.status,\n channelType: r.campaign?.advertisingChannelType,\n channelSubType: r.campaign?.advertisingChannelSubType,\n biddingStrategyType: r.campaign?.biddingStrategyType,\n targetCpaMicros: r.campaign?.targetCpa?.targetCpaMicros,\n targetRoas: r.campaign?.targetRoas?.targetRoas,\n maximizeConversionsTargetCpaMicros: r.campaign?.maximizeConversions\n ?.targetCpaMicros,\n budgetId: r.campaignBudget?.id,\n budgetMicros: r.campaignBudget?.amountMicros,\n budgetDeliveryMethod: r.campaignBudget?.deliveryMethod,\n budgetPeriod: r.campaignBudget?.period,\n impressions: r.metrics?.impressions,\n clicks: r.metrics?.clicks,\n costMicros: r.metrics?.costMicros,\n conversions: r.metrics?.conversions,\n ctr: r.metrics?.ctr,\n avgCpcMicros: r.metrics?.averageCpc,\n searchImpressionShare: r.metrics?.searchImpressionShare,\n searchBudgetLostIS: r.metrics?.searchBudgetLostImpressionShare,\n searchRankLostIS: r.metrics?.searchRankLostImpressionShare,\n })),\n adGroups: adGroups.map((r: any) => ({\n id: r.adGroup?.id,\n campaign: r.campaign?.name,\n name: r.adGroup?.name,\n status: r.adGroup?.status,\n type: r.adGroup?.type,\n cpcBidMicros: r.adGroup?.cpcBidMicros,\n impressions: r.metrics?.impressions,\n clicks: r.metrics?.clicks,\n costMicros: r.metrics?.costMicros,\n })),\n keywords: keywords.map((r: any) => ({\n adGroup: r.adGroup?.name,\n text: r.adGroupCriterion?.keyword?.text,\n matchType: r.adGroupCriterion?.keyword?.matchType,\n status: r.adGroupCriterion?.status,\n qualityScore: r.adGroupCriterion?.qualityInfo?.qualityScore,\n approvalStatus: r.adGroupCriterion?.approvalStatus,\n impressions: r.metrics?.impressions,\n clicks: r.metrics?.clicks,\n costMicros: r.metrics?.costMicros,\n })),\n ads: ads.map((r: any) => ({\n adGroup: r.adGroup?.name,\n adId: r.adGroupAd?.ad?.id,\n status: r.adGroupAd?.status,\n approvalStatus: r.adGroupAd?.policySummary?.approvalStatus,\n type: r.adGroupAd?.ad?.type,\n finalUrls: r.adGroupAd?.ad?.finalUrls,\n impressions: r.metrics?.impressions,\n clicks: r.metrics?.clicks,\n })),\n negativeKeywords: negatives\n .filter((r: any) => r.campaignCriterion?.negative)\n .map((r: any) => ({\n campaign: r.campaign?.name,\n text: r.campaignCriterion?.keyword?.text,\n })),\n locationTargets: locations.map((r: any) => ({\n campaign: r.campaign?.name,\n geoTargetConstant: r.campaignCriterion?.location?.geoTargetConstant,\n negative: r.campaignCriterion?.negative,\n })),\n languageTargets: languages.map((r: any) => ({\n campaign: r.campaign?.name,\n languageConstant: r.campaignCriterion?.language?.languageConstant,\n })),\n networkSettings: networks.map((r: any) => ({\n campaign: r.campaign?.name,\n targetGoogleSearch: r.campaign?.networkSettings?.targetGoogleSearch,\n targetSearchNetwork: r.campaign?.networkSettings?.targetSearchNetwork,\n targetContentNetwork: r.campaign?.networkSettings\n ?.targetContentNetwork,\n targetPartnerSearchNetwork: r.campaign?.networkSettings\n ?.targetPartnerSearchNetwork,\n })),\n });\n }\n\n if (mode === \"creative\") {\n const [assetGroups, assetGroupAssets, audienceSignals] = await Promise\n .all([\n gaqlSearch(\n customerId,\n headers,\n `SELECT asset_group.id, asset_group.name, asset_group.status,\n asset_group.ad_strength, campaign.name\n FROM asset_group`,\n ),\n gaqlSearch(\n customerId,\n headers,\n `SELECT asset_group_asset.resource_name, asset_group_asset.field_type, asset_group_asset.status,\n asset.type, asset.text_asset.text,\n asset.image_asset.full_size.url,\n asset.youtube_video_asset.youtube_video_id,\n asset_group.name, campaign.name\n FROM asset_group_asset`,\n ),\n gaqlSearch(\n customerId,\n headers,\n `SELECT asset_group_signal.audience.audience,\n asset_group_signal.search_theme.text,\n asset_group.name, campaign.name\n FROM asset_group_signal`,\n ).catch(() => []),\n ]);\n return Response.json({\n check: \"creative\",\n assetGroups: assetGroups.map((r: any) => ({\n id: r.assetGroup?.id,\n campaign: r.campaign?.name,\n name: r.assetGroup?.name,\n status: r.assetGroup?.status,\n adStrength: r.assetGroup?.adStrength,\n })),\n assets: assetGroupAssets.map((r: any) => ({\n resourceName: r.assetGroupAsset?.resourceName,\n campaign: r.campaign?.name,\n assetGroup: r.assetGroup?.name,\n fieldType: r.assetGroupAsset?.fieldType,\n status: r.assetGroupAsset?.status,\n assetType: r.asset?.type,\n text: r.asset?.textAsset?.text,\n imageUrl: r.asset?.imageAsset?.fullSize?.url,\n youtubeVideoId: r.asset?.youtubeVideoAsset?.youtubeVideoId,\n })),\n audienceSignals: audienceSignals.map((r: any) => ({\n campaign: r.campaign?.name,\n assetGroup: r.assetGroup?.name,\n audience: r.assetGroupSignal?.audience?.audience,\n searchTheme: r.assetGroupSignal?.searchTheme?.text,\n })),\n });\n }\n\n // Default: campaign performance\n const rows = await gaqlSearch(\n customerId,\n headers,\n `SELECT campaign.name, campaign.status, metrics.impressions, metrics.clicks,\n metrics.cost_micros, metrics.conversions, metrics.conversions_value\n FROM campaign\n WHERE segments.date DURING LAST_30_DAYS\n ORDER BY metrics.cost_micros DESC`,\n );\n const campaigns = rows.map((r: any) => ({\n campaign: r.campaign?.name,\n status: r.campaign?.status,\n impressions: Number(r.metrics?.impressions || 0),\n clicks: Number(r.metrics?.clicks || 0),\n cost: Math.round((Number(r.metrics?.costMicros || 0) / 1e6) * 100) / 100,\n conversions: Number(r.metrics?.conversions || 0),\n conversionsValue: Number(r.metrics?.conversionsValue || 0),\n }));\n const totals = campaigns.reduce((a: any, r: any) => ({\n impressions: a.impressions + r.impressions,\n clicks: a.clicks + r.clicks,\n cost: Math.round((a.cost + r.cost) * 100) / 100,\n conversions: a.conversions + r.conversions,\n }), { impressions: 0, clicks: 0, cost: 0, conversions: 0 });\n return Response.json({ range: \"last_30_days\", totals, campaigns });\n } catch (e) {\n return Response.json({ error: String(e) }, { status: 500 });\n }\n}","// Life Blood — Google Ads connector (READ + WRITE)\n// This REPLACES the existing read-only val. All existing GET behaviour\n// (default report, ?check=conversions, ?check=audit, ?check=creative)\n// is unchanged. New: POST for write actions.\n//\n// ── SAFETY MODEL ──────────────────────────────────────────────────────\n// This val will happily execute a budget change if asked. The actual\n// safeguard is behavioural: Lucy (Claude) is instructed to ALWAYS ask\n// Chris before calling action=update_budget or action=update_bid, and\n// never to send confirmed:true on those actions without his explicit\n// go-ahead in chat. As a second, technical layer, budget/bid mutations\n// in THIS val are hard-blocked unless the request body includes\n// \"confirmed\": true — so even an accidental/looped call fails safe.\n// Every other write action (assets, pause/enable, negatives) is\n// reversible and low-risk, so those run without the confirmed flag.\n//\n// All mutate calls support \"dryRun\": true, which sets Google Ads API\n// validate_only=true — it checks the request is valid and returns no\n// error, but makes no real change. Use this to test before going live.\n//\n// ── ACTIONS (POST body: { action, ...params }) ──────────────────────\n// add_asset_group_assets { assetGroupId, headlines?: string[], descriptions?: string[], longHeadlines?: string[] }\n// remove_asset_group_asset { assetGroupAssetResourceName }\n// pause_campaign { campaignId }\n// enable_campaign { campaignId }\n// pause_ad_group { adGroupId }\n// enable_ad_group { adGroupId }\n// add_negative_keyword { campaignId, text, matchType? } // matchType: EXACT|PHRASE|BROAD, default PHRASE\n// update_budget { campaignBudgetId, amountMicros, confirmed: true }\n// update_bid { adGroupId, cpcBidMicros, confirmed: true }\n// update_conversion_action { conversionActionId, primaryForGoal?, includeInConversionsMetric?, status?, confirmed: true }\n//\n// All actions accept optional \"dryRun\": true.\n\nconst API_VERSION = \"v24\";\nconst env = (k: string) => Deno.env.get(k);\n\nasync function getAccessToken(): Promise {\n const tokenRes = await fetch(\"https://oauth2.googleapis.com/token\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n body: new URLSearchParams({\n client_id: env(\"GOOGLE_ADS_CLIENT_ID\")!,\n client_secret: env(\"GOOGLE_ADS_CLIENT_SECRET\")!,\n refresh_token: env(\"GOOGLE_ADS_REFRESH_TOKEN\")!,\n grant_type: \"refresh_token\",\n }),\n });\n if (!tokenRes.ok) {\n throw new Error(`Token refresh failed: ${await tokenRes.text()}`);\n }\n const { access_token } = await tokenRes.json();\n return access_token;\n}\n\nasync function gaqlSearch(\n customerId: string,\n headers: Record,\n query: string,\n) {\n const res = await fetch(\n `https://googleads.googleapis.com/${API_VERSION}/customers/${customerId}/googleAds:search`,\n { method: \"POST\", headers, body: JSON.stringify({ query }) },\n );\n const data = await res.json();\n if (!res.ok) {\n throw new Error(`GAQL query failed: ${JSON.stringify(data)}`);\n }\n return data.results || [];\n}\n\nasync function mutate(\n customerId: string,\n headers: Record,\n service: string,\n operations: unknown[],\n dryRun: boolean,\n) {\n const res = await fetch(\n `https://googleads.googleapis.com/${API_VERSION}/customers/${customerId}/${service}:mutate`,\n {\n method: \"POST\",\n headers,\n body: JSON.stringify({\n operations,\n validate_only: !!dryRun,\n }),\n },\n );\n const data = await res.json();\n if (!res.ok) {\n throw new Error(`${service} mutate failed: ${JSON.stringify(data)}`);\n }\n return data;\n}\n\nexport default async function (req: Request): Promise {\n const need = [\n \"GOOGLE_ADS_DEVELOPER_TOKEN\",\n \"GOOGLE_ADS_CLIENT_ID\",\n \"GOOGLE_ADS_CLIENT_SECRET\",\n \"GOOGLE_ADS_REFRESH_TOKEN\",\n \"GOOGLE_ADS_CUSTOMER_ID\",\n ];\n const missing = need.filter((k) => !env(k));\n if (missing.length) {\n return Response.json({\n status: \"Connector is set up and waiting for credentials.\",\n missing,\n });\n }\n\n const customerId = env(\"GOOGLE_ADS_CUSTOMER_ID\")!.replace(/-/g, \"\");\n const loginCustomerId = (env(\"GOOGLE_ADS_LOGIN_CUSTOMER_ID\") || \"\").replace(\n /-/g,\n \"\",\n );\n\n let access_token: string;\n try {\n access_token = await getAccessToken();\n } catch (e) {\n return Response.json({ error: String(e) }, { status: 500 });\n }\n\n const headers: Record = {\n Authorization: `Bearer ${access_token}`,\n \"developer-token\": env(\"GOOGLE_ADS_DEVELOPER_TOKEN\")!,\n \"Content-Type\": \"application/json\",\n };\n if (loginCustomerId) headers[\"login-customer-id\"] = loginCustomerId;\n\n // ── WRITE PATH ──────────────────────────────────────────────────\n if (req.method === \"POST\") {\n let body: any;\n try {\n body = await req.json();\n } catch {\n return Response.json({ error: \"Body must be JSON.\" }, { status: 400 });\n }\n const { action, dryRun } = body;\n\n try {\n switch (action) {\n case \"add_asset_group_assets\": {\n const {\n assetGroupId,\n headlines = [],\n descriptions = [],\n longHeadlines = [],\n } = body;\n if (!assetGroupId) {\n return Response.json({ error: \"assetGroupId required\" }, {\n status: 400,\n });\n }\n const assetGroupResourceName =\n `customers/${customerId}/assetGroups/${assetGroupId}`;\n\n // Step 1: create the text assets.\n const textOps: any[] = [];\n const plan: { fieldType: string; tempId: number }[] = [];\n let tempId = -1;\n for (const text of headlines) {\n textOps.push({\n create: {\n resource_name: `customers/${customerId}/assets/${tempId}`,\n text_asset: { text },\n },\n });\n plan.push({ fieldType: \"HEADLINE\", tempId });\n tempId--;\n }\n for (const text of descriptions) {\n textOps.push({\n create: {\n resource_name: `customers/${customerId}/assets/${tempId}`,\n text_asset: { text },\n },\n });\n plan.push({ fieldType: \"DESCRIPTION\", tempId });\n tempId--;\n }\n for (const text of longHeadlines) {\n textOps.push({\n create: {\n resource_name: `customers/${customerId}/assets/${tempId}`,\n text_asset: { text },\n },\n });\n plan.push({ fieldType: \"LONG_HEADLINE\", tempId });\n tempId--;\n }\n if (!textOps.length) {\n return Response.json({\n error:\n \"Provide at least one of headlines / descriptions / longHeadlines\",\n }, { status: 400 });\n }\n\n const assetResult = await mutate(\n customerId,\n headers,\n \"assets\",\n textOps,\n dryRun,\n );\n\n if (dryRun) {\n return Response.json({\n action,\n dryRun: true,\n wouldCreate: plan.length,\n note: \"validate_only=true, nothing was created\",\n });\n }\n\n const createdResourceNames: string[] = assetResult.results.map((\n r: any,\n ) => r.resourceName);\n\n // Step 2: link each new asset into the asset group.\n const linkOps = createdResourceNames.map((rn: string, i: number) => ({\n create: {\n asset_group: assetGroupResourceName,\n asset: rn,\n field_type: plan[i].fieldType,\n },\n }));\n const linkResult = await mutate(\n customerId,\n headers,\n \"assetGroupAssets\",\n linkOps,\n false,\n );\n\n return Response.json({\n action,\n assetGroupId,\n created: linkResult.results.map((r: any) => r.resourceName),\n });\n }\n\n case \"remove_asset_group_asset\": {\n const { assetGroupAssetResourceName } = body;\n if (!assetGroupAssetResourceName) {\n return Response.json({\n error: \"assetGroupAssetResourceName required\",\n }, { status: 400 });\n }\n const result = await mutate(\n customerId,\n headers,\n \"assetGroupAssets\",\n [{ remove: assetGroupAssetResourceName }],\n dryRun,\n );\n return Response.json({ action, dryRun: !!dryRun, result });\n }\n\n case \"pause_campaign\":\n case \"enable_campaign\": {\n const { campaignId } = body;\n if (!campaignId) {\n return Response.json({ error: \"campaignId required\" }, {\n status: 400,\n });\n }\n const status = action === \"pause_campaign\" ? \"PAUSED\" : \"ENABLED\";\n const result = await mutate(\n customerId,\n headers,\n \"campaigns\",\n [{\n update: {\n resource_name:\n `customers/${customerId}/campaigns/${campaignId}`,\n status,\n },\n update_mask: \"status\",\n }],\n dryRun,\n );\n return Response.json({\n action,\n campaignId,\n status,\n dryRun: !!dryRun,\n result,\n });\n }\n\n case \"pause_ad_group\":\n case \"enable_ad_group\": {\n const { adGroupId } = body;\n if (!adGroupId) {\n return Response.json({ error: \"adGroupId required\" }, {\n status: 400,\n });\n }\n const status = action === \"pause_ad_group\" ? \"PAUSED\" : \"ENABLED\";\n const result = await mutate(\n customerId,\n headers,\n \"adGroups\",\n [{\n update: {\n resource_name: `customers/${customerId}/adGroups/${adGroupId}`,\n status,\n },\n update_mask: \"status\",\n }],\n dryRun,\n );\n return Response.json({\n action,\n adGroupId,\n status,\n dryRun: !!dryRun,\n result,\n });\n }\n\n case \"add_negative_keyword\": {\n const { campaignId, text, matchType = \"PHRASE\" } = body;\n if (!campaignId || !text) {\n return Response.json({ error: \"campaignId and text required\" }, {\n status: 400,\n });\n }\n const result = await mutate(\n customerId,\n headers,\n \"campaignCriteria\",\n [{\n create: {\n campaign: `customers/${customerId}/campaigns/${campaignId}`,\n negative: true,\n keyword: { text, match_type: matchType },\n },\n }],\n dryRun,\n );\n return Response.json({\n action,\n campaignId,\n text,\n matchType,\n dryRun: !!dryRun,\n result,\n });\n }\n\n // ── BUDGET / BID — hard-gated, requires confirmed:true ──────\n case \"update_budget\": {\n const { campaignBudgetId, amountMicros, confirmed } = body;\n if (!confirmed) {\n return Response.json({\n error:\n \"Budget changes require confirmed:true. This is a deliberate safeguard — Chris must approve budget changes before this is called.\",\n }, { status: 403 });\n }\n if (!campaignBudgetId || !amountMicros) {\n return Response.json({\n error: \"campaignBudgetId and amountMicros required\",\n }, { status: 400 });\n }\n const result = await mutate(\n customerId,\n headers,\n \"campaignBudgets\",\n [{\n update: {\n resource_name:\n `customers/${customerId}/campaignBudgets/${campaignBudgetId}`,\n amount_micros: amountMicros,\n },\n update_mask: \"amount_micros\",\n }],\n dryRun,\n );\n return Response.json({\n action,\n campaignBudgetId,\n amountMicros,\n dryRun: !!dryRun,\n result,\n });\n }\n\n case \"update_bid\": {\n const { adGroupId, cpcBidMicros, confirmed } = body;\n if (!confirmed) {\n return Response.json({\n error:\n \"Bid changes require confirmed:true. This is a deliberate safeguard — Chris must approve bid changes before this is called.\",\n }, { status: 403 });\n }\n if (!adGroupId || !cpcBidMicros) {\n return Response.json({\n error: \"adGroupId and cpcBidMicros required\",\n }, { status: 400 });\n }\n const result = await mutate(\n customerId,\n headers,\n \"adGroups\",\n [{\n update: {\n resource_name: `customers/${customerId}/adGroups/${adGroupId}`,\n cpc_bid_micros: cpcBidMicros,\n },\n update_mask: \"cpc_bid_micros\",\n }],\n dryRun,\n );\n return Response.json({\n action,\n adGroupId,\n cpcBidMicros,\n dryRun: !!dryRun,\n result,\n });\n }\n\n // ── CONVERSION GOALS — hard-gated, requires confirmed:true ──\n // Changes what \"counts\" toward Maximize Conversions / Target CPA / Target\n // ROAS bidding. Same blast radius as a budget or bid change (it can\n // silently redirect the whole account's optimisation target), so it gets\n // the same safeguard: refused unless the request includes confirmed:true.\n case \"update_conversion_action\": {\n const {\n conversionActionId,\n primaryForGoal,\n includeInConversionsMetric,\n status,\n confirmed,\n } = body;\n if (!confirmed) {\n return Response.json({\n error:\n \"Conversion action changes require confirmed:true. This is a deliberate safeguard — Chris must approve changes to what counts as a conversion before this is called.\",\n }, { status: 403 });\n }\n if (!conversionActionId) {\n return Response.json({ error: \"conversionActionId required\" }, {\n status: 400,\n });\n }\n const update: Record = {\n resource_name:\n `customers/${customerId}/conversionActions/${conversionActionId}`,\n };\n const maskFields: string[] = [];\n if (typeof primaryForGoal === \"boolean\") {\n update.primary_for_goal = primaryForGoal;\n maskFields.push(\"primary_for_goal\");\n }\n if (typeof includeInConversionsMetric === \"boolean\") {\n update.include_in_conversions_metric = includeInConversionsMetric;\n maskFields.push(\"include_in_conversions_metric\");\n }\n if (status) {\n update.status = status; // ENABLED | REMOVED | HIDDEN\n maskFields.push(\"status\");\n }\n if (!maskFields.length) {\n return Response.json({\n error:\n \"Provide at least one of primaryForGoal, includeInConversionsMetric, status\",\n }, { status: 400 });\n }\n const result = await mutate(\n customerId,\n headers,\n \"conversionActions\",\n [{ update, update_mask: maskFields.join(\",\") }],\n dryRun,\n );\n return Response.json({\n action,\n conversionActionId,\n changed: maskFields,\n dryRun: !!dryRun,\n result,\n });\n }\n\n // ── GOAL CATEGORY biddable toggle — hard-gated, requires confirmed:true ──\n // Turns a whole goal category (e.g. ADD_TO_CART, BEGIN_CHECKOUT) on/off as\n // a bidding target, at the customer-default and/or campaign-override level.\n // This is the fix for \"targeted goal is missing a primary conversion action\":\n // a category can stay biddable even after its individual actions are\n // demoted to secondary, leaving it empty. Same blast radius as budget/bid.\n case \"update_conversion_goal\": {\n const { level, campaignId, category, origin, biddable, confirmed } =\n body;\n if (!confirmed) {\n return Response.json({\n error:\n \"Conversion goal changes require confirmed:true. This is a deliberate safeguard — Chris must approve changes to bidding goals before this is called.\",\n }, { status: 403 });\n }\n if (!level || !category || !origin || typeof biddable !== \"boolean\") {\n return Response.json({\n error:\n \"level ('customer'|'campaign'), category, origin, biddable required\",\n }, { status: 400 });\n }\n if (level === \"campaign\") {\n if (!campaignId) {\n return Response.json({\n error: \"campaignId required for level=campaign\",\n }, { status: 400 });\n }\n const result = await mutate(\n customerId,\n headers,\n \"campaignConversionGoals\",\n [{\n update: {\n resource_name:\n `customers/${customerId}/campaignConversionGoals/${campaignId}~${category}~${origin}`,\n biddable,\n },\n update_mask: \"biddable\",\n }],\n dryRun,\n );\n return Response.json({\n action,\n level,\n campaignId,\n category,\n origin,\n biddable,\n dryRun: !!dryRun,\n result,\n });\n } else if (level === \"customer\") {\n const result = await mutate(\n customerId,\n headers,\n \"customerConversionGoals\",\n [{\n update: {\n resource_name:\n `customers/${customerId}/customerConversionGoals/${category}~${origin}`,\n biddable,\n },\n update_mask: \"biddable\",\n }],\n dryRun,\n );\n return Response.json({\n action,\n level,\n category,\n origin,\n biddable,\n dryRun: !!dryRun,\n result,\n });\n }\n return Response.json({\n error: \"level must be 'customer' or 'campaign'\",\n }, { status: 400 });\n }\n\n default:\n return Response.json({\n error: `Unknown action \"${action}\".`,\n validActions: [\n \"add_asset_group_assets\",\n \"remove_asset_group_asset\",\n \"pause_campaign\",\n \"enable_campaign\",\n \"pause_ad_group\",\n \"enable_ad_group\",\n \"add_negative_keyword\",\n \"update_budget (needs confirmed:true)\",\n \"update_bid (needs confirmed:true)\",\n \"update_conversion_action (needs confirmed:true)\",\n ],\n }, { status: 400 });\n }\n } catch (e) {\n return Response.json({ error: String(e) }, { status: 500 });\n }\n }\n\n // ── READ PATH (unchanged from the existing val) ────────────────\n const url = new URL(req.url);\n const mode = url.searchParams.get(\"check\");\n try {\n if (mode === \"goals\") {\n const results = await gaqlSearch(\n customerId,\n headers,\n `SELECT campaign.id, campaign.name,\n campaign_conversion_goal.category, campaign_conversion_goal.origin,\n campaign_conversion_goal.biddable\n FROM campaign_conversion_goal\n WHERE campaign.status = 'ENABLED'`,\n ).catch(() => []);\n const custResults = await gaqlSearch(\n customerId,\n headers,\n `SELECT customer_conversion_goal.category, customer_conversion_goal.origin,\n customer_conversion_goal.biddable\n FROM customer_conversion_goal`,\n ).catch(() => []);\n return Response.json({\n check: \"goals\",\n campaignConversionGoals: results.map((r: any) => ({\n campaign: r.campaign?.name,\n category: r.campaignConversionGoal?.category,\n origin: r.campaignConversionGoal?.origin,\n biddable: r.campaignConversionGoal?.biddable,\n })),\n customerConversionGoals: custResults.map((r: any) => ({\n category: r.customerConversionGoal?.category,\n origin: r.customerConversionGoal?.origin,\n biddable: r.customerConversionGoal?.biddable,\n })),\n });\n }\n\n if (mode === \"conversions\") {\n const results = await gaqlSearch(\n customerId,\n headers,\n `SELECT conversion_action.id, conversion_action.resource_name,\n conversion_action.name, conversion_action.status,\n conversion_action.type, conversion_action.category,\n conversion_action.origin, conversion_action.primary_for_goal,\n conversion_action.include_in_conversions_metric\n FROM conversion_action\n ORDER BY conversion_action.name`,\n );\n const actions = results.map((r: any) => ({\n id: r.conversionAction?.id,\n resourceName: r.conversionAction?.resourceName,\n name: r.conversionAction?.name,\n status: r.conversionAction?.status,\n type: r.conversionAction?.type,\n category: r.conversionAction?.category,\n origin: r.conversionAction?.origin,\n // primaryForGoal / includeInConversionsMetric together control whether this\n // action counts toward the \"Conversions\" column that Maximize Conversions /\n // Target CPA / Target ROAS bid strategies actually optimise against.\n primaryForGoal: r.conversionAction?.primaryForGoal,\n includeInConversionsMetric: r.conversionAction\n ?.includeInConversionsMetric,\n }));\n return Response.json({\n check: \"conversion_tracking\",\n found: actions.length,\n actions,\n });\n }\n\n if (mode === \"audit\") {\n const [\n campaigns,\n adGroups,\n keywords,\n ads,\n negatives,\n locations,\n languages,\n networks,\n ] = await Promise.all([\n gaqlSearch(\n customerId,\n headers,\n `SELECT campaign.id, campaign.name, campaign.status,\n campaign.advertising_channel_type, campaign.advertising_channel_sub_type,\n campaign.bidding_strategy_type,\n campaign.target_cpa.target_cpa_micros,\n campaign.target_roas.target_roas,\n campaign.maximize_conversions.target_cpa_micros,\n campaign_budget.id, campaign_budget.amount_micros, campaign_budget.delivery_method,\n campaign_budget.period,\n metrics.impressions, metrics.clicks, metrics.cost_micros,\n metrics.conversions, metrics.ctr, metrics.average_cpc,\n metrics.search_impression_share, metrics.search_budget_lost_impression_share,\n metrics.search_rank_lost_impression_share\n FROM campaign\n WHERE segments.date DURING LAST_30_DAYS`,\n ),\n gaqlSearch(\n customerId,\n headers,\n `SELECT ad_group.id, ad_group.name, ad_group.status, ad_group.type,\n ad_group.cpc_bid_micros, campaign.name,\n metrics.impressions, metrics.clicks, metrics.cost_micros\n FROM ad_group\n WHERE segments.date DURING LAST_30_DAYS`,\n ),\n gaqlSearch(\n customerId,\n headers,\n `SELECT ad_group_criterion.keyword.text, ad_group_criterion.keyword.match_type,\n ad_group_criterion.status, ad_group_criterion.quality_info.quality_score,\n ad_group_criterion.approval_status, ad_group.name,\n metrics.impressions, metrics.clicks, metrics.cost_micros\n FROM keyword_view\n WHERE segments.date DURING LAST_30_DAYS`,\n ).catch(() => []),\n gaqlSearch(\n customerId,\n headers,\n `SELECT ad_group_ad.ad.id, ad_group_ad.status,\n ad_group_ad.policy_summary.approval_status,\n ad_group_ad.ad.type, ad_group.name,\n ad_group_ad.ad.final_urls,\n metrics.impressions, metrics.clicks\n FROM ad_group_ad\n WHERE segments.date DURING LAST_30_DAYS`,\n ),\n gaqlSearch(\n customerId,\n headers,\n `SELECT campaign_criterion.keyword.text, campaign_criterion.negative,\n campaign.name\n FROM campaign_criterion\n WHERE campaign_criterion.type = 'KEYWORD'`,\n ).catch(() => []),\n gaqlSearch(\n customerId,\n headers,\n `SELECT campaign_criterion.location.geo_target_constant, campaign.name,\n campaign_criterion.negative\n FROM campaign_criterion\n WHERE campaign_criterion.type = 'LOCATION'`,\n ).catch(() => []),\n gaqlSearch(\n customerId,\n headers,\n `SELECT campaign_criterion.language.language_constant, campaign.name\n FROM campaign_criterion\n WHERE campaign_criterion.type = 'LANGUAGE'`,\n ).catch(() => []),\n gaqlSearch(\n customerId,\n headers,\n `SELECT campaign.name, campaign.network_settings.target_google_search,\n campaign.network_settings.target_search_network,\n campaign.network_settings.target_content_network,\n campaign.network_settings.target_partner_search_network\n FROM campaign`,\n ).catch(() => []),\n ]);\n return Response.json({\n check: \"campaign_audit\",\n campaigns: campaigns.map((r: any) => ({\n id: r.campaign?.id,\n name: r.campaign?.name,\n status: r.campaign?.status,\n channelType: r.campaign?.advertisingChannelType,\n channelSubType: r.campaign?.advertisingChannelSubType,\n biddingStrategyType: r.campaign?.biddingStrategyType,\n targetCpaMicros: r.campaign?.targetCpa?.targetCpaMicros,\n targetRoas: r.campaign?.targetRoas?.targetRoas,\n maximizeConversionsTargetCpaMicros: r.campaign?.maximizeConversions\n ?.targetCpaMicros,\n budgetId: r.campaignBudget?.id,\n budgetMicros: r.campaignBudget?.amountMicros,\n budgetDeliveryMethod: r.campaignBudget?.deliveryMethod,\n budgetPeriod: r.campaignBudget?.period,\n impressions: r.metrics?.impressions,\n clicks: r.metrics?.clicks,\n costMicros: r.metrics?.costMicros,\n conversions: r.metrics?.conversions,\n ctr: r.metrics?.ctr,\n avgCpcMicros: r.metrics?.averageCpc,\n searchImpressionShare: r.metrics?.searchImpressionShare,\n searchBudgetLostIS: r.metrics?.searchBudgetLostImpressionShare,\n searchRankLostIS: r.metrics?.searchRankLostImpressionShare,\n })),\n adGroups: adGroups.map((r: any) => ({\n id: r.adGroup?.id,\n campaign: r.campaign?.name,\n name: r.adGroup?.name,\n status: r.adGroup?.status,\n type: r.adGroup?.type,\n cpcBidMicros: r.adGroup?.cpcBidMicros,\n impressions: r.metrics?.impressions,\n clicks: r.metrics?.clicks,\n costMicros: r.metrics?.costMicros,\n })),\n keywords: keywords.map((r: any) => ({\n adGroup: r.adGroup?.name,\n text: r.adGroupCriterion?.keyword?.text,\n matchType: r.adGroupCriterion?.keyword?.matchType,\n status: r.adGroupCriterion?.status,\n qualityScore: r.adGroupCriterion?.qualityInfo?.qualityScore,\n approvalStatus: r.adGroupCriterion?.approvalStatus,\n impressions: r.metrics?.impressions,\n clicks: r.metrics?.clicks,\n costMicros: r.metrics?.costMicros,\n })),\n ads: ads.map((r: any) => ({\n adGroup: r.adGroup?.name,\n adId: r.adGroupAd?.ad?.id,\n status: r.adGroupAd?.status,\n approvalStatus: r.adGroupAd?.policySummary?.approvalStatus,\n type: r.adGroupAd?.ad?.type,\n finalUrls: r.adGroupAd?.ad?.finalUrls,\n impressions: r.metrics?.impressions,\n clicks: r.metrics?.clicks,\n })),\n negativeKeywords: negatives\n .filter((r: any) => r.campaignCriterion?.negative)\n .map((r: any) => ({\n campaign: r.campaign?.name,\n text: r.campaignCriterion?.keyword?.text,\n })),\n locationTargets: locations.map((r: any) => ({\n campaign: r.campaign?.name,\n geoTargetConstant: r.campaignCriterion?.location?.geoTargetConstant,\n negative: r.campaignCriterion?.negative,\n })),\n languageTargets: languages.map((r: any) => ({\n campaign: r.campaign?.name,\n languageConstant: r.campaignCriterion?.language?.languageConstant,\n })),\n networkSettings: networks.map((r: any) => ({\n campaign: r.campaign?.name,\n targetGoogleSearch: r.campaign?.networkSettings?.targetGoogleSearch,\n targetSearchNetwork: r.campaign?.networkSettings?.targetSearchNetwork,\n targetContentNetwork: r.campaign?.networkSettings\n ?.targetContentNetwork,\n targetPartnerSearchNetwork: r.campaign?.networkSettings\n ?.targetPartnerSearchNetwork,\n })),\n });\n }\n\n if (mode === \"creative\") {\n const [assetGroups, assetGroupAssets, audienceSignals] = await Promise\n .all([\n gaqlSearch(\n customerId,\n headers,\n `SELECT asset_group.id, asset_group.name, asset_group.status,\n asset_group.ad_strength, campaign.name\n FROM asset_group`,\n ),\n gaqlSearch(\n customerId,\n headers,\n `SELECT asset_group_asset.resource_name, asset_group_asset.field_type, asset_group_asset.status,\n asset.type, asset.text_asset.text,\n asset.image_asset.full_size.url,\n asset.youtube_video_asset.youtube_video_id,\n asset_group.name, campaign.name\n FROM asset_group_asset`,\n ),\n gaqlSearch(\n customerId,\n headers,\n `SELECT asset_group_signal.audience.audience,\n asset_group_signal.search_theme.text,\n asset_group.name, campaign.name\n FROM asset_group_signal`,\n ).catch(() => []),\n ]);\n return Response.json({\n check: \"creative\",\n assetGroups: assetGroups.map((r: any) => ({\n id: r.assetGroup?.id,\n campaign: r.campaign?.name,\n name: r.assetGroup?.name,\n status: r.assetGroup?.status,\n adStrength: r.assetGroup?.adStrength,\n })),\n assets: assetGroupAssets.map((r: any) => ({\n resourceName: r.assetGroupAsset?.resourceName,\n campaign: r.campaign?.name,\n assetGroup: r.assetGroup?.name,\n fieldType: r.assetGroupAsset?.fieldType,\n status: r.assetGroupAsset?.status,\n assetType: r.asset?.type,\n text: r.asset?.textAsset?.text,\n imageUrl: r.asset?.imageAsset?.fullSize?.url,\n youtubeVideoId: r.asset?.youtubeVideoAsset?.youtubeVideoId,\n })),\n audienceSignals: audienceSignals.map((r: any) => ({\n campaign: r.campaign?.name,\n assetGroup: r.assetGroup?.name,\n audience: r.assetGroupSignal?.audience?.audience,\n searchTheme: r.assetGroupSignal?.searchTheme?.text,\n })),\n });\n }\n\n // Default: campaign performance\n const rows = await gaqlSearch(\n customerId,\n headers,\n `SELECT campaign.name, campaign.status, metrics.impressions, metrics.clicks,\n metrics.cost_micros, metrics.conversions, metrics.conversions_value\n FROM campaign\n WHERE segments.date DURING LAST_30_DAYS\n ORDER BY metrics.cost_micros DESC`,\n );\n const campaigns = rows.map((r: any) => ({\n campaign: r.campaign?.name,\n status: r.campaign?.status,\n impressions: Number(r.metrics?.impressions || 0),\n clicks: Number(r.metrics?.clicks || 0),\n cost: Math.round((Number(r.metrics?.costMicros || 0) / 1e6) * 100) / 100,\n conversions: Number(r.metrics?.conversions || 0),\n conversionsValue: Number(r.metrics?.conversionsValue || 0),\n }));\n const totals = campaigns.reduce((a: any, r: any) => ({\n impressions: a.impressions + r.impressions,\n clicks: a.clicks + r.clicks,\n cost: Math.round((a.cost + r.cost) * 100) / 100,\n conversions: a.conversions + r.conversions,\n }), { impressions: 0, clicks: 0, cost: 0, conversions: 0 });\n return Response.json({ range: \"last_30_days\", totals, campaigns });\n } catch (e) {\n return Response.json({ error: String(e) }, { status: 500 });\n }\n}","createdAt",["D",1786282985000],"branchVersion","branchId","6d07d88f-a6d3-4868-a220-4e78d8ca17ff","id","e69d037c-ea36-481e-8379-50a14a7e0eed","Google-Ads",["D",1783685190686],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Google ads api connector","imageUrl","019d5060-1a72-70ea-92a9-e2c91a100d5a","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019d5060-1a72-70ea-92a9-e7b6c0748108","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_95":94,"_102":98},"org",{"_95":94,"_96":-5,"_97":98,"_18":55,"_99":100,"_101":25},"branch",{"_13":84,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"isOwned",21,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","Gearymeister","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzNCb3l3RnlPc1h0RkMwd2w3S3F0aDU2TWtzRSJ9","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":151,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":152,"_79":153,"_81":154,"_83":25},"tree",[146],"files",[146],"counts",{"_134":61,"_135":136,"_137":61,"_138":139,"_140":141},"contents",[126],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":127,"_32":28,"_30":31,"_128":-5,"_41":42,"_40":14,"_129":25,"_38":130,"_13":131,"_33":34,"_35":37,"_24":25,"_132":-5,"_27":133},"6174e78c-5920-4cf8-993e-645df9aebddf","parentId","latest",["D",1786282985000],14,"label",[28],"pulls","branches",1,"forks","envVars",{"_142":144,"_145":61},"connections",{"_142":61,"_143":61},"count","unfilledCount",6,"emptyCount",{"_43":127,"_32":28,"_30":31,"_128":-5,"_41":42,"_40":14,"_129":25,"_38":147,"_13":131,"_33":34,"_35":37,"_24":25,"_132":-5,"_148":149,"_27":150},["D",1786282985000],"children",[],[28],["D",1783685190686],{"_95":94,"_102":98},{"_95":94,"_96":-5,"_97":98,"_18":55,"_99":100,"_101":25},{"_13":84,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"ctx",{"_77":-5,"_123":188,"_189":190,"_191":192,"_193":25,"_194":25,"_195":25,"_196":121,"_197":-5,"_198":-7,"_199":-7,"_200":61,"_201":25,"_202":25,"_203":-5,"_204":25,"_205":25,"_206":25,"_207":-5},"ENV",{"_159":160,"_161":162,"_163":85,"_164":165,"_166":167,"_168":169,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v20