airavata-api/airavata-client-sdks/airavata-python-sdk/airavata/service/profile/tenant/cpi/TenantProfileService-remote

#!/usr/bin/env python
#
# Autogenerated by Thrift Compiler (0.18.1)
#
# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
#
#  options string: py
#

import sys
import pprint
if sys.version_info[0] > 2:
    from urllib.parse import urlparse
else:
    from urlparse import urlparse
from thrift.transport import TTransport, TSocket, TSSLSocket, THttpClient
from thrift.protocol.TBinaryProtocol import TBinaryProtocol

from airavata.service.profile.tenant.cpi import TenantProfileService
from airavata.service.profile.tenant.cpi.ttypes import *

if len(sys.argv) <= 1 or sys.argv[1] == '--help':
    print('')
    print('Usage: ' + sys.argv[0] + ' [-h host[:port]] [-u url] [-f[ramed]] [-s[sl]] [-novalidate] [-ca_certs certs] [-keyfile keyfile] [-certfile certfile] function [arg1 [arg2...]]')
    print('')
    print('Functions:')
    print('  string addGateway(AuthzToken authzToken, Gateway gateway)')
    print('  bool updateGateway(AuthzToken authzToken, Gateway updatedGateway)')
    print('  Gateway getGateway(AuthzToken authzToken, string airavataInternalGatewayId)')
    print('  bool deleteGateway(AuthzToken authzToken, string airavataInternalGatewayId, string gatewayId)')
    print('   getAllGateways(AuthzToken authzToken)')
    print('  bool isGatewayExist(AuthzToken authzToken, string gatewayId)')
    print('   getAllGatewaysForUser(AuthzToken authzToken, string requesterUsername)')
    print('  string getAPIVersion()')
    print('')
    sys.exit(0)

pp = pprint.PrettyPrinter(indent=2)
host = 'localhost'
port = 9090
uri = ''
framed = False
ssl = False
validate = True
ca_certs = None
keyfile = None
certfile = None
http = False
argi = 1

if sys.argv[argi] == '-h':
    parts = sys.argv[argi + 1].split(':')
    host = parts[0]
    if len(parts) > 1:
        port = int(parts[1])
    argi += 2

if sys.argv[argi] == '-u':
    url = urlparse(sys.argv[argi + 1])
    parts = url[1].split(':')
    host = parts[0]
    if len(parts) > 1:
        port = int(parts[1])
    else:
        port = 80
    uri = url[2]
    if url[4]:
        uri += '?%s' % url[4]
    http = True
    argi += 2

if sys.argv[argi] == '-f' or sys.argv[argi] == '-framed':
    framed = True
    argi += 1

if sys.argv[argi] == '-s' or sys.argv[argi] == '-ssl':
    ssl = True
    argi += 1

if sys.argv[argi] == '-novalidate':
    validate = False
    argi += 1

if sys.argv[argi] == '-ca_certs':
    ca_certs = sys.argv[argi+1]
    argi += 2

if sys.argv[argi] == '-keyfile':
    keyfile = sys.argv[argi+1]
    argi += 2

if sys.argv[argi] == '-certfile':
    certfile = sys.argv[argi+1]
    argi += 2

cmd = sys.argv[argi]
args = sys.argv[argi + 1:]

if http:
    transport = THttpClient.THttpClient(host, port, uri)
else:
    if ssl:
        socket = TSSLSocket.TSSLSocket(host, port, validate=validate, ca_certs=ca_certs, keyfile=keyfile, certfile=certfile)
    else:
        socket = TSocket.TSocket(host, port)
    if framed:
        transport = TTransport.TFramedTransport(socket)
    else:
        transport = TTransport.TBufferedTransport(socket)
protocol = TBinaryProtocol(transport)
client = TenantProfileService.Client(protocol)
transport.open()

if cmd == 'addGateway':
    if len(args) != 2:
        print('addGateway requires 2 args')
        sys.exit(1)
    pp.pprint(client.addGateway(eval(args[0]), eval(args[1]),))

elif cmd == 'updateGateway':
    if len(args) != 2:
        print('updateGateway requires 2 args')
        sys.exit(1)
    pp.pprint(client.updateGateway(eval(args[0]), eval(args[1]),))

elif cmd == 'getGateway':
    if len(args) != 2:
        print('getGateway requires 2 args')
        sys.exit(1)
    pp.pprint(client.getGateway(eval(args[0]), args[1],))

elif cmd == 'deleteGateway':
    if len(args) != 3:
        print('deleteGateway requires 3 args')
        sys.exit(1)
    pp.pprint(client.deleteGateway(eval(args[0]), args[1], args[2],))

elif cmd == 'getAllGateways':
    if len(args) != 1:
        print('getAllGateways requires 1 args')
        sys.exit(1)
    pp.pprint(client.getAllGateways(eval(args[0]),))

elif cmd == 'isGatewayExist':
    if len(args) != 2:
        print('isGatewayExist requires 2 args')
        sys.exit(1)
    pp.pprint(client.isGatewayExist(eval(args[0]), args[1],))

elif cmd == 'getAllGatewaysForUser':
    if len(args) != 2:
        print('getAllGatewaysForUser requires 2 args')
        sys.exit(1)
    pp.pprint(client.getAllGatewaysForUser(eval(args[0]), args[1],))

elif cmd == 'getAPIVersion':
    if len(args) != 0:
        print('getAPIVersion requires 0 args')
        sys.exit(1)
    pp.pprint(client.getAPIVersion())

else:
    print('Unrecognized method %s' % cmd)
    sys.exit(1)

transport.close()