The audit log Python API

# -*- coding: utf-8 -*-

# Zato
from zato.common.audit_log.api import AuditOutcome
from zato.server.service import Service

class RecentFailures(Service):
    """ Returns the failures recorded since a given moment.
    """
    input = 'time_from'

    def handle(self) -> 'None':

        # Search for failures recorded in the requested period ..
        events = self.audit.search(
            outcome=AuditOutcome.Error,
            time_from=self.request.input.time_from,
        )

        # .. and return the matching events.
        self.response.payload = {'events': events}

# Search for failures and expirations across both MLLP directions.
events = self.audit.search(
    source=[AuditSource.MLLP_Channel, AuditSource.MLLP_Outgoing],
    outcome=[AuditOutcome.Error, AuditOutcome.Expired],
)

# Zato
from zato.common.audit_log.api import AuditEvent, AuditOutcome, AuditSource, Status_Outstanding

# Search for arrivals and acknowledgments of one patient's messages.
events = self.audit.search(
    source=AuditSource.MLLP_Channel,
    query='12345678',
)

# Search for outgoing HL7 messages awaiting an acknowledgment.
events = self.audit.search(
    source=AuditSource.MLLP_Outgoing,
    status=Status_Outstanding,
)

# -*- coding: utf-8 -*-

# stdlib
from datetime import datetime, timedelta

# Zato
from zato.common.audit_log.api import AuditSource
from zato.server.service import Service

class SilentFeeds(Service):
    """ Returns the HL7 channels whose latest event is older than one hour.
    """
    output = 'silent'

    def handle(self) -> 'None':

        # Get the newest event time of each channel ..
        last_seen = self.audit.last_seen(AuditSource.MLLP_Channel)

        # .. calculate the one-hour silence threshold ..
        cutoff = datetime.utcnow() - timedelta(hours=1)
        cutoff_iso = cutoff.isoformat()

        # .. collect channels whose latest event precedes the threshold ..
        silent = []

        for channel_name, last_event_time in last_seen.items():
            if last_event_time < cutoff_iso:
                silent.append(channel_name)

        # .. and return their names.
        self.response.payload = {'silent': silent}

# Zato
from zato.common.audit_log.api import AuditBody

# Read the latest stored body of an event.
payload = self.audit.get_payload(event_id)

# Select a specific stored body.
request_body = self.audit.get_payload(event_id, AuditBody.Request)
response_body = self.audit.get_payload(event_id, AuditBody.Response)
error_body = self.audit.get_payload(event_id, AuditBody.Error)

# -*- coding: utf-8 -*-

# Zato
from zato.common.audit_log.api import AuditEvent, AuditSource
from zato.server.service import Service

# #####################################################################
# #####################################################################

class PatientMessageStatus(Service):
    """ Returns whether HL7 messages for a given patient MRN arrived,
    with the control ID, event type and arrival time of each.
    """
    name = 'patient.message-status'

    input  = 'patient_mrn'
    output = 'has_arrived', 'messages'

    def handle(self) -> 'None':

        # Read the MRN the caller asked about ..
        patient_mrn = self.request.input.patient_mrn

        # .. search for received MLLP messages that mention it ..
        events = self.audit.search(
            source=AuditSource.MLLP_Channel,
            event_type=AuditEvent.Message_Received,
            query=patient_mrn,
        )

        # .. copy only the fields needed by the caller ..
        messages = []

        for event in events:
            messages.append({
                'control_id': event['msg_id'],
                'event_type': event['event_type'],
                'received_at': event['event_time_iso'],
            })

        # .. determine whether at least one message arrived ..
        has_arrived = len(messages) > 0

        # .. and return the minimized result.
        self.response.payload = {
            'has_arrived': has_arrived,
            'messages': messages,
        }