Metadata-Version: 2.4
Name: fastn-auth
Version: 1.0.4
Summary: Python SDK for Fastn connector authentication
Author: Fastn
License-Expression: MIT
Project-URL: Homepage, https://github.com/fastn-ai/fastn-auth
Project-URL: Documentation, https://github.com/fastn-ai/fastn-auth#readme
Keywords: fastn,auth,oauth,connector,authentication
Classifier: Development Status :: 4 - Beta
Classifier: Intended Audience :: Developers
Classifier: Programming Language :: Python :: 3
Classifier: Programming Language :: Python :: 3.9
Classifier: Programming Language :: Python :: 3.10
Classifier: Programming Language :: Python :: 3.11
Classifier: Programming Language :: Python :: 3.12
Classifier: Typing :: Typed
Requires-Python: >=3.9
Description-Content-Type: text/markdown
Requires-Dist: aiohttp>=3.8.0
Provides-Extra: dev
Requires-Dist: pytest>=7.0.0; extra == "dev"
Requires-Dist: pytest-asyncio>=0.21.0; extra == "dev"

# fastn-auth (Python)

Python SDK for Fastn connector authentication. Provides a simple async interface for initiating OAuth and credential-based connector authentication flows.

## Installation

```bash
pip install fastn-auth
```

## Quick Start

```python
import asyncio
from fastn_auth import FastnAuth

async def main():
    # Create a client
    client = FastnAuth(
        space_id="your-space-id",
        api_key="your-api-key",  # or use auth_token instead
        base_url="https://live.fastn.ai/api",  # optional
    )

    # Initialize an authentication session
    session = await client.initialize(
        connector_id="google-sheets",
        org_id="org-id",      # optional
        tenant_id="tenant-id" # optional
    )

    # Redirect the user to complete OAuth
    print(f"Redirect user to: {session.redirect_url}")

    # Wait for the user to complete authentication
    result = await session.wait_for_completion()

    print("Authentication complete!", result.credentials)

asyncio.run(main())
```

## API Reference

### FastnAuth

The main client class for initializing authentication flows.

#### Constructor

```python
FastnAuth(
    space_id: str,
    api_key: str | None = None,
    auth_token: str | None = None,
    base_url: str | None = None,
)
```

| Parameter | Type | Required | Description |
|-----------|------|----------|-------------|
| `space_id` | `str` | Yes | The space/workspace ID |
| `api_key` | `str` | One of `api_key` or `auth_token` | API key — sent as `x-fastn-api-key` header |
| `auth_token` | `str` | One of `api_key` or `auth_token` | Bearer token — sent as `Authorization: Bearer {token}` header |
| `base_url` | `str` | No | Base URL for the Fastn API (defaults to `https://live.fastn.ai/api`) |

#### Methods

##### `async initialize(...) -> AuthSession`

Initialize a connector authentication flow.

```python
async def initialize(
    self,
    connector_id: str,
    org_id: str | None = None,
    tenant_id: str | None = None,
    connection_id: str | None = None,
) -> AuthSession
```

| Parameter | Type | Required | Description |
|-----------|------|----------|-------------|
| `connector_id` | `str` | Yes | The connector ID (e.g., "google-sheets", "salesforce") |
| `org_id` | `str` | No | Organization ID (defaults to `"community"`) |
| `tenant_id` | `str` | No | Tenant ID |
| `connection_id` | `str` | No | Connection instance ID |

##### `async get_credentials(options: GetCredentialsOptions) -> Credentials`

Fetch credentials for an already-authenticated connector without starting a new OAuth flow.

```python
from fastn_auth import FastnAuth, GetCredentialsOptions

credentials = await client.get_credentials(
    GetCredentialsOptions(
        connector_id="google-sheets",
        org_id="org-id",        # optional
        tenant_id="tenant-id",  # optional
        connection_id="conn-id" # optional
    )
)
```

| Parameter | Type | Required | Description |
|-----------|------|----------|-------------|
| `connector_id` | `str` | Yes | The connector ID |
| `org_id` | `str` | No | Organization ID (defaults to `"community"`) |
| `tenant_id` | `str` | No | Tenant ID |
| `connection_id` | `str` | No | Connection instance ID |

---

### AuthSession

Represents an active authentication session returned by `client.initialize()`.

#### Properties

| Property | Type | Description |
|----------|------|-------------|
| `id` | `str` | Unique identifier for this session |
| `state_key` | `str` | State key for the OAuth flow |
| `redirect_url` | `str` | URL to redirect the user to for OAuth authorization |

#### Methods

##### `async wait_for_completion(options: PollOptions | None = None) -> AuthResult`

Poll for the authentication status until it reaches `ACTIVE` or `FAILED`, or until the timeout is exceeded.

```python
@dataclass
class PollOptions:
    interval: float = 2.0   # Polling interval in seconds
    timeout: float = 300.0  # Maximum wait time in seconds (5 minutes)
```

Returns an `AuthResult` object:

```python
@dataclass
class AuthResult:
    status: AuthStatus
    credentials: Credentials | None = None
    error_message: str | None = None
```

##### `async get_status() -> StatusResponse`

Get the current status of the authentication session.

```python
@dataclass
class StatusResponse:
    status: AuthStatus
    error_message: str | None = None
```

##### `async get_credentials() -> Credentials`

Fetch the credentials for the authenticated connector after the OAuth flow completes.

```python
@dataclass
class Credentials:
    access_token: str | None = None
    refresh_token: str | None = None
    expires_at: str | None = None
    extra: dict  # connector-specific fields
```

---

## Error Handling

The SDK provides custom exception classes for different failure scenarios:

```python
from fastn_auth import (
    FastnAuthError,
    TimeoutError,
    AuthenticationError,
    NetworkError,
    InvalidResponseError,
)

try:
    result = await session.wait_for_completion()
except TimeoutError:
    print("Authentication timed out")
except AuthenticationError as e:
    print(f"Authentication failed: {e.message}")
except NetworkError as e:
    print(f"Network error: {e.message}, status: {e.status_code}")
except InvalidResponseError as e:
    print(f"Unexpected API response: {e.message}")
```

| Error Class | Code | Description |
|-------------|------|-------------|
| `FastnAuthError` | — | Base class for all SDK errors |
| `TimeoutError` | `TIMEOUT` | `wait_for_completion()` exceeded the timeout |
| `AuthenticationError` | `AUTH_FAILED` | The authentication flow returned `FAILED` |
| `NetworkError` | `NETWORK_ERROR` | HTTP request failed; includes `status_code` |
| `InvalidResponseError` | `INVALID_RESPONSE` | API response is missing required fields |

---

## Status Lifecycle

| Status | Description |
|--------|-------------|
| `INACTIVE` | OAuth initiated, awaiting user authorization |
| `ACTIVE` | Connector successfully authenticated |
| `FAILED` | Authentication failed |

---

## Requirements

- Python 3.9 or higher
- aiohttp >= 3.8.0

## License

MIT
