summaryrefslogtreecommitdiff
path: root/vyapi/device.py
blob: fc974d179f9ecf2387e7ff5f3a809aadd1077c08 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
import urllib3
urllib3.disable_warnings()

import requests
import json
import pprint
from dataclasses import dataclass

@dataclass
class ApiResponse:
    status: int
    request: dict
    result: dict
    error: str
    
class VyDevice:
    def __init__(self, hostname, key, protocol='https', port=443, verify=True, timeout=10):
        self.hostname = hostname
        self.key = key
        self.protocol = protocol
        self.port = port
        self.verify = verify
        self.timeout = timeout


    def _get_url(self, command):
        return f"{self.protocol}://{self.hostname}:{self.port}/{command}"

    def _get_payload(self, op, path):
        return {
            'data': json.dumps({'op': op, 'path': path}),
            'key': self.key
        }

    def _api_request(self, command, op, path=[], method='POST'):
        url = self._get_url(command)
        payload = self._get_payload(op, path)

        
        headers = {}
        error = False      
        result = {}

        try:
            resp = requests.post(url, verify=self.verify, data=payload, timeout=self.timeout, headers=headers)
        
            if resp.status_code == 200:
                try:
                    resp_decoded = resp.json()
                    if resp_decoded['success'] == True:
                        result = resp_decoded['data']
                        error = False
                    else:   
                        error = resp_decoded['error']
                   
                except json.JSONDecodeError:
                    error = 'json decode error'
            else:
                error = 'http error'

            status = resp.status_code

        except requests.exceptions.ConnectionError as e:
            error = 'connection error: ' + str(e)
            status = 0
  
        return ApiResponse(status=status, request=payload, result=result, error=error)


    def retrieve_show_config(self, path=[]):
        return self._api_request(command="retrieve", op='showConfig', path=[], method="POST")

    def retrieve_return_values(self, path=[]):
        pass

    def reset(self, path=[]):
        pass

    def image_add(self):
        pass

    def image_delete(self):
        pass
    
    def show(self, path=[]):
        pass

    def generate(self, path=[]):
        pass

    def configure_sef(self, path=[]):
        pass

    def configure_delete(self, path=[]):
        pass

    def config_file_save(self, file=None):
        pass

    def config_file_load(self, file=None):
        pass