ThirdPartyResource

Complexity

Total Complexity

9

Size/Duplication

Total Lines	49
Duplicated Lines	0 %

8 Methods

Rating	Name	Duplication	Size	Complexity
A	remove_trigger()	0	2	1
A	cleanup()	0	2	1
A	setup()	0	7	1
A	__init__()	0	4	1
A	add_trigger()	0	2	1
A	update_trigger()	0	2	1
A	poll()	0	16	2
A	_process_message()	0	2	1

#!/usr/bin/env python
import base64
import json
import requests
import yaml
import argparse
import os, sys
import pprint
import ast
from labels import Labels
from swagger_client import *
from swagger_client_beta1 import *
# from git@github.com:mward29/python-k8sclient.git

from st2reactor.sensor.base import PollingSensor


class ThirdPartyResource(PollingSensor):
    def __init__(self, sensor_service, config=None, poll_interval=None):
        super(ThirdPartyResource, self).__init__(sensor_service=sensor_service,
                                                  config=config,
                                                  poll_interval=poll_interval)
#        self._labels = self._config['labels'].get('thirdpartyresource', [])


    def setup(self):
        KUBERNETES_API_URL = self._config['kubernetes_api_url']
        auth = self._config['auth']
        encoded_auth = base64.b64encode(auth)
        Configuration().verify_ssl = False
        self.client = api_client.ApiClient(KUBERNETES_API_URL, 'Authorization', "Basic %s" % encoded_auth)
        pass

    def poll(self):
        client = self.client
        api_beta1 = apis.ApisextensionsvbetaApi(client)
        d = api_beta1.list_third_party_resource().to_dict()
        d_list = d['items']
        for i in xrange(len(d_list)):
            name =  d_list[i]['metadata']['name']
            uid = d_list[i]['metadata']['uid']
            metadata = d_list[i]['metadata']
            versions = d_list[i]['versions']
#            pprint.pprint(name)
#            pprint.pprint(uid)
            self._sensor_service.set_value(name=(name + uid), value=(metadata))
        kvp = self._sensor_service.list_values(prefix='mysql')
        pprint.pprint(kvp)
        pass



    def cleanup(self):
        pass

    def add_trigger(self, trigger):
        pass

    def update_trigger(self, trigger):
        pass

    def remove_trigger(self, trigger):
        pass

    def _process_message(self, message):
        pass

#        l = d_list[i]['metadata']['labels']
#        a = d_list[i]['metadata']['annotations']

        #            if l is not None:
        #                labels = ast.literal_eval(l)
        #            if a is not None:
        #                annotations = ast.literal_eval(a)

            #    labels_config = self._config['labels']['thirdpartyresource']
            #    pprint.pprint(labels_config)