remove unused functions

Author: salman2135

src/explorepy/explore.py

@@ -24,7 +24,6 @@
 from scipy import signal as scipy_signal
 
 import explorepy
-from explorepy._exceptions import ImpedanceModeActiveError
 from explorepy.command import (
     MemoryFormat,
     SetBinaryTime,
@@ -751,57 +750,3 @@ def is_bt_link_unstable(self):
 
     def get_channel_mask(self):
         return SettingsManager(self.device_name).get_adc_mask()
-
-    def is_asr_processor_available(self):
-        try:
-            return self.stream_processor.ensure_asr_processor_available()
-        except ImpedanceModeActiveError:
-            return False
-
-    def calibrate_asr(self, length=-1.0):
-        if self.is_asr_processor_available():
-            self.stream_processor.asr_processor.start_calibration(length)
-
-    def is_asr_calibration_data_available(self):
-        if self.is_asr_processor_available():
-            return self.stream_processor.asr_processor.calibration_data_available
-        else:
-            return False
-
-    def is_asr_calibrating(self):
-        if self.is_asr_processor_available():
-            return self.stream_processor.asr_processor.is_calibrating
-        else:
-            return False
-
-    def is_asr_running(self):
-        if self.is_asr_processor_available():
-            return self.stream_processor.asr_processor.is_cleaning
-        else:
-            return False
-
-    def start_asr(self, window=None):
-        if self.is_asr_processor_available():
-            if self.stream_processor.asr_processor.calibration_data_available:
-                self.stream_processor.asr_processor.start_cleaning(window)
-
-    def stop_asr(self):
-        if self.is_asr_processor_available():
-            if self.stream_processor.asr_processor.calibration_data_available:
-                self.stream_processor.asr_processor.stop_cleaning()
-
-    def set_asr_cutoff(self, new_cutoff: float):
-        if self.is_asr_processor_available():
-            self.stream_processor.asr_processor.cutoff = new_cutoff
-
-    def get_asr_cutoff(self):
-        if self.is_asr_processor_available():
-            return self.stream_processor.asr_processor.cutoff
-
-    def set_asr_refresh_window(self, new_window):
-        if self.is_asr_processor_available():
-            self.stream_processor.asr_processor.refresh_window = new_window
-
-    def get_asr_refresh_window(self):
-        if self.is_asr_processor_available():
-            return self.stream_processor.asr_processor.refresh_window

src/explorepy/stream_processor.py

@@ -15,8 +15,6 @@
 
 import numpy as np
 
-from explorepy._exceptions import ImpedanceModeActiveError
-from explorepy.asr_processor import AsrProcessor
 from explorepy.command import (
     DeviceConfiguration,
     ZMeasurementDisable,
@@ -26,7 +24,6 @@
 from explorepy.packet import (
     EEG,
     CalibrationInfoBase,
-    CleanEEG,
     CommandRCV,
     CommandStatus,
     DeviceInfo,
@@ -58,7 +55,6 @@ class StreamProcessor:
 
     def __init__(self, debug=False):
         self.parser = None
-        self.asr_processor = None
         self.filters = []
         self.device_info = {}
         self.old_device_info = {}
@@ -339,12 +335,6 @@ def process(self, packet):
                     self.dispatch(topic=TOPICS.filtered_ExG, packet=packet)
 
             self.dispatch(topic=TOPICS.filtered_ExG, packet=packet)
-            if not self._is_imp_mode and self.imp_calculator is None:
-                if self.asr_processor.cleaned_data_available:
-                    clean_packet = CleanEEG(timestamp=self.asr_processor.cleaned_data_ts,
-                                            payload=self.asr_processor.cleaned_data)
-                    self.dispatch(topic=TOPICS.asr_ExG, packet=clean_packet)
-                    self.asr_processor.clear_cleaned_data()
         elif isinstance(packet, DeviceInfo):
             self.old_device_info = self.device_info.copy()
             print(self.old_device_info)
@@ -354,7 +344,6 @@ def process(self, packet):
                     self.device_info["device_name"])
                 settings_manager.update_device_settings(packet.get_info())
             self.dispatch(topic=TOPICS.device_info, packet=packet)
-            self.asr_processor = AsrProcessor(self, TOPICS.raw_ExG)
         elif isinstance(packet, CommandRCV):
             self.dispatch(topic=TOPICS.cmd_ack, packet=packet)
         elif isinstance(packet, CommandStatus):
@@ -620,8 +609,3 @@ def get_power_line_freq(self):
             None
         )
         return match.get_cutoff_freq() if match else None
-
-    def ensure_asr_processor_available(self):
-        if self.is_imp_running():
-            raise ImpedanceModeActiveError()
-        return self.asr_processor is not None and self.asr_processor.is_initialized