diff --git a/geomagio/processing/obsrio.py b/geomagio/processing/obsrio.py index 7d29f1fd50a262f0432d6458fe5fb94366e753c0..d3d07b3cc610fd08fbc8d29bfe7bb08d36a320de 100644 --- a/geomagio/processing/obsrio.py +++ b/geomagio/processing/obsrio.py @@ -1,6 +1,8 @@ import os from typing import Optional +import typer + from ..algorithm import Algorithm, FilterAlgorithm from ..edge import EdgeFactory, MiniSeedFactory from ..Controller import Controller, get_realtime_interval @@ -8,6 +10,10 @@ from ..TimeseriesFactory import TimeseriesFactory from .factory import get_edge_factory, get_miniseed_factory +def main(): + typer.run(filter_realtime) + + def obsrio_minute( observatory: str, input_factory: Optional[TimeseriesFactory] = None, @@ -202,26 +208,3 @@ def obsrio_day( rename_output_channel=((input_channel, output_channel),), update_limit=update_limit, ) - - -def filter_realtime( - observatory: str, - input_factory: Optional[TimeseriesFactory] = None, - output_factory: Optional[TimeseriesFactory] = None, - realtime_interval: int = 600, - update_limit: int = 10, -): - """Filter 10Hz miniseed, 1 second and one minute data. - Defaults set for realtime processing; can also be implemented to update legacy data""" - obsrio_tenhertz( - observatory, realtime_interval, input_factory, output_factory, update_limit - ) - obsrio_second( - observatory, realtime_interval, input_factory, output_factory, update_limit - ) - obsrio_minute( - observatory, realtime_interval, input_factory, output_factory, update_limit - ) - obsrio_temperatures( - observatory, realtime_interval, input_factory, output_factory, update_limit - ) diff --git a/setup.py b/setup.py index 23146078a165a79b7e13d09f9d8cc2d6b034b30a..b1dc547f0ead527a1f175dc36d140899a3abbe17 100644 --- a/setup.py +++ b/setup.py @@ -26,6 +26,7 @@ setuptools.setup( entry_points={ "console_scripts": [ "magproc-prepfiles=geomagio.processing.magproc:main", + "update-legacy=geomagio.processing.obsrio:main", ], }, )