ryzom/server/tools/admin_modules_itf.py

   1 import logging
   2 from nel_message import *
   3
   4
   5 class CAdminServiceWeb(CCallbackClient):
   6
   7         def globalCmd(self, command):
   8                 msg = CMessage()
   9                 msg.setName("GCMD")
  10                 msg.serialString(command)
  11                 return self.sendMessage(msg)
  12
  13         def controlCmd(self, serviceAlias, command):
  14                 msg = CMessage()
  15                 msg.setName("CCMD")
  16
  17                 msg.serialString(serviceAlias)
  18                 msg.serialString(command)
  19
  20                 return self.sendMessage(msg)
  21
  22
  23         def serviceCmd(self, serviceAlias, command):
  24                 msg = CMessage()
  25                 msg.setName("SCMD")
  26
  27                 msg.serialString(serviceAlias)
  28                 msg.serialString(command)
  29
  30                 return self.sendMessage(msg)
  31
  32         def getShardOrders(self):
  33                 msg = CMessage()
  34                 msg.setName("GSO")
  35
  36                 ret = ""
  37                 ret = sendMessage(msg)
  38                 if not ret:
  39                         print("getShardOrders: Error in 'sendMessage'")
  40                         return False
  41
  42                 retMsg = waitMessage()
  43                 if not retMsg:
  44                         print("getShardOrders: Error in 'waitMessage'")
  45                         return False
  46
  47                 if not retMsg.MsgName == "R_GSO":
  48                         print("getShardOrders: Invalid response, awaited 'R_GSO', received: "+retMsg.MsgName)
  49                         return False
  50
  51                 nbElem = 0
  52                 retMsg.serialUInt32(nbElem)
  53                 retValue = []
  54                 for i in range(nbElem):
  55                         retMsg.serialString(item)
  56                         retValue.append(item)
  57
  58                 return retValue
  59
  60
  61         def waitCallback(self):
  62                 message = self.waitMessage()
  63
  64                 if not message:
  65                         return False
  66
  67                 if message.MsgName == "CMDR":
  68                         self.commandResult_skel(message)
  69                 else:
  70                         return False
  71                 return True
  72
  73         def commandResult_skel(self, message):
  74                 serviceAlias = message.serialString()
  75                 result = message.serialString()
  76                 self.commandResult(serviceAlias, result)
  77
  78         def commandResult(self, serviceAlias, result):
  79                 global command_return_data
  80                 command_return_data = result
  81
  82
  83
  84 def queryShard(service_name, fullcmd, waitCallback=True, is_control=False):
  85         global command_return_data
  86
  87         nel_result = ""
  88         nel_status = not waitCallback
  89         res = ""
  90         p_result = None
  91
  92         adminService = CAdminServiceWeb()
  93
  94         if adminService.connect("127.0.0.1", 46700, res):
  95                 command_return_data = ""
  96
  97                 if isinstance(fullcmd, str):
  98                         if is_control:
  99                                 adminService.controlCmd(service_name, fullcmd)
 100                         else:
 101                                 adminService.serviceCmd(service_name, fullcmd)
 102                         service_command = fullcmd
 103
 104                         if waitCallback and adminService.waitCallback():
 105                                 nel_status = True
 106                                 nel_result += command_return_data
 107                 else:
 108                         for service_command in fullcmd:
 109                                 if is_control:
 110                                         adminService.controlCmd(service_name, service_command)
 111                                 else:
 112                                         adminService.serviceCmd(service_name, service_command)
 113                 adminService.close()
 114
 115         return {"status": nel_status, "query": service_name+":"+fullcmd, "raw": nel_result.split("\n")[1:]}