in aios/apps/facility/swift/py_tools/swift_tools/cmd_context.py [0:0]
def __init__(self, argv, toolsConfFileDir=""):
if len(argv) < 2:
self._usage()
sys.exit(1)
self.initCmdAuthorityCheckTable()
cmdStr = argv[1]
if (cmdStr in ['deploy', 'dp']):
import swift_config_cmd
self.cmd = swift_config_cmd.SwiftDeployCmd()
self.cmdStr = 'dp'
elif (cmdStr in ['download', 'dl']):
import swift_config_cmd
self.cmd = swift_config_cmd.SwiftDownloadCmd()
self.cmdStr = 'dl'
elif (cmdStr in ['copy', 'cp']):
import swift_config_cmd
self.cmd = swift_config_cmd.SwiftCopyCmd()
self.cmdStr = 'cp'
elif (cmdStr in ['configversion', 'cv']):
import swift_config_cmd
self.cmd = swift_config_cmd.SwiftVersionCmd()
self.cmdStr = 'cv'
elif (cmdStr in ['getconfig', 'gc']):
import swift_config_cmd
self.cmd = swift_config_cmd.GetConfigCmd()
self.cmdStr = 'gc'
elif (cmdStr in ['updatebrokerconfig', 'ubc']):
import upc_cmd
self.cmd = upc_cmd.UpdateBrokerConfigCmd()
self.cmdStr = 'ubc'
elif (cmdStr in ['rollbackbrokerconfig', 'rbc']):
import upc_cmd
self.cmd = upc_cmd.RollbackBrokerConfigCmd()
self.cmdStr = 'rbc'
elif (cmdStr in ['updateadminconfig', 'uac']):
import app_cmd
self.cmd = app_cmd.SwiftUpdateAdminConfCmd()
self.cmdStr = 'uac'
elif (cmdStr in ['start', 'st']):
import app_cmd
self.cmd = app_cmd.SwiftStartCmd()
self.cmdStr = 'st'
elif (cmdStr in ['stop', 'sp']):
import app_cmd
self.cmd = app_cmd.SwiftStopCmd()
self.cmdStr = 'sp'
elif (cmdStr in ['gas', 'getappstatus']):
import app_cmd
self.cmd = app_cmd.SwiftAppStatusCmd()
self.cmdStr = 'gas'
elif (cmdStr in ['delete', 'del']):
import app_cmd
self.cmd = app_cmd.SwiftDeleteCmd()
self.cmdStr = 'del'
elif (cmdStr in ['getbrokerstatus', 'gbs']):
import app_cmd
self.cmd = app_cmd.GetBrokerStatusCmd()
self.cmdStr = 'gbs'
elif (cmdStr in ['killbroker', 'kb']):
import app_cmd
self.cmd = app_cmd.SwiftKillBrokerCmd()
self.cmdStr = 'kb'
elif (cmdStr in ['getstatus', 'gs']):
import swift_status_cmd
self.cmd = swift_status_cmd.SwiftStatusCmd()
self.cmdStr = 'gs'
elif (cmdStr in ['addtopic', 'at']):
import topic_cmd
self.cmd = topic_cmd.TopicAddCmd()
self.cmdStr = 'at'
elif (cmdStr in ['addtopicbatch', 'atb']):
import topic_cmd
self.cmd = topic_cmd.TopicBatchAddCmd()
self.cmdStr = 'atb'
elif (cmdStr in ['deletetopic', 'dt']):
import topic_cmd
self.cmd = topic_cmd.TopicDeleteCmd()
self.cmdStr = 'dt'
elif (cmdStr in ['deletetopicbatch', 'dtb']):
import topic_cmd
self.cmd = topic_cmd.TopicDeleteBatchCmd()
self.cmdStr = 'dtb'
elif (cmdStr in ['deletetopicsbytime', 'dtt']):
import topic_cmd
self.cmd = topic_cmd.TopicDeleteByTimeCmd()
self.cmdStr = 'dtt'
elif (cmdStr in ['deletetopicdata', 'dtd']):
import topic_cmd
self.cmd = topic_cmd.TopicDataDeleteCmd()
self.cmdStr = 'dtd'
elif (cmdStr in ['gettopicnames', 'gtn']):
import topic_cmd
self.cmd = topic_cmd.TopicNamesCmd()
self.cmdStr = 'gtn'
elif (cmdStr in ['gettopicinfo', 'gti']):
import topic_cmd
self.cmd = topic_cmd.TopicInfosCmd()
self.cmdStr = 'gti'
elif (cmdStr in ['gettopicsimpleinfo', 'gtsi']):
import topic_cmd
self.cmd = topic_cmd.TopicSimpleInfosCmd()
self.cmdStr = 'gtsi'
elif (cmdStr in ['gettopicmeta', 'gtm']):
import topic_cmd
self.cmd = topic_cmd.TopicMetaCmd()
self.cmdStr = 'gtm'
elif (cmdStr in ['modifytopic', 'mt']):
import topic_cmd
self.cmd = topic_cmd.TopicModifyCmd()
self.cmdStr = 'mt'
elif (cmdStr in ['transferpartition', 'tp']):
import topic_cmd
self.cmd = topic_cmd.TransferPartitionCmd()
self.cmdStr = 'tp'
elif (cmdStr in ['changeslot', 'cs']):
import topic_cmd
self.cmd = topic_cmd.ChangeSlotCmd()
self.cmdStr = 'cs'
elif (cmdStr in ['sendmsg', 'sm']):
import producer_cmd
self.cmd = producer_cmd.ProducerCmd()
self.cmdStr = 'sm'
elif (cmdStr in ['getmsg', 'gm']):
import consumer_cmd
self.cmd = consumer_cmd.ConsumerGetMsgCmd()
self.cmdStr = 'gm'
elif (cmdStr in ['getmaxmsgid', 'gmi']):
import consumer_cmd
self.cmd = consumer_cmd.ConsumerGetMaxMsgIdCmd()
self.cmdStr = 'gmi'
elif (cmdStr in ['getminmsgidbytime', 'gmit']):
import consumer_cmd
self.cmd = consumer_cmd.ConsumerGetMinMsgIdByTime()
self.cmdStr = 'gmit'
elif (cmdStr in ['exporttopics', 'et']):
import topic_cmd
self.cmd = topic_cmd.ExportTopicsCmd()
self.cmdStr = 'et'
elif (cmdStr in ['importtopics', 'it']):
import topic_cmd
self.cmd = topic_cmd.ImportTopicsCmd()
self.cmdStr = 'it'
elif (cmdStr in ['updatetopics', 'ut']):
import topic_cmd
self.cmd = topic_cmd.UpdateTopicsCmd()
self.cmdStr = 'ut'
elif (cmdStr in ['registerschema', 'regscm']):
import topic_cmd
self.cmd = topic_cmd.RegisterSchemaCmd()
self.cmdStr = 'regscm'
elif (cmdStr in ['getschema', 'gscm']):
import topic_cmd
self.cmd = topic_cmd.GetSchemaCmd()
self.cmdStr = 'gscm'
elif (cmdStr in ['gettopicrwtime', 'gtrw']):
import topic_cmd
self.cmd = topic_cmd.GetTopicRWTimeCmd()
self.cmdStr = 'gtrw'
elif (cmdStr in ['getlastdeletednousetopic', 'gtldnt']):
import topic_cmd
self.cmd = topic_cmd.GetLastDeletedNoUseTopicCmd()
self.cmdStr = 'gtldnt'
elif (cmdStr in ['getdeletednousetopic', 'gtdnt']):
import topic_cmd
self.cmd = topic_cmd.GetDeletedNoUseTopicCmd()
self.cmdStr = 'gtdnt'
elif (cmdStr in ['getdeletednousetopicfiles', 'gtdntf']):
import topic_cmd
self.cmd = topic_cmd.GetDeletedNoUseTopicFilesCmd()
self.cmdStr = 'gtdntf'
elif (cmdStr in ['topicaclmanage', 'tam']):
import topic_cmd
self.cmd = topic_cmd.TopicAclManageCmd()
self.cmdStr = 'tam'
elif (cmdStr in ['updatewriterversion', 'uwv']):
import app_cmd
self.cmd = app_cmd.UpdateWriterVersionCmd()
self.cmdStr = 'uwv'
elif (cmdStr in ['turntomaster', 'ttm']):
import app_cmd
self.cmd = app_cmd.TurnToMasterCmd()
self.cmdStr = 'ttm'
elif (cmdStr in ['test', 'test']):
import unittest_cmd
self.cmd = unittest_cmd.UnittestCmd(toolsConfFileDir)
self.cmdStr = 'test'
return
else:
self._usage()
sys.exit(1)
ret, errMsg = self.cmd.parseParams(argv[2:])
if not ret:
print('parseParams Error: %s' % errMsg)
self.cmd.usage()
sys.exit(1)