(command_data,opts)
| 40 | |
| 41 | |
| 42 | def get_auth(command_data,opts): |
| 43 | zkroot = command_data["zkdetails"]["zkroot"] |
| 44 | data_fpath = zkroot + "/config/dbcp/_data_" |
| 45 | f = open(data_fpath) |
| 46 | jsonStr = f.read() |
| 47 | data = json_to_dict(jsonStr) |
| 48 | f.close() |
| 49 | |
| 50 | if opts.endpoint.startswith("/js/"): |
| 51 | scope = "js" |
| 52 | else: |
| 53 | scope = "all" |
| 54 | |
| 55 | db_info = None |
| 56 | for db_info in data['dbs']: |
| 57 | dbSettings = {} |
| 58 | dbSettings["host"]=re.search('://(.*?):(.*?),',db_info["jdbc"]).groups()[0] |
| 59 | dbSettings["user"]=db_info["user"] |
| 60 | dbSettings["password"]=db_info["password"] |
| 61 | dbSettings["name"] = db_info["name"] |
| 62 | res = db_utils.get_keys(dbSettings,opts.client_name,scope) |
| 63 | if len(res)>0: |
| 64 | break |
| 65 | |
| 66 | if len(res) == 1: |
| 67 | return res[0] |
| 68 | else: |
| 69 | print "Failed to find single auth key" |
| 70 | print json.dumps(res) |
| 71 | sys.exit(1) |
| 72 | |
| 73 | def get_action_params(opts,params): |
| 74 | params["user"] = opts.user |
no test coverage detected