adding skeleton for station gui

bin/dm-station-gui

+#!/bin/sh
+
+# Run command
+
+if [ -z $DM_ROOT_DIR ]; then
+    cd `dirname $0` && myDir=`pwd`
+    setupFile=$myDir/../setup.sh
+    if [ ! -f $setupFile ]; then
+        echo "Cannot find setup file: $setupFile"
+        exit 1
+    fi
+    source $setupFile > /dev/null
+fi
+source $DM_ROOT_DIR/bin/dm_command_setup.sh
+
+eval "$DM_ROOT_DIR/src/python/dm/aps_beamline_tools/gui/dmStationUi.py $DM_COMMAND_ARGS"
+
+

src/python/dm/aps_beamline_tools/gui/__init__.py

+__version__ = "1.1 (2017.03.01)"

src/python/dm/aps_beamline_tools/gui/daqsTab.py

+#!/usr/bin/env python
+
+import wx
+from dmApiFactory import DmApiFactory
+ 
+# Define the DAQs tab content:
+class DaqsTab(wx.ListCtrl):
+    def __init__(self, stationName, parent, id=-1):
+        wx.ListCtrl.__init__(self, parent, id, style=wx.LC_REPORT)
+        self.stationName = stationName
+        self.experimentDaqApi = DmApiFactory.getInstance().getExperimentDaqApi()
+
+        self.InsertColumn(0, 'Id')
+        self.InsertColumn(2, 'Data Directory')
+        self.InsertColumn(3, '# Files')
+
+        self.SetColumnWidth(0, 150)
+        self.SetColumnWidth(1, 350)
+        self.SetColumnWidth(2, 250)
+
+        self.updateList()
+
+    def updateList(self):
+        self.daqList = self.experimentDaqApi.listDaqs()
+
+        i = 0
+        for daq in self.daqList:
+            print daq
+            self.InsertStringItem(i, daq.get('id'))
+            self.SetStringItem(i, 1, daq.get('dataDirectory', ''))
+            self.SetStringItem(i, 2, str(daq.get('nFiles', '0')))
+            if (i % 2) == 0:
+                self.SetItemBackgroundColour(i, '#e6f1f5')
+            i += 1
+
+ 
+

src/python/dm/aps_beamline_tools/gui/dmApiFactory.py

+#!/usr/bin/env python
+
+from dm.common.utility.singleton import Singleton
+from dm.common.utility.loggingManager import LoggingManager
+from dm.common.utility.configurationManager import ConfigurationManager
+
+class DmApiFactory(Singleton):
+
+
+    def __init__(self):
+        self.__configure()
+
+    def __configure(self):
+        self.logger = LoggingManager.getInstance().getLogger(self.__class__.__name__)
+        configManager = ConfigurationManager.getInstance()
+        (self.username,self.password) = configManager.parseLoginFile()
+        self.protocol = configManager.getWebServiceProtocol()
+        self.dsHost = configManager.getDsWebServiceHost()
+        self.dsPort = configManager.getDsWebServicePort()
+        self.daqHost = configManager.getDaqWebServiceHost()
+        self.daqPort = configManager.getDaqWebServicePort()
+
+    def getUserDsApi(self):
+        from dm.ds_web_service.api.userDsApi import UserDsApi
+        api = UserDsApi(self.username, self.password, self.dsHost, self.dsPort, self.protocol)
+        return api
+
+    def getExperimentDsApi(self):
+        from dm.ds_web_service.api.experimentDsApi import ExperimentDsApi
+        api = ExperimentDsApi(self.username, self.password, self.dsHost, self.dsPort, self.protocol)
+        return api
+
+    def getExperimentDaqApi(self):
+        from dm.daq_web_service.api.experimentDaqApi import ExperimentDaqApi
+        api = ExperimentDaqApi(self.username, self.password, self.daqHost, self.daqPort, self.protocol)
+        return api
+
+
+####################################################################
+# Testing
+
+if __name__ == '__main__':
+    pass
+

src/python/dm/aps_beamline_tools/gui/dmStationUi.py

+#!/usr/bin/env python
+
+import sys
+import wx
+
+from dm.common.constants import dmStatus
+from dm.common.exceptions.dmException import DmException
+from dm.common.exceptions.configurationError import ConfigurationError
+from dm.common.utility.loggingManager import LoggingManager
+from dm.common.utility.configurationManager import ConfigurationManager
+
+from experimentsTab import ExperimentsTab
+from daqsTab import DaqsTab
+from uploadsTab import UploadsTab
+ 
+class DmStationUi(wx.Frame):
+    def __init__(self):
+        self.__configure()
+        self.logger.debug('Starting UI for DM Station: %s' % self.stationName)
+        wx.Frame.__init__(self, None, title='DM Station: %s' % self.stationName, size=(900,500))
+ 
+        # Create a panel and notebook (tabs holder)
+        p = wx.Panel(self)
+        nb = wx.Notebook(p)
+ 
+        # Create the tab windows
+        experimentsTab = ExperimentsTab(self.stationName, nb)
+        daqsTab = DaqsTab(self.stationName, nb)
+        uploadsTab = UploadsTab(self.stationName, nb)
+ 
+        # Add the windows to tabs and name them.
+        nb.AddPage(experimentsTab, "Experiments")
+        nb.AddPage(daqsTab, "Real Time DAQs")
+        nb.AddPage(uploadsTab, "Data Uploads")
+ 
+        # Set noteboook in a sizer to create the layout
+        sizer = wx.BoxSizer()
+        sizer.Add(nb, 1, wx.EXPAND)
+        p.SetSizer(sizer)
+
+    def __configure(self):
+        self.logger = LoggingManager.getInstance().getLogger(self.__class__.__name__)
+        configManager = ConfigurationManager.getInstance()
+        self.stationName = configManager.getInstance().getStationName()
+        if not self.stationName:
+            raise ConfigurationError('DM_STATION_NAME environment variable is not defined.')
+ 
+if __name__ == "__main__":
+    try:
+        app = wx.App()
+        DmStationUi().Show()
+        app.MainLoop()
+    except DmException, ex:
+        print >>sys.stderr, 'ERROR: %s' % ex
+        raise SystemExit(ex.getErrorCode())
+    except Exception, ex:
+        print >>sys.stderr, '%s' % ex
+        raise SystemExit(dmStatus.DM_ERROR)

src/python/dm/aps_beamline_tools/gui/experimentsTab.py

+#!/usr/bin/env python
+
+import wx
+from dmApiFactory import DmApiFactory
+ 
+# Define the experiments tab content:
+class ExperimentsTab(wx.ListCtrl):
+    def __init__(self, stationName, parent, id=-1):
+        wx.ListCtrl.__init__(self, parent, id, style=wx.LC_REPORT)
+        self.stationName = stationName
+        self.experimentDsApi = DmApiFactory.getInstance().getExperimentDsApi()
+
+        self.InsertColumn(0, 'Name')
+        self.InsertColumn(1, 'Description')
+        self.InsertColumn(2, 'Start Date')
+
+        self.SetColumnWidth(0, 150)
+        self.SetColumnWidth(1, 500)
+        self.SetColumnWidth(2, 250)
+
+        self.updateList()
+
+    def updateList(self):
+        self.experimentList = self.experimentDsApi.getExperimentsByStation(self.stationName)
+
+        i = 0
+        for experiment in self.experimentList:
+            self.InsertStringItem(i, experiment.get('name'))
+            self.SetStringItem(i, 1, experiment.get('description', ''))
+            self.SetStringItem(i, 2, str(experiment.get('startDate', '')))
+            if (i % 2) == 0:
+                self.SetItemBackgroundColour(i, '#e6f1f5')
+            i += 1
+
+
+

src/python/dm/aps_beamline_tools/gui/uploadsTab.py

+#!/usr/bin/env python
+
+import wx
+from dmApiFactory import DmApiFactory
+ 
+# Define the experiments tab content:
+class UploadsTab(wx.ListCtrl):
+    def __init__(self, stationName, parent, id=-1):
+        wx.ListCtrl.__init__(self, parent, id, style=wx.LC_REPORT)
+        self.stationName = stationName
+        self.experimentDaqApi = DmApiFactory.getInstance().getExperimentDaqApi()
+
+        self.InsertColumn(0, 'Id')
+        self.InsertColumn(2, 'Data Directory')
+        self.InsertColumn(3, '# Files')
+
+        self.SetColumnWidth(0, 150)
+        self.SetColumnWidth(1, 350)
+        self.SetColumnWidth(2, 250)
+
+        self.updateList()
+
+    def updateList(self):
+        self.uploadList = self.experimentDaqApi.listUploads()
+
+        i = 0
+        for upload in self.uploadList:
+            self.InsertStringItem(i, upload.get('id'))
+            self.SetStringItem(i, 1, upload.get('dataDirectory', ''))
+            self.SetStringItem(i, 2, str(upload.get('nFiles', '0')))
+            if (i % 2) == 0:
+                self.SetItemBackgroundColour(i, '#e6f1f5')
+            i += 1
+ 
+

src/python/dm/common/utility/configurationManager.py

@@ -924,6 +924,24 @@ class ConfigurationManager(UserDict.UserDict):
     def hasBeamlineManagers(self):
         return self.has_key('beamlineManagers')
 
+    # Parse given login file for username/password
+    # Assume form <username><delimiter><password>
+    def parseLoginFile(self, loginFile=None, delimiter='|'):
+        username = None
+        password = None
+        if not loginFile:
+            loginFile = self.getLoginFile()
+        if not loginFile:
+            raise ConfigurationError('DM login file is not defined.')
+        try:
+            tokenList = open(loginFile).readline().split(delimiter)
+            if len(tokenList) == 2:
+                username = tokenList[0].strip()
+                password = tokenList[1].strip()
+        except Exception, ex:
+            raise ConfigurationError('Cannot parse login file %s: ex.' % (loginFile, ex))
+        return (username,password)
+
 #######################################################################
 # Testing.
 

src/python/dm/daq_web_service/api/experimentDaqApi.py

@@ -239,7 +239,7 @@ class ExperimentDaqApi(DaqRestApi):
 
         :raises DmException: in case of any other errors
 
-        >>> uplaodInfo = api.getUploadInfo('84311a75-c88b-4605-8948-08257eae6f5c')
+        >>> uploadInfo = api.getUploadInfo('84311a75-c88b-4605-8948-08257eae6f5c')
         >>> uploadStatus = uploadInfo.get('status')
         '''
 
@@ -292,7 +292,7 @@ class ExperimentDaqApi(DaqRestApi):
 
         :raises DmException: in case of any other errors
 
-        >>> uplaodInfo = api.stopUpload('84311a75-c88b-4605-8948-08257eae6f5c')
+        >>> uploadInfo = api.stopUpload('84311a75-c88b-4605-8948-08257eae6f5c')
         >>> print uploadInfo.get('nCompletedFiles')
         '''
         url = '%s/experimentUploads/stopUpload/%s' % (self.getContextRoot(),id)

src/python/dm/ds_web_service/api/dsRestApiFactory.py

@@ -52,11 +52,7 @@ class DsRestApiFactory:
     @classmethod
     def getExperimentDsApi(cls):
         from experimentDsApi import ExperimentDsApi
-        try:
-            (username, password, host, port, protocol) = cls.__getConfiguration()
-        except Exception, ex:
-            print ex
-            raise
+        (username, password, host, port, protocol) = cls.__getConfiguration()
         api = ExperimentDsApi(username, password, host, port, protocol)
         return api
 
@@ -66,6 +62,7 @@ class DsRestApiFactory:
         (username, password, host, port, protocol) = cls.__getConfiguration()
         api = FileDsApi(username, password, host, port, protocol)
         return api
+
 ####################################################################
 # Testing