Delete and Service from iWorkflow when BIG-IP is not reachable

!/usr/bin/python

"""
This is designed to be run locally on iWorkflow to remove stuck ASO in
"ERROR_IN_DELETION" status. See "Remove Service" at:
https://devcentral.f5.com/wiki/iWorkflow.APIRef_cm_cloud_tenants_tenant-name_services_iapp.ashx
Usage:
    ./delete-error.py -u username -p password
"""

import json
import httplib
from base64 import b64encode
import optparse
import sys
import socket

parser = optparse.OptionParser()


 debug option for args
parser.add_option(
    '-a',
    '--address',
    dest="address",
    default="127.0.0.1",
    action="store",
    help="address of remote device"
    )

parser.add_option(
    '-d',
    '--debug',
    dest="debug",
    default=False,
    action="store_true",
    help="Print out arg values given"
    )


parser.add_option(
    '-u',
    '--user',
    dest="remUser",
    default='admin',
    action="store",
    help="Remote user name"
    )

parser.add_option(
    '-p',
    '--pass',
    dest="remPass",
    default='admin',
    action="store",
    help="Remote user name"
    )


options, remainder = parser.parse_args()


 get auth token
def get_token(user, password, address, debug=False):
    conn = httplib.HTTPSConnection(address)
    cred = user + ":" + password
    userAndPass = b64encode(cred).decode("ascii")
    url = '/mgmt/shared/authn/login'
    post_data = '{"username":"' + user + '","password":"' + password + '"}'
    headers = {
        'Authorization': 'Basic %s' % userAndPass,
        'Content-Type': 'application/json'}
    try:
        conn.request("POST", url, post_data, headers=headers)
        r1 = conn.getresponse()
        if r1.status != 200:
            print r1.status, r1.reason
            sys.exit(0)
        data = r1.read()
    except socket.error, e:
        print e
        sys.exit(0)
    except:
        raise
    conn.close()
    data_dict = json.loads(data)
    token = data_dict['token']['token']
    return token


 GET
def get(address, url, auth_token, debug=False):
    conn = httplib.HTTPSConnection(address)
    headers = {
        'X-F5-Auth-Token': auth_token, 'Content-Type': 'application/json'}
    try:
        conn.request("GET", url, headers=headers)
        r1 = conn.getresponse()
        if r1.status != 200:
            print r1.status, r1.reason
            sys.exit(0)
        data = r1.read()
    except socket.error, e:
        print e
        sys.exit(0)
    except:
        raise
    conn.close()
    data_dict = json.loads(data)
    get_data = data_dict
    return get_data


 PUT
def put(address, url, auth_token, put_data, debug=False):
    conn = httplib.HTTPSConnection(address)
    headers = {
        'X-F5-Auth-Token': auth_token, 'Content-Type': 'application/json'}
    try:
        conn.request("PUT", url, put_data, headers=headers)
        r1 = conn.getresponse()
        if r1.status != 200:
            print r1.status, r1.reason
            sys.exit(0)
        data = r1.read()
    except socket.error, e:
        print e
        sys.exit(0)
    except:
        raise
    conn.close()
    data_dict = json.loads(data)
    put_result = data_dict
    return put_result


 post
def post(address, url, auth_token, post_data, debug=False):
    conn = httplib.HTTPSConnection(address)
    headers = {
        'X-F5-Auth-Token': auth_token, 'Content-Type': 'application/json'}
    try:
        conn.request("POST", url, post_data, headers=headers)
        r1 = conn.getresponse()
        if r1.status != 200:
            print r1.status, r1.reason
            sys.exit(0)
        data = r1.read()
    except socket.error, e:
        print e
        sys.exit(0)
    except:
        raise
    conn.close()
    data_dict = json.loads(data)
    post_result = data_dict
    return post_result


 PATCH
def patch(address, url, auth_token, patch_data, debug=False):
    conn = httplib.HTTPSConnection(address)
    headers = {
        'X-F5-Auth-Token': auth_token, 'Content-Type': 'application/json'}
    try:
        conn.request("PATCH", url, patch_data, headers=headers)
        r1 = conn.getresponse()
        if r1.status != 200:
            print r1.status, r1.reason
            sys.exit(0)
        data = r1.read()
    except socket.error, e:
        print e
        sys.exit(0)
    except:
        raise
    conn.close()
    data_dict = json.loads(data)
    patch_result = data_dict
    return patch_result


def delete(address, url, auth_token, debug=False):
    conn = httplib.HTTPSConnection(address)
    headers = {
        'X-F5-Auth-Token': auth_token, 'Content-Type': 'application/json'}
    try:
        conn.request("DELETE", url, headers=headers)
        r1 = conn.getresponse()
        if r1.status != 200:
            print r1.status, r1.reason
            sys.exit(0)
        data = r1.read()
    except socket.error, e:
        print e
        sys.exit(0)
    except:
        raise
    conn.close()
    return data


if __name__ == "__main__":

     setup vars
    user = options.remUser
    password = options.remPass
    address = options.address
    debug = options.debug

     print arg info in debug
    if options.debug:
        print "options dict: ", options, " remainder: ", remainder

     get auth token
    auth_token = get_token(user, password, address, debug)
    if options.debug:
        print "auth token is: ", auth_token

     GET list of placemnts in "status": "ERROR_IN_DELETION"
    url = '/mgmt/cm/cloud/tenants/services/placements/'
    get_placements = get(address, url, auth_token, debug)
    placements_list = get_placements['items']
    for p in placements_list:
        if p['status'] == 'ERROR_IN_DELETION':
            print "Placement ", p['appName'], " in status:"
            print "status ", p['status']
            print "For L4-L7 Service:"
            print p['tenantServiceInstance']['selfLink']

             doing a PUT on L4-L7 Service with the body of itself
             changes placement status to ERROR_IN_PLACEMENT
             then we can delete the L4-L7 Service
            url = p['tenantServiceInstance']['selfLink'][17:]

             GET service json for PUT body
            service = get(address, url, auth_token, debug)

             format of PUT body
            put_data = json.dumps(service, indent=4)

             Do PUT on the service to change placement status
            put_stat = put(
                address, url, auth_token, put_data, debug=False)

             delete service right after, seems to only work if done quickly
             I could not get to work by manually doing this with curl
             I do not know the reason for this
            print "Deleting ", p['appName'], "\n"
            delete_stat = delete(
                address, url, auth_token, debug=False)