msproject/link_monitoring.py at master · venkatant/msproject · GitHub

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
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
__author__ = 'venkat'


from header import *
from json_http_handler import *


class LinkTables:
    def __init__(self, switch=None, port=None, status=None, bw=None):
        self.check_gmail = IntVar()
        self.check_snmp = IntVar()
        self.var = IntVar()
        self.switchId = switch
        self.portName = port
        self.portStatus = status
        self.bandwidth = bw


    def updatelinkstatus(self, switch, port, status, bw):
        self.switchId = switch
        self.portName = port
        self.portStatus = status
        self.bandwidth = bw


    def printflowenties(self):
        print(self.switchId)
        print(self.portName)
        print(self.portStatus)
        print(self.bandwidth)

    def send_mail(self):
        print("Mail", self.check_gmail.get())
        return


    def send_trap(self):
        print("SNMP", self.check_snmp.get())
        return


    def mradioselect(self):
        print("Value Selected is ", self.var.get())
        return

def linkfaultmenu():

    toplevel = Toplevel()
    toplevel.title("Link Monitoring")
    toplevel.geometry("750x500")

    '''
    Create an object of Http JSON Handler Class to receive
    resp from respective Rest URL's
    '''
    http_obj = HttpJsonHandler()
    json_nodes = http_obj.getnodeinfo()

    position = 0
    flowTableList = []

    print("---------START--------------")
    ''' Outer For Loop is to iterate based on No of Nodes in the Network'''
    for node in json_nodes['nodeProperties']:
        json_link = http_obj.getlinkinfo(node['node']['id'])

        no_of_links_per_node = 0
        for flowCount in json_link['nodeConnectorProperties']:
            print(flowCount['nodeconnector'])
            no_of_links_per_node = no_of_links_per_node + 1

        print('-----------------------LINK INFO--------------------------')

        for pos in range(no_of_links_per_node):

            if int(json_link['nodeConnectorProperties'][pos]['nodeconnector']['id']) > 0:
                # Create an array of Objects using List
                obj = LinkTables()

                # Update the content in the newly created Object
                obj.updatelinkstatus(
                    json_link['nodeConnectorProperties'][pos]['nodeconnector']['node']['id'],
                    json_link['nodeConnectorProperties'][pos]['properties']['name']['value'],
                    json_link['nodeConnectorProperties'][pos]['properties']['state']['value'],
                    json_link['nodeConnectorProperties'][pos]['properties']['bandwidth']['value'])

                print((pos, position, json_link['nodeConnectorProperties'][pos]['nodeconnector']['id']))

                position = position + 1

                # Append the Object to the flow table List
                flowTableList.append(obj)

    for i in range(position):
        print(flowTableList[i].switchId, flowTableList[i].portName, flowTableList[i].portStatus,
              flowTableList[i].bandwidth)

    rows = []
    for i in range(position+1):

            cols = []
            for j in range(4):

                if i == 0:
                    e = Entry(toplevel, relief=RIDGE, width=15, fg="red")
                    e.grid(row=i, column=j, sticky=NSEW)

                    if j == 0:
                        e.insert(END, "  Switch ID")
                    elif j == 1:
                        e.insert(END, "  Port ID")
                    elif j == 2:
                        e.insert(END, "  Link Status")
                    elif j == 3:
                        e.insert(END, "  Bandwidth")

                else:
                    e = Entry(toplevel, relief=RIDGE)
                    e.grid(row=i, column=j, sticky=NSEW)

                    if j == 0:
                        e.insert(END, '%s' % flowTableList[i-1].switchId)
                    if j == 1:
                        e.insert(END, '%s' % flowTableList[i-1].portName)
                    if j == 2:
                        if 1 == flowTableList[i-1].portStatus:
                            e.insert(END, '%s' % "UP")
                        else:
                            e.insert(END, '%s' % "DOWN")
                            e.configure(fg="red")
                    if j == 3:
                        e.insert(END, '%s' % flowTableList[i-1].bandwidth)
                        cols.append(e)
            rows.append(cols)

    obj = LinkTables()

    Checkbutton(toplevel, text="Send E-Mail", variable=obj.check_gmail, command=obj.send_mail).grid(row=50, sticky=W)
    Checkbutton(toplevel, text="Send Trap", variable=obj.check_snmp, command=obj.send_trap).grid(row=51, stick=W)

    Radiobutton(toplevel, text="1 Sec ", variable=obj.var, value=1, command=obj.mradioselect).grid(row=52, column=0, sticky=W)
    Radiobutton(toplevel, text="5 Sec ", variable=obj.var, value=5, command=obj.mradioselect).grid(row=52, column=1, sticky=W)
    Radiobutton(toplevel, text="10 Sec", variable=obj.var, value=10, command=obj.mradioselect).grid(row=52, column=2, sticky=W)
    Radiobutton(toplevel, text="30 Sec", variable=obj.var, value=30, command=obj.mradioselect).grid(row=52, column=3, sticky=W)
    print()

    return