Metadata-Version: 2.4
Name: winterforge-channels
Version: 1.0.0
Summary: Communication primitives and transport abstraction for WinterForge
Author-email: WinterForge Team <team@winterforge.dev>
License: MIT
Project-URL: Homepage, https://github.com/winterforge/winterforge-channels
Project-URL: Documentation, https://winterforge-channels.readthedocs.io
Project-URL: Repository, https://github.com/winterforge/winterforge-channels
Project-URL: Issues, https://github.com/winterforge/winterforge-channels/issues
Project-URL: Changelog, https://github.com/winterforge/winterforge-channels/blob/main/CHANGELOG.md
Keywords: winterforge,messaging,channels,websocket,transport,communication,pubsub
Classifier: Development Status :: 4 - Beta
Classifier: Intended Audience :: Developers
Classifier: License :: OSI Approved :: MIT License
Classifier: Programming Language :: Python :: 3.10
Classifier: Programming Language :: Python :: 3.11
Classifier: Programming Language :: Python :: 3.12
Classifier: Topic :: Communications
Classifier: Topic :: Software Development :: Libraries :: Python Modules
Classifier: Framework :: AsyncIO
Requires-Python: >=3.10
Description-Content-Type: text/markdown
License-File: LICENSE
Requires-Dist: winterforge>=0.1.0
Requires-Dist: pydantic>=2.0
Requires-Dist: fastapi>=0.100.0
Requires-Dist: websockets>=12.0
Requires-Dist: httpx>=0.25.0
Provides-Extra: queue
Requires-Dist: celery>=5.3; extra == "queue"
Requires-Dist: redis>=5.0; extra == "queue"
Provides-Extra: email
Requires-Dist: aiosmtplib>=3.0; extra == "email"
Provides-Extra: all
Requires-Dist: celery>=5.3; extra == "all"
Requires-Dist: redis>=5.0; extra == "all"
Requires-Dist: aiosmtplib>=3.0; extra == "all"
Provides-Extra: dev
Requires-Dist: pytest>=7.0; extra == "dev"
Requires-Dist: pytest-asyncio>=0.21; extra == "dev"
Requires-Dist: pytest-cov>=4.1; extra == "dev"
Requires-Dist: black>=23.0; extra == "dev"
Requires-Dist: ruff>=0.1; extra == "dev"
Requires-Dist: mypy>=1.0; extra == "dev"
Dynamic: license-file

# winterforge-channels

**Communication primitives and transport abstraction for WinterForge**

[![Tests](https://img.shields.io/badge/tests-147%20passing-brightgreen)](tests/)
[![Python](https://img.shields.io/badge/python-3.10%2B-blue)](https://www.python.org)
[![License](https://img.shields.io/badge/license-MIT-blue)](LICENSE)

winterforge-channels provides transport-agnostic message routing with
permission-controlled channels and pluggable delivery mechanisms.

---

## Features

- **Transport Agnostic** - Messages don't know HOW they're delivered
- **Permission Controlled** - Channels enforce access via WinterForge's
  authorization system
- **Pluggable Transports** - HTTP, WebSocket, Queue, Email (extensible)
- **Subscriber Agnostic** - ANY Frag can subscribe (User, Bot, Service,
  System)
- **Thread Support** - Message threading and semantic references
- **Conversation Tracking** - Canonical conversation membership
- **CLI Interface** - Complete command-line management

---

## Installation

### Via WinterForge Extras (Recommended)

```bash
pip install winterforge[channels]
```

### Standalone

```bash
pip install winterforge-channels
```

---

## Quick Start

### Create a Channel

```python
from winterforge_channels.primitives import Channel

channel = Channel()
channel.set_title("General Chat")
channel.set_alias('egress_transport', 'websocket')
await channel.save()
```

### Send a Message

```python
from winterforge_channels.primitives import Message
from winterforge.frags import Manifest

message = Message()
message.set_content("Hello, world!")
message.set_author_id(user.id)
await message.save()

# Send via channel
await message.send(Manifest([channel]))
```

### Subscribe to Channel

```python
# Subscribe user to channel
await channel.subscribe(user_id=42)

# Get all subscribers
subscribers = await channel.get_subscribers()
```

### Thread Messages

```python
# Create original message
msg1 = Message()
msg1.set_content("What's the status?")
msg1.set_author_id(alice.id)
await msg1.save()

# Reply to message
msg2 = Message()
msg2.set_content("All systems operational")
msg2.set_author_id(bob.id)
msg2.set_reply_to_id(msg1.id)
await msg2.save()

# Get thread
from winterforge_channels.registries import MessageRegistry

registry = MessageRegistry()
thread = await registry.get_thread(msg2.id)
# Returns: [msg1, msg2]
```

---

## CLI Usage

```bash
# Create channel
winterforge channel create "Support Chat" --egress websocket

# Send message
winterforge channel send 1 "Hello!" --author-id 1

# Subscribe user to channel
winterforge channel subscribe 1 42

# List subscribers
winterforge channel list-subscribers 1

# Unsubscribe
winterforge channel unsubscribe 1 42

# List all channels
winterforge channel list
```

---

## Architecture

### Primitives

**Message** - Transport-agnostic communication unit
- Content, author, content_type
- Thread management (reply_to chains)
- Semantic references
- Conversation tracking
- Transport-agnostic sending

**Channel** - Permission-controlled routing mechanism
- Configurable ingress/egress transports
- Subscriber management
- Permission enforcement
- Transport repository access

**Subscription** - Links subscribers to channels
- Any Frag can be a subscriber
- Clean subscribe/unsubscribe workflow
- Query by subscriber or channel

### Traits

**messageable** - Content and metadata
- content: str
- author_id: int
- content_type: str (default: 'text/plain')

**conversable** - Canonical conversation tracking
- conversation_id: Optional[int]
- get_conversation() - Resolve conversation Frag

**transportable** - Send via channels
- send_to_channels(channels) - Permission check + routing

**subscribable** - Subscriber management
- get_subscribers() - Get all subscribers
- subscribe(subscriber_id) - Add subscriber
- unsubscribe(subscriber_id) - Remove subscriber

**routable** - Message routing
- route_message(message) - Orchestrate delivery

### Transport Plugins

**HTTP Ingress** - Receive messages via POST endpoint
- Validates payload
- Creates Message Frag
- Returns message ID

**HTTP Egress** - Send to subscriber endpoints
- POST to subscriber.endpoint
- Delivery status tracking
- Error handling

**WebSocket Egress** - Real-time delivery
- Active connection management
- Register/unregister connections
- Send to connected subscribers only

### Registries

**MessageRegistry** - Message queries
- get_thread(message_id) - Reconstruct thread
- get_for_conversation(conversation_id) - Filter by conversation

**ChannelRegistry** - Channel queries
- Standard FragRegistry operations

**SubscriptionRegistry** - Subscription queries
- Filter by subscriber or channel

---

## Permissions

Channels enforce three permissions via WinterForge's authorization
system:

- **channel.submit** - Can send messages to channel
- **channel.subscribe** - Can subscribe to channel
- **channel.manage** - Can configure channel

### Permission Setup

```python
from winterforge.frags import Frag

# Create permission
perm = Frag(affinities=['permission'], traits=['titled', 'persistable'])
perm.set_title('channel.submit')
await perm.save()

# Create role with permission
role = Frag(
    affinities=['role'],
    traits=['titled', 'permissioned', 'persistable'],
)
role.set_title('sender')
role.add_permission(perm.id)
await role.save()

# Assign role to user
user.add_role(role.id)
await user.save()

# Permission check
can_submit = await channel.can_submit(user.id)
```

---

## Transport Configuration

Channels can specify preferred transports via aliases:

```python
channel.set_alias('ingress_transport', 'http')
channel.set_alias('egress_transport', 'websocket')
await channel.save()
```

Transport resolution uses first-match strategy:
1. Channel-preferred transport (if available)
2. First available transport

---

## Message Threading

Messages support two types of relationships:

**reply_to** - Direct thread parent (single message)
```python
msg2.set_reply_to_id(msg1.id)
parent = await msg2.get_reply_to()
```

**references** - Semantic links (multiple messages)
```python
msg3.add_reference(msg1.id)
msg3.add_reference(msg2.id)
refs = await msg3.get_references()
```

**Thread Traversal:**
```python
registry = MessageRegistry()
thread = await registry.get_thread(message.id)
# Returns Manifest with [root, ..., message]
```

---

## Examples

### Complete Workflow

```python
from winterforge.frags import Frag, Manifest
from winterforge_channels.primitives import Message, Channel

# Create permission
perm = Frag(affinities=['permission'], traits=['titled', 'persistable'])
perm.set_title('channel.submit')
await perm.save()

# Create role
role = Frag(
    affinities=['role'],
    traits=['titled', 'permissioned', 'persistable'],
)
role.set_title('member')
role.add_permission(perm.id)
await role.save()

# Create user
alice = Frag(
    affinities=['user'],
    traits=['userable', 'authorizable', 'persistable'],
)
alice.set_username('alice')
alice.set_email('alice@example.com')
alice.add_role(role.id)
await alice.save()

# Create channel
general = Channel()
general.set_title("General Chat")
general.set_alias('egress_transport', 'websocket')
await general.save()

# Subscribe
await general.subscribe(alice.id)

# Send message
msg = Message()
msg.set_content("Hello everyone!")
msg.set_author_id(alice.id)
await msg.save()

results = await msg.send(Manifest([general]))
```

### Multi-Channel Broadcasting

```python
# Send to multiple channels at once
channels = Manifest([general, support, announcements])
results = await message.send(channels)

for result in results:
    print(f"Delivered: {result.delivered_count}")
    print(f"Failed: {result.failed_count}")
```

### Conversation Tracking

```python
# Create conversation
conversation = Frag(
    affinities=['conversation'],
    traits=['titled', 'persistable'],
)
conversation.set_title("Project Planning")
await conversation.save()

# Link messages to conversation
msg1.set_conversation_id(conversation.id)
msg2.set_conversation_id(conversation.id)

# Query conversation messages
registry = MessageRegistry()
messages = await registry.get_for_conversation(conversation.id)
```

---

## Testing

```bash
# Run all tests
pytest tests/winterforge_channels/

# Run with coverage
pytest tests/winterforge_channels/ --cov=winterforge_channels

# Run specific test file
pytest tests/winterforge_channels/primitives/test_message.py
```

**Current Status:** 147 tests passing

---

## Development

### Creating Custom Transports

Implement `IngressTransport` and/or `EgressTransport` protocols:

```python
from winterforge_channels.plugins.transports import (
    EgressTransport,
    TransportResult,
)

class EmailEgressTransport:
    """Send messages via email."""

    async def send(self, message, channel, subscribers):
        """Send email to subscribers."""
        delivered = 0
        failed = 0
        errors = []

        for subscriber in subscribers:
            try:
                await send_email(
                    to=subscriber.email,
                    subject=f"New message in {channel.title}",
                    body=message.content,
                )
                delivered += 1
            except Exception as e:
                errors.append(str(e))
                failed += 1

        return [TransportResult(
            success=(failed == 0),
            delivered_count=delivered,
            failed_count=failed,
            errors=errors,
        )]

    def is_available(self) -> bool:
        """Check if email transport is available."""
        return True
```

Register via decorator:
```python
from winterforge.plugins.decorators import plugin

@plugin('email', type='egress_transport')
class EmailEgressTransport:
    ...
```

---

## Architecture Principles

**Composition Over Inheritance**
- Messages, Channels, Subscriptions use trait composition
- No inheritance hierarchies

**Transport Agnostic**
- Messages don't know HOW they're delivered
- Channels handle routing

**Permission Controlled**
- Leverages WinterForge's authorizable trait
- Fine-grained access control

**Subscriber Agnostic**
- ANY Frag can be a subscriber
- No special requirements

**Fluent Interfaces**
- Chainable methods throughout
- Pythonic design

**Pattern Consistency**
- Matches WinterForge core patterns
- Repository/Manifest API alignment

---

## API Reference

See [getting_started.md](docs/getting_started.md) for detailed
documentation.

---

## Contributing

Contributions welcome! Please ensure:
- All tests pass
- New features have tests
- Code follows WinterForge mandates
- Line length ≤80 characters

---

## License

MIT License - see LICENSE file for details

---

## Links

- **WinterForge Core:** https://github.com/yourusername/winterforge
- **Documentation:** https://winterforge-channels.readthedocs.io
- **Issues:** https://github.com/yourusername/winterforge-channels/issues

---

Built with ❄️ by the WinterForge team
