Transport Frames

def __str__(self):
    """
    Returns formatted string with message content
    """

def __str__(self):
    """
    Returns formatted string with urgent message content
    """

def __str__(self):
    """
    Returns formatted string with user ID
    """

# Send regular transport message
regular_msg = TransportMessageFrame(
    message={
        "type": "status_update",
        "status": "connected"
    }
)

# Send urgent transport message
urgent_msg = TransportMessageUrgentFrame(
    message={
        "type": "connection_error",
        "action": "reconnect"
    }
)

# Request user image
image_request = UserImageRequestFrame(
    user_id="user123",
    context={
        "purpose": "profile_update",
        "required_size": (256, 256)
    }
)

# Transport-aware pipeline
pipeline = Pipeline([
    transport_input,
    message_handler,        # Processes transport messages
    image_request_handler,  # Handles image requests
    transport_output
])

# Message handler implementation
class TransportMessageHandler(Processor):
    async def process_frame(self, frame: Frame):
        if isinstance(frame, TransportMessageUrgentFrame):
            await self.handle_urgent_message(frame.message)
        elif isinstance(frame, TransportMessageFrame):
            await self.handle_regular_message(frame.message)

class PriorityMessageProcessor(Processor):
    async def process_frame(self, frame: Frame):
        if isinstance(frame, TransportMessageUrgentFrame):
            # Handle urgent message immediately
            await self.process_urgent(frame.message)
        elif isinstance(frame, TransportMessageFrame):
            # Queue regular message for processing
            await self.queue_message(frame.message)

class ImageRequestHandler(Processor):
    async def process_frame(self, frame: Frame):
        if isinstance(frame, UserImageRequestFrame):
            # Request image from user
            image = await self.request_user_image(
                frame.user_id,
                frame.context
            )
            # Create image frame with result
            await self.push_frame(UserImageRawFrame(
                image=image.data,
                size=image.size,
                format=image.format,
                user_id=frame.user_id
            ))