Changeset 29e319b

Timestamp:

06/07/11 12:39:08 (2 years ago)

Author:

yomguy <yomguy@…>

Branches:

master, crem, crem2, dev, dev2, diadems, forma, generic, instru_search, lam, nlivemulti, production, release/1.4.4, security, social, storage, test, video

Children:

6950984, bc4fa89

Parents:

fac4a3b

git-author:

yomguy <yomguy@…> (06/07/11 12:39:08)

git-committer:

yomguy <yomguy@…> (06/07/11 12:39:08)

Message:

Analyzers are now managed though the DB. Please syncdb before continue.

Location:

telemeta

Files:

• cache.py (modified) (2 diffs)
• models/media.py (modified) (1 diff)
• web/base.py (modified) (6 diffs)

telemeta/cache.py

@@ -106 +106 @@
     def write_analyzer_xml(self, data_list, file):
         path = self.dir + os.sep + file
+        data = self.get_analyzer_xml(data_list)
+        f = open(path, "w")
+        f.write(data)
+        f.close()
+
+    def get_analyzer_xml(self, data_list):
         doc = xml.dom.minidom.Document()
         root = doc.createElement('telemeta')
@@ -120 +126 @@
             node.setAttribute('value', str(value))
             root.appendChild(node)
-        f = open(path, "w")
-        f.write(xml.dom.minidom.Document.toprettyxml(doc))
-        f.close()
+        return xml.dom.minidom.Document.toprettyxml(doc)

telemeta/models/media.py

@@ -370 +370 @@
     item  = ForeignKey('MediaItem', related_name="analysis", verbose_name=_('item'))
     analyzer_id = CharField(_('id'), required=True)
-    analyzer_name = CharField(_('name'))
-    analyzer_value = CharField(_('value'))
-    analyzer_unit = CharField(_('unit'))
+    name = CharField(_('name'))
+    value = CharField(_('value'))
+    unit = CharField(_('unit'))
     
     class Meta(MetaCore):
         db_table = 'media_analysis'
+        ordering = ['name']
+        
+    def to_dict(self):
+        return {'id': self.analyzer_id, 'name': self.name, 'value': self.value, 'unit': self.unit}
         
         

telemeta/web/base.py

@@ -271 +271 @@
         
         previous, next = self.item_previous_next(item)
-        analyzers = self.item_analyze(item)
+        self.item_analyze(item)
         playlists = self.get_playlists(request)
         public_access = self.get_public_access(item.public_access, item.recorded_from_date, item.recorded_to_date)
@@ -277 +277 @@
         return render(request, template,
                     {'item': item, 'export_formats': formats,
-                    'visualizers': graphers, 'visualizer_id': grapher_id,'analysers': analyzers,
+                    'visualizers': graphers, 'visualizer_id': grapher_id,
                     'audio_export_enabled': getattr(settings, 'TELEMETA_DOWNLOAD_ENABLED', True),
                     'previous' : previous, 'next' : next, 'marker': marker_id, 'playlists' : playlists, 
@@ -322 +322 @@
         
         previous, next = self.item_previous_next(item)
-        analyzers = self.item_analyze(item)
+        self.item_analyze(item)
         
         if request.method == 'POST':
@@ -392 +392 @@
         
     def item_analyze(self, item):
-        public_id = str(item.public_id)
-        analyze_file = public_id + '.xml'
-        
-        if self.cache_data.exists(analyze_file):
-            analyzers = self.cache_data.read_analyzer_xml(analyze_file)
+        analyses = MediaItemAnalysis.objects.filter(item=item)
+        
+        if analyses:
             if not item.approx_duration:
-                for analyzer in analyzers:
-                    if analyzer['id'] == 'duration':
-                        value = analyzer['value']
+                for analysis in analyses:
+                    if analysis.id == 'duration':
+                        value = analysis.value
                         time = value.split(':')
                         time[2] = time[2].split('.')[0]
@@ -419 +417 @@
 
                 mime_type = decoder.format()
-                analyzers.append({'name': 'Mime type', 'id': 'mime_type', 'unit': '', 'value': mime_type})
-                analyzers.append({'name': 'Channels', 'id': 'channels', 'unit': '', 'value': decoder.channels()})
+                analysis = MediaItemAnalysis(item=item, name='MimeType', analyzer_id='mime_type', unit='', value=mime_type)
+                analysis.save()
+                analysis = MediaItemAnalysis(item=item, name='Channels', analyzer_id='channels', unit='', value=decoder.channels())
+                analysis.save()
                 
                 for analyzer in analyzers_sub:
@@ -433 +433 @@
                         value = datetime.timedelta(0,value)
                     
-                    analyzers.append({'name':analyzer.name(),
-                                      'id':analyzer.id(),
-                                      'unit':analyzer.unit(),
-                                      'value':str(value)})
-                  
-                self.cache_data.write_analyzer_xml(analyzers, analyze_file)
-            
-        return analyzers
-    
+                    analysis = MediaItemAnalysis(item=item, name=analyzer.name(), analyzer_id=analyzer.id(), 
+                                                 unit=analyzer.unit(), value=str(value))
+                    analysis.save()
+        
     def item_analyze_xml(self, request, public_id):
         item = MediaItem.objects.get(public_id=public_id)
-        analyze_file = public_id + '.xml'
-        if not self.cache_data.exists(analyze_file):
-            self.item_analyze(item)
+        analyses = MediaItemAnalysis.objects.filter(item=item)
+        analyzers = []
+        for analysis in analyses:
+            analyzers.append(analysis.to_dict())
         mime_type = 'text/xml'
-        response = HttpResponse(self.cache_data.read_stream_bin(analyze_file), mimetype=mime_type)
+        response = HttpResponse(self.cache_data.get_analyzer_xml(analyzers), mimetype=mime_type)
         response['Content-Disposition'] = 'attachment; filename='+public_id+'.xml'        
         return response