blob: 628b330ac9cc23710683c2cf6ee880d405ff6419 (
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
|
#!/usr/bin/env python3
import re
import sysrepo as sr
from pnf import PNF
def module_change_cb(sess, module_name, event, private_ctx):
""" Handle event change based on yang operation. """
try:
change_path = "/" + module_name + ":*"
iterate = sess.get_changes_iter(change_path)
change = sess.get_change_next(iterate)
changelist = []
operation = change.oper()
pnf = PNF()
if event == sr.SR_EV_APPLY:
print("------------------> Start Handle Change <------------------")
if operation == sr.SR_OP_CREATED:
while True:
change = sess.get_change_next(iterate)
if change is None:
break
changelist.append(change.new_val().to_string())
result = re.findall(r'\'(.*?)\'', changelist[0])
jobid = result[0]
print("Subscription Created : " + changelist[0])
pnf.create_job_id(jobid, changelist)
pnf.pm_job()
elif operation == sr.SR_OP_DELETED:
changelist.append(change.old_val().to_string())
result = re.findall(r'\'(.*?)\'', changelist[0])
jobid = result[0]
print("Subscription Deleted : " + changelist[0])
pnf.delete_job_id(jobid)
pnf.pm_job()
elif operation == sr.SR_OP_MODIFIED:
changelist.append(change.new_val().to_string())
element = changelist[0]
print("Subscription Modified :" + element)
result = re.findall(r'\'(.*?)\'', changelist[0])
jobid = result[0]
administrative_state = ((element.rsplit('/', 1)[1]).split('=', 1))[1].strip()
if administrative_state == "LOCKED":
pnf.delete_job_id(jobid)
pnf.pm_job()
elif administrative_state == "UNLOCKED":
select_xpath = "/" + module_name + ":*//*"
values = sess.get_items(select_xpath)
if values is not None:
for i in range(values.val_cnt()):
if jobid in values.val(i).to_string():
changelist.append(values.val(i).to_string())
pnf.create_job_id(jobid, changelist)
pnf.pm_job()
else:
print("Unknown Operation")
print("------------------> End Handle Change <------------------")
except Exception as error:
print(error)
return sr.SR_ERR_OK
def start():
""" main function to create connection based on moudule name. """
try:
module_name = "pnf-subscriptions"
conn = sr.Connection(module_name)
sess = sr.Session(conn)
subscribe = sr.Subscribe(sess)
subscribe.module_change_subscribe(module_name, module_change_cb)
sr.global_loop()
print("Application exit requested, exiting.")
except Exception as error:
print(error)
if __name__ == '__main__':
start()
|
