mirror of
https://github.com/deesiigneer/pyspapi.git
synced 2026-04-20 12:35:26 +00:00
Compare commits
21 Commits
v3-(asynci
...
3.3.2
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
508a209e74 | ||
|
|
2573c30800 | ||
|
|
dc36f05221 | ||
|
|
2e75de605d | ||
|
|
22219f3e37 | ||
|
|
83d4308906 | ||
|
|
e22a22b777 | ||
|
|
6906afb090 | ||
|
|
931b1a8621 | ||
|
|
e9765e8b6a | ||
|
|
047dbb38d0 | ||
|
|
6da906e0d1 | ||
|
|
4fc530caeb | ||
|
|
6e77bac3ba | ||
|
|
d36ecfca36 | ||
|
|
c086954c25 | ||
|
|
8d60472b9a | ||
|
|
14166cf519 | ||
|
|
ab60b4f104 | ||
|
|
b738db3252 | ||
| 18c1ff1daf |
20
.github/workflows/python-publish.yml
vendored
20
.github/workflows/python-publish.yml
vendored
@@ -17,20 +17,26 @@ jobs:
|
|||||||
runs-on: ubuntu-latest
|
runs-on: ubuntu-latest
|
||||||
strategy:
|
strategy:
|
||||||
matrix:
|
matrix:
|
||||||
python-version: [ 3.9 ]
|
python-version: [3.12]
|
||||||
steps:
|
steps:
|
||||||
- uses: actions/checkout@v3
|
- uses: actions/checkout@v3
|
||||||
|
|
||||||
- name: Set up Python ${{ matrix.python-version }}
|
- name: Set up Python ${{ matrix.python-version }}
|
||||||
uses: actions/setup-python@v2
|
uses: actions/setup-python@v2
|
||||||
with:
|
with:
|
||||||
python-version: ${{ matrix.python-version }}
|
python-version: ${{ matrix.python-version }}
|
||||||
|
|
||||||
|
- name: Install Poetry
|
||||||
|
run: |
|
||||||
|
curl -sSL https://install.python-poetry.org | python3 -
|
||||||
|
echo "$HOME/.local/bin" >> $GITHUB_PATH
|
||||||
|
|
||||||
- name: Install dependencies
|
- name: Install dependencies
|
||||||
run: |
|
run: poetry install --no-interaction
|
||||||
python -m pip install --upgrade pip
|
|
||||||
pip install twine
|
- name: Build package
|
||||||
- name: Compile package
|
run: poetry build
|
||||||
run: |
|
|
||||||
python3 setup.py sdist
|
|
||||||
- name: Publish package
|
- name: Publish package
|
||||||
uses: pypa/gh-action-pypi-publish@release/v1
|
uses: pypa/gh-action-pypi-publish@release/v1
|
||||||
with:
|
with:
|
||||||
|
|||||||
@@ -1,15 +1,13 @@
|
|||||||
version: 2
|
version: 2
|
||||||
formats: []
|
|
||||||
|
|
||||||
build:
|
build:
|
||||||
os: ubuntu-lts-latest
|
os: ubuntu-lts-latest
|
||||||
tools:
|
tools:
|
||||||
python: '3.8'
|
python: '3.12'
|
||||||
|
|
||||||
|
|
||||||
sphinx:
|
sphinx:
|
||||||
configuration: docs/conf.py
|
configuration: docs/conf.py
|
||||||
fail_on_warning: false
|
|
||||||
builder: html
|
builder: html
|
||||||
|
|
||||||
python:
|
python:
|
||||||
@@ -18,4 +16,3 @@ python:
|
|||||||
path: .
|
path: .
|
||||||
extra_requirements:
|
extra_requirements:
|
||||||
- docs
|
- docs
|
||||||
- requirements: docs/requirements.txt
|
|
||||||
|
|||||||
@@ -1,3 +0,0 @@
|
|||||||
include README.rst
|
|
||||||
include LICENSE
|
|
||||||
include requirements.txt
|
|
||||||
@@ -24,7 +24,7 @@ pyspapi
|
|||||||
|
|
||||||
Installation
|
Installation
|
||||||
-------------
|
-------------
|
||||||
**Requires Python 3.8 or higher**
|
**Requires Python 3.12 or higher**
|
||||||
|
|
||||||
*Windows*
|
*Windows*
|
||||||
|
|
||||||
|
|||||||
@@ -5,8 +5,8 @@
|
|||||||
# from the environment for the first two.
|
# from the environment for the first two.
|
||||||
SPHINXOPTS ?=
|
SPHINXOPTS ?=
|
||||||
SPHINXBUILD ?= sphinx-build
|
SPHINXBUILD ?= sphinx-build
|
||||||
SOURCEDIR = source
|
SOURCEDIR = .
|
||||||
BUILDDIR = build
|
BUILDDIR = _build
|
||||||
|
|
||||||
# Put it first so that "make" without argument is like "make help".
|
# Put it first so that "make" without argument is like "make help".
|
||||||
help:
|
help:
|
||||||
|
|||||||
16
docs/api.rst
16
docs/api.rst
@@ -1,25 +1,25 @@
|
|||||||
.. currentmodule:: pyspapi
|
.. currentmodule:: pyspapi
|
||||||
|
|
||||||
API Reference
|
Справочник API
|
||||||
===============
|
===============
|
||||||
|
|
||||||
The following section outlines the API of pyspapi.
|
В следующем разделе описывается API pyspapi.
|
||||||
|
|
||||||
Version Info
|
Информация о версии
|
||||||
---------------------
|
---------------------
|
||||||
|
|
||||||
There are two main ways to query version information.
|
Существует два основных способа запроса информации о версии.
|
||||||
|
|
||||||
.. data:: version_info
|
.. data:: version_info
|
||||||
|
|
||||||
A named tuple that is similar to :obj:`py:sys.version_info`.
|
Именованный кортеж, аналогичный :obj:`py:sys.version_info`.
|
||||||
|
|
||||||
Just like :obj:`py:sys.version_info` the valid values for ``releaselevel`` are
|
Как и в :obj:`py:sys.version_info`, допустимые значения для ``releaselevel`` это
|
||||||
'alpha', 'beta', 'candidate' and 'final'.
|
'alpha', 'beta', 'candidate' и 'final'.
|
||||||
|
|
||||||
.. data:: __version__
|
.. data:: __version__
|
||||||
|
|
||||||
A string representation of the version.
|
Строковое представление версии.
|
||||||
|
|
||||||
``pyspapi``
|
``pyspapi``
|
||||||
-----------
|
-----------
|
||||||
|
|||||||
68
docs/conf.py
68
docs/conf.py
@@ -1,59 +1,44 @@
|
|||||||
from re import search, MULTILINE
|
from importlib.metadata import version as pkg_version
|
||||||
import os
|
import os
|
||||||
import sys
|
|
||||||
|
|
||||||
|
project = "pyspapi"
|
||||||
|
author = "deesiigneer"
|
||||||
|
copyright = "2022, deesiigneer"
|
||||||
|
|
||||||
project = 'pyspapi'
|
version = pkg_version("pyspapi")
|
||||||
copyright = '2022, deesiigneer'
|
|
||||||
author = 'deesiigneer'
|
|
||||||
with open("../pyspapi/__init__.py") as f:
|
|
||||||
match = search(r'^__version__\s*=\s*[\'"]([^\'"]*)[\'"]', f.read(), MULTILINE)
|
|
||||||
|
|
||||||
if not match or match.group(1) is None:
|
|
||||||
raise RuntimeError("The version could not be resolved")
|
|
||||||
|
|
||||||
version = match.group(1)
|
|
||||||
|
|
||||||
# The full version, including alpha/beta/rc tags.
|
|
||||||
release = version
|
release = version
|
||||||
|
|
||||||
# -- General configuration
|
|
||||||
|
|
||||||
sys.path.insert(0, os.path.abspath(".."))
|
|
||||||
|
|
||||||
|
|
||||||
extensions = [
|
extensions = [
|
||||||
'sphinx.ext.duration',
|
"sphinx.ext.duration",
|
||||||
'sphinx.ext.doctest',
|
"sphinx.ext.doctest",
|
||||||
'sphinx.ext.autodoc',
|
"sphinx.ext.autodoc",
|
||||||
'sphinx.ext.autosummary',
|
"sphinx.ext.autosummary",
|
||||||
'sphinx.ext.intersphinx',
|
"sphinx.ext.intersphinx",
|
||||||
]
|
]
|
||||||
|
|
||||||
autodoc_member_order = "bysource"
|
autosummary_generate = True
|
||||||
autodoc_typehinta = "none"
|
|
||||||
|
|
||||||
intersphinx_mapping = {
|
|
||||||
'python': ('https://docs.python.org/3/', None),
|
|
||||||
'sphinx': ('https://www.sphinx-doc.org/en/master/', None),
|
|
||||||
}
|
|
||||||
|
|
||||||
version_match = os.environ.get("READTHEDOCS_VERSION")
|
version_match = os.environ.get("READTHEDOCS_VERSION")
|
||||||
json_url = f"https://pyspapi.readthedocs.io/ru/{version_match}/_static/switcher.json"
|
json_url = f"https://pyspapi.readthedocs.io/ru/{version_match}/_static/switcher.json"
|
||||||
|
|
||||||
intersphinx_disabled_domains = ['std']
|
|
||||||
language = 'en'
|
language = "ru"
|
||||||
locale_dirs = ["locale/"]
|
|
||||||
exclude_patterns = []
|
exclude_patterns = []
|
||||||
html_static_path = ["_static"]
|
html_static_path = ["_static"]
|
||||||
|
|
||||||
html_theme = "pydata_sphinx_theme"
|
html_theme = "pydata_sphinx_theme"
|
||||||
html_logo = "./images/logo.png"
|
html_logo = "./images/logo.png"
|
||||||
html_favicon = "./images/logo.ico"
|
html_favicon = "./images/logo.ico"
|
||||||
|
|
||||||
html_theme_options = {
|
html_theme_options = {
|
||||||
"external_links": [
|
"external_links": [
|
||||||
{
|
{
|
||||||
"url": "https://github.com/deesiigneer/pyspapi/releases",
|
"url": "https://github.com/deesiigneer/pyspapi/releases",
|
||||||
"name": "Changelog",
|
"name": "Changelog",
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"url": "https://github.com/sp-worlds/api-docs/wiki",
|
||||||
|
"name": "SPWorlds API Docs",
|
||||||
}
|
}
|
||||||
],
|
],
|
||||||
"icon_links": [
|
"icon_links": [
|
||||||
@@ -61,24 +46,27 @@ html_theme_options = {
|
|||||||
"name": "GitHub",
|
"name": "GitHub",
|
||||||
"url": "https://github.com/deesiigneer/pyspapi",
|
"url": "https://github.com/deesiigneer/pyspapi",
|
||||||
"icon": "fab fa-brands fa-github",
|
"icon": "fab fa-brands fa-github",
|
||||||
"type": "fontawesome"
|
"type": "fontawesome",
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
"name": "Discord",
|
"name": "Discord",
|
||||||
"url": "https://discord.gg/VbyHaKRAaN",
|
"url": "https://discord.gg/VbyHaKRAaN",
|
||||||
"icon": "fab fa-brands fa-discord",
|
"icon": "fab fa-brands fa-discord",
|
||||||
"type": "fontawesome"
|
"type": "fontawesome",
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
"name": "PyPi",
|
"name": "PyPI",
|
||||||
"url": "https://pypi.org/project/pyspapi/",
|
"url": "https://pypi.org/project/pyspapi/",
|
||||||
"icon": "fab fa-brands fa-python",
|
"icon": "fab fa-brands fa-python",
|
||||||
"type": "fontawesome"
|
"type": "fontawesome",
|
||||||
}
|
},
|
||||||
],
|
],
|
||||||
"header_links_before_dropdown": 4,
|
"header_links_before_dropdown": 4,
|
||||||
"show_toc_level": 1,
|
"show_toc_level": 1,
|
||||||
"navbar_start": ["navbar-logo"],
|
"navbar_start": ["navbar-logo"],
|
||||||
"navigation_with_keys": True,
|
"navigation_with_keys": True,
|
||||||
|
"switcher": {
|
||||||
|
"json_url": json_url,
|
||||||
|
"version_match": version_match,
|
||||||
|
},
|
||||||
}
|
}
|
||||||
html_css_files = ["custom.css"]
|
|
||||||
|
|||||||
@@ -1,32 +1,31 @@
|
|||||||
:theme_html_remove_secondary_sidebar:
|
:theme_html_remove_secondary_sidebar:
|
||||||
|
|
||||||
Welcome to pyspapi
|
Добро пожаловать в pyspapi
|
||||||
===================
|
===========================
|
||||||
|
|
||||||
API wrapper for SP servers written in Python.
|
Обертка API для SPWorlds серверов, написанная на Python.
|
||||||
|
|
||||||
Getting started
|
Начало работы
|
||||||
---------------
|
---------------
|
||||||
|
|
||||||
Is this your first time using the library? This is the place to get started!
|
Вы впервые используете библиотеку? Это место, с которого нужно начать!
|
||||||
|
|
||||||
- **First steps:** :ref:`Quickstart <quickstart>`
|
- **Первые шаги:** :ref:`Быстрый старт <quickstart>`
|
||||||
- **Examples:** Many examples are available in the `examples directory <https://github.com/deesiigneer/pyspapi/tree/main/examples/>`_.
|
- **Примеры:** Много примеров доступно в `папке примеров <https://github.com/deesiigneer/pyspapi/tree/main/examples/>`_.
|
||||||
|
|
||||||
Getting help
|
Получение помощи
|
||||||
------------
|
------------------
|
||||||
|
|
||||||
If you're having trouble with something, these resources might help.
|
Если у вас есть проблемы с чем-то, эти ресурсы могут помочь.
|
||||||
|
|
||||||
- Ask questions in `Discord <https://discord.gg/VbyHaKRAaN>`_ server.
|
- Задавайте вопросы на сервере `Discord <https://discord.gg/VbyHaKRAaN>`_.
|
||||||
- If you're looking for something specific, try the :ref:`searching <search>`.
|
- Если вы ищете что-то конкретное, попробуйте :ref:`поиск <search>`.
|
||||||
- Report bugs in the `issue tracker <https://github.com/deesiigneer/pyspapi/issues>`_.
|
- Сообщайте об ошибках в `трекер проблем <https://github.com/deesiigneer/pyspapi/issues>`_.
|
||||||
- Ask in `GitHub discussions page <https://github.com/deesiigneer/pyspapi/discussions>`_.
|
|
||||||
|
|
||||||
Manuals
|
Руководства
|
||||||
-------
|
-----------
|
||||||
|
|
||||||
These pages go into great detail about everything the API can do.
|
Эти страницы подробно описывают все, что может сделать API.
|
||||||
|
|
||||||
.. toctree::
|
.. toctree::
|
||||||
:maxdepth: 1
|
:maxdepth: 1
|
||||||
|
|||||||
@@ -4,17 +4,17 @@
|
|||||||
|
|
||||||
.. currentmodule:: pyspapi
|
.. currentmodule:: pyspapi
|
||||||
|
|
||||||
Quickstart
|
Быстрый старт
|
||||||
==========
|
==============
|
||||||
|
|
||||||
This page gives a brief introduction to the library.
|
На этой странице дается краткое введение в библиотеку.
|
||||||
|
|
||||||
Checking balance
|
Проверка баланса
|
||||||
----------------
|
-----------------
|
||||||
|
|
||||||
Let's output the amount of money remaining in the card account to the console.
|
Выведем количество денег, оставшихся на счету карты, на консоль.
|
||||||
|
|
||||||
It looks something like this:
|
Это выглядит примерно так:
|
||||||
|
|
||||||
.. code-block:: python
|
.. code-block:: python
|
||||||
|
|
||||||
@@ -30,7 +30,6 @@ It looks something like this:
|
|||||||
loop = get_event_loop()
|
loop = get_event_loop()
|
||||||
loop.run_until_complete(main())
|
loop.run_until_complete(main())
|
||||||
|
|
||||||
Make sure not to name it ``pyspapi`` as that'll conflict with the library.
|
Убедитесь, что вы не называете его ``pyspapi``, так как это вызовет конфликт с библиотекой.
|
||||||
|
|
||||||
|
Вы можете найти больше примеров в `папке примеров <https://github.com/deesiigneer/pyspapi/tree/main/examples/>`_ на GitHub.
|
||||||
You can find more examples in the `examples directory <https://github.com/deesiigneer/pyspapi/tree/main/examples/>`_ on GitHub.
|
|
||||||
@@ -1,7 +1,8 @@
|
|||||||
|
import asyncio
|
||||||
from pyspapi import SPAPI
|
from pyspapi import SPAPI
|
||||||
from asyncio import get_event_loop
|
|
||||||
|
|
||||||
spapi = SPAPI(card_id='CARD_ID', token='TOKEN')
|
spapi = SPAPI(card_id="CARD_ID", token="TOKEN")
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
async def main():
|
async def main():
|
||||||
@@ -11,5 +12,4 @@ async def main():
|
|||||||
print(card.name, card.number)
|
print(card.name, card.number)
|
||||||
|
|
||||||
|
|
||||||
loop = get_event_loop()
|
asyncio.run(main())
|
||||||
loop.run_until_complete(main())
|
|
||||||
|
|||||||
@@ -1,12 +1,12 @@
|
|||||||
|
import asyncio
|
||||||
from pyspapi import SPAPI
|
from pyspapi import SPAPI
|
||||||
from asyncio import get_event_loop
|
|
||||||
|
|
||||||
spapi = SPAPI(card_id='CARD_ID', token='TOKEN')
|
spapi = SPAPI(card_id="CARD_ID", token="TOKEN")
|
||||||
|
|
||||||
|
|
||||||
async def main():
|
async def main():
|
||||||
me = await spapi.me
|
me = await spapi.me
|
||||||
print(me)
|
print(me)
|
||||||
|
|
||||||
loop = get_event_loop()
|
|
||||||
loop.run_until_complete(main())
|
asyncio.run(main())
|
||||||
|
|||||||
@@ -1,21 +1,25 @@
|
|||||||
|
import asyncio
|
||||||
from pyspapi import SPAPI
|
from pyspapi import SPAPI
|
||||||
from pyspapi.types import Item
|
from pyspapi.types import Item
|
||||||
from asyncio import get_event_loop
|
|
||||||
|
|
||||||
spapi = SPAPI(card_id='CARD_ID', token='TOKEN')
|
spapi = SPAPI(card_id="CARD_ID", token="TOKEN")
|
||||||
|
|
||||||
items = [Item('first item', 1, 2, 'first item comment').to_json(),
|
|
||||||
Item('second item', 3, 4, 'second item comment').to_json()]
|
items = [
|
||||||
|
Item("first item", 1, 2, "first item comment").to_json(),
|
||||||
|
Item("second item", 3, 4, "second item comment").to_json(),
|
||||||
|
]
|
||||||
|
|
||||||
|
|
||||||
async def main():
|
async def main():
|
||||||
print(await spapi.create_payment(items=items,
|
print(
|
||||||
redirect_url='https://www.google.com/',
|
await spapi.create_payment(
|
||||||
webhook_url='https://www.google.com/',
|
items=items,
|
||||||
data='some-data'
|
redirect_url="https://www.google.com/",
|
||||||
|
webhook_url="https://www.google.com/",
|
||||||
|
data="some-data",
|
||||||
)
|
)
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
||||||
loop = get_event_loop()
|
asyncio.run(main())
|
||||||
loop.run_until_complete(main())
|
|
||||||
|
|||||||
@@ -1,16 +1,15 @@
|
|||||||
|
import asyncio
|
||||||
from pyspapi import SPAPI
|
from pyspapi import SPAPI
|
||||||
from asyncio import get_event_loop
|
|
||||||
|
|
||||||
spapi = SPAPI(card_id='CARD_ID', token='TOKEN')
|
spapi = SPAPI(card_id="CARD_ID", token="TOKEN")
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
async def main():
|
async def main():
|
||||||
new_balance = await spapi.create_transaction(receiver='77552',
|
new_balance = await spapi.create_transaction(
|
||||||
amount=1,
|
receiver="20199", amount=1, comment="test"
|
||||||
comment="test"
|
|
||||||
)
|
)
|
||||||
print(new_balance)
|
print(new_balance)
|
||||||
|
|
||||||
|
|
||||||
loop = get_event_loop()
|
asyncio.run(main())
|
||||||
loop.run_until_complete(main())
|
|
||||||
|
|||||||
@@ -1,13 +1,13 @@
|
|||||||
|
import asyncio
|
||||||
from pyspapi import SPAPI
|
from pyspapi import SPAPI
|
||||||
from asyncio import get_event_loop
|
|
||||||
|
|
||||||
spapi = SPAPI(card_id='CARD_ID', token='TOKEN')
|
spapi = SPAPI(card_id="CARD_ID", token="TOKEN")
|
||||||
|
|
||||||
# print(spapi.webhook_verify(data='webhook_data', header='webhook_header'))
|
# print(spapi.webhook_verify(data='webhook_data', header='webhook_header'))
|
||||||
|
|
||||||
|
|
||||||
async def main():
|
async def main():
|
||||||
print(await spapi.update_webhook(url='https://example.com/webhook'))
|
print(await spapi.update_webhook(url="https://example.com/webhook"))
|
||||||
|
|
||||||
loop = get_event_loop()
|
|
||||||
loop.run_until_complete(main())
|
asyncio.run(main())
|
||||||
|
|||||||
1826
poetry.lock
generated
Normal file
1826
poetry.lock
generated
Normal file
File diff suppressed because it is too large
Load Diff
32
pyproject.toml
Normal file
32
pyproject.toml
Normal file
@@ -0,0 +1,32 @@
|
|||||||
|
[project]
|
||||||
|
name = "pyspapi"
|
||||||
|
version = "3.3.2"
|
||||||
|
description = "API wrapper for SP servers written in Python."
|
||||||
|
readme = "README.rst"
|
||||||
|
license = { text = "MIT" }
|
||||||
|
authors = [{ name = "deesiigneer", email = "xdeesiigneerx@gmail.com" }]
|
||||||
|
requires-python = ">=3.12,<3.15"
|
||||||
|
dependencies = ["aiohttp>=3.9,<4.0"]
|
||||||
|
|
||||||
|
[project.urls]
|
||||||
|
Homepage = "https://pyspapi.deesiigneer.ru"
|
||||||
|
Documentation = "https://pyspapi.readthedocs.org"
|
||||||
|
Repository = "https://github.com/deesiigneer/pyspapi"
|
||||||
|
"Issue Tracker" = "https://github.com/deesiigneer/pyspapi/issues"
|
||||||
|
Discord = "https://discord.com/invite/VbyHaKRAaN"
|
||||||
|
|
||||||
|
[project.optional-dependencies]
|
||||||
|
docs = [
|
||||||
|
"sphinx>=7,<9",
|
||||||
|
"sphinx-autobuild>=2025.8.25,<2026.0.0",
|
||||||
|
"pydata-sphinx-theme>=0.16.1,<0.17.0",
|
||||||
|
]
|
||||||
|
dev = ["ruff>=0.14,<0.15", "toml-sort>=0.24,<0.25"]
|
||||||
|
|
||||||
|
|
||||||
|
[build-system]
|
||||||
|
requires = ["poetry-core>=2.0.0,<3.0.0"]
|
||||||
|
build-backend = "poetry.core.masonry.api"
|
||||||
|
|
||||||
|
[tool.poetry]
|
||||||
|
package-mode = true
|
||||||
@@ -1,8 +1,53 @@
|
|||||||
from .spworlds import *
|
"""
|
||||||
|
SPWorlds API Wrapper
|
||||||
|
~~~~~~~~~~~~~~~~~~~
|
||||||
|
|
||||||
|
High-level client for interacting with the SPWorlds API.
|
||||||
|
|
||||||
__author__ = 'deesiigneer'
|
:copyright: (c) 2022-present deesiigneer
|
||||||
__url__ = 'https://github.com/deesiigneer/pyspapi'
|
:license: MIT, see LICENSE for more details.
|
||||||
__description__ = 'API wrapper for SP servers written in Python.'
|
"""
|
||||||
__license__ = 'MIT'
|
|
||||||
__version__ = "3.1.0"
|
import importlib.metadata
|
||||||
|
|
||||||
|
from pyspapi.exceptions import (
|
||||||
|
BadRequestError,
|
||||||
|
ClientError,
|
||||||
|
ForbiddenError,
|
||||||
|
HTTPError,
|
||||||
|
InsufficientBalanceError,
|
||||||
|
NetworkError,
|
||||||
|
NotFoundError,
|
||||||
|
RateLimitError,
|
||||||
|
ServerError,
|
||||||
|
SPAPIError,
|
||||||
|
TimeoutError,
|
||||||
|
UnauthorizedError,
|
||||||
|
ValidationError,
|
||||||
|
)
|
||||||
|
from pyspapi.spworlds import SPAPI
|
||||||
|
|
||||||
|
__all__ = [
|
||||||
|
"SPAPI",
|
||||||
|
"BadRequestError",
|
||||||
|
"ClientError",
|
||||||
|
"ForbiddenError",
|
||||||
|
"HTTPError",
|
||||||
|
"InsufficientBalanceError",
|
||||||
|
"NetworkError",
|
||||||
|
"NotFoundError",
|
||||||
|
"RateLimitError",
|
||||||
|
"ServerError",
|
||||||
|
"SPAPIError",
|
||||||
|
"TimeoutError",
|
||||||
|
"UnauthorizedError",
|
||||||
|
"ValidationError",
|
||||||
|
]
|
||||||
|
|
||||||
|
__title__: str = "pyspapi"
|
||||||
|
__author__: str = "deesiigneer"
|
||||||
|
__description__: str = "API wrapper for SP servers written in Python."
|
||||||
|
__license__: str = "MIT"
|
||||||
|
__url__: str = "https://github.com/deesiigneer/pyspapi"
|
||||||
|
__copyright__: str = "2022-present deesiigneer"
|
||||||
|
__version__: str = importlib.metadata.version("pyspapi")
|
||||||
|
|||||||
@@ -1,2 +1,3 @@
|
|||||||
from .api import APISession
|
from .api import APISession
|
||||||
|
|
||||||
|
__all__ = ["APISession"]
|
||||||
|
|||||||
@@ -1,90 +1,352 @@
|
|||||||
from base64 import b64encode
|
import asyncio
|
||||||
from logging import getLogger
|
|
||||||
import aiohttp
|
|
||||||
import json
|
import json
|
||||||
|
from base64 import b64encode
|
||||||
|
from logging import NullHandler, getLogger
|
||||||
|
from typing import Any, Dict, Optional
|
||||||
|
|
||||||
|
import aiohttp
|
||||||
|
|
||||||
log = getLogger('pyspapi')
|
from pyspapi.exceptions import (
|
||||||
|
BadRequestError,
|
||||||
|
ClientError,
|
||||||
|
ForbiddenError,
|
||||||
|
HTTPError,
|
||||||
|
InsufficientBalanceError,
|
||||||
|
NetworkError,
|
||||||
|
NotFoundError,
|
||||||
|
RateLimitError,
|
||||||
|
ServerError,
|
||||||
|
SPAPIError,
|
||||||
|
UnauthorizedError,
|
||||||
|
ValidationError,
|
||||||
|
)
|
||||||
|
from pyspapi.exceptions import (
|
||||||
|
TimeoutError as APITimeoutError,
|
||||||
|
)
|
||||||
|
|
||||||
|
log = getLogger("pyspapi")
|
||||||
|
log.addHandler(NullHandler())
|
||||||
|
|
||||||
|
|
||||||
class APISession(object):
|
class APISession(object):
|
||||||
""" Holds aiohttp session for its lifetime and wraps different types of request """
|
def __init__(
|
||||||
|
self,
|
||||||
|
card_id: str,
|
||||||
|
token: str,
|
||||||
|
timeout: int = 5,
|
||||||
|
sleep_time: float = 0.2,
|
||||||
|
retries: int = 0,
|
||||||
|
raise_exception: bool = False,
|
||||||
|
proxy: str = None,
|
||||||
|
):
|
||||||
|
self._validate_credentials(card_id, token)
|
||||||
|
|
||||||
def __init__(self, card_id: str, token: str, timeout=5, sleep_time=0.2, retries=0):
|
self.__url = "https://spworlds.ru/api/public/"
|
||||||
self.__url = "https://spworlds.ru/"
|
|
||||||
self.__id = card_id
|
self.__id = card_id
|
||||||
self.__token = token
|
self.__token = token
|
||||||
self.__sleep_timeout = sleep_time
|
self.__sleep_timeout = sleep_time
|
||||||
self.__retries = retries
|
self.__retries = retries
|
||||||
self.__timeout = timeout
|
self.__timeout = timeout
|
||||||
self.session = None
|
self.__raise_exception = raise_exception
|
||||||
|
self.__proxy = proxy
|
||||||
|
self.session: Optional[aiohttp.ClientSession] = None
|
||||||
|
self._session_owner = False
|
||||||
|
|
||||||
|
@staticmethod
|
||||||
|
def _validate_credentials(card_id: str, token: str) -> None:
|
||||||
|
if not card_id or not isinstance(card_id, str):
|
||||||
|
raise ValueError("card_id must be a non-empty string")
|
||||||
|
if not token or not isinstance(token, str):
|
||||||
|
raise ValueError("token must be a non-empty string")
|
||||||
|
|
||||||
async def __aenter__(self):
|
async def __aenter__(self):
|
||||||
|
try:
|
||||||
|
if not self.session:
|
||||||
self.session = aiohttp.ClientSession(
|
self.session = aiohttp.ClientSession(
|
||||||
json_serialize=json.dumps,
|
json_serialize=json.dumps,
|
||||||
timeout=aiohttp.ClientTimeout(total=self.__timeout))
|
timeout=aiohttp.ClientTimeout(total=self.__timeout),
|
||||||
|
proxy=self.__proxy,
|
||||||
|
)
|
||||||
|
self._session_owner = True
|
||||||
|
log.debug(f"[pyspapi] Session created with timeout={self.__timeout}s")
|
||||||
|
else:
|
||||||
|
self._session_owner = False
|
||||||
|
except Exception as e:
|
||||||
|
log.error(f"[pyspapi] Failed to create session: {e}")
|
||||||
|
raise
|
||||||
return self
|
return self
|
||||||
|
|
||||||
async def __aexit__(self, *err):
|
async def __aexit__(self, exc_type, exc_val, exc_tb):
|
||||||
|
if self._session_owner and self.session:
|
||||||
|
try:
|
||||||
await self.session.close()
|
await self.session.close()
|
||||||
|
log.debug("[pyspapi] Session closed")
|
||||||
|
except Exception as e:
|
||||||
|
log.error(f"[pyspapi] Error closing session: {e}")
|
||||||
self.session = None
|
self.session = None
|
||||||
|
|
||||||
def __get_url(self, endpoint: str) -> str:
|
return False
|
||||||
""" Get URL for requests """
|
|
||||||
url = self.__url
|
|
||||||
api = "api/public"
|
|
||||||
return f"{url}{api}/{endpoint}"
|
|
||||||
|
|
||||||
async def __request(self, method: str, endpoint: str, data=None):
|
def _get_auth_header(self) -> str:
|
||||||
url = self.__get_url(endpoint)
|
credentials = f"{self.__id}:{self.__token}"
|
||||||
response = await self.session.request(
|
encoded = b64encode(credentials.encode("utf-8")).decode("utf-8")
|
||||||
method=method,
|
return f"Bearer {encoded}"
|
||||||
url=url,
|
|
||||||
json=data,
|
def _get_headers(self) -> Dict[str, str]:
|
||||||
headers={'Authorization': f"Bearer {str(b64encode(str(f'{self.__id}:{self.__token}').encode('utf-8')), 'utf-8')}",
|
return {
|
||||||
'User-Agent': 'https://github.com/deesiigneer/pyspapi'},
|
"Authorization": self._get_auth_header(),
|
||||||
ssl=True
|
"User-Agent": "https://github.com/deesiigneer/pyspapi",
|
||||||
|
"Content-Type": "application/json",
|
||||||
|
}
|
||||||
|
|
||||||
|
def _parse_error_response(self, content: str) -> Dict[str, Any]:
|
||||||
|
try:
|
||||||
|
return json.loads(content)
|
||||||
|
except json.JSONDecodeError:
|
||||||
|
return {"raw_response": content}
|
||||||
|
|
||||||
|
def _format_error_message(
|
||||||
|
self, error_data: Dict[str, Any], status_code: int
|
||||||
|
) -> str:
|
||||||
|
message = (
|
||||||
|
error_data.get("message")
|
||||||
|
or error_data.get("detail")
|
||||||
|
or error_data.get("msg")
|
||||||
|
or f"HTTP {status_code}"
|
||||||
)
|
)
|
||||||
if response.status not in [200, 201]:
|
|
||||||
message = await response.json()
|
if "error" in error_data:
|
||||||
raise aiohttp.ClientResponseError(
|
message = f"{message} (error: {error_data['error']})"
|
||||||
code=response.status,
|
|
||||||
message=message['message'],
|
return message
|
||||||
headers=response.headers,
|
|
||||||
history=response.history,
|
def _log_error_with_details(
|
||||||
request_info=response.request_info
|
self,
|
||||||
|
method: str,
|
||||||
|
endpoint: str,
|
||||||
|
status_code: int,
|
||||||
|
error_data: Dict[str, Any],
|
||||||
|
content: str,
|
||||||
|
) -> None:
|
||||||
|
message = self._format_error_message(error_data, status_code)
|
||||||
|
|
||||||
|
log.error(
|
||||||
|
f"[pyspapi] HTTP {status_code}: {method.upper()} {endpoint} | {message}"
|
||||||
)
|
)
|
||||||
return response
|
|
||||||
|
|
||||||
async def get(self, endpoint, **kwargs):
|
def _should_retry(self, status_code: int, attempt: int) -> bool:
|
||||||
""" GET requests """
|
if attempt > self.__retries:
|
||||||
try:
|
return False
|
||||||
return await self.__request("GET", endpoint, None, **kwargs)
|
return status_code in {408, 429, 500, 502, 503, 504}
|
||||||
except aiohttp.ClientResponseError as e:
|
|
||||||
log.error(f"GET request to {endpoint} failed with status {e.status}: {e.message}")
|
|
||||||
except aiohttp.ClientError as e:
|
|
||||||
log.error(f"GET request to {endpoint} failed: {e}")
|
|
||||||
except Exception as e:
|
|
||||||
log.error(f"GET request to {endpoint} failed: {e}")
|
|
||||||
|
|
||||||
async def post(self, endpoint, data, **kwargs):
|
async def _handle_http_error(
|
||||||
""" POST requests """
|
self,
|
||||||
try:
|
method: str,
|
||||||
return await self.__request("POST", endpoint, data, **kwargs)
|
endpoint: str,
|
||||||
except aiohttp.ClientResponseError as e:
|
status_code: int,
|
||||||
log.error(f"POST request to {endpoint} failed with status {e.status}: {e.message}")
|
content: str,
|
||||||
except aiohttp.ClientError as e:
|
) -> None:
|
||||||
log.error(f"POST request to {endpoint} failed: {e}")
|
error_data = self._parse_error_response(content)
|
||||||
except Exception as e:
|
|
||||||
log.error(f"POST request to {endpoint} failed: {e}")
|
self._log_error_with_details(method, endpoint, status_code, error_data, content)
|
||||||
|
|
||||||
|
if not self.__raise_exception:
|
||||||
|
return
|
||||||
|
|
||||||
|
error_message = self._format_error_message(error_data, status_code)
|
||||||
|
|
||||||
|
if status_code == 400:
|
||||||
|
error_code = error_data.get("error", "")
|
||||||
|
if "notEnoughBalance" in error_code:
|
||||||
|
raise InsufficientBalanceError(details=error_data)
|
||||||
|
raise BadRequestError(details=error_data)
|
||||||
|
elif status_code == 401:
|
||||||
|
raise UnauthorizedError(details=error_data)
|
||||||
|
elif status_code == 403:
|
||||||
|
raise ForbiddenError(details=error_data)
|
||||||
|
elif status_code == 404:
|
||||||
|
raise NotFoundError(resource=endpoint, details=error_data)
|
||||||
|
elif status_code == 422:
|
||||||
|
raise ValidationError(error_data)
|
||||||
|
elif status_code == 429:
|
||||||
|
retry_after = error_data.get("retry_after")
|
||||||
|
raise RateLimitError(retry_after=retry_after, details=error_data)
|
||||||
|
elif 400 <= status_code < 500:
|
||||||
|
raise ClientError(
|
||||||
|
status_code=status_code,
|
||||||
|
message=error_message,
|
||||||
|
response_body=content,
|
||||||
|
details=error_data,
|
||||||
|
)
|
||||||
|
elif 500 <= status_code < 600:
|
||||||
|
raise ServerError(
|
||||||
|
status_code=status_code,
|
||||||
|
message=error_message,
|
||||||
|
response_body=content,
|
||||||
|
details=error_data,
|
||||||
|
)
|
||||||
|
else:
|
||||||
|
raise HTTPError(
|
||||||
|
status_code=status_code,
|
||||||
|
message=error_message,
|
||||||
|
response_body=content,
|
||||||
|
details=error_data,
|
||||||
|
)
|
||||||
|
|
||||||
|
async def request(
|
||||||
|
self, method: str, endpoint: str, data: Optional[Dict] = None
|
||||||
|
) -> Any:
|
||||||
|
url = self.__url + endpoint
|
||||||
|
headers = self._get_headers()
|
||||||
|
|
||||||
|
attempt = 0
|
||||||
|
|
||||||
|
while True:
|
||||||
|
attempt += 1
|
||||||
|
if attempt > 1:
|
||||||
|
log.warning(
|
||||||
|
f"[pyspapi] Retry attempt {attempt}/{self.__retries + 1}: {method.upper()} {endpoint}"
|
||||||
|
)
|
||||||
|
|
||||||
async def put(self, endpoint, data, **kwargs):
|
|
||||||
""" PUT requests """
|
|
||||||
try:
|
try:
|
||||||
return await self.__request("PUT", endpoint, data, **kwargs)
|
async with self.session.request(
|
||||||
except aiohttp.ClientResponseError as e:
|
method, url, json=data, headers=headers
|
||||||
log.error(f"PUT request to {endpoint} failed with status {e.status}: {e.message}")
|
) as resp:
|
||||||
|
response_text = await resp.text()
|
||||||
|
|
||||||
|
if resp.status == 422:
|
||||||
|
try:
|
||||||
|
errors = json.loads(response_text)
|
||||||
|
except json.JSONDecodeError:
|
||||||
|
errors = {"raw_response": response_text}
|
||||||
|
|
||||||
|
error_msg = self._format_error_message(errors, 422)
|
||||||
|
log.error(
|
||||||
|
f"[pyspapi] Validation error (422): {method.upper()} {endpoint} | {error_msg}"
|
||||||
|
)
|
||||||
|
if self.__raise_exception:
|
||||||
|
raise ValidationError(errors)
|
||||||
|
return None
|
||||||
|
|
||||||
|
if resp.status >= 400:
|
||||||
|
await self._handle_http_error(
|
||||||
|
method, endpoint, resp.status, response_text
|
||||||
|
)
|
||||||
|
|
||||||
|
if self._should_retry(resp.status, attempt):
|
||||||
|
await asyncio.sleep(self.__sleep_timeout * attempt)
|
||||||
|
continue
|
||||||
|
|
||||||
|
return None
|
||||||
|
|
||||||
|
try:
|
||||||
|
return await resp.json()
|
||||||
|
except json.JSONDecodeError as e:
|
||||||
|
log.error(
|
||||||
|
f"[pyspapi] Failed to parse JSON response: {e} | Status: {resp.status}"
|
||||||
|
)
|
||||||
|
if self.__raise_exception:
|
||||||
|
raise SPAPIError(
|
||||||
|
status_code=resp.status,
|
||||||
|
message="Invalid JSON in response",
|
||||||
|
details={
|
||||||
|
"error": str(e),
|
||||||
|
"response": response_text[:500],
|
||||||
|
},
|
||||||
|
)
|
||||||
|
return None
|
||||||
|
|
||||||
|
except asyncio.TimeoutError:
|
||||||
|
log.warning(
|
||||||
|
f"[pyspapi] Request timeout ({self.__timeout}s): {method.upper()} {endpoint} | Attempt {attempt}/{self.__retries + 1}"
|
||||||
|
)
|
||||||
|
|
||||||
|
if self._should_retry(408, attempt):
|
||||||
|
await asyncio.sleep(self.__sleep_timeout * attempt)
|
||||||
|
continue
|
||||||
|
|
||||||
|
log.error("[pyspapi] Max retries reached for timeout")
|
||||||
|
if self.__raise_exception:
|
||||||
|
raise APITimeoutError(
|
||||||
|
timeout=self.__timeout,
|
||||||
|
endpoint=endpoint,
|
||||||
|
details={"method": method, "attempt": attempt},
|
||||||
|
)
|
||||||
|
return None
|
||||||
|
|
||||||
|
except aiohttp.ClientSSLError as e:
|
||||||
|
log.error(f"[pyspapi] SSL error: {e} | {method.upper()} {endpoint}")
|
||||||
|
if self.__raise_exception:
|
||||||
|
raise NetworkError(
|
||||||
|
message=f"SSL error: {str(e)}",
|
||||||
|
details={
|
||||||
|
"method": method,
|
||||||
|
"endpoint": endpoint,
|
||||||
|
"error": str(e),
|
||||||
|
},
|
||||||
|
)
|
||||||
|
return None
|
||||||
|
|
||||||
|
except (aiohttp.ClientConnectorError, aiohttp.ClientOSError) as e:
|
||||||
|
log.warning(
|
||||||
|
f"[pyspapi] Connection error: {e} | {method.upper()} {endpoint} | Attempt {attempt}/{self.__retries + 1}"
|
||||||
|
)
|
||||||
|
|
||||||
|
if self._should_retry(0, attempt):
|
||||||
|
await asyncio.sleep(self.__sleep_timeout * attempt)
|
||||||
|
continue
|
||||||
|
|
||||||
|
log.error("[pyspapi] Max retries reached for connection error")
|
||||||
|
if self.__raise_exception:
|
||||||
|
raise NetworkError(
|
||||||
|
message=f"Connection error: {str(e)}",
|
||||||
|
details={
|
||||||
|
"method": method,
|
||||||
|
"endpoint": endpoint,
|
||||||
|
"error": str(e),
|
||||||
|
"attempt": attempt,
|
||||||
|
},
|
||||||
|
)
|
||||||
|
return None
|
||||||
|
|
||||||
except aiohttp.ClientError as e:
|
except aiohttp.ClientError as e:
|
||||||
log.error(f"PUT request to {endpoint} failed: {e}")
|
log.error(f"[pyspapi] Client error: {e} | {method.upper()} {endpoint}")
|
||||||
|
if self.__raise_exception:
|
||||||
|
raise NetworkError(
|
||||||
|
message=f"HTTP client error: {str(e)}",
|
||||||
|
details={
|
||||||
|
"method": method,
|
||||||
|
"endpoint": endpoint,
|
||||||
|
"error": str(e),
|
||||||
|
},
|
||||||
|
)
|
||||||
|
return None
|
||||||
|
|
||||||
|
except SPAPIError:
|
||||||
|
raise
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
log.error(f"PUT request to {endpoint} failed: {e}")
|
log.exception(
|
||||||
|
f"[pyspapi] Unexpected error: {e} | {method.upper()} {endpoint}"
|
||||||
|
)
|
||||||
|
if self.__raise_exception:
|
||||||
|
raise SPAPIError(
|
||||||
|
message=f"Unexpected error: {str(e)}",
|
||||||
|
details={
|
||||||
|
"error": str(e),
|
||||||
|
"method": method,
|
||||||
|
"endpoint": endpoint,
|
||||||
|
},
|
||||||
|
)
|
||||||
|
return None
|
||||||
|
|
||||||
|
async def get(self, endpoint: str) -> Any:
|
||||||
|
async with self:
|
||||||
|
return await self.request("GET", endpoint)
|
||||||
|
|
||||||
|
async def post(self, endpoint: str, data: Optional[Dict] = None) -> Any:
|
||||||
|
async with self:
|
||||||
|
return await self.request("POST", endpoint, data)
|
||||||
|
|
||||||
|
async def put(self, endpoint: str, data: Optional[Dict] = None) -> Any:
|
||||||
|
async with self:
|
||||||
|
return await self.request("PUT", endpoint, data)
|
||||||
|
|||||||
@@ -0,0 +1,197 @@
|
|||||||
|
from typing import Any, Dict, Optional
|
||||||
|
|
||||||
|
|
||||||
|
class SPAPIError(Exception):
|
||||||
|
"""
|
||||||
|
Базовая ошибка для всех исключений, связанных с API SPWorlds.
|
||||||
|
"""
|
||||||
|
|
||||||
|
def __init__(
|
||||||
|
self,
|
||||||
|
status_code: Optional[int] = None,
|
||||||
|
message: str = "",
|
||||||
|
details: Optional[Dict[str, Any]] = None,
|
||||||
|
):
|
||||||
|
self.status_code = status_code
|
||||||
|
self.message = message
|
||||||
|
self.details = details or {}
|
||||||
|
error_msg = f"[{status_code}] {message}" if status_code else message
|
||||||
|
super().__init__(error_msg)
|
||||||
|
|
||||||
|
def __str__(self):
|
||||||
|
if self.status_code:
|
||||||
|
return f"{self.__class__.__name__}: [{self.status_code}] {self.message}"
|
||||||
|
return f"{self.__class__.__name__}: {self.message}"
|
||||||
|
|
||||||
|
def __repr__(self):
|
||||||
|
return f"{self.__class__.__name__}(status_code={self.status_code}, message={self.message!r}, details={self.details!r})"
|
||||||
|
|
||||||
|
|
||||||
|
class ValidationError(SPAPIError):
|
||||||
|
"""
|
||||||
|
Ошибка валидации (HTTP 422).
|
||||||
|
"""
|
||||||
|
|
||||||
|
def __init__(self, errors: Dict[str, Any]):
|
||||||
|
self.errors = errors
|
||||||
|
super().__init__(
|
||||||
|
status_code=422,
|
||||||
|
message="Validation failed",
|
||||||
|
details={"validation_errors": errors},
|
||||||
|
)
|
||||||
|
|
||||||
|
def __str__(self):
|
||||||
|
return f"{self.__class__.__name__}: {self.errors}"
|
||||||
|
|
||||||
|
|
||||||
|
class NetworkError(SPAPIError):
|
||||||
|
"""
|
||||||
|
Ошибка сетевого соединения.
|
||||||
|
"""
|
||||||
|
|
||||||
|
def __init__(self, message: str, details: Optional[Dict[str, Any]] = None):
|
||||||
|
super().__init__(message=message, details=details)
|
||||||
|
|
||||||
|
|
||||||
|
class TimeoutError(SPAPIError):
|
||||||
|
"""
|
||||||
|
Ошибка истечения времени ожидания.
|
||||||
|
"""
|
||||||
|
|
||||||
|
def __init__(
|
||||||
|
self,
|
||||||
|
timeout: float,
|
||||||
|
endpoint: str = "",
|
||||||
|
details: Optional[Dict[str, Any]] = None,
|
||||||
|
):
|
||||||
|
msg = f"Request timeout after {timeout}s"
|
||||||
|
if endpoint:
|
||||||
|
msg += f" for endpoint: {endpoint}"
|
||||||
|
super().__init__(
|
||||||
|
message=msg, details=details or {"timeout": timeout, "endpoint": endpoint}
|
||||||
|
)
|
||||||
|
|
||||||
|
|
||||||
|
class HTTPError(SPAPIError):
|
||||||
|
"""
|
||||||
|
Ошибка HTTP (4xx, 5xx).
|
||||||
|
"""
|
||||||
|
|
||||||
|
def __init__(
|
||||||
|
self,
|
||||||
|
status_code: int,
|
||||||
|
message: str = "",
|
||||||
|
response_body: str = "",
|
||||||
|
details: Optional[Dict[str, Any]] = None,
|
||||||
|
):
|
||||||
|
self.response_body = response_body
|
||||||
|
super().__init__(
|
||||||
|
status_code=status_code,
|
||||||
|
message=message or f"HTTP {status_code}",
|
||||||
|
details=details or {"response_body": response_body},
|
||||||
|
)
|
||||||
|
|
||||||
|
|
||||||
|
class ClientError(HTTPError):
|
||||||
|
"""
|
||||||
|
Ошибка клиента (4xx).
|
||||||
|
"""
|
||||||
|
|
||||||
|
pass
|
||||||
|
|
||||||
|
|
||||||
|
class ServerError(HTTPError):
|
||||||
|
"""
|
||||||
|
Ошибка сервера (5xx).
|
||||||
|
"""
|
||||||
|
|
||||||
|
pass
|
||||||
|
|
||||||
|
|
||||||
|
class RateLimitError(ClientError):
|
||||||
|
"""
|
||||||
|
Превышен лимит запросов (HTTP 429).
|
||||||
|
"""
|
||||||
|
|
||||||
|
def __init__(
|
||||||
|
self,
|
||||||
|
retry_after: Optional[int] = None,
|
||||||
|
details: Optional[Dict[str, Any]] = None,
|
||||||
|
):
|
||||||
|
self.retry_after = retry_after
|
||||||
|
msg = "Rate limit exceeded"
|
||||||
|
if retry_after:
|
||||||
|
msg += f". Retry after {retry_after}s"
|
||||||
|
super().__init__(
|
||||||
|
status_code=429,
|
||||||
|
message=msg,
|
||||||
|
details=details or {"retry_after": retry_after},
|
||||||
|
)
|
||||||
|
|
||||||
|
|
||||||
|
class UnauthorizedError(ClientError):
|
||||||
|
"""
|
||||||
|
Ошибка аутентификации (HTTP 401).
|
||||||
|
"""
|
||||||
|
|
||||||
|
def __init__(self, details: Optional[Dict[str, Any]] = None):
|
||||||
|
super().__init__(
|
||||||
|
status_code=401,
|
||||||
|
message="Unauthorized. Invalid or missing credentials.",
|
||||||
|
details=details,
|
||||||
|
)
|
||||||
|
|
||||||
|
|
||||||
|
class ForbiddenError(ClientError):
|
||||||
|
"""
|
||||||
|
Ошибка доступа (HTTP 403).
|
||||||
|
"""
|
||||||
|
|
||||||
|
def __init__(self, details: Optional[Dict[str, Any]] = None):
|
||||||
|
super().__init__(
|
||||||
|
status_code=403,
|
||||||
|
message="Forbidden. Access denied.",
|
||||||
|
details=details,
|
||||||
|
)
|
||||||
|
|
||||||
|
|
||||||
|
class NotFoundError(ClientError):
|
||||||
|
"""
|
||||||
|
Ресурс не найден (HTTP 404).
|
||||||
|
"""
|
||||||
|
|
||||||
|
def __init__(self, resource: str = "", details: Optional[Dict[str, Any]] = None):
|
||||||
|
msg = "Resource not found"
|
||||||
|
if resource:
|
||||||
|
msg += f": {resource}"
|
||||||
|
super().__init__(
|
||||||
|
status_code=404,
|
||||||
|
message=msg,
|
||||||
|
details=details or {"resource": resource},
|
||||||
|
)
|
||||||
|
|
||||||
|
|
||||||
|
class BadRequestError(ClientError):
|
||||||
|
"""
|
||||||
|
Некорректный запрос (HTTP 400).
|
||||||
|
"""
|
||||||
|
|
||||||
|
def __init__(self, details: Optional[Dict[str, Any]] = None):
|
||||||
|
super().__init__(
|
||||||
|
status_code=400,
|
||||||
|
message="Bad request. Invalid request parameters.",
|
||||||
|
details=details,
|
||||||
|
)
|
||||||
|
|
||||||
|
|
||||||
|
class InsufficientBalanceError(ClientError):
|
||||||
|
"""
|
||||||
|
Недостаточно средств на счете.
|
||||||
|
"""
|
||||||
|
|
||||||
|
def __init__(self, details: Optional[Dict[str, Any]] = None):
|
||||||
|
super().__init__(
|
||||||
|
status_code=400,
|
||||||
|
message="Insufficient balance. Not enough funds to complete the transaction.",
|
||||||
|
details=details or {"error": "error.public.transactions.notEnoughBalance"},
|
||||||
|
)
|
||||||
|
|||||||
@@ -1,21 +1,35 @@
|
|||||||
from .api import APISession
|
|
||||||
from .types import User
|
|
||||||
from .types.me import Account
|
|
||||||
from .types.payment import Item
|
|
||||||
from hmac import new, compare_digest
|
|
||||||
from hashlib import sha256
|
|
||||||
from base64 import b64encode
|
from base64 import b64encode
|
||||||
import aiohttp
|
from hashlib import sha256
|
||||||
|
from hmac import compare_digest, new
|
||||||
|
from typing import Optional
|
||||||
|
|
||||||
__all__ = ['SPAPI']
|
from pyspapi.api import APISession
|
||||||
|
from pyspapi.exceptions import InsufficientBalanceError
|
||||||
|
from pyspapi.types import User
|
||||||
|
from pyspapi.types.me import Account
|
||||||
|
from pyspapi.types.payment import Item
|
||||||
|
|
||||||
|
__all__ = ["SPAPI"]
|
||||||
|
|
||||||
|
|
||||||
class SPAPI(APISession):
|
class SPAPI(APISession):
|
||||||
"""
|
"""
|
||||||
Представляет собой клиент API для взаимодействия с конкретным сервисом.
|
pyspapi — высокоуровневый клиент для взаимодействия с SPWorlds API.
|
||||||
|
|
||||||
|
Предоставляет удобные методы для работы с балансом карты, вебхуками,
|
||||||
|
информацией о пользователе, транзакциями и платежами, а также верификацией вебхуков.
|
||||||
"""
|
"""
|
||||||
|
|
||||||
def __init__(self, card_id=None, token=None, timeout=5, sleep_time=0.2, retries=0):
|
def __init__(
|
||||||
|
self,
|
||||||
|
card_id: str,
|
||||||
|
token: str,
|
||||||
|
timeout: int = 5,
|
||||||
|
sleep_time: float = 0.2,
|
||||||
|
retries: int = 0,
|
||||||
|
raise_exception: bool = False,
|
||||||
|
proxy: str = None,
|
||||||
|
):
|
||||||
"""
|
"""
|
||||||
Инициализирует объект SPAPI.
|
Инициализирует объект SPAPI.
|
||||||
|
|
||||||
@@ -24,13 +38,19 @@ class SPAPI(APISession):
|
|||||||
:param token: Токен API.
|
:param token: Токен API.
|
||||||
:type token: str
|
:type token: str
|
||||||
:param timeout: Таймаут для запросов API в секундах. По умолчанию 5.
|
:param timeout: Таймаут для запросов API в секундах. По умолчанию 5.
|
||||||
:type timeout: int, optional
|
:type timeout: int
|
||||||
:param sleep_time: Время ожидания между повторными запросами в секундах. По умолчанию 0.2.
|
:param sleep_time: Время ожидания между повторными запросами в секундах. По умолчанию 0.2.
|
||||||
:type sleep_time: float, optional
|
:type sleep_time: float
|
||||||
:param retries: Количество повторных попыток для неудачных запросов. По умолчанию 0.
|
:param retries: Количество повторных попыток для неудачных запросов. По умолчанию 0.
|
||||||
:type retries: int, optional
|
:type retries: int
|
||||||
|
:param raise_exception: Поднимать исключения при ошибке, если True.
|
||||||
|
:type raise_exception: bool
|
||||||
|
:param proxy: Прокси для подключения к API. По умолчанию None.
|
||||||
|
:type proxy: str
|
||||||
"""
|
"""
|
||||||
super().__init__(card_id, token, timeout, sleep_time, retries)
|
super().__init__(
|
||||||
|
card_id, token, timeout, sleep_time, retries, raise_exception, proxy
|
||||||
|
)
|
||||||
self.__card_id = card_id
|
self.__card_id = card_id
|
||||||
self.__token = token
|
self.__token = token
|
||||||
|
|
||||||
@@ -38,67 +58,73 @@ class SPAPI(APISession):
|
|||||||
"""
|
"""
|
||||||
Возвращает строковое представление объекта SPAPI.
|
Возвращает строковое представление объекта SPAPI.
|
||||||
"""
|
"""
|
||||||
return "%s(%s)" % (
|
return f"{self.__class__.__name__}({vars(self)})"
|
||||||
self.__class__.__name__,
|
|
||||||
self.__dict__
|
|
||||||
)
|
|
||||||
|
|
||||||
async def __get(self, method):
|
|
||||||
"""
|
|
||||||
Выполняет GET-запрос к API.
|
|
||||||
|
|
||||||
:param method: Метод API для вызова.
|
|
||||||
:type method: str
|
|
||||||
|
|
||||||
:return: JSON-ответ от API.
|
|
||||||
:rtype: dict
|
|
||||||
"""
|
|
||||||
async with APISession(self.__card_id, self.__token) as session:
|
|
||||||
response = await session.get(method)
|
|
||||||
response = await response.json()
|
|
||||||
return response
|
|
||||||
|
|
||||||
@property
|
@property
|
||||||
async def balance(self):
|
async def balance(self) -> Optional[int]:
|
||||||
"""
|
"""
|
||||||
Получает текущий баланс карты.
|
Получает текущий баланс карты.
|
||||||
|
|
||||||
:return: Текущий баланс карты.
|
:return: Текущий баланс карты.
|
||||||
:rtype: int
|
:rtype: int
|
||||||
"""
|
"""
|
||||||
card = await self.__get('card')
|
try:
|
||||||
return card['balance']
|
response = await super().get("card")
|
||||||
|
if response is None:
|
||||||
|
return None
|
||||||
|
return int(response.get("balance", 0))
|
||||||
|
except (KeyError, ValueError, TypeError) as e:
|
||||||
|
log = __import__("logging").getLogger("pyspapi")
|
||||||
|
log.error(f"Failed to parse balance response: {e}")
|
||||||
|
return None
|
||||||
|
|
||||||
@property
|
@property
|
||||||
async def webhook(self) -> str:
|
async def webhook(self) -> Optional[str]:
|
||||||
"""
|
"""
|
||||||
Получает URL вебхука, связанного с картой.
|
Получает URL вебхука, связанного с картой.
|
||||||
|
|
||||||
:return: URL вебхука.
|
:return: URL вебхука.
|
||||||
:rtype: str
|
:rtype: str
|
||||||
"""
|
"""
|
||||||
card = await self.__get('card')
|
try:
|
||||||
return card['webhook']
|
response = await super().get("card")
|
||||||
|
if response is None:
|
||||||
|
return None
|
||||||
|
return str(response.get("webhook", ""))
|
||||||
|
except (KeyError, ValueError, TypeError) as e:
|
||||||
|
log = __import__("logging").getLogger("pyspapi")
|
||||||
|
log.error(f"Failed to parse webhook response: {e}")
|
||||||
|
return None
|
||||||
|
|
||||||
@property
|
@property
|
||||||
async def me(self):
|
async def me(self) -> Optional[Account]:
|
||||||
"""
|
"""
|
||||||
Получает информацию об аккаунте текущего пользователя.
|
Получает информацию об аккаунте текущего пользователя.
|
||||||
|
|
||||||
:return: Объект Account, представляющий аккаунт текущего пользователя.
|
:return: Объект Account, представляющий аккаунт текущего пользователя.
|
||||||
:rtype: Account
|
:rtype: :class:`Account`
|
||||||
"""
|
"""
|
||||||
me = await self.__get('account/me')
|
try:
|
||||||
return Account(
|
me = await super().get("accounts/me")
|
||||||
account_id=me['id'],
|
if me is None:
|
||||||
username=me['username'],
|
return None
|
||||||
status=me['status'],
|
|
||||||
roles=me['roles'],
|
|
||||||
city=me['city'],
|
|
||||||
cards=me['cards'],
|
|
||||||
created_at=me['createdAt'])
|
|
||||||
|
|
||||||
async def get_user(self, discord_id: int) -> User:
|
return Account(
|
||||||
|
account_id=me.get("id"),
|
||||||
|
username=me.get("username"),
|
||||||
|
minecraftuuid=me.get("minecraftUUID"),
|
||||||
|
status=me.get("status"),
|
||||||
|
roles=me.get("roles", []),
|
||||||
|
cities=me.get("cities", []),
|
||||||
|
cards=me.get("cards", []),
|
||||||
|
created_at=me.get("createdAt"),
|
||||||
|
)
|
||||||
|
except (KeyError, TypeError) as e:
|
||||||
|
log = __import__("logging").getLogger("pyspapi")
|
||||||
|
log.error(f"Failed to parse account response: {e}")
|
||||||
|
return None
|
||||||
|
|
||||||
|
async def get_user(self, discord_id: int) -> Optional[User]:
|
||||||
"""
|
"""
|
||||||
Получает информацию о пользователе по его ID в Discord.
|
Получает информацию о пользователе по его ID в Discord.
|
||||||
|
|
||||||
@@ -106,13 +132,29 @@ class SPAPI(APISession):
|
|||||||
:type discord_id: int
|
:type discord_id: int
|
||||||
|
|
||||||
:return: Объект User, представляющий пользователя.
|
:return: Объект User, представляющий пользователя.
|
||||||
:rtype: User
|
:rtype: :class:`User`
|
||||||
"""
|
"""
|
||||||
user = await self.__get(f'users/{discord_id}')
|
if not discord_id:
|
||||||
cards = await self.__get(f"accounts/{user['username']}/cards")
|
raise ValueError("discord_id must be a non-empty integer")
|
||||||
return User(user['username'], user['uuid'], cards)
|
|
||||||
|
|
||||||
async def create_transaction(self, receiver: str, amount: int, comment: str):
|
try:
|
||||||
|
user = await super().get(f"users/{discord_id}")
|
||||||
|
if user is None:
|
||||||
|
return None
|
||||||
|
|
||||||
|
cards = await super().get(f"accounts/{user['username']}/cards")
|
||||||
|
if cards is None:
|
||||||
|
cards = []
|
||||||
|
|
||||||
|
return User(user["username"], user["uuid"], cards)
|
||||||
|
except (KeyError, TypeError) as e:
|
||||||
|
log = __import__("logging").getLogger("pyspapi")
|
||||||
|
log.error(f"Failed to parse user response: {e}")
|
||||||
|
return None
|
||||||
|
|
||||||
|
async def create_transaction(
|
||||||
|
self, receiver: str, amount: int, comment: str
|
||||||
|
) -> Optional[int]:
|
||||||
"""
|
"""
|
||||||
Создает транзакцию.
|
Создает транзакцию.
|
||||||
|
|
||||||
@@ -126,17 +168,31 @@ class SPAPI(APISession):
|
|||||||
:return: Баланс после транзакции.
|
:return: Баланс после транзакции.
|
||||||
:rtype: int
|
:rtype: int
|
||||||
"""
|
"""
|
||||||
async with APISession(self.__card_id, self.__token) as session:
|
if not receiver:
|
||||||
data = {
|
raise ValueError("receiver must be a non-empty string")
|
||||||
'receiver': receiver,
|
if not isinstance(amount, int) or amount <= 0:
|
||||||
'amount': amount,
|
raise ValueError("amount must be a positive integer")
|
||||||
'comment': comment
|
|
||||||
}
|
|
||||||
res = await session.post('transactions', data)
|
|
||||||
res = await res.json()
|
|
||||||
return res['balance']
|
|
||||||
|
|
||||||
async def create_payment(self, webhook_url: str, redirect_url: str, data: str, items) -> str:
|
try:
|
||||||
|
data = {"receiver": receiver, "amount": amount, "comment": comment}
|
||||||
|
response = await super().post("transactions", data)
|
||||||
|
|
||||||
|
if response is None:
|
||||||
|
return None
|
||||||
|
|
||||||
|
return int(response.get("balance", 0))
|
||||||
|
except (KeyError, ValueError, TypeError) as e:
|
||||||
|
log = __import__("logging").getLogger("pyspapi")
|
||||||
|
log.error(f"Failed to create transaction: {e}")
|
||||||
|
return None
|
||||||
|
except InsufficientBalanceError as ibe:
|
||||||
|
log = __import__("logging").getLogger("pyspapi")
|
||||||
|
log.error(f"Insufficient balance for transaction: {ibe}")
|
||||||
|
return None
|
||||||
|
|
||||||
|
async def create_payment(
|
||||||
|
self, webhook_url: str, redirect_url: str, data: str, items: list[Item]
|
||||||
|
) -> Optional[str]:
|
||||||
"""
|
"""
|
||||||
Создает платеж.
|
Создает платеж.
|
||||||
|
|
||||||
@@ -148,40 +204,57 @@ class SPAPI(APISession):
|
|||||||
:type data: str
|
:type data: str
|
||||||
:param items: Элементы, включаемые в платеж.
|
:param items: Элементы, включаемые в платеж.
|
||||||
|
|
||||||
:return: URL для платежа.
|
:return: URL для платежа или None при ошибке.
|
||||||
:rtype: str
|
:rtype: str
|
||||||
"""
|
"""
|
||||||
async with APISession(self.__card_id, self.__token) as session:
|
if not webhook_url or not redirect_url:
|
||||||
data = {
|
raise ValueError("webhook_url and redirect_url must be non-empty strings")
|
||||||
'items': items,
|
if not items or len(items) == 0:
|
||||||
'redirectUrl': redirect_url,
|
raise ValueError("items must contain at least one item")
|
||||||
'webhookUrl': webhook_url,
|
|
||||||
'data': data
|
|
||||||
}
|
|
||||||
res = await session.post('payments',data)
|
|
||||||
res = await res.json()
|
|
||||||
return res['url']
|
|
||||||
|
|
||||||
async def update_webhook(self, url: str):
|
try:
|
||||||
|
payload = {
|
||||||
|
"items": items,
|
||||||
|
"redirectUrl": redirect_url,
|
||||||
|
"webhookUrl": webhook_url,
|
||||||
|
"data": data,
|
||||||
|
}
|
||||||
|
|
||||||
|
response = await super().post("payments", payload)
|
||||||
|
|
||||||
|
if response is None:
|
||||||
|
return None
|
||||||
|
|
||||||
|
return str(response.get("url", ""))
|
||||||
|
except (KeyError, ValueError, TypeError) as e:
|
||||||
|
log = __import__("logging").getLogger("pyspapi")
|
||||||
|
log.error(f"Failed to create payment: {e}")
|
||||||
|
return None
|
||||||
|
|
||||||
|
async def update_webhook(self, url: str) -> Optional[dict]:
|
||||||
"""
|
"""
|
||||||
Обновляет URL вебхука, связанного с картой.
|
Обновляет URL вебхука, связанного с картой.
|
||||||
|
|
||||||
:param url: Новый URL вебхука.
|
:param url: Новый URL вебхука.
|
||||||
:type url: str
|
:return: Ответ API в виде словаря или None при ошибке.
|
||||||
|
|
||||||
:return: JSON-ответ от API.
|
|
||||||
:rtype: dict
|
|
||||||
"""
|
"""
|
||||||
async with APISession(self.__card_id, self.__token) as session:
|
if not url:
|
||||||
data = {
|
raise ValueError("url must be a non-empty string")
|
||||||
'url': url
|
|
||||||
}
|
|
||||||
res = await session.put(endpoint='card/webhook', data=data)
|
|
||||||
if res:
|
|
||||||
res = await res.json()
|
|
||||||
return res
|
|
||||||
|
|
||||||
def webhook_verify(self, data: str, header) -> bool:
|
try:
|
||||||
|
data = {"url": url}
|
||||||
|
response = await super().put("card/webhook", data)
|
||||||
|
|
||||||
|
if response is None:
|
||||||
|
return None
|
||||||
|
|
||||||
|
return response
|
||||||
|
except (KeyError, TypeError) as e:
|
||||||
|
log = __import__("logging").getLogger("pyspapi")
|
||||||
|
log.error(f"Failed to update webhook: {e}")
|
||||||
|
return None
|
||||||
|
|
||||||
|
def webhook_verify(self, data: str, header: str) -> bool:
|
||||||
"""
|
"""
|
||||||
Проверяет достоверность вебхука.
|
Проверяет достоверность вебхука.
|
||||||
|
|
||||||
@@ -192,8 +265,8 @@ class SPAPI(APISession):
|
|||||||
:return: True, если заголовок из вебхука достоверен, иначе False.
|
:return: True, если заголовок из вебхука достоверен, иначе False.
|
||||||
:rtype: bool
|
:rtype: bool
|
||||||
"""
|
"""
|
||||||
hmac_data = b64encode(new(self.__token.encode('utf-8'), data, sha256).digest())
|
hmac_data = b64encode(new(self.__token.encode("utf-8"), data, sha256).digest())
|
||||||
return compare_digest(hmac_data, header.encode('utf-8'))
|
return compare_digest(hmac_data, header.encode("utf-8"))
|
||||||
|
|
||||||
def to_dict(self) -> dict:
|
def to_dict(self) -> dict:
|
||||||
"""
|
"""
|
||||||
|
|||||||
@@ -1,3 +1,5 @@
|
|||||||
from .payment import Item
|
from pyspapi.types.me import Account, Card, City
|
||||||
from .users import User
|
from pyspapi.types.payment import Item
|
||||||
from .me import Account
|
from pyspapi.types.users import User, UserCards
|
||||||
|
|
||||||
|
__all__ = ["Account", "Card", "City", "Item", "User", "UserCards"]
|
||||||
|
|||||||
@@ -3,47 +3,65 @@ class City:
|
|||||||
self,
|
self,
|
||||||
city_id=None,
|
city_id=None,
|
||||||
name=None,
|
name=None,
|
||||||
description=None,
|
x=None,
|
||||||
x_cord=None,
|
z=None,
|
||||||
z_cord=None,
|
nether_x=None,
|
||||||
is_mayor=None,
|
nether_z=None,
|
||||||
|
lane=None,
|
||||||
|
role=None,
|
||||||
|
created_at=None,
|
||||||
):
|
):
|
||||||
self._id = city_id
|
self._id = city_id
|
||||||
self._name = name
|
self._name = name
|
||||||
self._description = description
|
self._x = x
|
||||||
self._x_cord = x_cord
|
self._z = z
|
||||||
self._z_cord = z_cord
|
self._nether_x = nether_x
|
||||||
self._isMayor = is_mayor
|
self._nether_z = nether_z
|
||||||
|
self._lane = lane
|
||||||
|
self._role = role
|
||||||
|
self._created_at = created_at
|
||||||
|
|
||||||
@property
|
@property
|
||||||
def id(self):
|
def id(self):
|
||||||
return self._id
|
return self._id
|
||||||
|
|
||||||
@property
|
|
||||||
def description(self):
|
|
||||||
return self._description
|
|
||||||
|
|
||||||
@property
|
@property
|
||||||
def name(self):
|
def name(self):
|
||||||
return self._name
|
return self._name
|
||||||
|
|
||||||
@property
|
@property
|
||||||
def x_cord(self):
|
def x(self):
|
||||||
return self._x_cord
|
return self._x
|
||||||
|
|
||||||
@property
|
@property
|
||||||
def z_cord(self):
|
def z(self):
|
||||||
return self._z_cord
|
return self._z
|
||||||
|
|
||||||
@property
|
@property
|
||||||
def mayor(self):
|
def nether_x(self):
|
||||||
return self._isMayor
|
return self._nether_x
|
||||||
|
|
||||||
|
@property
|
||||||
|
def nether_z(self):
|
||||||
|
return self._nether_z
|
||||||
|
|
||||||
|
@property
|
||||||
|
def lane(self):
|
||||||
|
return self._lane
|
||||||
|
|
||||||
|
@property
|
||||||
|
def role(self):
|
||||||
|
return self._role
|
||||||
|
|
||||||
|
@property
|
||||||
|
def created_at(self):
|
||||||
|
return self._created_at
|
||||||
|
|
||||||
def __repr__(self):
|
def __repr__(self):
|
||||||
return f"City(id={self.id}, name={self.name}, description={self.description}, x={self.x_cord}, z={self.z_cord}, is_mayor={self.mayor})"
|
return f"<{self.__class__.__name__}(id={self._id!r}, name={self._name!r}, lane={self._lane!r}, role={self._role!r})>"
|
||||||
|
|
||||||
|
|
||||||
class Cards:
|
class Card:
|
||||||
def __init__(self, card_id=None, name=None, number=None, color=None):
|
def __init__(self, card_id=None, name=None, number=None, color=None):
|
||||||
self._id = card_id
|
self._id = card_id
|
||||||
self._name = name
|
self._name = name
|
||||||
@@ -67,18 +85,42 @@ class Cards:
|
|||||||
return self._color
|
return self._color
|
||||||
|
|
||||||
def __repr__(self):
|
def __repr__(self):
|
||||||
return f"Card(id={self.id}, name={self.name}, number={self.number}, color={self.color})"
|
return f"<{self.__class__.__name__}(id={self._id!r}, name={self._name!r}, number={self._number!r})>"
|
||||||
|
|
||||||
|
|
||||||
class Account:
|
class Account:
|
||||||
def __init__(self, account_id, username, status, roles, created_at, cards, city):
|
def __init__(
|
||||||
|
self,
|
||||||
|
account_id,
|
||||||
|
username,
|
||||||
|
minecraftuuid,
|
||||||
|
status,
|
||||||
|
roles,
|
||||||
|
created_at,
|
||||||
|
cards,
|
||||||
|
cities,
|
||||||
|
):
|
||||||
self._id = account_id
|
self._id = account_id
|
||||||
self._username = username
|
self._username = username
|
||||||
|
self._minecraftuuid = minecraftuuid
|
||||||
self._status = status
|
self._status = status
|
||||||
self._roles = roles
|
self._roles = roles
|
||||||
self._city = City(**city) if city else None
|
self._cities = [
|
||||||
|
City(
|
||||||
|
city_id=city["city"]["id"],
|
||||||
|
name=city["city"]["name"],
|
||||||
|
x=city["city"]["x"],
|
||||||
|
z=city["city"]["z"],
|
||||||
|
nether_x=city["city"]["netherX"],
|
||||||
|
nether_z=city["city"]["netherZ"],
|
||||||
|
lane=city["city"]["lane"],
|
||||||
|
role=city["role"],
|
||||||
|
created_at=city["createdAt"],
|
||||||
|
)
|
||||||
|
for city in cities
|
||||||
|
]
|
||||||
self._cards = [
|
self._cards = [
|
||||||
Cards(
|
Card(
|
||||||
card_id=card["id"],
|
card_id=card["id"],
|
||||||
name=card["name"],
|
name=card["name"],
|
||||||
number=card["number"],
|
number=card["number"],
|
||||||
@@ -96,6 +138,10 @@ class Account:
|
|||||||
def username(self):
|
def username(self):
|
||||||
return self._username
|
return self._username
|
||||||
|
|
||||||
|
@property
|
||||||
|
def minecraftuuid(self):
|
||||||
|
return self._minecraftuuid
|
||||||
|
|
||||||
@property
|
@property
|
||||||
def status(self):
|
def status(self):
|
||||||
return self._status
|
return self._status
|
||||||
@@ -105,8 +151,8 @@ class Account:
|
|||||||
return self._roles
|
return self._roles
|
||||||
|
|
||||||
@property
|
@property
|
||||||
def city(self):
|
def cities(self):
|
||||||
return self._city
|
return self._cities
|
||||||
|
|
||||||
@property
|
@property
|
||||||
def cards(self):
|
def cards(self):
|
||||||
@@ -117,4 +163,7 @@ class Account:
|
|||||||
return self._created_at
|
return self._created_at
|
||||||
|
|
||||||
def __repr__(self):
|
def __repr__(self):
|
||||||
return f"Account(id={self.id}, username={self.username}, status={self.status}, roles={self.roles}, city={self.city}, cards={self.cards}, created_at={self.created_at})"
|
return (
|
||||||
|
f"<{self.__class__.__name__}(id={self._id!r}, username={self._username!r}, status={self._status!r}, "
|
||||||
|
f"roles={self._roles}, cities={self._cities}, cards={self._cards})>"
|
||||||
|
)
|
||||||
|
|||||||
@@ -9,10 +9,13 @@ class Item:
|
|||||||
def name(self):
|
def name(self):
|
||||||
return self._name
|
return self._name
|
||||||
|
|
||||||
|
def __repr__(self):
|
||||||
|
return f"<{self.__class__.__name__}(name={self._name!r}, count={self._count!r}, price={self._price!r}, comment={self._comment!r})>"
|
||||||
|
|
||||||
def to_json(self):
|
def to_json(self):
|
||||||
return {
|
return {
|
||||||
"name": self._name,
|
"name": self._name,
|
||||||
"count": self._count,
|
"count": self._count,
|
||||||
"price": self._price,
|
"price": self._price,
|
||||||
"comment": self._comment
|
"comment": self._comment,
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,5 +1,4 @@
|
|||||||
class Cards:
|
class UserCards:
|
||||||
|
|
||||||
def __init__(self, name, number):
|
def __init__(self, name, number):
|
||||||
self._name: str = name
|
self._name: str = name
|
||||||
self._number: str = number
|
self._number: str = number
|
||||||
@@ -12,20 +11,16 @@ class Cards:
|
|||||||
def number(self):
|
def number(self):
|
||||||
return self._number
|
return self._number
|
||||||
|
|
||||||
# def __repr__(self):
|
def __repr__(self):
|
||||||
# return "%s(%s)" % (
|
return f"<{self.__class__.__name__}(id={self._id!r}, name={self._name!r}, number={self._number!r})>"
|
||||||
# self.__class__.__name__,
|
|
||||||
# self.__dict__
|
|
||||||
# )
|
|
||||||
|
|
||||||
|
|
||||||
class User:
|
class User:
|
||||||
|
|
||||||
def __init__(self, username, uuid, cards):
|
def __init__(self, username, uuid, cards):
|
||||||
self._username: str = username
|
self._username: str = username
|
||||||
self._uuid: str = uuid
|
self._uuid: str = uuid
|
||||||
self._cards = [
|
self._cards = [
|
||||||
Cards(
|
UserCards(
|
||||||
name=card["name"],
|
name=card["name"],
|
||||||
number=card["number"],
|
number=card["number"],
|
||||||
)
|
)
|
||||||
@@ -45,7 +40,4 @@ class User:
|
|||||||
return self._cards
|
return self._cards
|
||||||
|
|
||||||
def __repr__(self):
|
def __repr__(self):
|
||||||
return "%s(%s)" % (
|
return "%s(%s)" % (self.__class__.__name__, self.__dict__)
|
||||||
self.__class__.__name__,
|
|
||||||
self.__dict__
|
|
||||||
)
|
|
||||||
|
|||||||
@@ -1 +0,0 @@
|
|||||||
aiohttp>=3.8.0
|
|
||||||
46
setup.py
46
setup.py
@@ -1,46 +0,0 @@
|
|||||||
import re
|
|
||||||
|
|
||||||
from setuptools import setup
|
|
||||||
|
|
||||||
requirements = []
|
|
||||||
with open("requirements.txt") as f:
|
|
||||||
requirements = f.read().splitlines()
|
|
||||||
|
|
||||||
version = ""
|
|
||||||
with open("pyspapi/__init__.py") as f:
|
|
||||||
match = re.search(r'^__version__\s*=\s*[\'"]([^\'"]*)[\'"]', f.read(), re.MULTILINE)
|
|
||||||
if match is None or match.group(1) is None:
|
|
||||||
raise RuntimeError('Version is not set')
|
|
||||||
|
|
||||||
version = match.group(1)
|
|
||||||
|
|
||||||
if not version:
|
|
||||||
raise RuntimeError("Version is not set")
|
|
||||||
|
|
||||||
readme = ""
|
|
||||||
with open("README.rst") as f:
|
|
||||||
readme = f.read()
|
|
||||||
|
|
||||||
packages = [
|
|
||||||
"pyspapi"
|
|
||||||
]
|
|
||||||
|
|
||||||
setup(
|
|
||||||
name='pyspapi',
|
|
||||||
license='MIT',
|
|
||||||
author='deesiigneer',
|
|
||||||
version=version,
|
|
||||||
url='https://github.com/deesiigneer/pyspapi',
|
|
||||||
project_urls={
|
|
||||||
"Documentation": "https://pyspapi.readthedocs.io/ru/latest/",
|
|
||||||
"GitHub": "https://github.com/deesiigneer/pyspapi",
|
|
||||||
"Discord": "https://discord.com/invite/VbyHaKRAaN"
|
|
||||||
},
|
|
||||||
description='API wrapper for SP servers written in Python',
|
|
||||||
long_description=readme,
|
|
||||||
long_description_content_type='text/x-rst',
|
|
||||||
packages=packages,
|
|
||||||
include_package_data=True,
|
|
||||||
install_requires=requirements,
|
|
||||||
python_requires='>=3.8.0',
|
|
||||||
)
|
|
||||||
Reference in New Issue
Block a user