src/python/dm/proc_web_service/service/impl/workflowSessionControllerImpl.py

+#!/usr/bin/env python
+
+#
+# Implementation for workflow controller.
+#
+
+from dm.common.objects.dmObject import DmObject
+from dm.common.objects.dmObjectManager import DmObjectManager
+from dm.common.mongodb.api.workflowMongoDbApi import WorkflowMongoDbApi
+
+class WorkflowSessionControllerImpl(DmObjectManager):
+    """ Workflow controller implementation class. """
+
+    def __init__(self):
+        DmObjectManager.__init__(self)
+        self.workflowMongoDbApi = WorkflowMongoDbApi()
+
+    def getWorkflowByName(self, owner, name):
+        return self.workflowMongoDbApi.getWorkflowByName(owner, name)
+

src/python/dm/proc_web_service/service/procWebService.py

+#!/usr/bin/env python
+
+#
+# DM PROC Web Service
+#
+
+from dm.common.service.dmRestWebServiceBase import DmRestWebServiceBase
+from dm.common.utility.dmModuleManager import DmModuleManager
+from dm.common.utility.configurationManager import ConfigurationManager
+
+from procWebServiceRouteMapper import ProcWebServiceRouteMapper
+
+class ProcWebService(DmRestWebServiceBase):
+
+    def __init__(self):
+        DmRestWebServiceBase.__init__(self, ProcWebServiceRouteMapper)
+
+    def initDmModules(self):
+        self.logger.debug('Initializing dm modules')
+
+        # Add modules that will be started.
+        moduleManager = DmModuleManager.getInstance()
+
+        self.logger.debug('Initialized dm modules')
+
+    def getDefaultServerHost(self):
+        return ConfigurationManager.getInstance().getServiceHost()
+
+    def getDefaultServerPort(self):
+        return ConfigurationManager.getInstance().getServicePort()
+
+####################################################################
+# Run service
+
+if __name__ == '__main__':
+    ConfigurationManager.getInstance().setServiceName('proc-web-service')
+    service = ProcWebService();
+    service.run()

src/python/dm/proc_web_service/service/procWebServiceRouteMapper.py

+#!/usr/bin/env python
+
+#
+# Route mapper for DM DAQ web service.
+#
+
+import sys
+import os
+
+import cherrypy
+from dm.common.utility.loggingManager import LoggingManager
+from dm.common.utility.configurationManager import ConfigurationManager
+from dm.common.service.loginRouteDescriptor import LoginRouteDescriptor
+from workflowRouteDescriptor import WorkflowRouteDescriptor
+
+class ProcWebServiceRouteMapper:
+
+    @classmethod
+    def setupRoutes(cls):
+        """ Setup RESTFul routes. """
+        logger = LoggingManager.getInstance().getLogger(cls.__name__)
+        contextRoot = ConfigurationManager.getInstance().getContextRoot()
+        logger.debug('Using context root: %s' % contextRoot)
+
+        # Get routes.
+        routes = LoginRouteDescriptor.getRoutes() 
+        routes += WorkflowRouteDescriptor.getRoutes()
+
+        # Add routes to dispatcher. 
+        d = cherrypy.dispatch.RoutesDispatcher()
+        for route in routes:
+            logger.debug('Connecting route: %s' % route)
+            d.connect(route['name'], route['path'], action=route['action'], controller=route['controller'], conditions=dict(method=route['method']))
+        return d
+
+

src/python/dm/proc_web_service/service/workflowRouteDescriptor.py

+#!/usr/bin/env python
+
+#
+# User route descriptor.
+#
+
+from dm.common.utility.configurationManager import ConfigurationManager
+from workflowSessionController import WorkflowSessionController
+
+class WorkflowRouteDescriptor:
+
+    @classmethod
+    def getRoutes(cls):
+        contextRoot = ConfigurationManager.getInstance().getContextRoot()
+
+        # Static instances shared between different routes
+        workflowSessionController = WorkflowSessionController()
+
+        # Define routes.
+        routes = [
+
+            # Get workflow
+            {
+                'name' : 'getWorkflowByName',
+                'path' : '%s/workflowsByOwner/:(owner)/:(encodedName)' % contextRoot,
+                'controller' : workflowSessionController,
+                'action' : 'getWorkflowByName',
+                'method' : ['GET']
+            },
+
+        ]
+       
+        return routes
+
+

src/python/dm/proc_web_service/service/workflowSessionController.py

+#!/usr/bin/env python
+
+import cherrypy
+import json
+from dm.common.utility.encoder import Encoder
+from dm.common.service.dmSessionController import DmSessionController
+from dm.proc_web_service.service.impl.workflowSessionControllerImpl import WorkflowSessionControllerImpl
+
+class WorkflowSessionController(DmSessionController):
+
+    def __init__(self):
+        DmSessionController.__init__(self)
+        self.workflowSessionControllerImpl = WorkflowSessionControllerImpl()
+
+    @cherrypy.expose
+    @DmSessionController.require(DmSessionController.canManageStation())
+    @DmSessionController.execute
+    def getWorkflowByName(self, owner, encodedName, **kwargs):
+        if not owner:
+            raise InvalidRequest('Invalid owner provided.')
+        name = Encoder.decode(encodedName)
+        if not name:
+            raise InvalidRequest('Invalid workflow name provided.')
+        response = self.workflowSessionControllerImpl.getWorkflowByName(owner, name).getFullJsonRep()
+        return response
+

tools/make/RULES_DM

+all:
+	for d in $(SUBDIRS); do $(MAKE) -C $$d $(ARCH); done
+
+dist:
+	for d in $(SUBDIRS); do $(MAKE) -C $$d $(ARCH); done
+
+clean:
+	for d in $(SUBDIRS); do $(MAKE) -C $$d clean; done
+
+distclean:
+	for d in $(SUBDIRS); do $(MAKE) -C $$d distclean; done
+	for d in $(SUBDIRS); do rm -f `find $$d -name 'RELEASE.local'`; done
+
+tidy: distclean
+