feat(openadapt.record): implemented notifications on record (#510)

* implemented notifications on record

fixed deprecated/visualize

* fix import

openadapt/app/cards.py

@@ -11,7 +11,7 @@
 
 from openadapt.app.objects.local_file_picker import LocalFilePicker
 from openadapt.app.util import get_scrub, set_dark, set_scrub, sync_switch
-from openadapt.crud import new_session
+from openadapt.db.crud import new_session
 
 record_proc = None
 

openadapt/app/tray.py

@@ -16,7 +16,7 @@
 
 from openadapt.app.cards import quick_record, stop_record
 from openadapt.app.main import FPATH, start
-from openadapt.crud import get_all_recordings
+from openadapt.db.crud import get_all_recordings
 from openadapt.extensions.thread import Thread as oaThread
 from openadapt.models import Recording
 from openadapt.replay import replay

openadapt/deprecated/visualize.py

@@ -13,7 +13,7 @@
 from tqdm import tqdm
 
 from openadapt import config
-from openadapt.crud import get_latest_recording
+from openadapt.db.crud import get_latest_recording
 from openadapt.events import get_events
 from openadapt.models import Recording
 from openadapt.privacy.providers.presidio import PresidioScrubbingProvider

openadapt/record.py

@@ -19,6 +19,7 @@
 import tracemalloc
 
 from loguru import logger
+from notifypy import Notify
 from oa_pynput import keyboard, mouse
 from pympler import tracker
 from tqdm import tqdm
@@ -180,6 +181,7 @@ def process_events(
     """
     utils.set_start_time(recording_timestamp)
     logger.info("Starting")
+    Notify("Status", "Starting recording...", "OpenAdapt").send()
 
     prev_event = None
     prev_screen_event = None
@@ -238,6 +240,7 @@ def process_events(
         del prev_event
         prev_event = event
     logger.info("Done")
+    Notify("Status", "Writing to database...", "OpenAdapt").send()
 
 
 def write_action_event(
@@ -345,6 +348,7 @@ def write_events(
 
     if progress is not None:
         progress.close()
+        Notify("Status", "Recording complete.", "OpenAdapt").send()
 
     logger.info(f"{event_type=} done")