laantungir/routstr-core
1
0
Fork 0
mirror of https://github.com/Routstr/routstr-core.git synced 2026-08-12 04:03:21 +00:00
Code Issues Packages Projects Releases Wiki Activity

no auth for routstr node to check and topup balance

Browse Source
This commit is contained in:
9qeklajc
2026-03-09 22:13:33 +01:00
parent 12f2cfecc9
commit 4643aefb22
1 changed files with 10 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
routstr/core/admin.py
+10 -4
View File
@@ -830,10 +830,13 @@ async def topup_provider_with_token(
async with httpx.AsyncClient() as client:
clean_url = provider.base_url.rstrip("/")
headers = {}
if provider.api_key:
headers["Authorization"] = f"Bearer {provider.api_key}"
resp = await client.post(
f"{clean_url}/v1/balance/topup",
json={"cashu_token": payload.token},
headers={"Authorization": f"Bearer {provider.api_key}"},
headers=headers,
)
if resp.status_code == 200:
@@ -890,7 +893,7 @@ async def initiate_provider_topup(
"purpose": "topup",
"api_key": provider.api_key,
},
headers={"Authorization": f"Bearer {provider.api_key}"},
headers={"Authorization": f"Bearer {provider.api_key}"} if provider.api_key else {},
)
if resp.status_code == 200:
@@ -974,7 +977,7 @@ async def check_topup_status(provider_id: int, invoice_id: str) -> dict[str, obj
clean_url = provider.base_url.rstrip("/")
resp = await client.get(
f"{clean_url}/v1/balance/lightning/invoice/{invoice_id}/status",
headers={"Authorization": f"Bearer {provider.api_key}"},
headers={"Authorization": f"Bearer {provider.api_key}"} if provider.api_key else {},
)
if resp.status_code == 200:
status_data = resp.json()
@@ -1024,9 +1027,12 @@ async def get_provider_balance(provider_id: int) -> dict[str, object]:
async with httpx.AsyncClient() as client:
clean_url = provider.base_url.rstrip("/")
headers = {}
if provider.api_key:
headers["Authorization"] = f"Bearer {provider.api_key}"
resp = await client.get(
f"{clean_url}/v1/balance/info",
headers={"Authorization": f"Bearer {provider.api_key}"},
headers=headers,
)
if resp.status_code == 200:
data = resp.json()