12112350604

Committed 02 Dec 2024 03:52AM UTC coverage: 89.891% (-0.04%) from 89.932%

Build # 12112350604

Build Type

Pull #1611

github

Committed by

web-flow

Commit Message

Merge 9176d03d1 into f2f296b80

Pull Request Pull Request #1611: Mail channel implementation

Run Details

383 of 434 new or added lines in 15 files covered. (88.25%)

12 existing lines in 2 files now uncovered.

24141 of 26856 relevant lines covered (89.89%)

0.9 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

71.43

/kairon/events/definitions/mail_channel_schedule.py

from typing import Text
from loguru import logger
from kairon import Utility
from kairon.events.definitions.base import EventsBase
from kairon.shared.channels.mail.processor import MailProcessor
from kairon.shared.constants import EventClass, ChannelTypes


class MailChannelScheduleEvent(EventsBase):
    """
    Event to start mail channel scheduler if not already running.
    """

    def __init__(self, bot: Text, user: Text, **kwargs):
        """
        Initialise event.
        """
        self.bot = bot
        self.user = user

    def validate(self):
        """
        validate mail channel exists
        """
        pass


    def enqueue(self, **kwargs):
        """
        Send event to event server.
        """
        try:
            mails: list = kwargs.get('mails', [])
            payload = {'bot': self.bot, 'user': self.user, 'mails': mails}
            Utility.request_event_server(EventClass.email_channel_scheduler, payload)
        except Exception as e:
            logger.error(str(e))
            raise e

    def execute(self, **kwargs):
        """
        Execute the event.
        """
        try:
            mails = kwargs.get('mails')
            if mails:
                MailProcessor.process_message_task(self.bot, mails)
        except Exception as e:
            logger.error(str(e))
            raise e

1	from typing import Text	1✔
2	from loguru import logger	1✔
3	from kairon import Utility	1✔
4	from kairon.events.definitions.base import EventsBase	1✔
5	from kairon.shared.channels.mail.processor import MailProcessor	1✔
6	from kairon.shared.constants import EventClass, ChannelTypes	1✔
7
8
9	class MailChannelScheduleEvent(EventsBase):	1✔
10	"""
11	Event to start mail channel scheduler if not already running.
12	"""
13
14	def __init__(self, bot: Text, user: Text, **kwargs):	1✔
15	"""
16	Initialise event.
17	"""
18	self.bot = bot	1✔
19	self.user = user	1✔
20
21	def validate(self):	1✔
22	"""
23	validate mail channel exists
24	"""
NEW 25	pass	×
26
27
28	def enqueue(self, **kwargs):	1✔
29	"""
30	Send event to event server.
31	"""
32	try:	1✔
33	mails: list = kwargs.get('mails', [])	1✔
34	payload = {'bot': self.bot, 'user': self.user, 'mails': mails}	1✔
35	Utility.request_event_server(EventClass.email_channel_scheduler, payload)	1✔
NEW 36	except Exception as e:	×
NEW 37	logger.error(str(e))	×
NEW 38	raise e	×
39
40	def execute(self, **kwargs):	1✔
41	"""
42	Execute the event.
43	"""
44	try:	1✔
45	mails = kwargs.get('mails')	1✔
46	if mails:	1✔
NEW 47	MailProcessor.process_message_task(self.bot, mails)	×
NEW 48	except Exception as e:	×
NEW 49	logger.error(str(e))	×
NEW 50	raise e	×

digiteinfotech / kairon / 12112350604

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous