
# slixmpp.xmlstream.handler.callback
# ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
# Part of Slixmpp: The Slick XMPP Library
# :copyright: (c) 2011 <NAME>
# :license: MIT, see LICENSE for more details
from __future__ import annotations

from asyncio import iscoroutinefunction, ensure_future
from typing import Optional, Callable, Awaitable, TYPE_CHECKING

from slixmpp.xmlstream.stanzabase import StanzaBase
from slixmpp.xmlstream.handler.base import BaseHandler
from slixmpp.xmlstream.matcher.base import MatcherBase

CoroutineFunction = Callable[[StanzaBase], Awaitable[None]]

if TYPE_CHECKING:
    from slixmpp.xmlstream.xmlstream import XMLStream


class CoroutineCallback(BaseHandler):

    """
    The Callback handler will execute a callback function with
    matched stanzas.

    The handler may execute the callback either during stream
    processing or during the main event loop.

    The event will be scheduled to be run soon in the event loop instead
    of immediately.

    :param string name: The name of the handler.
    :param matcher: A :class:`~slixmpp.xmlstream.matcher.base.MatcherBase`
                    derived object for matching stanza objects.
    :param pointer: The function to execute during callback. If ``pointer``
                    is not a coroutine, this function will raise a ValueError.
    :param bool once: Indicates if the handler should be used only
                      once. Defaults to False.
    :param bool instream: Indicates if the callback should be executed
                          during stream processing instead of in the
                          main event loop.
    :param stream: The :class:`~slixmpp.xmlstream.xmlstream.XMLStream`
                   instance this handler should monitor.
    """

    _once: bool
    _instream: bool

    def __init__(self, name: str, matcher: MatcherBase,
                 pointer: CoroutineFunction, once: bool = False,
                 instream: bool = False, stream: Optional[XMLStream] = None):
        BaseHandler.__init__(self, name, matcher, stream)
        if not iscoroutinefunction(pointer):
            raise ValueError("Given function is not a coroutine")

        async def pointer_wrapper(stanza: StanzaBase) -> None:
            try:
                await pointer(stanza)
            except Exception as e:
                stanza.exception(e)

        self._pointer: CoroutineFunction = pointer_wrapper
        self._once = once
        self._instream = instream

    def prerun(self, payload: StanzaBase) -> None:
        """Execute the callback during stream processing, if
        the callback was created with ``instream=True``.

        :param payload: The matched
            :class:`~slixmpp.xmlstream.stanzabase.StanzaBase` object.
        """
        if self._once:
            self._destroy = True
        if self._instream:
            self.run(payload, True)

    def run(self, payload: StanzaBase, instream: bool = False) -> None:
        """Execute the callback function with the matched stanza payload.

        :param payload: The matched
            :class:`~slixmpp.xmlstream.stanzabase.StanzaBase` object.
        :param bool instream: Force the handler to execute during stream
                              processing. This should only be used by
                              :meth:`prerun()`. Defaults to ``False``.
        """
        if not self._instream or instream:
            ensure_future(self._pointer(payload))
            if self._once:
                self._destroy = True
                del self._pointer


# slixmpp.xmlstream.handler.callback
# ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
# Part of Slixmpp: The Slick XMPP Library
# :copyright: (c) 2011 <NAME>
# :license: MIT, see LICENSE for more details
from __future__ import annotations

from asyncio import iscoroutinefunction, ensure_future
from typing import Optional, Callable, Awaitable, TYPE_CHECKING

from slixmpp.xmlstream.stanzabase import StanzaBase
from slixmpp.xmlstream.handler.base import BaseHandler
from slixmpp.xmlstream.matcher.base import MatcherBase

CoroutineFunction = Callable[[StanzaBase], Awaitable[None]]

if TYPE_CHECKING:
    from slixmpp.xmlstream.xmlstream import XMLStream


class CoroutineCallback(BaseHandler):

    """
    The Callback handler will execute a callback function with
    matched stanzas.

    The handler may execute the callback either during stream
    processing or during the main event loop.

    The event will be scheduled to be run soon in the event loop instead
    of immediately.

    :param string name: The name of the handler.
    :param matcher: A :class:`~slixmpp.xmlstream.matcher.base.MatcherBase`
                    derived object for matching stanza objects.
    :param pointer: The function to execute during callback. If ``pointer``
                    is not a coroutine, this function will raise a ValueError.
    :param bool once: Indicates if the handler should be used only
                      once. Defaults to False.
    :param bool instream: Indicates if the callback should be executed
                          during stream processing instead of in the
                          main event loop.
    :param stream: The :class:`~slixmpp.xmlstream.xmlstream.XMLStream`
                   instance this handler should monitor.
    """

    _once: bool
    _instream: bool

    def __init__(self, name: str, matcher: MatcherBase,
                 pointer: CoroutineFunction, once: bool = False,
                 instream: bool = False, stream: Optional[XMLStream] = None):
        BaseHandler.__init__(self, name, matcher, stream)
        if not iscoroutinefunction(pointer):
            raise ValueError("Given function is not a coroutine")

        async def pointer_wrapper(stanza: StanzaBase) -> None:
            try:
                await pointer(stanza)
            except Exception as e:
                stanza.exception(e)

        self._pointer: CoroutineFunction = pointer_wrapper
        self._once = once
        self._instream = instream

    def prerun(self, payload: StanzaBase) -> None:
        """Execute the callback during stream processing, if
        the callback was created with ``instream=True``.

        :param payload: The matched
            :class:`~slixmpp.xmlstream.stanzabase.StanzaBase` object.
        """
        if self._once:
            self._destroy = True
        if self._instream:
            self.run(payload, True)

    def run(self, payload: StanzaBase, instream: bool = False) -> None:
        """Execute the callback function with the matched stanza payload.

        :param payload: The matched
            :class:`~slixmpp.xmlstream.stanzabase.StanzaBase` object.
        :param bool instream: Force the handler to execute during stream
                              processing. This should only be used by
                              :meth:`prerun()`. Defaults to ``False``.
        """
        if not self._instream or instream:
            ensure_future(self._pointer(payload))
            if self._once:
                self._destroy = True
                del self._pointer

# slixmpp.xmlstream.handler.callback # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ # Part of Slixmpp: The Slick XMPP Library # :copyright: (c) 2011 <NAME> # :license: MIT, see LICENSE for more details The Callback handler will execute a callback function with     matched stanzas.      The handler may execute the callback either during stream     processing or during the main event loop.      The event will be scheduled to be run soon in the event loop instead     of immediately.      :param string name: The name of the handler.     :param matcher: A :class:`~slixmpp.xmlstream.matcher.base.MatcherBase`                     derived object for matching stanza objects.     :param pointer: The function to execute during callback. If ``pointer``                     is not a coroutine, this function will raise a ValueError.     :param bool once: Indicates if the handler should be used only                       once. Defaults to False.     :param bool instream: Indicates if the callback should be executed                           during stream processing instead of in the                           main event loop.     :param stream: The :class:`~slixmpp.xmlstream.xmlstream.XMLStream`                    instance this handler should monitor. Execute the callback during stream processing, if         the callback was created with ``instream=True``.          :param payload: The matched             :class:`~slixmpp.xmlstream.stanzabase.StanzaBase` object. Execute the callback function with the matched stanza payload.          :param payload: The matched             :class:`~slixmpp.xmlstream.stanzabase.StanzaBase` object.         :param bool instream: Force the handler to execute during stream                               processing. This should only be used by                               :meth:`prerun()`. Defaults to ``False``.