Python SDK

# Clone the repository
git clone https://github.com/HyperTekOrg/hyperstack.git
cd hyperstack/python/hyperstack-sdk

# Install in development mode
pip install -e .

from hyperstack import HyperstackClient

async def main():
    # Initialize client
    client = HyperstackClient(
        url="wss://mainnet.hyperstack.xyz",
        auto_reconnect=True
    )
    
    # Connect to server
    await client.connect()
    
    print(f"Connected: {client.is_connected}")

async def stream_updates():
    client = HyperstackClient(url="wss://mainnet.hyperstack.xyz")
    await client.connect()
    
    # Subscribe to entity updates
    async for update in client.subscribe("games"):
        if update.type == "upsert":
            print(f"Game updated: {update.key} - {update.data}")
        elif update.type == "delete":
            print(f"Game deleted: {update.key}")

async def query_state():
    client = HyperstackClient(url="wss://mainnet.hyperstack.xyz")
    await client.connect()
    
    # Get all entities
    games = await client.list("games")
    print(f"Found {len(games)} games")
    
    # Get specific entity
    game = await client.get("games", "game-123")
    if game:
        print(f"Game data: {game}")

async def watch_diffs():
    client = HyperstackClient(url="wss://mainnet.hyperstack.xyz")
    await client.connect()
    
    # Subscribe with before/after diffs
    async for update in client.subscribe_rich("tokens"):
        if update.type == "updated":
            print(f"Before: {update.before}")
            print(f"After: {update.after}")
            print(f"Changed fields: {update.patch}")

async def manage_connection():
    client = HyperstackClient(
        url="wss://mainnet.hyperstack.xyz",
        auto_reconnect=True,
        max_reconnect_attempts=10,
        ping_interval=30
    )
    
    # Connection state callback
    def on_state_change(state):
        print(f"Connection state: {state}")
    
    client.on_connection_state_change(on_state_change)
    
    await client.connect()
    
    # ... do work ...
    
    await client.disconnect()

from my_stack import Game, Player

async def typed_query(client: HyperstackClient):
    # Fully typed entities
    games: list[Game] = await client.list("games")
    player: Player | None = await client.get("players", "player-123")

import pandas as pd

async def to_dataframe(client: HyperstackClient):
    # Get all tokens
    tokens = await client.list("tokens")
    
    # Convert to DataFrame
    df = pd.DataFrame(tokens)
    
    # Analyze
    print(df.describe())
    print(df.groupby("status").count())

async def filter_stream():
    client = HyperstackClient(url="wss://mainnet.hyperstack.xyz")
    await client.connect()
    
    async for update in client.subscribe("players"):
        if update.data.get("score", 0) > 1000:
            print(f"High scorer: {update.data['name']}")

# Generate Python SDK
hs sdk create python settlement-game

# With custom output directory
hs sdk create python settlement-game --output ./generated

# With custom package name
hs sdk create python settlement-game --package-name game_sdk

generated/settlement_game_sdk/
├── __init__.py
├── types.py       # Type definitions
├── client.py      # Client class
└── entities.py    # Entity classes

# Clone and navigate
git clone https://github.com/HyperTekOrg/hyperstack.git
cd hyperstack/python/hyperstack-sdk

# Create virtual environment
python -m venv venv
source venv/bin/activate  # or `venv\Scripts\activate` on Windows

# Install dependencies
pip install -e ".[dev]"

# Run tests
pytest

# Format code
black .
ruff check .

from hyperstack import HyperstackClient

# Basic client initialization (WIP)
client = HyperstackClient()
await client.connect()

import { HyperStack } from 'hyperstack-typescript';

const hs = await HyperStack.connect('wss://mainnet.hyperstack.xyz', {
  stack: MY_STACK,
});

for await (const update of hs.views.myView.list.watch()) {
  console.log('Update:', update);
}