Refactor: move ProjectAPI to its own module

1 files changed, 1 insertions, 71 deletions

diff --git a/ick2/controllerapi.py b/ick2/controllerapi.py
index 4283e82..4b67d10 100644
--- a/ick2/controllerapi.py
+++ b/ick2/controllerapi.py
@@ -32,7 +32,7 @@ class ControllerAPI:
             '/version': ick2.VersionAPI,
             '/builds': ick2.BuildsAPI,
             '/logs': ick2.LogAPI,
-            '/projects': ProjectAPI,
+            '/projects': ick2.ProjectAPI,
             '/work': ick2.WorkAPI,
             '/workers': ick2.WorkerAPI,
         }
@@ -44,73 +44,3 @@ class ControllerAPI:
             routes.extend(api.get_routes(path))
         ick2.log.log('info', msg_texg='Found routes', routes=routes)
         return routes
-
-
-class ProjectAPI(ick2.ResourceApiBase):
-
-    def __init__(self, state):
-        super().__init__('projects', state)
-
-    def get_resource_name(self, resource):
-        return resource['project']
-
-    def get_routes(self, path):  # pragma: no cover
-        return super().get_routes(path) + self.get_pipeline_routes(path)
-
-    def get_pipeline_routes(self, path):  # pragma: no cover
-        pipeline_path = '{}/<project>/pipelines/<pipeline>'.format(path)
-        builds_path = '{}/<project>/builds'.format(path)
-        return [
-            {
-                'method': 'GET',
-                'path': pipeline_path,
-                'callback': self.GET(self.get_pipeline),
-            },
-            {
-                'method': 'PUT',
-                'path': pipeline_path,
-                'callback': self.PUT(self.set_pipeline_callback),
-            },
-            {
-                'method': 'GET',
-                'path': builds_path,
-                'callback': self.GET(self.get_builds),
-            },
-        ]
-
-    def get_pipeline(self, project, pipeline):
-        p = self._state.get_resource(self._type_name, project)
-        for pl in p['pipelines']:
-            if pl['name'] == pipeline:
-                return {
-                    'status': pl.get('status', 'idle'),
-                }
-        raise ick2.NotFound()
-
-    def set_pipeline_callback(
-            self, body, project, pipeline):  # pragma: no cover
-        return self.set_pipeline(body['status'], project, pipeline)
-
-    def set_pipeline(self, state, project, pipeline):
-        allowed_changes = {
-            'idle': 'triggered',
-            'triggered': 'building',
-            'building': 'idle',
-        }
-        p = self._state.get_resource(self._type_name, project)
-        for pl in p['pipelines']:
-            if pl['name'] == pipeline:
-                old_state = pl.get('status', 'idle')
-                if allowed_changes[old_state] != state:
-                    raise ick2.WrongPipelineStatus(state)
-                pl['status'] = state
-                self._state.update_resource(self._type_name, project, p)
-                return {'status': state}
-        raise ick2.NotFound()
-
-    def get_builds(self, project):
-        p = self._state.get_resource(self._type_name, project)
-        return {
-            'project': project,
-            'builds': p.get('builds', []),
-        }