client

#!/usr/bin/env python

# based on code from git://github.com/openstack/nova.git
# nova/volume/nexenta/jsonrpc.py
#
# Copyright 2011 Nexenta Systems, Inc.
# All Rights Reserved.
#
#    Licensed under the Apache License, Version 2.0 (the "License"); you may
#    not use this file except in compliance with the License. You may obtain
#    a copy of the License at
#
#         http://www.apache.org/licenses/LICENSE-2.0

# This program is free software; you can redistribute it and/or modify
# it under the terms of the GNU General Public License as
# published by the Free Software Foundation; either version 3 of the
# License, or (at your option) any later version.
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
# GNU General Public License for more details.
#
# You should have received a copy of the GNU General Public License
# along with this program.  If not, see <http://www.gnu.org/licenses/>.
#
# Copyright 2012, Andy Grover <agrover@redhat.com>
#
# Test client to exercise targetd.
#


import sys
import urllib2
import json
import time
import socket

user = "admin"
password = ""
url = "http://localhost:18700/targetrpc"
host = 'localhost'
port = 18700
path = '/targetrpc'
id = 1
ssl = False
pool = 'vg-targetd'
host_name = "localhost"

def jsonrequest(method, params=None):
    print "+"*20, method
    global id
    data = json.dumps(dict(id=id, method=method, params=params, jsonrpc="2.0"))
    id += 1
    auth = ('%s:%s' % (user, password)).encode('base64')[:-1]
    headers = {'Content-Type': 'application/json',
               'Authorization': 'Basic %s' % (auth,)}
    #print('Sending JSON data: %s' % data)
    if ssl:
        scheme = 'https'
    else:
        scheme = 'http'
    url = "%s://%s:%s%s" % (scheme, host, port, path)
    try:
        request = urllib2.Request(url, data, headers)
        response_obj = urllib2.urlopen(request)
    except socket.error, e:
        print "error, retrying with SSL"
        url = "https://%s:%s%s" % (host, port, path)
        request = urllib2.Request(url, data, headers)
        response_obj = urllib2.urlopen(request)
    response_data = response_obj.read()
    print('Got response: %s' % response_data)
    response = json.loads(response_data)
    if response.get('error') is not None:
        if response['error']['code'] <= 0:
            raise Exception(response['error'].get('message', ''))
        else:
            print "Invalid error code, should be negative!"
    else:
        return response.get('result')


jsonrequest("discover_portal", dict(hostname=host_name))
jsonrequest("delete_discovery", dict(hostname=host_name))
jsonrequest("display_discovery", dict(hostname=host_name))
jsonrequest("display_discovery_summary")

results = jsonrequest("export_list")
for result in results:
    print "export", result['initiator_wwn'], result['pool'], result['vol_name'], result['lun']

#sys.exit(1)

results = jsonrequest("pool_list")
for result in results:
    print "pool", result['name'], result['size'], result['free_size']

results = jsonrequest("vol_list", dict(pool=pool))
for result in results:
    print "vol", result['name'], result['size'], result['uuid']

#sys.exit(1)

try:
    jsonrequest('vol_create', dict(pool=pool, name="test2", size=4000000))

    try:
        jsonrequest("vol_copy", dict(pool=pool, vol_orig="test2", vol_new="test2-copy"))

        try:
            jsonrequest("export_create", dict(pool=pool, vol="test2", lun=5, initiator_wwn="iqn.2006-03.com.wtf.ohyeah:666"))

            print "waiting"
            time.sleep(5)
            results = jsonrequest("export_list")
            for result in results:
                print "export", result['initiator_wwn'], result['pool'], result['vol_name'], result['lun'], result['vol_uuid']
            time.sleep(5)
            print "go!"

        finally:
            jsonrequest("export_destroy", dict(pool=pool, vol="test2", initiator_wwn="iqn.2006-03.com.wtf.ohyeah:666"))

    finally:
        jsonrequest("vol_destroy", dict(pool=pool, name="test2-copy"))

finally:
    jsonrequest("vol_destroy", dict(pool=pool, name="test2"))
    print "done"