Controller for geomagio

geomagio/Controller.py

+#! /usr/bin/env python
+
+"""Converts iaga2002 files from one coordinate system to another.
+
+    Inputs
+    ------
+    inputFactory: TimeseriesFactory
+    outputFactory: TimeseriesFactory
+    algorithm: Algorithm
+"""
+
+
+class Controller(object):
+
+    def __init__(self, inputFactory, outputFactory, algorithm=None):
+        self._inputFactory = inputFactory
+        self._algorithm = algorithm
+        self._outputFactory = outputFactory
+
+    def run(self, starttime, endtime):
+        input_channels = self._algorithm.get_input_channels()
+        timeseries = self._inputFactory.get_timeseries(starttime, endtime,
+                channels=input_channels)
+        if self._algorithm is not None:
+            processed = self._algorithm.process(timeseries)
+        else:
+            processed = timeseries
+        output_channels = self._algorithm.get_output_channels()
+        self._outputFactory.put_timeseries(processed, channels=output_channels)