TODOs et modifs mineures

haribo
1 parent 00bc9770
Showing 15 changed files with 31 additions and 19 deletions Show diff stats
src/alert_manager/tasks.py
src/alert_manager/templates/alert_manager/alerts.html
src/alert_manager/tests.py
src/analyzer/tasks.py
src/common/RequestBuilder.py
src/majordome/tasks.py
src/misc/saved_requests/request10.xml
src/misc/templates/base.html
src/monitoring/tasks.py
src/observation_manager/tasks.py
src/pyros/settings.py
src/routine_manager/RequestSerializer.py
src/routine_manager/views.py
src/scheduler/tasks.py
src/user_manager/forms.py
@@ -77,6 +77,7 @@ class alert_listener(Task):
  
         with open(os.path.join(VOEVENTS_PATH, event_file), 'rb') as f:
             voevent = voeventparse.load(f)
+            # TODO: Faire un try/except pour gérer les mauvais fichiers
         self.create_related_request(voevent, event_file)
  
     def create_related_request(self, voevent, event_file):
@@ -91,10 +92,10 @@ class alert_listener(Task):
         pyros_user = PyrosUser.objects.get(user__username="pyros")
         scientific_program = ScientificProgram.objects.get(name="GRB")
  
-
         alert = self.get_alert_attributes(voevent, event_file)
  
         if alert == None or StrategyObs.objects.filter(is_default=True).exists() == False:
+            # TODO: Supprimer le fichier reçu ? Ou le stocker dans un dossier à part
             return
  
         alert.strat = StrategyObs.objects.filter(is_default=True)[0]
@@ -12,19 +12,15 @@
 			<div class="row">
 				<h3>Default strategy</h3>
  
-{#				<form action="{% url 'change_default_strategy' %}" method="POST" id="strat_change_form">#}
-{#					{% csrf_token %}#}
 					<input class="span2" id="default_strat" name="default_strat" type="hidden">
 					<div class="dropdown">
 						<button class="btn {{btn_type}} dropdown-toggle" type="button" data-toggle="dropdown">{{current_default}}&nbsp<span class="caret"></span></button>
 						<ul class="dropdown-menu">
 							{% for strat in strat_list %}
-{#								<li onclick="$('#default_strat').val({{strat}});$('#strat_change_form').submit()"><a>{{ strat }}</a></li>#}
 								<li><a href="{% url 'change_default_strategy' strat.id %}">{{ strat.name }}</a></li>
 							{% endfor %}
 						</ul>
 					</div>
-{#				</form>#}
  
 			</div>
  
@@ -101,7 +101,7 @@ class AlertListenerTestsCelery(TestCase):
     def test_basic(self):
         '''
             Used to test scripts/celery_test.sh
-            Only work if the initial_fixture is on the prod DB (an only it)
+            Only work if the initial_fixture is on the celery test DB (an only it)
         '''
         Country.objects.create(name="TEEEEST")
         self.assertEqual(Country.objects.count(), 2, "should be 2 countries")
@@ -41,7 +41,7 @@ class analysis(Task):
         # TODO: récupérer les bonne images dans le dossier analyzer/calibrations, et les appliquer
         # renvoie le nom de l'image calibrée; penser à vérifier que les fichiers de calibration existent à cet endroit
         # TODO: copier l'image dans le bon dossier pour le filesync (lien symbolique)
-        return "toto.fitz"
+        return "toto.fits"
  
     def do_analysis(self, new_img):
         '''
@@ -171,7 +171,8 @@ class RequestBuilder():
  
         if settings.CELERY_TEST == False:
             pass
-            # TODO: mettre une condition de temps pour lancer le scheduling (il faut être nuit -2 min au minimum)
+            # TODO: uncomment
+            # mettre une condition de temps pour lancer le scheduling (il faut être nuit -2 min au minimum)
             # scheduler.tasks.scheduling.delay(first_schedule=True, alert=self.request.is_alert)  # TODO : changer le first_schedule ...
  
         return self.request
@@ -27,7 +27,7 @@ class execute_sequence(Task):
  
  
     def run(self, shs_pk):
-        # on ne supprime JAMAIS un séquence en cours, donc je peux la virer des tasks dès le début
+        # on ne supprime JAMAIS une séquence en cours, donc je peux la virer des tasks dès le début
         TaskId.objects.filter(task_id=self.request.id).delete()
  
         shs = ScheduleHasSequences.objects.get(pk=shs_pk)
@@ -44,7 +44,7 @@ class execute_sequence(Task):
         countdown = self.get_countdown(shs, sequence)
  
         if countdown > MAX_WAIT * DAILY_SECOND:
-            scheduler.tasks.scheduling.delay(first_schedule=True, alert=False)  # TODO : changer le first_schedule à False
+            scheduler.tasks.scheduling.delay(first_schedule=False, alert=False)
             return
  
         tel = Tel.TelescopeController()
@@ -85,7 +85,7 @@ class execute_sequence(Task):
             try:
                 while plan_result.ready() == False:
                     print("not finished")
-                    time.sleep(4)
+                    time.sleep(1)
                 print("result : %s " % (plan_result.status,))
             except Exception as e:
                 print("exception : %s" % (str(e),))
@@ -93,6 +93,7 @@ class execute_sequence(Task):
                 shs.save()
                 sequence.status = Sequence.CANCELLED
                 sequence.save()
+                # TODO: rendre le quota à l'utilisateur
                 return
  
         shs.status = Sequence.EXECUTED
@@ -138,6 +139,7 @@ class system_restart(Task):
         Task called by the monitoring when there is no more problem.
         Should just make a scheduling.
     '''
+
     def run(self):
         time.sleep(5)
         print("system_restart")
@@ -0,0 +1,8 @@
+<?xml version="1.0" ?>
+<request name="Bluuua bla" scientific_program="GRB" target_type="qsdqsd">
+    <sequence duration="654655642.3" jd1="0E-8" jd2="0E-8" name="QQQS" target_coords="QsQS">
+        <album detector="Visible camera" name="MyAlbumPhoto">
+            <plan duration="6.0" filter="Second visble filter" name="New plan" nb_images="3"/>
+        </album>
+    </sequence>
+</request>
@@ -47,7 +47,7 @@
         <div class="collapse navbar-collapse navbar-ex1-collapse">
  
           <ul class="nav navbar-nav side-nav">
-            <li><a href="{% url "schedule_simulation" %}">Schedule</a></li>
+            <li><a href="{% url "current_schedule" %}">Schedule</a></li>
             <li><a href="{% url "system" %}">System</a></li>
             <li><a href="{% url "alerts_list" %}">Alerts</a></li>
             <li><a href="{% url "requests_list" %}">Routines</a></li>
@@ -165,3 +165,4 @@ class monitoring(Task):
  
         pass
         # TODO: toute la fct
+        # On calcule le nouveau seeing, et si il y a eu du changement, on crée une tâche de majordome.change_obs_conditions
@@ -37,11 +37,11 @@ class execute_plan_vis(Task):
  
         cam.do("START")
  
-# TODO: décommenter quand on aura un simulateur
-#         st = self.wait_camera_finished(cam)
+        st = self.wait_camera_finished(cam)
  
         # TODO: récupérer les vraies images ? je fais quoi ?
         time.sleep(1)
+        # Penser qu'un plan peut créer plusieurs images (et analyser image par image)
         analysis.delay(plan_id)
         message = 'Finished plan ' + str(plan_id) + ' execution'
         Log.objects.create(agent='Observation manager', message=message)
@@ -45,6 +45,9 @@ SECRET_KEY = &#39;0*@w)$rq4x1c2w!c#gn58*$*u$w=s8uw2zpr_c3nj*u%qlxc23&#39;
  
 # SECURITY WARNING: don't run with debug turned on in production!
 DEBUG = True
+
+# TODO: enelever le système actuel de simulation d'alerte, et le refaire sur la page principale des alertes
+# Supprimer le vue associée (et le template)
 SIMULATION = False
  
 ALLOWED_HOSTS = ['localhost']
@@ -133,7 +133,7 @@ class RequestSerializer():
             elif name == "duration":
                 seq.duration = Decimal(value) / 86400
  
-        # TODO: faire des checks ?? j'imagine
+        # TODO: faire des checks ?? j'imagine, par exemple pour la cohérence des valeurs
         album_list = []
         self.sequences.append((seq, album_list))
  
@@ -389,7 +389,7 @@ def submit_request(request, req_id, redir):
         return redirect(action_request, req_id=req_id, action="view", status=-1, message=message)
  
     for seq in req.sequences.all():
-        seq.status = Sequence.OBSERVABLE  # TODO: utiliser le monitoring
+        seq.status = Sequence.OBSERVABLE  # TODO: utiliser le monitoring (regarder les conditions d'obseration pour dire si on met TBP ou OBS)
         seq.save()
     req.submitted = True
     req.save()
@@ -411,7 +411,7 @@ def unsubmit_request(request, req_id):
  
     req = Request.objects.get(id=req_id)
  
-# TODO: Décommenter pour la production
+# TODO: uncomment pour la production
 #     if req.sequences.filter(Q(status=Sequence.EXECUTED) | Q(status=Sequence.EXECUTING)).exists():
 #         message = "You can't unsubmit an request with executed sequences"
 #         return redirect(action_request, req_id=req_id, action="view", status=-1, message=message)
@@ -423,6 +423,7 @@ def unsubmit_request(request, req_id):
     for seq in sequences:
         seq.status = Sequence.COMPLETE
         seq.save()
+    # TODO: uncomment
     # scheduler.tasks.scheduling.delay(first_schedule=True, alert=False)  # TODO : changer le first_schedule ...
  
     if req.complete == True:
@@ -22,7 +22,7 @@ class scheduling(Task):
         Log.objects.create(agent='Scheduler', message='Start schedule')
         self.scheduler = Scheduler()
         if first_schedule is True:
-            self.determine_schedule_limits()
+            self.determine_schedule_limits()  # DEV ONLY (en production, les night start / end seront passés en paramètre par le monitoring)
         self.scheduler.make_schedule(first_schedule)
  
         schedule = Schedule.objects.order_by("-created")[0]
@@ -20,7 +20,6 @@ class PyrosUserCreationForm(forms.ModelForm):
     class Meta:
         model = PyrosUser
         fields = ('tel', 'laboratory', 'address')
-#         fields = ('user.email', 'user_password', 'user_first_name', 'user_last_name', 'tel', 'laboratory', 'address')
  
     def __init__(self, *args, **kwargs):
         super(PyrosUserCreationForm, self).__init__(*args, **kwargs)