From: yomguy <>
Date: Fri, 3 Sep 2010 08:23:44 +0000 (+0000)
Subject: fix timeside, analyzers back, works well through django runserver, but not yet with... 
X-Git-Tag: 1.1~490
X-Git-Url: https://git.parisson.com/?a=commitdiff_plain;h=516595b9f24b7558c606671994eab0e3386859e8;p=telemeta.git

fix timeside, analyzers back, works well through django runserver, but not yet with wsgi 3.3
---

diff --git a/telemeta/templates/telemeta_default/mediaitem_detail.html b/telemeta/templates/telemeta_default/mediaitem_detail.html
index 3f5c8c52..4133495e 100644
--- a/telemeta/templates/telemeta_default/mediaitem_detail.html
+++ b/telemeta/templates/telemeta_default/mediaitem_detail.html
@@ -80,7 +80,7 @@ load_player({{ item.approx_duration.as_seconds }});
                 <input type="submit" value="Set" />
             </form>
 
-<!--          <div class="analyzer">
+          <div class="analyzer">
             <table width="100%">
              <tr class="analyzer-title">
               <td>Property</td>
@@ -101,7 +101,7 @@ load_player({{ item.approx_duration.as_seconds }});
             </tr>
             {% endfor %}
            </table>
-         </div>-->
+         </div>
 <!--
         <form method="get" action="#">
             <p>&nbsp;Vamp plugin analysis</p>
diff --git a/telemeta/urls.py b/telemeta/urls.py
index 3fc26b39..41dc1309 100644
--- a/telemeta/urls.py
+++ b/telemeta/urls.py
@@ -37,7 +37,7 @@
 from django.conf.urls.defaults import *
 from telemeta.models import MediaItem, MediaCollection
 #from telemeta.core import ComponentManager
-from telemeta.web import WebView
+from telemeta.web.base import WebView
 import os.path
 import telemeta.config
 
diff --git a/telemeta/util/__init__.py b/telemeta/util/__init__.py
index e69de29b..8674a000 100644
--- a/telemeta/util/__init__.py
+++ b/telemeta/util/__init__.py
@@ -0,0 +1 @@
+from telemeta.util import *
diff --git a/telemeta/util/logger.py b/telemeta/util/logger.py
index b6f54ca3..41ed0086 100644
--- a/telemeta/util/logger.py
+++ b/telemeta/util/logger.py
@@ -1,13 +1,23 @@
 
+import logging
+
 class Logger:
-    "Provide simple message logging"
+    """A logging object"""
+
+    def __init__(self, file):
+        self.logger = logging.getLogger('myapp')
+        self.hdlr = logging.FileHandler(file)
+        self.formatter = logging.Formatter('%(asctime)s %(levelname)s %(message)s')
+        self.hdlr.setFormatter(self.formatter)
+        self.logger.addHandler(self.hdlr)
+        self.logger.setLevel(logging.INFO)
 
-    filename="/tmp/telemeta.log"
+    def write_info(self, message):
+        self.logger.info(message)
 
-    def __init__(self):
-        self.file = open(self.filename, "a")
+    def write_error(self, message):
+        self.logger.error(message)
 
     def debug(self, msg):
-        self.file.write(msg + "\n")
-        self.file.flush()
+        self.logger.error(message)
         
diff --git a/telemeta/web/__init__.py b/telemeta/web/__init__.py
index 6857d986..9c3afc8a 100644
--- a/telemeta/web/__init__.py
+++ b/telemeta/web/__init__.py
@@ -1,2 +1,3 @@
-from telemeta.web.base import WebView
-import pages
+#import telemeta.web.base
+#import telemeta.web.pages
+
diff --git a/telemeta/web/base.py b/telemeta/web/base.py
index b21b4756..ddfdc756 100644
--- a/telemeta/web/base.py
+++ b/telemeta/web/base.py
@@ -54,15 +54,16 @@ import telemeta.interop.oai as oai
 from telemeta.interop.oaidatasource import TelemetaOAIDataSource
 from django.core.exceptions import ObjectDoesNotExist
 from telemeta.util.unaccent import unaccent
-from telemeta.web import pages
 from telemeta.util.unaccent import unaccent_icmp
+from telemeta.util.logger import Logger
+import telemeta.web.pages as pages
 
 def render(request, template, data = None, mimetype = None):
     return render_to_response(template, data, context_instance=RequestContext(request), 
                               mimetype=mimetype)
 
-def stream(file):
-    chunk_size = 0x10000
+def stream_from_file(file):
+    chunk_size = 0x1000
     f = open(file,  'r')
     while True:
         _chunk = f.read(chunk_size)
@@ -71,14 +72,23 @@ def stream(file):
         yield _chunk
     f.close()
 
+def stream_from_processor(decoder, processor):
+    while True:
+        frames,  eod = decoder.process()
+        buffer,  eod_proc = processor.process(frames, eod)
+        yield buffer
+        if eod_proc:
+            break
+
 
 class WebView:
     """Provide web UI methods"""
 
-    graphers = timeside.processors(timeside.api.IGrapher)
-    decoders = timeside.processors(timeside.api.IDecoder)
-    encoders= timeside.processors(timeside.api.IEncoder)
-    analyzers = timeside.processors(timeside.api.IAnalyzer)
+    graphers = timeside.core.processors(timeside.api.IGrapher)
+    decoders = timeside.core.processors(timeside.api.IDecoder)
+    encoders= timeside.core.processors(timeside.api.IEncoder)
+    analyzers = timeside.core.processors(timeside.api.IAnalyzer)
+    logger = Logger('/tmp/telemeta.log')
     
     def index(self, request):
         """Render the homepage"""
@@ -152,6 +162,7 @@ class WebView:
                     })
 
     def item_visualize(self, request, public_id, visualizer_id, width, height):
+        mime_type = 'image/png'
         grapher_id = visualizer_id
         for grapher in self.graphers:
             if grapher.id() == grapher_id:
@@ -159,19 +170,22 @@ class WebView:
 
         if grapher.id() != grapher_id:
             raise Http404
-
+        
         media = settings.TELEMETA_DATA_CACHE_DIR + \
                     os.sep + '_'.join([public_id,  grapher_id,  width,  height]) + '.png'
+
         #graph.set_colors((255,255,255), 'purple')
         
         if not os.path.exists(media):
             item = MediaItem.objects.get(public_id=public_id)
             audio = os.path.join(os.path.dirname(__file__), item.file.path)
             decoder  = timeside.decoder.FileDecoder(audio)
-            graph = grapher(width=int(width), height=int(height), output=media)
-            (decoder | graph).run()
-            graph.render()
-        response = HttpResponse(stream(media), mimetype = 'image/png')
+            graph = grapher(width=int(width), height=int(height))
+            pipe = decoder | graph
+            pipe.run()
+            graph.render(media)
+
+        response = HttpResponse(stream_from_file(media), mimetype = mime_type)
         return response
 
     def list_export_extensions(self):
@@ -204,17 +218,19 @@ class WebView:
         print decoder.format(),  mime_type
         if decoder.format() == mime_type:
             # source > stream
-            media = audio
+            response = HttpResponse(stream_from_file(audio), mimetype = mime_type)
         else:        
             if not os.path.exists(media):
                 # source > encoder > stream
-                decoder  = timeside.decoder.FileDecoder(audio)
-                enc = encoder(media)
-                metadata = dublincore.express_item(item).to_list()
+                decoder.setup()
+                proc = encoder(media)
+                proc.setup(decoder.channels(), decoder.samplerate())
+                #metadata = dublincore.express_item(item).to_list()
                 #enc.set_metadata(metadata)
-                (decoder | enc).run()
-            
-        response = HttpResponse(stream(media), mimetype = mime_type)
+                response = HttpResponse(stream_from_processor(decoder, proc), mimetype = mime_type)
+            else:
+                response = HttpResponse(stream_from_file(media), mimetype = mime_type)
+        
         response['Content-Disposition'] = 'attachment'
         return response