#!/usr/bin/env python

import sys
import jwt
import base64
import httplib
import urllib
import ssl
import json
import time

def kronos_req(req_type, path, data_js):
    data = json.loads(data_js)

    secret = 'C/E3FX1Axxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx' + \
             'xxxxxxxxxxxxxxxxxxxxxx=='

    headers = {"Content-type": "application/json",
               "Accept": "application/json",
               "Authorization": "Bearer " +
               jwt.encode(data, base64.b64decode(secret), algorithm = 'HS256') }

    conn = httplib.HTTPSConnection(host = 'kronosxtst.valleymed.net', port = 9999,
                                   context=ssl._create_unverified_context())

    #data_js = json.dumps(data)
    conn.request(req_type, path, data_js, headers)

    r1 = conn.getresponse()
    print "Status:", r1.status, r1.reason
    print r1.getheaders()
    content = r1.read()

    if len(content) > 0:
        #print json.loads(content)
        print content

    conn.close()

sub_data = '{"path": "/mypath/update", "host": "myhost.valleymed.org", "scheme": "https", "port": 443, "apiVersion": "1.0"}'

print('cancel old subscription:')
kronos_req('DELETE', '/subscription', sub_data)
print('resubscribe:')
kronos_req('POST', '/subscription', sub_data)
print('get inventory:')
kronos_req('GET', '/inventory', sub_data)
while True:
    print('heartbeat:')
    kronos_req('GET', '/heartbeat', sub_data)
    time.sleep(30)