4 Commits

2 changed files with 29 additions and 27 deletions
+1 -1
View File
@@ -1,6 +1,6 @@
[project]
name = "rbx-upload"
version = "0.2.1"
version = "0.2.6"
description = "Roblox asset upload client"
requires-python = ">=3.13"
dependencies = [
+28 -26
View File
@@ -255,35 +255,23 @@ class RobloxClient:
async def onsale_asset(
self,
asset_id: int,
name: str,
description: str,
group_id: int,
collectible_item_id: str,
price: int = 5,
) -> dict:
"""Put an asset on sale."""
csrf = await self._get_csrf_token()
data = {
"saleLocationConfiguration": {"saleLocationType": 1, "places": []},
"targetId": asset_id,
"priceInRobux": price,
"publishingType": 2,
"idempotencyToken": str(uuid.uuid4()),
"publisherUserId": self._publisher_user_id,
"creatorGroupId": group_id,
"name": name,
"description": description,
"isFree": False,
"agreedPublishingFee": 0,
"priceOffset": 0,
"quantity": 0,
"quantityLimitPerUser": 0,
"resaleRestriction": 2,
"targetType": 0,
}
response = await self._http.post(
self._proxy_url("https://itemconfiguration.roblox.com/v1/collectibles", force_direct=True),
json=data,
response = await self._http.patch(
f"https://itemconfiguration.roblox.com/v1/collectibles/{collectible_item_id}",
json={
"saleLocationConfiguration": {"saleLocationType": 1, "places": []},
"saleStatus": 0,
"quantityLimitPerUser": 0,
"resaleRestriction": 2,
"priceInRobux": price,
"priceOffset": 0,
"optOutFromRegionalPricing": False,
"isFree": False,
},
headers={
"X-CSRF-TOKEN": csrf,
"User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:145.0) Gecko/20100101 Firefox/145.0",
@@ -299,7 +287,21 @@ class RobloxClient:
raise AuthError("Not authorized to put this asset on sale.")
response.raise_for_status()
return response.json()
return response.json() if response.text else {}
async def get_collectible_item_id(self, asset_id: int, max_attempts: int = 10, poll_interval: float = 3.0) -> str:
"""Look up the collectible item ID (UUID) for a given asset ID, retrying until available."""
for _ in range(max_attempts):
response = await self._http.get(
self._proxy_url(f"https://economy.roblox.com/v2/assets/{asset_id}/details"),
cookies=self._csrf_cookies,
)
response.raise_for_status()
collectible_item_id = response.json().get("CollectibleItemId")
if collectible_item_id:
return collectible_item_id
await asyncio.sleep(poll_interval)
raise UploadError(f"collectibleItemId not available for asset {asset_id} after {max_attempts} attempts.")
async def close(self):
"""Close the underlying HTTP client."""