radarsys Commit - r380:34e7637f39b2 · Jicamarca Repository

Se unió ATRAD al SIR

Renato Huallpa -

r380:34e7637f39b2

parent child

Context file:

r380:34e7637f39b2

Expand all files

apps/atrad/__init__.py created 644 +2 0

@@ -0,0 +1,2
	1	from . import mqtt
	2	mqtt.client.loop_start() No newline at end of file

apps/atrad/admin.py created 644 +6 0

@@ -0,0 +1,6
	1	from django.contrib import admin
	2	from .models import ATRADConfiguration
	3
	4	# Register your models here.
	5
	6	admin.site.register(ATRADConfiguration)

apps/atrad/apps.py created 644 +6 0

@@ -0,0 +1,6
	1	#from django.apps import AppConfig
	2
	3
	4	#class AtradConfig(AppConfig):#
	5	# default_auto_field = 'django.db.models.BigAutoField'
	6	# name = 'atrad'

apps/atrad/files.py created 644 +19 0

@@ -0,0 +1,19
	1	import json
	2
	3	def read_json_file(fp):
	4
	5	kwargs = {}
	6
	7	json_data = fp
	8	data = json.load(json_data)
	9	json_data.close()
	10
	11	topic = data["topic"][0][1]
	12
	13	kwargs['topic'] = topic
	14
	15	return kwargs
	16
	17
	18	def write_json_file(filename):
	19	pass No newline at end of file

apps/atrad/forms.py created 644 +27 0

@@ -0,0 +1,27
	1	from django import forms
	2	from apps.main.models import Device
	3	from .models import ATRADConfiguration
	4
	5	class ATRADConfigurationForm(forms.ModelForm):
	6
	7	def __init__(self, args, *kwargs):
	8	super(ATRADConfigurationForm, self).__init__(args, *kwargs)
	9	instance = getattr(self, 'instance', None)
	10
	11	if instance and instance.pk:
	12	devices = Device.objects.filter(device_type__name='atrad')
	13	if instance.experiment:
	14	self.fields['experiment'].widget.attrs['disabled'] = 'disabled'
	15	self.fields['device'].widget.choices = [(device.id, device) for device in devices]
	16
	17	def clean(self):
	18	return
	19
	20	class Meta:
	21	model = ATRADConfiguration
	22	exclude = ('type', 'parameters', 'status', 'author', 'hash')
	23
	24
	25	class UploadFileForm(forms.Form):
	26	title = forms.CharField(label='Extension Type', widget=forms.TextInput(attrs={'readonly':'readonly'}))
	27	file = forms.FileField()

apps/atrad/models.py created 644 +175 0

@@ -0,0 +1,175
	1	from django.db import models
	2	from apps.main.models import Configuration
	3	from apps.main.utils import Params
	4	from django.core.validators import MinValueValidator, MaxValueValidator
	5
	6	from .files import read_json_file
	7	import requests
	8	# Create your models here. validators=[MinValueValidator(62.5e6), MaxValueValidator(450e6)]
	9
	10	class ATRADConfiguration(Configuration):
	11
	12	topic = models.PositiveIntegerField(verbose_name='Topic',validators=[MaxValueValidator(10)], default = 0)
	13
	14	def verify_frequencies(self):
	15
	16	return True
	17
	18
	19	def status_device(self):
	20
	21	ip=self.device.ip_address
	22	port=self.device.port_address
	23
	24	route = "http://" + str(ip) + ":" + str(port) + "/status/"
	25	try:
	26	r = requests.get(route, timeout=0.7)
	27	except Exception as e:
	28	self.device.status = 0
	29	self.device.save()
	30	self.message = 'Could not read TX status: ' + str(e)
	31	return False
	32
	33	response = r.json()
	34	self.device.status = response['status']
	35	self.message = response['message']
	36	self.device.save()
	37
	38	if response['components_status']==0:
	39	return False
	40
	41	return True
	42
	43
	44	def start_device(self):
	45
	46	ip=self.device.ip_address
	47	port=self.device.port_address
	48
	49	#---Device must be configured
	50	if not self.device.status == 2:
	51	self.message = 'TX Device must be configured.'
	52	return False
	53	#---Frequencies from form
	54	post_data = self.parms_to_dict()
	55	route = "http://" + str(ip) + ":" + str(port) + "/write/"
	56
	57	try:
	58	r = requests.post(route, post_data, timeout=0.7)
	59	except Exception as e:
	60	self.message = "Could not start TX device. "+str(e)
	61	return False
	62
	63	response = r.json()
	64	if response['status']==1:
	65	self.device.status = 1
	66	self.device.save()
	67	self.message = response['message']
	68	return False
	69
	70	self.device.status = response['status']
	71	self.device.save()
	72	self.message = response['message']
	73
	74	return True
	75
	76
	77	def stop_device(self):
	78
	79	ip=self.device.ip_address
	80	port=self.device.port_address
	81
	82	if self.device.status == 2: #Configured
	83	self.message = 'TX device is already stopped.'
	84	return False
	85
	86	post_data = {"topic":0}
	87	route = "http://" + str(ip) + ":" + str(port) + "/write/"
	88
	89	try:
	90	r = requests.post(route, post_data, timeout=0.7)
	91	except Exception as e:
	92	self.message = "Could not write TX parameters. "+str(e)
	93	self.device.status = 0
	94	self.device.save()
	95	return False
	96
	97	response = r.json()
	98	status = response['status']
	99	if status == 1:
	100	self.device.status = status
	101	self.device.save()
	102	self.message = 'Could not stop TX device.'
	103	return False
	104
	105	self.message = 'TX device has been stopped successfully.'
	106	self.device.status = 2
	107	self.device.save()
	108
	109	return True
	110
	111
	112	def read_device(self):
	113
	114	ip=self.device.ip_address
	115	port=self.device.port_address
	116
	117	route = "http://" + str(ip) + ":" + str(port) + "/read/"
	118	try:
	119	frequencies = requests.get(route,timeout=0.7)
	120	except:
	121	self.message = "Could not read TX parameters from this device"
	122	return None
	123
	124	frequencies = frequencies.json()
	125	if frequencies:
	126	frequencies = frequencies.get("Frequencies")
	127	topic = frequencies.get("topic")
	128
	129	parms = {'topic': topic}
	130
	131	self.message = "TX parameters have been successfully read"
	132	return parms
	133	else:
	134	self.message = "Error reading TX parameters"
	135	return None
	136
	137
	138	def write_device(self):
	139
	140	ip=self.device.ip_address
	141	port=self.device.port_address
	142
	143	#---Frequencies from form
	144	parms = self.parms_to_dict()['configurations']
	145	for parm in parms['allIds']:
	146	byid = parm
	147	frequencies = parms['byId'][byid]
	148	post_data = {}
	149	for data in frequencies:
	150	if data in ['topic']:
	151	post_data[data] = frequencies[data]
	152
	153	route = "http://" + str(ip) + ":" + str(port) + "/write/"
	154	print (post_data)
	155	try:
	156	r = requests.post(route, post_data, timeout=0.7)
	157	except:
	158	self.message = "Could not write TX parameters"
	159	self.device.status = 0
	160	self.device.save()
	161	return False
	162
	163	response = r.json()
	164	self.message = response['message']
	165	self.device.status = response['status']
	166	self.device.save()
	167
	168	if self.device.status==1:
	169	return False
	170
	171	return True
	172
	173
	174	class Meta:
	175	db_table = 'atrad_configurations' No newline at end of file

apps/atrad/mqtt.py created 644 +38 0

@@ -0,0 +1,38
	1	import paho.mqtt.client as mqtt
	2	from radarsys import settings
	3	from radarsys.socketconfig import sio as sio
	4	import numpy as np
	5
	6	def on_connect(mqtt_client, userdata, flags, rc):
	7	if rc == 0:
	8	print('Connected successfully')
	9	mqtt_client.subscribe('atrad/test3')
	10	else:
	11	print('Bad connection. Code:', rc)
	12
	13	def maxima_temp(trs):
	14	np_array = [np.array(i) for i in trs]
	15	temps = [max(i[i<40]) for i in np_array]
	16	return max(temps)
	17
	18	def on_message(mqtt_client, userdata, msg):
	19	print(f'Received message on topic: {msg.topic} with payload: {msg.payload}', flush=True)
	20	trsi = [[],[],[],[]]
	21	mensaje = str(msg.payload)
	22	datos = [i for i in mensaje[21:-1].split("*")]
	23	status=''.join([datos[i][3] for i in [0,1,2,3]])
	24	for trs,i in zip(datos,[0,1,2,3]) :
	25	trsi[i]= [int(i) for i in trs[1:-1].split(",")]
	26	potencias = [trsi[0][34],trsi[0][36],trsi[2][32],trsi[2][34]]
	27	tmax = maxima_temp(trsi)
	28	sio.emit('test', data={'time':mensaje[2:21],'num':trsi[0][0],'pow':potencias,'tmax':str(tmax),'status':status})
	29
	30	client = mqtt.Client()
	31	client.on_connect = on_connect
	32	client.on_message = on_message
	33	client.username_pw_set(settings.MQTT_USER, settings.MQTT_PASSWORD)
	34	client.connect(
	35	host=settings.MQTT_SERVER,
	36	port=settings.MQTT_PORT,
	37	keepalive=settings.MQTT_KEEPALIVE
	38	) No newline at end of file

apps/atrad/templates/atrad_conf.html created 644 +288 0

@@ -0,0 +1,288
	1	{% extends "dev_conf.html" %}
	2	{% block extra-head %}
	3	<style>
	4	.dot {
	5	height: 25px;
	6	width: 25px;
	7	background-color: #b0b3af;
	8	border-radius: 50%;
	9	display: inline-block;
	10	}
	11	</style>
	12	{% endblock %}
	13
	14	{% block extra-content %}
	15	<script type="text/javascript" src="https://cdnjs.cloudflare.com/ajax/libs/jquery/3.6.3/jquery.min.js"></script>
	16	<script type="text/javascript" src="//cdnjs.cloudflare.com/ajax/libs/socket.io/4.4.1/socket.io.min.js"></script>
	17
	18	<div class="container-fluid">
	19	<div class="row">
	20	<div class="col-xs-12">
	21	<h1>Atrad Monitor</h1>
	22	</div>
	23	</div>
	24
	25	<div class="row ">
	26	<!-- Potencia -->
	27	<div class="col col-xs-12">
	28	<div class="row">
	29	<div class="panel panel-default" style="width:100%;">
	30	<div class="panel-heading">
	31	<h3 class="panel-title">Potencia</h3>
	32	</div>
	33	<div class="panel-body">
	34	<div class="col-xs-12">
	35	<div class="row">
	36	<div id="plot-pot"></div>
	37	</div>
	38	</div>
	39	</div>
	40	<div class="panel-footer">
	41	<button type="button" class="btn btn-primary" data-toggle="modal" data-target="#Pot1">T1</button>
	42	<button type="button" class="btn btn-primary" data-toggle="modal" data-target="#Pot2">T2</button>
	43	</div>
	44	</div>
	45	</div>
	46	</div>
	47	<div class="col col-xs-12">
	48	<div class="panel panel-default">
	49	<div class="panel-heading">
	50	<h3 class="panel-title">Status</h3>
	51	</div>
	52	<div class="panel-body">
	53	<table class="table table-borderless" style="max-width: 300px;">
	54	<tbody>
	55	<tr>
	56	<th scope="row">Tx1</th>
	57	<td><span id="status1" class="dot"></span></td>
	58	<td><p id="status-text1" class="font-weight-bold">Sin envio de datos</p></td>
	59	</tr>
	60	<tr>
	61	<th scope="row">Tx2</th>
	62	<td><span id="status2" class="dot"></span></td>
	63	<td><p id="status-text2" class="font-weight-bold">Sin envio de datos</p></td>
	64	</tr>
	65	</tbody>
	66	</table>
	67	</div>
	68	</div>
	69	</div>
	70	</div>
	71
	72	<!-- Temperatura -->
	73	<div class="row">
	74	<div class="col-xs-12">
	75	<div class="panel panel-default">
	76	<div class="panel-heading">
	77	<h3 class="panel-title">Temperatura</h3>
	78	</div>
	79	<div class="panel-body">
	80	<div class="col-xs-12">
	81	<div class="row">
	82	<div id="plot-temp"></div>
	83	</div>
	84	</div>
	85	</div>
	86	</div>
	87	</div>
	88	</div>
	89
	90	<div class="row">
	91	<!-- Controles -->
	92	<div class="col-xs-6">
	93	<div class="panel panel-default">
	94	<div class="panel-heading">
	95	<h3 class="panel-title">Control</h3>
	96	</div>
	97	<div class="panel-body">
	98	<div class="col-xs-12">
	99	<div class="form-row">
	100	<div class="form-group col-xs-6">
	101	<form id="controlON" method="POST" action=''>
	102	<button type="summit" class="btn btn-secondary btn-lg">Prender</button>
	103	</form>
	104	</div>
	105	<div class="form-group col-xs-6">
	106	<form id="controlOFF" method="POST" action=''>
	107	<button type="summit" class="btn btn-secondary btn-lg">Apagar</button>
	108	</form>
	109	</div>
	110	</div>
	111	</div>
	112	</div>
	113	</div>
	114	</div>
	115
	116	<div class="col-xs-6">
	117	<div class="panel panel-default">
	118	<div class="panel-heading">
	119	</div>
	120	</div>
	121	</div>
	122	</div>
	123	</div>
	124
	125	<!--Modales-->
	126	<div class="modal fade" id="Pot1" role="dialog">
	127	<div class="modal-dialog modal-md" style="min-width:760px">
	128	<div class="modal-content">
	129	<div class="modal-header">
	130	<h4 class="modal-title">Potencia incidente - Transmisor 1</h4>
	131	<button type="button" class="close" data-dismiss="modal">×</button>
	132	</div>
	133	<div class="modal-body">
	134	<div class="col-xs-12">
	135	<div id="plot-pot-t1"></div>
	136	</div>
	137	<div clas="col-xs-12">
	138	<table class="table table-borderless">
	139	<tbody>
	140	<tr>
	141	<th scope="row">P1</th>
	142	<td>e</td>
	143	<td>e</td>
	144	</tr>
	145	<tr>
	146	<th scope="row">P2</th>
	147	<td>e</td>
	148	<td>e</td>
	149	</tr>
	150	<tr>
	151	<th scope="row">P3</th>
	152	<td>e</td>
	153	<td>e</td>
	154	</tr>
	155	<tr>
	156	<th scope="row">P4</th>
	157	<td>e</td>
	158	<td>e</td>
	159	</tr>
	160	</tbody>
	161	</table>
	162	</div>
	163	</div>
	164	</div>
	165	</div>
	166	</div>
	167
	168	<div class="modal fade" id="Pot2" role="dialog">
	169	<div class="modal-dialog modal-md" style="min-width:760px">
	170	<div class="modal-content">
	171	<div class="modal-header">
	172	<h4 class="modal-title">Potencia incidente - Transmisor 2</h4>
	173	<button type="button" class="close" data-dismiss="modal">×</button>
	174	</div>
	175	<div class="modal-body">
	176	<div class="col-xs-12">
	177	<div id="plot-pot-t2"></div>
	178	</div>
	179	</div>
	180	</div>
	181	</div>
	182	</div>
	183
	184	<script type="text/javascript" charset="utf-8">
	185	$(document).ready(function() {
	186	var socket = io.connect('http://' + document.domain + ':' + location.port);
	187
	188	socket.on('connect', function(data) {
	189	console.log('Connecting... OK');
	190	makePlot("plot-temp",2,["T1","T2"],[14, 45])
	191	makePlot("plot-pot",2,["T1","T2"],[70,100])
	192	makePlot("plot-pot-t1",4,["P1","P2","P3","P4"],[0,26])
	193	makePlot("plot-pot-t2",4,["P1","P2","P3","P4"],[0,26])
	194	})
	195
	196	socket.on('test', function(data) {
	197	let total = data.pow.reduce((a, b) => a + b, 0);
	198	var id = (data.num/4)>>0;
	199	streamPlot("plot-pot",data.time,total/1000.0,id,81);
	200	streamPlot("plot-temp",data.time,data.tmax,id>>0,40);
	201	if(id == 0){streamPlot2("plot-pot-t1",data.time,data.pow);ligthStatus('status1','status-text1',data.status);}
	202	if(id == 1){streamPlot2("plot-pot-t2",data.time,data.pow);ligthStatus('status2','status-text2',data.status);}
	203	})
	204	$('form#controlON').submit(function(event) {
	205	socket.emit('control_event', {data: 1});
	206	return false;
	207	});
	208	$('form#controlOFF').submit(function(event) {
	209	socket.emit('control_event', {data: 0});
	210	return false;
	211	});
	212	$("#btn1").click(function(){
	213	$("#box").animate({height: "300px"});
	214	});
	215	$("#btn2").click(function(){
	216	$("#box").animate({height: "100px"});
	217	});
	218	});
	219
	220	function makePlot(div, n=1, names=["", ""],ranges){
	221	var plotDiv = document.getElementById(div);
	222	var traces = [];
	223	for (let i = 0; i < n; i++) {
	224	traces.push({x: [], y: [],mode: 'lines', name: names[i]});
	225	}
	226	traces.push({x: [], y: [],mode: 'lines',line: {color:'rgb(219, 64, 82)',dash: 'dot',width: 2},name:"nominal",showlegend: false});
	227	var yrange = ranges;
	228	var layout = {
	229	height: 350,
	230	font: {size: 12},
	231	margin: { t: 10, b:50},
	232	xaxis: {
	233	type: 'date'
	234	},
	235	yaxis: {
	236	range: yrange,
	237	},
	238	};
	239
	240	Plotly.plot(plotDiv, traces, layout);
	241	};
	242
	243	function streamPlot(div,x,y,ind,val){
	244	var plotDiv = document.getElementById(div);
	245	if (plotDiv.data[ind].x.length > 8){
	246	plotDiv.data[2].x = plotDiv.data[2].x.slice(-23)
	247	plotDiv.data[2].y = plotDiv.data[2].y.slice(-23)
	248	plotDiv.data[ind].x = plotDiv.data[ind].x.slice(-11)
	249	plotDiv.data[ind].y = plotDiv.data[ind].y.slice(-11)
	250	}
	251	var tm = [x];
	252	var values = [y];
	253	var data_update = {x: [tm,tm], y: [values,[val]]}
	254	Plotly.extendTraces(plotDiv, data_update,[ind,2])
	255	};
	256	function streamPlot2(div,x,y){
	257	var plotDiv = document.getElementById(div);
	258	if (plotDiv.data[0].x.length > 8){
	259	for(let i=0;i<4;i++){
	260	plotDiv.data[i].x = plotDiv.data[i].x.slice(-11)
	261	plotDiv.data[i].y = plotDiv.data[i].y.slice(-11)
	262	}
	263	}
	264	var tm = [x];
	265	var values = [];
	266	for(let i=0;i<4;i++){
	267	values[i]=[y[i]/1000.0];
	268	}
	269	var data_update = {x: [tm,tm,tm,tm], y: values}
	270	Plotly.extendTraces(plotDiv, data_update,[0,1,2,3])
	271	};
	272	function ligthStatus(div1,div2,status){
	273	if(status==='0000'){
	274	document.getElementById(div1).style.backgroundColor = "green";
	275	document.getElementById(div2).innerHTML = "Desabilitado";
	276	}
	277	else if(status==='1111'){
	278	document.getElementById(div1).style.backgroundColor = "green";
	279	document.getElementById(div2).innerHTML = "Habilitado";
	280	}
	281	else{
	282	document.getElementById(div1).style.backgroundColor = "yellow";
	283	document.getElementById(div2).innerHTML = "Incompleto";
	284	}
	285	}
	286
	287	</script>
	288	{% endblock %} No newline at end of file

apps/atrad/templates/atrad_conf_edit.html created 644 0 0

NO CONTENT: new file 100644

apps/atrad/templates/atrad_conf_import.html created 644 +7 0

@@ -0,0 +1,7
	1	{% extends "dev_conf_edit.html" %}
	2	{% load django_bootstrap5 %}
	3	{% load static %}
	4	{% load main_tags %}
	5
	6	{% block extra-js%}
	7	{% endblock %} No newline at end of file

apps/atrad/templates/index.html created 644 +15 0

@@ -0,0 +1,15
	1	{% extends "base.html" %}
	2	{% block mainactive %}active{% endblock %}
	3
	4	{% block content-title %}TITLE{% endblock %}
	5	{% block content-suptitle %}Suptitle{% endblock %}
	6
	7	{% block content %}
	8	<p class="text-justify">
	9	{% lorem %}
	10	</p>
	11	{% endblock %}
	12
	13	{% block sidebar%}
	14
	15	{% endblock %}

apps/atrad/templates/index_atrad.html created 644 +46 0

@@ -0,0 +1,46
	1	{% extends "base.html" %}
	2	{% load django_bootstrap5 %}
	3	{% block mainactive %}active{% endblock %}
	4
	5	{% block content-title %}DEVICE CGS{% endblock %}
	6	{% block content-suptitle %}CLOCK GENERATOR AND SYNCHRONIZER{% endblock %}
	7
	8	{% block content %}
	9	<p class="text-justify">
	10	Ingresar Frecuencias
	11	</p>
	12
	13
	14
	15	<!-- Agregado 30-11-2015 -->
	16	{% if form.is_multipart %}
	17
	18	<script type="text/javascript">
	19
	20	</script>
	21
	22	<form id="{{ idform }}" enctype="multipart/form-data" method="{{ submit_method\|default:'post' }}" action="" class="form">
	23	{% else %}
	24	<form method="{{ submit_method\|default:'post' }}" action="" class="form">
	25	{% endif %}
	26
	27	{% if step_field %}
	28	<input type="hidden" name="{{ step_field }}" value="{{ step0 }}" />
	29	{% endif %}
	30
	31	{% if submit_method != 'GET' and submit_method != 'get' %}
	32	{% csrf_token %}
	33	{% endif %}
	34	<!-- Agregado 30-11-2015 -->
	35
	36
	37
	38	<div class='col-md-8'>
	39	{% bootstrap_form form size='md' %}
	40	<button type="submit" class="btn btn-primary pull-right">Submit</button>
	41	</div>
	42	{% endblock %}
	43
	44	{% block sidebar%}
	45
	46	{% endblock %} No newline at end of file

apps/atrad/tests.py created 644 +3 0

@@ -0,0 +1,3
	1	from django.test import TestCase
	2
	3	# Create your tests here.

apps/atrad/urls.py created 644 +8 0

@@ -0,0 +1,8
	1	from django.urls import path
	2
	3	from . import views
	4
	5	urlpatterns = (
	6	path('<int:id_conf>/', views.atrad_conf, name='url_atrad_conf'),
	7	path('<int:id_conf>/edit/', views.atrad_conf_edit, name='url_edit_atrad_conf'),
	8	) No newline at end of file

apps/atrad/views.py created 644 +108 0

@@ -0,0 +1,108
	1	from django.shortcuts import redirect, render, get_object_or_404
	2	from django.contrib import messages
	3	from django.http import HttpResponse
	4
	5	from apps.main.models import Experiment
	6	from .models import ATRADConfiguration
	7
	8	from .forms import ATRADConfigurationForm, UploadFileForm
	9	from apps.main.views import sidebar
	10
	11	import requests
	12	import json
	13
	14	import os
	15	from django.http import JsonResponse
	16	from .mqtt import client as mqtt_client
	17	from radarsys.socketconfig import sio as sio
	18
	19
	20	def atrad_conf(request, id_conf):
	21
	22	conf = get_object_or_404(ATRADConfiguration, pk=id_conf)
	23
	24	ip=conf.device.ip_address
	25	port=conf.device.port_address
	26
	27	kwargs = {}
	28
	29	kwargs['status'] = conf.device.get_status_display()
	30
	31	kwargs['dev_conf'] = conf
	32	kwargs['dev_conf_keys'] = ['label',
	33	'topic']
	34
	35	kwargs['title'] = 'ATRAD Configuration'
	36	kwargs['suptitle'] = 'Details'
	37
	38	kwargs['button'] = 'Edit Configuration'
	39
	40	#kwargs['no_play'] = True
	41
	42	###### SIDEBAR ######
	43	kwargs.update(sidebar(conf=conf))
	44
	45	return render(request, 'atrad_conf.html', kwargs)
	46
	47	def atrad_conf_edit(request, id_conf):
	48
	49	conf = get_object_or_404(ATRADConfiguration, pk=id_conf)
	50
	51	if request.method=='GET':
	52	form = ATRADConfigurationForm(instance=conf)
	53
	54	if request.method=='POST':
	55	form = ATRADConfigurationForm(request.POST, instance=conf)
	56
	57	if form.is_valid():
	58	if conf.topic == None: conf.topic = 0
	59
	60	conf = form.save(commit=False)
	61
	62	if conf.verify_frequencies():
	63	conf.save()
	64	return redirect('url_atrad_conf', id_conf=conf.id)
	65
	66	kwargs = {}
	67	kwargs['id_dev'] = conf.id
	68	kwargs['form'] = form
	69	kwargs['title'] = 'Device Configuration'
	70	kwargs['suptitle'] = 'Edit'
	71	kwargs['button'] = 'Save'
	72
	73	return render(request, 'atrad_conf_edit.html', kwargs)
	74
	75	import os
	76	from django.http import HttpResponse#
	77
	78	def publish_message(request):
	79	rc, mid = mqtt_client.publish('test/data2',1)
	80	return JsonResponse({'code1': 'HIKA', 'code2': 'LUCAS'})
	81
	82	def monitor(request):
	83	kwargs = {'no_sidebar': True}
	84	return render(request, 'monitor.html', kwargs)
	85
	86	def prueba(request):
	87	kwargs = {'no_sidebar': True}
	88	return render(request, 'prueba.html', kwargs)
	89
	90	@sio.on('connection-bind')
	91	def connection_bind(sid, data):
	92	print("sid:",sid,"data",data)
	93
	94	@sio.on('disconnect')
	95	def test_disconnect(sid):
	96	print("Disconnected")
	97
	98	@sio.event
	99	def control_event(sid,message):
	100	mqtt_client.publish('test/data2',message['data'])
	101
	102	def hello(data):
	103	try:
	104	rc, mid = mqtt_client.publish('test/data2', 'Hello')
	105	sio.emit('test', data={'topic':mid, 'status': 'Not Running'})
	106	except:
	107	print('ERROR', flush=True)
	108	return HttpResponse("Hello") No newline at end of file

radarsys/socketconfig.py created 644 +6 0

@@ -0,0 +1,6
	1	import os
	2	import socketio
	3	async_mode = None
	4
	5	basedir = os.path.dirname(os.path.realpath(__file__))
	6	sio = socketio.Server(async_mode='eventlet') No newline at end of file

apps/main/fixtures/main_initial_data.json +8 0

             [
                 {
                     "fields": {
                         "name": "JRO",
                         "description": ""
                     },
                     "model": "main.location",
                     "pk": 1
                 },
                 {
                     "fields": {
                         "name": "JASMET",
                         "description": ""
                     },
                     "model": "main.location",
                     "pk": 2
                 },
                 {
                     "fields": {
                         "name": "SOUSY",
                         "description": ""
                     },
                     "model": "main.location",
                     "pk": 3
                 },
                 {
                     "fields": {
                         "name": "JULIA",
                         "description": ""
                     },
                     "model": "main.location",
                     "pk": 4
                 },
                 {
                     "fields": {
                         "name": "CLAIRE",
                         "description": ""
                     },
                     "model": "main.location",
                     "pk": 5
                 },
                 {
                     "fields": {
                         "name": "IDI",
                         "description": ""
                     },
                     "model": "main.location",
                     "pk": 6
                 },
                 {
                     "fields": {
                         "name": "rc",
                         "description": ""
                     },
                     "model": "main.devicetype",
                     "pk": 1
                 },
                 {
                     "fields": {
                         "name": "dds",
                         "description": ""
                     },
                     "model": "main.devicetype",
                     "pk": 2
                 },
                 {
                     "fields": {
                         "name": "cgs",
                         "description": ""
                     },
                     "model": "main.devicetype",
                     "pk": 3
                 },
                 {
                     "fields": {
                         "name": "jars",
                         "description": ""
                     },
                     "model": "main.devicetype",
                     "pk": 4
                 },
                 {
                     "fields": {
                         "name": "abs",
                         "description": ""
                     },
                     "model": "main.devicetype",
                     "pk": 5
                 },
                 {
                     "fields": {
                         "name": "dds_rest",
                         "description": ""
                     },
                     "model": "main.devicetype",
                     "pk": 6
+                },
+                {
+                    "fields": {
+                        "name": "atrad",
+                        "description": ""
+                    },
+                    "model": "main.devicetype",
+                    "pk": 7
                 },
                 {
                     "fields": {
                         "name": "Operator"
                     },
                     "model": "auth.group",
                     "pk": 1
                 },
                 {
                     "fields": {
                         "name": "Developer"
                     },
                     "model": "auth.group",
                     "pk": 2
                 },
                 {
                     "fields": {
                         "password": "pbkdf2_sha256$24000$6RRL7xETgdgN$ORRPhrITZKzTTZHCm8T+Er6ght415kYKeU7QP3rry5M=",
                         "last_login": null,
                         "is_superuser": true,
                         "username": "admin",
                         "first_name": "Administrador",
                         "last_name": "IDI",
                         "email": "admin@admin.com",
                         "is_staff": true,
                         "is_active": true,
                         "date_joined": "2017-01-12T16:10:24.383",
                         "groups": [],
                         "user_permissions": []
                     },
                     "model": "auth.user",
                     "pk": 1
                 },
                 {
                     "fields": {
                         "user": 1,
                         "theme": "spacelab"
                     },
                     "model": "main.profile",
                     "pk": 1
                 }
             ]

apps/main/models.py +1 0

             import os
             import json
             import requests
             import time
             from datetime import datetime
             try:
                 from polymorphic.models import PolymorphicModel
             except:
                 from polymorphic import PolymorphicModel
             from django.template.base import kwarg_re
             from django.db import models
             from django.urls import reverse
             from django.core.validators import MinValueValidator, MaxValueValidator
             from django.shortcuts import get_object_or_404
             from django.contrib.auth.models import User
             from django.db.models.signals import post_save
             from django.dispatch import receiver
             from apps.main.utils import Params
             from apps.rc.utils import RCFile
             from apps.jars.utils import RacpFile
             from devices.dds import api as dds_api
             from devices.dds import data as dds_data
             DEV_PORTS = {
                             'rc'    : 2000,
                             'dds'   : 2000,
                             'jars'  : 2000,
                             'usrp'  : 2000,
                             'cgs'   : 8080,
                             'abs'   : 8080,
                             'dds_rest': 80
                         }
             RADAR_STATES = (
                              (0, 'No connected'),
                              (1, 'Connected'),
                              (2, 'Configured'),
                              (3, 'Running'),
                              (4, 'Scheduled'),
                          )
             EXPERIMENT_TYPE = (
                                (0, 'RAW_DATA'),
                                (1, 'PDATA'),
                                )
             DECODE_TYPE = (
                          (0, 'None'),
                          (1, 'TimeDomain'),
                          (2, 'FreqDomain'),
                          (3, 'InvFreqDomain'),
                          )
             DEV_STATES = (
                              (0, 'No connected'),
                              (1, 'Connected'),
                              (2, 'Configured'),
                              (3, 'Running'),
                              (4, 'Unknown'),
                          )
             DEV_TYPES = (
                             ('', 'Select a device type'),
                             ('rc', 'Radar Controller'),
                             ('dds', 'Direct Digital Synthesizer'),
                             ('jars', 'Jicamarca Radar Acquisition System'),
                             ('usrp', 'Universal Software Radio Peripheral'),
                             ('cgs', 'Clock Generator System'),
                             ('abs', 'Automatic Beam Switching'),
                             ('dds_rest', 'Direct Digital Synthesizer_REST'),
+                            ('atrad', 'Transmitter ATRAD'),
                         )
             EXP_STATES = (
                              (0,'Error'),                 #RED
                              (1,'Cancelled'),             #YELLOW
                              (2,'Running'),               #GREEN
                              (3,'Scheduled'),             #BLUE
                              (4,'Unknown'),               #WHITE
                          )
             CONF_TYPES = (
                              (0, 'Active'),
                              (1, 'Historical'),
                          )
             class Profile(models.Model):
                 user = models.OneToOneField(User, on_delete=models.CASCADE)
                 theme = models.CharField(max_length=30, default='spacelab')
             @receiver(post_save, sender=User)
             def create_user_profile(sender, instance, created, **kwargs):
                 if created:
                     Profile.objects.create(user=instance)
             @receiver(post_save, sender=User)
             def save_user_profile(sender, instance, **kwargs):
                 instance.profile.save()
             class Location(models.Model):
                 name = models.CharField(max_length = 30)
                 description = models.TextField(blank=True, null=True)
                 class Meta:
                     db_table = 'db_location'
                 def __str__(self):
                     return u'%s' % self.name
                 def get_absolute_url(self):
                     return reverse('url_location', args=[str(self.id)])
             class DeviceType(models.Model):
                 name = models.CharField(max_length = 10, choices = DEV_TYPES, default = 'dds_rest')
                 sequence = models.PositiveSmallIntegerField(default=55)
                 description = models.TextField(blank=True, null=True)
                 class Meta:
                     db_table = 'db_device_types'
                 def __str__(self):
                     return u'%s' % self.get_name_display()
             class Device(models.Model):
                 device_type  = models.ForeignKey('DeviceType', on_delete=models.CASCADE)
                 location     = models.ForeignKey('Location', on_delete=models.CASCADE)
                 ip_address   = models.GenericIPAddressField(protocol='IPv4', default='0.0.0.0')
                 port_address = models.PositiveSmallIntegerField(default=2000)
                 description  = models.TextField(blank=True, null=True)
                 status       = models.PositiveSmallIntegerField(default=4, choices=DEV_STATES)
                 conf_active  = models.PositiveIntegerField(default=0, verbose_name='Current configuration')
                 class Meta:
                     db_table = 'db_devices'
                 def __str__(self):
                     ret = u'{} [{}]'.format(self.device_type.name.upper(), self.location.name)
                     return ret
                 @property
                 def name(self):
                     return str(self)
                 def get_status(self):
                     return self.status
                 @property
                 def status_color(self):
                     color = 'muted'
                     if self.status == 0:
                         color = "danger"
                     elif self.status == 1:
                         color = "warning"
                     elif self.status == 2:
                         color = "info"
                     elif self.status == 3:
                         color = "success"
                     return color
                 def url(self, path=None):
                     if path:
                         return 'http://{}:{}/{}/'.format(self.ip_address, self.port_address, path)
                     else:
                         return 'http://{}:{}/'.format(self.ip_address, self.port_address)
                 def get_absolute_url(self):
                     return reverse('url_device', args=[str(self.id)])
                 def get_absolute_url_edit(self):
                     return reverse('url_edit_device', args=[str(self.id)])
                 def get_absolute_url_delete(self):
                     return reverse('url_delete_device', args=[str(self.id)])
                 def change_ip(self, ip_address, mask, gateway, dns, **kwargs):
                     if self.device_type.name=='dds':
                         try:
                             answer = dds_api.change_ip(ip = self.ip_address,
                                                        port = self.port_address,
                                                        new_ip = ip_address,
                                                        mask = mask,
                                                        gateway = gateway)
                             if answer[0]=='1':
                                 self.message = '25|DDS - {}'.format(answer)
                                 self.ip_address = ip_address
                                 self.save()
                             else:
                                 self.message = '30|DDS - {}'.format(answer)
                                 return False
                         except Exception as e:
                             self.message = '40|{}'.format(str(e))
                             return False
                     elif self.device_type.name=='rc':
                         headers = {'content-type': "application/json",
                                    'cache-control': "no-cache"}
                         ip      = [int(x) for x in ip_address.split('.')]
                         dns     = [int(x) for x in dns.split('.')]
                         gateway = [int(x) for x in gateway.split('.')]
                         subnet  = [int(x) for x in mask.split('.')]
                         payload = {
                             "ip": ip,
                             "dns": dns,
                             "gateway": gateway,
                             "subnet": subnet
                             }
                         req = requests.post(self.url('changeip'), data=json.dumps(payload), headers=headers)
                         try:
                             answer = req.json()
                             if answer['changeip']=='ok':
                                 self.message    = '25|IP succesfully changed'
                                 self.ip_address = ip_address
                                 self.save()
                             else:
                                 self.message = '30|An error ocuur when changing IP'
                         except Exception as e:
                             self.message = '40|{}'.format(str(e))
                     else:
                         self.message = 'Not implemented'
                         return False
                     return True
             class Campaign(models.Model):
                 template    = models.BooleanField(default=False)
                 name        = models.CharField(max_length=60, unique=True)
                 start_date  = models.DateTimeField(blank=True, null=True)
                 end_date    = models.DateTimeField(blank=True, null=True)
                 tags        = models.CharField(max_length=40, blank=True, null=True)
                 description = models.TextField(blank=True, null=True)
                 experiments = models.ManyToManyField('Experiment', blank=True)
                 author      = models.ForeignKey(User, null=True, blank=True,on_delete=models.CASCADE)
                 class Meta:
                     db_table = 'db_campaigns'
                     ordering = ('name',)
                 def __str__(self):
                     if self.template:
                         return u'{} (template)'.format(self.name)
                     else:
                         return u'{}'.format(self.name)
                 def jsonify(self):
                     data = {}
                     ignored = ('template')
                     for field in self._meta.fields:
                         if field.name in ignored:
                             continue
                         data[field.name] = field.value_from_object(self)
                     data['start_date'] = data['start_date'].strftime('%Y-%m-%d')
                     data['end_date']   = data['end_date'].strftime('%Y-%m-%d')
                     return data
                 def parms_to_dict(self):
                     params = Params({})
                     params.add(self.jsonify(), 'campaigns')
                     for exp in Experiment.objects.filter(campaign = self):
                         params.add(exp.jsonify(), 'experiments')
                         configurations = Configuration.objects.filter(experiment=exp, type=0)
                         for conf in configurations:
                             params.add(conf.jsonify(), 'configurations')
                             if conf.device.device_type.name=='rc':
                                 for line in conf.get_lines():
                                     params.add(line.jsonify(), 'lines')
                     return params.data
                 def dict_to_parms(self, parms, CONF_MODELS):
                     experiments = Experiment.objects.filter(campaign = self)
                     if experiments:
                         for experiment in experiments:
                             experiment.delete()
                     for id_exp in parms['experiments']['allIds']:
                         exp_parms = parms['experiments']['byId'][id_exp]
                         dum = (datetime.now() - datetime(1970, 1, 1)).total_seconds()
                         exp = Experiment(name='{}'.format(dum))
                         exp.save()
                         exp.dict_to_parms(parms, CONF_MODELS, id_exp=id_exp)
                         self.experiments.add(exp)
                     camp_parms = parms['campaigns']['byId'][parms['campaigns']['allIds'][0]]
                     self.name       = '{}-{}'.format(camp_parms['name'], datetime.now().strftime('%y%m%d'))
                     self.start_date = camp_parms['start_date']
                     self.end_date   = camp_parms['end_date']
                     self.tags       = camp_parms['tags']
                     self.save()
                     return self
                 def get_experiments_by_radar(self, radar=None):
                     ret = []
                     if radar:
                         locations = Location.objects.filter(pk=radar)
                     else:
                         locations = set([e.location for e in self.experiments.all()])
                     for loc in locations:
                         dum = {}
                         dum['name']        = loc.name
                         dum['id']          = loc.pk
                         dum['experiments'] = [e for e in self.experiments.all() if e.location==loc]
                         ret.append(dum)
                     return ret
                 def get_absolute_url(self):
                     return reverse('url_campaign', args=[str(self.id)])
                 def get_absolute_url_edit(self):
                     return reverse('url_edit_campaign', args=[str(self.id)])
                 def get_absolute_url_delete(self):
                     return reverse('url_delete_campaign', args=[str(self.id)])
                 def get_absolute_url_export(self):
                     return reverse('url_export_campaign', args=[str(self.id)])
                 def get_absolute_url_import(self):
                     return reverse('url_import_campaign', args=[str(self.id)])
             class RunningExperiment(models.Model):
                 radar              = models.OneToOneField('Location', on_delete=models.CASCADE)
                 running_experiment = models.ManyToManyField('Experiment', blank = True)
                 status             = models.PositiveSmallIntegerField(default=0, choices=RADAR_STATES)
             class Experiment(models.Model):
                 template   = models.BooleanField(default=False)
                 name       = models.CharField(max_length=40, default='', unique=True)
                 location   = models.ForeignKey('Location', null=True, blank=True, on_delete=models.CASCADE)
                 freq       = models.FloatField(verbose_name='Operating Freq. (MHz)', validators=[MinValueValidator(1), MaxValueValidator(10000)], default=49.9200)
                 start_time = models.TimeField(default='00:00:00')
                 end_time   = models.TimeField(default='23:59:59')
                 task       = models.CharField(max_length=36, default='', blank=True, null=True)
                 status     = models.PositiveSmallIntegerField(default=4, choices=EXP_STATES)
                 author     = models.ForeignKey(User, null=True, blank=True,on_delete=models.CASCADE)
                 hash       = models.CharField(default='', max_length=64, null=True, blank=True)
                 class Meta:
                     db_table = 'db_experiments'
                     ordering = ('template', 'name')
                 def __str__(self):
                     if self.template:
                         return u'%s (template)' % (self.name)
                     else:
                         return u'%s' % (self.name)
                 def jsonify(self):
                     data = {}
                     ignored = ('template')
                     for field in self._meta.fields:
                         if field.name in ignored:
                             continue
                         data[field.name] = field.value_from_object(self)
                     data['start_time'] = data['start_time'].strftime('%H:%M:%S')
                     data['end_time']   = data['end_time'].strftime('%H:%M:%S')
                     data['location']   = self.location.name
                     data['configurations'] = ['{}'.format(conf.pk) for
                         conf in Configuration.objects.filter(experiment=self, type=0)]
                     return data
                 @property
                 def radar_system(self):
                     return self.location
                 def clone(self, **kwargs):
                     confs = Configuration.objects.filter(experiment=self, type=0)
                     self.pk = None
                     self.name = '{}_{:%y%m%d%H%M%S}'.format(self.name, datetime.now())
                     for attr, value in kwargs.items():
                         setattr(self, attr, value)
                     self.save()
                     for conf in confs:
                         conf.clone(experiment=self, template=False)
                     return self
                 def start(self):
                     '''
                     Configure and start experiments's devices
                     ABS-CGS-DDS-RC-JARS
                     '''
                     confs = []
                     allconfs = Configuration.objects.filter(experiment=self, type = 0).order_by('-device__device_type__sequence')
                     rc_mix   = [conf for conf in allconfs if conf.device.device_type.name=='rc' and conf.mix]
                     if rc_mix:
                         for conf in allconfs:
                             if conf.device.device_type.name == 'rc' and  not conf.mix:
                                 continue
                             confs.append(conf)
                     else:
                         confs = allconfs
                     print("confs: ",confs)
                     #try:
                     for conf in confs:
                         print("conf->",conf)
                         conf.stop_device()
                         conf.write_device()
                         conf.device.conf_active = conf.pk
                         conf.device.save()
                         conf.start_device()
                         time.sleep(1)
                     #except:
                         #return 0
                     return 2
                 def stop(self):
                     '''
                     Stop experiments's devices
                     DDS-JARS-RC-CGS-ABS
                     '''
                     confs = Configuration.objects.filter(experiment=self, type = 0).order_by('device__device_type__sequence')
                     confs = confs.exclude(device__device_type__name='cgs')
                     try:
                         for conf in confs:
                             conf.stop_device()
                     except:
                         return 0
                     return 1
                 def get_status(self):
                     if self.status == 3:
                         return
                     confs =  Configuration.objects.filter(experiment=self, type=0)
                     for conf in confs:
                         conf.status_device()
                     total = confs.aggregate(models.Sum('device__status'))['device__status__sum']
                     if total==2*confs.count():
                         status = 1
                     elif total == 3*confs.count():
                         status = 2
                     else:
                         status = 0
                     self.status = status
                     self.save()
                 def status_color(self):
                     color = 'muted'
                     if self.status == 0:
                         color = "danger"
                     elif self.status == 1:
                         color = "warning"
                     elif self.status == 2:
                         color = "success"
                     elif self.status == 3:
                         color = "info"
                     return color
                 def parms_to_dict(self):
                     params = Params({})
                     params.add(self.jsonify(), 'experiments')
                     configurations = Configuration.objects.filter(experiment=self, type=0)
                     for conf in configurations:
                         params.add(conf.jsonify(), 'configurations')
                         if conf.device.device_type.name=='rc':
                             for line in conf.get_lines():
                                 params.add(line.jsonify(), 'lines')
                     return params.data
                 def dict_to_parms(self, parms, CONF_MODELS, id_exp=None):
                     configurations = Configuration.objects.filter(experiment=self)
                     if id_exp is not None:
                         exp_parms = parms['experiments']['byId'][id_exp]
                     else:
                         exp_parms = parms['experiments']['byId'][parms['experiments']['allIds'][0]]
                     if configurations:
                         for configuration in configurations:
                             configuration.delete()
                     for id_conf in exp_parms['configurations']:
                         conf_parms = parms['configurations']['byId'][id_conf]
                         device     = Device.objects.filter(device_type__name=conf_parms['device_type'])[0]
                         model      = CONF_MODELS[conf_parms['device_type']]
                         conf = model(
                             experiment = self,
                             device = device,
                             )
                         conf.dict_to_parms(parms, id=id_conf)
                     location, created = Location.objects.get_or_create(name=exp_parms['location'])
                     self.name = '{}-{}'.format(exp_parms['name'], datetime.now().strftime('%y%m%d'))
                     self.location   = location
                     self.start_time = exp_parms['start_time']
                     self.end_time   = exp_parms['end_time']
                     self.save()
                     return self
                 def get_absolute_url(self):
                     return reverse('url_experiment', args=[str(self.id)])
                 def get_absolute_url_edit(self):
                     return reverse('url_edit_experiment', args=[str(self.id)])
                 def get_absolute_url_delete(self):
                     return reverse('url_delete_experiment', args=[str(self.id)])
                 def get_absolute_url_import(self):
                     return reverse('url_import_experiment', args=[str(self.id)])
                 def get_absolute_url_export(self):
                     return reverse('url_export_experiment', args=[str(self.id)])
                 def get_absolute_url_start(self):
                     return reverse('url_start_experiment', args=[str(self.id)])
                 def get_absolute_url_stop(self):
                     return reverse('url_stop_experiment', args=[str(self.id)])
             class Configuration(PolymorphicModel):
                 template        = models.BooleanField(default=False)
                 # name          = models.CharField(verbose_name="Configuration Name", max_length=40, default='')
                 device          = models.ForeignKey('Device', verbose_name='Device', null=True, on_delete=models.CASCADE)
                 label           = models.CharField(verbose_name="Label", max_length=40, default='', blank=True, null=True)
                 experiment      = models.ForeignKey('Experiment', verbose_name='Experiment', null=True, blank=True, on_delete=models.CASCADE)
                 type            = models.PositiveSmallIntegerField(default=0, choices=CONF_TYPES)
                 created_date    = models.DateTimeField(auto_now_add=True)
                 programmed_date = models.DateTimeField(auto_now=True)
                 parameters      = models.TextField(default='{}')
                 author          = models.ForeignKey(User, null=True, blank=True,on_delete=models.CASCADE)
                 hash            = models.CharField(default='', max_length=64, null=True, blank=True)
                 message = ""
                 class Meta:
                     db_table = 'db_configurations'
                     ordering = ('device__device_type__name',)
                 def __str__(self):
                     ret = u'{} '.format(self.device.device_type.name.upper())
                     if 'mix' in [f.name for f in self._meta.get_fields()]:
                         if self.mix:
                             ret = '{} MIX '.format(self.device.device_type.name.upper())
                     if 'label' in [f.name for f in self._meta.get_fields()]:
                         ret += '{}'.format(self.label)
                     if self.template:
                         ret += ' (template)'
                     return ret
                 @property
                 def name(self):
                     return str(self)
                 def jsonify(self):
                     data = {}
                     ignored = ('type', 'polymorphic_ctype', 'configuration_ptr',
                                'created_date', 'programmed_date', 'template', 'device',
                                'experiment')
                     for field in self._meta.fields:
                         if field.name in ignored:
                             continue
                         data[field.name] = field.value_from_object(self)
                     data['device_type'] = self.device.device_type.name
                     if self.device.device_type.name == 'rc':
                         data['lines'] = ['{}'.format(line.pk) for line in self.get_lines()]
                         data['delays'] = self.get_delays()
                         data['pulses'] = self.get_pulses()
                     elif self.device.device_type.name == 'jars':
                         data['decode_type'] = DECODE_TYPE[self.decode_data][1]
                     elif self.device.device_type.name == 'dds':
                         data['frequencyA_Mhz'] = float(data['frequencyA_Mhz'])
                         data['frequencyB_Mhz'] = float(data['frequencyB_Mhz'])
                         data['phaseA'] = dds_data.phase_to_binary(data['phaseA_degrees'])
                         data['phaseB'] = dds_data.phase_to_binary(data['phaseB_degrees'])
                     elif self.device.device_type.name == 'dds_rest':
                         data['frequencyA_Mhz'] = float(data['frequencyA_Mhz'])
                         data['frequencyB_Mhz'] = float(data['frequencyB_Mhz'])
                         data['phaseA'] = dds_data.phase_to_binary(data['phaseA_degrees'])
                         data['phaseB'] = dds_data.phase_to_binary(data['phaseB_degrees'])
                         data['delta_frequency_Mhz'] = float(data['delta_frequency_Mhz'] or 0.00)
                         data['update_clock_Mhz']    = float(data['update_clock_Mhz'] or 0.00)
                         data['ramp_rate_clock_Mhz'] = float(data['ramp_rate_clock_Mhz'] or 0.0)
                     return data
                 def clone(self, **kwargs):
                     self.pk = None
                     self.id = None
                     for attr, value in kwargs.items():
                         setattr(self, attr, value)
                     self.save()
                     return self
                 def parms_to_dict(self):
                     params = Params({})
                     params.add(self.jsonify(), 'configurations')
                     if self.device.device_type.name=='rc':
                         for line in self.get_lines():
                             params.add(line.jsonify(), 'lines')
                     return params.data
                 def parms_to_text(self):
                     raise NotImplementedError("This method should be implemented in %s Configuration model" %str(self.device.device_type.name).upper())
                 def parms_to_binary(self):
                     raise NotImplementedError("This method should be implemented in %s Configuration model" %str(self.device.device_type.name).upper())
                 def dict_to_parms(self, parameters, id=None):
                     params = Params(parameters)
                     if id:
                         data = params.get_conf(id_conf=id)
                     else:
                         data = params.get_conf(dtype=self.device.device_type.name)
                     if data['device_type']=='rc':
                         self.clean_lines()
                         lines = data.pop('lines', None)
                         for line_id in lines:
                             pass
                     for key, value in data.items():
                         if key not in ('id', 'device_type'):
                             setattr(self, key, value)
                     self.save()
                 def export_to_file(self, format="json"):
                     content_type = ''
                     if format == 'racp':
                         content_type = 'text/plain'
                         filename = '%s_%s.%s' %(self.device.device_type.name, self.name, 'racp')
                         content = self.parms_to_text(file_format = 'racp')
                     if format == 'text':
                         content_type = 'text/plain'
                         filename = '%s_%s.%s' %(self.device.device_type.name, self.name, self.device.device_type.name)
                         content = self.parms_to_text()
                     if format == 'binary':
                         content_type = 'application/octet-stream'
                         filename = '%s_%s.bin' %(self.device.device_type.name, self.name)
                         content = self.parms_to_binary()
                     if not content_type:
                         content_type = 'application/json'
                         filename = '%s_%s.json' %(self.device.device_type.name, self.name)
                         content = json.dumps(self.parms_to_dict(), indent=2)
                     fields = {'content_type':content_type,
                               'filename':filename,
                               'content':content
                               }
                     return fields
                 def import_from_file(self, fp):
                     parms = {}
                     path, ext = os.path.splitext(fp.name)
                     if ext == '.json':
                         parms = json.load(fp)
                     if ext == '.dds':
                         lines = fp.readlines()
                         parms = dds_data.text_to_dict(lines)
                     if ext == '.racp':
                         if self.device.device_type.name == 'jars':
                             parms = RacpFile(fp).to_dict()
                             parms['filter_parms'] = json.loads(self.filter_parms)
                             return parms
                         parms = RCFile(fp).to_dict()
                     return parms
                 def status_device(self):
                     self.message = 'Function not implemented'
                     return False
                 def stop_device(self):
                     self.message = 'Function not implemented'
                     return False
                 def start_device(self):
                     self.message = 'Function not implemented'
                     return False
                 def write_device(self, parms):
                     self.message = 'Function not implemented'
                     return False
                 def read_device(self):
                     self.message = 'Function not implemented'
                     return False
                 def get_absolute_url(self):
                     return reverse('url_%s_conf' % self.device.device_type.name, args=[str(self.id)])
                 def get_absolute_url_edit(self):
                     return reverse('url_edit_%s_conf' % self.device.device_type.name, args=[str(self.id)])
                 def get_absolute_url_delete(self):
                     return reverse('url_delete_dev_conf', args=[str(self.id)])
                 def get_absolute_url_import(self):
                     return reverse('url_import_dev_conf', args=[str(self.id)])
                 def get_absolute_url_export(self):
                     return reverse('url_export_dev_conf', args=[str(self.id)])
                 def get_absolute_url_write(self):
                     return reverse('url_write_dev_conf', args=[str(self.id)])
                 def get_absolute_url_read(self):
                     return reverse('url_read_dev_conf', args=[str(self.id)])
                 def get_absolute_url_start(self):
                     return reverse('url_start_dev_conf', args=[str(self.id)])
                 def get_absolute_url_stop(self):
                     return reverse('url_stop_dev_conf', args=[str(self.id)])
                 def get_absolute_url_status(self):
                     return reverse('url_status_dev_conf', args=[str(self.id)])

apps/main/views.py +4 0

             import ast
             import json
             import hashlib
             from datetime import datetime, timedelta
             from django.shortcuts import render, redirect, get_object_or_404, HttpResponse
             from django.utils.safestring import mark_safe
             from django.http import HttpResponseRedirect
             from django.urls import reverse
             from django.db.models import Q
             from django.core.paginator import Paginator, EmptyPage, PageNotAnInteger
             from django.contrib import messages
             from django.http.request import QueryDict
             from django.contrib.auth.decorators import login_required, user_passes_test
             from django.utils.timezone import is_aware
             try:
                 from urllib.parse import urlencode
             except ImportError:
                 from urllib import urlencode
             from .forms import CampaignForm, ExperimentForm, DeviceForm, ConfigurationForm, LocationForm, UploadFileForm, DownloadFileForm, OperationForm, NewForm
             from .forms import OperationSearchForm, FilterForm, ChangeIpForm
             from apps.rc.forms import RCConfigurationForm, RCLineCode, RCMixConfigurationForm
             from apps.dds.forms import DDSConfigurationForm
             from apps.jars.forms import JARSConfigurationForm
             from apps.cgs.forms import CGSConfigurationForm
             from apps.abs.forms import ABSConfigurationForm
             from apps.usrp.forms import USRPConfigurationForm
             from apps.dds_rest.forms import DDSRestConfigurationForm
+            from apps.atrad.forms import ATRADConfigurationForm
             from .utils import Params
             from .models              import Campaign, Experiment, Device, Configuration, Location, RunningExperiment, DEV_STATES
             from apps.cgs.models      import CGSConfiguration
             from apps.jars.models     import JARSConfiguration, EXPERIMENT_TYPE
             from apps.usrp.models     import USRPConfiguration
             from apps.abs.models      import ABSConfiguration
             from apps.rc.models       import RCConfiguration, RCLine, RCLineType, RCClock
             from apps.dds.models      import DDSConfiguration
             from apps.dds_rest.models import DDSRestConfiguration
+            from apps.atrad.models import ATRADConfiguration
             #from .tasks import task_start
             from radarsys.celery import app
             #comentario test
             CONF_FORMS = {
                 'rc': RCConfigurationForm,
                 'dds': DDSConfigurationForm,
                 'dds_rest': DDSRestConfigurationForm,
                 'jars': JARSConfigurationForm,
                 'cgs': CGSConfigurationForm,
                 'abs': ABSConfigurationForm,
                 'usrp': USRPConfigurationForm,
+                'atrad': ATRADConfigurationForm,
             }
             CONF_MODELS = {
                 'rc': RCConfiguration,
                 'dds': DDSConfiguration,
                 'dds_rest': DDSRestConfiguration,
                 'jars': JARSConfiguration,
                 'cgs': CGSConfiguration,
                 'abs': ABSConfiguration,
                 'usrp': USRPConfiguration,
+                'atrad': ATRADConfiguration,
             }
             MIX_MODES = {
                 '0': 'P',
                 '1': 'S',
             }
             MIX_OPERATIONS = {
                 '0': 'OR',
                 '1': 'XOR',
                 '2': 'AND',
                 '3': 'NAND',
             }
             def is_developer(user):
                 groups = [str(g.name) for g in user.groups.all()]
                 return 'Developer' in groups or user.is_staff
             def is_operator(user):
                 groups = [str(g.name) for g in user.groups.all()]
                 return 'Operator' in groups or user.is_staff
             def has_been_modified(model):
                 prev_hash = model.hash
                 new_hash = hashlib.sha256(str(model.parms_to_dict).encode()).hexdigest()
                 if prev_hash != new_hash:
                     model.hash = new_hash
                     model.save()
                     return True
                 return False
             def index(request):
                 kwargs = {'no_sidebar': True}
                 return render(request, 'index.html', kwargs)
             def locations(request):
                 page = request.GET.get('page')
                 order = ('name',)
                 kwargs = get_paginator(Location, page, order)
                 kwargs['keys'] = ['name', 'description']
                 kwargs['title'] = 'Radar System'
                 kwargs['suptitle'] = 'List'
                 kwargs['no_sidebar'] = True
                 return render(request, 'base_list.html', kwargs)
             def location(request, id_loc):
                 location = get_object_or_404(Location, pk=id_loc)
                 kwargs = {}
                 kwargs['location'] = location
                 kwargs['location_keys'] = ['name', 'description']
                 kwargs['title'] = 'Location'
                 kwargs['suptitle'] = 'Details'
                 return render(request, 'location.html', kwargs)
             @login_required
             def location_new(request):
                 if request.method == 'GET':
                     form = LocationForm()
                 if request.method == 'POST':
                     form = LocationForm(request.POST)
                     if form.is_valid():
                         form.save()
                         return redirect('url_locations')
                 kwargs = {}
                 kwargs['form'] = form
                 kwargs['title'] = 'Radar System'
                 kwargs['suptitle'] = 'New'
                 kwargs['button'] = 'Create'
                 return render(request, 'base_edit.html', kwargs)
             @login_required
             def location_edit(request, id_loc):
                 location = get_object_or_404(Location, pk=id_loc)
                 if request.method == 'GET':
                     form = LocationForm(instance=location)
                 if request.method == 'POST':
                     form = LocationForm(request.POST, instance=location)
                     if form.is_valid():
                         form.save()
                         return redirect('url_locations')
                 kwargs = {}
                 kwargs['form'] = form
                 kwargs['title'] = 'Location'
                 kwargs['suptitle'] = 'Edit'
                 kwargs['button'] = 'Update'
                 return render(request, 'base_edit.html', kwargs)
             @login_required
             def location_delete(request, id_loc):
                 location = get_object_or_404(Location, pk=id_loc)
                 if request.method == 'POST':
                     if is_developer(request.user):
                         location.delete()
                         return redirect('url_locations')
                     messages.error(request, 'Not enough permission to delete this object')
                     return redirect(location.get_absolute_url())
                 kwargs = {
                     'title': 'Delete',
                     'suptitle': 'Location',
                     'object': location,
                     'delete': True
                 }
                 return render(request, 'confirm.html', kwargs)
             def devices(request):
                 page = request.GET.get('page')
                 order = ('location', 'device_type')
                 filters = request.GET.copy()
                 kwargs = get_paginator(Device, page, order, filters)
                 form = FilterForm(initial=request.GET, extra_fields=['tags'])
                 kwargs['keys'] = ['device_type', 'location',
                                   'ip_address', 'port_address', 'actions']
                 kwargs['title'] = 'Device'
                 kwargs['suptitle'] = 'List'
                 kwargs['no_sidebar'] = True
                 kwargs['form'] = form
                 kwargs['add_url'] = reverse('url_add_device')
                 filters.pop('page', None)
                 kwargs['q'] = urlencode(filters)
                 kwargs['menu_devices'] = 'active'
                 return render(request, 'base_list.html', kwargs)
             def device(request, id_dev):
                 device = get_object_or_404(Device, pk=id_dev)
                 kwargs = {}
                 kwargs['device'] = device
                 kwargs['device_keys'] = ['device_type',
                                          'ip_address', 'port_address', 'description']
                 kwargs['title'] = 'Device'
                 kwargs['suptitle'] = 'Details'
                 kwargs['menu_devices'] = 'active'
                 return render(request, 'device.html', kwargs)
             @login_required
             def device_new(request):
                 if request.method == 'GET':
                     form = DeviceForm()
                 if request.method == 'POST':
                     form = DeviceForm(request.POST)
                     if form.is_valid():
                         form.save()
                         return redirect('url_devices')
                 kwargs = {}
                 kwargs['form'] = form
                 kwargs['title'] = 'Device'
                 kwargs['suptitle'] = 'New_2'
                 kwargs['button'] = 'Create'
                 kwargs['menu_devices'] = 'active'
                 return render(request, 'base_edit.html', kwargs)
             @login_required
             def device_edit(request, id_dev):
                 device = get_object_or_404(Device, pk=id_dev)
                 if request.method == 'GET':
                     form = DeviceForm(instance=device)
                 if request.method == 'POST':
                     form = DeviceForm(request.POST, instance=device)
                     if form.is_valid():
                         form.save()
                         return redirect(device.get_absolute_url())
                 kwargs = {}
                 kwargs['form'] = form
                 kwargs['title'] = 'Device'
                 kwargs['suptitle'] = 'Edit'
                 kwargs['button'] = 'Update'
                 kwargs['menu_devices'] = 'active'
                 return render(request, 'base_edit.html', kwargs)
             @login_required
             def device_delete(request, id_dev):
                 device = get_object_or_404(Device, pk=id_dev)
                 if request.method == 'POST':
                     if is_developer(request.user):
                         device.delete()
                         return redirect('url_devices')
                     messages.error(request, 'Not enough permission to delete this object')
                     return redirect(device.get_absolute_url())
                 kwargs = {
                     'title': 'Delete',
                     'suptitle': 'Device',
                     'object': device,
                     'delete': True
                 }
                 kwargs['menu_devices'] = 'active'
                 return render(request, 'confirm.html', kwargs)
             @login_required
             def device_change_ip(request, id_dev):
                 device = get_object_or_404(Device, pk=id_dev)
                 if request.method == 'POST':
                     if is_developer(request.user):
                         device.change_ip(**request.POST.dict())
                         print(device.ip_address, device.message)
                         level, message = device.message.split('|')
                         messages.add_message(request, level, message)
                     else:
                         messages.error(
                             request, 'Not enough permission to delete this object')
                     return redirect(device.get_absolute_url())
                 kwargs = {
                     'title': 'Device',
                     'suptitle': 'Change IP',
                     'object': device,
                     'previous': device.get_absolute_url(),
                     'form': ChangeIpForm(initial={'ip_address': device.ip_address}),
                     'message': ' ',
                 }
                 kwargs['menu_devices'] = 'active'
                 return render(request, 'confirm.html', kwargs)
             def campaigns(request):
                 page = request.GET.get('page')
                 order = ('-start_date',)
                 filters = request.GET.copy()
                 kwargs = get_paginator(Campaign, page, order, filters)
                 form = FilterForm(initial=request.GET, extra_fields=[
                                   'range_date', 'tags', 'template'])
                 kwargs['keys'] = ['name', 'start_date', 'end_date', 'actions']
                 kwargs['title'] = 'Campaign'
                 kwargs['suptitle'] = 'List'
                 kwargs['no_sidebar'] = True
                 kwargs['form'] = form
                 kwargs['add_url'] = reverse('url_add_campaign')
                 filters.pop('page', None)
                 kwargs['q'] = urlencode(filters)
                 kwargs['menu_campaigns'] = 'active'
                 return render(request, 'base_list.html', kwargs)
             def campaign(request, id_camp):
                 campaign = get_object_or_404(Campaign, pk=id_camp)
                 experiments = Experiment.objects.filter(campaign=campaign)
                 form = CampaignForm(instance=campaign)
                 kwargs = {}
                 kwargs['campaign'] = campaign
                 kwargs['campaign_keys'] = ['template', 'name',
                                            'start_date', 'end_date', 'tags', 'description']
                 kwargs['experiments'] = experiments
                 kwargs['experiment_keys'] = [
                     'name', 'radar_system', 'start_time', 'end_time']
                 kwargs['title'] = 'Campaign'
                 kwargs['suptitle'] = 'Details'
                 kwargs['form'] = form
                 kwargs['button'] = 'Add Experiment'
                 kwargs['menu_campaigns'] = 'active'
                 return render(request, 'campaign.html', kwargs)
             @login_required
             def campaign_new(request):
                 kwargs = {}
                 if request.method == 'GET':
                     if 'template' in request.GET:
                         if request.GET['template'] == '0':
                             form = NewForm(initial={'create_from': 2},
                                            template_choices=Campaign.objects.filter(template=True).values_list('id', 'name'))
                         else:
                             kwargs['button'] = 'Create'
                             kwargs['experiments'] = Configuration.objects.filter(
                                 experiment=request.GET['template'])
                             kwargs['experiment_keys'] = ['name', 'start_time', 'end_time']
                             camp = Campaign.objects.get(pk=request.GET['template'])
                             form = CampaignForm(instance=camp,
                                                 initial={'name': '{}_{:%Y%m%d%H%M%S}'.format(camp.name, datetime.now()),
                                                          'template': False})
                     elif 'blank' in request.GET:
                         kwargs['button'] = 'Create'
                         form = CampaignForm()
                     else:
                         form = NewForm()
                 if request.method == 'POST':
                     kwargs['button'] = 'Create'
                     post = request.POST.copy()
                     experiments = []
                     for id_exp in post.getlist('experiments'):
                         exp = Experiment.objects.get(pk=id_exp)
                         new_exp = exp.clone(template=False)
                         experiments.append(new_exp)
                     post.setlist('experiments', [])
                     form = CampaignForm(post)
                     if form.is_valid():
                         campaign = form.save(commit=False)
                         campaign.author = request.user
                         campaign.save()
                         for exp in experiments:
                             campaign.experiments.add(exp)
                         return redirect('url_campaign', id_camp=campaign.id)
                 kwargs['form']           = form
                 kwargs['title']          = 'Campaign'
                 kwargs['suptitle']       = 'New'
                 kwargs['menu_campaigns'] = 'active'
                 return render(request, 'campaign_edit.html', kwargs)
             @login_required
             def campaign_edit(request, id_camp):
                 campaign = get_object_or_404(Campaign, pk=id_camp)
                 if request.method == 'GET':
                     form = CampaignForm(instance=campaign)
                 if request.method == 'POST':
                     exps     = campaign.experiments.all().values_list('pk', flat=True)
                     post     = request.POST.copy()
                     new_exps = post.getlist('experiments')
                     post.setlist('experiments', [])
                     form     = CampaignForm(post, instance=campaign)
                     if form.is_valid():
                         camp = form.save()
                         for id_exp in new_exps:
                             if int(id_exp) in exps:
                                 exps.pop(id_exp)
                             else:
                                 exp = Experiment.objects.get(pk=id_exp)
                                 if exp.template:
                                     camp.experiments.add(exp.clone(template=False))
                                 else:
                                     camp.experiments.add(exp)
                         for id_exp in exps:
                             camp.experiments.remove(Experiment.objects.get(pk=id_exp))
                         return redirect('url_campaign', id_camp=id_camp)
                 kwargs                   = {}
                 kwargs['form']           = form
                 kwargs['title']          = 'Campaign'
                 kwargs['suptitle']       = 'Edit'
                 kwargs['button']         = 'Update'
                 kwargs['menu_campaigns'] = 'active'
                 return render(request, 'campaign_edit.html', kwargs)
             @login_required
             def campaign_delete(request, id_camp):
                 campaign = get_object_or_404(Campaign, pk=id_camp)
                 if request.method == 'POST':
                     if is_developer(request.user):
                         for exp in campaign.experiments.all():
                             for conf in Configuration.objects.filter(experiment=exp):
                                 conf.delete()
                             exp.delete()
                         campaign.delete()
                         return redirect('url_campaigns')
                     messages.error(request, 'Not enough permission to delete this object')
                     return redirect(campaign.get_absolute_url())
                 kwargs = {
                     'title': 'Delete',
                     'suptitle': 'Campaign',
                     'object': campaign,
                     'delete': True
                 }
                 kwargs['menu_campaigns'] = 'active'
                 return render(request, 'confirm.html', kwargs)
             @login_required
             def campaign_export(request, id_camp):
                 campaign = get_object_or_404(Campaign, pk=id_camp)
                 content = campaign.parms_to_dict()
                 content_type = 'application/json'
                 filename = '%s_%s.json' % (campaign.name, campaign.id)
                 response = HttpResponse(content_type=content_type)
                 response['Content-Disposition'] = 'attachment; filename="%s"' % filename
                 response.write(json.dumps(content, indent=2))
                 return response
             @login_required
             def campaign_import(request, id_camp):
                 campaign = get_object_or_404(Campaign, pk=id_camp)
                 if request.method == 'GET':
                     file_form = UploadFileForm()
                 if request.method == 'POST':
                     file_form = UploadFileForm(request.POST, request.FILES)
                     if file_form.is_valid():
                         new_camp = campaign.dict_to_parms(
                             json.load(request.FILES['file']), CONF_MODELS)
                         messages.success(
                             request, "Parameters imported from: '%s'." % request.FILES['file'].name)
                         return redirect(new_camp.get_absolute_url_edit())
                     messages.error(request, "Could not import parameters from file")
                 kwargs = {}
                 kwargs['title'] = 'Campaign'
                 kwargs['form'] = file_form
                 kwargs['suptitle'] = 'Importing file'
                 kwargs['button'] = 'Import'
                 kwargs['menu_campaigns'] = 'active'
                 return render(request, 'campaign_import.html', kwargs)
             def experiments(request):
                 page = request.GET.get('page')
                 order = ('location',)
                 filters = request.GET.copy()
                 if 'my experiments' in filters:
                     filters.pop('my experiments', None)
                     filters['mine'] = request.user.id
                 kwargs = get_paginator(Experiment, page, order, filters)
                 fields = ['tags', 'template']
                 if request.user.is_authenticated:
                     fields.append('my experiments')
                 form = FilterForm(initial=request.GET, extra_fields=fields)
                 kwargs['keys'] = ['name', 'radar_system',
                                   'start_time', 'end_time', 'actions']
                 kwargs['title'] = 'Experiment'
                 kwargs['suptitle'] = 'List'
                 kwargs['no_sidebar'] = True
                 kwargs['form'] = form
                 kwargs['add_url'] = reverse('url_add_experiment')
                 filters = request.GET.copy()
                 filters.pop('page', None)
                 kwargs['q'] = urlencode(filters)
                 kwargs['menu_experiments'] = 'active'
                 return render(request, 'base_list.html', kwargs)
             def experiment(request, id_exp):
                 experiment = get_object_or_404(Experiment, pk=id_exp)
                 configurations = Configuration.objects.filter(
                     experiment=experiment, type=0)
                 kwargs = {}
                 kwargs['experiment_keys'] = ['template', 'radar_system',
                                              'name', 'freq', 'start_time', 'end_time']
                 kwargs['experiment'] = experiment
                 kwargs['configuration_keys'] = ['name', 'device__ip_address',
                                                 'device__port_address', 'device__status']
                 kwargs['configurations'] = configurations
                 kwargs['title'] = 'Experiment'
                 kwargs['suptitle'] = 'Details'
                 kwargs['button'] = 'Add Configuration'
                 kwargs['menu_experiments'] = 'active'
                 ###### SIDEBAR ######
                 kwargs.update(sidebar(experiment=experiment))
                 return render(request, 'experiment.html', kwargs)
             @login_required
             def experiment_new(request, id_camp=None):
                 if not is_developer(request.user):
                     messages.error(
                         request, 'Developer required, to create new Experiments')
                     return redirect('index')
                 kwargs = {}
                 if request.method == 'GET':
                     if 'template' in request.GET:
                         if request.GET['template'] == '0':
                             form = NewForm(initial={'create_from': 2},
                                            template_choices=Experiment.objects.filter(template=True).values_list('id', 'name'))
                         else:
                             kwargs['button'] = 'Create'
                             kwargs['configurations'] = Configuration.objects.filter(
                                 experiment=request.GET['template'])
                             kwargs['configuration_keys'] = ['name', 'device__name',
                                                             'device__ip_address', 'device__port_address']
                             exp = Experiment.objects.get(pk=request.GET['template'])
                             form = ExperimentForm(instance=exp,
                                                   initial={'name': '{}_{:%y%m%d}'.format(exp.name, datetime.now()),
                                                            'template': False})
                     elif 'blank' in request.GET:
                         kwargs['button'] = 'Create'
                         form = ExperimentForm()
                     else:
                         form = NewForm()
                 if request.method == 'POST':
                     form = ExperimentForm(request.POST)
                     if form.is_valid():
                         experiment = form.save(commit=False)
                         experiment.author = request.user
                         experiment.save()
                         if 'template' in request.GET:
                             configurations = Configuration.objects.filter(
                                 experiment=request.GET['template'], type=0)
                             for conf in configurations:
                                 conf.clone(experiment=experiment, template=False)
                         return redirect('url_experiment', id_exp=experiment.id)
                 kwargs['form'] = form
                 kwargs['title'] = 'Experiment'
                 kwargs['suptitle'] = 'New'
                 kwargs['menu_experiments'] = 'active'
                 return render(request, 'experiment_edit.html', kwargs)
             @login_required
             def experiment_edit(request, id_exp):
                 experiment = get_object_or_404(Experiment, pk=id_exp)
                 if request.method == 'GET':
                     form = ExperimentForm(instance=experiment)
                 if request.method == 'POST':
                     form = ExperimentForm(request.POST, instance=experiment)
                     if form.is_valid():
                         experiment = form.save()
                         return redirect('url_experiment', id_exp=experiment.id)
                 kwargs                     = {}
                 kwargs['form']             = form
                 kwargs['title']            = 'Experiment'
                 kwargs['suptitle']         = 'Edit'
                 kwargs['button']           = 'Update'
                 kwargs['menu_experiments'] = 'active'
                 return render(request, 'experiment_edit.html', kwargs)
             @login_required
             def experiment_delete(request, id_exp):
                 experiment = get_object_or_404(Experiment, pk=id_exp)
                 if request.method == 'POST':
                     if is_developer(request.user):
                         for conf in Configuration.objects.filter(experiment=experiment):
                             conf.delete()
                         experiment.delete()
                         return redirect('url_experiments')
                     messages.error(request, 'Not enough permission to delete this object')
                     return redirect(experiment.get_absolute_url())
                 kwargs = {
                     'title': 'Delete',
                     'suptitle': 'Experiment',
                     'object': experiment,
                     'delete': True
                 }
                 return render(request, 'confirm.html', kwargs)
             @login_required
             def experiment_export(request, id_exp):
                 experiment = get_object_or_404(Experiment, pk=id_exp)
                 content = experiment.parms_to_dict()
                 content_type = 'application/json'
                 filename = '%s_%s.json' % (experiment.name, experiment.id)
                 response = HttpResponse(content_type=content_type)
                 response['Content-Disposition'] = 'attachment; filename="%s"' % filename
                 response.write(json.dumps(content, indent=2))
                 return response
             @login_required
             def experiment_import(request, id_exp):
                 experiment = get_object_or_404(Experiment, pk=id_exp)
                 configurations = Configuration.objects.filter(experiment=experiment)
                 if request.method == 'GET':
                     file_form = UploadFileForm()
                 if request.method == 'POST':
                     file_form = UploadFileForm(request.POST, request.FILES)
                     if file_form.is_valid():
                         new_exp = experiment.dict_to_parms(
                             json.load(request.FILES['file']), CONF_MODELS)
                         messages.success(
                             request, "Parameters imported from: '%s'." % request.FILES['file'].name)
                         return redirect(new_exp.get_absolute_url_edit())
                     messages.error(request, "Could not import parameters from file")
                 kwargs = {}
                 kwargs['title'] = 'Experiment'
                 kwargs['form'] = file_form
                 kwargs['suptitle'] = 'Importing file'
                 kwargs['button'] = 'Import'
                 kwargs['menu_experiments'] = 'active'
                 kwargs.update(sidebar(experiment=experiment))
                 return render(request, 'experiment_import.html', kwargs)
             @login_required
             def experiment_start(request, id_exp):
                 exp = get_object_or_404(Experiment, pk=id_exp)
                 if exp.status == 2:
                     messages.warning(request, 'Experiment {} already runnnig'.format(exp))
                 else:
                     exp.status = exp.start()
                     if exp.status == 0:
                         messages.error(request, 'Experiment {} not start'.format(exp))
                     if exp.status == 2:
                         messages.success(request, 'Experiment {} started'.format(exp))
                     exp.save()
                 return redirect(exp.get_absolute_url())
             @login_required
             def experiment_stop(request, id_exp):
                 exp = get_object_or_404(Experiment, pk=id_exp)
                 if exp.status == 2:
                     exp.status = exp.stop()
                     exp.save()
                     messages.success(request, 'Experiment {} stopped'.format(exp))
                 else:
                     messages.error(request, 'Experiment {} not running'.format(exp))
                 return redirect(exp.get_absolute_url())
             def experiment_status(request, id_exp):
                 exp = get_object_or_404(Experiment, pk=id_exp)
                 exp.get_status()
                 return redirect(exp.get_absolute_url())
             @login_required
             def experiment_mix(request, id_exp):
                 experiment = get_object_or_404(Experiment, pk=id_exp)
                 rc_confs = [conf for conf in RCConfiguration.objects.filter(
                     experiment=id_exp,
                     type=0,
                     mix=False)]
                 if len(rc_confs) < 2:
                     messages.warning(
                         request, 'You need at least two RC Configurations to make a mix')
                     return redirect(experiment.get_absolute_url())
                 mix_confs = RCConfiguration.objects.filter(experiment=id_exp, mix=True, type=0)
                 if mix_confs:
                     mix = mix_confs[0]
                 else:
                     mix = RCConfiguration(experiment=experiment,
                                           device=rc_confs[0].device,
                                           ipp=rc_confs[0].ipp,
                                           clock_in=rc_confs[0].clock_in,
                                           clock_divider=rc_confs[0].clock_divider,
                                           mix=True,
                                           parameters='')
                     mix.save()
                     line_type = RCLineType.objects.get(name='mix')
                     print("VIew obteniendo len getlines")
                     print(len(rc_confs[0].get_lines()))
                     for i in range(len(rc_confs[0].get_lines())):
                         line = RCLine(rc_configuration=mix, line_type=line_type, channel=i)
                         line.save()
                 initial = {'name': mix.name,
                            'result': parse_mix_result(mix.parameters),
                            'delay': 0,
                            'mask': [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15]
                            }
                 if request.method == 'GET':
                     form = RCMixConfigurationForm(confs=rc_confs, initial=initial)
                 if request.method == 'POST':
                     result = mix.parameters
                     if '{}|'.format(request.POST['experiment']) in result:
                         messages.error(request, 'Configuration already added')
                     else:
                         if 'operation' in request.POST:
                             operation = MIX_OPERATIONS[request.POST['operation']]
                         else:
                             operation = '   '
                         mode = MIX_MODES[request.POST['mode']]
                         if result:
                             result = '{}-{}|{}|{}|{}|{}'.format(mix.parameters,
                                                                 request.POST['experiment'],
                                                                 mode,
                                                                 operation,
                                                                 float(
                                                                     request.POST['delay']),
                                                                 parse_mask(
                                                                     request.POST.getlist('mask'))
                                                                 )
                         else:
                             result = '{}|{}|{}|{}|{}'.format(request.POST['experiment'],
                                                              mode,
                                                              operation,
                                                              float(request.POST['delay']),
                                                              parse_mask(
                                                                  request.POST.getlist('mask'))
                                                              )
                         mix.parameters = result
                         mix.save()
                         mix.update_pulses()
                     initial['result'] = parse_mix_result(result)
                     initial['name'] = mix.name
                     form = RCMixConfigurationForm(initial=initial, confs=rc_confs)
                 kwargs = {
                     'title': 'Experiment',
                     'suptitle': 'Mix Configurations',
                     'form': form,
                     'extra_button': 'Delete',
                     'button': 'Add',
                     'cancel': 'Back',
                     'previous': experiment.get_absolute_url(),
                     'id_exp': id_exp,
                 }
                 kwargs['menu_experiments'] = 'active'
                 return render(request, 'experiment_mix.html', kwargs)
             @login_required
             def experiment_mix_delete(request, id_exp):
                 conf = RCConfiguration.objects.get(experiment=id_exp, mix=True, type=0)
                 values = conf.parameters.split('-')
                 conf.parameters = '-'.join(values[:-1])
                 conf.save()
                 return redirect('url_mix_experiment', id_exp=id_exp)
             def experiment_summary(request, id_exp):
                 experiment = get_object_or_404(Experiment, pk=id_exp)
                 configurations = Configuration.objects.filter(
                     experiment=experiment, type=0)
                 kwargs = {}
                 kwargs['experiment_keys'] = ['radar_system',
                                              'name', 'freq', 'start_time', 'end_time']
                 kwargs['experiment'] = experiment
                 kwargs['configurations'] = []
                 kwargs['title'] = 'Experiment Summary'
                 kwargs['suptitle'] = 'Details'
                 kwargs['button'] = 'Verify Parameters'
                 c_vel = 3.0*(10**8)  # m/s
                 ope_freq = experiment.freq*(10**6)  # 1/s
                 radar_lambda = c_vel/ope_freq  # m
                 kwargs['radar_lambda'] = radar_lambda
                 ipp = None
                 nsa = 1
                 code_id = 0
                 tx_line = {}
                 for configuration in configurations.filter(device__device_type__name = 'rc'):
                     if configuration.mix:
                         continue
                     conf = {'conf': configuration}
                     conf['keys'] = []
                     conf['NTxs'] = configuration.ntx
                     conf['keys'].append('NTxs')
                     ipp = configuration.ipp
                     conf['IPP'] = ipp
                     conf['keys'].append('IPP')
                     lines = configuration.get_lines(line_type__name='tx')
                     for tx_line in lines:
                         tx_params = json.loads(tx_line.params)
                         conf[tx_line.get_name()] = '{} Km'.format(tx_params['pulse_width'])
                         conf['keys'].append(tx_line.get_name())
                         delays = tx_params['delays']
                         if delays not in ('', '0'):
                             n = len(delays.split(','))
                             taus = '{} Taus: {}'.format(n, delays)
                         else:
                             taus = '-'
                         conf['Taus ({})'.format(tx_line.get_name())] = taus
                         conf['keys'].append('Taus ({})'.format(tx_line.get_name()))
                         for code_line in configuration.get_lines(line_type__name='codes'):
                             code_params = json.loads(code_line.params)
                             code_id = code_params['code']
                             if tx_line.pk == int(code_params['TX_ref']):
                                 conf['Code ({})'.format(tx_line.get_name())] = '{}:{}'.format(RCLineCode.objects.get(pk=code_params['code']),
                                                                 '-'.join(code_params['codes']))
                                 conf['keys'].append('Code ({})'.format(tx_line.get_name()))
                         for windows_line in configuration.get_lines(line_type__name='windows'):
                             win_params = json.loads(windows_line.params)
                             if tx_line.pk == int(win_params['TX_ref']):
                                 windows = ''
                                 nsa = win_params['params'][0]['number_of_samples']
                                 for i, params in enumerate(win_params['params']):
                                     windows += 'W{}: Ho={first_height} km DH={resolution} km NSA={number_of_samples}<br>'.format(
                                         i, **params)
                                 conf['Window'] = mark_safe(windows)
                                 conf['keys'].append('Window')
                     kwargs['configurations'].append(conf)
                 for configuration in configurations.filter(device__device_type__name = 'jars'):
                     conf = {'conf': configuration}
                     conf['keys'] = []
                     conf['Type of Data'] = EXPERIMENT_TYPE[configuration.exp_type][1]
                     conf['keys'].append('Type of Data')
                     channels_number = configuration.channels_number
                     exp_type = configuration.exp_type
                     fftpoints = configuration.fftpoints
                     filter_parms = json.loads(configuration.filter_parms)
                     spectral_number = configuration.spectral_number
                     acq_profiles = configuration.acq_profiles
                     cohe_integr = configuration.cohe_integr
                     profiles_block = configuration.profiles_block
                     conf['Num of Profiles'] = acq_profiles
                     conf['keys'].append('Num of Profiles')
                     conf['Prof per Block'] = profiles_block
                     conf['keys'].append('Prof per Block')
                     conf['Blocks per File'] = configuration.raw_data_blocks
                     conf['keys'].append('Blocks per File')
                     if exp_type == 0:  # Short
                         bytes_ = 2
                         b = nsa*2*bytes_*channels_number
                     else:  # Float
                         bytes_ = 4
                         channels = channels_number + spectral_number
                         b = nsa*2*bytes_*fftpoints*channels
                     codes_num = 7
                     if code_id == 2:
                         codes_num = 7
                     elif code_id == 12:
                         codes_num = 15
                     #Jars filter values:
                     clock = float(filter_parms['clock'])
                     filter_2 = int(filter_parms['cic_2'])
                     filter_5 = int(filter_parms['cic_5'])
                     filter_fir = int(filter_parms['fir'])
                     Fs_MHz = clock/(filter_2*filter_5*filter_fir)
                     #Jars values:
                     if ipp is not None:
                         IPP_units = ipp/0.15*Fs_MHz
                         IPP_us = IPP_units / Fs_MHz
                         IPP_s = IPP_units / (Fs_MHz * (10**6))
                         Ts = 1/(Fs_MHz*(10**6))
                         Va = radar_lambda/(4*Ts*cohe_integr)
                         rate_bh = ((nsa-codes_num)*channels_number*2 *
                                     bytes_/IPP_us)*(36*(10**8)/cohe_integr)
                         rate_gh = rate_bh/(1024*1024*1024)
                         conf['Time per Block'] = IPP_s * profiles_block * cohe_integr
                         conf['keys'].append('Time per Block')
                         conf['Acq time'] = IPP_s * acq_profiles
                         conf['keys'].append('Acq time')
                         conf['Data rate'] = str(rate_gh)+" (GB/h)"
                         conf['keys'].append('Data rate')
                         conf['Va (m/s)'] = Va
                         conf['keys'].append('Va (m/s)')
                         conf['Vrange (m/s)'] = 3/(2*IPP_s*cohe_integr)
                         conf['keys'].append('Vrange (m/s)')
                     kwargs['configurations'].append(conf)
                 kwargs['menu_experiments'] = 'active'
                 ###### SIDEBAR ######
                 kwargs.update(sidebar(experiment=experiment))
                 return render(request, 'experiment_summary.html', kwargs)
             @login_required
             def experiment_verify(request, id_exp):
                 experiment = get_object_or_404(Experiment, pk=id_exp)
                 experiment_data = experiment.parms_to_dict()
                 configurations = Configuration.objects.filter(
                     experiment=experiment, type=0)
                 kwargs = {}
                 kwargs['experiment_keys'] = ['template',
                                              'radar_system', 'name', 'start_time', 'end_time']
                 kwargs['experiment'] = experiment
                 kwargs['configuration_keys'] = ['name', 'device__ip_address',
                                                 'device__port_address', 'device__status']
                 kwargs['configurations'] = configurations
                 kwargs['experiment_data'] = experiment_data
                 kwargs['title'] = 'Verify Experiment'
                 kwargs['suptitle'] = 'Parameters'
                 kwargs['button'] = 'Update'
                 jars_conf = False
                 rc_conf = False
                 dds_conf = False
                 for configuration in configurations:
                     #-------------------- JARS -----------------------:
                     if configuration.device.device_type.name == 'jars':
                         jars_conf = True
                         jars = configuration
                         kwargs['jars_conf'] = jars_conf
                         filter_parms = json.loads(jars.filter_parms)
                         kwargs['filter_parms'] = filter_parms
                         #--Sampling Frequency
                         clock = filter_parms['clock']
                         filter_2 = filter_parms['cic_2']
                         filter_5 = filter_parms['cic_5']
                         filter_fir = filter_parms['fir']
                         samp_freq_jars = clock/filter_2/filter_5/filter_fir
                         kwargs['samp_freq_jars'] = samp_freq_jars
                         kwargs['jars'] = configuration
                     #--------------------- RC ----------------------:
                     if configuration.device.device_type.name == 'rc' and not configuration.mix:
                         rc_conf = True
                         rc = configuration
                         rc_parms = configuration.parms_to_dict()
                         win_lines = rc.get_lines(line_type__name='windows')
                         if win_lines:
                             dh = json.loads(win_lines[0].params)['params'][0]['resolution']
                             #--Sampling Frequency
                             samp_freq_rc = 0.15/dh
                             kwargs['samp_freq_rc'] = samp_freq_rc
                             kwargs['rc_conf'] = rc_conf
                             kwargs['rc'] = configuration
                     #-------------------- DDS ----------------------:
                     if configuration.device.device_type.name == 'dds':
                         dds_conf = True
                         dds = configuration
                         dds_parms = configuration.parms_to_dict()
                         kwargs['dds_conf'] = dds_conf
                         kwargs['dds'] = configuration
                 #------------Validation------------:
                 #Clock
                 if dds_conf and rc_conf and jars_conf:
                     if float(filter_parms['clock']) != float(rc_parms['configurations']['byId'][str(rc.pk)]['clock_in']) and float(rc_parms['configurations']['byId'][str(rc.pk)]['clock_in']) != float(dds_parms['configurations']['byId'][str(dds.pk)]['clock']):
                         messages.warning(request, "Devices don't have the same clock.")
                 elif rc_conf and jars_conf:
                     if float(filter_parms['clock']) != float(rc_parms['configurations']['byId'][str(rc.pk)]['clock_in']):
                         messages.warning(request, "Devices don't have the same clock.")
                 elif rc_conf and dds_conf:
                     if float(rc_parms['configurations']['byId'][str(rc.pk)]['clock_in']) != float(dds_parms['configurations']['byId'][str(dds.pk)]['clock']):
                         messages.warning(request, "Devices don't have the same clock.")
                     if float(samp_freq_rc) != float(dds_parms['configurations']['byId'][str(dds.pk)]['frequencyA']):
                         messages.warning(
                             request, "Devices don't have the same Frequency A.")
                 #------------POST METHOD------------:
                 if request.method == 'POST':
                     if request.POST['suggest_clock']:
                         try:
                             suggest_clock = float(request.POST['suggest_clock'])
                         except:
                             messages.warning(request, "Invalid value in CLOCK IN.")
                             return redirect('url_verify_experiment', id_exp=experiment.id)
                     else:
                         suggest_clock = ""
                     if suggest_clock:
                         if rc_conf:
                             rc.clock_in = suggest_clock
                             rc.save()
                         if jars_conf:
                             filter_parms = jars.filter_parms
                             filter_parms = ast.literal_eval(filter_parms)
                             filter_parms['clock'] = suggest_clock
                             jars.filter_parms = json.dumps(filter_parms)
                             jars.save()
                             kwargs['filter_parms'] = filter_parms
                         if dds_conf:
                             dds.clock = suggest_clock
                             dds.save()
                     if request.POST['suggest_frequencyA']:
                         try:
                             suggest_frequencyA = float(request.POST['suggest_frequencyA'])
                         except:
                             messages.warning(request, "Invalid value in FREQUENCY A.")
                             return redirect('url_verify_experiment', id_exp=experiment.id)
                     else:
                         suggest_frequencyA = ""
                     if suggest_frequencyA:
                         if jars_conf:
                             filter_parms = jars.filter_parms
                             filter_parms = ast.literal_eval(filter_parms)
                             filter_parms['fch'] = suggest_frequencyA
                             jars.filter_parms = json.dumps(filter_parms)
                             jars.save()
                             kwargs['filter_parms'] = filter_parms
                         if dds_conf:
                             dds.frequencyA_Mhz = request.POST['suggest_frequencyA']
                             dds.save()
                 kwargs['menu_experiments'] = 'active'
                 kwargs.update(sidebar(experiment=experiment))
                 return render(request, 'experiment_verify.html', kwargs)
             def parse_mix_result(s):
                 values = s.split('-')
                 html = 'EXP                MOD OPE DELAY         MASK\r\n'
                 if not values or values[0] in ('', ' '):
                     return mark_safe(html)
                 for i, value in enumerate(values):
                     if not value:
                         continue
                     pk, mode, operation, delay, mask = value.split('|')
                     conf = RCConfiguration.objects.get(pk=pk)
                     if i == 0:
                         html += '{:20.18}{:3}{:4}{:9}km{:>6}\r\n'.format(
                             conf.name,
                             mode,
                             '   ',
                             delay,
                             mask)
                     else:
                         html += '{:20.18}{:3}{:4}{:9}km{:>6}\r\n'.format(
                             conf.name,
                             mode,
                             operation,
                             delay,
                             mask)
                 return mark_safe(html)
             def parse_mask(l):
                 values = []
                 for x in range(16):
                     if '{}'.format(x) in l:
                         values.append(1)
                     else:
                         values.append(0)
                 values.reverse()
                 return int(''.join([str(x) for x in values]), 2)
             def dev_confs(request):
                 page = request.GET.get('page')
                 order = ('-programmed_date', )
                 filters = request.GET.copy()
                 if 'my configurations' in filters:
                     filters.pop('my configurations', None)
                     filters['mine'] = request.user.id
                 kwargs = get_paginator(Configuration, page, order, filters)
                 fields = ['tags', 'template', 'historical']
                 if request.user.is_authenticated:
                     fields.append('my configurations')
                 form = FilterForm(initial=request.GET, extra_fields=fields)
                 kwargs['keys'] = ['name', 'experiment',
                                   'type', 'programmed_date', 'actions']
                 kwargs['title'] = 'Configuration'
                 kwargs['suptitle'] = 'List'
                 kwargs['no_sidebar'] = True
                 kwargs['form'] = form
                 kwargs['add_url'] = reverse('url_add_dev_conf', args=[0])
                 filters = request.GET.copy()
                 filters.pop('page', None)
                 kwargs['q'] = urlencode(filters)
                 kwargs['menu_configurations'] = 'active'
                 return render(request, 'base_list.html', kwargs)
             def dev_conf(request, id_conf):
                 conf = get_object_or_404(Configuration, pk=id_conf)
                 return redirect(conf.get_absolute_url())
             @login_required
             def dev_conf_new(request, id_exp=0, id_dev=0):
                 if not is_developer(request.user):
                     messages.error(
                         request, 'Developer required, to create new configurations')
                     return redirect('index')
                 initial = {}
                 kwargs = {}
                 if id_exp != 0:
                     initial['experiment'] = id_exp
                 if id_dev != 0:
                     initial['device'] = id_dev
                 if request.method == 'GET':
                     if id_dev:
                         kwargs['button'] = 'Create'
                         device = Device.objects.get(pk=id_dev)
                         DevConfForm = CONF_FORMS[device.device_type.name]
                         initial['name'] = request.GET['name']
                         form = DevConfForm(initial=initial)
                     else:
                         if 'template' in request.GET:
                             if request.GET['template'] == '0':
                                 choices = [(conf.pk, '{}'.format(conf))
                                            for conf in Configuration.objects.filter(template=True)]
                                 form = NewForm(initial={'create_from': 2},
                                                template_choices=choices)
                             else:
                                 kwargs['button'] = 'Create'
                                 conf = Configuration.objects.get(
                                     pk=request.GET['template'])
                                 id_dev = conf.device.pk
                                 DevConfForm = CONF_FORMS[conf.device.device_type.name]
                                 form = DevConfForm(instance=conf,
                                                    initial={'name': '{}_{:%y%m%d}'.format(conf.name, datetime.now()),
                                                             'template': False,
                                                             'experiment': id_exp})
                         elif 'blank' in request.GET:
                             kwargs['button'] = 'Create'
                             form = ConfigurationForm(initial=initial)
                         else:
                             form = NewForm()
                 if request.method == 'POST':
                     device = Device.objects.get(pk=request.POST['device'])
                     DevConfForm = CONF_FORMS[device.device_type.name]
                     form = DevConfForm(request.POST)
                     kwargs['button'] = 'Create'
                     if form.is_valid():
                         conf = form.save(commit=False)
                         conf.author = request.user
                         conf.save()
                         if 'template' in request.GET and conf.device.device_type.name == 'rc':
                             lines = RCLine.objects.filter(
                                 rc_configuration=request.GET['template'])
                             for line in lines:
                                 line.clone(rc_configuration=conf)
                             new_lines = conf.get_lines()
                             for line in new_lines:
                                 line_params = json.loads(line.params)
                                 if 'TX_ref' in line_params:
                                     ref_line = RCLine.objects.get(pk=line_params['TX_ref'])
                                     line_params['TX_ref'] = ['{}'.format(
                                         l.pk) for l in new_lines if l.get_name() == ref_line.get_name()][0]
                                     line.params = json.dumps(line_params)
                                     line.save()
                         elif conf.device.device_type.name == 'rc':
                             clk = RCClock(rc_configuration=conf)
                             clk.save()
                         return redirect('url_dev_conf', id_conf=conf.pk)
                 kwargs['id_exp'] = id_exp
                 kwargs['form'] = form
                 kwargs['title'] = 'Configuration'
                 kwargs['suptitle'] = 'New'
                 kwargs['menu_configurations'] = 'active'
                 if id_dev != 0:
                     device = Device.objects.get(pk=id_dev)
                     kwargs['device'] = device.device_type.name
                 print(id_exp)
                 return render(request, 'dev_conf_edit.html', kwargs)
             @login_required
             def dev_conf_edit(request, id_conf):
                 conf = get_object_or_404(Configuration, pk=id_conf)
                 DevConfForm = CONF_FORMS[conf.device.device_type.name]
                 if request.method == 'GET':
                     form = DevConfForm(instance=conf)
                 if request.method == 'POST':
                     form = DevConfForm(request.POST, instance=conf)
                     if form.is_valid():
                         form.save()
                         return redirect('url_dev_conf', id_conf=id_conf)
                 kwargs = {}
                 kwargs['form'] = form
                 kwargs['title'] = 'Device Configuration'
                 kwargs['suptitle'] = 'Edit'
                 kwargs['button'] = 'Update'
                 kwargs['menu_configurations'] = 'active'
                 ###### SIDEBAR ######
                 kwargs.update(sidebar(conf=conf))
                 return render(request, '%s_conf_edit.html' % conf.device.device_type.name, kwargs)
             @login_required
             def dev_conf_start(request, id_conf):
                 conf = get_object_or_404(Configuration, pk=id_conf)
                 if conf.start_device():
                     messages.success(request, conf.message)
                 else:
                     messages.error(request, conf.message)
                 #conf.status_device()
                 return redirect(conf.get_absolute_url())
             @login_required
             def dev_conf_stop(request, id_conf):
                 conf = get_object_or_404(Configuration, pk=id_conf)
                 if conf.stop_device():
                     messages.success(request, conf.message)
                 else:
                     messages.error(request, conf.message)
                 #conf.status_device()
                 return redirect(conf.get_absolute_url())
             @login_required
             def dev_conf_status(request, id_conf):
                 conf = get_object_or_404(Configuration, pk=id_conf)
                 conf_active = Configuration.objects.filter(pk=conf.device.conf_active).first()
                 if conf_active!=conf:
                     url = '#' if conf_active is None else conf_active.get_absolute_url()
                     label = 'None' if conf_active is None else conf_active.label
                     messages.warning(
                         request,
                         mark_safe('The current configuration has not been written to device, the active configuration is <a href="{}">{}</a>'.format(
                             url,
                             label
                             ))
                         )
                     return redirect(conf.get_absolute_url())
                 if conf.status_device():
                     messages.success(request, conf.message)
                 else:
                     messages.error(request, conf.message)
                 return redirect(conf.get_absolute_url())
             @login_required
             def dev_conf_reset(request, id_conf):
                 conf = get_object_or_404(Configuration, pk=id_conf)
                 if conf.reset_device():
                     messages.success(request, conf.message)
                 else:
                     messages.error(request, conf.message)
                 return redirect(conf.get_absolute_url())
             @login_required
             def dev_conf_write(request, id_conf):
                 conf = get_object_or_404(Configuration, pk=id_conf)
                 if request.method == 'POST':
                     if conf.write_device():
                         conf.device.conf_active = conf.pk
                         conf.device.save()
                         messages.success(request, conf.message)
                         if has_been_modified(conf):
                             conf.clone(type=1, template=False)
                     else:
                         messages.error(request, conf.message)
                     return redirect(get_object_or_404(Configuration, pk=id_conf).get_absolute_url())
                 kwargs = {
                     'title': 'Write Configuration',
                     'suptitle': conf.label,
                     'message': 'Are you sure yo want to write this {} configuration?'.format(conf.device),
                     'delete': False
                 }
                 kwargs['menu_configurations'] = 'active'
                 return render(request, 'confirm.html', kwargs)
             @login_required
             def dev_conf_read(request, id_conf):
                 conf = get_object_or_404(Configuration, pk=id_conf)
                 DevConfForm = CONF_FORMS[conf.device.device_type.name]
                 if request.method == 'GET':
                     parms = conf.read_device()
                     #conf.status_device()
                     if not parms:
                         messages.error(request, conf.message)
                         return redirect(conf.get_absolute_url())
                     form = DevConfForm(initial=parms, instance=conf)
                 if request.method == 'POST':
                     form = DevConfForm(request.POST, instance=conf)
                     if form.is_valid():
                         form.save()
                         return redirect(conf.get_absolute_url())
                     messages.error(request, "Parameters could not be saved")
                 kwargs = {}
                 kwargs['id_dev'] = conf.id
                 kwargs['form'] = form
                 kwargs['title'] = 'Device Configuration'
                 kwargs['suptitle'] = 'Parameters read from device'
                 kwargs['button'] = 'Save'
                 ###### SIDEBAR ######
                 kwargs.update(sidebar(conf=conf))
                 return render(request, '%s_conf_edit.html' % conf.device.device_type.name, kwargs)
             @login_required
             def dev_conf_import(request, id_conf):
                 conf = get_object_or_404(Configuration, pk=id_conf)
                 DevConfForm = CONF_FORMS[conf.device.device_type.name]
                 if request.method == 'GET':
                     file_form = UploadFileForm()
                 if request.method == 'POST':
                     file_form = UploadFileForm(request.POST, request.FILES)
                     if file_form.is_valid():
                         data = conf.import_from_file(request.FILES['file'])
                         parms = Params(data=data).get_conf(
                             dtype=conf.device.device_type.name)
                         if parms:
                             form = DevConfForm(initial=parms, instance=conf)
                             kwargs = {}
                             kwargs['id_dev'] = conf.id
                             kwargs['form'] = form
                             kwargs['title'] = 'Device Configuration'
                             kwargs['suptitle'] = 'Parameters imported'
                             kwargs['button'] = 'Save'
                             kwargs['action'] = conf.get_absolute_url_edit()
                             kwargs['previous'] = conf.get_absolute_url()
                             ###### SIDEBAR ######
                             kwargs.update(sidebar(conf=conf))
                             messages.success(
                                 request, "Parameters imported from: '%s'." % request.FILES['file'].name)
                             return render(request, '%s_conf_edit.html' % conf.device.device_type.name, kwargs)
                     messages.error(request, "Could not import parameters from file")
                 kwargs = {}
                 kwargs['id_dev'] = conf.id
                 kwargs['title'] = 'Device Configuration'
                 kwargs['form'] = file_form
                 kwargs['suptitle'] = 'Importing file'
                 kwargs['button'] = 'Import'
                 kwargs['menu_configurations'] = 'active'
                 kwargs.update(sidebar(conf=conf))
                 return render(request, 'dev_conf_import.html', kwargs)
             @login_required
             def dev_conf_export(request, id_conf):
                 conf = get_object_or_404(Configuration, pk=id_conf)
                 if request.method == 'GET':
                     file_form = DownloadFileForm(conf.device.device_type.name)
                 if request.method == 'POST':
                     file_form = DownloadFileForm(
                         conf.device.device_type.name, request.POST)
                     if file_form.is_valid():
                         fields = conf.export_to_file(
                             format=file_form.cleaned_data['format'])
                         if not fields['content']:
                             messages.error(request, conf.message)
                             return redirect(conf.get_absolute_url_export())
                         response = HttpResponse(content_type=fields['content_type'])
                         response['Content-Disposition'] = 'attachment; filename="%s"' % fields['filename']
                         response.write(fields['content'])
                         return response
                     messages.error(request, "Could not export parameters")
                 kwargs = {}
                 kwargs['id_dev'] = conf.id
                 kwargs['title'] = 'Device Configuration'
                 kwargs['form'] = file_form
                 kwargs['suptitle'] = 'Exporting file'
                 kwargs['button'] = 'Export'
                 kwargs['menu_configurations'] = 'active'
                 return render(request, 'dev_conf_export.html', kwargs)
             @login_required
             def dev_conf_delete(request, id_conf):
                 conf = get_object_or_404(Configuration, pk=id_conf)
                 if request.method == 'POST':
                     if is_developer(request.user):
                         conf.delete()
                         return redirect('url_dev_confs')
                     messages.error(request, 'Not enough permission to delete this object')
                     return redirect(conf.get_absolute_url())
                 kwargs = {
                     'title': 'Delete',
                     'suptitle': 'Configuration',
                     'object': conf,
                     'delete': True
                 }
                 kwargs['menu_configurations'] = 'active'
                 return render(request, 'confirm.html', kwargs)
             def sidebar(**kwargs):
                 side_data = {}
                 conf = kwargs.get('conf', None)
                 experiment = kwargs.get('experiment', None)
                 if not experiment:
                     experiment = conf.experiment
                 if experiment:
                     side_data['experiment'] = experiment
                     campaign = experiment.campaign_set.all()
                     if campaign:
                         side_data['campaign'] = campaign[0]
                         experiments = campaign[0].experiments.all().order_by('name')
                     else:
                         experiments = [experiment]
                     configurations = experiment.configuration_set.filter(type=0)
                     side_data['side_experiments'] = experiments
                     side_data['side_configurations'] = configurations.order_by(
                         'device__device_type__name')
                 return side_data
             def get_paginator(model, page, order, filters={}, n=8):
                 kwargs = {}
                 query = Q()
                 if isinstance(filters, QueryDict):
                     filters = filters.dict()
                 copy_filters=filters.copy()
                 [filters.pop(key) for key in copy_filters.keys() if copy_filters[key] in ('    ', ' ')]
                 filters.pop('page', None)
                 fields = [f.name for f in model._meta.get_fields()]
                 if 'template' in copy_filters:
                     filters['template'] = True
                 if 'historical' in copy_filters:
                     filters.pop('historical')
                     filters['type'] = 1
                 elif 'type' in fields:
                    filters['type'] = 0
                 if 'start_date' in copy_filters:
                    filters['start_date__gte'] =filters.pop('start_date')
                 if 'end_date' in copy_filters:
                    filters['start_date__lte'] =filters.pop('end_date')
                 if 'tags' in copy_filters:
                     tags =filters.pop('tags')
                     if 'tags' in fields:
                         query = query | Q(tags__icontains=tags)
                     if 'label' in fields:
                         query = query | Q(label__icontains=tags)
                     if 'location' in fields:
                         query = query | Q(location__name__icontains=tags)
                     if 'device' in fields:
                         query = query | Q(device__device_type__name__icontains=tags)
                         query = query | Q(device__location__name__icontains=tags)
                     if 'device_type' in fields:
                         query = query | Q(device_type__name__icontains=tags)
                 if 'mine' in copy_filters:
                    filters['author_id'] =filters['mine']
                    filters.pop('mine')
                 object_list = model.objects.filter(query, **filters).order_by(*order)
                 paginator = Paginator(object_list, n)
                 try:
                     objects = paginator.page(page)
                 except PageNotAnInteger:
                     objects = paginator.page(1)
                 except EmptyPage:
                     objects = paginator.page(paginator.num_pages)
                 kwargs['objects'] = objects
                 kwargs['offset'] = (int(page)-1)*n if page else 0
                 return kwargs
             # def get_paginator(model, page, order, filters={}, n=8):
             #     kwargs = {}
             #     query = Q()
             #     if isinstance(filters, QueryDict):
             #         filters = filters.dict()
             #     [filters.pop(key) for key in filters.keys() if filters[key] in ('', ' ')]
             #     filters.pop('page', None)
             #     fields = [f.name for f in model._meta.get_fields()]
             #     if 'template' in filters:
             #         filters['template'] = True
             #     if 'historical' in filters:
             #         filters.pop('historical')
             #         filters['type'] = 1
             #     elif 'type' in fields:
             #         filters['type'] = 0
             #     if 'start_date' in filters:
             #         filters['start_date__gte'] = filters.pop('start_date')
             #     if 'end_date' in filters:
             #         filters['start_date__lte'] = filters.pop('end_date')
             #     if 'tags' in filters:
             #         tags = filters.pop('tags')
             #         if 'tags' in fields:
             #             query = query | Q(tags__icontains=tags)
             #         if 'label' in fields:
             #             query = query | Q(label__icontains=tags)
             #         if 'location' in fields:
             #             query = query | Q(location__name__icontains=tags)
             #         if 'device' in fields:
             #             query = query | Q(device__device_type__name__icontains=tags)
             #             query = query | Q(device__location__name__icontains=tags)
             #         if 'device_type' in fields:
             #             query = query | Q(device_type__name__icontains=tags)
             #     if 'mine' in filters:
             #         filters['author_id'] = filters['mine']
             #         filters.pop('mine')
             #     object_list = model.objects.filter(query, **filters).order_by(*order)
             #     paginator = Paginator(object_list, n)
             #     try:
             #         objects = paginator.page(page)
             #     except PageNotAnInteger:
             #         objects = paginator.page(1)
             #     except EmptyPage:
             #         objects = paginator.page(paginator.num_pages)
             #     kwargs['objects'] = objects
             #     kwargs['offset'] = (int(page)-1)*n if page else 0
             #     return kwargs
             def operation(request, id_camp=None):
                 kwargs = {}
                 kwargs['title'] = 'Radars Operation'
                 kwargs['no_sidebar'] = True
                 kwargs['menu_operation'] = 'active'
                 campaigns = Campaign.objects.filter(start_date__lte=datetime.now(),
                                                     end_date__gte=datetime.now()).order_by('-start_date')
                 if id_camp:
                     campaign = get_object_or_404(Campaign, pk=id_camp)
                     form = OperationForm(
                         initial={'campaign': campaign.id}, campaigns=campaigns)
                     kwargs['campaign'] = campaign
                 else:
                     # form = OperationForm(campaigns=campaigns)
                     kwargs['campaigns'] = campaigns
                     return render(request, 'operation.html', kwargs)
                 #---Experiment
                 keys = ['id', 'name', 'start_time', 'end_time', 'status']
                 kwargs['experiment_keys'] = keys[1:]
                 kwargs['experiments'] = experiments
                 #---Radar
                 kwargs['locations'] = campaign.get_experiments_by_radar()
                 kwargs['form'] = form
                 return render(request, 'operation.html', kwargs)
             @login_required
             def radar_start(request, id_camp, id_radar):
                 campaign    = get_object_or_404(Campaign, pk=id_camp)
                 experiments = campaign.get_experiments_by_radar(id_radar)[0]['experiments']
                 now         = datetime.now()
                 for exp in experiments:
                     #app.control.revoke(exp.task)
                     print("----------------------")
                     print("status:->", exp.status)
                     start = datetime.combine(datetime.now().date(), exp.start_time)
                     end   = datetime.combine(datetime.now().date(), exp.end_time)
                     print("start exp: ",exp.start_time)
                     print("end exp: ",exp.end_time)
                     print("start comb: ",start)
                     print("end comb: ",end)
                     print(is_aware(start))
                     print("start camp",campaign.start_date)
                     print("end camp",campaign.end_date)
                     print(is_aware(campaign.start_date))
                     if end < start:
                         end += timedelta(1)
                     if exp.status == 2:
                         messages.warning(
                             request, 'Experiment {} already running'.format(exp))
                         #continue
                     if exp.status == 3:
                         messages.warning(
                             request, 'Experiment {} already programmed'.format(exp))
                         #continue
                     if exp.status == 1:
                         messages.warning(
                             request, 'Experiment {} stopped'.format(exp))
                         #continue
                     if start > campaign.end_date:
                         messages.warning(
                             request, 'Experiment {} out of date'.format(exp))
                     #app.control.revoke(exp.task)
                     print("Llego luego del revoke")
                     if now >= start and now <= end:
                         print("Caso now > start and < end -- (1)")
                         # -------------------------------------------
                         # task = task_start.delay(exp.id)
                         # exp.task   = task.id
                         # exp.status = task.get()
                         # -------------------------------------------
                         #exp.status = task.wait()
                         if exp.status == 0:
                             messages.error(request, 'Experiment {} not start'.format(exp))
                         if exp.status == 2:
                             messages.success(request, 'Experiment {} started'.format(exp))
                     elif now < start:
                         print("Caso now <= start -- (2)",exp.pk)
                         #task = task_start.apply_async((exp.pk, ), eta=start)#start+timedelta(hours=5))
                         # task = task_start.apply_async((exp.pk, ), eta=start+timedelta(hours=5))#)
                         # exp.task   = task.id
                         # exp.status = 3
                         messages.success(request, 'Experiment {} programmed to start at {}'.format(exp, start))
                     else:
                         print("Caso now > end -- (3)")
                         exp.status = 4
                         messages.warning(
                             request, 'Experiment {} out of date'.format(exp))
                     exp.save()
                 return HttpResponseRedirect(reverse('url_operation', args=[id_camp]))
             @login_required
             def radar_stop(request, id_camp, id_radar):
                 campaign    = get_object_or_404(Campaign, pk=id_camp)
                 experiments = campaign.get_experiments_by_radar(id_radar)[0]['experiments']
                 print("Ingreso en stop radar_stop")
                 #for exp in experiments:
                     # if exp.task:
                     #     print("Ingreso antes de revoke stop")
                     #     app.control.revoke(exp.task)
                     # if exp.status == 2: #status 2 es started
                     #     print("llama a exp.stop")
                     #     exp.stop()
                     #     messages.warning(request, 'Experiment {} stopped'.format(exp))
                     # exp.status = 1
                     # exp.save()
                 #return HttpResponseRedirect(reverse('url_operation', args=[id_camp]))
             @login_required
             def radar_refresh(request, id_camp, id_radar):
                 campaign    = get_object_or_404(Campaign, pk=id_camp)
                 experiments = campaign.get_experiments_by_radar(id_radar)[0]['experiments']
                 i         = app.control.inspect()
                 print("inspect",i)
                 print(i.scheduled())
                 print(i.scheduled().values())
                 scheduled = list(i.scheduled().values())[0]
                 revoked   = list(i.revoked().values())[0]
                 # for exp in experiments:
                 #     if exp.task in revoked:
                 #         exp.status = 1
                 #     elif exp.task in [t['request']['id'] for t in scheduled if 'task_stop' in t['request']['name']]:
                 #         exp.status = 2
                 #     elif exp.task in [t['request']['id'] for t in scheduled if 'task_start' in t['request']['name']]:
                 #         exp.status = 3
                 #     else:
                 #         exp.status = 4
                 #     exp.save()
                 # return HttpResponseRedirect(reverse('url_operation', args=[id_camp]))
             #@login_required
             # def revoke_tasks(request, id_camp):
             #     i         = app.control.inspect()
             #     scheduled = list(i.scheduled().values())[0]
             #     revoked   = list(i.revoked().values())[0]
             #     for t in scheduled:
             #         if t['request']['id'] in revoked:
             #             continue
             #         app.control.revoke(t['request']['id'])
             #         exp  = Experiment.objects.get(pk=eval(str(t['request']['args']))[0])
             #         eta  = t['eta']
             #         #task = t['request']['name'].split('.')[-1]
             #         messages.warning(request, 'Scheduled {} at {} for experiment {} revoked'.format(task, eta, exp.name))
             #     return HttpResponseRedirect(reverse('url_operation', args=[id_camp]))
             # @login_required
             # def show_tasks(request, id_camp):
             #     i         = app.control.inspect()
             #     scheduled = list(i.scheduled().values())[0]
             #     revoked   = list(i.revoked().values())[0]
             #     for t in scheduled:
             #         if t['request']['id'] in revoked:
             #             continue
             #         exp = Experiment.objects.get(pk=eval(str(t['request']['args']))[0])
             #         eta = t['eta']
             #         #task = t['request']['name'].split('.')[-1]
             #         #messages.success(request, 'Task {} scheduled at {} for experiment {}'.format(task, eta, exp.name))
             #     return HttpResponseRedirect(reverse('url_operation', args=[id_camp]))
             def real_time(request):
                 graphic_path = "/home/fiorella/Pictures/catwbeanie.jpg"
                 kwargs = {}
                 kwargs['title'] = 'CLAIRE'
                 kwargs['suptitle'] = 'Real Time'
                 kwargs['no_sidebar'] = True
                 kwargs['graphic_path'] = graphic_path
                 kwargs['graphic1_path'] = 'http://www.bluemaize.net/im/girls-accessories/shark-beanie-11.jpg'
                 return render(request, 'real_time.html', kwargs)
             def theme(request, theme):
                 user = request.user
                 user.profile.theme = theme
                 user.save()
                 return redirect('index')

docker-compose.yml +2 -2

             version: '3'
             services:
              # Django app
               radarsys:
                 container_name: 'radarsys'
                 build: .
                 restart: always
                 image: radarsys
                 #command: gunicorn radarsys.wsgi:application -w 2 -b :8000
                 #command: python manage.py runserver 0.0.0.0:8000
                 ports:
                   - 8000:8000
                 #ports:
                 #  - 8030:8030
                 env_file: .env
                 links:
               #    - redis
                   - postgres
                 volumes:
                   - './:/radarsys'
                   - '${DOCKER_DATA}/static:/radarsys/static'
                 depends_on:
               #    - redis
                   - postgres
               # redis:
               #   container_name: 'radarsys-redis'
               #   image: 'redis:3.2-alpine'
               #   volumes:
               #     - '${DOCKER_DATA}/redis:/data'
               # celery_worker:
               #   container_name: 'radarsys-celery'
               #   image: radarsys
               #   env_file: .env
               #   command: celery -A radarsys worker -l info
               #   volumes_from:
               #     - web
               #   depends_on:
               #     - web
               # PostgreSQL
               postgres:
                 container_name: 'radarsys-postgres'
                 build: ./postgres/
                 volumes:
                   - ./postgres/docker-entrypoint-initdb.d:/docker-entrypoint-initdb.d
                   - pgdata:/var/lib/postgresql/data
                 ports:
                  - 5432:5432
                 env_file: .env
               #Web Server
-              nginx:
+              radarsys-nginx:
                 container_name: 'radarsys-nginx'
                 restart: always
                 build: ./nginx/
                 ports:
-                  - '8030:8030'
+                  - '0.0.0.0:80:80'
                 volumes_from:
                   - radarsys
                 links:
                   - radarsys:radarsys
                 depends_on:
                   - radarsys
             volumes:
               pgdata:
                 driver: local

entrypoint.sh +1 -1

             #!/bin/sh
             python3 manage.py makemigrations --no-input
             python3 manage.py migrate --no-input
             python3 manage.py loaddata apps/main/fixtures/main_initial_data.json
             python3 manage.py loaddata apps/rc/fixtures/rc_initial_data.json
             python3 manage.py loaddata apps/jars/fixtures/initial_filters_data.json
             python3 manage.py collectstatic --no-input
             #DJANGO_SUPERUSER_PASSWORD=$SUPER_USER_PASSWORD python manage.py createsuperuser --username $SUPER_USER_NAME --email $SUPER_USER_EMAIL --noinput
-            gunicorn radarsys.wsgi:application -w 2 -b :8000
+            gunicorn -k eventlet radarsys.wsgi:application --bind 0.0.0.0:8000
   No newline at end of file

nginx/sites-enabled/radarsys.conf +16 -8

+            upstream django {
+            	server radarsys:8000;
+            }
             server {
-                listen 8030;
+                listen 80;
                 server_name localhost;
-                access_log /dev/stdout;
+                #access_log /dev/stdout;
-                error_log /dev/stdout info;
+                #error_log /dev/stdout info;
                 location /static {
                     alias /radarsys/static;
                 }
                 location / {
-                    proxy_set_header Host "localhost";
+                    proxy_pass http://django;
-                    proxy_pass http://radarsys:8000;
+                    proxy_set_header   X-Real-IP  $remote_addr;
-                    # proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
+            		proxy_set_header   Host       $host;
+                    proxy_set_header   X-Forwarded-For $proxy_add_x_forwarded_for;
+                    proxy_set_header   X-Forwarded-Proto $scheme;
+                    proxy_http_version 1.1;
+                    proxy_set_header   Upgrade $http_upgrade;
+                    proxy_set_header   Connection "upgrade";
                 }
+            }
  No newline at end of file

radarsys/settings.py +8 -1

             """
             Django settings for radarsys project.
             Generated by 'django-admin startproject' using Django 1.8.6.
             For more information on this file, see
             https://docs.djangoproject.com/en/1.8/topics/settings/
             For the full list of settings and their values, see
             https://docs.djangoproject.com/en/1.8/ref/settings/
             """
             # Build paths inside the project like this: os.path.join(BASE_DIR, ...)
             import os
             BASE_DIR = os.path.dirname(os.path.dirname(os.path.abspath(__file__)))
             # Quick-start development settings - unsuitable for production
             # See https://docs.djangoproject.com/en/1.8/howto/deployment/checklist/
             # SECURITY WARNING: keep the secret key used in production secret!
             SECRET_KEY = 'xshb$k5fc-+j16)cvyffj&9u__0q3$l!hieh#+tbzqg)*f^km0'
             # SECURITY WARNING: don't run with debug turned on in production!
             DEBUG = True
             ALLOWED_HOSTS = ['*']
             CSRF_TRUSTED_ORIGINS=[
                 "http://*.localhost:8030",
                 "http://localhost:8030",
                 "http://127.0.0.1:8030"
             ]
             #Si se requiere que la aplicación salga de este entorno, para otros usuarios es necesario hacer una API request https://fractalideas.com/blog/making-react-and-django-play-well-together-single-page-app-model/
             # Application definition
             INSTALLED_APPS = [
                 'django.contrib.admin',
                 'django.contrib.auth',
                 'django.contrib.contenttypes',
                 'django.contrib.sessions',
                 'django.contrib.messages',
                 'django.contrib.staticfiles',
                 'apps.accounts',
                 'apps.main',
                 'apps.misc',
                 'apps.rc',
                 'apps.dds',
                 'apps.jars',
                 'apps.usrp',
                 'apps.abs',
                 'apps.cgs',
                 'apps.dds_rest',
+                'apps.atrad',
                 "django_bootstrap5",
                 'polymorphic',
-                'channels',
+                'radarsys',
             ]
             MIDDLEWARE = [
                 'django.middleware.security.SecurityMiddleware',
                 'django.contrib.sessions.middleware.SessionMiddleware',
                 'django.middleware.common.CommonMiddleware',
                 'django.middleware.csrf.CsrfViewMiddleware',
                 'django.contrib.auth.middleware.AuthenticationMiddleware',
                 'django.contrib.messages.middleware.MessageMiddleware',
                 'django.middleware.clickjacking.XFrameOptionsMiddleware',
             ]
             ROOT_URLCONF = 'radarsys.urls'
             TEMPLATES = [
                 {
                     'BACKEND': 'django.template.backends.django.DjangoTemplates',
                     'DIRS': [os.path.join(BASE_DIR, "templates")],
                     'APP_DIRS': True,
                     'OPTIONS': {
                         'context_processors': [
                             'django.template.context_processors.debug',
                             'django.template.context_processors.request',
                             'django.contrib.auth.context_processors.auth',
                             'django.contrib.messages.context_processors.messages',
                             'apps.main.processors.radarsys_globals',
                         ],
                     },
                 },
             ]
             WSGI_APPLICATION = 'radarsys.wsgi.application'
             ASGI_APPLICATION = 'radarsys.asgi.application'
             # Database
             # https://docs.djangoproject.com/en/1.8/ref/settings/#databases
             DATABASES = {
                 # 'default': {
                 #     'ENGINE': 'django.db.backends.sqlite3',
                 #     'NAME': 'radarsys.sqlite',
                 # }
                 'default': {
                     'ENGINE': 'django.db.backends.postgresql_psycopg2',
                     'NAME': os.environ.get('DB_NAME', 'radarsys'),
                     'USER': os.environ.get('DB_USER', 'docker'),
                     'PASSWORD': os.environ.get('DB_PASSWORD', 'docker'),
                     'HOST': os.environ.get('POSTGRES_PORT_5432_TCP_ADDR', 'localhost'),
                     'PORT': os.environ.get('POSTGRES_PORT_5432_TCP_PORT', '5432'),
                 }
             }
             # Internationalization
             # https://docs.djangoproject.com/en/1.8/topics/i18n/
             LANGUAGE_CODE = 'en-us'
             USE_TZ   = False #True
             TIME_ZONE = os.environ.get('TZ', 'America/Lima')
             USE_I18N = True
             USE_L10N = True
             # Static files (CSS, JavaScript, Images)
             # https://docs.djangoproject.com/en/1.8/howto/static-files/
             MEDIA_URL = '/media/'
             MEDIA_ROOT = os.path.join(BASE_DIR, 'media')
             STATICFILES_DIRS = [
                os.path.join(BASE_DIR, 'radarsys/static/')
             ]
             STATIC_URL = '/static/'
             STATIC_ROOT = os.path.join(BASE_DIR, 'static')
             LOGIN_URL = '/accounts/login'
             LOGOUT_URL = 'logout'
             LOGIN_REDIRECT_URL = '/admin'
             LOGOUT_REDIRECT_URL = '/'
             STATICFILES_FINDERS = (
                 'django.contrib.staticfiles.finders.FileSystemFinder',
                 'django.contrib.staticfiles.finders.AppDirectoriesFinder',
             )
             # # Celery stuff
             # REDIS_HOST = os.environ.get('REDIS_HOST', 'localhost')
             # #REDIS_HOST = os.environ.get('REDIS_HOST', '127.0.0.1')
             # REDIS_PORT = os.environ.get('REDIS_PORT', 6379)
             # BROKER_TRANSPORT = 'redis'
             # #BROKER_URL       = 'redis://{}:{}/0'.format(REDIS_HOST, REDIS_PORT)
             # BROKER_URL       = 'redis://{}:{}'.format(REDIS_HOST, REDIS_PORT)
             # CELERY_RESULT_BACKEND    = 'redis://{}:{}/0'.format(REDIS_HOST, REDIS_PORT)
             # CELERY_BROKER_TRANSPORT  = BROKER_URL
             # CELERY_ACCEPT_CONTENT    = ['application/json']
             # CELERY_TASK_SERIALIZER   = 'json'
             # CELERY_RESULT_SERIALIZER = 'json'
             # CELERY_ENABLE_UTC        = False
             # CELERY_TIMEZONE          = 'America/Lima'
             import django
             from django.utils.encoding import force_str
             django.utils.encoding.force_text = force_str
             # choose of auto-created primary keys
             DEFAULT_AUTO_FIELD='django.db.models.AutoField'
+            MQTT_SERVER = '10.10.10.99'
+            MQTT_PORT = 1883
+            MQTT_KEEPALIVE = 60
+            MQTT_USER = ''
+            MQTT_PASSWORD = ''
  No newline at end of file

radarsys/urls.py +1 -1

             from django.urls import include, path
             from django.contrib import admin
             #from django.contrib.staticfiles.urls import staticfiles_urlpatterns
             urlpatterns = [
                 path('admin/',admin.site.urls),
                 path('accounts/', include('apps.accounts.urls')),
                 path('', include('apps.main.urls')),
                 path('rc/', include('apps.rc.urls')),
                 path('dds/', include('apps.dds.urls')),
                 path('cgs/', include('apps.cgs.urls')),
                 path('jars/',include('apps.jars.urls')),
                 path('usrp/', include('apps.usrp.urls')),
                 path('abs/', include('apps.abs.urls')),
                 path('misc/',include('apps.misc.urls')),
                 path('dds_rest/', include('apps.dds_rest.urls')),
+                path('atrad/', include('apps.atrad.urls')),
             ]
             #urlpatterns += staticfiles_urlpatterns()

radarsys/wsgi.py +3 0

             """
             WSGI config for radarsys project.
             It exposes the WSGI callable as a module-level variable named ``application``.
             For more information on this file, see
             https://docs.djangoproject.com/en/1.8/howto/deployment/wsgi/
             """
             import os
             from django.core.wsgi import get_wsgi_application
+            from .socketconfig import sio
+            import socketio
             os.environ.setdefault("DJANGO_SETTINGS_MODULE", "radarsys.settings")
             application = get_wsgi_application()
+            application = socketio.WSGIApp(sio, application)

requirements.txt +6 -2

             Django==4.1.5
             django-bootstrap5==22.2
             psycopg2-binary==2.9.5
             django-polymorphic==3.1
             bokeh==3.0.3
             numpy==1.24.1
             matplotlib==3.6.3
             scipy==1.10.0
             celery==5.2.7
             gunicorn==20.1.0
             requests==2.28.2
             redis==4.4.2
-            channels==4.0.0
-            daphne==4.0.0
  No newline at end of file
+            paho-mqtt==1.6.1
+            eventlet==0.30.2
+            python-engineio
+            python-socketio
  No newline at end of file

radarsys/asgi.py removed 0 -13

NO CONTENT: file was removed

General Comments 0

Write
Preview

You need to be logged in to leave comments. Login now

No TODOs yet

	Site-wide shortcuts
/	Use quick search box
g h	Goto home page
g g	Goto my private gists page
g G	Goto my public gists page
g 0-9	Goto bookmarked items from 0-9
n r	New repository page
n g	New gist page

	Repositories
g s	Goto summary page
g c	Goto changelog page
g f	Goto files page
g F	Goto files page with file search activated
g p	Goto pull requests page
g o	Goto repository settings
g O	Goto repository access permissions settings
t s	Toggle sidebar on some pages