Uniquely merge BCC and Manager lists for sending notification email.

[htsworkflow.git] / htsworkflow / frontend / experiments / views.py

diff --git a/htsworkflow/frontend/experiments/views.py b/htsworkflow/frontend/experiments/views.py
old mode 100755 (executable)
new mode 100644 (file)
index a1775d4..28a355f
--- a/htsworkflow/frontend/experiments/views.py
+++ b/htsworkflow/frontend/experiments/views.py
@@ -13,7 +13,12 @@ from django.shortcuts import render_to_response, get_object_or_404
 from django.template import RequestContext
 from django.template.loader import get_template
 
-from htsworkflow.frontend.experiments.models import DataRun, DataFile, FlowCell
+from htsworkflow.frontend.experiments.models import \
+     DataRun, \
+     DataFile, \
+     FlowCell, \
+     Lane, \
+     Sequencer
 from htsworkflow.frontend.experiments.experiments import \
      estimateFlowcellDuration, \
      estimateFlowcellTimeRemaining, \
@@ -23,14 +28,8 @@ from htsworkflow.frontend.experiments.experiments import \
 
 def index(request):
     all_runs = DataRun.objects.order_by('-run_start_time')
-    #t = loader.get_template('experiments/index.html')
-    #c = Context({
-    #    'data_run_list': all_runs,
-    #})
-    #return HttpResponse(t.render(c)) 
-    # shortcut to the above module usage
-    return render_to_response('experiments/index.html',{'data_run_list': all_runs}) 
-    
+    return render_to_response('experiments/index.html',{'data_run_list': all_runs})
+
 def detail(request, run_folder):
     html_str = '<h2>Exp Track Details Page</h2>'
     html_str += 'Run Folder: '+run_folder
@@ -85,7 +84,7 @@ def startedEmail(request, pk):
         if user.email is None or len(user.email) == 0:
             warnings.append((user.admin_url(), user.username))
     user=None
-    
+
     for user_email in email_lane.keys():
         sending = ""
         # build body
@@ -95,7 +94,7 @@ def startedEmail(request, pk):
                                   u'runfolder': 'blank',
                                   u'finish_low': estimate_low,
                                   u'finish_high': estimate_high,
-                                  u'now': datetime.now(),        
+                                  u'now': datetime.now(),
                                   })
 
         # build view
@@ -104,9 +103,15 @@ def startedEmail(request, pk):
 
         if send:
             email = EmailMessage(subject, body, sender, to=[user_email])
+            notified = set()
             if bcc_managers:
-                email.bcc = settings.MANAGERS
-            email.bcc.append(settings.NOTIFICATION_BCC)
+                for manager in settings.MANAGERS:
+                    if len(manager) > 0:
+                        notified.add(manager)
+            for user in settings.NOTIFICATION_BCC:
+                if len(user) > 0:
+                    notified.add(user)
+            email.bcc = list(notified)
             email.send()
 
         emails.append((user_email, subject, body, sending))
@@ -122,39 +127,48 @@ def startedEmail(request, pk):
           'warnings': warnings,
         })
     return HttpResponse(email_verify.render(verify_context))
-    
+
 def finishedEmail(request, pk):
     """
     """
     return HttpResponse("I've got nothing.")
 
 
-def flowcell_detail(request, flowcell_id):
+def flowcell_detail(request, flowcell_id, lane_number=None):
     fc = get_object_or_404(FlowCell, flowcell_id__startswith=flowcell_id)
     fc.update_data_runs()
 
+
+    if lane_number is not None:
+        lanes = fc.lane_set.filter(lane_number=lane_number)
+    else:
+        lanes = fc.lane_set.all()
+
     context = RequestContext(request,
-                             {'flowcell': fc})
-    
+                             {'flowcell': fc,
+                              'lanes': lanes})
+
     return render_to_response('experiments/flowcell_detail.html',
                               context)
 
-def flowcell_lane_detail(request, flowcell_id, lane_number):
-    fc = get_object_or_404(FlowCell, flowcell_id__startswith=flowcell_id)
-    lane = get_object_or_404(fc.lane_set, lane_number=lane_number)
-    
-    fc.update_data_runs()
+def flowcell_lane_detail(request, lane_pk):
+    lane = get_object_or_404(Lane, id=lane_pk)
+    lane.flowcell.update_data_runs()
 
     dataruns = []
-    for run in fc.datarun_set.all():
-        dataruns.append((run, lane.lane_number, run.lane_files()[lane.lane_number]))
-        
+    lane.flowcell.update_data_runs()
+    for run in lane.flowcell.datarun_set.all():
+        files = run.lane_files().get(lane.lane_number, None)
+        dataruns.append((run,
+                         lane.lane_number,
+                         files))
+
     context = RequestContext(request,
                              {'lib': lane.library,
                               'lane': lane,
-                              'flowcell': fc,
+                              'flowcell': lane.flowcell,
                               'filtered_dataruns': dataruns})
-    
+
     return render_to_response('experiments/flowcell_lane_detail.html',
                               context)
 
@@ -162,7 +176,7 @@ def read_result_file(self, key):
     """Return the contents of filename if everything is approved
     """
     data_file = get_object_or_404(DataFile, random_key = key)
-    
+
     mimetype = 'application/octet-stream'
     if data_file.file_type.mimetype is not None:
         mimetype = data_file.file_type.mimetype
@@ -172,5 +186,10 @@ def read_result_file(self, key):
                             mimetype=mimetype)
 
     raise Http404
-      
-  
+
+
+def sequencer(request, sequencer_id):
+    sequencer = get_object_or_404(Sequencer, id=sequencer_id)
+    context = RequestContext(request,
+                             {'sequencer': sequencer})
+    return render_to_response('experiments/sequencer.html', context)