Skip to content

Messaging

hypha.apply.activity.messaging

logger module-attribute 

logger = getLogger(__name__)

User module-attribute 

User = get_user_model()

adapters module-attribute 

adapters = [ActivityAdapter(), SlackAdapter(), EmailAdapter(), DjangoMessagesAdapter()]

messenger module-attribute 

messenger = MessengerBackend(*adapters)

MessengerBackend 

MessengerBackend(*adapters)
Source code in hypha/apply/activity/messaging.py 
14
15
def __init__(self, *adapters):
    self.adapters = adapters

adapters instance-attribute 

adapters = adapters

send 

send(message_type, request, user, related, source=None, sources=None, **kwargs)
Source code in hypha/apply/activity/messaging.py 
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
def send(
    self, message_type, request, user, related, source=None, sources=None, **kwargs
):
    from .models import Event

    if sources is None:
        sources = []

    if source:
        event = Event.objects.create(type=message_type.name, by=user, source=source)
        for adapter in self.adapters:
            adapter.process(
                message_type,
                event,
                request=request,
                user=user,
                source=source,
                related=related,
                **kwargs,
            )

    elif sources:
        events = Event.objects.bulk_create(
            Event(type=message_type.name, by=user, source=source)
            for source in sources
        )
        for adapter in self.adapters:
            adapter.process_batch(
                message_type,
                events,
                request=request,
                user=user,
                sources=sources,
                related=related,
                **kwargs,
            )