gnue/reports src/GRServer.py grpc/GRServer.grpc

[Jan Ischebeck]

CVSROOT:        /cvsroot/gnue
Module name:    gnue
Changes by:     Jan Ischebeck <address@hidden>  02/06/04 17:30:36

Modified files:
        reports/src    : GRServer.py 
Added files:
        reports/grpc   : GRServer.grpc 

Log message:
        add basic rpc server functions to GRServer.

CVSWeb URLs:
http://savannah.gnu.org/cgi-bin/viewcvs/gnue/gnue/reports/src/GRServer.py.diff?tr1=1.7&tr2=1.8&r1=text&r2=text
http://savannah.gnu.org/cgi-bin/viewcvs/gnue/gnue/reports/grpc/GRServer.grpc?rev=1.1

Patches:
Index: gnue/reports/src/GRServer.py
diff -c gnue/reports/src/GRServer.py:1.7 gnue/reports/src/GRServer.py:1.8
*** gnue/reports/src/GRServer.py:1.7    Mon Jun  3 15:09:37 2002
--- gnue/reports/src/GRServer.py        Tue Jun  4 17:30:36 2002
***************
*** 28,71 ****
  #
  
  
! from gnue.common.GServerApp import GServerApp
! 
! 
! from gnue.common import GDebug
! from gnue.common.GClientApp import GClientApp
  from GREngine import GREngine
  from GRConfig import ConfigOptions
  import GRExceptions
! import string, sys
  from gnue.reports import VERSION
  
  
! 
! class GRServer (GServerApp):
  
    #
!   # GServerApp() overrides
    #
    VERSION = VERSION
    COMMAND = "gnue-reports-server"
    NAME = "GNUe Reports Server"
!   USAGE = GServerApp.USAGE
!   COMMAND_OPTIONS = [ ]
    SUMMARY = \
       "GNUe Reports is the primary reporting agent of the GNU Enterprise 
system."
  
    #
    # Initialize the class
    #
    def __init__(self):
!     GServerApp.__init__(self,defaults=ConfigOptions)
  
  
!   def run(self): 
  
-     # Take us into daemon mode...
-     GServerApp.run(self)
  
  
    def runInstance(self): 
      try: 
--- 28,125 ----
  #
  
  
! from gnue.common import GDebug, GComm, GServerApp, GConfig
  from GREngine import GREngine
  from GRConfig import ConfigOptions
  import GRExceptions
! import string, sys, time
  from gnue.reports import VERSION
  
  
! class GRServer (GServerApp.GServerApp): 
  
    #
!   # GBaseApp() overrides
    #
    VERSION = VERSION
    COMMAND = "gnue-reports-server"
    NAME = "GNUe Reports Server"
!   USAGE = GServerApp.GServerApp.USAGE
!   COMMAND_OPTIONS = [    
!     [ 'rpctype',None,'rpc_type',1,"xmlrpc", 'type',
!       _('Set the GNURPC connection type. The currently supported values ')+
!       _("for <type> are 'xmlrpc' and 'pw_xmlrpc'. For more information on ")+
!       _('GNURPC connection types have a look at ')+
!       _('common/doc/RPC-abstraction. ')]]
! #    [ 'username',"u",'username',1,None, 'user',
! #      _('Set the username for the used database.')],
! #    [ 'password',"p",'password',1,None, 'password',
! #      _('Set the password for the used database.')]]
    SUMMARY = \
       "GNUe Reports is the primary reporting agent of the GNU Enterprise 
system."
  
+   
    #
    # Initialize the class
    #
    def __init__(self):
!     GServerApp.GServerApp.__init__(self)
  
  
!   ## set a list of transports
!   def setTransports(self,transports):
!     
!     self._transports=transports
! 
! 
!   def phaseInit(self):
!     
!     self._transports={}
!         
!     if self.OPTIONS["rpctype"]=="xmlrpc":
!       
!       print "Exporting our services via xmlrpc (port 8766) ..."
!       self.setTransports({'xmlrpc':{ 'port': 8766 }})
!       
!     elif self.OPTIONS["rpctype"]=="pw_xmlrpc":
!     
!       print "Exporting our services via pw_xmlrpc (port 8766) ..."
!       self.setTransports({'pw_xmlrpc':{ 'port': 8766 }})
! 
!     elif self.OPTIONS["rpctype"]=="sockets":
! 
!       # Sockets not working yet
!       print "Exporting our services via sockets (port 8766) ..."
!       self.setTransports({'sockets':{ 'port': 8766 }})
! 
!     else:
! 
!       # not transport protocol set. exiting
!       print "The protocol you've set is currently not supported."
!       sys.exit(-1)
! 
!   def run(self):
!            
!     # Create the various servers
!     servers=GComm.bind (GConfig.getInstalledBase('install_prefix')+\
!                         '/shared/grpc/GRServer.grpc',
!                          self._transports,                         
!                          {'GReportServer': self.requestServer })
! 
!     # Daemonize (if appropriate)
!     GServerApp.GServerApp.run(self)
! 
!     # Start the server for the different protocolls
!     for key in servers.keys():
!       servers[key].serveAsNewThread()      
! 
!     # wait for the servers shut down
!     while 1==1:
!       time.sleep(199999999)
  
  
+   def requestServer(self):
+     return self
  
    def runInstance(self): 
      try: 
***************
*** 95,103 ****
  
      return ( ('raw','Do not process the XML with a filter. Emit raw XML.'), )
  
  
  
  if __name__ == '__main__':
!   GRServer().run()
  
    
--- 149,175 ----
  
      return ( ('raw','Do not process the XML with a filter. Emit raw XML.'), )
  
+   #
+   #  Returns the report definition (in XML format)
+   #
+ 
+   def getReportDefinition(self,location):
+     # Parameters: * location <string>   The location of the report
+ 
+     pass
+ 
+   #
+   #  Returns the report definition (in XML format)
+   #
+ 
+   def getReportHeader(self,location):
+     # Parameters: * location <string>   The location of the report
  
+     pass
  
  if __name__ == '__main__':
!   grserv=GRServer()
!   grserv.phaseInit()
!   grserv.run()