views.py
4.74 KB
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
from django.shortcuts import render
from common.models import *
from alert_manager.StrategyBuilder import StrategyBuilder
import socket
from alert_manager import tasks as am_tasks
import majordome
from django.contrib.auth.decorators import login_required
@login_required
def alert_simulation(request):
'''
Opens a page with a button to simulate an alert
'''
return render(request, "alert_manager/alert_simulation.html", {})
@login_required
def alert_simulation_start(request):
'''
Called when the alert simulation button is pressed
Opens a connection on the alert_listener simulation socket to unlock it (so that the workflow starts)
'''
Log.objects.all().delete()
clientsocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
try:
clientsocket.connect((am_tasks.IP, am_tasks.PORT))
Log.objects.create(agent='Alert manager', message='Start simulation')
except Exception as e:
print("exception : ", e)
return render(request, "alert_manager/alert_simulation.html", {})
@login_required
def alerts_list(request):
'''
Display the list of all alerts
'''
alerts = Alert.objects.order_by("-request__created")
if StrategyObs.objects.filter(is_default=True).exists():
current_default = StrategyObs.objects.filter(is_default=True)[0].name
btn_type = "btn-primary"
else:
current_default = "Warning: please choose a default strategy"
btn_type = "btn-danger"
strat_list = StrategyObs.objects.all()
return render(request, "alert_manager/alerts.html", locals())
@login_required
def change_default_strategy(request, strat_id):
'''
Changes the strategy to be used when an alert is received
'''
strategies = StrategyObs.objects.all()
if strategies.filter(id=strat_id).exists():
for strat in strategies:
strat.is_default = False
strat.save()
strat = strategies.get(id=strat_id)
strat.is_default = True
strat.save()
success = True
message = "Default strategy successfully changed"
else:
error = True
message = "Could not find this strategy"
alerts = Alert.objects.order_by("-request__created")
if StrategyObs.objects.filter(is_default=True).exists():
current_default = StrategyObs.objects.filter(is_default=True)[0].name
btn_type = "btn-primary"
else:
current_default = "Warning: please choose a default strategy"
btn_type = "btn-danger"
strat_list = StrategyObs.objects.all()
return render(request, "alert_manager/alerts.html", locals())
@login_required
def change_obs_strategy(request, alert_id):
'''
Open a page for a given alert, listing all the other strategies
'''
alert = Alert.objects.get(id=alert_id)
if alert.strategyobs is not None:
strategies = StrategyObs.objects.exclude(id=alert.strategyobs.id)
else:
strategies = StrategyObs.objects.all()
return render(request, "alert_manager/strategy_change.html", locals())
@login_required
def change_obs_strategy_validate(request, alert_id):
'''
Creates a new request with the strategy given for the selected alert
'''
try:
alert = Alert.objects.get(id=alert_id)
except Exception:
alerts = Alert.objects.all()
error = True
message = "This alert doesn't exist"
return render(request, "alert_manager/alerts.html", locals())
strategies = StrategyObs.objects.exclude(id=alert.strategyobs.id)
if request.method == "POST":
strategy_id = request.POST["strategy_choice"]
try:
strategy = StrategyObs.objects.get(id=strategy_id)
except Exception:
error = True
message = "This strategy doesn't exist"
return render(request, "alert_manager/strategy_change.html", locals())
if str(alert.strategyobs.id) == strategy_id:
error = True
message = "This is already the current strategy for this alert"
return render(request, "alert_manager/strategy_change.html", locals())
sb = StrategyBuilder()
file = strategy.xml_file
pyros_user = alert.request.pyros_user
scientific_program = alert.request.scientific_program
name = alert.request.name
sb.create_request_from_strategy(file, pyros_user, scientific_program, name)
req = sb.validate()
alert.pk = None
alert.strategyobs = strategy
alert.request = req
alert.save()
strategies = StrategyObs.objects.exclude(id=alert.strategyobs.id)
success = True
message = "Strategy successfully changed. A new request was created."
return render(request, "alert_manager/strategy_change.html", locals())