ChannelVisitor

def visit(
    self,
    *,
    sub: "LogicSubscriber",
    channel: str | None = None,
    list: str | None = None,
    stream: str | None = None,
) -> str | None:
    if channel is None or not isinstance(sub, ChannelSubscriber):
        return None

    sub_channel = sub.channel

    if (
        sub_channel.pattern
        and bool(
            re.match(
                sub_channel.name.replace(".", "\\.").replace("*", ".*"),
                channel or "",
            ),
        )
    ) or channel == sub_channel.name:
        return channel

    return None

def get_message(  # type: ignore[override]
    self,
    channel: str,
    body: Any,
    sub: "ChannelSubscriber",
) -> Any:
    return PubSubMessage(
        type="message",
        data=body,
        channel=channel,
        pattern=sub.channel.pattern.encode() if sub.channel.pattern else None,
    )