Metadata-Version: 2.4
Name: morphe-adapter-sdk
Version: 1.0.3
Summary: Python adapter SDK for emitting events to the Morphe Control Plane
Classifier: License :: OSI Approved :: MIT License
Classifier: Operating System :: OS Independent
Classifier: Programming Language :: Python :: 3
Requires-Python: >=3.9
Requires-Dist: httpx>=0.27
Requires-Dist: jsonschema>=4.23
Provides-Extra: dev
Requires-Dist: mypy>=1.9; extra == 'dev'
Requires-Dist: pytest-httpx>=0.30; extra == 'dev'
Requires-Dist: pytest>=8; extra == 'dev'
Description-Content-Type: text/markdown

# morphe-adapter-sdk

Python adapter SDK for emitting events to the [Morphe Control Plane](https://os.morphe.io).

## Installation

```bash
pip install morphe-adapter-sdk
```

## Quick start

```python
import asyncio
from morphe_adapter_sdk import MorpheClient

async def main():
    async with MorpheClient(token="your-token") as client:
        result = await client.emit({
            "event_type": "dataops.v1.sync_failed",
            "system_id":  "your-system-uuid",
            "payload":    {"records_failed": 42, "source": "warehouse"},
        })
        print(result)

asyncio.run(main())
```

## Configuration

| Parameter       | Type    | Default                    | Description                                      |
|-----------------|---------|----------------------------|--------------------------------------------------|
| `token`         | `str`   | required                   | API token from your Morphe workspace             |
| `hmac_secret`   | `str`   | `None`                     | Optional HMAC secret for request signing         |
| `validate_schema` | `bool` | `False`                  | Validate payload against event schema before emit |
| `endpoint`      | `str`   | `https://api.morphe.io`    | Override for self-hosted deployments             |
| `max_retries`   | `int`   | `3`                        | Number of retries on transient network errors    |

## Error handling

```python
from morphe_adapter_sdk import MorpheClient
from morphe_adapter_sdk.errors import ApiError, NetworkError, SchemaValidationError

async with MorpheClient(token="your-token") as client:
    try:
        await client.emit(event)
    except SchemaValidationError as e:
        print("Schema errors:", e.errors)
    except ApiError as e:
        print(f"API error {e.status_code}: {e.message}")
    except NetworkError as e:
        print("Network error:", e)
```

## License

MIT
