fix(generator): emit header params instead of silently dropping them

extract_parameters captured "in": "header" params but generate_method_body
bucketed only query/body/raw_body/path, so every header param was dropped at
emission: posts.create_post(x_request_id=...) was accepted and thrown away,
making the server's idempotency window unreachable from Python. BaseClient
also had no headers kwarg on _post.

Header dicts are emitted inline keyed on the verbatim wire name, so
x-request-id stays lowercase where _build_params would have camelCased it.
headers is threaded through _get/_aget/_post/_apost only, including the
separate httpx client built for multipart uploads; no PUT/PATCH/DELETE
operation declares a header param today.

Regenerates connect, ad_campaigns, phone_numbers, posts and
whatsapp_phone_numbers: 12 header params across those five were being
dropped, not just x-request-id.

Header params supplied via a component $ref (Idempotency-Key on 9 further
operations) are still discarded by the $ref branch of extract_parameters and
are left for a follow-up.

https://app.crisp.chat/website/20dea5d6-a684-4c80-b097-2258b0b41421/inbox/session_0aff04b5-6834-480a-ba49-f525956329db/

Author: Zernio-Elean

scripts/generate_resources.py

@@ -294,6 +294,7 @@ def generate_method_body(
     body_params = [p for p in params if p["in"] == "body"]
     raw_body_params = [p for p in params if p["in"] == "raw_body"]
     path_params = [p for p in params if p["in"] == "path"]
+    header_params = [p for p in params if p["in"] == "header"]
 
     # Handle path parameters
     path_expr = f'"{path}"'
@@ -314,6 +315,9 @@ def generate_method_body(
     use_query_params = http_method.upper() in ("GET", "DELETE") and query_params
     use_body_params = http_method.upper() in ("POST", "PUT", "PATCH") and body_params
     use_query_on_post = http_method.upper() in ("POST", "PUT", "PATCH") and query_params
+    # Only _get and _post accept a `headers` kwarg (see BaseClient); no
+    # operation on PUT/PATCH/DELETE currently has a header param.
+    use_headers = http_method.upper() in ("GET", "POST") and header_params
 
     # Build params dict if needed
     if use_query_params or use_query_on_post:
@@ -329,12 +333,27 @@ def generate_method_body(
             lines.append(f"            {p['name']}={p['name']},")
         lines.append("        )")
 
+    # Build headers dict if needed, keyed on the wire name (original_name)
+    if use_headers:
+        header_entries = ", ".join(
+            f'"{p["original_name"]}": {p["name"]}' for p in header_params
+        )
+        lines.append(
+            "        headers = {k: v for k, v in {"
+            + header_entries
+            + "}.items() if v is not None}"
+        )
+
     # Make the request
     if http_method.upper() == "GET":
+        call_args = [path_expr]
         if query_params:
-            lines.append(f"        return {await_prefix}self._client.{client_method}({path_expr}, params=params)")
-        else:
-            lines.append(f"        return {await_prefix}self._client.{client_method}({path_expr})")
+            call_args.append("params=params")
+        if use_headers:
+            call_args.append("headers=headers")
+        lines.append(
+            f"        return {await_prefix}self._client.{client_method}({', '.join(call_args)})"
+        )
     elif http_method.upper() == "DELETE":
         if query_params:
             lines.append(f"        return {await_prefix}self._client.{client_method}({path_expr}, params=params)")
@@ -348,6 +367,8 @@ def generate_method_body(
             call_args.append(f"data={raw_body_params[0]['name']}")
         if query_params:
             call_args.append("params=params")
+        if use_headers:
+            call_args.append("headers=headers")
         lines.append(
             f"        return {await_prefix}self._client.{client_method}({', '.join(call_args)})"
         )

src/late/resources/_generated/ad_campaigns.py

@@ -214,7 +214,12 @@ def create_ad_campaign(
             bid_amount=bid_amount,
             roas_average_floor=roas_average_floor,
         )
-        return self._client._post("/v1/ads/campaigns", data=payload)
+        headers = {
+            k: v
+            for k, v in {"Idempotency-Key": idempotency_key}.items()
+            if v is not None
+        }
+        return self._client._post("/v1/ads/campaigns", data=payload, headers=headers)
 
     def update_ad_campaign_status(
         self, campaign_id: str, status: str, platform: str
@@ -297,8 +302,13 @@ def duplicate_ad_campaign(
             rename_suffix=rename_suffix,
             sync_after=sync_after,
         )
+        headers = {
+            k: v
+            for k, v in {"Idempotency-Key": idempotency_key}.items()
+            if v is not None
+        }
         return self._client._post(
-            f"/v1/ads/campaigns/{campaign_id}/duplicate", data=payload
+            f"/v1/ads/campaigns/{campaign_id}/duplicate", data=payload, headers=headers
         )
 
     def duplicate_ad_set(
@@ -330,8 +340,13 @@ def duplicate_ad_set(
             rename_suffix=rename_suffix,
             sync_after=sync_after,
         )
+        headers = {
+            k: v
+            for k, v in {"Idempotency-Key": idempotency_key}.items()
+            if v is not None
+        }
         return self._client._post(
-            f"/v1/ads/ad-sets/{ad_set_id}/duplicate", data=payload
+            f"/v1/ads/ad-sets/{ad_set_id}/duplicate", data=payload, headers=headers
         )
 
     def duplicate_ad(
@@ -355,7 +370,14 @@ def duplicate_ad(
             rename_suffix=rename_suffix,
             sync_after=sync_after,
         )
-        return self._client._post(f"/v1/ads/{ad_id}/duplicate", data=payload)
+        headers = {
+            k: v
+            for k, v in {"Idempotency-Key": idempotency_key}.items()
+            if v is not None
+        }
+        return self._client._post(
+            f"/v1/ads/{ad_id}/duplicate", data=payload, headers=headers
+        )
 
     def get_ad_set_details(
         self, ad_set_id: str, account_id: str, *, fields: str | None = None
@@ -941,7 +963,14 @@ async def acreate_ad_campaign(
             bid_amount=bid_amount,
             roas_average_floor=roas_average_floor,
         )
-        return await self._client._apost("/v1/ads/campaigns", data=payload)
+        headers = {
+            k: v
+            for k, v in {"Idempotency-Key": idempotency_key}.items()
+            if v is not None
+        }
+        return await self._client._apost(
+            "/v1/ads/campaigns", data=payload, headers=headers
+        )
 
     async def aupdate_ad_campaign_status(
         self, campaign_id: str, status: str, platform: str
@@ -1026,8 +1055,13 @@ async def aduplicate_ad_campaign(
             rename_suffix=rename_suffix,
             sync_after=sync_after,
         )
+        headers = {
+            k: v
+            for k, v in {"Idempotency-Key": idempotency_key}.items()
+            if v is not None
+        }
         return await self._client._apost(
-            f"/v1/ads/campaigns/{campaign_id}/duplicate", data=payload
+            f"/v1/ads/campaigns/{campaign_id}/duplicate", data=payload, headers=headers
         )
 
     async def aduplicate_ad_set(
@@ -1059,8 +1093,13 @@ async def aduplicate_ad_set(
             rename_suffix=rename_suffix,
             sync_after=sync_after,
         )
+        headers = {
+            k: v
+            for k, v in {"Idempotency-Key": idempotency_key}.items()
+            if v is not None
+        }
         return await self._client._apost(
-            f"/v1/ads/ad-sets/{ad_set_id}/duplicate", data=payload
+            f"/v1/ads/ad-sets/{ad_set_id}/duplicate", data=payload, headers=headers
         )
 
     async def aduplicate_ad(
@@ -1084,7 +1123,14 @@ async def aduplicate_ad(
             rename_suffix=rename_suffix,
             sync_after=sync_after,
         )
-        return await self._client._apost(f"/v1/ads/{ad_id}/duplicate", data=payload)
+        headers = {
+            k: v
+            for k, v in {"Idempotency-Key": idempotency_key}.items()
+            if v is not None
+        }
+        return await self._client._apost(
+            f"/v1/ads/{ad_id}/duplicate", data=payload, headers=headers
+        )
 
     async def aget_ad_set_details(
         self, ad_set_id: str, account_id: str, *, fields: str | None = None

src/late/resources/_generated/connect.py

@@ -301,7 +301,14 @@ def list_pinterest_boards_for_selection(
             profile_id=profile_id,
             temp_token=temp_token,
         )
-        return self._client._get("/v1/connect/pinterest/select-board", params=params)
+        headers = {
+            k: v
+            for k, v in {"X-Connect-Token": x_connect_token}.items()
+            if v is not None
+        }
+        return self._client._get(
+            "/v1/connect/pinterest/select-board", params=params, headers=headers
+        )
 
     def select_pinterest_board(
         self,
@@ -336,7 +343,14 @@ def list_snapchat_profiles(
             profile_id=profile_id,
             temp_token=temp_token,
         )
-        return self._client._get("/v1/connect/snapchat/select-profile", params=params)
+        headers = {
+            k: v
+            for k, v in {"X-Connect-Token": x_connect_token}.items()
+            if v is not None
+        }
+        return self._client._get(
+            "/v1/connect/snapchat/select-profile", params=params, headers=headers
+        )
 
     def select_snapchat_profile(
         self,
@@ -360,7 +374,14 @@ def select_snapchat_profile(
             expires_in=expires_in,
             redirect_url=redirect_url,
         )
-        return self._client._post("/v1/connect/snapchat/select-profile", data=payload)
+        headers = {
+            k: v
+            for k, v in {"X-Connect-Token": x_connect_token}.items()
+            if v is not None
+        }
+        return self._client._post(
+            "/v1/connect/snapchat/select-profile", data=payload, headers=headers
+        )
 
     def connect_bluesky_credentials(
         self,
@@ -423,8 +444,13 @@ def list_whats_app_phone_numbers(
             profile_id=profile_id,
             temp_token=temp_token,
         )
+        headers = {
+            k: v
+            for k, v in {"X-Connect-Token": x_connect_token}.items()
+            if v is not None
+        }
         return self._client._get(
-            "/v1/connect/whatsapp/select-phone-number", params=params
+            "/v1/connect/whatsapp/select-phone-number", params=params, headers=headers
         )
 
     def complete_whats_app_phone_selection(
@@ -447,8 +473,13 @@ def complete_whats_app_phone_selection(
             user_profile=user_profile,
             redirect_url=redirect_url,
         )
+        headers = {
+            k: v
+            for k, v in {"X-Connect-Token": x_connect_token}.items()
+            if v is not None
+        }
         return self._client._post(
-            "/v1/connect/whatsapp/select-phone-number", data=payload
+            "/v1/connect/whatsapp/select-phone-number", data=payload, headers=headers
         )
 
     def connect_whats_app_embedded_signup(
@@ -1002,8 +1033,13 @@ async def alist_pinterest_boards_for_selection(
             profile_id=profile_id,
             temp_token=temp_token,
         )
+        headers = {
+            k: v
+            for k, v in {"X-Connect-Token": x_connect_token}.items()
+            if v is not None
+        }
         return await self._client._aget(
-            "/v1/connect/pinterest/select-board", params=params
+            "/v1/connect/pinterest/select-board", params=params, headers=headers
         )
 
     async def aselect_pinterest_board(
@@ -1041,8 +1077,13 @@ async def alist_snapchat_profiles(
             profile_id=profile_id,
             temp_token=temp_token,
         )
+        headers = {
+            k: v
+            for k, v in {"X-Connect-Token": x_connect_token}.items()
+            if v is not None
+        }
         return await self._client._aget(
-            "/v1/connect/snapchat/select-profile", params=params
+            "/v1/connect/snapchat/select-profile", params=params, headers=headers
         )
 
     async def aselect_snapchat_profile(
@@ -1067,8 +1108,13 @@ async def aselect_snapchat_profile(
             expires_in=expires_in,
             redirect_url=redirect_url,
         )
+        headers = {
+            k: v
+            for k, v in {"X-Connect-Token": x_connect_token}.items()
+            if v is not None
+        }
         return await self._client._apost(
-            "/v1/connect/snapchat/select-profile", data=payload
+            "/v1/connect/snapchat/select-profile", data=payload, headers=headers
         )
 
     async def aconnect_bluesky_credentials(
@@ -1138,8 +1184,13 @@ async def alist_whats_app_phone_numbers(
             profile_id=profile_id,
             temp_token=temp_token,
         )
+        headers = {
+            k: v
+            for k, v in {"X-Connect-Token": x_connect_token}.items()
+            if v is not None
+        }
         return await self._client._aget(
-            "/v1/connect/whatsapp/select-phone-number", params=params
+            "/v1/connect/whatsapp/select-phone-number", params=params, headers=headers
         )
 
     async def acomplete_whats_app_phone_selection(
@@ -1162,8 +1213,13 @@ async def acomplete_whats_app_phone_selection(
             user_profile=user_profile,
             redirect_url=redirect_url,
         )
+        headers = {
+            k: v
+            for k, v in {"X-Connect-Token": x_connect_token}.items()
+            if v is not None
+        }
         return await self._client._apost(
-            "/v1/connect/whatsapp/select-phone-number", data=payload
+            "/v1/connect/whatsapp/select-phone-number", data=payload, headers=headers
         )
 
     async def aconnect_whats_app_embedded_signup(

src/late/resources/_generated/phone_numbers.py

@@ -209,7 +209,10 @@ def view_phone_number_kyc_document(self, document_id: str) -> dict[str, Any]:
 
     def upload_phone_number_kyc_document(self, x_filename: str) -> dict[str, Any]:
         """Upload a KYC document"""
-        return self._client._post("/v1/phone-numbers/kyc/upload-document")
+        headers = {k: v for k, v in {"X-Filename": x_filename}.items() if v is not None}
+        return self._client._post(
+            "/v1/phone-numbers/kyc/upload-document", headers=headers
+        )
 
     def validate_phone_number_kyc_address(
         self,
@@ -543,7 +546,10 @@ async def aupload_phone_number_kyc_document(
         self, x_filename: str
     ) -> dict[str, Any]:
         """Upload a KYC document (async)"""
-        return await self._client._apost("/v1/phone-numbers/kyc/upload-document")
+        headers = {k: v for k, v in {"X-Filename": x_filename}.items() if v is not None}
+        return await self._client._apost(
+            "/v1/phone-numbers/kyc/upload-document", headers=headers
+        )
 
     async def avalidate_phone_number_kyc_address(
         self,

src/late/resources/_generated/posts.py

@@ -154,7 +154,10 @@ def create_post(
             queued_from_profile=queued_from_profile,
             queue_id=queue_id,
         )
-        return self._client._post("/v1/posts", data=payload)
+        headers = {
+            k: v for k, v in {"x-request-id": x_request_id}.items() if v is not None
+        }
+        return self._client._post("/v1/posts", data=payload, headers=headers)
 
     def get_post(self, post_id: str) -> dict[str, Any]:
         """Get post"""
@@ -359,7 +362,10 @@ async def acreate_post(
             queued_from_profile=queued_from_profile,
             queue_id=queue_id,
         )
-        return await self._client._apost("/v1/posts", data=payload)
+        headers = {
+            k: v for k, v in {"x-request-id": x_request_id}.items() if v is not None
+        }
+        return await self._client._apost("/v1/posts", data=payload, headers=headers)
 
     async def aget_post(self, post_id: str) -> dict[str, Any]:
         """Get post (async)"""