[api] fix uploads

Author: david-lev

pywa/api.py

@@ -31,7 +31,6 @@ def __init__(
         self._base_url = f"{base_url}/v{api_version}"
         self._session.headers.update(
             {
-                "Content-Type": "application/json",
                 "Authorization": f"Bearer {token}",
                 "User-Agent": f"PyWa/{pywa.__version__}",
             }
@@ -251,16 +250,11 @@ def upload_media(
         Returns:
             A dict with the ID of the uploaded media file.
         """
-        headers = self._session.headers.copy()
         return self._make_request(
             method="POST",
             endpoint=f"/{self.phone_id}/media",
-            headers=headers,
-            files={
-                "file": (filename, media, mime_type),
-                "messaging_product": (None, "whatsapp"),
-                "type": (None, mime_type),
-            },
+            files=[("file", (filename, media, mime_type))],
+            data={"messaging_product": "whatsapp"},
         )
 
     def get_media_url(self, media_id: str) -> dict:
@@ -767,16 +761,14 @@ def update_flow_json(self, flow_id: str, flow_json: str) -> dict:
               ]
             }
         """
-        headers = self._session.headers.copy()
         return self._make_request(
             method="POST",
             endpoint=f"/{flow_id}/assets",
-            headers=headers,
-            files={
-                "file": ("flow.json", flow_json, "application/json"),
-                "name": (None, "flow.json"),
-                "asset_type": (None, "FLOW_JSON"),
-                "messaging_product": (None, "whatsapp"),
+            files=[("file", ("flow.json", flow_json, "application/json"))],
+            data={
+                "name": "flow.json",
+                "asset_type": "FLOW_JSON",
+                "messaging_product": "whatsapp",
             },
         )
 

pywa_async/api.py

@@ -767,11 +767,9 @@ async def update_flow_json(self, flow_id: str, flow_json: str) -> dict:
               ]
             }
         """
-        headers = self._session.headers.copy()
         return await self._make_request(
             method="POST",
             endpoint=f"/{flow_id}/assets",
-            headers=headers,
             files={
                 "file": ("flow.json", flow_json, "application/json"),
                 "name": (None, "flow.json"),

pywa_async/client.py

@@ -1326,7 +1326,9 @@ async def upload_media(
                     mime_type or mimetypes.guess_type(path)[0],
                 )
             elif (url := str(media)).startswith(("https://", "http://")):
-                res = await (dl_session or httpx).get(url)
+                res = await (
+                    dl_session or httpx.AsyncClient(follow_redirects=True)
+                ).get(url)
                 try:
                     res.raise_for_status()
                 except httpx.HTTPError as e: