Robokassa Mcp

import asynciofrom decimal import Decimalfrom robokassa import create_invoice, RobokassaClient
# Build a signed checkout URL (no HTTP — just URL construction).invoice = create_invoice(    merchant_login="my-shop",    out_sum=Decimal("599.00"),    inv_id=12345,    password1="...",    description="Premium subscription",    email="[email protected]",)print(invoice.url)  # https://auth.robokassa.ru/Merchant/Index.aspx?...
# Check the state of a payment (hits the OpStateExt XML endpoint).async def check() -> None:    async with RobokassaClient("my-shop", password2="...") as client:        state = await client.check_payment(inv_id=12345)        print(state.is_paid, state.info.op_key)
asyncio.run(check())

from robokassa import RobokassaClient
async def refund_flow(inv_id: int) -> None:    async with RobokassaClient("my-shop", password2="p2", password3="p3") as client:        # 1. Fetch the payment state to get its OpKey.        state = await client.check_payment(inv_id)        assert state.info.op_key, "payment not complete yet"
        # 2. Initiate a refund.        created = await client.refund_create(state.info.op_key)        print("refund requestId:", created.request_id)
        # 3. Poll status until finished / canceled.        while True:            status = await client.refund_status(created.request_id)            if status.is_terminal:                print("final:", status.state)                break

from fastapi import FastAPI, Request, HTTPException, PlainTextResponsefrom robokassa import verify_result_signature, build_ok_response
app = FastAPI()
@app.post("/robokassa/result")async def result_url(req: Request) -> PlainTextResponse:    form = dict(await req.form())    if not verify_result_signature(form, password2="..."):        raise HTTPException(status_code=403, detail="Bad signature")    # ... persist the notification, mark invoice paid ...    return PlainTextResponse(build_ok_response(form["InvId"]))