add timers to func calls in add_or_reactivate_participant (#2967)

* add timers to func calls in add_or_reactivate_participant

* add timer to incident.get

Author: wssheldon

src/dispatch/incident/flows.py

@@ -3,6 +3,7 @@
 from datetime import datetime
 from typing import Any, List
 
+from dispatch.decorators import timer
 from dispatch.conference import service as conference_service
 from dispatch.conference.models import ConferenceCreate
 from dispatch.conversation import service as conversation_service
@@ -599,6 +600,7 @@ def set_conversation_bookmarks(incident: Incident, db_session: SessionLocal):
         log.exception(e)
 
 
+@timer
 def add_participants_to_conversation(
     participant_emails: List[str], incident: Incident, db_session: SessionLocal
 ):
@@ -630,6 +632,7 @@ def add_participants_to_conversation(
         log.exception(e)
 
 
+@timer
 def add_participant_to_tactical_group(
     user_email: str, incident: Incident, db_session: SessionLocal
 ):

src/dispatch/incident/messaging.py

@@ -6,6 +6,7 @@
 """
 import logging
 
+from dispatch.decorators import timer
 from dispatch.config import DISPATCH_UI_URL
 from dispatch.conversation.enums import ConversationCommands
 from dispatch.database.core import SessionLocal, resolve_attr
@@ -214,6 +215,7 @@ def send_welcome_email_to_participant(
     log.debug(f"Welcome email sent to {participant_email}.")
 
 
+@timer
 def send_incident_welcome_participant_messages(
     participant_email: str, incident: Incident, db_session: SessionLocal
 ):
@@ -227,6 +229,7 @@ def send_incident_welcome_participant_messages(
     log.debug(f"Welcome participant messages sent {participant_email}.")
 
 
+@timer
 def get_suggested_document_items(incident: Incident, db_session: SessionLocal):
     """Create the suggested document item message."""
     suggested_documents = get_suggested_documents(db_session, incident)
@@ -246,6 +249,7 @@ def get_suggested_document_items(incident: Incident, db_session: SessionLocal):
     return items
 
 
+@timer
 def send_incident_suggested_reading_messages(
     incident: Incident, items: list, participant_email: str, db_session: SessionLocal
 ):
@@ -464,6 +468,7 @@ def send_incident_update_notifications(
     log.debug("Incident updated notifications sent.")
 
 
+@timer
 def send_incident_participant_announcement_message(
     participant_email: str, incident: Incident, db_session: SessionLocal
 ):

src/dispatch/incident/service.py

@@ -10,6 +10,7 @@
 from typing import List, Optional
 from pydantic.error_wrappers import ErrorWrapper, ValidationError
 
+from dispatch.decorators import timer
 from dispatch.case import service as case_service
 from dispatch.database.core import SessionLocal
 from dispatch.event import service as event_service
@@ -62,6 +63,7 @@ def resolve_and_associate_role(
     return email_address, service_id
 
 
+@timer
 def get(*, db_session, incident_id: int) -> Optional[Incident]:
     """Returns an incident based on the given id."""
     return db_session.query(Incident).filter(Incident.id == incident_id).first()

src/dispatch/participant/flows.py

@@ -1,6 +1,7 @@
 import logging
 from typing import TypeVar
 
+from dispatch.decorators import timer
 from dispatch.case.models import Case
 from dispatch.database.core import SessionLocal, get_table_name_by_class_instance
 from dispatch.event import service as event_service
@@ -21,6 +22,7 @@
 Subject = TypeVar("Subject", Case, Incident)
 
 
+@timer
 def add_participant(
     user_email: str,
     subject: Subject,
@@ -147,6 +149,7 @@ def inactivate_participant(user_email: str, incident: Incident, db_session: Sess
     return True
 
 
+@timer
 def reactivate_participant(
     user_email: str, incident: Incident, db_session: SessionLocal, service_id: int = None
 ):

src/dispatch/participant/service.py

@@ -1,5 +1,6 @@
 from typing import List, Optional
 
+from dispatch.decorators import timer
 from dispatch.case import service as case_service
 from dispatch.incident import service as incident_service
 from dispatch.individual import service as individual_service
@@ -43,6 +44,7 @@ def get_by_case_id_and_role(*, db_session, case_id: int, role: str) -> Optional[
     )
 
 
+@timer
 def get_by_incident_id_and_email(
     *, db_session, incident_id: int, email: str
 ) -> Optional[Participant]:
@@ -67,6 +69,7 @@ def get_by_case_id_and_email(*, db_session, case_id: int, email: str) -> Optiona
     )
 
 
+@timer
 def get_by_incident_id_and_service_id(
     *, db_session, incident_id: int, service_id: int
 ) -> Optional[Participant]: