dev-update-packages (#7)

* edits and test attempts

* flexing with tests

* refactor(tests): update private API tests and pytest config

- Refactor private API tests to use manual server/client creation
- Add proper cleanup with try/finally blocks
- Ensure server is closed after each test
- Set explicit asyncio_default_fixture_loop_scope in pytest config

The changes improve test isolation and follow the integration tests pattern.
Each test now creates its own server and client instances, making tests
more reliable and easier to debug. The pytest configuration update removes
deprecation warning by explicitly setting the event loop scope to "function".

* chore(lint): enable Ruff unsafe fixes

Enable unsafe fixes in Ruff configuration to allow automatic
fixing of docstring formatting and other similar issues.
This will help maintain consistent code style with less
manual intervention.

* remomve unused

* ruff check finished

* preparation for 1st release

* removed private client
removed multiexchange
changed config for pyright

* changes for pyright

* edits for starting stdio or sse

* claude desktop client not working for now

* update packages
bump version
fix client and tests

* update packages
bump version
fix client and tests

Author: doubledare704

.pre-commit-config.yaml

@@ -9,13 +9,13 @@ repos:
     -   id: check-toml
 
 -   repo: https://github.com/astral-sh/ruff-pre-commit
-    rev: v0.11.7
+    rev: v0.12.10
     hooks:
     -   id: ruff
         args: [--fix]
     -   id: ruff-format
 
 -   repo: https://github.com/RobertCraigie/pyright-python
-    rev: v1.1.400
+    rev: v1.1.404
     hooks:
     -   id: pyright

README.md

@@ -16,6 +16,12 @@ top of [aiowhitebit](https://github.com/doubledare704/aiowhitebit) library and [
 - Caching with disk persistence
 - Rate limiting and circuit breaker patterns
 
+### New in aiowhitebit 0.3.0 Integration
+
+- **BookTicker WebSocket Streams**: Real-time best bid/ask price updates
+- **Funding History for Futures**: Access historical funding rates for futures markets
+- **Enhanced WebSocket Events**: All WebSocket events now include optional metadata (event_time, update_id)
+
 ## Quick Start
 
 ```bash
@@ -56,6 +62,14 @@ async def main():
         orderbook = await client.get_orderbook("BTC_USDT")
         print("Order book:", orderbook)
 
+        # Get funding history for futures market
+        funding_history = await client.get_funding_history("BTC_USDT")
+        print("Funding history:", funding_history)
+
+        # Subscribe to BookTicker for real-time best bid/ask
+        subscription = await client.bookticker_subscribe("BTC_USDT")
+        print("BookTicker subscription:", subscription)
+
 if __name__ == "__main__":
     asyncio.run(main())
 ```
@@ -93,10 +107,15 @@ if __name__ == "__main__":
 - `get_fee(market: str)`: Get trading fees
 - `get_server_status()`: Get server status
 - `get_asset_status_list()`: Get status of all assets
+- `get_funding_history(market: str)`: Get funding rate history for futures markets
 
 ### WebSocket API
 - `get_last_price(market: str)`: Get real-time price
 - `get_market_depth(market: str)`: Get real-time order book
+- `bookticker_subscribe(market: str)`: Subscribe to BookTicker stream for best bid/ask prices
+- `bookticker_unsubscribe(market: str)`: Unsubscribe from BookTicker stream
+- `connect_websocket()`: Connect to WebSocket API
+- `disconnect_websocket()`: Disconnect from WebSocket API
 
 ### Resources
 - `whitebit://markets`: Get all markets information

pyproject.toml

@@ -1,10 +1,10 @@
 [build-system]
-requires = ["setuptools>=42", "wheel"]
+requires = ["setuptools>=68.2.2", "wheel"]
 build-backend = "setuptools.build_meta"
 
 [project]
 name = "aiowhitebit-mcp"
-version = "0.2.7"
+version = "0.3.0"
 description = "MCP server and client for WhiteBit cryptocurrency exchange API"
 readme = "README.md"
 authors = [
@@ -25,20 +25,20 @@ classifiers = [
 keywords = ["whitebit", "cryptocurrency", "exchange", "api", "mcp", "claude"]
 requires-python = ">=3.10"
 dependencies = [
-    "aiowhitebit==0.2.5",
-    "fastmcp==2.10.2",
-    "pydantic>=2.11.7",
-    "aiohttp>=3.12.13",
+    "aiowhitebit==0.4.0",
+    "fastmcp==2.12.5",
+    "pydantic>=2.12.3",
+    "aiohttp>=3.13.1",
 ]
 
 [project.optional-dependencies]
 dev = [
-    "pytest>=8.4.0",
-    "pytest-asyncio>=1.0.0",
-    "pytest-cov>=6.2.1",
-    "ruff>=0.11.13",
-    "pyright>=1.1.402",
-    "pre-commit>=4.2.0",
+    "pytest>=8.4.2",
+    "pytest-asyncio>=1.2.0",
+    "pytest-cov>=7.0.0",
+    "ruff>=0.14.1",
+    "pyright>=1.1.406",
+    "pre-commit>=4.3.0",
 ]
 
 [project.urls]

requirements-dev.txt

@@ -1,10 +1,10 @@
 # Development dependencies
-pytest~=8.4.0
-pytest-asyncio~=1.0.0
-pytest-cov==6.2.1
-ruff==0.11.13
-pyright==1.1.402
-pre-commit==4.2.0
+pytest~=8.4.2
+pytest-asyncio~=1.2.0
+pytest-cov==7.0.0
+ruff==0.14.1
+pyright==1.1.406
+pre-commit==4.3.0
 
 # Project dependencies
 -r requirements.txt

requirements.txt

@@ -1,6 +1,6 @@
-aiowhitebit==0.2.5
-fastmcp==2.10.2
+aiowhitebit==0.4.0
+fastmcp==2.12.5
 
-pydantic~=2.11.7
-aiohttp~=3.12.13
+pydantic~=2.12.3
+aiohttp~=3.13.1
 setuptools~=80.9.0

setup.py

@@ -13,17 +13,17 @@
 
 # Define development requirements
 development_requires = [
-    "pytest>=8.4.0",
-    "pytest-asyncio>=1.0.0",
-    "pytest-cov>=6.2.1",
-    "ruff>=0.11.13",
-    "pyright>=1.1.402",
-    "pre-commit>=4.2.0",
+    "pytest>=8.4.2",
+    "pytest-asyncio>=1.2.0",
+    "pytest-cov>=7.0.0",
+    "ruff>=0.14.1",
+    "pyright>=1.1.406",
+    "pre-commit>=4.3.0",
 ]
 
 setup(
     name="aiowhitebit-mcp",
-    version="0.2.7",
+    version="0.3.0",
     description="MCP server and client for WhiteBit cryptocurrency exchange API",
     long_description=long_description,
     long_description_content_type="text/markdown",
@@ -33,10 +33,10 @@
     packages=find_packages(where="src"),
     package_dir={"": "src"},
     install_requires=[
-        "aiowhitebit==0.2.5",
-        "fastmcp==2.10.2",
-        "pydantic>=2.11.7",
-        "aiohttp>=3.12.13",
+        "aiowhitebit==0.4.0",
+        "fastmcp==2.12.5",
+        "pydantic>=2.12.3",
+        "aiohttp>=3.13.1",
     ],
     entry_points={
         "console_scripts": [

src/aiowhitebit_mcp/__init__.py

@@ -3,4 +3,4 @@
 Provides Message Control Protocol (MCP) server and client for WhiteBit exchange.
 """
 
-__version__ = "0.2.7"
+__version__ = "0.3.0"

src/aiowhitebit_mcp/client.py

@@ -122,6 +122,33 @@ async def get_market_depth(self, market: str) -> str:
         result = await self.client.call_tool("get_market_depth", {"market": {"market": market}})
         return self._extract_text(result)
 
+    async def get_funding_history(self, market: str) -> str:
+        """Get funding rate history for a futures market.
+
+        Args:
+            market: Market pair (e.g., 'BTC_USDT')
+        """
+        result = await self.client.call_tool("get_funding_history", {"market": {"market": market}})
+        return self._extract_text(result)
+
+    async def bookticker_subscribe(self, market: str) -> str:
+        """Subscribe to BookTicker stream for a market.
+
+        Args:
+            market: Market pair (e.g., 'BTC_USDT')
+        """
+        result = await self.client.call_tool("bookticker_subscribe", {"market": {"market": market}})
+        return self._extract_text(result)
+
+    async def bookticker_unsubscribe(self, market: str) -> str:
+        """Unsubscribe from BookTicker stream for a market.
+
+        Args:
+            market: Market pair (e.g., 'BTC_USDT')
+        """
+        result = await self.client.call_tool("bookticker_unsubscribe", {"market": {"market": market}})
+        return self._extract_text(result)
+
     def _extract_resource_text(self, response: list[TextResourceContents | BlobResourceContents]) -> str:
         """Extract text from resource response.
 

src/aiowhitebit_mcp/metrics.py

@@ -127,7 +127,7 @@ class MetricsCollector:
     """Collector for WhiteBit MCP server metrics.
 
     This class collects metrics about the WhiteBit MCP server's performance
-    and usage, and provides methods for reporting those metrics.
+    and usage and provides methods for reporting those metrics.
     """
 
     def __init__(self):

src/aiowhitebit_mcp/proxy.py

@@ -10,6 +10,8 @@
 from aiowhitebit.models.public.v4 import (
     AssetStatus,
     Fee,
+    FundingHistoryItem,
+    FundingHistoryResponse,
     MarketActivity,
     MarketInfo,
     Orderbook,
@@ -110,9 +112,8 @@ async def get_server_time(self) -> ServerTime:
                 time_data = result.model_dump()
                 logger.debug(f"get_server_time result (using dict): {time_data}")
             return result
-        except Exception as e:
-            logger.error(f"Error in get_server_time: {e}")
-            logger.debug(traceback.format_exc())
+        except Exception:
+            logger.exception("Error in get_server_time")
             return ServerTime(time=1000000000)
 
     @optimized(ttl_seconds=60, rate_limit_name="public")  # Server status doesn't change often
@@ -130,9 +131,8 @@ async def get_server_status(self) -> ServerStatus:
             logger.debug("Calling get_server_status")
             return await self._original_client.get_server_status()
 
-        except Exception as e:
-            logger.error(f"Error in get_server_status: {e}")
-            logger.debug(traceback.format_exc())
+        except Exception:
+            logger.exception("Error in get_server_status")
             return ServerStatus(["pong"])  # Return a mock object for testing
 
     @cached(cache_name="market_info", ttl=300, persist=True)  # Market info changes infrequently
@@ -203,9 +203,8 @@ async def get_orderbook(self, market: str, limit: int = 100, level: int = 0) ->
                 bids_count = len(orderbook_data.get("bids", []))
                 logger.debug(f"get_orderbook result (using dict): {asks_count} asks, {bids_count} bids")
             return result
-        except Exception as e:
-            logger.error(f"Error in get_orderbook for {market}: {e}")
-            logger.debug(traceback.format_exc())
+        except Exception:
+            logger.exception(f"Error in get_orderbook for {market}:")
             return Orderbook(
                 ticker_id=market, asks=[], bids=[], timestamp=1000000000
             )  # Return a mock object for testing
@@ -285,6 +284,34 @@ async def get_asset_status_list(self) -> list[AssetStatus]:
             logger.debug(traceback.format_exc())
             return cast("list[AssetStatus]", [{"name": "BTC", "status": "active"}])
 
+    @optimized(ttl_seconds=300, rate_limit_name="public")  # Funding history changes infrequently
+    @circuit_breaker(name="public_v4_get_funding_history", failure_threshold=3, recovery_timeout=30.0, timeout=10.0)
+    @rate_limited("public")
+    async def get_funding_history(self, market: str) -> "FundingHistoryResponse":
+        """Get funding rate history for a futures market.
+
+        Args:
+            market: Market symbol (e.g., "BTC_USDT")
+
+        Returns:
+            FundingHistoryResponse: List of funding rate history items containing:
+                - Timestamp of the funding rate
+                - Funding rate value
+
+        Raises:
+            Exception: If there is an error communicating with the WhiteBit API
+        """
+        try:
+            logger.debug(f"Calling get_funding_history for {market}")
+            result = await self._original_client.get_funding_history(market)
+            logger.debug(f"get_funding_history result: {len(result.result)} items")
+            return result
+        except Exception:
+            logger.exception("Error in get_funding_history: ")
+            return FundingHistoryResponse(
+                result=[FundingHistoryItem(timestamp=1000000000, funding_rate="rate")]
+            )  # Return a mock object for testing
+
     async def close(self) -> None:
         """Close the client and release resources.