Add sync method and make them work

Author: Jkuzz

src/apify_client/clients/resource_clients/run.py

@@ -1,7 +1,8 @@
 from __future__ import annotations
 
-from typing import Any
+import json
 import time
+from typing import Any
 
 from apify_shared.utils import filter_out_none_values_recursively, ignore_docs, parse_date_fields
 
@@ -12,7 +13,6 @@
 from apify_client.clients.resource_clients.log import LogClient, LogClientAsync
 from apify_client.clients.resource_clients.request_queue import RequestQueueClient, RequestQueueClientAsync
 
-RUN_CHARGE_IDEMPOTENCY_HEADER = 'idempotency-key'
 
 class RunClient(ActorJobBaseClient):
     """Sub-client for manipulating a single Actor run."""
@@ -228,6 +228,35 @@ def log(self: RunClient) -> LogClient:
             **self._sub_resource_init_options(resource_path='log'),
         )
 
+    def charge(
+            self: RunClient,
+            event_name: str,
+            count: int | None = None,
+            idempotency_key: str | None = None,
+        ) -> dict:
+        """Charge for an event of a Pay-Per-Event Actor run.
+
+        TODO: docs url
+
+        Returns:
+            dict: Status and message of the charge event.
+        """
+        if not event_name:
+            raise ValueError('eventName is required for charging an event')
+
+        return self.http_client.call(
+            url=self._url('charge'),
+            method='POST',
+            headers={
+                'idempotency-key': idempotency_key or f'{self.resource_id}-{event_name}-{int(time.time() * 1000)}',
+                'content-type': 'application/json',
+            },
+            data=json.dumps({
+                'eventName': event_name,
+                'count': count or 1,
+            })
+        )
+
 
 class RunClientAsync(ActorJobBaseClientAsync):
     """Async sub-client for manipulating a single Actor run."""
@@ -445,9 +474,9 @@ def log(self: RunClientAsync) -> LogClientAsync:
 
     async def charge(
             self: RunClient,
-            eventName: str,
+            event_name: str,
             count: int | None = None,
-            idempotencyKey: str | None = None,
+            idempotency_key: str | None = None,
         ) -> dict:
         """Charge for an event of a Pay-Per-Event Actor run.
 
@@ -456,23 +485,18 @@ async def charge(
         Returns:
             dict: Status and message of the charge event.
         """
+        if not event_name:
+            raise ValueError('eventName is required for charging an event')
 
-        if not eventName:
-            raise ValueError("eventName is required for charging an event")
-
-        idempotencyKey = idempotencyKey or "{runId}-{eventName}-{timestamp}".format(
-            runId=self.resource_id,
-            eventName=eventName,
-            timestamp=int(time.time() * 1000),
-        )
-
-        response = await self.http_client.call(
+        return await self.http_client.call(
             url=self._url('charge'),
             method='POST',
-            headers={RUN_CHARGE_IDEMPOTENCY_HEADER: idempotencyKey},
-            data={
-                'eventName': eventName,
+            headers={
+                'idempotency-key': idempotency_key or f'{self.resource_id}-{event_name}-{int(time.time() * 1000)}',
+                'content-type': 'application/json',
+            },
+            data=json.dumps({
+                'eventName': event_name,
                 'count': count or 1,
-            }
+            })
         )
-        return response